b2894lxlx/tms-erp-api
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: A301-3 分录按契约改为单条——e_receivableamt=全部未推送金额，seq/e_corebillno=第一张结算单id

Browse Source
This commit is contained in:
刘泉佳
2026-09-29 11:10:41 +08:00
parent ffc2f6eea2
commit 175dd52d33
2 changed files with 21 additions and 38 deletions
Download Patch File Download Diff File Expand all files Collapse all files
blade-service/blade-transport/src/main/java/org/springblade/transport/service/impl/ReceiptFlowServiceImpl.java
+15 -32
View File
@@ -801,15 +801,6 @@ public class ReceiptFlowServiceImpl extends BaseServiceImpl<KingdeeReceiptFlowMa
if (allocations.isEmpty()) {
return ReceiptClaimPushResult.fail("该流水无有效认领分摊，无法推送");
}
List<Long> settlementIds = allocations.stream()
.map(ReceiptClaimSettlement::getFormalSettlementId)
.filter(Objects::nonNull)
.distinct()
.toList();
Map<Long, FormalSettlement> settlements = settlementIds.isEmpty() ? Map.of()
: formalSettlementMapper.selectList(Wrappers.<FormalSettlement>lambdaQuery()
.in(FormalSettlement::getId, settlementIds)).stream()
.collect(Collectors.toMap(FormalSettlement::getId, Function.identity(), (first, second) -> first));
// 推送来源编码：分摊结算单号下划线拼接（A301-3 契约口径；分摊不变则重试编码不变，
// 金蝶按 awrp_src_sys + awrp_src_code 幂等防重试双单）
String awrpSrcCode = allocations.stream()
@@ -819,7 +810,7 @@ public class ReceiptFlowServiceImpl extends BaseServiceImpl<KingdeeReceiptFlowMa
.collect(Collectors.joining("_"));
flow.setAwrpSrcCode(awrpSrcCode);
BfiClaimPushDTO param = buildClaimPushDTO(flow, allocations, settlements);
BfiClaimPushDTO param = buildClaimPushDTO(flow, claimedTotal, allocations);
log.info("调用BFI接口 收款认领结果推送开始 flowId：{}，billId：{}，awrpSrcCode：{}，分摊明细 {} 行，认领金额 {}",
flow.getId(), flow.getBillId(), flow.getAwrpSrcCode(), allocations.size(), claimedTotal);
try {
@@ -831,10 +822,10 @@ public class ReceiptFlowServiceImpl extends BaseServiceImpl<KingdeeReceiptFlowMa
}
/**
* A301-3 推送报文组装：billid=公告id，分录取各分摊行（一笔流水一张金蝶收款单）
* A301-3 推送报文组装：billid=公告id，单条分录、金额=全部未推送金额（一笔流水一张金蝶收款单）
*/
private BfiClaimPushDTO buildClaimPushDTO(KingdeeReceiptFlow flow, List<ReceiptClaimSettlement> allocations,
Map<Long, FormalSettlement> settlements) {
private BfiClaimPushDTO buildClaimPushDTO(KingdeeReceiptFlow flow, BigDecimal claimedTotal,
List<ReceiptClaimSettlement> allocations) {
BfiClaimPushDTO param = new BfiClaimPushDTO();
// 【必填】认领公告id
param.setBillid(flow.getBillId());
@@ -850,25 +841,17 @@ public class ReceiptFlowServiceImpl extends BaseServiceImpl<KingdeeReceiptFlowMa
param.setRecviewpayer(flow.getPayerName());
// 【必填】付款人id
param.setRecpayer(flow.getPayerId());
List<BfiClaimPushEntryDTO> entries = new ArrayList<>();
for (ReceiptClaimSettlement allocation : allocations) {
BfiClaimPushEntryDTO entry = new BfiClaimPushEntryDTO();
// 【必填】应收金额（分摊金额）
entry.setEReceivableamt(money(allocation.getAllocatedReceiptAmount()));
// 分录行序号（结算单id）
entry.setSeq(allocation.getFormalSettlementId());
FormalSettlement settlement = settlements.get(allocation.getFormalSettlementId());
if (settlement != null && Func.isNotEmpty(settlement.getKingdeeBillNo())) {
// 结算单已同步金蝶应收单时携带核心单据引用，金蝶按结算单id核销认领金额
// 核心单据类型
// entry.setECorebilltype(KingdeeBfiConstant.BFI_CLAIM_CORE_BILL_TYPE);
// 核心单据编号（结算单id）
entry.setECorebillno(String.valueOf(settlement.getId()));
}
entries.add(entry);
}
// 【必填】单据体分录
param.setEntryentity(entries);
// 【必填】单据体分录：仅一条，应收金额=全部未推送金额（累计有效认领）
BfiClaimPushEntryDTO entry = new BfiClaimPushEntryDTO();
// 【必填】应收金额（全部未推送金额）
entry.setEReceivableamt(claimedTotal);
// 分录行序号（第一张结算单id，分摊已按结算单id升序，多张取最小）
entry.setSeq(allocations.get(0).getFormalSettlementId());
// 核心单据类型
// entry.setECorebilltype(KingdeeBfiConstant.BFI_CLAIM_CORE_BILL_TYPE);
// 核心单据编号（第一张结算单id）
entry.setECorebillno(String.valueOf(allocations.get(0).getFormalSettlementId()));
param.setEntryentity(List.of(entry));
return param;
}
doc/docs/业务流程/2026-09-28-收款认领推送金蝶重构设计（认领本地化-A301-3定时+手动推送-按流水归集）.md
+6 -6
View File
@@ -29,7 +29,7 @@
新增两条核心规则（本次重构的业务闸门）：
- **认领完成 = 累计有效认领金额 == 公告未认领金额**（`unclaimed_amount`，即 A301-2 的 `unclaimamount`；作废分摊不计入累计）。只有认领完成的流水才满足推送条件——**不认领完就不推**。
- **推送单元 = 收款流水**：一条流水只产生一张金蝶收款单，分录取该流水下全部有效分摊行（可能跨多次认领主单）；`awrp_src_code` 按分摊结算单号下划线拼接（A301-3 契约口径），一条流水只推送一次，编码不会撞码。
- **推送单元 = 收款流水**：一条流水只产生一张金蝶收款单，**单条分录、金额 = 全部未推送金额**（累计有效认领，闸门保证等于公告未认领金额）；`awrp_src_code` 按分摊结算单号下划线拼接（A301-3 契约口径），一条流水只推送一次，编码不会撞码。
## 3. 领域模型与职责划分
@@ -117,9 +117,9 @@ claimed 累计有效认领 == unclaimed_amount（且 > 0） ← 「认领
- 重验：累计有效认领 == 最新 unclaimed_amount，不等 → 失败并提示两侧金额差额
（不等说明金蝶侧有人认领过或金额有变，需人工核对后作废/补认领）
④ awrp_src_code：按分摊结算单号下划线拼接生成并落库（分摊不变则重试编码不变）
⑤ 组装 A301-3：billid=流水.bill_id，entries = 该流水全部有效分摊行
（分摊行 join 结算单，按结算单 id 升序；金额=allocated_receipt_amount；
seq=结算单id；结算单有 kingdee_bill_no 时携带 e_corebillno=结算单id，沿用契约取数）
⑤ 组装 A301-3：billid=流水.bill_id，**单条分录**：
e_receivableamt = 全部未推送金额（累计有效认领）；
seq / e_corebillno = 第一张结算单id（分摊按结算单id升序，多张取最小）
⑥ 调 pushClaimResult：
成功 → push_status=pushed、push_fail_reason 清空、pushed_time=now、
kingdee_bill_no=响应 number、kingdee_bill_status=pushed；
@@ -230,7 +230,7 @@ claimed 累计有效认领 == unclaimed_amount（且 > 0） ← 「认领
| 认领事务 | 落库后同事务立即推 A301-3，失败整体回滚 | 纯本地落库，不调 BFI |
| 推送触发 | 每次认领动作 | 定时任务（`receiptClaimPush.*` 开关）+ 手动按钮，双入口同一服务方法 |
| 推送条件 | 无（认领即推） | 累计有效认领 == 公告未认领金额（推送前重查 A301-2 实时对账） |
| 推送粒度 | 每次认领一张金蝶收款单 | 一条流水一张金蝶收款单（分摊行归集） |
| 推送粒度 | 每次认领一张金蝶收款单 | 一条流水一张金蝶收款单（单条分录，金额=全部未推送金额） |
| awrp_src_code | 认领主单上，每次认领各自按结算单号拼接（多流水分摊到同一批结算单时撞码） | 流水上，按该流水全部分摊结算单号拼接，一条流水仅推送一次，不再撞码 |
| 认领上限/认领完成口径 | receipt_amount | unclaimed_amount |
| 推送状态/失败原因 | 无（失败即回滚无痕） | 流水上 push_status / push_fail_reason / pushed_time，失败可重试可追溯 |
@@ -244,7 +244,7 @@ claimed 累计有效认领 == unclaimed_amount（且 > 0） ← 「认领
| 认领 | `ReceiptFlowServiceImpl.claim()` | 上限口径改公告未认领金额（缺失/为0拦截）；删除同步推送调用，事务内只落本地 |
| 推送 | `IReceiptFlowService.pushClaimToKingdee(flowId)` / `pushClaimByTask()` | 新增。共用 `pushClaimLocked`（`TransactionTemplate` 编程式事务，流水行锁覆盖闸门→对账→推送→落库，防并发双推）；失败不抛异常跨事务边界，以 `ReceiptClaimPushResult` 返回 |
| 定时任务 | `task/ReceiptClaimPushTask.java`（新增） | Nacos 开关 `thirdParty.bfi.receiptClaimPush.syncEnabled/cron`（默认关闭、每10分钟）；候选=认领完成且 push_status ∈ (none, failed)，按认领人姓名去重逐人重查 A301-2 |
| 推送报文 | `buildClaimPushDTO` | billid=流水.bill_id；分录=该流水全部有效分摊行（结算单升序）；seq=结算单id；e_corebillno=结算单id（结算单已同步金蝶应收时携带）；awrp_src_code=分摊结算单号下划线拼接 |
| 推送报文 | `buildClaimPushDTO` | billid=流水.bill_id；**单条分录**：e_receivableamt=全部未推送金额（累计有效认领），seq/e_corebillno=第一张结算单id；awrp_src_code=分摊结算单号下划线拼接 |
| 手动接口 | `ReceiptFlowController.pushKingdee`（`POST /receipt-flow/push-kingdee`） | 成功返回金蝶收款单号，失败 R.fail(原因)；按钮权限 `receipt_flow_push` |
| 回写 | `ReceiptClaimRecordServiceImpl.refreshKingdeeResult()` | 轮询对象改流水（push_status=pushed 且回写状态 pushed/approved），按流水 awrp_src_code 匹配，级联刷新认领主单冗余字段 |
| 作废 | `ReceiptClaimRecordServiceImpl.voidClaim()` | claim_status 重算口径改对照公告未认领金额（其余不变，作废不触发推送） |