2号车位逻辑调整

zgzt-sys-java/jeecg-module-conn/src/main/java/org/jeecg/modules/billetActual/service/impl/BilletHotsendBaseServiceImpl.java

@@ -264,7 +264,6 @@ public class BilletHotsendBaseServiceImpl extends ServiceImpl<BilletHotsendBaseM
 		log.info("{}{}", "C端自动化热装<保存>mqtt参数:", jsonObject);
 		BilletHotsendDetailsVo billetHotsendDetailsVo = new BilletHotsendDetailsVo();
 
-		String ccmNo = jsonObject.getString("ccmNo");
 		String billetNos = jsonObject.getString("billetNos");
 		String licensePlate = jsonObject.getString("licensePlate");
 		String destination = jsonObject.getString("destination");
@@ -279,17 +278,20 @@ public class BilletHotsendBaseServiceImpl extends ServiceImpl<BilletHotsendBaseM
 			log.info("{}{}", "参数为空，C端自动化热装<保存>失败！", jsonObject);
 			return;
 		}
-
-		// 取钢坯号的第九位字符
-		ccmNo = Optional.ofNullable(billetNos)
-				.filter(s -> !s.isEmpty())
-				.map(s -> s.split(","))
-				.filter(arr -> arr.length > 0)
-				.map(arr -> arr[0])
-				.filter(num -> num.length() >= 9)
-				.map(num -> String.valueOf(num.charAt(8)))
-				.orElse("");
-		log.info("C端自动化热装,钢坯中截取的铸机号:{}", ccmNo);
+		String ccmNo = jsonObject.getString("ccmNo");
+		// 2号车位不验证铸机号
+		if (positionNum.equals("2")) {
+			// 取钢坯号的第九位字符
+			ccmNo = Optional.ofNullable(billetNos)
+					.filter(s -> !s.isEmpty())
+					.map(s -> s.split(","))
+					.filter(arr -> arr.length > 0)
+					.map(arr -> arr[0])
+					.filter(num -> num.length() >= 9)
+					.map(num -> String.valueOf(num.charAt(8)))
+					.orElse("");
+			log.info("C端自动化热装,钢坯中截取的铸机号:{}", ccmNo);
+		}
 		String shiftGroup = shiftGroupHandle(ccmNo);
 		String shift = shiftHandle(ccmNo);
 		log.info("C端自动化热装缓存中的班组、班别:{}", shiftGroup + ":" + shift);

zgzt-sys-java/jeecg-module-conn/src/main/java/org/jeecg/modules/stackingAndLoadingVehicles/service/impl/StackingAndLoadingVehiclesServiceImpl.java

@@ -330,8 +330,6 @@ public class StackingAndLoadingVehiclesServiceImpl extends ServiceImpl<StackingA
         BilletLiftingBill billetLiftingBill = new BilletLiftingBill();
         billetLiftingBill.setId(String.valueOf(IdWorker.getId()));
         billetLiftingBill.setCcmNo(ccmNo);
-        billetLiftingBill.setShiftGroup(shiftGroupHandle(ccmNo));
-        billetLiftingBill.setShift(shiftHandle(ccmNo));
         billetLiftingBill.setAddress(address);
         billetLiftingBill.setLayer(layer);
         billetLiftingBill.setVehicleNumber(jsonObject.getString("vehicleNumber"));
