4dkankan-center-manage/src/main/java/com/fdkankan/manage/service/impl/CameraServiceImpl.java

package com.fdkankan.manage.service.impl;

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.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.fdkankan.common.constant.Constant;
import com.fdkankan.manage.common.*;
import com.fdkankan.manage.constant.CameraOutTypeEnum;
import com.fdkankan.manage.entity.*;
import com.fdkankan.manage.exception.BusinessException;
import com.fdkankan.common.util.DateUtil;
import com.fdkankan.manage.constant.CameraConstant;
import com.fdkankan.manage.mapper.ICameraMapper;
import com.fdkankan.manage.service.*;
import com.fdkankan.manage.util.DateUtils;
import com.fdkankan.manage.vo.request.CameraInOutParam;
import com.fdkankan.manage.vo.request.CameraParam;
import com.fdkankan.manage.vo.response.CameraDetailVo;
import com.fdkankan.rabbitmq.util.RabbitMqProducer;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.*;
import java.util.stream.Collectors;

/**
 * <p>
 * 相机主表 服务实现类
 * </p>
 *
 * @author 
 * @since 2022-06-16
 */
@Service
@Slf4j
public class CameraServiceImpl extends ServiceImpl<ICameraMapper, Camera> implements ICameraService {

    @Autowired
    ICameraDetailService cameraDetailService;
    @Autowired
    ISceneService sceneService;
    @Autowired
    ISceneProService sceneProService;
    @Autowired
    IUserIncrementService userIncrementService;
    @Autowired
    ISceneResourceCameraService sceneResourceCameraService;
    @Autowired
    IScenePlusService scenePlusService;
    @Autowired
    ICompanyService companyService;
    @Autowired
    IExcelService excelService;
    @Autowired
    IOrderService orderService;
    @Autowired
    ICameraWifiPrefixService cameraWifiPrefixService;
    @Autowired
    ICameraTypeService cameraTypeService;

    @Override
    public List<Camera> getListByCameraIdList(List<Long> cameraIdList) {
        LambdaQueryWrapper<Camera> wrapper = new LambdaQueryWrapper<>();
        wrapper.in(Camera::getId,cameraIdList);
        return this.list(wrapper);
    }

    @Override
    public Camera getBySnCode(String snCode) {
        LambdaQueryWrapper<Camera> wrapper = new LambdaQueryWrapper<>();
        wrapper.eq(Camera::getSnCode,snCode);
        List<Camera> list = this.list(wrapper);
        if(list == null || list.size() <=0 ){
            return null;
        }
        return list.get(0);
    }

    private List<Camera> getBySnCodes(List<String> snCodeList) {
        LambdaQueryWrapper<Camera> wrapper = new LambdaQueryWrapper<>();
        wrapper.in(Camera::getSnCode,snCodeList);
        return this.list(wrapper);
    }
    private List<Camera> getByOutSnCodes(List<String> snCodeList) {
        return this.getBaseMapper().getByOutSnCodes(snCodeList);
    }

    @Override
    public void unbindCamera(Long cameraId) {
        userIncrementService.unbindCamera(cameraId);        //取消关联用户权益
        cameraDetailService.unbindCamera(cameraId);         //取消相机用户关联
        sceneService.unbindCamera(cameraId);                //取消关联场景
        sceneProService.unbindCamera(cameraId);             //取消关联场景
        scenePlusService.unbindCamera(cameraId);             //取消关联场景
        sceneResourceCameraService.unbindCamera(cameraId);  //删除协作相机
    }

    @Override
    public PageInfo pageList(CameraParam param) {
        Page<CameraDetailVo> voPage = this.getBaseMapper().pageList(new Page<>(param.getPageNum(),param.getPageSize()),param);
        List<CameraType> list = cameraTypeService.list();
        HashMap<String,CameraType> typeHashMap = new HashMap<>();
        for (CameraType cameraType : list) {
            typeHashMap.put(cameraType.getCameraType().toString(),cameraType);
        }
        for (CameraDetailVo record : voPage.getRecords()) {
            record.setTypeStr(typeHashMap.get(record.getType()).getName());
        }
        return PageInfo.PageInfo(voPage);
    }

