package com.ruoyi.system.service.impl;

import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.ruoyi.common.basic.PageInfo;
import com.ruoyi.system.export.TCrmChangePointsBranchExport;
import com.ruoyi.system.export.TCrmChangePointsClinicExport;
import com.ruoyi.system.export.TCrmChangePointsSalespersonExport;
import com.ruoyi.system.mapper.TCrmChangePointsMapper;
import com.ruoyi.system.mapper.TCrmClinicMapper;
import com.ruoyi.system.mapper.TErpProcurementMapper;
import com.ruoyi.system.model.TCrmChangePoints;
import com.ruoyi.system.model.TCrmClinic;
import com.ruoyi.system.model.TErpProcurement;
import com.ruoyi.system.model.TSysActivity;
import com.ruoyi.system.query.TCrmChangePointsQuery;
import com.ruoyi.system.service.TCrmChangePointsService;
import com.ruoyi.system.vo.TCrmChangePointsVO;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.util.CollectionUtils;

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

/**
 * <p>
 * crm修改积分记录 服务实现类
 * </p>
 *
 * @author xiaochen
 * @since 2025-09-02
 */
@Service
public class TCrmChangePointsServiceImpl extends ServiceImpl<TCrmChangePointsMapper, TCrmChangePoints> implements TCrmChangePointsService {

    @Autowired
    private TErpProcurementMapper erpProcurementMapper;
    @Autowired
    private TCrmClinicMapper crmClinicMapper;

    @Override
    public PageInfo<TCrmChangePointsVO> pageListBranch(TCrmChangePointsQuery query) {
        PageInfo<TCrmChangePointsVO> pageInfo = new PageInfo<>(query.getPageNum(), query.getPageSize());
        List<TCrmChangePointsVO> list = this.baseMapper.pageListBranch(query,pageInfo);
        if(CollectionUtils.isEmpty(list)){
            return pageInfo;
        }
        List<String> procurementIds = list.stream().map(TCrmChangePointsVO::getProcurementId)
                .filter(Objects::nonNull).collect(Collectors.toList());
        // 查询诊所
        List<TCrmClinic> crmClinics = crmClinicMapper.selectList(Wrappers.lambdaQuery(TCrmClinic.class));
        if(!CollectionUtils.isEmpty(procurementIds)){
            List<TErpProcurement> erpProcurements = erpProcurementMapper.selectList(Wrappers.lambdaQuery(TErpProcurement.class).in(TErpProcurement::getId, procurementIds));
            for (TCrmChangePointsVO tCrmChangePointsVO : list) {
                List<TErpProcurement> collect = erpProcurements.stream().filter(tErpProcurement -> tErpProcurement.getId().equals(tCrmChangePointsVO.getProcurementId())).collect(Collectors.toList());
                if(!CollectionUtils.isEmpty(collect)){
                    tCrmChangePointsVO.setProcurementCode(collect.get(0).getProcurementCode());
                    tCrmChangePointsVO.setPayMoney(collect.get(0).getPayMoney());
                    List<TCrmClinic> clinics = crmClinics.stream().filter(tCrmClinic -> tCrmClinic.getId().equals(collect.get(0).getClinicId())).collect(Collectors.toList());
                    if(!CollectionUtils.isEmpty(clinics)){
                        tCrmChangePointsVO.setClinicName(clinics.get(0).getClinicName());
                    }
                }
            }
        }
        pageInfo.setRecords(list);
        return pageInfo;
    }

