1.分布式光伏遥测数据接口新增
This commit is contained in:
@@ -246,7 +246,7 @@ public class DisPhotovoltaicController {
|
|||||||
}
|
}
|
||||||
return "数据导入失败";
|
return "数据导入失败";
|
||||||
}
|
}
|
||||||
@Scheduled(cron = "0 10 0 * * ?")
|
@Scheduled(cron = "0 30 0 * * ?")
|
||||||
public void insert() {
|
public void insert() {
|
||||||
log.error(Thread.currentThread().getName(),"1.定时器启动----!");
|
log.error(Thread.currentThread().getName(),"1.定时器启动----!");
|
||||||
DateTime dateTime = DateUtil.offsetDay(new Date(), -1);
|
DateTime dateTime = DateUtil.offsetDay(new Date(), -1);
|
||||||
@@ -259,7 +259,7 @@ public class DisPhotovoltaicController {
|
|||||||
log.error(Thread.currentThread().getName() + "2.定时器执行数据成功 "+ds+"----!");
|
log.error(Thread.currentThread().getName() + "2.定时器执行数据成功 "+ds+"----!");
|
||||||
}
|
}
|
||||||
|
|
||||||
@Scheduled(cron = "0 10 2 * * ?")
|
@Scheduled(cron = "0 0 3 * * ?")
|
||||||
public void insertPms() {
|
public void insertPms() {
|
||||||
log.error(Thread.currentThread().getName(),"1.定时器启动----!");
|
log.error(Thread.currentThread().getName(),"1.定时器启动----!");
|
||||||
DateTime dateTime = DateUtil.offsetDay(new Date(), -1);
|
DateTime dateTime = DateUtil.offsetDay(new Date(), -1);
|
||||||
|
|||||||
@@ -263,10 +263,10 @@ public class AreaInterfaceDataProcessing {
|
|||||||
//log.error("数据批量入库异常,异常为:{}", exception.toString());
|
//log.error("数据批量入库异常,异常为:{}", exception.toString());
|
||||||
exception.printStackTrace();
|
exception.printStackTrace();
|
||||||
}
|
}
|
||||||
log.error("已经入库{}条记录!", count * 20000);
|
log.info("Pms遥测数据--已经入库{}条记录!", count * 20000);
|
||||||
count++;
|
count++;
|
||||||
}
|
}
|
||||||
log.error("当前批次所有数据,{}条均已入库!", sqlList.size());
|
log.info("Pms遥测数据--当前批次所有数据,{}条均已入库!", sqlList.size());
|
||||||
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user