| | |
| | | Page<MediaJobDTO> mediaPage(@Param("page") Page<MediaJobDTO> mediaFileEntityPage, @Param("workspaceId") String workspaceId, @Param("param") SearchMediaParam param); |
| | | |
| | | |
| | | Page<MediaJobDTO> mediaDetail(Page<MediaJobDTO> mediaJobDTOPage, @Param("jobId") String jobId); |
| | | Page<MediaJobDTO> mediaDetail(Page<MediaJobDTO> mediaJobDTOPage, @Param("jobId") String jobId, @Param("fileAddress") String fileAddress); |
| | | } |
| | |
| | | DATE_FORMAT(FROM_UNIXTIME(j.create_time/1000,'%Y-%m-%d'),'%Y-%m-%d') as create_time |
| | | FROM |
| | | media_file m LEFT JOIN wayline_job j ON m.job_id = j.job_id |
| | | LEFT JOIN (SELECT CONCAT("https://dev.jxpskj.com:8026/cloud-bucket",object_key) as url,job_id from media_file WHERE file_name LIKE '%.jpeg' GROUP BY job_id) t ON t.job_id = m.job_id |
| | | -- LEFT JOIN (SELECT CONCAT("https://dev.jxpskj.com:8026/cloud-bucket",object_key) as url,job_id from media_file WHERE file_name LIKE '%.jpeg' GROUP BY job_id) t ON t.job_id = m.job_id |
| | | LEFT JOIN (SELECT CONCAT(#{param.fileAddress},object_key) as url,job_id from media_file WHERE file_name LIKE '%.jpeg' GROUP BY job_id) t ON t.job_id = m.job_id |
| | | LEFT JOIN wayline_file w ON w.wayline_id = j.file_id |
| | | where 1=1 |
| | | <if test="workspaceId != null and workspaceId != ''"> |
| | |
| | | m.collect_status, |
| | | m.job_id, |
| | | m.file_id, |
| | | CONCAT("https://dev.jxpskj.com:8026/cloud-bucket",m.object_key) as url, |
| | | CONCAT(#{fileAddress},m.object_key) as url, |
| | | CASE WHEN m.file_name LIKE '%.mp4' THEN "视频" ELSE "图片" END AS type, |
| | | DATE_FORMAT( FROM_UNIXTIME( m.create_time / 1000, '%Y-%m-%d' ), '%Y-%m-%d' ) AS create_time |
| | | FROM |
| | |
| | | private Long page; |
| | | private Long pageSize; |
| | | private String dockSn; |
| | | private String fileAddress; |
| | | } |
| | |
| | | import com.fasterxml.jackson.databind.ObjectMapper; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.beans.factory.annotation.Value; |
| | | import org.springframework.integration.annotation.ServiceActivator; |
| | | import org.springframework.messaging.MessageHeaders; |
| | | import org.springframework.stereotype.Service; |
| | |
| | | @Autowired |
| | | private IFileMapper mapper; |
| | | |
| | | @Value("${oss.out-net-file-address}") |
| | | private String fileAddress; |
| | | @Value("${oss.bucket}") |
| | | private String bucket; |
| | | @Override |
| | | public Boolean fastUpload(String workspaceId, String fingerprint) { |
| | | return fileService.checkExist(workspaceId, fingerprint); |
| | |
| | | |
| | | @Override |
| | | public PaginationData<MediaJobDTO> mediaPage(String workspaceId, SearchMediaParam param) { |
| | | param.setFileAddress(fileAddress+"/"+bucket); |
| | | 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); |
| | | Page<MediaJobDTO> waylineJobDTOPage = mapper.mediaDetail(new Page<MediaJobDTO>(page, pageSize), jobId,fileAddress+"/"+bucket); |
| | | return new PaginationData<MediaJobDTO>(waylineJobDTOPage.getRecords(), new Pagination(waylineJobDTOPage)); |
| | | } |
| | | |
| | |
| | | max-request-size: 2GB |
| | | # rabbitmq: |
| | | # host: 182.106.212.58 |
| | | # port: 25672 |
| | | # port: 35672 |
| | | # username: root |
| | | # password: root |
| | | # virtualHost: / |
| | |
| | | expire: 3600 |
| | | region: us-east-1 |
| | | object-dir-prefix: |
| | | out-net-file-address: http://171.34.76.171:8880/drone/file |
| | | |
| | | logging: |
| | | level: |