From dc84bb47fbc3ffc22a6ba36d30a2852432c2d01d Mon Sep 17 00:00:00 2001
From: ZY <zc857179121@qq.com>
Date: 星期六, 10 五月 2025 09:23:50 +0800
Subject: [PATCH] 读取第二数据源
---
src/main/java/com/zy/nc/task/handler/BaseDataHandler.java | 13 +++++++++++--
1 files changed, 11 insertions(+), 2 deletions(-)
diff --git a/src/main/java/com/zy/nc/task/handler/BaseDataHandler.java b/src/main/java/com/zy/nc/task/handler/BaseDataHandler.java
index fb441a6..3406dbc 100644
--- a/src/main/java/com/zy/nc/task/handler/BaseDataHandler.java
+++ b/src/main/java/com/zy/nc/task/handler/BaseDataHandler.java
@@ -151,17 +151,26 @@
Page<NccJcRyWms> wmsFlag = nccJcRyWmsService.selectPage(page, new EntityWrapper<NccJcRyWms>().ne("wms_flag", 1).eq("sszzmc", "娴欐睙绂忚幈鏂版潗鏂欒偂浠芥湁闄愬叕鍙哥儫鍙板垎鍏徃"));
for (NccJcRyWms nccJcRyWms : wmsFlag.getRecords()) {
User user = userService.selectOne(new EntityWrapper<User>().eq("username", nccJcRyWms.getRybm()));
- nccJcRyWms.setWmsFlag(1);
if (user == null) {
user = new User();
user.setUsername(nccJcRyWms.getRybm());
+ user.setNickname(nccJcRyWms.getRymc());
+ user.setRoleId(12L);
user.setStatus(1);
user.setCreateTime(new Date());
userService.insert(user);
+ }else {
+ user.setUsername(nccJcRyWms.getRybm());
+ user.setNickname(nccJcRyWms.getRymc());
+ user.setRoleId(12L);
+ user.setStatus(1);
+ userService.updateById(user);
}
+ nccJcRyWms.setWmsFlag(1);
+ nccJcRyWmsService.updateById(nccJcRyWms);
log.info("NccJcRyWms鏁版嵁:{}", JSONObject.toJSON(nccJcRyWms));
}
- nccJcRyWmsService.updateBatchById(wmsFlag.getRecords());
+
return SUCCESS;
}
--
Gitblit v1.9.1