xieb
2024-02-27 db7d67e9ef32723d9b397740168e09053d9c2cff
src/main/java/com/dji/sample/wayline/service/impl/FlightTaskServiceImpl.java
@@ -65,6 +65,7 @@
    /**
     * Handle the progress messages of the flight tasks reported by the dock.
     * 处理机场上报的飞行任务进度信息
     * @param receiver
     * @param headers
     */
@@ -74,6 +75,9 @@
                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();
@@ -110,7 +114,7 @@
                .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());