推送零担调整

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

@@ -40,6 +40,7 @@ public interface IDistributionSignforClient {
     String API_PREFIX = "signfor/client";
     String TOP = API_PREFIX + "/top";
     String CLERKCHECKPUSHDATA = API_PREFIX + "/clerkCheckPushData";
+    String CLERKINVENTORYCHECKDATA = API_PREFIX + "/clerkInventoryCheckPushData";
 
     /**
      * 获取签收管理列表
@@ -64,4 +65,15 @@ public interface IDistributionSignforClient {
 	 */
 	@GetMapping(CLERKCHECKPUSHDATA)
 	Map<String,Object> clerkCheckPushData(@RequestParam("id") Long id);
+
+
+	/**
+	 * 推送老系统零担信息
+	 * @param params
+	 * @return
+	 */
+	@GetMapping(CLERKINVENTORYCHECKDATA)
+	Map<String, Object> clerkInventoryCheckPushData(@RequestParam("orderPackageCode")String orderPackageCode);
+
+
 }

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

@@ -116,6 +116,15 @@ public class DistributionSignforClient implements IDistributionSignforClient {
 
 	}
 
+	@Override
+	public Map<String, Object> clerkInventoryCheckPushData(String orderPackageCode) {
+
+
+
+		return null;
+	}
+
+
 	private void buildNameAndPhone(List<SignPushDataUnitDTO> pushOldPackageSigning) {
 		for (SignPushDataUnitDTO signPushDataUnitDTO : pushOldPackageSigning) {
 			User user = bladeRedis.get(RedisKeyConstant.USER_NAME_PHONE_KEY + signPushDataUnitDTO.getAdministratorsId());

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

@@ -368,4 +368,11 @@ public interface IDistributionSignforService extends BaseService<DistributionSig
 	 * @return
 	 */
 	List<DistributionAddvaluePackageDTO> checkAddValuePCPackageList(Long reservationId);
+
+	/**
+	 *
+	 * @param orderCode
+	 * @return
+	 */
+	Map<String, Object> clerkCheckPushZeroData(String orderCode);
 }

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

@@ -6557,10 +6557,12 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl<Distribution
 						List<SignPushDataUnitDTO> pushOldPackageLoading = distributionSignforMapper.selectPushOldPackageLoading(distributionSignforEntity.getReservationId(), distributionSignforEntity.getDeliveryId());
 						List<SignPushDataUnitDTO> pushOldPackageSigning = distributionSignforMapper.selectPushOldPackageSigning(distributionSignforEntity.getReservationId(), distributionSignforEntity.getDeliveryId());
 						if (Func.isNotEmpty(pushOldPackageLoading)) {
+							pushOldPackageLoading = handleSignPushDataUnitDTOList(pushOldPackageLoading);
 							buildNameAndPhone(pushOldPackageLoading);
 							signPushDataUnitDTOS.addAll(pushOldPackageLoading);
 						}
 						if (Func.isNotEmpty(pushOldPackageSigning)) {
+							pushOldPackageLoading = handleSignPushDataUnitDTOList(pushOldPackageSigning);
 							buildNameAndPhone(pushOldPackageSigning);
 							signPushDataUnitDTOS.addAll(pushOldPackageSigning);
 						}
@@ -6615,6 +6617,28 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl<Distribution
 
 	}
 
+	private List<SignPushDataUnitDTO> handleSignPushDataUnitDTOList(List<SignPushDataUnitDTO> pushOldPackageLoading) {
+		pushOldPackageLoading.stream().forEach(k->{
+			if (k.getGoods_type() == 3){
+				String unitNo = k.getUnitNo();
+				int indexOfUnitNo = unitNo.lastIndexOf("-");
+				if (indexOfUnitNo>0){
+					unitNo.substring(indexOfUnitNo);
+					k.setUnitNo(unitNo);
+				}
+				String orderSelfNum = k.getOrderSelfNum();
+				int indexOfOrderSelfNum = orderSelfNum.lastIndexOf("-");
+				if (indexOfUnitNo>0){
+					orderSelfNum.substring(indexOfUnitNo);
+					k.setOrderSelfNum(orderSelfNum);
+				}
+			}
+		});
+
+
+		return pushOldPackageLoading;
+	}
+
 	@Override
 	public DistributionSignforExcelDTO distributionSignforDetailExcel(Long id) {
 		DistributionSignforExcelDTO distributionSignforExcelDTO = new DistributionSignforExcelDTO();
@@ -6779,6 +6803,17 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl<Distribution
 		return list;
 	}
 
+	@Override
+	public Map<String, Object> clerkCheckPushZeroData(String orderCode) {
+
+
+
+
+
+
+		return null;
+	}
+
 	private void buildNameAndPhone(List<SignPushDataUnitDTO> pushOldPackageSigning) {
 		for (SignPushDataUnitDTO signPushDataUnitDTO : pushOldPackageSigning) {
 			User user = bladeRedis.get(RedisKeyConstant.USER_NAME_PHONE_KEY + signPushDataUnitDTO.getAdministratorsId());

blade-service/logpm-patch/src/main/java/com/logpm/patch/jobhandle/DistributionDatarepair.java

@@ -241,6 +241,32 @@ public class DistributionDatarepair {
 		return ReturnT.SUCCESS;
 	}
 
+	/**
+	 * 转库存品包件推送老系统
+	 *订单自编号
+	 * @return
+	 */
+	@XxlJob("pushInventorySingleNotification")
+	public ReturnT<String> pushInventorySingleNotification(String params) {
+		Map<String, Object> map = distributionSignforClient.clerkInventoryCheckPushData(params);
+		Long id = Long.parseLong(params);
+		Boolean b = (Boolean) map.get("result");
+		log.info(">>> 推送反馈信息  map :{}",map);
+		if (b != null && b) {
+			warehouseMappingDataMapper.updateClearSignforStatusBysignforId(Long.parseLong(params), 1);
+			log.info(">>> 推送成功 {}", Long.parseLong(params));
+		} else {
+			String remarks = (String) map.get("msg");
+			warehouseMappingDataMapper.updateClearSignforRemarks(id, remarks);
+			log.error(">>> 推送失败 id=" + Long.parseLong(params));
+		}
+		return ReturnT.SUCCESS;
+	}
+
+
+
+
+
 	/**
 	 * 推送自提签收老系统系统
 	 *

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

@@ -472,6 +472,7 @@ public class WarehouseWaybillServiceImpl extends BaseServiceImpl<WarehouseWaybil
 				}
 				//存入零担订单包件数量
 				distributionParcelNumberClient.addBatch(parcelNumberList);
+				//TODO  日志增加
 			}
 		}
 		distributionStockArticleClient.submitHandleNumAndTotalNumberByOrderId(subNum, articleId);