diff --git a/src/main/java/com/njcn/jbsyncdata/controller/DisPhotovoltaicController.java b/src/main/java/com/njcn/jbsyncdata/controller/DisPhotovoltaicController.java index 3dacdcb..bca250f 100644 --- a/src/main/java/com/njcn/jbsyncdata/controller/DisPhotovoltaicController.java +++ b/src/main/java/com/njcn/jbsyncdata/controller/DisPhotovoltaicController.java @@ -246,7 +246,7 @@ public class DisPhotovoltaicController { } return "数据导入失败"; } - @Scheduled(cron = "0 10 0 * * ?") + @Scheduled(cron = "0 30 0 * * ?") public void insert() { log.error(Thread.currentThread().getName(),"1.定时器启动----!"); DateTime dateTime = DateUtil.offsetDay(new Date(), -1); @@ -259,7 +259,7 @@ public class DisPhotovoltaicController { log.error(Thread.currentThread().getName() + "2.定时器执行数据成功 "+ds+"----!"); } - @Scheduled(cron = "0 10 2 * * ?") + @Scheduled(cron = "0 0 3 * * ?") public void insertPms() { log.error(Thread.currentThread().getName(),"1.定时器启动----!"); DateTime dateTime = DateUtil.offsetDay(new Date(), -1); diff --git a/src/main/java/com/njcn/jbsyncdata/util/AreaInterfaceDataProcessing.java b/src/main/java/com/njcn/jbsyncdata/util/AreaInterfaceDataProcessing.java index 0282474..4712008 100644 --- a/src/main/java/com/njcn/jbsyncdata/util/AreaInterfaceDataProcessing.java +++ b/src/main/java/com/njcn/jbsyncdata/util/AreaInterfaceDataProcessing.java @@ -263,10 +263,10 @@ public class AreaInterfaceDataProcessing { //log.error("数据批量入库异常,异常为:{}", exception.toString()); exception.printStackTrace(); } - log.error("已经入库{}条记录!", count * 20000); + log.info("Pms遥测数据--已经入库{}条记录!", count * 20000); count++; } - log.error("当前批次所有数据,{}条均已入库!", sqlList.size()); + log.info("Pms遥测数据--当前批次所有数据,{}条均已入库!", sqlList.size()); } }