From 32a905fbf1daeac74cbd573e5b841709c44955c2 Mon Sep 17 00:00:00 2001
From: ZY <zc857179121@qq.com>
Date: 星期四, 08 五月 2025 17:01:27 +0800
Subject: [PATCH] 代码编写
---
src/main/java/com/zy/nc/task/handler/BaseDataHandler.java | 242 ++++++++++++++++++++++++++++++++++++++++++++++--
1 files changed, 230 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..fb441a6 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,27 @@
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.Tag;
+import com.zy.asrs.entity.param.MatSyncParam;
+import com.zy.asrs.service.OpenService;
+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 java.util.ArrayList;
+import java.util.Date;
+import java.util.List;
@Service
@Slf4j
@@ -22,25 +34,231 @@
@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;
+
+ @Value("${NYNC.pageSize}")
+ private Integer pageSize;
+
/**
- *
- *
* @return
*/
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
*/
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;
}
+
+ 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;
+ }
+
+ 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;
+ }
+
+
+ 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;
+ }
+
+ 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));
+ }
+ return SUCCESS;
+ }
+
+ 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;
+ }
+
+ 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("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.setStatus(1);
+ user.setCreateTime(new Date());
+ userService.insert(user);
+ }
+ log.info("NccJcRyWms鏁版嵁:{}", JSONObject.toJSON(nccJcRyWms));
+ }
+ nccJcRyWmsService.updateBatchById(wmsFlag.getRecords());
+ return SUCCESS;
+ }
+
+ 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;
+ }
+
+ 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;
+ }
+
+
+ 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.setMemo(vGetBdMaterial.get澶囨敞());
+ matParam.setGroupCode(vGetBdMaterial.get瀛樿揣鍒嗙被缂栫爜());
+ matParam.setGroupName(vGetBdMaterial.get瀛樿揣鍒嗙被鍚嶇О());
+ matDetails.add(matParam);
+ }
+ if (!matDetails.isEmpty()) {
+ param.setMatDetails(matDetails);
+ openService.syncMat(param);
+ for (VGetBdMaterial vGetBdMaterial : wmsFlag.getRecords()) {
+ vGetBdMaterial.setWmsFlag(1);
+ }
+ vGetBdMaterialService.updateBatchById(wmsFlag.getRecords());
+ }
+ return SUCCESS;
+ }
+
}
--
Gitblit v1.9.1