    @Override
    public synchronized void in(String wifiName) {
        if(StringUtils.isEmpty(wifiName) ){
            throw new BusinessException(ResultCode.MISSING_REQUIRED_PARAMETERS);
        }
        List<CameraWifiPrefix> list = cameraWifiPrefixService.list();
        Set<String> wifiNamePrefixList = list.stream().map(CameraWifiPrefix::getWifiNamePrefix).collect(Collectors.toSet());

        if(!wifiName.contains("_")){
            throw new BusinessException(ResultCode.WIFI_NAME_ERROR);
        }
        String[] split = wifiName.split("_");
        String cameraPrefix = split[0] +"_";
        String snCode = split[1];

        if(!wifiNamePrefixList.contains(cameraPrefix)){
            throw new BusinessException(ResultCode.WIFI_NAME_ERROR);
        }
        HashMap<String,CameraWifiPrefix> cameraTypeMap = new HashMap<>();
        list.forEach(entity->cameraTypeMap.put(entity.getWifiNamePrefix(),entity));

        if(cameraTypeMap.get(cameraPrefix) == null){
            throw new BusinessException(ResultCode.WIFI_NAME_ERROR);
        }

        LambdaQueryWrapper<Camera> wrapper = new LambdaQueryWrapper<>();
        wrapper.eq(Camera::getSnCode,snCode);
        long count = this.count(wrapper);
        if(count > 0){
            throw new BusinessException(ResultCode.WIFI_NAME_REPEAT);
        }
        saveBatchCamera(Collections.singletonList(wifiName),cameraTypeMap);
    }

