自提BUG修复

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

@@ -351,4 +351,10 @@ public interface IDistributionAsyncService {
 	 * @param s
 	 */
 	void sendFactorySignforInfo(String s,BasicdataWarehouseEntity warehouse,BladeUser user);
+
+	/**
+	 * 异步维护取消自提的单子信息
+	 * @param ids
+	 */
+    void maintenanceCancelBillLading(List<Long> ids);
 }

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

@@ -3066,6 +3066,25 @@ public class DistributionAsyncServiceImpl implements IDistributionAsyncService {
 		}
 	}
 
+	@Override
+	public void maintenanceCancelBillLading(List<Long> ids) {
+		for (Long id : ids) {
+			List<DistrilbutionBillPackageEntity> list = billPackageService.list(Wrappers.<DistrilbutionBillPackageEntity>query().lambda()
+				.eq(DistrilbutionBillPackageEntity::getBillLadingId, id)
+				.eq(DistrilbutionBillPackageEntity::getPacketBarStatus, ReservationPackageStatusConstant.quxiao.getValue())
+			);
+			if (!list.isEmpty()) {
+				List<Long> packageIds = list.stream().map(DistrilbutionBillPackageEntity::getParceListId).collect(Collectors.toList());
+				distributionParcelListService.update(Wrappers.<DistributionParcelListEntity>update().lambda()
+					.in(DistributionParcelListEntity::getId,packageIds)
+					.set(DistributionParcelListEntity::getOrderPackageReservationStatus,OrderPackageReservationStatusConstant.daiyuyue.getValue())
+				);
+				List<Long> orderIds = list.stream().map(DistrilbutionBillPackageEntity::getStockArticleId).distinct().collect(Collectors.toList());
+				distributionStockArticleService.maintenanceOrderInfoByIds(orderIds);
+			}
+		}
+	}
+
 	private void handlePushFactoryOrderIds(List<Long> orderIds, String s, BasicdataWarehouseEntity warehouse, BladeUser user) {
 		if (!orderIds.isEmpty()) {
 			List<DistributionStockArticleEntity> distributionStockArticleEntities = distributionStockArticleService.list(Wrappers.<DistributionStockArticleEntity>query().lambda()

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

@@ -2217,7 +2217,6 @@ public class DistributionStockArticleServiceImpl extends BaseServiceImpl<Distrib
 					if ((loadingQuantity + deliveryQuantity) == 0) {
 						if (stockArticleEntity.getTotalNumber() == inWarehouseQuantity) {
 							stockArticleEntity.setOrderStatus(OrderStatusConstant.ruku.getValue());
-							stockArticleEntity.setReservationStatus(OrderReservationStatusConstant.daiyuyue.getValue());
 						} else if (inWarehouseQuantity > 0) {
 							stockArticleEntity.setOrderStatus(OrderStatusConstant.bufenruku.getValue());
 						}
@@ -2228,6 +2227,7 @@ public class DistributionStockArticleServiceImpl extends BaseServiceImpl<Distrib
 						} else if ((loadingQuantity + deliveryQuantity) > 0) {
 							stockArticleEntity.setReservationStatus(OrderReservationStatusConstant.bufenyuyue.getValue());
 						}
+
 					}
 					if (signingQuantity == 0) {
 						stockArticleEntity.setOrderStatus(OrderStatusConstant.ruku.getValue());

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

@@ -942,6 +942,8 @@ public class DistrilbutionBillLadingServiceImpl extends BaseServiceImpl<Distrilb
 						distributionStockupInfoService.updateById(distributionStockupInfoEntity);
 					}
 				}
+				//对自提所有的包件进行状态恢复
+				distributionAsyncService.maintenanceCancelBillLading(ids);
 				return R.status(true);
 			case 1:
 				return R.fail("未授权!!!");