配置修改

meter-reading-sishui/read-sqlSever/src/main/java/com/zcxk/service/SyncService.java

@@ -43,8 +43,8 @@ public class SyncService {
     @Autowired
     private SyncMeterDataJob syncMeterDataJob;
 
-    //@Scheduled(cron = "0 0 * * * ?")
-    public void countPlanDevice(){
+    //@Scheduled(cron = "10 0 0 * * ?")
+    /*public void countPlanDevice(){
 
         WaterMeterBaseEntity waterMeterBaseEntity=new WaterMeterBaseEntity();
 
@@ -64,13 +64,15 @@ public class SyncService {
 
 
 
-    }
+    }*/
+    @Scheduled(cron = "10 0 0 * * ?")
     public void uploadRelationId(){
         WaterMeterBaseEntity waterMeterBaseEntity=new WaterMeterBaseEntity();
 
-        log.info("获取泗水水表列表");
+
         List<Map<String, Object>> meterInfor = receiveDao.getMeterInfor(waterMeterBaseEntity);
         Sets.SetView<String> meterNoIntersection = needSyncMeterNo(meterInfor);
+        log.info("获取泗水水表列表,数量={}",meterInfor.size());
         meterInfor.forEach(meter->{
             String meterNo = (String) meter.get("meterNo");
             if(meterNoIntersection.contains(meterNo)){
@@ -185,19 +187,20 @@ public class SyncService {
         Sets.SetView<String> difference = Sets.difference(allDeviceNos, hasDeviceNos);
         return difference;
     }
-    //@Scheduled(cron = "* 0/30 * * * ?")
+    @Scheduled(cron = "* 0/30 * * * ?")
     public void uploadData(){
         Map<String,Object>args2=new HashMap<>();
+        log.info("获取泗水上传计划");
         List<Map<String, Object>> uploadPlan = receiveDao.getUploadPlan(args2);
         uploadPlan.forEach(map->{
             String planId=(String) map.get("PlanId");
-            log.info("获取泗水上传计划");
+
             //syncMeterDataJob.sendTask(map);
             if(!quartzManager.checkExists(planId)){
-
-                quartzManager.addJob(planId, SyncMeterDataJob.class,setCron((Date) map.get("UploadTime")),map);
+                Date date=(Date) map.get("UploadTime");
+                quartzManager.addJob(planId, SyncMeterDataJob.class,setCron(date),map);
                 //quartzManager.addJob(planId, SyncMeterDataJob.class,"15 41 15 * * ?", map);
-                log.info("设置泗水上传计划定时任务");
+                log.info("设置泗水上传计划定时任务={}",date.toString());
             }
 
         });

meter-reading-sishui/read-sqlSever/src/main/resources/application-dev.properties

@@ -1,4 +1,4 @@
-server.port=9080
+server.port=9085
 spring.application.name=sishui-meter-reading
 logging.file.path=./logs/sishui-meter-reading
 logging.level.root=info

meter-reading-sishui/read-sqlSever/src/main/resources/application-prd.properties

@@ -16,7 +16,7 @@ mybatis.configuration.map-underscore-to-camel-case=true
 mybatis.configuration.log-impl=org.apache.ibatis.logging.stdout.StdOutImpl
 mybatis.configuration.use-column-label=true
 
-customerId=137
+customerId=76
 siteId=1
 sysId=58
 buildingId=1

meter-reading-sishui/read-sqlSever/src/main/resources/application.properties

@@ -1 +1 @@
-spring.profiles.active=prd
+spring.profiles.active=dev

meter-reading-sishui/read-sqlSever/src/main/resources/logback-spring.xml

@@ -1,6 +1,6 @@
 <?xml version="1.0" encoding="UTF-8"?>
 <configuration>
-    <springProperty scope="context" name="LOG_PATH" source="logging.path" defaultValue="/tmp" />
+    <springProperty scope="context" name="LOG_PATH" source="logging.file.path" defaultValue="D:/db/泗水/logs" />
     <include resource="org/springframework/boot/logging/logback/defaults.xml" />
     <include resource="org/springframework/boot/logging/logback/console-appender.xml" />
     <appender name="TIME_FILE"

meter-reading-sishui/read-sqlSever/src/main/resources/mysql-mapper/SendDao.xml

@@ -128,7 +128,7 @@
     </insert>
     <update id="updateRelationId">
         update sc_device set relation_id=#{relationId} where
-        relation_id is null and water_meter_no=#{waterMeterNo} and customer_id=#{customerId}
+        relation_id is null and water_meter_no=#{waterMeterNo} and customer_id=#{customerId} and status=1
     </update>
     <select id="getBuilding" resultType="com.zcxk.entity.Building">
         select
@@ -147,7 +147,7 @@
         where sb.status = 1 and sb.id = #{buildingId}
     </select>
     <select id="selectDeviceMeterReader" resultType="com.zcxk.entity.MeterReadRecord">
-      select device_no, read_time ,read_data
+      select device_no, read_time ,read_data,customer_id
       from sc_meter_read_record where customer_id=#{customerId}
       and read_date=#{readDate}
     </select>
@@ -159,13 +159,15 @@
     </select>
     <select id="selectRelationIdsByDeviceNo" resultType="java.util.Map">
         select device_no deviceNo ,relation_id relationId from sc_device
-        where
-        <foreach collection="list" item="item" index="index" separator=",">
-            device_no=#{item.deviceNo}
+        where device_no in
+       <foreach collection="list" item="item" open="(" separator="," close=")">
+            #{item.deviceNo}
         </foreach>
+        and relation_id is not null
     </select>
     <select id="selectMeterNo" resultType="java.lang.String">
           select water_meter_no from sc_device where customer_id=#{customerId} and   relation_id is null
+          and status=1
     </select>