diff --git a/blade-biz-common/src/main/java/org/springblade/common/constant/broadcast/FanoutConstants.java b/blade-biz-common/src/main/java/org/springblade/common/constant/broadcast/FanoutConstants.java index bec0f49e2..852a02c3a 100644 --- a/blade-biz-common/src/main/java/org/springblade/common/constant/broadcast/FanoutConstants.java +++ b/blade-biz-common/src/main/java/org/springblade/common/constant/broadcast/FanoutConstants.java @@ -165,7 +165,7 @@ public abstract class FanoutConstants { interface signfor{ String EXCHANGE = "fanout.distribution.signfor" + ModuleNameConstant.DEVAUTH; interface QUEUE { - String FACTORY_NODE_WORK_DISTRIBUTION_SIGNFOR_QUERY = "fanout.factory.node_work.distribution.signfor_query"+ ModuleNameConstant.DEVAUTH; + String FACTORY_NODE_WORK_DISTRIBUTION_SIGNFOR_QUERY = "fanout.factory.nodework.distribution.signforquery"+ ModuleNameConstant.DEVAUTH; } } diff --git a/blade-service-api/logpm-trunkline-api/src/main/java/com/logpm/trunkline/dto/LoadCarsDTO.java b/blade-service-api/logpm-trunkline-api/src/main/java/com/logpm/trunkline/dto/LoadCarsDTO.java index 50e14c9d7..d306ed6ce 100644 --- a/blade-service-api/logpm-trunkline-api/src/main/java/com/logpm/trunkline/dto/LoadCarsDTO.java +++ b/blade-service-api/logpm-trunkline-api/src/main/java/com/logpm/trunkline/dto/LoadCarsDTO.java @@ -31,12 +31,19 @@ public class LoadCarsDTO implements Serializable { private String loadCarsNo; private String loadStatus; + private String carrierName; + private String carrierOrderCode; + private String startWarehouseName; + private String deliveryType; + private String operator; + private String settlementPerson; private Long warehouseId; private Integer startCarType; private Integer loadingType; private Integer unloadType; + private Integer isSettlement; private List carsOrderList = new ArrayList<>(); @@ -63,6 +70,7 @@ public class LoadCarsDTO implements Serializable { private Integer isZero; private String scanCode; private String scanStatus; + private String payMethod; private List packageList = new ArrayList<>(); private List zeroList = new ArrayList<>(); diff --git a/blade-service/logpm-factory/src/main/java/com/logpm/factory/receiver/NodeWorkHandler.java b/blade-service/logpm-factory/src/main/java/com/logpm/factory/receiver/NodeWorkHandler.java index aae180552..e8d1820c8 100644 --- a/blade-service/logpm-factory/src/main/java/com/logpm/factory/receiver/NodeWorkHandler.java +++ b/blade-service/logpm-factory/src/main/java/com/logpm/factory/receiver/NodeWorkHandler.java @@ -3,18 +3,15 @@ package com.logpm.factory.receiver; import cn.hutool.json.JSONObject; import cn.hutool.json.JSONUtil; import com.logpm.factory.mt.service.IMtFactoryDataService; -import com.logpm.factorydata.enums.BrandEnums; import lombok.AllArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.springblade.common.constant.broadcast.FanoutConstants; -import org.springblade.common.model.BroadcastNodeData; import org.springframework.amqp.core.ExchangeTypes; import org.springframework.amqp.rabbit.annotation.Exchange; import org.springframework.amqp.rabbit.annotation.Queue; import org.springframework.amqp.rabbit.annotation.QueueBinding; import org.springframework.amqp.rabbit.annotation.RabbitListener; import org.springframework.stereotype.Component; -import org.springframework.transaction.annotation.Transactional; /** * 作业节点数据监听 diff --git a/blade-service/logpm-factory/src/main/resources/application-dev.yml b/blade-service/logpm-factory/src/main/resources/application-dev.yml index a9a180282..3274465f2 100644 --- a/blade-service/logpm-factory/src/main/resources/application-dev.yml +++ b/blade-service/logpm-factory/src/main/resources/application-dev.yml @@ -12,10 +12,10 @@ server: spring: #rabbitmq配置 rabbitmq: - host: 192.168.2.46 + host: 192.168.3.100 port: 5672 username: admin - password: admin + password: 123456 #虚拟host 可以不设置,使用server默认host virtual-host: / #确认消息已发送到队列(Queue) diff --git a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/controller/OpenOrderController.java b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/controller/OpenOrderController.java index 03fa30bb9..0f16d25bf 100644 --- a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/controller/OpenOrderController.java +++ b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/controller/OpenOrderController.java @@ -1011,8 +1011,15 @@ public class OpenOrderController { log.warn(method+"订单号为空 orderCode={}",orderCode); throw new CustomerException(405,"订单号为空"); } + + String brand = openLabelDTO.getBrand(); + if(StringUtil.isBlank(brand)){ + log.warn(method+"品牌为空 brand={}",brand); + throw new CustomerException(405,"品牌为空"); + } + Integer totalNumber = openLabelDTO.getTotalNumber(); - if(totalNumber == 0){ + if(totalNumber == 0 && !"曼好家".equals(brand)){ log.warn(method+"总数量不正确 totalNumber={}",totalNumber); throw new CustomerException(405,"总数量不正确"); } @@ -1021,11 +1028,7 @@ public class OpenOrderController { log.warn(method+"一级品类为空 firsts={}",firsts); throw new CustomerException(405,"一级品类为空"); } - String brand = openLabelDTO.getBrand(); - if(StringUtil.isBlank(brand)){ - log.warn(method+"品牌为空 brand={}",brand); - throw new CustomerException(405,"品牌为空"); - } + String dealerName = openLabelDTO.getDealerName(); if(StringUtil.isBlank(dealerName)){ log.warn(method+"商场为空 dealerName={}",dealerName); diff --git a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mapper/TrunklineCarsLoadMapper.xml b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mapper/TrunklineCarsLoadMapper.xml index ceada808a..a95db511c 100644 --- a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mapper/TrunklineCarsLoadMapper.xml +++ b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mapper/TrunklineCarsLoadMapper.xml @@ -400,6 +400,33 @@ and Locate(#{param.loadCarsNo},ltcl.cars_no) > 0 + + and Locate(#{param.carrierName},ltcl.carrier_name) > 0 + + + and ltcl.pay_method = #{param.payMethod} + + + and Locate(#{param.carrierOrderCode},ltcl.carrier_order_code) > 0 + + + and Locate(#{param.startWarehouseName},ltcl.start_warehouse_name) > 0 + + + and ltcl.load_status = #{param.loadStatus} + + + and ltcl.is_settlement = #{param.isSettlement} + + + and ltcl.delivery_type = #{param.deliveryType} + + + and Locate(#{param.operator},ltcl.operator) > 0 + + + and Locate(#{param.settlementPerson},ltcl.settlement_person) > 0 + group by ltcl.id order by ltcl.create_time desc diff --git a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mapper/TrunklineCarsLoadScanMapper.java b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mapper/TrunklineCarsLoadScanMapper.java index e64daa9d9..6331971cd 100644 --- a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mapper/TrunklineCarsLoadScanMapper.java +++ b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mapper/TrunklineCarsLoadScanMapper.java @@ -118,7 +118,7 @@ public interface TrunklineCarsLoadScanMapper extends BaseMapper findUnloadByLoadIdAndWarehouseId(@Param("loadId") Long loadId, @Param("warehouseId") Long warehouseId); - void updateScanStatusByLoadId(@Param("loadId") Long loadId, @Param("scanStatus") String scanStatus, @Param("unloadTime") Date unloadTime); + void updateScanStatusByLoadId(@Param("loadId") Long loadId, @Param("scanStatus") String scanStatus, @Param("unloadTime") Date unloadTime,@Param("signUserName") String signUserName); List findSignListOrderPackageCodes(@Param("loadId") Long loadId); 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 078c45086..c7476dc14 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 @@ -473,12 +473,7 @@ set scan_status = #{scanStatus}, sign_time = #{unloadTime}, sign_user_name = #{signUserName}, - unload_abnormal = 0, - unload_num = num, - unload_user_name = #{signUserName}, - unload_time = #{unloadTime}, - unload_node_id = #{warehouseId}, - unload_node_name = #{warehouseName} + sign_abnormal = 0 where 1=1 and id in @@ -590,7 +585,9 @@ update logpm_trunkline_cars_load_scan set scan_status = #{scanStatus}, - sign_time = #{unloadTime} + sign_time = #{unloadTime}, + sign_user_name = #{signUserName}, + sign_abnormal = 0 where load_id = #{loadId} diff --git a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mapper/TrunklineWaybillTrackMapper.xml b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mapper/TrunklineWaybillTrackMapper.xml index 2a710a662..bcde05b3e 100644 --- a/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mapper/TrunklineWaybillTrackMapper.xml +++ b/blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mapper/TrunklineWaybillTrackMapper.xml @@ -23,7 +23,8 @@