package com.gkhy.labRiskManage.domain.basic.service.impl;

import com.gkhy.labRiskManage.application.basic.dto.bo.BasicExperimentPersonAppInsertBO;
import com.gkhy.labRiskManage.application.basic.dto.bo.BasicExperimentPersonAppQueryBO;
import com.gkhy.labRiskManage.application.basic.dto.bo.BasicExperimentPersonAppUpdateBO;
import com.gkhy.labRiskManage.commons.domain.SearchResult;
import com.gkhy.labRiskManage.commons.enums.ResultCode;
import com.gkhy.labRiskManage.commons.enums.StatusEnum;
import com.gkhy.labRiskManage.commons.enums.UserTagEnum;
import com.gkhy.labRiskManage.commons.exception.BusinessException;
import com.gkhy.labRiskManage.commons.utils.BeanCopyUtils;
import com.gkhy.labRiskManage.domain.account.model.dto.UserInfoDomainDTO;
import com.gkhy.labRiskManage.domain.account.service.UserDomainService;
import com.gkhy.labRiskManage.domain.basic.converter.ToInsertPersonBOConverter;
import com.gkhy.labRiskManage.domain.basic.converter.ToQueryPersonBOConverter;
import com.gkhy.labRiskManage.domain.basic.entity.BasicExperimentPerson;
import com.gkhy.labRiskManage.domain.basic.model.bo.PersonInsertBO;
import com.gkhy.labRiskManage.domain.basic.model.bo.PersonQueryBO;
import com.gkhy.labRiskManage.domain.basic.model.dto.*;
import com.gkhy.labRiskManage.domain.basic.repository.jpa.BasicExperimentPersonRepository;
import com.gkhy.labRiskManage.domain.basic.service.BasicExperimentPersonService;
import com.gkhy.labRiskManage.domain.riskReport.utils.GetRoleTagUtils;
import com.gkhy.labRiskManage.domain.riskReport.utils.SearchAuthUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.PageRequest;
import org.springframework.data.domain.Sort;
import org.springframework.data.jpa.domain.Specification;
import org.springframework.stereotype.Service;
import org.springframework.util.ObjectUtils;

import javax.persistence.criteria.CriteriaBuilder;
import javax.persistence.criteria.CriteriaQuery;
import javax.persistence.criteria.Predicate;
import javax.persistence.criteria.Root;
import java.time.LocalDateTime;
import java.util.ArrayList;
import java.util.List;


/**
 * 基础实验人员管理
 */
@Service
public class BasicExperimentPersonServiceImpl implements BasicExperimentPersonService {

    @Autowired
    private BasicExperimentPersonRepository personRepository;
    @Autowired
    private UserDomainService userDomainService;

    /**
     * 基础实验人员 - 插入
     * */
    @Override
    public PersonInsertDTO insertBasicExperimentPerson(Long currentUserId, BasicExperimentPersonAppInsertBO personAppInsertDO) {

        if (currentUserId < 0){
            throw new BusinessException(this.getClass(), ResultCode.BUSINESS_ERROR_NOT_ALLOWED.getCode() ,"当前用户无效，请重新登陆");
        }

        //接收，转换参数  todo ,目前所有信息，缺乏唯一性标识。需要如身份证，手机号，人员身份码之类的信息
        ToInsertPersonBOConverter converter = new ToInsertPersonBOConverter();
        PersonInsertBO personInsertBO = converter.toInsertPersonDTO(personAppInsertDO);

        //参数校验
        if (ObjectUtils.isEmpty(personInsertBO)){
            throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR_NULL.getCode(), "人员信息不能为空");
        }
        if (ObjectUtils.isEmpty(personInsertBO.getPersonName())){
            throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR_NULL.getCode(), "姓名不能为空");
        }
        if (ObjectUtils.isEmpty(personInsertBO.getPersonAge())){
            throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR_NULL.getCode(), "年龄不能为空");
        }
        if (ObjectUtils.isEmpty(personInsertBO.getPersonGender())){
            throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR_NULL.getCode(), "性别不能为空");
        }
        if (ObjectUtils.isEmpty(personInsertBO.getPersonMajor())){
            throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR_NULL.getCode(), "专业不能为空");
        }
