From 7bf754a7835d06f26240c4ca15bc5f83650de377 Mon Sep 17 00:00:00 2001
From: 云 <2163098428@qq.com>
Date: 星期一, 21 九月 2026 20:52:25 +0800
Subject: [PATCH] docs(api): 更新信托基金与代储台账及油品出库相关接口文档
---
src/main/java/com/ruoyi/ai/tools/SalesAgentTools.java | 156 ++++++++++++++-------------------------------------
1 files changed, 43 insertions(+), 113 deletions(-)
diff --git a/src/main/java/com/ruoyi/ai/tools/SalesAgentTools.java b/src/main/java/com/ruoyi/ai/tools/SalesAgentTools.java
index 8a63db7..10b55f9 100644
--- a/src/main/java/com/ruoyi/ai/tools/SalesAgentTools.java
+++ b/src/main/java/com/ruoyi/ai/tools/SalesAgentTools.java
@@ -14,9 +14,11 @@
import com.ruoyi.sales.mapper.SalesLedgerMapper;
import com.ruoyi.sales.mapper.SalesQuotationMapper;
import com.ruoyi.sales.mapper.ShippingInfoMapper;
+import com.ruoyi.sales.mapper.StockOutRecordSalesLedgerMapper;
import com.ruoyi.sales.pojo.SalesLedger;
import com.ruoyi.sales.pojo.SalesQuotation;
import com.ruoyi.sales.pojo.ShippingInfo;
+import com.ruoyi.sales.pojo.StockOutRecordSalesLedger;
import com.ruoyi.stock.mapper.StockOutRecordMapper;
import com.ruoyi.stock.pojo.StockOutRecord;
import dev.langchain4j.agent.tool.P;
@@ -53,6 +55,7 @@
private final ShippingInfoMapper shippingInfoMapper;
private final AccountSalesCollectionMapper accountSalesCollectionMapper;
private final StockOutRecordMapper stockOutRecordMapper;
+ private final StockOutRecordSalesLedgerMapper stockOutRecordSalesLedgerMapper;
private final AiSessionUserContext aiSessionUserContext;
public SalesAgentTools(CustomerMapper customerMapper,
@@ -61,6 +64,7 @@
ShippingInfoMapper shippingInfoMapper,
AccountSalesCollectionMapper accountSalesCollectionMapper,
StockOutRecordMapper stockOutRecordMapper,
+ StockOutRecordSalesLedgerMapper stockOutRecordSalesLedgerMapper,
AiSessionUserContext aiSessionUserContext) {
this.customerMapper = customerMapper;
this.salesLedgerMapper = salesLedgerMapper;
@@ -68,6 +72,7 @@
this.shippingInfoMapper = shippingInfoMapper;
this.accountSalesCollectionMapper = accountSalesCollectionMapper;
this.stockOutRecordMapper = stockOutRecordMapper;
+ this.stockOutRecordSalesLedgerMapper = stockOutRecordSalesLedgerMapper;
this.aiSessionUserContext = aiSessionUserContext;
}
@@ -121,60 +126,6 @@
@P(value = "杩斿洖鏉℃暟锛岄粯璁�10锛屾渶澶�30", required = false) Integer limit) {
LoginUser loginUser = currentLoginUser(memoryId);
DateRange range = resolveDateRange(startDate, endDate, null);
- /*
- List<AccountSalesCollection> collections = queryCollections(loginUser, range);
- if (collections.isEmpty()) {
- return jsonResponse(true, "sales_customer_interaction_list", "閺堫亝鐓＄拠銏犲煂鐎广垺鍩涘鈧弶銉唶瑜�?, rangeSummary(range, 0, keyword), Map.of("items", List.of()), Map.of());
- }
-
- Map<Integer, Set<Long>> ledgerIdsByCollectionId = mapCollectionLedgerIds(loginUser, collections);
- Set<Long> ledgerIds = ledgerIdsByCollectionId.values().stream()
- .flatMap(Collection::stream)
- .collect(Collectors.toSet());
- Map<Long, SalesLedger> ledgerMap = defaultList(salesLedgerMapper.selectBatchIds(ledgerIds)).stream()
- .filter(ledger -> tenantMatched(ledger.getTenantId(), loginUser.getTenantId()))
- .collect(Collectors.toMap(SalesLedger::getId, item -> item, (a, b) -> a, LinkedHashMap::new));
-
- int finalLimit = normalizeLimit(limit);
- List<Map<String, Object>> items = new ArrayList<>();
- for (AccountSalesCollection collection : collections) {
- Set<Long> relatedLedgerIds = ledgerIdsByCollectionId.get(collection.getId());
- if (relatedLedgerIds == null || relatedLedgerIds.isEmpty()) {
- if (!matchInteractionKeyword(collection, null, keyword)) {
- continue;
- }
- items.add(toInteractionItem(collection, null));
- if (items.size() >= finalLimit) {
- break;
- }
- continue;
- }
- for (Long ledgerId : relatedLedgerIds) {
- SalesLedger ledger = ledgerMap.get(ledgerId);
- if (ledger == null || !matchInteractionKeyword(collection, ledger, keyword)) {
- continue;
- }
- items.add(toInteractionItem(collection, ledger));
- if (items.size() >= finalLimit) {
- break;
- }
- }
- if (items.size() >= finalLimit) {
- break;
- }
- }
-
- BigDecimal totalReceiptAmount = items.stream()
- .map(item -> asBigDecimal(item.get("receiptPaymentAmount")))
- .reduce(BigDecimal.ZERO, BigDecimal::add);
- Map<String, Object> summary = rangeSummary(range, items.size(), keyword);
- summary.put("totalReceiptAmount", totalReceiptAmount);
- summary.put("customerCount", items.stream()
- .map(item -> String.valueOf(item.get("customerName")))
- .filter(StringUtils::hasText)
- .distinct()
- .count());
- */
LambdaQueryWrapper<SalesQuotation> wrapper = new LambdaQueryWrapper<>();
applyTenantFilter(wrapper, loginUser.getTenantId(), SalesQuotation::getTenantId);
applyDeptFilter(wrapper, loginUser.getCurrentDeptId(), SalesQuotation::getDeptId);
@@ -398,59 +349,7 @@
.filter(StringUtils::hasText)
.distinct()
.count());
- if (summary.size() >= 0) {
- return jsonResponse(true, "sales_customer_interaction_list", "ok", summary, Map.of("items", items), Map.of());
- }
-// LambdaQueryWrapper<ReceiptPayment> wrapper = new LambdaQueryWrapper<>();
-// applyTenantFilter(wrapper, loginUser.getTenantId(), ReceiptPayment::getTenantId);
-// applyDeptFilter(wrapper, loginUser.getCurrentDeptId(), ReceiptPayment::getDeptId);
-// wrapper.ge(ReceiptPayment::getReceiptPaymentDate, range.start())
-// .le(ReceiptPayment::getReceiptPaymentDate, range.end())
-// .orderByDesc(ReceiptPayment::getReceiptPaymentDate, ReceiptPayment::getId);
-// List<ReceiptPayment> payments = defaultList(receiptPaymentMapper.selectList(wrapper));
-// if (payments.isEmpty()) {
-// return jsonResponse(true, "sales_customer_interaction_list", "鏈煡璇㈠埌瀹㈡埛寰�鏉ヨ褰�", rangeSummary(range, 0, keyword), Map.of("items", List.of()), Map.of());
-// }
-//
-// List<Long> ledgerIds = payments.stream()
-// .map(ReceiptPayment::getSalesLedgerId)
-// .filter(Objects::nonNull)
-// .distinct()
-// .collect(Collectors.toList());
-// Map<Long, SalesLedger> ledgerMap = defaultList(salesLedgerMapper.selectBatchIds(ledgerIds)).stream()
-// .filter(ledger -> tenantMatched(ledger.getTenantId(), loginUser.getTenantId()))
-// .collect(Collectors.toMap(SalesLedger::getId, item -> item, (a, b) -> a, LinkedHashMap::new));
-//
-// List<ReceiptPayment> filtered = payments.stream()
-// .filter(item -> matchInteractionKeyword(item, ledgerMap.get(item.getSalesLedgerId()), keyword))
-// .limit(normalizeLimit(limit))
-// .collect(Collectors.toList());
-//
-// BigDecimal totalReceiptAmount = filtered.stream()
-// .map(ReceiptPayment::getReceiptPaymentAmount)
-// .filter(Objects::nonNull)
-// .reduce(BigDecimal.ZERO, BigDecimal::add);
-
-// List<Map<String, Object>> items = filtered.stream().map(item -> {
-// SalesLedger ledger = ledgerMap.get(item.getSalesLedgerId());
-// Map<String, Object> map = new LinkedHashMap<>();
-// map.put("id", item.getId());
-// map.put("salesLedgerId", item.getSalesLedgerId());
-// map.put("salesContractNo", ledger == null ? "" : safe(ledger.getSalesContractNo()));
-// map.put("customerName", ledger == null ? "" : safe(ledger.getCustomerName()));
-// map.put("projectName", ledger == null ? "" : safe(ledger.getProjectName()));
-// map.put("receiptPaymentDate", formatDate(item.getReceiptPaymentDate()));
-// map.put("receiptPaymentAmount", item.getReceiptPaymentAmount());
-// map.put("receiptPaymentType", safe(item.getReceiptPaymentType()));
-// map.put("registrant", safe(item.getRegistrant()));
-// return map;
-// }).collect(Collectors.toList());
-
-// Map<String, Object> summary = rangeSummary(range, items.size(), keyword);
-// summary.put("totalReceiptAmount", totalReceiptAmount);
-// summary.put("customerCount", items.stream().map(item -> String.valueOf(item.get("customerName"))).filter(StringUtils::hasText).distinct().count());
-// return jsonResponse(true, "sales_customer_interaction_list", "宸茶繑鍥炲鎴峰線鏉ユ槑缁�", summary, Map.of("items", items), Map.of());
- return jsonResponse(true, "sales_customer_interaction_list", "宸茶繑鍥炲鎴峰線鏉ユ槑缁�", null, Map.of("items", List.of()), Map.of());
+ return jsonResponse(true, "sales_customer_interaction_list", "ok", summary, Map.of("items", items), Map.of());
}
@Tool(name = "鏌ヨ鍙戣揣鍙拌处", value = "鎸夊叧閿瘝鍜屾椂闂磋寖鍥存煡璇㈠彂璐у彴璐�")
@@ -965,12 +864,6 @@
return Map.of();
}
Map<Long, BigDecimal> result = new HashMap<>();
-// for (InvoiceLedgerDto item : defaultList(invoiceLedgerMapper.invoicedTotal(ledgerIds))) {
-// if (item.getSalesLedgerId() == null) {
-// continue;
-// }
-// result.merge(item.getSalesLedgerId().longValue(), defaultDecimal(item.getInvoiceTotal()), BigDecimal::add);
-// }
return result;
}
@@ -1116,9 +1009,46 @@
result.put(entry.getKey(), ledgerIds);
}
}
+ mergeOilOutBindingLedgerIds(collections, result);
return result;
}
+ /**
+ * 娌瑰搧鍑哄簱鐨勬敹娆惧崟涓嶅瓨鍑哄簱鍗� id锛屽瓨鐨勬槸缁戝畾琛� id锛堜竴涓嚭搴撳崟鍙兘鎸夊鎴锋媶缁欏涓彴璐︼級銆�
+ * 缁戝畾琛屼笂鐩存帴甯� sales_ledger_id锛屼笉闇�瑕佸啀缁� shipping_info 涓浆銆�
+ */
+ private void mergeOilOutBindingLedgerIds(List<AccountSalesCollection> collections, Map<Integer, Set<Long>> result) {
+ Map<Integer, List<Long>> bindingIdsByCollection = new HashMap<>();
+ Set<Long> allBindingIds = new HashSet<>();
+ for (AccountSalesCollection collection : collections) {
+ if (collection.getId() == null) {
+ continue;
+ }
+ List<Long> bindingIds = parseLongIds(collection.getStockOutBindingIds());
+ if (bindingIds.isEmpty()) {
+ continue;
+ }
+ bindingIdsByCollection.put(collection.getId(), bindingIds);
+ allBindingIds.addAll(bindingIds);
+ }
+ if (allBindingIds.isEmpty()) {
+ return;
+ }
+ Map<Long, Long> ledgerIdByBindingId = defaultList(stockOutRecordSalesLedgerMapper.selectByIds(allBindingIds)).stream()
+ .filter(item -> item.getId() != null && item.getSalesLedgerId() != null)
+ .collect(Collectors.toMap(StockOutRecordSalesLedger::getId, StockOutRecordSalesLedger::getSalesLedgerId, (a, b) -> a));
+
+ for (Map.Entry<Integer, List<Long>> entry : bindingIdsByCollection.entrySet()) {
+ Set<Long> ledgerIds = result.computeIfAbsent(entry.getKey(), key -> new LinkedHashSet<>());
+ for (Long bindingId : entry.getValue()) {
+ Long ledgerId = ledgerIdByBindingId.get(bindingId);
+ if (ledgerId != null) {
+ ledgerIds.add(ledgerId);
+ }
+ }
+ }
+ }
+
private boolean isSalesOutboundRecord(StockOutRecord stockOutRecord) {
if (stockOutRecord == null || !StringUtils.hasText(stockOutRecord.getRecordType())) {
return false;
--
Gitblit v1.9.3