4dkankan-manage-jp/src/main/java/com/fdkankan/manage_jp/service/impl/ScenePlusServiceImpl.java

package com.fdkankan.manage_jp.service.impl;

import cn.hutool.core.io.FileUtil;
import cn.hutool.core.thread.ThreadUtil;
import cn.hutool.core.util.StrUtil;
import cn.hutool.json.JSONUtil;
import com.alibaba.fastjson.JSONObject;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.fdkankan.common.constant.SceneVersionType;
import com.fdkankan.common.util.FileUtils;
import com.fdkankan.fyun.face.FYunFileServiceInterface;
import com.fdkankan.manage_jp.common.*;
import com.fdkankan.manage_jp.entity.*;
import com.fdkankan.manage_jp.exception.BusinessException;
import com.fdkankan.manage_jp.httpClient.service.LaserService;
import com.fdkankan.manage_jp.mapper.IScenePlusMapper;
import com.fdkankan.manage_jp.service.*;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.fdkankan.manage_jp.util.SceneResourcePath;
import com.fdkankan.redis.util.RedisUtil;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.bytedeco.javacpp.presets.opencv_core;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;

import java.io.File;
import java.util.HashMap;
import java.util.List;
import java.util.Objects;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutorService;

/**
 * <p>
 * 场景主表 服务实现类
 * </p>
 *
 * @author 
 * @since 2022-12-30
 */
@Service
@Slf4j
public class ScenePlusServiceImpl extends ServiceImpl<IScenePlusMapper, ScenePlus> implements IScenePlusService {

    @Autowired
    IScene3dNumService scene3dNumService;
    @Autowired
    IScenePlusExtService scenePlusExtService;
    @Autowired
    ISceneEditInfoService sceneEditInfoService;
    @Autowired
    ISceneEditInfoExtService sceneEditInfoExtService;
    @Autowired
    ISceneEditControlsService sceneEditControlsService;
    @Autowired
    FYunFileServiceInterface fYunFileServiceInterface;
    @Autowired
    SceneCommonService sceneCommonService;
    @Autowired
    ISurveillanceService surveillanceService;
    @Autowired
    LaserService laserService;
    @Autowired
    ISceneProService sceneProService;
    @Autowired
    RedisUtil redisUtil;

    @Override
    public ScenePlus getByNum(String sceneNum) {
        LambdaQueryWrapper<ScenePlus> wrapper = new LambdaQueryWrapper<>();
        wrapper.eq(ScenePlus::getNum,sceneNum);
        List<ScenePlus> list = this.list(wrapper);
        if(list!=null && list.size() >0){
            return list.get(0);
        }
        return null;
    }

    @Override
    public HashMap<String, ScenePlus> getByNumList(List<String> numList) {
        HashMap<String, ScenePlus> map = new HashMap<>();
        if(numList == null || numList.isEmpty()){
            return map;
        }
        LambdaQueryWrapper<ScenePlus> wrapper = new LambdaQueryWrapper<>();
        wrapper.in(ScenePlus::getNum,numList);
        List<ScenePlus> list = this.list(wrapper);
        list.forEach(e -> map.put(e.getNum(),e));
        return map;
    }

    @Override
    public void unbind(Long cameraId,Long userId) {
        LambdaUpdateWrapper<ScenePlus> wrapper = new LambdaUpdateWrapper<>();
        wrapper.eq(ScenePlus::getCameraId,cameraId);
        wrapper.set(ScenePlus::getUserId,userId);
        this.update(wrapper);
    }

    @Override
    public ScenePlus copyScene(ScenePlus scenePlus) {
        if(scenePlus.getSceneStatus() !=-2){
            throw new BusinessException(ResultCode.SCENE_ERROR);
        }
        String oldNum = scenePlus.getNum();
        String newNum = sceneCommonService.getNewNum(oldNum);

        Long plusId = scenePlus.getId();
        String oldSceneName = scenePlus.getTitle();

        ScenePlusExt plusExt = scenePlusExtService.getByPlusId(plusId);
        if(plusExt == null){
            throw new BusinessException(ResultCode.NOT_RECORD);
        }
        scenePlus.setNum(newNum);
        scenePlus.setTitle(scenePlus.getTitle() +"(copy)");
        scenePlus.setSceneStatus(0);
        scenePlus.setId(null);
        this.save(scenePlus);

        if(SceneSourceUtil.isLaser(scenePlus.getSceneSource())){
            String redisKey = RedisKeyUtil.laserCopyLock + newNum;
            redisUtil.set(redisKey,"1",60*60);
        }
        try {
            sceneCommonService.v4Async(plusExt,oldNum,newNum,scenePlus,plusId,oldSceneName);
        }catch (Exception e){
            log.error("复制场景失败-sceneNum:{},error:{}",oldNum,e);
            scenePlus.setSceneStatus(-1);
            this.updateById(scenePlus);
            throw new BusinessException(ResultCode.SCENE_DATA_ERROR);
        }
        return scenePlus;
    }

