From cd506c91ff429eb676a14615cd034ecd1f286329 Mon Sep 17 00:00:00 2001 From: lsh <lsh@163.com> Date: 星期六, 08 六月 2024 11:16:18 +0800 Subject: [PATCH] # --- src/main/java/com/zy/asrs/task/handler/WorkLogHandler.java | 52 ++++++++++++++++++++++++++++++++++++++++++++++++++++ 1 files changed, 52 insertions(+), 0 deletions(-) diff --git a/src/main/java/com/zy/asrs/task/handler/WorkLogHandler.java b/src/main/java/com/zy/asrs/task/handler/WorkLogHandler.java index 3eabe70..35c3e9f 100644 --- a/src/main/java/com/zy/asrs/task/handler/WorkLogHandler.java +++ b/src/main/java/com/zy/asrs/task/handler/WorkLogHandler.java @@ -40,6 +40,15 @@ private WrkMastStaService wrkMastStaService; @Autowired private WrkMastStaLogService wrkMastStaLogService; + @Autowired + private WrkMastSplitTwinService wrkMastSplitTwinService; + @Autowired + private WrkMastSplitTwinLogService wrkMastSplitTwinLogService; + @Autowired + private WrkMastCrnService wrkMastCrnService; + @Autowired + private WrkMastCrnLogService wrkMastCrnLogService; + @Transactional public ReturnT<String> start(WrkMast wrkMast) { @@ -152,4 +161,47 @@ return SUCCESS; } + @Transactional + public ReturnT<String> start(WrkMastSplitTwin wrkMastSplitTwin) { + try { + WrkMastSplitTwinLog wrkMastSplitTwinLog = new WrkMastSplitTwinLog(); + wrkMastSplitTwinLog.sync(wrkMastSplitTwin); + // 淇濆瓨宸ヤ綔涓绘。鍘嗗彶妗� + if (!wrkMastSplitTwinLogService.insert(wrkMastSplitTwinLog)) { + exceptionHandle("淇濆瓨wrkMastSplitTwinLog宸ヤ綔鍘嗗彶妗workNo={0}]澶辫触", wrkMastSplitTwin.getWrkNo()); + } + // 鍒犻櫎宸ヤ綔涓绘。 + if (!wrkMastSplitTwinService.deleteById(wrkMastSplitTwin)) { + exceptionHandle("鍒犻櫎wrkMastSplitTwin宸ヤ綔涓绘。[workNo={0}]澶辫触", wrkMastSplitTwin.getWrkNo()); + } + } catch (Exception e) { + log.error("fail", e); + TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); + return FAIL.setMsg(e.getMessage()); + } + return SUCCESS; + } + + @Transactional + public ReturnT<String> start(WrkMastCrn wrkMastCrn) { + try { + WrkMastCrnLog wrkMastCrnLog = new WrkMastCrnLog(); + wrkMastCrnLog.sync(wrkMastCrn); + // 淇濆瓨宸ヤ綔涓绘。鍘嗗彶妗� + if (!wrkMastCrnLogService.insert(wrkMastCrnLog)) { + exceptionHandle("淇濆瓨wrkMastCrnLog宸ヤ綔鍘嗗彶妗workNo={0}]澶辫触", wrkMastCrn.getWrkNo()); + } + // 鍒犻櫎宸ヤ綔涓绘。 + if (!wrkMastCrnService.deleteById(wrkMastCrn)) { + exceptionHandle("鍒犻櫎wrkMastCrn宸ヤ綔涓绘。[workNo={0}]澶辫触", wrkMastCrn.getWrkNo()); + } + } catch (Exception e) { + log.error("fail", e); + TransactionAspectSupport.currentTransactionStatus().setRollbackOnly(); + return FAIL.setMsg(e.getMessage()); + } + return SUCCESS; + } + + } -- Gitblit v1.9.1