package cn.iocoder.yudao.module.crm.service.quotation;

import cn.hutool.core.collection.CollUtil;
import cn.iocoder.yudao.framework.common.pojo.PageResult;
import cn.iocoder.yudao.framework.common.util.number.MoneyUtils;
import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
import cn.iocoder.yudao.module.crm.controller.admin.contract.vo.contract.CrmContractSaveReqVO;
import cn.iocoder.yudao.module.crm.controller.admin.quotation.vo.CrmSaleQuotationPageReqVO;
import cn.iocoder.yudao.module.crm.controller.admin.quotation.vo.CrmSaleQuotationSaveReqVO;
import cn.iocoder.yudao.module.crm.dal.dataobject.contract.CrmContractDO;
import cn.iocoder.yudao.module.crm.dal.dataobject.quotation.CrmSaleQuotationDO;
import cn.iocoder.yudao.module.crm.dal.dataobject.quotation.CrmSaleQuotationProductDO;
import cn.iocoder.yudao.module.crm.dal.mysql.quotation.CrmSaleQuotationMapper;
import cn.iocoder.yudao.module.crm.dal.mysql.quotation.CrmSaleQuotationProductMapper;
import cn.iocoder.yudao.module.crm.dal.redis.no.CrmNoRedisDAO;
import cn.iocoder.yudao.module.crm.enums.common.CrmBizTypeEnum;
import cn.iocoder.yudao.module.crm.enums.permission.CrmPermissionLevelEnum;
import cn.iocoder.yudao.module.crm.enums.quotation.CrmSaleQuotationStatusEnum;
import cn.iocoder.yudao.module.crm.service.business.CrmBusinessService;
import cn.iocoder.yudao.module.crm.service.contact.CrmContactService;
import cn.iocoder.yudao.module.crm.service.contract.CrmContractService;
import cn.iocoder.yudao.module.crm.service.customer.CrmCustomerService;
import cn.iocoder.yudao.module.crm.api.customer.CrmCustomerApi;
import cn.iocoder.yudao.module.crm.service.permission.CrmPermissionService;
import cn.iocoder.yudao.module.crm.service.permission.bo.CrmPermissionCreateReqBO;
import cn.iocoder.yudao.module.mdm.api.item.MdmItemApi;
import cn.iocoder.yudao.module.mdm.api.item.dto.MdmItemRespDTO;
import jakarta.annotation.Resource;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.validation.annotation.Validated;

import java.math.BigDecimal;
import java.util.*;

import static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
import static cn.iocoder.yudao.framework.common.util.collection.CollectionUtils.*;
import static cn.iocoder.yudao.module.crm.enums.ErrorCodeConstants.*;

/**
 * CRM 销售报价单 Service 实现类
 *
 * @author 芋道源码
 */
@Service
@Validated
@Slf4j
public class CrmSaleQuotationServiceImpl implements CrmSaleQuotationService {

    @Resource
    private CrmSaleQuotationMapper saleQuotationMapper;
    @Resource
    private CrmSaleQuotationProductMapper saleQuotationProductMapper;

    @Resource
    private CrmNoRedisDAO noRedisDAO;

    @Resource
    private MdmItemApi mdmItemApi;

    @Resource
    private CrmCustomerService customerService;
    @Resource
    private CrmCustomerApi customerApi;
    @Resource
    private CrmBusinessService businessService;
    @Resource
    private CrmContactService contactService;
    @Resource
    private CrmPermissionService permissionService;
    @Resource
    private CrmContractService contractService;

