| | |
| | | import javax.servlet.http.HttpServletResponse; |
| | | import java.time.LocalDate; |
| | | import java.util.*; |
| | | import java.util.concurrent.CompletableFuture; |
| | | import java.util.concurrent.TimeUnit; |
| | | import java.util.stream.Collectors; |
| | | |
| | |
| | | } |
| | | |
| | | @PostMapping("/syncMedInhospForShiyi") |
| | | public void syncMedInhospForShiyi(@RequestParam("startTime") String startTime, @RequestParam("endTime") String endTime) { |
| | | public AjaxResult syncMedInhospForShiyi(@RequestParam("startTime") String startTime, @RequestParam("endTime") String endTime) { |
| | | // 立即返回,后台异步执行 |
| | | CompletableFuture.runAsync(() -> { |
| | | collectHISService.syncMedInhosp(startTime, endTime); |
| | | }); |
| | | return AjaxResult.success("同步任务已启动,请稍后查看结果"); |
| | | } |
| | | |
| | | @PostMapping("/syncMedInhospForShiyiYesterday") |
| | | public AjaxResult syncMedInhospForShiyiYesterday() { |
| | | // 立即返回,后台异步执行 |
| | | ryTask.collectHISYesterday(); |
| | | return AjaxResult.success("同步任务已启动,请稍后查看结果"); |
| | | } |
| | | |
| | | |
| | | @PostMapping("/syncMedOperForShiyi") |
| | | public void syncMedOperForShiyi(@RequestParam("startTime") String startTime, @RequestParam("endTime") String endTime) { |
| | | public AjaxResult syncMedOperForShiyi(@RequestParam("startTime") String startTime, @RequestParam("endTime") String endTime) { |
| | | // 立即返回,后台异步执行 |
| | | CompletableFuture.runAsync(() -> { |
| | | collectHISService.syncOper(startTime, endTime); |
| | | }); |
| | | return AjaxResult.success("同步任务已启动,请稍后查看结果"); |
| | | } |
| | | } |