fix: accept wallet result event hashes
This commit is contained in:
@@ -1681,7 +1681,7 @@ SELECT 'PASS' AS migration_status, '海外仓业务、海外仓资源与IAM安
|
|||||||
CREATE TABLE IF NOT EXISTS ll_wallet_event_inbox (
|
CREATE TABLE IF NOT EXISTS ll_wallet_event_inbox (
|
||||||
event_id VARCHAR(64) NOT NULL COMMENT '国内Finance资金结果事件ID',
|
event_id VARCHAR(64) NOT NULL COMMENT '国内Finance资金结果事件ID',
|
||||||
command_event_id VARCHAR(64) NOT NULL COMMENT '原海外资金指令事件ID',
|
command_event_id VARCHAR(64) NOT NULL COMMENT '原海外资金指令事件ID',
|
||||||
payload_hash CHAR(64) NOT NULL COMMENT '规范化载荷SHA-256',
|
payload_hash VARCHAR(71) NOT NULL COMMENT '规范化载荷SHA-256,包含sha256:前缀',
|
||||||
payload_json JSON NOT NULL COMMENT '冻结事件信封',
|
payload_json JSON NOT NULL COMMENT '冻结事件信封',
|
||||||
status VARCHAR(16) NOT NULL COMMENT 'RECEIVED或PROCESSED',
|
status VARCHAR(16) NOT NULL COMMENT 'RECEIVED或PROCESSED',
|
||||||
received_at DATETIME(3) NOT NULL COMMENT '接收时间',
|
received_at DATETIME(3) NOT NULL COMMENT '接收时间',
|
||||||
@@ -1691,6 +1691,9 @@ CREATE TABLE IF NOT EXISTS ll_wallet_event_inbox (
|
|||||||
KEY idx_ll_wallet_event_status (status,received_at)
|
KEY idx_ll_wallet_event_status (status,received_at)
|
||||||
) ENGINE=InnoDB COMMENT='跨区客户资金结果幂等收件箱';
|
) ENGINE=InnoDB COMMENT='跨区客户资金结果幂等收件箱';
|
||||||
|
|
||||||
|
ALTER TABLE ll_wallet_event_inbox
|
||||||
|
MODIFY COLUMN payload_hash VARCHAR(71) NOT NULL COMMENT '规范化载荷SHA-256,包含sha256:前缀';
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
CREATE TABLE IF NOT EXISTS ll_procurement_daily_sequence (
|
CREATE TABLE IF NOT EXISTS ll_procurement_daily_sequence (
|
||||||
|
|||||||
@@ -1890,7 +1890,7 @@ INSERT IGNORE INTO ll_security_projection (
|
|||||||
CREATE TABLE IF NOT EXISTS ll_wallet_event_inbox (
|
CREATE TABLE IF NOT EXISTS ll_wallet_event_inbox (
|
||||||
event_id VARCHAR(64) NOT NULL COMMENT '国内Finance资金结果事件ID',
|
event_id VARCHAR(64) NOT NULL COMMENT '国内Finance资金结果事件ID',
|
||||||
command_event_id VARCHAR(64) NOT NULL COMMENT '原海外资金指令事件ID',
|
command_event_id VARCHAR(64) NOT NULL COMMENT '原海外资金指令事件ID',
|
||||||
payload_hash CHAR(64) NOT NULL COMMENT '规范化载荷SHA-256',
|
payload_hash VARCHAR(71) NOT NULL COMMENT '规范化载荷SHA-256,包含sha256:前缀',
|
||||||
payload_json JSON NOT NULL COMMENT '冻结事件信封',
|
payload_json JSON NOT NULL COMMENT '冻结事件信封',
|
||||||
status VARCHAR(16) NOT NULL COMMENT 'RECEIVED或PROCESSED',
|
status VARCHAR(16) NOT NULL COMMENT 'RECEIVED或PROCESSED',
|
||||||
received_at DATETIME(3) NOT NULL COMMENT '接收时间',
|
received_at DATETIME(3) NOT NULL COMMENT '接收时间',
|
||||||
|
|||||||
+4
@@ -17,6 +17,8 @@ class OverseasProcurementSchemaContractTest {
|
|||||||
}
|
}
|
||||||
assertTrue(sql.contains("CREATE TABLE IF NOT EXISTS ll_overseas_procurement_order"));
|
assertTrue(sql.contains("CREATE TABLE IF NOT EXISTS ll_overseas_procurement_order"));
|
||||||
assertTrue(sql.contains("CREATE TABLE IF NOT EXISTS ll_overseas_procurement_status_history"));
|
assertTrue(sql.contains("CREATE TABLE IF NOT EXISTS ll_overseas_procurement_status_history"));
|
||||||
|
assertTrue(sql.contains("CREATE TABLE IF NOT EXISTS ll_wallet_event_inbox"));
|
||||||
|
assertTrue(sql.contains("payload_hash VARCHAR(71) NOT NULL"));
|
||||||
assertTrue(sql.contains("operation_type VARCHAR(32) NOT NULL"));
|
assertTrue(sql.contains("operation_type VARCHAR(32) NOT NULL"));
|
||||||
assertTrue(sql.contains("review_idempotency_key VARCHAR(255) NULL"));
|
assertTrue(sql.contains("review_idempotency_key VARCHAR(255) NULL"));
|
||||||
assertTrue(sql.contains("review_request_hash CHAR(64) NULL"));
|
assertTrue(sql.contains("review_request_hash CHAR(64) NULL"));
|
||||||
@@ -44,5 +46,7 @@ class OverseasProcurementSchemaContractTest {
|
|||||||
"ALTER TABLE ll_overseas_procurement_order ADD COLUMN outbound_details JSON NULL"));
|
"ALTER TABLE ll_overseas_procurement_order ADD COLUMN outbound_details JSON NULL"));
|
||||||
assertTrue(sql.contains(
|
assertTrue(sql.contains(
|
||||||
"table_name='ll_overseas_procurement_status_history' AND column_name='idempotency_key'"));
|
"table_name='ll_overseas_procurement_status_history' AND column_name='idempotency_key'"));
|
||||||
|
assertTrue(sql.contains("ALTER TABLE ll_wallet_event_inbox"));
|
||||||
|
assertTrue(sql.contains("MODIFY COLUMN payload_hash VARCHAR(71) NOT NULL"));
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user