|
package com.qxueyou.scc.teach.res.service.impl.resitem;
|
|
import java.io.File;
|
import java.util.Date;
|
|
import com.obs.services.ObsClient;
|
import com.obs.services.model.ObsObject;
|
import com.qxueyou.scc.sys.utils.VideoUtil;
|
import org.apache.commons.io.FileUtils;
|
import org.apache.commons.lang3.StringUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Service;
|
|
import com.alibaba.fastjson.JSONObject;
|
import com.qxueyou.scc.base.model.Result;
|
import com.qxueyou.scc.base.service.ICacheService;
|
import com.qxueyou.scc.base.service.impl.CommonAppService;
|
import com.qxueyou.scc.base.util.CollectionUtils;
|
import com.qxueyou.scc.base.util.TraceUtils;
|
import com.qxueyou.scc.media.model.MediaVideo;
|
import com.qxueyou.scc.media.model.VideoConverTask;
|
import com.qxueyou.scc.teach.res.model.Res;
|
import com.qxueyou.scc.teach.res.model.ResFile;
|
import com.qxueyou.scc.teach.res.model.ResItemAudio;
|
import com.qxueyou.scc.teach.res.model.ResItemVideo;
|
import com.qxueyou.scc.teach.res.service.IFileService;
|
import com.qxueyou.scc.teach.res.service.IResItemService;
|
import com.qxueyou.scc.teach.res.service.impl.ResService;
|
|
@Service(value = "ResItemVideoService")
|
public class ResItemVideoService extends CommonAppService implements IResItemService {
|
|
public static final String RES_VIDEO_CONVER_LST = "RES_VIDEO_CONVER_LST";
|
|
@Autowired
|
IFileService fileService;
|
|
@Autowired
|
ICacheService cacheService;
|
|
|
@Override
|
public String add(String fileId, String name) {
|
ResFile file = fileService.read(fileId);
|
String mediaVideoId = addVideoConverTask(file);
|
|
ResItemVideo resVideo = new ResItemVideo();
|
|
TraceUtils.setCreateTrace(resVideo);
|
try {
|
resVideo.setFileId(fileId);
|
resVideo.setPlayTime((int) VideoUtil.getMp4Duration(file.getPath()));
|
resVideo.setName(name);
|
resVideo.setMediaVideoId(mediaVideoId);
|
resVideo.setStatus(ResItemVideo.STATUS_LINEUP);
|
save(resVideo);
|
|
// 将mediaVideoId放进缓存
|
cacheService.lstRightPush(RES_VIDEO_CONVER_LST, mediaVideoId);
|
}catch (Exception e){
|
e.printStackTrace();
|
}
|
return resVideo.getVideoId();
|
}
|
|
private String addVideoConverTask(ResFile file) {
|
|
MediaVideo video = insertMediaVideo(file);
|
insertMediaVideoConverTask(video);
|
|
return video.getVideoId();
|
|
}
|
|
private MediaVideo insertMediaVideo(ResFile file) {
|
|
MediaVideo video = new MediaVideo();
|
|
TraceUtils.setCreateTrace(video);
|
|
try {
|
video.setDeleteFlag(false);
|
video.setPlayTime((int) VideoUtil.getMp4Duration(file.getPath()));
|
video.setName(file.getFileName());
|
video.setOrigUrl(file.getPath());
|
video.setStatus(MediaVideo.STATUS_LINEUP);
|
video.setType(MediaVideo.MEDIA_VIDEO);
|
}catch (Exception e){
|
e.printStackTrace();
|
}
|
|
save(video);
|
|
return video;
|
}
|
|
private Result insertMediaVideoConverTask(MediaVideo resVideo) {
|
|
VideoConverTask task = new VideoConverTask();
|
|
task.setCreateTime(new Date());
|
task.setDeleteFlag(false);
|
task.setVideoId(resVideo.getVideoId());
|
task.setVideoUrl(resVideo.getOrigUrl());
|
task.setType(MediaVideo.MEDIA_VIDEO);
|
task.setPriority(5);
|
|
save(task);
|
|
return new Result(true);
|
}
|
|
@Override
|
public Result update(String id, String name) {
|
|
ResItemVideo video = read(ResItemVideo.class, id);
|
|
TraceUtils.setUpdateTrace(video);
|
|
video.setName(name);
|
|
save(video);
|
|
return new Result(true, "success");
|
}
|
|
@Override
|
public String readAccessPath(String resId, String attribute) {
|
|
ResItemVideo resItemVideo = read(ResItemVideo.class, resId);
|
|
if (resItemVideo != null && resItemVideo.getStatus() != ResItemVideo.STATUS_DRAFT) {
|
ResFile resFile = read(ResFile.class, resItemVideo.getFileId());
|
return resFile.getPath();
|
// return null;
|
}
|
|
MediaVideo video = read(MediaVideo.class, resItemVideo.getMediaVideoId());
|
|
if (video == null) {
|
return null;
|
}
|
|
return JSONObject.toJSONString(CollectionUtils.newObjectMap("hd", video.getAndroidHD(), "sd", video.getAndroidSD(), "ld", video.getAndroidLD(), "path", StringUtils.isNotEmpty(video.getAndroidHD()) ? video.getAndroidHD()
|
: StringUtils.isNotEmpty(video.getAndroidSD()) ? video.getAndroidSD() : video.getAndroidLD()));
|
|
}
|
|
@Override
|
public String getResItemType() {
|
return Res.FILE_TYPE_VIDEO;
|
}
|
|
/**
|
* 定时器转码成功后 同步更新ResItemVideo的状态
|
*/
|
@Scheduled(cron = "0/2 * * * * ?") // 每2秒执行一次
|
public void doTimer() {
|
|
String mediaVideoId = cacheService.lstLeftPop(RES_VIDEO_CONVER_LST);
|
|
if (StringUtils.isBlank(mediaVideoId)) {
|
return;
|
}
|
|
MediaVideo mediaVideo = read(MediaVideo.class, mediaVideoId);
|
if (mediaVideo.getStatus() == MediaVideo.STATUS_DRAFT) {
|
if (mediaVideo.getType().equals("video")) {
|
ResItemVideo resItemVideo = findUnique(
|
"from ResItemVideo where deleteFlag is false and mediaVideoId = ?",
|
CollectionUtils.newList(mediaVideoId), ResItemVideo.class);
|
resItemVideo.setStatus(ResItemVideo.STATUS_DRAFT);
|
TraceUtils.setUpdateTrace(resItemVideo);
|
resItemVideo.setVideoSeconds(mediaVideo.getPlayTime());
|
save(resItemVideo);
|
|
cacheService.lstRightPush(ResService.RES_TOUPDATE_CONVER_STATUS_LST, resItemVideo.getVideoId());// 将转码完成后的文件id放入缓存。
|
return;
|
} else if (mediaVideo.getType().equals("audio")) {
|
ResItemAudio resItemAudio = findUnique(
|
"from ResItemAudio where deleteFlag is false and mediaVideoId = ?",
|
CollectionUtils.newList(mediaVideoId), ResItemAudio.class);
|
resItemAudio.setStatus(ResItemVideo.STATUS_DRAFT);
|
TraceUtils.setUpdateTrace(resItemAudio);
|
resItemAudio.setSeconds(mediaVideo.getPlayTime());
|
save(resItemAudio);
|
|
cacheService.lstRightPush(ResService.RES_TOUPDATE_CONVER_STATUS_LST, resItemAudio.getAudioId());// 将转码完成后的文件id放入缓存。
|
return;
|
}
|
|
}
|
cacheService.lstRightPush(RES_VIDEO_CONVER_LST, mediaVideoId);
|
|
}
|
}
|
