From f269e1934915ec7d20aa117a7aa2bc927d96ece5 Mon Sep 17 00:00:00 2001 From: zch Date: Fri, 6 Jun 2025 19:46:43 +0800 Subject: [PATCH] =?UTF-8?q?feat(record):=20=E4=BC=98=E5=8C=96=E5=91=8A?= =?UTF-8?q?=E8=AD=A6=E6=95=B0=E6=8D=AE=E5=A4=84=E7=90=86=E5=BC=82=E5=B8=B8?= =?UTF-8?q?=E9=80=BB=E8=BE=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - 添加事务注解确保数据一致性 - 修改异常处理逻辑，返回实际处理的记录数 - 优化代码结构，提高可读性和可维护性 --- .../service/impl/EmsRecordAlarmDataServiceImpl.java | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/os-ems/src/main/java/com/os/ems/record/service/impl/EmsRecordAlarmDataServiceImpl.java b/os-ems/src/main/java/com/os/ems/record/service/impl/EmsRecordAlarmDataServiceImpl.java index a6e06cf..0766839 100644 --- a/os-ems/src/main/java/com/os/ems/record/service/impl/EmsRecordAlarmDataServiceImpl.java +++ b/os-ems/src/main/java/com/os/ems/record/service/impl/EmsRecordAlarmDataServiceImpl.java @@ -21,6 +21,7 @@ import org.springframework.stereotype.Service; import com.os.ems.record.mapper.EmsRecordAlarmDataMapper; import com.os.ems.record.domain.EmsRecordAlarmData; import com.os.ems.record.service.IEmsRecordAlarmDataService; +import org.springframework.transaction.annotation.Transactional; import static com.os.common.utils.SecurityUtils.getUsername; @@ -153,16 +154,19 @@ public class EmsRecordAlarmDataServiceImpl implements IEmsRecordAlarmDataService * @return */ @Override + @Transactional(rollbackFor = Exception.class) public int handleExceptionsAlarmData(Long[] objIds) { + int result = 0; for (Long objId : objIds) { EmsRecordAlarmData alarmData = new EmsRecordAlarmData(); alarmData.setObjId(objId); alarmData.setAlarmStatus(0L); alarmData.setOperationName(getUsername()); alarmData.setOperationTime(DateUtils.getNowDate()); - emsRecordAlarmDataMapper.updateEmsRecordAlarmData(alarmData); + int i = emsRecordAlarmDataMapper.updateEmsRecordAlarmData(alarmData); + result += 1; } - return 1; + return result; } /**