diff --git a/msg-center-dal/src/main/resources/mapper/MessageRecordMapper.xml b/msg-center-dal/src/main/resources/mapper/MessageRecordMapper.xml
index e7de5068..919ec835 100644
--- a/msg-center-dal/src/main/resources/mapper/MessageRecordMapper.xml
+++ b/msg-center-dal/src/main/resources/mapper/MessageRecordMapper.xml
@@ -11,8 +11,8 @@
     VALUES
     <foreach collection="records" item="i" separator=",">
       (
-      #{i.id}, #{i.fromId}, #{i.toId}, #{i.personId}, #{i.type}, #{i.relationId}, #{i.moduleId}, #{i.title}, #{i.content}, #{i.receiveType}, #{i.terminalType},
-      #{i.terminalId}, #{i.terminalName}, #{i.state}, #{i.bizId}, #{i.routerParams}, #{i.extra}, #{i.retryCount}, #{i.callbackUrl}, #{i.failCause},
+      #{i.id}, #{i.fromId}, #{i.toId}, #{i.personId}, COALESCE(#{i.type}, 0), #{i.relationId}, #{i.moduleId}, #{i.title}, #{i.content}, COALESCE(#{i.receiveType}, 0), COALESCE(#{i.terminalType}, 0),
+      #{i.terminalId}, #{i.terminalName}, COALESCE(#{i.state}, 0), #{i.bizId}, #{i.routerParams}, #{i.extra}, #{i.retryCount}, #{i.callbackUrl}, #{i.failCause},
       #{i.eventSource}, #{i.tenantId}, #{i.isDelete}, #{i.createAt}, #{i.updateAt}, #{i.oldTypeId}
       )
     </foreach>
diff --git a/start/src/test/java/cn/axzo/msg/center/message/xxl/MigrateOldMsgHotDataJobTest.java b/start/src/test/java/cn/axzo/msg/center/message/xxl/MigrateOldMsgHotDataJobTest.java
index 78926092..c6f2d1a9 100644
--- a/start/src/test/java/cn/axzo/msg/center/message/xxl/MigrateOldMsgHotDataJobTest.java
+++ b/start/src/test/java/cn/axzo/msg/center/message/xxl/MigrateOldMsgHotDataJobTest.java
@@ -18,7 +18,7 @@ class MigrateOldMsgHotDataJobTest {
 
     @Test @Commit
     void foo() throws Exception {
-        migrateOldMsgHotDataJob.execute("{\"daysAgo\": 365}");
+        migrateOldMsgHotDataJob.execute("{ \"daysAgo\": 180, \"saveBatch\": 200 }\n");
     }
 
 }
\ No newline at end of file