提交

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

@@ -1,7 +1,7 @@
 package com.dashitech.migration;
 
-import com.dashitech.migration.core.FieldMapper;
 import com.dashitech.migration.task.uc.CompanyTask;
+import com.dashitech.migration.task.uc.DepartmentTask;
 import com.dashitech.migration.task.uc.HospitalTask;
 import com.dashitech.migration.task.uc.XyGroupTask;
 import org.apache.commons.logging.Log;
@@ -33,6 +33,8 @@ public class StartApplication {
     CompanyTask companyTask;
     @Autowired
     SqlTask roleUserTask;
+    @Autowired
+    DepartmentTask departmentTask;
 
     @Value("${application.name}")
     private String appName;
@@ -53,11 +55,15 @@ public class StartApplication {
 
 //            userGroupTask.start();
 
+           // userTask.loadCache();
 //            roleUserTask.start();
 
             System.out.println("AAAAA");
         }
 
+        //companyTask.start();
+        //userTask.start();
+        departmentTask.start();
 
         log.info("########### 迁移任务完成！###########");
     }

src/main/java/com/dashitech/migration/task/category/IncidentCategoryConfigTask.java

@@ -0,0 +1,48 @@
+package com.dashitech.migration.task.category;
+
+import com.dashitech.migration.BaseTask;
+import com.dashitech.migration.core.FieldMapper;
+import com.dashitech.migration.util.JdbcUtil;
+import org.apache.commons.collections.CollectionUtils;
+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月12日
+ */
+@Component
+public class IncidentCategoryConfigTask extends BaseTask {
+
+    public static Log log = LogFactory.getLog(IncidentCategoryConfigTask.class);
+    @Override
+    @Transactional
+    public void start() {
+        StringBuffer sql = new StringBuffer("SELECT version,a.category_id,b._priority as priority,a.duty_id,a.branch_user_group_type as user_group,a.group_id,");
+        sql.append("a.user_id,NOW() as add_time,a.branch_id as hos_id FROM itsm_incident_category_usergroup a ");
+        sql.append(" JOIN itsm_incident_category b ON a.category_id = b.id");
+        if ("xiangyang".equals(appName)) {
+            sql.append(" WHERE a.branch_id <> 4 ");
+        }
+        List<Map<String, Object>> categoryConfigList = jdbcTemplateMdv2.queryForList(sql.toString());
+        FieldMapper mapper = new FieldMapper();
+        if (CollectionUtils.isNotEmpty(categoryConfigList)) {
+            mapper.addOperationAdd("score", getDicId(jdbcTemplateHsms,"incident_score","1"));
+            mapper.trans2JdbcRow(categoryConfigList);
+
+            JdbcUtil jdbcUtil = new JdbcUtil(jdbcTemplateHsms);
+            jdbcUtil.batchPageInsert("itsm_itsm_incident_category_config", mapper.getRows());
+        }
+        mapper.clear();
+    }
+
+    @Override
+    public FieldMapper loadCache() {
+        return null;
+    }
+}

src/main/java/com/dashitech/migration/task/category/IncidentCategoryTask.java

@@ -0,0 +1,43 @@
+package com.dashitech.migration.task.category;
+
+import com.dashitech.migration.BaseTask;
+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.stereotype.Component;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * @author song
+ * @date 2024年10月12日
+ */
+@Component
+public class IncidentCategoryTask extends BaseTask {
+
+    public static Log log = LogFactory.getLog(IncidentCategoryTask.class);
+    @Override
+    @Transactional
+    public void start() {
+        StringBuffer sql = new StringBuffer("SELECT id,version,category,parentid as parent,delete_flag,quanPinyin as qp,suoPinyin as jp,now() as add_time,");
+        sql.append("hierarchy,muti_category,muti_suoPinyin as muti_jp,muti_quanPinyin as muti_qp,alias,IFNULL(branch_id,1) as hos_id ");
+        sql.append(" FROM itsm_incident_category ");
+        List<Map<String, Object>> categoryList = jdbcTemplateMdv2.queryForList(sql.toString());
+
+        FieldMapper mapper = new FieldMapper();
+        mapper.trans2JdbcRow(categoryList);
+
+        JdbcUtil jdbcUtil = new JdbcUtil(jdbcTemplateHsms);
+        jdbcUtil.batchPageInsert("itsm_itsm_incident_category", mapper.getRows());
+
+        mapper.clear();
+    }
+
+    @Override
+    public FieldMapper loadCache() {
+        return null;
+    }
+}

