From d8a4cd4460982dda68b5b7ee21de226e04156807 Mon Sep 17 00:00:00 2001
From: huminmin <mac@MacBook-Pro.local>
Date: 星期六, 28 三月 2026 13:48:09 +0800
Subject: [PATCH] 客户档案增加客户分类
---
src/main/java/com/ruoyi/basic/service/impl/CustomerServiceImpl.java | 78 +++++++++++++++++++++++++++++++++++++--
1 files changed, 74 insertions(+), 4 deletions(-)
diff --git a/src/main/java/com/ruoyi/basic/service/impl/CustomerServiceImpl.java b/src/main/java/com/ruoyi/basic/service/impl/CustomerServiceImpl.java
index 899e21f..521b093 100644
--- a/src/main/java/com/ruoyi/basic/service/impl/CustomerServiceImpl.java
+++ b/src/main/java/com/ruoyi/basic/service/impl/CustomerServiceImpl.java
@@ -17,17 +17,17 @@
import com.ruoyi.framework.web.domain.AjaxResult;
import com.ruoyi.project.system.domain.SysUser;
import com.ruoyi.sales.mapper.SalesLedgerMapper;
+import com.ruoyi.sales.mapper.SalesLedgerProductMapper;
import com.ruoyi.sales.pojo.SalesLedger;
+import com.ruoyi.sales.pojo.SalesLedgerProduct;
import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import org.springframework.util.CollectionUtils;
import org.springframework.web.multipart.MultipartFile;
-import java.util.Arrays;
-import java.util.List;
-import java.util.Map;
-import java.util.Objects;
+import java.math.BigDecimal;
+import java.util.*;
import java.util.stream.Collectors;
@@ -42,6 +42,7 @@
@Slf4j
public class CustomerServiceImpl extends ServiceImpl<CustomerMapper, Customer> implements ICustomerService {
private final SalesLedgerMapper salesLedgerMapper;
+ private final SalesLedgerProductMapper salesLedgerProductMapper;
private CustomerMapper customerMapper;
/**
@@ -74,8 +75,12 @@
// 2. 鏋勫缓鏌ヨ鏉′欢锛堝寮虹┖鍊煎畨鍏級
LambdaQueryWrapper<Customer> queryWrapper = new LambdaQueryWrapper<>();
String customerName = customer.getCustomerName();
+ String customerType = customer.getCustomerType();
if (StringUtils.isNotBlank(customerName)) {
queryWrapper.like(Customer::getCustomerName, customerName);
+ }
+ if (StringUtils.isNotBlank(customerType)) {
+ queryWrapper.like(Customer::getCustomerType, customerType);
}
// 3. 鎵ц鍒嗛〉鏌ヨ锛堜繚鐣欏垎椤靛厓鏁版嵁锛�
@@ -89,6 +94,71 @@
String address = StringUtils.defaultString(c.getCompanyAddress(), "");
String phone = StringUtils.defaultString(c.getCompanyPhone(), "");
c.setAddressPhone(address + "(" + phone + ")"); // 浼樺寲瀛楃涓叉嫾鎺�
+ // 鏌ヨ璇ュ鎴峰叧鑱旂殑閿�鍞彴璐︿腑锛岃喘涔版鏁般�佸钩鍧囬噾棰濄�佹渶杩戣喘涔版椂闂�
+ List<SalesLedger> salesLedgers = salesLedgerMapper.selectList(new QueryWrapper<SalesLedger>().lambda().eq(SalesLedger::getCustomerId, c.getId()));
+ if (!CollectionUtils.isEmpty(salesLedgers)) {
+ // 璁＄畻璐拱娆℃暟
+ int purchaseCount = salesLedgers.size();
+ c.setPurchaseCount(purchaseCount);
+
+ // 璁＄畻骞冲潎閲戦
+ if (purchaseCount > 0) {
+ BigDecimal totalAmount = salesLedgers.stream()
+ .map(SalesLedger::getContractAmount)
+ .filter(Objects::nonNull)
+ .reduce(BigDecimal.ZERO, BigDecimal::add);
+ BigDecimal averageAmount = totalAmount.divide(BigDecimal.valueOf(purchaseCount), 2, BigDecimal.ROUND_HALF_UP);
+ c.setAverageAmount(averageAmount);
+ } else {
+ c.setAverageAmount(BigDecimal.ZERO);
+ }
+
+ // 璁＄畻鏈�杩戣喘涔版椂闂�
+ SalesLedger latestLedger = salesLedgers.stream()
+ .max((l1, l2) -> l1.getExecutionDate().compareTo(l2.getExecutionDate()))
+ .orElse(null);
+ if (latestLedger != null) {
+ c.setLatestPurchaseTime(latestLedger.getExecutionDate());
+ }
+
+ // 璁＄畻甯歌喘浜у搧锛坱op 3锛�
+ List<SalesLedgerProduct> allProducts = new ArrayList<>();
+ for (SalesLedger ledger : salesLedgers) {
+ List<SalesLedgerProduct> products = salesLedgerProductMapper.selectList(
+ new QueryWrapper<SalesLedgerProduct>().lambda()
+ .eq(SalesLedgerProduct::getSalesLedgerId, ledger.getId())
+ );
+ if (!CollectionUtils.isEmpty(products)) {
+ allProducts.addAll(products);
+ }
+ }
+
+ if (!CollectionUtils.isEmpty(allProducts)) {
+ // 鎸変骇鍝佺被鍒拰瑙勬牸鍨嬪彿鍒嗙粍锛岀粺璁¤喘涔版鏁�
+ Map<String, Long> productCountMap = allProducts.stream()
+ .collect(Collectors.groupingBy(
+ p -> p.getProductCategory() + "-" + p.getSpecificationModel(),
+ Collectors.counting()
+ ));
+
+ // 鎺掑簭骞跺彇鍓�3
+ List<String> topProducts = productCountMap.entrySet().stream()
+ .sorted(Map.Entry.<String, Long>comparingByValue().reversed())
+ .limit(3)
+ .map(Map.Entry::getKey)
+ .collect(Collectors.toList());
+
+ c.setTopProducts(topProducts);
+ } else {
+ c.setTopProducts(new ArrayList<>());
+ }
+ } else {
+ // 娌℃湁閿�鍞褰曟椂璁剧疆榛樿鍊�
+ c.setPurchaseCount(0);
+ c.setAverageAmount(BigDecimal.ZERO);
+ c.setLatestPurchaseTime(null);
+ c.setTopProducts(new ArrayList<>());
+ }
})
.collect(Collectors.toList());
--
Gitblit v1.9.3