    @Override
    @Transactional(rollbackFor = Exception.class)
    public Long createSaleQuotation(CrmSaleQuotationSaveReqVO createReqVO, Long userId) {
        // 1.1 校验物料项的有效性
        List<CrmSaleQuotationProductDO> quotationProducts = validateQuotationItems(createReqVO.getItems());
        // 1.2 生成报价单号，并校验唯一性
        String no = noRedisDAO.generate(CrmNoRedisDAO.SALE_QUOTATION_NO_PREFIX);
        if (saleQuotationMapper.selectByNo(no) != null) {
            throw exception(SALE_QUOTATION_NO_EXISTS);
        }
        // 1.3 校验关联字段
        validateRelationDataExists(createReqVO);

        // 2.1 插入报价单
        CrmSaleQuotationDO saleQuotation = BeanUtils.toBean(createReqVO, CrmSaleQuotationDO.class, q -> q
                .setNo(no)
                .setStatus(CrmSaleQuotationStatusEnum.DRAFT.getStatus()));
        calculateTotalPrice(saleQuotation, quotationProducts);
        saleQuotationMapper.insert(saleQuotation);
        // 2.2 插入报价明细
        quotationProducts.forEach(p -> p.setQuotationId(saleQuotation.getId()));
        saleQuotationProductMapper.insertBatch(quotationProducts);
        // 2.3 创建数据权限
        permissionService.createPermission(new CrmPermissionCreateReqBO()
                .setUserId(userId)
                .setBizType(CrmBizTypeEnum.CRM_SALE_QUOTATION.getType())
                .setBizId(saleQuotation.getId())
                .setLevel(CrmPermissionLevelEnum.OWNER.getLevel()));
        return saleQuotation.getId();
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void updateSaleQuotation(CrmSaleQuotationSaveReqVO updateReqVO) {
        // 1.1 校验存在
        CrmSaleQuotationDO saleQuotation = validateSaleQuotationExists(updateReqVO.getId());
        // 1.2 校验状态，只有草稿状态才能修改
        if (!CrmSaleQuotationStatusEnum.DRAFT.getStatus().equals(saleQuotation.getStatus())) {
            throw exception(SALE_QUOTATION_UPDATE_FAIL_NOT_DRAFT, saleQuotation.getNo());
        }
        // 1.3 校验物料项的有效性
        List<CrmSaleQuotationProductDO> quotationProducts = validateQuotationItems(updateReqVO.getItems());
        // 1.4 校验关联字段
        validateRelationDataExists(updateReqVO);

        // 2.1 更新报价单
        CrmSaleQuotationDO updateObj = BeanUtils.toBean(updateReqVO, CrmSaleQuotationDO.class);
        calculateTotalPrice(updateObj, quotationProducts);
        saleQuotationMapper.updateById(updateObj);
        // 2.2 更新报价明细
        updateQuotationProductList(updateReqVO.getId(), quotationProducts);
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void deleteSaleQuotation(List<Long> ids) {
        // 1. 校验不处于非草稿状态
        List<CrmSaleQuotationDO> saleQuotations = saleQuotationMapper.selectByIds(ids);
        if (CollUtil.isEmpty(saleQuotations)) {
            return;
        }
        saleQuotations.forEach(saleQuotation -> {
            if (!CrmSaleQuotationStatusEnum.DRAFT.getStatus().equals(saleQuotation.getStatus())) {
                throw exception(SALE_QUOTATION_DELETE_FAIL_NOT_DRAFT, saleQuotation.getNo());
            }
        });

        // 2. 遍历删除
        saleQuotations.forEach(saleQuotation -> {
            // 2.1 删除报价单
            saleQuotationMapper.deleteById(saleQuotation.getId());
            // 2.2 删除报价明细
            saleQuotationProductMapper.deleteByQuotationId(saleQuotation.getId());
            // 2.3 删除数据权限
            permissionService.deletePermission(CrmBizTypeEnum.CRM_SALE_QUOTATION.getType(), saleQuotation.getId());
        });
    }

    private CrmSaleQuotationDO validateSaleQuotationExists(Long id) {
        CrmSaleQuotationDO saleQuotation = saleQuotationMapper.selectById(id);
        if (saleQuotation == null) {
            throw exception(SALE_QUOTATION_NOT_EXISTS);
        }
        return saleQuotation;
    }

    private List<CrmSaleQuotationProductDO> validateQuotationItems(List<CrmSaleQuotationSaveReqVO.Item> list) {
        // 1. 校验物料存在且启用
        Set<Long> itemIds = convertSet(list, CrmSaleQuotationSaveReqVO.Item::getItemId);
        Map<Long, MdmItemRespDTO> itemMap = mdmItemApi.getItemMap(itemIds);
        // 2. 转换为 CrmSaleQuotationProductDO 列表
        return convertList(list, o -> BeanUtils.toBean(o, CrmSaleQuotationProductDO.class, item -> {
            MdmItemRespDTO mdmItem = itemMap.get(item.getItemId());
            if (mdmItem == null) {
                throw exception(SALE_QUOTATION_ITEM_NOT_EXISTS);
            }
            item.setItemUnitId(mdmItem.getUnitMeasureId());
            // 物料原价，如果 MDM 中没有则默认为 0
            item.setItemPrice(mdmItem.getSalesPrice() != null ? mdmItem.getSalesPrice() : BigDecimal.ZERO);
            if (item.getQuotationPrice() != null && item.getCount() != null) {
                item.setTotalPrice(MoneyUtils.priceMultiply(item.getQuotationPrice(), item.getCount()));
                if (item.getTaxPercent() != null) {
                    item.setTaxPrice(MoneyUtils.priceMultiplyPercent(item.getTotalPrice(), item.getTaxPercent()));
                }
            }
        }));
    }

    private void validateRelationDataExists(CrmSaleQuotationSaveReqVO reqVO) {
        // 1. 校验客户
        customerService.validateCustomer(reqVO.getCustomerId());
        // 2. 校验商机（可选）
        if (reqVO.getBusinessId() != null) {
            businessService.validateBusiness(reqVO.getBusinessId());
        }
        // 3. 校验联系人（可选）
        if (reqVO.getContactId() != null) {
            contactService.validateContact(reqVO.getContactId());
        }
    }

    private void updateQuotationProductList(Long id, List<CrmSaleQuotationProductDO> newList) {
        // 第一步，对比新老数据，获得添加、修改、删除的列表
        List<CrmSaleQuotationProductDO> oldList = saleQuotationProductMapper.selectListByQuotationId(id);
        List<List<CrmSaleQuotationProductDO>> diffList = diffList(oldList, newList,
                (oldVal, newVal) -> oldVal.getId().equals(newVal.getId()));

        // 第二步，批量添加、修改、删除
        if (CollUtil.isNotEmpty(diffList.get(0))) {
            diffList.get(0).forEach(o -> o.setQuotationId(id));
            saleQuotationProductMapper.insertBatch(diffList.get(0));
        }
        if (CollUtil.isNotEmpty(diffList.get(1))) {
            saleQuotationProductMapper.updateBatch(diffList.get(1));
        }
        if (CollUtil.isNotEmpty(diffList.get(2))) {
            saleQuotationProductMapper.deleteByIds(convertList(diffList.get(2), CrmSaleQuotationProductDO::getId));
        }
    }

    private void calculateTotalPrice(CrmSaleQuotationDO saleQuotation, List<CrmSaleQuotationProductDO> items) {
        saleQuotation.setTotalProductPrice(getSumValue(items, CrmSaleQuotationProductDO::getTotalPrice, BigDecimal::add, BigDecimal.ZERO));
        BigDecimal totalTaxPrice = getSumValue(items, CrmSaleQuotationProductDO::getTaxPrice, BigDecimal::add, BigDecimal.ZERO);
        saleQuotation.setTaxPrice(totalTaxPrice);
        // 计算优惠价格
        if (saleQuotation.getDiscountPercent() == null) {
            saleQuotation.setDiscountPercent(BigDecimal.ZERO);
        }
        BigDecimal basePrice = saleQuotation.getTotalProductPrice().add(totalTaxPrice);
        saleQuotation.setDiscountPrice(MoneyUtils.priceMultiplyPercent(basePrice, saleQuotation.getDiscountPercent()));
        saleQuotation.setTotalPrice(basePrice.subtract(saleQuotation.getDiscountPrice()));
    }

    @Override
    public CrmSaleQuotationDO getSaleQuotation(Long id) {
        return saleQuotationMapper.selectById(id);
    }

    @Override
    public PageResult<CrmSaleQuotationDO> getSaleQuotationPage(CrmSaleQuotationPageReqVO pageReqVO, Long userId) {
        // 获取用户有权限的客户 ID 列表
        List<Long> permittedCustomerIds = customerApi.getPermittedCustomerIds();
        return saleQuotationMapper.selectPage(pageReqVO, userId, permittedCustomerIds);
    }

    @Override
    public PageResult<CrmSaleQuotationDO> getSaleQuotationPageByCustomerId(CrmSaleQuotationPageReqVO pageReqVO) {
        return saleQuotationMapper.selectPageByCustomerId(pageReqVO);
    }

    @Override
    public PageResult<CrmSaleQuotationDO> getSaleQuotationPageByBusinessId(CrmSaleQuotationPageReqVO pageReqVO) {
        return saleQuotationMapper.selectPageByBusinessId(pageReqVO);
    }

    @Override
    public List<CrmSaleQuotationProductDO> getSaleQuotationProductListByQuotationId(Long quotationId) {
        return saleQuotationProductMapper.selectListByQuotationId(quotationId);
    }

    @Override
    public List<CrmSaleQuotationProductDO> getSaleQuotationProductListByQuotationIds(Collection<Long> quotationIds) {
        if (CollUtil.isEmpty(quotationIds)) {
            return Collections.emptyList();
        }
        return saleQuotationProductMapper.selectListByQuotationIds(quotationIds);
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public Long convertToContract(Long id, Long userId) {
        // 1. 校验报价单存在且为草稿状态
        CrmSaleQuotationDO saleQuotation = validateSaleQuotationExists(id);
        if (!CrmSaleQuotationStatusEnum.DRAFT.getStatus().equals(saleQuotation.getStatus())) {
            throw exception(SALE_QUOTATION_CONVERT_FAIL_NOT_DRAFT, saleQuotation.getNo());
        }
        // 校验是否已转合同
        if (saleQuotation.getContractId() != null) {
            throw exception(SALE_QUOTATION_CONTRACT_EXISTS);
        }

        // 2. 获取报价明细
        List<CrmSaleQuotationProductDO> quotationProducts = saleQuotationProductMapper.selectListByQuotationId(id);

        // 3. 构建合同创建 VO
        CrmContractSaveReqVO contractVO = new CrmContractSaveReqVO();
        contractVO.setName(saleQuotation.getName() + "-合同");
        contractVO.setCustomerId(saleQuotation.getCustomerId());
        contractVO.setBusinessId(saleQuotation.getBusinessId());
        contractVO.setOwnerUserId(saleQuotation.getOwnerUserId());
        contractVO.setOrderDate(saleQuotation.getQuotationTime());
        contractVO.setDiscountPercent(saleQuotation.getDiscountPercent());
        contractVO.setRemark("由报价单[" + saleQuotation.getNo() + "]生成");
        // 转换明细项：报价单物料 -> 合同产品
        List<CrmContractSaveReqVO.Product> contractProducts = convertList(quotationProducts, qp -> {
            CrmContractSaveReqVO.Product product = new CrmContractSaveReqVO.Product();
            product.setItemId(qp.getItemId());
            product.setItemPrice(qp.getItemPrice());
            product.setContractPrice(qp.getQuotationPrice());
            product.setCount(qp.getCount().intValue());
            return product;
        });
        contractVO.setProducts(contractProducts);

        // 4. 创建合同（会自动检测合同审批流程并提交审批）
        Long contractId = contractService.createContract(contractVO, userId);

        // 5. 更新报价单关联信息
        CrmContractDO contract = contractService.getContract(contractId);
        saleQuotationMapper.updateById(new CrmSaleQuotationDO()
                .setId(id)
                .setContractId(contractId)
                .setContractNo(contract.getNo())
                .setStatus(CrmSaleQuotationStatusEnum.CONVERTED.getStatus()));

        return contractId;
    }

}