From 7aab004601e77890b158f19d1735594a8326feaa Mon Sep 17 00:00:00 2001
From: liurunyu <lry9898@163.com>
Date: 星期四, 24 四月 2025 17:11:17 +0800
Subject: [PATCH] 数据库事务注解位置调整

---
 pipIrr-platform/pipIrr-web/pipIrr-web-wechat/src/main/java/com/dy/pipIrrWechat/irrigatePlan/IrrigatePlanSv.java |   20 ++++++++++++++++++--
 1 files changed, 18 insertions(+), 2 deletions(-)

diff --git a/pipIrr-platform/pipIrr-web/pipIrr-web-wechat/src/main/java/com/dy/pipIrrWechat/irrigatePlan/IrrigatePlanSv.java b/pipIrr-platform/pipIrr-web/pipIrr-web-wechat/src/main/java/com/dy/pipIrrWechat/irrigatePlan/IrrigatePlanSv.java
index 1b3d0f2..e9c674f 100644
--- a/pipIrr-platform/pipIrr-web/pipIrr-web-wechat/src/main/java/com/dy/pipIrrWechat/irrigatePlan/IrrigatePlanSv.java
+++ b/pipIrr-platform/pipIrr-web/pipIrr-web-wechat/src/main/java/com/dy/pipIrrWechat/irrigatePlan/IrrigatePlanSv.java
@@ -19,6 +19,7 @@
 import org.apache.ibatis.annotations.Param;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 import java.time.LocalDateTime;
 import java.time.ZoneId;
@@ -72,6 +73,7 @@
      * @param po
      * @return
      */
+    @Transactional(rollbackFor = Exception.class)
     public Long addIrrigatePlan(IrIrrigatePlan po) {
         irrigatePlanMapper.insert(po);
         return po.getId();
@@ -82,6 +84,7 @@
      * @param planSimple
      * @return
      */
+    @Transactional(rollbackFor = Exception.class)
     public Map deletePlan(PlanSimple planSimple) {
         Long planId = planSimple.getPlanId();
         Long operatorId = planSimple.getOperatorId();
@@ -184,7 +187,7 @@
         planStopTime = Date.from(stopTime.atZone(ZoneId.systemDefault()).toInstant());
 
         // 鏍规嵁璁″垝ID鏇存柊璁″垝淇℃伅锛堣捣姝㈡椂闂淬�佽鍒掔姸鎬侊級
-        if(irrigatePlanMapper.updatePlanTimes(planStartTime, planStopTime, planId) == 0) {
+        if(this.updatePlanTimes(planStartTime, planStopTime, planId) == 0) {
             Map map = new HashMap<>();
             map.put("success", false);
             map.put("msg", "璁″垝淇℃伅鏇存柊澶辫触");
@@ -200,7 +203,7 @@
             if(scheduleStartTime == null) {
                 scheduleStartTime = planStartTime;
             }
-            updateScheduleStartTime(schedule.getScheduleId(), scheduleStartTime);
+            this.updateScheduleStartTime(schedule.getScheduleId(), scheduleStartTime);
 
             // 璁＄畻涓嬩竴缁勭殑寮�濮嬫椂闂�
             LocalDateTime LocalscheduleStartTime = scheduleStartTime.toInstant().atZone(ZoneId.systemDefault()) .toLocalDateTime();
@@ -308,6 +311,7 @@
      * @param po
      * @return
      */
+    @Transactional(rollbackFor = Exception.class)
     public Integer updatePlan(IrIrrigatePlan po) {
         return irrigatePlanMapper.updateByPrimaryKeySelective(po);
     }
@@ -371,6 +375,7 @@
      * @param po
      * @return
      */
+    @Transactional(rollbackFor = Exception.class)
     public Long addPlanOperate(IrPlanOperate po) {
         irPlanOperateMapper.insert(po);
         return po.getId();
@@ -381,6 +386,7 @@
      * @param po
      * @return
      */
+    @Transactional(rollbackFor = Exception.class)
     public Long addIrrigateSchedule(IrIrrigateSchedule po) {
         irIrrigateScheduleMapper.insert(po);
         return po.getId();
@@ -391,6 +397,7 @@
      * @param planId
      * @return
      */
+    @Transactional(rollbackFor = Exception.class)
     public Integer terminateSchedule(Long planId) {
         return irIrrigateScheduleMapper.terminateSchedule(planId);
     }
@@ -418,6 +425,7 @@
      * @param po
      * @return
      */
+    @Transactional(rollbackFor = Exception.class)
     public Long addPlanSchedule(IrPlanSchedule po) {
         irPlanScheduleMapper.insert(po);
         return po.getId();
@@ -429,6 +437,7 @@
      * @param startTime
      * @return
      */
+    @Transactional(rollbackFor = Exception.class)
     public Integer updateScheduleStartTime(Long scheduleId, Date startTime) {
         return irIrrigateScheduleMapper.updateScheduleStartTime(scheduleId, startTime);
     }
@@ -516,4 +525,11 @@
         return planDetails;
 
     }
+
+    @Transactional(rollbackFor = Exception.class)
+    private Integer updatePlanTimes(Date planStartTime, Date planEndTime,  Long planId){
+        return irrigatePlanMapper.updatePlanTimes(planStartTime, planEndTime, planId);
+    }
+
+
 }

--
Gitblit v1.8.0