From cc6dae7468506691bfb23ca81be5e14045771bce Mon Sep 17 00:00:00 2001
From: skyouc
Date: 星期三, 15 一月 2025 20:43:59 +0800
Subject: [PATCH] #  拍灯容器流动流程修改  发货确认功能开发 部分功能优化

---
 zy-asrs-wms/src/main/java/com/zy/asrs/wms/apis/wcs/services/Impl/WcsApiServiceImpl.java |  288 +++++++++++++++++++++++++++++++++++++++++----------------
 1 files changed, 207 insertions(+), 81 deletions(-)

diff --git a/zy-asrs-wms/src/main/java/com/zy/asrs/wms/apis/wcs/services/Impl/WcsApiServiceImpl.java b/zy-asrs-wms/src/main/java/com/zy/asrs/wms/apis/wcs/services/Impl/WcsApiServiceImpl.java
index 7c4be6f..b3f6d2a 100644
--- a/zy-asrs-wms/src/main/java/com/zy/asrs/wms/apis/wcs/services/Impl/WcsApiServiceImpl.java
+++ b/zy-asrs-wms/src/main/java/com/zy/asrs/wms/apis/wcs/services/Impl/WcsApiServiceImpl.java
@@ -1,25 +1,37 @@
 package com.zy.asrs.wms.apis.wcs.services.Impl;
 
+import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
 import com.zy.asrs.framework.common.R;
 import com.zy.asrs.framework.exception.CoolException;
+import com.zy.asrs.wms.apis.wcs.entity.domain.SystemProperties;
 import com.zy.asrs.wms.apis.wcs.entity.enums.EssTaskStatus;
 import com.zy.asrs.wms.apis.wcs.entity.request.*;
+import com.zy.asrs.wms.apis.wcs.entity.response.CommonReponse;
 import com.zy.asrs.wms.apis.wcs.services.WcsApiService;
 import com.zy.asrs.wms.asrs.entity.Task;
+import com.zy.asrs.wms.asrs.entity.TaskDetl;
+import com.zy.asrs.wms.asrs.entity.WaveSeed;
 import com.zy.asrs.wms.asrs.entity.enums.TaskStsType;
-import com.zy.asrs.wms.asrs.service.TaskService;
-import com.zy.asrs.wms.asrs.service.WaitPakinService;
-import com.zy.asrs.wms.asrs.service.WorkService;
+import com.zy.asrs.wms.asrs.service.*;
 import io.jsonwebtoken.lang.Collections;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.http.HttpEntity;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.HttpMethod;
+import org.springframework.http.ResponseEntity;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
+import org.springframework.util.LinkedMultiValueMap;
+import org.springframework.util.MultiValueMap;
+import org.springframework.web.client.RestTemplate;
 
-import java.util.Date;
 import java.util.List;
+import java.util.Map;
+import java.util.Objects;
+import java.util.stream.Collectors;
 
 @Slf4j
 @Service
@@ -31,7 +43,14 @@
     private WorkService workService;
     @Autowired
     private TaskService taskService;
+    @Autowired
+    private TaskDetlService taskDetlService;
 
