加日志

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

@@ -1,14 +1,15 @@
 package com.dashitech.migration;
 
-import com.dashitech.migration.task.other.DictionaryTask;
-import com.dashitech.migration.task.uc.HospitalTask;
+import com.dashitech.utils.SpringContextHolder;
 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.context.ApplicationContext;
 import org.springframework.stereotype.Service;
 
 import java.util.List;
+import java.util.Map;
 
 /**
  * 迁移数据启动类
@@ -20,24 +21,66 @@ public class StartApplication {
     public static Log log = LogFactory.getLog(StartApplication.class);
 
     @Autowired
-    private List<SqlTask> sqlTasks;
+    SqlTask hospitalTask;
 
     @Value("${application.name}")
     private String appName;
 
     public void start() {
         log.info("########### 开始迁移任务！###########");
-        for (SqlTask sqlTask : sqlTasks) {
-            if (sqlTask instanceof DictionaryTask) {
-                continue;
-            }
-            if ("xiangyang".equals(appName) && sqlTask instanceof HospitalTask) {
-                sqlTask.start();
-            }
-        }
+        SqlTask task = null;
+        task = SpringContextHolder.getBean("dictionaryTask");
+        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.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();
+
+
+
+//        test();
 
         log.info("########### 迁移任务完成！###########");
     }
 
+    public void startOrder() {
+        hospitalTask.start();
+    }
 
 }

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

@@ -23,7 +23,7 @@ public class IncidentCategoryConfigTask extends BaseTask {
     @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,");
+        StringBuffer sql = new StringBuffer("SELECT a.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)) {

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

@@ -23,7 +23,7 @@ public class IncidentCategoryTask extends BaseTask {
     @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("hierarchy,muti_category,muti_suoPinyin as muti_jp,muti_quanPinyin as muti_qp,IFNULL(branch_id,1) as hos_id ");
         sql.append(" FROM itsm_incident_category ");
         List<Map<String, Object>> categoryList = jdbcTemplateMdv2.queryForList(sql.toString());
 

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

@@ -0,0 +1,85 @@
+package com.dashitech.migration.task.incident;
+
+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(4)
+public class IncidentTask extends BaseTask {
+
+    @Autowired
+    SqlTask hospitalTask;
+
+    @Autowired
+    SqlTask departmentTask;
+
+    public static Log log = LogFactory.getLog(IncidentTask.class);
+
+    @Override
+    @Transactional
+    public void start() {
+        log.info(" *** DepartmentTask start 开始 *** ");
+
+        StringBuffer sb = new StringBuffer();
+        sb.append(" select version,ACCOUNT,GENDER,NAME,PHONE,PWD,WEIXIN,DEPTID,delete_flag, ");
+        sb.append(" pinyin,py as 'input_code',online,branch_id as 'hospital_id', ");
+        sb.append(" duty_id as 'duty_dept',company as 'company_id',engineer ");
+        sb.append(" from itsm_uc_user ");
+        sb.append(" where ACCOUNT != 'dsadmin' ");
+
+        List list = jdbcTemplateMdv2.queryForList(sb.toString());
+
+        FieldMapper mapper = new FieldMapper();
+        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();
+        RowsWrap rw = DataMigrationter.getRowsWrap(mapper,userMapper);
+        JdbcUtil jdbcUtil = new JdbcUtil(jdbcTemplateHsms);
+        jdbcUtil.batchPageInsert("itsm_uc_user", rw.getInsertRows());
+        jdbcUtil.batchPageUpdate("itsm_uc_user", rw.getUpdateRows());
+
+        //clear释放内存
+        mapper.clear();
+        userMapper.clear();
+    }
+
+    @Override
+    public FieldMapper loadCache() {
+        log.info(" *** DepartmentTask loadCache 开始 *** ");
+
+        String sql = " select id,ACCOUNT,delete_flag from itsm_uc_user ";
+        List<Map<String, Object>> list = jdbcTemplateHsms.queryForList(sql);
+        sql = " select id,ACCOUNT,delete_flag from itsm_uc_user ";
+        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;
+    }
+}

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

@@ -19,7 +19,7 @@ import java.util.Map;
  * Created by CX on 2024/10/10.
  */
 @Component
