From ee2e593c5736c27dad7d93f9fca98290f578b5da Mon Sep 17 00:00:00 2001 From: zhang <zc857179121@qq.com> Date: 星期三, 21 五月 2025 21:36:25 +0800 Subject: [PATCH] 接口编写 --- src/main/java/com/zy/nc/task/PlanOrderTask.java | 38 +++++++++++++++++++++++++++++--------- 1 files changed, 29 insertions(+), 9 deletions(-) diff --git a/src/main/java/com/zy/nc/task/PlanOrderTask.java b/src/main/java/com/zy/nc/task/PlanOrderTask.java index 804312e..7c29060 100644 --- a/src/main/java/com/zy/nc/task/PlanOrderTask.java +++ b/src/main/java/com/zy/nc/task/PlanOrderTask.java @@ -2,14 +2,8 @@ import com.baomidou.mybatisplus.mapper.EntityWrapper; import com.zy.asrs.task.core.ReturnT; -import com.zy.nc.entity.NccCgCgdhdWms; -import com.zy.nc.entity.NccCkPddWms; -import com.zy.nc.entity.NccSaleXsfhmxWms; -import com.zy.nc.entity.NccScZkmxbWms; -import com.zy.nc.service.NccCgCgdhdWmsService; -import com.zy.nc.service.NccCkPddWmsService; -import com.zy.nc.service.NccSaleXsfhmxWmsService; -import com.zy.nc.service.NccScZkmxbWmsService; +import com.zy.nc.entity.*; +import com.zy.nc.service.*; import com.zy.nc.task.handler.PlanOrderHandler; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; @@ -34,6 +28,9 @@ @Autowired private NccCgCgdhdWmsService nccCgCgdhdWmsService; + + @Autowired + private NccSaleDbddWmsService nccSaleDbddWmsService; @Autowired private NccCkPddWmsService nccCkPddWmsService; @@ -105,6 +102,29 @@ } /** + * 璋冩嫧鍑哄簱 + * + * @return + */ + @Scheduled(cron = "0/3 * * * * ? ") + public void execute5() { + List<String> strings = nccSaleDbddWmsService.selectDbdd(); + for (String string : strings) { + List<NccSaleDbddWms> wmsFlag = nccSaleDbddWmsService.selectList(new EntityWrapper<NccSaleDbddWms>().eq("vbillcode", string).ne("wms_flag", 1)); + ReturnT<String> returnT = planOrderHandler.start5(wmsFlag); + if (!returnT.isSuccess()) { + for (NccSaleDbddWms wms : wmsFlag) { + wms.setWmsMemo(returnT.getMsg()); + nccSaleDbddWmsService.updateById(wms); + } + log.error(returnT.getMsg()); + } + } + + } + + + /** * 鐩樼偣鍗� * * @return @@ -113,7 +133,7 @@ public void execute4() { List<String> strings = nccCkPddWmsService.selectPdd(); for (String string : strings) { - List<NccCkPddWms> wmsFlag = nccCkPddWmsService.selectList(new EntityWrapper<NccCkPddWms>().eq("vbillcode", string).ne("wms_flag", 1)); + List<NccCkPddWms> wmsFlag = nccCkPddWmsService.selectList(new EntityWrapper<NccCkPddWms>().eq("vbillcode", string).ne("wms_flag", 1).eq("hdr",0).eq("bdr",0)); ReturnT<String> returnT = planOrderHandler.start4(wmsFlag); if (!returnT.isSuccess()) { for (NccCkPddWms wms : wmsFlag) { -- Gitblit v1.9.1