    private Integer saveBatchCamera(List<String> wifiNameList,HashMap<String,CameraWifiPrefix> cameraTypeMap){
        HashSet<String> wifiNameSet = new HashSet<>(wifiNameList);
        List<Camera> cameraList = new ArrayList<>();
        for (String wifiName : wifiNameSet) {
            String[] res = wifiName.split("_");
            if(res.length !=2 || StringUtils.isBlank(res[1])){
                throw new BusinessException(ResultCode.WIFI_NAME_ERROR);
            }
            if(cameraTypeMap.get(res[0] +"_") == null){
                throw new BusinessException(ResultCode.WIFI_NAME_ERROR);
            }
            Camera camera = new Camera();
            camera.setWifiName(wifiName);
            camera.setSnCode(res[1]);
            camera.setChildName(res[1]);
            camera.setWifiPassword(CameraConstant.WIFI_PASSWORD_VALUE);
            camera.setChildPassword(CameraConstant.CHILD_PASSWORD_VALUE);
            camera.setActivatedTime(DateUtil.date2String(new Date(),DateUtil.DEFAULT_DATE_FORMAT));
            cameraList.add(camera);

        }
        this.saveBatch(cameraList);

        List<CameraDetail> cameraDetailList = new ArrayList<>();
        for (Camera camera : cameraList) {
            CameraDetail cameraDetail = new CameraDetail();
            cameraDetail.setAgency(CameraConstant.DEFAULT_AGENT);
            cameraDetail.setCameraId(camera.getId());
            cameraDetail.setCountry(0);//默认中国
            String wifiNamePrix = camera.getWifiName().split("_")[0]+"_";
            CameraWifiPrefix cameraType = cameraTypeMap.get(wifiNamePrix);
            cameraDetail.setType(cameraType.getCameraType());

            cameraDetail.setTotalSpace(Long.valueOf(Constant.CAMERA_BASE_SPACE_VALUE));
            cameraDetail.setUsedSpace(0L);

            cameraDetail.setUnit(CacheUtil.cameraUnit);
            if(cameraDetail.getUnit().equals("SP")){
                cameraDetail.setTotalSpace(Long.valueOf(CacheUtil.cameraSpaceNum));
            }
            if("aws".equals(CacheUtil.uploadType)){
                cameraDetail.setCountry(1);//1-国外
            }
            Long goodId = null;
            if(cameraDetail.getType() == 1 || cameraDetail.getType() == 4){
                goodId = 4L;
            }
            if(cameraDetail.getType() == 9){
                goodId = 9L;
            }
            if(cameraDetail.getType() == 10){
                goodId = 10L;
            }
            cameraDetail.setGoodsId(goodId);

            if("local".equals(CacheUtil.uploadType)) { //本地版本 ,入库即出库，并且添加无限期会员权限
                cameraDetail.setCountry(2);
                cameraDetail.setOwn(2);
                cameraDetail.setOutTime(DateUtils.getDate(new Date()));
            }
            cameraDetailList.add(cameraDetail);
        }
        return  cameraDetailService.saveBatch(cameraDetailList) ? cameraList.size() : 0;

    }
    @Override
    public Integer ins(List<String> wifiNameList){
        List<CameraWifiPrefix> cameraTypeList = cameraWifiPrefixService.list();
        Set<String> wifiNamePrefixList = cameraTypeList.stream().map(CameraWifiPrefix::getWifiNamePrefix).collect(Collectors.toSet());
        List<Integer> errorRow = getErrorRow(wifiNameList,wifiNamePrefixList);
        HashMap<String,CameraWifiPrefix> cameraTypeMap = new HashMap<>();
        cameraTypeList.forEach(entity->cameraTypeMap.put(entity.getWifiNamePrefix(),entity));

        excelService.toExcelError(errorRow);
        List<String> snCodeList = new ArrayList<>();
        for (String wifiName : wifiNameList) {
            snCodeList.add(wifiName.split("_")[1]);
        }
        LambdaQueryWrapper<Camera> wrapper = new LambdaQueryWrapper<>();
        wrapper.in(Camera::getSnCode,snCodeList);
        List<Camera> list = this.list(wrapper);
        if(list.size() >0){
            List<String> newList = list.parallelStream().map(Camera::getSnCode).collect(Collectors.toList());
            List<Integer> errorRow2 = getErrorRow(snCodeList, newList);
            excelService.toExcelError(errorRow2);
        }
        return saveBatchCamera(wifiNameList,cameraTypeMap);
    }



    private List<Integer> getErrorRow(List<String> wifiNameList,Set<String> wifiNamePrefixList){
        List<Integer> errorIndexList = new ArrayList<>();
        Set<String> wifiNameSet = new HashSet<>();
        Integer index = 0;
        List<String> snCodes = new ArrayList<>();
        for (String wifiName : wifiNameList) {
            index ++;
            if(StringUtils.isBlank(wifiName)){
                errorIndexList.add(index);
                continue;
            }
            if(wifiNameSet.contains(wifiName)){
                errorIndexList.add(index);
                continue;
            }
            if(!wifiName.contains("_")){
                errorIndexList.add(index);
                continue;
            }
            String[] split = wifiName.split("_");
            String cameraPrefix = split[0] +"_";
            String snCode = split[1];
            if(!wifiNamePrefixList.contains(cameraPrefix)){
                errorIndexList.add(index);
                continue;
            }
            if(snCodes.contains(snCode)){
                errorIndexList.add(index);
                continue;
            }
            snCodes.add(snCode);
            wifiNameSet.add(wifiName);
        }
        return errorIndexList;
    }
    private List<Integer> getErrorRow(List<String> wifiNameList,List<String> dbList){
        List<Integer> errorIndexList = new ArrayList<>();

        if(dbList.size() <=0){
            return errorIndexList;
        }
        Integer index = 0;
        for (String wifiName : wifiNameList) {
            index ++;
            if(dbList.contains(wifiName)){
               errorIndexList.add(index);
            }
        }
        return errorIndexList;
    }

