From b86cae2a0a22f1e296e8c4cf717892a4ea1bef96 Mon Sep 17 00:00:00 2001
From: wr <1754607820@qq.com>
Date: Tue, 2 Jul 2024 08:49:06 +0800
Subject: [PATCH] =?UTF-8?q?1.=E5=88=86=E5=B8=83=E5=BC=8F=E5=85=89=E4=BC=8F?=
 =?UTF-8?q?=E9=81=A5=E6=B5=8B=E6=95=B0=E6=8D=AE=E6=8E=A5=E5=8F=A3=E6=96=B0?=
 =?UTF-8?q?=E5=A2=9E?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../njcn/jbsyncdata/controller/DisPhotovoltaicController.java | 4 ++--
 .../com/njcn/jbsyncdata/util/AreaInterfaceDataProcessing.java | 4 ++--
 2 files changed, 4 insertions(+), 4 deletions(-)

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());
 
     }
 }