|
|
@@ -56,26 +56,26 @@ public class XCFYDataV_STAFF_INFOJob implements Job {
|
|
|
// ORG_ID,STAFF_CODE,WORK_CODE,STAFE_NAME,STAFE_SEY,STAFE_BIRTHDA,IDENTITY_CARD_NO,MOBI_PHON,ADMIN_DEE,BOWIN_DEDT_WAR,LOGIN_USER,TECH_TITLE
|
|
|
String querySql = "select ORG_ID,STAFF_CODE as DOCTOR_ID,WORK_CODE,STAFF_NAME as DOCTOR_NAME,STAFF_SEX as SEX,STAFF_BIRTHDAY as BIRTH_DATE,IDENTITY_CARD_NO," +
|
|
|
"MOBI_PHONE,ADMIN_DEPT as DEPT_CODE,ADMIN_DEPT_NAME as DEPT_NAME,LOGIN_USER,TECH_TITLE as DOCTOR_LEVEL from V_STAFF_INFO ";
|
|
|
- while (true) {
|
|
|
- log.info("开始同步V_STAFF_INFO数据");
|
|
|
- Map<String, Object> paramMap = new HashMap<>();
|
|
|
- Integer count = xcfyDataTransferService.transferDataList(querySql, insertSql, paramMap, new TransferDataCallFunction() {
|
|
|
- @Override
|
|
|
- public Boolean transferData(Map<String, Object> dataMap) throws Exception {
|
|
|
- dataMap.put("CREATE_BY", "auto");
|
|
|
- dataMap.put("CREATE_TIME", new Date());
|
|
|
- dataMap.put("DUTY_NAME", dataMap.get("DOCTOR_LEVEL"));
|
|
|
- CommonUtil.setDockerLevel(dataMap);
|
|
|
- addUser(dataMap);
|
|
|
- return true;
|
|
|
- }
|
|
|
- });
|
|
|
- if (count <= 0) {
|
|
|
- log.info("V_STAFF_INFO 没有的数据,停止同步");
|
|
|
- return;
|
|
|
+
|
|
|
+ log.info("开始同步V_STAFF_INFO数据");
|
|
|
+ Map<String, Object> paramMap = new HashMap<>();
|
|
|
+ Integer count = xcfyDataTransferService.transferDataList(querySql, insertSql, paramMap, new TransferDataCallFunction() {
|
|
|
+ @Override
|
|
|
+ public Boolean transferData(Map<String, Object> dataMap) throws Exception {
|
|
|
+ dataMap.put("CREATE_BY", "auto");
|
|
|
+ dataMap.put("CREATE_TIME", new Date());
|
|
|
+ dataMap.put("DUTY_NAME", dataMap.get("DOCTOR_LEVEL"));
|
|
|
+ CommonUtil.setDockerLevel(dataMap);
|
|
|
+ addUser(dataMap);
|
|
|
+ return true;
|
|
|
}
|
|
|
+ });
|
|
|
+ if (count <= 0) {
|
|
|
+ log.info("V_STAFF_INFO 没有的数据,停止同步");
|
|
|
+ return;
|
|
|
}
|
|
|
|
|
|
+
|
|
|
}
|
|
|
|
|
|
|