From bb28c2f09f7fa36b8b80f9d19f23631623b80d1c Mon Sep 17 00:00:00 2001
From: pang.jiabao <pang_jiabao@163.com>
Date: 星期六, 01 三月 2025 16:59:46 +0800
Subject: [PATCH] #

---
 zy-asrs-wms/src/main/java/com/zy/asrs/wms/apis/wcs/services/Impl/WaveManagentServiceImpl.java |  109 ++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 109 insertions(+), 0 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 004a0a9..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
@@ -1,22 +1,131 @@
 package com.zy.asrs.wms.apis.wcs.services.Impl;
 
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.mysql.cj.util.StringUtils;
 import com.zy.asrs.framework.common.R;
+import com.zy.asrs.framework.exception.CoolException;
+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.*;
+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.*;
+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;
 
 @Service
 public class WaveManagentServiceImpl implements WaveManagentService {
     @Autowired
     private WaveSeedService waveSeedService;
 
+    @Autowired
+    private TaskService taskService;
+    @Autowired
+    private TaskMapper taskMapper;
+
+    @Autowired
+    private TaskTypeMapper taskTypeMapper;
+    @Autowired
+    private OrderMapper orderMapper;
+    @Autowired
+    private OrderDetlMapper orderDetlMapper;
+    @Autowired
+    private CacheSiteMapper cacheSiteMapper;
+
     @Override
     public R getSowSeeds() {
         List<SowSeeds> waveSeeds = waveSeedService.selectSeedsList();
         return R.ok(waveSeeds);
     }
+
+    @Override
+    public R reviewSeeds(WaveSeedReviewParam reviewParam) {
+         waveSeedService.waveSeedReview(reviewParam);
+         return R.ok("鎾澶嶆牳鎴愬姛");
+    }
+
+    @Override
+    public int removeSowSeed(Long id) {
+        if (id == null) {
+            throw new CoolException("鎾ID涓嶈兘涓虹┖锛侊紒");
+        }
+        return waveSeedService.removeSowById(id);
+
+    }
+
+    @Override
+    public R getTask() {
+         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
+    public R getTaskDetl(String taskNo) {
+        List<WaveTaskDetl> taskDetls = taskMapper.getTaskDetlByTaskNo(taskNo);
+        return R.ok(taskDetls);
+    }
+
+    /**
+     * 鑾峰彇闈炴眹鎬绘槑缁嗘暟鎹�
+     * @param taskNo
+     * @return
+     */
+    @Override
+    public R getTaskDetlQutify(String taskNo) {
+        List<WaveTaskDetl> taskDetls = taskMapper.getTaskDetlQutify(taskNo);
+        return R.ok(taskDetls);
+    }
+
+    /**
+     * 鑾峰彇娉㈡涓嬫墍鏈夎鍗�
+     * @param waveNo
+     * @return
+     */
+    @Override
+    public R getAllOrders(String waveNo) {
+        if (StringUtils.isNullOrEmpty(waveNo)) {
+            throw new CoolException("娉㈡缂栫爜涓嶈兘涓虹┖锛侊紒");
+        }
+        List<Order> orders = orderMapper.selectList(new LambdaQueryWrapper<Order>().eq(Order::getWaveNo, waveNo));
+        if (orders.isEmpty()) {
+            throw new CoolException("褰撳墠娉㈡涓嬫病鏈夎鍗�!!");
+        }
+
+        orders.forEach(order -> {
+            if (order.getPickStatus() == OrderPickStatus.ORDER_PICK_STATUS_DONE.val) {
+                order.setOrderStatus("宸插畬鎴�");//宸插畬鎴�
+            } else if (order.getPickStatus() == OrderPickStatus.ORDER_PICK_STATUS_SECTION.val) {//閮ㄥ垎瀹屾垚
+                order.setOrderStatus("閮ㄥ垎瀹屾垚");
+            } else {//鏈畬鎴�
+                order.setOrderStatus("鏈畬鎴�");
+            }
+        });
+
+        return R.ok(orders);
+    }
+
+    /**
+     * 鑾蜂簡褰撳墠鎾澧欏簱浣嶄俊鎭�
+     * @return
+     */
+    @Override
+    public R AllSeedLocs() {
+        List<CacheSite> cacheSites = cacheSiteMapper.selectList(new LambdaQueryWrapper<CacheSite>());
+        if (cacheSites.isEmpty()) {
+            return R.error("褰撳墠鎾澧欎俊鎭湭璁剧疆锛侊紒");
+        }
+        return R.ok(cacheSites);
+    }
 }

--
Gitblit v1.9.1