22

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

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

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

@@ -28,11 +28,11 @@ public class StartApplication {
         log.info("########### 开始迁移任务！###########");
 
         //工作组
-        groupTask.start();
+//        groupTask.start();
 
 //        userTask.start();
 
-//        groupTask.loadCache();
+        groupTask.loadCache();
 
         log.info("########### 迁移任务完成！###########");
     }

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

@@ -0,0 +1,34 @@
+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.transaction.annotation.Transactional;
+
+/**
+ * Created by CX on 2024/10/10.
+ */
+@Component
+public class CompanyTask extends BaseTask {
+
+    public static Log log = LogFactory.getLog(CompanyTask.class);
+
+    @Override
+    @Transactional
+    public void start() {
+
+    }
+
+    @Override
+    public FieldMapper loadCache() {
+        log.info(" *** 加载请求人Requesterl缓存 *** ");
+
+        FieldMapper mapper = new FieldMapper();
+
+
+
+        return mapper;
+    }
+}

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

@@ -25,18 +25,17 @@ public class DictionaryTask extends BaseTask {
     }
 
     @Override
-    public FieldMapper loadCache(String key) {
+    public FieldMapper loadCache() {
         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); //已停用
 
-        }
+        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(null).getIdCache();
+        Map<Long, Long> hosIdCache = hospitalTask.loadCache().getIdCache();
         mapper.addOperationReplace("branch_id", hosIdCache);
         mapper.trans2JdbcRow(list);
 
@@ -52,7 +52,7 @@ public class GroupTask extends BaseTask {
     }
 
     @Override
