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/command/CommandSv.java | 3 +++
pipIrr-platform/pipIrr-web/pipIrr-web-wechat/src/main/java/com/dy/pipIrrWechat/irrigatePlan/IrrigatePlanCtrl.java | 6 +++---
pipIrr-platform/pipIrr-web/pipIrr-web-wechat/src/main/java/com/dy/pipIrrWechat/irrigatePlan/IrrigatePlanSv.java | 20 ++++++++++++++++++--
3 files changed, 24 insertions(+), 5 deletions(-)
diff --git a/pipIrr-platform/pipIrr-web/pipIrr-web-wechat/src/main/java/com/dy/pipIrrWechat/command/CommandSv.java b/pipIrr-platform/pipIrr-web/pipIrr-web-wechat/src/main/java/com/dy/pipIrrWechat/command/CommandSv.java
index 9b390ec..6bbaac0 100644
--- a/pipIrr-platform/pipIrr-web/pipIrr-web-wechat/src/main/java/com/dy/pipIrrWechat/command/CommandSv.java
+++ b/pipIrr-platform/pipIrr-web/pipIrr-web-wechat/src/main/java/com/dy/pipIrrWechat/command/CommandSv.java
@@ -47,6 +47,7 @@
import org.springframework.beans.factory.annotation.Value;
import org.springframework.core.env.Environment;
import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
import java.util.*;
@@ -258,6 +259,7 @@
* @param automaticClose
* @return
*/
+ @Transactional(rollbackFor = Exception.class)
public Map planedOpenTimedClose(AutomaticClose automaticClose, Long planId, Byte operatetype, Date startTime, Integer duration) {
Long intakeId = automaticClose.getIntakeId();
Long vcId = automaticClose.getVcId();
@@ -687,6 +689,7 @@
* @param operatetype
* @return
*/
+ @Transactional(rollbackFor = Exception.class)
public Map closeWx(ValveClose valve, Long planId, Byte operatetype) {
String rtuAddr = valve.getRtuAddr();
String vcNum = valve.getVcNum();
diff --git a/pipIrr-platform/pipIrr-web/pipIrr-web-wechat/src/main/java/com/dy/pipIrrWechat/irrigatePlan/IrrigatePlanCtrl.java b/pipIrr-platform/pipIrr-web/pipIrr-web-wechat/src/main/java/com/dy/pipIrrWechat/irrigatePlan/IrrigatePlanCtrl.java
index 481f38d..a30cb61 100644
--- a/pipIrr-platform/pipIrr-web/pipIrr-web-wechat/src/main/java/com/dy/pipIrrWechat/irrigatePlan/IrrigatePlanCtrl.java
+++ b/pipIrr-platform/pipIrr-web/pipIrr-web-wechat/src/main/java/com/dy/pipIrrWechat/irrigatePlan/IrrigatePlanCtrl.java
@@ -61,7 +61,7 @@
* @return
*/
@PostMapping(path = "createPlan", consumes = MediaType.APPLICATION_JSON_VALUE)
- @Transactional(rollbackFor = Exception.class)
+ //@Transactional(rollbackFor = Exception.class)
public BaseResponse<Boolean> createPlan(@RequestBody @Valid IrrigatePlan planAndSchedule, BindingResult bindingResult){
if(bindingResult != null && bindingResult.hasErrors()){
return BaseResponseUtils.buildErrorMsg(Objects.requireNonNull(bindingResult.getFieldError()).getDefaultMessage());
@@ -193,7 +193,7 @@
* @return
*/
@PostMapping(path = "publishPlan", consumes = MediaType.APPLICATION_JSON_VALUE)
- @Transactional(rollbackFor = Exception.class)
+ //@Transactional(rollbackFor = Exception.class)
public BaseResponse<Boolean> publishPlan(@RequestBody @Valid PlanSimple planSimple, BindingResult bindingResult){
if(bindingResult != null && bindingResult.hasErrors()){
return BaseResponseUtils.buildErrorMsg(Objects.requireNonNull(bindingResult.getFieldError()).getDefaultMessage());
@@ -315,7 +315,7 @@
* @return
*/
@PostMapping(path = "terminatePlan", consumes = MediaType.APPLICATION_JSON_VALUE)
- @Transactional(rollbackFor = Exception.class)
+ //@Transactional(rollbackFor = Exception.class)
public BaseResponse<Boolean> terminatePlan(@RequestBody @Valid PlanSimple planSimple, BindingResult bindingResult){
if(bindingResult != null && bindingResult.hasErrors()){
return BaseResponseUtils.buildErrorMsg(Objects.requireNonNull(bindingResult.getFieldError()).getDefaultMessage());
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