From eae5b71ac4d99b7682a4e9c1212c1ab267a12f87 Mon Sep 17 00:00:00 2001
From: PigBaoBei <2739175034@qq.com>
Date: Sun, 22 Sep 2024 23:49:24 +0800
Subject: [PATCH] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E5=8F=91=E8=BD=A6=E5=88=A4?=
 =?UTF-8?q?=E6=96=AD=E6=8E=A5=E5=8F=A3?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../DistributionDeliveryAppController.java    | 11 ++++
 .../IDistributionDeliveryListService.java     |  8 +++
 .../DistributionDeliveryListServiceImpl.java  | 59 +++++++++++++++++++
 3 files changed, 78 insertions(+)

diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/api/DistributionDeliveryAppController.java b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/api/DistributionDeliveryAppController.java
index 5a9491cdd..ac791c42b 100644
--- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/api/DistributionDeliveryAppController.java
+++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/api/DistributionDeliveryAppController.java
@@ -309,6 +309,17 @@ public class DistributionDeliveryAppController {
 		return msg;
 	}
 
+
+	/**
+	 * 配送管理 发车
+	 */
+	@PostMapping("/isStart")
+	@ApiOperationSupport(order = 7)
+	@ApiOperation(value = "发车", notes = "传入DistrilbutionloadingscanDTO")
+	public R isStart(@Valid @RequestBody DistrilbutionloadingscanDTO distrilbutionloadingscanDTO) {
+		return distributionDeliveryListService.isStart(distrilbutionloadingscanDTO);
+	}
+
 	/**
 	 * 配送管理 发车
 	 */
diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/IDistributionDeliveryListService.java b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/IDistributionDeliveryListService.java
index cf1dccc69..87c1ec364 100644
--- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/IDistributionDeliveryListService.java
+++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/IDistributionDeliveryListService.java
@@ -568,6 +568,14 @@ public interface IDistributionDeliveryListService extends BaseService<Distributi
 	 */
 	boolean retentionReservationZeroPackageByNum(Long deliveryId, Long reservationId, Long orderPackageId, Integer retentionQuantity, Long orderId);
 
+	/**
+	 * 是否可以发车
+	 * @param distrilbutionloadingscanDTO
+	 * @return
+	 */
+	R isStart(DistrilbutionloadingscanDTO distrilbutionloadingscanDTO);
+
+
 
 //	/**
 //	 * 滞留取消配送
diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionDeliveryListServiceImpl.java b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionDeliveryListServiceImpl.java
index 8a6c97cd9..fb4af2177 100644
--- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionDeliveryListServiceImpl.java
+++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionDeliveryListServiceImpl.java
@@ -4794,6 +4794,36 @@ public class DistributionDeliveryListServiceImpl extends BaseServiceImpl<Distrib
 			);
 		}
 	}
+	private boolean judgeIsStart(DistributionDeliveryListEntity distributionDeliveryList, BasicdataWarehouseEntity warehouseEntity) {
+		List<DistributionParcelListEntity> distributionParcelListEntities = baseMapper.selectPackageListByDeliveryListId(distributionDeliveryList.getId());
+		List<DistributionLoadscanAbnormalEntity> abnormalEntityList = new ArrayList<>();
+		if (!distributionParcelListEntities.isEmpty()) {
+			for (DistributionParcelListEntity distributionParcelListEntity : distributionParcelListEntities) {
+				if (OrderPackageLoadingStatusConstant.weizhuancghe.getValue().equals(distributionParcelListEntity.getOrderPackageLoadingStatus())) {
+					DistributionLoadscanAbnormalEntity packageLoadscanAbnormalEntity = createdPakcageAbnormal(distributionDeliveryList, distributionParcelListEntity, warehouseEntity);
+					abnormalEntityList.add(packageLoadscanAbnormalEntity);
+				}
+			}
+		}
+		List<DisStockListDetailEntity> disStockListDetailEntities = baseMapper.selectInventoryListByDeliveryListId(distributionDeliveryList.getId());
+		if (!disStockListDetailEntities.isEmpty()) {
+			for (DisStockListDetailEntity disStockListDetailEntity : disStockListDetailEntities) {
+				if (InventoryLoadingStatusConstant.weizhuangche.getValue().equals(disStockListDetailEntity.getStockLockingStatus())) {
+					DistributionLoadscanAbnormalEntity inventoryLoadscanAbnormalEntity = createdInventoryPakcageAbnormal(distributionDeliveryList, disStockListDetailEntity, warehouseEntity);
+					abnormalEntityList.add(inventoryLoadscanAbnormalEntity);
+				}
+			}
+		}
+		//零担
+		List<DistributionLoadscanAbnormalEntity> zeroLoadscanAbnormalList = baseMapper.selectZeroListByDeliveryId(distributionDeliveryList.getId());
+		if (!zeroLoadscanAbnormalList.isEmpty()) {
+			abnormalEntityList.addAll(zeroLoadscanAbnormalList);
+		}
+		if (!abnormalEntityList.isEmpty()) {
+			return false;
+		}
+		return true;
+	}
 
 	private DistributionLoadscanAbnormalEntity createdPakcageAbnormal(DistributionDeliveryListEntity distributionDeliveryList, DistributionParcelListEntity distributionParcelListEntity, BasicdataWarehouseEntity warehouseEntity) {
 		DistributionLoadscanAbnormalEntity distributionLoadscanAbnormalEntity = new DistributionLoadscanAbnormalEntity();
@@ -9570,6 +9600,35 @@ public class DistributionDeliveryListServiceImpl extends BaseServiceImpl<Distrib
 		return true;
 	}
 
+	@Override
+	public R isStart(DistrilbutionloadingscanDTO distrilbutionloadingscanDTO) {
+		String method = "#########################DistributionStockArticleController.loadingStart";
+		if (Objects.isNull(distrilbutionloadingscanDTO.getDeliveryId())) {
+			log.error(method + "参数缺失DeliveryId()");
+			return Resp.fail("参数缺失,请联系管理员");
+		}
+		BasicdataWarehouseEntity myCurrentWarehouse = warehouseClient.getMyCurrentWarehouse();
+		if (Objects.isNull(myCurrentWarehouse)) {
+			return R.fail(403, "未授权!!!");
+		}
+		BladeUser user = AuthUtil.getUser();
+		//获取当前用户司机
+		DistributionDeliveryListEntity distributionDeliveryListEntity = distributionDeliveryListMapper.selectById(distrilbutionloadingscanDTO.getDeliveryId());
+		if (DeliveryStatusConstant.yiwancheng.getValue().equals(distributionDeliveryListEntity.getDeliveryStatus())) {
+			return Resp.scanFail("该任务已完结！", "该任务已完结!");
+		}
+		if (Integer.parseInt(IsOrNoConstant.yes.getValue()) == distributionDeliveryListEntity.getIsStart()) {
+			return Resp.scanFail("该车次已发车！", "该车次已发车!");
+		}
+		Boolean isDriverFlag = judgeIsDriver(user);
+		if (!isDriverFlag) {
+			return Resp.scanFail("当前操作人必须是司机！", "当前操作人必须是司机!");
+		}
+		boolean flag = judgeIsStart(distributionDeliveryListEntity, myCurrentWarehouse);
+
+		return Resp.status(flag);
+	}
+
 	private DistributionRetentionScanEntity buildZeroRetentionEntity(DistributionLoadscanEntity loadscanEntity) {
 		DistributionRetentionScanEntity packageRetentionScanEntity = new DistributionRetentionScanEntity();