-    public FieldMapper loadCache(String key) {
+    public FieldMapper loadCache() {
         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(null).getIdCache();
+        Map<Long, Long> hosIdCache = hospitalTask.loadCache().getIdCache();
         mapper.addOperationReplace("branch_id", hosIdCache);
 
         DataMigrationter.loadCache(list, list2, mapper);

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

@@ -36,9 +36,25 @@ public class HospitalTask extends BaseTask {
     }
 
     @Override
-    public FieldMapper loadCache(String key) {
+    public FieldMapper loadCache() {
         log.info(" *** 加载院区Hospital缓存 *** ");
 
+        FieldMapper mapper = loadNanjingCache();
+
+        return mapper;
+    }
+
+    public FieldMapper loadXiangyangCache() {
+        FieldMapper mapper = new FieldMapper();
+        Map<Long, Long> hosIdCache = new HashMap<>();
+        mapper.setIdCache(hosIdCache);
+
+
+
+        return mapper;
+    }
+
+    public FieldMapper loadNanjingCache() {
         FieldMapper mapper = new FieldMapper();
         Map<Long, Long> hosIdCache = new HashMap<>();
         mapper.setIdCache(hosIdCache);
@@ -48,7 +64,6 @@ public class HospitalTask extends BaseTask {
         hosIdCache.put(3L, 5L); //信息科
         hosIdCache.put(4L, 6L); //设备科
 
-
         return mapper;
     }
 }

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

@@ -0,0 +1,34 @@
+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.transaction.annotation.Transactional;
+
+/**
+ * Created by CX on 2024/10/10.
+ */
+@Component
+public class RoleTask extends BaseTask {
+
+    public static Log log = LogFactory.getLog(RoleTask.class);
+
+    @Override
+    @Transactional
+    public void start() {
+
+    }
+
+    @Override
+    public FieldMapper loadCache() {
+        log.info(" *** 加载角色Role缓存 *** ");
+
+        FieldMapper mapper = new FieldMapper();
+
+
+
+        return mapper;
+    }
+}

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(null);
+        FieldMapper groupMapper = groupTask.loadCache();
         System.out.println(groupMapper.getIdCache());
 
 
     }
 
     @Override
-    public FieldMapper loadCache(String key) {
+    public FieldMapper loadCache() {
         log.info(" *** 加载用户user缓存 *** ");
 
 

src/main/resources/migration.sql

@@ -0,0 +1,135 @@
+
+
+TRUNCATE TABLE itsm_itsm_alarm;
+TRUNCATE TABLE itsm_itsm_alarm_incident;
+TRUNCATE TABLE itsm_itsm_asset;
+TRUNCATE TABLE itsm_itsm_asset_consumables_history;
+TRUNCATE TABLE itsm_itsm_asset_product;
+TRUNCATE TABLE itsm_itsm_asset_product_incident_category;
+TRUNCATE TABLE itsm_itsm_consumable;
+TRUNCATE TABLE itsm_itsm_incident;
+TRUNCATE TABLE itsm_itsm_incident_assign_manager;
+TRUNCATE TABLE itsm_itsm_incident_category;
+TRUNCATE TABLE itsm_itsm_incident_category_config;
+TRUNCATE TABLE itsm_itsm_incident_log;
+TRUNCATE TABLE itsm_itsm_incident_synergetic;
+TRUNCATE TABLE itsm_itsm_inspection;
+TRUNCATE TABLE itsm_itsm_inspection_batch;
+TRUNCATE TABLE itsm_itsm_inspection_form;
+TRUNCATE TABLE itsm_itsm_inspection_form_item;
+TRUNCATE TABLE itsm_itsm_inspection_form_item_config;
+TRUNCATE TABLE itsm_itsm_inspection_form_page;
+TRUNCATE TABLE itsm_itsm_inspection_form_values;
+TRUNCATE TABLE itsm_itsm_inspection_node;
+TRUNCATE TABLE itsm_itsm_inspection_node_tag;
+TRUNCATE TABLE itsm_itsm_inspection_task;
+TRUNCATE TABLE itsm_itsm_inspection_task_log;
+TRUNCATE TABLE itsm_itsm_inspection_temp_nodes;
+TRUNCATE TABLE itsm_itsm_inspection_template;
+TRUNCATE TABLE itsm_itsm_repair_summary;
+TRUNCATE TABLE itsm_itsm_solution;
+TRUNCATE TABLE itsm_itsm_solution_introduce;
+TRUNCATE TABLE itsm_itsm_solution_log;
+TRUNCATE TABLE itsm_itsm_solution_star;
+TRUNCATE TABLE itsm_itsm_summary_consumables;
+TRUNCATE TABLE itsm_itsm_work_hour_management;
+TRUNCATE TABLE itsm_itsm_wx_incident;
+
+TRUNCATE TABLE itsm_hjzx_record;
+TRUNCATE TABLE itsm_call_config;
+-- TRUNCATE TABLE itsm_uc_company;
+TRUNCATE TABLE itsm_uc_room;
+TRUNCATE TABLE itsm_view_workday;
+TRUNCATE TABLE itsm_view_hjzx_message;
+TRUNCATE TABLE itsm_view_hjzx_evaluate;
+
+
+
+
+
+手动同步院区，责任科室 -> 院区,院区配置
+
+用户角色补全
+itsm_uc_user engineer company branch_id duty_id
+itsm_uc_company     院区id
+itsm_uc_user_role
+itsm_uc_role_menu   需要手动重新配置
+itsm_uc_groups  需要手动重新配置：班次组长等
+
+
+
+
+
+
+迁移数据
+
+itsm_base_dictionary 有没有自定义增加的字典
+
+itsm_uc_requester -> itsm_itsm_incident.requesterId userId
+
+itsm_message_job  复制数据
+
+
+系统配置补全
+itsm_system_configurations
+
+附件迁移 表+文件
+itsm_base_attachment -> itsm_base_attachment
+
+#通话记录
+itsm_call_record -> itsm_call_log
+#留言
+itsm_hjzx_record -> itsm_hjzx_record
+
+微信配置多条，itsm_message_manager绑定wechatConfigId
+
+callSocket重新配置
+
+nginx 地址处理
+
+ftp 安装
+
+录音文件整合
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+