dianliang/lanan-system
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

注掉自动派单

Browse Source
This commit is contained in:
xiao-fajia 2024-10-04 22:13:23 +08:00
parent c436aa8d9d
commit ea93d5f209
1 changed files with 34 additions and 33 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

67
dl-module-rescue/src/main/java/cn/iocoder/yudao/module/rescue/service/impl/RescueInfoServiceImpl.java
View File

@ -412,39 +412,40 @@ public class RescueInfoServiceImpl extends ServiceImpl<RescueInfoMapper, RescueI
baseMapper.insert(rescueInfo); baseMapper.insert(rescueInfo);
detailService.save(new RescueInfoDetail(rescueInfo.getId(), "0", "救援发起", "救援发起")); detailService.save(new RescueInfoDetail(rescueInfo.getId(), "0", "救援发起", "救援发起"));
// 自动通知对应路段司机 // TODO 暂时注掉 后面在看要不要完善
List<RescueDictStaff> list = rescueDictStaffService.list(new LambdaQueryWrapper<RescueDictStaff>().in(RescueDictStaff::getDictId, rescueInfo.getRoadIds())); // // 自动通知对应路段司机
if (CollectionUtil.isEmpty(list)) { // List<RescueDictStaff> list = rescueDictStaffService.list(new LambdaQueryWrapper<RescueDictStaff>().in(RescueDictStaff::getDictId, rescueInfo.getRoadIds()));
throw exception0(500, "该路段没有司机，请先配置"); // if (CollectionUtil.isEmpty(list)) {
} // throw exception0(500, "该路段没有司机，请先配置");
// 司机的userId // }
Set<Long> driverIds = list.stream() // // 司机的userId
.map(RescueDictStaff::getDriverIds) // Set<Long> driverIds = list.stream()
.flatMap(item -> Arrays.stream(item.split(","))) // .map(RescueDictStaff::getDriverIds)
.map(Long::parseLong) // .flatMap(item -> Arrays.stream(item.split(",")))
.collect(Collectors.toSet()); // .map(Long::parseLong)
// 司机的driver_id // .collect(Collectors.toSet());
List<DriverInfo> driverInfos = driverInfoService.list(new LambdaQueryWrapper<DriverInfo>().in(DriverInfo::getUserId, driverIds)); // // 司机的driver_id
driverInfos.forEach(item -> { // List<DriverInfo> driverInfos = driverInfoService.list(new LambdaQueryWrapper<DriverInfo>().in(DriverInfo::getUserId, driverIds));
// 发消息 // driverInfos.forEach(item -> {
SysAnnouncement sysAnnouncement = new SysAnnouncement(); // // 发消息
sysAnnouncement.setType("救援信息"); // SysAnnouncement sysAnnouncement = new SysAnnouncement();
sysAnnouncement.setToUserIds(Collections.singletonList(item.getUserId())); // sysAnnouncement.setType("救援信息");
sysAnnouncement.setTitle("有新的救援订单请立即处理"); // sysAnnouncement.setToUserIds(Collections.singletonList(item.getUserId()));
sysAnnouncement.setContent("有新的救援订单请立即处理"); // sysAnnouncement.setTitle("有新的救援订单请立即处理");
announcementService.insertSysAnnouncements(sysAnnouncement); // sysAnnouncement.setContent("有新的救援订单请立即处理");
// 发订单 // announcementService.insertSysAnnouncements(sysAnnouncement);
RescueDriverInfo rescueDriverInfo = new RescueDriverInfo(); // // 发订单
rescueDriverInfo.setDriverId(item.getId()); // RescueDriverInfo rescueDriverInfo = new RescueDriverInfo();
rescueDriverInfo.setRescueId(rescueInfo.getId()); // rescueDriverInfo.setDriverId(item.getId());
rescueDriverInfo.setDriverAccept("2"); // rescueDriverInfo.setRescueId(rescueInfo.getId());
rescueDriverInfoService.insertRescueDriverInfo(rescueDriverInfo); // rescueDriverInfo.setDriverAccept("2");
}); // rescueDriverInfoService.insertRescueDriverInfo(rescueDriverInfo);
// 新增延迟消息，用于三分钟后没人接单通知 // });
TaskDto taskDto = new TaskDto(); // // 新增延迟消息，用于三分钟后没人接单通知
taskDto.setManageId(loginUser.getId()); // TaskDto taskDto = new TaskDto();
taskDto.setRescueInfoId(rescueInfo.getId()); // taskDto.setManageId(loginUser.getId());
redissonDelayQueue.offerTask(JSON.toJSONString(taskDto), UserConstants.RESCUE_TIME); // taskDto.setRescueInfoId(rescueInfo.getId());
// redissonDelayQueue.offerTask(JSON.toJSONString(taskDto), UserConstants.RESCUE_TIME);
} }
} }