From e5d2c6f2eb8cc33675308d7d33fd4029d5fd2e34 Mon Sep 17 00:00:00 2001
From: skyouc
Date: 星期二, 20 五月 2025 18:42:11 +0800
Subject: [PATCH] 添加全盘出库 修改任务列表,完成按钮显示逻辑

---
 rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/QlyInspectServiceImpl.java |   48 +++++++++++++++++++++++++++++++++++++++++++++++-
 1 files changed, 47 insertions(+), 1 deletions(-)

diff --git a/rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/QlyInspectServiceImpl.java b/rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/QlyInspectServiceImpl.java
index 1ca78d1..bb134c6 100644
--- a/rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/QlyInspectServiceImpl.java
+++ b/rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/QlyInspectServiceImpl.java
@@ -3,6 +3,7 @@
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.vincent.rsf.framework.common.R;
 import com.vincent.rsf.framework.exception.CoolException;
 import com.vincent.rsf.server.manager.controller.params.IsptOrderParam;
@@ -112,7 +113,7 @@
                         .select("asn_id as id, SUM(anfme) anfme, SUM(qty) qty, area_id, area_name, asn_code, asn_id, splr_id, splr_batch")
                         .eq(StringUtils.isNotBlank(code), "asn_code", code)
                         .lambda()
-                        .isNull(WarehouseAreasItem::getIsptResult)
+//                        .isNull(WarehouseAreasItem::getIsptResult)
                         .lt(WarehouseAreasItem::getWorkQty, 1)
                         .lt(WarehouseAreasItem::getQty, 1)
                 .groupBy(WarehouseAreasItem::getAsnCode));
@@ -174,11 +175,17 @@
                 isptItem.setAsnItemId(orderItem.getId())
                         .setIspectId(inspect.getId())
                         .setRcptQty(orderItem.getAnfme())
+                        .setRcptId(orderItem.getId())
+                        .setPlatItemId(orderItem.getPlatItemId())
+                        .setPlatOrderCode(orderItem.getPlatOrderCode())
+                        .setPlatWorkCode(orderItem.getPlatWorkCode())
+                        .setProjectCode(orderItem.getProjectCode())
                         .setAnfme(0.0)
                         .setFieldsIndex(orderItem.getFieldsIndex())
                         .setSplrBatch(orderItem.getSplrBatch())
                         .setSplrName(orderItem.getSplrId$())
                         .setCreateBy(loginUserId)
+                        .setUpdateBy(loginUserId)
                         .setDlyQty(orderItem.getAnfme());
                 items.add(isptItem);
             }
@@ -210,4 +217,43 @@
 
         return this.save(qlyInspect);
     }
+
+    /**
+     * @author Ryan
+     * @date 2025/5/14
+     * @description: 璐ㄦ瀹℃牳纭
+     * @version 1.0
+     */
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public R verifyComplate(Long id) {
+        if (Objects.isNull(id)) {
+            throw new CoolException("鍙傛暟涓嶈兘涓虹┖锛侊紒");
+        }
+        QlyInspect inspect = this.getById(id);
+        if (Objects.isNull(inspect)) {
+            throw new CoolException("璐ㄦ鍗曟嵁涓嶅瓨鍦紒锛�");
+        }
+        inspect.setIsptStatus(QlyIsptStatus.QLY_ISPT_STAS_DONE.val);
+        if (!this.saveOrUpdate(inspect)) {
+            throw new CoolException("鍗曟嵁淇敼澶辫触锛侊紒");
+        }
+        List<QlyIsptItem> items = qlyIsptItemService.selectIsptResult(new LambdaQueryWrapper<QlyIsptItem>().eq(QlyIsptItem::getIspectId, inspect.getId()));
+        if (items.isEmpty()) {
+            throw new CoolException("璐ㄦ鍗曟嵁鏄庣粏涓嶅瓨鍦紒锛�");
+        }
+
+        for (QlyIsptItem isptItem : items) {
+            if (isptItem.getSafeQty().compareTo(0.0) <= 0 && isptItem.getDisQty().compareTo(0.0) <= 0 ) {
+                continue;
+            }
+            WarehouseAreasItem item = warehouseAreasItemService.getById(isptItem.getRcptId());
+            if (Objects.isNull(item)) {
+                throw new CoolException("搴撳瓨鏄庣粏涓嶅瓨鍦紒锛�");
+            }
+            qlyIsptItemService.confirmReceipt(isptItem, item);
+        }
+
+        return R.ok("瀹℃牳瀹屾垚锛侊紒");
+    }
 }

--
Gitblit v1.9.1