From 5b976ae793a2a068427fdb9c7d80fdf4ea6a96a5 Mon Sep 17 00:00:00 2001
From: skyouc
Date: 星期五, 22 八月 2025 15:12:14 +0800
Subject: [PATCH] 盘点功能优化,bug修复

---
 rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/ReceiveMsgServiceImpl.java |   45 ++++++++++++++++++++++++++++++++++++++-------
 1 files changed, 38 insertions(+), 7 deletions(-)

diff --git a/rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/ReceiveMsgServiceImpl.java b/rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/ReceiveMsgServiceImpl.java
index c607f9d..deebdd3 100644
--- a/rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/ReceiveMsgServiceImpl.java
+++ b/rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/ReceiveMsgServiceImpl.java
@@ -9,6 +9,9 @@
 import com.vincent.rsf.framework.common.R;
 import com.vincent.rsf.framework.exception.CoolException;
 import com.vincent.rsf.server.api.controller.erp.params.*;
+import com.vincent.rsf.server.api.controller.erp.params.dto.CheckDiffDto;
+import com.vincent.rsf.server.api.controller.erp.params.dto.TransferInfoDto;
+import com.vincent.rsf.server.api.controller.erp.params.dto.WkOrderDto;
 import com.vincent.rsf.server.common.domain.BaseParam;
 import com.vincent.rsf.server.common.domain.PageParam;
 import com.vincent.rsf.server.manager.controller.dto.LocStockDto;
@@ -16,7 +19,6 @@
 import com.vincent.rsf.server.manager.enums.*;
 import com.vincent.rsf.server.manager.service.*;
 import com.vincent.rsf.server.manager.service.impl.MatnrServiceImpl;
-import com.vincent.rsf.server.manager.service.impl.TransferItemServiceImpl;
 import com.vincent.rsf.server.system.constant.SerialRuleCode;
 import com.vincent.rsf.server.system.entity.Fields;
 import com.vincent.rsf.server.system.service.FieldsItemService;
@@ -24,7 +26,6 @@
 import com.vincent.rsf.server.system.utils.SerialRuleUtils;
 import com.vincent.rsf.server.api.service.ReceiveMsgService;
 import lombok.extern.slf4j.Slf4j;
-import org.apache.poi.ss.formula.functions.T;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
@@ -51,8 +52,6 @@
     @Autowired
     private FieldsService fieldsService;
     @Autowired
-    private FieldsItemService fieldsItemService;
-    @Autowired
     private MatnrGroupService matnrGroupService;
     @Autowired
     private MatnrServiceImpl matnrService;
@@ -66,8 +65,6 @@
     private DeliveryItemService deliveryItemService;
     @Autowired
     private LocService locService;
-    @Autowired
-    private LocItemService locItemService;
     @Autowired
     private WarehouseAreasService warehouseAreasService;
     @Autowired
@@ -84,6 +81,10 @@
     private ReviseLogService reviseLogService;
     @Autowired
     private ReviseLogItemService reviseLogItemService;
+    @Autowired
+    private CheckDiffService checkDiffService;
+    @Autowired
+    private CheckDiffItemService checkDiffItemService;
 
 
     /**
@@ -93,7 +94,7 @@
      * @version 1.0
      */
     @Override
-    @Transactional(rollbackFor = Exception.class)
+    @Transactional(timeout = 60, rollbackFor = Exception.class)
     public boolean syncPurchasee(List<OrderParams> orders) {
         if (orders.isEmpty()) {
             throw new CoolException("鍗曟嵁鍐呭涓嶈兘涓虹┖锛侊紒");
@@ -175,6 +176,7 @@
      * @param matnrs
      */
     @Override
+    @Transactional(timeout = 60, rollbackFor = Exception.class)
     public void syncMatnrs(List<BaseMatParms> matnrs) {
         List<Matnr> syncMatnrs = new ArrayList<>();
         if (!matnrs.isEmpty()) {
@@ -631,4 +633,33 @@
         wkorderDto.setTransfer(transfer).setItems(orderItems);
         return R.ok().add(wkorderDto);
     }
+
+    /**
+     * @author Ryan
+     * @date 2025/8/22
+     * @description: 鐩樼偣宸紓鍗曞悓姝�
+     * @version 1.0
+     */
+    @Override
+    @Transactional(timeout = 60, rollbackFor = Exception.class)
+    public R syncCheckDiffs(SyncCheckDiffParams syncParams) {
+        List<CheckDiff> diffs = checkDiffService.list(new LambdaQueryWrapper<CheckDiff>()
+                .eq(CheckDiff::getExceStatus, CheckDiffExceStatus.CHECK_DIFF_EXCE_STATUS_END.val)
+                .in(CheckDiff::getOrderCode, syncParams.getDiffCode()));
+        if (diffs.isEmpty()) {
+            return R.ok();
+        }
+        List<CheckDiffDto> dtos = new ArrayList<>();
+        diffs.forEach(check -> {
+            CheckDiffDto checkDto = new CheckDiffDto();
+            CheckDiff checkDiff = new CheckDiff();
+            BeanUtils.copyProperties(check, checkDiff);
+            List<CheckDiffItem> items = checkDiffItemService.list(new LambdaQueryWrapper<CheckDiffItem>().eq(CheckDiffItem::getCheckId, check.getId()));
+            checkDto.setItems(items)
+                    .setCheckDiff(checkDiff);
+            dtos.add(checkDto);
+        });
+
+        return R.ok().add(dtos);
+    }
 }

--
Gitblit v1.9.1