无人机java后台代码
blame | history | patch | commit | commitdiff | show whitespace
shenyijian
2023-11-09 64fe243e5a223a09bb07c90958ecfd436ed018ea 
 src/main/java/com/dji/sample/media/service/impl/MediaServiceImpl.java


@@ -1,5 +1,8 @@


package com.dji.sample.media.service.impl;




import com.baomidou.mybatisplus.extension.plugins.pagination.Page;


import com.dji.sample.common.model.Pagination;


import com.dji.sample.common.model.PaginationData;


import com.dji.sample.common.model.ResponseResult;


import com.dji.sample.component.mqtt.model.ChannelName;


import com.dji.sample.component.mqtt.model.CommonTopicReceiver;


@@ -13,10 +16,9 @@


import com.dji.sample.manage.model.enums.UserTypeEnum;


import com.dji.sample.manage.service.IDeviceRedisService;


import com.dji.sample.manage.service.IDeviceService;


import com.dji.sample.media.model.FileUploadCallback;


import com.dji.sample.media.model.FileUploadDTO;


import com.dji.sample.media.model.MediaFileCountDTO;


import com.dji.sample.media.model.MediaFileDTO;


import com.dji.sample.media.dao.IFileMapper;


import com.dji.sample.media.model.*;


import com.dji.sample.media.model.param.SearchMediaParam;


import com.dji.sample.media.service.IFileService;


import com.dji.sample.media.service.IMediaService;


import com.dji.sample.wayline.model.dto.WaylineJobDTO;


@@ -27,6 +29,7 @@


import org.springframework.integration.annotation.ServiceActivator;


import org.springframework.messaging.MessageHeaders;


import org.springframework.stereotype.Service;


import org.springframework.web.bind.annotation.RequestParam;




import java.util.List;


import java.util.Map;


@@ -64,6 +67,9 @@


    @Autowired


    private IDeviceRedisService deviceRedisService;




    @Autowired


    private IFileMapper mapper;




    @Override


    public Boolean fastUpload(String workspaceId, String fingerprint) {


        return fileService.checkExist(workspaceId, fingerprint);


@@ -92,6 +98,18 @@




    }




    @Override


    public PaginationData<MediaJobDTO> mediaPage(String workspaceId, SearchMediaParam param) {


        Page<MediaJobDTO> waylineJobDTOPage = mapper.mediaPage(new Page<MediaJobDTO>(param.getPage(), param.getPageSize()), workspaceId, param);


        return new PaginationData<MediaJobDTO>(waylineJobDTOPage.getRecords(), new Pagination(waylineJobDTOPage));


    }




    @Override


    public PaginationData<MediaJobDTO> mediaDetail( String jobId,Long page, Long pageSize) {


        Page<MediaJobDTO> waylineJobDTOPage = mapper.mediaDetail(new Page<MediaJobDTO>(page, pageSize), jobId);


        return new PaginationData<MediaJobDTO>(waylineJobDTOPage.getRecords(), new Pagination(waylineJobDTOPage));


    }




    /**


     * Handle media files messages reported by dock.


     * 处理由dock报告的媒体文件消息。