package cn.huge.module.xylink.service;
|
|
import cn.huge.base.common.exception.ServiceException;
|
import cn.huge.base.common.utils.DateUtils;
|
import cn.huge.base.common.utils.IdUtils;
|
import cn.huge.base.common.utils.ObjectUtils;
|
import cn.huge.module.client.api.impl.UtilsClientImpl;
|
import cn.huge.module.xylink.constant.XylinkConsts;
|
import cn.huge.module.xylink.dao.mapper.XylinkVideoMapper;
|
import cn.huge.module.xylink.domain.dto.XylinkVedioDTO;
|
import cn.huge.module.xylink.domain.po.XylinkSys;
|
import cn.huge.module.xylink.domain.po.XylinkVideo;
|
import cn.huge.module.xylink.utils.XylinkUtils;
|
import com.alibaba.fastjson.JSON;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import org.apache.commons.io.FileUtils;
|
import org.apache.http.client.methods.CloseableHttpResponse;
|
import org.apache.http.client.methods.HttpGet;
|
import org.apache.http.client.utils.URIBuilder;
|
import org.apache.http.impl.client.CloseableHttpClient;
|
import org.apache.http.impl.client.HttpClients;
|
import org.apache.http.util.EntityUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Service;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.data.domain.Page;
|
import org.springframework.data.domain.PageImpl;
|
import org.springframework.data.domain.PageRequest;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import javax.annotation.PostConstruct;
|
import java.io.File;
|
import java.io.FileOutputStream;
|
import java.io.InputStream;
|
import java.io.OutputStream;
|
import java.net.HttpURLConnection;
|
import java.net.URISyntaxException;
|
import java.net.URL;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.Map;
|
|
/**
|
* @title: 小鱼云会议录制视频记录表业务逻辑处理
|
* @Description JPA的单表数据查询以由BaseService完成
|
* @company hugeinfo
|
* @author liyj
|
* @Time 2023-08-18 14:12:24
|
* @version 1.0.0
|
*/
|
@Slf4j
|
@Service
|
@Transactional(rollbackFor = Exception.class)
|
public class XylinkVideoService extends ServiceImpl<XylinkVideoMapper, XylinkVideo>{
|
|
@Autowired
|
private XylinkVideoMapper mapper;
|
|
@Autowired
|
private XylinkSysService xylinkSysService;
|
|
@Autowired
|
private UtilsClientImpl utilsClient;
|
|
/**
|
* 更新对象
|
* @param entity 对象
|
*/
|
public void updateXylinkVideo(XylinkVideo entity){
|
try{
|
mapper.updateXylinkVideo(entity);
|
}catch (Exception e){
|
log.error("service方法[XylinkVideoService.updateXylinkVideo]调用异常："+e, e);
|
throw new ServiceException("XylinkVideoService.updateXylinkVideo", e);
|
}
|
}
|
|
/**
|
* 条件更新对象
|
* @param entity 对象
|
* @param terms 条件
|
*/
|
public void updateXylinkVideoTerms(XylinkVideo entity, Map<String, Object> terms){
|
try{
|
mapper.updateXylinkVideoTerms(entity, terms);
|
}catch (Exception e){
|
log.error("service方法[XylinkVideoService.updateXylinkVideoTerms]调用异常："+e, e);
|
throw new ServiceException("XylinkVideoService.updateXylinkVideoTerms", e);
|
}
|
}
|
|
/**
|
* 根据编号物理删除
|
* @param id 查询条件集合
|
*/
|
public void deleteXylinkVideo(String id){
|
try{
|
mapper.deleteXylinkVideo(id);
|
}catch (Exception e){
|
log.error("service方法[XylinkVideoService.deleteXylinkVideo]调用异常："+e, e);
|
throw new ServiceException("XylinkVideoService.deleteXylinkVideo", e);
|
}
|
}
|
|
/**
|
* 按条件查询
|
* @param terms 条件
|
* @return List
|
*/
|
public List<XylinkVideo> listTerms(Map<String, Object> terms){
|
return mapper.listTerms(terms);
|
}
|
|
/**
|
* 按条件统计
|
* @param terms 条件
|
* @return long
|
*/
|
public long countTerms(Map<String, Object> terms){
|
return mapper.countTerms(terms);
|
}
|
|
/**
|
* 按条件分页查询
|
* @param page 分页对象
|
* @param terms 条件
|
* @return Page
|
*/
|
public Page<XylinkVideo> pageQuery(PageRequest page, Map<String, Object> terms){
|
long total = mapper.countTerms(terms);
|
List<XylinkVideo> content = mapper.pageTerms(page, terms);
|
return new PageImpl<XylinkVideo>(content, page, total);
|
}
|
|
/**
|
* 新增或更新对象
|
* @param xylinkVideo 实体对象
|
*/
|
public void saveXylinkVideo(XylinkVideo xylinkVideo){
|
try{
|
Date nowDate = DateUtils.getNowDate();
|
// 判断是否新增
|
if (IdUtils.checkNewId(xylinkVideo.getId())){
|
xylinkVideo.setId(utilsClient.getNewTimeId());
|
xylinkVideo.setCreateTime(nowDate);
|
}
|
xylinkVideo.setUpdateTime(nowDate);
|
this.saveOrUpdate(xylinkVideo);
|
}catch (Exception e){
|
log.error("service方法[XylinkVideoService.saveXylinkVideo]调用异常："+e, e);
|
throw new ServiceException("XylinkVideoService.saveXylinkVideo", e);
|
}
|
}
|
|
/**
|
* 小鱼云会议录制视频转存到平台服务器
|
* @param vodId
|
*/
|
public String saveVideoToDyh(String vodId, String fileName){
|
try{
|
log.info("start saveVideoToDyh fileName {}",fileName);
|
String url = XylinkUtils.getDownloadUrl(vodId);
|
// 下载文件保存路径
|
XylinkSys dyhSavenSys = xylinkSysService.getByTypeAndCode(XylinkConsts.SYS_TYPE_1, XylinkConsts.SYS_CODE_1);
|
if(ObjectUtils.isNotEmpty(dyhSavenSys)){
|
log.info("start saveVideoToDyh dyhSavenSys {}", JSON.toJSONString(dyhSavenSys));
|
}
|
|
// 路径不存在创建路径
|
File sf = new File(dyhSavenSys.getSysValue());
|
if(!sf.exists()){
|
sf.mkdirs();
|
}
|
String savePath = dyhSavenSys.getSysValue() + fileName;
|
log.info("saveVideoToDyh savePath {}, DownloadUrl {}",savePath,url);
|
CloseableHttpClient httpclient = HttpClients.createDefault();
|
// URIBuilder urlBuilder = new URIBuilder(url);
|
// urlBuilder.addParameter("fileName", fileName);
|
HttpGet httpGet = new HttpGet(url);
|
try (CloseableHttpResponse response = httpclient.execute(httpGet)) {
|
log.info("finish saveVideoToDyh response {}",response);
|
if (response.getStatusLine().getStatusCode() == 200) {
|
try (InputStream inputStream = response.getEntity().getContent();
|
FileOutputStream outputStream = new FileOutputStream(new File(savePath))) {
|
byte[] buffer = new byte[1024];
|
int bytesRead;
|
while ((bytesRead = inputStream.read(buffer)) != -1) {
|
outputStream.write(buffer, 0, bytesRead);
|
}
|
}
|
// 删除小鱼服务器上的视频
|
XylinkUtils.deleteVideo(vodId);
|
// 返回多元化访问url
|
XylinkSys dyhPlayUrlSys = xylinkSysService.getByTypeAndCode(XylinkConsts.SYS_TYPE_1, XylinkConsts.SYS_CODE_2);
|
String dyhPlayUrl = dyhPlayUrlSys.getSysValue()+fileName;
|
log.info("finish saveVideoToDyh dyhPlayUrl {}",dyhPlayUrl);
|
return dyhPlayUrl;
|
} else {
|
log.error("Failed to download video, status code: {}", response.getStatusLine().getStatusCode());
|
return null;
|
}
|
}
|
}catch (Exception e){
|
log.error("service方法[XylinkVideoService.saveVideoToDyh]调用异常："+e, e);
|
return null;
|
}
|
}
|
|
|
/**
|
* 根据url下载文件流 todo
|
* @param urlStr
|
* @return
|
*/
|
public String getInputStreamByUrl(String urlStr, String name) {
|
try {
|
//url解码
|
URL url = new URL(java.net.URLDecoder.decode(urlStr, "UTF-8"));
|
HttpURLConnection conn = (HttpURLConnection) url.openConnection();
|
//设置超时间为3秒
|
conn.setConnectTimeout(3 * 1000);
|
//防止屏蔽程序抓取而返回403错误
|
conn.setRequestProperty("User-Agent", "Mozilla/4.0 (compatible; MSIE 5.0; Windows NT; DigExt)");
|
//得到输入流
|
InputStream is = conn.getInputStream();
|
byte[] bs = new byte[1024];
|
int len;
|
XylinkSys downUrlSys = xylinkSysService.getByTypeAndCode(XylinkConsts.SYS_TYPE_1, XylinkConsts.SYS_CODE_1);
|
String downPath = downUrlSys.getSysValue();
|
File sf = new File(downPath);
|
if(!sf.exists()){
|
sf.mkdirs();
|
}
|
OutputStream os = new FileOutputStream(downPath+name);
|
while ((len = is.read(bs)) != -1) {
|
os.write(bs, 0, len);
|
}
|
os.close();
|
is.close();
|
XylinkSys showUrlSys = xylinkSysService.getByTypeAndCode(XylinkConsts.SYS_TYPE_1, XylinkConsts.SYS_CODE_1);
|
String showUrl = showUrlSys+name;
|
return showUrl;
|
} catch (Exception e) {
|
log.error("获取失败！");
|
return null;
|
}
|
}
|
|
}
|
