SurveillanceServiceImpl.java 6.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167
  1. package com.fdkankan.scene.service.impl;
  2. import cn.hutool.core.bean.BeanUtil;
  3. import cn.hutool.core.util.StrUtil;
  4. import com.alibaba.fastjson.JSON;
  5. import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
  6. import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
  7. import com.fdkankan.common.constant.CommonStatus;
  8. import com.fdkankan.common.constant.ErrorCode;
  9. import com.fdkankan.common.constant.ServerCode;
  10. import com.fdkankan.common.exception.BusinessException;
  11. import com.fdkankan.fyun.face.FYunFileServiceInterface;
  12. import com.fdkankan.model.constants.UploadFilePath;
  13. import com.fdkankan.scene.entity.*;
  14. import com.fdkankan.scene.mapper.ISurveillanceMapper;
  15. import com.fdkankan.scene.service.*;
  16. import com.fdkankan.scene.vo.BaseSidParamVO;
  17. import com.fdkankan.scene.vo.SurveillanceParamVO;
  18. import com.fdkankan.scene.vo.SurveillanceVO;
  19. import com.fdkankan.web.response.ResultData;
  20. import java.io.IOException;
  21. import java.util.List;
  22. import java.util.Objects;
  23. import java.util.stream.Collectors;
  24. import org.springframework.beans.factory.annotation.Autowired;
  25. import org.springframework.stereotype.Service;
  26. import javax.annotation.Resource;
  27. /**
  28. * <p>
  29. * 监控推拉流信息 服务实现类
  30. * </p>
  31. *
  32. * @author
  33. * @since 2022-09-16
  34. */
  35. @Service
  36. public class SurveillanceServiceImpl extends ServiceImpl<ISurveillanceMapper, Surveillance> implements ISurveillanceService {
  37. @Autowired
  38. private IScenePlusService scenePlusService;
  39. @Autowired
  40. private ISceneEditInfoExtService sceneEditInfoExtService;
  41. @Autowired
  42. private ISceneEditInfoService sceneEditInfoService;
  43. @Resource
  44. private FYunFileServiceInterface yunFileService;
  45. @Autowired
  46. private IScenePlusExtService scenePlusExtService;
  47. @Autowired
  48. private ICommonService commonService;
  49. @Override
  50. public ResultData saveSurveillance(SurveillanceParamVO param) throws Exception {
  51. if(param.getUrlType() == 1){
  52. if(StrUtil.isEmpty(param.getPlayUrl())){
  53. throw new BusinessException(ServerCode.PARAM_REQUIRED.code(), ServerCode.PARAM_REQUIRED.formatMessage("playUrl"));
  54. }
  55. }else{
  56. if(StrUtil.isEmpty(param.getFileName()) || StrUtil.isEmpty(param.getPoster())){
  57. throw new BusinessException(ServerCode.PARAM_REQUIRED.code(), ServerCode.PARAM_REQUIRED.formatMessage("fileName、poster"));
  58. }
  59. }
  60. ScenePlus scenePlus = scenePlusService.getScenePlusByNum(param.getNum());
  61. if(Objects.isNull(scenePlus)){
  62. throw new BusinessException(ErrorCode.FAILURE_CODE_5005);
  63. }
  64. ScenePlusExt scenePlusExt = scenePlusExtService.getScenePlusExtByPlusId(scenePlus.getId());
  65. //转换视频格式
  66. if(param.getUrlType() == 2){
  67. commonService.transferToFlv(param.getNum(), param.getFileName(), scenePlusExt.getYunFileBucket());
  68. }
  69. SceneEditInfo sceneEditInfo = sceneEditInfoService.getByScenePlusId(scenePlus.getId());
  70. SceneEditInfoExt sceneEditInfoExt = sceneEditInfoExtService.getByScenePlusId(scenePlus.getId());
  71. Surveillance surveillance = this.getBySid(param.getNum(), param.getSid());
  72. if(Objects.isNull(surveillance)){
  73. surveillance = new Surveillance();
  74. }
  75. surveillance.setSid(param.getSid());
  76. surveillance.setPanoId(param.getPanoId());
  77. surveillance.setNum(param.getNum());
  78. surveillance.setName(param.getName());
  79. surveillance.setData(param.getData().toJSONString());
  80. surveillance.setPlayUrl(param.getPlayUrl());
  81. surveillance.setUrlType(param.getUrlType());
  82. surveillance.setFileName(param.getFileName());
  83. surveillance.setPoster(param.getPoster());
  84. this.saveOrUpdate(surveillance);
  85. sceneEditInfoExt.setSurveillances(CommonStatus.YES.code().intValue());
  86. sceneEditInfoExtService.updateById(sceneEditInfoExt);
  87. sceneEditInfoService.upgradeVersionById(sceneEditInfo.getId());
  88. return ResultData.ok();
  89. }
  90. @Override
  91. public ResultData deleteSurveillance(BaseSidParamVO param) throws IOException {
  92. ScenePlus scenePlus = scenePlusService.getScenePlusByNum(param.getNum());
  93. if(Objects.isNull(scenePlus)){
  94. throw new BusinessException(ErrorCode.FAILURE_CODE_5005);
  95. }
  96. Surveillance surveillance = this.getBySid(param.getNum(), param.getSid());
  97. if(Objects.isNull(surveillance)){
  98. return ResultData.ok("sid不存在");
  99. }
  100. ScenePlusExt scenePlusExt = scenePlusExtService.getScenePlusExtByPlusId(scenePlus.getId());
  101. SceneEditInfo sceneEditInfo = sceneEditInfoService.getByScenePlusId(scenePlus.getId());
  102. SceneEditInfoExt sceneEditInfoExt = sceneEditInfoExtService.getByScenePlusId(scenePlus.getId());
  103. String bucket = scenePlusExt.getYunFileBucket();
  104. this.remove(new LambdaQueryWrapper<Surveillance>().eq(Surveillance::getSid, param.getSid()));
  105. long count = this.count(new LambdaQueryWrapper<Surveillance>().eq(Surveillance::getNum, param.getNum()));
  106. if(count < 1){
  107. sceneEditInfoExt.setSurveillances(CommonStatus.NO.code().intValue());
  108. }
  109. //如果是视频类型监控,需要删除oss文件
  110. if(surveillance.getUrlType() == 2){
  111. String userEditPath = String.format(UploadFilePath.USER_EDIT_PATH, param.getNum());
  112. if(StrUtil.isNotEmpty(surveillance.getFileName())){
  113. yunFileService.deleteFile(bucket, userEditPath.concat(surveillance.getFileName()));
  114. }
  115. if(StrUtil.isNotEmpty(surveillance.getPoster())){
  116. yunFileService.deleteFile(bucket, userEditPath.concat(surveillance.getPoster()));
  117. }
  118. }
  119. sceneEditInfoExtService.updateById(sceneEditInfoExt);
  120. sceneEditInfoService.upgradeVersionById(sceneEditInfo.getId());
  121. return ResultData.ok();
  122. }
  123. @Override
  124. public List<SurveillanceVO> listSurveillance(String num) {
  125. List<Surveillance> list = this.list(new LambdaQueryWrapper<Surveillance>().eq(Surveillance::getNum, num).orderByDesc(Surveillance::getId));
  126. if(Objects.isNull(list)){
  127. return null;
  128. }
  129. List<SurveillanceVO> voList = list.stream().map(item -> {
  130. SurveillanceVO vo = BeanUtil.copyProperties(item, SurveillanceVO.class, "data");
  131. vo.setData(JSON.parseObject(item.getData()));
  132. return vo;
  133. }).collect(Collectors.toList());
  134. return voList;
  135. }
  136. @Override
  137. public Surveillance getBySid(String num, String sid) {
  138. return this.getOne(new LambdaQueryWrapper<Surveillance>().eq(Surveillance::getSid, sid).eq(Surveillance::getNum, num));
  139. }
  140. }