提交

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

@@ -2,10 +2,15 @@ package com.dashitech.migration.task.category;
 
 import com.dashitech.migration.BaseTask;
 import com.dashitech.migration.core.FieldMapper;
+import com.dashitech.migration.task.other.DictionaryTask;
+import com.dashitech.migration.task.uc.GroupTask;
+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;
 
@@ -20,6 +25,19 @@ import java.util.Map;
 public class IncidentCategoryConfigTask extends BaseTask {
 
     public static Log log = LogFactory.getLog(IncidentCategoryConfigTask.class);
+
+    @Autowired
+    private DictionaryTask dictionaryTask;
+
+    @Autowired
+    private GroupTask groupTask;
+
+    @Autowired
+    private UserTask userTask;
+
+    @Autowired
+    private HospitalTask hospitalTask;
+
     @Override
     @Transactional(rollbackFor = Exception.class)
     public void start() {
@@ -33,6 +51,10 @@ public class IncidentCategoryConfigTask extends BaseTask {
         FieldMapper mapper = new FieldMapper();
         if (CollectionUtils.isNotEmpty(categoryConfigList)) {
             mapper.addOperationAdd("score", getDicId(jdbcTemplateHsms,"incident_score","1"));
+            mapper.addOperationReplace("priority", dictionaryTask.loadCache().getIdCache());
+            mapper.addOperationReplace("duty_id", hospitalTask.loadCache().getIdCache());
+            mapper.addOperationReplace("group_id", groupTask.loadCache().getIdCache());
+            mapper.addOperationReplace("user_id", userTask.loadCache().getIdCache());
             mapper.trans2JdbcRow(categoryConfigList);
 
             JdbcUtil jdbcUtil = new JdbcUtil(jdbcTemplateHsms);

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

@@ -50,7 +50,9 @@ public class IncidentAssignManagerTask extends BaseTask {
         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());
+        if ("xiangyang".equals(appName)) {
+            mapper.addOperationReplace("dept_id", departmentTask.loadCache().getIdCache());
+        }
         mapper.addOperationReplace("handle_user", userTask.loadCache().getIdCache());
         mapper.addOperationReplace("_group", groupTask.loadCache().getIdCache());
         mapper.trans2JdbcRow(list);

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

@@ -40,16 +40,96 @@ public class DictionaryTask extends BaseTask {
     private FieldMapper loadXiangYangCache() {
         log.info(" *** 加载襄阳字典缓存 *** ");
         FieldMapper mapper = new FieldMapper();
-        Map<Long, Long> dicIdCache = new HashMap<>();
-        mapper.setIdCache(dicIdCache);
+        Map<Long, Long> idCache = new HashMap<>();
+        mapper.setIdCache(idCache);
         //知识库
-        dicIdCache.put(71L, 20404L); //待审核
-        dicIdCache.put(72L, 20405L); //已发布
-        dicIdCache.put(73L, 20406L); //待整改
-        dicIdCache.put(74L, 20407L); //已停用
+        idCache.put(71L, 20404L); //待审核
+        idCache.put(72L, 20405L); //已发布
+        idCache.put(73L, 20406L); //待整改
+        idCache.put(74L, 20407L); //已停用
         //耗材消耗
-        dicIdCache.put(1735L, 20557L);//消耗
-        dicIdCache.put(1736L, 20558L);//撤销
+        idCache.put(1735L, 20557L);//消耗
+        idCache.put(1736L, 20558L);//撤销
+        //公司分类
+        idCache.put(1709L,20240L);
+        idCache.put(1710L,20241L);
+        //性别
+        idCache.put(1609L,279L);
+        idCache.put(1610L,280L);
+
+        //事件-关闭代码
+        idCache.put(1572L,20501L);
+        idCache.put(1573L,20502L);
+        idCache.put(1575L,20503L);
+        idCache.put(1574L,20504L);
+        idCache.put(1576L,20504L);
+        idCache.put(1577L,20504L);
+
+        //事件-满意度
+        idCache.put(1578L,20496L);
+        idCache.put(1579L,20497L);
+        idCache.put(1580L,20498L);
+        idCache.put(1581L,20499L);
+        idCache.put(1582L,20500L);
+
+        //事件-优先级
+        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,20484L);
+        idCache.put(1548L,20485L);
+        idCache.put(1549L,20486L);
+        idCache.put(1550L,20488L);
+        idCache.put(1551L,20487L);
+        idCache.put(1552L,20488L);
+        idCache.put(1700L,20488L);
+        idCache.put(1747L,20488L);
+
+        //事件-incident_status
+        idCache.put(1479L,20505L);
+        idCache.put(1543L,20506L);
+        idCache.put(1544L,20507L);
+        idCache.put(1545L,20508L);
+        idCache.put(1546L,20508L);
+        idCache.put(1674L,20509L);
+        idCache.put(1748L,20510L);
+        idCache.put(1749L,20511L);
+        idCache.put(1750L,20512L);
+
+        //事件-incident_handleresult
+        idCache.put(1568L,20483L);
+        idCache.put(1569L,20483L);
+        idCache.put(1570L,20483L);
+        idCache.put(1571L,20483L);
+
+        //事件-wxincident_degree
+        idCache.put(1598L,20496L);
+        idCache.put(1599L,20497L);
+        idCache.put(1600L,20498L);
+        idCache.put(1601L,20499L);
+        idCache.put(1602L,20500L);
+
+        //事件日志-incident_log_type
+        idCache.put(1736L,20517L);
+        idCache.put(1737L,20518L);
+        idCache.put(1738L,20519L);
+        idCache.put(1739L,20520L);
+        idCache.put(1740L,20521L);
+        idCache.put(1741L,20522L);
+        idCache.put(1742L,20523L);
+        idCache.put(1743L,20524L);
+        idCache.put(1744L,20525L);
+        idCache.put(1745L,20526L);
+        idCache.put(1751L,20527L);
+        idCache.put(1752L,20528L);
+        idCache.put(1753L,20529L);
+        idCache.put(1754L,20530L);
+        idCache.put(1755L,20531L);
+        idCache.put(1766L,20532L);
 
         return mapper;
     }

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

@@ -25,24 +25,26 @@ public class DepartmentTask extends BaseTask {
     @Override
     @Transactional(rollbackFor = Exception.class)
     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)");
-        List<Map<String, Object>> deptList = jdbcTemplateMdv2.queryForList(sql.toString());
+        if ("xiangyang".equals(appName)) {
+            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)");
+            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 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());
+            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();
+            mapper.clear();
+            deptMapper.clear();
+        }
     }
 
     @Override