From 35f0079d7ed8da8353a7fdd37b8500c12b740360 Mon Sep 17 00:00:00 2001
From: PigBaoBei <2739175034@qq.com>
Date: Sat, 19 Oct 2024 19:39:17 +0800
Subject: [PATCH] =?UTF-8?q?=E5=90=8E=E5=8F=B0=E7=AD=BE=E6=94=B6=E5=BA=93?=
 =?UTF-8?q?=E5=AD=98=E5=93=81BUG=E4=BF=AE=E5=A4=8D?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../controller/DistributionReservationController.java  |  8 ++++++++
 .../service/impl/DistributionSignforServiceImpl.java   | 10 ++++++----
 2 files changed, 14 insertions(+), 4 deletions(-)

diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/controller/DistributionReservationController.java b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/controller/DistributionReservationController.java
index 18112794f..03e0c3a1f 100644
--- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/controller/DistributionReservationController.java
+++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/controller/DistributionReservationController.java
@@ -19,6 +19,7 @@ package com.logpm.distribution.controller;
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
 import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.github.xiaoymin.knife4j.annotations.ApiOperationSupport;
 import com.logpm.basicdata.entity.BasicdataWarehouseEntity;
 import com.logpm.basicdata.feign.IBasicdataWarehouseClient;
@@ -96,9 +97,14 @@ public class DistributionReservationController extends BladeController {
 	@ApiOperation(value = "分页", notes = "传入distrbutionReservation")
 	public R<IPage<DistributionReservationVO>> list(@ApiIgnore @RequestParam Map<String, Object> distrbutionReservation, Query query) {
 		String excludeId = (String) distrbutionReservation.get("excludeId");
+		String reservationStatus = (String) distrbutionReservation.get("reservationStatus");
 		if (Func.isNotEmpty(excludeId)){
 			distrbutionReservation.remove("excludeId");
 		}
+
+		if (!Objects.isNull(reservationStatus)){
+			distrbutionReservation.remove("reservationStatus");
+		}
 		QueryWrapper<DistributionReservationEntity> queryWrapper = Condition.getQueryWrapper(distrbutionReservation, DistributionReservationEntity.class);
 		//获取当前登录人仓库
 		List<BasicdataWarehouseEntity> myWatchWarehouse = basicdataWarehouseClient.getMyWatchWarehouse();
@@ -111,7 +117,9 @@ public class DistributionReservationController extends BladeController {
 			List<Long> ids = Func.toLongList(",", excludeId);
 			lambda.notIn(DistributionReservationEntity::getId,ids);
 		}
+
 		lambda.orderByDesc(DistributionReservationEntity::getCreateTime);
+		lambda.eq(!Objects.isNull(reservationStatus),DistributionReservationEntity::getReservationStatus,reservationStatus);
 		IPage<DistributionReservationEntity> pages = reservationService.page(Condition.getPage(query),lambda );
 		pages.getRecords().forEach(i ->{
 			R<User> userR = userClient.userInfoById(i.getCreateUser());
diff --git a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionSignforServiceImpl.java b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionSignforServiceImpl.java
index 28a847dac..f87e7fa63 100644
--- a/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionSignforServiceImpl.java
+++ b/blade-service/logpm-distribution/src/main/java/com/logpm/distribution/service/impl/DistributionSignforServiceImpl.java
@@ -960,8 +960,8 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl<Distribution
 						loadscaninvnEntity.setSigningTime(simpleDateFormat.format(new Date()));
 						loadscaninvnEntity.setOneQclick(1);
 						distributionLoadscaninvnService.updateById(loadscaninvnEntity);
-						//维护签收数量
-						Integer j = distributionSignforMapper.updatesignforByinvn(loadscaninvnEntity.getDeliveryId(), loadscaninvnEntity.getReservationId(), loadscaninvnEntity.getPackageNub());
+//						//维护签收数量
+//						Integer j = distributionSignforMapper.updatesignforByinvn(loadscaninvnEntity.getDeliveryId(), loadscaninvnEntity.getReservationId(), loadscaninvnEntity.getPackageNub());
 						//更新签收人
 						Integer i = distributionSignforMapper.updateSignUser(loadscaninvnEntity.getDeliveryId(), loadscaninvnEntity.getReservationId(), user);
 					} else {
@@ -1027,8 +1027,8 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl<Distribution
 						distributionLoadscaninvnEntity.setSigningUserId(user.getUserId());
 						distributionLoadscaninvnEntity.setSigningTime(simpleDateFormat.format(new Date(System.currentTimeMillis() + (6 * 1000))));
 						distributionLoadscaninvnService.save(distributionLoadscaninvnEntity);
-						//更新装车数量
-						Integer j = distributionSignforMapper.updateLoadAndsignforByinvn(distributionLoadscaninvnEntity.getDeliveryId(), distributionLoadscaninvnEntity.getReservationId(), distributionLoadscaninvnEntity.getPackageNub());
+//						//更新装车数量
+//						Integer j = distributionSignforMapper.updateLoadAndsignforByinvn(distributionLoadscaninvnEntity.getDeliveryId(), distributionLoadscaninvnEntity.getReservationId(), distributionLoadscaninvnEntity.getPackageNub());
 						//更新签收人
 						Integer i = distributionSignforMapper.updateSignUser(distributionLoadscaninvnEntity.getDeliveryId(), distributionLoadscaninvnEntity.getReservationId(), AuthUtil.getUser());
 						//扣减库存
@@ -1056,6 +1056,8 @@ public class DistributionSignforServiceImpl extends BaseServiceImpl<Distribution
 			}
 			warehouseUpdownStockUpAreaClient.downStockUpShelf(jsonObjects);
 		}
+		//维护签收数量
+		this.maintenanceSignfor(distrilbutionloadingscanDTO.getReservationId());
 		return R.status(true);
 	}