| | |
| | | import com.ard.sample.component.mqtt.service.IMessageSenderService; |
| | | import com.ard.common.core.redis.RedisConst; |
| | | import com.ard.common.core.redis.RedisOpsUtils; |
| | | import com.ard.sample.component.websocket.enums.MessageType; |
| | | import com.ard.sample.component.websocket.handler.DockWebSocketHandler; |
| | | import com.ard.sample.component.websocket.model.BizCodeEnum; |
| | | import com.ard.sample.component.websocket.model.CustomWebSocketMessage; |
| | | import com.ard.sample.component.websocket.service.ISendMessageService; |
| | |
| | | private ObjectMapper mapper; |
| | | |
| | | @Autowired |
| | | private DockWebSocketHandler _dockWebSocketHandler; |
| | | |
| | | @Autowired |
| | | private ISendMessageService websocketMessageService; |
| | | |
| | | @Autowired |
| | |
| | | new TypeReference<EventsReceiver<WaylineTaskProgressReceiver>>(){}); |
| | | eventsReceiver.setBid(receiver.getBid()); |
| | | eventsReceiver.setSn(receiver.getGateway()); |
| | | eventsReceiver.setType(MessageType.STATUS.getType()+"-flighttask_progress"); |
| | | eventsReceiver.setMethod(EventsMethodEnum.FLIGHT_TASK_PROGRESS.getMethod()); |
| | | |
| | | WaylineTaskProgressReceiver output = eventsReceiver.getOutput(); |
| | | |
| | |
| | | .bizCode(BizCodeEnum.FLIGHT_TASK_PROGRESS.getCode()) |
| | | .build()); |
| | | |
| | | if (receiver.getNeedReply() == 1) { |
| | | String json=""; |
| | | try { |
| | | json = mapper.writeValueAsString(eventsReceiver); |
| | | } |
| | | catch (Exception e){ |
| | | e.printStackTrace(); |
| | | } |
| | | _dockWebSocketHandler.sendMessageToSubscribers(dockSn, MessageType.STATUS.getType() + "-flighttask_progress",json); |
| | | |
| | | if (receiver.getNeedReply()!=null &&receiver.getNeedReply() == 1) { |
| | | messageSender.publish(receivedTopic + TopicConst._REPLY_SUF, |
| | | CommonTopicResponse.builder() |
| | | .tid(receiver.getTid()) |
| | |
| | | .data(RequestsReply.success()) |
| | | .build()); |
| | | } |
| | | |
| | | } |
| | | |
| | | /** |
| | | * 定时检查并处理航线定时任务 |
| | | * <p> |
| | | * 该方法每5秒执行一次,从Redis有序集合中获取最早需要执行的任务,检查其执行时间: |
| | | * 1. 若任务已过期(超过当前时间30秒),则标记为失败并删除 |
| | | * 2. 若任务在允许的时间窗口内(当前时间±30秒),则执行任务并删除 |
| | | * </p> |
| | | * |
| | | * <p>任务ID格式:{workspace_id}:{dock_sn}:{job_id}</p> |
| | | */ |
| | | @Scheduled(initialDelay = 10, fixedRate = 5, timeUnit = TimeUnit.SECONDS) |
| | | private void checkScheduledJob() { |
| | | Object jobIdValue = RedisOpsUtils.zGetMin(RedisConst.WAYLINE_JOB_TIMED_EXECUTE); |