From 02b948fe62503972dd6bcbfabf819fb3ca46a579 Mon Sep 17 00:00:00 2001
From: “mitao” <“2763622819@qq.com”>
Date: 星期六, 28 二月 2026 16:13:17 +0800
Subject: [PATCH] fix:接口联调修改
---
xp-robotaxi-maintenance-boot/src/main/java/com/xiaopeng/maintenance/service/impl/XpTaskServiceImpl.java | 8 +++++---
1 files changed, 5 insertions(+), 3 deletions(-)
diff --git a/xp-robotaxi-maintenance-boot/src/main/java/com/xiaopeng/maintenance/service/impl/XpTaskServiceImpl.java b/xp-robotaxi-maintenance-boot/src/main/java/com/xiaopeng/maintenance/service/impl/XpTaskServiceImpl.java
index 110a95c..c49f456 100644
--- a/xp-robotaxi-maintenance-boot/src/main/java/com/xiaopeng/maintenance/service/impl/XpTaskServiceImpl.java
+++ b/xp-robotaxi-maintenance-boot/src/main/java/com/xiaopeng/maintenance/service/impl/XpTaskServiceImpl.java
@@ -46,6 +46,7 @@
import org.springframework.beans.BeanUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
import org.springframework.util.CollectionUtils;
import java.text.SimpleDateFormat;
@@ -155,6 +156,7 @@
return pageInfo;
}
+ @Transactional(rollbackFor = Exception.class)
@Override
public void saveVehicleAccident(SaveVehicleAccidentDto dto, XpOperationsUser xpOperationsUser) {
XpTask xpTask = new XpTask();
@@ -167,7 +169,7 @@
xpTask.setTaskDescription(dto.getTaskDescription());
// todo 获取车辆当前位置
// xpTask.setVehicleLocation();
- xpTask.setVehicleId(dto.getId());
+ xpTask.setVehicleId(dto.getId());
// xpTask.setVehicleLon();
// xpTask.setVehicleLat();
xpTask.setReportUserId(xpOperationsUser.getId());
@@ -184,12 +186,12 @@
List<Long> userIds = xpOperationsRoleResult.getData().stream().map(XpOperationsRole::getOperationsUserId).collect(Collectors.toList());
xpTask.setHandleUserId(StringUtils.join(userIds, ","));
}
- //查询事故处理限时配置
+ // 根据事故处理限时配置设置任务截止时间
LocalDateTime endTime = LocalDateTime.now().plusMinutes(taskRule.getProcessingTimeLimit());
xpTask.setEndTime(endTime);
this.save(xpTask);
- //发送消息通知
+ // 发送消息通知
List<Long> userIds = Arrays.stream(xpTask.getHandleUserId().split(",")).map(Long::valueOf).collect(Collectors.toList());
if (CollUtil.isNotEmpty(userIds)) {
R<List<XpOperationsUser>> xpOperationUserResult = xpOperationUserClient.listByIds(userIds);
--
Gitblit v1.7.1