package com.doumee.service.business.impl;

import com.doumee.core.constants.ResponseStatus;
import com.doumee.core.exception.BusinessException;
import com.doumee.core.model.PageData;
import com.doumee.core.model.PageWrap;
import com.doumee.core.utils.Constants;
import com.doumee.core.utils.DateUtil;
import com.doumee.core.utils.Utils;
import com.doumee.dao.business.*;
import com.doumee.dao.business.model.Areas;
import com.doumee.dao.business.model.Company;
import com.doumee.dao.business.model.Declares;
import com.doumee.dao.business.model.Project;
import com.doumee.dao.business.model.ProjectSo;
import com.doumee.service.business.AreasService;
import com.doumee.service.business.ProjectSoService;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;
import com.baomidou.mybatisplus.core.metadata.IPage;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.github.yulichang.wrapper.MPJLambdaWrapper;
import java.math.BigDecimal;

import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.util.CollectionUtils;

import java.util.Date;
import java.util.List;
import java.util.Objects;
import java.util.stream.Collectors;

/**
 * 项目关联服务机构关联表Service实现
 * @author 江蹄蹄
 * @date 2023/02/15 08:55
 */
@Service
public class ProjectSoServiceImpl implements ProjectSoService {

    @Autowired
    private ProjectSoMapper projectSoMapper;
    @Autowired
    private ProjectSoJoinMapper projectSoJoinMapper;
    @Autowired
    private ProjectMapper projectMapper;
    @Autowired
    private CompanyMapper companyMapper;
    @Autowired
    private AreasService areasService;

    @Override
    public Integer create(ProjectSo projectSo) {
        if(projectSo.getProjectId() == null
            || projectSo.getCompanyId() == null
            || projectSo.getType() == null){
            throw  new BusinessException(ResponseStatus.BAD_REQUEST);
        }
        if(Constants.equalsObject(projectSo.getType(),Constants.ZERO) && Constants.formatBigdecimal(projectSo.getPrice()).compareTo(new BigDecimal(0)) != 1){
            throw  new BusinessException(ResponseStatus.BAD_REQUEST);
        }
        ProjectSo ps = new ProjectSo();
        ps.setCompanyId(projectSo.getCompanyId());
        ps.setProjectId(projectSo.getProjectId());
        ps.setType(projectSo.getType());
        ps.setIsdeleted(Constants.ZERO);
        //配置对象名称
        String orgType = Constants.equalsObject(projectSo.getType(),Constants.ONE)? Constants.CompanyType.ZF_SERVICE_COMPANY.getDes():Constants.CompanyType.SERVICE_COMPANYTYPE.getDes();
        if(findOne(ps) != null){
            throw  new BusinessException(ResponseStatus.DATA_EXISTS.getCode(),"对不起，该"+orgType+"配置已关联，无需重复提交！");
        }
        if(projectMapper.selectById(projectSo.getProjectId()) == null){
            throw  new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"对不起，该项目信息不存在！");
        }
        Company com  =companyMapper.selectById(projectSo.getCompanyId());
        if( com== null
             || !Constants.equalsInteger(com.getIsdeleted(),Constants.ZERO)
                || (Constants.equalsObject(projectSo.getType(),Constants.ZERO) ^ Constants.equalsInteger(com.getType(),Constants.CompanyType.SERVICE_COMPANYTYPE.getValue()))
                || (Constants.equalsObject(projectSo.getType(),Constants.ONE) ^ Constants.equalsInteger(com.getType(),Constants.CompanyType.ZF_SERVICE_COMPANY.getValue()))){
            throw  new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"对不起，该"+orgType+"信息不存在！");
        }
        projectSo.setIsdeleted(Constants.ZERO);
        projectSo.setCreateDate(DateUtil.getCurrentDate());
        projectSoMapper.insert(projectSo);
        return projectSo.getId();
    }

    @Override
    public List<Integer> createBatch(ProjectSo projectSo) {
        if(projectSo.getProjectId() == null
                || CollectionUtils.isEmpty(projectSo.getCompanyIds())
                || projectSo.getType() == null){
            throw  new BusinessException(ResponseStatus.BAD_REQUEST);
        }
        if(Constants.equalsObject(projectSo.getType(),Constants.ZERO) && Constants.formatBigdecimal(projectSo.getPrice()).compareTo(new BigDecimal(0)) != 1){
            throw  new BusinessException(ResponseStatus.BAD_REQUEST);
        }
        List<Integer> collect = projectSo.getCompanyIds().stream().distinct().collect(Collectors.toList());
        QueryWrapper<Company> wrapper = new QueryWrapper<>();
        wrapper.lambda()
                .eq(Company::getIsdeleted,Constants.ZERO)
                .eq(Company::getType,Constants.CompanyType.ZF_SERVICE_COMPANY.getValue())
                .in(Company::getId,collect);
        List<Company> coms  =companyMapper.selectList(wrapper);
        if (CollectionUtils.isEmpty(coms)){
            throw  new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"对不起，该"+projectSo.getCompanyIds()+"信息不存在！");
        }
        long count = coms.stream().filter(s -> Constants.equalsInteger(s.getType(), Constants.CompanyType.ZF_SERVICE_COMPANY.getValue())).count();

        if (count == 0){
            throw  new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"对不起，该"+projectSo.getCompanyIds()+"信息不存在！");
        }

        ProjectSo ps = new ProjectSo();
