Quellcode durchsuchen

解决druid与LocalDateTime兼容性

zhoujiangyuan vor 4 Jahren
Ursprung
Commit
7a1a3503ba

+ 1 - 1
gydatasync/pom.xml

@@ -52,7 +52,7 @@
         <dependency>
             <groupId>com.alibaba</groupId>
             <artifactId>druid-spring-boot-starter</artifactId>
-            <version>1.1.9</version>
+            <version>1.1.23</version>
         </dependency>
 
 

+ 8 - 9
gydatasync/src/main/java/com/huaxu/gydatasync/service/ReadMeter.java

@@ -3,6 +3,8 @@ package com.huaxu.gydatasync.service;
 import com.huaxu.gydatasync.dao.mssql.SaveMeterDataDao;
 import com.huaxu.gydatasync.dao.mysql.ReadMeterDao;
 import com.huaxu.gydatasync.entity.MeterReadData;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
@@ -18,6 +20,8 @@ import java.util.List;
 @Component
 public class ReadMeter {
 
+    private Logger logger = LoggerFactory.getLogger(ReadMeter.class);
+
     @Autowired
     private ReadMeterDao readMeterDao;
 
@@ -26,16 +30,10 @@ public class ReadMeter {
 
     //定时任务 每天凌晨3点将前一天抄到数据的表同步
     @Scheduled(cron = "0 0 3 * * ?")
+    //@Scheduled(fixedDelay = 1000*60*60)
     public void configureTasks(){
         try {
-
-            int isExist = saveMeterDataDao.IsExist();
-            if(isExist > 0)
-            {
-
-                System.out.println("当天数据已存在!-----");
-                return;
-            }
+            logger.info("开始同步桂阳数据...");
 
 
             //读取前一天的抄表数据
@@ -58,10 +56,11 @@ public class ReadMeter {
                     saveMeterDataDao.SaveData(subDataList);
                 }
             }
+            logger.info("同步桂阳数据结束...");
         }
         catch (Exception ex)
         {
-
+            logger.error(ex.getMessage());
         }
 
     }

+ 1 - 0
gydatasync/src/main/resources/mappers/mysql/ReadMeterMapper.xml

@@ -16,5 +16,6 @@
     WHERE
         a.read_date = DATE_FORMAT( DATE_SUB( now(), INTERVAL 1 DAY ), '%Y%m%d' ) AND a.read_data is not null
         AND a.device_id IN ( SELECT id FROM sc_device WHERE customer_id = (SELECT id FROM sc_customer WHERE customer_name='桂阳自来水有限公司') AND STATUS = 1 )
+
     </select>
 </mapper>