    @Override
    public void move(String num, String version, CameraDetail cameraDetail, User user) {
        if(version.equals("v3")){
            LambdaUpdateWrapper<ScenePro> wrapper2 = new LambdaUpdateWrapper<>();
            wrapper2.eq(ScenePro::getNum,num);
            if(cameraDetail != null){
                wrapper2.set(ScenePro::getCameraId,cameraDetail.getCameraId());
            }
            if(user != null){
                wrapper2.set(ScenePro::getUserId,user.getId());
            }
            sceneProService.update(wrapper2);
        }else if(version.equals("v4")){
            LambdaUpdateWrapper<ScenePlus> wrapper = new LambdaUpdateWrapper<>();
            wrapper.eq(ScenePlus::getNum,num);
            if(cameraDetail != null){
                wrapper.set(ScenePlus::getCameraId,cameraDetail.getCameraId());
            }
            if(user != null){
                wrapper.set(ScenePlus::getUserId,user.getId());
            }
            this.update(wrapper);
        }


    }

    @Override
    public void updatePayStatus(String num,String version,Integer sceneSource,Integer payStatus,CameraDetail cameraDetail,User user) {
        if(version.equals("v3")){
            LambdaUpdateWrapper<ScenePro> wrapper2 = new LambdaUpdateWrapper<>();
            wrapper2.set(ScenePro::getPayStatus,payStatus);
            wrapper2.eq(ScenePro::getNum,num);
            if(cameraDetail != null){
                wrapper2.set(ScenePro::getCameraId,cameraDetail.getCameraId());
            }
            if(user != null){
                wrapper2.set(ScenePro::getUserId,user.getId());
            }
            sceneProService.update(wrapper2);
            updateOssPayStatus(String.format(OssPath.v3_statusPath,num),payStatus);
        }else if(version.equals("v4")){
            LambdaUpdateWrapper<ScenePlus> wrapper = new LambdaUpdateWrapper<>();
            wrapper.set(ScenePlus::getPayStatus,payStatus);
            wrapper.eq(ScenePlus::getNum,num);
            if(cameraDetail != null){
                wrapper.set(ScenePlus::getCameraId,cameraDetail.getCameraId());
            }
            if(user != null){
                wrapper.set(ScenePlus::getUserId,user.getId());
            }
            this.update(wrapper);
            updateOssPayStatus(String.format(OssPath.v4_statusPath,num),payStatus);
        }

        if(SceneSourceUtil.isLaser(sceneSource)){
             laserService.updateStatus(num, payStatus == 1 ? 2 : 3);
        }


    }

    /**
     *  修改oss status.json中 payStatus
     */
    public void updateOssPayStatus(String path,Integer payStatus) {
        try {
            if(!fYunFileServiceInterface.fileExist(path)){
                return;
            }
            String data = fYunFileServiceInterface.getFileContent(path);
            if(StringUtils.isBlank(data)){
                return;
            }
            JSONObject jsonObject = JSONObject.parseObject(data);
            jsonObject.put("payStatus",payStatus);
            String json = JSONUtil.toJsonStr(jsonObject);
            FileUtils.writeFile(OssPath.localStatusPath ,json);
            log.info("updateOssStatus--localPath:{},ossPath:{},payStatus:{}",OssPath.localStatusPath,path,payStatus);
            fYunFileServiceInterface.uploadFile(OssPath.localStatusPath,path);
        }catch (Exception e){
            e.printStackTrace();
        }finally {
            FileUtil.del(OssPath.localStatusPath);
        }
    }

    @Override
    public void updateTitleByNum(String sceneNum, String sceneNewTitle) {
        LambdaUpdateWrapper<ScenePlus> updateWrapper = new LambdaUpdateWrapper<>();
        updateWrapper.eq(ScenePlus::getNum,sceneNum);
        updateWrapper.set(ScenePlus::getLaserTitle,sceneNewTitle);
        this.update(updateWrapper);
    }
}