From 6f01b51fc0770fda7787076caf0314be7a7f6656 Mon Sep 17 00:00:00 2001
From: Junjie <fallin.jie@qq.com>
Date: 星期五, 27 六月 2025 10:58:21 +0800
Subject: [PATCH] #
---
src/main/java/com/zy/nc/task/handler/BaseDataHandler.java | 289 +++++++++++++++++++++++++++++++++++++++++++++++++++++++--
1 files changed, 277 insertions(+), 12 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 370b5d3..b2d4976 100644
--- a/src/main/java/com/zy/nc/task/handler/BaseDataHandler.java
+++ b/src/main/java/com/zy/nc/task/handler/BaseDataHandler.java
@@ -2,15 +2,30 @@
import com.alibaba.fastjson.JSONObject;
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;
-import com.zy.nc.entity.NccBdCustomerWms;
-import com.zy.nc.entity.NccSaleDbckmxb;
-import com.zy.nc.service.NccBdCustomerWmsService;
-import com.zy.nc.service.NccCgCgdhdWmsService;
+import com.zy.common.utils.NodeUtils;
+import com.zy.nc.entity.*;
+import com.zy.nc.service.*;
+import com.zy.system.entity.User;
+import com.zy.system.service.UserService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.ArrayList;
+import java.util.Date;
+import java.util.List;
@Service
@Slf4j
@@ -22,25 +37,275 @@
@Autowired
private NccCgCgdhdWmsService nccCgCgdhdWmsService;
+ @Autowired
+ private NccCkPddWmsService nccCkPddWmsService;
+
+
+ @Autowired
+ private NccJcBmWmsService nccJcBmWmsService;
+
+ @Autowired
+ private NccJcCkhwService nccJcCkhwService;
+
+ @Autowired
+ private NccJcCkWmsService nccJcCkWmsService;
+
+ @Autowired
+ private NccJcQilibcBarcodeflowWmsService nccJcQilibcBarcodeflowWmsService;
+
+ @Autowired
+ private NccJcRyWmsService nccJcRyWmsService;
+
+ @Autowired
+ private NccJcWlflWmsService nccJcWlflWmsService;
+
+ @Autowired
+ private NccOrgCorpWmsService nccOrgCorpWmsService;
+
+
+ @Autowired
+ private VGetBdMaterialService vGetBdMaterialService;
+
+ @Autowired
+ private OpenService openService;
+
+ @Autowired
+ private TagService tagService;
+
+ @Autowired
+ private UserService userService;
+
+ @Autowired
+ private StoreTypeService storeTypeService;
+
+ @Value("${NYNC.pageSize}")
+ private Integer pageSize;
+
/**
- *
- *
* @return
*/
+ @Transactional
public ReturnT<String> start1() {
- nccBdCustomerWmsService.selectList(new EntityWrapper<NccBdCustomerWms>().ne("wms_flag",1))
- log.info("shuju:{}", JSONObject.toJSON(nccSaleXsckmx));
+ Page<NccBdCustomerWms> page = new Page<>(1, pageSize);
+ Page<NccBdCustomerWms> wmsFlag = nccBdCustomerWmsService.selectPage(page, new EntityWrapper<NccBdCustomerWms>().ne("wms_flag", 1));
+ for (NccBdCustomerWms nccBdCustomerWms : wmsFlag.getRecords()) {
+ //TODO
+ log.info("NccBdCustomerWms鏁版嵁:{}", JSONObject.toJSON(nccBdCustomerWms));
+ }
return SUCCESS;
}
/**
- *
- *
* @return
*/
+ @Transactional
public ReturnT<String> start2() {
- NccSaleDbckmxb nccSaleDbckmxb = NccCgCgdhdWmsService.selectById("1001A1100000000H9KKJ");
- log.info("shuju:{}", JSONObject.toJSON(nccSaleDbckmxb));
+ Page<NccCgCgdhdWms> page = new Page<>(1, pageSize);
+ Page<NccCgCgdhdWms> wmsFlag = nccCgCgdhdWmsService.selectPage(page, new EntityWrapper<NccCgCgdhdWms>().ne("wms_flag", 1));
+ for (NccCgCgdhdWms nccCgCgdhdWms : wmsFlag.getRecords()) {
+ log.info("NccCgCgdhdWms鏁版嵁:{}", JSONObject.toJSON(nccCgCgdhdWms));
+ }
return SUCCESS;
}
+
+ @Transactional
+ public ReturnT<String> start3() {
+ Page<NccCkPddWms> page = new Page<>(1, pageSize);
+ Page<NccCkPddWms> wmsFlag = nccCkPddWmsService.selectPage(page, new EntityWrapper<NccCkPddWms>().ne("wms_flag", 1));
+ for (NccCkPddWms nccCkPddWms : wmsFlag.getRecords()) {
+ log.info("NccCkPddWms鏁版嵁:{}", JSONObject.toJSON(nccCkPddWms));
+ }
+ return SUCCESS;
+ }
+
+ @Transactional
+ public ReturnT<String> start4() {
+ Page<NccJcBmWms> page = new Page<>(1, pageSize);
+ Page<NccJcBmWms> wmsFlag = nccJcBmWmsService.selectPage(page, new EntityWrapper<NccJcBmWms>().ne("wms_flag", 1));
+ for (NccJcBmWms nccCkPddWms : wmsFlag.getRecords()) {
+ log.info("NccJcBmWms鏁版嵁:{}", JSONObject.toJSON(nccCkPddWms));
+ }
+ return SUCCESS;
+ }
+
+ @Transactional
+ public ReturnT<String> start5() {
+ Page<NccJcCkhw> page = new Page<>(1, pageSize);
+ Page<NccJcCkhw> wmsFlag = nccJcCkhwService.selectPage(page, new EntityWrapper<NccJcCkhw>().ne("wms_flag", 1));
+ for (NccJcCkhw nccJcCkhw : wmsFlag.getRecords()) {
+ log.info("NccJcCkhw鏁版嵁:{}", JSONObject.toJSON(nccJcCkhw));
+ }
+ return SUCCESS;
+ }
+
+ @Transactional
+ public ReturnT<String> start6() {
+ Page<NccJcCkWms> page = new Page<>(1, pageSize);
+ 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());
+ storeType.setDepartmentId((Cools.isEmpty(nccJcCkWms.getDef3()) || "~".equals(nccJcCkWms.getDef3())) ? null : nccJcCkWms.getDef3());
+ //storeType.setDepartment();
+ storeTypeService.insert(storeType);
+ } else {
+ storeType.setStoreName(nccJcCkWms.getName());
+ storeType.setDepartmentId((Cools.isEmpty(nccJcCkWms.getDef3()) || "~".equals(nccJcCkWms.getDef3())) ? null : nccJcCkWms.getDef3());
+ storeTypeService.updateById(storeType);
+ }
+ nccJcCkWms.setWmsFlag(1);
+ nccJcCkWmsService.update(nccJcCkWms, new EntityWrapper<NccJcCkWms>().eq("code", nccJcCkWms.getCode()));
+ }
+ return SUCCESS;
+ }
+
+ @Transactional
+ public ReturnT<String> start7() {
+ Page<NccJcQilibcBarcodeflowWms> page = new Page<>(1, pageSize);
+ Page<NccJcQilibcBarcodeflowWms> wmsFlag = nccJcQilibcBarcodeflowWmsService.selectPage(page, new EntityWrapper<NccJcQilibcBarcodeflowWms>().ne("wms_flag", 1));
+ for (NccJcQilibcBarcodeflowWms nccJcQilibcBarcodeflowWms : wmsFlag.getRecords()) {
+ log.info("NccJcQilibcBarcodeflowWms鏁版嵁:{}", JSONObject.toJSON(nccJcQilibcBarcodeflowWms));
+ }
+ return SUCCESS;
+ }
+
+ @Transactional
+ public ReturnT<String> start8() {
+ Page<NccJcRyWms> page = new Page<>(1, pageSize);
+ Page<NccJcRyWms> wmsFlag = nccJcRyWmsService.selectPage(page, new EntityWrapper<NccJcRyWms>().ne("wms_flag", 1).eq("sszzbm", "FYT"));
+ for (NccJcRyWms nccJcRyWms : wmsFlag.getRecords()) {
+ User user = userService.selectOne(new EntityWrapper<User>().eq("username", nccJcRyWms.getRybm()));
+ if (user == null) {
+ user = new User();
+ user.setUsername(nccJcRyWms.getRybm());
+ user.setNickname(nccJcRyWms.getRymc());
+ user.setMobile(nccJcRyWms.getRybm());
+ user.setRoleId(12L);
+ user.setStatus(1);
+ user.setCreateTime(new Date());
+ userService.insert(user);
+ } else {
+ user.setUsername(nccJcRyWms.getRybm());
+ user.setNickname(nccJcRyWms.getRymc());
+ user.setMobile(nccJcRyWms.getRybm());
+ user.setStatus(1);
+ userService.updateById(user);
+ }
+ nccJcRyWms.setWmsFlag(1);
+ nccJcRyWmsService.update(nccJcRyWms, new EntityWrapper<NccJcRyWms>().eq("rybm", nccJcRyWms.getRybm()));
+ log.info("NccJcRyWms鏁版嵁:{}", JSONObject.toJSON(nccJcRyWms));
+ }
+
+ return SUCCESS;
+ }
+
+ @Transactional
+ public ReturnT<String> start9() {
+ Page<NccJcWlflWms> page = new Page<>(1, pageSize);
+ Page<NccJcWlflWms> wmsFlag = nccJcWlflWmsService.selectPage(page, new EntityWrapper<NccJcWlflWms>().ne("wms_flag", 1));
+ Tag top = tagService.getTop();
+ for (NccJcWlflWms nccJcWlflWms : wmsFlag.getRecords()) {
+ if (!Cools.isEmpty(nccJcWlflWms.getSjflbm())) {
+ Tag priTag = tagService.selectOne(new EntityWrapper<Tag>().eq("uuid", nccJcWlflWms.getSjflbm()));
+ if (priTag == null) {
+ continue;
+ } else {
+ Tag tag = new Tag();
+ tag.setUuid(nccJcWlflWms.getCode());
+ tag.setName(nccJcWlflWms.getName());
+ tag.setParentId(priTag.getId());
+ tag.setParentName(priTag.getName());
+ tag.setType(0);
+ tag.setLevel(priTag.getLevel() + 1);
+ tag.setStatus(1);
+ tag.setCreateTime(new Date());
+ tag.setPath(priTag.getPath());
+ NodeUtils nodeUtils = new NodeUtils();
+ nodeUtils.executePath(priTag.getId());
+ tag.setPath(nodeUtils.path.toString());
+ tag.setPathName(nodeUtils.pathName.toString());
+ tagService.insert(tag);
+ nccJcWlflWms.setWmsFlag(1);
+ nccJcWlflWmsService.updateById(nccJcWlflWms);
+ }
+ } else {
+ Tag tag = new Tag();
+ tag.setUuid(nccJcWlflWms.getCode());
+ tag.setName(nccJcWlflWms.getName());
+ tag.setStatus(1);
+ tag.setCreateTime(new Date());
+ tag.setType(0);
+ tag.setLevel(2);
+ tag.setParentId(top.getId());
+ tag.setParentName(top.getName());
+ tag.setPath(top.getPath());
+ NodeUtils nodeUtils = new NodeUtils();
+ nodeUtils.executePath(top.getId());
+ tag.setPath(nodeUtils.path.toString());
+ tag.setPathName(nodeUtils.pathName.toString());
+ tagService.insert(tag);
+ nccJcWlflWms.setWmsFlag(1);
+ nccJcWlflWmsService.updateById(nccJcWlflWms);
+ }
+ log.info("NccJcWlflWms鏁版嵁:{}", JSONObject.toJSON(nccJcWlflWms));
+ }
+ return SUCCESS;
+ }
+
+ @Transactional
+ public ReturnT<String> start10() {
+ Page<NccOrgCorpWms> page = new Page<>(1, pageSize);
+ Page<NccOrgCorpWms> wmsFlag = nccOrgCorpWmsService.selectPage(page, new EntityWrapper<NccOrgCorpWms>().ne("wms_flag", 1));
+ for (NccOrgCorpWms nccOrgCorpWms : wmsFlag.getRecords()) {
+
+ log.info("NccOrgCorpWms鏁版嵁:{}", JSONObject.toJSON(nccOrgCorpWms));
+ }
+ return SUCCESS;
+ }
+
+ @Transactional
+ public ReturnT<String> start13() {
+ Page<VGetBdMaterial> page = new Page<>(1, pageSize);
+ Page<VGetBdMaterial> wmsFlag = vGetBdMaterialService.selectPage(page, new EntityWrapper<VGetBdMaterial>().ne("wms_flag", 1));
+ MatSyncParam param = new MatSyncParam();
+ List<MatSyncParam.MatParam> matDetails = new ArrayList<>();
+ MatSyncParam.MatParam matParam;
+ for (VGetBdMaterial vGetBdMaterial : wmsFlag.getRecords()) {
+ Tag priTag = tagService.selectOne(new EntityWrapper<Tag>().eq("uuid", vGetBdMaterial.get瀛樿揣鍒嗙被缂栫爜()));
+ if (priTag == null) {
+ continue;
+ }
+ matParam = new MatSyncParam.MatParam();
+ matParam.setMatnr(vGetBdMaterial.get鐗╂枡缂栫爜());
+ matParam.setMaktx(vGetBdMaterial.get鐗╂枡鍚嶇О());
+ matParam.setSpecs(vGetBdMaterial.get瑙勬牸());
+ matParam.setModel(vGetBdMaterial.get鍨嬪彿());
+ matParam.setUnit(vGetBdMaterial.get涓诲崟浣�());
+ matParam.setManu(vGetBdMaterial.get杈呭崟浣�());
+ matParam.setMemo(vGetBdMaterial.get澶囨敞());
+ matParam.setSku(vGetBdMaterial.get鐗╂枡绠�绉皍8鏃у搧鍚�());
+ matParam.setOrigin(vGetBdMaterial.get涓昏緟鎹㈢畻姣�());
+ matParam.setGroupCode(priTag.getId() + "");
+ matDetails.add(matParam);
+ }
+ if (!matDetails.isEmpty()) {
+ param.setMatDetails(matDetails);
+ openService.syncMat(param);
+ for (VGetBdMaterial vGetBdMaterial : wmsFlag.getRecords()) {
+ vGetBdMaterial.setWmsFlag(1);
+ }
+ for (VGetBdMaterial vGetBdMaterial : wmsFlag.getRecords()) {
+ vGetBdMaterialService.update(vGetBdMaterial, new EntityWrapper<VGetBdMaterial>().eq("鐗╂枡缂栫爜", vGetBdMaterial.get鐗╂枡缂栫爜()));
+ }
+ }
+ return SUCCESS;
+ }
+
}
--
Gitblit v1.9.1