From 413cab848746903b881af3850ad8f42020b07fea Mon Sep 17 00:00:00 2001
From: wu <wsjxh1023@163.com>
Date: Thu, 28 Dec 2023 09:25:01 +0800
Subject: [PATCH] =?UTF-8?q?=E6=B7=BB=E5=8A=A0=E6=9B=B4=E6=96=B0=E7=AE=97?=
 =?UTF-8?q?=E6=B3=95=E6=95=B0=E6=8D=AE=E5=B9=B6=E6=8E=A8=E9=80=81=E6=8E=A5?=
 =?UTF-8?q?=E5=8F=A3?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../pt/controller/RemoteCallsController.java  | 22 +++++++++++++++++++
 .../service/impl/RemoteCallsServiceImpl.java  |  2 ++
 2 files changed, 24 insertions(+)

diff --git a/ruoyi-admin/src/main/java/com/ruoyi/pt/controller/RemoteCallsController.java b/ruoyi-admin/src/main/java/com/ruoyi/pt/controller/RemoteCallsController.java
index 8d7daff..f391cf3 100644
--- a/ruoyi-admin/src/main/java/com/ruoyi/pt/controller/RemoteCallsController.java
+++ b/ruoyi-admin/src/main/java/com/ruoyi/pt/controller/RemoteCallsController.java
@@ -12,6 +12,8 @@ import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
 import javax.annotation.Resource;
+import java.time.LocalDate;
+import java.time.format.DateTimeFormatter;
 import java.util.List;
 
 /**
@@ -67,6 +69,26 @@ public class RemoteCallsController extends BaseController {
         return success();
     }
 
+    @ApiOperation(value = "更新算法数据并推送")
+    @GetMapping("/pushDate")
+    public AjaxResult pushData() {
+        // 获取社会治理中心增量事件保存到events_import表
+        remoteCallsService.getEventDate();
+        // 获取昨天的数据
+        LocalDate localDate = LocalDate.now();
+        LocalDate yesterday = localDate.minusDays(1);
+        DateTimeFormatter formatter = DateTimeFormatter.ofPattern("yyyy-MM-dd");
+        String yesterdayStr = yesterday.format(formatter);
+        // 紧急事件接口
+        remoteCallsService.urgentAlgorithm(yesterdayStr);
+        // 群体事件接口
+        remoteCallsService.groupAlgorithm();
+        // 同人事件接口
+        remoteCallsService.onepersonAlgorithm();
+        // 推送
+        remoteCallsService.imports();
+        return success();
+    }
     /**
      * 算法处理所有数据
      *
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 2860daf..01fbbd8 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
@@ -197,6 +197,8 @@ public class RemoteCallsServiceImpl implements RemoteCallsService {
         Object records = map.get("records");
         String recordsStr = JSONUtil.toJsonStr(records);
         List<CasesImport> list = JSONUtil.toList(recordsStr, CasesImport.class);
+        log.info("=======================================");
+        log.info("一共获取" + list.size() + "条数据");
         if (CollectionUtil.isNotEmpty(list)) {
             casesImportService.saveBatch(list);
             id = casesImportService.findIdDesc();