From c22266b4dfbe3f338d2dd0bb31b10df1b5c92fb5 Mon Sep 17 00:00:00 2001
From: zhang <zc857179121@qq.com>
Date: 星期六, 24 五月 2025 13:54:39 +0800
Subject: [PATCH] 13
---
src/main/java/com/zy/nc/task/handler/BaseDataHandler.java | 22 +++++++++++++++++++++-
1 files changed, 21 insertions(+), 1 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 3406dbc..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;
}
@@ -159,7 +179,7 @@
user.setStatus(1);
user.setCreateTime(new Date());
userService.insert(user);
- }else {
+ } else {
user.setUsername(nccJcRyWms.getRybm());
user.setNickname(nccJcRyWms.getRymc());
user.setRoleId(12L);
--
Gitblit v1.9.1