    @Override
    public PageInfo<TCrmChangePointsVO> pageListSalesperson(TCrmChangePointsQuery query) {
        PageInfo<TCrmChangePointsVO> pageInfo = new PageInfo<>(query.getPageNum(), query.getPageSize());
        List<TCrmChangePointsVO> list = this.baseMapper.pageListSalesperson(query,pageInfo);
        if(CollectionUtils.isEmpty(list)){
            return pageInfo;
        }
        List<String> procurementIds = list.stream().map(TCrmChangePointsVO::getProcurementId)
                .filter(Objects::nonNull).collect(Collectors.toList());
        // 查询诊所
        List<TCrmClinic> crmClinics = crmClinicMapper.selectList(Wrappers.lambdaQuery(TCrmClinic.class));
        if(!CollectionUtils.isEmpty(procurementIds)){
            List<TErpProcurement> erpProcurements = erpProcurementMapper.selectList(Wrappers.lambdaQuery(TErpProcurement.class).in(TErpProcurement::getId, procurementIds));
            for (TCrmChangePointsVO tCrmChangePointsVO : list) {
                List<TErpProcurement> collect = erpProcurements.stream().filter(tErpProcurement -> tErpProcurement.getId().equals(tCrmChangePointsVO.getProcurementId())).collect(Collectors.toList());
                if(!CollectionUtils.isEmpty(collect)){
                    tCrmChangePointsVO.setProcurementCode(collect.get(0).getProcurementCode());
                    tCrmChangePointsVO.setPayMoney(collect.get(0).getPayMoney());
                    List<TCrmClinic> clinics = crmClinics.stream().filter(tCrmClinic -> tCrmClinic.getId().equals(collect.get(0).getClinicId())).collect(Collectors.toList());
                    if(!CollectionUtils.isEmpty(clinics)){
                        tCrmChangePointsVO.setClinicName(clinics.get(0).getClinicName());
                    }
                }
            }
        }
        pageInfo.setRecords(list);
        return pageInfo;
    }

    @Override
    public PageInfo<TCrmChangePointsVO> pageListClinic(TCrmChangePointsQuery query) {
        PageInfo<TCrmChangePointsVO> pageInfo = new PageInfo<>(query.getPageNum(), query.getPageSize());
        List<TCrmChangePointsVO> list = this.baseMapper.pageListClinic(query,pageInfo);
        if(CollectionUtils.isEmpty(list)){
            return pageInfo;
        }
        List<String> procurementIds = list.stream().map(TCrmChangePointsVO::getProcurementId)
                .filter(Objects::nonNull).collect(Collectors.toList());
        if(!CollectionUtils.isEmpty(procurementIds)){
            List<TErpProcurement> erpProcurements = erpProcurementMapper.selectList(Wrappers.lambdaQuery(TErpProcurement.class).in(TErpProcurement::getId, procurementIds));
            for (TCrmChangePointsVO tCrmChangePointsVO : list) {
                List<TErpProcurement> collect = erpProcurements.stream().filter(tErpProcurement -> tErpProcurement.getId().equals(tCrmChangePointsVO.getProcurementId())).collect(Collectors.toList());
                if(!CollectionUtils.isEmpty(collect)){
                    tCrmChangePointsVO.setProcurementCode(collect.get(0).getProcurementCode());
                    tCrmChangePointsVO.setPayMoney(collect.get(0).getPayMoney());
                }
            }
        }
        pageInfo.setRecords(list);
        return pageInfo;
    }

    @Override
    public List<TCrmChangePointsBranchExport> pageListBranchExport(TCrmChangePointsQuery query) {
        List<TCrmChangePointsBranchExport> list = this.baseMapper.pageListBranchExport(query);
        if(CollectionUtils.isEmpty(list)){
            return list;
        }
        List<String> procurementIds = list.stream().map(TCrmChangePointsBranchExport::getProcurementId)
                .filter(Objects::nonNull).collect(Collectors.toList());
        // 查询诊所
        List<TCrmClinic> crmClinics = crmClinicMapper.selectList(Wrappers.lambdaQuery(TCrmClinic.class));
        if(!CollectionUtils.isEmpty(procurementIds)){
            List<TErpProcurement> erpProcurements = erpProcurementMapper.selectList(Wrappers.lambdaQuery(TErpProcurement.class).in(TErpProcurement::getId, procurementIds));
            for (TCrmChangePointsBranchExport crmChangePointsBranchExport : list) {
                List<TErpProcurement> collect = erpProcurements.stream().filter(tErpProcurement -> tErpProcurement.getId().equals(crmChangePointsBranchExport.getProcurementId())).collect(Collectors.toList());
                if(!CollectionUtils.isEmpty(collect)){
                    crmChangePointsBranchExport.setProcurementCode(collect.get(0).getProcurementCode());
                    crmChangePointsBranchExport.setPayMoney(collect.get(0).getPayMoney());
                    List<TCrmClinic> clinics = crmClinics.stream().filter(tCrmClinic -> tCrmClinic.getId().equals(collect.get(0).getClinicId())).collect(Collectors.toList());
                    if(!CollectionUtils.isEmpty(clinics)){
                        crmChangePointsBranchExport.setClinicName(clinics.get(0).getClinicName());
                    }
                }
            }
        }
        return list;
    }

