4dkankan-agent/src/main/java/com/fdkankan/agent/service/impl/SceneProServiceImpl.java

package com.fdkankan.agent.service.impl;

import cn.hutool.core.io.FileUtil;
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.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.fdkankan.agent.common.OssPath;
import com.fdkankan.agent.common.PageInfo;
import com.fdkankan.agent.common.ResultCode;
import com.fdkankan.agent.entity.*;
import com.fdkankan.agent.exception.BusinessException;
import com.fdkankan.agent.httpClient.client.FdKKClient;
import com.fdkankan.agent.httpClient.service.LaserService;
import com.fdkankan.agent.mapper.ISceneProMapper;
import com.fdkankan.agent.request.SceneParam;
import com.fdkankan.agent.response.SceneVo;
import com.fdkankan.agent.service.*;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.fdkankan.agent.util.MangerUploadToOssUtil;
import com.fdkankan.agent.util.SceneStatusUtil;
import com.fdkankan.common.constant.SceneConstant;
import com.fdkankan.common.util.FileUtils;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.stream.Collectors;

/**
 * <p>
 * pro场景表 服务实现类
 * </p>
 *
 * @author 
 * @since 2022-11-09
 */
@Service
@Slf4j
public class SceneProServiceImpl extends ServiceImpl<ISceneProMapper, ScenePro> implements ISceneProService {

    @Autowired
    LaserService laserService;
    @Autowired
    IScenePlusService scenePlusService;
    @Autowired
    IScenePlusExtService scenePlusExtService;
    @Resource
    FdKKClient fdKKClient;
    @Autowired
    ICameraService cameraService;
    @Autowired
    ICameraDetailService cameraDetailService;
    @Autowired
    IUserIncrementService userIncrementService;
    @Autowired
    IIncrementTypeService incrementTypeService;
    @Autowired
    MangerUploadToOssUtil mangerUploadToOssUtil;
    @Autowired
    IFolderSceneService folderSceneService;
    @Autowired
    ISceneService sceneService;
    @Autowired
    ISceneCopyLogService sceneCopyLogService;
    @Autowired
    IUserService userService;
    @Autowired
    IAgentNewService agentNewService;
    @Autowired
    IAgentNewCameraService agentNewCameraService;

    @Override
    public Object pageList(SceneParam param) {
        if(param.getAgentId() == null){
            throw new BusinessException(ResultCode.PARAM_MISS);
        }

        if(param.getType() == 3){ //双目lite
            return sceneService.pageList(param);
        }
        //优化查询，去掉left join
        //snCode 查询，userName 查询，companyId查询
        //snCode回显，userName回显
        if(StringUtils.isNotBlank(param.getSnCode())){
            List<Camera> cameraList = cameraService.getLikeBySnCode(param.getSnCode());
            List<Long> cameraIds = cameraList.stream().map(Camera::getId).collect(Collectors.toList());
            param.setCameraIds(cameraIds);
        }
        if(StringUtils.isNotBlank(param.getUserName())){
            List<User> userList = userService.getLikeByUserName(param.getUserName());
            List<Long> userIds = userList.stream().map(User::getId).collect(Collectors.toList());
            param.setUserIds(userIds);
        }

        if(param.getAgentNew().getParentId() != null){ //分销商
            AgentNew agentNew = agentNewService.getById(param.getAgentNew().getParentId());
            param.setSubAgentId(param.getAgentId());
            param.setAgentId(agentNew.getId());
        }

        List<CameraDetail> details = cameraDetailService.getListByAgentId(param.getAgentId());
        List<Long> cameraIds = details.stream().map(CameraDetail::getCameraId).collect(Collectors.toList());
        if(param.getCameraIds() == null ){
            param.setCameraIds(cameraIds);
        }else {
            if(param.getCameraIds().isEmpty()){
                return PageInfo.PageInfo(new Page(param.getPageNum(),param.getPageSize()));
            }
            List<Long> intersection = cameraIds.stream().filter(param.getCameraIds()::contains).collect(Collectors.toList());
            param.setCameraIds(intersection);
        }
        if((param.getCameraIds() != null && param.getCameraIds().size()<=0) || (param.getUserIds() != null && param.getUserIds().size()<=0)){
            return PageInfo.PageInfo(new Page(param.getPageNum(),param.getPageSize()));
        }
        if(param.getSubAgentId() != null){ //指定分销商查询
            List<Long> subCameraIds = agentNewCameraService.getBySubAgent(param.getSubAgentId());
            if(subCameraIds.isEmpty()){
                return PageInfo.PageInfo(new Page(param.getPageNum(),param.getPageSize()));
            }
            if(!param.getCameraIds().isEmpty()){
                List<Long> newCameraIds = param.getCameraIds().stream().filter(subCameraIds::contains).collect(Collectors.toList());
                param.setCameraIds(newCameraIds);
                if(newCameraIds.isEmpty()){
                    return PageInfo.PageInfo(new Page(param.getPageNum(),param.getPageSize()));
                }
            }else {
                param.setCameraIds(subCameraIds);
            }
        }

        Page<SceneVo> page = this.getBaseMapper().pageList(new Page<>(param.getPageNum(),param.getPageSize()),param);
        List<SceneVo> records = page.getRecords();
        HashMap<String,SceneCopyLog> map = null;
        HashMap<Long, User> userMap = null;
        HashMap<Long, Camera> cameraMap = null;
        HashMap<String,JSONObject> ssSceneMap = null;

        List<String> sceneNumList = page.getRecords().stream().map(SceneVo::getNum).collect(Collectors.toList());
        if(!records.isEmpty()){
            map = sceneCopyLogService.getByNewNumList(sceneNumList);
            List<Long> userIds = records.parallelStream().map(SceneVo::getUserId).collect(Collectors.toList());
            userMap = userService.getByIds(userIds);
            List<Long> cameraIds2 = records.parallelStream().map(SceneVo::getCameraId).collect(Collectors.toList());
            cameraMap = cameraService.getByIds(cameraIds2);

            if(param.getType() == 2 ){
                ssSceneMap = laserService.list(sceneNumList,4);
            }
            if(param.getType() == 6){
                ssSceneMap = laserService.list(sceneNumList,5);
            }
        }
        for (SceneVo record : page.getRecords()) {
            if(param.getType() == 2 || param.getType() == 6){
                JSONObject ssObj = ssSceneMap.get(record.getNum());
                if(ssObj!=null){
                    record.setSceneName(ssObj.getString("title"));
                    record.setThumb(ssObj.getString("thumb"));
                    record.setWebSite(ssObj.getString("webSite"));
                    record.setIsObj(ssObj.getInteger("buildObjStatus"));
                    record.setViewCount(ssObj.getInteger("viewCount"));
                    record.setStatus(toFdStatus(ssObj.getInteger("status")));
                    record.setAlgorithmTime(ssObj.getString("algorithmTime"));
                }else{
                    record.setStatus(0);
                    record.setWebSite(null);
                }
            }

            record.setStatusString(SceneStatusUtil.getStatusString(record));
            if(userMap != null){
                User user = userMap.get(record.getUserId());
                if(user != null){
                    record.setUserName(user.getUserName());
                }
            }
            if(cameraMap != null){
                Camera camera = cameraMap.get(record.getCameraId());
                if(camera != null){
                    record.setSnCode(camera.getSnCode());
                }
            }
            if(map !=null ){
                SceneCopyLog sceneCopyLog = map.get(record.getNum());
                if(sceneCopyLog != null){
                    record.setCopyTime(sceneCopyLog.getCreateTime());
                    record.setIsCopy(true);
                }
            }
        }
        return PageInfo.PageInfo(page);
    }