    @Override
    public void out(CameraInOutParam param) {
        if(param.getOutType() == null  || param.getId() == null){
            throw  new BusinessException(ResultCode.MISSING_REQUIRED_PARAMETERS);
        }
        if(StringUtils.isNotBlank(param.getCompanyName())){
            Company company = companyService.getCompanyByName(param.getCompanyName());
            if(company == null){
                throw new BusinessException(ResultCode.COMPANY_NAME_NOT_EXIST);
            }
            param.setCompanyId(company.getId());
        }

        Camera camera = this.getById(param.getId());
        if(camera == null){
            throw new BusinessException(ResultCode.CAMERA_NOT_EXIST);
        }
        CameraDetail detail = cameraDetailService.getByCameraId(camera.getId());
        if(detail ==null){
            throw new BusinessException(ResultCode.CAMERA_NOT_IN);
        }

        HashMap<Long,CameraDetail> detailMap = new HashMap<>();
        detailMap.put(detail.getCameraId(),detail);
        this.saveBatchDetail(detailMap, Collections.singletonList(param));

    }
    @Override
    public Integer outs(List<CameraInOutParam> params){
        setCompanyIdByDb(params);
        checkOrderSn(params);
        HashMap<String, Object> resultMap = getResultMap(params,1);
        HashMap<Long,CameraDetail> detailMap = (HashMap<Long, CameraDetail>) resultMap.get("detailMap");
        HashMap<String, Camera> snCodeMap = (HashMap<String, Camera>) resultMap.get("snCodeMap");
        for (CameraInOutParam param : params) {
            if(param.getId() == null){
                param.setId(snCodeMap.get(param.getSnCode()).getId());
            }
        }
        return this.saveBatchDetail(detailMap,params);

    }

    private void checkOrderSn(List<CameraInOutParam> params) {
        List<String> orderSnList = params.stream().map(CameraInOutParam::getOrderSn).collect(Collectors.toList());
        if(orderSnList.size() >0){
            List<Order> orders =  orderService.getByOrderSnList(orderSnList);
            List<String> dbOrderSn = orders.stream().map(Order::getOrderSn).collect(Collectors.toList());
            List<Integer> errorList = new ArrayList<>();
            Integer index = 0;
            for (String sn : orderSnList) {
                index ++;
                if(StringUtils.isBlank(sn)){
                    continue;
                }
                if(!dbOrderSn.contains(sn)){
                    log.error("excel-export-error-->:订单号不存在不存在:index:{},orderSn:{}",index+3,sn);
                    errorList.add(index);
                }
            }
            excelService.toExcelError(errorList);
        }

    }


    private Integer saveBatchDetail(HashMap<Long, CameraDetail> detailMap, List<CameraInOutParam> params){
        List<CameraDetail> cameraDetails = new ArrayList<>();
        for (CameraInOutParam param : params) {
            CameraDetail cameraDetail = detailMap.get(param.getId());
            if(cameraDetail == null){
                throw new BusinessException(ResultCode.CAMERA_NOT_IN);
            }
            cameraDetail.setAgentId(param.getAgentId());
            cameraDetail.setBuyDate(DateUtils.getDayDate(param.getBuyDate()));
            cameraDetail.setOrderSn(param.getOrderSn());
            cameraDetail.setOwn(param.getOutType());
            cameraDetail.setCompanyId(param.getCompanyId());
            cameraDetail.setOutTime(DateUtils.getDate(new Date()));
            cameraDetail.setUnit(CacheUtil.cameraUnit);
            if(cameraDetail.getUnit().equals("SP")){
                cameraDetail.setTotalSpace(Long.valueOf(CacheUtil.cameraSpaceNum));
            }
            cameraDetails.add(cameraDetail);
        }
        List<Long> cameraIds = cameraDetails.stream().map(CameraDetail::getCameraId).collect(Collectors.toList());
        if(!cameraIds.isEmpty()){
            HashMap<String,Object> map = new HashMap<>();
            map.put("cameraIds",cameraIds);
            rabbitMqProducer.sendByWorkQueue("camera-update-agent",map);
        }
        return cameraDetailService.saveOrUpdateBatch(cameraDetails) ? cameraDetails.size() : 0;
    }