-@Order(7)
+@Order(3)
 public class CompanyTask extends BaseTask {
 
     public static Log log = LogFactory.getLog(CompanyTask.class);

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

@@ -27,6 +27,7 @@ public class DepartmentTask extends BaseTask {
     @Override
     @Transactional
     public void start() {
+        log.info(" *** DepartmentTask 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)");
@@ -48,7 +49,7 @@ public class DepartmentTask extends BaseTask {
 
     @Override
     public FieldMapper loadCache() {
-        log.info(" *** 加载科室缓存 *** ");
+        log.info(" *** DepartmentTask load开始 *** ");
         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());

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

@@ -0,0 +1,46 @@
+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.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;
+
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * Created by CX on 2024/10/10.
+ */
+@Component
+@Order(1)
+public class HospitalConfigTask extends BaseTask {
+
+    public static Log log = LogFactory.getLog(HospitalConfigTask.class);
+
+    @Override
+    @Transactional
+    public void start() {
+        log.info(" *** HospitalConfigTask start开始 *** ");
+        FieldMapper mapper = new FieldMapper();
+
+        //clear释放内存
+        mapper.clear();
+    }
+
+    @Override
+    public FieldMapper loadCache() {
+        log.info(" *** HospitalConfigTask loadCache开始 *** ");
+        FieldMapper mapper = new FieldMapper();
+
+
+        return mapper;
+    }
+
+
+}

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

@@ -26,11 +26,34 @@ public class HospitalTask extends BaseTask {
     @Override
     @Transactional
     public void start() {
+        log.info(" *** HospitalTask start开始 *** ");
+        if ("xiangyang".equals(appName)) {
+            startXy();
+        } else {
+            startNj();
+        }
+    }
+
+    public void startXy() {
         StringBuffer sql = new StringBuffer("SELECT 0 as version,branch_id as parentId,dept as _hos_name,IFNULL(code,py) as _hos_no,delete_flag,now() as operator_time ");
         sql.append(" FROM `itsm_uc_duty_dept` where dept not like 'Z%'  and dept not like '%保卫%' and id not in (20,21)");
         List<Map<String, Object>> hosList = jdbcTemplateMdv2.queryForList(sql.toString());
         FieldMapper mapper = new FieldMapper();
-        mapper.addOperationAdd("type", 20390L);//院区类型 维修科室
+        mapper.addOperationAdd("type", getDicId(jdbcTemplateHsms,"hospital_type","6"));//院区类型 维修科室
+        mapper.trans2JdbcRow(hosList);
+        JdbcUtil jdbcUtil = new JdbcUtil(jdbcTemplateHsms);
+        jdbcUtil.batchPageInsert("itsm_uc_hospital", mapper.getRows());
+
+        //clear释放内存
+        mapper.clear();
+    }
+
+    public void startNj() {
+        StringBuffer sql = new StringBuffer("SELECT 0 as version,branch_id as parentId,dept as _hos_name,IFNULL(code,py) as _hos_no,delete_flag,now() as operator_time ");
+        sql.append(" FROM `itsm_uc_duty_dept` ");
+        List<Map<String, Object>> hosList = jdbcTemplateMdv2.queryForList(sql.toString());
+        FieldMapper mapper = new FieldMapper();
+        mapper.addOperationAdd("type", getDicId(jdbcTemplateHsms,"hospital_type","6"));//院区类型 维修科室
         mapper.trans2JdbcRow(hosList);
         JdbcUtil jdbcUtil = new JdbcUtil(jdbcTemplateHsms);
         jdbcUtil.batchPageInsert("itsm_uc_hospital", mapper.getRows());

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

@@ -31,7 +31,7 @@ public class UserGroupTask extends BaseTask {
     @Override
     @Transactional
     public void start() {
-        log.info(" *** UserGroupTask 转换开始 *** ");
+        log.info(" *** UserGroupTask 转换 开始 *** ");
 
         StringBuffer sb = new StringBuffer();
         //只拿运维人员
@@ -58,7 +58,7 @@ public class UserGroupTask extends BaseTask {
 
     @Override
     public FieldMapper loadCache() {
-
+        log.info(" *** UserGroupTask loadCache 开始 *** ");
 
         return null;
     }

src/main/java/com/dashitech/migration/util/JdbcUtil.java

@@ -190,13 +190,13 @@ public class JdbcUtil {
 
 
     /**
-     * 分批执行批量操作，默认1000条
+     * 分批执行批量操作，默认10000条
      */
     public boolean batchPageInsert(String table, final List<JdbcRow> rows) {
         if (table == null || table.length()== 0 || rows == null || rows.size() == 0) {
             return false;
         }
-        List<List<JdbcRow>> pageList = pageList(rows, 1000);
+        List<List<JdbcRow>> pageList = pageList(rows, 10000);
         for (List<JdbcRow> jdbcRows : pageList) {
             batchInsert(table, jdbcRows);
         }
@@ -204,13 +204,13 @@ public class JdbcUtil {
     }
 
     /**
-     * 分批执行批量操作，默认1000条
+     * 分批执行批量操作，默认10000条
      */
     public boolean batchPageUpdate(String table, final List<JdbcRow> rows) {
         if (table == null || table.length()== 0 || rows == null || rows.size() == 0) {
             return false;
         }
-        List<List<JdbcRow>> pageList = pageList(rows, 1000);
+        List<List<JdbcRow>> pageList = pageList(rows, 10000);
         for (List<JdbcRow> jdbcRows : pageList) {
             batchUpdate(table, jdbcRows);
         }