//        if (ObjectUtils.isEmpty(insertPersonDO.getDepName())){
//            throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR_NULL.getCode(), "所属部门不能为空");
//        }  todo 暂时没有部门
        if (ObjectUtils.isEmpty(personInsertBO.getAptitude())){
            throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR_NULL.getCode(), "相关资质不能为空");
        }
        if (ObjectUtils.isEmpty(personInsertBO.getTraining())){
            throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR_NULL.getCode(), "培训情况不能为空");
        }
        if (ObjectUtils.isEmpty(personInsertBO.getPhone())){
            throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR_NULL.getCode(), "手机号不能为空");
        }
        BasicExperimentPerson personByPhone = personRepository.getPersonByPhone(personInsertBO.getPhone());
        if (!ObjectUtils.isEmpty(personByPhone)){
            throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR_NULL.getCode(), "手机号已被使用");
        }

        BasicExperimentPerson person = BeanCopyUtils.copyBean(personInsertBO, BasicExperimentPerson.class);
        UserInfoDomainDTO userInfoById = userDomainService.getUserInfoById(currentUserId);
        //获取参数
        LocalDateTime date = LocalDateTime.now();
        //封装参数
        person.setCreateByUserId(userInfoById.getId());
        person.setCreateTime(date);
        person.setUpdateByUserId(userInfoById.getId());
        person.setUpdateTime(date);
        person.setDeleteStatus(StatusEnum.DELETE_NOT.getCode().byteValue());


        BasicExperimentPerson saveResult = personRepository.save(person);
        return BeanCopyUtils.copyBean(saveResult, PersonInsertDTO.class);
    }

    /**
     * 基础实验人员 - 分页查询
     * */
    @Override
    public SearchResult<PersonQueryDTO> getBasicExperimentPersonPage(Long currentUserId, BasicExperimentPersonAppQueryBO queryParam) {

        //校验参数
        if (ObjectUtils.isEmpty(queryParam.getPageSize())){
            throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR.getCode() ,"分页信息不能为空");
        }
        if (ObjectUtils.isEmpty(queryParam.getPageIndex())){
            throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR.getCode() ,"分页信息不能为空");
        }
        if (queryParam.getPersonName() == ""){
            queryParam.setPersonName(null);
        }
        if (queryParam.getDepName()  == ""){
            queryParam.setDepName(null);
        }

        //接收，转换参数
        ToQueryPersonBOConverter converter = new ToQueryPersonBOConverter();
        PersonQueryBO queryPageParam = converter.toQueryPersonDOConverter(queryParam);

        SearchResult searchResult = new SearchResult<>();

        searchResult.setPageIndex(queryPageParam.getPageIndex());
        searchResult.setPageSize(queryPageParam.getPageSize());

        UserInfoDomainDTO user = userDomainService.getUserById(currentUserId);
        int roleTag = GetRoleTagUtils.GetRoleTagUtils(user);

        //封装查询参数
        Specification<BasicExperimentPerson> specification = new Specification<BasicExperimentPerson>() {
            @Override
            public Predicate toPredicate(Root<BasicExperimentPerson> root, CriteriaQuery<?> query, CriteriaBuilder criteriaBuilder) {
                List<Predicate> predicateList = new ArrayList<>();
                if (queryPageParam.getPersonName() != null && !queryPageParam.getPersonName().equals("")){
                    predicateList.add(criteriaBuilder.equal(root.get("personName"), queryPageParam.getPersonName()));
                }
                if (queryPageParam.getDepName() != null && !queryPageParam.getDepName().equals("")){
                    predicateList.add(criteriaBuilder.equal(root.get("depName"), queryPageParam.getDepName()));
                }
                if (queryPageParam.getTraining() != null && !queryPageParam.getTraining().equals("")){
                    predicateList.add(criteriaBuilder.equal(root.get("training"), queryPageParam.getTraining()));
                }
                if (SearchAuthUtils.basicSearchAuth() == 1){
                    if (roleTag == UserTagEnum.USER_TAG_0.getCode()){
                        predicateList.add(criteriaBuilder.equal(root.get("createByUserId"), currentUserId));
                    }
                }
                predicateList.add(criteriaBuilder.equal(root.get("deleteStatus"),StatusEnum.DELETE_NOT.getCode()));
                return criteriaBuilder.and(predicateList.toArray(new Predicate[0]));
            }
        };
        PageRequest pageParam = PageRequest.of(queryPageParam.getPageIndex() - 1, queryPageParam.getPageSize(), Sort.Direction.DESC, "updateTime");

        Page<BasicExperimentPerson> pageResult = personRepository.findAll(specification, pageParam);
        List<PersonQueryDTO> personQueryDTOS = BeanCopyUtils.copyBeanList(pageResult.getContent(), PersonQueryDTO.class);