    private void checkSnCode(List<String> snCodeList,List<String> dbSnCode) {
        HashMap<String,Integer> map = new HashMap<>();
        List<Integer> errorList = new ArrayList<>();
        Integer index = 0;
        for (String snCode : snCodeList) {
            index ++;
            if(StringUtils.isBlank(snCode)){
                log.error("excel-export-error-->:index:{},snCode不存在:snCode:{}",index+3,snCode);
                errorList.add(index);
            }
            if(map.get(snCode) == null){
                map.put(snCode,1);
            }else {
                map.put(snCode,2);
                log.error("excel-export-error-->:index:{},snCode已存在:snCode:{}",index+3,snCode);
                errorList.add(index);
            }
        }
        excelService.toExcelError(errorList);

        Integer index2 = 0;
        for (String snCode : snCodeList) {
            index2 ++;
            if(!dbSnCode.contains(snCode)){
                log.error("excel-export-error-->:index:{},snCode未入库:snCode:{}",index2+3,snCode);
                errorList.add(index2);
            }
        }
        excelService.toExcelError(errorList);

    }


    @Override
    public void updateCamera(CameraInOutParam param) {
        if(param.getId() == null|| param.getOutType() == null){
            throw new BusinessException(ResultCode.MISSING_REQUIRED_PARAMETERS);
        }
        CameraDetail cameraDetail = cameraDetailService.getByCameraId(param.getId());
        if(cameraDetail == null){
            throw new BusinessException(ResultCode.MISSING_REQUIRED_PARAMETERS);
        }
        LambdaUpdateWrapper<CameraDetail> wrapper = new LambdaUpdateWrapper<>();
        wrapper.eq(CameraDetail::getId,cameraDetail.getId());
        if(StringUtils.isNotBlank(param.getCompanyName())){
            Company company = companyService.getCompanyByName(param.getCompanyName());
            if(company == null){
                throw new BusinessException(ResultCode.COMPANY_NAME_NOT_EXIST);
            }
            wrapper.set(CameraDetail::getCompanyId,company.getId());
        }else {
            wrapper.set(CameraDetail::getCompanyId,null);
        }
        if(StringUtils.isNotBlank(param.getOrderSn())){
             Order orderSn = orderService.getByOrderSn(param.getOrderSn());
            if(orderSn == null ){
                throw new BusinessException(ResultCode.ORDER_SN_ERROR);
            }
            wrapper.set(CameraDetail::getOrderSn,orderSn.getOrderSn());
        }else {
            wrapper.set(CameraDetail::getOrderSn,null);
        }
        if(param.getAgentId() != null){
            wrapper.set(CameraDetail::getAgentId,param.getAgentId());
        }else {
            wrapper.set(CameraDetail::getAgentId,null);
        }
        wrapper.set(CameraDetail::getOwn,param.getOutType());
        cameraDetailService.update(wrapper);
    }

    @Override
    public void deleteCamera(Long id) {
        if(id == null){
            throw new BusinessException(ResultCode.MISSING_REQUIRED_PARAMETERS);
        }
        CameraDetail cameraDetail = cameraDetailService.getByCameraId(id);
        if(cameraDetail !=null && cameraDetail.getUserId()!=null){
            this.unbindCamera(cameraDetail.getCameraId());
        }
        this.removeById(id);
        cameraDetailService.deleteByCameraId(id);
    }

    @Override
    public Integer updateCompany(List<CameraInOutParam> companyParams) {
        setCompanyIdByDb(companyParams);
        HashMap<String, Object> resultMap = getResultMap(companyParams,2);
        HashMap<Long, CameraDetail> detailMap = (HashMap<Long, CameraDetail>) resultMap.get("detailMap");
        HashMap<String, Camera> snCodeMap = (HashMap<String, Camera>) resultMap.get("snCodeMap");
        List<CameraDetail> updateDetailList = new ArrayList<>();
        for (CameraInOutParam companyParam : companyParams) {
            Camera camera = snCodeMap.get(companyParam.getSnCode());
            CameraDetail cameraDetail = detailMap.get(camera.getId());
            cameraDetail.setCompanyId(companyParam.getCompanyId());
            updateDetailList.add(cameraDetail);
        }
        return cameraDetailService.updateBatchById(updateDetailList) ? updateDetailList.size() : 0;

    }

