package com.fdkankan.ucenter.service.impl;

import com.fdkankan.common.constant.AppConstant;
import com.fdkankan.common.exception.BusinessException;
import com.fdkankan.common.util.FileSizeUtil;
import com.fdkankan.ucenter.constant.CameraConstant;
import com.fdkankan.ucenter.constant.LoginConstant;
import com.fdkankan.ucenter.entity.Camera;
import com.fdkankan.ucenter.entity.CameraDetail;
import com.fdkankan.ucenter.entity.User;
import com.fdkankan.ucenter.entity.UserIncrement;
import com.fdkankan.ucenter.service.*;
import com.fdkankan.ucenter.vo.response.CameraAppVo;
import com.fdkankan.ucenter.vo.response.GroupByCount;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.util.ObjectUtils;

import java.math.BigInteger;
import java.util.Collections;
import java.util.HashMap;
import java.util.List;
import java.util.stream.Collectors;

@Service
public class AppCameraService {

    @Autowired
    IUserService userService;
    @Autowired
    ICameraDetailService cameraDetailService;
    @Autowired
    ICameraService cameraService;
    @Autowired
    ISceneProService sceneProService;
    @Autowired
    IScenePlusService scenePlusService;
    @Autowired
    IUserIncrementService userIncrementService;


    public List<CameraAppVo> getCameraForUser(String userName, Integer cameraType) {
        if(StringUtils.isEmpty(userName) || cameraType == null){
            throw new BusinessException(LoginConstant.FAILURE_CODE_3001, LoginConstant.FAILURE_MSG_3001);
        }
        User user = userService.getByUserName(userName);
        if(user == null){
            throw new BusinessException(LoginConstant.FAILURE_CODE_3015, LoginConstant.FAILURE_MSG_3015);
        }
        List<CameraAppVo> cameraAppVoList = cameraDetailService.getListByUserAndType(user.getId(), cameraType);
        for (CameraAppVo cameraApp : cameraAppVoList) {
            UserIncrement userIncrementEntity = userIncrementService.getByCameraId(cameraApp.getId());
            if(userIncrementEntity != null){
                cameraApp.setUserIncrementId(userIncrementEntity.getId());
                cameraApp.setIsExpire(userIncrementEntity.getIsExpired());
            }
        }
        return cameraAppVoList;
    }

    public CameraAppVo bindCamera(String userName, String snCode) {
        User user = userService.getByUserName(userName);
        if(user == null){
            throw new BusinessException(AppConstant.FAILURE_CODE_4007, AppConstant.FAILURE_MSG_4007);
        }
        Camera camera = cameraService.getBySnCode(snCode);
        if(camera == null){
            throw new BusinessException(AppConstant.FAILURE_CODE_4010, AppConstant.FAILURE_MSG_4010);
        }
        CameraDetail cameraDetail = cameraDetailService.getByCameraId(camera.getId());
        if(cameraDetail == null){
            throw new BusinessException(AppConstant.FAILURE_CODE_4010, AppConstant.FAILURE_MSG_4010);
        }
        if (cameraDetail.getUserId() != null){
            throw new BusinessException(CameraConstant.FAILURE_CODE_6006, CameraConstant.FAILURE_MSG_6006);
        }
        List<Long> cameraIds = Collections.singletonList(camera.getId());

        cameraDetail.setUserId(user.getId());
        cameraDetailService.bindCamera(cameraIds,user.getId());
        sceneProService.bindOrUnCamera(cameraIds,user.getId());
        scenePlusService.bindOrUnCamera(cameraIds,user.getId());
        CameraAppVo responseCamera = new CameraAppVo();
        responseCamera.setChildName(camera.getChildName());

        responseCamera.setUsedSpace(BigInteger.valueOf(cameraDetail.getUsedSpace()));
        responseCamera.setTotalSpace(BigInteger.valueOf(cameraDetail.getTotalSpace()));
        responseCamera.setUsedSpaceStr(FileSizeUtil.formatFileSize(cameraDetail.getUsedSpace()));
        responseCamera.setTotalSpaceStr(FileSizeUtil.formatFileSize(cameraDetail.getTotalSpace()));
        return responseCamera;
    }

    public void unbindCamera(String userName, String childName) {
        User user = userService.getByUserName(userName);
        if(user == null){
            throw new BusinessException(AppConstant.FAILURE_CODE_4007, AppConstant.FAILURE_MSG_4007);
        }
        Camera camera = cameraService.getByChildName(childName);
        if(camera == null){
            throw new BusinessException(AppConstant.FAILURE_CODE_4010, AppConstant.FAILURE_MSG_4010);
        }
        CameraDetail cameraDetail = cameraDetailService.getByCameraId(camera.getId());
        if(cameraDetail == null){
            throw new BusinessException(AppConstant.FAILURE_CODE_4010, AppConstant.FAILURE_MSG_4010);
        }
        if(!user.getId().equals(cameraDetail.getUserId())){
            throw new BusinessException(CameraConstant.FAILURE_CODE_6005, CameraConstant.FAILURE_MSG_6005);
        }
        List<Long> cameraIds = Collections.singletonList(camera.getId());

        userIncrementService.unbindCamera(cameraIds);                   //取消关联用户权益
        cameraDetailService.unbindCamera(cameraIds);                     //取消相机用户关联
        sceneProService.bindOrUnCamera(cameraIds,null);             //取消关联场景
        scenePlusService.bindOrUnCamera(cameraIds,null);            //取消关联场景
    }

    public CameraAppVo getCameraInfo(String childName, String childPassword) {
        if(StringUtils.isEmpty(childName) || StringUtils.isEmpty(childPassword)){
            throw new BusinessException(LoginConstant.FAILURE_CODE_3001, LoginConstant.FAILURE_MSG_3001);
        }
        List<CameraAppVo> cameraAppVos = cameraService.getCameraInfo(childName,childPassword);
        if(cameraAppVos.size()<=0){
            return null;
        }
        List<Long> cameraIdList = cameraAppVos.parallelStream().map(CameraAppVo::getId).collect(Collectors.toList());
        //场景数量,最后拍摄时间
        HashMap<Long, GroupByCount> sceneNumMap =  sceneProService.findSceneNumByCameraIds(cameraIdList);
        for (CameraAppVo vo : cameraAppVos) {
            Long sceneCount = sceneNumMap.get(vo.getId()) == null ? 0L : sceneNumMap.get(vo.getId()).getCount();
            vo.setSceneCount(Math.toIntExact(sceneCount));

            UserIncrement userIncrementEntity = userIncrementService.getByCameraId(vo.getId());
            if(userIncrementEntity != null){
                vo.setUserIncrementId(userIncrementEntity.getId());
                vo.setIsExpire(userIncrementEntity.getIsExpired());
            }
        }
        return cameraAppVos.get(0);
    }

    public void uploadUserCameraInfo(String snCode, String cameraVersion, String appVersion) {
        Camera cameraEntity = cameraService.getBySnCode(snCode);
        if(ObjectUtils.isEmpty(cameraEntity)){
            return;
        }
        cameraDetailService.uploadUserCameraInfo(cameraEntity.getId(),cameraVersion,appVersion);
    }
}