ソースを参照

看板同步、编辑装运单同步事务异常回滚处理

qiangxuan 1 ヶ月 前
コミット
ec41d70b6d

+ 3 - 10
zgztBus/jeecg-module-sbm/src/main/java/org/jeecg/modules/billet/storageBill/service/impl/StorageBillServiceImpl.java

@@ -1277,8 +1277,6 @@ public class StorageBillServiceImpl extends ServiceImpl<StorageBillMapper, Stora
                 timeOffset.addAndGet(1000); // 这里假设每次增加1秒(1000毫秒)的时间偏移量
             });
             rollClubTwoDetailsService.saveBatch(rollClubTwoDetailsList);
-            // 更新交班表中的热装总支数
-            updateShiftInfoByType(billetHotsend.getCcmNo(), billetHotsend.getShift(), billetHotsend.getShiftGroup(), rollClubTwoDetailsList.size(), "roll_club_two", "hotCharge");
         }
 
         if ("roll_club_three".equals(billetHotsendDetailsVo.getBelongTable())){
@@ -1326,8 +1324,6 @@ public class StorageBillServiceImpl extends ServiceImpl<StorageBillMapper, Stora
                 timeOffset.addAndGet(1000); // 这里假设每次增加1秒(1000毫秒)的时间偏移量
             });
             rollClubThreeDetailsService.saveBatch(rollClubThreeDetailsList);
-            // 更新交班表中的热装总支数
-            updateShiftInfoByType(billetHotsend.getCcmNo(), billetHotsend.getShift(), billetHotsend.getShiftGroup(), rollClubThreeDetailsList.size(), "roll_club_three", "hotCharge");
         }
 
         /**
@@ -1378,8 +1374,6 @@ public class StorageBillServiceImpl extends ServiceImpl<StorageBillMapper, Stora
                 timeOffset.addAndGet(1000); // 这里假设每次增加1秒(1000毫秒)的时间偏移量
             });
             rollOutShippDetailsService.saveBatch(rollOutShippDetailsList);
-            // 更新交班表中的热装总支数
-            updateShiftInfoByType(billetHotsend.getCcmNo(), billetHotsend.getShift(), billetHotsend.getShiftGroup(), rollOutShippDetailsList.size(), "roll_out_shipp", "hotCharge");
         }
         return result;
     }
@@ -3024,8 +3018,8 @@ public class StorageBillServiceImpl extends ServiceImpl<StorageBillMapper, Stora
         } catch (Exception e) {
             // 记录异常日志
             log.error("B端编辑装运单未知目的地明细同步发生异常", e);
-            result.put("fail", "系统错误,请稍后再试!");
-            return result;
+            // 抛出异常触发事务回滚
+            throw new RuntimeException(e);
         }
     }
 
@@ -3304,8 +3298,7 @@ public class StorageBillServiceImpl extends ServiceImpl<StorageBillMapper, Stora
         }catch (Exception e){
             // 记录异常日志
             log.error("B端监控看板确认目的地,同步发生异常", e.getMessage());
-            result.put("fail", "系统错误,请稍后再试!");
-            return result;
+            throw new RuntimeException(e);
         }
     }