+    @Autowired
+    private WaveSeedService waveSeedService;
+
+    @Autowired
+    private RestTemplate restTemplate;
 
 
     /**
@@ -78,6 +97,13 @@
         return R.success("success");
     }
 
+    /**
+     * 瀹瑰櫒鎵ц鐘舵�佷笂鎶�
+     *
+     * @param callbackParam
+     * @param stockType
+     * @param hostId
+     */
     @Override
     @Transactional(rollbackFor = Exception.class)
     public void receiveTaskStatus(TasksStatusCallbackParam callbackParam, String stockType, Long hostId) {
@@ -86,87 +112,89 @@
                 .eq(Task::getTaskNo, callbackParam.getTaskCode()));
         if (!Collections.isEmpty(list)) {
             list.forEach(task -> {
-                    TaskStsType taskStsType = null;
-                    if (stockType.equals("inStock")) { //鍏ュ簱浠诲姟
-                        if (callbackParam.getEventType().equals(EssTaskStatus.TASK_EVENT_TOTE_LOAD.event)) { //涓婃姤鍙栫鐘舵��
-                            if (task.getTaskSts() == TaskStsType.WCS_CONVEYOR_START.id) {
-                                taskStsType = TaskStsType.WCS_TOTE_LOAD;
-                            } else {
-                                String errMsg = "浠诲姟缂栧彿锛�" + task.getTaskNo() +  "鐘舵�佷负涓嶅尮閰嶏紝"  + "涓嶈兘鎵ц锛�" + TaskStsType.WCS_TOTE_LOAD.desc + "浠诲姟";
-                                log.error(errMsg);
-                                throw new CoolException(errMsg);
-                            }
-                        } else if (callbackParam.getEventType().equals(EssTaskStatus.TASK_EVENT_TOTE_UNLOAD.event)) { //涓婃姤鏀剧鐘舵��
-                            if (task.getTaskSts() == TaskStsType.WCS_TOTE_LOAD.id) {
-                                taskStsType = TaskStsType.WCS_TOTE_UNLOAD;
-                            } else {
-                                String errMsg = "浠诲姟缂栧彿锛�" + task.getTaskNo() +  "鐘舵�佷负涓嶅尮閰嶏紝"  + "涓嶈兘鎵ц锛�" + TaskStsType.WCS_TOTE_UNLOAD.desc + "浠诲姟";
-                                log.error(errMsg);
-                                throw new CoolException(errMsg);
-                            }
-                        } else if (callbackParam.getEventType().equals(EssTaskStatus.TASK_EVENT_STATUS.event)) { //TODO 闇�纭涓婃姤浠诲姟涓紝浠诲姟瀹屾垚鏄摢涓簨浠讹紝鐩墠鏆傚畾task浜嬩欢
-                            if (task.getTaskSts() == TaskStsType.WCS_TOTE_UNLOAD.id) {
-                                taskStsType = TaskStsType.WCS_PUTAWAY_SUCESS;
-                            } else {
-                                String errMsg = "浠诲姟缂栧彿锛�" + task.getTaskNo() +  "鐘舵�佷负涓嶅尮閰嶏紝"  + "涓嶈兘鎵ц锛�" + TaskStsType.WCS_PUTAWAY_SUCESS.desc + "浠诲姟";
-                                log.error(errMsg);
-                                throw new CoolException(errMsg);
-                            }
+                TaskStsType taskStsType = null;
+                if (stockType.equals("inStock")) { //鍏ュ簱浠诲姟
+                    if (callbackParam.getEventType().equals(EssTaskStatus.TASK_EVENT_TOTE_LOAD.event)) { //涓婃姤鍙栫鐘舵��
+                        if (task.getTaskSts() == TaskStsType.WCS_CONVEYOR_START.id) {
+                            taskStsType = TaskStsType.WCS_TOTE_LOAD;
+                        } else {
+                            String errMsg = "浠诲姟缂栧彿锛�" + task.getTaskNo() + "鐘舵�佷负涓嶅尮閰嶏紝" + "涓嶈兘鎵ц锛�" + TaskStsType.WCS_TOTE_LOAD.desc + "浠诲姟";
+                            log.error(errMsg);
+                            throw new CoolException(errMsg);
                         }
-                        boolean result = taskService.update(new LambdaUpdateWrapper<Task>()
-                                .set(Task::getRobotCode, callbackParam.getRobotCode())
-                                .set(Task::getSysTaskCode, callbackParam.getSysTaskCode())
-                                .set(Task::getTaskSts, taskStsType.id)
-                                .set(Task::getExcudeStatus, callbackParam.getStatus())
-                                .set(Task::getTaskDesc, callbackParam.getMessage())
-                                .eq(Task::getBarcode, callbackParam.getContainerCode())
-                                .eq(Task::getTaskNo, callbackParam.getTaskCode()));
-
-                        if (callbackParam.getEventType().equals(EssTaskStatus.TASK_EVENT_STATUS.event) && result) {
-                            workService.completeTask(task.getId());
+                    } else if (callbackParam.getEventType().equals(EssTaskStatus.TASK_EVENT_TOTE_UNLOAD.event)) { //涓婃姤鏀剧鐘舵��
+                        if (task.getTaskSts() == TaskStsType.WCS_TOTE_LOAD.id) {
+                            taskStsType = TaskStsType.WCS_TOTE_UNLOAD;
+                        } else {
+                            String errMsg = "浠诲姟缂栧彿锛�" + task.getTaskNo() + "鐘舵�佷负涓嶅尮閰嶏紝" + "涓嶈兘鎵ц锛�" + TaskStsType.WCS_TOTE_UNLOAD.desc + "浠诲姟";
+                            log.error(errMsg);
+                            throw new CoolException(errMsg);
                         }
-                    } else { //鍑哄簱浠诲姟
-                        if (callbackParam.getEventType().equals(EssTaskStatus.TASK_EVENT_TOTE_LOAD.event)) { //涓婃姤鍙栫鐘舵��
-                            //TODO 瀹氭椂鍣ㄥ紑鍚悗锛岃鍒犻櫎 || task.getTaskType() == TaskStsType.GENERATE_OUT.id
-                            if (task.getTaskSts() == TaskStsType.WCS_EXECUTE_OUT.id || task.getTaskSts() == TaskStsType.GENERATE_OUT.id) {
-                                taskStsType = TaskStsType.WCS_EXECUTE_OUT_TOTE_LOAD;
-                            } else {
-                                String errMsg = "浠诲姟缂栧彿锛�" + task.getTaskNo() +  "鐘舵�佷负涓嶅尮閰嶏紝"  + "涓嶈兘鎵ц锛�" + TaskStsType.WCS_EXECUTE_OUT_TOTE_LOAD.desc + "浠诲姟";
-                                log.error(errMsg);
-                                throw new CoolException(errMsg);
-                            }
-                        } else if (callbackParam.getEventType().equals(EssTaskStatus.TASK_EVENT_TOTE_UNLOAD.event)) { //涓婃姤鏀剧鐘舵��
-                            if (task.getTaskSts() == TaskStsType.WCS_EXECUTE_OUT_TOTE_LOAD.id) {
-                                taskStsType = TaskStsType.WCS_EXECUTE_OUT_TOTE_UNLOAD;
-                            } else {
-                                String errMsg = "浠诲姟缂栧彿锛�" + task.getTaskNo() +  "鐘舵�佷负涓嶅尮閰嶏紝"  + "涓嶈兘鎵ц锛�" + TaskStsType.WCS_EXECUTE_OUT_TOTE_UNLOAD.desc + "浠诲姟";
-                                log.error(errMsg);
-                                throw new CoolException(errMsg);
-                            }
-                        } else if (callbackParam.getEventType().equals(EssTaskStatus.TASK_EVENT_STATUS.event)) { //涓婃姤瀹屾垚鐘舵��
-                            if (task.getTaskSts() == TaskStsType.WCS_EXECUTE_OUT_TOTE_UNLOAD.id || task.getTaskSts() == TaskStsType.WCS_EXECUTE_OUT_TASK_DONE.id) {
-                                //鍑哄簱浠诲姟瀹屾垚锛屼慨鏀圭姸鎬佷负瀹瑰櫒鍒拌揪锛屽畾鏃朵换鍔$敓鎴愭挱绉嶆尝娆�
-                                taskStsType = TaskStsType.WCS_EXECUTE_OUT_TASK_DONE;
-                            } else {
-                                String errMsg = "浠诲姟缂栧彿锛�" + task.getTaskNo() +  "鐘舵�佷负涓嶅尮閰嶏紝"  + "涓嶈兘鎵ц锛�" + TaskStsType.WCS_EXECUTE_OUT_TASK_DONE.desc + "浠诲姟";
-                                log.error(errMsg);
-                                throw new CoolException(errMsg);
-                            }
+                    } else if (callbackParam.getEventType().equals(EssTaskStatus.TASK_EVENT_STATUS.event)) { //TODO 闇�纭涓婃姤浠诲姟涓紝浠诲姟瀹屾垚鏄摢涓簨浠讹紝鐩墠鏆傚畾task浜嬩欢
+                        if (task.getTaskSts() == TaskStsType.WCS_TOTE_UNLOAD.id) {
+                            taskStsType = TaskStsType.WCS_PUTAWAY_SUCESS;
+                        } else {
+                            String errMsg = "浠诲姟缂栧彿锛�" + task.getTaskNo() + "鐘舵�佷负涓嶅尮閰嶏紝" + "涓嶈兘鎵ц锛�" + TaskStsType.WCS_PUTAWAY_SUCESS.desc + "浠诲姟";
+                            log.error(errMsg);
+                            throw new CoolException(errMsg);
                         }
+                    }
+                    boolean result = taskService.update(new LambdaUpdateWrapper<Task>()
+                            .set(Task::getRobotCode, callbackParam.getRobotCode())
+                            .set(Task::getSysTaskCode, callbackParam.getSysTaskCode())
+                            .set(Task::getTaskSts, taskStsType.id)
+                            .set(Task::getExcudeStatus, callbackParam.getStatus())
+                            .set(Task::getTaskDesc, callbackParam.getMessage())
+                            .eq(Task::getBarcode, callbackParam.getContainerCode())
+                            .eq(Task::getTaskNo, callbackParam.getTaskCode()));
 
-                        //鏇存柊鍑哄簱鐘舵�佸強鐩稿叧瀛楁
-                         taskService.update(new LambdaUpdateWrapper<Task>()
-                                .set(Task::getRobotCode, callbackParam.getRobotCode())
-                                .set(Task::getSysTaskCode, callbackParam.getSysTaskCode())
-                                .set(Task::getTaskSts, taskStsType.id)
-                                .set(Task::getExcudeStatus, callbackParam.getStatus())
-                                .set(Task::getTaskDesc, callbackParam.getMessage())
-                                .eq(Task::getBarcode, callbackParam.getContainerCode())
-                                .eq(Task::getTaskNo, callbackParam.getTaskCode()));
-
+                    //event浜嬩欢涓簍ask锛岃〃鏄庝换鍔′笂鎶ュ畬鎴愮姸鎬�
+                    if (callbackParam.getEventType().equals(EssTaskStatus.TASK_EVENT_STATUS.event) && result) {
+                        //浠诲姟鐘舵�佷慨鏀逛负 99 鍏ュ簱瀹屾垚
+                        workService.completeTask(task.getId());
+                    }
+                } else { //鍑哄簱浠诲姟
+                    if (callbackParam.getEventType().equals(EssTaskStatus.TASK_EVENT_TOTE_LOAD.event)) { //涓婃姤鍙栫鐘舵��
+                        //TODO 瀹氭椂鍣ㄥ紑鍚悗锛岃鍒犻櫎 || task.getTaskType() == TaskStsType.GENERATE_OUT.id
+                        if (task.getTaskSts() == TaskStsType.WCS_EXECUTE_OUT.id || task.getTaskSts() == TaskStsType.GENERATE_OUT.id) {
+                            taskStsType = TaskStsType.WCS_EXECUTE_OUT_TOTE_LOAD;
+                        } else {
+                            String errMsg = "浠诲姟缂栧彿锛�" + task.getTaskNo() + "鐘舵�佷负涓嶅尮閰嶏紝" + "涓嶈兘鎵ц锛�" + TaskStsType.WCS_EXECUTE_OUT_TOTE_LOAD.desc + "浠诲姟";
+                            log.error(errMsg);
+                            throw new CoolException(errMsg);
+                        }
+                    } else if (callbackParam.getEventType().equals(EssTaskStatus.TASK_EVENT_TOTE_UNLOAD.event)) { //涓婃姤鏀剧鐘舵��
+                        if (task.getTaskSts() == TaskStsType.WCS_EXECUTE_OUT_TOTE_LOAD.id) {
+                            taskStsType = TaskStsType.WCS_EXECUTE_OUT_TOTE_UNLOAD;
+                        } else {
+                            String errMsg = "浠诲姟缂栧彿锛�" + task.getTaskNo() + "鐘舵�佷负涓嶅尮閰嶏紝" + "涓嶈兘鎵ц锛�" + TaskStsType.WCS_EXECUTE_OUT_TOTE_UNLOAD.desc + "浠诲姟";
+                            log.error(errMsg);
+                            throw new CoolException(errMsg);
+                        }
+                    } else if (callbackParam.getEventType().equals(EssTaskStatus.TASK_EVENT_STATUS.event)) { //涓婃姤瀹屾垚鐘舵��
+                        if (task.getTaskSts() == TaskStsType.WCS_EXECUTE_OUT_TOTE_UNLOAD.id || task.getTaskSts() == TaskStsType.WCS_EXECUTE_OUT_TASK_DONE.id) {
+                            //鍑哄簱浠诲姟瀹屾垚锛屼慨鏀圭姸鎬佷负瀹瑰櫒鍒拌揪锛屽畾鏃朵换鍔$敓鎴愭挱绉嶆尝娆�
+                            taskStsType = TaskStsType.WCS_EXECUTE_OUT_TASK_DONE;
+                        } else {
+                            String errMsg = "浠诲姟缂栧彿锛�" + task.getTaskNo() + "鐘舵�佷负涓嶅尮閰嶏紝" + "涓嶈兘鎵ц锛�" + TaskStsType.WCS_EXECUTE_OUT_TASK_DONE.desc + "浠诲姟";
+                            log.error(errMsg);
+                            throw new CoolException(errMsg);
+                        }
                     }
 
-                });
+                    //鏇存柊鍑哄簱鐘舵�佸強鐩稿叧瀛楁
+                    taskService.update(new LambdaUpdateWrapper<Task>()
+                            .set(Task::getRobotCode, callbackParam.getRobotCode())
+                            .set(Task::getSysTaskCode, callbackParam.getSysTaskCode())
+                            .set(Task::getTaskSts, taskStsType.id)
+                            .set(Task::getExcudeStatus, callbackParam.getStatus())
+                            .set(Task::getTaskDesc, callbackParam.getMessage())
+                            .eq(Task::getBarcode, callbackParam.getContainerCode())
+                            .eq(Task::getTaskNo, callbackParam.getTaskCode()));
+
+                }
+
+            });
         } else {
             throw new CoolException("鏇存柊鍐呭涓嶅瓨鍦紒锛�");
         }
@@ -174,15 +202,16 @@
 
     /**
      * 瀹瑰櫒娴佸姩閫氱煡
+     *
      * @param code
      * @return
      */
     @Override
-    public R containerConveryor(String code) {
+    public synchronized R containerConveryor(String code) {
         List<Task> tasks = taskService.list(new LambdaQueryWrapper<Task>().eq(Task::getBarcode, code));
         if (tasks.isEmpty()) {
             return R.error("瀹瑰櫒鐮佷换鍔′笉瀛樺湪锛侊紒");
-        } else if (tasks.size() > 1){
+        } else if (tasks.size() > 1) {
             return R.error("瀹瑰櫒鐮佷换鍔¢敊璇紒锛�");
         }
         tasks.forEach(task -> {
@@ -214,6 +243,8 @@
             //娴佸姩閫氱煡涓嬪彂瀹屾垚鍚庯紝淇敼浠诲姟鐘舵�佷负杈撻�佺嚎娴佸姩涓�傘��
             //TODO 鍒ゆ柇浠诲姟鏄惁涓�103鎷f枡鍑哄簱锛�103鎷f枡娴佸姩鍚庝慨鏀逛负4锛圧CS瀹瑰櫒娴佸姩浠诲姟宸蹭笅鍙戯級
             if (task.getTaskType() == 103) {
+                //TODO 闇�鎵炬捣鏌旂‘璁ゆ槸鍚﹂渶瑕侀噸鏂拌皟鐢ㄥ叆搴撴帴鍙�
+                //鏇存柊搴撳瓨淇℃伅,淇敼浠诲姟鐘舵�佷负4 锛圧CS瀹瑰櫒娴佸姩浠诲姟宸蹭笅鍙戯級
                 workService.pickTask(task.getId());
 //                taskService.update(new LambdaUpdateWrapper<Task>().eq(Task::getId, task.getId()).set(Task::getTaskSts, TaskStsType.WCS_CONVEYOR_START))
             } else {
@@ -238,4 +269,99 @@
         return R.ok();
     }
 
+
+    @Override
+    public R rfidCallback(RfidSingalRequest request) {
+
+
+        return null;
+    }
+
+    /**
+     * 鎷嶇伅鎷f枡閫昏緫锛岃缁嗚鏄庤鎺ュ彛璋冪敤璇存槑
+     *
+     * @param request
+     */
+    @Override
+    public void slapLightLogic(Map<String, Object> request) {
+        String taskNo = request.get("taskNo").toString();
+        String orderNo = request.get("orderNo").toString();
+
+        //* 1. 鍒ゆ柇褰撳墠瀹瑰櫒鏄惁杩樻湁鐗╂枡鏈嫞锛屾湭鎷e畬闂伅锛屾嫞瀹岄�氱煡瀹瑰櫒娴佸姩锛屽苟鐏伅
+        SlapLightControlParam slapParam = new SlapLightControlParam();
+        MultiValueMap<String, Object> params = new LinkedMultiValueMap<>();
+        //榛樿娴佸姩
+        boolean converyor = false;
+        //鍒ゆ柇鏄惁杩樻湁鐗╂枡鏈嫞
+
+        if (!checked(orderNo, taskNo)) {
+            //璋冪敤涓夋柟鎺ュ彛,闂伅涓嶅仛鎿嶄綔
+
+            // 璁剧疆璇锋眰鍙傛暟
+            params.add("params", JSONObject.toJSONString(slapParam));
+            log.info("璇锋眰鍦板潃锛歿}锛岃姹傚弬鏁帮細{}", SystemProperties.SLAP_LIGHT, JSONObject.toJSONString(slapParam));
+
+        } else {
+            //璋冪敤涓夋柟鎺ュ彛,鏉ョ伅閫氱煡瀹瑰櫒娴佸姩锛� 浼犵伃鐏弬鏁�
+
+            params.add("params", JSONObject.toJSONString(slapParam));
+            log.info("璇锋眰鍦板潃锛歿}锛岃姹傚弬鏁帮細{}", SystemProperties.SLAP_LIGHT, JSONObject.toJSONString(slapParam));
+        }
+
+        HttpHeaders headers = new HttpHeaders();
+        headers.add("Content-Type", "application/json");
+        HttpEntity httpEntity = new HttpEntity<>(params, headers);
+        // 璇锋眰
+        ResponseEntity<CommonReponse> exchange = restTemplate.exchange(SystemProperties.CONVEYOR_START, HttpMethod.POST, httpEntity, CommonReponse.class);
+        log.info("涓嬪彂娴佸姩閫氱煡 杩斿洖缁撴灉锛歿}", exchange);
+        if (exchange.getBody() == null) {
+            throw new CoolException("涓嬪彂娴佸姩閫氱煡澶辫触锛侊紒");
+        } else {
+            CommonReponse response = exchange.getBody();
+            if (response.getCode() == 0) {
+                if (!converyor) {
+                    //* 2. 瀹瑰櫒娴佸姩鍒ゆ柇锛屽鏋滄枡绠辨病鏈夌墿鏂� code浼�200锛� 鏈夌墿鏂欎紶100 鎵ц鍥炲簱浠诲姟,淇敼浠诲姟鐘舵�佷负  璋冪敤containerConveryor锛坱askNo锛夋柟娉�
+                    containerConveryor(request.get("taskNo").toString());
+                }
+            }
+        }
+    }
+
+    /**
+     * 鍒ゆ柇褰撳墠浠诲姟涓嬶紝璁㈠崟鏄惁宸插畬鎴愭嫞璐�
+     *
+     * @param orderNo
+     * @param taskNo
+     * @return
+     */
+    public synchronized boolean checked(String orderNo, String taskNo) {
+        if (Objects.isNull(orderNo)) {
+            throw new CoolException("璁㈠崟缂栫爜涓嶈兘涓虹┖锛侊紒");
+        }
+        if (Objects.isNull(taskNo)) {
+            throw new CoolException("浠诲姟缂栫爜涓嶈兘涓虹┖锛侊紒");
+        }
+
+        List<TaskDetl> taskDetls = taskDetlService.list(new LambdaQueryWrapper<TaskDetl>().eq(TaskDetl::getTaskNo, taskNo));
+        if (taskDetls.isEmpty()) {
+            throw new CoolException("璁㈠崟鏄庣粏涓嶅瓨鍦紒锛�");
+        }
+
+        List<Long> detlIds = taskDetls.stream().map(TaskDetl::getId).collect(Collectors.toList());
+
+        double taskNum = taskDetls.stream().mapToDouble(TaskDetl::getAnfme).sum();
+
+        List<WaveSeed> seeds = waveSeedService.list(new LambdaQueryWrapper<WaveSeed>().in(WaveSeed::getTaskDetlId, detlIds));
+        if (seeds.isEmpty()) {
+            throw new CoolException("鎾淇℃伅涓嶅瓨鍦紒锛侊紒");
+        }
+        double seedNum = seeds.stream().mapToDouble(WaveSeed::getWorkQty).sum();
+        //鍒ゆ柇浠诲姟闇�姹傛�婚噺鏄惁绛夋挱绉嶆�绘暟閲�
+        if (taskNum == seedNum) {
+            return true;
+        } else  {
+            return false;
+        }
+    }
+
 }

--
Gitblit v1.9.1