package cn.iocoder.yudao.module.erp.service.statistics;

import cn.iocoder.yudao.framework.common.util.collection.CollectionUtils;
import cn.iocoder.yudao.module.crm.api.customer.CrmCustomerApi;
import cn.iocoder.yudao.module.crm.api.customer.dto.CrmCustomerRespDTO;
import cn.iocoder.yudao.module.erp.controller.admin.statistics.vo.sale.ErpSaleCustomerSummaryRespVO;
import cn.iocoder.yudao.module.erp.controller.admin.statistics.vo.sale.ErpSaleProductSummaryRespVO;
import cn.iocoder.yudao.module.erp.dal.dataobject.sale.ErpSaleCustomerReceiptStatisticsDO;
import cn.iocoder.yudao.module.erp.dal.dataobject.sale.ErpSaleCustomerStatisticsDO;
import cn.iocoder.yudao.module.erp.dal.dataobject.sale.ErpSaleProductStatisticsDO;
import cn.iocoder.yudao.module.erp.dal.mysql.statistics.ErpSaleStatisticsMapper;
import cn.iocoder.yudao.module.mdm.api.item.MdmItemApi;
import cn.iocoder.yudao.module.mdm.api.item.dto.MdmItemRespDTO;
import jakarta.annotation.Resource;
import org.springframework.stereotype.Service;

import java.math.BigDecimal;
import java.time.LocalDateTime;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;

/**
 * ERP 销售统计 Service 实现类
 *
 * @author 超级管理员
 */
@Service
public class ErpSaleStatisticsServiceImpl implements ErpSaleStatisticsService {

    @Resource
    private ErpSaleStatisticsMapper saleStatisticsMapper;

    @Resource
    private CrmCustomerApi customerApi;

    @Resource
    private MdmItemApi mdmItemApi;

    @Override
    public BigDecimal getSalePrice(LocalDateTime beginTime, LocalDateTime endTime) {
        return saleStatisticsMapper.getSalePrice(beginTime, endTime);
    }

    @Override
    public List<ErpSaleCustomerSummaryRespVO> getCustomerSummary(Long customerId, LocalDateTime beginTime, LocalDateTime endTime) {
        List<ErpSaleCustomerStatisticsDO> saleList = saleStatisticsMapper.selectCustomerStatistics(customerId, beginTime, endTime);
        if (CollectionUtils.isAnyEmpty(saleList)) {
            return new ArrayList<>();
        }
        // 1. 已收款金额按客户归集（收款单可能早于/晚于订单，不做订单级勾稽，只按客户汇总）
        Map<Long, BigDecimal> receiptMap = CollectionUtils.convertMap(
                saleStatisticsMapper.selectCustomerReceiptStatistics(customerId, beginTime, endTime),
                ErpSaleCustomerReceiptStatisticsDO::getCustomerId,
                ErpSaleCustomerReceiptStatisticsDO::getReceiptAmount);
        // 2. 客户名称
        Map<Long, CrmCustomerRespDTO> customerMap = customerApi.getCustomerMap(
                CollectionUtils.convertSet(saleList, ErpSaleCustomerStatisticsDO::getCustomerId));
        // 3. 组装
        List<ErpSaleCustomerSummaryRespVO> result = new ArrayList<>(saleList.size());
        for (ErpSaleCustomerStatisticsDO sale : saleList) {
            BigDecimal saleAmount = sale.getSaleAmount() == null ? BigDecimal.ZERO : sale.getSaleAmount();
            BigDecimal receiptAmount = receiptMap.getOrDefault(sale.getCustomerId(), BigDecimal.ZERO);
            CrmCustomerRespDTO customer = customerMap.get(sale.getCustomerId());
            ErpSaleCustomerSummaryRespVO vo = new ErpSaleCustomerSummaryRespVO();
            vo.setCustomerId(sale.getCustomerId());
            vo.setCustomerName(customer != null ? customer.getName() : "客户(" + sale.getCustomerId() + ")");
            vo.setOrderCount(sale.getOrderCount());
            vo.setSaleAmount(saleAmount);
            vo.setReceiptAmount(receiptAmount);
            vo.setUnreceivedAmount(saleAmount.subtract(receiptAmount));
            vo.setLastOrderTime(sale.getLastOrderTime());
            result.add(vo);
        }
        return result;
    }

    @Override
    public List<ErpSaleProductSummaryRespVO> getProductSummary(Long productId, LocalDateTime beginTime, LocalDateTime endTime) {
        List<ErpSaleProductStatisticsDO> saleList = saleStatisticsMapper.selectProductStatistics(productId, beginTime, endTime);
        if (CollectionUtils.isAnyEmpty(saleList)) {
            return new ArrayList<>();
        }
        // 1. 产品名称与参考成本价
        Map<Long, MdmItemRespDTO> itemMap = mdmItemApi.getItemMap(
                CollectionUtils.convertSet(saleList, ErpSaleProductStatisticsDO::getProductId));
        // 2. 组装，毛利 = 销售金额 - 数量 × 参考成本价
        List<ErpSaleProductSummaryRespVO> result = new ArrayList<>(saleList.size());
        for (ErpSaleProductStatisticsDO sale : saleList) {
            MdmItemRespDTO item = itemMap.get(sale.getProductId());
            BigDecimal saleAmount = sale.getSaleAmount() == null ? BigDecimal.ZERO : sale.getSaleAmount();
            BigDecimal costPrice = item != null && item.getCostPrice() != null ? item.getCostPrice() : BigDecimal.ZERO;
            BigDecimal totalCount = sale.getTotalCount() == null ? BigDecimal.ZERO : sale.getTotalCount();
            BigDecimal costAmount = costPrice.multiply(totalCount);
            ErpSaleProductSummaryRespVO vo = new ErpSaleProductSummaryRespVO();
            vo.setProductId(sale.getProductId());
            vo.setProductName(item != null ? item.getName() : "产品(" + sale.getProductId() + ")");
            vo.setOrderCount(sale.getOrderCount());
            vo.setTotalCount(totalCount);
            vo.setSaleAmount(saleAmount);
            vo.setCostAmount(costAmount);
            vo.setProfitAmount(saleAmount.subtract(costAmount));
            result.add(vo);
        }
        return result;
    }

}