package com.gkhy.assess.system.service.impl;

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.gkhy.assess.common.enums.DeleteFlagEnum;
import com.gkhy.assess.common.exception.ApiException;
import com.gkhy.assess.common.utils.StringUtils;
import com.gkhy.assess.system.domain.AssFaceRecognition;
import com.gkhy.assess.system.domain.AssPlanPerson;
import com.gkhy.assess.system.enums.ReportProgressEnum;
import com.gkhy.assess.system.mapper.AssFaceRecognitionMapper;
import com.gkhy.assess.system.mapper.AssPlanPersonMapper;
import com.gkhy.assess.system.domain.vo.UploadObjectVO;
import com.gkhy.assess.system.service.AssFaceRecognitionService;
import com.gkhy.assess.system.service.AssProjectService;
import com.gkhy.assess.system.service.SysCommonService;
import com.gkhy.assess.system.utils.ShiroUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;

/**
 * <p>
 * 签字确认表 服务实现类
 * </p>
 *
 * @author kzy
 * @since 2023-12-12 10:46:54
 */
@Service
public class AssFaceRecognitionServiceImpl extends ServiceImpl<AssFaceRecognitionMapper, AssFaceRecognition> implements AssFaceRecognitionService {

    @Autowired
    private AssProjectService projectService;
    @Autowired
    private SysCommonService commonService;
    @Autowired
    private AssPlanPersonMapper planPersonMapper;

    @Override
    public int addFaceRecognition(AssFaceRecognition faceRecognition) {
        projectService.checkUserAllowed(faceRecognition.getProjectId());
        AssFaceRecognition existRecord=checkFaceRecognitionUnique(faceRecognition.getPersonId(),faceRecognition.getProjectId());
        if(existRecord!=null){
            throw new ApiException("签字确认记录已存在");
        }
        faceRecognition.setCreateBy(ShiroUtils.getSysUser().getUsername());
        int row=baseMapper.insert(faceRecognition);
        return row;
    }

    @Override
    public void doFaceRecognition(Map map) {
        Long projectId= Long.parseLong(map.get("projectId").toString());
        projectService.checkUserAllowed(projectId);
        //todo 校验项目成员是否都完成了签字确认
        checkAllFaceRecongnition(projectId);
        //校验项目状态
        projectService.checkReportProgress(projectId, ReportProgressEnum.PROJECT_MATERIAL);
        //更新项目状态
        projectService.changeReportProgress(projectId,ReportProgressEnum.FACE_RECOGNITION);
    }

    @Override
    public Boolean checkAllFaceRecongnition(Long projectId){
        projectService.checkUserAllowed(projectId);
        List<AssPlanPerson> planPersonList=planPersonMapper.getAllPlanPersonByProjectId(projectId);
        Map<Long,AssPlanPerson> planPersonMap=planPersonList.stream().collect(Collectors.toMap(AssPlanPerson::getPersonId,a -> a,(k1,k2) -> k1));
        planPersonList=planPersonMap.values().stream().collect(Collectors.toList());
        List<AssFaceRecognition> faceRecognitionList=baseMapper.getSimpleFaceRecognitionByProjectId(projectId);
        Map<Long,AssFaceRecognition> map=faceRecognitionList.stream().collect(Collectors.toMap(AssFaceRecognition::getPersonId,a -> a,(k1,k2) -> k1));
        String message="";
        for(AssPlanPerson planPerson:planPersonList){
            if(map.get(planPerson.getPersonId())==null){
                message=message+planPerson.getPerson().getName()+",";
            }
        }
        if(StringUtils.isNotBlank(message)){
            message=message+"未签字确认";
            throw new ApiException(message);
        }
        return true;
    }

    public AssFaceRecognition checkFaceRecognitionUnique(Long personId,Long projectId){
        LambdaQueryWrapper<AssFaceRecognition> lambdaQueryWrapper = Wrappers.<AssFaceRecognition>lambdaQuery()
                .eq(AssFaceRecognition::getPersonId, personId)
                .eq(AssFaceRecognition::getProjectId, projectId)
                .eq(AssFaceRecognition::getDelFlag, DeleteFlagEnum.UN_DELETE);
        return getOne(lambdaQueryWrapper);
    }

    @Override
    public int editFaceRecognition(AssFaceRecognition faceRecognition) {
        projectService.checkUserAllowed(faceRecognition.getProjectId());
        faceRecognition.setUpdateBy(ShiroUtils.getSysUser().getUsername());
        int row=baseMapper.updateById(faceRecognition);
        return row;
    }

    @Override
    public List<AssFaceRecognition> getFaceRecognitionByProjectId(Long projectId) {
        projectService.checkUserAllowed(projectId);
        List<AssFaceRecognition> faceRecognitionList= baseMapper.getFaceRecognitionByProjectId(projectId);
        //同一个人员担任多种角色
        Map<Long,List<Integer>> playRoleMap=faceRecognitionList.stream().collect(Collectors.toMap(AssFaceRecognition::getPersonId,p -> {
            List<Integer> pRoles=new ArrayList<>();
            pRoles.add(p.getPlanPerson().getPlayRole());
            return pRoles;
        },(List<Integer>value1,List<Integer> value2) -> {
                value1.addAll(value2);
                return value1;
        }));
        Map<Long,AssFaceRecognition> faceMap=faceRecognitionList.stream().collect(Collectors.toMap(AssFaceRecognition::getPersonId,a -> a,(k1,k2) -> k2));
        List<AssFaceRecognition> faceRecognitions=faceMap.values().stream().collect(Collectors.toList());
        for(AssFaceRecognition faceRecognition:faceRecognitions){
            faceRecognition.getPlanPerson().setPlayRoles(playRoleMap.get(faceRecognition.getPersonId()));
        }
        return faceRecognitions;
    }


    @Override
    public AssFaceRecognition getFaceRecognitionById(Long faceRecognitionId) {
        AssFaceRecognition faceRecognition= baseMapper.getFaceRecognitionById(faceRecognitionId);
        projectService.checkUserAllowed(faceRecognition.getProjectId());
        return faceRecognition;
    }

    @Override
    public AssFaceRecognition getRecognitionByPersonId(Long projectId, Long personId) {
        projectService.checkUserAllowed(projectId);
        return getOne(Wrappers.<AssFaceRecognition>lambdaQuery()
                .eq(AssFaceRecognition::getPersonId,personId)
                .eq(AssFaceRecognition::getProjectId,projectId)
                .eq(AssFaceRecognition::getDelFlag, DeleteFlagEnum.UN_DELETE.getCode()));
    }
}