From 7591ba21194595cc8d9a1293dfdbfa945bc9948f Mon Sep 17 00:00:00 2001
From: huminmin <mac@MacBook-Pro.local>
Date: 星期一, 17 八月 2026 16:36:54 +0800
Subject: [PATCH] Merge branch 'dev_business' of http://114.132.189.42:9002/r/mom-pro2-after into dev_business

---
 yudao-module-crm/src/main/java/cn/iocoder/yudao/module/crm/controller/admin/business/CrmBusinessController.java |   74 +++++++++++++++++++++++++++++++-----
 1 files changed, 63 insertions(+), 11 deletions(-)

diff --git a/yudao-module-crm/src/main/java/cn/iocoder/yudao/module/crm/controller/admin/business/CrmBusinessController.java b/yudao-module-crm/src/main/java/cn/iocoder/yudao/module/crm/controller/admin/business/CrmBusinessController.java
index 33e8d84..0c51c0e 100644
--- a/yudao-module-crm/src/main/java/cn/iocoder/yudao/module/crm/controller/admin/business/CrmBusinessController.java
+++ b/yudao-module-crm/src/main/java/cn/iocoder/yudao/module/crm/controller/admin/business/CrmBusinessController.java
@@ -14,11 +14,13 @@
 import cn.iocoder.yudao.module.crm.dal.dataobject.business.CrmBusinessStatusDO;
 import cn.iocoder.yudao.module.crm.dal.dataobject.business.CrmBusinessStatusTypeDO;
 import cn.iocoder.yudao.module.crm.dal.dataobject.customer.CrmCustomerDO;
-import cn.iocoder.yudao.module.crm.dal.dataobject.product.CrmProductDO;
 import cn.iocoder.yudao.module.crm.service.business.CrmBusinessService;
 import cn.iocoder.yudao.module.crm.service.business.CrmBusinessStatusService;
 import cn.iocoder.yudao.module.crm.service.customer.CrmCustomerService;
-import cn.iocoder.yudao.module.crm.service.product.CrmProductService;
+import cn.iocoder.yudao.module.mdm.api.item.MdmItemApi;
+import cn.iocoder.yudao.module.mdm.api.item.dto.MdmItemRespDTO;
+import cn.iocoder.yudao.module.mdm.api.unit.MdmUnitMeasureApi;
+import cn.iocoder.yudao.module.mdm.api.unit.dto.MdmUnitMeasureRespDTO;
 import cn.iocoder.yudao.module.system.api.dept.DeptApi;
 import cn.iocoder.yudao.module.system.api.dept.dto.DeptRespDTO;
 import cn.iocoder.yudao.module.system.api.user.AdminUserApi;
@@ -34,9 +36,7 @@
 import org.springframework.web.bind.annotation.*;
 
 import java.io.IOException;
-import java.util.Collections;
-import java.util.List;
-import java.util.Map;
+import java.util.*;
 import java.util.stream.Stream;
 
 import static cn.iocoder.yudao.framework.apilog.core.enums.OperateTypeEnum.EXPORT;
@@ -62,7 +62,9 @@
     @Resource
     private CrmBusinessStatusService businessStatusService;
     @Resource
-    private CrmProductService productService;
+    private MdmItemApi mdmItemApi;
+    @Resource
+    private MdmUnitMeasureApi mdmUnitMeasureApi;
 
     @Resource
     private AdminUserApi adminUserApi;
@@ -117,12 +119,42 @@
         CrmBusinessRespVO businessVO = buildBusinessDetailList(Collections.singletonList(business)).get(0);
         // 鎷兼帴浜у搧椤�
         List<CrmBusinessProductDO> businessProducts = businessService.getBusinessProductListByBusinessId(businessVO.getId());