//        BasicExperimentPerson person = new BasicExperimentPerson();
//        person.set
//        personQueryDTOS.add()

        List<UserInfoDomainDTO> userList = userDomainService.getUserList();
        for (PersonQueryDTO personQueryDTO : personQueryDTOS) {
            for (UserInfoDomainDTO userInfo : userList) {
                if (userInfo.getId() == personQueryDTO.getCreateByUserId()){
                    personQueryDTO.setCreateByUserName(userInfo.getRealName());
                }
                if (userInfo.getId() == personQueryDTO.getUpdateByUserId()){
                    personQueryDTO.setUpdateByUserName(userInfo.getRealName());
                }
            }
        }

        searchResult.setData(personQueryDTOS);
        searchResult.setTotal(pageResult.getTotalElements());

        return searchResult;
    }

    /**
     * 基础实验人员 - 修改
     * */
    @Override
    public PersonUpdateDTO updateBasicExperimentPerson(Long currentUserId, BasicExperimentPersonAppUpdateBO updateParam) {

        if (currentUserId < 0){
            throw new BusinessException(this.getClass(), ResultCode.BUSINESS_ERROR_NOT_ALLOWED.getCode() ,"当前用户无效，请重新登陆");
        }

        //参数校验
        if (ObjectUtils.isEmpty(updateParam)){
            throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR_NULL.getCode(), "人员信息不能为空");
        }
        if (ObjectUtils.isEmpty(updateParam.getPersonName())){
            throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR_NULL.getCode(), "姓名不能为空");
        }
        if (ObjectUtils.isEmpty(updateParam.getPersonAge())){
            throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR_NULL.getCode(), "年龄不能为空");
        }
        if (ObjectUtils.isEmpty(updateParam.getPersonGender())){
            throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR_NULL.getCode(), "性别不能为空");
        }
        if (ObjectUtils.isEmpty(updateParam.getPersonMajor())){
            throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR_NULL.getCode(), "专业不能为空");
        }
//        if (ObjectUtils.isEmpty(insertPersonDO.getDepName())){
//            throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR_NULL.getCode(), "所属部门不能为空");
//        }  todo 暂时没有部门
        if (ObjectUtils.isEmpty(updateParam.getAptitude())){
            throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR_NULL.getCode(), "相关资质不能为空");
        }
        if (ObjectUtils.isEmpty(updateParam.getTraining())){
            throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR_NULL.getCode(), "培训情况不能为空");
        }
        if (ObjectUtils.isEmpty(updateParam.getPhone())){
            throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR_NULL.getCode(), "手机号不能为空");
        }
        BasicExperimentPerson personByPhone = personRepository.getPersonByPhone(updateParam.getPhone());
