From cb5092a38a5123bd9da452ad311b9323561802b1 Mon Sep 17 00:00:00 2001 From: zwl <1051256694@qq.com> Date: 星期二, 20 五月 2025 13:55:11 +0800 Subject: [PATCH] # --- src/main/java/com/zy/asrs/task/WorkMastScheduler.java | 23 ++++++++++++++++++++++- 1 files changed, 22 insertions(+), 1 deletions(-) diff --git a/src/main/java/com/zy/asrs/task/WorkMastScheduler.java b/src/main/java/com/zy/asrs/task/WorkMastScheduler.java index 92be3a2..38dbcb5 100644 --- a/src/main/java/com/zy/asrs/task/WorkMastScheduler.java +++ b/src/main/java/com/zy/asrs/task/WorkMastScheduler.java @@ -1,12 +1,19 @@ package com.zy.asrs.task; +import com.baomidou.mybatisplus.mapper.EntityWrapper; +import com.zy.asrs.entity.LocDetl; +import com.zy.asrs.entity.LocMast; import com.zy.asrs.entity.WrkMast; +import com.zy.asrs.service.LocDetlService; +import com.zy.asrs.service.LocMastService; import com.zy.asrs.service.WrkMastService; +import com.zy.asrs.task.core.ReturnT; import com.zy.asrs.task.handler.WorkMastHandler; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.scheduling.annotation.Scheduled; +import org.springframework.stereotype.Component; import java.util.Date; import java.util.List; @@ -14,7 +21,7 @@ /** * Created by vincent on 2020/7/7 */ -//@Component +@Component public class WorkMastScheduler { private static final Logger log = LoggerFactory.getLogger(WorkMastScheduler.class); @@ -23,10 +30,23 @@ private WrkMastService wrkMastService; @Autowired private WorkMastHandler workMastHandler; + @Autowired + private LocMastService locMastService; + @Autowired + private LocDetlService locDetlService; @Scheduled(cron = "0/3 * * * * ? ") private void execute(){ List<WrkMast> wrkMasts = wrkMastService.selectToBeCompleteData(); + //绌哄簱浣嶆暟鎹兘娓呯┖ + List<LocMast> locMasts = locMastService.selectList(new EntityWrapper<LocMast>().eq("loc_sts","O")); + for (LocMast locMast : locMasts) { + LocDetl locDetl = locDetlService.selectOne(new EntityWrapper<LocDetl>().eq("loc_no",locMast.getLocNo())); + if(locDetl==null){ + continue; + } + locDetlService.delete(new EntityWrapper<LocDetl>().eq("loc_no",locMast.getLocNo())); + } if (wrkMasts.isEmpty()) { return; } @@ -41,6 +61,7 @@ } } } + } } -- Gitblit v1.9.1