    @Override
    public void copy(String sceneNum) throws Exception {
        ScenePro scenePro = this.getByNum(sceneNum);
        ScenePlus scenePlus = scenePlusService.getByNum(sceneNum);
        if((scenePro == null || scenePro.getCameraId() == null ) && (scenePlus== null || scenePlus.getCameraId() == null)){
            throw new BusinessException(ResultCode.SCENE_EMPTY);
        }
        Long cameraId = scenePro == null ? scenePlus.getCameraId() : scenePro.getCameraId();
        Camera camera = cameraService.getById(cameraId);
        if(camera == null){
            throw new BusinessException(ResultCode.CAMERA_EMPTY);
        }
        CameraDetail detailEntity = cameraDetailService.getByCameraId(cameraId);
        if(detailEntity == null){
            throw new BusinessException(ResultCode.CAMERA_EMPTY);
        }

        Long needSpace = 0L;
        if(scenePro != null){
            needSpace = scenePro.getSpace();
        }
        if(scenePlus != null){
            ScenePlusExt scenePlusExt = scenePlusExtService.getByPlusId(scenePlus.getId());
            if(scenePlusExt != null && scenePlusExt.getSpace() != null){
                needSpace = scenePlusExt.getSpace();
            }
        }
        Boolean checkSpace = cameraDetailService.checkSpace(detailEntity, needSpace);

        if(!checkSpace){
            throw new BusinessException(ResultCode.CAMERA_SPACE_ERROR);
        }

        HashMap<String, Object> param = new HashMap<>();
        param.put("num",sceneNum);
        JSONObject jsonObject = fdKKClient.copyScene(param, "m_a_n_a_g_e");
        Integer code = jsonObject.getInteger("code");
        if(code != 0){
            throw new BusinessException(jsonObject.getInteger("code"),jsonObject.getString("msg"));
        }

    }

    @Override
    public ScenePro getByNum(String num) {
        LambdaQueryWrapper<ScenePro> wrapper = new LambdaQueryWrapper<>();
        wrapper.eq(ScenePro::getNum,num);
        wrapper.eq(ScenePro::getIsUpgrade,0);
        List<ScenePro> list = this.list(wrapper);
        if(list == null || list.size() <=0){
            return null;
        }
        return list.get(0);
    }

    @Override
    public Long getCountByCameraId(Long cameraId) {
        LambdaQueryWrapper<ScenePro> wrapper = new LambdaQueryWrapper<>();
        wrapper.eq(ScenePro::getIsUpgrade,0);
        wrapper.eq(ScenePro::getCameraId,cameraId);
        wrapper.in(ScenePro::getStatus,0,-2);
        return this.count(wrapper);
    }


    private Integer toFdStatus(Integer status) {
        //深时状态,-1:场景被删 0:计算中 1计算失败 2计算成功 3封存 4生成OBJ中
        switch (status) {
            case 0:
            case 4:
                return 0;
            case 2:
                return -2;
            case 3:
                return -3;
            default:
                return -1;
        }
    }
}