From 323a159cfe54156adfc04a4b7e5ed4b552214632 Mon Sep 17 00:00:00 2001
From: chen.lin <1442464845@qq.com>
Date: 星期六, 07 二月 2026 12:15:09 +0800
Subject: [PATCH] 跳过波次任务

---
 rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/TaskServiceImpl.java |  310 +++++++++++++++++++++++++++++++++++++++++++--------
 1 files changed, 259 insertions(+), 51 deletions(-)

diff --git a/rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/TaskServiceImpl.java b/rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/TaskServiceImpl.java
index 62f7b06..f76d167 100644
--- a/rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/TaskServiceImpl.java
+++ b/rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/TaskServiceImpl.java
@@ -508,25 +508,157 @@
     @Override
     @Transactional(rollbackFor = Exception.class)
     public Task operateComplete(Long id, Long loginUserId) {
-        List<Integer> longs = Arrays.asList(TaskStsType.GENERATE_IN.id, TaskStsType.GENERATE_OUT.id);
+        // 鍏堟煡璇换鍔★紝涓嶉檺鍒剁姸鎬�
         Task task = taskService.getOne(new LambdaQueryWrapper<Task>()
-                .eq(Task::getId, id)
-                .in(Task::getTaskStatus, longs));
+                .eq(Task::getId, id));
 
         if (Objects.isNull(task)) {
-            throw new CoolException("鏁版嵁閿欒锛氬綋鍓嶄换鍔′笉鍙墽琛屽畬缁撴搷浣滐紒锛�");
+            throw new CoolException("浠诲姟涓嶅瓨鍦紒锛�");
+        }
+
+        // 鏍规嵁鍓嶇閫昏緫鍒ゆ柇鏄惁鍏佽瀹屾垚锛�
+        // 鍓嶇鏉′欢锛�((taskStatus < 98) || (taskType >= 101 && taskStatus < 198)) || (taskType == 11 && taskStatus == 101)
+        // 1. 浠讳綍浠诲姟鐘舵�� < 98 閮藉彲浠ュ畬鎴�
+        // 2. 鍑哄簱浠诲姟锛坱askType >= 101锛変笖鐘舵�� < 198 鍙互瀹屾垚
+        // 3. 搴撴牸绉昏浇锛坱askType == 11锛変笖鐘舵�� == 101 鍙互瀹屾垚
+        boolean canComplete = false;
+        if (task.getTaskStatus() < TaskStsType.COMPLETE_IN.id) {
+            // 浠讳綍浠诲姟鐘舵�� < 98 閮藉彲浠ュ畬鎴�
+            canComplete = true;
+        } else if (task.getTaskType() >= 101 && task.getTaskStatus() < TaskStsType.COMPLETE_OUT.id) {
+            // 鍑哄簱浠诲姟涓旂姸鎬� < 198
+            canComplete = true;
+        } else if (task.getTaskType().equals(TaskType.TASK_TYPE_LOC_MOVE.type) 
+                && task.getTaskStatus().equals(TaskStsType.GENERATE_OUT.id)) {
+            // 搴撴牸绉昏浇涓旂姸鎬� == 101
+            canComplete = true;
+        }
+
+        if (!canComplete) {
+            throw new CoolException("鏁版嵁閿欒锛氬綋鍓嶄换鍔′笉鍙墽琛屽畬缁撴搷浣滐紒锛佷换鍔$被鍨嬶細" + task.getTaskType() + "锛屼换鍔$姸鎬侊細" + task.getTaskStatus());
         }
 
         modiftyTaskSort(task, loginUserId);