src/main/java/com/dashitech/migration/task/consumable/ConsumableHistoryTask.java

@@ -0,0 +1,71 @@
+package com.dashitech.migration.task.consumable;
+
+import com.dashitech.migration.BaseTask;
+import com.dashitech.migration.core.FieldMapper;
+import com.dashitech.migration.task.uc.DepartmentTask;
+import com.dashitech.migration.task.uc.HospitalTask;
+import com.dashitech.migration.task.uc.UserTask;
+import com.dashitech.migration.util.JdbcUtil;
+import org.apache.commons.collections.CollectionUtils;
+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月12日
+ */
+@Component
+public class ConsumableHistoryTask extends BaseTask {
+
+    public static Log log = LogFactory.getLog(ConsumableHistoryTask.class);
+
+    @Autowired
+    private HospitalTask hospitalTask;
+
+    @Autowired
+    private UserTask userTask;
+
+    @Autowired
+    private DepartmentTask departmentTask;
+
+    @Override
+    @Transactional
+    public void start() {
+        StringBuffer sql = new StringBuffer("SELECT id,asset_consumables_id,operator,VERSION,time,motion,source,source_id,type,consumables_sum,_description,");
+        sql.append("_version_number,_details,extra1,extra2,spd_code,consume_type,consume_source,use_dept,his_id,incident_id,repair_summary_id,summary_id,");
+        if ("xiangyang".equals(appName)) {
+            sql.append("if(repair_duty=4,10,repair_duty) as repair_duty,IF(branch_id=4,3,branch_id) as hos_id ");
+        } else {
+            sql.append("repair_duty,hos_id ");
+        }
+        sql.append(" FROM itsm_asset_consumables_history ");
+        List<Map<String, Object>> consumableHistoryList = jdbcTemplateMdv2.queryForList(sql.toString());
+        FieldMapper mapper = new FieldMapper();
+        if (CollectionUtils.isNotEmpty(consumableHistoryList)) {
+            mapper.addOperationReplace("repair_duty", hospitalTask.loadCache().getIdCache());
+            mapper.addOperationReplace("operator", userTask.loadCache().getIdCache());
+            if ("xiangyang".equals(appName)) {
+                mapper.addOperationReplace("use_dept", departmentTask.loadCache().getIdCache());
+            }
+            mapper.trans2JdbcRow(consumableHistoryList);
+
+            JdbcUtil jdbcUtil = new JdbcUtil(jdbcTemplateHsms);
+            jdbcUtil.batchPageInsert("itsm_asset_consumables_history", mapper.getRows());
+        }
+
+
+        mapper.clear();
+
+    }
+
+    @Override
+    public FieldMapper loadCache() {
+        return null;
+    }
+}

src/main/java/com/dashitech/migration/task/consumable/ConsumableTask.java

