From a783f501ca98856680b508d269c70a6e76140df4 Mon Sep 17 00:00:00 2001
From: PigBaoBei <2739175034@qq.com>
Date: Tue, 23 Jan 2024 16:49:18 +0800
Subject: [PATCH] =?UTF-8?q?=E8=87=AA=E6=8F=90=E5=8F=96=E6=B6=88=E8=BF=87?=
 =?UTF-8?q?=E6=BB=A4=E6=9D=A1=E4=BB=B6=E3=80=81=E8=87=AA=E6=8F=90=E5=AF=BC?=
 =?UTF-8?q?=E5=87=BA=E4=BF=AE=E5=A4=8D?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../DistrilbutionBillLadingController.java    |  2 +-
 .../mapper/DistrilbutionBillLadingMapper.xml  | 64 +++++++++----------
 .../IDistrilbutionBillLadingService.java      |  2 +-
 .../DistrilbutionBillLadingServiceImpl.java   | 30 ++++++++-
 4 files changed, 60 insertions(+), 38 deletions(-)

diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/controller/DistrilbutionBillLadingController.java b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/controller/DistrilbutionBillLadingController.java
index 3bada1f38..ea322394a 100644
--- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/controller/DistrilbutionBillLadingController.java
+++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/controller/DistrilbutionBillLadingController.java
@@ -279,7 +279,7 @@ public class DistrilbutionBillLadingController extends BladeController {
 	@ApiOperationSupport(order = 1)
 	@ApiOperation(value = "批量取消自提单", notes = "传入distrilbutionBillLading")
 	public R cancelBillLoding(@Valid @RequestBody DistrilbutionBillLadingDTO distrilbutionBillLadingDTO) {
-		return R.status(distrilbutionBillLadingService.cancelBillLoding(distrilbutionBillLadingDTO.getBillLodingIds()));
+		return distrilbutionBillLadingService.cancelBillLoding(distrilbutionBillLadingDTO.getBillLodingIds());
 	}
 
 
diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistrilbutionBillLadingMapper.xml b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistrilbutionBillLadingMapper.xml
index dbaa527f5..71ad97c65 100644
--- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistrilbutionBillLadingMapper.xml
+++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/mapper/DistrilbutionBillLadingMapper.xml
@@ -121,40 +121,35 @@
     </select>
 
     <select id="exportDistributionBillLading" resultType="com.logpm.distribution.vo.DistrilbutionBillLadingVO">
-        select dbl.id,
-               dsa.service_number serviceNumber,
-               dsa.waybill_number waybillNumber,
-               dsa.consignee_unit consigneeUnit,
-               dsa.customer_name customerName,
-               dsa.customer_telephone customerTelephone,
-               dsa.warehouse,
-               dsa.warehouse_entry_time warehouseEntryTime,
-               dsa.storage_fee storageFee,
-               dsa.total_number totalNumber,
-               dbl.certificate_type certificateType,
-               dsa.brand,
-               dsa.type_service typeService,
-               dbl.pick_up_time pickUpTime,
-               dbl.consignee,
-               dbl.delivery_document deliveryDocument,
-               dbl.conditions,
-               dbl.total_cost totalCost,
-               dbl.pick_up_plate pickUpPlate,
-               dbl.pickup_batch pickupBatch,
-                (
-                select COUNT(lds.id)
-                from logpm_distribution_delivery_details lddd
-                LEFT JOIN logpm_distribution_stock lds on lds.stock_list_id = lddd.stock_list_id
-                where lddd.bill_lading_id = dbl.id
-                ) + (
-                select COUNT(lds.id)
-                from logpm_distrilbution_bill_stock ldbs
-                LEFT JOIN logpm_distribution_stock lds on lds.stock_article = ldbs.stock_article_id
-                where ldbs.bill_lading_id = dbl.id
-                ) stopNum
-        from logpm_distrilbution_bill_lading dbl
-        LEFT JOIN logpm_distribution_stock_article dsa
-        on dbl.stock_article_id = dsa.id
+        SELECT
+        dbl.id,
+        dsa.service_number AS serviceNumber,
+        dsa.waybill_number AS waybillNumber,
+        dsa.consignee_unit AS consigneeUnit,
+        dsa.customer_name AS customerName,
+        dsa.customer_telephone AS customerTelephone,
+        dsa.warehouse,
+        dsa.warehouse_entry_time AS warehouseEntryTime,
+        dsa.storage_fee AS storageFee,
+        (count(DISTINCT ldbp.id,0)+count(DISTINCT lddd.quantity,0)) AS totalNumber,
+        dbl.certificate_type AS certificateType,
+        dsa.brand,
+        dsa.type_service AS typeService,
+        dbl.pick_up_time AS pickUpTime,
+        dbl.consignee,
+        dbl.delivery_document AS deliveryDocument,
+        dbl.conditions,
+        dbl.total_cost AS totalCost,
+        dbl.pick_up_plate AS pickUpPlate,
+        dbl.pickup_batch AS pickupBatch,
+        count(DISTINCT ldbls.id ) AS stopNum
+        FROM
+        logpm_distrilbution_bill_lading dbl
+        LEFT JOIN logpm_distrilbution_bill_stock AS ldbs ON ldbs.bill_lading_id = dbl.id AND ldbs.order_status != 3
+        LEFT JOIN logpm_distribution_stock_article dsa ON ldbs.stock_article_id = dsa.id
+        LEFT JOIN logpm_distrilbution_bill_package AS ldbp ON ldbp.stock_article_id = dsa.id AND ldbp.bill_lading_id = dbl.id AND ldbp.packet_bar_status != 3
+        LEFT JOIN logpm_distribution_delivery_details AS lddd ON   lddd.bill_lading_id = dbl.id AND lddd.inventory_status != 3
+        LEFT JOIN logpm_distribution_bill_lading_scan ldbls ON ldbls.bill_lading_id = dbl.id
         <where>
             dbl.is_deleted = 0
             <if test="param.serviceNumber != null and param.serviceNumber != ''">
@@ -219,6 +214,7 @@
             </if>
 
         </where>
+        GROUP BY dbl.id
     </select>
 
     <select id="selectDistrilbutionBillLadingPage" resultMap="distrilbutionBillLadingResultMap">
diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/IDistrilbutionBillLadingService.java b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/IDistrilbutionBillLadingService.java
index 67f1d18de..a402c65fd 100644
--- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/IDistrilbutionBillLadingService.java
+++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/IDistrilbutionBillLadingService.java
@@ -220,5 +220,5 @@ public interface IDistrilbutionBillLadingService extends BaseService<Distrilbuti
 	 * @param billLodingIds
 	 * @return
 	 */
-	boolean cancelBillLoding(String billLodingIds);
+	R cancelBillLoding(String billLodingIds);
 }
diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistrilbutionBillLadingServiceImpl.java b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistrilbutionBillLadingServiceImpl.java
index 12acdfc28..2a10959bb 100644
--- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistrilbutionBillLadingServiceImpl.java
+++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistrilbutionBillLadingServiceImpl.java
@@ -646,9 +646,35 @@ public class DistrilbutionBillLadingServiceImpl extends BaseServiceImpl<Distrilb
 	}
 
 	@Override
-	public boolean cancelBillLoding(String billLodingIds) {
+	public R cancelBillLoding(String billLodingIds) {
+		String method = "##########类DistrilbutionBillLadingServiceImpl执行方法cancelBillLoding,";
+		List<Long> ids = Func.toLongList(",", billLodingIds);
+		List<DistrilbutionBillLadingEntity> distrilbutionBillLadingEntities = this.listByIds(ids);
+		if (Func.isEmpty(distrilbutionBillLadingEntities)){
+			log.error(method+"查询自提单信息失败:{}",billLodingIds);
+			return R.fail("服务器正忙，请联系管理员!!!");
+		}
+		String errorBillLading = distrilbutionBillLadingEntities.stream().filter(f -> !f.getConditions().equals(BillLadingStatusConstant.daitihuo.getValue())).map(DistrilbutionBillLadingEntity::getPickupBatch).collect(Collectors.joining(","));
+		if (Func.isNotEmpty(errorBillLading)){
+			log.error(method+"存在已提货或签收自提单:{}",errorBillLading);
+			return R.fail(errorBillLading+"已提货或已签收!!!");
+		}
+		//查询是否存在自提扫描的有效包件
+		List<DistributionBillLadingScanEntity> ladingScanEntities = distributionBillLadingScanService.list(Wrappers.<DistributionBillLadingScanEntity>query().lambda()
+			.in(DistributionBillLadingScanEntity::getBillLadingId, ids)
+		);
+		if (Func.isNotEmpty(ladingScanEntities)){
+			log.error(method+"取消自提单存在自提扫描数据:{}",errorBillLading);
+			return R.fail(errorBillLading+"已提货或已签收!!!");
+		}
 
-		return false;
+		//满足进行取消自提，进行自提单的资源释放
+
+
+
+
+
+		return R.status(true);
 	}
 
 	/**