| | |
| | | import java.util.List; |
| | | |
| | | import com.alibaba.fastjson2.JSON; |
| | | import com.ard.common.core.domain.entity.SysUser; |
| | | import com.ard.common.utils.DateUtils; |
| | | import com.ard.common.utils.SecurityUtils; |
| | | import com.ard.common.utils.uuid.IdUtils; |
| | |
| | | import com.ard.route.domain.route.ArdRoutePoint; |
| | | import com.ard.route.mapper.ArdRoutePointMapper; |
| | | import com.ard.route.websocket.utils.MiWebSocketUtils; |
| | | import com.ard.system.mapper.SysUserMapper; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.stereotype.Service; |
| | |
| | | |
| | | @Autowired |
| | | private ArdRoutePointMapper ardRoutePointMapper; |
| | | |
| | | @Autowired |
| | | private SysUserMapper sysUserMapper; |
| | | |
| | | /** |
| | | * 查询航线任务 |
| | |
| | | ardRouteMission.setExecuteStatus("0"); |
| | | ardRouteMission.setIsRead("0"); |
| | | ardRouteMission.setCreateTime(DateUtils.getNowDate()); |
| | | ardRouteMission.setIssuerName(getUserName(ardRouteMission.getIssuerId())); |
| | | dataProcessingRoutePoint(ardRouteMission.getMissionDetailList(),ardRouteMission.getId()); |
| | | Long userId = ardRouteMission.getIssuerId().longValue(); |
| | | try { |
| | | log.debug("给用户{}定时推送,航线任务信息", ardRouteMission.getIssuerName()); |
| | | MiWebSocketUtils.sendMessage(userId,JSON.toJSONString(ardRouteMission)); |
| | | MiWebSocketUtils.sendMessage(ardRouteMission.getIssuerId(),JSON.toJSONString(ardRouteMission)); |
| | | } catch (Exception e) { |
| | | log.error("Error sending message to session {}", ardRouteMission.getIssuerName(), e); |
| | | } |
| | |
| | | @Override |
| | | public int updateArdRouteMission(ArdRouteMission ardRouteMission) { |
| | | ardRouteMission.setUpdateTime(DateUtils.getNowDate()); |
| | | ardRouteMission.setIssuerName(getUserName(ardRouteMission.getIssuerId())); |
| | | // 删除航线任务航点 |
| | | ardRoutePointMapper.deleteArdRoutePointByMissionId(ardRouteMission.getId()); |
| | | // 重新插入航线任务航点 |
| | |
| | | return ardRouteMissionMapper.updateArdRouteMission(ardRouteMission); |
| | | } |
| | | |
| | | // 获取用户名称 |
| | | private String getUserName(Long userId) { |
| | | SysUser sysUser = sysUserMapper.selectUserById(userId); |
| | | return sysUser.getUserName(); |
| | | } |
| | | |
| | | /** |
| | | * 航线任务航点对象数据加工 |
| | | */ |