@@ -0,0 +1,49 @@
+package com.dashitech.migration.task.consumable;
+
+import com.dashitech.migration.BaseTask;
+import com.dashitech.migration.core.FieldMapper;
+import com.dashitech.migration.task.uc.HospitalTask;
+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月12日
+ */
+@Component
+public class ConsumableTask extends BaseTask {
+
+    public static Log log = LogFactory.getLog(ConsumableTask.class);
+
+    @Autowired
+    private HospitalTask hospitalTask;
+
+    @Override
+    @Transactional
+    public void start() {
+        StringBuffer sql = new StringBuffer("SELECT id,version,NAME,brand_model as model,inventory_num as stock,start_price as price,company_ids as supplier_id,");
+        sql.append("delete_flag,unit,IFNULL(spd_code,spdcode) as spd_code,duty_id as hos_id FROM itsm_asset_consumable");
+        List<Map<String, Object>> consumableList = jdbcTemplateMdv2.queryForList(sql.toString());
+        FieldMapper mapper = new FieldMapper();
+        mapper.addOperationReplace("hos_id", hospitalTask.loadCache().getIdCache());
+        mapper.trans2JdbcRow(consumableList);
+
+        JdbcUtil jdbcUtil = new JdbcUtil(jdbcTemplateHsms);
+        jdbcUtil.batchPageInsert("itsm_itsm_consumable", mapper.getRows());
+
+        mapper.clear();
+
+    }
+
+    @Override
+    public FieldMapper loadCache() {
+        return null;
+    }
+}

src/main/java/com/dashitech/migration/task/consumable/SummaryConsumableTask.java

@@ -0,0 +1,41 @@
+package com.dashitech.migration.task.consumable;
+
+import com.dashitech.migration.BaseTask;
+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.stereotype.Component;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * @author song
+ * @date 2024年10月12日
+ */
+@Component
+public class SummaryConsumableTask extends BaseTask {
+
+    public static Log log = LogFactory.getLog(SummaryConsumableTask.class);
+    @Override
+    @Transactional
+    public void start() {
+        StringBuffer sql = new StringBuffer("SELECT * from itsm_summary_consumables");
+        List<Map<String, Object>> summaryConsuableList = jdbcTemplateMdv2.queryForList(sql.toString());
+        FieldMapper mapper = new FieldMapper();
+        mapper.trans2JdbcRow(summaryConsuableList);
+
+        JdbcUtil jdbcUtil = new JdbcUtil(jdbcTemplateHsms);
+        jdbcUtil.batchPageInsert("itsm_itsm_summary_consumables", mapper.getRows());
+
+        mapper.clear();
+
+    }
+
+    @Override
+    public FieldMapper loadCache() {
+        return null;
+    }
+}

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

@@ -35,21 +35,24 @@ public class DictionaryTask extends BaseTask {
     }
 
 
