From c46d1d8c3b9875f051a6ec3c4a1d3fa7bd32e5db Mon Sep 17 00:00:00 2001
From: skyouc
Date: 星期四, 15 五月 2025 17:15:21 +0800
Subject: [PATCH] 新增库存管理 新增库存明细

---
 rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/QlyIsptItemServiceImpl.java |  116 +++++++++++++++++++++++++++++++++++++++++++++++++++++++--
 1 files changed, 111 insertions(+), 5 deletions(-)

diff --git a/rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/QlyIsptItemServiceImpl.java b/rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/QlyIsptItemServiceImpl.java
index cfcbd2c..66440f7 100644
--- a/rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/QlyIsptItemServiceImpl.java
+++ b/rsf-server/src/main/java/com/vincent/rsf/server/manager/service/impl/QlyIsptItemServiceImpl.java
@@ -8,11 +8,9 @@
 import com.vincent.rsf.server.common.domain.BaseParam;
 import com.vincent.rsf.server.common.domain.PageParam;
 import com.vincent.rsf.server.manager.controller.params.IsptItemsParams;
-import com.vincent.rsf.server.manager.entity.QlyInspect;
-import com.vincent.rsf.server.manager.entity.QlyInspectResult;
+import com.vincent.rsf.server.manager.entity.*;
 import com.vincent.rsf.server.manager.enums.QlyIsptResult;
 import com.vincent.rsf.server.manager.mapper.QlyIsptItemMapper;
-import com.vincent.rsf.server.manager.entity.QlyIsptItem;
 import com.vincent.rsf.server.manager.service.AsnOrderItemService;
 import com.vincent.rsf.server.manager.service.QlyInspectResultService;
 import com.vincent.rsf.server.manager.service.QlyInspectService;
@@ -40,6 +38,8 @@
     private QlyInspectResultService qlyInspectResultService;
     @Autowired
     private QlyIsptItemService qlyIsptItemService;
