From 70ea74cfb981f812bfa4e3ef91843c5ad93f7b27 Mon Sep 17 00:00:00 2001
From: gaoluyang <2820782392@qq.com>
Date: 星期三, 04 十一月 2026 17:32:49 +0800
Subject: [PATCH] feat(erp): 采购台账改造与采购退货增强

---
 yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/controller/admin/wm/returnvendor/MesWmReturnVendorController.java |   84 +++++++++++++++++++++++++++++++++++++++--
 1 files changed, 79 insertions(+), 5 deletions(-)

diff --git a/yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/controller/admin/wm/returnvendor/MesWmReturnVendorController.java b/yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/controller/admin/wm/returnvendor/MesWmReturnVendorController.java
index 839444e..560f754 100644
--- a/yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/controller/admin/wm/returnvendor/MesWmReturnVendorController.java
+++ b/yudao-module-mes/src/main/java/cn/iocoder/yudao/module/mes/controller/admin/wm/returnvendor/MesWmReturnVendorController.java
@@ -13,8 +13,16 @@
 import cn.iocoder.yudao.module.mes.controller.admin.wm.returnvendor.vo.MesWmReturnVendorSaveReqVO;
 import cn.iocoder.yudao.module.srm.api.supplier.SrmSupplierApi;
 import cn.iocoder.yudao.module.srm.api.supplier.dto.SrmSupplierRespDTO;
+import cn.iocoder.yudao.module.erp.api.finance.ErpFinancePaymentApi;
+import cn.iocoder.yudao.module.erp.api.finance.dto.ErpFinancePaymentRespDTO;
+import cn.iocoder.yudao.module.mes.dal.dataobject.wm.arrivalnotice.MesWmArrivalNoticeDO;
 import cn.iocoder.yudao.module.mes.dal.dataobject.wm.returnvendor.MesWmReturnVendorDO;
+import cn.iocoder.yudao.module.mes.enums.wm.MesWmReturnVendorStatusEnum;
+import cn.iocoder.yudao.module.mes.service.wm.arrivalnotice.MesWmArrivalNoticeService;
 import cn.iocoder.yudao.module.mes.service.wm.returnvendor.MesWmReturnVendorService;
+import cn.iocoder.yudao.module.mes.service.wm.returnvendor.MesWmReturnVendorServiceImpl;
+import cn.iocoder.yudao.module.system.api.storage.StorageAttachmentApi;
+import cn.iocoder.yudao.module.system.api.storage.dto.StorageBlobRespDTO;
 import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.Parameter;
 import io.swagger.v3.oas.annotations.tags.Tag;
@@ -26,6 +34,7 @@
 import org.springframework.web.bind.annotation.*;
 
 import java.io.IOException;
+import java.util.Arrays;
 import java.util.Collections;
 import java.util.List;
 import java.util.Map;
@@ -44,6 +53,12 @@
     private MesWmReturnVendorService returnVendorService;
     @Resource
     private SrmSupplierApi srmSupplierApi;
+    @Resource
+    private StorageAttachmentApi storageAttachmentApi;
+    @Resource
+    private ErpFinancePaymentApi financePaymentApi;
+    @Resource
+    private MesWmArrivalNoticeService arrivalNoticeService;
 
     @PostMapping("/create")
     @Operation(summary = "鍒涘缓渚涘簲鍟嗛��璐у崟")
@@ -109,6 +124,41 @@
         return success(true);
     }
 
