执法仪推送数据到事件 更改执法中心

src/main/java/com/sooka/sponest/dataexchange/remoteapi/fallback/center/lawenforcement/RemoteLawenforcementBaseServiceFallbackFactory.java

@@ -0,0 +1,35 @@
+package com.sooka.sponest.dataexchange.remoteapi.fallback.center.lawenforcement;
+
+
+import com.alibaba.fastjson.JSONArray;
+import com.ruoyi.common.core.domain.R;
+import com.sooka.sponest.dataexchange.exchange.domian.DataExchangeEntity;
+import com.sooka.sponest.dataexchange.remoteapi.service.center.data.RemoteDataBaseService;
+import com.sooka.sponest.dataexchange.remoteapi.service.center.event.RemoteEventBaseService;
+import com.sooka.sponest.dataexchange.remoteapi.service.center.lawenforcement.RemoteLawenforcementBaseService;
+import com.sooka.sponest.dataexchange.sendChange.domian.CenterdataTKeyProjects;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.cloud.openfeign.FallbackFactory;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+
+@Component
+public class RemoteLawenforcementBaseServiceFallbackFactory implements FallbackFactory<RemoteLawenforcementBaseService> {
+    private static final Logger log = LoggerFactory.getLogger(RemoteLawenforcementBaseServiceFallbackFactory.class);
+
+    @Override
+    public RemoteLawenforcementBaseService create(Throwable cause) {
+        log.error("执法中心-服务调用失败:{}", cause.getMessage());
+
+        return new RemoteLawenforcementBaseService() {
+
+            @Override
+            public R<?> insertEnforceLawInfoByList(JSONArray jsonArray) {
+                return null;
+            }
+        };
+    }
+}

src/main/java/com/sooka/sponest/dataexchange/remoteapi/service/ModulesServiceNameContants.java

@@ -9,6 +9,8 @@ public class ModulesServiceNameContants extends ServiceNameConstants {
 
    //数据中心
    public static final String CENTER_DATA = "sooka-sponest-center-data";
+    //执法中心
+   public static final String CENTER_LAWEN = "sooka-sponest-lawenforcement";
 
    //测评中心
    public static final String CENTER_EVALUATION = "sooka-sponest-center-evaluation";

src/main/java/com/sooka/sponest/dataexchange/remoteapi/service/center/lawenforcement/RemoteLawenforcementBaseService.java

@@ -0,0 +1,32 @@
+package com.sooka.sponest.dataexchange.remoteapi.service.center.lawenforcement;
+
+
+import com.alibaba.fastjson.JSONArray;
+import com.ruoyi.common.core.domain.R;
+import com.sooka.sponest.dataexchange.remoteapi.fallback.center.data.RemoteDataBaseServiceFallbackFactory;
+import com.sooka.sponest.dataexchange.remoteapi.fallback.center.lawenforcement.RemoteLawenforcementBaseServiceFallbackFactory;
+import com.sooka.sponest.dataexchange.remoteapi.service.ModulesServiceNameContants;
+import com.sooka.sponest.dataexchange.sendChange.domian.CenterdataTKeyProjects;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.PostMapping;
+
+import java.util.List;
+
+
+@FeignClient(
+        contextId = "RemoteLawenforcementBaseService",
+        value = ModulesServiceNameContants.CENTER_LAWEN,
+        fallbackFactory = RemoteLawenforcementBaseServiceFallbackFactory.class
+)
+public interface RemoteLawenforcementBaseService {
+
+    /**
+     * 执法仪
+     * @param
+     * @return
+     */
+
+    @PostMapping("/record/insertEnforceLawInfoByList")
+    public R<?> insertEnforceLawInfoByList(JSONArray jsonArray);
+
+}

src/main/java/com/sooka/sponest/dataexchange/sendChange/quartz/EquipDataJob.java

@@ -5,6 +5,7 @@ import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
 import com.ruoyi.common.core.domain.R;
 import com.sooka.sponest.dataexchange.remoteapi.service.center.data.RemoteDataBaseService;
+import com.sooka.sponest.dataexchange.remoteapi.service.center.lawenforcement.RemoteLawenforcementBaseService;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.scheduling.annotation.Scheduled;
@@ -28,7 +29,7 @@ import java.util.Date;
 public class EquipDataJob {
 
     @Resource
-    private RemoteDataBaseService remoteDataBaseService;
+    private RemoteLawenforcementBaseService remoteLawenforcementBaseService;
 
     @Value("${equioData.accessKey}")
     private String accessKey;
@@ -37,6 +38,7 @@ public class EquipDataJob {
     private String ip;
 
     @Scheduled(cron = "0 0/10 * * * ?")
+//@Scheduled(cron = "0/10 * * * * ?")
     public void getEquipJobRecords() throws Exception {
         SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
         Date now = new Date();
@@ -51,7 +53,7 @@ public class EquipDataJob {
         Integer page = 1;
         for (int i = 1; i <= page; i++) {
             String urlString = ip + "/dev-api/outData/getJobRecords?page=" + page + "&size=10&updateStartTime=" + startTime + "&updateEndTime=" + endTime;
-//            String urlString = "http://36.135.7.83:81/dev-api/outData/getJobRecords?page=1&size=10&updateStartTime=2024-05-20%2010:50:33&updateEndTime=2024-11-20%2010:50:33";
+//            String urlString = "http://36.135.7.83:81/dev-api/outData/getJobRecords?page=" + page + "&size=5&updateStartTime=2024-05-20%2010:50:33&updateEndTime=2024-11-20%2010:50:33";
             try {
                 URL url = new URL(urlString);
                 HttpURLConnection connection = (HttpURLConnection) url.openConnection();
@@ -69,7 +71,7 @@ public class EquipDataJob {
                     JSONObject jsonObject = JSONObject.parseObject(response.toString());
                     page = (Integer) JSONObject.parseObject(jsonObject.get("data").toString()).get("pages");
                     JSONArray jsonArray = JSONObject.parseArray(JSONObject.parseObject(jsonObject.get("data").toString()).get("records").toString());
-                    R<?> result = remoteDataBaseService.insertEnforceLawInfoByList(jsonArray);
+                    R<?> result = remoteLawenforcementBaseService.insertEnforceLawInfoByList(jsonArray);
                     if (result.getCode() == 200) {
                         log.info("推送成功");
                     } else {