feat: 收款流水同步落库核算组织与收款公司编码

This commit is contained in:
刘泉佳
2026-10-29 14:52:14 +08:00
parent 87288ae10d
commit cad4ccd9cb
4 changed files with 43 additions and 1 deletions
@@ -80,6 +80,14 @@ public class KingdeeReceiptFlow extends TenantEntity {
* 收款人(A301-1 收款公司名称 org_name)
*/
private String payeeName;
/**
* 收款人(公司).编码(A301-1 org_number)
*/
private String orgNumber;
/**
* 核算组织.编码(A301-1 openorg_number)
*/
private String openOrgNumber;
/**
* 金蝶收款单号(A301-1 billno)
*/
@@ -812,6 +812,10 @@ public class ReceiptFlowServiceImpl extends BaseServiceImpl<KingdeeReceiptFlowMa
target.setPayerName(trimToEmpty(source.getPayername()));
// 收款人(收款公司名称)
target.setPayeeName(trimToNull(source.getOrgName()));
// 收款人(公司).编码
target.setOrgNumber(trimToNull(source.getOrgNumber()));
// 核算组织.编码
target.setOpenOrgNumber(trimToNull(source.getOpenorgNumber()));
// 收款金额(主单入账金额 inneraccountamount)
target.setReceiptAmount(row.receiptAmount());
// 对方单位名称(取付款人名称)
@@ -77,7 +77,9 @@ A301-1 收款单查询(业务日期窗口取 `thirdParty.bfi.recBillSync.days`
| receipt_amount | 主单 `inneraccountamount` | 收款金额(入账金额口径,非流水分录 bei_creditamount) |
| unclaimed_amount | `unmatchamountrec` | 未匹配收款金额,**认领上限口径** |
| payer_name / counterparty_name | `payername` | 付款人名称 |
| payee_name | `org_name` | 收款公司名称 |
| payee_name | `org_name` | 收款人(收款公司名称) |
| org_number | `org_number` | 收款人(公司).编码 |
| open_org_number | `openorg_number` | 核算组织.编码 |
| counterparty_account | `payeracctbanknum` | 付款账户 |
| counterparty_bank | `payerbankname` | 付款银行 |
| summary | `txt_description` | 摘要 |
@@ -0,0 +1,28 @@
-- 收款流水表增加金蝶收款单组织/公司编码字段(A301-1 收款单查询同步落库)
-- openorg_number 核算组织.编码、org_number 收款人(公司).编码;org_name 已由 payee_name 承载不加列
SET @ddl_sql = (
SELECT IF(COUNT(*) = 0,
'ALTER TABLE `blade_kingdee_receipt_flow` ADD COLUMN `org_number` varchar(50) COLLATE utf8mb4_general_ci DEFAULT NULL COMMENT ''收款人(公司).编码(A301-1 org_number)'' AFTER `payee_name`',
'SELECT 1')
FROM information_schema.COLUMNS
WHERE TABLE_SCHEMA = DATABASE()
AND TABLE_NAME = 'blade_kingdee_receipt_flow'
AND COLUMN_NAME = 'org_number'
);
PREPARE ddl_stmt FROM @ddl_sql;
EXECUTE ddl_stmt;
DEALLOCATE PREPARE ddl_stmt;
SET @ddl_sql = (
SELECT IF(COUNT(*) = 0,
'ALTER TABLE `blade_kingdee_receipt_flow` ADD COLUMN `open_org_number` varchar(50) COLLATE utf8mb4_general_ci DEFAULT NULL COMMENT ''核算组织.编码(A301-1 openorg_number)'' AFTER `org_number`',
'SELECT 1')
FROM information_schema.COLUMNS
WHERE TABLE_SCHEMA = DATABASE()
AND TABLE_NAME = 'blade_kingdee_receipt_flow'
AND COLUMN_NAME = 'open_org_number'
);
PREPARE ddl_stmt FROM @ddl_sql;
EXECUTE ddl_stmt;
DEALLOCATE PREPARE ddl_stmt;