修改

src/main/java/com/dashitech/migration/SqlTask.java

@@ -14,6 +14,9 @@ public interface SqlTask {
 
     /**
      * 如果之前执行有报错，需要重新加载特定字段缓存数据
+     * 字段缓存可根据指定key加载
      */
-    FieldMapper loadCache();
+    FieldMapper loadCache(String key);
+
+
 }

src/main/java/com/dashitech/migration/StartApplication.java

@@ -1,5 +1,6 @@
 package com.dashitech.migration;
 
+import com.dashitech.migration.task.uc.HospitalTask;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -20,6 +21,9 @@ public class StartApplication {
     @Autowired
     SqlTask userTask;
 
+    @Autowired
+    HospitalTask hospitalTask;
+
     public void start() {
         log.info("########### 开始迁移任务！###########");
 

src/main/java/com/dashitech/migration/task/uc/DictionaryTask.java

@@ -0,0 +1,42 @@
+package com.dashitech.migration.task.uc;
+
+import com.dashitech.migration.BaseTask;
+import com.dashitech.migration.core.FieldMapper;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.springframework.stereotype.Component;
+import org.springframework.util.Assert;
+
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * @author song
+ * @date 2024年10月12日
+ */
+
+@Component
+public class DictionaryTask extends BaseTask {
+
+    public static Log log = LogFactory.getLog(DictionaryTask.class);
+    @Override
+    public void start() {
+
+    }
+
+    @Override
+    public FieldMapper loadCache(String key) {
+        log.info(" *** 加载字典缓存 *** ");
+        FieldMapper mapper = new FieldMapper();
+        Map<Long, Long> dicIdCache = new HashMap<>();
+        mapper.setIdCache(dicIdCache);
+        if ("solution".equals(key)) {
+            dicIdCache.put(71L, 20404L); //待审核
+            dicIdCache.put(72L, 20405L); //已发布
+            dicIdCache.put(73L, 20406L); //待整改
+            dicIdCache.put(74L, 20407L); //已停用
+
+        }
+        return mapper;
+    }
+}

src/main/java/com/dashitech/migration/task/uc/GroupTask.java

@@ -40,7 +40,7 @@ public class GroupTask extends BaseTask {
         mapper.addOperationRemove("id").addOperationRemove("duty_id");
         mapper.addOperationUpdate("_hospital_id", "branch_id");
         mapper.addOperationAdd("type", 3);
-        Map<Long, Long> hosIdCache = hospitalTask.loadCache().getIdCache();
+        Map<Long, Long> hosIdCache = hospitalTask.loadCache(null).getIdCache();
         mapper.addOperationReplace("branch_id", hosIdCache);
         mapper.trans2JdbcRow(list);
 
@@ -52,7 +52,7 @@ public class GroupTask extends BaseTask {
     }
 
     @Override
-    public FieldMapper loadCache() {
+    public FieldMapper loadCache(String key) {
         log.info(" *** 加载工作组group缓存 *** ");
 
         String sql = " select id,groupname,delete_flag,_hospital_id from itsm_uc_groups ";
@@ -64,7 +64,7 @@ public class GroupTask extends BaseTask {
         mapper.addFieldMapper("groupname", "groupname");
         mapper.addFieldMapper("delete_flag", "delete_flag");
         mapper.addFieldMapper("_hospital_id", "branch_id");
-        Map<Long, Long> hosIdCache = hospitalTask.loadCache().getIdCache();
+        Map<Long, Long> hosIdCache = hospitalTask.loadCache(null).getIdCache();
         mapper.addOperationReplace("branch_id", hosIdCache);
 
         DataMigrationter.loadCache(list, list2, mapper);

src/main/java/com/dashitech/migration/task/uc/HospitalTask.java

@@ -1,11 +1,10 @@
 package com.dashitech.migration.task.uc;
 
 import com.dashitech.migration.BaseTask;
-import com.dashitech.migration.SqlTask;
 import com.dashitech.migration.core.FieldMapper;
+import com.dashitech.migration.util.JdbcUtil;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
-import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 import org.springframework.transaction.annotation.Transactional;
 
@@ -24,11 +23,20 @@ public class HospitalTask extends BaseTask {
     @Override
     @Transactional
     public void start() {
+        StringBuffer sql = new StringBuffer("SELECT 0 as version,branch_id as parentId,dept as _hos_name,IFNULL(code,py) as _hos_no,delete_flag,now() as operator_time ");
+        sql.append(" FROM `itsm_uc_duty_dept` where dept not like 'Z%'  and dept not like '%保卫%' and id not in (20,21)");
+        List<Map<String, Object>> hosList = jdbcTemplateMdv2.queryForList(sql.toString());
+        FieldMapper mapper = new FieldMapper();
+        mapper.trans2JdbcRow(hosList);
+        JdbcUtil jdbcUtil = new JdbcUtil(jdbcTemplateHsms);
+        //jdbcUtil.batchPageInsert("itsm_uc_hospital", mapper.getRows());
 
+        //clear释放内存
+        mapper.clear();
     }
 
     @Override
-    public FieldMapper loadCache() {
+    public FieldMapper loadCache(String key) {
         log.info(" *** 加载院区Hospital缓存 *** ");
 
         FieldMapper mapper = new FieldMapper();

src/main/java/com/dashitech/migration/task/uc/SolutionTask.java

@@ -0,0 +1,30 @@
+package com.dashitech.migration.task.uc;
+
+import com.dashitech.migration.BaseTask;
+import com.dashitech.migration.core.FieldMapper;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * @author song
+ * @date 2024年10月12日
+ */
+public class SolutionTask extends BaseTask {
+
+    @Override
+    @Transactional
+    public void start() {
+        StringBuffer sql = new StringBuffer("SELECT id,version,case when categoryId is null then 20342 else 20340 end as type,title,keywords,content,STATUS,");
+        sql.append("create_user_id,createtime as create_time,renew_user_id,renewtime as renew_time,solutionnumber as solution_number,");
+        sql.append("version_number,star,categoryId as category_id,introduce_count,file_abstract,duty_dept,IF( `status` = 74, 1, 0 ) AS delete_flag FROM itsm_solution");
+        List<Map<String, Object>> solutionList = jdbcTemplateMdv2.queryForList(sql.toString());
+        FieldMapper mapper = new FieldMapper();
+    }
+
+    @Override
+    public FieldMapper loadCache(String key) {
+        return null;
+    }
+}

src/main/java/com/dashitech/migration/task/uc/UserTask.java

@@ -32,14 +32,14 @@ public class UserTask extends BaseTask {
 
         List list = jdbcTemplateHsms.queryForList(sb.toString());
 
-        FieldMapper groupMapper = groupTask.loadCache();
+        FieldMapper groupMapper = groupTask.loadCache(null);
         System.out.println(groupMapper.getIdCache());
 
 
     }
 
     @Override
-    public FieldMapper loadCache() {
+    public FieldMapper loadCache(String key) {
         log.info(" *** 加载用户user缓存 *** ");