diff --git a/ruoyi-admin/src/main/java/com/ruoyi/pt/quartz/PushQuartz.java b/ruoyi-admin/src/main/java/com/ruoyi/pt/quartz/PushQuartz.java index 35e7f69..ad5376f 100644 --- a/ruoyi-admin/src/main/java/com/ruoyi/pt/quartz/PushQuartz.java +++ b/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); diff --git a/ruoyi-admin/src/main/java/com/ruoyi/pt/service/RemoteCallsService.java b/ruoyi-admin/src/main/java/com/ruoyi/pt/service/RemoteCallsService.java index 31160c4..12d1adb 100644 --- a/ruoyi-admin/src/main/java/com/ruoyi/pt/service/RemoteCallsService.java +++ b/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(); } diff --git a/ruoyi-admin/src/main/java/com/ruoyi/pt/service/impl/RemoteCallsServiceImpl.java b/ruoyi-admin/src/main/java/com/ruoyi/pt/service/impl/RemoteCallsServiceImpl.java index c1cbc1c..5bfc9f0 100644 --- a/ruoyi-admin/src/main/java/com/ruoyi/pt/service/impl/RemoteCallsServiceImpl.java +++ b/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 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 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 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表 *