fix:增加部分接口的异常处理能力，删除部分无效代码

blade-service/logpm-distribution/src/main/java/com/logpm/distribution/api/DistributionAddvalueAppController.java

@@ -5,10 +5,8 @@ import com.github.xiaoymin.knife4j.annotations.ApiOperationSupport;
 import com.logpm.distribution.dto.DistributionAddvaluePackageDTO;
 import com.logpm.distribution.dto.app.DistributionAppAddvalueDTO;
 import com.logpm.distribution.service.IDistributionAddvalueService;
-import com.logpm.distribution.service.impl.DistributionAddvalueServiceImpl;
 import com.logpm.distribution.vo.DistributionAddvalueDetailVO;
-import com.logpm.distribution.vo.DistributionAddvaluePackageVO;
+import com.logpm.distribution.vo.app.DistributionAppAddvalueVO;
-import com.logpm.distribution.vo.app.*;
 import io.swagger.annotations.Api;
 import io.swagger.annotations.ApiOperation;
 import lombok.AllArgsConstructor;

blade-service/logpm-distribution/src/main/java/com/logpm/distribution/api/DistributionBillLadingAppController.java

@@ -74,11 +74,18 @@ public class DistributionBillLadingAppController extends BladeController {
 	@ApiOperationSupport(order = 1)
 	@ApiOperation(value = "分页列表", notes = "传入stockupDTO")
 	public R<IPage<DistrilbutionBillLadingAppVO>> pageList(@RequestBody BillLadingAppDTO billLadingAppDTO) {
+		IPage<DistrilbutionBillLadingAppVO> pages = null;
+		try {
 			Query query = new Query();
 			query.setCurrent(billLadingAppDTO.getCurrent());
 			query.setSize(billLadingAppDTO.getSize());
-		IPage<DistrilbutionBillLadingAppVO> pages = distrilbutionBillLadingService.pageListApp(Condition.getPage(query), billLadingAppDTO);
+			pages = distrilbutionBillLadingService.pageListApp(Condition.getPage(query), billLadingAppDTO);
 			return R.data(pages);
+		} catch (Exception e) {
+			log.error("自提列表信息异常", e);
+			return R.fail(e.getMessage());
+		}
+
 	}
 
 	@ResponseBody
@@ -126,20 +133,14 @@ public class DistributionBillLadingAppController extends BladeController {
 	@ApiOperation(value = "自提扫描id")
 	@GetMapping("/scan")
 	public R scan(@ApiIgnore @RequestParam Map<String, Object> distrilbutionBillLading){
-		Resp scan = distrilbutionBillLadingService.getScan(distrilbutionBillLading);
+		Resp scan = null;
-
+		try {
-		//获取传入类型
+			scan = distrilbutionBillLadingService.getScan(distrilbutionBillLading);
-		String type =distrilbutionBillLading.get("type").toString();
+		} catch (Exception e) {
-		if(scan.getCode()==200){
+			log.error("自提扫描id异常", e);
-			if("2".equals(type)){
+			scan = new Resp();
-				BasicdataWarehouseEntity myCurrentWarehouse = basicdataWarehouseClient.getMyCurrentWarehouse();
+			scan.setCode(500);
-				String coding = distrilbutionBillLading.get("coding").toString();
+			scan.setMsg(e.getMessage());
-
-//				warehouseUpdownTypeClient.downPackageOrDelTray(coding, myCurrentWarehouse.getId(),"签收下架解托");
-			}else if("1".equals(type)){
-				//todo 这里需要增加对备货库存品的下架逻辑  但是备货是会进行下架的
-				log.warn("库存品下架的逻辑");
-			}
 		}
 
 		return scan;
@@ -170,6 +171,8 @@ public class DistributionBillLadingAppController extends BladeController {
 	@PostMapping("/zeroBillBatch")
 	@ApiOperation(value = "零担自提批量签收")
 	public R zeroBillBatch(@RequestBody BillLadingAppDTO billLadingAppDTO) {
+		R b = null;
+		try {
 			log.debug("=====零担自提签收：{}",billLadingAppDTO);
 			if (ObjectUtils.isNull(billLadingAppDTO.getBillLadingId())) {
 				return R.fail(3002, "自提id不能为空 !");
@@ -178,12 +181,20 @@ public class DistributionBillLadingAppController extends BladeController {
 				return R.fail(3002, "零担数据不能为空 !");
 			}
 
-		R b = distrilbutionBillLadingService.zeroBill(billLadingAppDTO);
+			b = distrilbutionBillLadingService.zeroBill(billLadingAppDTO);
+		} catch (Exception e) {
+			log.error("零担自提批量签收", e);
+			b = new Resp();
+			b.setCode(500);
+			b.setMsg(e.getMessage());
+		}
 		return b;
 	}
 	@PostMapping("/zeroBillPack")
 	@ApiOperation(value = "零担自提单个签收")
 	public R zeroBillPack(@RequestBody BillLadingAppDTO billLadingAppDTO) {
+		R b = null;
+		try {
 			log.debug("=====零担自提签收：{}",billLadingAppDTO);
 			if (ObjectUtils.isNull(billLadingAppDTO.getBillLadingId())) {
 				return R.fail(3002, "自提id不能为空 !");
@@ -191,8 +202,13 @@ public class DistributionBillLadingAppController extends BladeController {
 			if(ObjectUtils.isNull(billLadingAppDTO.getBillLadingZeroVO())){
 				return R.fail(3002, "零担数据不能为空 !");
 			}
-
+			b = distrilbutionBillLadingService.zeroBillPack(billLadingAppDTO);
-		R b = distrilbutionBillLadingService.zeroBillPack(billLadingAppDTO);
+		} catch (Exception e) {
+			log.error("零担自提单个签收", e);
+			b = new Resp();
+			b.setCode(500);
+			b.setMsg(e.getMessage());
+		}
 		return b;
 	}
 
@@ -201,6 +217,8 @@ public class DistributionBillLadingAppController extends BladeController {
 	@ApiOperation(value = "添加自提单签收图片")
 	public R updateReceivedImage(@RequestBody BillLadingAppDTO billLadingAppDTO) {
 
+		R b = null;
+		try {
 			log.debug("=====签收图片自提签收：{}",billLadingAppDTO);
 			if (ObjectUtils.isNull(billLadingAppDTO.getBillLadingId())) {
 				return R.fail(3002, "自提id不能为空 !");
@@ -212,7 +230,13 @@ public class DistributionBillLadingAppController extends BladeController {
 			if(ObjectUtils.isNull(billLadingAppDTO.getPrintList()) || billLadingAppDTO.getPrintList().isEmpty()){
 				throw new ServiceException("图片对象不能为空！！");
 			}
-		R b = distrilbutionBillLadingService.updateReceivedImage(billLadingAppDTO);
+			b = distrilbutionBillLadingService.updateReceivedImage(billLadingAppDTO);
+		} catch (Exception e) {
+			log.error("零担自提单个签收", e);
+			b = new Resp();
+			b.setCode(500);
+			b.setMsg(e.getMessage());
+		}
 		return b;
 	}
 

blade-service/logpm-distribution/src/main/java/com/logpm/distribution/api/DistributionSignforAppController.java

@@ -49,10 +49,6 @@ public class DistributionSignforAppController {
 
 	private final IDistributionSignforService distributionSignforService;
 
-	private final IDistributionDeliveryListService distributionDeliveryListService;
-
-	private final IDistributionReservationService reservationService;
-
 	private final IWarehouseUpdownTypeClient updownTypeClient;
 
 	private final IBasicdataWarehouseClient warehouseClient;

blade-service/logpm-distribution/src/main/java/com/logpm/distribution/controller/DistributionReservationController.java

@@ -283,7 +283,12 @@ public class DistributionReservationController extends BladeController {
 	@ApiOperationSupport(order = 7)
 	@ApiOperation(value = "转市配任务")
 	public R deliveryTask(@RequestBody DistributionDeliveryAllocationDTO allocationDTO) {
-		R<?> result = reservationService.deliveryTask(allocationDTO);
+		R<?> result = null;
+		try {
+			result = reservationService.deliveryTask(allocationDTO);
+		} catch (Exception e) {
+			return R.fail(e.getMessage());
+		}
 		return result;
 	}
 

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

@@ -1265,7 +1265,7 @@ public class DistributionReservationServiceImpl extends BaseServiceImpl<Distribu
 		//创建备货任务
 		DistributionStockupDTO stockup = allocationDTO.getStockup();
 		List<Long> ids = Func.toLongList(reservationIds);
-		Integer stockListTotal = distributionReservationStocklistMapper.getStockListTotal(ids);
+//		Integer stockListTotal = distributionReservationStocklistMapper.getStockListTotal(ids);
 
 		DistributionDeliveryListEntity distributionDeliveryListEntity = new DistributionDeliveryListEntity();
 		String numberMa = trainNumberMa();
@@ -1289,7 +1289,7 @@ public class DistributionReservationServiceImpl extends BaseServiceImpl<Distribu
 		//司机名称拼接
 		StringBuilder driverNames = new StringBuilder();
 		//查询根据预约ID查询这些预约的备货状态
-		List<DistributionReservationEntity> reservationEntityList = baseMapper.selectList(Wrappers.<DistributionReservationEntity>query().lambda().in(DistributionReservationEntity::getId, ids));
+		List<DistributionReservationEntity> reservationEntityList = baseMapper.selectList(Wrappers.<DistributionReservationEntity>query().lambda().eq(DistributionReservationEntity::getId, ids));
 		//判断是否存在预约进行了配送任务的提交
 		boolean match = reservationEntityList.stream().anyMatch(r -> ReservationStatusConstant.daipeisong.getValue().equals(r.getReservationStatus()));
 		if (match) {
@@ -1407,7 +1407,7 @@ public class DistributionReservationServiceImpl extends BaseServiceImpl<Distribu
 			}
 		}
 		if (Func.isNotEmpty(builder)) {
-			throw new RuntimeException(builder + "该预约单已进行配送请核对");
+			throw new CustomerException(builder + "该预约单已进行配送请核对");
 		}
 		Long deliveryListId = distributionDeliveryListEntity.getId();
 		//操作司机信息