-        //
-//        if (task.getTaskType().equals(TaskType.TASK_TYPE_LOC_MOVE.type)) {
-//            task.setTaskStatus(TaskStsType.COMPLETE_OUT.id);
-//        } else {
-        task.setTaskStatus(task.getTaskType() < 100 ? TaskStsType.COMPLETE_IN.id : TaskStsType.AWAIT.id);
-//        }
+        
+        // 濡傛灉浠诲姟鐘舵�佸凡缁忔槸AWAIT (196)锛屽啀娆$偣鍑诲畬缁撴椂锛岀洿鎺ュ畬鎴�
+        if (task.getTaskStatus().equals(TaskStsType.AWAIT.id)) {
+            // AWAIT鐘舵�佺殑浠诲姟鍐嶆瀹岀粨锛岀洿鎺ヨ缃负鍑哄簱瀹屾垚
+            task.setTaskStatus(TaskStsType.COMPLETE_OUT.id);
+            
+            // 鏇存柊鍑哄簱绔欑偣鐘舵�侊紙涓嶳CS閫氱煡瀹岀粨淇濇寔涓�鑷达級
+            if (task.getTaskType() >= TaskType.TASK_TYPE_OUT.type && StringUtils.isNotBlank(task.getTargSite())) {
+                BasStation station = basStationService.getOne(new LambdaQueryWrapper<BasStation>()
+                        .eq(BasStation::getStationName, task.getTargSite()));
+                if (Objects.nonNull(station) && station.getType().equals(StationTypeEnum.STATION_TYPE_NORMAL.type)) {
+                    station.setUseStatus(LocStsType.LOC_STS_TYPE_F.type);
+                    if (!basStationService.updateById(station)) {
+                        throw new CoolException("鍑哄簱绔欑偣鐘舵�佷慨鏀瑰け璐ワ紒锛�");
+                    }
+                }
+            }
+        } else {
+            // 鍏朵粬鎯呭喌鎸夊師鏈夐�昏緫澶勭悊
+            // 鍏ュ簱浠诲姟锛坱askType < 100锛夛細璁剧疆涓哄叆搴撳畬鎴�
+            // 鍑哄簱浠诲姟锛坱askType >= 100锛夛細璁剧疆涓虹瓑寰呯‘璁�
+            Integer newStatus = task.getTaskType() < 100 ? TaskStsType.COMPLETE_IN.id : TaskStsType.AWAIT.id;
+            task.setTaskStatus(newStatus);
+            
+            // 濡傛灉鏄叆搴撲换鍔″畬鎴愶紝鏇存柊鍏ュ簱绔欑偣鐘舵�侊紙涓嶳CS閫氱煡瀹岀粨淇濇寔涓�鑷达級
+            if (newStatus.equals(TaskStsType.COMPLETE_IN.id) && StringUtils.isNotBlank(task.getOrgSite())) {
+                BasStation station = basStationService.getOne(new LambdaQueryWrapper<BasStation>()
+                        .eq(BasStation::getStationName, task.getOrgSite()));
+                if (Objects.nonNull(station) && station.getType().equals(StationTypeEnum.STATION_TYPE_NORMAL.type)) {
+                    station.setUseStatus(LocStsType.LOC_STS_TYPE_O.type);
+                    if (!basStationService.updateById(station)) {
+                        throw new CoolException("鍏ュ簱绔欑偣鐘舵�佷慨鏀瑰け璐ワ紒锛�");
+                    }
+                }
+            }
+        }
+        
         if (!this.updateById(task)) {
             throw new CoolException("瀹屾垚浠诲姟澶辫触");
         }
