diff --git a/deploy/sql/海外区域统一增量-MySQL8.sql b/deploy/sql/海外区域统一增量-MySQL8.sql index bb79d6db3..b076f5a4a 100644 --- a/deploy/sql/海外区域统一增量-MySQL8.sql +++ b/deploy/sql/海外区域统一增量-MySQL8.sql @@ -1681,7 +1681,7 @@ SELECT 'PASS' AS migration_status, '海外仓业务、海外仓资源与IAM安 CREATE TABLE IF NOT EXISTS ll_wallet_event_inbox ( event_id VARCHAR(64) NOT NULL COMMENT '国内Finance资金结果事件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 '冻结事件信封', status VARCHAR(16) NOT NULL COMMENT 'RECEIVED或PROCESSED', 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) ) 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 ( diff --git a/lastleg-service/src/main/resources/db/lastleg.sql b/lastleg-service/src/main/resources/db/lastleg.sql index de2ac3d03..eac660912 100644 --- a/lastleg-service/src/main/resources/db/lastleg.sql +++ b/lastleg-service/src/main/resources/db/lastleg.sql @@ -1890,7 +1890,7 @@ INSERT IGNORE INTO ll_security_projection ( CREATE TABLE IF NOT EXISTS ll_wallet_event_inbox ( event_id VARCHAR(64) NOT NULL COMMENT '国内Finance资金结果事件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 '冻结事件信封', status VARCHAR(16) NOT NULL COMMENT 'RECEIVED或PROCESSED', received_at DATETIME(3) NOT NULL COMMENT '接收时间', diff --git a/lastleg-service/src/test/java/com/baiyue/lastleg/procurement/OverseasProcurementSchemaContractTest.java b/lastleg-service/src/test/java/com/baiyue/lastleg/procurement/OverseasProcurementSchemaContractTest.java index 07e85bdfd..54fa76c18 100644 --- a/lastleg-service/src/test/java/com/baiyue/lastleg/procurement/OverseasProcurementSchemaContractTest.java +++ b/lastleg-service/src/test/java/com/baiyue/lastleg/procurement/OverseasProcurementSchemaContractTest.java @@ -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_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("review_idempotency_key VARCHAR(255) 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")); assertTrue(sql.contains( "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")); } }