提交

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

@@ -25,52 +25,58 @@ 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("incidentCategoryTask");
-//        task.start();
-//        task = SpringContextHolder.getBean("incidentCategoryConfigTask");
-//        task.start();
-        task = SpringContextHolder.getBean("incidentTask");
+        //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("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("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();
 
 
         log.info("########### 迁移任务完成！###########");

src/main/java/com/dashitech/migration/core/DataMigrationter.java

@@ -29,7 +29,7 @@ public class DataMigrationter {
                 //拼接联合主键，判断是更新，还是新增
                 StringBuffer key = new StringBuffer();
                 for (DataMapper fieldMapper : cacheMapper.getFieldList()) {
-                    Object value = row.get(fieldMapper.getSourceName());
+                    Object value = row.get(fieldMapper.getTargetName());
                     //可能构建联合主键时，需要替换成新数据
                     value = getOprationReplaceValue(dataMapper, fieldMapper, value);
                     key.append(value).append("_");

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

@@ -8,7 +8,6 @@ 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.core.annotation.Order;
 import org.springframework.stereotype.Component;
 import org.springframework.transaction.annotation.Transactional;
 
@@ -27,6 +26,12 @@ public class IncidentAssignManagerTask extends BaseTask {
     @Autowired
     SqlTask departmentTask;
 
+    @Autowired
+    SqlTask userTask;
+
+    @Autowired
+    SqlTask groupTask;
+
     public static Log log = LogFactory.getLog(IncidentAssignManagerTask.class);
 
     @Override
@@ -35,21 +40,26 @@ public class IncidentAssignManagerTask extends BaseTask {
         log.info(" *** IncidentAssignManagerTask start 开始 *** ");
 
         StringBuffer sb = new StringBuffer();
-        sb.append(" select * from itsm_incident ");
+        sb.append(" select * from itsm_incident_assign_manager ");
 
         List list = jdbcTemplateMdv2.queryForList(sb.toString());
 
         FieldMapper mapper = new FieldMapper();
-        mapper.addOperationRemove("id").addOperationRemove("version");
+        mapper.addOperationRemove("id").addOperationRemove("userOrGroupType").addOperationRemove("branch_id");
+        mapper.addOperationUpdate("handle_group", "_group");
+        mapper.addOperationUpdate("batch_no", "batch_id");
+        mapper.addOperationUpdate("hos_id", "duty_id");
+        mapper.addOperationReplace("duty_id", hospitalTask.loadCache().getIdCache());
+        mapper.addOperationReplace("dept_id", departmentTask.loadCache().getIdCache());
+        mapper.addOperationReplace("handle_user", userTask.loadCache().getIdCache());
+        mapper.addOperationReplace("_group", groupTask.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_assign_manager", mapper.getRows());
 
         //clear释放内存
         mapper.clear();
-        userMapper.clear();
     }
 
     @Override

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

@@ -4,7 +4,6 @@ import com.dashitech.migration.BaseTask;
 import com.dashitech.migration.SqlTask;
 import com.dashitech.migration.core.DataMigrationter;
 import com.dashitech.migration.core.FieldMapper;
-import com.dashitech.migration.core.RowsWrap;
 import com.dashitech.migration.util.JdbcUtil;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
@@ -35,6 +34,9 @@ public class IncidentTask extends BaseTask {
     @Autowired
     SqlTask dictionaryTask;
 
+    @Autowired
+    SqlTask placeTask;
+
     public static Log log = LogFactory.getLog(IncidentTask.class);
 
     @Override
@@ -71,6 +73,7 @@ public class IncidentTask extends BaseTask {
         //只有襄阳需要处理科室，南京不用
         if ("xiangyang".equals(appName)) {
             mapper.addOperationReplace("dept", departmentTask.loadCache().getIdCache());
+            mapper.addOperationReplace("placeid", placeTask.loadCache().getIdCache());
         }
         mapper.trans2JdbcRow(list);
 

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

@@ -0,0 +1,60 @@
+package com.dashitech.migration.task.uc;
+
+import com.dashitech.migration.BaseTask;
+import com.dashitech.migration.core.DataMigrationter;
+import com.dashitech.migration.core.FieldMapper;
+import com.dashitech.migration.core.RowsWrap;
+import com.dashitech.migration.util.JdbcUtil;
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
+import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * @author song
+ * @date 2024年10月14日
+ */
+@Component
+public class AreaTask extends BaseTask {
+
+    public static Log log = LogFactory.getLog(AreaTask.class);
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public void start() {
+        log.info(" *** 楼栋AreaTask转换开始 *** ");
+        StringBuffer sql = new StringBuffer("select 0 as version,IF(branch_id=4,3,branch_id) as hos_id,area as building_name,now() as operator_time, ");
+        sql.append(" delete_flag as _delete from itsm_uc_area");
+        List<Map<String, Object>> areaList = jdbcTemplateMdv2.queryForList(sql.toString());
+        FieldMapper mapper = new FieldMapper();
+        mapper.trans2JdbcRow(areaList);
+
+        FieldMapper areaMapper = this.loadCache();
+        RowsWrap rw = DataMigrationter.getRowsWrap(mapper,areaMapper);
+        JdbcUtil jdbcUtil = new JdbcUtil(jdbcTemplateHsms);
+        //科室只做更新 已有的科室不做处理
+        jdbcUtil.batchPageInsert("itsm_uc_building", rw.getInsertRows());
+
+        mapper.clear();
+    }
+
+    @Override
+    public FieldMapper loadCache() {
+        log.info(" *** 加载楼栋area缓存 *** ");
+        StringBuffer sql = new StringBuffer("select id,hos_id,building_name from itsm_uc_building ");
+        List<Map<String, Object>> buildingList = jdbcTemplateHsms.queryForList(sql.toString());
+        sql = new StringBuffer("select id,IF(branch_id=4,3,branch_id) as branch_id,area from itsm_uc_area ");
+        List<Map<String, Object>> areaList = jdbcTemplateMdv2.queryForList(sql.toString());
+
+        FieldMapper mapper = new FieldMapper();
+        mapper.addFieldMapper("building_name", "area");
+        mapper.addFieldMapper("hos_id", "branch_id");
+
+        DataMigrationter.loadCache(buildingList, areaList, mapper);
+
+        return mapper;
+    }
+}

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

@@ -0,0 +1,64 @@
+package com.dashitech.migration.task.uc;
+
+import com.dashitech.migration.BaseTask;
+import com.dashitech.migration.core.DataMigrationter;
+import com.dashitech.migration.core.FieldMapper;
+import com.dashitech.migration.core.RowsWrap;
+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;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * @author song
+ * @date 2024年10月14日
+ */
+@Component
+public class PlaceTask extends BaseTask {
+
+    public static Log log = LogFactory.getLog(PlaceTask.class);
+
+    @Autowired
+    private AreaTask areaTask;
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public void start() {
+        log.info(" *** 楼层PlaceTask转换开始 *** ");
+        StringBuffer sql = new StringBuffer("select 0 as version,area_id as build_id,SUBSTRING_INDEX(SUBSTRING_INDEX(place,'楼',1),'号',1) as floor_name,IF(branch_id=4,3,branch_id) as hos_id,now() as operator_time, ");
+        sql.append(" delete_flag as _delete from itsm_uc_place");
+        List<Map<String, Object>> placeList = jdbcTemplateMdv2.queryForList(sql.toString());
+        FieldMapper mapper = new FieldMapper();
+        mapper.addOperationReplace("build_id", areaTask.loadCache().getIdCache());
+        mapper.trans2JdbcRow(placeList);
+
+        FieldMapper areaMapper = this.loadCache();
+        RowsWrap rw = DataMigrationter.getRowsWrap(mapper,areaMapper);
+        JdbcUtil jdbcUtil = new JdbcUtil(jdbcTemplateHsms);
+        //科室只做更新 已有的科室不做处理
+        jdbcUtil.batchPageInsert("itsm_uc_floor", rw.getInsertRows());
+    }
+
+    @Override
+    public FieldMapper loadCache() {
+        log.info(" *** 加载楼层place缓存 *** ");
+        StringBuffer sql = new StringBuffer("select id,hos_id,build_id,floor_name from itsm_uc_floor ");
+        List<Map<String, Object>> floorList = jdbcTemplateHsms.queryForList(sql.toString());
+        sql = new StringBuffer("select id,IF(branch_id=4,3,branch_id) as branch_id,area_id,SUBSTRING_INDEX(SUBSTRING_INDEX(place,'楼',1),'号',1) as place from itsm_uc_place ");
+        List<Map<String, Object>> placeList = jdbcTemplateMdv2.queryForList(sql.toString());
+
+        FieldMapper mapper = new FieldMapper();
+        mapper.addFieldMapper("floor_name", "place");
+        mapper.addFieldMapper("build_id", "area_id");
+        mapper.addFieldMapper("hos_id", "branch_id");
+
+        DataMigrationter.loadCache(floorList, placeList, mapper);
+
+        return mapper;
+    }
+}