4dkankan-center-user/src/main/java/com/fdkankan/ucenter/service/impl/CameraDetailServiceImpl.java

package com.fdkankan.ucenter.service.impl;

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.LambdaUpdateWrapper;
import com.fdkankan.common.constant.Constant;
import com.fdkankan.ucenter.entity.*;
import com.fdkankan.ucenter.mapper.ICameraDetailMapper;
import com.fdkankan.ucenter.service.*;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.fdkankan.ucenter.vo.response.CameraAppVo;
import com.fdkankan.ucenter.vo.response.CameraSpaceVo;
import org.joda.time.DateTime;
import org.joda.time.Days;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Set;

/**
 * <p>
 * 相机子表 服务实现类
 * </p>
 *
 * @author 
 * @since 2022-07-04
 */
@Service
public class CameraDetailServiceImpl extends ServiceImpl<ICameraDetailMapper, CameraDetail> implements ICameraDetailService {

    @Autowired
    IUserService userService;
    @Autowired
    ICameraSpaceService cameraSpaceService;
    @Autowired
    FdkkLaserService fdkkLaserService;
    @Autowired
    ICameraService cameraService;
    @Autowired
    ISceneCooperationService sceneCooperationService;
    @Autowired
    ISceneProService sceneProService;
    @Autowired
    IScenePlusService scenePlusService;

    @Override
    public CameraDetail getByCameraId(Long cameraId) {
        LambdaQueryWrapper<CameraDetail> wrapper = new LambdaQueryWrapper<>();
        wrapper.eq(CameraDetail::getCameraId,cameraId);
        List<CameraDetail> list = this.list(wrapper);
        if(list!=null && list.size() >0){
            return list.get(0);
        }
        return null;
    }

    @Override
    public HashMap<Long, CameraDetail> getByCameraIds(List<Long> cameraIds) {
        LambdaQueryWrapper<CameraDetail> wrapper = new LambdaQueryWrapper<>();
        wrapper.in(CameraDetail::getCameraId,cameraIds);
        List<CameraDetail> list = this.list(wrapper);
        HashMap<Long, CameraDetail> map = new HashMap<>();
        list.forEach(entity -> map.put(entity.getCameraId(),entity));
        return map;
    }

    @Override
    public Long getCountByUserId(Long userId) {
        LambdaQueryWrapper<CameraDetail> wrapper = new LambdaQueryWrapper<>();
        wrapper.eq(CameraDetail::getUserId,userId);
        return this.count(wrapper);
    }

    @Override
    public Integer deadlineNumber(String username) {
        User user = userService.getByUserName(username);
        QueryWrapper<CameraDetail> queryWrapper = new QueryWrapper<>();
        queryWrapper.lambda().eq(CameraDetail::getUserId,user.getId());
        List<CameraDetail> list = this.list(queryWrapper);
        Integer number = 0;
        List<CameraSpaceVo> cameraList = null;
        for (CameraDetail cameraDetailEntity : list) {
            cameraList = cameraSpaceService.getVoListByCameraId(cameraDetailEntity.getCameraId());
            if(cameraList != null && cameraList.size() > 0){
                if(Days.daysBetween(new DateTime(), new DateTime(cameraList.get(0).getSpaceEndTime())).getDays() < 30){
                    number++;
                }
            }
        }
        return number;
    }

    @Override
    public void unbindCamera(List<Long> cameraIds) {
        HashMap<Long, CameraDetail> detailMap = this.getByCameraIds(cameraIds);
        HashMap<Long, Camera> cameraMap = cameraService.getByIds(cameraIds);
        for (Long cameraId : detailMap.keySet()) {
            CameraDetail cameraDetail = detailMap.get(cameraId);
            LambdaUpdateWrapper<CameraDetail> wrapper = new LambdaUpdateWrapper<>();
            wrapper.eq(CameraDetail::getId,cameraDetail.getId());
            wrapper.set(CameraDetail::getUserId,null);
            wrapper.set(CameraDetail::getCooperationUser,null);
            wrapper.set(CameraDetail::getTotalSpace,Long.parseLong(Constant.EXPANSION_SPACE_VALUE_1G ) * 10L);
            this.update(wrapper);
            sceneProService.lockOrUnLockBySpace(cameraDetail,cameraId,-2);     //封存场景
        }
        //恢复10G基本容量

        //删除场景协作信息
        List<ScenePro> sceneProList = sceneProService.getListByCameraIds(cameraIds);
        List<ScenePlus> scenePlusList = scenePlusService.getListByCameraIds(cameraIds);
        sceneCooperationService.deleteCooperationList(sceneProList,scenePlusList);
        fdkkLaserService.disableCooperation(detailMap, cameraMap);
    }

    @Override
    public void bindCamera(List<Long> cameraIds,Long userId) {
        LambdaUpdateWrapper<CameraDetail> wrapper = new LambdaUpdateWrapper<>();
        wrapper.in(CameraDetail::getCameraId,cameraIds)
                .set(CameraDetail::getUserId,userId);
        this.update(wrapper);
    }

    @Override
    public void updateCooperationByIds(List<Long> cameraIds, Long userId) {
        LambdaUpdateWrapper<CameraDetail> wrapper = new LambdaUpdateWrapper<>();
        wrapper.in(CameraDetail::getCameraId,cameraIds)
                .set(CameraDetail::getCooperationUser,userId);
        this.update(wrapper);
    }

    @Override
    public void addUsedSpace(HashMap<Long, Long> cameraMap) {
        Set<Long> cameraIds = cameraMap.keySet();
        LambdaQueryWrapper<CameraDetail> wrapper = new LambdaQueryWrapper<>();
        wrapper.in(CameraDetail::getCameraId,cameraIds);
        List<CameraDetail> list = this.list(wrapper);
        for (CameraDetail cameraDetail : list) {
            long subSpace = cameraMap.get(cameraDetail.getCameraId()) == null ? 0L : cameraMap.get(cameraDetail.getCameraId());
            long usedSpace = cameraDetail.getUsedSpace() - subSpace ;
            cameraDetail.setUsedSpace(usedSpace < 0 ? 0L :usedSpace);
            //解封封存场景
            sceneProService.lockOrUnLockBySpace(cameraDetail,cameraDetail.getCameraId(),1);
        }
        this.updateBatchById(list);
    }

    @Override
    public List<CameraAppVo> getListByUserAndType(Long userId, Integer cameraType) {
        return this.getBaseMapper().getListByUserAndType(userId,cameraType);
    }
}