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 13a9c469b..a50ff69ea 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 @@ -222,4 +222,7 @@ public interface IDistributionStockArticleClient { @PostMapping(API_PREFIX + "/findWaybillNoByOrderIds") List findWaybillNoByOrderIds(@RequestBody Set stockArticleIds); + + @PostMapping(API_PREFIX + "/updateEntity") + void updateEntity(@RequestBody DistributionStockArticleEntity stockArticleEntity); } diff --git a/blade-service/logpm-aftersales/src/main/java/com/logpm/aftersales/service/impl/AftersalesAbnormalRecordServiceImpl.java b/blade-service/logpm-aftersales/src/main/java/com/logpm/aftersales/service/impl/AftersalesAbnormalRecordServiceImpl.java index 961db016c..ecb5e7ed3 100644 --- a/blade-service/logpm-aftersales/src/main/java/com/logpm/aftersales/service/impl/AftersalesAbnormalRecordServiceImpl.java +++ b/blade-service/logpm-aftersales/src/main/java/com/logpm/aftersales/service/impl/AftersalesAbnormalRecordServiceImpl.java @@ -160,7 +160,7 @@ public class AftersalesAbnormalRecordServiceImpl extends BaseServiceImpl>>>>>>>> 当前作业对象 {} 未 商家对象",data.getTenantName() ); return ; } @@ -71,9 +71,6 @@ public class BusinessPreOrderDataQueueHandler { if (tenantList.isSuccess()) { List data = tenantList.getData(); data.forEach(tenant -> { - - - if (!ObjectUtil.isEmpty(tenant.getTenantType())) { if (2 == tenant.getTenantType()) { List basicdataClientEntitysTenantId = basicdataClientClient.findBasicdataClientEntitysTenantId(tenant.getTenantId()); @@ -93,7 +90,6 @@ public class BusinessPreOrderDataQueueHandler { if (list != null && !list.isEmpty()) { resoveData(tenant,distributionDeliveryListEntity, basicdataClientEntitysTenantId, list); } - } } } diff --git a/blade-service/logpm-factory-data/logpm-factory-data-olo/src/main/java/com/logpm/factorydata/olo/job/AdvanceJob.java b/blade-service/logpm-factory-data/logpm-factory-data-olo/src/main/java/com/logpm/factorydata/olo/job/AdvanceJob.java new file mode 100644 index 000000000..c6e780d69 --- /dev/null +++ b/blade-service/logpm-factory-data/logpm-factory-data-olo/src/main/java/com/logpm/factorydata/olo/job/AdvanceJob.java @@ -0,0 +1,58 @@ +package com.logpm.factorydata.olo.job; + +import cn.hutool.core.collection.CollUtil; +import cn.hutool.core.date.DateTime; +import cn.hutool.core.date.DateUtil; +import cn.hutool.core.util.StrUtil; +import com.baomidou.mybatisplus.core.toolkit.Wrappers; +import com.logpm.factorydata.olo.entity.DeliveryNoteEntity; +import com.logpm.factorydata.olo.service.DeliveryNoteService; +import com.xxl.job.core.biz.model.ReturnT; +import com.xxl.job.core.handler.annotation.XxlJob; +import lombok.AllArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.springframework.stereotype.Component; + +import java.util.List; + +/** + * 我乐定时生成暂存单 + * + * @author zhaoqiaobo + * @create 2024-04-02 + */ +@AllArgsConstructor +@Component +@Slf4j +public class AdvanceJob { + + private final DeliveryNoteService deliveryNoteService; + + /** + * 定时扫描数据库 + * 背景:我乐每天晚上凌晨1点拉取订单数据,然后存入我乐订单池。 + * 任务:1点半去定时生成暂存单 + * + * @param param + * @return + * @throws Exception + */ + @XxlJob("createAdvance") + public ReturnT createAdvance(String param) throws Exception { + // 指定天数生成暂存单或者系统自动处理 + DateTime time = DateUtil.date(); + if (StrUtil.isNotEmpty(param)) { + time = DateUtil.parseDate(param); + } + // 1 查询出当前拉取的数据 + // 大于等于 time 的开始 小于 time 的结束 + List list = deliveryNoteService.list(Wrappers.lambdaQuery().between(DeliveryNoteEntity::getCreateTime, DateUtil.beginOfDay(time), DateUtil.endOfDay(time))); + // 2 按订单和发货单分组作为一个暂存单 + if (CollUtil.isNotEmpty(list)) { + // 3 生成暂存单 + deliveryNoteService.buildAdvance(list); + } + return ReturnT.SUCCESS; + } + +} diff --git a/blade-service/logpm-factory-data/logpm-factory-data-olo/src/main/java/com/logpm/factorydata/olo/mq/FactoryOrderListener.java b/blade-service/logpm-factory-data/logpm-factory-data-olo/src/main/java/com/logpm/factorydata/olo/mq/FactoryOrderListener.java index 6261c84cd..ccad88250 100644 --- a/blade-service/logpm-factory-data/logpm-factory-data-olo/src/main/java/com/logpm/factorydata/olo/mq/FactoryOrderListener.java +++ b/blade-service/logpm-factory-data/logpm-factory-data-olo/src/main/java/com/logpm/factorydata/olo/mq/FactoryOrderListener.java @@ -153,8 +153,8 @@ public class FactoryOrderListener { } if (CollUtil.isNotEmpty(entities)) { deliveryNoteService.saveBatch(entities); - // 处理暂存单 - deliveryNoteService.buildAdvance(entities); + // 处理暂存单 暂存单由定时任务定时生成 + // deliveryNoteService.buildAdvance(entities); FactoryOrderLogEntity logEntity1 = new FactoryOrderLogEntity(); logEntity1.setSaxStatus(SaxStatusEnums.SUCCESS.getCode()); logEntity1.setId(logId); diff --git a/blade-service/logpm-factory-data/logpm-factory-data-olo/src/main/java/com/logpm/factorydata/olo/mq/NodeDataPushListener.java b/blade-service/logpm-factory-data/logpm-factory-data-olo/src/main/java/com/logpm/factorydata/olo/mq/NodeDataPushListener.java index 00f2ee197..23b1a23a5 100644 --- a/blade-service/logpm-factory-data/logpm-factory-data-olo/src/main/java/com/logpm/factorydata/olo/mq/NodeDataPushListener.java +++ b/blade-service/logpm-factory-data/logpm-factory-data-olo/src/main/java/com/logpm/factorydata/olo/mq/NodeDataPushListener.java @@ -73,7 +73,7 @@ public class NodeDataPushListener { if (CollUtil.isNotEmpty(content)) { FactoryNodeEnums factoryNode = NodeMappingEnums.getFactoryByNodeAndStatus(workNodeEnums, 1); // 1 先处理 批次件 OLO开头的包件 OLO2312064418-20231226010129-1-001 原始包件 2312064418 回传按原始包件回传 - content.stream().map(i -> { + content = content.stream().map(i -> { String packageCode = i.getPackageCode(); if (StrUtil.startWith(packageCode, "OLO")) { if (StrUtil.isNotEmpty(packageCode)) { @@ -82,7 +82,7 @@ public class NodeDataPushListener { } } return i; - }); + }).collect(Collectors.toList()); // 2 先查出 包件+订单 的所有发运分单号和发运单号 Set packageSet = content.stream().map(PushData::getPackageCode).collect(Collectors.toSet()); Set orderSet = content.stream().map(PushData::getOrderCode).collect(Collectors.toSet()); diff --git a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/TrunklineAdvanceServiceImpl.java b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/TrunklineAdvanceServiceImpl.java index 7db37f96d..1e4048ecc 100644 --- a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/TrunklineAdvanceServiceImpl.java +++ b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/TrunklineAdvanceServiceImpl.java @@ -589,6 +589,7 @@ public class TrunklineAdvanceServiceImpl extends BaseServiceImpl loadScanQueryWrapper1 = new QueryWrapper<>(); +// loadScanQueryWrapper1.eq("load_id", loadId) +// .eq("scan_code", orderPackageCode) +// .eq("scan_status","2") +// .eq("unload_node_id", warehouseId); +// carsLoadScanEntity = trunklineCarsLoadScanService.getOne(loadScanQueryWrapper); +// } + + //判断是否有装车扫描记录 if (Objects.isNull(carsLoadScanEntity)) { //没有装车扫码记录