提交

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

@@ -36,13 +36,12 @@ public class SolutionTask extends BaseTask {
 
         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");
+        sql.append("version_number,star,categoryId as category_id,introduce_count,file_abstract,duty_dept as hos_id,IF( `status` = 74, 1, 0 ) AS delete_flag FROM itsm_solution");
         List<Map<String, Object>> solutionList = jdbcTemplateMdv2.queryForList(sql.toString());
         FieldMapper mapper = new FieldMapper();
-        mapper.addOperationUpdate("duty_dept", "hos_id");
         Map<Long, Long> hosIdCache = hospitalTask.loadCache().getIdCache();
         Map<Long, Long> dicIdCache = dictionaryTask.loadCache().getIdCache();
-        mapper.addOperationReplace("duty_dept", hosIdCache);
+        mapper.addOperationReplace("hos_id", hosIdCache);
         mapper.addOperationReplace("status", dicIdCache);
         mapper.trans2JdbcRow(solutionList);