-        Map<Long, CrmProductDO> productMap = productService.getProductMap(
-                convertSet(businessProducts, CrmBusinessProductDO::getProductId));
+        Map<Long, MdmItemRespDTO> itemMap = mdmItemApi.getItemMap(
+                convertSet(businessProducts, CrmBusinessProductDO::getItemId));
+        // 鏀堕泦鎵�鏈夐渶瑕佹煡璇㈢殑鍗曚綅ID锛堜富鍗曚綅 + 杈呭崟浣�1 + 杈呭崟浣�2锛�
+        Set<Long> unitIds = new HashSet<>();
+        unitIds.addAll(convertSet(businessProducts, CrmBusinessProductDO::getItemUnitId));
+        itemMap.values().forEach(item -> {
+            if (item.getUnitMeasureId2() != null) {
+                unitIds.add(item.getUnitMeasureId2());
+            }
+            if (item.getUnitMeasureId3() != null) {
+                unitIds.add(item.getUnitMeasureId3());
+            }
+        });
+        Map<Long, MdmUnitMeasureRespDTO> unitMap = mdmUnitMeasureApi.getUnitMeasureMap(unitIds);
         businessVO.setProducts(BeanUtils.toBean(businessProducts, CrmBusinessRespVO.Product.class, businessProductVO ->
-                MapUtils.findAndThen(productMap, businessProductVO.getProductId(),
-                        product -> businessProductVO.setProductName(product.getName())
-                                .setProductNo(product.getNo()).setProductUnit(product.getUnit()))));
+                MapUtils.findAndThen(itemMap, businessProductVO.getItemId(),
+                        item -> businessProductVO.setItemName(item.getName())
+                                .setItemCode(item.getCode())
+                                .setBarCode(item.getBarCode())
+                                .setItemSpecification(item.getSpecification()))));
+        // 濉厖鍗曚綅鍚嶇О锛堜富鍗曚綅 + 杈呭崟浣�1 + 杈呭崟浣�2锛�
+        businessVO.getProducts().forEach(product -> {
+            MapUtils.findAndThen(unitMap, product.getItemUnitId(),
+                    unit -> product.setItemUnitName(unit.getName()));
+            // 濉厖杈呭崟浣嶅悕绉�
+            MapUtils.findAndThen(itemMap, product.getItemId(), item -> {
+                if (item.getUnitMeasureId2() != null) {
+                    MapUtils.findAndThen(unitMap, item.getUnitMeasureId2(),
+                            unit -> product.setItemUnitName2(unit.getName()));
+                }
+                if (item.getUnitMeasureId3() != null) {
+                    MapUtils.findAndThen(unitMap, item.getUnitMeasureId3(),
+                            unit -> product.setItemUnitName3(unit.getName()));
+                }
+            });
+        });
         return businessVO;
     }
 
@@ -138,6 +170,26 @@
                         .setCustomerId(business.getCustomerId())));
     }
 
+    @GetMapping("/list-by-customer")
+    @Operation(summary = "鑾峰緱鍟嗘満鍒楄〃锛屽熀浜庢寚瀹氬鎴�")
+    @Parameter(name = "customerId", description = "瀹㈡埛缂栧彿", required = true)
+    @PreAuthorize("@ss.hasPermission('crm:business:query')")
+    public CommonResult<List<CrmBusinessRespVO>> getBusinessListByCustomer(@RequestParam("customerId") Long customerId) {
+        List<CrmBusinessDO> list = businessService.getBusinessListByCustomerId(customerId);
+        return success(convertList(list, business -> // 鍙繑鍥� id銆乶ame 瀛楁
+                new CrmBusinessRespVO().setId(business.getId()).setName(business.getName())
+                        .setCustomerId(business.getCustomerId())));
+    }
+
+    @GetMapping("/list-by-contact")
+    @Operation(summary = "鑾峰緱鍟嗘満鍒楄〃锛屽熀浜庢寚瀹氳仈绯讳汉")
+    @Parameter(name = "contactId", description = "鑱旂郴浜虹紪鍙�", required = true)
+    @PreAuthorize("@ss.hasPermission('crm:business:query')")
+    public CommonResult<List<CrmBusinessRespVO>> getBusinessListByContact(@RequestParam("contactId") Long contactId) {
+        List<CrmBusinessDO> list = businessService.getBusinessListByContact(contactId);
+        return success(buildBusinessDetailList(list));
+    }
+
     @GetMapping("/page")
     @Operation(summary = "鑾峰緱鍟嗘満鍒嗛〉")
     @PreAuthorize("@ss.hasPermission('crm:business:query')")

--
Gitblit v1.9.3