From 684e4306a08feeae188070f264148e6765da8dcf Mon Sep 17 00:00:00 2001
From: 云 <2163098428@qq.com>
Date: 星期日, 20 九月 2026 19:25:15 +0800
Subject: [PATCH] feat(account): 更新往来付款回款流水表及接口
---
src/main/java/com/ruoyi/purchase/service/impl/PurchaseLedgerServiceImpl.java | 72 +++++++++++++++++++++++++++++++----
1 files changed, 63 insertions(+), 9 deletions(-)
diff --git a/src/main/java/com/ruoyi/purchase/service/impl/PurchaseLedgerServiceImpl.java b/src/main/java/com/ruoyi/purchase/service/impl/PurchaseLedgerServiceImpl.java
index a81fca7..553b2fa 100644
--- a/src/main/java/com/ruoyi/purchase/service/impl/PurchaseLedgerServiceImpl.java
+++ b/src/main/java/com/ruoyi/purchase/service/impl/PurchaseLedgerServiceImpl.java
@@ -105,6 +105,11 @@
*/
private static final Integer LEDGER_TYPE_PURCHASE = 2;
+ /**
+ * 澶囦欢娴佹按鏉ユ簮锛氶噰璐叆搴撱�傝 spare_parts_record.source_type
+ */
+ private static final Integer SPARE_PARTS_SOURCE_PURCHASE = 1;
+
private final PurchaseLedgerMapper purchaseLedgerMapper;
private final SalesLedgerMapper salesLedgerMapper;
private final SalesLedgerProductMapper salesLedgerProductMapper;
@@ -719,10 +724,13 @@
salesLedgerProduct.setRegisterDate(localDateTime);
salesLedgerProductMapper.insert(salesLedgerProduct);
}
- // 浠呮柊澧炴槑缁嗗洖鍐欏浠讹紝缂栬緫璧� update 鍒嗘敮澶╃劧涓嶉噸澶嶈鏁�
- if (LEDGER_TYPE_PURCHASE.equals(ledgerType)) {
- recordSparePartsInbound(insertList, purchaseLedger);
- }
+ }
+ // 閲囪喘鏄庣粏鍥炲啓澶囦欢锛氬厛鎸夊彴璐﹀洖婊氫笂涓�娆＄殑娴佹按锛屽啀鎸夊綋鍓嶆槑缁嗘暣浣撻噸寤恒��
+ // 缂栬緫鏃舵槑缁嗚鍙兘琚Щ闄わ紝鍙鏂板琛屼細婕忔帀绉婚櫎鐨勯偅浜涳紱鏁翠綋閲嶅缓澶╃劧涓庡綋鍓嶆槑缁嗗榻愩��
+ // 娉ㄦ剰杩欐蹇呴』鍦� insertList 涔嬪锛屽惁鍒欍�屽彧鍒犳槑缁嗐�佷笉鏂板銆嶇殑缂栬緫涓嶄細瑙﹀彂鍥炴粴
+ if (LEDGER_TYPE_PURCHASE.equals(ledgerType)) {
+ rollbackSparePartsInbound(salesLedgerId);
+ recordSparePartsInbound(products, purchaseLedger);
}
// 璁＄畻鎬诲惈绋庨噾棰�
@@ -739,11 +747,54 @@
}
/**
- * 閲囪喘鍙拌处鏂板鏄庣粏鎸夎鏍煎尮閰嶅浠讹細绱姞澶囦欢搴撳瓨骞惰涓�鏉″叆搴撴祦姘淬��
- * 鏈淮鎶よ鏍肩殑澶囦欢涓嶅弬涓庯紝闈欓粯璺宠繃銆�
+ * 鎸夐噰璐彴璐﹀洖婊氬浠讹細鎶婅鍙拌处浜х敓鐨勫叆搴撴祦姘撮�愬浠跺噺鍥炲簱瀛橈紝鐒跺悗鍒犻櫎杩欎簺娴佹按銆�
+ *
+ * <p>澶囦欢鍏堢敱閲囪喘鍏ヨ处銆佸悗缁缁翠慨/淇濆吇棰嗙敤鍑鸿处锛岃嫢鍏ヨ处閲忓凡缁忚棰嗙敤鎺夛紝鍑忓洖浼氬嚭鐜拌礋搴撳瓨锛�
+ * 姝ゆ椂鐩存帴鎷︿綇涓嶈鍒狅紝閬垮厤鎶婂浠惰处鍋氳姳銆傚垹闄ゅ彴璐︿笌缂栬緫閲嶅缓閮借蛋杩欓噷锛屽彛寰勭粺涓�銆�</p>
*/
- private void recordSparePartsInbound(List<SalesLedgerProduct> insertList, PurchaseLedger purchaseLedger) {
- List<Long> modelIds = insertList.stream()
+ private void rollbackSparePartsInbound(Long ledgerId) {
+ List<SparePartsRecord> records = sparePartsRecordService.list(new LambdaQueryWrapper<SparePartsRecord>()
+ .eq(SparePartsRecord::getSourceType, SPARE_PARTS_SOURCE_PURCHASE)
+ .eq(SparePartsRecord::getSourceId, ledgerId));
+ if (CollectionUtils.isEmpty(records)) {
+ return;
+ }
+ Map<Long, BigDecimal> rollbackBySparePartsId = new HashMap<>();
+ for (SparePartsRecord record : records) {
+ BigDecimal quantity = record.getQuantity() == null ? BigDecimal.ZERO : record.getQuantity();
+ rollbackBySparePartsId.merge(record.getSparePartsId(), quantity, BigDecimal::add);
+ }
+ for (Map.Entry<Long, BigDecimal> entry : rollbackBySparePartsId.entrySet()) {
+ if (entry.getKey() == null) {
+ continue;
+ }
+ SpareParts spareParts = sparePartsMapper.selectById(entry.getKey());
+ if (spareParts == null) {
+ continue;
+ }
+ BigDecimal current = spareParts.getQuantity() == null ? BigDecimal.ZERO : spareParts.getQuantity();
+ if (current.compareTo(entry.getValue()) < 0) {
+ throw new BaseException("澶囦欢銆�" + spareParts.getName() + "銆嶅綋鍓嶅簱瀛� " + current
+ + "锛屼笉瓒充互鍥炴粴鏈閲囪喘鍏ュ簱鐨� " + entry.getValue() + "锛岃鍏堝鐞嗛鐢ㄨ褰�");
+ }
+ spareParts.setQuantity(current.subtract(entry.getValue()));
+ sparePartsMapper.updateById(spareParts);
+ }
+ sparePartsRecordService.removeByIds(records.stream()
+ .map(SparePartsRecord::getId)
+ .filter(Objects::nonNull)
+ .collect(Collectors.toList()));
+ }
+
+ /**
+ * 閲囪喘鍙拌处鏄庣粏鎸夎鏍煎尮閰嶅浠讹細绱姞澶囦欢搴撳瓨骞惰涓�鏉″叆搴撴祦姘淬��
+ * 鏈淮鎶よ鏍肩殑澶囦欢涓嶅弬涓庯紝闈欓粯璺宠繃銆�
+ *
+ * <p>璋冪敤鍓嶅繀椤诲厛 {@link #rollbackSparePartsInbound(Long)}锛屼袱鑰呮垚瀵瑰嚭鐜帮細
+ * 鍥炴粴鏃ф祦姘� + 鎸夊綋鍓嶆槑缁嗛噸寤猴紝鎵嶈兘淇濊瘉缂栬緫鍙拌处鍚庡浠舵暟閲忎笌鏄庣粏涓�鑷淬��</p>
+ */
+ private void recordSparePartsInbound(List<SalesLedgerProduct> products, PurchaseLedger purchaseLedger) {
+ List<Long> modelIds = products.stream()
.map(SalesLedgerProduct::getProductModelId)
.filter(Objects::nonNull)
.distinct()
@@ -758,7 +809,7 @@
}
Map<Long, SpareParts> sparePartsByModelId = sparePartsList.stream()
.collect(Collectors.toMap(SpareParts::getProductModelId, s -> s, (a, b) -> a));
- for (SalesLedgerProduct product : insertList) {
+ for (SalesLedgerProduct product : products) {
SpareParts spareParts = sparePartsByModelId.get(product.getProductModelId());
if (spareParts == null || product.getQuantity() == null
|| product.getQuantity().compareTo(BigDecimal.ZERO) <= 0) {
@@ -790,6 +841,9 @@
if (purchaseLedger.getApprovalStatus().equals(3)) {
throw new BaseException(purchaseLedger.getPurchaseContractNumber()+"宸茬粡瀹℃壒閫氳繃锛屼笉鍏佽鍒犻櫎");
}
+ // 鍙拌处鍒犻櫎瑕佹妸璇ュ彴璐﹂噰璐叆搴撴椂绱姞鍒板浠朵笂鐨勬暟閲忓噺鍥炲幓锛屽苟鍒犳帀瀵瑰簲娴佹按锛�
+ // 鍚﹀垯澶囦欢搴撳瓨铏氶珮銆佹祦姘存畫鐣欍�傚浠跺凡棰嗙敤瀵艰嚧鍑忓洖涓鸿礋鏃朵細鍦ㄨ繖閲屾嫤浣�
+ rollbackSparePartsInbound(id);
}
// 鎵归噺鍒犻櫎鍏宠仈鐨勯噰璐叆搴撹褰�
LambdaQueryWrapper<SalesLedgerProduct> salesLedgerProductQueryWrapper = new LambdaQueryWrapper<>();
--
Gitblit v1.9.3