//        ps.setCompanyId(projectSo.getCompanyId());
        ps.setProjectId(projectSo.getProjectId());
        ps.setType(projectSo.getType());
        ps.setIsdeleted(Constants.ZERO);
        //配置对象名称
        String orgType = Constants.equalsObject(projectSo.getType(),Constants.ONE)? Constants.CompanyType.ZF_SERVICE_COMPANY.getDes():Constants.CompanyType.SERVICE_COMPANYTYPE.getDes();

        List<ProjectSo> list = findList(ps);

        //是否存在已经关联的综合服务单位
        if( !CollectionUtils.isEmpty(list) && list.stream().anyMatch(s -> projectSo.getCompanyIds().contains(s.getCompanyId()))){
            throw  new BusinessException(ResponseStatus.DATA_EXISTS.getCode(),"对不起，该"+orgType+"配置已关联，无需重复提交！");
        }

        if(projectMapper.selectById(projectSo.getProjectId()) == null){
            throw  new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"对不起，该项目信息不存在！");
        }

        List<Integer> collect1 = projectSo.getCompanyIds().stream().map(s -> {
            ProjectSo insert = new ProjectSo();
            insert.setCreator(projectSo.getCreator());
            insert.setEditor(projectSo.getCreator());
            insert.setType(Constants.ONE);
            insert.setEditDate(DateUtil.getCurrentDate());
            insert.setIsdeleted(Constants.ZERO);
            insert.setName(projectSo.getName());
            insert.setRemark(projectSo.getRemark());
            insert.setCompanyId(s);
            insert.setProjectId(projectSo.getProjectId());
            insert.setSortnum(projectSo.getSortnum());
            insert.setCreateDate(DateUtil.getCurrentDate());
            projectSoMapper.insert(insert);
            return insert.getId();
        }).collect(Collectors.toList());
        return collect1;

    }

    @Override
    public void deleteById(Integer id) {
        projectSoMapper.deleteById(id);
    }

    @Override
    public void delete(ProjectSo projectSo) {
        UpdateWrapper<ProjectSo> deleteWrapper = new UpdateWrapper<>(projectSo);
        projectSoMapper.delete(deleteWrapper);
    }

    @Override
    public void deleteByIdInBatch(List<Integer> ids) {
        if (CollectionUtils.isEmpty(ids)) {
            return;
        }
        projectSoMapper.deleteBatchIds(ids);
    }

    @Override
    public void updateById(ProjectSo projectSo) {
        projectSoMapper.updateById(projectSo);
    }
    @Override
    public void updateByPrice(ProjectSo projectSo) {
        if(projectSo.getId() == null
            ||Constants.formatBigdecimal(projectSo.getPrice()).compareTo(new BigDecimal(0)) != 1){
            throw  new BusinessException(ResponseStatus.BAD_REQUEST);
        }
        ProjectSo model = findById(projectSo.getId());
        if(model == null){
            throw  new BusinessException(ResponseStatus.DATA_EMPTY.getCode(),"对不起，请求数据不存在！");
        }
        if( Constants.formatBigdecimal(projectSo.getPrice()).compareTo(Constants.formatBigdecimal(model.getPrice())) ==0 ){
            throw  new BusinessException(ResponseStatus.BAD_REQUEST.getCode(),"对不起，价格无变化！");
        }
        projectSo.setEditDate(DateUtil.getCurrentDate());
        projectSoMapper.updateById(projectSo);
    }

    @Override
    public void updateByIdInBatch(List<ProjectSo> projectSos) {
        if (CollectionUtils.isEmpty(projectSos)) {
            return;
        }
        for (ProjectSo projectSo: projectSos) {
            this.updateById(projectSo);
        }
    }

    @Override
    public ProjectSo findById(Integer id) {
        return projectSoMapper.selectById(id);
    }

    @Override
    public ProjectSo findOne(ProjectSo projectSo) {
        QueryWrapper<ProjectSo> wrapper = new QueryWrapper<>(projectSo);
        return projectSoMapper.selectOne(wrapper);
    }

    @Override
    public List<ProjectSo> findList(ProjectSo projectSo) {
        QueryWrapper<ProjectSo> wrapper = new QueryWrapper<>(projectSo);
        return projectSoMapper.selectList(wrapper);
    }
  
    @Override
    public PageData<ProjectSo> findPage(PageWrap<ProjectSo> pageWrap) {
        pageWrap.getModel().setIsdeleted(Constants.ZERO);
        IPage<ProjectSo> page = new Page<>(pageWrap.getPage(), pageWrap.getCapacity());
        MPJLambdaWrapper<ProjectSo> queryWrapper = new MPJLambdaWrapper<>();
        Utils.MP.blankToNull(pageWrap.getModel());
        queryWrapper.leftJoin(Company.class,Company::getId,ProjectSo::getCompanyId);
        queryWrapper.eq(ProjectSo::getProjectId, pageWrap.getModel().getProjectId());
        queryWrapper.eq(ProjectSo::getIsdeleted,Constants.ZERO);
        queryWrapper.eq(Company::getIsdeleted,Constants.ZERO);
        queryWrapper.selectAll(ProjectSo.class);
        queryWrapper.selectAs(Company::getName, ProjectSo::getCompanyName);
        queryWrapper.selectAs(Company::getAreaId, ProjectSo::getCompanyAreaId);
        queryWrapper.selectAs(Company::getCityId, ProjectSo::getCompanyCityId);
        queryWrapper.selectAs(Company::getLinkName,ProjectSo::getCompanyLinkName);
        queryWrapper.selectAs(Company::getLinkPhone,ProjectSo::getCompanyLinkPhone);
        queryWrapper.eq(ProjectSo::getType,pageWrap.getModel().getType());
        if(StringUtils.isNotBlank(pageWrap.getModel().getCompanyName())){
            queryWrapper.like(Company::getName,pageWrap.getModel().getCompanyName());
        }
        queryWrapper.orderByDesc(ProjectSo::getCreateDate);
        IPage<ProjectSo> result = projectSoJoinMapper.selectJoinPage(page,ProjectSo.class, queryWrapper);
        if (!CollectionUtils.isEmpty(result.getRecords())){
            result.getRecords().forEach(s->{
                s.setCompanyBelongAddress(areasService.getAddress(s.getCompanyCityId(),s.getCompanyAreaId()));
            });
        }
        return PageData.from(result);
    }

    @Override
    public long count(ProjectSo projectSo) {
        QueryWrapper<ProjectSo> wrapper = new QueryWrapper<>(projectSo);
        return projectSoMapper.selectCount(wrapper);
    }


    /**
     * 判断当前服务机构是否属于该项目中的服务机构
     * @param declares
     * @return
     */
    @Override
    public ProjectSo belongToService(Declares declares,Integer soId) {

        MPJLambdaWrapper<ProjectSo> queryWrapper = new MPJLambdaWrapper<>();
        queryWrapper.selectAll(ProjectSo.class);
        queryWrapper.selectAs(Company::getName, ProjectSo::getCompanyName);
        queryWrapper.leftJoin(Company.class,Company::getId,ProjectSo::getCompanyId);
        queryWrapper.eq(ProjectSo::getProjectId,declares.getProjectId());
        queryWrapper.eq(ProjectSo::getCompanyId,soId);
        queryWrapper.eq(ProjectSo::getIsdeleted,Constants.ZERO);
        queryWrapper.eq(ProjectSo::getType,Constants.ZERO);
        queryWrapper.last(" limit 1");
        ProjectSo  model=projectSoJoinMapper.selectJoinOne(ProjectSo.class,queryWrapper);
        return  model;
      /*  List<ProjectSo> list=projectSoJoinMapper.selectJoinList(ProjectSo.class,queryWrapper);
        for(int i=0;i<list.size();i++){
            ProjectSo queryPS=list.get(i);
            if(Constants.equalsInteger(queryPS.getCompanyId(),soId)){
                return queryPS;
            }
        }
        return null;*/
    }
}