提交

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

@@ -1,15 +1,15 @@
 package com.dashitech.migration;
 
-import com.dashitech.migration.task.uc.CompanyTask;
-import com.dashitech.migration.task.uc.DepartmentTask;
+import com.dashitech.migration.task.other.DictionaryTask;
 import com.dashitech.migration.task.uc.HospitalTask;
-import com.dashitech.migration.task.uc.XyGroupTask;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Service;
 
+import java.util.List;
+
 /**
  * 迁移数据启动类
  * Created by CX on 2024/10/10.
@@ -20,51 +20,22 @@ public class StartApplication {
     public static Log log = LogFactory.getLog(StartApplication.class);
 
     @Autowired
-    SqlTask groupTask;
-    @Autowired
-    SqlTask userTask;
-    @Autowired
-    SqlTask userGroupTask;
-    @Autowired
-    HospitalTask hospitalTask;
-    @Autowired
-    XyGroupTask xyGroupTask;
-    @Autowired
-    CompanyTask companyTask;
-    @Autowired
-    SqlTask roleUserTask;
-    @Autowired
-    DepartmentTask departmentTask;
+    private List<SqlTask> sqlTasks;
 
     @Value("${application.name}")
     private String appName;
 
     public void start() {
         log.info("########### 开始迁移任务！###########");
-
-        if ("xiangyang".equals(appName)) {
-            //责任科室转院区
-            //hospitalTask.start();
-            //工作组
-            //xyGroupTask.start();
-        } else {
-
-//            companyTask.start();
-
-//            userTask.start();
-
-//            userGroupTask.start();
-
-           // userTask.loadCache();
-//            roleUserTask.start();
-
-            System.out.println("AAAAA");
+        for (SqlTask sqlTask : sqlTasks) {
+            if (sqlTask instanceof DictionaryTask) {
+                continue;
+            }
+            if ("xiangyang".equals(appName) && sqlTask instanceof HospitalTask) {
+                sqlTask.start();
+            }
         }
 
-        //companyTask.start();
-        //userTask.start();
-        departmentTask.start();
-
         log.info("########### 迁移任务完成！###########");
     }
 

src/main/java/com/dashitech/migration/task/call/CallLogTask.java

@@ -0,0 +1,46 @@
+package com.dashitech.migration.task.call;
+
+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 CallLogTask extends BaseTask {
+
+    public static Log log = LogFactory.getLog(CallLogTask.class);
+
+    @Override
+    @Transactional
+    public void start() {
+        log.info("通话记录callLog转换开始");
+
+        StringBuffer sql = new StringBuffer("SELECT version,call_accept,caller_id_number as DTMFA,destination_number as DTMFB,created_time as response_time,");
+        sql.append("gate_way as phyIDA,recording_file_name as _path,call_type,is_answered as call_state,branch_id as hos_id");
+        sql.append("if(calltime is null,if(is_answered=1,TIMESTAMPDIFF(MINUTE,created_time,over_time),null),calltime) as long_time FROM titsm_call_record");
+        List<Map<String, Object>> callLogList = jdbcTemplateMdv2.queryForList(sql.toString());
+
+        FieldMapper mapper = new FieldMapper();
+        mapper.trans2JdbcRow(callLogList);
+
+        JdbcUtil jdbcUtil = new JdbcUtil(jdbcTemplateHsms);
+        jdbcUtil.batchPageInsert("itsm_call_log", mapper.getRows());
+
+        mapper.clear();
+    }
+
+    @Override
+    public FieldMapper loadCache() {
+        return null;
+    }
+}

src/main/java/com/dashitech/migration/task/call/HjzxRecordTask.java

@@ -0,0 +1,46 @@
+package com.dashitech.migration.task.call;
+
+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 HjzxRecordTask extends BaseTask {
+
+    public static Log log = LogFactory.getLog(HjzxRecordTask.class);
+    @Override
+    @Transactional
+    public void start() {
+        log.info("呼叫中心HjzxRecord转换开始");
+
+        StringBuffer sql = new StringBuffer(" select * from itsm_hjzx_record");
+        List<Map<String, Object>> hjzxList = jdbcTemplateMdv2.queryForList(sql.toString());
+
+        FieldMapper mapper = new FieldMapper();
+        mapper.addOperationRemove("id");
+        mapper.addOperationUpdate("hos_id", "branch_id");
+        mapper.trans2JdbcRow(hjzxList);
+
+        JdbcUtil jdbcUtil = new JdbcUtil(jdbcTemplateHsms);
+        jdbcUtil.batchPageInsert("itsm_hjzx_record", mapper.getRows());
+
+        mapper.clear();
+    }
+
+    @Override
+    public FieldMapper loadCache() {
+        return null;
+    }
+}

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

@@ -37,6 +37,8 @@ public class ConsumableHistoryTask extends BaseTask {
     @Override
     @Transactional
     public void start() {
+        log.info("耗材日志ConsumableHistoryTask转换开始");
+
         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)) {

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

@@ -2,6 +2,7 @@ package com.dashitech.migration.task.consumable;
 
 import com.dashitech.migration.BaseTask;
 import com.dashitech.migration.core.FieldMapper;
+import com.dashitech.migration.task.uc.CompanyTask;
 import com.dashitech.migration.task.uc.HospitalTask;
 import com.dashitech.migration.util.JdbcUtil;
 import org.apache.commons.logging.Log;
@@ -25,14 +26,19 @@ public class ConsumableTask extends BaseTask {
     @Autowired
     private HospitalTask hospitalTask;
 
+    @Autowired
+    private CompanyTask companyTask;
+
     @Override
     @Transactional
     public void start() {
+        log.info("耗材ConsumableTask转换开始");
         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.addOperationReplace("supplier_id", companyTask.loadCache().getIdCache());
         mapper.trans2JdbcRow(consumableList);
 
         JdbcUtil jdbcUtil = new JdbcUtil(jdbcTemplateHsms);

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

@@ -22,6 +22,7 @@ public class SummaryConsumableTask extends BaseTask {
     @Override
     @Transactional
     public void start() {
+        log.info("汇总单耗材数据SummaryConsumableTask转换开始");
         StringBuffer sql = new StringBuffer("SELECT * from itsm_summary_consumables");
         List<Map<String, Object>> summaryConsuableList = jdbcTemplateMdv2.queryForList(sql.toString());
         FieldMapper mapper = new FieldMapper();

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

@@ -4,6 +4,8 @@ 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.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;
@@ -16,7 +18,9 @@ import java.util.Map;
  * @date 2024年10月12日
  */
 @Component