+    @Autowired
+    private WarehouseAreasItemServiceImpl warehouseAreasItemService;
 
     /**
      * @param
@@ -76,6 +76,7 @@
 
             QlyInspectResult result = new QlyInspectResult();
             result.setIsptId(item.getIspectId())
+                    .setRcptId(item.getRcptId())
                     .setIsptItemId(item.getId());
             if (!Objects.isNull(item.getDisQty()) && item.getDisQty().compareTo(0.00) > 0) {
                 result.setAnfme(item.getDisQty())
@@ -85,6 +86,7 @@
 
             result = new QlyInspectResult();
             result.setIsptId(item.getIspectId())
+                    .setRcptId(item.getRcptId())
                     .setIsptItemId(item.getId());
             if (!Objects.isNull(item.getSafeQty()) && item.getSafeQty().compareTo(0.00) > 0) {
                 result.setAnfme(item.getSafeQty())
@@ -104,10 +106,34 @@
                     .eq(QlyIsptItem::getId, item.getId()))) {
                 throw new CoolException("鍗曟嵁鏄庣粏鏁伴噺淇敼澶辫触锛侊紒");
             }
+
+//            WarehouseAreasItem orderItem = warehouseAreasItemService.getById(item.getRcptId());
+//            if (Objects.isNull(orderItem)) {
+//                throw new CoolException("鏀惰揣鍗曟嵁涓嶅瓨鍦紒锛�");
+//            }
+
+//            Double disQty = Objects.isNull(item.getDisQty()) ? 0 : item.getDisQty();
+//            Double safeQty = Objects.isNull(item.getSafeQty()) ? 0 : item.getSafeQty();
+//
+//            Double sum = disQty + safeQty;
+//            orderItem.setIsptQty(sum);
+//
+//            if (sum.compareTo(0.0) > 0) {
+//                if (!warehouseAreasItemService.updateById(orderItem)) {
+//                    throw new CoolException("鏀惰揣鍖哄簱瀛樹俊鎭洿鏂板け璐ワ紒锛�");
+//                }
+//                //鏂板缓璐ㄦ鍗曪紝涓嶄細鏈夎川妫�缁撴灉
+//                confirmReceipt(item, orderItem);
+//
+////                if (Objects.isNull(orderItem.getIsptResult())) {
+////                    operateReceipt(item, orderItem);
+////                }
+//            }
         }
 
         Set<Long> isptIds = isptItem.stream().map(QlyIsptItem::getIspectId).collect(Collectors.toSet());
-        List<QlyInspectResult> items = qlyInspectResultService.list(new LambdaQueryWrapper<QlyInspectResult>().in(QlyInspectResult::getIsptId, isptIds));
+        List<QlyInspectResult> items = qlyInspectResultService.list(new LambdaQueryWrapper<QlyInspectResult>()
+                .in(QlyInspectResult::getIsptId, isptIds));
         Double sum = items.stream().mapToDouble(QlyInspectResult::getAnfme).sum();
         if (sum.compareTo(0.00) > 0) {
             qlyInspectService.update(new LambdaUpdateWrapper<QlyInspect>()
@@ -117,6 +143,76 @@
         }
 
         return true;
+    }
+
+    /**
+     * @author Ryan
+     * @date 2025/5/12
+     * @description: 璐ㄦ鍚庝慨鏀规敹璐у尯瀛樹俊鎭�
+     * @version 1.0
+     */
+    @Transactional(rollbackFor = Exception.class)
+    public void confirmReceipt(QlyIsptItem item, WarehouseAreasItem orderItem) {
+        Double disQty = Objects.isNull(item.getDisQty()) ? 0 : item.getDisQty();
+        Double safeQty = Objects.isNull(item.getSafeQty()) ? 0 : item.getSafeQty();
+        Double sum = disQty + safeQty;
+        if (sum.compareTo(orderItem.getAnfme()) >= 0) {
+            //瀹屾垚璐ㄦ,鍋氭洿鏂版搷浣�
+            if (safeQty.compareTo(0.0) > 0) {
+                orderItem.setIsptQty(safeQty).setAnfme(safeQty);
+                orderItem.setIsptResult(QlyIsptResult.QLY_ISPT_RESULT_EXCELLENT.val);
+                if (!warehouseAreasItemService.updateById(orderItem)) {
+                    throw new CoolException("鏀惰揣鍖哄簱瀛樻槑缁嗘洿鏂板け璐ワ紒锛�");
+                }
+            }
+
+            WarehouseAreasItem areasItem = new WarehouseAreasItem();
+            BeanUtils.copyProperties(orderItem, areasItem);
+            if (disQty.compareTo(0.0) > 0) {
+                areasItem.setIsptQty(disQty)
+                        .setAnfme(disQty)
+                        .setId(null)
+                        .setIsptResult(QlyIsptResult.QLY_ISPT_RESULT_DEFECT.val);
+                if (!warehouseAreasItemService.saveOrUpdate(areasItem)) {
+                    throw new CoolException("鏀惰揣鍖哄簱瀛樻槑缁嗘洿鏂板け璐ワ紒锛�");
+                }
+            }
+        } else {
+            orderItem.setAnfme(orderItem.getAnfme() - sum);
+            if (!warehouseAreasItemService.updateById(orderItem)) {
+                throw new CoolException("鏀惰揣鍖哄簱瀛樻槑缁嗘洿鏂板け璐ワ紒锛�");
+            }
+
+            WarehouseAreasItem areasItem = new WarehouseAreasItem();
+            BeanUtils.copyProperties(orderItem, areasItem);
+            //鏈畬鎴愬仛娣诲姞鎿嶄綔
+            if (safeQty.compareTo(0.0) > 0) {
+                areasItem.setIsptQty(safeQty)
+                        .setAnfme(safeQty)
+                        .setId(null)
+                        .setIsptResult(QlyIsptResult.QLY_ISPT_RESULT_EXCELLENT.val);
+                if (!warehouseAreasItemService.saveOrUpdate(areasItem)) {
+                    throw new CoolException("鏀惰揣鍖哄簱瀛樻槑缁嗘洿鏂板け璐ワ紒锛�");
+                }
+            }
+
+            WarehouseAreasItem items = new WarehouseAreasItem();
+            BeanUtils.copyProperties(orderItem, items);
+            if (disQty.compareTo(0.0) > 0) {
+                items.setIsptQty(disQty)
+                        .setAnfme(disQty)
+                        .setId(null)
+                        .setIsptResult(QlyIsptResult.QLY_ISPT_RESULT_DEFECT.val);
+                if (!warehouseAreasItemService.saveOrUpdate(items)) {
+                    throw new CoolException("鏀惰揣鍖哄簱瀛樻槑缁嗘洿鏂板け璐ワ紒锛�");
+                }
+            }
+        }
+    }
+
+    @Override
+    public List<QlyIsptItem> selectIsptResult(LambdaQueryWrapper<QlyIsptItem> eq) {
+        return this.baseMapper.selectIsptResult(eq);
     }
 
     /**
@@ -132,7 +228,7 @@
             List<QlyIsptItem> records = page.getRecords();
             for (int i = 0; i < records.size(); i++) {
                 List<QlyInspectResult> results = qlyInspectResultService.list(new QueryWrapper<QlyInspectResult>()
-                        .select("id, ispt_result, SUM(anfme) anfme, ispt_item_id, ispt_id")
+                        .select("id, ispt_result, SUM(anfme) anfme, ispt_item_id, ispt_id, rcpt_id")
                         .lambda()
                         .eq(QlyInspectResult::getIsptItemId, records.get(i).getId()).groupBy(QlyInspectResult::getIsptResult));
                 if (!results.isEmpty()) {
@@ -149,4 +245,14 @@
         }
         return page;
     }
+
+    @Override
+    public IPage<QlyIsptItem> pageByIsptResult(PageParam<QlyIsptItem, BaseParam> pageParam, QueryWrapper<QlyIsptItem> queryWrapper) {
+        if (Objects.isNull(pageParam)) {
+            PageParam<QlyIsptItem, BaseParam> param = new PageParam<>();
+            return this.baseMapper.selectPage(param, queryWrapper);
+        } else {
+            return this.baseMapper.pageByWrapper(pageParam, queryWrapper);
+        }
+    }
 }

--
Gitblit v1.9.1