ltkj-admin/src/main/java/com/ltkj/web/config/timer/AsyncResultTask.java
@@ -95,15 +95,17 @@ // 将该用户ID添加到已调度任务集合中 scheduledTasks.add(dictHosp.getCode()); // 创建定时任务,任务将在15分钟后执行 taskScheduler.schedule(() -> { /* taskScheduler.schedule(() -> { try { // 执行任务的超时控制 taskScheduler.schedule(() -> { executeTask(dictHosp); }, Instant.now()); } catch (Exception e) { log.error("创建任务时发生异常:{}", e.getMessage()); } }, Instant.now().plus(15, ChronoUnit.MINUTES));*/ log.info("任务创建成功 ->{}",dictHosp.getCode()); // 执行任务的超时控制 taskScheduler.schedule(() -> { executeTask(dictHosp); }, Instant.now().plus(15, ChronoUnit.MINUTES)); } @@ -219,10 +221,12 @@ // 检查并添加新的用户任务 public void checkAndAddNewTasks() { DataSourceContextHolder.setDataSourceKey(DataSourceType.MASTER.name()); // 获取所有需要同步日志的用户列表 LambdaQueryWrapper<DictHosp> wrapper = new LambdaQueryWrapper<>(); wrapper.eq(DictHosp::getIsAutoAsyncJg,1); List<DictHosp> hospList = dictHospService.list(wrapper); log.info("检查并添加需要同步的医院列表:{}", JSONUtil.toJsonStr(hospList)); hospList.forEach(this::createTask); taskScheduler.schedule(this::checkAndAddNewTasks, Instant.now().plus(2, ChronoUnit.MINUTES)); } ltkj-admin/src/main/java/com/ltkj/web/controller/system/TjCheckController.java
@@ -1943,6 +1943,15 @@ } @GetMapping("/zongjianyishengHuiFuyichangxiangmuanniu") @ApiOperation(value = "总检恢复异常项目按钮接口") public AjaxResult zongjianyishengHuiFuyichangxiangmuanniu(@RequestParam String id) { int a = ycxmService.zongjianyishengHuiFuyichangxiangmuanniu(id); return AjaxResult.success(a); } @GetMapping("/csymxmxzqtyybcjk") @ApiOperation(value = "初审页面项目选择其他原因保存接口") ltkj-hosp/src/main/java/com/ltkj/hosp/mapper/TjOrderYcxmMapper.java
@@ -5,6 +5,7 @@ import org.apache.ibatis.annotations.Delete; import org.apache.ibatis.annotations.Mapper; import org.apache.ibatis.annotations.Select; import org.apache.ibatis.annotations.Update; import java.util.List; @@ -26,4 +27,9 @@ @Select("select * FROM tj_order_ycxm WHERE tjh=#{tjNum} and deleted=1") List<TjOrderYcxm> zongjianyishengHuiFuyichangxiangmu(String tjNum); @Update("update tj_order_ycxm a set" + " a.deleted=0 " + " where a.id=id") int zongjianyishengHuiFuyichangxiangmuanniu(String id); } ltkj-hosp/src/main/java/com/ltkj/hosp/service/TjOrderYcxmService.java
@@ -19,4 +19,6 @@ List<TjOrderYcxm> selectListByTjh(String tjNumber); List<TjOrderYcxm> zongjianyishengHuiFuyichangxiangmu(String tjNum); int zongjianyishengHuiFuyichangxiangmuanniu(String id); } ltkj-hosp/src/main/java/com/ltkj/hosp/service/impl/TjOrderYcxmServiceImpl.java
@@ -36,4 +36,9 @@ public List<TjOrderYcxm> zongjianyishengHuiFuyichangxiangmu(String tjNum) { return mapper.zongjianyishengHuiFuyichangxiangmu(tjNum); } @Override public int zongjianyishengHuiFuyichangxiangmuanniu(String id) { return mapper.zongjianyishengHuiFuyichangxiangmuanniu(id); } }