|
@@ -27,35 +27,41 @@ public class WatermarkVideoJob implements Job {
|
|
|
private IMaterialInfoService materialInfoService;
|
|
|
@Override
|
|
|
public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
|
|
|
- QueryWrapper<VideoWatermarkTask> queryWrapper = new QueryWrapper<>();
|
|
|
- queryWrapper.in("status","Submitted","Transcoding");
|
|
|
- List<VideoWatermarkTask> list = videoWaterMarkService.list(queryWrapper);
|
|
|
- if(list != null && list.size() > 0){
|
|
|
- for (VideoWatermarkTask videoWatermarkTask : list){
|
|
|
- MpsUtils mpsUtils = new MpsUtils();
|
|
|
- QueryJobListResponse.Job job = mpsUtils.getJobStatus(videoWatermarkTask.getJobId());
|
|
|
- if (job.getState().equals("TranscodeSuccess")){
|
|
|
- String url = "https://ctop-media.oss-cn-beijing.aliyuncs.com/"+job.getOutput().getOutputFile().getObject();
|
|
|
+ Thread thread = new Thread() {
|
|
|
+ @Override
|
|
|
+ public void run() {
|
|
|
+ QueryWrapper<VideoWatermarkTask> queryWrapper = new QueryWrapper<>();
|
|
|
+ queryWrapper.in("status", "Submitted", "Transcoding");
|
|
|
+ List<VideoWatermarkTask> list = videoWaterMarkService.list(queryWrapper);
|
|
|
+ if (list != null && list.size() > 0) {
|
|
|
+ for (VideoWatermarkTask videoWatermarkTask : list) {
|
|
|
+ MpsUtils mpsUtils = new MpsUtils();
|
|
|
+ QueryJobListResponse.Job job = mpsUtils.getJobStatus(videoWatermarkTask.getJobId());
|
|
|
+ if (job.getState().equals("TranscodeSuccess")) {
|
|
|
+ String url = "https://ctop-media.oss-cn-beijing.aliyuncs.com/" + job.getOutput().getOutputFile().getObject();
|
|
|
|
|
|
- try {
|
|
|
- String localPath = LoadFileUtil.downLoadFromUrl(url, PropertiesUtils.getValue("kuaishou_config", "video_sava_path"));
|
|
|
-// String localPath = LoadFileUtil.downLoadFromUrl(url,"D:/video/");
|
|
|
- String md5 = LoadFileUtil.getMD5(localPath);
|
|
|
- LoadFileUtil.delFile(localPath);
|
|
|
- QueryWrapper<MaterialInfo> materialInfoQueryWrapper = new QueryWrapper<>();
|
|
|
- materialInfoQueryWrapper.eq("watermark_code",job.getJobId());
|
|
|
- MaterialInfo materialInfo = materialInfoService.getOne(materialInfoQueryWrapper);
|
|
|
- materialInfo.setWatermarkUrl(url);
|
|
|
- materialInfoService.saveOrUpdate(materialInfo);
|
|
|
- videoWatermarkTask.setVideoUrl(url);
|
|
|
- videoWatermarkTask.setStatus(job.getState());
|
|
|
- videoWatermarkTask.setVideoId(materialInfo.getId());
|
|
|
- videoWaterMarkService.updateById(videoWatermarkTask);
|
|
|
- } catch (IOException e) {
|
|
|
- e.printStackTrace();
|
|
|
+ try {
|
|
|
+ String localPath = LoadFileUtil.downLoadFromUrl(url, PropertiesUtils.getValue("kuaishou_config", "video_sava_path"));
|
|
|
+ // String localPath = LoadFileUtil.downLoadFromUrl(url,"D:/video/");
|
|
|
+ String md5 = LoadFileUtil.getMD5(localPath);
|
|
|
+ LoadFileUtil.delFile(localPath);
|
|
|
+ QueryWrapper<MaterialInfo> materialInfoQueryWrapper = new QueryWrapper<>();
|
|
|
+ materialInfoQueryWrapper.eq("watermark_code", job.getJobId());
|
|
|
+ MaterialInfo materialInfo = materialInfoService.getOne(materialInfoQueryWrapper);
|
|
|
+ materialInfo.setWatermarkUrl(url);
|
|
|
+ materialInfoService.saveOrUpdate(materialInfo);
|
|
|
+ videoWatermarkTask.setVideoUrl(url);
|
|
|
+ videoWatermarkTask.setStatus(job.getState());
|
|
|
+ videoWatermarkTask.setVideoId(materialInfo.getId());
|
|
|
+ videoWaterMarkService.updateById(videoWatermarkTask);
|
|
|
+ } catch (IOException e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ }
|
|
|
+ }
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
- }
|
|
|
+ };
|
|
|
+ thread.start();
|
|
|
}
|
|
|
}
|