    private void setCompanyIdByDb(List<CameraInOutParam> companyParams){
        List<String> companyNames = companyParams.parallelStream().map(CameraInOutParam::getCompanyName).collect(Collectors.toList());
        List<Company> companyList = companyService.getCompanyByNames(companyNames);
        HashMap<String,Long> companyNameMap = new HashMap<>();
        for (Company company : companyList) {
            companyNameMap.put(company.getCompanyName(),company.getId());
        }
        List<Integer> errorList = new ArrayList<>();
        Integer index = 0;
        for (CameraInOutParam companyParam : companyParams) {
            index ++;
            if(StringUtils.isNotBlank(companyParam.getCompanyName())){
                if(companyNameMap.get(companyParam.getCompanyName()) == null){
                    log.error("outError-->出库错误:客户名称不存在:snCode:{},outType:{},companyName:{},orderSn:{},agentName:{}"
                            ,companyParam.getSnCode(),companyParam.getOutType(),companyParam.getCompanyName(),companyParam.getOrderSn(),companyParam.getAgentId());
                    errorList.add(index);
                }
                companyParam.setCompanyId(companyNameMap.get(companyParam.getCompanyName()));
            }
        }
        excelService.toExcelError(errorList);
    }

    private HashMap<String, Object> getResultMap(List<CameraInOutParam> params,Integer type){
        HashMap<String,Object> resultMap = new HashMap<>();
        List<String> snCodeList = params.parallelStream().map(CameraInOutParam::getSnCode).collect(Collectors.toList());

        List<Camera> cameraList = new ArrayList<>();
        if(type == 1){
            cameraList = this.getBySnCodes(snCodeList);
        }
        if(type == 2){
            cameraList = this.getByOutSnCodes(snCodeList);
        }
        checkSnCode(snCodeList,cameraList.stream().map(Camera::getSnCode).collect(Collectors.toList()));

        List<Long> cameraIds = cameraList.parallelStream().map(Camera::getId).collect(Collectors.toList());
        List<CameraDetail> cameraDetails = cameraDetailService.getByCameraIds(cameraIds);
        HashMap<Long,CameraDetail> detailMap = new HashMap<>();
        for (CameraDetail cameraDetail : cameraDetails) {
            detailMap.put(cameraDetail.getCameraId(),cameraDetail);
        }

        HashMap<String,Camera> snCodeMap = new HashMap<>();
        for (Camera camera : cameraList) {
            snCodeMap.put(camera.getSnCode(),camera);
        }
        List<Integer> errorList = new ArrayList<>();
        for (String snCode : snCodeList) {
            Camera camera = snCodeMap.get(snCode);
            if(camera == null || detailMap.get(camera.getId()) ==null){
                log.error("excel-export-error-->:相机未入库:snCode:{}",snCode);
                errorList.add(snCodeList.indexOf(snCode) );
            }
        }
        excelService.toExcelError(errorList);
        resultMap.put("detailMap",detailMap);
        resultMap.put("snCodeMap",snCodeMap);
        return resultMap;
    }