+        return task;
+    }
+
+    /**
+     * 鍏ㄧ増鍑哄簱瀹岀粨锛氭墸闄ゅ簱浣嶆暟閲忥紝灏嗗簱浣嶇姸鎬佽涓虹┖
+     *
+     * @param id 浠诲姟ID
+     * @param loginUserId 鐧诲綍鐢ㄦ埛ID
+     * @return 浠诲姟瀵硅薄
+     */
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public Task completeFullOutStock(Long id, Long loginUserId) {
+        // 鏌ヨ浠诲姟
+        Task task = taskService.getOne(new LambdaQueryWrapper<Task>()
+                .eq(Task::getId, id));
+
+        if (Objects.isNull(task)) {
+            throw new CoolException("浠诲姟涓嶅瓨鍦紒锛�");
+        }
+
+        // 妫�鏌ヤ换鍔$被鍨嬫槸鍚︿负鍏ㄧ増鍑哄簱
+        if (!task.getTaskType().equals(TaskType.TASK_TYPE_OUT.type)) {
+            throw new CoolException("褰撳墠浠诲姟涓嶆槸鍏ㄧ増鍑哄簱浠诲姟锛屾棤娉曟墽琛屾鎿嶄綔锛侊紒");
+        }
+
+        // 妫�鏌ヤ换鍔$姸鎬侊細蹇呴』鏄�199锛圵AVE_SEED锛夌姸鎬佹墠鑳芥墜鍔ㄥ畬缁�
+        if (!task.getTaskStatus().equals(TaskStsType.WAVE_SEED.id)) {
+            throw new CoolException("浠诲姟鐘舵�佷笉鏄瓑寰呯‘璁ょ姸鎬侊紙199锛夛紝鏃犳硶鎵ц姝ゆ搷浣滐紒锛佸綋鍓嶇姸鎬侊細" + task.getTaskStatus());
+        }
+
+        // 鏌ヨ搴撲綅
+        Loc loc = locService.getOne(new LambdaQueryWrapper<Loc>().eq(Loc::getCode, task.getOrgLoc()));
+        if (Objects.isNull(loc)) {
+            throw new CoolException("搴撲綅涓嶅瓨鍦紒锛�");
+        }
+
+        // 鍒犻櫎搴撲綅鏄庣粏锛堟墸闄ゆ暟閲忥級
+        try {
+            subtractLocItem(loc);
+        } catch (Exception e) {
+            logger.error("鍒犻櫎搴撲綅鏄庣粏澶辫触", e);
+            throw new CoolException("鍒犻櫎搴撲綅鏄庣粏澶辫触锛�" + e.getMessage());
+        }
+
+        // 鍒犻櫎浣滀笟涓簱瀛樿褰曪紙LocItemWorking锛�
+        locItemWorkingService.remove(new LambdaQueryWrapper<LocItemWorking>()
+                .eq(LocItemWorking::getTaskId, task.getId()));
+
+        // 灏嗗簱浣嶇姸鎬佽涓虹┖锛圤鐘舵�侊級
+        if (!locService.update(new LambdaUpdateWrapper<Loc>()
+                .set(Loc::getBarcode, null)
+                .set(Loc::getUseStatus, LocStsType.LOC_STS_TYPE_O.type)
+                .set(Loc::getUpdateBy, loginUserId)
+                .set(Loc::getUpdateTime, new Date())
+                .eq(Loc::getCode, task.getOrgLoc()))) {
+            throw new CoolException("搴撲綅鐘舵�佷慨鏀瑰け璐ワ紒锛�");
+        }
+
+        // 鏇存柊鍑哄簱绔欑偣鐘舵�侊紙濡傛灉鏈夌洰鏍囩珯鐐癸級
+        if (StringUtils.isNotBlank(task.getTargSite())) {
+            BasStation station = basStationService.getOne(new LambdaQueryWrapper<BasStation>()
+                    .eq(BasStation::getStationName, task.getTargSite()));
+            if (Objects.nonNull(station) && station.getType().equals(StationTypeEnum.STATION_TYPE_NORMAL.type)) {
+                station.setUseStatus(LocStsType.LOC_STS_TYPE_F.type);
+                if (!basStationService.updateById(station)) {
+                    throw new CoolException("鍑哄簱绔欑偣鐘舵�佷慨鏀瑰け璐ワ紒锛�");
+                }
+            }
+        }
+
+        // 鏇存柊浠诲姟鐘舵�佷负搴撳瓨鏇存柊瀹屾垚锛�200锛�
+        task.setTaskStatus(TaskStsType.UPDATED_OUT.id)
+                .setUpdateBy(loginUserId)
+                .setUpdateTime(new Date());
+
+        if (!this.updateById(task)) {
+            throw new CoolException("浠诲姟鐘舵�佹洿鏂板け璐ワ紒锛�");
+        }
+
         return task;
     }
 
