222

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

@@ -25,58 +25,61 @@ public class StartApplication {
     public void start() {
         log.info("########### 开始迁移任务！###########");
         SqlTask task = null;
-        //task = SpringContextHolder.getBean("dictionaryTask");
-        //task.start();
-        //task = SpringContextHolder.getBean("tokenTask");
-        //task.start();
-        //task = SpringContextHolder.getBean("attachmentTask");
-        //task.start();
-        //task = SpringContextHolder.getBean("hospitalTask");
-        //task.start();
-        //task = SpringContextHolder.getBean("hospitalConfigTask");
-        //task.start();
-        //task = SpringContextHolder.getBean("groupTask");
-        //task.start();
-        //task = SpringContextHolder.getBean("departmentTask");
-        //task.start();
-        //task = SpringContextHolder.getBean("companyTask");
-        //task.start();
-        //task = SpringContextHolder.getBean("userTask");
-        //task.start();
-        //task = SpringContextHolder.getBean("userGroupTask");
-        //task.start();
-        //task = SpringContextHolder.getBean("roleUserTask");
-        //task.start();
-        //task = SpringContextHolder.getBean("areaTask");
-        //task.start();
-        task = SpringContextHolder.getBean("placeTask");
-        task.start();
-        //task = SpringContextHolder.getBean("incidentCategoryTask");
-        //task.start();
-        //task = SpringContextHolder.getBean("incidentCategoryConfigTask");
-        //task.start();
-        //task = SpringContextHolder.getBean("incidentAssignManagerTask");
-        //task.start();
-        //task = SpringContextHolder.getBean("incidentTask");
-        //task.start();
-        //task = SpringContextHolder.getBean("workHourManagementTask");
-        //task.start();
-        //task = SpringContextHolder.getBean("solutionTask");
-        //task.start();
-        //task = SpringContextHolder.getBean("solutionIntroduceTask");
-        //task.start();
-        //task = SpringContextHolder.getBean("consumableTask");
-        //task.start();
-        //task = SpringContextHolder.getBean("consumableHistoryTask");
-        //task.start();
-        //task = SpringContextHolder.getBean("repairSummaryTask");
-        //task.start();
-        //task = SpringContextHolder.getBean("summaryConsumableTask");
-        //task.start();
-        //task = SpringContextHolder.getBean("callLogTask");
-        //task.start();
-        //task = SpringContextHolder.getBean("hjzxRecordTask");
-        //task.start();
+//        task = SpringContextHolder.getBean("dictionaryTask");
+//        task.start();
+//        task = SpringContextHolder.getBean("tokenTask");
+//        task.start();
+//        task = SpringContextHolder.getBean("attachmentTask");
+//        task.start();
+//        task = SpringContextHolder.getBean("hospitalTask");
+//        task.start();
+//        task = SpringContextHolder.getBean("hospitalConfigTask");
+//        task.start();
+//        task = SpringContextHolder.getBean("groupTask");
+//        task.start();
+//        task = SpringContextHolder.getBean("departmentTask");
+//        task.start();
+//        task = SpringContextHolder.getBean("companyTask");
+//        task.start();
+//        task = SpringContextHolder.getBean("userTask");
+//        task.start();
+//        task = SpringContextHolder.getBean("userGroupTask");
+//        task.start();
+//        task = SpringContextHolder.getBean("roleUserTask");
+//        task.start();
+//		  task = SpringContextHolder.getBean("areaTask");
+//        task.start();
+//        task = SpringContextHolder.getBean("placeTask");
+//		  task.start();
+//        task = SpringContextHolder.getBean("incidentCategoryTask");
+//        task.start();
+//        task = SpringContextHolder.getBean("incidentCategoryConfigTask");
+//        task.start();
+//        task = SpringContextHolder.getBean("incidentTask");
+//        task.start();
+//        task = SpringContextHolder.getBean("incidentLogTask");
+//        task.start();
+//        task = SpringContextHolder.getBean("incidentSynergeticTask");
+//        task.start();
+//        task = SpringContextHolder.getBean("workHourManagementTask");
+//        task.start();
+//        task = SpringContextHolder.getBean("solutionTask");
+//        task.start();
+//        task = SpringContextHolder.getBean("solutionIntroduceTask");
+//        task.start();
+//        task = SpringContextHolder.getBean("consumableTask");
+//        task.start();
+//        task = SpringContextHolder.getBean("consumableHistoryTask");
+//        task.start();
+//        task = SpringContextHolder.getBean("repairSummaryTask");
+//        task.start();
+//        task = SpringContextHolder.getBean("summaryConsumableTask");
+//        task.start();
+//        task = SpringContextHolder.getBean("callLogTask");
+//        task.start();
+//        task = SpringContextHolder.getBean("hjzxRecordTask");
+//        task.start();
+		
 
 
         log.info("########### 迁移任务完成！###########");

src/main/java/com/dashitech/migration/task/incident/IncidentLogTask.java

@@ -22,10 +22,13 @@ import java.util.Map;
 public class IncidentLogTask extends BaseTask {
 
     @Autowired
+    SqlTask userTask;
+    @Autowired
+    SqlTask groupTask;
+    @Autowired
     SqlTask hospitalTask;
-
     @Autowired
-    SqlTask departmentTask;
+    SqlTask dictionaryTask;
 
     public static Log log = LogFactory.getLog(IncidentLogTask.class);
 
@@ -35,38 +38,32 @@ public class IncidentLogTask extends BaseTask {
         log.info(" *** IncidentLogTask start 开始 *** ");
 
         StringBuffer sb = new StringBuffer();
-        sb.append(" select * from itsm_incident ");
+        sb.append(" select * from itsm_incident_log ");
 
         List list = jdbcTemplateMdv2.queryForList(sb.toString());
 
         FieldMapper mapper = new FieldMapper();
-        mapper.addOperationRemove("id").addOperationRemove("version");
+        Map<Long, Long> userCache = userTask.loadCache().getIdCache();
+        mapper.addOperationUpdate("hos_id", "branch_id");
+        mapper.addOperationReplace("log_type", dictionaryTask.loadCache().getIdCache());
+        mapper.addOperationReplace("appointor_id", userCache);
+        mapper.addOperationReplace("worker_id", userCache);
+        mapper.addOperationReplace("group_id", groupTask.loadCache().getIdCache());
+        mapper.addOperationReplace("duty_id", hospitalTask.loadCache().getIdCache());
         mapper.trans2JdbcRow(list);
 
-        FieldMapper userMapper = loadCache();
         JdbcUtil jdbcUtil = new JdbcUtil(jdbcTemplateHsms);
-        jdbcUtil.batchPageInsert("itsm_itsm_incident", mapper.getRows());
+        jdbcUtil.batchPageInsert("itsm_itsm_incident_log", mapper.getRows());
 
         //clear释放内存
         mapper.clear();
-        userMapper.clear();
     }
 
     @Override
     public FieldMapper loadCache() {
         log.info(" *** IncidentLogTask loadCache 开始 *** ");
 
-        String sql = " select id,ACCOUNT,delete_flag from itsm_incident ";
-        List<Map<String, Object>> list = jdbcTemplateHsms.queryForList(sql);
-        sql = " select id,ACCOUNT,delete_flag from itsm_itsm_incident ";
-        List<Map<String, Object>> list2 = jdbcTemplateMdv2.queryForList(sql);
-
-        FieldMapper mapper = new FieldMapper();
-        mapper.addFieldMapper("ACCOUNT", "ACCOUNT");
-        mapper.addFieldMapper("delete_flag", "delete_flag");
-
-        DataMigrationter.loadCache(list, list2, mapper);
 
-        return mapper;
+        return null;
     }
 }

src/main/java/com/dashitech/migration/task/incident/IncidentSynergeticTask.java

@@ -23,9 +23,8 @@ public class IncidentSynergeticTask extends BaseTask {
 
     @Autowired
     SqlTask hospitalTask;
-
     @Autowired
-    SqlTask departmentTask;
+    SqlTask userTask;
 
     public static Log log = LogFactory.getLog(IncidentSynergeticTask.class);
 
@@ -35,38 +34,28 @@ public class IncidentSynergeticTask extends BaseTask {
         log.info(" *** IncidentSynergeticTask start 开始 *** ");
 
         StringBuffer sb = new StringBuffer();
-        sb.append(" select * from itsm_incident ");
+        sb.append(" select * from itsm_incident_synergetic ");
 
         List list = jdbcTemplateMdv2.queryForList(sb.toString());
 
         FieldMapper mapper = new FieldMapper();
-        mapper.addOperationRemove("id").addOperationRemove("version");
+        mapper.addOperationUpdate("hos_id", "branch_id");
+        mapper.addOperationReplace("user_id", userTask.loadCache().getIdCache());
+        mapper.addOperationReplace("duty_id", hospitalTask.loadCache().getIdCache());
         mapper.trans2JdbcRow(list);
 
-        FieldMapper userMapper = loadCache();
         JdbcUtil jdbcUtil = new JdbcUtil(jdbcTemplateHsms);
-        jdbcUtil.batchPageInsert("itsm_itsm_incident", mapper.getRows());
+        jdbcUtil.batchPageInsert("itsm_itsm_incident_synergetic", mapper.getRows());
 
         //clear释放内存
         mapper.clear();
-        userMapper.clear();
     }
 
     @Override
     public FieldMapper loadCache() {
         log.info(" *** IncidentSynergeticTask loadCache 开始 *** ");
 
-        String sql = " select id,ACCOUNT,delete_flag from itsm_incident ";
-        List<Map<String, Object>> list = jdbcTemplateHsms.queryForList(sql);
-        sql = " select id,ACCOUNT,delete_flag from itsm_itsm_incident ";
-        List<Map<String, Object>> list2 = jdbcTemplateMdv2.queryForList(sql);
-
-        FieldMapper mapper = new FieldMapper();
-        mapper.addFieldMapper("ACCOUNT", "ACCOUNT");
-        mapper.addFieldMapper("delete_flag", "delete_flag");
-
-        DataMigrationter.loadCache(list, list2, mapper);
 
-        return mapper;
+        return null;
     }
 }

src/main/java/com/dashitech/migration/task/incident/IncidentTask.java

@@ -45,7 +45,7 @@ public class IncidentTask extends BaseTask {
         log.info(" *** IncidentTask start 开始 *** ");
 
         StringBuffer sb = new StringBuffer();
-        sb.append(" select * from itsm_incident limit 0,1000 ");
+        sb.append(" select * from itsm_incident ");
 
         List list = jdbcTemplateMdv2.queryForList(sb.toString());
 
@@ -53,7 +53,6 @@ public class IncidentTask extends BaseTask {
         Map<Long, Long> userCache = userTask.loadCache().getIdCache();
         Map<Long, Long> dicCache = dictionaryTask.loadCache().getIdCache();
 
-        mapper.addOperationRemove("id").addOperationRemove("version");
         mapper.addOperationRemove("emergencyid").addOperationRemove("influenceid");
         mapper.addOperationUpdate("priority_id", "priorityid");
         mapper.addOperationUpdate("hos_id", "branch_id");

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

@@ -122,6 +122,24 @@ public class DictionaryTask extends BaseTask {
         idCache.put(1601L,20417L);
         idCache.put(1602L,20418L);
 
+        //事件日志-incident_log_type
+        idCache.put(1736L,20435L);
+        idCache.put(1737L,20436L);
+        idCache.put(1738L,20437L);
+        idCache.put(1739L,20438L);
+        idCache.put(1740L,20439L);
+        idCache.put(1741L,20440L);
+        idCache.put(1742L,20441L);
+        idCache.put(1743L,20442L);
+        idCache.put(1744L,20443L);
+        idCache.put(1745L,20444L);
+        idCache.put(1751L,20445L);
+        idCache.put(1752L,20446L);
+        idCache.put(1753L,20447L);
+        idCache.put(1754L,20448L);
+        idCache.put(1755L,20449L);
+        idCache.put(1766L,20450L);
+
         return mapper;
     }
 }