    @Autowired
    RabbitMqProducer rabbitMqProducer;
    @Override
    public void initAllCameraSpace(Long userId) {
        List<Long> cameraIds ;
        List<CameraDetail> cameraDetails;
        if(userId != null){
            cameraDetails = cameraDetailService.getByUserId(userId);
        }else {
            List<Camera> list = this.list();
            cameraIds = list.stream().map(Camera::getId).collect(Collectors.toList());
            cameraDetails = cameraDetailService.getByCameraIds(cameraIds);
        }
        if(cameraDetails == null || cameraDetails.size() <=0){
            return;
        }
//        for (CameraDetail cameraDetail : cameraDetails) {
//            ScenePayStatusVo scenePayStatusVo = new ScenePayStatusVo(cameraDetail.getCameraId());
//            rabbitMqProducer.sendByWorkQueue("scene-pay-status", JSONObject.toJSONString(scenePayStatusVo));
//        }

        HashMap<Long, Long> map = sceneProService.getSpaceGroupByCameraId();
        for (CameraDetail cameraDetail : cameraDetails) {
            Long space = map.get(cameraDetail.getCameraId());
            if(space != null){
                space = space  > 0 ? space : 0;
                LambdaUpdateWrapper<CameraDetail> wrapper = new LambdaUpdateWrapper<>();
                wrapper.eq(CameraDetail::getId,cameraDetail.getId());
                wrapper.set(CameraDetail::getUsedSpace,space);
                cameraDetailService.update(wrapper);
            }
        }

    }

    @Override
    public void updateCameraType(CameraInOutParam param) {
        if(param.getId() == null || param.getCameraType() == null){
            throw new BusinessException(ResultCode.MISSING_REQUIRED_PARAMETERS);
        }
        Camera camera = this.getById(param.getId());
        if(camera == null){
            throw new BusinessException(ResultCode.CAMERA_NOT_EXIST);
        }
        String wifiNamePrefix = null;
        if(StringUtils.isNotBlank(param.getWifiNamePrefix())){
            wifiNamePrefix = param.getWifiNamePrefix();
        }else {
            CameraType cameraType = cameraTypeService.getByType(param.getCameraType());
            if(cameraType == null){
                throw new BusinessException(ResultCode.CAMERA_TYPE_ERROR);
            }
            wifiNamePrefix = cameraType.getWifiNamePrefix();

        }
        LambdaUpdateWrapper<Camera> cameraLambdaUpdateWrapper = new LambdaUpdateWrapper<>();
        cameraLambdaUpdateWrapper.eq(Camera::getId,param.getId());
        cameraLambdaUpdateWrapper.set(Camera::getWifiName,wifiNamePrefix+ camera.getSnCode());
        this.update(cameraLambdaUpdateWrapper);


        LambdaUpdateWrapper<CameraDetail> wrapper  = new LambdaUpdateWrapper<>();
        wrapper.eq(CameraDetail::getCameraId,param.getId());
        wrapper.set(CameraDetail::getType,param.getCameraType());
        wrapper.set(CameraDetail::getGoodsId,param.getCameraType() == 1? 4: param.getCameraType());
        cameraDetailService.update(wrapper);


    }

    @Override
    public List<Camera> getLikeBySnCode(String snCode) {
        LambdaQueryWrapper<Camera> wrapper = new LambdaQueryWrapper<>();
        wrapper.like(Camera::getSnCode,snCode);
        return this.list(wrapper);
    }

    @Override
    public HashMap<Long, Camera> getByIds(List<Long> cameraIds) {
        HashMap<Long, Camera> map = new HashMap<>();
        if(cameraIds != null && !cameraIds.isEmpty()){
            List<Camera> cameraList = this.listByIds(cameraIds);
            cameraList.forEach(entity -> map.put(entity.getId(),entity));
        }
        return map;
    }

    @Override
    public List<Camera> getBySnCodes(Set<String> snCodes) {
        if(snCodes.isEmpty()){
            return new ArrayList<>();
        }
        LambdaQueryWrapper<Camera> wrapper = new LambdaQueryWrapper<>();
        wrapper.in(Camera::getSnCode,snCodes);
        return this.list(wrapper);
    }