@@ -358,7 +356,6 @@ public class StackingAndLoadingVehiclesServiceImpl extends ServiceImpl<StackingA
         List<StackingAndLoadingVehicles> stackingAndLoadingVehiclesLists = new ArrayList<>();
 
         StackingAndLoadingVehicles stackingAndLoadingVehiclesInfo = baseMapper.selectOne(new LambdaQueryWrapper<StackingAndLoadingVehicles>()
-                .eq(StackingAndLoadingVehicles::getCcmNo, ccmNo)
                 .eq(StackingAndLoadingVehicles::getLayer, layer)
                 .eq(StackingAndLoadingVehicles::getAddress, address)
                 .eq(StackingAndLoadingVehicles::getTypeConfigId, billetHotsendTypeConfig.getId())
@@ -370,31 +367,7 @@ public class StackingAndLoadingVehiclesServiceImpl extends ServiceImpl<StackingA
         stackingAndLoadingVehiclesLists.add(stackingAndLoadingVehiclesInfo);
         loadingParams.setStackingAndLoadingVehiclesList(stackingAndLoadingVehiclesLists);
         String allBilletNos  = stackingAndLoadingVehiclesInfo.getBilletNos();
-        // 获取所有的坯号集合
-        List<String> allBilletNoList  = Arrays.asList(allBilletNos.split(","));
-
-        LambdaQueryWrapper<BilletBasicInfo> queryWrapperBB = new LambdaQueryWrapper<BilletBasicInfo>()
-                .eq(BilletBasicInfo::getCcmNo, Integer.valueOf(ccmNo))
-                .in(BilletBasicInfo::getBilletNo, allBilletNoList);
-        List<BilletBasicInfo> billetBasicInfoList = billetBasicInfoService.list(queryWrapperBB);
-        if (oConvertUtils.listIsEmpty(billetBasicInfoList)) {
-            log.info("{}{}", "钢坯基础信息为空，C端自动化垛位装车保存失败", stackingAndLoadingVehiclesInfo.getBilletNos());
-            return;
-        }
 
-        // 2025 3.3，C端自动化推送保存、B端手动发车临时方案，
-        LambdaQueryWrapper<StorageBill> queryWrapper2 = new LambdaQueryWrapper<>();
-        queryWrapper2.eq(StorageBill::getPositionNum, Integer.valueOf(positionNum))
-                .isNull(StorageBill::getOutTime);
-        // 2号车位不验证铸机号
-        if (!positionNum.equals("2")) {
-            queryWrapper2.eq(StorageBill::getCcmNo, ccmNo);
-        }
-        StorageBill isStorageBill = storageBillService.getOne(queryWrapper2);
-        if (oConvertUtils.isEmpty(isStorageBill)) {
-            log.info("钢坯装运单不存在，车位号为:{}，C端自动化垛位装车保存失败！", positionNum);
-            return;
-        }
         // 截取钢坯的第九位字符，为最终铸机号
         ccmNo = Optional.ofNullable(allBilletNos)
                 .filter(s -> !s.isEmpty())
@@ -409,14 +382,22 @@ public class StackingAndLoadingVehiclesServiceImpl extends ServiceImpl<StackingA
         String shift = shiftHandle(ccmNo);
         log.info("C端自动化垛位装车缓存中的班组、班别:{}", shiftGroup + ":" + shift);
         if (oConvertUtils.isEmpty(shiftGroup) || oConvertUtils.isEmpty(shift)){
-            log.info("{}{}", "班组班别获取为空，C端自动化垛位装车<保存>失败！", JSON.toJSON(isStorageBill));
+            log.info("{}{}", "班组班别获取为空，C端自动化垛位装车<保存>失败！", JSON.toJSON(jsonObject));
+            return;
+        }
+        // 2025 3.3，C端自动化推送保存、B端手动发车临时方案，
+        LambdaQueryWrapper<StorageBill> queryWrapper2 = new LambdaQueryWrapper<>();
+        queryWrapper2.eq(StorageBill::getPositionNum, Integer.valueOf(positionNum))
+                .isNull(StorageBill::getOutTime);
+        // 2号车位不验证铸机号
+        if (!positionNum.equals("2")) {
+            queryWrapper2.eq(StorageBill::getCcmNo, ccmNo);
+        }
+        StorageBill isStorageBill = storageBillService.getOne(queryWrapper2);
+        if (oConvertUtils.isEmpty(isStorageBill)) {
+            log.info("钢坯装运单不存在，车位号为:{}，C端自动化垛位装车保存失败！", positionNum);
             return;
         }
-        BilletHotsend billetHotsend = new BilletHotsend();
-        billetHotsend.setCcmNo(ccmNo);
-        billetHotsend.setShiftGroup(shiftGroup);
-        billetHotsend.setShift(shift);
-        loadingParams.setBilletHotsend(billetHotsend);
         // 更新装运单铸机号、班别、班组
         if ("0".equals(isStorageBill.getCcmNo())) {
             // 更新铸机号，到装运单
@@ -430,17 +411,36 @@ public class StackingAndLoadingVehiclesServiceImpl extends ServiceImpl<StackingA
                 return;
             }
         }
+
+        BilletHotsend billetHotsend = new BilletHotsend();
+        billetHotsend.setCcmNo(ccmNo);
+        billetHotsend.setShiftGroup(shiftGroup);
+        billetHotsend.setShift(shift);
+        loadingParams.setBilletHotsend(billetHotsend);
+
         loadingParams.setStorageBill(isStorageBill);
 
         log.info("{}{}", "自动化堆垛装车，装运单信息：", JSON.toJSON(isStorageBill));
 
         StorageBill storageBill = loadingParams.getStorageBill();
 
-        final double billetWeightTotal = billetBasicInfoList.stream().mapToDouble(BilletBasicInfo::getBilletWeight).sum();
+        // 获取所有的坯号集合
+        List<String> allBilletNoList  = Arrays.asList(allBilletNos.split(","));
+
+        LambdaQueryWrapper<BilletBasicInfo> queryWrapperBB = new LambdaQueryWrapper<BilletBasicInfo>()
+                .eq(BilletBasicInfo::getCcmNo, Integer.valueOf(ccmNo))
+                .in(BilletBasicInfo::getBilletNo, allBilletNoList);
+        List<BilletBasicInfo> billetBasicInfoList = billetBasicInfoService.list(queryWrapperBB);
+        if (oConvertUtils.listIsEmpty(billetBasicInfoList)) {
+            log.info("{}{}", "钢坯基础信息为空，C端自动化垛位装车保存失败", stackingAndLoadingVehiclesInfo.getBilletNos());
+            return;
+        }
 
         // 根据坯号查询吊运单信息。更新billetWeightTotal
         BilletLiftingBill billetLiftingBillUpdate = billetLiftingBillService.getById(billetLiftingBill.getId());
         if (oConvertUtils.isNotEmpty(billetLiftingBillUpdate)){
+            final double billetWeightTotal = billetBasicInfoList.stream().mapToDouble(BilletBasicInfo::getBilletWeight).sum();
+
             billetLiftingBillUpdate.setShiftGroup(shiftGroup);
             billetLiftingBillUpdate.setShift(shift);
             // 维护吊运单，坯重、组坯号、炉号