From b9d80dfdb1cef36c9edb8bf6b2fdf9e6e1708d2b Mon Sep 17 00:00:00 2001
From: zhang <zc857179121@qq.com>
Date: 星期一, 26 五月 2025 16:18:24 +0800
Subject: [PATCH] 13
---
src/main/java/com/zy/nc/task/handler/BaseDataHandler.java | 33 +++++++++++++++++++++++++++++++--
1 files changed, 31 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..0499cd0 100644
--- a/src/main/java/com/zy/nc/task/handler/BaseDataHandler.java
+++ b/src/main/java/com/zy/nc/task/handler/BaseDataHandler.java
@@ -4,9 +4,11 @@
import com.baomidou.mybatisplus.mapper.EntityWrapper;
import com.baomidou.mybatisplus.plugins.Page;
import com.core.common.Cools;
+import com.zy.asrs.entity.StoreType;
import com.zy.asrs.entity.Tag;
import com.zy.asrs.entity.param.MatSyncParam;
import com.zy.asrs.service.OpenService;
+import com.zy.asrs.service.StoreTypeService;
import com.zy.asrs.service.TagService;
import com.zy.asrs.task.AbstractHandler;
import com.zy.asrs.task.core.ReturnT;
@@ -72,6 +74,9 @@
@Autowired
private UserService userService;
+ @Autowired
+ private StoreTypeService storeTypeService;
+
@Value("${NYNC.pageSize}")
private Integer pageSize;
@@ -133,6 +138,21 @@
Page<NccJcCkWms> wmsFlag = nccJcCkWmsService.selectPage(page, new EntityWrapper<NccJcCkWms>().ne("wms_flag", 1));
for (NccJcCkWms nccJcCkWms : wmsFlag.getRecords()) {
log.info("NccJcCkWms鏁版嵁:{}", JSONObject.toJSON(nccJcCkWms));
+ StoreType storeType = storeTypeService.selectById(nccJcCkWms.getCode());
+ if (storeType == null) {
+ storeType = new StoreType();
+ storeType.setStoreName(nccJcCkWms.getName());
+ storeType.setStatus(1);
+ storeType.setStoreId(nccJcCkWms.getCode());
+ storeType.setCreateBy(1L);
+ storeType.setCreateTime(new Date());
+ storeTypeService.insert(storeType);
+ } else {
+ storeType.setStoreName(nccJcCkWms.getName());
+ storeTypeService.updateById(storeType);
+ }
+ nccJcCkWms.setWmsFlag(1);
+ nccJcCkWmsService.updateById(nccJcCkWms);
}
return SUCCESS;
}
@@ -151,17 +171,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