feat(record): 优化告警数据处理异常逻辑

- 添加事务注解确保数据一致性
- 修改异常处理逻辑,返回实际处理的记录数
- 优化代码结构,提高可读性和可维护性
boardTest
zch 3 weeks ago
parent 911c8e1889
commit f269e19349

@ -21,6 +21,7 @@ import org.springframework.stereotype.Service;
import com.os.ems.record.mapper.EmsRecordAlarmDataMapper; import com.os.ems.record.mapper.EmsRecordAlarmDataMapper;
import com.os.ems.record.domain.EmsRecordAlarmData; import com.os.ems.record.domain.EmsRecordAlarmData;
import com.os.ems.record.service.IEmsRecordAlarmDataService; import com.os.ems.record.service.IEmsRecordAlarmDataService;
import org.springframework.transaction.annotation.Transactional;
import static com.os.common.utils.SecurityUtils.getUsername; import static com.os.common.utils.SecurityUtils.getUsername;
@ -153,16 +154,19 @@ public class EmsRecordAlarmDataServiceImpl implements IEmsRecordAlarmDataService
* @return * @return
*/ */
@Override @Override
@Transactional(rollbackFor = Exception.class)
public int handleExceptionsAlarmData(Long[] objIds) { public int handleExceptionsAlarmData(Long[] objIds) {
int result = 0;
for (Long objId : objIds) { for (Long objId : objIds) {
EmsRecordAlarmData alarmData = new EmsRecordAlarmData(); EmsRecordAlarmData alarmData = new EmsRecordAlarmData();
alarmData.setObjId(objId); alarmData.setObjId(objId);
alarmData.setAlarmStatus(0L); alarmData.setAlarmStatus(0L);
alarmData.setOperationName(getUsername()); alarmData.setOperationName(getUsername());
alarmData.setOperationTime(DateUtils.getNowDate()); alarmData.setOperationTime(DateUtils.getNowDate());
emsRecordAlarmDataMapper.updateEmsRecordAlarmData(alarmData); int i = emsRecordAlarmDataMapper.updateEmsRecordAlarmData(alarmData);
result += 1;
} }
return 1; return result;
} }
/** /**

Loading…
Cancel
Save