1.所有bug修复

blade-biz-common/src/main/java/org/springblade/common/constant/broadcast/FanoutConstants.java

@@ -48,6 +48,8 @@ public abstract class FanoutConstants {
 
 				String PACKAGE_SIGN = "fanout.trunkline.packagenode.statisticsdata.packagesign" + ModuleNameConstant.DEVAUTH;
 
+				String PACKAGE_INCOMING = "fanout.trunkline.packagenode.statisticsdata.packageincoming" + ModuleNameConstant.DEVAUTH;
+
 			}
 
 		}

blade-biz-common/src/main/java/org/springblade/common/constant/carsload/CarsLoadLogTypeConstant.java

@@ -24,7 +24,9 @@ public enum CarsLoadLogTypeConstant {
 	END_UNLOAD_CARS_LOAD("终点卸车",15),
 	TRIPARTITE_TRANSFER_SIGN("三方中转签收",16),
 	TRIPARTITE_TRANSFER_SETTLEMENT("三方中转结算",17),
-	SEND_DIRECTLY_SIGN("直发商家签收",18);
+	SEND_DIRECTLY_SIGN("直发商家签收",18),
+	SEND_DIRECTLY_SIGNPHOTO("直发商家签收图片",19),
+	TRIPARTITE_TRANSFER_SIGNPHOTO("三方中转签收图片",20);
 
 	/**
 	 * 描述

blade-service-api/logpm-basicdata-api/src/main/java/com/logpm/basicdata/feign/IBasicdataTripartiteMallClient.java

@@ -51,5 +51,6 @@ public interface IBasicdataTripartiteMallClient {
 	@GetMapping(GETNAMEBRAND)
 	Long getClientIdByNameAndBrand(@RequestParam String name, @RequestParam String brand);
 
-
+	@GetMapping(API_PREFIX+"/findEntityByDealerNameAndDealerCodeAndBrand")
+    BasicdataTripartiteMallEntity findEntityByDealerNameAndDealerCodeAndBrand(@RequestParam String dealerName, @RequestParam String dealerCode, @RequestParam String brand);
 }

blade-service-api/logpm-basicdata-api/src/main/java/com/logpm/basicdata/vo/ClientInfoVO.java

@@ -9,8 +9,13 @@ public class ClientInfoVO implements Serializable {
 
 	private Long clientId;
 	private String clientName;
+	private String provinceId;
+	private String cityId;
+	private String areaId;
 	private String linkMan;
 	private String linkPhone;
 	private String linkAddress;
+	private Integer defaultPayWay;
+	private Long brandId;
 
 }

blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/feign/IDistributionParcelListClient.java

@@ -199,4 +199,6 @@ public interface IDistributionParcelListClient {
 	@PostMapping(API_PREFIX + "/findALLNoUpShelfPackageByOrderCodeList")
 	List<DistributionParcelListEntity> findALLNoUpShelfPackageByOrderCodeList(@RequestBody FindParamterDTO findParamterDTO);
 
+	@PostMapping(API_PREFIX + "/findAllParcelListByAdvanceIds")
+    List<DistributionParcelListEntity> findAllParcelListByAdvanceIds(@RequestBody List<Long> advanceIds);
 }

blade-service-api/logpm-distribution-api/src/main/java/com/logpm/distribution/feign/IDistributionStockArticleClient.java

@@ -31,6 +31,7 @@ import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestParam;
 
+import java.util.ArrayList;
 import java.util.List;
 import java.util.Map;
 
@@ -188,4 +189,7 @@ public interface IDistributionStockArticleClient {
 
 	@PostMapping(value = API_PREFIX + "/findOrderTotalNumByOrderPackageCodes",consumes = MediaType.APPLICATION_JSON_VALUE)
 	Integer findOrderTotalNumByOrderPackageCodes(@RequestBody JSONObject jsonObject);
+
+	@PostMapping(value = API_PREFIX + "/findAllStockArticleListByOrderCodes",consumes = MediaType.APPLICATION_JSON_VALUE)
+    List<DistributionStockArticleEntity> findAllStockArticleListByOrderCodes(@RequestBody List<String> orderCodes);
 }

blade-service-api/logpm-trunkline-api/src/main/java/com/logpm/trunkline/vo/TrunklineCarsLoadVO.java

@@ -49,5 +49,6 @@ public class TrunklineCarsLoadVO extends TrunklineCarsLoadEntity {
 
 	private Integer lastStartCarStatus;
 	private Integer planUnloadNum;
+	private Integer totalLoadingNum;
 
 }

blade-service-api/logpm-warehouse-api/src/main/java/com/logpm/warehouse/vo/WarehouseWaybillVO.java

@@ -38,6 +38,7 @@ public class WarehouseWaybillVO extends WarehouseWaybillEntity {
 	List<WarehouseWayBillDetail> detailList = new ArrayList<>();
 
 	private Integer handleNum;
+	private Integer noBillladingNum;
 
 	private Integer planNum;
 	private Integer totalPlanNum;

blade-service/logpm-aftersales/src/main/java/com/logpm/aftersales/controller/AftersalesAbnormalRecordController.java

@@ -58,7 +58,6 @@ public class AftersalesAbnormalRecordController extends BladeController {
 
 		try{
 
-
 			return aftersalesAbnormalRecordService.findPageList(abnormalRecordDTO);
 		}catch (CustomerException e){
 			log.error(e.message,e);

blade-service/logpm-aftersales/src/main/java/com/logpm/aftersales/dto/AbnormalRecordDTO.java

@@ -3,6 +3,8 @@ package com.logpm.aftersales.dto;
 import com.logpm.aftersales.entity.AftersalesAbnormalRecordEntity;
 import lombok.Data;
 
+import java.util.Date;
+
 @Data
 public class AbnormalRecordDTO extends AftersalesAbnormalRecordEntity {
 
@@ -13,4 +15,16 @@ public class AbnormalRecordDTO extends AftersalesAbnormalRecordEntity {
 
 	private Integer dealType;
 
+	private String createDateStartStr;
+	private String createDateEndStr;
+
+	private Date createDateStart;
+	private Date createDateEnd;
+
+	private String dealDateStartStr;
+	private String dealDateEndStr;
+
+	private Date dealDateStart;
+	private Date dealDateEnd;
+
 }

blade-service/logpm-aftersales/src/main/java/com/logpm/aftersales/mapper/AftersalesAbnormalRecordMapper.xml

@@ -45,6 +45,20 @@
         <if test="param.dealUserName !=null and param.dealUserName != ''">
             and Locate(#{param.dealUserName},deal_user_name) > 0
         </if>
+        <if test="param.createDateStart !=null">
+            and create_time &gt;= #{param.createDateStart}
+        </if>
+        <if test="param.createDateEnd !=null">
+            and create_time &lt;= #{param.createDateEnd}
+        </if>
+        <if test="param.dealDateStart !=null">
+            and deal_time &gt;= #{param.dealDateStart}
+        </if>
+        <if test="param.dealDateEnd !=null">
+            and deal_time &lt;= #{param.dealDateEnd}
+        </if>
+
+
         order by up_time desc
     </select>
 

blade-service/logpm-aftersales/src/main/java/com/logpm/aftersales/service/impl/AftersalesAbnormalRecordServiceImpl.java

@@ -12,6 +12,7 @@ import com.logpm.basicdata.feign.IBasicdataWarehouseClient;
 import com.logpm.trunkline.feign.ITrunklineCarsLoadScanClient;
 import lombok.AllArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
+import org.springblade.common.utils.CommonUtil;
 import org.springblade.core.mp.base.BaseServiceImpl;
 import org.springblade.core.secure.utils.AuthUtil;
 import org.springblade.core.tool.api.R;
@@ -50,8 +51,11 @@ public class AftersalesAbnormalRecordServiceImpl extends BaseServiceImpl<Aftersa
 			warehouseIdList = myWarehouseList.stream().map(BasicdataWarehouseEntity::getId).collect(Collectors.toList());
 		}
 
+		abnormalRecordDTO.setCreateDateStart(CommonUtil.getStartByDateStr(abnormalRecordDTO.getCreateDateStartStr()));
+		abnormalRecordDTO.setCreateDateEnd(CommonUtil.getEndByDateStr(abnormalRecordDTO.getCreateDateEndStr()));
 
-
+		abnormalRecordDTO.setDealDateStart(CommonUtil.getStartByDateStr(abnormalRecordDTO.getDealDateStartStr()));
+		abnormalRecordDTO.setDealDateEnd(CommonUtil.getEndByDateStr(abnormalRecordDTO.getDealDateEndStr()));
 
 		IPage<AftersalesAbnormalRecordEntity> pageList = baseMapper.findPageList(page,abnormalRecordDTO,warehouseIdList);
 

blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/feign/BasicdataTripartiteMallClient.java

@@ -16,6 +16,8 @@
  */
 package com.logpm.basicdata.feign;
 
+import cn.hutool.core.collection.CollUtil;
+import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.logpm.basicdata.entity.BasicdataTripartiteMallEntity;
 import com.logpm.basicdata.service.IBasicdataTripartiteMallService;
@@ -27,6 +29,8 @@ import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.RestController;
 import springfox.documentation.annotations.ApiIgnore;
 
+import java.util.List;
+
 /**
  * 客户三方商城 Feign实现类
  *
@@ -55,4 +59,18 @@ public class BasicdataTripartiteMallClient implements IBasicdataTripartiteMallCl
 		return basicdataTripartiteMallService.getClientIdByNameAndBrand(name,brand);
 	}
 
+	@Override
+	public BasicdataTripartiteMallEntity findEntityByDealerNameAndDealerCodeAndBrand(String dealerName, String dealerCode, String brand) {
+		QueryWrapper<BasicdataTripartiteMallEntity> queryWrapper = new QueryWrapper<>();
+		queryWrapper.eq("tripartite_mall",dealerName)
+			.eq("tripartite_coding",dealerCode)
+			.eq("brand_name",brand);
+		List<BasicdataTripartiteMallEntity> list = basicdataTripartiteMallService.list(queryWrapper);
+		if(CollUtil.isEmpty(list)){
+			return null;
+		}else{
+			return list.get(0);
+		}
+	}
+
 }

blade-service/logpm-basicdata/src/main/java/com/logpm/basicdata/mapper/BasicdataClientMapper.xml

@@ -59,9 +59,15 @@
                lbc.client_name clientName,
                 lbsc.linkman linkMan,
                 lbsc.phone linkPhone,
-                lbc.detailedly linkAddress
+                lbc.detailedly linkAddress,
+               lbc.blade_region_province_id provinceId,
+               lbc.blade_region_city_id cityId,
+               lbc.blade_region_area_id areaId,
+               lbc.default_payment_methods defaultPayWay,
+               t.brand_id brandId
         from logpm_basicdata_client lbc
         left join logpm_basicdata_store_contact lbsc on lbsc.shop_id = lbc.id
+        left join (select lbsb.client_id,max(lbsb.brand_id) brand_id from logpm_basicdata_store_brand lbsb group by lbsb.client_id) t on t.client_id = lbc.id
         where lbc.is_deleted = 0
           <if test="clientName != null and clientName != ''">
               and lbc.client_name like CONCAT('%',#{clientName},'%')

blade-service/logpm-distribution/src/main/java/com/logpm/distribution/controller/DistributionStockArticleController.java

@@ -19,6 +19,7 @@ package com.logpm.distribution.controller;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.github.xiaoymin.knife4j.annotations.ApiOperationSupport;
 import com.logpm.basicdata.entity.BasicdataClientUserEntity;
+import com.logpm.basicdata.entity.BasicdataWarehouseEntity;
 import com.logpm.basicdata.feign.IBasicdataClientClient;
 import com.logpm.basicdata.feign.IBasicdataWarehouseClient;
 import com.logpm.distribution.dto.DistributionStockArticleDTO;
@@ -563,6 +564,29 @@ public class DistributionStockArticleController extends BladeController {
 	}
 
 
+	@GetMapping("/showOrderCodeByCode")
+	@ApiOperationSupport(order = 2)
+	@ApiOperation(value = "展示订单码")
+	public R showOrderCodeByCode(@ApiIgnore  @RequestParam Map<String,Object> params){
+
+		OrderCodeDataVO orderCodeDataVO= null;
+		try {
+			BasicdataWarehouseEntity myCurrentWarehouse = warehouseClient.getMyCurrentWarehouse();
+			if(Objects.isNull(myCurrentWarehouse)){
+				log.warn("##########showOrderCodeByCode: 仓库信息不存在");
+				return R.fail(405,"仓库信息不存在");
+			}
+			params.put("warehouseId",myCurrentWarehouse.getId());
+
+			orderCodeDataVO = distributionStockArticleService.showOrderCodeByCode(params);
+		} catch (Exception e) {
+			return R.fail(e.getMessage());
+		}
+		return R.data(orderCodeDataVO);
+
+	}
+
+
 
 
 	/**

blade-service/logpm-distribution/src/main/java/com/logpm/distribution/feign/DistributionParcelListClient.java

@@ -448,4 +448,15 @@ public class DistributionParcelListClient implements IDistributionParcelListClie
 	public List<DistributionParcelListEntity> findALLNoUpShelfPackageByOrderCodeList(FindParamterDTO findParamterDTO) {
 		return distributionParcelListService.findALLNoUpShelfPackageByOrderCodeList(findParamterDTO.getOrderCodeList(),findParamterDTO.getWarehouseId());
 	}
+
+	@Override
+	public List<DistributionParcelListEntity> findAllParcelListByAdvanceIds(List<Long> advanceIds) {
+		QueryWrapper<DistributionParcelListEntity> queryWrapper = new QueryWrapper<>();
+		queryWrapper.in("advance_id", advanceIds)
+			.eq("is_deleted", 0);
+
+		List<DistributionParcelListEntity> list = distributionParcelListService.list(queryWrapper);
+
+		return list;
+	}
 }

blade-service/logpm-distribution/src/main/java/com/logpm/distribution/feign/DistributionStockArticleClient.java

@@ -370,4 +370,13 @@ public class DistributionStockArticleClient implements IDistributionStockArticle
 		return distributionStockArticleService.findOrderTotalNumByOrderPackageCodes(orderPackageCodes,warehouseId);
 	}
 
+	@Override
+	public List<DistributionStockArticleEntity> findAllStockArticleListByOrderCodes(List<String> orderCodes) {
+		QueryWrapper<DistributionStockArticleEntity> queryWrapper = new QueryWrapper<>();
+		queryWrapper.in("order_code",orderCodes)
+			.eq("is_deleted",0);
+
+		return distributionStockArticleService.list(queryWrapper);
+	}
+
 }

blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/IDistributionStockArticleService.java

@@ -303,4 +303,5 @@ public interface IDistributionStockArticleService extends BaseService<Distributi
 
 	void clearAllocationByIds(List<Long> clearAllocationStockArticleIdList);
 
+	OrderCodeDataVO showOrderCodeByCode(Map<String, Object> params) throws Exception;
 }

blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionStockArticleServiceImpl.java

@@ -2503,6 +2503,71 @@ public class DistributionStockArticleServiceImpl extends BaseServiceImpl<Distrib
 		return orderCodeDataVO;
 	}
 
+
+	@Override
+	public OrderCodeDataVO showOrderCodeByCode(Map<String, Object> params) throws Exception {
+		OrderCodeDataVO orderCodeDataVO = new OrderCodeDataVO();
+		List<Map<String, Object>> data = new ArrayList<>();
+		BasicPrintTemplateEntity template = basicPrintTemplateClient.getPrintTemplate(PrintTemplateStatusConstant.daiqueren_14.getValue());
+		if (ObjectUtil.isEmpty(template)) {
+			throw new ServiceException("模板内容未找到");
+		}
+
+		String html = TemplateUtil.getTemplateByUrl(template.getTemplateUrl());
+		orderCodeDataVO.setTemplateHtml(html);
+		orderCodeDataVO.setTemplateId(template.getId());
+		Long warehouseId = (Long) params.get("warehouseId");
+		String orderCodes = (String) params.get("orderCodes");
+
+		String[] orderCodesArray = orderCodes.split(",");
+		if (ObjectUtils.isNull(orderCodesArray)) {
+			throw new ServiceException("参数错误");
+
+		}
+		for (String orderCode : orderCodesArray) {
+			DistributionStockArticleEntity stockArticleEntity = findStockArticleByOrderCodeAndWarehouseId(orderCode, warehouseId);
+			if(Objects.isNull(stockArticleEntity)){
+				continue;
+			}
+
+			Long orderId = stockArticleEntity.getId();
+			String waybillNo = stockArticleEntity.getWaybillNumber();
+			String descriptionGoods = stockArticleEntity.getDescriptionGoods();
+			Integer totalNumber = stockArticleEntity.getTotalNumber();
+
+			Map<String, Object> map = new HashMap<>();
+			map.put("id", orderId);
+			String filename = QRCodeUtil.createCodeToFile(orderCode);
+			map.put("orderCodeImage", QRCodeUtil.getEmpAutograph(filename));
+			// 订单号 生成二维码
+			String fileTypeName = QRCodeUtil.createCodeToFile(orderCode);
+			map.put("imgType", QRCodeUtil.getEmpAutograph(fileTypeName));
+			if (orderCode.equals(waybillNo)) {
+				map.put("product", descriptionGoods + "（" + totalNumber + "）");
+			} else {
+				QueryWrapper<DistributionParcelListEntity> queryWrapper = new QueryWrapper<>();
+				queryWrapper.eq("stock_article_id", orderId);
+				List<DistributionParcelListEntity> list = distributionParcelListService.list(queryWrapper);
+				StringBuilder product = new StringBuilder();
+				for (DistributionParcelListEntity parcelListEntity : list) {
+					String firsts = parcelListEntity.getFirsts();
+					Integer quantity = parcelListEntity.getQuantity();
+					if (StringUtils.isBlank(product)) {
+						product.append(firsts).append("（").append(quantity).append("）");
+					} else {
+						product.append(",").append(firsts).append("（").append(quantity).append("）");
+					}
+				}
+				map.put("product", product.toString());
+			}
+
+			data.add(map);
+		}
+		orderCodeDataVO.setDataList(data);
+
+		return orderCodeDataVO;
+	}
+
 	/**
 	 * @param page
 	 * @param distributionSignforStockArticle

blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/controller/OpenOrderController.java

@@ -574,6 +574,13 @@ public class OpenOrderController {
 			throw new CustomerException(405,"发站仓不属于当前仓");
 		}
 
+		Long brandId = openOrderDTO.getBrandId();
+		String brand = openOrderDTO.getBrand();
+		if(Objects.isNull(brandId) || StringUtil.isBlank(brand)){
+			log.warn("#################openZeroOrderParamVerify: 品牌不能为空 brandId={} brand={}",brandId,brand);
+			throw new CustomerException(405,"品牌不能为空");
+		}
+
 		Long destinationWarehouseId = openOrderDTO.getDestinationWarehouseId();
 		String destinationWarehouseName = openOrderDTO.getDestinationWarehouseName();
 		if(Objects.isNull(destinationWarehouseId) && StringUtil.isBlank(destinationWarehouseName)){

blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mapper/TrunklineAdvanceDetailMapper.xml

@@ -260,8 +260,8 @@
                    max(cls.update_time) cupdateTime
             from  logpm_trunkline_cars_load_scan cls
             group by cls.scan_code
-        ) cmax on cmax.scan_code = ltcls.scan_code and cmax.cupdateTime = ltcls.update_time) m on m.scan_code = t.order_package_code
-         left join logpm_distribution_loadscan ldl on ldl.order_package_code = t.order_package_code and ldl.scan_status != 1 and ldl.is_deleted = 0
+        ) cmax on cmax.scan_code = ltcls.scan_code and cmax.cupdateTime = ltcls.update_time) m on m.scan_code = ltad.order_package_code
+         left join logpm_distribution_loadscan ldl on ldl.order_package_code = ltad.order_package_code and ldl.scan_status != 1 and ldl.is_deleted = 0
         left join logpm_distribution_delivery_list lddl on lddl.id = ldl.delivery_id
         where 1=1
         <if test="param.orderCode != null and param.orderCode != '' ">

blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mapper/TrunklineBillladingMapper.xml

@@ -94,6 +94,7 @@
         lww.customer_train customerTrain,
         lww.shipper shipper,
         lww.total_count totalCount,
+        lww.total_count-lww.billlading_num noBillladingNum,
         lww.total_count-lww.billlading_num totalPlanNum,
         lww.total_weight totalWeight,
         lww.total_volume totalVolume,
@@ -106,9 +107,9 @@
         lww.destination_warehouse_name destinationWarehouseName,
         lww.remark remark
         from logpm_warehouse_waybill lww
-        where lww.billlading_num != lww.total_count
+        where lww.billlading_num < lww.total_count
         and lww.departure_warehouse_id = #{param.warehouseId}
-        <if test="param.waybillNos != null and @org.apache.commons.collections4.CollectionUtils@isNotEmpty(param.waybillNos)">
+        <if test="param.waybillNos != null and param.waybillNos.size() > 0">
               and lww.waybill_no not in
             <foreach collection="param.waybillNos" item="item" open="(" separator="," close=")">
                 #{item}

blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mapper/TrunklineCarsLoadMapper.xml

@@ -423,10 +423,10 @@
           and ltcll.sort != 1
           and ltcl.load_status != '0'
           and ltcl.load_type != '4'
-        <if test="param.startDate != null and param.startDate != ''">
+        <if test="param.startTime != null">
             and ltcl.start_time &gt;= #{param.startDate}
         </if>
-        <if test="param.endDate != null and param.endDate != ''">
+        <if test="param.endTime != null">
             and ltcl.start_time &lt;= #{param.endDate}
         </if>
     </select>

blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mapper/TrunklineCarsLoadScanMapper.java

@@ -1,5 +1,6 @@
 package com.logpm.trunkline.mapper;
 
+import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.mapper.BaseMapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.logpm.distribution.entity.DistributionParcelListEntity;
@@ -91,7 +92,7 @@ public interface TrunklineCarsLoadScanMapper extends BaseMapper<TrunklineCarsLoa
 
 	List<LoadingListGoodsVO> findUnloadGoods(@Param("loadId") Long loadId, @Param("warehouseId") Long warehouseId, @Param("orderCode") String orderCode, @Param("waybillNo") String waybillNo);
 
-    void updateScanStatusAndTime(@Param("loadScanIds") List<Long> loadScanIds, @Param("scanStatus") String scanStatus, @Param("unloadTime") Date unloadTime,@Param("signUserName") String signUserName);
+    void updateScanStatusAndTime(@Param("loadScanIds") List<Long> loadScanIds, @Param("scanStatus") String scanStatus, @Param("unloadTime") Date unloadTime,@Param("signUserName") String signUserName,@Param("warehouseId") Long warehouseId,@Param("warehouseName") String warehouseName);
 
     List<LoadScanWaybillVO> findLoadScanWaybillList(@Param("loadId") Long loadId, @Param("nodeId") Long nodeId);
 
@@ -152,4 +153,10 @@ public interface TrunklineCarsLoadScanMapper extends BaseMapper<TrunklineCarsLoa
     List<Long> findCarsLoadScanIdsByWaybillIds(@Param("waybillIds") List<Long> waybillIds);
 
     List<CarsLoadScanAbnormalVO> findAbnormalData(@Param("loadId") Long loadId);
+
+    List<UnloadZeroVO> findUnloadZeroList(@Param("loadId") Long loadId, @Param("warehouseId") Long warehouseId);
+
+    JSONObject findUnloadNumAudio(@Param("loadId") Long loadId, @Param("warehouseId") Long warehouseId);
+
+	void updateFinalNodeIdAndFinalNodeNameByLoadIdNoData(@Param("loadId") Long loadId, @Param("warehouseId") Long warehouseId, @Param("warehouseName") String warehouseName);
 }

blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mapper/TrunklineCarsLoadScanMapper.xml

@@ -56,7 +56,6 @@
         from logpm_trunkline_cars_load_scan
         where scan_code = #{orderPackageCode}
         and load_id = #{loadId}
-        and scan_status = '1'
     </select>
 
 
@@ -372,7 +371,7 @@
 
 
     <select id="findPlanUnloadNumByLoadIdAndFinalNodeId" resultType="int">
-        select sum(IFNULL(num,0))
+        select sum(IFNULL(num-IFNULL(unload_num,0),0))
         from logpm_trunkline_cars_load_scan
         where load_id = #{loadId}
         and final_node_id = #{warehouseId}
@@ -398,6 +397,7 @@
                  left join logpm_warehouse_waybill lww on ltcls.waybill_no = lww.waybill_no
         where ltcls.load_id = #{loadId}
           and ltcls.warehouse_id = #{warehouseId}
+          and ltcls.order_code is not null
         group by ltcls.order_code,
                  ltcls.waybill_no,
                  ltcls.type,
@@ -472,7 +472,13 @@
         update logpm_trunkline_cars_load_scan
         set scan_status = #{scanStatus},
             sign_time = #{unloadTime},
-            sign_user_name = #{signUserName}
+            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}
         where 1=1
         <if test="loadScanIds != null and loadScanIds.size() > 0">
             and id in
@@ -506,7 +512,7 @@
     <select id="findUnloadLoadScanWaybillList" resultType="com.logpm.trunkline.vo.LoadScanWaybillVO">
         select waybill_no waybillNo,
                sum(num) num,
-               sum(IF(unload_node_id = null,0,num)) unloadNum
+               sum(IF(unload_node_id = null,0,unload_num)) unloadNum
         from logpm_trunkline_cars_load_scan
         where load_id = #{loadId}
           and final_node_id = #{nodeId}
@@ -812,5 +818,34 @@
         order by IFNULL(ltcls.waybill_no,'--') desc, ltcls.order_code desc
     </select>
 
+    <select id="findUnloadZeroList" resultType="com.logpm.trunkline.vo.UnloadZeroVO">
+        select ltcls.waybill_no waybillNo,
+               ltcls.order_code orderCode,
+               IFNULL(sum(ltcls.num),0) loadingNum,
+               IFNULL(sum(ltcls.unload_num),0) unloadNum
+        from logpm_trunkline_cars_load_scan ltcls
+        where ltcls.load_id = #{loadId}
+        and ltcls.final_node_id = #{warehouseId}
+        and ltcls.type = '2'
+        group by ltcls.waybill_no,
+               ltcls.order_code
+    </select>
+
+    <select id="findUnloadNumAudio" resultType="com.alibaba.fastjson.JSONObject">
+        select IFNULL(sum(unload_num),0) totalUnloadNum,
+               IFNULL(sum(IF(unload_abnormal = 1,unload_num,0)),0) abnormalUnloadNum
+        from logpm_trunkline_cars_load_scan
+        where load_id = #{loadId}
+          and unload_node_id = #{warehouseId}
+          and scan_status != '1'
+    </select>
+
+    <update id="updateFinalNodeIdAndFinalNodeNameByLoadIdNoData" >
+        update logpm_trunkline_cars_load_scan
+        set final_node_id = #{warehouseId},
+            final_node_name = #{warehouseName}
+        where load_id = #{loadId}
+        and final_node_id is null
+    </update>
 
 </mapper>

blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mapper/TrunklineCarsOrderMapper.xml

@@ -109,7 +109,7 @@
                wb.create_time createTime,
                wb.destination destination,
                wb.destination_warehouse_name destinationWarehouseName,
-               IF(wb.check_user_id IS NULL , 0,1) checkStatus,
+               IF(wb.check_user_id = NULL , 0,1) checkStatus,
                wb.shipper shipper,
                wb.shipper_name shipperName,
                wb.consignee consignee,
@@ -177,7 +177,7 @@
                IFNULL(lww.total_freight/lww.total_count*ltwo.total_number,0) orderFreight,
                IFNULL(lww.total_freight/lww.total_count*ltco.unload_num,0) unloadIncome,
                IFNULL(lww.total_freight/lww.total_count*ltco.plan_num,0) orderLineCost,
-               sum(ltwo.total_number) orderNum,
+               ltwo.total_number orderNum,
                sum(IF(ltcls.scan_status = '3',ltcls.num,0)) signNum
         from logpm_trunkline_cars_order ltco
             left join logpm_trunkline_cars_load_scan ltcls on ltcls.waybill_no = ltco.waybill_no and ltcls.order_code = ltco.order_code

blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/mq/PackageFanoutListener.java

@@ -33,11 +33,11 @@ public class PackageFanoutListener {
 	private final IBasicdataWarehouseClient warehouseClient;
 
 	@RabbitListener(bindings = @QueueBinding(
-		value = @Queue(name = FanoutConstants.trunkline.PACKAGNODE.QUEUE.PACKAGE_SIGN),
+		value = @Queue(name = FanoutConstants.trunkline.PACKAGNODE.QUEUE.PACKAGE_INCOMING),
 		exchange = @Exchange(name = FanoutConstants.trunkline.PACKAGNODE.EXCHANGE, type = ExchangeTypes.FANOUT)
 	))
 	@Transactional(rollbackFor = Exception.class)
-	public void packageSignFanout(String msg) {
+	public void packageIncomingFanout(String msg) {
 		JSONObject jsonObject = JSONUtil.parseObj(msg);
 		Integer workNode = jsonObject.getInt("workNode");
 		if(WorkNodeEnums.INITIAL_WAREHOUSE_ENTRY.getCode().equals(workNode)

blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/ITrunklineCarsLoadScanService.java

@@ -1,5 +1,6 @@
 package com.logpm.trunkline.service;
 
+import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.logpm.distribution.entity.DistributionParcelListEntity;
 import com.logpm.distribution.entity.DistributionStockArticleEntity;
@@ -86,7 +87,7 @@ public interface ITrunklineCarsLoadScanService extends BaseService<TrunklineCars
 
 	List<LoadingListGoodsVO> findUnloadGoods(Long loadId, Long warehouseId, String orderCode, String waybillNo);
 
-    void updateScanStatusAndTime(List<Long> loadScanIds, String scanStatus,Date unloadTime,String signUserName);
+    void updateScanStatusAndTime(List<Long> loadScanIds, String scanStatus,Date unloadTime,String signUserName,Long warehouseId,String warehouseName);
 
     List<LoadScanWaybillVO> findLoadScanWaybillList(Long loadId, Long nodeId);
 
@@ -147,4 +148,10 @@ public interface ITrunklineCarsLoadScanService extends BaseService<TrunklineCars
     List<Long> findCarsLoadScanIdsByWaybillIds(List<Long> waybillIds);
 
     List<CarsLoadScanAbnormalVO> findAbnormalData(Long loadId);
+
+    List<UnloadZeroVO> findUnloadZeroList(Long loadId, Long warehouseId);
+
+    JSONObject findUnloadNumAudio(Long loadId, Long warehouseId);
+
+	void updateFinalNodeIdAndFinalNodeNameByLoadIdNoData(Long loadId, Long warehouseId, String warehouseName);
 }

blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/CarsLoadAsyncServiceImpl.java

@@ -404,11 +404,14 @@ public class CarsLoadAsyncServiceImpl implements ICarsLoadAsyncService {
 			abnormalRecordEntity.setOrderPackageCode(scanCode);
 			abnormalRecordEntity.setUpUserId(userId);
 			abnormalRecordEntity.setUpUserName(nickName);
-			abnormalRecordEntity.setAbnormalStatus(0);
+			abnormalRecordEntity.setDealTime(new Date());
+			abnormalRecordEntity.setDealUserId(userId);
+			abnormalRecordEntity.setDealUserName(nickName);
+			abnormalRecordEntity.setAbnormalStatus(1);
 			abnormalRecordEntity.setUpTime(new Date());
 			abnormalRecordEntity.setAssociationId(loadScanId);
 			abnormalRecordEntity.setAssociationType(1);
-			abnormalRecordEntity.setRemark("无装车记录");
+			abnormalRecordEntity.setRemark("无装车记录  系统自动完结");
 			abnormalRecordClient.addAbnormalRecord(abnormalRecordEntity);
 		}
 	}
@@ -436,7 +439,7 @@ public class CarsLoadAsyncServiceImpl implements ICarsLoadAsyncService {
 			String orderCode = trunklineCarsLoadScanEntity.getOrderCode();
 			String scanCode = trunklineCarsLoadScanEntity.getScanCode();
 			Long scanId = trunklineCarsLoadScanEntity.getId();
-			//无装车计划
+			//无卸车计划
 			AftersalesAbnormalRecordEntity abnormalRecordEntity = new AftersalesAbnormalRecordEntity();
 			abnormalRecordEntity.setTenantId(tenantId);
 			abnormalRecordEntity.setCreateUser(userId);

blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/InComingServiceImpl.java

@@ -4,7 +4,11 @@ import cn.hutool.core.collection.CollUtil;
 import cn.hutool.core.date.DateUtil;
 import cn.hutool.json.JSONUtil;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
+import com.logpm.basicdata.entity.BasicdataStorageServicesEntity;
+import com.logpm.basicdata.entity.BasicdataTripartiteMallEntity;
 import com.logpm.basicdata.entity.BasicdataWarehouseEntity;
+import com.logpm.basicdata.feign.IBasicdataStorageServicesClient;
+import com.logpm.basicdata.feign.IBasicdataTripartiteMallClient;
 import com.logpm.basicdata.feign.IBasicdataWarehouseClient;
 import com.logpm.factorydata.enums.BrandEnums;
 import com.logpm.factorydata.util.FactoryDataMessageSender;
@@ -14,6 +18,7 @@ import com.logpm.trunkline.bean.Resp;
 import com.logpm.trunkline.dto.InComingDTO;
 import com.logpm.trunkline.dto.OrderStatusDTO;
 import com.logpm.trunkline.entity.TrunklineAdvanceDetailEntity;
+import com.logpm.trunkline.entity.TrunklineAdvanceEntity;
 import com.logpm.trunkline.entity.TrunklineBillladingPackageEntity;
 import com.logpm.trunkline.service.*;
 import com.logpm.trunkline.vo.TrunklineAdvanceVO;
@@ -58,6 +63,8 @@ public class InComingServiceImpl implements IInComingService {
 	private final ISysClient sysClient;
 	private final IWarehouseWaybillClient warehouseWaybillClient;
 	private final IOpenOrderAsyncService openOrderAsyncService;
+	private final IBasicdataTripartiteMallClient tripartiteMallClient;
+	private final IBasicdataStorageServicesClient storageServicesClient;
 
 
 	@Override
@@ -389,8 +396,6 @@ public class InComingServiceImpl implements IInComingService {
 							});
 						} catch (Exception e) {
 							log.error(">>>>>>>>>>>>>>>>>>>>>>>>>> 预入库消息推送失败~ 请联系管理员！ ", e);
-//						throw new CustomerException("服务器异常");
-
 						}
 
 
@@ -400,13 +405,13 @@ public class InComingServiceImpl implements IInComingService {
 							log.warn("############incomingPackage: 包件已入库 orderPackageCodes={} warehouseId={}", orderPackageCodes, warehouseId);
 							throw new CustomerException(405, "包件" + orderPackageCodes + "已入库");
 						} else {
-							if (!Objects.isNull(billladingId)) {
-								//先判断该包件是否已经有提货记录了
-								List<String> noOrderPackageCodes = billladingPackageServicie.findBillladingPackages(orderPackageCodes);
-								if (!noOrderPackageCodes.isEmpty()) {
-									billladingPackageServicie.saveEntityBatch(noOrderPackageCodes, billladingId, warehouseId, incomingType);
-								}
-							}
+//							if (!Objects.isNull(billladingId)) {
+//								//先判断该包件是否已经有提货记录了
+//								List<String> noOrderPackageCodes = billladingPackageServicie.findBillladingPackages(orderPackageCodes);
+//								if (!noOrderPackageCodes.isEmpty()) {
+//									billladingPackageServicie.saveEntityBatch(noOrderPackageCodes, billladingId, warehouseId, incomingType);
+//								}
+//							}
 
 							//4.如果有托盘码
 							orderPackageCodes.forEach(packageCode -> {
@@ -423,10 +428,33 @@ public class InComingServiceImpl implements IInComingService {
 					}
 				}
 			});
+
+			int size = packageCodes.size();
+			if(size == 1){
+				if(incomingType == 2){
+					//只有扫码入库才报服务仓库
+					String packageCode = packageCodes.get(0);
+					TrunklineAdvanceDetailEntity advanceDetailEntity = advanceDetailService.findEntityByOrderPackageCode(packageCode);
+					Long advanceId = advanceDetailEntity.getAdvanceId();
+					TrunklineAdvanceEntity advanceEntity = advanceService.getById(advanceId);
+					String dealerName = advanceEntity.getDealerName();
+					String dealerCode = advanceEntity.getDealerCode();
+					String brand = advanceEntity.getBrand();
+					BasicdataTripartiteMallEntity tripartiteMallEntity = tripartiteMallClient.findEntityByDealerNameAndDealerCodeAndBrand(dealerName,dealerCode,brand);
+					if(!Objects.isNull(tripartiteMallEntity)){
+						Long clientId = tripartiteMallEntity.getClientId();
+						BasicdataStorageServicesEntity storageServicesEntity = storageServicesClient.findEntityBySendWarehouseIdAndClientId(warehouseId, clientId);
+						if(!Objects.isNull(storageServicesEntity)){
+							String serveWarehouseName = storageServicesEntity.getServeWarehouseName();
+							return Resp.scanSuccess(dealerName+"的服务仓库为"+serveWarehouseName,dealerName+"的服务仓库为"+serveWarehouseName);
+						}
+					}
+				}
+			}
+
 		}catch (Exception e){
-			e.printStackTrace();
 			log.error("入库异常",e);
-			throw new CustomerException("系统异常,请联系管理员");
+			throw e;
 		}
 
 		return R.success("入库成功");

blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/OpenOrderServiceImpl.java

@@ -924,6 +924,25 @@ public class OpenOrderServiceImpl implements IOpenOrderService {
 				openOrderVO.setShipperName(basicdataClientEntity.getLinkman());
 				openOrderVO.setShipperMobile(basicdataClientEntity.getPhone());
 				openOrderVO.setShipperAddress(basicdataClientEntity.getDetailedly());
+
+				List<String> departureArray = new ArrayList<>();
+				String badeRegionAreaId = basicdataClientEntity.getBladeRegionAreaId();
+				String bladeRegionProvinceId = basicdataClientEntity.getBladeRegionProvinceId();
+				String bladeRegionCityId = basicdataClientEntity.getBladeRegionCityId();
+				departureArray.add(bladeRegionProvinceId);
+				departureArray.add(bladeRegionCityId);
+				String name = regionFeign.getName(bladeRegionCityId);
+				String areaId = bladeRegionCityId;
+				if (!StringUtil.isBlank(badeRegionAreaId)) {
+					departureArray.add(badeRegionAreaId);
+					name = regionFeign.getName(badeRegionAreaId);
+					areaId = badeRegionAreaId;
+				}
+
+				openOrderVO.setDeparture(name);
+				openOrderVO.setDepartureCode(areaId);
+				openOrderVO.setDepartureArray(departureArray);
+
 			}
 		}
 
@@ -957,6 +976,14 @@ public class OpenOrderServiceImpl implements IOpenOrderService {
 	@Override
 	public R findClientInfo(String clientName, String linkMan, String linkPhone) {
 
+		BasicdataWarehouseEntity myCurrentWarehouse = basicdataWarehouseClient.getMyCurrentWarehouse();
+		if(Objects.isNull(myCurrentWarehouse)){
+			log.warn("###########findClientInfo: 仓库信息不存在 myCurrentWarehouse={}",myCurrentWarehouse);
+			return R.fail(405,"仓库信息不存在");
+		}
+
+		Long warehouseId = myCurrentWarehouse.getId();
+
 		if (clientName == null) {
 			clientName = "";
 		}
@@ -969,6 +996,37 @@ public class OpenOrderServiceImpl implements IOpenOrderService {
 
 		List<JSONObject> ls = basicdataClientClient.findListByClientName(clientName, linkMan, linkPhone);
 
+		ls.forEach(basicdataClientJson -> {
+			Long clientId = basicdataClientJson.getLong("clientId");
+			List<String> destinationArray = new ArrayList<>();
+			String badeRegionAreaId = basicdataClientJson.getString("areaId");
+			String bladeRegionProvinceId = basicdataClientJson.getString("provinceId");
+			String bladeRegionCityId = basicdataClientJson.getString("cityId");
+			basicdataClientJson.put("provinceId", bladeRegionProvinceId);
+			basicdataClientJson.put("cityId", bladeRegionCityId);
+			basicdataClientJson.put("areaId", badeRegionAreaId);
+
+			basicdataClientJson.put("defaultDeliveryWay","2");
+			String typeService = "1";
+			BasicdataStoreBusinessEntity storeBusinessEntity = basicdataStoreBusinessClient.findByClientIdAndTypeService(clientId, 3);
+			if(!Objects.isNull(storeBusinessEntity)){
+				typeService = storeBusinessEntity.getMold();
+			}
+			if ("1".equals(typeService)){
+				basicdataClientJson.put("defaultDeliveryWay","2");
+			}else if("2".equals(typeService)){
+				basicdataClientJson.put("defaultDeliveryWay","3");
+			}else if("3".equals(typeService)){
+				basicdataClientJson.put("defaultDeliveryWay","1");
+			}
+
+			//查询目的仓数据
+			BasicdataStorageServicesEntity basicdataStorageServicesEntity = basicdataStorageServicesClient.findEntityBySendWarehouseIdAndClientId(warehouseId, clientId);
+			if (!Objects.isNull(basicdataStorageServicesEntity)) {
+				basicdataClientJson.put("destinationWarehouseId",basicdataStorageServicesEntity.getServeWarehouseId());
+				basicdataClientJson.put("destinationWarehouseName",basicdataStorageServicesEntity.getServeWarehouseName());
+			}
+		});
 		return R.data(ls);
 	}
 
@@ -2082,9 +2140,62 @@ public class OpenOrderServiceImpl implements IOpenOrderService {
 		List<Long> waybillIds = new ArrayList<>();
 		waybillIds.add(waybillId);
 		List<Long> advanceIds = trunklineWaybillOrderService.findAdvanceIdsByWaybillIds(waybillIds);
-
 		openOrderAsyncService.sendUpdateWaybillFanout(waybillEntity,wayBillDetailList,advanceIds);
 
+
+		List<DistributionParcelListEntity> parcelListEntityList = distributionParcelListClient.findAllParcelListByAdvanceIds(advanceIds);
+		if(CollUtil.isNotEmpty(parcelListEntityList)){
+			Long consigneeId = waybillEntity.getConsigneeId();
+			String consignee = waybillEntity.getConsignee();
+			String consigneeName = waybillEntity.getConsigneeName();
+			String consigneeAddress = waybillEntity.getConsigneeAddress();
+			String consigneeMobile = waybillEntity.getConsigneeMobile();
+			Long departureWarehouseId = waybillEntity.getDepartureWarehouseId();
+			Long destinationWarehouseId = waybillEntity.getDestinationWarehouseId();
+			String departureWarehouseName = waybillEntity.getDepartureWarehouseName();
+			String destinationWarehouseName = waybillEntity.getDestinationWarehouseName();
+			BasicdataClientEntity basicdataClientEntity = basicdataClientClient.findEntityById(consigneeId);
+
+
+			//把parcelListEntityList包件集合中所有元素的orderCode放入一个Set集合
+			Set<String> orderCodeSet = parcelListEntityList.stream().map(DistributionParcelListEntity::getOrderCode).collect(Collectors.toSet());
+			List<DistributionStockArticleEntity> stockArticleEntities = distributionStockArticleClient.findAllStockArticleListByOrderCodes(new ArrayList<>(orderCodeSet));
+			stockArticleEntities.forEach(stockArticleEntity -> {
+				stockArticleEntity.setMallId(consigneeId);
+				if(!Objects.isNull(basicdataClientEntity)){
+					stockArticleEntity.setMallCode(basicdataClientEntity.getClientCode());
+				}else{
+					stockArticleEntity.setMallCode("");
+				}
+				stockArticleEntity.setMallName(consignee);
+				stockArticleEntity.setConsigneeUnit(consignee);
+				stockArticleEntity.setConsigneePerson(consigneeName);
+				stockArticleEntity.setConsigneeAddress(consigneeAddress);
+				stockArticleEntity.setConsigneeMobile(consigneeMobile);
+			});
+
+			parcelListEntityList.forEach(parcelListEntity -> {
+
+				parcelListEntity.setSendWarehouseId(departureWarehouseId);
+				parcelListEntity.setSendWarehouseName(departureWarehouseName);
+				parcelListEntity.setAcceptWarehouseId(destinationWarehouseId);
+				parcelListEntity.setAcceptWarehouseName(destinationWarehouseName);
+
+				if(departureWarehouseId.equals(destinationWarehouseId)){
+					parcelListEntity.setIsTransfer(0);
+				}else{
+					parcelListEntity.setIsTransfer(1);
+				}
+
+			});
+			if(CollUtil.isNotEmpty(stockArticleEntities)){
+				distributionStockArticleClient.updateByBatchId(stockArticleEntities);
+			}
+			if(CollUtil.isNotEmpty(parcelListEntityList)){
+				distributionParcelListClient.updateList(parcelListEntityList);
+			}
+		}
+
 		return R.success("改单成功");
 	}
 
@@ -3838,7 +3949,7 @@ public class OpenOrderServiceImpl implements IOpenOrderService {
 
 		String newConsigneeMobile = openOrderDTO.getConsigneeMobile();
 		String consigneeMobile = waybillEntity.getConsigneeMobile();
-		if (!ObjectUtil.equals(consigneeMobile,newConsigneeName)) {
+		if (!ObjectUtil.equals(consigneeMobile,newConsigneeMobile)) {
 			stringBuilder.append("收货人电话：").append(consigneeMobile).append("-->").append(newConsigneeMobile).append(";");
 			waybillEntity.setConsigneeMobile(newConsigneeMobile);
 		}

blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/TrunklineAdvanceServiceImpl.java

@@ -734,10 +734,13 @@ public class TrunklineAdvanceServiceImpl extends BaseServiceImpl<TrunklineAdvanc
 
 		//把advanceDetailEntities中所有元素的waybillId提取到一个Set中
 		Set<Long> waybillIdSet = advanceDetailEntities.stream().map(TrunklineAdvanceDetailEntity::getWaybillId).collect(Collectors.toSet());
+		Map<String, WarehouseWaybillEntity> waybillEntityMap = new HashMap<>();
+		if(!waybillIdSet.isEmpty()){
+			List<WarehouseWaybillEntity> waybillEntityList = warehouseWaybillClient.findListByWaybillIds(new ArrayList<>(waybillIdSet));
+			//把waybillEntityList转化成以id为key的Map
+			waybillEntityMap = waybillEntityList.stream().collect(Collectors.toMap(WarehouseWaybillEntity::getWaybillNo, Function.identity()));
+		}
 
-		List<WarehouseWaybillEntity> waybillEntityList = warehouseWaybillClient.findListByWaybillIds(new ArrayList<>(waybillIdSet));
-		//把waybillEntityList转化成以id为key的Map
-		Map<String, WarehouseWaybillEntity> waybillEntityMap = waybillEntityList.stream().collect(Collectors.toMap(WarehouseWaybillEntity::getWaybillNo, Function.identity()));
 
 		//提取出advanceDetailEntities所有元素的advanceId存入Set
 		Set<Long> advanceIdSet = advanceDetailEntities.stream().map(TrunklineAdvanceDetailEntity::getAdvanceId).collect(Collectors.toSet());
@@ -778,6 +781,7 @@ public class TrunklineAdvanceServiceImpl extends BaseServiceImpl<TrunklineAdvanc
 		List<DistributionStockArticleEntity> addStockArticleEntities = new ArrayList<>();
 		List<DistributionStockArticleEntity> updateStockArticleEntities = new ArrayList<>();
 
+		Map<String, WarehouseWaybillEntity> finalWaybillEntityMap = waybillEntityMap;
 		orderCodeSet.forEach(orderCode -> {
 			int total = baseMapper.getAllTotalNum(orderCode);
 
@@ -812,7 +816,7 @@ public class TrunklineAdvanceServiceImpl extends BaseServiceImpl<TrunklineAdvanc
 					stockArticleEntity.setTypeService("1");//默认商配
 
 					if(!StringUtil.isBlank(waybillNo)){
-						WarehouseWaybillEntity waybillEntity = waybillEntityMap.get(waybillNo);
+						WarehouseWaybillEntity waybillEntity = finalWaybillEntityMap.get(waybillNo);
 						if(!Objects.isNull(waybillEntity)){
 							Long consigneeId = waybillEntity.getConsigneeId();
 
@@ -925,7 +929,7 @@ public class TrunklineAdvanceServiceImpl extends BaseServiceImpl<TrunklineAdvanc
 						parcelList.setIsTransfer(1);
 						String waybillNo = ad.getWaybillNo();
 						if(StringUtil.isNotBlank(waybillNo)){
-							WarehouseWaybillEntity waybillEntity = waybillEntityMap.get(waybillNo);
+							WarehouseWaybillEntity waybillEntity = finalWaybillEntityMap.get(waybillNo);
 							if(!Objects.isNull(waybillEntity)){
 								parcelList.setWaybillId(waybillEntity.getId());
 								parcelList.setWaybillNumber(waybillEntity.getWaybillNo());
@@ -1000,7 +1004,7 @@ public class TrunklineAdvanceServiceImpl extends BaseServiceImpl<TrunklineAdvanc
 		List<WarehouseWaybillEntity> updateWaybillList = new ArrayList<>();
 		parcelListEntityMap.keySet().forEach(waybillNo->{
 			WarehouseWaybillEntity updateWaybill = new WarehouseWaybillEntity();
-			WarehouseWaybillEntity waybillEntity = waybillEntityMap.get(waybillNo);
+			WarehouseWaybillEntity waybillEntity = finalWaybillEntityMap.get(waybillNo);
 
 			if(!Objects.isNull(waybillEntity)){
 				List<DistributionParcelListEntity> pl = parcelListEntityMap.get(waybillNo);

blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/TrunklineBillladingPackageServiceImpl.java

@@ -1,5 +1,6 @@
 package com.logpm.trunkline.service.impl;
 
+import cn.hutool.core.collection.CollUtil;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.logpm.basicdata.entity.BasicdataWarehouseEntity;
@@ -250,9 +251,13 @@ public class TrunklineBillladingPackageServiceImpl extends BaseServiceImpl<Trunk
 		List<TrunklineAdvanceEntity> advanceEntities = trunklineAdvanceService.list(advanceEntityQueryWrapper);
 		//把advanceEntities所有元素的waybillNo放入一个Set<String>
 		Set<String> waybillNoSet = advanceEntities.stream().map(TrunklineAdvanceEntity::getWaybillNo).collect(Collectors.toSet());
-		List<WarehouseWaybillEntity> waybillEntityList = warehouseWaybillClient.findWaybillBilllByWaybillNos(new ArrayList<>(waybillNoSet));
-		//把waybillEntityList转化成waybillNo为key的Map
-		Map<String, WarehouseWaybillEntity> waybillEntityMap = waybillEntityList.stream().collect(Collectors.toMap(WarehouseWaybillEntity::getWaybillNo, Function.identity()));
+		Map<String, WarehouseWaybillEntity> waybillEntityMap = new HashMap<>();
+		if(!waybillNoSet.isEmpty()){
+			List<WarehouseWaybillEntity> waybillEntityList = warehouseWaybillClient.findWaybillBilllByWaybillNos(new ArrayList<>(waybillNoSet));
+			//把waybillEntityList转化成waybillNo为key的Map
+			waybillEntityMap = waybillEntityList.stream().collect(Collectors.toMap(WarehouseWaybillEntity::getWaybillNo, Function.identity()));
+		}
+
 
 		//把advanceEntities转成以id为key的Map
 		Map<Long, TrunklineAdvanceEntity> advanceEntityMap = advanceEntities.stream().collect(Collectors.toMap(TrunklineAdvanceEntity::getId, Function.identity()));
@@ -262,47 +267,57 @@ public class TrunklineBillladingPackageServiceImpl extends BaseServiceImpl<Trunk
 			.collect(Collectors.groupingBy(TrunklineAdvanceDetailEntity::getAdvanceId));
 
 		Map<String,Integer> waybillNoMNumMap = new HashMap<>();
+		Map<String, WarehouseWaybillEntity> finalWaybillEntityMap = waybillEntityMap;
 		advanceEntityMap.keySet().forEach(advanceId -> {
 			TrunklineAdvanceEntity advanceEntity = advanceEntityMap.get(advanceId);
 			String waybillNo = advanceEntity.getWaybillNo();
 			if(StringUtil.isNotBlank(waybillNo)){
 				List<TrunklineAdvanceDetailEntity> advanceDetailEntities = advanceIdGroupedEntities.get(advanceId);
 				int size = advanceDetailEntities.size();
-				WarehouseWaybillEntity waybillEntity = waybillEntityMap.get(waybillNo);
-				Integer stockCount = waybillEntity.getStockCount();
-				Integer totalCount = waybillEntity.getTotalCount();
-				if(Objects.isNull(stockCount)){
-					stockCount = 0;
-				}
-				int diff = 0;
-				int all = stockCount + size;
-				if(all > totalCount){
+				WarehouseWaybillEntity waybillEntity = finalWaybillEntityMap.get(waybillNo);
+				if(!Objects.isNull(waybillEntity)){
+					Integer stockCount = waybillEntity.getStockCount();
+					Integer totalCount = waybillEntity.getTotalCount();
+					Integer billladingNum = waybillEntity.getBillladingNum();
+					if(Objects.isNull(stockCount)){
+						stockCount = 0;
+					}
+					int diff = 0;
+					int all = stockCount + size;
+					int allBillladingNum = billladingNum + size;
+					waybillEntity.setBillladingNum(allBillladingNum);
+					if(all > totalCount){
 //					waybillEntity.setStockCount(totalCount);
-					diff = totalCount - stockCount;
-				}else{
+						diff = totalCount - stockCount;
+					}else{
 //					waybillEntity.setStockCount(all);
-					diff = size;
-				}
-				Integer integer = waybillNoMNumMap.get(waybillNo);
-				if(Objects.isNull(integer)){
-					waybillNoMNumMap.put(waybillNo,diff);
-				}else{
-					waybillNoMNumMap.put(waybillNo,diff+integer);
-				}
+						diff = size;
+					}
+					Integer integer = waybillNoMNumMap.get(waybillNo);
+					if(Objects.isNull(integer)){
+						waybillNoMNumMap.put(waybillNo,diff);
+					}else{
+						waybillNoMNumMap.put(waybillNo,diff+integer);
+					}
 
-				waybillEntityMap.put(waybillNo,waybillEntity);
+					finalWaybillEntityMap.put(waybillNo,waybillEntity);
+				}
 			}
 		});
 
-		QueryWrapper<TrunklineBillladingWaybillEntity> billladingWaybillEntityQueryWrapper = new QueryWrapper<>();
-		billladingWaybillEntityQueryWrapper.in("waybill_no",waybillNoSet)
-			.eq("billlading_id",billladingId)
-			.eq("is_deleted",0);
+		Map<String, TrunklineBillladingWaybillEntity> billladingWaybillEntityMap = new HashMap<>();
+		if(!waybillNoSet.isEmpty()){
+			QueryWrapper<TrunklineBillladingWaybillEntity> billladingWaybillEntityQueryWrapper = new QueryWrapper<>();
+			billladingWaybillEntityQueryWrapper.in("waybill_no",waybillNoSet)
+				.eq("billlading_id",billladingId)
+				.eq("is_deleted",0);
+
+			List<TrunklineBillladingWaybillEntity> billladingWaybillEntityList = trunklineBillladingWaybillService.list(billladingWaybillEntityQueryWrapper);
 
-		List<TrunklineBillladingWaybillEntity> billladingWaybillEntityList = trunklineBillladingWaybillService.list(billladingWaybillEntityQueryWrapper);
+			//把billladingWaybillEntityList转化成waybillNo为key的Map
+			billladingWaybillEntityMap = billladingWaybillEntityList.stream().collect(Collectors.toMap(TrunklineBillladingWaybillEntity::getWaybillNo, Function.identity()));
+		}
 
-		//把billladingWaybillEntityList转化成waybillNo为key的Map
-		Map<String, TrunklineBillladingWaybillEntity> billladingWaybillEntityMap = billladingWaybillEntityList.stream().collect(Collectors.toMap(TrunklineBillladingWaybillEntity::getWaybillNo, Function.identity()));
 
 		List<TrunklineBillladingWaybillEntity> addList = new ArrayList<>();
 		List<TrunklineBillladingWaybillEntity> updateList = new ArrayList<>();
@@ -348,14 +363,17 @@ public class TrunklineBillladingPackageServiceImpl extends BaseServiceImpl<Trunk
 		TrunklineBillladingEntity billladingEntity = trunklineBillladingService.getById(billladingId);
 		if(!Objects.isNull(billladingEntity)){
 			int realNum = billladingEntity.getRealNum();
-			Integer all = waybillNoMNumMap.values().stream().reduce(Integer::sum).get();
+			Integer all = 0;
+			if(CollUtil.isNotEmpty(waybillNoMNumMap)){
+				all = waybillNoMNumMap.values().stream().reduce(Integer::sum).get();
+			}
 			billladingEntity.setRealNum(realNum+all);
 			trunklineBillladingService.updateById(billladingEntity);
 		}
 
 		List<WarehouseWaybillEntity> warehouseWaybillEntities = new ArrayList<>();
-		waybillEntityMap.keySet().forEach(waybillNo -> {
-			WarehouseWaybillEntity waybillEntity = waybillEntityMap.get(waybillNo);
+		finalWaybillEntityMap.keySet().forEach(waybillNo -> {
+			WarehouseWaybillEntity waybillEntity = finalWaybillEntityMap.get(waybillNo);
 			if(!Objects.isNull(waybillEntity)){
 				Integer totalCount = waybillEntity.getTotalCount();
 				Integer stockCount = waybillEntity.getStockCount();

blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/TrunklineBillladingServiceImpl.java

@@ -1,5 +1,6 @@
 package com.logpm.trunkline.service.impl;
 
+import cn.hutool.core.collection.CollUtil;
 import cn.hutool.core.util.ObjectUtil;
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
@@ -106,7 +107,7 @@ public class TrunklineBillladingServiceImpl extends BaseServiceImpl<TrunklineBil
 		updateById(trunklineBillladingEntity);
 
 		List<TrunklineBillladingWaybillEntity> saveBillladingWaybillList = new ArrayList<>();
-		Map<Long, Integer> waybillBillladingNumMap = new HashMap<>();
+//		Map<Long, Integer> waybillBillladingNumMap = new HashMap<>();
 		//保存提货运单
 		List<TrunklineBillladingWaybillVO> billladingWaybillList = billladingDTO.getBillladingWaybillList();
 		for (TrunklineBillladingWaybillVO billladingWaybillVO:billladingWaybillList){
@@ -118,29 +119,29 @@ public class TrunklineBillladingServiceImpl extends BaseServiceImpl<TrunklineBil
 			billladingWaybillEntity.setRealWeight(BigDecimal.ZERO);
 			billladingWaybillEntity.setRealVolume(BigDecimal.ZERO);
 			billladingWaybillEntity.setBillladingFee(BigDecimal.ZERO);
-			billladingWaybillEntity.setPlanNum(billladingWaybillVO.getPlanNum());
+//			billladingWaybillEntity.setPlanNum(billladingWaybillVO.getPlanNum());
 			saveBillladingWaybillList.add(billladingWaybillEntity);
-			waybillBillladingNumMap.put(billladingWaybillVO.getWaybillId(),billladingWaybillVO.getPlanNum());
+//			waybillBillladingNumMap.put(billladingWaybillVO.getWaybillId(),billladingWaybillVO.getPlanNum());
 		}
 		billladingWaybillService.saveBatch(saveBillladingWaybillList);
 
-		Set<Long> waybillIds = waybillBillladingNumMap.keySet();
-
-		List<WarehouseWaybillEntity> waybillEntityList = warehouseWaybillClient.findListByWaybillIds(new ArrayList<>(waybillIds));
-		waybillEntityList.forEach(waybillEntity -> {
-			Long waybillEntityId = waybillEntity.getId();
-			Integer planNum = waybillBillladingNumMap.get(waybillEntityId);
-			if(Objects.isNull(planNum)){
-				planNum = 0;
-			}
-			Integer billladingNum = waybillEntity.getBillladingNum();
-			if(Objects.isNull(billladingNum)){
-				billladingNum = 0;
-			}
-			waybillEntity.setBillladingNum(billladingNum+planNum);
-		});
-
-		warehouseWaybillClient.updateList(waybillEntityList);
+//		Set<Long> waybillIds = waybillBillladingNumMap.keySet();
+//
+//		List<WarehouseWaybillEntity> waybillEntityList = warehouseWaybillClient.findListByWaybillIds(new ArrayList<>(waybillIds));
+//		waybillEntityList.forEach(waybillEntity -> {
+//			Long waybillEntityId = waybillEntity.getId();
+//			Integer planNum = waybillBillladingNumMap.get(waybillEntityId);
+//			if(Objects.isNull(planNum)){
+//				planNum = 0;
+//			}
+//			Integer billladingNum = waybillEntity.getBillladingNum();
+//			if(Objects.isNull(billladingNum)){
+//				billladingNum = 0;
+//			}
+//			waybillEntity.setBillladingNum(billladingNum+planNum);
+//		});
+//
+//		warehouseWaybillClient.updateList(waybillEntityList);
 
 
 		TrunklineBillladingLogEntity logEntity = new TrunklineBillladingLogEntity();
@@ -536,6 +537,10 @@ public class TrunklineBillladingServiceImpl extends BaseServiceImpl<TrunklineBil
 		Integer stockNum = 0;
 		BigDecimal stockWeight = BigDecimal.ZERO;
 		BigDecimal stockVolume = BigDecimal.ZERO;
+
+		List<TrunklineBillladingWaybillEntity> updateBillladingWaybillList = new ArrayList<>();
+		List<WarehouseWaybillEntity> updateWaybillList = new ArrayList<>();
+
 		for (BillladingWaybillDTO billladingWaybillDTO:billladingWaybillEnterList){
 			Long billladingWaybillId = billladingWaybillDTO.getBillladingWaybillId();
 
@@ -551,19 +556,39 @@ public class TrunklineBillladingServiceImpl extends BaseServiceImpl<TrunklineBil
 			BigDecimal enterWeight = billladingWaybillDTO.getEnterWeight();
 			BigDecimal enterVolume = billladingWaybillDTO.getEnterVolume();
 
+			//查询运单信息
+			WarehouseWaybillEntity waybillEntity = warehouseWaybillClient.findByWaybillId(waybillId);
+			if(Objects.isNull(waybillEntity)){
+				log.warn("#############updateBillladingWaybillNum: 运单信息不存在 waybillId={}",waybillId);
+				throw new CustomerException(405,"运单"+waybillNo+"信息不存在");
+			}
+			Integer billladingNum = waybillEntity.getBillladingNum();
+			int totalCount = waybillEntity.getTotalCount();
+
+			int tNum =billladingNum+(enterNum-realNum);//最终的提货件数
+			if(tNum > totalCount){
+				log.warn("#############updateBillladingWaybillNum: 运单{}提货件数已超过总件数 waybillId={}",waybillNo,waybillId);
+				throw new CustomerException(405,"运单"+waybillNo+"提货件数已超过总件数");
+			}
+
+			TrunklineBillladingWaybillEntity updateBillladingWaybillEntity = new TrunklineBillladingWaybillEntity();
+			updateBillladingWaybillEntity.setId(billladingWaybillId);
+			updateBillladingWaybillEntity.setRealNum(enterNum);
+			updateBillladingWaybillEntity.setRealWeight(enterWeight);
+			updateBillladingWaybillEntity.setRealVolume(enterVolume);
+			updateBillladingWaybillList.add(updateBillladingWaybillEntity);
+
+			WarehouseWaybillEntity updateWaybillEntity = new WarehouseWaybillEntity();
+			updateWaybillEntity.setId(waybillId);
+			updateWaybillEntity.setBillladingNum(tNum);
+			updateWaybillList.add(updateWaybillEntity);
+
 //			Integer tNum = billladingWaybillService.getFinishNumByWaybillIdNotBillladingWaybillId(waybillId,billladingWaybillId);
 
 			//这个运单总件数不应该查询运单上的总件数，应该取统计运单下暂存单的包件数量，因为运单可能会涉及到改单 总数会变
 
 //			Integer totalCount = trunklineWaybillOrderService.getOrderPackageNumByWaybillId(waybillId);
 
-			if(enterNum > planNum){
-				log.warn("###############updateBillladingWaybillNum: 运单提货数量已经大于计划数 waybillId={} planNum={}",waybillId,planNum);
-				throw new CustomerException(405,"【"+waybillNo+"】运单提货数量已经大于计划数");
-			}
-
-			billladingWaybillService.updateDataByBillladingWaybillId(billladingWaybillId,enterNum,enterWeight,enterVolume);
-
 //			Integer diffNum = enterNum-realNum;
 //			BigDecimal diffWeight = realWeight.subtract(enterWeight);
 //			BigDecimal diffVolume = realVolume.subtract(enterVolume);
@@ -595,6 +620,13 @@ public class TrunklineBillladingServiceImpl extends BaseServiceImpl<TrunklineBil
 //			warehouseWaybillClient.updateEntity(waybillEntity);
 		}
 
+		if(CollUtil.isNotEmpty(updateBillladingWaybillList)){
+			billladingWaybillService.updateBatchById(updateBillladingWaybillList);
+		}
+		if(CollUtil.isNotEmpty(updateWaybillList)){
+			warehouseWaybillClient.updateList(updateWaybillList);
+		}
+
 		TrunklineBillladingNumVO numVO = billladingWaybillService.getNumVOByBillladingId(billladingId);
 
 		billladingEntity.setRealNum(numVO.getNum());

blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/TrunklineCarsLoadLogServiceImpl.java

@@ -134,7 +134,7 @@ public class TrunklineCarsLoadLogServiceImpl extends BaseServiceImpl<TrunklineCa
 				if(!list.isEmpty()){
 					signNum = list.size();
 				}
-				content = "【"+nodeName+"】三方中转签收，车次号："+carsNo+"，车牌号："+carNumber+"，司机姓名："+driverName+
+				content = "【"+nodeName+"】三方中转【整车】签收，车次号："+carsNo+"，车牌号："+carNumber+"，司机姓名："+driverName+
 					"，司机手机号："+driverMobile+"，签收件数："+ signNum + "/" + realLoadingNumber + "件";
 				break;
 			case 17:
@@ -145,6 +145,14 @@ public class TrunklineCarsLoadLogServiceImpl extends BaseServiceImpl<TrunklineCa
 				content = "【"+nodeName+"】直发商家签收，车次号："+carsNo+"，车牌号："+carNumber+"，司机姓名："+driverName+
 					"，司机手机号："+driverMobile+"，签收时间："+ now;
 				break;
+			case 19:
+				content = "【"+nodeName+"】直发商家签收图片上传，车次号："+carsNo+"，车牌号："+carNumber+"，司机姓名："+driverName+
+					"，司机手机号："+driverMobile+"，上传时间："+ now;
+				break;
+			case 20:
+				content = "【"+nodeName+"】三方中转签收图片上传，车次号："+carsNo+"，车牌号："+carNumber+"，司机姓名："+driverName+
+					"，司机手机号："+driverMobile+"，上传时间："+ now;
+				break;
 			default:
 				content = "【"+nodeName+"】其他日志，车次号："+carsNo+"，车牌号："+carNumber+"，司机姓名："+driverName+
 					"，司机手机号："+driverMobile;
@@ -153,7 +161,8 @@ public class TrunklineCarsLoadLogServiceImpl extends BaseServiceImpl<TrunklineCa
 		carsLoadLogEntity.setType(cardLoadType);
 		carsLoadLogEntity.setCreateUserName(AuthUtil.getNickName());
 
-		if(CarsLoadLogTypeConstant.TRIPARTITE_TRANSFER_SIGN.getValue().equals(cardLoadType)){
+		if(CarsLoadLogTypeConstant.TRIPARTITE_TRANSFER_SIGN.getValue().equals(cardLoadType)
+			|| CarsLoadLogTypeConstant.SEND_DIRECTLY_SIGN.getValue().equals(cardLoadType)){
 			QueryWrapper<TrunklineCarsLoadLogEntity> qw = new QueryWrapper<>();
 			qw.eq("node_id",nodeId)
 				.eq("load_id",loadId)
@@ -161,12 +170,32 @@ public class TrunklineCarsLoadLogServiceImpl extends BaseServiceImpl<TrunklineCa
 			TrunklineCarsLoadLogEntity carsLoadLogEntity1 = baseMapper.selectOne(qw);
 			if(Objects.isNull(carsLoadLogEntity1)){
 				save(carsLoadLogEntity);
+				return;
 			}else{
 				carsLoadLogEntity1.setContent(content);
 				updateById(carsLoadLogEntity1);
+				return;
 			}
-		}else{
-			save(carsLoadLogEntity);
 		}
+
+		if(CarsLoadLogTypeConstant.SEND_DIRECTLY_SIGNPHOTO.getValue().equals(cardLoadType)
+			|| CarsLoadLogTypeConstant.TRIPARTITE_TRANSFER_SIGNPHOTO.getValue().equals(cardLoadType)){
+			QueryWrapper<TrunklineCarsLoadLogEntity> qw = new QueryWrapper<>();
+			qw.eq("node_id",nodeId)
+				.eq("load_id",loadId)
+				.eq("type",cardLoadType);
+			TrunklineCarsLoadLogEntity carsLoadLogEntity1 = baseMapper.selectOne(qw);
+			if(Objects.isNull(carsLoadLogEntity1)){
+				save(carsLoadLogEntity);
+				return;
+			}else{
+				carsLoadLogEntity1.setContent(content);
+				updateById(carsLoadLogEntity1);
+				return;
+			}
+		}
+
+		save(carsLoadLogEntity);
+
 	}
 }

blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/TrunklineCarsLoadScanServiceImpl.java

@@ -1,5 +1,6 @@
 package com.logpm.trunkline.service.impl;
 
+import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.logpm.distribution.entity.DistributionParcelListEntity;
 import com.logpm.distribution.entity.DistributionStockArticleEntity;
@@ -203,8 +204,8 @@ public class TrunklineCarsLoadScanServiceImpl extends BaseServiceImpl<TrunklineC
 	}
 
 	@Override
-	public void updateScanStatusAndTime(List<Long> loadScanIds, String scanStatus,Date unloadTime,String signUserName) {
-		baseMapper.updateScanStatusAndTime(loadScanIds,scanStatus,unloadTime,signUserName);
+	public void updateScanStatusAndTime(List<Long> loadScanIds, String scanStatus,Date unloadTime,String signUserName,Long warehouseId,String warehouseName) {
+		baseMapper.updateScanStatusAndTime(loadScanIds,scanStatus,unloadTime,signUserName,warehouseId,warehouseName);
 	}
 
 	@Override
@@ -357,4 +358,19 @@ public class TrunklineCarsLoadScanServiceImpl extends BaseServiceImpl<TrunklineC
 		return baseMapper.findAbnormalData(loadId);
 	}
 
+	@Override
+	public List<UnloadZeroVO> findUnloadZeroList(Long loadId, Long warehouseId) {
+		return baseMapper.findUnloadZeroList(loadId,warehouseId);
+	}
+
+	@Override
+	public JSONObject findUnloadNumAudio(Long loadId, Long warehouseId) {
+		return baseMapper.findUnloadNumAudio(loadId,warehouseId);
+	}
+
+	@Override
+	public void updateFinalNodeIdAndFinalNodeNameByLoadIdNoData(Long loadId, Long warehouseId, String warehouseName) {
+		baseMapper.updateFinalNodeIdAndFinalNodeNameByLoadIdNoData(loadId,warehouseId,warehouseName);
+	}
+
 }

blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/TrunklineCarsLoadServiceImpl.java

@@ -594,20 +594,12 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
 			log.warn("#############cancelStartCarByLoadId: 配载计划不存在 loadId={}", loadId);
 			throw new CustomerException(400, "配载计划不存在");
 		}
-		String loadStatus = carsLoadEntity.getLoadStatus();
-		if (!"10".equals(loadStatus) && !"30".equals(loadStatus)) {
-			log.warn("#############cancelStartCarByLoadId: 配载计划暂未发车 loadId={} loadStatus={}", loadId, loadStatus);
-			throw new CustomerException(400, "配载计划暂未发车");
-		}
-
-
 		Long nowWarehouseId = carsLoadEntity.getNowWarehouseId();
 		if (!nowWarehouseId.equals(warehouseId)) {
-			log.warn("#############cancelStartCarByLoadId: 未有权限进行该操作 nowWarehouseId={} warehouseId={}", nowWarehouseId, warehouseId);
-			throw new CustomerException(400, "未有权限进行该操作");
+			log.warn("#############cancelStartCarByLoadId: 车辆不在当前节点 nowWarehouseId={} warehouseId={}", nowWarehouseId, warehouseId);
+			throw new CustomerException(400, "车辆不在当前节点");
 		}
 
-
 		//查询当前节点信息
 		TrunklineCarsLoadLineEntity currentCarsLoadLineEntity = trunklineCarsLoadLineService.findEntityByLoadIdAndNodeId(loadId, nowWarehouseId);
 		if (Objects.isNull(currentCarsLoadLineEntity)) {
@@ -622,6 +614,12 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
 		}
 		Integer sort = currentCarsLoadLineEntity.getSort();
 
+		String loadStatus = carsLoadEntity.getLoadStatus();
+		if (!"10".equals(loadStatus) && !"30".equals(loadStatus)) {
+			log.warn("#############cancelStartCarByLoadId: 配载计划暂未发车 loadId={} loadStatus={}", loadId, loadStatus);
+			throw new CustomerException(400, "配载计划暂未发车");
+		}
+
 		//查询下一节点
 		TrunklineCarsLoadLineEntity nextCarsLoadLineEntity = trunklineCarsLoadLineService.findEntityByLoadIdAndSort(loadId, sort + 1);
 		if (Objects.isNull(nextCarsLoadLineEntity)) {
@@ -897,6 +895,7 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
 
 	}
 
+	@Transactional(rollbackFor = Exception.class)
 	@Override
 	public void unloadByLoadId(LoadCarsDTO loadCarsDTO) {
 		log.info("############unloadByLoadId: 卸车确认");
@@ -1014,6 +1013,115 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
 			throw new CustomerException(400, "未知的卸车确认类型");
 		}
 
+		QueryWrapper<TrunklineCarsLoadScanEntity> queryWrapper = new QueryWrapper<>();
+		queryWrapper.eq("load_id", loadId)
+			.eq("unload_node_id", warehouseId)
+			.eq("type", 2)
+			.ne("scan_status", "1");
+
+		List<TrunklineCarsLoadScanEntity> carsLoadScanEntityList = trunklineCarsLoadScanService.list(queryWrapper);
+		if(CollUtil.isNotEmpty(carsLoadScanEntityList)){
+			//把carsLoadScanEntityList通过orderCode进行分组
+			Map<String, List<TrunklineCarsLoadScanEntity>> orderCodemap = carsLoadScanEntityList.stream().collect(Collectors.groupingBy(TrunklineCarsLoadScanEntity::getOrderCode));
+			orderCodemap.keySet().forEach(orderCode -> {
+				List<TrunklineCarsLoadScanEntity> orderCodeList = orderCodemap.get(orderCode);
+				//把orderCodeList通过fromWarehouseId进行分组
+				Map<Long, List<TrunklineCarsLoadScanEntity>> fromWarehouseIdmap = orderCodeList.stream().collect(Collectors.groupingBy(TrunklineCarsLoadScanEntity::getFromWarehouseId));
+				fromWarehouseIdmap.keySet().forEach(fromWarehouseId -> {
+					TrunklineCarsOrderEntity trunklineCarsOrderEntity = trunklineCarsOrderService.findEntityByLoadIdAndWarehouseIdAndOrderCodeAndWaybillNo(loadId, fromWarehouseId, orderCode, orderCode);
+					if(!Objects.isNull(trunklineCarsOrderEntity)){
+						Integer realNum = trunklineCarsOrderEntity.getRealNum();
+						List<TrunklineCarsLoadScanEntity> fromWarehouseIdList = fromWarehouseIdmap.get(fromWarehouseId);
+						//把fromWarehouseIdList中所有元素的unloadNum累加
+						int unloadNum = fromWarehouseIdList.stream().mapToInt(TrunklineCarsLoadScanEntity::getUnloadNum).sum();
+						DistributionStockArticleEntity stockArticleEntity = distributionStockArticleClient.findZeroByOrderCodeAndWarehouseId(orderCode, fromWarehouseId);
+						if(!Objects.isNull(stockArticleEntity)){
+							Integer handQuantity = stockArticleEntity.getHandQuantity();
+
+							if(unloadNum > realNum){
+								//卸车数大于实际装车数
+								throw new CustomerException(405,"零担订单"+orderCode+"卸车件数已大于实际装车件数,请去调整补录");
+							}else {
+								if(unloadNum < realNum){
+									distributionStockArticleClient.addHandQuantity(stockArticleEntity.getId(),realNum-unloadNum);
+								}
+
+								DistributionStockArticleEntity newStockArticleEntity = distributionStockArticleClient.findStockArticleByOrderCodeAndWarehouseId(orderCode, warehouseId);
+								if (Objects.isNull(newStockArticleEntity)) {
+									newStockArticleEntity = new DistributionStockArticleEntity();
+									BeanUtil.copy(stockArticleEntity, newStockArticleEntity);
+									newStockArticleEntity.setId(null);
+									newStockArticleEntity.setOrderReceiveStatus("20");
+									newStockArticleEntity.setOrderStatus("10");
+									newStockArticleEntity.setHandQuantity(unloadNum);
+									newStockArticleEntity.setIncomingNum(unloadNum);
+									newStockArticleEntity.setWarehouse(warehouseEntity.getName());
+									newStockArticleEntity.setWarehouseId(warehouseEntity.getId());
+									newStockArticleEntity.setCarsLoadNum(0);
+									Long orderId = distributionStockArticleClient.addData(newStockArticleEntity);
+									if (orderId != 0) {
+										List<DistributionParcelListEntity> parcelListEntityList = distributionParcelListClient.findEntityListByOrderCode(orderCode, fromWarehouseId);
+										List<DistributionParcelNumberEntity> ls = new ArrayList<>();
+										for (DistributionParcelListEntity parcelListEntity : parcelListEntityList) {
+											DistributionParcelListEntity newParcelListEntity = new DistributionParcelListEntity();
+											BeanUtil.copy(parcelListEntity, newParcelListEntity);
+											newParcelListEntity.setId(null);
+											newParcelListEntity.setWarehouseId(warehouseId);
+											newParcelListEntity.setWarehouse(warehouseEntity.getName());
+											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 hQuantity = newStockArticleEntity.getHandQuantity() + unloadNum;
+									Integer incomingNum = newStockArticleEntity.getIncomingNum() + unloadNum;
+									Integer totalNumber = newStockArticleEntity.getTotalNumber();
+
+									if (incomingNum.equals(totalNumber)) {
+										if (hQuantity.equals(totalNumber)) {
+											newStockArticleEntity.setOrderStatus("20");
+										} else {
+											newStockArticleEntity.setOrderStatus("30");
+										}
+										newStockArticleEntity.setOrderReceiveStatus("30");
+									} else {
+										if (incomingNum.equals(hQuantity)) {
+											newStockArticleEntity.setOrderStatus("10");
+										} else {
+											newStockArticleEntity.setOrderStatus("30");
+										}
+										newStockArticleEntity.setOrderReceiveStatus("20");
+									}
+									newStockArticleEntity.setHandQuantity(hQuantity);
+									newStockArticleEntity.setIncomingNum(incomingNum);
+
+									distributionStockArticleClient.saveOrUpdate(newStockArticleEntity);
+								}
+							}
+						}
+					}
+				});
+			});
+		}
+
 		//无装车记录异常日志记录
 		try {
 //			carsLoadAsyncService.
@@ -1842,6 +1950,9 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
 		carsLoadLineEntity.setStartUserName(AuthUtil.getUserName());
 		trunklineCarsLoadLineService.updateById(carsLoadLineEntity);
 
+		//三方中转发车把异常的数据计划目的仓设置成当前仓
+		trunklineCarsLoadScanService.updateFinalNodeIdAndFinalNodeNameByLoadIdNoData(loadId,warehouseId,warehouseEntity.getName());
+
 		carsLoadEntity.setLoadStatus("10");
 		carsLoadEntity.setStartTime(date);
 		updateById(carsLoadEntity);
@@ -2023,6 +2134,12 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
 			throw new CustomerException(400, "暂未有权限进行操作");
 		}
 
+		TrunklineCarsLoadLineEntity carsLoadLineEntity = trunklineCarsLoadLineService.findEntityByLoadIdAndNodeId(loadId, warehouseId);
+		if (Objects.isNull(carsLoadLineEntity)) {
+			log.warn("#############signCars: 三方中转节点不存在 loadId={} carsLoadLineEntity={}", loadId,carsLoadLineEntity);
+			throw new CustomerException(400, "三方中转节点不存在");
+		}
+
 		carsLoadEntity.setSignTime(new Date());
 		carsLoadEntity.setLoadStatus("90");
 		updateById(carsLoadEntity);
@@ -2030,7 +2147,7 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
 		trunklineCarsLoadScanService.updateScanStatusByLoadId(loadId, "3", new Date());
 
 		try {
-			trunklineCarsLoadLogService.saveLog(carsLoadEntity, null, CarsLoadLogTypeConstant.TRIPARTITE_TRANSFER_SIGN.getValue());
+			trunklineCarsLoadLogService.saveLog(carsLoadEntity, carsLoadLineEntity, CarsLoadLogTypeConstant.TRIPARTITE_TRANSFER_SIGN.getValue());
 
 			List<String> orderPackageCodes = trunklineCarsLoadScanService.findSignListOrderPackageCodes(loadId);
 
@@ -2954,6 +3071,7 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
 				carsLoadWaybillInfoVO.setWaybillNo(waybillNo);
 				if(!"--".equals(waybillNo)){
 					if(!Objects.isNull(warehouseWaybillEntity)){
+						Integer totalCount = warehouseWaybillEntity.getTotalCount();
 						carsLoadWaybillInfoVO.setCreateTime(warehouseWaybillEntity.getCreateTime());
 						carsLoadWaybillInfoVO.setDestination(warehouseWaybillEntity.getDestination());
 						carsLoadWaybillInfoVO.setDestinationWarehouseName(warehouseWaybillEntity.getDestinationWarehouseName());
@@ -2961,7 +3079,7 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
 						carsLoadWaybillInfoVO.setShipperName(warehouseWaybillEntity.getShipperName());
 						carsLoadWaybillInfoVO.setConsignee(warehouseWaybillEntity.getConsignee());
 						carsLoadWaybillInfoVO.setConsigneeName(warehouseWaybillEntity.getConsigneeName());
-						carsLoadWaybillInfoVO.setWaybillNum(warehouseWaybillEntity.getTotalCount());
+						carsLoadWaybillInfoVO.setWaybillNum(totalCount);
 						carsLoadWaybillInfoVO.setWaybillType(warehouseWaybillEntity.getWaybillType());
 						carsLoadWaybillInfoVO.setWaybillId(warehouseWaybillEntity.getId());
 						carsLoadWaybillInfoVO.setRemark(warehouseWaybillEntity.getRemark());
@@ -2981,6 +3099,7 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
 						carsLoadWaybillInfoVO.setHandlingFee(handlingFee);
 						carsLoadWaybillInfoVO.setOtherFee(otherFee);
 						carsLoadWaybillInfoVO.setInsuranceFee(insuranceFee);
+						carsLoadWaybillInfoVO.setOpenPrice(totalFreight.divide(new BigDecimal(totalCount),2, RoundingMode.HALF_UP).toPlainString());
 						carsLoadWaybillInfoVO.setTotalFee(totalFreight.add(deliveryFee).add(pickupFee).add(warehouseManagementFee).add(storageFee).add(handlingFee).add(otherFee).add(insuranceFee));
 						TrunklineCostShareRecordEntity costShareRecordEntity = trunklineCostShareRecordService.findTotalUnloadNumByLoadAndWaybillNo(loadId, waybillNo);
 						carsLoadWaybillInfoVO.setCostPiece(costShareRecordEntity.getCostPiece());
@@ -2998,16 +3117,16 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
 					carsLoadOrderInfoVO.setLoadingNum(carsLoadScanAbnormalVO.getLoadingNum());
 					carsLoadOrderInfoVO.setUnloadNum(carsLoadScanAbnormalVO.getUnloadNum());
 					BigDecimal unloadIncome = finalFreightPrice.multiply(BigDecimal.valueOf(carsLoadScanAbnormalVO.getUnloadNum()));
-					carsLoadOrderInfoVO.setUnloadIncome(unloadIncome.setScale(2));
+					carsLoadOrderInfoVO.setUnloadIncome(unloadIncome.setScale(2,BigDecimal.ROUND_UP));
 					carsLoadOrderInfoVO.setPlanNum(0);
 					String orderCode = carsLoadScanAbnormalVO.getOrderCode();
 					if("--".equals(waybillNo) || "--".equals(orderCode)){
 						carsLoadOrderInfoVO.setOrderNum(0);
-						carsLoadOrderInfoVO.setOrderFreight(BigDecimal.ZERO.setScale(2));
+						carsLoadOrderInfoVO.setOrderFreight(BigDecimal.ZERO.setScale(2,BigDecimal.ROUND_UP));
 					}else{
 						Integer num = trunklineWaybillOrderService.findTotalNumByWaybillAndOrderCode(waybillNo, orderCode);
 						carsLoadOrderInfoVO.setOrderNum(num);
-						carsLoadOrderInfoVO.setOrderFreight(finalFreightPrice.multiply(BigDecimal.valueOf(num)).setScale(2));
+						carsLoadOrderInfoVO.setOrderFreight(finalFreightPrice.multiply(new BigDecimal(num)).setScale(2,BigDecimal.ROUND_UP));
 					}
 					TrunklineCostShareRecordEntity orderCostShareRecordEntity = trunklineCostShareRecordService.findTotalUnloadNumByLoadAndWaybillNoAndOrderCode(loadId,waybillNo,orderCode);
 					carsLoadOrderInfoVO.setCostZhang(orderCostShareRecordEntity.getCostZhang());
@@ -3501,7 +3620,11 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
 		}
 		updateNumByLoadId(loadId);
 
-		return R.success("卸车成功");
+		JSONObject jsonObject = trunklineCarsLoadScanService.findUnloadNumAudio(loadId, warehouseId);
+		Integer totalUnloadNum = jsonObject.getInteger("totalUnloadNum");
+		Integer abnormalUnloadNum = jsonObject.getInteger("abnormalUnloadNum");
+
+		return Resp.scanSuccess("卸车成功","卸车"+totalUnloadNum+"件,异常卸车"+abnormalUnloadNum+"件");
 	}
 
 	@Override
@@ -4243,6 +4366,9 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
 				carsLoadScanEntity.setLoadingAbnormal(1);
 				carsLoadScanEntity.setUnloadAbnormal(1);
 				carsLoadScanEntity.setUnloadNum(1);
+				carsLoadScanEntity.setUnloadUserName(AuthUtil.getNickName());
+				carsLoadScanEntity.setUnloadNodeId(warehouseId);
+				carsLoadScanEntity.setUnloadNodeName(warehouseEntity.getName());
 				carsLoadScanEntity.setSignTime(date);
 				carsLoadScanEntity.setSignAbnormal(1);
 				carsLoadScanEntity.setSignUserName(AuthUtil.getNickName());
@@ -4286,6 +4412,9 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
 				carsLoadScanEntity.setLoadingAbnormal(1);
 				carsLoadScanEntity.setUnloadAbnormal(1);
 				carsLoadScanEntity.setUnloadNum(1);
+				carsLoadScanEntity.setUnloadUserName(AuthUtil.getNickName());
+				carsLoadScanEntity.setUnloadNodeId(warehouseId);
+				carsLoadScanEntity.setUnloadNodeName(warehouseEntity.getName());
 				carsLoadScanEntity.setSignTime(date);
 				carsLoadScanEntity.setSignAbnormal(1);
 				carsLoadScanEntity.setSignUserName(AuthUtil.getNickName());
@@ -4304,6 +4433,18 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
 			}
 
 		} else {
+			String scanStatus = carsLoadScanEntity.getScanStatus();
+			if ("2".equals(scanStatus)) {
+				log.warn("##############signScanPackageCode: 包件已卸车 loadId={},orderPackageCode={} scanStatus={}", loadId, orderPackageCode, scanStatus);
+				return R.fail(405, "包件已卸车");
+			}
+
+			if ("3".equals(scanStatus)) {
+				log.warn("##############signScanPackageCode: 包件已签收 loadId={},orderPackageCode={} scanStatus={}", loadId, orderPackageCode, scanStatus);
+				return R.fail(405, "包件已签收");
+			}
+
+
 			Long fromWarehouseId = carsLoadScanEntity.getFromWarehouseId();
 			String waybillNo = carsLoadScanEntity.getWaybillNo();
 			DistributionParcelListEntity parcelListEntity = distributionParcelListClient.findByPacketBarCodeAndWarehouseId(orderPackageCode, fromWarehouseId);
@@ -4337,11 +4478,6 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
 				carsLoadScanEntity.setSignAbnormal(0);
 			}
 
-			String scanStatus = carsLoadScanEntity.getScanStatus();
-			if ("2".equals(scanStatus)) {
-				log.warn("##############signScanPackageCode: 包件已卸车 loadId={},orderPackageCode={} scanStatus={}", loadId, orderPackageCode, scanStatus);
-				return R.fail(405, "包件已卸车");
-			}
 			Long wid = carsLoadScanEntity.getWarehouseId();
 			if (!wid.equals(warehouseId)) {
 				log.warn("##############signScanPackageCode: 包件不在签收计划中 loadId={},orderPackageCode={} scanStatus={}", loadId, orderPackageCode, scanStatus);
@@ -4353,6 +4489,9 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
 			carsLoadScanEntity.setSignUserName(AuthUtil.getNickName());
 			carsLoadScanEntity.setSignOrderId(signOrderId);
 			carsLoadScanEntity.setUnloadTime(date);
+			carsLoadScanEntity.setUnloadUserName(AuthUtil.getNickName());
+			carsLoadScanEntity.setUnloadNodeId(warehouseId);
+			carsLoadScanEntity.setUnloadNodeName(warehouseEntity.getName());
 			trunklineCarsLoadScanService.updateById(carsLoadScanEntity);
 
 			//生成签收记录
@@ -4431,6 +4570,12 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
 		Long loadId = signOrderEntity.getLoadId();
 		Long warehouseId = signOrderEntity.getWarehouseId();
 
+		BasicdataWarehouseEntity warehouseEntity = basicdataWarehouseClient.getEntityWarehouseId(warehouseId);
+		if(Objects.isNull(warehouseEntity)){
+			log.warn("##############signZeroOrder: 仓库信息不存在 warehouseId={}", warehouseId);
+			return R.fail(405, "仓库信息不存在");
+		}
+
 		TrunklineCarsLoadScanEntity carsLoadScanEntity = trunklineCarsLoadScanService.getById(carsLoadScanId);
 		if (Objects.isNull(carsLoadScanEntity)) {
 			log.warn("##############signZeroOrder: 装车记录不存在 carsLoadScanId={}", carsLoadScanId);
@@ -4439,10 +4584,16 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
 
 		String scanStatus = carsLoadScanEntity.getScanStatus();
 		if ("2".equals(scanStatus)) {
-			log.warn("##############signZeroOrder: 包件已卸车 carsLoadScanId={} scanStatus={}", carsLoadScanId, scanStatus);
+			log.warn("##############signZeroOrder: 零担已卸车 carsLoadScanId={} scanStatus={}", carsLoadScanId, scanStatus);
 			return R.fail(405, "零担已卸车");
 		}
 
+		if ("3".equals(scanStatus)) {
+			log.warn("##############signZeroOrder: 零担已签收 carsLoadScanId={} scanStatus={}", carsLoadScanId, scanStatus);
+			return R.fail(405, "零担已签收");
+		}
+
+
 		Long wid = carsLoadScanEntity.getWarehouseId();
 		if (!wid.equals(warehouseId)) {
 			log.warn("##############signScanPackageCode: 包件不在签收计划中 loadId={} scanStatus={}", loadId, scanStatus);
@@ -4452,7 +4603,12 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
 		carsLoadScanEntity.setScanStatus("3");
 		carsLoadScanEntity.setUnloadNum(enterNum);
 		carsLoadScanEntity.setSignTime(date);
+		carsLoadScanEntity.setSignAbnormal(0);
+		carsLoadScanEntity.setSignUserName(AuthUtil.getNickName());
 		carsLoadScanEntity.setUnloadTime(date);
+		carsLoadScanEntity.setUnloadUserName(AuthUtil.getNickName());
+		carsLoadScanEntity.setUnloadNodeId(warehouseId);
+		carsLoadScanEntity.setUnloadNodeName(warehouseEntity.getName());
 		trunklineCarsLoadScanService.updateById(carsLoadScanEntity);
 
 		//生成签收记录
@@ -4885,6 +5041,12 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
 			log.warn("############signLoadScanByIds: 车辆配载信息不存在 loadId={}", loadId);
 			return R.fail(405, "车辆配载信息不存在");
 		}
+		String loadStatus = carsLoadEntity.getLoadStatus();
+		if("0".equals(loadStatus)){
+			log.warn("############signLoadScanByIds: 车辆还未发车 loadId={}", loadId);
+			return R.fail(405, "车辆还未发车");
+		}
+
 		Integer realLoadingNumber = carsLoadEntity.getRealLoadingNumber();
 
 		BasicdataWarehouseEntity warehouseEntity = basicdataWarehouseClient.getEntityWarehouseId(warehouseId);
@@ -4894,7 +5056,7 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
 		}
 		Date date = new Date();
 
-		trunklineCarsLoadScanService.updateScanStatusAndTime(loadScanIds, "3", new Date(),AuthUtil.getNickName());
+		trunklineCarsLoadScanService.updateScanStatusAndTime(loadScanIds, "3", new Date(),AuthUtil.getNickName(),warehouseId,warehouseEntity.getName());
 
 		List<String> orderPackageCodes = trunklineCarsLoadScanService.findSignListOrderPackageCodesByIds(loadScanIds);
 
@@ -5133,12 +5295,32 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
 	@Override
 	public R uploadSignPhoto(LoadCarsDTO loadCarsDTO) {
 		Long signOrderId = loadCarsDTO.getSignOrderId();
+		Long warehouseId = loadCarsDTO.getWarehouseId();
 		List<TrunklineLoadSignPhotoEntity> signPhotoList = loadCarsDTO.getSignPhotoList();
 		List<TrunklineLoadSignPhotoEntity> oldSignPhotoList = loadSignPhotoService.findBySignPhotoList(signOrderId);
 
 		loadSignPhotoService.removeBatchByIds(oldSignPhotoList);
 		loadSignPhotoService.saveBatch(signPhotoList);
 
+		TrunklineLoadSignOrderEntity signOrderEntity = trunklineLoadSignOrderService.getById(signOrderId);
+		if(Objects.isNull(signOrderEntity)){
+
+			TrunklineCarsLoadEntity carsLoadEntity = baseMapper.selectById(signOrderId);
+			if(!Objects.isNull(carsLoadEntity)){
+				//三方中转上传图片
+				TrunklineCarsLoadLineEntity carsLoadLineEntity = trunklineCarsLoadLineService.findEntityByLoadIdAndNodeId(signOrderId, warehouseId);
+				if(!Objects.isNull(carsLoadLineEntity)){
+					trunklineCarsLoadLogService.saveLog(carsLoadEntity, carsLoadLineEntity, CarsLoadLogTypeConstant.TRIPARTITE_TRANSFER_SIGNPHOTO.getValue());
+				}
+			}
+
+		}else{
+			//直发商家签收单
+
+
+		}
+
+
 		return R.success("添加成功");
 	}
 
@@ -5635,9 +5817,9 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
 		page.setSize(loadCarsDTO.getPageSize());
 
 		Date start = CommonUtil.getStartByDateStr(loadCarsDTO.getStartDate());
-		Date end = CommonUtil.getStartByDateStr(loadCarsDTO.getEndDate());
-		loadCarsDTO.setStartDate(CommonUtil.dateToStringGeneral(start));
-		loadCarsDTO.setEndDate(CommonUtil.dateToStringGeneral(end));
+		Date end = CommonUtil.getEndByDateStr(loadCarsDTO.getEndDate());
+		loadCarsDTO.setStartTime(start);
+		loadCarsDTO.setEndTime(end);
 
 		IPage<TrunklineCarsLoadVO> pageList = baseMapper.arriveUnloadPageList(page, loadCarsDTO);
 
@@ -5668,6 +5850,7 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
 			Integer realLoadingNumber = trunklineCarsLoadVO.getRealLoadingNumber();
 			Integer unloadNumber = trunklineCarsLoadVO.getUnloadNumber();
 			trunklineCarsLoadVO.setRealLoadingNumber(realLoadingNumber - unloadNumber);
+			trunklineCarsLoadVO.setTotalLoadingNum(realLoadingNumber);
 		}
 		pageList.setRecords(records);
 		return R.data(pageList);
@@ -5696,6 +5879,7 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
 			return R.fail(405, "配载计划节点信息不存在");
 		}
 		String unloadStatus = loadLineEntity.getUnloadStatus();
+		Integer unloadNumber = loadLineEntity.getUnloadNumber();
 		if (!"0".equals(unloadStatus)) {
 			log.warn("############unloadPackage: 当前网点已经卸车确认 loadId={} warehouseId={}", loadId, warehouseId);
 			return R.fail(405, "当前网点已经卸车确认");
@@ -5726,8 +5910,7 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
 		//先判断包件是否在配载计划的装车扫描中
 		QueryWrapper<TrunklineCarsLoadScanEntity> loadScanQueryWrapper = new QueryWrapper<>();
 		loadScanQueryWrapper.eq("load_id", loadId)
-			.eq("scan_code", orderPackageCode)
-			.eq("scan_status", "1");
+			.eq("scan_code", orderPackageCode);
 		TrunklineCarsLoadScanEntity carsLoadScanEntity = trunklineCarsLoadScanService.getOne(loadScanQueryWrapper);
 		//判断是否有装车扫描记录
 		if (Objects.isNull(carsLoadScanEntity)) {
@@ -5737,45 +5920,80 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
 			Long loadScanId = null;
 			if (Objects.isNull(parcelListEntity)) {
 				//没有包件数据
+				TrunklineAdvanceDetailEntity advanceDetailEntity = trunklineAdvanceDetailService.findEntityByOrderPackageCode(orderPackageCode);
+				if(!Objects.isNull(advanceDetailEntity)){
+					String packageStatus = advanceDetailEntity.getPackageStatus();
+					if("0".equals(packageStatus)){
+						InComingDTO inComingDTO = new InComingDTO();
+						inComingDTO.setOrderPackageCode(orderPackageCode);
+						inComingDTO.setIncomingType(incomingType);
+						inComingDTO.setWarehouseId(warehouseId);
+						inComingService.incomingPackage(inComingDTO);
 
-				InComingDTO inComingDTO = new InComingDTO();
-				inComingDTO.setOrderPackageCode(orderPackageCode);
-				inComingDTO.setIncomingType(incomingType);
-				inComingDTO.setWarehouseId(warehouseId);
-				inComingService.incomingPackage(inComingDTO);
-//				int code = r.getCode();
-//				if(code != 200){
-//					log.warn("##############unloadPackage: 包件入库失败");
-//				}
-
-				//需要补装车扫记录
-				TrunklineCarsLoadScanEntity trunklineCarsLoadScanEntity = new TrunklineCarsLoadScanEntity();
-				trunklineCarsLoadScanEntity.setWarehouseId(warehouseId);
-				trunklineCarsLoadScanEntity.setWarehouseName(warehouseName);
-				trunklineCarsLoadScanEntity.setLoadId(loadId);
-				trunklineCarsLoadScanEntity.setLoadCode(loadCode);
-				trunklineCarsLoadScanEntity.setScanCode(orderPackageCode);
-				trunklineCarsLoadScanEntity.setScanStatus("2");
-				trunklineCarsLoadScanEntity.setNum(1);
-				trunklineCarsLoadScanEntity.setType(1);
-				trunklineCarsLoadScanEntity.setIsData(0);
-				trunklineCarsLoadScanEntity.setLoadingAbnormal(1);
-				trunklineCarsLoadScanEntity.setUnloadAbnormal(1);
-				trunklineCarsLoadScanEntity.setUnloadNodeId(warehouseId);
-				trunklineCarsLoadScanEntity.setUnloadNum(1);
-				trunklineCarsLoadScanEntity.setIsSupple(0);
-				trunklineCarsLoadScanEntity.setLoadingUserName(AuthUtil.getNickName());
-				trunklineCarsLoadScanEntity.setUnloadUserName(AuthUtil.getNickName());
-				trunklineCarsLoadScanEntity.setUnloadTime(new Date());
-				trunklineCarsLoadScanService.save(trunklineCarsLoadScanEntity);
-				loadScanId = trunklineCarsLoadScanEntity.getId();
-
-				trunklineCarsLoadingLogService.savaLoadingLog(warehouseId, warehouseName, loadId, loadCode, null, null, null, orderPackageCode, 1,
-					1, 0, 1, trayId, trayCode, trayName, null, loadScanId, "无数据,补装车计划,异常装车");
-
-				trunklineCarsUnloadLogService.savaUnloadLog(warehouseId, warehouseName, loadId, loadCode, null, null, null, orderPackageCode, 1,
-					1, 0, 1, trayId, trayCode, trayName, null, loadScanId, "无数据,异常卸车");
+						//需要补装车扫记录
+						TrunklineCarsLoadScanEntity trunklineCarsLoadScanEntity = new TrunklineCarsLoadScanEntity();
+						trunklineCarsLoadScanEntity.setWarehouseId(warehouseId);
+						trunklineCarsLoadScanEntity.setWarehouseName(warehouseName);
+						trunklineCarsLoadScanEntity.setOrderCode(advanceDetailEntity.getOrderCode());
+						trunklineCarsLoadScanEntity.setWaybillId(advanceDetailEntity.getWaybillId());
+						trunklineCarsLoadScanEntity.setWaybillNo(advanceDetailEntity.getWaybillNo());
+						trunklineCarsLoadScanEntity.setLoadId(loadId);
+						trunklineCarsLoadScanEntity.setLoadCode(loadCode);
+						trunklineCarsLoadScanEntity.setScanCode(orderPackageCode);
+						trunklineCarsLoadScanEntity.setScanStatus("2");
+						trunklineCarsLoadScanEntity.setNum(1);
+						trunklineCarsLoadScanEntity.setType(1);
+						trunklineCarsLoadScanEntity.setIsData(1);
+						trunklineCarsLoadScanEntity.setLoadingAbnormal(1);
+						trunklineCarsLoadScanEntity.setUnloadAbnormal(1);
+						trunklineCarsLoadScanEntity.setUnloadNodeName(warehouseName);
+						trunklineCarsLoadScanEntity.setUnloadNodeId(warehouseId);
+						trunklineCarsLoadScanEntity.setUnloadNum(1);
+						trunklineCarsLoadScanEntity.setIsSupple(0);
+						trunklineCarsLoadScanEntity.setLoadingUserName(AuthUtil.getNickName());
+						trunklineCarsLoadScanEntity.setUnloadUserName(AuthUtil.getNickName());
+						trunklineCarsLoadScanEntity.setUnloadTime(new Date());
+						trunklineCarsLoadScanService.save(trunklineCarsLoadScanEntity);
+						loadScanId = trunklineCarsLoadScanEntity.getId();
+
+						trunklineCarsLoadingLogService.savaLoadingLog(warehouseId, warehouseName, loadId, loadCode, null, null, null, orderPackageCode, 1,
+							1, 1, 1, trayId, trayCode, trayName, null, loadScanId, "有数据,补装车计划,异常装车");
+
+						trunklineCarsUnloadLogService.savaUnloadLog(warehouseId, warehouseName, loadId, loadCode, null, null, null, orderPackageCode, 1,
+							1, 1, 1, trayId, trayCode, trayName, null, loadScanId, "有数据,异常卸车");
 
+					}
+				}else{
+					//需要补装车扫记录
+					TrunklineCarsLoadScanEntity trunklineCarsLoadScanEntity = new TrunklineCarsLoadScanEntity();
+					trunklineCarsLoadScanEntity.setWarehouseId(warehouseId);
+					trunklineCarsLoadScanEntity.setWarehouseName(warehouseName);
+					trunklineCarsLoadScanEntity.setLoadId(loadId);
+					trunklineCarsLoadScanEntity.setLoadCode(loadCode);
+					trunklineCarsLoadScanEntity.setOrderCode("--");
+					trunklineCarsLoadScanEntity.setScanCode(orderPackageCode);
+					trunklineCarsLoadScanEntity.setScanStatus("2");
+					trunklineCarsLoadScanEntity.setNum(1);
+					trunklineCarsLoadScanEntity.setType(1);
+					trunklineCarsLoadScanEntity.setIsData(0);
+					trunklineCarsLoadScanEntity.setLoadingAbnormal(1);
+					trunklineCarsLoadScanEntity.setUnloadAbnormal(1);
+					trunklineCarsLoadScanEntity.setUnloadNodeName(warehouseName);
+					trunklineCarsLoadScanEntity.setUnloadNodeId(warehouseId);
+					trunklineCarsLoadScanEntity.setUnloadNum(1);
+					trunklineCarsLoadScanEntity.setIsSupple(0);
+					trunklineCarsLoadScanEntity.setLoadingUserName(AuthUtil.getNickName());
+					trunklineCarsLoadScanEntity.setUnloadUserName(AuthUtil.getNickName());
+					trunklineCarsLoadScanEntity.setUnloadTime(new Date());
+					trunklineCarsLoadScanService.save(trunklineCarsLoadScanEntity);
+					loadScanId = trunklineCarsLoadScanEntity.getId();
+
+					trunklineCarsLoadingLogService.savaLoadingLog(warehouseId, warehouseName, loadId, loadCode, null, null, null, orderPackageCode, 1,
+						1, 0, 1, trayId, trayCode, trayName, null, loadScanId, "无数据,补装车计划,异常装车");
+
+					trunklineCarsUnloadLogService.savaUnloadLog(warehouseId, warehouseName, loadId, loadCode, null, null, null, orderPackageCode, 1,
+						1, 0, 1, trayId, trayCode, trayName, null, loadScanId, "无数据,异常卸车");
+				}
 			} else {
 				String waybillNumber = parcelListEntity.getWaybillNumber();
 				orderCode = parcelListEntity.getOrderCode();
@@ -5918,7 +6136,11 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
 			}
 
 		} else {
-//			carsLoadScanEntity.getS
+			String scanStatus = carsLoadScanEntity.getScanStatus();
+			if(!"1".equals(scanStatus)){
+				log.warn("##############unloadPackage: 包件已卸车 orderPackageCode={}", orderPackageCode);
+				return R.fail(405, "包件已卸车");
+			}
 
 			Long finalNodeId = carsLoadScanEntity.getFinalNodeId();
 			Long waybillId = carsLoadScanEntity.getWaybillId();
@@ -5958,81 +6180,91 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
 			if (1 == isData) {
 				DistributionParcelListEntity parcelListEntity = distributionParcelListClient.findByPacketBarCodeAndWarehouseId(orderPackageCode, fromWarehouseId);
 				if (Objects.isNull(parcelListEntity)) {
-					log.warn("##############unloadPackage: 包件信息不存在 orderPackageCode={} fromWarehouseId={}", orderPackageCode, fromWarehouseId);
-					return R.fail(405, "包件信息不存在");
-				}
-
-				Long currentOrderId = null;
-				//查询当前仓库订单信息有没有
-				DistributionStockArticleEntity stockArticleEntity = distributionStockArticleClient.findStockArticleByOrderCodeAndWarehouseId(orderCode, warehouseId);
-				if (Objects.isNull(stockArticleEntity)) {
-					//查询包件前面仓的订单信息
-					DistributionStockArticleEntity articleEntity = distributionStockArticleClient.findStockArticleByOrderCodeAndWarehouseId(orderCode, fromWarehouseId);
-					stockArticleEntity = new DistributionStockArticleEntity();
-					BeanUtil.copy(articleEntity, stockArticleEntity);
-					stockArticleEntity.setId(null);
-					stockArticleEntity.setWarehouseId(warehouseId);
-					stockArticleEntity.setWarehouse(warehouseName);
-					stockArticleEntity.setHandQuantity(0);
-					stockArticleEntity.setCompleteSet(1);
-					stockArticleEntity.setStockupStatus("10");
-					stockArticleEntity.setReservationStatus("10");
-					stockArticleEntity.setOrderStatus("10");
-					stockArticleEntity.setGroundingStatus("10");
-					stockArticleEntity.setOrderReceiveStatus("10");
-					stockArticleEntity.setFreezeStatus("10");
-					stockArticleEntity.setSortingQuantity(0);
-					stockArticleEntity.setDeliveryQuantity(0);
-					stockArticleEntity.setTransferQuantity(0);
-					stockArticleEntity.setSigninQuantity(0);
-					stockArticleEntity.setIncomingNum(0);
-					currentOrderId = distributionStockArticleClient.addData(stockArticleEntity);
-					stockArticleEntity.setId(currentOrderId);
-				} else {
-					currentOrderId = stockArticleEntity.getId();
-				}
-
-				//判断包件当前仓是否是目的仓
-				WarehouseWaybillEntity warehouseWaybillEntity = warehouseWaybillClient.findByWaybillNo(waybillNo);
-
-				if (Objects.isNull(distributionParcelListEntity)) {
-					distributionParcelListEntity = new DistributionParcelListEntity();
-					BeanUtil.copy(parcelListEntity, distributionParcelListEntity);
-					distributionParcelListEntity.setId(null);
-					distributionParcelListEntity.setOrderPackageStatus("20");
-					if (!Objects.isNull(warehouseWaybillEntity)) {
-						Long destinationWarehouseId = warehouseWaybillEntity.getDestinationWarehouseId();//目的仓
-						if (destinationWarehouseId.equals(warehouseId)) {
-							distributionParcelListEntity.setIsTransfer(0);
-						} else {
-							distributionParcelListEntity.setIsTransfer(1);
-						}
+					InComingDTO inComingDTO = new InComingDTO();
+					inComingDTO.setOrderPackageCode(orderPackageCode);
+					inComingDTO.setIncomingType(incomingType);
+					inComingDTO.setWarehouseId(warehouseId);
+					R r = inComingService.incomingPackage(inComingDTO);
+					int code = r.getCode();
+					if(code != 200){
+						log.warn("##############unloadPackage: 包件入库失败 orderPackageCode={}", orderPackageCode);
+						return R.fail(405, "包件入库失败");
 					}
-					distributionParcelListEntity.setWarehouseId(warehouseId);
-					distributionParcelListEntity.setWarehouse(warehouseName);
-					distributionParcelListEntity.setTrainNumber(loadCode);
-					distributionParcelListEntity.setStockArticleId(currentOrderId);
-					distributionParcelListEntity.setOrderPackageFreezeStatus("10");
-					distributionParcelListEntity.setOrderPackageGroundingStatus("10");
-					distributionParcelListEntity.setOrderPackageStockupStatus("10");
-					distributionParcelListEntity.setOrderPackageReservationStatus("10");
-					distributionParcelListEntity.setOrderPackageLoadingStatus("10");
-					distributionParcelListEntity.setWarehouseEntryTimeEnd(new Date());
-					boolean add = distributionParcelListClient.add(distributionParcelListEntity);
-					if (add) {
-						distributionStockArticleClient.addIncomingNum(currentOrderId, 1);
+//					parcelListEntity = distributionParcelListClient.findByPacketBarCodeAndWarehouseId(orderPackageCode, warehouseId);
+				}else{
+					Long currentOrderId = null;
+					//查询当前仓库订单信息有没有
+					DistributionStockArticleEntity stockArticleEntity = distributionStockArticleClient.findStockArticleByOrderCodeAndWarehouseId(orderCode, warehouseId);
+					if (Objects.isNull(stockArticleEntity)) {
+						//查询包件前面仓的订单信息
+						DistributionStockArticleEntity articleEntity = distributionStockArticleClient.findStockArticleByOrderCodeAndWarehouseId(orderCode, fromWarehouseId);
+						stockArticleEntity = new DistributionStockArticleEntity();
+						BeanUtil.copy(articleEntity, stockArticleEntity);
+						stockArticleEntity.setId(null);
+						stockArticleEntity.setWarehouseId(warehouseId);
+						stockArticleEntity.setWarehouse(warehouseName);
+						stockArticleEntity.setHandQuantity(0);
+						stockArticleEntity.setCompleteSet(1);
+						stockArticleEntity.setStockupStatus("10");
+						stockArticleEntity.setReservationStatus("10");
+						stockArticleEntity.setOrderStatus("10");
+						stockArticleEntity.setGroundingStatus("10");
+						stockArticleEntity.setOrderReceiveStatus("10");
+						stockArticleEntity.setFreezeStatus("10");
+						stockArticleEntity.setSortingQuantity(0);
+						stockArticleEntity.setDeliveryQuantity(0);
+						stockArticleEntity.setTransferQuantity(0);
+						stockArticleEntity.setSigninQuantity(0);
+						stockArticleEntity.setIncomingNum(0);
+						currentOrderId = distributionStockArticleClient.addData(stockArticleEntity);
+						stockArticleEntity.setId(currentOrderId);
+					} else {
+						currentOrderId = stockArticleEntity.getId();
 					}
-				} else {
-					if (!Objects.isNull(warehouseWaybillEntity)) {
-						Long destinationWarehouseId = warehouseWaybillEntity.getDestinationWarehouseId();//目的仓
-						if (destinationWarehouseId.equals(warehouseId)) {
-							distributionParcelListEntity.setIsTransfer(0);
-						} else {
-							distributionParcelListEntity.setIsTransfer(1);
+
+					//判断包件当前仓是否是目的仓
+					WarehouseWaybillEntity warehouseWaybillEntity = warehouseWaybillClient.findByWaybillNo(waybillNo);
+
+					if (Objects.isNull(distributionParcelListEntity)) {
+						distributionParcelListEntity = new DistributionParcelListEntity();
+						BeanUtil.copy(parcelListEntity, distributionParcelListEntity);
+						distributionParcelListEntity.setId(null);
+						distributionParcelListEntity.setOrderPackageStatus("20");
+						if (!Objects.isNull(warehouseWaybillEntity)) {
+							Long destinationWarehouseId = warehouseWaybillEntity.getDestinationWarehouseId();//目的仓
+							if (destinationWarehouseId.equals(warehouseId)) {
+								distributionParcelListEntity.setIsTransfer(0);
+							} else {
+								distributionParcelListEntity.setIsTransfer(1);
+							}
+						}
+						distributionParcelListEntity.setWarehouseId(warehouseId);
+						distributionParcelListEntity.setWarehouse(warehouseName);
+						distributionParcelListEntity.setTrainNumber(loadCode);
+						distributionParcelListEntity.setStockArticleId(currentOrderId);
+						distributionParcelListEntity.setOrderPackageFreezeStatus("10");
+						distributionParcelListEntity.setOrderPackageGroundingStatus("10");
+						distributionParcelListEntity.setOrderPackageStockupStatus("10");
+						distributionParcelListEntity.setOrderPackageReservationStatus("10");
+						distributionParcelListEntity.setOrderPackageLoadingStatus("10");
+						distributionParcelListEntity.setWarehouseEntryTimeEnd(new Date());
+						boolean add = distributionParcelListClient.add(distributionParcelListEntity);
+						if (add) {
+							distributionStockArticleClient.addIncomingNum(currentOrderId, 1);
 						}
+					} else {
+						if (!Objects.isNull(warehouseWaybillEntity)) {
+							Long destinationWarehouseId = warehouseWaybillEntity.getDestinationWarehouseId();//目的仓
+							if (destinationWarehouseId.equals(warehouseId)) {
+								distributionParcelListEntity.setIsTransfer(0);
+							} else {
+								distributionParcelListEntity.setIsTransfer(1);
+							}
+						}
+						distributionParcelListClient.update(distributionParcelListEntity);
 					}
-					distributionParcelListClient.update(distributionParcelListEntity);
 				}
+
 			} else {
 				//无数据
 				TrunklineAdvanceDetailEntity advanceDetailEntity = trunklineAdvanceDetailService.findEntityByOrderPackageCode(orderPackageCode);
@@ -6047,13 +6279,6 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
 						inComingDTO.setWarehouseId(warehouseId);
 						inComingService.incomingPackage(inComingDTO);
 
-						carsLoadScanEntity.setOrderCode(orderCode);
-						carsLoadScanEntity.setWaybillNo(waybillNo1);
-						carsLoadScanEntity.setUnloadUserName(AuthUtil.getNickName());
-						carsLoadScanEntity.setUnloadTime(new Date());
-						carsLoadScanEntity.setIsData(1);
-						isData = 1;
-						trunklineCarsLoadScanService.updateById(carsLoadScanEntity);
 					} else {
 						DistributionParcelListEntity parcelListEntity = distributionParcelListClient.findByOrderPackageCodeAndStatus(orderPackageCode);
 						if (!Objects.isNull(parcelListEntity)) {
@@ -6081,6 +6306,15 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
 							distributionParcelListClient.add(newParcelListEntity);
 						}
 					}
+
+					carsLoadScanEntity.setOrderCode(orderCode);
+					carsLoadScanEntity.setWaybillNo(waybillNo1);
+					carsLoadScanEntity.setUnloadUserName(AuthUtil.getNickName());
+					carsLoadScanEntity.setUnloadTime(new Date());
+					carsLoadScanEntity.setIsData(1);
+					isData = 1;
+					trunklineCarsLoadScanService.updateById(carsLoadScanEntity);
+
 				}
 			}
 		}
@@ -6127,13 +6361,18 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
 				log.error("入库推送失败：{}", e);
 			}
 		} catch (Exception e) {
-			log.warn("#########3卸车存入日志失败");
+			log.warn("#########卸车存入日志失败");
 		}
 
+		JSONObject jsonObject = trunklineCarsLoadScanService.findUnloadNumAudio(loadId,warehouseId);
+		Integer totalUnloadNum = jsonObject.getInteger("totalUnloadNum");
+		Integer abnormalUnloadNum = jsonObject.getInteger("abnormalUnloadNum");
+
+
 		if (isData == 0) {
 			return Resp.scanSuccess("卸车成功", "系统无编码");
 		}
-		return R.success("卸车成功");
+		return Resp.scanSuccess("卸车成功", "卸车"+totalUnloadNum+"件,异常卸车"+abnormalUnloadNum+"件");
 	}
 
 
@@ -6203,12 +6442,6 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
 		if (enterNun > num) {
 			log.warn("#############unloadZero: 零担信息卸车数量大于装车件数 enterNun={} num={}", enterNun, num);
 			return R.fail(405, "零担信息卸车数量大于装车件数");
-		} else {
-
-			Integer difficute = num - enterNun;
-			DistributionStockArticleEntity stockArticleEntity = distributionStockArticleClient.findStockArticleByOrderCodeAndWarehouseId(orderCode, fromWarehouseId);
-			Long orderId = stockArticleEntity.getId();
-			distributionStockArticleClient.addHandQuantity(orderId, difficute);
 		}
 
 		carsLoadScanEntity.setUnloadNum(enterNun);
@@ -6230,76 +6463,76 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
 			}
 		}
 
-		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<DistributionParcelListEntity> parcelListEntityList = distributionParcelListClient.findEntityListByOrderCode(orderCode, fromWarehouseId);
-				List<DistributionParcelNumberEntity> 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);
-		}
+//		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<DistributionParcelListEntity> parcelListEntityList = distributionParcelListClient.findEntityListByOrderCode(orderCode, fromWarehouseId);
+//				List<DistributionParcelNumberEntity> 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);
 
@@ -6370,7 +6603,7 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
 		}
 
 		//查询已装车的零担
-		List<UnloadZeroVO> zeroList = trunklineCarsOrderService.findUnloadZeroList(loadId, warehouseId);
+		List<UnloadZeroVO> zeroList = trunklineCarsLoadScanService.findUnloadZeroList(loadId, warehouseId);
 		for (UnloadZeroVO unloadZeroVO : zeroList) {
 			Integer loadingNum = unloadZeroVO.getLoadingNum();
 			String waybillNo = unloadZeroVO.getWaybillNo();

blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/TrunklineWaybillPackageServiceImpl.java

@@ -173,21 +173,19 @@ public class TrunklineWaybillPackageServiceImpl extends BaseServiceImpl<Trunklin
 			queryWrapper.in("order_package_code",orderPackageCodes)
 				.eq("is_deleted",0);
 			List<TrunklineWaybillPackageEntity> trunklineWaybillPackageEntities = baseMapper.selectList(queryWrapper);
-			if(trunklineWaybillPackageEntities.isEmpty()){
-				return;
-			}
-			for (TrunklineWaybillPackageEntity trunklineWaybillPackageEntity : trunklineWaybillPackageEntities) {
-				trunklineWaybillPackageEntity.setPackageStatus(packageStatus);
-				waybillIds.add(trunklineWaybillPackageEntity.getWaybillId());
-			}
+			if(!trunklineWaybillPackageEntities.isEmpty()){
+				for (TrunklineWaybillPackageEntity trunklineWaybillPackageEntity : trunklineWaybillPackageEntities) {
+					trunklineWaybillPackageEntity.setPackageStatus(packageStatus);
+					waybillIds.add(trunklineWaybillPackageEntity.getWaybillId());
+				}
 
-			updateBatchById(trunklineWaybillPackageEntities);
+				updateBatchById(trunklineWaybillPackageEntities);
 
-			for (Long waybillId : waybillIds) {
-				WarehouseWaybillEntity waybillEntity = warehouseWaybillClient.findByWaybillId(waybillId);
-				updateWaybillStatus(waybillEntity);
+				for (Long waybillId : waybillIds) {
+					WarehouseWaybillEntity waybillEntity = warehouseWaybillClient.findByWaybillId(waybillId);
+					updateWaybillStatus(waybillEntity);
+				}
 			}
-
 		}
 
 		packageTrackLogAsyncService.sendPackageWorkNodeFanout(orderPackageCodes,workNode,warehouseId, map);

blade-service/logpm-warehouse/src/main/java/com/logpm/warehouse/api/WarehouseTrayTypeApiController.java

@@ -1,5 +1,6 @@
 package com.logpm.warehouse.api;
 
+import cn.hutool.core.collection.CollUtil;
 import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.metadata.IPage;
@@ -8,6 +9,7 @@ import com.logpm.basicdata.entity.BasicdataTrayEntity;
 import com.logpm.basicdata.entity.BasicdataWarehouseEntity;
 import com.logpm.basicdata.feign.IBasicdataTrayClient;
 import com.logpm.basicdata.feign.IBasicdataWarehouseClient;
+import com.logpm.warehouse.dto.DownPackageCodeDTO;
 import com.logpm.warehouse.dto.TrayTypeDTO;
 import com.logpm.warehouse.dto.ZeroOrderVO;
 import com.logpm.warehouse.service.IWarehouseTaryAllocationService;
@@ -1438,4 +1440,71 @@ public class WarehouseTrayTypeApiController {
 		}
 	}
 
+
+	@ResponseBody
+	@PostMapping("/findPackageTrayInfo")
+	@ApiOperationSupport(order = 1)
+	@ApiOperation(value = "查询包件所在托盘", notes = "传入trayTypeDTO")
+	public R findPackageTrayInfo(@RequestBody TrayTypeDTO trayTypeDTO) {
+		String method = "###########findPackageTrayInfo: ";
+		log.info(method + "查询包件所在托盘 trayTypeDTO={}", trayTypeDTO);
+		String orderPackageCode = trayTypeDTO.getOrderPackageCode();
+
+		try{
+
+			BasicdataWarehouseEntity myCurrentWarehouse = warehouseClient.getMyCurrentWarehouse();
+			if(Objects.isNull(myCurrentWarehouse)){
+				log.warn(method+"仓库信息不能为空");
+				return R.fail(403,"仓库信息不能为空");
+			}
+
+			if(StringUtil.isBlank(orderPackageCode)){
+				log.warn(method+"包件码不能为空 orderPackageCode={}",orderPackageCode);
+				return R.fail(403,"包件码不能为空");
+			}
+
+			return warehouseTrayTypeService.findPackageTrayInfo(orderPackageCode,myCurrentWarehouse.getId());
+		}catch (CustomerException e){
+			log.warn(e.message);
+			return R.fail(e.code,e.message);
+		}catch (Exception e){
+			log.error(method+"系统异常，联系管理员",e);
+			return R.fail(500,"系统异常，联系管理员");
+		}
+	}
+
+
+	@ResponseBody
+	@PostMapping("/downPackageCodes")
+	@ApiOperationSupport(order = 1)
+	@ApiOperation(value = "解托包件", notes = "传入trayTypeDTO")
+	public R downPackageCodes(@RequestBody TrayTypeDTO trayTypeDTO) {
+		String method = "###########downPackageCodes: ";
+		log.info(method + "查询包件所在托盘 trayTypeDTO={}", trayTypeDTO);
+		List<DownPackageCodeDTO> downPackageCodeDTOS = trayTypeDTO.getDownPackageCodeDTOS();
+
+		try{
+
+			BasicdataWarehouseEntity myCurrentWarehouse = warehouseClient.getMyCurrentWarehouse();
+			if(Objects.isNull(myCurrentWarehouse)){
+				log.warn(method+"仓库信息不能为空");
+				return R.fail(403,"仓库信息不能为空");
+			}
+
+			if(CollUtil.isEmpty(downPackageCodeDTOS)){
+				log.warn(method+"解托数据不能为空");
+				return R.fail(403,"解托数据不能为空");
+			}
+
+			return warehouseTrayTypeService.downPackageCodes(downPackageCodeDTOS,myCurrentWarehouse.getId());
+		}catch (CustomerException e){
+			log.warn(e.message);
+			return R.fail(e.code,e.message);
+		}catch (Exception e){
+			log.error(method+"系统异常，联系管理员",e);
+			return R.fail(500,"系统异常，联系管理员");
+		}
+	}
+
+
 }

blade-service/logpm-warehouse/src/main/java/com/logpm/warehouse/dto/DownPackageCodeDTO.java

@@ -0,0 +1,13 @@
+package com.logpm.warehouse.dto;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+@Data
+public class DownPackageCodeDTO implements Serializable {
+
+	private String orderPackageCode;
+	private Long warehouseId;
+
+}

blade-service/logpm-warehouse/src/main/java/com/logpm/warehouse/dto/TrayTypeDTO.java

@@ -57,4 +57,6 @@ public class TrayTypeDTO implements Serializable {
 
 	private List<Long> trayGoodsIds = new ArrayList<>();
 
+	private List<DownPackageCodeDTO> downPackageCodeDTOS = new ArrayList<>();
+
 }

blade-service/logpm-warehouse/src/main/java/com/logpm/warehouse/service/IWarehouseTrayTypeService.java

@@ -3,6 +3,7 @@ package com.logpm.warehouse.service;
 import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.logpm.distribution.entity.DistributionParcelListEntity;
+import com.logpm.warehouse.dto.DownPackageCodeDTO;
 import com.logpm.warehouse.dto.TrayTypeDTO;
 import com.logpm.warehouse.dto.ZeroOrderVO;
 import com.logpm.warehouse.entity.WarehouseTrayTypeEntity;
@@ -118,4 +119,8 @@ public interface IWarehouseTrayTypeService extends BaseService<WarehouseTrayType
 
 
 	void orderScanOrderPackageCodeList(WarehouseTrayTypeEntity trayTypeEntity, List<DistributionParcelListEntity> parcelListEntityList, Long warehouseId, String remark);
+
+	R findPackageTrayInfo(String orderPackageCode, Long warehouseId);
+
+	R downPackageCodes(List<DownPackageCodeDTO> downPackageCodeDTOS, Long warehouseId);
 }

blade-service/logpm-warehouse/src/main/java/com/logpm/warehouse/service/impl/WarehouseTrayTypeServiceImpl.java

@@ -1,5 +1,6 @@
 package com.logpm.warehouse.service.impl;
 
+import cn.hutool.core.collection.CollUtil;
 import com.alibaba.fastjson.JSONObject;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
@@ -28,6 +29,7 @@ import com.logpm.trunkline.feign.ITrunklineAdvanceDetailClient;
 import com.logpm.trunkline.feign.ITrunklineDetailProductClient;
 import com.logpm.trunkline.feign.ITrunklineWaybillOrderClient;
 import com.logpm.warehouse.bean.Resp;
+import com.logpm.warehouse.dto.DownPackageCodeDTO;
 import com.logpm.warehouse.dto.TrayTypeDTO;
 import com.logpm.warehouse.dto.ZeroOrderVO;
 import com.logpm.warehouse.entity.*;
@@ -937,6 +939,71 @@ public class WarehouseTrayTypeServiceImpl extends BaseServiceImpl<WarehouseTrayT
 
 	}
 
+	@Override
+	public R findPackageTrayInfo(String orderPackageCode, Long warehouseId) {
+		QueryWrapper<WarehouseTrayGoodsEntity> queryWrapper = new QueryWrapper<>();
+		queryWrapper.eq("association_value",orderPackageCode)
+			.eq("association_type","3");
+		WarehouseTrayGoodsEntity trayGoodsEntity = warehouseTrayGoodsService.getOne(queryWrapper);
+		if(Objects.isNull(trayGoodsEntity)){
+			log.warn("##########findPackageTrayInfo: 包件暂未打托 orderPackageCode={}",orderPackageCode);
+			return R.fail(405,"包件暂未打托");
+		}
+
+		DistributionParcelListEntity parcelListEntity = distributionParcelListClient.findByPacketBarCodeAndWarehouseId(orderPackageCode, warehouseId);
+		if(Objects.isNull(parcelListEntity)){
+			log.warn("##########findPackageTrayInfo: 包件暂未入库 orderPackageCode={}",orderPackageCode);
+			return R.fail(405,"包件暂未入库");
+		}
+
+		Long trayWarehouseId = trayGoodsEntity.getWarehouseId();//打托仓库
+		BasicdataWarehouseEntity trayWarehouseEntity = basicdataWarehouseClient.getEntityWarehouseId(trayWarehouseId);
+		if(Objects.isNull(trayWarehouseEntity)){
+			log.warn("##########findPackageTrayInfo: 仓库信息为空 trayWarehouseId={}",trayWarehouseId);
+			return R.fail(405,"仓库信息为空");
+		}
+		String trayWarehouseName = trayWarehouseEntity.getName();
+		String trayCode = trayGoodsEntity.getTrayCode();
+		Long trayId = trayGoodsEntity.getTrayId();
+
+		BasicdataTrayEntity trayEntity = basicdataTrayClient.getTrayByTrayCode(trayCode);
+		if(Objects.isNull(trayEntity)){
+			log.warn("##########findPackageTrayInfo: 托盘信息不存在 trayCode={}",trayCode);
+			return R.fail(405,"托盘信息不存在");
+		}
+		String trayName = trayEntity.getPalletName();
+
+		Long trayAllocationId = warehouseTaryAllocationService.getAllocationIdByTrayId(trayId);
+		if(!Objects.isNull(trayAllocationId)){
+			log.warn("##########findPackageTrayInfo: 包件已在 {} 上架",trayWarehouseName);
+			return R.fail(405,"包件已在"+trayWarehouseName+"上架");
+		}
+
+		Map<String,Object> map = new HashMap<>();
+		map.put("waybillNo",parcelListEntity.getWaybillNumber());
+		map.put("orderCode",parcelListEntity.getOrderCode());
+		map.put("orderPackageCode",orderPackageCode);
+		map.put("trayName",trayName);
+		map.put("trayWarehouseName",trayWarehouseName);
+
+		return R.data(map);
+	}
+
+	@Override
+	public R downPackageCodes(List<DownPackageCodeDTO> downPackageCodeDTOS, Long warehouseId) {
+		//把downPackageCodeDTOS中元素通过warehouseId进行分组
+		Map<Long,List<DownPackageCodeDTO>> downPackageCodeDTOSMap = downPackageCodeDTOS.stream().collect(Collectors.groupingBy(DownPackageCodeDTO::getWarehouseId));
+
+		downPackageCodeDTOSMap.keySet().forEach(trayWarehouseId -> {
+			List<DownPackageCodeDTO> downPackageCodeDTOSList = downPackageCodeDTOSMap.get(trayWarehouseId);
+			if(CollUtil.isNotEmpty(downPackageCodeDTOSList)){
+				//把downPackageCodeDTOSList中所有元素的orderPackageCode放入一个List
+				List<String> orderPackageCodeList = downPackageCodeDTOSList.stream().map(DownPackageCodeDTO::getOrderPackageCode).collect(Collectors.toList());
+				downPackageByOrderPackageCodeList(orderPackageCodeList,"手动远程批量解托",trayWarehouseId);
+			}
+		});
+		return R.success("解绑成功");
+	}
 
 
 	@Override