修改重点接口，新增一人同诉，多人多诉接口

ruoyi-admin/src/main/java/com/ruoyi/pt/quartz/PushQuartz.java

@@ -67,13 +67,19 @@ public class PushQuartz {
         remoteCallsService.urgentAlgorithm(localTimeStr);
         // 重点人员接口
         log.info("==============推送重点人员接口" + LocalDateTime.now() + "============");
-        remoteCallsService.keypersonAlgorithm(localTimeStr);
+        remoteCallsService.keypersonAlgorithm();
         // 群体事件接口
         log.info("==============推送群体事件接口" + LocalDateTime.now() + "============");
         remoteCallsService.groupAlgorithm();
         // 同人事件接口
         log.info("==============推送同人事件接口" + LocalDateTime.now() + "============");
         remoteCallsService.onepersonAlgorithm();
+        // 同人同诉接口
+        log.info("==============推送同人同诉接口" + LocalDateTime.now() + "============");
+        remoteCallsService.samepersonComplaint();
+        // 一人多诉接口
+        log.info("==============推送一人多诉接口" + LocalDateTime.now() + "============");
+        remoteCallsService.onepersonSues();
         // 推送
         log.info("==============推送到预警平台接口" + LocalDateTime.now() + "============");
         int num = remoteCallsService.imports(1);

ruoyi-admin/src/main/java/com/ruoyi/pt/service/RemoteCallsService.java

@@ -25,6 +25,7 @@ public interface RemoteCallsService {
 
     /**
      * 获取社会治理中心增量事件保存到events_import表
+     *
      * @return 数据条数
      */
     int getEventDate();
@@ -38,10 +39,8 @@ public interface RemoteCallsService {
 
     /**
      * 重点人员接口
-     *
-     * @param yesterdayStr 昨天日期字符串 yyyy-MM-dd
      */
-    void keypersonAlgorithm(String yesterdayStr);
+    void keypersonAlgorithm();
 
     /**
      * 群体事件接口
@@ -75,4 +74,14 @@ public interface RemoteCallsService {
      * @param innerEventId 事件id
      */
     void pushByInnerEventId(String innerEventId);
+
+    /**
+     * 同人同诉接口
+     */
+    void samepersonComplaint();
+
+    /**
+     * 一人多诉接口
+     */
+    void onepersonSues();
 }

ruoyi-admin/src/main/java/com/ruoyi/pt/service/impl/RemoteCallsServiceImpl.java

@@ -208,16 +208,15 @@ public class RemoteCallsServiceImpl implements RemoteCallsService {
 
     /**
      * 重点人员接口
-     *
-     * @param yesterdayStr 昨天日期字符串 yyyy-MM-dd
      */
     @Override
-    public void keypersonAlgorithm(String yesterdayStr) {
+    public void keypersonAlgorithm() {
         Map<String, Object> body = new HashMap<>();
-        body.put("data", yesterdayStr);
+        //data写死成3
+        body.put("data", 3);
         String bodyStr = JSONUtil.toJsonStr(body);
         HttpRequest.post("http://localhost:9003/keyperson_algorithm").body(bodyStr).execute().body();
-        log.info(yesterdayStr);
+
     }
 
     /**
@@ -320,6 +319,22 @@ public class RemoteCallsServiceImpl implements RemoteCallsService {
         HttpRequest.post(url + "/gateway/event/event/eventData/imports").header("Authorization", "Bearer " + accessToken).body(jsonStr).execute().body();
     }
 
+    @Override
+    public void samepersonComplaint() {
+        Map<String, Object> body = new HashMap<>();
+        body.put("data", 7);
+        String bodyStr = JSONUtil.toJsonStr(body);
+        HttpRequest.post("http://localhost:9003/oneperson_algorithm").body(bodyStr).execute().body();
+    }
+
+    @Override
+    public void onepersonSues() {
+        Map<String, Object> body = new HashMap<>();
+        body.put("data", 7);
+        String bodyStr = JSONUtil.toJsonStr(body);
+        HttpRequest.post("http://localhost:9003/oneperson_muti_algorithm").body(bodyStr).execute().body();
+    }
+
     /**
      * 获取社会治理中心增量事件保存到events_import表
      *