4dkankan-parent/4dkankan-center-scene/src/main/java/com/fdkankan/scene/service/impl/SurveillanceServiceImpl.java

package com.fdkankan.scene.service.impl;

import cn.hutool.core.bean.BeanUtil;
import cn.hutool.core.util.StrUtil;
import cn.hutool.json.JSONUtil;
import com.alibaba.fastjson.JSON;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.fdkankan.common.constant.CommonStatus;
import com.fdkankan.common.constant.ErrorCode;
import com.fdkankan.common.exception.BusinessException;
import com.fdkankan.common.response.ResultData;
import com.fdkankan.scene.bean.SurveillanceBean;
import com.fdkankan.scene.entity.SceneEditInfoExt;
import com.fdkankan.scene.entity.ScenePlus;
import com.fdkankan.scene.entity.Surveillance;
import com.fdkankan.scene.mapper.ISurveillanceMapper;
import com.fdkankan.scene.service.ISceneEditInfoExtService;
import com.fdkankan.scene.service.IScenePlusService;
import com.fdkankan.scene.service.ISurveillanceService;
import com.fdkankan.scene.vo.BaseSidParamVO;
import com.fdkankan.scene.vo.SurveillanceParamVO;
import com.fdkankan.scene.vo.BaseIdParamVO;
import java.util.List;
import java.util.Objects;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

/**
 * <p>
 * 监控推拉流信息 服务实现类
 * </p>
 *
 * @author 
 * @since 2022-09-16
 */
@Service
public class SurveillanceServiceImpl extends ServiceImpl<ISurveillanceMapper, Surveillance> implements ISurveillanceService {

    @Autowired
    private IScenePlusService scenePlusService;
    @Autowired
    private ISceneEditInfoExtService sceneEditInfoExtService;

    @Override
    public ResultData saveSurveillance(SurveillanceParamVO param) {

        ScenePlus scenePlus = scenePlusService.getScenePlusByNum(param.getNum());
        if(Objects.isNull(scenePlus)){
            throw new BusinessException(ErrorCode.FAILURE_CODE_5005);
        }
        SceneEditInfoExt sceneEditInfoExt = sceneEditInfoExtService.getByScenePlusId(scenePlus.getId());

        Surveillance surveillance = null;
        if(StrUtil.isNotEmpty(param.getSid())){
            surveillance = this.getBySid(param.getSid());
        }else{
            surveillance = new Surveillance();
            surveillance.setSid(param.getData().getString("sid"));
        }
        surveillance.setNum(param.getNum());
        surveillance.setName(param.getName());
        surveillance.setData(param.getData().toJSONString());
        surveillance.setPlayUrl(param.getPlayUrl());
        this.saveOrUpdate(surveillance);

        sceneEditInfoExt.setSurveillances(CommonStatus.YES.code().intValue());
        sceneEditInfoExtService.updateById(sceneEditInfoExt);

        return ResultData.ok();
    }

    @Override
    public ResultData deleteSurveillance(BaseSidParamVO param) {
        ScenePlus scenePlus = scenePlusService.getScenePlusByNum(param.getNum());
        if(Objects.isNull(scenePlus)){
            throw new BusinessException(ErrorCode.FAILURE_CODE_5005);
        }
        SceneEditInfoExt sceneEditInfoExt = sceneEditInfoExtService.getByScenePlusId(scenePlus.getId());

        this.remove(new LambdaQueryWrapper<Surveillance>().eq(Surveillance::getSid, param.getSid()));

        long count = this.count(new LambdaQueryWrapper<Surveillance>().eq(Surveillance::getNum, param.getNum()));
        if(count < 1){
            sceneEditInfoExt.setSurveillances(CommonStatus.NO.code().intValue());
        }
        sceneEditInfoExtService.updateById(sceneEditInfoExt);
        return ResultData.ok();
    }

    @Override
    public List<SurveillanceBean> listSurveillance(String num) {
        List<Surveillance> list = this.list(new LambdaQueryWrapper<Surveillance>().eq(Surveillance::getNum, num));
        return BeanUtil.copyToList(list, SurveillanceBean.class);
    }

    @Override
    public Surveillance getBySid(String sid) {
        return this.getOne(new LambdaQueryWrapper<Surveillance>().eq(Surveillance::getSid, sid));
    }

}