fix 风险数据全量推送

README.md

@@ -129,7 +129,7 @@ http://198.17.188.2:83/index.html?code=BTLQ+ClrznbhOHCub6CGUcY62Y+uR1dbJR9PTNL7R
 
 > 服务器启动
 
-- cd C:\cbwq\nginx-1.22.0
+- cd C:\cbwq\nginx-1.23.3
 - start nginx
 - cd C:\Program Files\Redis
 - redis-server.exe redis.windows.conf

pom.xml

@@ -27,7 +27,7 @@
         <oshi.version>5.7.5</oshi.version>
         <jna.version>5.8.0</jna.version>
         <commons.io.version>2.10.0</commons.io.version>
-        <commons.fileupload.version>1.4</commons.fileupload.version>
+        <commons.fileupload.version>1.5</commons.fileupload.version>
         <commons.collections.version>3.2.2</commons.collections.version>
         <poi.version>4.1.2</poi.version>
         <velocity.version>1.7</velocity.version>

ruoyi-admin/src/main/java/com/ruoyi/web/job/CanalScheduling.java

@@ -486,14 +486,15 @@ public class CanalScheduling implements Runnable, ApplicationContextAware {
             illegalShipData.setSystemId(Convert.toStr(afterDataMap.get("id")));
             illegalShipData.setSystemEsIndex(indexName);
             // 查询此船是否已上报过，如果是，则不需要再上报.根据mmsi和uploadFlag=1,illegalStatus=2
-            IllegalShipData existBean = new IllegalShipData();
+            /*IllegalShipData existBean = new IllegalShipData();
             existBean.setMmsi(illegalShipData.getMmsi());
             existBean.setIllegalStatus(2);
+            existBean.setSystemEsIndex(indexName);
             existBean.setUploadFlag(1);
             List<IllegalShipData> exist = illegalShipDataService.selectIllegalShipDataList(existBean);
             if (exist != null && exist.size() > 0) {
                 illegalShipData.setIllegalStatus(4);
-            }
+            }*/
             try {
                 illegalShipDataService.insertIllegalShipData(illegalShipData);
                 // 发送短信给海事人员(常熟海事局)
@@ -511,7 +512,7 @@ public class CanalScheduling implements Runnable, ApplicationContextAware {
                             "船名：", illegalShipData.getShipName(), "。", detail);
                     SMSUtil smsUtil = new SMSUtil();
                     for (String phone : csPhone.split(",")) {
-                        smsUtil.sendMessage(content, phone);
+//                        smsUtil.sendMessage(content, phone);
                     }
                 }
             } catch (Exception ignored) {