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

import cn.hutool.core.util.ObjectUtil;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
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.AssPlanPerson;
import com.gkhy.assess.system.domain.SysUser;
import com.gkhy.assess.system.enums.PlayRoleEnum;
import com.gkhy.assess.system.mapper.AssPlanPersonMapper;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.gkhy.assess.system.mapper.SysUserMapper;
import com.gkhy.assess.system.service.AssPlanPersonService;
import com.gkhy.assess.system.service.AssProjectService;
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.Arrays;
import java.util.List;
import java.util.stream.Collectors;

/**
 * <p>
 * 评价项目组成员表 服务实现类
 * </p>
 *
 * @author kzy
 * @since 2023-12-12 10:46:54
 */
@Service
public class AssPlanPersonServiceImpl extends ServiceImpl<AssPlanPersonMapper, AssPlanPerson> implements AssPlanPersonService {
    @Autowired
    private AssProjectService projectService;
    @Autowired
    private SysUserMapper sysUserMapper;
    @Override
    public List<AssPlanPerson> getByProjectId(Long projectId) {
        projectService.checkUserAllowed(projectId);
        return baseMapper.getPlanPersonByProjectId(projectId);
    }


    @Override
    public int addPlanPerson(AssPlanPerson planPerson) {
        projectService.checkUserAllowed(planPerson.getProjectId());
        checkPersonUnique(planPerson);
        planPerson.setCreateBy(ShiroUtils.getSysUser().getUsername());
        return baseMapper.insert(planPerson);
    }

    @Override
    public void checkPersonUnique(AssPlanPerson planPerson) {
        if(planPerson.getPlayRole()==null){
            planPerson.setPlayRole(PlayRoleEnum.PROJECT_MEMBER.getCode());
        }
        LambdaQueryWrapper<AssPlanPerson> lambdaQueryWrapper = Wrappers.<AssPlanPerson>lambdaQuery()
                .eq(AssPlanPerson::getPersonId, planPerson.getPersonId())
                .eq(AssPlanPerson::getDelFlag, DeleteFlagEnum.UN_DELETE)
                .eq(AssPlanPerson::getProjectId, planPerson.getProjectId())
                .eq(AssPlanPerson::getPlayRole,planPerson.getPlayRole());
        if(planPerson.getId()!=null){
            lambdaQueryWrapper.ne(AssPlanPerson::getId,planPerson.getId());
        }
        AssPlanPerson pPerson= getOne(lambdaQueryWrapper);
        if(pPerson!=null){
            PlayRoleEnum playRoleEnum=PlayRoleEnum.getInfoByCode(pPerson.getPlayRole());
            SysUser sysUser=sysUserMapper.selectById(planPerson.getPersonId());
            if(sysUser==null){
                throw new ApiException("选择的用户不存在");
            }
            String message=playRoleEnum!=null?playRoleEnum.getInfo():"";
            if(StringUtils.isBlank(message)){
                message=String.format("用户<%s>已担任职务",sysUser.getName());
            }else{
                message=String.format("用户<%s>已担任%s",sysUser.getName(),message);
            }
            throw new ApiException(message);
        }
    }

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

    @Override
    public int getMajorPlanPersonCountByProject(Long projectId) {
        return baseMapper.getMajorPlanPersonCountByProject(projectId);
    }

    @Override
    public int editPlanPerson(AssPlanPerson planPerson) {
        projectService.checkUserAllowed(planPerson.getProjectId());
        if(planPerson.getPersonId()!=null){
            checkPersonUnique(planPerson);
        }
        planPerson.setUpdateBy(ShiroUtils.getSysUser().getUsername());
        return baseMapper.updateById(planPerson);
    }

    @Override
    public int deletePlanPersonById(Long planPersonId) {
        AssPlanPerson planPerson=getById(planPersonId);
        projectService.checkUserAllowed(planPerson.getProjectId());
        planPerson=new AssPlanPerson().setId(planPersonId)
                .setDelFlag(DeleteFlagEnum.DELETED.getCode());
        planPerson.setUpdateBy(ShiroUtils.getSysUser().getUsername());
        return baseMapper.updateById(planPerson);
    }

    @Override
    public int deletePlanPersonByPersonId(Long personId,Long projectId,Integer playCode) {
        return baseMapper.update(null,Wrappers.<AssPlanPerson>lambdaUpdate()
                .set(AssPlanPerson::getDelFlag,DeleteFlagEnum.DELETED.getCode())
                .set(AssPlanPerson::getUpdateBy,ShiroUtils.getSysUser().getUsername())
                .eq(AssPlanPerson::getPersonId,personId)
                .eq(AssPlanPerson::getProjectId,projectId)
                .eq(AssPlanPerson::getPlayRole,playCode));
    }
}