Merge branch 'dev' into pre-production

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

@@ -1870,6 +1870,10 @@ public class DistributionAsyncServiceImpl implements IDistributionAsyncService {
 					.eq(DistrilbutionBillPackageEntity::getBillLadingId, l)
 					.in(DistrilbutionBillPackageEntity::getParceListId, packageIds)
 				);
+				//增加释放日志
+
+
+
 			}
 			String collect = distributionParcelListEntities.stream().map(DistributionParcelListEntity::getOrderCode).distinct().collect(Collectors.joining(","));
 			distributionStockArticleService.maintenanceOrderInfo(collect, warehouseId);

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

@@ -126,6 +126,7 @@ import org.springblade.common.constant.order.OrderStatusConstant;
 import org.springblade.common.constant.orderpackage.OrderPackageLoadingStatusConstant;
 import org.springblade.common.constant.orderpackage.OrderPackageReservationStatusConstant;
 import org.springblade.common.constant.orderpackage.OrderPackageStatusConstant;
+import org.springblade.common.constant.orderpackage.OrderPackageStockupStatusConstant;
 import org.springblade.common.constant.pda.PdaAudioLingoStatus;
 import org.springblade.common.constant.reservation.ReservationOrderStatusConstant;
 import org.springblade.common.constant.reservation.ReservationPackageStatusConstant;
@@ -3614,7 +3615,7 @@ public class DistrilbutionBillLadingServiceImpl extends BaseServiceImpl<Distrilb
 //					}
 					if (integer != sum) {
 						//存在资源释放操作
-						distributionAsyncService.releaseBillLadingResource(Long.parseLong(s), myCurrentWarehouse.getId());
+						releaseBillLadingResource(Long.parseLong(s), myCurrentWarehouse,distrilbutionBillLadingEntity.getPickupBatch());
 					}
 					try {
 						if (sum > 0){
@@ -3730,6 +3731,49 @@ public class DistrilbutionBillLadingServiceImpl extends BaseServiceImpl<Distrilb
 		}
 	}
 
+	public void releaseBillLadingResource(Long l, BasicdataWarehouseEntity warehouse,String pickupBatch) {
+		List<DistrilbutionBillPackageEntity> list = distrilbutionBillPackageService.list(Wrappers.<DistrilbutionBillPackageEntity>query().lambda()
+			.eq(DistrilbutionBillPackageEntity::getBillLadingId, l)
+			.ne(DistrilbutionBillPackageEntity::getPacketBarStatus, 2)
+		);
+		if (Func.isNotEmpty(list)) {
+			List<Long> ids = list.stream().map(DistrilbutionBillPackageEntity::getParceListId).collect(Collectors.toList());
+			//查询包件
+			List<DistributionParcelListEntity> distributionParcelListEntities = distributionParcelListService.listByIds(ids);
+			List<Long> packageIds = distributionParcelListEntities.stream().filter(f -> !OrderPackageLoadingStatusConstant.yizhuangche.getValue().equals(f.getOrderPackageLoadingStatus()) || !OrderPackageStatusConstant.yiqianshou.getValue().equals(f.getOrderPackageStatus())).map(DistributionParcelListEntity::getId).collect(Collectors.toList());
+			if (Func.isNotEmpty(packageIds)) {
+				distributionParcelListService.update(new UpdateWrapper<DistributionParcelListEntity>().lambda()
+					.set(DistributionParcelListEntity::getOrderPackageReservationStatus, OrderPackageReservationStatusConstant.daiyuyue.getValue())
+					.set(DistributionParcelListEntity::getOrderPackageLoadingStatus, OrderPackageLoadingStatusConstant.weizhuancghe.getValue())
+					.set(DistributionParcelListEntity::getOrderPackageStatus, OrderPackageStatusConstant.yiruku.getValue())
+					.set(DistributionParcelListEntity::getOrderPackageStockupStatus, OrderPackageStockupStatusConstant.daibeihuo.getValue())
+					.in(DistributionParcelListEntity::getId, packageIds)
+				);
+				distrilbutionBillPackageService.update(new UpdateWrapper<DistrilbutionBillPackageEntity>().lambda()
+					.set(DistrilbutionBillPackageEntity::getPacketBarStatus, 2)
+					.eq(DistrilbutionBillPackageEntity::getBillLadingId, l)
+					.in(DistrilbutionBillPackageEntity::getParceListId, packageIds)
+				);
+				List<JSONObject> logList = new ArrayList<>();
+
+				for (DistributionParcelListEntity distributionParcelListEntity : distributionParcelListEntities) {
+					String content = "包件在" + warehouse.getName() + "由" + AuthUtil.getNickName() + "取消自提,操作方式:复核自提单包件释放,自提批次号:" + pickupBatch;
+					JSONObject logJS = handleLogJSONObject(warehouse, AuthUtil.getUser(), distributionParcelListEntity.getOrderPackageCode(), content, WorkNodeEnums.CANCEL_BILLOFLADING.getCode());
+					logList.add(logJS);
+				}
+				if (!logList.isEmpty()) {
+					trunklinePackageTrackLogClient.addPackageTrackLog(logList);
+				}
+
+			}
+			String collect = distributionParcelListEntities.stream().map(DistributionParcelListEntity::getOrderCode).distinct().collect(Collectors.joining(","));
+			distributionStockArticleService.maintenanceOrderInfo(collect, warehouse.getId());
+			//维护自提单订单信息
+			distrilbutionBillStockService.maintenanceOrderInfo(l);
+		}
+
+	}
+
 	private void sendFactory(BasicdataWarehouseEntity myCurrentWarehouse, Set<Long> parcelListIds) {
 		try {
 			// ladingScanEntities中的包件id数据封装为set