-    public FieldMapper loadXiangYangCache() {
+    private FieldMapper loadXiangYangCache() {
         log.info(" *** 加载襄阳字典缓存 *** ");
         FieldMapper mapper = new FieldMapper();
         Map<Long, Long> dicIdCache = new HashMap<>();
         mapper.setIdCache(dicIdCache);
-
+        //知识库
         dicIdCache.put(71L, 20404L); //待审核
         dicIdCache.put(72L, 20405L); //已发布
         dicIdCache.put(73L, 20406L); //待整改
         dicIdCache.put(74L, 20407L); //已停用
+        //耗材消耗
+        dicIdCache.put(1735L, 20557L);//消耗
+        dicIdCache.put(1736L, 20558L);//撤销
 
         return mapper;
     }
 
-    public FieldMapper loadNanJingCache() {
+    private FieldMapper loadNanJingCache() {
         log.info(" *** 加载南京字典缓存 *** ");
         FieldMapper mapper = new FieldMapper();
         Map<Long, Long> idCache = new HashMap<>();

src/main/java/com/dashitech/migration/task/solution/SolutionIntroduce.java

@@ -0,0 +1,42 @@
+package com.dashitech.migration.task.solution;
+
+import com.dashitech.migration.BaseTask;
+import com.dashitech.migration.core.FieldMapper;
+import com.dashitech.migration.task.uc.UserTask;
+import com.dashitech.migration.util.JdbcUtil;
+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月12日
+ */
+@Component
+public class SolutionIntroduce extends BaseTask {
+
+    @Autowired
+    private UserTask userTask;
+
+    @Override
+    @Transactional
+    public void start() {
+        StringBuffer sql = new StringBuffer("select * from itsm_itsm_solution_introduce");
+        List<Map<String, Object>> solutionStarList = jdbcTemplateMdv2.queryForList(sql.toString());
+        FieldMapper mapper = new FieldMapper();
+        Map<Long, Long> userIdCache = userTask.loadCache().getIdCache();
+        mapper.addOperationReplace("user_id", userIdCache);
+        mapper.trans2JdbcRow(solutionStarList);
+
+        JdbcUtil jdbcUtil = new JdbcUtil(jdbcTemplateHsms);
+        jdbcUtil.batchPageInsert("itsm_itsm_solution_introduce", mapper.getRows());
+    }
+
+    @Override
+    public FieldMapper loadCache() {
+        return null;
+    }
+}

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

@@ -2,6 +2,11 @@ package com.dashitech.migration.task.solution;
 
 import com.dashitech.migration.BaseTask;
 import com.dashitech.migration.core.FieldMapper;
+import com.dashitech.migration.task.other.DictionaryTask;
+import com.dashitech.migration.task.uc.HospitalTask;
+import com.dashitech.migration.util.JdbcUtil;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
 import org.springframework.transaction.annotation.Transactional;
 
 import java.util.List;
@@ -11,16 +16,35 @@ import java.util.Map;
  * @author song
  * @date 2024年10月12日
  */
+@Component
 public class SolutionTask extends BaseTask {
 
+    @Autowired
+    HospitalTask hospitalTask;
+
+    @Autowired
+    DictionaryTask dictionaryTask;
+
     @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,");
+        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();
+        mapper.addOperationUpdate("duty_dept", "hos_id");
+        Map<Long, Long> hosIdCache = hospitalTask.loadCache().getIdCache();
+        Map<Long, Long> dicIdCache = dictionaryTask.loadCache().getIdCache();
+        mapper.addOperationReplace("duty_dept", hosIdCache);
+        mapper.addOperationReplace("status", dicIdCache);
+        mapper.trans2JdbcRow(solutionList);
+
+        JdbcUtil jdbcUtil = new JdbcUtil(jdbcTemplateHsms);
+        jdbcUtil.batchPageInsert("itsm_itsm_solution", mapper.getRows());
+
+        //clear释放内存
+        mapper.clear();
     }
 
     @Override

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

@@ -0,0 +1,61 @@
+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月12日
+ */
+@Component
+public class DepartmentTask extends BaseTask {
+
+    public static Log log = LogFactory.getLog(DepartmentTask.class);
+
+    @Override
+    @Transactional
+    public void start() {
+        StringBuffer sql = new StringBuffer("SELECT dept,CODE,parentId,email,delete_flag,address as _address,place_id as floor_id,area_id as building_id,pinyin,");
+        sql.append("branch_id as _hospital_id,dept_alias,input_code,phone as many_phone,qrcode,1 as flag,IF(phone is not null,SUBSTRING_INDEX(phone,',',1),null) as _phone ");
+        sql.append(" FROM itsm_uc_dept where id in (select distinct b.id from itsm_incident a join itsm_uc_dept b on a.dept = b.id where a.dept > 1204)");
+        List<Map<String, Object>> deptList = jdbcTemplateMdv2.queryForList(sql.toString());
+
+        FieldMapper mapper = new FieldMapper();
+        mapper.addOperationAdd("_type", getDicId(jdbcTemplateHsms, "dept_type", "other"));
+        mapper.trans2JdbcRow(deptList);
+
+        FieldMapper deptMapper = this.loadCache();
+        RowsWrap rw = DataMigrationter.getRowsWrap(mapper,deptMapper);
+        JdbcUtil jdbcUtil = new JdbcUtil(jdbcTemplateHsms);
+        //科室只做更新 已有的科室不做处理
+        jdbcUtil.batchPageInsert("itsm_uc_dept", rw.getInsertRows());
+
+        mapper.clear();
+        deptMapper.clear();
+    }
+
+    @Override
+    public FieldMapper loadCache() {
+        log.info(" *** 加载科室缓存 *** ");
+        StringBuffer sql = new StringBuffer("select id,dept from itsm_uc_dept");
+        List<Map<String, Object>> hsmsDeptList = jdbcTemplateHsms.queryForList(sql.toString());
+        List<Map<String, Object>> itsmDeptList = jdbcTemplateMdv2.queryForList(sql.toString());
+
+        FieldMapper mapper = new FieldMapper();
+        mapper.addFieldMapper("dept", "dept");
+
+        DataMigrationter.loadCache(hsmsDeptList, itsmDeptList, mapper);
+
+        return mapper;
+    }
+}

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

@@ -24,6 +24,9 @@ public class UserTask extends BaseTask {
     @Autowired
     SqlTask hospitalTask;
 
+    @Autowired
+    SqlTask departmentTask;
+
     public static Log log = LogFactory.getLog(UserTask.class);
 
     @Override
@@ -44,6 +47,9 @@ public class UserTask extends BaseTask {
         mapper.addOperationAdd("usertype", getDicId(jdbcTemplateHsms,"usertype","4")); //用户类型-默认三方人员
         mapper.addOperationReplace("hospital_id", hospitalTask.loadCache().getIdCache());
         mapper.addOperationReplace("duty_dept", hospitalTask.loadCache().getIdCache());
+        if ("xiangyang".equals(appName)) {
+            mapper.addOperationReplace("DEPTID", departmentTask.loadCache().getIdCache());
+        }
         mapper.trans2JdbcRow(list);
 
         FieldMapper userMapper = loadCache();

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

@@ -7,6 +7,7 @@ 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;
@@ -25,6 +26,7 @@ public class XyGroupTask extends BaseTask {
 
 
     @Override
+    @Transactional
     public void start() {
         log.info(" *** 襄阳工作组group转换开始 *** ");
 
@@ -43,7 +45,7 @@ public class XyGroupTask extends BaseTask {
         mapper.trans2JdbcRow(groupList);
 
         JdbcUtil jdbcUtil = new JdbcUtil(jdbcTemplateHsms);
-        //jdbcUtil.batchPageInsert("itsm_uc_groups", mapper.getRows());
+        jdbcUtil.batchPageInsert("itsm_uc_groups", mapper.getRows());
 
         //clear释放内存
         mapper.clear();

src/main/java/com/dashitech/migration/task/workhour/WorkHourManagementTask.java

@@ -0,0 +1,43 @@
+package com.dashitech.migration.task.workhour;
+
+import com.dashitech.migration.BaseTask;
+import com.dashitech.migration.core.FieldMapper;
+import com.dashitech.migration.task.uc.HospitalTask;
+import com.dashitech.migration.util.JdbcUtil;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+import java.util.Map;
+
+/**
+ * @author song
+ * @date 2024年10月12日
+ */
+@Component
+public class WorkHourManagementTask extends BaseTask {
+
+    @Autowired
+    private HospitalTask hospitalTask;
+
+    @Override
+    public void start() {
+        StringBuffer sql = new StringBuffer("SELECT id,version,work_unit,work_name,tree_level,parent,wage,");
+        sql.append("work_hour_num as work_hour,duty as hos_id,delete_flag FROM itsm_work_hour_management ");
+        List<Map<String, Object>> workHourList = jdbcTemplateMdv2.queryForList(sql.toString());
+
+        FieldMapper mapper = new FieldMapper();
+        mapper.addOperationReplace("hos_id", hospitalTask.loadCache().getIdCache());
+        mapper.trans2JdbcRow(workHourList);
+
+        JdbcUtil jdbcUtil = new JdbcUtil(jdbcTemplateHsms);
+        jdbcUtil.batchPageInsert("itsm_itsm_work_hour_management", mapper.getRows());
+
+        mapper.clear();
+    }
+
+    @Override
+    public FieldMapper loadCache() {
+        return null;
+    }
+}