From 4cb8ffac6221f56476d10a39dc2605aebb39de77 Mon Sep 17 00:00:00 2001 From: "pref_mail@163.com" Date: Tue, 13 Aug 2024 15:38:35 +0800 Subject: [PATCH 01/32] =?UTF-8?q?=E4=BF=AE=E5=A4=8Dsnm=20=E6=95=B0?= =?UTF-8?q?=E6=8D=AE=E9=87=8D=E5=A4=8D=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../factory/jobhandler/FactoryXxlJob.java | 86 +++++++++---------- 1 file changed, 41 insertions(+), 45 deletions(-) diff --git a/blade-service/logpm-factory/src/main/java/com/logpm/factory/jobhandler/FactoryXxlJob.java b/blade-service/logpm-factory/src/main/java/com/logpm/factory/jobhandler/FactoryXxlJob.java index c7d5cfeb4..d58108693 100644 --- a/blade-service/logpm-factory/src/main/java/com/logpm/factory/jobhandler/FactoryXxlJob.java +++ b/blade-service/logpm-factory/src/main/java/com/logpm/factory/jobhandler/FactoryXxlJob.java @@ -5,6 +5,7 @@ import cn.hutool.core.util.ObjectUtil; import cn.hutool.core.util.StrUtil; import cn.hutool.json.JSONUtil; import com.alibaba.fastjson.JSONObject; +import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.toolkit.StringUtils; import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.logpm.factory.comfac.dto.OrderStatusDTO; @@ -127,78 +128,72 @@ public class FactoryXxlJob { // 获取请求日志 按照状态来识别 List ls = orderLogService.lambdaQuery().eq(OrderLogEntity::getType, 1).eq(OrderLogEntity::getStatus, 1).list(); -// //XxlJobLogger.log("日志集合 {}", ls); - //XxlJobLogger.log("目前存在的数据 {}", newList); + + // 查询所有的数据库内容 只包含客户单号 + List allDataList = stationOrderService.list(); + XxlJobLogger.log("allDataList{}", allDataList.size()); // 解析数据 ls.forEach(orderLogEntity -> { - // 查询所有的数据库内容 只包含客户单号 - List allDataList = stationOrderService.list(); - XxlJobLogger.log("allDataList{}", allDataList.size()); - -// List newList = new ArrayList<>(); -// if (allDataList.size() != 0) { -// newList.addAll(allDataList.stream().map(StationOrderEntity::getTcWlb008).collect(Collectors.toList())); -// XxlJobLogger.log("newList{}", newList.size()); -// -// } - - //XxlJobLogger.log("日志对象 {}", orderLogEntity); Map map = orderService.dataRelative(orderLogEntity); - List dataList = map.get(StationOrderEntity.class.getName()); + List dataList = (List) map.get(StationOrderEntity.class.getName()); if (dataList.isEmpty()) { - //XxlJobLogger.log("本次解析操作没有数据"); - //更新数据库请求日志状态 + // 更新数据库请求日志状态 orderLogEntity.setStatus(0); orderLogService.updateById(orderLogEntity); return; } dataList = checkDataExit(dataList, allDataList); - if (dataList != null && dataList.size() != 0) { - //XxlJobLogger.log("保存对象StationOrderEntity {}", dataList); + if (!dataList.isEmpty()) { stationOrderService.saveBatch(dataList); } - //XxlJobLogger.log("日志对象 {}", dataList.get(0).getId()); - - List staorderPackagesEntityList = map.get(StaorderPackagesEntity.class.getName()); - List allDataStaorderPackagesEntity = staorderPackagesService.lambdaQuery().select(StaorderPackagesEntity::getPackagenum).list(); - List allStaorderPackagesEntityUnionId = allDataStaorderPackagesEntity.stream().map(StaorderPackagesEntity::getPackagenum).collect(Collectors.toList()); + List staorderPackagesEntityList = (List) map.get(StaorderPackagesEntity.class.getName()); - allStaorderPackagesEntityUnionId.forEach(t -> { - for (int i = 0; i < staorderPackagesEntityList.size(); i++) { - if (staorderPackagesEntityList.get(i).getPackagenum().equals(t)) { - staorderPackagesEntityList.remove(i); - break; - } + Set existingPackageNumbers = new HashSet<>(); + if (staorderPackagesEntityList != null) { + for (StaorderPackagesEntity staorderPackagesEntity : staorderPackagesEntityList) { + existingPackageNumbers.add(staorderPackagesEntity.getPackagenum()); } - }); - - /*************** SNM 存在 相同的车次 多次推送 重复的包件的操作**************/ - // 需要移除 当前合同号下的已经存在的包件 - + } - dataList.forEach(v -> { - for (int i = 0; i < staorderPackagesEntityList.size(); i++) { - if (staorderPackagesEntityList.get(i).getTcPoa014().equals(v.getTcWlb008())) { - staorderPackagesEntityList.get(i).setOrderId(v.getId()); + List finalDataList = dataList; + List filteredStaorderPackagesEntityList = staorderPackagesEntityList.stream() + .filter(staorderPackagesEntity -> { + + List list = staorderPackagesService.lambdaQuery() + .eq(StaorderPackagesEntity::getIsDeleted, 0) + .eq(StaorderPackagesEntity::getTcPoa014, staorderPackagesEntity.getTcPoa014()).list(); + // 验证查询处理的包件中是否包含当前循环的包件 + boolean exists = list.stream() + .anyMatch(t -> t.getPackagenum().equals(staorderPackagesEntity.getPackagenum())); + + if (!exists) { + // 更新订单ID + for (StationOrderEntity v : finalDataList) { + if (v.getTcWlb008().equals(staorderPackagesEntity.getTcPoa014())) { + staorderPackagesEntity.setOrderId(v.getId()); + } + } } - } - }); + + return !exists && !existingPackageNumbers.contains(staorderPackagesEntity.getPackagenum()); + }) + .collect(Collectors.toList()); // 插入数据库 - if (staorderPackagesEntityList != null && !staorderPackagesEntityList.isEmpty()) { - //XxlJobLogger.log("保存对象StaorderPackagesEntity {}", staorderPackagesEntityList); - staorderPackagesService.saveBatch(staorderPackagesEntityList); + if (!filteredStaorderPackagesEntityList.isEmpty()) { + staorderPackagesService.saveBatch(filteredStaorderPackagesEntityList); } - //更新数据库请求日志状态 + // 更新数据库请求日志状态 orderLogEntity.setStatus(0); orderLogService.updateById(orderLogEntity); }); + // 调用接口写入到老系统的数据库 if (ObjectUtil.equal(sendDataProperties.getSend(), "old")) { log.info("推送到老系统"); @@ -212,6 +207,7 @@ public class FactoryXxlJob { return ReturnT.SUCCESS; } + private Timestamp initTimestamp() { Calendar calendar = Calendar.getInstance(); From fa57fe7750c5a3bb953cdc6bcc92355a0b28a6cc Mon Sep 17 00:00:00 2001 From: zhaoqiaobo <583671871@qq.com> Date: Tue, 13 Aug 2024 15:45:23 +0800 Subject: [PATCH 02/32] =?UTF-8?q?feat(all):=20=E5=A2=9E=E5=8A=A0=E6=A2=A6?= =?UTF-8?q?=E5=A4=A9=E5=9B=9E=E6=8E=A8=E8=80=81=E6=8E=A5=E5=8F=A3=E5=BC=80?= =?UTF-8?q?=E5=85=B3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../receiver/BusinessData2FactoryHandler.java | 9 +++++--- ...BusinessDataClerkCheck2FactoryHandler.java | 7 ++++++- .../factory/props/MtFactoryProperties.java | 3 +++ .../receiver/HwyOrderStatusHandler.java | 14 ++++++++----- .../receiver/HwyUnloadCarComHandler.java | 8 ++++++- .../factory/receiver/OrderStatusHandler.java | 21 +++++++++++++------ 6 files changed, 46 insertions(+), 16 deletions(-) diff --git a/blade-service/logpm-factory/src/main/java/com/logpm/factory/mt/receiver/BusinessData2FactoryHandler.java b/blade-service/logpm-factory/src/main/java/com/logpm/factory/mt/receiver/BusinessData2FactoryHandler.java index eeaab1ae9..38916fb40 100644 --- a/blade-service/logpm-factory/src/main/java/com/logpm/factory/mt/receiver/BusinessData2FactoryHandler.java +++ b/blade-service/logpm-factory/src/main/java/com/logpm/factory/mt/receiver/BusinessData2FactoryHandler.java @@ -1,12 +1,11 @@ package com.logpm.factory.mt.receiver; import com.alibaba.fastjson.JSONObject; -import com.fasterxml.jackson.core.JsonProcessingException; import com.logpm.factory.mt.service.IMtFactoryDataService; +import com.logpm.factory.props.MtFactoryProperties; import com.rabbitmq.client.Channel; import lombok.extern.slf4j.Slf4j; import org.springblade.common.constant.RabbitConstant; -import org.springblade.core.tool.api.R; import org.springblade.core.tool.utils.DateUtil; import org.springframework.amqp.core.Message; import org.springframework.amqp.rabbit.annotation.RabbitHandler; @@ -30,6 +29,8 @@ public class BusinessData2FactoryHandler { @Autowired private IMtFactoryDataService mtFactoryDataService; + @Autowired + private MtFactoryProperties mtFactoryProperties; @RabbitHandler public void sendOrderPackageScan(Map map, Message message, Channel channel) throws IOException, NoSuchAlgorithmException { @@ -44,7 +45,9 @@ public class BusinessData2FactoryHandler { String destinationWarehouse = object.getString("destinationWarehouse"); try { - mtFactoryDataService.qianshouScanForNewSystem(orderPackageCode, operationTime, distributionContactId, destinationWarehouse); + if(mtFactoryProperties.getSendEnable()){ + mtFactoryDataService.qianshouScanForNewSystem(orderPackageCode, operationTime, distributionContactId, destinationWarehouse); + } } catch (Exception e) { log.error(">>>>>>", e); } diff --git a/blade-service/logpm-factory/src/main/java/com/logpm/factory/mt/receiver/BusinessDataClerkCheck2FactoryHandler.java b/blade-service/logpm-factory/src/main/java/com/logpm/factory/mt/receiver/BusinessDataClerkCheck2FactoryHandler.java index b9d1df19f..a12d9f390 100644 --- a/blade-service/logpm-factory/src/main/java/com/logpm/factory/mt/receiver/BusinessDataClerkCheck2FactoryHandler.java +++ b/blade-service/logpm-factory/src/main/java/com/logpm/factory/mt/receiver/BusinessDataClerkCheck2FactoryHandler.java @@ -3,6 +3,7 @@ package com.logpm.factory.mt.receiver; import com.alibaba.fastjson.JSONObject; import com.logpm.factory.mt.dto.MtReceiveDTO; import com.logpm.factory.mt.service.IMtFactoryDataService; +import com.logpm.factory.props.MtFactoryProperties; import com.rabbitmq.client.Channel; import lombok.extern.slf4j.Slf4j; import org.springblade.common.constant.RabbitConstant; @@ -29,6 +30,8 @@ public class BusinessDataClerkCheck2FactoryHandler { @Autowired private IMtFactoryDataService mtFactoryDataService; + @Autowired + private MtFactoryProperties mtFactoryProperties; @RabbitHandler public void sendOrderPackageScan(Map map, Message message, Channel channel) throws IOException, NoSuchAlgorithmException { @@ -38,7 +41,9 @@ public class BusinessDataClerkCheck2FactoryHandler { MtReceiveDTO mtReceiveDTO = JSONObject.parseObject(json,MtReceiveDTO.class); try { - mtFactoryDataService.sendReceiveInfoByNewSystem(mtReceiveDTO); + if(mtFactoryProperties.getSendEnable()){ + mtFactoryDataService.sendReceiveInfoByNewSystem(mtReceiveDTO); + } } catch (Exception e) { log.error(">>>>>>", e); } diff --git a/blade-service/logpm-factory/src/main/java/com/logpm/factory/props/MtFactoryProperties.java b/blade-service/logpm-factory/src/main/java/com/logpm/factory/props/MtFactoryProperties.java index 6b24adea5..60753cb15 100644 --- a/blade-service/logpm-factory/src/main/java/com/logpm/factory/props/MtFactoryProperties.java +++ b/blade-service/logpm-factory/src/main/java/com/logpm/factory/props/MtFactoryProperties.java @@ -19,5 +19,8 @@ public class MtFactoryProperties { private String userpwd ; + /** 是否推送梦天 */ + private Boolean sendEnable = true; + } diff --git a/blade-service/logpm-factory/src/main/java/com/logpm/factory/receiver/HwyOrderStatusHandler.java b/blade-service/logpm-factory/src/main/java/com/logpm/factory/receiver/HwyOrderStatusHandler.java index 40b9b481b..466605527 100644 --- a/blade-service/logpm-factory/src/main/java/com/logpm/factory/receiver/HwyOrderStatusHandler.java +++ b/blade-service/logpm-factory/src/main/java/com/logpm/factory/receiver/HwyOrderStatusHandler.java @@ -6,6 +6,7 @@ import com.logpm.factory.comfac.dto.OrderStatusDTO; import com.logpm.factory.mt.service.IMtFactoryDataService; import com.logpm.factory.oupai.service.IOuPaiFactoryService; import com.logpm.factory.pan.service.IPanFactoryDataService; +import com.logpm.factory.props.MtFactoryProperties; import com.logpm.trunkline.entity.TrunklineAdvanceEntity; import com.logpm.trunkline.feign.ITrunklineAdvanceClient; import com.rabbitmq.client.Channel; @@ -37,6 +38,7 @@ import java.util.Objects; public class HwyOrderStatusHandler { private final IPanFactoryDataService panFactoryDataService; + private final MtFactoryProperties mtFactoryProperties; private final IMtFactoryDataService mtFactoryDataService; private final IOuPaiFactoryService ouPaiFactoryService; private final ITrunklineAdvanceClient trunklineAdvanceClient; @@ -70,11 +72,13 @@ public class HwyOrderStatusHandler { } break; case FactoryConstant.MENGT: - r = mtFactoryDataService.handleStatusData(orderStatusDTO); - if (r.getCode() == 400 || r.getCode() == 200) { - log.info("TAG {} ##################hwyOrderStatusHandler: 该条数据不用处理 orderNo={}", FactoryConstant.MENGT, orderSelfNum); - } else { - throw new CustomerException(r.getCode(), r.getMsg()); + if(mtFactoryProperties.getSendEnable()){ + r = mtFactoryDataService.handleStatusData(orderStatusDTO); + if (r.getCode() == 400 || r.getCode() == 200) { + log.info("TAG {} ##################hwyOrderStatusHandler: 该条数据不用处理 orderNo={}", FactoryConstant.MENGT, orderSelfNum); + } else { + throw new CustomerException(r.getCode(), r.getMsg()); + } } break; case FactoryConstant.OUPAI: diff --git a/blade-service/logpm-factory/src/main/java/com/logpm/factory/receiver/HwyUnloadCarComHandler.java b/blade-service/logpm-factory/src/main/java/com/logpm/factory/receiver/HwyUnloadCarComHandler.java index cdf04f883..563774309 100644 --- a/blade-service/logpm-factory/src/main/java/com/logpm/factory/receiver/HwyUnloadCarComHandler.java +++ b/blade-service/logpm-factory/src/main/java/com/logpm/factory/receiver/HwyUnloadCarComHandler.java @@ -14,6 +14,7 @@ import com.logpm.factory.mt.entity.MtPushData; import com.logpm.factory.mt.service.IMtFactoryDataService; import com.logpm.factory.mt.service.IMtFactoryOrderMainService; import com.logpm.factory.mt.service.IMtPushDataService; +import com.logpm.factory.props.MtFactoryProperties; import com.logpm.factory.snm.vo.MTOrderPackageRelationVO; import com.logpm.factorydata.enums.BrandEnums; import com.logpm.factorydata.vo.NodePushMsg; @@ -61,6 +62,9 @@ public class HwyUnloadCarComHandler { @Autowired private IMtPushDataService mtPushDataService; + @Autowired + private MtFactoryProperties mtFactoryProperties; + @RabbitHandler public void unloadCarComDataHandler(NodePushMsg nodePushMsg, Message message, Channel channel) { @@ -68,7 +72,9 @@ public class HwyUnloadCarComHandler { BrandEnums brand = nodePushMsg.getBrand(); switch (brand) { case MTMM: - pushMentTian(nodePushMsg); + if(mtFactoryProperties.getSendEnable()){ + pushMentTian(nodePushMsg); + } break; } } diff --git a/blade-service/logpm-factory/src/main/java/com/logpm/factory/receiver/OrderStatusHandler.java b/blade-service/logpm-factory/src/main/java/com/logpm/factory/receiver/OrderStatusHandler.java index cee58bc3c..cd54d98f5 100644 --- a/blade-service/logpm-factory/src/main/java/com/logpm/factory/receiver/OrderStatusHandler.java +++ b/blade-service/logpm-factory/src/main/java/com/logpm/factory/receiver/OrderStatusHandler.java @@ -7,13 +7,18 @@ import com.logpm.factory.comfac.dto.OrderStatusDTO; import com.logpm.factory.mt.service.IMtFactoryDataService; import com.logpm.factory.oupai.service.IOuPaiFactoryService; import com.logpm.factory.pan.service.IPanFactoryDataService; +import com.logpm.factory.props.MtFactoryProperties; import com.logpm.factory.zb.service.IZbFactoryDataService; import com.logpm.oldproject.entity.AdvanceEntity; import com.logpm.oldproject.feign.IAdvanceClient; import com.logpm.oldproject.feign.ITrayClient; import com.logpm.oldproject.feign.ITrayScanClient; import com.logpm.oldproject.feign.ITrayScanDesClient; -import com.logpm.warehouse.feign.*; +import com.logpm.warehouse.feign.IWarehouseTaryAllocationClient; +import com.logpm.warehouse.feign.IWarehouseTrayGoodsClient; +import com.logpm.warehouse.feign.IWarehouseTrayTypeClient; +import com.logpm.warehouse.feign.IWarehouseUpdownGoodsClient; +import com.logpm.warehouse.feign.IWarehouseUpdownTypeClient; import com.rabbitmq.client.Channel; import lombok.extern.slf4j.Slf4j; import org.springblade.common.constant.RabbitConstant; @@ -50,6 +55,8 @@ public class OrderStatusHandler { private IMtFactoryDataService mtFactoryDataService; @Autowired private IZbFactoryDataService zbFactoryDataService; + @Autowired + private MtFactoryProperties mtFactoryProperties; @Autowired private IOuPaiFactoryService ouPaiFactoryService; @@ -105,11 +112,13 @@ public class OrderStatusHandler { } break; case FactoryConstant.MENGT: - r = mtFactoryDataService.handleStatusData(orderStatusDTO); - if (r.getCode() == 400 || r.getCode() == 200) { - log.info("TAG {} ##################orderStatusHandler: 该条数据不用处理 orderNo={}", FactoryConstant.MENGT, orderSelfNum); - } else { - throw new CustomerException(r.getCode(), r.getMsg()); + if(mtFactoryProperties.getSendEnable()){ + r = mtFactoryDataService.handleStatusData(orderStatusDTO); + if (r.getCode() == 400 || r.getCode() == 200) { + log.info("TAG {} ##################orderStatusHandler: 该条数据不用处理 orderNo={}", FactoryConstant.MENGT, orderSelfNum); + } else { + throw new CustomerException(r.getCode(), r.getMsg()); + } } break; case FactoryConstant.ZHIBANG: From 3b15d99659becbf56185a750e030a873e09b6dd2 Mon Sep 17 00:00:00 2001 From: zhenghaoyu Date: Tue, 13 Aug 2024 16:24:42 +0800 Subject: [PATCH 03/32] =?UTF-8?q?1.=E5=B9=B2=E7=BA=BFbug=E4=BF=AE=E5=A4=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../feign/IDistributionParcelListClient.java | 9 + .../IDistributionStockArticleClient.java | 8 + .../feign/DistributionParcelListClient.java | 10 + .../feign/DistributionStockArticleClient.java | 10 + .../IDistributionParcelListService.java | 1 + .../impl/PanFactoryDataServiceImpl.java | 4 + .../impl/SyncOrderInfoServiceImpl.java | 7 + .../listener/mq/PackageFanoutListener.java | 3 +- .../service/impl/OpenOrderServiceImpl.java | 20 +- .../impl/TrunklineCarsLoadServiceImpl.java | 24 ++ .../impl/WarehouseTrayGoodsServiceImpl.java | 5 +- .../impl/WarehouseTrayTypeServiceImpl.java | 209 +++++++++++++++++- 12 files changed, 295 insertions(+), 15 deletions(-) diff --git a/blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/feign/IDistributionParcelListClient.java b/blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/feign/IDistributionParcelListClient.java index 30fe2601b..b4d2e6835 100644 --- a/blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/feign/IDistributionParcelListClient.java +++ b/blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/feign/IDistributionParcelListClient.java @@ -204,4 +204,13 @@ public interface IDistributionParcelListClient { @PostMapping(API_PREFIX + "/addZeroParcelList") void addZeroParcelList(@RequestBody List addParcelListEntityList); + + @PostMapping(API_PREFIX + "/findListByIds") + List findListByIds(@RequestBody List orderPackageIdList); + + @PostMapping(API_PREFIX + "/clearPallet") + void clearPallet(@RequestBody List orderPackageIdList); + + + } diff --git a/blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/feign/IDistributionStockArticleClient.java b/blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/feign/IDistributionStockArticleClient.java index 72f9194f1..344e7c3a9 100644 --- a/blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/feign/IDistributionStockArticleClient.java +++ b/blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/feign/IDistributionStockArticleClient.java @@ -33,6 +33,7 @@ import org.springframework.web.bind.annotation.RequestParam; import java.util.List; import java.util.Map; +import java.util.Set; /** * 配送在库订单 Feign接口类 @@ -194,4 +195,11 @@ public interface IDistributionStockArticleClient { @GetMapping(API_PREFIX + "/addHandQuantityAndIncomingNum") void addHandQuantityAndIncomingNum(@RequestParam Long stockId, @RequestParam Integer enterNum); + + @GetMapping(API_PREFIX + "/findListByIds") + List findListByIds(@RequestBody Set stockArticleIdSet); + + @GetMapping(API_PREFIX + "/clearTraysByIds") + void clearTraysByIds(@RequestBody List clearStockArticleIdList); + } diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/feign/DistributionParcelListClient.java b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/feign/DistributionParcelListClient.java index 55e3c569a..816f5d8bc 100644 --- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/feign/DistributionParcelListClient.java +++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/feign/DistributionParcelListClient.java @@ -492,4 +492,14 @@ public class DistributionParcelListClient implements IDistributionParcelListClie distributionParcelNumberService.saveBatch(addList); } + + @Override + public List findListByIds(List orderPackageIdList) { + return distributionParcelListService.listByIds(orderPackageIdList); + } + + @Override + public void clearPallet(List orderPackageIdList) { + distributionParcelListService.clearPalletByIds(orderPackageIdList); + } } diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/feign/DistributionStockArticleClient.java b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/feign/DistributionStockArticleClient.java index fc6fe492f..9be71d31c 100644 --- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/feign/DistributionStockArticleClient.java +++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/feign/DistributionStockArticleClient.java @@ -389,4 +389,14 @@ public class DistributionStockArticleClient implements IDistributionStockArticle distributionStockArticleService.addHandQuantityAndIncomingNum(stockId,enterNum); } + @Override + public List findListByIds(Set stockArticleIdSet) { + return distributionStockArticleService.listByIds(stockArticleIdSet); + } + + @Override + public void clearTraysByIds(List clearStockArticleIdList) { + distributionStockArticleService.clearTraysByIds(clearStockArticleIdList); + } + } diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/IDistributionParcelListService.java b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/IDistributionParcelListService.java index ea2c3d3c5..3f363a7e2 100644 --- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/IDistributionParcelListService.java +++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/IDistributionParcelListService.java @@ -254,4 +254,5 @@ public interface IDistributionParcelListService extends BaseService parcelListIdList, String orderCode); void clearAllocationByIds(List clearTrayList); + } diff --git a/blade-service/logpm-factory/src/main/java/com/logpm/factory/pan/service/impl/PanFactoryDataServiceImpl.java b/blade-service/logpm-factory/src/main/java/com/logpm/factory/pan/service/impl/PanFactoryDataServiceImpl.java index ae60e6b22..66a4a45ce 100644 --- a/blade-service/logpm-factory/src/main/java/com/logpm/factory/pan/service/impl/PanFactoryDataServiceImpl.java +++ b/blade-service/logpm-factory/src/main/java/com/logpm/factory/pan/service/impl/PanFactoryDataServiceImpl.java @@ -660,6 +660,10 @@ public class PanFactoryDataServiceImpl implements IPanFactoryDataService { }else{ distributionStockArticleEntity.setTotalNumber(total); distributionStockArticleEntity.setGenre(1); + String reservationStatus = distributionStockArticleEntity.getReservationStatus(); + if("30".equals(reservationStatus)){ + distributionStockArticleEntity.setReservationStatus("20"); + } distributionStockArticleClient.saveOrUpdate(distributionStockArticleEntity); } diff --git a/blade-service/logpm-patch/src/main/java/com/logpm/patch/service/impl/SyncOrderInfoServiceImpl.java b/blade-service/logpm-patch/src/main/java/com/logpm/patch/service/impl/SyncOrderInfoServiceImpl.java index c10c530be..5efe2dab1 100644 --- a/blade-service/logpm-patch/src/main/java/com/logpm/patch/service/impl/SyncOrderInfoServiceImpl.java +++ b/blade-service/logpm-patch/src/main/java/com/logpm/patch/service/impl/SyncOrderInfoServiceImpl.java @@ -1613,6 +1613,7 @@ public class SyncOrderInfoServiceImpl implements ISyncOrderInfoService { private void saveOrderPackage(DistributionStockArticleEntity distributionStockArticleEntity, BasicdataWarehouseEntity basicdataWarehouseEntity, String waybillNo,String operationTime,Integer oldWarehouseId,Integer inventoryId) { String orderCode = distributionStockArticleEntity.getOrderCode(); + String reservationStatus = distributionStockArticleEntity.getReservationStatus(); Long warehouseId = basicdataWarehouseEntity.getId(); //查询订单下的所有包件 @@ -1771,6 +1772,12 @@ public class SyncOrderInfoServiceImpl implements ISyncOrderInfoService { log.warn("#################handleDataToPlatform: 保存包件信息失败 orderCode={}", entity.getOrderCode()); }else{ log.info("################handleDataToPlatform: 保存包件成功 OrderPackageCode={}",vo.getPacketBarCode()); + if("30".equals(reservationStatus)){ + distributionStockArticleEntity.setReservationStatus("20"); + distributionStockArticleClient.saveOrUpdate(distributionStockArticleEntity); + } + + // distributionStockArticleClient.updateOrderInfo(orderCode,distributionStockArticleEntity.getWarehouseId()); // Integer handQuantity = distributionStockArticleEntity.getHandQuantity(); // Integer totalNumber = distributionStockArticleEntity.getTotalNumber(); diff --git a/blade-service/logpm-statisticsdata/src/main/java/com/logpm/statistics/listener/mq/PackageFanoutListener.java b/blade-service/logpm-statisticsdata/src/main/java/com/logpm/statistics/listener/mq/PackageFanoutListener.java index 984a8bc4d..5c5eccb20 100644 --- a/blade-service/logpm-statisticsdata/src/main/java/com/logpm/statistics/listener/mq/PackageFanoutListener.java +++ b/blade-service/logpm-statisticsdata/src/main/java/com/logpm/statistics/listener/mq/PackageFanoutListener.java @@ -54,7 +54,8 @@ public class PackageFanoutListener { Integer workNode = jsonObject.getInt("workNode"); if (WorkNodeEnums.SIGN_DIRECT_SHIPPER.getCode().equals(workNode) || WorkNodeEnums.SIGN_TRIPARTITE_TRANSFER_DEPART.getCode().equals(workNode) - || WorkNodeEnums.DISTRIBUTION_SIGN_FOR.getCode().equals(workNode)) { + || WorkNodeEnums.DISTRIBUTION_SIGN_FOR.getCode().equals(workNode) + || WorkNodeEnums.DISTRIBUTION_ABNORMAL_SIGN_FOR.getCode().equals(workNode)) { JSONArray orderPackageCodes = jsonObject.getJSONArray("orderPackageCodes"); List orderPackageCodeList = orderPackageCodes.toList(String.class); diff --git a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/OpenOrderServiceImpl.java b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/OpenOrderServiceImpl.java index 91921cb14..3cfa6a2c9 100644 --- a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/OpenOrderServiceImpl.java +++ b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/OpenOrderServiceImpl.java @@ -190,24 +190,26 @@ public class OpenOrderServiceImpl implements IOpenOrderService { } + TrunklineAdvanceEntity advanceEntity = list.get(0); + if(!Objects.isNull(advanceEntity)){ + String consigneePerson = advanceEntity.getConsigneePerson(); + if(!StringUtil.isBlank(consigneePerson)){ + openOrderVO.setConsigneeName(consigneePerson); + openOrderVO.setConsigneeMobile(advanceEntity.getConsigneeMobile()); + openOrderVO.setConsigneeAddress(advanceEntity.getConsigneeAddress()); + } + } + //收货单位-----根据三方商场找到对应的clientId Long clientId = basicdataTripartiteMallClient.getClientIdByNameAndBrandAndCode(dealerName,StringUtil.isBlank(dealerCode)?"":dealerCode, brand); BasicdataClientVO basicdataClientEntity = basicdataClientClient.findEntityVoById(clientId); if (!Objects.isNull(basicdataClientEntity)) { openOrderVO.setConsigneeClientId(clientId); - TrunklineAdvanceEntity advanceEntity = list.get(0); openOrderVO.setConsignee(basicdataClientEntity.getClientName()); openOrderVO.setConsigneeName(basicdataClientEntity.getLinkman()); openOrderVO.setConsigneeMobile(basicdataClientEntity.getPhone()); openOrderVO.setConsigneeAddress(basicdataClientEntity.getDetailedly()); - if(!Objects.isNull(advanceEntity)){ - String consigneePerson = advanceEntity.getConsigneePerson(); - if(!StringUtil.isBlank(consigneePerson)){ - openOrderVO.setConsigneeName(consigneePerson); - openOrderVO.setConsigneeMobile(advanceEntity.getConsigneeMobile()); - openOrderVO.setConsigneeAddress(advanceEntity.getConsigneeAddress()); - } - } + List destinationArray = new ArrayList<>(); String badeRegionAreaId = basicdataClientEntity.getBladeRegionAreaId(); diff --git a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/TrunklineCarsLoadServiceImpl.java b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/TrunklineCarsLoadServiceImpl.java index 4cebefb91..c77040f3a 100644 --- a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/TrunklineCarsLoadServiceImpl.java +++ b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/TrunklineCarsLoadServiceImpl.java @@ -1142,6 +1142,8 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl queryWrapper = new QueryWrapper<>(); queryWrapper.eq("tray_code",trayCode) .eq("is_deleted",0); WarehouseTrayTypeEntity trayTypeEntity = baseMapper.selectOne(queryWrapper); trayTypeEntity.setWarehouseId(warehouseId); updateById(trayTypeEntity); - Long trayTypeId = trayTypeEntity.getId(); warehouseTrayGoodsService.updeteWarehouseIdByTrayTypeId(trayTypeId,warehouseId); + + + + QueryWrapper trayGoodsEntityQueryWrapper = new QueryWrapper<>(); + trayGoodsEntityQueryWrapper.eq("tray_type_id",trayTypeId); + List trayGoodsEntities = warehouseTrayGoodsService.list(trayGoodsEntityQueryWrapper); + + List updateStockArticleList = new ArrayList<>(); + List clearStockArticleIdList = new ArrayList<>(); + List updateParceList = new ArrayList<>(); + + + //把trayGoodsEntities中所有元素的associationType进行分组 + Map> map = trayGoodsEntities.stream().collect(Collectors.groupingBy(WarehouseTrayGoodsEntity::getAssociationType)); + map.keySet().forEach(associationType -> { + List warehouseTrayGoodsEntities = map.get(associationType); + if("1".equals(associationType)){ + //把warehouseTrayGoodsEntities中所有的associationId放入一个Set + Set orderIdSet = warehouseTrayGoodsEntities.stream().map(WarehouseTrayGoodsEntity::getAssociationId).collect(Collectors.toSet()); + List stockArticleEntityList = distributionStockArticleClient.findListByIds(orderIdSet); + stockArticleEntityList.forEach(stockArticleEntity -> { + String trays = stockArticleEntity.getTrays(); + if(!StringUtil.isBlank(trays)){ + if(trays.contains(palletName)){ + List list = Arrays.asList(trays.split(trays)); + List trayList = new ArrayList<>(list); + trayList.remove(palletName); + if(CollUtil.isNotEmpty(trayList)){ + DistributionStockArticleEntity updateStockArticle = new DistributionStockArticleEntity(); + updateStockArticle.setId(stockArticleEntity.getId()); + updateStockArticle.setTrays(StringUtil.join(trayList.toArray(),",")); + updateStockArticleList.add(updateStockArticle); + }else{ + clearStockArticleIdList.add(stockArticleEntity.getId()); + } + } + } + }); + + }else if ("3".equals(associationType)){ + //把trayGoodsEntities中的所有元素的associationId放入一个List + List orderPackageIdList = warehouseTrayGoodsEntities.stream().map(WarehouseTrayGoodsEntity::getAssociationId).collect(Collectors.toList()); + + //清除原来仓库的包件上的托盘信息 + distributionParcelListClient.clearPallet(orderPackageIdList); + + //查询原仓库有哪些包件 + List oldParceList = distributionParcelListClient.findListByIds(orderPackageIdList); + //把oldParceList中的所有元素的stockArticleId放入一个set + Set stockArticleIdSet = oldParceList.stream().map(DistributionParcelListEntity::getStockArticleId).collect(Collectors.toSet()); + List oldStockArticleList = distributionStockArticleClient.findListByIds(stockArticleIdSet); + oldStockArticleList.forEach(stockArticleEntity -> { + String trays = stockArticleEntity.getTrays(); + if(!StringUtil.isBlank(trays)){ + if(trays.contains(palletName)){ + List list = Arrays.asList(trays.split(trays)); + List trayList = new ArrayList<>(list); + trayList.remove(palletName); + if(CollUtil.isNotEmpty(trayList)){ + DistributionStockArticleEntity updateStockArticle = new DistributionStockArticleEntity(); + updateStockArticle.setId(stockArticleEntity.getId()); + updateStockArticle.setTrays(StringUtil.join(trayList.toArray(),",")); + updateStockArticleList.add(updateStockArticle); + }else{ + clearStockArticleIdList.add(stockArticleEntity.getId()); + } + } + } + }); + } + }); + +// if(CollUtil.isNotEmpty(updateStockArticleList)){ +// distributionStockArticleClient.updateByBatchId(updateStockArticleList); +// } +// +// if(CollUtil.isNotEmpty(clearStockArticleIdList)){ +// distributionStockArticleClient.clearTraysByIds(clearStockArticleIdList); +// } + + + List updateTrayGoodsList = new ArrayList<>(); + + //处理新的 + map.keySet().forEach(associationType -> { + List warehouseTrayGoodsEntities = map.get(associationType); + //把warehouseTrayGoodsEntities转化成以associationValue为key的Map + Map warehouseTrayGoodsMap = warehouseTrayGoodsEntities.stream() + .collect(Collectors.toMap( + WarehouseTrayGoodsEntity::getAssociationValue, // key + entity -> entity, // value + (existing, replacement) -> existing // 如果key重复，保留第一个值 + )); + + + if("1".equals(associationType)){ + //把warehouseTrayGoodsEntities中所有元素的associationValue放入一个Set + Set orderCodeSet = warehouseTrayGoodsEntities.stream().map(WarehouseTrayGoodsEntity::getAssociationValue).collect(Collectors.toSet()); + FindParamterDTO findParamterDTO = new FindParamterDTO(); + findParamterDTO.setOrderCodeSet(orderCodeSet); + findParamterDTO.setWarehouseId(warehouseId); + List stockArticleEntityList = distributionStockArticleClient.findListByOrderCodesAndWarehouseId(findParamterDTO); + stockArticleEntityList.forEach(stockArticleEntity -> { + WarehouseTrayGoodsEntity warehouseTrayGoodsEntity = warehouseTrayGoodsMap.get(stockArticleEntity.getOrderCode()); + if(!Objects.isNull(warehouseTrayGoodsEntity)){ + warehouseTrayGoodsEntity.setAssociationId(stockArticleEntity.getId()); + warehouseTrayGoodsEntity.setWarehouseId(warehouseId); + updateTrayGoodsList.add(warehouseTrayGoodsEntity); + } + String trays = stockArticleEntity.getTrays(); + if(!StringUtil.isBlank(trays)){ + if(!trays.contains(palletName)){ + List list = Arrays.asList(trays.split(trays)); + List trayList = new ArrayList<>(list); + trayList.add(palletName); + DistributionStockArticleEntity updateStockArticle = new DistributionStockArticleEntity(); + updateStockArticle.setId(stockArticleEntity.getId()); + updateStockArticle.setTrays(StringUtil.join(trayList.toArray(),",")); + updateStockArticleList.add(updateStockArticle); + } + }else{ + DistributionStockArticleEntity updateStockArticle = new DistributionStockArticleEntity(); + updateStockArticle.setId(stockArticleEntity.getId()); + updateStockArticle.setTrays(palletName); + updateStockArticleList.add(updateStockArticle); + } + }); + + }else if ("3".equals(associationType)){ + + //把warehouseTrayGoodsEntities中所有元素的associationValue放入一个Set + Set orderPackageCodeSet = warehouseTrayGoodsEntities.stream().map(WarehouseTrayGoodsEntity::getAssociationValue).collect(Collectors.toSet()); + FindParamterDTO findParamterDTO = new FindParamterDTO(); + findParamterDTO.setOrderPackageCodeList(new ArrayList<>(orderPackageCodeSet)); + findParamterDTO.setWarehouseId(warehouseId); + List parcelListEntityList = distributionParcelListClient.findListByOrderPackageCodeList(findParamterDTO); + + //把parcelListEntityList转化成以orderPackageCode为key的Map + Map parcelListEntityMap = parcelListEntityList.stream() + .collect(Collectors.toMap( + DistributionParcelListEntity::getOrderPackageCode, // key + entity -> entity, // value + (existing, replacement) -> existing // 如果key重复，保留第一个值 + )); + + warehouseTrayGoodsEntities.forEach(warehouseTrayGoodsEntity -> { + DistributionParcelListEntity parcelList = parcelListEntityMap.get(warehouseTrayGoodsEntity.getAssociationValue()); + if(!Objects.isNull(parcelList)){ + warehouseTrayGoodsEntity.setAssociationId(parcelList.getId()); + warehouseTrayGoodsEntity.setWarehouseId(warehouseId); + updateTrayGoodsList.add(warehouseTrayGoodsEntity); + + DistributionParcelListEntity updateParceEntity = new DistributionParcelListEntity(); + updateParceEntity.setId(parcelList.getId()); + updateParceEntity.setPallet(palletName); + updateParceList.add(updateParceEntity); + } + }); + + + //把parcelListEntityList中所有元素的orderCode放入一个Set + Set orderCodeSet = parcelListEntityList.stream().map(DistributionParcelListEntity::getOrderCode).collect(Collectors.toSet()); + + findParamterDTO.setOrderCodeSet(orderCodeSet); + findParamterDTO.setWarehouseId(warehouseId); + List stockArticleEntityList = distributionStockArticleClient.findListByOrderCodesAndWarehouseId(findParamterDTO); + stockArticleEntityList.forEach(stockArticleEntity -> { + String trays = stockArticleEntity.getTrays(); + if(!StringUtil.isBlank(trays)){ + if(trays.contains(palletName)){ + List list = Arrays.asList(trays.split(trays)); + List trayList = new ArrayList<>(list); + trayList.remove(palletName); + if(CollUtil.isNotEmpty(trayList)){ + DistributionStockArticleEntity updateStockArticle = new DistributionStockArticleEntity(); + updateStockArticle.setId(stockArticleEntity.getId()); + updateStockArticle.setTrays(StringUtil.join(trayList.toArray(),",")); + updateStockArticleList.add(updateStockArticle); + }else{ + clearStockArticleIdList.add(stockArticleEntity.getId()); + } + } + } + }); + } + }); + + if(CollUtil.isNotEmpty(updateParceList)){ + distributionParcelListClient.updateList(updateParceList); + } + + + if(CollUtil.isNotEmpty(updateStockArticleList)){ + distributionStockArticleClient.updateByBatchId(updateStockArticleList); + } + + if(CollUtil.isNotEmpty(clearStockArticleIdList)){ + distributionStockArticleClient.clearTraysByIds(clearStockArticleIdList); + } + } @Override From 31bd29fc7bbf63916c6b849c31737a10be19a630 Mon Sep 17 00:00:00 2001 From: zhenghaoyu Date: Tue, 13 Aug 2024 16:51:31 +0800 Subject: [PATCH 04/32] =?UTF-8?q?1.=E5=B9=B2=E7=BA=BFbug=E4=BF=AE=E5=A4=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../logpm/trunkline/mapper/TrunklineCarsLoadScanMapper.xml | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mapper/TrunklineCarsLoadScanMapper.xml b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mapper/TrunklineCarsLoadScanMapper.xml index efd905924..74363958b 100644 --- a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mapper/TrunklineCarsLoadScanMapper.xml +++ b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mapper/TrunklineCarsLoadScanMapper.xml @@ -62,10 +62,9 @@ From bc7c0c7d6a39c44f301a47443c9eea6380e2ec4b Mon Sep 17 00:00:00 2001 From: zhenghaoyu Date: Tue, 13 Aug 2024 17:14:54 +0800 Subject: [PATCH 05/32] =?UTF-8?q?1.=E5=B9=B2=E7=BA=BFbug=E4=BF=AE=E5=A4=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../impl/TrunklineCarsLoadServiceImpl.java | 178 +++++++++++++++++- .../impl/WarehouseTrayTypeServiceImpl.java | 5 + 2 files changed, 181 insertions(+), 2 deletions(-) diff --git a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/TrunklineCarsLoadServiceImpl.java b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/TrunklineCarsLoadServiceImpl.java index c77040f3a..4b463a25b 100644 --- a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/TrunklineCarsLoadServiceImpl.java +++ b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/TrunklineCarsLoadServiceImpl.java @@ -1102,7 +1102,8 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl carsLoadScanEntityList = trunklineCarsLoadScanService.list(queryWrapper); if(CollUtil.isNotEmpty(carsLoadScanEntityList)){ @@ -8487,6 +8488,179 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl queryWrapper = new QueryWrapper<>(); + queryWrapper.eq("waybill_no", waybillNo) + .eq("load_id", loadId) + .eq("final_node_id", warehouseId) + .eq("order_code", orderCode); + TrunklineCarsLoadScanEntity carsLoadScanEntity = trunklineCarsLoadScanService.getOne(queryWrapper); + if (Objects.isNull(carsLoadScanEntity)) { + log.warn("#############unloadZero: 零担信息不存在 waybillNo={} order_code={} loadId={} finalNodeId={}", waybillNo, orderCode, loadId, warehouseId); + return R.fail(405, "零担信息不存在"); + } + + Integer isAbnormal = 0; + Integer num = carsLoadScanEntity.getNum(); + Long fromWarehouseId = carsLoadScanEntity.getFromWarehouseId(); + Long waybillId = carsLoadScanEntity.getWaybillId(); + String scanCode = carsLoadScanEntity.getScanCode(); + Long loadScanId = carsLoadScanEntity.getId(); + if (enterNun > num) { + log.warn("#############unloadZero: 零担信息卸车数量大于装车件数 enterNun={} num={}", enterNun, num); + return R.fail(405, "零担信息卸车数量大于装车件数"); + } + + carsLoadScanEntity.setUnloadNum(enterNun); + carsLoadScanEntity.setUnloadNodeId(warehouseId); + carsLoadScanEntity.setUnloadNodeName(warehouseName); + carsLoadScanEntity.setUnloadAbnormal(0); + carsLoadScanEntity.setScanStatus("2"); + carsLoadScanEntity.setLoadingUserName(AuthUtil.getNickName()); + carsLoadScanEntity.setUnloadUserName(AuthUtil.getNickName()); + carsLoadScanEntity.setUnloadTime(new Date()); + carsLoadScanEntity.setUnloadTrayName(unloadTrayName); + carsLoadScanEntity.setUnloadTrayCode(unloadTrayCode); + trunklineCarsLoadScanService.updateById(carsLoadScanEntity); + + trunklineCarsUnloadLogService.savaUnloadLog(warehouseId, warehouseName, loadId, loadCode, waybillId, waybillNo, orderCode, + scanCode, enterNun, 2, 1, isAbnormal, trayId, trayCode, trayName, fromWarehouseId, loadScanId, remark); + + if (unbindTray == 1) { + if (!StringUtil.isBlank(trayCode)) { + trayTypeClient.deleteZeroOrderByTrayCode(orderCode, trayCode, fromWarehouseId, "干线卸车零担解托"); + } + } + + DistributionStockArticleEntity newStockArticleEntity = distributionStockArticleClient.findStockArticleByOrderCodeAndWarehouseId(orderCode, warehouseId); + if (Objects.isNull(newStockArticleEntity)) { + DistributionStockArticleEntity stockArticleEntity = distributionStockArticleClient.findStockArticleByOrderCodeAndWarehouseId(orderCode, fromWarehouseId); + newStockArticleEntity = new DistributionStockArticleEntity(); + BeanUtil.copy(stockArticleEntity, newStockArticleEntity); + newStockArticleEntity.setId(null); + newStockArticleEntity.setOrderReceiveStatus("20"); + newStockArticleEntity.setOrderStatus("10"); + newStockArticleEntity.setHandQuantity(enterNun); + newStockArticleEntity.setIncomingNum(enterNun); + newStockArticleEntity.setWarehouse(basicdataWarehouseEntity.getName()); + newStockArticleEntity.setWarehouseId(basicdataWarehouseEntity.getId()); + newStockArticleEntity.setCarsLoadNum(0); + Long orderId = distributionStockArticleClient.addData(newStockArticleEntity); + if (orderId != 0) { + List parcelListEntityList = distributionParcelListClient.findEntityListByOrderCode(orderCode, fromWarehouseId); + List ls = new ArrayList<>(); + for (DistributionParcelListEntity parcelListEntity : parcelListEntityList) { + DistributionParcelListEntity newParcelListEntity = new DistributionParcelListEntity(); + BeanUtil.copy(parcelListEntity, newParcelListEntity); + newParcelListEntity.setId(null); + newParcelListEntity.setWarehouseId(warehouseId); + newParcelListEntity.setWarehouse(warehouseName); + newParcelListEntity.setStockArticleId(orderId); + Long acceptWarehouseId = parcelListEntity.getAcceptWarehouseId(); + if(warehouseId.equals(acceptWarehouseId)){ + newParcelListEntity.setIsTransfer(0); + }else{ + newParcelListEntity.setIsTransfer(1); + } + Long orderPackageId = distributionParcelListClient.addReturnId(newParcelListEntity); + + DistributionParcelNumberEntity parcelNumberEntity = new DistributionParcelNumberEntity(); + parcelNumberEntity.setStockArticleId(orderId); + parcelNumberEntity.setParcelListId(orderPackageId); + parcelNumberEntity.setQuantity(newParcelListEntity.getQuantity()); + parcelNumberEntity.setHandQuantity(0); + parcelNumberEntity.setDeliveryQuantity(0); + parcelNumberEntity.setSigninQuantity(0); + parcelNumberEntity.setOutboundQuantity(0); + parcelNumberEntity.setWarehouseId(warehouseId); + ls.add(parcelNumberEntity); + } + distributionParcelNumberClient.addBatch(ls); + } + } else { + Integer handQuantity = newStockArticleEntity.getHandQuantity() + enterNun; + Integer incomingNum = newStockArticleEntity.getIncomingNum() + enterNun; + Integer totalNumber = newStockArticleEntity.getTotalNumber(); + + if (incomingNum.equals(totalNumber)) { + if (handQuantity.equals(totalNumber)) { + newStockArticleEntity.setOrderStatus("20"); + } else { + newStockArticleEntity.setOrderStatus("30"); + } + newStockArticleEntity.setOrderReceiveStatus("30"); + } else { + if (incomingNum.equals(handQuantity)) { + newStockArticleEntity.setOrderStatus("10"); + } else { + newStockArticleEntity.setOrderStatus("30"); + } + newStockArticleEntity.setOrderReceiveStatus("20"); + } + newStockArticleEntity.setHandQuantity(handQuantity); + newStockArticleEntity.setIncomingNum(incomingNum); + + distributionStockArticleClient.saveOrUpdate(newStockArticleEntity); + } + + updateNumByLoadId(loadId); + +// JSONObject jsonObject = trunklineCarsLoadScanService.findUnloadNumAudio(loadId,warehouseId); +// Integer totalUnloadNum = jsonObject.getInteger("totalUnloadNum"); +// Integer abnormalUnloadNum = jsonObject.getInteger("abnormalUnloadNum"); +// StringBuilder audio = new StringBuilder(); +// audio.append("卸车").append(totalUnloadNum).append("件"); +// if(!Objects.isNull(abnormalUnloadNum) && !abnormalUnloadNum.equals(0)){ +// audio.append("异常卸车").append(abnormalUnloadNum).append("件"); +// } + return Resp.scanSuccess("卸车成功", audio.toString()); + } + + public R unloadZeroNoXz(Long loadId, String waybillNo, Integer enterNun, Long warehouseId, Integer unbindTray, String trayCode, String orderCode, String remark) { log.info("#############unloadZero: 卸车零担"); @@ -8761,7 +8935,7 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl Date: Tue, 13 Aug 2024 17:18:12 +0800 Subject: [PATCH 06/32] =?UTF-8?q?1.=E5=B9=B2=E7=BA=BFbug=E4=BF=AE=E5=A4=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../trunkline/service/impl/TrunklineCarsLoadServiceImpl.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/TrunklineCarsLoadServiceImpl.java b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/TrunklineCarsLoadServiceImpl.java index 4b463a25b..b67e3494b 100644 --- a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/TrunklineCarsLoadServiceImpl.java +++ b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/TrunklineCarsLoadServiceImpl.java @@ -8657,7 +8657,7 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl Date: Tue, 13 Aug 2024 17:59:05 +0800 Subject: [PATCH 07/32] =?UTF-8?q?=E4=BF=AE=E5=A4=8Dsnm=20=E6=95=B0?= =?UTF-8?q?=E6=8D=AE=E9=87=8D=E5=A4=8D=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/logpm/factory/jobhandler/FactoryXxlJob.java | 6 ++---- .../logpm/factory/snm/service/impl/OrderServiceImpl.java | 3 +++ 2 files changed, 5 insertions(+), 4 deletions(-) diff --git a/blade-service/logpm-factory/src/main/java/com/logpm/factory/jobhandler/FactoryXxlJob.java b/blade-service/logpm-factory/src/main/java/com/logpm/factory/jobhandler/FactoryXxlJob.java index d58108693..9d82d0e83 100644 --- a/blade-service/logpm-factory/src/main/java/com/logpm/factory/jobhandler/FactoryXxlJob.java +++ b/blade-service/logpm-factory/src/main/java/com/logpm/factory/jobhandler/FactoryXxlJob.java @@ -5,7 +5,6 @@ import cn.hutool.core.util.ObjectUtil; import cn.hutool.core.util.StrUtil; import cn.hutool.json.JSONUtil; import com.alibaba.fastjson.JSONObject; -import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; import com.baomidou.mybatisplus.core.toolkit.StringUtils; import com.baomidou.mybatisplus.core.toolkit.Wrappers; import com.logpm.factory.comfac.dto.OrderStatusDTO; @@ -132,7 +131,7 @@ public class FactoryXxlJob { // 查询所有的数据库内容 只包含客户单号 List allDataList = stationOrderService.list(); - XxlJobLogger.log("allDataList{}", allDataList.size()); + XxlJobLogger.log("allDataList {}", allDataList.size()); // 解析数据 ls.forEach(orderLogEntity -> { @@ -220,7 +219,7 @@ public class FactoryXxlJob { } @Transactional(rollbackFor = Exception.class) - public Boolean resoveFactoryData() { + public void resoveFactoryData() { Map> map = new HashMap<>(); //TODO 调用Service 获取需要处理的数据 //查询要处理的订单信息 @@ -416,7 +415,6 @@ public class FactoryXxlJob { }); } - return true; } @Transactional(rollbackFor = Exception.class) diff --git a/blade-service/logpm-factory/src/main/java/com/logpm/factory/snm/service/impl/OrderServiceImpl.java b/blade-service/logpm-factory/src/main/java/com/logpm/factory/snm/service/impl/OrderServiceImpl.java index fef7abcdc..d3d356bbb 100644 --- a/blade-service/logpm-factory/src/main/java/com/logpm/factory/snm/service/impl/OrderServiceImpl.java +++ b/blade-service/logpm-factory/src/main/java/com/logpm/factory/snm/service/impl/OrderServiceImpl.java @@ -121,6 +121,7 @@ public class OrderServiceImpl implements IOrderService { @Override public Map dataRelative(OrderLogEntity orderLogEntity) { + logger.info(">>>>>>>>>>>>>> 待解析数据{}", orderLogEntity.getResBody()); Map map = new HashMap<>(); String resBody = orderLogEntity.getResBody(); @@ -136,6 +137,8 @@ public class OrderServiceImpl implements IOrderService { List rs = new ArrayList<>(); List PACKAGE_LIST = new ArrayList<>(); + logger.info(">>>>>>>>>>>>>> responseStationOrderVo.getData() {}", responseStationOrderVo.getData()); + responseStationOrderVo.getData().forEach(responseStationOrderInfoVo -> { StationOrderEntity stationOrderEntity = new StationOrderEntity(); PACKAGE_LIST.addAll(responseStationOrderInfoVo.getPACKAGE_LIST()); From 76c01d83a62252d873069b8beab6aa15dcf33457 Mon Sep 17 00:00:00 2001 From: "pref_mail@163.com" Date: Tue, 13 Aug 2024 18:21:49 +0800 Subject: [PATCH 08/32] =?UTF-8?q?=E4=BF=AE=E5=A4=8Dsnm=20=E6=95=B0?= =?UTF-8?q?=E6=8D=AE=E9=87=8D=E5=A4=8D=E9=97=AE=E9=A2=98=202?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/logpm/factory/jobhandler/FactoryXxlJob.java | 6 ++++-- .../logpm/factory/snm/service/impl/OrderServiceImpl.java | 4 +++- 2 files changed, 7 insertions(+), 3 deletions(-) diff --git a/blade-service/logpm-factory/src/main/java/com/logpm/factory/jobhandler/FactoryXxlJob.java b/blade-service/logpm-factory/src/main/java/com/logpm/factory/jobhandler/FactoryXxlJob.java index 9d82d0e83..9b0997a66 100644 --- a/blade-service/logpm-factory/src/main/java/com/logpm/factory/jobhandler/FactoryXxlJob.java +++ b/blade-service/logpm-factory/src/main/java/com/logpm/factory/jobhandler/FactoryXxlJob.java @@ -163,12 +163,12 @@ public class FactoryXxlJob { .filter(staorderPackagesEntity -> { List list = staorderPackagesService.lambdaQuery() - .eq(StaorderPackagesEntity::getIsDeleted, 0) .eq(StaorderPackagesEntity::getTcPoa014, staorderPackagesEntity.getTcPoa014()).list(); // 验证查询处理的包件中是否包含当前循环的包件 boolean exists = list.stream() .anyMatch(t -> t.getPackagenum().equals(staorderPackagesEntity.getPackagenum())); - + log.info("staorderPackagesEntity.getPackagenum() {}", staorderPackagesEntity.getPackagenum()); + log.info("exists", exists); if (!exists) { // 更新订单ID for (StationOrderEntity v : finalDataList) { @@ -177,11 +177,13 @@ public class FactoryXxlJob { } } } + log.info("existingPackageNumbers {}", existingPackageNumbers); return !exists && !existingPackageNumbers.contains(staorderPackagesEntity.getPackagenum()); }) .collect(Collectors.toList()); + log.info("filteredStaorderPackagesEntityList {}", filteredStaorderPackagesEntityList.size()); // 插入数据库 if (!filteredStaorderPackagesEntityList.isEmpty()) { staorderPackagesService.saveBatch(filteredStaorderPackagesEntityList); diff --git a/blade-service/logpm-factory/src/main/java/com/logpm/factory/snm/service/impl/OrderServiceImpl.java b/blade-service/logpm-factory/src/main/java/com/logpm/factory/snm/service/impl/OrderServiceImpl.java index d3d356bbb..404bee3b2 100644 --- a/blade-service/logpm-factory/src/main/java/com/logpm/factory/snm/service/impl/OrderServiceImpl.java +++ b/blade-service/logpm-factory/src/main/java/com/logpm/factory/snm/service/impl/OrderServiceImpl.java @@ -141,7 +141,9 @@ public class OrderServiceImpl implements IOrderService { responseStationOrderVo.getData().forEach(responseStationOrderInfoVo -> { StationOrderEntity stationOrderEntity = new StationOrderEntity(); - PACKAGE_LIST.addAll(responseStationOrderInfoVo.getPACKAGE_LIST()); + if(!ObjectUtils.isEmpty(responseStationOrderInfoVo.getPACKAGE_LIST())){ + PACKAGE_LIST.addAll(responseStationOrderInfoVo.getPACKAGE_LIST()); + } try { buildStationOrderEntityByRelative(responseStationOrderInfoVo, stationOrderEntity); } catch (NoSuchFieldException e) { From 1852f7361fb43d1778b5111f055b83e34874bc92 Mon Sep 17 00:00:00 2001 From: zhaoqiaobo <583671871@qq.com> Date: Tue, 13 Aug 2024 18:32:33 +0800 Subject: [PATCH 09/32] =?UTF-8?q?feat(all):=20=E4=BF=AE=E6=94=B9=E6=8A=A5?= =?UTF-8?q?=E8=A1=A8=E6=A8=A1=E5=9D=97=E5=AF=BC=E5=87=BA=E9=80=BB=E8=BE=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/logpm/report/util/ReportExcelUtil.java | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/blade-service/logpm-report/src/main/java/com/logpm/report/util/ReportExcelUtil.java b/blade-service/logpm-report/src/main/java/com/logpm/report/util/ReportExcelUtil.java index 1cd0d4a38..56e64f072 100644 --- a/blade-service/logpm-report/src/main/java/com/logpm/report/util/ReportExcelUtil.java +++ b/blade-service/logpm-report/src/main/java/com/logpm/report/util/ReportExcelUtil.java @@ -23,14 +23,12 @@ import java.io.IOException; import java.io.UnsupportedEncodingException; import java.net.URLEncoder; import java.nio.charset.StandardCharsets; -import java.util.ArrayList; import java.util.List; import java.util.Map; import java.util.concurrent.CompletableFuture; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.CountDownLatch; import java.util.concurrent.Executor; -import java.util.concurrent.ExecutorService; /** * excel导出工具类 @@ -109,7 +107,7 @@ public class ReportExcelUtil { throw new ServiceException("导出数据不能大于50w，请增加检索条件"); } // 每个 sheet 放多少条数据 - Double sheetDataNum = onceSheetDataNum.doubleValue(); + Long sheetDataNum = Math.min(count, onceSheetDataNum); // 总共要几个 sheet int sheetNum = (int) Math.ceil((count / sheetDataNum)); // 总共需要查询数据库几次 @@ -129,9 +127,11 @@ public class ReportExcelUtil { for (int i = 0; i < sheetNum; i++) { // sheet编号 int finalI = i + 1; + // long ceilNum = Math.min(count, 100) + // 还剩多少条数据 + long l = count - (sheetDataNum * num); // 每页需要查几次 - long l = count - (pageSize * num); - long ceil = l > pageSize ? (int) Math.ceil(onceSheetDataNum / pageSize.doubleValue()) : (int) Math.ceil(l / pageSize.doubleValue()); + long ceil = (int) Math.ceil(l / pageSize.doubleValue()); for (int j = 0; j < ceil; j++) { // 已经查询过几次了 int finalNum = num; From d3990f33329fbc309866e98f4a9e3906068b3b33 Mon Sep 17 00:00:00 2001 From: "pref_mail@163.com" Date: Tue, 13 Aug 2024 18:53:41 +0800 Subject: [PATCH 10/32] =?UTF-8?q?=E4=BF=AE=E5=A4=8Dsnm=20=E6=95=B0?= =?UTF-8?q?=E6=8D=AE=E9=87=8D=E5=A4=8D=E9=97=AE=E9=A2=98=203?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../logpm/factory/jobhandler/FactoryXxlJob.java | 15 +++++---------- 1 file changed, 5 insertions(+), 10 deletions(-) diff --git a/blade-service/logpm-factory/src/main/java/com/logpm/factory/jobhandler/FactoryXxlJob.java b/blade-service/logpm-factory/src/main/java/com/logpm/factory/jobhandler/FactoryXxlJob.java index 9b0997a66..368599d49 100644 --- a/blade-service/logpm-factory/src/main/java/com/logpm/factory/jobhandler/FactoryXxlJob.java +++ b/blade-service/logpm-factory/src/main/java/com/logpm/factory/jobhandler/FactoryXxlJob.java @@ -151,12 +151,7 @@ public class FactoryXxlJob { List staorderPackagesEntityList = (List) map.get(StaorderPackagesEntity.class.getName()); - Set existingPackageNumbers = new HashSet<>(); - if (staorderPackagesEntityList != null) { - for (StaorderPackagesEntity staorderPackagesEntity : staorderPackagesEntityList) { - existingPackageNumbers.add(staorderPackagesEntity.getPackagenum()); - } - } + List finalDataList = dataList; List filteredStaorderPackagesEntityList = staorderPackagesEntityList.stream() @@ -168,7 +163,7 @@ public class FactoryXxlJob { boolean exists = list.stream() .anyMatch(t -> t.getPackagenum().equals(staorderPackagesEntity.getPackagenum())); log.info("staorderPackagesEntity.getPackagenum() {}", staorderPackagesEntity.getPackagenum()); - log.info("exists", exists); + log.info("exists {}" , exists); if (!exists) { // 更新订单ID for (StationOrderEntity v : finalDataList) { @@ -177,9 +172,9 @@ public class FactoryXxlJob { } } } - log.info("existingPackageNumbers {}", existingPackageNumbers); - - return !exists && !existingPackageNumbers.contains(staorderPackagesEntity.getPackagenum()); + boolean isExist = !exists ; + log.info("isExist {}", isExist); + return isExist; }) .collect(Collectors.toList()); From db915d849efec605ca4a42faf65e957887d9234c Mon Sep 17 00:00:00 2001 From: zhaoqiaobo <583671871@qq.com> Date: Tue, 13 Aug 2024 19:07:13 +0800 Subject: [PATCH 11/32] =?UTF-8?q?feat(all):=20=E4=BF=AE=E6=94=B9=E6=8A=A5?= =?UTF-8?q?=E8=A1=A8=E6=A8=A1=E5=9D=97=E5=AF=BC=E5=87=BA=E9=80=BB=E8=BE=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/logpm/report/service/impl/AsyncServiceImpl.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/blade-service/logpm-report/src/main/java/com/logpm/report/service/impl/AsyncServiceImpl.java b/blade-service/logpm-report/src/main/java/com/logpm/report/service/impl/AsyncServiceImpl.java index 5f0552320..630a26f66 100644 --- a/blade-service/logpm-report/src/main/java/com/logpm/report/service/impl/AsyncServiceImpl.java +++ b/blade-service/logpm-report/src/main/java/com/logpm/report/service/impl/AsyncServiceImpl.java @@ -74,7 +74,8 @@ public class AsyncServiceImpl implements IAsyncService { // 当前第几次查询 int current = finalNum + 1; // 当前查询需要查询几条数据 - long lastNum = remaindNum > pageSize ? pageSize : remaindNum; + // long lastNum = remaindNum > pageSize ? pageSize : remaindNum; + long lastNum = pageSize; // 分页查询对象 Page page = new Page(current, lastNum); // 执行查询操作返回数据 From b105a6a875cbbb06cb3015f993b30e9d486794cf Mon Sep 17 00:00:00 2001 From: zhaoqiaobo <583671871@qq.com> Date: Tue, 13 Aug 2024 19:37:00 +0800 Subject: [PATCH 12/32] =?UTF-8?q?feat(all):=20=E4=BF=AE=E6=94=B9=E6=8A=A5?= =?UTF-8?q?=E8=A1=A8=E6=A8=A1=E5=9D=97=E5=AF=BC=E5=87=BA=E9=80=BB=E8=BE=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/logpm/report/service/impl/ReportDeliverServiceImpl.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/blade-service/logpm-report/src/main/java/com/logpm/report/service/impl/ReportDeliverServiceImpl.java b/blade-service/logpm-report/src/main/java/com/logpm/report/service/impl/ReportDeliverServiceImpl.java index e62f16a56..e69c6e9c6 100644 --- a/blade-service/logpm-report/src/main/java/com/logpm/report/service/impl/ReportDeliverServiceImpl.java +++ b/blade-service/logpm-report/src/main/java/com/logpm/report/service/impl/ReportDeliverServiceImpl.java @@ -196,7 +196,7 @@ public class ReportDeliverServiceImpl implements ReportDeliverService { trainCustomQuery(query, queryWrapper); // 仓库权限 ReportUtil.buildReportWarehouseAuth(vo.getWarehouseName(), query.getWarehouseNameRange(), queryWrapper, warehouseClient); - reportExcelUtil.export(response, deliveryTrainReader, ReportDevilerVO.class, queryWrapper, "配送车次维度报表",20L, ReportExcelUtil.SHEETDATANUM); + reportExcelUtil.export(response, deliveryTrainReader, ReportDevilerVO.class, queryWrapper, "配送车次维度报表",5000L, ReportExcelUtil.SHEETDATANUM); } @Override From 51e2eaff5e19731d807369e624bfe8b12dc7d4cf Mon Sep 17 00:00:00 2001 From: zhaoqiaobo <583671871@qq.com> Date: Wed, 14 Aug 2024 09:48:12 +0800 Subject: [PATCH 13/32] =?UTF-8?q?feat(all):=20=E4=BF=AE=E6=94=B9=E6=8A=A5?= =?UTF-8?q?=E8=A1=A8=E6=A8=A1=E5=9D=97=E5=AF=BC=E5=87=BA=E9=80=BB=E8=BE=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/logpm/report/service/impl/ReportDeliverServiceImpl.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/blade-service/logpm-report/src/main/java/com/logpm/report/service/impl/ReportDeliverServiceImpl.java b/blade-service/logpm-report/src/main/java/com/logpm/report/service/impl/ReportDeliverServiceImpl.java index e69c6e9c6..668733116 100644 --- a/blade-service/logpm-report/src/main/java/com/logpm/report/service/impl/ReportDeliverServiceImpl.java +++ b/blade-service/logpm-report/src/main/java/com/logpm/report/service/impl/ReportDeliverServiceImpl.java @@ -196,7 +196,7 @@ public class ReportDeliverServiceImpl implements ReportDeliverService { trainCustomQuery(query, queryWrapper); // 仓库权限 ReportUtil.buildReportWarehouseAuth(vo.getWarehouseName(), query.getWarehouseNameRange(), queryWrapper, warehouseClient); - reportExcelUtil.export(response, deliveryTrainReader, ReportDevilerVO.class, queryWrapper, "配送车次维度报表",5000L, ReportExcelUtil.SHEETDATANUM); + reportExcelUtil.export(response, deliveryTrainReader, ReportDevilerVO.class, queryWrapper, "配送车次维度报表",500L, ReportExcelUtil.SHEETDATANUM); } @Override From 68f09d85698524ea9abe2e23800652177e0e7559 Mon Sep 17 00:00:00 2001 From: zhaoqiaobo <583671871@qq.com> Date: Wed, 14 Aug 2024 10:18:14 +0800 Subject: [PATCH 14/32] =?UTF-8?q?feat(all):=20=E4=BF=AE=E6=94=B9=E6=8A=A5?= =?UTF-8?q?=E8=A1=A8=E6=A8=A1=E5=9D=97=E5=AF=BC=E5=87=BA=E9=80=BB=E8=BE=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/logpm/report/service/impl/ReportDeliverServiceImpl.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/blade-service/logpm-report/src/main/java/com/logpm/report/service/impl/ReportDeliverServiceImpl.java b/blade-service/logpm-report/src/main/java/com/logpm/report/service/impl/ReportDeliverServiceImpl.java index 668733116..384a0cb55 100644 --- a/blade-service/logpm-report/src/main/java/com/logpm/report/service/impl/ReportDeliverServiceImpl.java +++ b/blade-service/logpm-report/src/main/java/com/logpm/report/service/impl/ReportDeliverServiceImpl.java @@ -196,7 +196,7 @@ public class ReportDeliverServiceImpl implements ReportDeliverService { trainCustomQuery(query, queryWrapper); // 仓库权限 ReportUtil.buildReportWarehouseAuth(vo.getWarehouseName(), query.getWarehouseNameRange(), queryWrapper, warehouseClient); - reportExcelUtil.export(response, deliveryTrainReader, ReportDevilerVO.class, queryWrapper, "配送车次维度报表",500L, ReportExcelUtil.SHEETDATANUM); + reportExcelUtil.export(response, deliveryTrainReader, ReportDevilerVO.class, queryWrapper, "配送车次维度报表",2000L, ReportExcelUtil.SHEETDATANUM); } @Override From 1a1bc0048c1ed507a3a9387af2f04ea7bcc19d90 Mon Sep 17 00:00:00 2001 From: "pref_mail@163.com" Date: Wed, 14 Aug 2024 11:12:25 +0800 Subject: [PATCH 15/32] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E6=8E=A8=E9=80=81?= =?UTF-8?q?=E8=80=81=E7=B3=BB=E7=BB=9F=E6=8A=A5=E9=94=99=20=E6=B2=A1?= =?UTF-8?q?=E6=9C=89=E9=94=99=E8=AF=AF=E4=BF=A1=E6=81=AF=E7=9A=84=E6=B8=85?= =?UTF-8?q?=E7=90=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../feign/IDistributionSignforClient.java | 4 +- .../oldproject/feign/IOldSignPushClient.java | 2 +- .../feign/DistributionSignforClient.java | 3 +- .../ClerkCheckPushDataQueueHandler.java | 4 +- .../service/IDistributionSignforService.java | 2 +- .../impl/DistributionSignforServiceImpl.java | 23 +++-- .../oldproject/feign/SignPushClient.java | 11 ++- .../jobhandle/DistributionDatarepair.java | 97 ++++++++++--------- 8 files changed, 81 insertions(+), 65 deletions(-) diff --git a/blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/feign/IDistributionSignforClient.java b/blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/feign/IDistributionSignforClient.java index 53ca6e01c..be055727d 100644 --- a/blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/feign/IDistributionSignforClient.java +++ b/blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/feign/IDistributionSignforClient.java @@ -24,6 +24,8 @@ import org.springframework.cloud.openfeign.FeignClient; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.RequestParam; +import java.util.Map; + /** * 签收管理 Feign接口类 * @@ -61,5 +63,5 @@ public interface IDistributionSignforClient { * @return */ @GetMapping(CLERKCHECKPUSHDATA) - Boolean clerkCheckPushData(@RequestParam("id") Long id); + Map clerkCheckPushData(@RequestParam("id") Long id); } diff --git a/blade-service-api/logpm-old-project-api/src/main/java/com/logpm/oldproject/feign/IOldSignPushClient.java b/blade-service-api/logpm-old-project-api/src/main/java/com/logpm/oldproject/feign/IOldSignPushClient.java index f5c0818e6..90d735e35 100644 --- a/blade-service-api/logpm-old-project-api/src/main/java/com/logpm/oldproject/feign/IOldSignPushClient.java +++ b/blade-service-api/logpm-old-project-api/src/main/java/com/logpm/oldproject/feign/IOldSignPushClient.java @@ -20,7 +20,7 @@ public interface IOldSignPushClient { String API_PREFIX = "/client"; @PostMapping(API_PREFIX + "/pushOldSystemSignInfo") - Boolean pushOldSystemSignInfo(@RequestBody SignPushDataDTO signPushDataDTO); + Map pushOldSystemSignInfo(@RequestBody SignPushDataDTO signPushDataDTO); diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/feign/DistributionSignforClient.java b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/feign/DistributionSignforClient.java index ed3aa21d3..a347285fa 100644 --- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/feign/DistributionSignforClient.java +++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/feign/DistributionSignforClient.java @@ -51,6 +51,7 @@ import springfox.documentation.annotations.ApiIgnore; import java.util.ArrayList; import java.util.List; +import java.util.Map; import java.util.stream.Collectors; /** @@ -109,7 +110,7 @@ public class DistributionSignforClient implements IDistributionSignforClient { * @return */ @Override - public Boolean clerkCheckPushData(Long id) { + public Map clerkCheckPushData(Long id) { return distributionSignforService.clerkCheckPushData(id); diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/receiver/ClerkCheckPushDataQueueHandler.java b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/receiver/ClerkCheckPushDataQueueHandler.java index e8bc11e97..94ca9f12a 100644 --- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/receiver/ClerkCheckPushDataQueueHandler.java +++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/receiver/ClerkCheckPushDataQueueHandler.java @@ -64,8 +64,8 @@ public class ClerkCheckPushDataQueueHandler { log.info(">>>>>>>>>>>>> clerkCheckPushDataHandler 签收ID为空"); return; } - Boolean b = distributionSignforService.clerkCheckPushData(t); - log.info(">>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>> 推送老系统签收队列 成功状态： {}",b); + Map map1= distributionSignforService.clerkCheckPushData(t); + log.info(">>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>> 推送老系统签收队列 成功状态： {}",map1); } catch (Exception e) { log.error(">>>>> 推送老系统签收信息报错", e); } diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/IDistributionSignforService.java b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/IDistributionSignforService.java index bfafa9103..fbb265899 100644 --- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/IDistributionSignforService.java +++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/IDistributionSignforService.java @@ -339,7 +339,7 @@ public interface IDistributionSignforService extends BaseService clerkCheckPushData(Long id); /** * 导出签收详情列表 diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionSignforServiceImpl.java b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionSignforServiceImpl.java index 04a39fd2f..519785df1 100644 --- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionSignforServiceImpl.java +++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionSignforServiceImpl.java @@ -1727,7 +1727,7 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl map = oldSystemDataPushClient.pushOldSystemSignInfo(delivery); } catch (Exception e) { log.error(">>>>> 推送老系统签收信息报错", e); } @@ -6445,13 +6445,15 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl clerkCheckPushData(Long id) { + Map resultMap = new HashMap<>(); try { log.info(">>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>> 推送老系统签收队列"); //得到审核的任务ＩＤ if (ObjectUtil.isEmpty(id)) { log.info(">>>>>>>>>>>>> clerkCheckPushDataHandler 签收ID为空"); - return false; + resultMap.put("result",false); + return resultMap; } //得到签收对象 @@ -6461,20 +6463,23 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl>>>>>>>>>>> clerkCheckPushDataHandler distributionSignforEntity {}", distributionSignforEntity); - return false; + resultMap.put("result",false); + return resultMap; } //　得到配送计划 DistributionDeliveryListEntity distributionDeliveryListEntity = distributionDeliveryListMapper.selectById(distributionSignforEntity.getDeliveryId()); if (ObjectUtil.isEmpty(distributionDeliveryListEntity)) { log.info(">>>>>>>>>>> clerkCheckPushDataHandler distributionDeliveryListEntity {}", distributionDeliveryListEntity); - return false; + resultMap.put("result",false); + return resultMap; } // 得到配送客户 DistributionReservationEntity distributionReservationEntity = distributionReservationMapper.selectById(distributionSignforEntity.getReservationId()); if (ObjectUtil.isEmpty(distributionReservationEntity)) { log.info(">>>>>>>>>>>> clerkCheckPushDataHandler distributionReservationEntity {}", distributionReservationEntity); - return false; + resultMap.put("result",false); + return resultMap; } @@ -6582,14 +6587,14 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl>>> clerkCheckPushData SignPushDataDTO :{}", delivery); - Boolean b = oldSystemDataPushClient.pushOldSystemSignInfo(delivery); - return b; + resultMap= oldSystemDataPushClient.pushOldSystemSignInfo(delivery); + return resultMap; } catch (Exception e) { log.error(">>>>> 推送老系统签收信息报错", e); } + return resultMap; - return false; } @Override diff --git a/blade-service/logpm-old-project/src/main/java/com/logpm/oldproject/feign/SignPushClient.java b/blade-service/logpm-old-project/src/main/java/com/logpm/oldproject/feign/SignPushClient.java index 8dccde415..516b52037 100644 --- a/blade-service/logpm-old-project/src/main/java/com/logpm/oldproject/feign/SignPushClient.java +++ b/blade-service/logpm-old-project/src/main/java/com/logpm/oldproject/feign/SignPushClient.java @@ -26,11 +26,11 @@ public class SignPushClient implements IOldSignPushClient { @Autowired private OldSystemProperties oldSystemProperties; @Override - public Boolean pushOldSystemSignInfo(SignPushDataDTO signPushDataDTO) { + public Map pushOldSystemSignInfo(SignPushDataDTO signPushDataDTO) { //todo 这里存在调用老系统的接口 将数据会写给老系统 int timeoutMilliseconds = 60000; - + Map resultMap = new HashMap<>(); Boolean result =false; log.info(">>>> pushOldSystemSignInfo 程序执行 start time: {}",System.currentTimeMillis()); String authCode = oldLogin(signPushDataDTO.getWarehouseId()+""); @@ -41,12 +41,14 @@ public class SignPushClient implements IOldSignPushClient { log.info(">>>> pushOldSystemSignInfo request url:{} data:{}",url,data); String body = HttpRequest.post(url).body(data).header("token", authCode).setConnectionTimeout(timeoutMilliseconds).execute().body(); + log.info(">>>> pushOldSystemSignInfo body :{}",body); if (StringUtil.isNotBlank(body)) { JSONObject res = JSON.parseObject(body); if ("200".equals(res.getString("code"))) { result= true; }else { String msg = res.getString("msg"); + resultMap.put("msg",result); log.info(">>>> pushOldSystemSignInfo response msg:{}",msg); log.info(">>>> pushOldSystemSignInfo 推送配送ID signPushDataDTO ID:{}",signPushDataDTO.getId()); } @@ -55,7 +57,10 @@ public class SignPushClient implements IOldSignPushClient { log.info(">>>> pushOldSystemSignInfo 程序执行 end time : {} >> return result :{} ",System.currentTimeMillis(),result); - return result; + resultMap.put("result",result); + + + return resultMap; } @Override diff --git a/blade-service/logpm-patch/src/main/java/com/logpm/patch/jobhandle/DistributionDatarepair.java b/blade-service/logpm-patch/src/main/java/com/logpm/patch/jobhandle/DistributionDatarepair.java index 171609dce..8176174fc 100644 --- a/blade-service/logpm-patch/src/main/java/com/logpm/patch/jobhandle/DistributionDatarepair.java +++ b/blade-service/logpm-patch/src/main/java/com/logpm/patch/jobhandle/DistributionDatarepair.java @@ -82,20 +82,22 @@ public class DistributionDatarepair { Map> packageMap = deliveryParcelListEntities.stream().collect(Collectors.groupingBy(DistributionParcelListEntity::getWarehouseId)); packageMap.forEach((k, v) -> { String orderPackageCodes = v.stream().map(DistributionParcelListEntity::getOrderPackageCode).collect(Collectors.joining(",")); - stringBuffer.append("仓库:"+k).append("包件下架"+orderPackageCodes);; - Map map = new HashMap<>(); - map.put("orderPackageCode",orderPackageCodes); - map.put("warehouseId",k); + stringBuffer.append("仓库:" + k).append("包件下架" + orderPackageCodes); + ; + Map map = new HashMap<>(); + map.put("orderPackageCode", orderPackageCodes); + map.put("warehouseId", k); warehouseUpdownTypeClient.downDeliveryPackage(map); }); } - log.info("执行包件下架操作>>>>>>>>>>>>>"+stringBuffer.toString()); + log.info("执行包件下架操作>>>>>>>>>>>>>" + stringBuffer.toString()); return ReturnT.SUCCESS; } /** * 对已签收包件进行解托 + * * @return */ @XxlJob("downTrayOldPackage") @@ -108,144 +110,150 @@ public class DistributionDatarepair { Map> packageMap = deliveryParcelListEntities.stream().collect(Collectors.groupingBy(DistributionParcelListEntity::getWarehouseId)); packageMap.forEach((k, v) -> { String orderPackageCodes = v.stream().map(DistributionParcelListEntity::getOrderPackageCode).collect(Collectors.joining(",")); - stringBuffer.append("仓库:"+k).append("包件解托"+orderPackageCodes);; - warehouseUpdownTypeClient.downPackageOrDelTray(orderPackageCodes, k,"签收下架解托"); + stringBuffer.append("仓库:" + k).append("包件解托" + orderPackageCodes); + ; + warehouseUpdownTypeClient.downPackageOrDelTray(orderPackageCodes, k, "签收下架解托"); }); } - log.info("执行包件下架操作>>>>>>>>>>>>>"+stringBuffer.toString()); + log.info("执行包件下架操作>>>>>>>>>>>>>" + stringBuffer.toString()); return ReturnT.SUCCESS; } /** * 维护配送状态 + * * @return */ @XxlJob("maintenanceDeliveryStatus") public ReturnT maintenanceDeliveryStatus(String params) { //维护配送的状态 String method = "######################DistributionDatarepair.maintenanceDeliveryStatus"; - log.info(method+"维护配送订单id:{}",params); + log.info(method + "维护配送订单id:{}", params); deliveryListClient.maintenanceDeliveryInfo(params); - log.info(method+"维护配送订单结束"); + log.info(method + "维护配送订单结束"); return ReturnT.SUCCESS; } /** * 维护预约单信息 + * * @return */ @XxlJob("maintenanceReservationInfo") public ReturnT maintenanceReservationInfo(String params) { //维护配送的状态 String method = "######################DistributionDatarepair.maintenanceDeliveryStatus"; - log.info(method+"维护配送订单id:{}",params); + log.info(method + "维护配送订单id:{}", params); distributionReservationClient.maintenanceReservationInfo(params); - log.info(method+"维护配送订单结束"); + log.info(method + "维护配送订单结束"); return ReturnT.SUCCESS; } /** * 维护指定取消预约信息 + * * @return */ @XxlJob("maintenanceCancelReservation") public ReturnT maintenanceCancelReservation(String params) { //维护配送的状态 String method = "######################DistributionDatarepair.maintenanceDeliveryStatus"; - log.info(method+"维护配送订单id:{}",params); + log.info(method + "维护配送订单id:{}", params); distributionReservationClient.maintenanceCancelReservation(params); - log.info(method+"维护配送订单结束"); + log.info(method + "维护配送订单结束"); return ReturnT.SUCCESS; } - /** * 维护指定取消预约信息 + * * @return */ @XxlJob("maintenanceDeliveryInfo") public ReturnT maintenanceDeliveryInfo(String params) { //维护配送的状态 String method = "######################DistributionDatarepair.maintenanceDeliveryStatus"; - log.info(method+"维护配送订单id:{}",params); + log.info(method + "维护配送订单id:{}", params); deliveryListClient.maintenanceDeliveryInfoByWarehouseId(params); - log.info(method+"维护配送订单结束"); + log.info(method + "维护配送订单结束"); return ReturnT.SUCCESS; } - - /** * 推送老系统系统 + * * @return */ @XxlJob("pushNotification") public ReturnT pushNotification(String params) { // 得到当前仓库所有的签收任务 Integer parmeId = null; - if(StringUtil.isNotBlank(params)){ + if (StringUtil.isNotBlank(params)) { parmeId = Integer.parseInt(params); } List allSignfor = warehouseMappingDataMapper.findAllSignfor(parmeId); for (JSONObject entries : allSignfor) { Long id = entries.getLong("singnforId"); - Boolean b = distributionSignforClient.clerkCheckPushData(id); - if(b!=null&&b){ + Map map = distributionSignforClient.clerkCheckPushData(id); + Boolean b = (Boolean) map.get("b"); + if (b != null && b) { warehouseMappingDataMapper.updateClearSignforStatus(id, entries.getLong("warehouseId"), 1); - log.info(">>> 推送成功 {}",id); - }else{ - log.error(">>> 推送失败 id="+id); + log.info(">>> 推送成功 {}", id); + } else { + log.error(">>> 推送失败 id=" + id); } } return ReturnT.SUCCESS; } - /** * 推送单个 老系统系统 + * * @return */ @XxlJob("pushSingleNotification") public ReturnT pushSingleNotification(String params) { - Boolean b = distributionSignforClient.clerkCheckPushData(Long.parseLong(params)); - if(b!=null&&b){ - warehouseMappingDataMapper.updateClearSignforStatusBysignforId(Long.parseLong(params), 1); - log.info(">>> 推送成功 {}",Long.parseLong(params)); - }else{ - log.error(">>> 推送失败 id="+Long.parseLong(params)); - } + Map map = distributionSignforClient.clerkCheckPushData(Long.parseLong(params)); + Boolean b = (Boolean) map.get("b"); + if (b != null && b) { + warehouseMappingDataMapper.updateClearSignforStatusBysignforId(Long.parseLong(params), 1); + log.info(">>> 推送成功 {}", Long.parseLong(params)); + } else { + log.error(">>> 推送失败 id=" + Long.parseLong(params)); + } return ReturnT.SUCCESS; } /** * 推送自提签收老系统系统 + * * @return */ @XxlJob("pushBillNotification") public ReturnT pushBillNotification(String params) { // 得到当前仓库所有的签收任务 Long parmeId = null; - if(StringUtil.isNotBlank(params)){ + if (StringUtil.isNotBlank(params)) { parmeId = Long.parseLong(params); } List allSignfor = warehouseMappingDataMapper.findAllBillSign(parmeId); for (JSONObject entries : allSignfor) { try { Long id = entries.getLong("billId"); - Boolean b =distrilbutionBillLadingClient.clerkBillCheckPushData(id); - if(b!=null&&b){ + Boolean b = distrilbutionBillLadingClient.clerkBillCheckPushData(id); + if (b != null && b) { warehouseMappingDataMapper.updateClearBillSignforStatus(entries.getLong("id"), entries.getLong("warehouseId"), 1); - log.info(">>> pushBillNotification 成功 id={}",id); - }else{ - log.error(">>> pushBillNotification 失败 id="+id); + log.info(">>> pushBillNotification 成功 id={}", id); + } else { + log.error(">>> pushBillNotification 失败 id=" + id); } - Thread.sleep(1000*60); + Thread.sleep(1000 * 60); } catch (InterruptedException e) { throw new RuntimeException(e); } finally { @@ -257,22 +265,17 @@ public class DistributionDatarepair { } - /** * 推送自提签收信息至工厂 + * * @return */ @XxlJob("sendFactorySignforInfo") public ReturnT sendFactorySignforInfo(String params) { // 得到当前仓库所有的签收任务 - Boolean b =distrilbutionBillLadingClient.sendFactorySignforInfo(params); + Boolean b = distrilbutionBillLadingClient.sendFactorySignforInfo(params); return ReturnT.SUCCESS; } - - - - - } From 7e9a85dd0ed3a7ca7b741ef55df023d6841904c2 Mon Sep 17 00:00:00 2001 From: PigBaoBei <2739175034@qq.com> Date: Wed, 14 Aug 2024 11:33:15 +0800 Subject: [PATCH 16/32] =?UTF-8?q?=E6=8E=A8=E9=80=81BUG=E4=BF=AE=E5=A4=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../feign/IDistributionSignforClient.java | 2 +- .../feign/DistributionSignforClient.java | 4 +- .../service/IDistributionSignforService.java | 2 +- .../impl/DistributionSignforServiceImpl.java | 91 +++++++++---------- .../DistrilbutionBillLadingServiceImpl.java | 1 - .../oldproject/feign/SignPushClient.java | 4 +- .../jobhandle/DistributionDatarepair.java | 6 ++ .../mapper/WarehouseMappingDataMapper.java | 7 ++ .../mapper/WarehouseMappingDataMapper.xml | 5 + 9 files changed, 67 insertions(+), 55 deletions(-) diff --git a/blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/feign/IDistributionSignforClient.java b/blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/feign/IDistributionSignforClient.java index be055727d..739add728 100644 --- a/blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/feign/IDistributionSignforClient.java +++ b/blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/feign/IDistributionSignforClient.java @@ -54,7 +54,7 @@ public interface IDistributionSignforClient { @GetMapping(TOP+"push0ldSystemSignInfo") - void push0ldSystemSignInfo(@RequestParam("current") Long signingId); + Map push0ldSystemSignInfo(@RequestParam("current") Long signingId); /** diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/feign/DistributionSignforClient.java b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/feign/DistributionSignforClient.java index a347285fa..24e73250b 100644 --- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/feign/DistributionSignforClient.java +++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/feign/DistributionSignforClient.java @@ -99,8 +99,8 @@ public class DistributionSignforClient implements IDistributionSignforClient { * @param signingId */ @Override - public void push0ldSystemSignInfo(Long signingId) { - distributionSignforService.push0ldSystemSignInfo(signingId); + public Map push0ldSystemSignInfo(Long signingId) { + return distributionSignforService.push0ldSystemSignInfo(signingId); } diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/IDistributionSignforService.java b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/IDistributionSignforService.java index fbb265899..b706f41b9 100644 --- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/IDistributionSignforService.java +++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/IDistributionSignforService.java @@ -335,7 +335,7 @@ public interface IDistributionSignforService extends BaseService push0ldSystemSignInfo(Long signingId); SignforPageCountVO selectDistributionSignforPageCount( DistributionSignforVO distributionSignfor); diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionSignforServiceImpl.java b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionSignforServiceImpl.java index 519785df1..e9feb3411 100644 --- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionSignforServiceImpl.java +++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionSignforServiceImpl.java @@ -910,13 +910,13 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl().lambda() - .eq(DistributionLoadscanEntity::getReservationId, signforEntity.getReservationId()) - .ne(DistributionLoadscanEntity::getScanStatus, LoadingStatusConstant.quxiao.getValue())) + .eq(DistributionLoadscanEntity::getReservationId, signforEntity.getReservationId()) + .ne(DistributionLoadscanEntity::getScanStatus, LoadingStatusConstant.quxiao.getValue())) .intValue(); Integer nad = distributionLoadscaninvnMapper.selectCount(new QueryWrapper().lambda() - .eq(DistributionLoadscaninvnEntity::getReservationId, signforEntity.getReservationId()) - .ne(DistributionLoadscaninvnEntity::getScanStatus, LoadingStatusConstant.quxiao.getValue())) + .eq(DistributionLoadscaninvnEntity::getReservationId, signforEntity.getReservationId()) + .ne(DistributionLoadscaninvnEntity::getScanStatus, LoadingStatusConstant.quxiao.getValue())) .intValue(); signforEntity.setLoadedNumber(lad); signforEntity.setLoadedinNumber(nad); @@ -1592,13 +1592,13 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl push0ldSystemSignInfo(Long signingId) { try { log.info(">>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>> 推送老系统签收队列"); //得到审核的任务ＩＤ if (ObjectUtil.isEmpty(signingId)) { log.info(">>>>>>>>>>>>> clerkCheckPushDataHandler 签收ID为空"); - return; + return null; } //得到签收对象 @@ -1608,20 +1608,20 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl>>>>>>>>>>> clerkCheckPushDataHandler distributionSignforEntity {}", distributionSignforEntity); - return; + return null; } //　得到配送计划 DistributionDeliveryListEntity distributionDeliveryListEntity = distributionDeliveryListMapper.selectById(distributionSignforEntity.getDeliveryId()); if (ObjectUtil.isEmpty(distributionDeliveryListEntity)) { log.info(">>>>>>>>>>> clerkCheckPushDataHandler distributionDeliveryListEntity {}", distributionDeliveryListEntity); - return; + return null; } // 得到配送客户 DistributionReservationEntity distributionReservationEntity = distributionReservationMapper.selectById(distributionSignforEntity.getReservationId()); if (ObjectUtil.isEmpty(distributionReservationEntity)) { log.info(">>>>>>>>>>>> clerkCheckPushDataHandler distributionReservationEntity {}", distributionReservationEntity); - return; + return null; } @@ -1727,12 +1727,13 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl map = oldSystemDataPushClient.pushOldSystemSignInfo(delivery); + Map map = oldSystemDataPushClient.pushOldSystemSignInfo(delivery); + return map; } catch (Exception e) { log.error(">>>>> 推送老系统签收信息报错", e); } - + return null; } @@ -2466,7 +2467,7 @@ public class DistributionSignforServiceImpl extends BaseServiceImplquery().lambda() .eq(DistributionSignforEntity::getReservationId, distrilbutionloadingscanDTO.getReservationId()) ); @@ -2809,7 +2810,7 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl>>>> 签收异常报错", e); - throw new CustomerException("签收异常报错"+e.getMessage()); + throw new CustomerException("签收异常报错" + e.getMessage()); } } @@ -2981,7 +2982,7 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl>>> 签收推送报错", e); - // } + // try { + // sendMessage(orderPackageCode, distributionReservationEntity.getReservationCode(), + // deliveryListEntity.getTrainNumber(), deliveryListEntity.getVehicleName(), deliveryListEntity.getDriverName(), + // AuthUtil.getUserName(), myCurrentWarehouse.getId(), AuthUtil.getTenantId()); + // } catch (Exception e) { + //// throw new RuntimeException(e); + // log.error(">>>> 签收推送报错", e); + // } } else { //一个客户下出现重复包条码 @@ -3271,7 +3272,7 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl packageLockIds = new ArrayList<>(); @@ -3390,7 +3391,7 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl>>>>>>>>>>>>>>reservationId:{},deliveryId:{},orderPackageCode:{}", distributionLoadscanEntity.getReservationId(), distributionLoadscanEntity.getDeliveryId(), distributionLoadscanEntity.getOrderPackageCode()); //进行签收数量的修改 Integer i = distributionDeliveryListMapper.updateloadingTimeById(distrilbutionloadingscanDTO.getDeliveryId()); @@ -3422,7 +3423,7 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl>>>>包件已签收:{}",parcelListEntity.getOrderPackageCode()); + if (OrderPackageStatusConstant.yiqianshou.getValue().equals(parcelListEntity.getOrderPackageStatus())) { + log.info("司机一键签收 >>>>>包件已签收:{}", parcelListEntity.getOrderPackageCode()); continue; } //查询是否进行装车 @@ -6097,8 +6098,8 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl clerkCheckPushData(Long id) { - Map resultMap = new HashMap<>(); + public Map clerkCheckPushData(Long id) { + Map resultMap = new HashMap<>(); try { log.info(">>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>> 推送老系统签收队列"); //得到审核的任务ＩＤ if (ObjectUtil.isEmpty(id)) { log.info(">>>>>>>>>>>>> clerkCheckPushDataHandler 签收ID为空"); - resultMap.put("result",false); + resultMap.put("result", false); return resultMap; } @@ -6463,14 +6464,14 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl>>>>>>>>>>> clerkCheckPushDataHandler distributionSignforEntity {}", distributionSignforEntity); - resultMap.put("result",false); + resultMap.put("result", false); return resultMap; } //　得到配送计划 DistributionDeliveryListEntity distributionDeliveryListEntity = distributionDeliveryListMapper.selectById(distributionSignforEntity.getDeliveryId()); if (ObjectUtil.isEmpty(distributionDeliveryListEntity)) { log.info(">>>>>>>>>>> clerkCheckPushDataHandler distributionDeliveryListEntity {}", distributionDeliveryListEntity); - resultMap.put("result",false); + resultMap.put("result", false); return resultMap; } @@ -6478,7 +6479,7 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl>>>>>>>>>>> clerkCheckPushDataHandler distributionReservationEntity {}", distributionReservationEntity); - resultMap.put("result",false); + resultMap.put("result", false); return resultMap; } @@ -6587,7 +6588,7 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl>>> clerkCheckPushData SignPushDataDTO :{}", delivery); - resultMap= oldSystemDataPushClient.pushOldSystemSignInfo(delivery); + resultMap = oldSystemDataPushClient.pushOldSystemSignInfo(delivery); return resultMap; } catch (Exception e) { log.error(">>>>> 推送老系统签收信息报错", e); @@ -6752,7 +6753,7 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl list = new ArrayList<>(); if (!addvaluePackageVOS.isEmpty()) { - addvaluePackageVOS.forEach(a->{ + addvaluePackageVOS.forEach(a -> { DistributionAddvaluePackageDTO dto = Func.copy(a, DistributionAddvaluePackageDTO.class); list.add(dto); }); @@ -6858,11 +6859,11 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl ladingScanEntities = distributionBillLadingScanService.list(Wrappers.query().lambda() .eq(DistributionBillLadingScanEntity::getBillLadingId, Long.parseLong(s)) - .eq(DistributionBillLadingScanEntity::getMaterialType, "2") ); if (ladingScanEntities.isEmpty()){ return R.fail("无签收数据!!"); diff --git a/blade-service/logpm-old-project/src/main/java/com/logpm/oldproject/feign/SignPushClient.java b/blade-service/logpm-old-project/src/main/java/com/logpm/oldproject/feign/SignPushClient.java index 516b52037..8569711dd 100644 --- a/blade-service/logpm-old-project/src/main/java/com/logpm/oldproject/feign/SignPushClient.java +++ b/blade-service/logpm-old-project/src/main/java/com/logpm/oldproject/feign/SignPushClient.java @@ -48,15 +48,13 @@ public class SignPushClient implements IOldSignPushClient { result= true; }else { String msg = res.getString("msg"); - resultMap.put("msg",result); + resultMap.put("msg",msg); log.info(">>>> pushOldSystemSignInfo response msg:{}",msg); log.info(">>>> pushOldSystemSignInfo 推送配送ID signPushDataDTO ID:{}",signPushDataDTO.getId()); } } log.info(">>>> pushOldSystemSignInfo response url:{} body:{}",url,body); - log.info(">>>> pushOldSystemSignInfo 程序执行 end time : {} >> return result :{} ",System.currentTimeMillis(),result); - resultMap.put("result",result); diff --git a/blade-service/logpm-patch/src/main/java/com/logpm/patch/jobhandle/DistributionDatarepair.java b/blade-service/logpm-patch/src/main/java/com/logpm/patch/jobhandle/DistributionDatarepair.java index 8176174fc..d3e5904f4 100644 --- a/blade-service/logpm-patch/src/main/java/com/logpm/patch/jobhandle/DistributionDatarepair.java +++ b/blade-service/logpm-patch/src/main/java/com/logpm/patch/jobhandle/DistributionDatarepair.java @@ -205,6 +205,9 @@ public class DistributionDatarepair { warehouseMappingDataMapper.updateClearSignforStatus(id, entries.getLong("warehouseId"), 1); log.info(">>> 推送成功 {}", id); } else { + String remarks = (String) map.get("msg"); + //进行错误记录 + warehouseMappingDataMapper.updateClearSignforRemarks(id, remarks); log.error(">>> 推送失败 id=" + id); } } @@ -220,11 +223,14 @@ public class DistributionDatarepair { @XxlJob("pushSingleNotification") public ReturnT pushSingleNotification(String params) { Map map = distributionSignforClient.clerkCheckPushData(Long.parseLong(params)); + Long id = Long.parseLong(params); Boolean b = (Boolean) map.get("b"); if (b != null && b) { warehouseMappingDataMapper.updateClearSignforStatusBysignforId(Long.parseLong(params), 1); log.info(">>> 推送成功 {}", Long.parseLong(params)); } else { + String remarks = (String) map.get("msg"); + warehouseMappingDataMapper.updateClearSignforRemarks(id, remarks); log.error(">>> 推送失败 id=" + Long.parseLong(params)); } return ReturnT.SUCCESS; diff --git a/blade-service/logpm-patch/src/main/java/com/logpm/patch/mapper/WarehouseMappingDataMapper.java b/blade-service/logpm-patch/src/main/java/com/logpm/patch/mapper/WarehouseMappingDataMapper.java index 877736ec5..b5f7c3b6c 100644 --- a/blade-service/logpm-patch/src/main/java/com/logpm/patch/mapper/WarehouseMappingDataMapper.java +++ b/blade-service/logpm-patch/src/main/java/com/logpm/patch/mapper/WarehouseMappingDataMapper.java @@ -123,5 +123,12 @@ public interface WarehouseMappingDataMapper { List findStockAllocationInfo(); void updateClearSignforStatusBysignforId(@Param("singnforId")Long singnforId, @Param("dealStatus") Integer dealStatus); + + /** + * 修改备注 + * @param id + * @param msg + */ + void updateClearSignforRemarks(@Param("singnforId")Long id,@Param("remarks") String remarks); } diff --git a/blade-service/logpm-patch/src/main/java/com/logpm/patch/mapper/WarehouseMappingDataMapper.xml b/blade-service/logpm-patch/src/main/java/com/logpm/patch/mapper/WarehouseMappingDataMapper.xml index 04810b882..bc23cf9d8 100644 --- a/blade-service/logpm-patch/src/main/java/com/logpm/patch/mapper/WarehouseMappingDataMapper.xml +++ b/blade-service/logpm-patch/src/main/java/com/logpm/patch/mapper/WarehouseMappingDataMapper.xml @@ -354,6 +354,11 @@ set deal_status = #{dealStatus} where singnfor_id = #{singnforId} + + update clear_singnfor_status_record + set deal_status = #{dealStatus} + where remarks = #{remarks} + From 9837465dd0e7151214a51977b4ded6b3418ed578 Mon Sep 17 00:00:00 2001 From: PigBaoBei <2739175034@qq.com> Date: Wed, 14 Aug 2024 12:30:45 +0800 Subject: [PATCH 23/32] =?UTF-8?q?BUG=E4=BF=AE=E5=A4=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../java/com/logpm/patch/jobhandle/DistributionDatarepair.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/blade-service/logpm-patch/src/main/java/com/logpm/patch/jobhandle/DistributionDatarepair.java b/blade-service/logpm-patch/src/main/java/com/logpm/patch/jobhandle/DistributionDatarepair.java index 0d638b9bb..0fa17f409 100644 --- a/blade-service/logpm-patch/src/main/java/com/logpm/patch/jobhandle/DistributionDatarepair.java +++ b/blade-service/logpm-patch/src/main/java/com/logpm/patch/jobhandle/DistributionDatarepair.java @@ -200,6 +200,7 @@ public class DistributionDatarepair { Long id = entries.getLong("singnforId"); Map map = distributionSignforClient.clerkCheckPushData(id); + log.info(">>> 推送失败 map :{}",map); Boolean b = (Boolean) map.get("result"); if (b != null && b) { warehouseMappingDataMapper.updateClearSignforStatus(id, entries.getLong("warehouseId"), 1); @@ -225,6 +226,7 @@ public class DistributionDatarepair { Map map = distributionSignforClient.clerkCheckPushData(Long.parseLong(params)); Long id = Long.parseLong(params); Boolean b = (Boolean) map.get("result"); + log.info(">>> 推送失败 map :{}",map); if (b != null && b) { warehouseMappingDataMapper.updateClearSignforStatusBysignforId(Long.parseLong(params), 1); log.info(">>> 推送成功 {}", Long.parseLong(params)); From dd701dc873e71d21967a4b9b54aebfe0da7dc2fd Mon Sep 17 00:00:00 2001 From: "pref_mail@163.com" Date: Wed, 14 Aug 2024 13:56:36 +0800 Subject: [PATCH 24/32] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E6=95=B0=E6=8D=AE?= =?UTF-8?q?=E5=87=86=E5=A4=87=E9=94=99=E8=AF=AF=E7=9A=84=E4=BF=A1=E6=81=AF?= =?UTF-8?q?=E5=A4=84=E7=90=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/impl/DistributionSignforServiceImpl.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionSignforServiceImpl.java b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionSignforServiceImpl.java index e9feb3411..4b1dcc388 100644 --- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionSignforServiceImpl.java +++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionSignforServiceImpl.java @@ -6591,6 +6591,8 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl>>>> 推送老系统签收信息报错", e); } From 91636809680772d2e5921b4c79ecf143d7e1852b Mon Sep 17 00:00:00 2001 From: "pref_mail@163.com" Date: Wed, 14 Aug 2024 13:57:57 +0800 Subject: [PATCH 25/32] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E6=95=B0=E6=8D=AE?= =?UTF-8?q?=E5=87=86=E5=A4=87=E9=94=99=E8=AF=AF=E7=9A=84=E4=BF=A1=E6=81=AF?= =?UTF-8?q?=E5=A4=84=E7=90=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/logpm/patch/jobhandle/DistributionDatarepair.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/blade-service/logpm-patch/src/main/java/com/logpm/patch/jobhandle/DistributionDatarepair.java b/blade-service/logpm-patch/src/main/java/com/logpm/patch/jobhandle/DistributionDatarepair.java index 0fa17f409..7ec122996 100644 --- a/blade-service/logpm-patch/src/main/java/com/logpm/patch/jobhandle/DistributionDatarepair.java +++ b/blade-service/logpm-patch/src/main/java/com/logpm/patch/jobhandle/DistributionDatarepair.java @@ -200,7 +200,7 @@ public class DistributionDatarepair { Long id = entries.getLong("singnforId"); Map map = distributionSignforClient.clerkCheckPushData(id); - log.info(">>> 推送失败 map :{}",map); + log.info(">>> 推送反馈信息 map :{}",map); Boolean b = (Boolean) map.get("result"); if (b != null && b) { warehouseMappingDataMapper.updateClearSignforStatus(id, entries.getLong("warehouseId"), 1); @@ -226,7 +226,7 @@ public class DistributionDatarepair { Map map = distributionSignforClient.clerkCheckPushData(Long.parseLong(params)); Long id = Long.parseLong(params); Boolean b = (Boolean) map.get("result"); - log.info(">>> 推送失败 map :{}",map); + log.info(">>> 推送反馈信息 map :{}",map); if (b != null && b) { warehouseMappingDataMapper.updateClearSignforStatusBysignforId(Long.parseLong(params), 1); log.info(">>> 推送成功 {}", Long.parseLong(params)); From a0ea67194cf05b8a488164cd144cc3f715773dce Mon Sep 17 00:00:00 2001 From: "pref_mail@163.com" Date: Wed, 14 Aug 2024 14:16:05 +0800 Subject: [PATCH 26/32] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E6=95=B0=E6=8D=AE?= =?UTF-8?q?=E5=87=86=E5=A4=87=E9=94=99=E8=AF=AF=E7=9A=84=E4=BF=A1=E6=81=AF?= =?UTF-8?q?=E5=A4=84=E7=90=862?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/impl/DistributionSignforServiceImpl.java | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionSignforServiceImpl.java b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionSignforServiceImpl.java index 4b1dcc388..a40ca8acb 100644 --- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionSignforServiceImpl.java +++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionSignforServiceImpl.java @@ -6464,7 +6464,9 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl>>>>>>>>>>> clerkCheckPushDataHandler distributionSignforEntity {}", distributionSignforEntity); + resultMap.put("result", false); + resultMap.put("msg", "没有签收对象 distributionSignforEntity"); return resultMap; } //　得到配送计划 @@ -6472,6 +6474,8 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl>>>>>>>>>> clerkCheckPushDataHandler distributionDeliveryListEntity {}", distributionDeliveryListEntity); resultMap.put("result", false); + resultMap.put("msg", "没有配送计划 distributionDeliveryListEntity"); + return resultMap; } @@ -6480,6 +6484,8 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl>>>>>>>>>>> clerkCheckPushDataHandler distributionReservationEntity {}", distributionReservationEntity); resultMap.put("result", false); + resultMap.put("msg", "没有配送客户 distributionReservationEntity"); + return resultMap; } From 6c6f9a87948db32d67b8d147ceced0605837e770 Mon Sep 17 00:00:00 2001 From: "pref_mail@163.com" Date: Wed, 14 Aug 2024 15:00:18 +0800 Subject: [PATCH 27/32] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E4=BB=93=E5=BA=93?= =?UTF-8?q?=E6=A8=A1=E5=9D=97=E7=9A=84=E5=BC=82=E6=AD=A5=E7=BA=BF=E7=A8=8B?= =?UTF-8?q?=E7=BB=91=E5=AE=9A=E5=BD=93=E5=89=8D=E4=BC=9A=E8=AF=9D=20?= =?UTF-8?q?=E6=97=A0=E6=B3=95=E8=8E=B7=E5=8F=96token=E7=BB=91=E5=AE=9A?= =?UTF-8?q?=E7=A7=9F=E6=88=B7ID=E7=9A=84=E6=83=85=E5=86=B5?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/logpm/warehouse/config/ExecutorConfig.java | 13 ++++++++++++- 1 file changed, 12 insertions(+), 1 deletion(-) diff --git a/blade-service/logpm-warehouse/src/main/java/com/logpm/warehouse/config/ExecutorConfig.java b/blade-service/logpm-warehouse/src/main/java/com/logpm/warehouse/config/ExecutorConfig.java index cb8d0f169..beffac986 100644 --- a/blade-service/logpm-warehouse/src/main/java/com/logpm/warehouse/config/ExecutorConfig.java +++ b/blade-service/logpm-warehouse/src/main/java/com/logpm/warehouse/config/ExecutorConfig.java @@ -1,6 +1,7 @@ package com.logpm.warehouse.config; import com.baomidou.dynamic.datasource.toolkit.DynamicDataSourceContextHolder; +import com.baomidou.mybatisplus.core.toolkit.StringUtils; import lombok.extern.slf4j.Slf4j; import org.slf4j.MDC; import org.springblade.core.secure.utils.AuthUtil; @@ -66,7 +67,17 @@ public class ExecutorConfig { RequestContextHolder.setRequestAttributes(context); // 未当前的异步线程绑定租户ID 和切换数据源 log.info(">>>> 异步线程创建，绑定租户数据源 {}",tenantId); - DynamicDataSourceContextHolder.push(tenantId); + log.info(">>>> 异步线程创建，绑定租户数据源 {}",tenantId); + if(StringUtils.isBlank(tenantId)){ + //这里为null 存在问题 + log.info(">>>> 异步线程创建，没有用户信息 {}",AuthUtil.getUserId()); + log.info(">>>> 异步线程创建，没有用户信息 {}",AuthUtil.getUser()); + log.info(">>>> 异步线程创建，没有用户信息 {}",context); + DynamicDataSourceContextHolder.push("627683"); + }else{ + // 未当前的异步线程绑定租户ID 和切换数据源 + DynamicDataSourceContextHolder.push(tenantId); + } runnable.run(); } finally { RequestContextHolder.resetRequestAttributes(); From 0f162719ab5bea6eb6d72f7e1b46f4bdc11ab8e9 Mon Sep 17 00:00:00 2001 From: PigBaoBei <2739175034@qq.com> Date: Wed, 14 Aug 2024 15:47:10 +0800 Subject: [PATCH 28/32] =?UTF-8?q?=E8=BD=A6=E8=BE=86=E5=A2=9E=E5=8A=A0?= =?UTF-8?q?=E8=AF=A6=E6=83=85=E6=8E=A5=E5=8F=A3=E3=80=81=E4=BF=AE=E5=A4=8D?= =?UTF-8?q?=E8=87=AA=E6=8F=90=E5=AE=9E=E6=8F=90=E4=BB=B6=E6=95=B0=E6=95=B0?= =?UTF-8?q?=E9=87=8F?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../entity/BasicdataVehicleEntity.java | 2 +- .../BasicdataVehicleController.java | 6 +- .../mapper/BasicdataVehicleMapper.java | 7 ++ .../mapper/BasicdataVehicleMapper.xml | 79 +++++++++++++++++++ .../service/IBasicdataVehicleService.java | 7 ++ .../impl/BasicdataVehicleServiceImpl.java | 5 ++ .../mapper/DistrilbutionBillLadingMapper.xml | 2 +- 7 files changed, 104 insertions(+), 4 deletions(-) diff --git a/blade-service-api/logpm-basicdata-api/src/main/java/com/logpm/basicdata/entity/BasicdataVehicleEntity.java b/blade-service-api/logpm-basicdata-api/src/main/java/com/logpm/basicdata/entity/BasicdataVehicleEntity.java index a86e18ded..1467a7bc3 100644 --- a/blade-service-api/logpm-basicdata-api/src/main/java/com/logpm/basicdata/entity/BasicdataVehicleEntity.java +++ b/blade-service-api/logpm-basicdata-api/src/main/java/com/logpm/basicdata/entity/BasicdataVehicleEntity.java @@ -251,7 +251,7 @@ public class BasicdataVehicleEntity extends TenantEntity { * 车辆年审有效期 */ @ApiModelProperty(value = "车辆年审有效期") - private Integer reviewValidity; + private String reviewValidity; /** * 车辆保险开始时间 */ diff --git a/blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/controller/BasicdataVehicleController.java b/blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/controller/BasicdataVehicleController.java index aabd86583..163b9b6a4 100644 --- a/blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/controller/BasicdataVehicleController.java +++ b/blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/controller/BasicdataVehicleController.java @@ -83,8 +83,10 @@ public class BasicdataVehicleController extends BladeController { @GetMapping("/detail") @ApiOperationSupport(order = 1) @ApiOperation(value = "详情", notes = "传入basicdataVehicle") - public R detail(BasicdataVehicleDTO basicdataVehicle) { - BasicdataVehicleEntity detail = basicdataVehicleService.getOne(Condition.getQueryWrapper(basicdataVehicle)); + public R detail(@Param("id") Long id) { + +// BasicdataVehicleEntity detail = basicdataVehicleService.getOne(Condition.getQueryWrapper(basicdataVehicle)); + BasicdataVehicleEntity detail = basicdataVehicleService.getVehicleDetail(id); //查询历史照片 BasicdataVehicleVO basicdataVehicleVO = new BasicdataVehicleVO(); BeanUtils.copyProperties(detail,basicdataVehicleVO); diff --git a/blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/mapper/BasicdataVehicleMapper.java b/blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/mapper/BasicdataVehicleMapper.java index e4a68f1fc..90be4aadc 100644 --- a/blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/mapper/BasicdataVehicleMapper.java +++ b/blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/mapper/BasicdataVehicleMapper.java @@ -62,4 +62,11 @@ public interface BasicdataVehicleMapper extends BaseMapper selectBasicdataDictionary(@Param("vehicleNub") String vehicleNub); List findCarListByName(@Param("carNumber") String carNumber); + + /** + * 查询车辆详情 + * @param id + * @return + */ + BasicdataVehicleEntity getVehicleDetail(@Param("id")Long id); } diff --git a/blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/mapper/BasicdataVehicleMapper.xml b/blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/mapper/BasicdataVehicleMapper.xml index 9cf648ff0..6fc64c167 100644 --- a/blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/mapper/BasicdataVehicleMapper.xml +++ b/blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/mapper/BasicdataVehicleMapper.xml @@ -252,6 +252,85 @@ and vehicle_nub like concat('%',#{carNumber},'%') limit 10 + diff --git a/blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/service/IBasicdataVehicleService.java b/blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/service/IBasicdataVehicleService.java index d84633e31..0d849a8aa 100644 --- a/blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/service/IBasicdataVehicleService.java +++ b/blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/service/IBasicdataVehicleService.java @@ -92,4 +92,11 @@ public interface IBasicdataVehicleService extends BaseService data); + + /** + * 查询车辆详情 + * @param id + * @return + */ + BasicdataVehicleEntity getVehicleDetail(Long id); } diff --git a/blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/service/impl/BasicdataVehicleServiceImpl.java b/blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/service/impl/BasicdataVehicleServiceImpl.java index 2c6837bdd..84fe80763 100644 --- a/blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/service/impl/BasicdataVehicleServiceImpl.java +++ b/blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/service/impl/BasicdataVehicleServiceImpl.java @@ -286,4 +286,9 @@ public class BasicdataVehicleServiceImpl extends BaseServiceImpl Date: Wed, 14 Aug 2024 16:27:10 +0800 Subject: [PATCH 29/32] =?UTF-8?q?feat(all):=20=E4=BF=AE=E6=94=B9=E6=A2=A6?= =?UTF-8?q?=E5=A4=A9=E6=8E=A8=E9=80=81=E8=AF=B7=E6=B1=82=E7=9A=84=E8=B6=85?= =?UTF-8?q?=E6=97=B6=E6=97=B6=E9=97=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../factorydata/mengtian/mq/NodeDataPushListener.java | 11 ++++++----- 1 file changed, 6 insertions(+), 5 deletions(-) diff --git a/blade-service/logpm-factory-data/logpm-factory-data-mengtian/src/main/java/com/logpm/factorydata/mengtian/mq/NodeDataPushListener.java b/blade-service/logpm-factory-data/logpm-factory-data-mengtian/src/main/java/com/logpm/factorydata/mengtian/mq/NodeDataPushListener.java index de950d14f..485ba3af9 100644 --- a/blade-service/logpm-factory-data/logpm-factory-data-mengtian/src/main/java/com/logpm/factorydata/mengtian/mq/NodeDataPushListener.java +++ b/blade-service/logpm-factory-data/logpm-factory-data-mengtian/src/main/java/com/logpm/factorydata/mengtian/mq/NodeDataPushListener.java @@ -328,23 +328,24 @@ public class NodeDataPushListener { HttpRequest post = HttpUtil.createPost(mengTianProperties.getHost() + url); post.header("ClientId", "mt.ht"); post.header("OperationCode", operationCode); - post.timeout(5000); + post.timeout(30000); post.body(body); // 存入日志表 entity.setContent(body); entity.setOperationCode(operationCode); entity.setSendUrl(mengTianProperties.getHost() + url); + String resBody = ""; try { HttpResponse execute = post.execute(); - String resBody = execute.body(); + resBody = execute.body(); log.info("推送工厂结果：{}", resBody); JSONObject entries = JSONUtil.parseObj(resBody); String resultCode = entries.getStr("Result"); entity.setResultContent(resBody); - entity.setSendStatus(StrUtil.isEmpty(resultCode) ? "0" : resultCode); + entity.setSendStatus(StrUtil.isEmpty(resultCode) ? "-1" : resultCode); } catch (Exception e) { - entity.setResultContent(e.getMessage()); - entity.setSendStatus("0"); + entity.setResultContent(resBody); + entity.setSendStatus("-1"); } factoryNodePushService.save(entity); } From 61f9d53dbb5fe4783e319e53945e5dbd21e25c45 Mon Sep 17 00:00:00 2001 From: PigBaoBei <2739175034@qq.com> Date: Wed, 14 Aug 2024 16:53:15 +0800 Subject: [PATCH 30/32] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E6=89=B9=E9=87=8F?= =?UTF-8?q?=E7=AD=BE=E6=94=B6=E6=8B=A6=E6=88=AA?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/impl/DistributionSignforServiceImpl.java | 9 +++++++++ 1 file changed, 9 insertions(+) diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionSignforServiceImpl.java b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionSignforServiceImpl.java index a40ca8acb..c72a9f0bf 100644 --- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionSignforServiceImpl.java +++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionSignforServiceImpl.java @@ -59,6 +59,7 @@ import com.logpm.warehouse.feign.IWarehouseUpdownStockUpAreaClient; import com.logpm.warehouse.feign.IWarehouseUpdownTypeClient; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang.StringUtils; +import org.apache.logging.log4j.util.Strings; import org.jetbrains.annotations.NotNull; import org.springblade.common.constant.DistributionTypeConstant; import org.springblade.common.constant.Inventory.InventoryLoadingStatusConstant; @@ -4938,10 +4939,13 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl packageLockIds = new ArrayList<>(); //查询数据 DistributionSignforEntity distributionSignforEntity = baseMapper.selectOne(new QueryWrapper().lambda() @@ -5449,6 +5457,7 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl Date: Wed, 14 Aug 2024 17:10:35 +0800 Subject: [PATCH 31/32] =?UTF-8?q?=E5=8F=B8=E6=9C=BA=E7=AD=BE=E6=94=B6?= =?UTF-8?q?=E6=97=B6=E9=97=B4=E8=B0=83=E6=95=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../distribution/api/DistributionSignforAppController.java | 2 +- .../service/impl/DistributionSignforServiceImpl.java | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/api/DistributionSignforAppController.java b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/api/DistributionSignforAppController.java index 8616b38e4..1fdcfddeb 100644 --- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/api/DistributionSignforAppController.java +++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/api/DistributionSignforAppController.java @@ -224,7 +224,7 @@ public class DistributionSignforAppController { } /** - * 司机签收管理 确认签收 + * 上传签收图片 */ @PostMapping("/signforack") @ApiOperationSupport(order = 2) diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionSignforServiceImpl.java b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionSignforServiceImpl.java index c72a9f0bf..e5d5697cf 100644 --- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionSignforServiceImpl.java +++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionSignforServiceImpl.java @@ -951,7 +951,7 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl distributionSignPrintList = new ArrayList<>(); @@ -3222,7 +3222,7 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl distributionSignPrintList = new ArrayList<>(); From aa42c434be224b6457eefd09cc94e6f2ff9fb111 Mon Sep 17 00:00:00 2001 From: PigBaoBei <2739175034@qq.com> Date: Wed, 14 Aug 2024 18:20:22 +0800 Subject: [PATCH 32/32] =?UTF-8?q?=E5=A4=87=E8=B4=A7BUG=E4=BF=AE=E5=A4=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../distribution/mapper/DistributionReservationMapper.xml | 1 + .../service/impl/DistributionParcelListServiceImpl.java | 4 +++- 2 files changed, 4 insertions(+), 1 deletion(-) diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionReservationMapper.xml b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionReservationMapper.xml index 68e7b444a..95738205c 100644 --- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionReservationMapper.xml +++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistributionReservationMapper.xml @@ -367,6 +367,7 @@ association_value ) AS t2 ON t.cargo_number = t2.association_value where ldslNew.is_deleted = 0 AND ldslNew.warehouse_id=#{warehouseId} + AND ldslNew.market_name=#{mallName} GROUP BY ldslNew.cargo_number diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionParcelListServiceImpl.java b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionParcelListServiceImpl.java index 1aafa7acc..ef8b8d95d 100644 --- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionParcelListServiceImpl.java +++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionParcelListServiceImpl.java @@ -904,8 +904,9 @@ public class DistributionParcelListServiceImpl extends BaseServiceImpl materialUnit = distributionParcelListEntities.stream().map(DistributionParcelListEntity::getMaterialUnit).distinct().collect(Collectors.toList()); List mallId = distributionParcelListEntities.stream().map(DistributionParcelListEntity::getMarketId).distinct().collect(Collectors.toList()); List materialName = distributionParcelListEntities.stream().map(DistributionParcelListEntity::getMaterialName).distinct().collect(Collectors.toList()); + List brandName = distributionParcelListEntities.stream().map(DistributionParcelListEntity::getBrandName).distinct().collect(Collectors.toList()); List brandId = distributionParcelListEntities.stream().map(DistributionParcelListEntity::getBrandId).distinct().collect(Collectors.toList()); - if (materialId.size() != 1 || materialCode.size() != 1 || materialUnit.size() != 1 || mallId.size() != 1 || materialName.size() != 1 || brandId.size() != 1) { + if (materialId.size() != 1 || materialCode.size() != 1 || materialUnit.size() != 1 || mallId.size() != 1 || materialName.size() != 1 || brandName.size() != 1) { //该批次包件出现多种物料包件 return null; } @@ -941,6 +942,7 @@ public class DistributionParcelListServiceImpl extends BaseServiceImpl