111

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

@@ -25,17 +25,17 @@ public class StartApplication {
     public void start() {
         log.info("########### 开始迁移任务！###########");
         SqlTask task = null;
-        //task = SpringContextHolder.getBean("dictionaryTask");
-        //task.start();
-        //task = SpringContextHolder.getBean("attachmentTask");
-        //task.start();
-        //task = SpringContextHolder.getBean("tokenTask");
-        //task.start();
-        //task = SpringContextHolder.getBean("hospitalTask");
-        //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 = SpringContextHolder.getBean("groupTask");
         task.start();
         task = SpringContextHolder.getBean("departmentTask");
         task.start();
@@ -70,7 +70,7 @@ public class StartApplication {
         task = SpringContextHolder.getBean("callLogTask");
         task.start();
         task = SpringContextHolder.getBean("hjzxRecordTask");
-        task.start();*/
+        task.start();
 
 
         log.info("########### 迁移任务完成！###########");

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

@@ -44,7 +44,7 @@ public class ConsumableHistoryTask extends BaseTask {
         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("repair_duty,branch_id as 'hos_id' ");
         }
         sql.append(" FROM itsm_asset_consumables_history ");
         List<Map<String, Object>> consumableHistoryList = jdbcTemplateMdv2.queryForList(sql.toString());

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

@@ -0,0 +1,72 @@
+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.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
+public class IncidentAssignManagerTask extends BaseTask {
+
+    @Autowired
+    SqlTask hospitalTask;
+
+    @Autowired
+    SqlTask departmentTask;
+
+    public static Log log = LogFactory.getLog(IncidentAssignManagerTask.class);
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public void start() {
+        log.info(" *** IncidentAssignManagerTask start 开始 *** ");
+
+        StringBuffer sb = new StringBuffer();
+        sb.append(" select * from itsm_incident ");
+
+        List list = jdbcTemplateMdv2.queryForList(sb.toString());
+
+        FieldMapper mapper = new FieldMapper();
+        mapper.addOperationRemove("id").addOperationRemove("version");
+        mapper.trans2JdbcRow(list);
+
+        FieldMapper userMapper = loadCache();
+        JdbcUtil jdbcUtil = new JdbcUtil(jdbcTemplateHsms);
+        jdbcUtil.batchPageInsert("itsm_itsm_incident", mapper.getRows());
+
+        //clear释放内存
+        mapper.clear();
+        userMapper.clear();
+    }
+
+    @Override
+    public FieldMapper loadCache() {
+        log.info(" *** IncidentAssignManagerTask 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;
+    }
+}

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

@@ -0,0 +1,72 @@
+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.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
+public class IncidentLogTask extends BaseTask {
+
+    @Autowired
+    SqlTask hospitalTask;
+
+    @Autowired
+    SqlTask departmentTask;
+
+    public static Log log = LogFactory.getLog(IncidentLogTask.class);
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public void start() {
+        log.info(" *** IncidentLogTask start 开始 *** ");
+
+        StringBuffer sb = new StringBuffer();
+        sb.append(" select * from itsm_incident ");
+
+        List list = jdbcTemplateMdv2.queryForList(sb.toString());
+
+        FieldMapper mapper = new FieldMapper();
+        mapper.addOperationRemove("id").addOperationRemove("version");
+        mapper.trans2JdbcRow(list);
+
+        FieldMapper userMapper = loadCache();
+        JdbcUtil jdbcUtil = new JdbcUtil(jdbcTemplateHsms);
+        jdbcUtil.batchPageInsert("itsm_itsm_incident", 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;
+    }
+}

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

@@ -0,0 +1,72 @@
+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.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
+public class IncidentSynergeticTask extends BaseTask {
+
+    @Autowired
+    SqlTask hospitalTask;
+
+    @Autowired
+    SqlTask departmentTask;
+
+    public static Log log = LogFactory.getLog(IncidentSynergeticTask.class);
+
+    @Override
+    @Transactional(rollbackFor = Exception.class)
+    public void start() {
+        log.info(" *** IncidentSynergeticTask start 开始 *** ");
+
+        StringBuffer sb = new StringBuffer();
+        sb.append(" select * from itsm_incident ");
+
+        List list = jdbcTemplateMdv2.queryForList(sb.toString());
+
+        FieldMapper mapper = new FieldMapper();
+        mapper.addOperationRemove("id").addOperationRemove("version");
+        mapper.trans2JdbcRow(list);
+
+        FieldMapper userMapper = loadCache();
+        JdbcUtil jdbcUtil = new JdbcUtil(jdbcTemplateHsms);
+        jdbcUtil.batchPageInsert("itsm_itsm_incident", 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;
+    }
+}

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

@@ -27,56 +27,64 @@ public class IncidentTask extends BaseTask {
     SqlTask hospitalTask;
 
     @Autowired
+    SqlTask userTask;
+
+    @Autowired
     SqlTask departmentTask;
 
+    @Autowired
+    SqlTask incidentCategoryTask;
+
     public static Log log = LogFactory.getLog(IncidentTask.class);
 
     @Override
     @Transactional(rollbackFor = Exception.class)
     public void start() {
-        log.info(" *** DepartmentTask start 开始 *** ");
+        log.info(" *** IncidentTask 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' ");
+        sb.append(" select * from itsm_incident limit 0,1000 ");
 
         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());
+        Map<Long, Long> userCache = userTask.loadCache().getIdCache();
+
+        mapper.addOperationRemove("id").addOperationRemove("version");
+        mapper.addOperationRemove("emergencyid").addOperationRemove("influenceid");
+        mapper.addOperationUpdate("priority_id", "priorityid");
+        mapper.addOperationUpdate("hos_id", "branch_id");
+        //襄阳id4-
+        mapper.addOperationReplace("userid", userCache);
+        mapper.addOperationReplace("close_userid", userCache);
+        mapper.addOperationReplace("requesterid", userCache);
+        mapper.addOperationReplace("handleruserid", userCache);
+        mapper.addOperationReplace("handlingPersonnelUserId", userCache);
+        mapper.addOperationReplace("duty_id", hospitalTask.loadCache().getIdCache());
+        //只有襄阳需要处理科室，南京不用
         if ("xiangyang".equals(appName)) {
-            mapper.addOperationReplace("DEPTID", departmentTask.loadCache().getIdCache());
+            mapper.addOperationReplace("dept", 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());
+        jdbcUtil.batchPageInsert("itsm_itsm_incident", mapper.getRows());
 
         //clear释放内存
         mapper.clear();
-        userMapper.clear();
     }
 
     @Override
     public FieldMapper loadCache() {
-        log.info(" *** DepartmentTask loadCache 开始 *** ");
+        log.info(" *** IncidentTask loadCache 开始 *** ");
 
-        String sql = " select id,ACCOUNT,delete_flag from itsm_uc_user ";
+        String sql = " select id,incidentsign from itsm_itsm_incident ";
         List<Map<String, Object>> list = jdbcTemplateHsms.queryForList(sql);
-        sql = " select id,ACCOUNT,delete_flag from itsm_uc_user ";
+        sql = " select id,incidentsign from itsm_incident ";
         List<Map<String, Object>> list2 = jdbcTemplateMdv2.queryForList(sql);
 
         FieldMapper mapper = new FieldMapper();
-        mapper.addFieldMapper("ACCOUNT", "ACCOUNT");
-        mapper.addFieldMapper("delete_flag", "delete_flag");
+        mapper.addFieldMapper("incidentsign", "incidentsign");
 
         DataMigrationter.loadCache(list, list2, mapper);
 

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

@@ -66,6 +66,61 @@ public class DictionaryTask extends BaseTask {
         idCache.put(279L,1609L);
         idCache.put(280L,1610L);
 
+        //事件-关闭代码
+        idCache.put(1572L,20419L);
+        idCache.put(1573L,20420L);
+        idCache.put(1575L,20421L);
+        idCache.put(1574L,20422L);
+        idCache.put(1576L,20422L);
+        idCache.put(1577L,20422L);
+
+        //事件-满意度
+        idCache.put(1578L,20414L);
+        idCache.put(1579L,20415L);
+        idCache.put(1580L,20416L);
+        idCache.put(1581L,20417L);
+        idCache.put(1582L,20418L);
+
+        //事件-优先级
+        idCache.put(1560L,5L);
+        idCache.put(1561L,4L);
+        idCache.put(1562L,3L);
+        idCache.put(1563L,2L);
+        idCache.put(1704L,1L);
+
+        //事件-incident_source
+        idCache.put(1547L,20402L);
+        idCache.put(1548L,20403L);
+        idCache.put(1549L,1549L);
+        idCache.put(1550L,20406L);
+        idCache.put(1551L,20405L);
+        idCache.put(1552L,20406L);
+        idCache.put(1700L,20406L);
+        idCache.put(1747L,20406L);
+
+        //事件-incident_status
+        idCache.put(1479L,20423L);
+        idCache.put(1543L,20424L);
+        idCache.put(1544L,20425L);
+        idCache.put(1545L,20426L);
+        idCache.put(1546L,20426L);
+        idCache.put(1674L,20427L);
+        idCache.put(1748L,20428L);
+        idCache.put(1749L,20429L);
+        idCache.put(1750L,20430L);
+
+        //事件-incident_handleresult
+        idCache.put(1568L,20401L);
+        idCache.put(1569L,20401L);
+        idCache.put(1570L,20401L);
+        idCache.put(1571L,20401L);
+
+        //事件-wxincident_degree
+        idCache.put(1598L,20414L);
+        idCache.put(1599L,20415L);
+        idCache.put(1600L,20416L);
+        idCache.put(1601L,20417L);
+        idCache.put(1602L,20418L);
 
         return mapper;
     }

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

@@ -88,14 +88,14 @@ public class HospitalTask extends BaseTask {
     }
 
     public FieldMapper loadNanjingCache() {
+        StringBuffer sql = new StringBuffer("SELECT id,dept FROM `itsm_uc_duty_dept` ");
+        List<Map<String, Object>> dutyList = jdbcTemplateMdv2.queryForList(sql.toString());
+        sql = new StringBuffer("select id,_hos_name from itsm_uc_hospital ");
+        List<Map<String, Object>> hosList = jdbcTemplateHsms.queryForList(sql.toString());
         FieldMapper mapper = new FieldMapper();
-        Map<Long, Long> hosIdCache = new HashMap<>();
-        mapper.setIdCache(hosIdCache);
+        mapper.addFieldMapper("_hos_name", "dept");
 
-        hosIdCache.put(1L, 4L); //总务科
-        hosIdCache.put(2L, 4L); //总务科
-        hosIdCache.put(3L, 5L); //信息科
-        hosIdCache.put(4L, 6L); //设备科
+        DataMigrationter.loadCache(hosList, dutyList, mapper);
 
         return mapper;
     }

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

@@ -181,13 +181,13 @@ public class JdbcUtil {
 
 
     /**
-     * 分批执行批量操作，默认10000条
+     * 分批执行批量操作，默认1000条
      */
     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, 10000);
+        List<List<JdbcRow>> pageList = pageList(rows, 1000);
         for (List<JdbcRow> jdbcRows : pageList) {
             batchInsert(table, jdbcRows);
         }
@@ -195,13 +195,13 @@ public class JdbcUtil {
     }
 
     /**
-     * 分批执行批量操作，默认10000条
+     * 分批执行批量操作，默认1000条
      */
     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, 10000);
+        List<List<JdbcRow>> pageList = pageList(rows, 1000);
         for (List<JdbcRow> jdbcRows : pageList) {
             batchUpdate(table, jdbcRows);
         }