    @Override
    public List<TCrmChangePointsSalespersonExport> pageListSalespersonExport(TCrmChangePointsQuery query) {
        List<TCrmChangePointsSalespersonExport> list = this.baseMapper.pageListSalespersonExport(query);
        if(CollectionUtils.isEmpty(list)){
            return list;
        }
        List<String> procurementIds = list.stream().map(TCrmChangePointsSalespersonExport::getProcurementId)
                .filter(Objects::nonNull).collect(Collectors.toList());
        // 查询诊所
        List<TCrmClinic> crmClinics = crmClinicMapper.selectList(Wrappers.lambdaQuery(TCrmClinic.class));
        if(!CollectionUtils.isEmpty(procurementIds)){
            List<TErpProcurement> erpProcurements = erpProcurementMapper.selectList(Wrappers.lambdaQuery(TErpProcurement.class).in(TErpProcurement::getId, procurementIds));
            for (TCrmChangePointsSalespersonExport crmChangePointsSalespersonExport : list) {
                List<TErpProcurement> collect = erpProcurements.stream().filter(tErpProcurement -> tErpProcurement.getId().equals(crmChangePointsSalespersonExport.getProcurementId())).collect(Collectors.toList());
                if(!CollectionUtils.isEmpty(collect)){
                    crmChangePointsSalespersonExport.setProcurementCode(collect.get(0).getProcurementCode());
                    crmChangePointsSalespersonExport.setPayMoney(collect.get(0).getPayMoney());
                    List<TCrmClinic> clinics = crmClinics.stream().filter(tCrmClinic -> tCrmClinic.getId().equals(collect.get(0).getClinicId())).collect(Collectors.toList());
                    if(!CollectionUtils.isEmpty(clinics)){
                        crmChangePointsSalespersonExport.setClinicName(clinics.get(0).getClinicName());
                    }
                }
            }
        }
        return list;
    }

    @Override
    public List<TCrmChangePointsClinicExport> pageListClinicExport(TCrmChangePointsQuery query) {
        List<TCrmChangePointsClinicExport> list = this.baseMapper.pageListClinicExport(query);
        if(CollectionUtils.isEmpty(list)){
            return list;
        }
        List<String> procurementIds = list.stream().map(TCrmChangePointsClinicExport::getProcurementId)
                .filter(Objects::nonNull).collect(Collectors.toList());
        if(!CollectionUtils.isEmpty(procurementIds)){
            List<TErpProcurement> erpProcurements = erpProcurementMapper.selectList(Wrappers.lambdaQuery(TErpProcurement.class).in(TErpProcurement::getId, procurementIds));
            for (TCrmChangePointsClinicExport crmChangePointsClinicExport : list) {
                List<TErpProcurement> collect = erpProcurements.stream().filter(tErpProcurement -> tErpProcurement.getId().equals(crmChangePointsClinicExport.getProcurementId())).collect(Collectors.toList());
                if(!CollectionUtils.isEmpty(collect)){
                    crmChangePointsClinicExport.setProcurementCode(collect.get(0).getProcurementCode());
                    crmChangePointsClinicExport.setPayMoney(collect.get(0).getPayMoney());
                }
            }
        }
        return list;
    }
}