Merge branch 'dev' into pre-production

blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/InComingServiceImpl.java

@@ -43,6 +43,7 @@ import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
 import java.util.*;
+import java.util.concurrent.atomic.AtomicReference;
 import java.util.function.Function;
 import java.util.stream.Collectors;
 
@@ -198,6 +199,7 @@ public class InComingServiceImpl implements IInComingService {
 
 	@Transactional(rollbackFor = Exception.class)
 	public R incomingPackage(InComingDTO inComingDTO) {
+		AtomicReference<String> audio = new AtomicReference<>();
 		try{
 			String orderPackageCode = inComingDTO.getOrderPackageCode();//包件码
 			Long warehouseId = inComingDTO.getWarehouseId();//仓库id
@@ -235,6 +237,8 @@ public class InComingServiceImpl implements IInComingService {
 				}
 			}
 
+
+
 			//把advanceDetailEntityList通过packageStatus分组
 			Map<String, List<TrunklineAdvanceDetailEntity>> advanceDetailEntityMap = advanceDetailEntityList.stream().collect(Collectors.groupingBy(TrunklineAdvanceDetailEntity::getPackageStatus));
 
@@ -327,7 +331,11 @@ public class InComingServiceImpl implements IInComingService {
 									map.put("trayCode", trayCode);
 									map.put("warehouseId", warehouseId);
 									map.put("orderPackageCode", packageCode);
-									warehouseTrayTypeClient.orderScanOrderPackageCodeReturnR(map);
+									R r = warehouseTrayTypeClient.orderScanOrderPackageCodeReturnR(map);
+									Object data = r.getData();
+									if(!Objects.isNull(data)){
+										audio.set((String) data);
+									}
 								}
 							});
 						}
@@ -421,7 +429,11 @@ public class InComingServiceImpl implements IInComingService {
 									map.put("trayCode", trayCode);
 									map.put("warehouseId", warehouseId);
 									map.put("orderPackageCode", packageCode);
-									warehouseTrayTypeClient.orderScanOrderPackageCode(map);
+									R r = warehouseTrayTypeClient.orderScanOrderPackageCodeReturnR(map);
+									Object data = r.getData();
+									if(!Objects.isNull(data)){
+										audio.set((String) data);
+									}
 								}
 							});
 						}
@@ -469,6 +481,11 @@ public class InComingServiceImpl implements IInComingService {
 			throw e;
 		}
 
+		String a = audio.get();
+		if(StringUtil.isNotBlank(a)){
+			return Resp.scanSuccess("入库成功",a);
+		}
+
 		return R.success("入库成功");
 	}
 

blade-service/logpm-trunkline/src/main/java/com/logpm/trunkline/service/impl/TrunklineCarsLoadServiceImpl.java

@@ -2290,12 +2290,12 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
 //			return R.fail(405, "包件已经装车");
 //		}
 
-		TrunklineCarsLoadScanEntity isExit = trunklineCarsLoadScanService.findEntityByOrderPackageCodeAndScanStatus(orderPackageCode, "1");
-		if (!Objects.isNull(isExit)) {
-			String loadCode = isExit.getLoadCode();
-			log.warn("##################loadingScan: 包件已经装车 orderPackageCode={}", orderPackageCode);
-			return R.fail(405, "包件已经装车到" + loadCode);
-		}
+//		TrunklineCarsLoadScanEntity isExit = trunklineCarsLoadScanService.findEntityByOrderPackageCodeAndScanStatus(orderPackageCode, "1");
+//		if (!Objects.isNull(isExit)) {
+//			String loadCode = isExit.getLoadCode();
+//			log.warn("##################loadingScan: 包件已经装车 orderPackageCode={}", orderPackageCode);
+//			return R.fail(405, "包件已经装车到" + loadCode);
+//		}
 
 		String audio = "";
 		String loadCode = carsLoadEntity.getCarsNo();
@@ -6300,6 +6300,12 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
 		//判断是否有装车扫描记录
 		if (Objects.isNull(carsLoadScanEntity)) {
 			//没有装车扫码记录
+			//先判断是否在其他车次中
+//			QueryWrapper<TrunklineCarsLoadScanEntity> loadScanQueryWrapper = new QueryWrapper<>();
+//			loadScanQueryWrapper.eq("load_id", loadId)
+//				.eq("scan_code", orderPackageCode);
+//			carsLoadScanEntity = trunklineCarsLoadScanService.getOne(loadScanQueryWrapper);
+
 			//不在计划中，则查询在哪个仓库中
 			DistributionParcelListEntity parcelListEntity = distributionParcelListClient.findByOrderPackageCodeAndStatus(orderPackageCode);
 			Long loadScanId = null;
@@ -7116,7 +7122,17 @@ public class TrunklineCarsLoadServiceImpl extends BaseServiceImpl<TrunklineCarsL
 		//处理托盘的入库和货物的入库
 		trayTypeClient.changeTrayWarehouseInfo(trayCode, warehouseId);
 
-		return R.success("卸车成功");
+		JSONObject jsonObject = trunklineCarsLoadScanService.findUnloadNumAudio(loadId,warehouseId);
+		Integer totalUnloadNum = jsonObject.getInteger("totalUnloadNum");
+		Integer abnormalUnloadNum = jsonObject.getInteger("abnormalUnloadNum");
+		StringBuilder audio = new StringBuilder();
+		audio.append("卸车").append(totalUnloadNum).append("件");
+		if(!Objects.isNull(abnormalUnloadNum) && !abnormalUnloadNum.equals(0)){
+			audio.append("异常卸车").append(abnormalUnloadNum).append("件");
+		}
+
+
+		return Resp.scanSuccess("卸车成功",audio.toString());
 	}
 
 

blade-service/logpm-warehouse/src/main/java/com/logpm/warehouse/service/impl/WarehouseTrayTypeServiceImpl.java

@@ -1277,7 +1277,9 @@ public class WarehouseTrayTypeServiceImpl extends BaseServiceImpl<WarehouseTrayT
 
 		if(chuanFlag){
 			log.warn("#########orderScanOrderPackageCode: 不属于同一个"+msg+" 串货 filterValue={} orderPackageCode={}",filterValue,orderPackageCode);
-			return R.success("扫描成功");
+			JSONObject jsonObject = new JSONObject();
+			jsonObject.put("audio","串货");
+			return R.data(jsonObject.toJSONString());
 		}else{
 			return R.success("扫描成功");
 		}