diff --git a/src/main/java/digital/laboratory/platform/entrustment/EntrustmentApplication.java b/src/main/java/digital/laboratory/platform/entrustment/EntrustmentApplication.java index 90c8741..6961858 100644 --- a/src/main/java/digital/laboratory/platform/entrustment/EntrustmentApplication.java +++ b/src/main/java/digital/laboratory/platform/entrustment/EntrustmentApplication.java @@ -8,7 +8,7 @@ import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.cloud.client.discovery.EnableDiscoveryClient; import org.springframework.scheduling.annotation.EnableScheduling; -@EnableScheduling // 开启定时任务 +// todo @EnableScheduling // 开启定时任务 @EnableDLPSwagger2 @EnableDLPFeignClients @EnableDiscoveryClient diff --git a/src/main/java/digital/laboratory/platform/entrustment/service/PushDataToLabsCareService.java b/src/main/java/digital/laboratory/platform/entrustment/service/PushDataToLabsCareService.java index 25bf80b..4b16ba0 100644 --- a/src/main/java/digital/laboratory/platform/entrustment/service/PushDataToLabsCareService.java +++ b/src/main/java/digital/laboratory/platform/entrustment/service/PushDataToLabsCareService.java @@ -2,7 +2,6 @@ package digital.laboratory.platform.entrustment.service; import digital.laboratory.platform.entrustment.vo.EntrustmentVO; -import java.util.Map; /** * @author ChenJiangBao diff --git a/src/main/java/digital/laboratory/platform/entrustment/service/impl/PushDataToLabsCareServiceImpl.java b/src/main/java/digital/laboratory/platform/entrustment/service/impl/PushDataToLabsCareServiceImpl.java index e4c543a..7bc9b5c 100644 --- a/src/main/java/digital/laboratory/platform/entrustment/service/impl/PushDataToLabsCareServiceImpl.java +++ b/src/main/java/digital/laboratory/platform/entrustment/service/impl/PushDataToLabsCareServiceImpl.java @@ -70,7 +70,7 @@ public class PushDataToLabsCareServiceImpl implements PushDataToLabsCareService /** * 做一个定时推送,对于推送失败的委托进行重新推送, 每天凌晨1点推送 */ -// @Scheduled(cron = "30 * * * * ?") +// @Scheduled(cron = "30 * * * * ?") // 测试 @Scheduled(cron = "0 0 1 * * ?") // 每天凌晨 1 点执行 public void timingPushDataToLabsCare() throws IllegalAccessException { // 查询受理后推送失败的委托 @@ -297,7 +297,8 @@ public class PushDataToLabsCareServiceImpl implements PushDataToLabsCareService } else { flagList.add(newFlag); } - + // 更新标识, 防止定时任务那里连续推送数据时推送标识更新出错 + entrustVO.setPushFlag(String.join(",", flagList)); // 更新数据库 entrustmentService.update(Wrappers.lambdaUpdate() .eq(Entrustment::getId, entrustVO.getId())