From f640ac6b781487c8a88c7715586e03933b7f0d00 Mon Sep 17 00:00:00 2001
From: skyouc
Date: 星期二, 26 八月 2025 16:40:05 +0800
Subject: [PATCH] 单据修改接口优化 单据删除接口优化

---
 rsf-server/src/main/java/com/vincent/rsf/server/api/service/impl/ReceiveMsgServiceImpl.java |  299 +++++++++++++++++++++++++++++++++++++----------------------
 1 files changed, 189 insertions(+), 110 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..acf0704 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,15 +19,19 @@
 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.DictTypeCode;
 import com.vincent.rsf.server.system.constant.SerialRuleCode;
+import com.vincent.rsf.server.system.entity.DictData;
+import com.vincent.rsf.server.system.entity.DictType;
 import com.vincent.rsf.server.system.entity.Fields;
-import com.vincent.rsf.server.system.service.FieldsItemService;
+import com.vincent.rsf.server.system.service.DictDataService;
+import com.vincent.rsf.server.system.service.DictTypeService;
 import com.vincent.rsf.server.system.service.FieldsService;
+import com.vincent.rsf.server.system.service.impl.DictDataServiceImpl;
 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.apache.commons.lang3.StringUtils;
 import org.springframework.beans.BeanUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
@@ -51,8 +58,6 @@
     @Autowired
     private FieldsService fieldsService;
     @Autowired
-    private FieldsItemService fieldsItemService;
-    @Autowired
     private MatnrGroupService matnrGroupService;
     @Autowired
     private MatnrServiceImpl matnrService;
@@ -66,8 +71,6 @@
     private DeliveryItemService deliveryItemService;
     @Autowired
     private LocService locService;
-    @Autowired
-    private LocItemService locItemService;
     @Autowired
     private WarehouseAreasService warehouseAreasService;
     @Autowired
@@ -84,6 +87,14 @@
     private ReviseLogService reviseLogService;
     @Autowired
     private ReviseLogItemService reviseLogItemService;
+    @Autowired
+    private CheckDiffService checkDiffService;
+    @Autowired
+    private CheckDiffItemService checkDiffItemService;
+    @Autowired
+    private DictDataService dictDataService;
+    @Autowired
+    private DictTypeService dictTypeService;
 
 
     /**
@@ -93,7 +104,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 +186,7 @@
      * @param matnrs
      */
     @Override
