| | |
| | | |
| | | /** |
| | | * Handle the progress messages of the flight tasks reported by the dock. |
| | | * 处理机场上报的飞行任务进度信息 |
| | | * @param receiver |
| | | * @param headers |
| | | */ |
| | |
| | | new TypeReference<EventsReceiver<WaylineTaskProgressReceiver>>(){}); |
| | | eventsReceiver.setBid(receiver.getBid()); |
| | | eventsReceiver.setSn(receiver.getGateway()); |
| | | |
| | | //用户记录飞行任务id |
| | | RedisOpsUtils.set(RedisConst.FLIGHT_LOG + "job_id",receiver.getBid()); |
| | | |
| | | WaylineTaskProgressReceiver output = eventsReceiver.getOutput(); |
| | | |
| | |
| | | .mediaCount(mediaCount) |
| | | .build(); |
| | | |
| | | // record the update of the media count. |
| | | //记录媒体计数的更新 |
| | | if (Objects.nonNull(job.getMediaCount()) && job.getMediaCount() != 0) { |
| | | RedisOpsUtils.hashSet(RedisConst.MEDIA_FILE_PREFIX + receiver.getGateway(), job.getJobId(), |
| | | MediaFileCountDTO.builder().jobId(receiver.getBid()).mediaCount(job.getMediaCount()).uploadedCount(0).build()); |