//        if (!ObjectUtils.isEmpty(personByPhone) && updateParam.getId() != personByPhone.getId()){
//            throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR_NULL.getCode(), "手机号已被使用");
//        }

        BasicExperimentPerson personById = personRepository.getPersonById(updateParam.getId());
        BasicExperimentPerson person = BeanCopyUtils.copyBean(personById, BasicExperimentPerson.class);
        UserInfoDomainDTO userInfoById = userDomainService.getUserInfoById(currentUserId);

        //获取参数
        LocalDateTime date = LocalDateTime.now();
        //封装参数
        person.setUpdateByUserId(userInfoById.getId());
        person.setUpdateTime(date);
        person.setPersonName(updateParam.getPersonName());
        person.setPersonAge(updateParam.getPersonAge());
        person.setPersonGender(updateParam.getPersonGender());
        person.setPersonMajor(updateParam.getPersonMajor());
        person.setDepName(updateParam.getDepName());
        person.setAptitude(updateParam.getAptitude());
        person.setTraining(updateParam.getTraining());
        person.setPhone(updateParam.getPhone());
        person.setImage(updateParam.getImage());

        //更新数据
        BasicExperimentPerson saveResult = personRepository.save(person);

        return BeanCopyUtils.copyBean(saveResult, PersonUpdateDTO.class);
    }

    /**
     * 基础实验人员 - 删除
     * */
    @Override
    public PersonDeleteDTO deleteBasicExperimentPerson(Long currentUserId, Long id) {

        if (currentUserId < 0){
            throw new BusinessException(this.getClass(), ResultCode.BUSINESS_ERROR_NOT_ALLOWED.getCode() ,"当前用户无效，请重新登陆");
        }

        //校验参数
        if (ObjectUtils.isEmpty(id)){
            throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR_NULL.getCode(), "请求参数错误");
        }
        BasicExperimentPerson personById = personRepository.getPersonById(id);
        if (ObjectUtils.isEmpty(personById)){
            throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR_NULL.getCode(), "该人员不存在，或已被删除");
        }
        UserInfoDomainDTO userInfoById = userDomainService.getUserInfoById(currentUserId);
        LocalDateTime date = LocalDateTime.now();
        //设置数据为删除
        personById.setDeleteStatus(StatusEnum.DELETED.getCode().byteValue());
        personById.setUpdateByUserId(userInfoById.getId());
        personById.setUpdateTime(date);
        //执行数据更新
        BasicExperimentPerson deleteResult = personRepository.save(personById);

        return BeanCopyUtils.copyBean(deleteResult, PersonDeleteDTO.class);
    }

    /**
     * 基础实验人员 - 列表
     * */
    @Override
    public List<PersonListDTO> listBasicExperimentPerson(Long currentUserId) {

        UserInfoDomainDTO user = userDomainService.getUserById(currentUserId);
        int roleTag = GetRoleTagUtils.GetRoleTagUtils(user);

        List<BasicExperimentPerson> peopleList = new ArrayList<>();
        if (SearchAuthUtils.basicSearchAuth() ==  0){
            peopleList = personRepository.listPerson(currentUserId);
            return BeanCopyUtils.copyBeanList(peopleList, PersonListDTO.class);
        }


        if (roleTag != UserTagEnum.USER_TAG_0.getCode()){
            peopleList = personRepository.listPerson(currentUserId);
        }else {
            peopleList = personRepository.listPersonByUserId(currentUserId);
        }
        return BeanCopyUtils.copyBeanList(peopleList, PersonListDTO.class);
    }

    /**
     * 基础实验人员 - 查询 by id
     * */
    @Override
    public PersonQueryDTO getBasicExperimentPersonById(Long id) {
        if (ObjectUtils.isEmpty(id)){
            throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR_NULL.getCode(), "请求参数不能为空");
        }

        BasicExperimentPerson personById = personRepository.getPersonById(id);

        if (ObjectUtils.isEmpty(personById)){
            throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR.getCode(), "请检查是否输入有误或人员已被删除");
        }
        return BeanCopyUtils.copyBean(personById, PersonQueryDTO.class);
    }

    /**
     * 基础实验人员 - 查询 by id --评估计划使用
     * */
    @Override
    public PersonQueryDTO getPersonByIdAndSellInfo(Long id, String Info) {
        if (ObjectUtils.isEmpty(id)){
            throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR_NULL.getCode(), "请求参数不能为空");
        }

        BasicExperimentPerson personById = personRepository.getPersonById(id);

        if (ObjectUtils.isEmpty(personById)){
            throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR.getCode(), Info + "不存在，请检查是否输入有误或人员已被删除");
        }
        return BeanCopyUtils.copyBean(personById, PersonQueryDTO.class);
    }

    /**
     * 基础实验人员 - 通过id列表查询
     * */
    @Override
    public List<PersonQueryDTO> getBasicExperimentPersonByIdList(List<Long> ids) {
        if (ids.size() < 1){
            throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR.getCode(), "请求参数不能为空");
        }

        List<BasicExperimentPerson> listResult  = personRepository.batchById(ids);
        if (listResult.size() < 1){
            throw new BusinessException(this.getClass(), ResultCode.PARAM_ERROR.getCode(), "查询结果为空");
        }

        return BeanCopyUtils.copyBeanList(listResult, PersonQueryDTO.class);
    }
}