From 60fdc9564c65b90a8911ff10a25f3f3a63d3812c Mon Sep 17 00:00:00 2001 From: pjb <123456> Date: 星期五, 20 六月 2025 11:06:27 +0800 Subject: [PATCH] 出库任务历史档优化 --- zy-asrs-wms/src/main/java/com/zy/asrs/wms/apis/wcs/services/Impl/WaveManagentServiceImpl.java | 32 ++++++++++++-------------------- 1 files changed, 12 insertions(+), 20 deletions(-) diff --git a/zy-asrs-wms/src/main/java/com/zy/asrs/wms/apis/wcs/services/Impl/WaveManagentServiceImpl.java b/zy-asrs-wms/src/main/java/com/zy/asrs/wms/apis/wcs/services/Impl/WaveManagentServiceImpl.java index 1a502b0..b59a34e 100644 --- a/zy-asrs-wms/src/main/java/com/zy/asrs/wms/apis/wcs/services/Impl/WaveManagentServiceImpl.java +++ b/zy-asrs-wms/src/main/java/com/zy/asrs/wms/apis/wcs/services/Impl/WaveManagentServiceImpl.java @@ -7,23 +7,19 @@ import com.zy.asrs.wms.apis.wcs.entity.domain.WaveTaskDetl; import com.zy.asrs.wms.apis.wcs.entity.response.SowSeeds; import com.zy.asrs.wms.apis.wcs.services.WaveManagentService; -import com.zy.asrs.wms.asrs.entity.CacheSite; -import com.zy.asrs.wms.asrs.entity.Order; -import com.zy.asrs.wms.asrs.entity.OrderDetl; -import com.zy.asrs.wms.asrs.entity.Task; +import com.zy.asrs.wms.asrs.entity.*; import com.zy.asrs.wms.asrs.entity.dto.LargeScreenTaskDto; +import com.zy.asrs.wms.asrs.entity.enums.OrderPickStatus; import com.zy.asrs.wms.asrs.entity.enums.TaskStsType; import com.zy.asrs.wms.asrs.entity.param.WaveSeedReviewParam; -import com.zy.asrs.wms.asrs.mapper.CacheSiteMapper; -import com.zy.asrs.wms.asrs.mapper.OrderDetlMapper; -import com.zy.asrs.wms.asrs.mapper.OrderMapper; -import com.zy.asrs.wms.asrs.mapper.TaskMapper; +import com.zy.asrs.wms.asrs.mapper.*; import com.zy.asrs.wms.asrs.service.TaskService; import com.zy.asrs.wms.asrs.service.WaveSeedService; import org.aspectj.weaver.ast.Or; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; +import java.math.BigDecimal; import java.util.ArrayList; import java.util.List; import java.util.stream.Collectors; @@ -37,6 +33,9 @@ private TaskService taskService; @Autowired private TaskMapper taskMapper; + + @Autowired + private TaskTypeMapper taskTypeMapper; @Autowired private OrderMapper orderMapper; @Autowired @@ -67,8 +66,9 @@ @Override public R getTask() { - List<LargeScreenTaskDto> taskDtos = taskMapper.getTaskIntegrateByTaskNo(new LambdaQueryWrapper<Task>().eq(Task::getTaskSts, TaskStsType.WAVE_SEED.id)); - return R.ok(taskDtos); + List<LargeScreenTaskDto> taskDtos = taskMapper.getTaskIntegrateByTaskNo(new LambdaQueryWrapper<Task>().eq(Task::getTaskSts, TaskStsType.WAVE_SEED.id).orderByAsc(Task::getUpdateTime).last("limit 1")); + + return R.ok(taskDtos); } @Override @@ -104,17 +104,9 @@ } orders.forEach(order -> { - List<OrderDetl> detls = orderDetlMapper.selectList(new LambdaQueryWrapper<OrderDetl>().eq(OrderDetl::getOrderId, order.getId())); - if (detls.isEmpty()) { - throw new CoolException("璁㈠崟锛�" + order.getOrderNo() + " 娌℃湁鏄庣粏,璇疯仈绯荤鐞嗗憳锛侊紒"); - } - List<OrderDetl> orderDetls = detls.stream().filter(orderDetl -> { - return orderDetl.getAnfme() == (orderDetl.getWorkQty() + orderDetl.getQty()); - }).collect(Collectors.toList()); - - if (!orderDetls.isEmpty() && orderDetls.size() == detls.size()) { + if (order.getPickStatus() == OrderPickStatus.ORDER_PICK_STATUS_DONE.val) { order.setOrderStatus("宸插畬鎴�");//宸插畬鎴� - } else if (orderDetls.size() < detls.size() && orderDetls.size() != 0) {//閮ㄥ垎瀹屾垚 + } else if (order.getPickStatus() == OrderPickStatus.ORDER_PICK_STATUS_SECTION.val) {//閮ㄥ垎瀹屾垚 order.setOrderStatus("閮ㄥ垎瀹屾垚"); } else {//鏈畬鎴� order.setOrderStatus("鏈畬鎴�"); -- Gitblit v1.9.1