+    @Transactional(timeout = 60, rollbackFor = Exception.class)
     public void syncMatnrs(List<BaseMatParms> matnrs) {
         List<Matnr> syncMatnrs = new ArrayList<>();
         if (!matnrs.isEmpty()) {
@@ -367,58 +379,49 @@
         return R.ok();
     }
 
-
+    /**
+     * @author Ryan
+     * @date 2025/8/26
+     * @description: 鍗曟嵁鍚屾
+     * @version 1.0
+     */
     @Override
     @Transactional(timeout = 60, rollbackFor = Exception.class)
-    public R syncCheckOrder(SyncOrderParams syncOrders, Long loginUserId) {
-        List<SyncOrdersItem> ordersItems = syncOrders.getItems();
-        Map<String, List<SyncOrdersItem>> listMap = ordersItems.stream().collect(Collectors.groupingBy(SyncOrdersItem::getOrderCode));
-        listMap.keySet().forEach(orderCode -> {
-            WkOrder wkOrder = new WkOrder();
-            String ruleCode = null;
-            if (syncOrders.getType().equals(OrderType.ORDER_CHECK.type)) {
-                ruleCode = SerialRuleUtils.generateRuleCode(SerialRuleCode.SYS_CHECK_RULE_CODE, null);
-            } else if (syncOrders.getType().equals(OrderType.ORDER_IN.type)) {
-                ruleCode = SerialRuleUtils.generateRuleCode(SerialRuleCode.SYS_ASN_ORDER, null);
-            } else if (syncOrders.getType().equals(OrderType.ORDER_OUT.type)) {
-                ruleCode = SerialRuleUtils.generateRuleCode(SerialRuleCode.SYS_OUT_STOCK_CODE, null);
-            } else if (syncOrders.getType().equals(OrderType.ORDER_REVISE.type)) {
-                ruleCode = SerialRuleUtils.generateRuleCode(SerialRuleCode.SYS_LOC_REVISE_CODE, null);
-            } else if (syncOrders.getType().equals(OrderType.ORDER_TRANSFER.type)) {
-                ruleCode = SerialRuleUtils.generateRuleCode(SerialRuleCode.SYS_TRANSFER_ORDER_CODE, null);
-            }
-
-            SyncOrdersItem ordersItem = listMap.get(orderCode).stream().findFirst().get();
-            Double anfmes = listMap.get(orderCode).stream().mapToDouble(SyncOrdersItem::getAnfme).sum();
-            wkOrder.setType(syncOrders.getType())
-                    .setWkType(OrderWorkType.getWorkType(ordersItem.getWkType()))
-                    .setAnfme(anfmes)
-                    .setPoCode(orderCode)
-                    .setPoId(ordersItem.getId())
-                    .setCode(ruleCode)
-                    .setId(null)
-                    .setCreateTime(new Date())
-                    .setUpdateTime(new Date())
-                    .setCreateBy(loginUserId)
-                    .setUpdateBy(loginUserId);
-
-            if (!asnOrderService.save(wkOrder)) {
-                throw new CoolException("鍗曟嵁淇濆瓨澶辫触锛侊紒");
-            }
-
-            listMap.get(orderCode).forEach(order -> {
-                WkOrderItem wkOrderItem = new WkOrderItem();
-                BeanUtils.copyProperties(order, wkOrderItem);
-                wkOrderItem.setOrderCode(wkOrder.getCode())
-                        .setOrderId(wkOrder.getId())
-                        .setId(null);
-
-                if (!asnOrderItemService.save(wkOrderItem)) {
-                    throw new CoolException("鍗曟嵁鏄庣粏淇濆瓨澶辫触锛侊紒");
+    public R syncCheckOrder(List<SyncOrderParams> syncOrders, Long loginUserId) {
+        if (!syncOrders.isEmpty()) {
+            syncOrders.forEach(syncOrder -> {
+                WkOrder wkOrder = new WkOrder();
+                DictData one = dictDataService.getOne(new LambdaQueryWrapper<DictData>().eq(DictData::getDictTypeCode, DictTypeCode.DICT_SYS_BUSINESS_TYPE)
+                        .eq(DictData::getLabel, syncOrder.getWkType()), false);
+                if (Objects.isNull(one)) {
+                    throw new CoolException("鍗曟嵁锛�" + syncOrder.getOrderNo() + ", 涓氬姟绫诲瀷涓嶅瓨鍦紒锛�");
                 }
+                wkOrder.setType(OrderWorkType.getOrderType(syncOrder.getWkType()))
+                        .setWkType(OrderWorkType.getWorkType(syncOrder.getWkType()))
+                        .setAnfme(syncOrder.getAnfme())
+                        .setCode(syncOrder.getOrderNo())
+                        .setArrTime(syncOrder.getArrTime())
+                        .setId(null)
+                        .setCreateTime(new Date())
+                        .setUpdateTime(new Date())
+                        .setCreateBy(loginUserId)
+                        .setUpdateBy(loginUserId);
+                if (!asnOrderService.save(wkOrder)) {
+                    throw new CoolException("鍗曟嵁淇濆瓨澶辫触锛侊紒");
+                }
+                List<SyncOrdersItem> ordersItems = syncOrder.getOrdersItems();
+                ordersItems.forEach(item -> {
+                    WkOrderItem wkOrderItem = new WkOrderItem();
+                    BeanUtils.copyProperties(item, wkOrderItem);
+                    wkOrderItem.setOrderCode(wkOrder.getCode())
+                            .setOrderId(wkOrder.getId())
+                            .setId(null);
+                    if (!asnOrderItemService.save(wkOrderItem)) {
+                        throw new CoolException("鍗曟嵁鏄庣粏淇濆瓨澶辫触锛侊紒");
+                    }
+                });
             });
-        });
-
+        }
         return R.ok();
     }
 
@@ -430,17 +433,17 @@
      */
     @Override
     @Transactional(timeout = 60, rollbackFor = Exception.class)
-    public R syncTransfer(SyncTransferParams transferParams) {
+    public R syncTransfer(SyncTransferParams transferParams, Long loginUserId) {
         Transfer transfer = new Transfer();
         WarehouseAreas warehouseAreas = warehouseAreasService
                 .getOne(new LambdaQueryWrapper<WarehouseAreas>()
-                        .eq(WarehouseAreas::getName, transfer.getOrgAreaName()));
+                        .eq(WarehouseAreas::getName, transferParams.getOrgAreaName()));
         if (Objects.isNull(warehouseAreas)) {
             throw new CoolException("鍘熷簱鍖轰笉瀛樺湪锛侊紒");
         }
 
         WarehouseAreas warehouseAreas1 = warehouseAreasService.getOne(new LambdaQueryWrapper<WarehouseAreas>()
-                .eq(WarehouseAreas::getName, transfer.getTarAreaName()));
+                .eq(WarehouseAreas::getName, transferParams.getTarAreaName()));
         if (Objects.isNull(warehouseAreas1)) {
             throw new CoolException("鐩爣搴撳尯涓嶅瓨鍦紒锛�");
         }
@@ -454,6 +457,11 @@
                 .setTarAreaId(warehouseAreas1.getId())
                 .setTarWareName(warehouseAreas1.getWarehouseId$())
                 .setTarWareId(warehouseAreas1.getWarehouseId())
+                .setCreateBy(loginUserId)
+                .setCreateTime(new Date())
+                .setUpdateTime(new Date())
+                .setUpdateBy(loginUserId)
+                .setCode(SerialRuleUtils.generateRuleCode(SerialRuleCode.SYS_TRANSFER_ORDER_CODE, null))
                 .setSource(OrderSourceType.ORDER_SOURCE_TYPE_ERP.val);
 
         if (!transferService.save(transfer)) {
@@ -469,6 +477,10 @@
             }
             transferItem.setMatnrId(matnr.getId())
                     .setTransferId(transfer.getId())
+                    .setCreateBy(loginUserId)
+                    .setUpdateBy(loginUserId)
+                    .setCreateTime(new Date())
+                    .setUpdateTime(new Date())
                     .setTransferCode(transfer.getCode());
 
             if (!transferItemService.save(transferItem)) {
@@ -487,7 +499,7 @@
      */
     @Override
     @Transactional(timeout = 60, rollbackFor = Exception.class)
-    public R syncLocRevise(SyncLocReviseParams reviseParams) {
+    public R syncLocRevise(SyncLocReviseParams reviseParams, Long loginUserId) {
         LocRevise locRevise = new LocRevise();
         if (Objects.isNull(reviseParams.getAreaName())) {
             throw new CoolException("搴撳尯涓嶈兘涓虹┖锛侊紒");
@@ -498,7 +510,13 @@
         if (Objects.isNull(warehouseAreas)) {
             throw new CoolException("搴撳尯涓嶅瓨鍦紒锛�");
         }
-        locRevise.setAreaName(locRevise.getAreaName())
+
+        locRevise.setAreaName(warehouseAreas.getName())
+                .setType(LocReviseType.getLocRevise(reviseParams.getType()))
+                .setCreateBy(loginUserId)
+                .setUpdateBy(loginUserId)
+                .setCreateTime(new Date())
+                .setUpdateTime(new Date())
                 .setAreaId(warehouseAreas.getId());
         locRevise.setCode(SerialRuleUtils.generateRuleCode(SerialRuleCode.SYS_LOC_REVISE_CODE, null));
 
@@ -506,22 +524,40 @@
             throw new CoolException("搴撳瓨璋冩暣鍗曚繚瀛樺け璐ワ紒锛�");
         }
 
-        reviseParams.getItems().forEach(revise -> {
+        reviseParams.getReviseItems().forEach(revise -> {
             Loc loc = locService.getOne(new LambdaQueryWrapper<Loc>().eq(Loc::getCode, revise.getLocCode()));
             ReviseLog reviseLog = new ReviseLog();
             BeanUtils.copyProperties(loc, reviseLog);
-            reviseLog.setReviseId(locRevise.getId()).setReviseCode(locRevise.getCode());
+            reviseLog.setReviseId(locRevise.getId())
+                    .setLocCode(loc.getCode())
+                    .setType(Integer.parseInt(loc.getType()))
+                    .setCreateBy(loginUserId)
+                    .setUpdateBy(loginUserId)
+                    .setCreateTime(new Date())
+                    .setUpdateTime(new Date())
+                    .setReviseCode(locRevise.getCode());
             if (!reviseLogService.save(reviseLog)) {
                 throw new CoolException("搴撳瓨璋冩暣鍗曚笉鑳戒负绌猴紒锛�");
             }
             revise.getItems().forEach(reviseItem -> {
                 ReviseLogItem logItem = new ReviseLogItem();
                 BeanUtils.copyProperties(reviseItem, logItem);
+                Matnr matnr = matnrService.getOne(new LambdaQueryWrapper<Matnr>().eq(Matnr::getCode, reviseItem.getMatnrCode()));
+                if (Objects.isNull(matnr)) {
+                    throw new CoolException("鐗╂枡涓嶅瓨鍦紒锛�");
+                }
                 logItem.setLocId(loc.getId())
                         .setLocCode(loc.getCode())
                         .setId(null)
+                        .setMaktx(matnr.getName())
+                        .setMatnrCode(matnr.getCode())
+                        .setMatnrId(matnr.getId())
+                        .setReviseLogId(reviseLog.getId())
+                        .setCreateBy(loginUserId)
+                        .setUpdateBy(loginUserId)
+                        .setCreateTime(new Date())
+                        .setUpdateTime(new Date())
                         .setReviseQty(reviseItem.getAnfme());
-
                 if (!reviseLogItemService.save(logItem)) {
                     throw new CoolException("璋冩暣搴撳瓨鏄庣粏淇濆瓨澶辫触锛侊紒");
                 }
@@ -539,42 +575,46 @@
      */
     @Override
     @Transactional(timeout = 60, rollbackFor = Exception.class)
-    public R syncOrderUpdate(SyncOrderParams orders) {
-        //鍏ュ簱鍗曚慨鏀�
-        if (orders.getType().equals(OrderType.ORDER_IN.type)) {
-            orders.getItems().forEach(orderItem -> {
-                WkOrder order = asnOrderService.getOne(new LambdaQueryWrapper<WkOrder>()
-                        .eq(WkOrder::getType, OrderType.ORDER_IN.type)
-                        .eq(WkOrder::getCode, orderItem.getOrderCode()));
-                if (Objects.isNull(order)) {
-                    throw new CoolException("鍗曟嵁涓嶅瓨鍦紒锛�");
-                }
-
-                if (!asnOrderItemService.update(new LambdaUpdateWrapper<WkOrderItem>()
-                        .eq(WkOrderItem::getOrderCode, orderItem.getOrderCode())
+    public R syncOrderUpdate(List<SyncOrderParams> orders) {
+        orders.forEach(order -> {
+            List<Short> list = Arrays.asList(AsnExceStatus.ASN_EXCE_STATUS_UN_EXCE.val,
+                    AsnExceStatus.OUT_STOCK_STATUS_TASK_INIT.val);
+            WkOrder wkOrder = asnOrderService.getOne(new LambdaQueryWrapper<WkOrder>()
+                    .in(WkOrder::getExceStatus, list)
+                    .eq(WkOrder::getCode, order.getOrderNo()));
+            if (Objects.isNull(wkOrder)) {
+                throw new CoolException("璇风‘璁ゅ崟鎹細" + order.getOrderNo() + "鏄惁宸茬粡鎵ц鎴栨槸鍚﹀悓姝ワ紒锛�");
+            }
+            order.getOrdersItems().forEach(orderItem -> {
+                WkOrderItem wkOrderItem = asnOrderItemService.getOne(new LambdaUpdateWrapper<WkOrderItem>()
                         .eq(WkOrderItem::getMatnrCode, orderItem.getMatnrCode())
-                        .eq(WkOrderItem::getSplrBatch, orderItem.getBatch())
-                        .set(WkOrderItem::getAnfme, orderItem.getAnfme()))) {
-                    throw new CoolException("鍗曟嵁淇敼澶辫触锛侊紒");
-                }
-
-                List<WkOrderItem> orderItems = asnOrderItemService.list(new LambdaQueryWrapper<WkOrderItem>()
-                        .eq(WkOrderItem::getOrderId, order.getId()));
-                if (orderItems.isEmpty()) {
-                    throw new CoolException("鍗曟嵁鏄庣粏涓嶅瓨鍦紒锛�");
-                }
-
-                Double summed = orderItems.stream().mapToDouble(WkOrderItem::getAnfme).sum();
-                order.setAnfme(summed);
-
-                if (!asnOrderService.updateById(order)) {
-                    throw new CoolException("鍗曟嵁淇敼澶辫触锛侊紒");
+                        .eq(StringUtils.isNotEmpty(orderItem.getBatch()), WkOrderItem::getSplrBatch, orderItem.getBatch())
+                        .eq(WkOrderItem::getOrderCode, wkOrder.getCode()));
+                if (!Objects.isNull(wkOrderItem)) {
+                    if (!asnOrderItemService.update(new LambdaUpdateWrapper<WkOrderItem>()
+                            .eq(WkOrderItem::getOrderCode, wkOrder.getCode())
+                            .eq(WkOrderItem::getMatnrCode, orderItem.getMatnrCode())
+                            .eq(StringUtils.isNotEmpty(orderItem.getBatch()), WkOrderItem::getSplrBatch, orderItem.getBatch())
+                            .eq(StringUtils.isNotEmpty(orderItem.getPlatItemId()), WkOrderItem::getPlatItemId, orderItem.getPlatItemId())
+                            .set(WkOrderItem::getAnfme, orderItem.getAnfme()))) {
+                        throw new CoolException("鍗曟嵁淇敼澶辫触锛侊紒");
+                    }
+                } else {
+                    WkOrderItem wkOrderItem1 = new WkOrderItem();
+                    BeanUtils.copyProperties(orderItem, wkOrderItem1);
+                    wkOrderItem1.setOrderCode(wkOrder.getCode())
+                            .setOrderId(wkOrder.getId());
+                    if (!asnOrderItemService.save(wkOrderItem1)) {
+                        throw new CoolException("鍗曟嵁淇濆瓨澶辫触锛侊紒");
+                    }
                 }
             });
-        } else {
-
-        }
-        return null;
+            wkOrder.setAnfme(order.getAnfme());
+            if (!asnOrderService.updateById(wkOrder)) {
+                throw new CoolException("涓诲崟鎹慨鏀瑰け璐ワ紒锛�");
+            }
+        });
+        return R.ok();
     }
 
     /**
@@ -587,24 +627,33 @@
     @Transactional(timeout = 60, rollbackFor = Exception.class)
     public R syncOrderDelete(List<SyncOrderParams> orders) {
         orders.forEach(order -> {
-            order.getItems().forEach(orderItem -> {
-                WkOrder wkOrder = asnOrderService.getOne(new LambdaQueryWrapper<WkOrder>()
-                        .eq(WkOrder::getType, order.getType())
-                        .in(WkOrder::getExceStatus, Arrays.asList(AsnExceStatus.ASN_EXCE_STATUS_UN_EXCE.val, AsnExceStatus.OUT_STOCK_STATUS_TASK_INIT.val))
-                        .eq(WkOrder::getId, orderItem.getOrderId()));
-                if (Objects.isNull(wkOrder)) {
-                    throw new CoolException("璁㈠崟锛�" + orderItem.getOrderCode() + "锛屽綋鍓嶇姸鎬侊紝涓嶅彲鎵ц鍒犻櫎鎿嶄綔锛侊紒");
-                }
+            List<Short> list = Arrays.asList(AsnExceStatus.ASN_EXCE_STATUS_UN_EXCE.val,
+                    AsnExceStatus.OUT_STOCK_STATUS_TASK_INIT.val);
+            WkOrder wkOrder = asnOrderService.getOne(new LambdaQueryWrapper<WkOrder>()
+                    .in(WkOrder::getExceStatus, list)
+                    .eq(WkOrder::getCode, order.getOrderNo()));
+            if (Objects.isNull(wkOrder)) {
+                throw new CoolException("璁㈠崟锛�" + wkOrder.getCode() + "锛屽綋鍓嶇姸鎬侊紝涓嶅彲鎵ц鍒犻櫎鎿嶄綔锛侊紒");
+            }
+            order.getOrdersItems().forEach(orderItem -> {
                 if (!asnOrderItemService.remove(new LambdaQueryWrapper<WkOrderItem>()
-                        .eq(WkOrderItem::getMatnrId, orderItem.getMatnrId())
-                        .eq(WkOrderItem::getSplrBatch, orderItem.getBatch())
-                        .eq(WkOrderItem::getOrderCode, orderItem.getOrderCode()))) {
+                        .eq(WkOrderItem::getMatnrCode, orderItem.getMatnrCode())
+                        .eq(StringUtils.isNotEmpty(orderItem.getBatch()), WkOrderItem::getSplrBatch, orderItem.getBatch())
+                        .eq(StringUtils.isNotEmpty(orderItem.getPlatItemId()), WkOrderItem::getPlatItemId, orderItem.getPlatItemId())
+                        .eq(WkOrderItem::getOrderCode, wkOrder.getCode()))) {
                     throw new CoolException("鍗曟嵁鏄庣粏鍒犻櫎澶辫触锛侊紒");
                 }
-                List<WkOrderItem> orderItems = asnOrderItemService.list(new LambdaQueryWrapper<WkOrderItem>().eq(WkOrderItem::getOrderId, orderItem.getOrderId()));
+                List<WkOrderItem> orderItems = asnOrderItemService.list(new LambdaQueryWrapper<WkOrderItem>().eq(WkOrderItem::getOrderId, wkOrder.getId()));
                 if (orderItems.isEmpty()) {
-                    if (!asnOrderService.removeById(orderItem.getOrderId())) {
+                    if (!asnOrderService.removeById(wkOrder.getId())) {
                         throw new CoolException("鍗曟嵁鍒犻櫎澶辫触锛侊紒");
+                    }
+                } else {
+                    Double sum = orderItems.stream().mapToDouble(WkOrderItem::getAnfme).sum();
+                    if (!asnOrderService.update(new LambdaUpdateWrapper<WkOrder>()
+                            .eq(WkOrder::getId, wkOrder.getId())
+                            .set(WkOrder::getAnfme, sum))) {
+                        throw new CoolException("涓诲崟鏁伴噺淇敼澶辫触锛侊紒");
                     }
                 }
             });
@@ -631,4 +680,34 @@
         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