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

import cn.hutool.core.util.StrUtil;
import cn.iocoder.yudao.framework.common.exception.ServiceException;
import cn.iocoder.yudao.module.crm.controller.admin.quotation.vo.CrmSaleQuotationImportExcelVO;
import cn.iocoder.yudao.module.crm.controller.admin.quotation.vo.CrmSaleQuotationSaveReqVO;
import cn.iocoder.yudao.module.crm.dal.dataobject.customer.CrmCustomerDO;
import cn.iocoder.yudao.module.crm.dal.dataobject.quotation.CrmSaleQuotationDO;
import cn.iocoder.yudao.module.crm.dal.mysql.customer.CrmCustomerMapper;
import cn.iocoder.yudao.module.crm.dal.mysql.quotation.CrmSaleQuotationMapper;
import cn.iocoder.yudao.module.mdm.api.item.MdmItemApi;
import cn.iocoder.yudao.module.mdm.api.item.dto.MdmItemRespDTO;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import jakarta.annotation.Resource;
import org.springframework.stereotype.Service;
import java.math.BigDecimal;
import java.util.*;

@Service
public class CrmSaleQuotationImportService {
    @Resource private CrmCustomerMapper customerMapper;
    @Resource private CrmSaleQuotationMapper quotationMapper;
    @Resource private MdmItemApi itemApi;
    @Resource private CrmSaleQuotationService quotationService;

    public Map<String, Object> importRows(List<CrmSaleQuotationImportExcelVO> rows, Long userId) {
        Map<String, List<CrmSaleQuotationImportExcelVO>> groups = new LinkedHashMap<>();
        int rowNumber = 1;
        for (CrmSaleQuotationImportExcelVO row : rows) {
            rowNumber++;
            if (row == null) continue;
            if (StrUtil.isBlank(row.getName()) && StrUtil.isBlank(row.getCustomerName()) && StrUtil.isBlank(row.getItemCode())) continue;
            if (StrUtil.isBlank(row.getName()) || StrUtil.isBlank(row.getCustomerName())) {
                throw new IllegalArgumentException("第" + rowNumber + "行报价名称和客户名称不能为空");
            }
            String key = row.getCustomerName().trim() + " / " + row.getName().trim();
            groups.computeIfAbsent(key, ignored -> new ArrayList<>()).add(row);
        }
        if (groups.isEmpty()) throw new IllegalArgumentException("导入数据不能为空");
        List<String> created = new ArrayList<>();
        Map<String, String> failures = new LinkedHashMap<>();
        groups.forEach((key, group) -> {
            try {
                CrmSaleQuotationImportExcelVO first = group.get(0);
                CrmCustomerDO customer = customerMapper.selectByCustomerName(first.getCustomerName().trim());
                if (customer == null) throw new IllegalArgumentException("客户不存在：" + first.getCustomerName());
                if (quotationMapper.selectCount(new LambdaQueryWrapper<CrmSaleQuotationDO>()
                        .eq(CrmSaleQuotationDO::getCustomerId, customer.getId()).eq(CrmSaleQuotationDO::getName, first.getName().trim())) > 0) {
                    throw new IllegalArgumentException("该客户已有同名报价单，请勿重复导入");
                }
                CrmSaleQuotationSaveReqVO req = new CrmSaleQuotationSaveReqVO();
                req.setName(first.getName().trim()); req.setCustomerId(customer.getId()); req.setOwnerUserId(userId);
                req.setQuotationTime(first.getQuotationTime()); req.setValidUntil(first.getValidUntil());
                req.setDiscountPercent(first.getDiscountPercent() == null ? BigDecimal.ZERO : first.getDiscountPercent());
                if (req.getDiscountPercent().signum() < 0 || req.getDiscountPercent().compareTo(new BigDecimal("100")) > 0) throw new IllegalArgumentException("折扣须在 0 到 100 之间");
                if (req.getQuotationTime() != null && req.getValidUntil() != null && req.getValidUntil().isBefore(req.getQuotationTime())) throw new IllegalArgumentException("有效期不能早于报价日期");
                List<CrmSaleQuotationSaveReqVO.Item> items = new ArrayList<>();
                for (CrmSaleQuotationImportExcelVO row : group) {
                    if (row.getQuotationTime() != null && !row.getQuotationTime().equals(first.getQuotationTime()) || row.getValidUntil() != null && !row.getValidUntil().equals(first.getValidUntil()) || row.getDiscountPercent() != null && (first.getDiscountPercent() == null || row.getDiscountPercent().compareTo(first.getDiscountPercent()) != 0)) throw new IllegalArgumentException("同一报价单的日期和折扣必须一致");
                    if (StrUtil.isBlank(row.getItemCode()) || row.getPrice() == null || row.getPrice().signum() < 0 || row.getCount() == null || row.getCount().signum() <= 0) throw new IllegalArgumentException("物料编码、非负单价和大于零的数量不能为空");
                    if (row.getTaxPercent() != null && (row.getTaxPercent().signum() < 0 || row.getTaxPercent().compareTo(new BigDecimal("100")) > 0)) throw new IllegalArgumentException("税率须在 0 到 100 之间");
                    MdmItemRespDTO item = itemApi.getItemByCode(row.getItemCode().trim()).getCheckedData();
                    if (item == null) throw new IllegalArgumentException("物料不存在：" + row.getItemCode());
                    CrmSaleQuotationSaveReqVO.Item detail = new CrmSaleQuotationSaveReqVO.Item();
                    detail.setItemId(item.getId()); detail.setQuotationPrice(row.getPrice()); detail.setCount(row.getCount()); detail.setTaxPercent(row.getTaxPercent()); detail.setRemark(row.getRemark()); items.add(detail);
                }
                req.setItems(items);
                quotationService.createSaleQuotation(req, userId);
                created.add(key);
            } catch (ServiceException | IllegalArgumentException ex) {
                failures.put(key, ex.getMessage());
            }
        });
        Map<String, Object> result = new LinkedHashMap<>();
        result.put("createQuotationNames", created); result.put("failureQuotationNames", failures);
        return result;
    }
}