diff --git a/inside-notices/src/main/java/cn/axzo/msg/center/message/xxl/MigrateFromPendingMessageJob.java b/inside-notices/src/main/java/cn/axzo/msg/center/message/xxl/MigrateFromPendingMessageJob.java
index aa1a703f..1c5c188b 100644
--- a/inside-notices/src/main/java/cn/axzo/msg/center/message/xxl/MigrateFromPendingMessageJob.java
+++ b/inside-notices/src/main/java/cn/axzo/msg/center/message/xxl/MigrateFromPendingMessageJob.java
@@ -71,12 +71,7 @@ public class MigrateFromPendingMessageJob extends IJobHandler {
             MigrateCount migrateCount = new MigrateCount();
 
             List<Long> businessIds;
-            QueryWrapper<Todo> todoQuery = new QueryWrapper<Todo>()
-                    .select("DISTINCT todo_business_id")
-                    .last("AND biz_code <> '' AND record_ext -> '$.isMigratedFromPendingMessage' = true");
-            businessIds = todoDao.list(todoQuery).stream()
-                    .map(Todo::getTodoBusinessId)
-                    .collect(toList());
+            businessIds = todoDao.getBaseMapper().getMigratedBusinessId();
             log.info("remove businessIds:{}", JSON.toJSONString(businessIds));
 
             if (!businessIds.isEmpty()) {
diff --git a/msg-center-dal/src/main/java/cn/axzo/msg/center/dal/mapper/TodoMapper.java b/msg-center-dal/src/main/java/cn/axzo/msg/center/dal/mapper/TodoMapper.java
index 461d7c8d..37dfe89f 100644
--- a/msg-center-dal/src/main/java/cn/axzo/msg/center/dal/mapper/TodoMapper.java
+++ b/msg-center-dal/src/main/java/cn/axzo/msg/center/dal/mapper/TodoMapper.java
@@ -19,4 +19,6 @@ public interface TodoMapper extends BaseMapper<Todo> {
                                    @Param("personId") Long personId,
                                    @Param("isNowDay") boolean isNowDay);
 
+    List<Long> getMigratedBusinessId();
+
 }
diff --git a/msg-center-dal/src/main/resources/mapper/Todo.xml b/msg-center-dal/src/main/resources/mapper/Todo.xml
new file mode 100644
index 00000000..923bfd6e
--- /dev/null
+++ b/msg-center-dal/src/main/resources/mapper/Todo.xml
@@ -0,0 +1,20 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="cn.axzo.msg.center.dal.mapper.TodoMapper">
+
+    <delete id="deleteByIds">
+        delete from todo_business WHERE id in
+        <foreach collection="ids" item="id" separator="," open="(" close=")">
+            #{id}
+        </foreach>
+    </delete>
+
+    <select id="getMigratedBusinessId" resultType="long">
+        SELECT DISTINCT todo_business_id
+        FROM todo
+        WHERE biz_code != ''
+          AND record_ext -> '$.isMigratedFromPendingMessage' = true
+    </select>
+
+</mapper>
+