提交

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

@@ -25,20 +25,23 @@ public class AreaTask extends BaseTask {
     @Override
     @Transactional(rollbackFor = Exception.class)
     public void start() {
-        log.info(" *** 楼栋AreaTask转换开始 *** ");
-        StringBuffer sql = new StringBuffer("select 0 as version,IF(branch_id=4,3,branch_id) as hos_id,area as building_name,now() as operator_time, ");
-        sql.append(" delete_flag as _delete from itsm_uc_area");
-        List<Map<String, Object>> areaList = jdbcTemplateMdv2.queryForList(sql.toString());
-        FieldMapper mapper = new FieldMapper();
-        mapper.trans2JdbcRow(areaList);
-
-        FieldMapper areaMapper = this.loadCache();
-        RowsWrap rw = DataMigrationter.getRowsWrap(mapper,areaMapper);
-        JdbcUtil jdbcUtil = new JdbcUtil(jdbcTemplateHsms);
-        //科室只做更新 已有的科室不做处理
-        jdbcUtil.batchPageInsert("itsm_uc_building", rw.getInsertRows());
+        if ("xiangyang".equals(appName)) {
+            log.info(" *** 楼栋AreaTask转换开始 *** ");
+            StringBuffer sql = new StringBuffer("select 0 as version,IF(branch_id=4,3,branch_id) as hos_id,area as building_name,now() as operator_time, ");
+            sql.append(" delete_flag as _delete from itsm_uc_area");
+            List<Map<String, Object>> areaList = jdbcTemplateMdv2.queryForList(sql.toString());
+            FieldMapper mapper = new FieldMapper();
+            mapper.trans2JdbcRow(areaList);
+
+            FieldMapper areaMapper = this.loadCache();
+            RowsWrap rw = DataMigrationter.getRowsWrap(mapper,areaMapper);
+            JdbcUtil jdbcUtil = new JdbcUtil(jdbcTemplateHsms);
+            //科室只做更新 已有的科室不做处理
+            jdbcUtil.batchPageInsert("itsm_uc_building", rw.getInsertRows());
+
+            mapper.clear();
+        }
 
-        mapper.clear();
     }
 
     @Override

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

@@ -29,19 +29,21 @@ public class PlaceTask extends BaseTask {
     @Override
     @Transactional(rollbackFor = Exception.class)
     public void start() {
-        log.info(" *** 楼层PlaceTask转换开始 *** ");
-        StringBuffer sql = new StringBuffer("select 0 as version,area_id as build_id,SUBSTRING_INDEX(SUBSTRING_INDEX(place,'楼',1),'号',1) as floor_name,IF(branch_id=4,3,branch_id) as hos_id,now() as operator_time, ");
-        sql.append(" delete_flag as _delete from itsm_uc_place");
-        List<Map<String, Object>> placeList = jdbcTemplateMdv2.queryForList(sql.toString());
-        FieldMapper mapper = new FieldMapper();
-        mapper.addOperationReplace("build_id", areaTask.loadCache().getIdCache());
-        mapper.trans2JdbcRow(placeList);
+        if ("xiangyang".equals(appName)) {
+            log.info(" *** 楼层PlaceTask转换开始 *** ");
+            StringBuffer sql = new StringBuffer("select 0 as version,area_id as build_id,SUBSTRING_INDEX(SUBSTRING_INDEX(place,'楼',1),'号',1) as floor_name,IF(branch_id=4,3,branch_id) as hos_id,now() as operator_time, ");
+            sql.append(" delete_flag as _delete from itsm_uc_place");
+            List<Map<String, Object>> placeList = jdbcTemplateMdv2.queryForList(sql.toString());
+            FieldMapper mapper = new FieldMapper();
+            mapper.addOperationReplace("build_id", areaTask.loadCache().getIdCache());
+            mapper.trans2JdbcRow(placeList);
 
-        FieldMapper areaMapper = this.loadCache();
-        RowsWrap rw = DataMigrationter.getRowsWrap(mapper,areaMapper);
-        JdbcUtil jdbcUtil = new JdbcUtil(jdbcTemplateHsms);
-        //科室只做更新 已有的科室不做处理
-        jdbcUtil.batchPageInsert("itsm_uc_floor", rw.getInsertRows());
+            FieldMapper areaMapper = this.loadCache();
+            RowsWrap rw = DataMigrationter.getRowsWrap(mapper,areaMapper);
+            JdbcUtil jdbcUtil = new JdbcUtil(jdbcTemplateHsms);
+            //科室只做更新 已有的科室不做处理
+            jdbcUtil.batchPageInsert("itsm_uc_floor", rw.getInsertRows());
+        }
     }
 
     @Override