@@ -733,7 +865,7 @@
             LocItem locItem = new LocItem();
             LocItemWorking locWorking = locItemWorkingService.getOne(new LambdaQueryWrapper<LocItemWorking>()
                     .eq(LocItemWorking::getTaskId, taskItem.getTaskId())
-                    .eq(LocItemWorking::getFieldsIndex, taskItem.getFieldsIndex())
+                    .eq(StringUtils.isNotBlank(taskItem.getFieldsIndex()), LocItemWorking::getFieldsIndex, taskItem.getFieldsIndex())
                     .eq(StringUtils.isNotEmpty(taskItem.getBatch()), LocItemWorking::getBatch, taskItem.getBatch())
                     .eq(LocItemWorking::getMatnrId, taskItem.getMatnrId()));
             if (Objects.isNull(locWorking)) {
@@ -1165,17 +1297,27 @@
 
         tempLocs.forEach(working -> {
             taskItems.forEach(taskItem -> {
-                if (taskItem.getFieldsIndex().equals(working.getFieldsIndex())) {
+                if (Objects.equals(taskItem.getFieldsIndex(), working.getFieldsIndex())) {
                     Double minQty = taskItem.getAnfme();
                     if (!task.getTaskType().equals(TaskType.TASK_TYPE_CHECK_IN.type)) {
+                        // 璁$畻鍓╀綑鏁伴噺锛氫粠LocItemWorking涓噺鍘籘askItem鐨勬嫞鏂欐暟閲�
                         minQty = Math.round((working.getAnfme() - taskItem.getQty()) * 1000000) / 1000000.0;
                     }
                     if (minQty.compareTo(0.0) >= 0) {
+                        // 鏇存柊TaskItem鐨勫墿浣欐暟閲�
                         taskItem.setAnfme(minQty);
                         if (!taskItemService.updateById(taskItem)) {
                             throw new CoolException("浠诲姟鏄庣粏淇敼澶辫触锛侊紒");
                         }
+                        // 鏇存柊LocItemWorking鐨勫墿浣欐暟閲忥紙闈炵洏鐐瑰叆搴撴椂闇�瑕佹洿鏂帮級
+                        if (!task.getTaskType().equals(TaskType.TASK_TYPE_CHECK_IN.type)) {
+                            working.setAnfme(minQty);
+                            if (!locItemWorkingService.updateById(working)) {
+                                throw new CoolException("浣滀笟搴撳瓨鏁伴噺鏇存柊澶辫触锛侊紒");
+                            }
+                        }
                     } else {
+                        // 鍓╀綑鏁伴噺灏忎簬0锛屽垹闄や换鍔℃槑缁�
                         if (!taskItemService.removeById(taskItem)) {
                             log.error("浠诲姟鏄庣粏淇敼澶辫触锛侊紒");
                         }
@@ -1183,10 +1325,13 @@
                 }
             });
         });
-        List<String> matnrIds = taskItems.stream().map(TaskItem::getFieldsIndex).collect(Collectors.toList());
+        List<String> matnrIds = taskItems.stream()
+                .map(TaskItem::getFieldsIndex)
+                .filter(Objects::nonNull)
+                .collect(Collectors.toList());
         //鍒犻櫎涓庝换鍔℃槑缁嗛噸澶嶇殑搴撳瓨淇℃伅锛屼互浠诲姟鏄庣粏涓哄噯
         List<LocItemWorking> itemWorkings = tempLocs.stream()
-                .filter(working -> !matnrIds.contains(working.getFieldsIndex()))
+                .filter(working -> working.getFieldsIndex() != null && !matnrIds.contains(working.getFieldsIndex()))
                 .collect(Collectors.toList());
         itemWorkings.forEach(working -> {
             TaskItem taskItem = taskItems.stream().findFirst().get();
@@ -1254,42 +1399,67 @@
         if (Objects.isNull(loc)) {
             throw new CoolException("搴撲綅涓嶅瓨鍦紒锛�");
         }
-        if (!loc.getUseStatus().equals(LocStsType.LOC_STS_TYPE_R.type)) {
-            throw new CoolException("搴撲綅鐘舵�佷笉澶勭悊浜嶳.鍑哄簱棰勭害锛侊紒");
-        }
-
+        
         List<TaskItem> taskItems = taskItemService.list(new LambdaQueryWrapper<TaskItem>().eq(TaskItem::getTaskId, task.getId()));
         if (taskItems.isEmpty()) {
             throw new CoolException("浠诲姟鏄庣粏涓嶅瓨鍦紒锛�");
         }
 
         List<LocItem> locItems = locItemService.list(new LambdaQueryWrapper<LocItem>().eq(LocItem::getLocId, loc.getId()));
-        if (locItems.isEmpty()) {
-            throw new CoolException("搴撲綅鏄庣粏涓嶅瓨鍦紒锛�");
+        
+        // 濡傛灉搴撲綅鐘舵�佷笉鏄疪锛屾鏌ユ槸鍚﹀凡缁忓鐞嗚繃
+        if (!loc.getUseStatus().equals(LocStsType.LOC_STS_TYPE_R.type)) {
+            // 濡傛灉搴撲綅鏄庣粏涓虹┖锛岃鏄庡凡缁忓鐞嗚繃浜嗭紝鐩存帴鏇存柊浠诲姟鐘舵�佷负199
+            if (locItems.isEmpty()) {
+                logger.warn("浠诲姟{}鐨勫簱浣峽}鐘舵�佷负{}锛屼絾搴撲綅鏄庣粏涓虹┖锛屽彲鑳藉凡缁忓鐞嗚繃锛岀洿鎺ユ洿鏂颁换鍔$姸鎬佷负199", 
+                        task.getId(), loc.getCode(), loc.getUseStatus());
+                if (!this.update(new LambdaUpdateWrapper<Task>()
+                        .eq(Task::getId, task.getId())
+                        .set(Task::getUpdateBy, loginUserId)
+                        .set(Task::getUpdateTime, new Date())
+                        .set(Task::getTaskStatus, TaskStsType.WAVE_SEED.id))) {
+                    throw new CoolException("浠诲姟鐘舵�佹洿鏂板け璐ワ紒锛�");
+                }
+                return; // 璺宠繃鍚庣画澶勭悊
+            } else {
+                // 搴撲綅鏄庣粏涓嶄负绌轰絾鐘舵�佷笉鏄疪锛岃褰曢敊璇絾涓嶆姏鍑哄紓甯革紝璁╁畾鏃朵换鍔$户缁鐞嗗叾浠栦换鍔�
+                logger.error("浠诲姟{}鐨勫簱浣峽}鐘舵�佷负{}锛屼笉鏄疪.鍑哄簱棰勭害鐘舵�侊紝浣嗗簱浣嶆槑缁嗕笉涓虹┖锛岃烦杩囧鐞嗐�備换鍔$紪鐮侊細{}锛屽簱浣嶇紪鐮侊細{}", 
+                        task.getId(), loc.getCode(), loc.getUseStatus(), task.getTaskCode(), loc.getCode());
+                return; // 璺宠繃澶勭悊锛岄伩鍏嶅紓甯镐腑鏂畾鏃朵换鍔�
+            }
         }
+        
+        // 濡傛灉搴撲綅鏄庣粏涓虹┖锛屽彲鑳芥槸宸茬粡琚鐞嗚繃浜嗭紝鍏佽缁х画鎵ц
+        if (!locItems.isEmpty()) {
+            List<LocItemWorking> workings = new ArrayList<>();
+            for (LocItem item : locItems) {
+                LocItemWorking working = new LocItemWorking();
+                BeanUtils.copyProperties(item, working);
+                working.setId(null)
+                        .setTaskId(task.getId())
+                        .setLocItemId(item.getId())
+                        .setUpdateBy(loginUserId)
+                        .setUpdateTime(new Date());
+                workings.add(working);
+            }
 
-        List<LocItemWorking> workings = new ArrayList<>();
-        for (LocItem item : locItems) {
-            LocItemWorking working = new LocItemWorking();
-            BeanUtils.copyProperties(item, working);
-            working.setId(null)
-                    .setTaskId(task.getId())
-                    .setLocItemId(item.getId())
-                    .setUpdateBy(loginUserId)
-                    .setUpdateTime(new Date());
-            workings.add(working);
-        }
+            if (!workings.isEmpty() && !locItemWorkingService.saveBatch(workings)) {
+                throw new CoolException("涓存椂搴撳瓨淇濆瓨澶辫触锛侊紒");
+            }
 
-        if (!locItemWorkingService.saveBatch(workings)) {
-            throw new CoolException("涓存椂搴撳瓨淇濆瓨澶辫触锛侊紒");
-        }
-
-        try {
-            //鏇存柊搴撲綅鏄庣粏
-            subtractLocItem(loc);
-        } catch (Exception e) {
-            logger.error("<UNK>", e);
-            throw new CoolException(e.getMessage());
+            try {
+                // 鏍规嵁浠诲姟绫诲瀷鏇存柊搴撲綅鏄庣粏
+                if (task.getTaskType().equals(TaskType.TASK_TYPE_OUT.type)) {
+                    // 鍏ㄧ増鍑哄簱锛氬垹闄ゆ墍鏈夊簱浣嶆槑缁�
+                    subtractLocItem(loc);
+                } else {
+                    // 閮ㄥ垎鍑哄簱锛堝鎷f枡鍑哄簱锛夛細鏍规嵁TaskItem鏁伴噺鎵e噺搴撲綅鏄庣粏
+                    subtractLocItemByTaskItems(loc, taskItems, loginUserId);
+                }
+            } catch (Exception e) {
+                logger.error("<UNK>", e);
+                throw new CoolException(e.getMessage());
+            }
         }
 
         //娣诲姞鍑哄叆搴撹褰曚俊鎭�
@@ -1840,13 +2010,49 @@
     /**
      * @author Ryan
      * @date 2025/5/20
-     * @description: 鎵e噺搴撳瓨鏄庣粏
+     * @description: 鎵e噺搴撳瓨鏄庣粏锛堝叏鐗堝嚭搴擄細鍒犻櫎鎵�鏈夊簱浣嶆槑缁嗭級
      * @version 1.0
      */
     @Transactional(rollbackFor = Exception.class)
     public void subtractLocItem(Loc loc) throws Exception {
-        if (!locItemService.remove(new LambdaQueryWrapper<LocItem>().eq(LocItem::getLocId, loc.getId()))) {
-            throw new CoolException("搴撳瓨鏄庣粏鍒犻櫎澶辫触锛侊紒");
+        // 鍒犻櫎搴撲綅鏄庣粏锛屽鏋滄病鏈夎褰曞垯蹇界暐锛堝彲鑳藉凡缁忚鍒犻櫎杩囦簡锛�
+        locItemService.remove(new LambdaQueryWrapper<LocItem>().eq(LocItem::getLocId, loc.getId()));
+    }
+
+    /**
+     * 鏍规嵁浠诲姟鏄庣粏鎵e噺搴撲綅鏄庣粏鏁伴噺锛堥儴鍒嗗嚭搴擄級
+     *
+     * @param loc 搴撲綅
+     * @param taskItems 浠诲姟鏄庣粏鍒楄〃
+     * @param loginUserId 鐧诲綍鐢ㄦ埛ID
+     */
+    @Transactional(rollbackFor = Exception.class)
+    public void subtractLocItemByTaskItems(Loc loc, List<TaskItem> taskItems, Long loginUserId) {
+        for (TaskItem taskItem : taskItems) {
+            // 鏌ヨ瀵瑰簲鐨勫簱浣嶆槑缁�
+            LocItem locItem = locItemService.getOne(new LambdaQueryWrapper<LocItem>()
+                    .eq(LocItem::getLocId, loc.getId())
+                    .eq(LocItem::getMatnrId, taskItem.getMatnrId())
+                    .eq(StringUtils.isNotBlank(taskItem.getBatch()), LocItem::getBatch, taskItem.getBatch())
+                    .eq(StringUtils.isNotBlank(taskItem.getFieldsIndex()), LocItem::getFieldsIndex, taskItem.getFieldsIndex()));
+
+            if (Objects.nonNull(locItem)) {
+                // 璁$畻鎵e噺鍚庣殑鏁伴噺
+                Double newAnfme = Math.round((locItem.getAnfme() - taskItem.getQty()) * 1000000) / 1000000.0;
+                
+                if (newAnfme.compareTo(0.0) <= 0) {
+                    // 鏁伴噺灏忎簬绛変簬0锛屽垹闄ゅ簱浣嶆槑缁�
+                    locItemService.removeById(locItem.getId());
+                } else {
+                    // 鏇存柊搴撲綅鏄庣粏鏁伴噺
+                    locItem.setAnfme(newAnfme)
+                            .setUpdateBy(loginUserId)
+                            .setUpdateTime(new Date());
+                    if (!locItemService.updateById(locItem)) {
+                        throw new CoolException("搴撲綅鏄庣粏鏁伴噺鎵e噺澶辫触锛侊紒");
+                    }
+                }
+            }
         }
     }
 
@@ -1982,6 +2188,7 @@
                     .eq(StringUtils.isNotBlank(taskItem.getFieldsIndex()), LocItem::getFieldsIndex, taskItem.getFieldsIndex())
             );
             if (Objects.isNull(locItem)) {
+                // 搴撲綅鏄庣粏涓嶅瓨鍦紝鍒涘缓鏂扮殑搴撲綅鏄庣粏
                 BeanUtils.copyProperties(taskItem, item);
                 item.setLocCode(loc.getCode())
                         .setId(null)
@@ -1993,13 +2200,14 @@
                     throw new CoolException("搴撲綅鏄庣粏鏇存柊澶辫触锛侊紒");
                 }
             } else {
-//                logger.error("褰撳墠绁ㄥ彿:"  + locItem.getFieldsIndex()  + " 宸插湪搴撳唴锛岃妫�鏌ュ悗鍐嶆搷浣滐紒锛�");
-//                throw new CoolException("褰撳墠绁ㄥ彿宸插湪搴撳唴锛岃妫�鏌ュ悗鍐嶆搷浣滐紒锛�");
-//                locItem.setAnfme(Math.round((locItem.getAnfme() + taskItem.getAnfme()) * 1000000) / 1000000.0)
-//                        .setUpdateTime(new Date());
-//                if (!locItemService.saveOrUpdate(locItem)) {
-//                    throw new CoolException("搴撲綅鏄庣粏鏇存柊澶辫触锛侊紒");
-//                }
+                // 搴撲綅鏄庣粏宸插瓨鍦紝绱姞鏁伴噺
+                Double newAnfme = Math.round((locItem.getAnfme() + taskItem.getAnfme()) * 1000000) / 1000000.0;
+                locItem.setAnfme(newAnfme)
+                        .setUpdateBy(loginUserId)
+                        .setUpdateTime(new Date());
+                if (!locItemService.updateById(locItem)) {
+                    throw new CoolException("搴撲綅鏄庣粏鏁伴噺鏇存柊澶辫触锛侊紒");
+                }
             }
         });
 

--
Gitblit v1.9.1