+    @PutMapping("/submit-approval")
+    @Operation(summary = "鎻愪氦渚涘簲鍟嗛��璐у崟瀹℃壒", description = "璧� BPM 娴佺▼锛氶噰璐� -> 璐ㄩ噺 -> 浠撳簱")
+    @Parameter(name = "id", description = "缂栧彿", required = true)
+    @Parameter(name = "processDefinitionKey", description = "娴佺▼瀹氫箟 Key", required = true, example = "purchase_return_vendor_approve")
+    @PreAuthorize("@ss.hasPermission('mes:wm-return-vendor:submit-approval')")
+    public CommonResult<Boolean> submitReturnVendorApproval(@RequestParam("id") Long id,
+                                                            @RequestParam("processDefinitionKey") String processDefinitionKey) {
+        returnVendorService.submitReturnVendorApproval(id, processDefinitionKey);
+        return success(true);
+    }
+
+    @GetMapping("/attachments")
+    @Operation(summary = "鑾峰緱渚涘簲鍟嗛��璐у崟闄勪欢鍒楄〃")
+    @Parameter(name = "id", description = "缂栧彿", required = true)
+    public CommonResult<List<StorageBlobRespDTO>> getReturnVendorAttachments(@RequestParam("id") Long id) {
+        return success(storageAttachmentApi.listAttachments(
+                MesWmReturnVendorServiceImpl.RETURN_VENDOR_RECORD_TYPE, id));
+    }
+
+    @PostMapping("/red-flush")
+    @Operation(summary = "鐢熸垚閲囪喘閫�璐ц礋鏁板啿绾粯娆惧崟", description = "骞傜瓑锛氬凡鐢熸垚鍒欑洿鎺ヨ繑鍥炲凡鏈夊啿绾㈠崟缂栧彿")
+    @Parameter(name = "id", description = "缂栧彿", required = true)
+    @PreAuthorize("@ss.hasPermission('mes:wm-return-vendor:finish')")
+    public CommonResult<Long> createRedFlushPayment(@RequestParam("id") Long id) {
+        return success(returnVendorService.createRedFlushPayment(id));
+    }
+
+    @PostMapping("/replacement-notice")
+    @Operation(summary = "鐢熸垚鎹㈣揣鍒拌揣閫氱煡鍗�", description = "骞傜瓑锛氬凡鐢熸垚鍒欑洿鎺ヨ繑鍥炲凡鏈夊埌璐ч�氱煡鍗曠紪鍙�")
+    @Parameter(name = "id", description = "缂栧彿", required = true)
+    @PreAuthorize("@ss.hasPermission('mes:wm-return-vendor:finish')")
+    public CommonResult<Long> createReplacementNotice(@RequestParam("id") Long id) {
+        return success(returnVendorService.createReplacementNotice(id));
+    }
+
     @PutMapping("/stock")
     @Operation(summary = "鎵ц鎷h揣")
     @Parameter(name = "id", description = "缂栧彿", required = true)
@@ -162,11 +212,35 @@
                 convertSet(list, MesWmReturnVendorDO::getVendorId)).getCheckedData().stream()
                 .collect(java.util.stream.Collectors.toMap(SrmSupplierRespDTO::getId, s -> s));
         // 2. 鏋勫缓缁撴灉
-        return BeanUtils.toBean(list, MesWmReturnVendorRespVO.class, vo ->
-                MapUtils.findAndThen(vendorMap, vo.getVendorId(), vendor -> {
-                    vo.setVendorName(vendor.getName());
-                    vo.setVendorCode(vendor.getCode());
-                }));
+        return BeanUtils.toBean(list, MesWmReturnVendorRespVO.class, vo -> {
+            MapUtils.findAndThen(vendorMap, vo.getVendorId(), vendor -> {
+                vo.setVendorName(vendor.getName());
+                vo.setVendorCode(vendor.getCode());
+            });
+            vo.setStatusName(resolveStatusName(vo.getStatus()));
+            vo.setAttachmentList(storageAttachmentApi.listAttachments(
+                    MesWmReturnVendorServiceImpl.RETURN_VENDOR_RECORD_TYPE, vo.getId()));
+            // 鍐茬孩鍗曞彿 / 鎹㈣揣鍒拌揣鍗曞彿锛堜粎鍦ㄥ凡鐢熸垚鏃舵煡璇級
+            if (vo.getRedFlushPaymentId() != null) {
+                ErpFinancePaymentRespDTO payment = financePaymentApi
+                        .getFinancePayment(vo.getRedFlushPaymentId()).getCheckedData();
+                if (payment != null) {
+                    vo.setRedFlushPaymentNo(payment.getNo());
+                }
+            }
+            if (vo.getReplacementNoticeId() != null) {
+                MesWmArrivalNoticeDO notice = arrivalNoticeService.getArrivalNotice(vo.getReplacementNoticeId());
+                if (notice != null) {
+                    vo.setReplacementNoticeCode(notice.getCode());
+                }
+            }
+        });
+    }
+
+    private String resolveStatusName(Integer status) {
+        MesWmReturnVendorStatusEnum statusEnum = Arrays.stream(MesWmReturnVendorStatusEnum.values())
+                .filter(item -> item.getStatus().equals(status)).findFirst().orElse(null);
+        return statusEnum != null ? statusEnum.getName() : null;
     }
 
 }

--
Gitblit v1.9.3