用水发送一件事数据至IRS新增nacos配置开关

zfjg-modules/zfjg-manage/src/main/java/com/zfjg/manage/sync/remote/DefaultLjZfjgSyncDataService.java

@@ -51,7 +51,6 @@ import org.springframework.web.client.RestTemplate;
 import javax.annotation.Resource;
 import java.io.Serializable;
 import java.util.*;
-import java.util.function.Function;
 import java.util.stream.Collectors;
 
 @Slf4j
@@ -67,6 +66,8 @@ public class DefaultLjZfjgSyncDataService implements ILjZfjgSyncDataService {
     private Boolean enabled;
     @Value("${data.sync.fireRoomEnable}")
     private Boolean fireRoomEnable;
+    @Value("${data.sync.useWaterEnable}")
+    private Boolean useWaterEnable;
     @Resource
     private CommMapper commMapper;
     private final RestTemplate restTemplate;
@@ -410,6 +411,9 @@ public class DefaultLjZfjgSyncDataService implements ILjZfjgSyncDataService {
     }
 
     public void updateUseWater() {
+        if (!useWaterEnable) {
+            return;
+        }
         List<EnforceJobFireRoomDTO> enforceJobFireRoomDTOS = enforceObjServiceExtend.enforceJobUseWaterList();
         if (enforceJobFireRoomDTOS.isEmpty()) {
             log.error("未找到不合格的消防给水设施");

zfjg-modules/zfjg-manage/src/main/java/com/zfjg/manage/task/job/EnforceJobTask.java

@@ -112,6 +112,14 @@ public class EnforceJobTask {
         }
     }
 
+
+    @Scheduled(cron = "0 20 0 * * ?")
+    public void updateUseWater() {
+        log.info("每日用水一件事儿");
+        ljZfjgSyncDataService.updateUseWater();
+    }
+
+
     @Scheduled(cron = "0 20 0 * * ?")
     public void updateFireRoom() {
         log.info("每日执行消控室一件事儿");