    @Override
    public Integer insExcelList(List<HashMap<Integer, String>> excelRowList) {
        List<String> wifiNameList = new ArrayList<>();
        Integer index = 0;
        for (HashMap<Integer, String> map : excelRowList) {
            index ++;
            if(map.isEmpty()){
                continue;
            }
            if(index == 0 && !map.get(0).equals("设备入库模板")){
                throw new BusinessException(ResultCode.TEMPLATE_TYPE_ERROR);
            }
            if(index <4){   //从第四行开始
                continue;
            }
            String wifiName = map.get(0);
            wifiNameList.add(wifiName);
        }

        if(wifiNameList.size() <=0){
            throw new BusinessException(ResultCode.IN_TEMPLATE_EMPTY);
        }
        return this.ins(wifiNameList);
    }

    @Autowired
    IAgentNewService agentNewService;
    @Override
    public Integer outExcelList(List<HashMap<Integer, String>> excelRowList) {
        List<CameraInOutParam> params = new ArrayList<>();
        List<Integer> errorIndex = new ArrayList<>();
        Integer index = 0;
        for (HashMap<Integer, String> map : excelRowList) {
            index ++;
            if(map.isEmpty()){
                continue;
            }
            if(index == 0 && !map.get(0).equals("设备出库模板")){
                throw new BusinessException(ResultCode.TEMPLATE_TYPE_ERROR);
            }
            if(index <4){
                continue;
            }
            String snCode = map.get(0);
            String outTypeString = map.get(1);
            String companyName = map.get(2);
            String orderSn = map.get(3);
            String agentName = map.get(4);
            String buyDate = map.get(5);
            CameraOutTypeEnum outTypeEnum = CameraOutTypeEnum.getByMsg(outTypeString);
            if(outTypeEnum == null || StringUtils.isBlank(snCode) || StringUtils.isBlank(buyDate)){
                log.error("outError-->出库错误:出库类型为空或snCode为空:snCode:{},outType:{},companyName:{},orderSn:{},agentName:{}"
                        ,snCode,outTypeString,companyName,orderSn,agentName);
                errorIndex.add(index -3);
            }
            CameraInOutParam param = new CameraInOutParam();
            if(outTypeEnum != null){
                int outType = outTypeEnum.getCode();
                param.setOutType(outType);
            }
            param.setBuyDate(buyDate);
            if(StringUtils.isNotBlank(agentName)){
                AgentNew agentNew = agentNewService.getByName(agentName);
                if(agentNew == null){
                    log.error("outError-->出库错误:代理商不存在:snCode:{},outType:{},companyName:{},orderSn:{},agentName:{}"
                            ,snCode,outTypeString,companyName,orderSn,agentName);
                    errorIndex.add(index -3);
                }else {
                    param.setAgentId(agentNew.getId());
                }
            }
            param.setCompanyName(companyName);
            param.setOrderSn(orderSn);
            param.setSnCode(snCode);
            params.add(param);

        }

        excelService.toExcelError(errorIndex);

        if(params.size() <=0){
            throw new BusinessException(ResultCode.OUT_TEMPLATE_EMPTY);
        }
        return this.outs(params);
    }

    @Override
    public Integer companyExcelList(List<HashMap<Integer, String>> excelRowList) {
        List<CameraInOutParam> companyParams = new ArrayList<>();
        List<Integer> errorIndex = new ArrayList<>();
        Integer index = 0;
        for (HashMap<Integer, String> map : excelRowList) {
            index ++;
            if(map.isEmpty()){
                continue;
            }
            if(index == 0 && !map.get(0).equals("客户关联模板")){
                throw new BusinessException(ResultCode.TEMPLATE_TYPE_ERROR);
            }
            if(index <4){
                continue;
            }
            CameraInOutParam param = new CameraInOutParam();
            param.setCompanyName(map.get(0));
            param.setSnCode(map.get(1));
            if(StringUtils.isBlank(param.getSnCode()) || StringUtils.isBlank(param.getCompanyName())){
                errorIndex.add(index -3 );
            }
            companyParams.add(param);

        }
        excelService.toExcelError(errorIndex);


        if( companyParams.size() <=0){
            throw new BusinessException(ResultCode.COMPANY_TEMPLATE_EMPTY);
        }
        return this.updateCompany(companyParams);
    }
}