-public class SolutionIntroduce extends BaseTask {
+public class SolutionIntroduceTask extends BaseTask {
+
+    private Log log = LogFactory.getLog(SolutionIntroduceTask.class);
 
     @Autowired
     private UserTask userTask;
@@ -24,6 +28,8 @@ public class SolutionIntroduce extends BaseTask {
     @Override
     @Transactional
     public void start() {
+        log.info("知识库引用数据SolutionIntroduceTask转换开始");
+
         StringBuffer sql = new StringBuffer("select * from itsm_itsm_solution_introduce");
         List<Map<String, Object>> solutionStarList = jdbcTemplateMdv2.queryForList(sql.toString());
         FieldMapper mapper = new FieldMapper();

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

@@ -5,6 +5,8 @@ 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.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;
@@ -19,6 +21,8 @@ import java.util.Map;
 @Component
 public class SolutionTask extends BaseTask {
 
+    private Log log = LogFactory.getLog(SolutionTask.class);
+
     @Autowired
     HospitalTask hospitalTask;
 
@@ -28,6 +32,8 @@ public class SolutionTask extends BaseTask {
     @Override
     @Transactional
     public void start() {
+        log.info("知识库数据SolutionTask转换开始");
+
         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");

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

@@ -4,12 +4,11 @@ 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.task.other.DictionaryTask;
 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;
 
@@ -20,6 +19,7 @@ import java.util.Map;
  * Created by CX on 2024/10/10.
  */
 @Component
+@Order(7)
 public class CompanyTask extends BaseTask {
 
     public static Log log = LogFactory.getLog(CompanyTask.class);

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

@@ -7,6 +7,7 @@ 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.core.annotation.Order;
 import org.springframework.stereotype.Component;
 import org.springframework.transaction.annotation.Transactional;
 
@@ -18,6 +19,7 @@ import java.util.Map;
  * @date 2024年10月12日
  */
 @Component
+@Order(3)
 public class DepartmentTask extends BaseTask {
 
     public static Log log = LogFactory.getLog(DepartmentTask.class);

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

@@ -8,6 +8,7 @@ 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;
 
@@ -18,6 +19,7 @@ import java.util.Map;
  * Created by CX on 2024/10/10.
  */
 @Component
+@Order(2)
 public class GroupTask extends BaseTask {
 
     public static Log log = LogFactory.getLog(GroupTask.class);
@@ -30,18 +32,30 @@ public class GroupTask extends BaseTask {
     public void start() {
         log.info(" *** 工作组group转换开始 *** ");
 
-        StringBuffer sb = new StringBuffer();
-        sb.append(" select * from itsm_uc_groups ");
+        StringBuffer sql = new StringBuffer();
+        if ("xiangyang".equals(appName)) {
+            sql.append("select 0 as version,a.groupname,a.delete_flag,a.duty_id ,now() as operator_time,1 as schedule_class_id");
+            sql.append(" from itsm_uc_groups a join itsm_uc_duty_dept b on a.duty_id = b.id ");
+            sql.append("where b.dept not like 'Z%' and dept not like '%保卫%' and b.id not in (20,21)");
+        } else if ("nanjing".equals(appName)) {
+            sql.append(" select * from itsm_uc_groups ");
+        }
 
-        List list = jdbcTemplateMdv2.queryForList(sb.toString());
+
+        List list = jdbcTemplateMdv2.queryForList(sql.toString());
 
         //测试
         FieldMapper mapper = new FieldMapper();
-        mapper.addOperationRemove("id").addOperationRemove("duty_id");
-        mapper.addOperationUpdate("_hospital_id", "branch_id");
         mapper.addOperationAdd("type", 3);
         Map<Long, Long> hosIdCache = hospitalTask.loadCache().getIdCache();
-        mapper.addOperationReplace("branch_id", hosIdCache);
+        if ("xiangyang".equals(appName)) {
+            mapper.addOperationUpdate("_hospital_id", "duty_id");
+            mapper.addOperationReplace("duty_id", hosIdCache);
+        } else if ("nanjing".equals(appName)) {
+            mapper.addOperationRemove("id").addOperationRemove("duty_id");
+            mapper.addOperationUpdate("_hospital_id", "branch_id");
+            mapper.addOperationReplace("branch_id", hosIdCache);
+        }
         mapper.trans2JdbcRow(list);
 
         JdbcUtil jdbcUtil = new JdbcUtil(jdbcTemplateHsms);

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

@@ -6,6 +6,7 @@ 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.core.annotation.Order;
 import org.springframework.stereotype.Component;
 import org.springframework.transaction.annotation.Transactional;
 
@@ -17,6 +18,7 @@ import java.util.Map;
  * Created by CX on 2024/10/10.
  */
 @Component
+@Order(1)
 public class HospitalTask extends BaseTask {
 
     public static Log log = LogFactory.getLog(HospitalTask.class);
@@ -31,7 +33,7 @@ public class HospitalTask extends BaseTask {
         mapper.addOperationAdd("type", 20390L);//院区类型 维修科室
         mapper.trans2JdbcRow(hosList);
         JdbcUtil jdbcUtil = new JdbcUtil(jdbcTemplateHsms);
-        jdbcUtil.batchPageInsert("itsm_uc_hospital", mapper.getRows());
+        //jdbcUtil.batchPageInsert("itsm_uc_hospital", mapper.getRows());
 
         //clear释放内存
         mapper.clear();

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

@@ -7,6 +7,7 @@ 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;
 
@@ -16,6 +17,7 @@ import java.util.List;
  * Created by CX on 2024/10/10.
  */
 @Component
+@Order(6)
 public class RoleUserTask extends BaseTask {
 
     public static Log log = LogFactory.getLog(RoleUserTask.class);

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

@@ -2,23 +2,22 @@ package com.dashitech.migration.task.uc;
 
 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;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.core.annotation.Order;
 import org.springframework.stereotype.Component;
 import org.springframework.transaction.annotation.Transactional;
 
 import java.util.List;
-import java.util.Map;
 
 /**
  * Created by CX on 2024/10/10.
  */
 @Component
+@Order(5)
 public class UserGroupTask extends BaseTask {
 
     @Autowired

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

@@ -9,6 +9,7 @@ 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;
 
@@ -19,6 +20,7 @@ import java.util.Map;
  * Created by CX on 2024/10/10.
  */
 @Component
+@Order(4)
 public class UserTask extends BaseTask {
 
     @Autowired

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

@@ -1,58 +0,0 @@
-package com.dashitech.migration.task.uc;
-
-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.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 XyGroupTask extends BaseTask {
-
-    public static Log log = LogFactory.getLog(XyGroupTask.class);
-
-    @Autowired
-    private HospitalTask hospitalTask;
-
-
-    @Override
-    @Transactional
-    public void start() {
-        log.info(" *** 襄阳工作组group转换开始 *** ");
-
-        StringBuffer sql = new StringBuffer("select 0 as version,a.groupname,a.delete_flag,a.duty_id ,now() as operator_time,1 as schedule_class_id");
-        sql.append(" from itsm_uc_groups a join itsm_uc_duty_dept b on a.duty_id = b.id ");
-        sql.append("where b.dept not like 'Z%' and dept not like '%保卫%' and b.id not in (20,21)");
-
-        List<Map<String, Object>> groupList = jdbcTemplateMdv2.queryForList(sql.toString());
-
-        //测试
-        FieldMapper mapper = new FieldMapper();
-        mapper.addOperationUpdate("_hospital_id", "duty_id");
-        mapper.addOperationAdd("type", 3);
-        Map<Long, Long> hosIdCache = hospitalTask.loadXiangyangCache().getIdCache();
-        mapper.addOperationReplace("duty_id", hosIdCache);
-        mapper.trans2JdbcRow(groupList);
-
-        JdbcUtil jdbcUtil = new JdbcUtil(jdbcTemplateHsms);
-        jdbcUtil.batchPageInsert("itsm_uc_groups", mapper.getRows());
-
-        //clear释放内存
-        mapper.clear();
-    }
-
-    @Override
-    public FieldMapper loadCache() {
-        return null;
-    }
-}