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 list = JSONUtil.toList(recordsStr, CasesImport.class); + log.info("======================================="); + log.info("一共获取" + list.size() + "条数据"); if (CollectionUtil.isNotEmpty(list)) { casesImportService.saveBatch(list); id = casesImportService.findIdDesc();