package cn.iocoder.yudao.module.mes.service.wm.itemreceipt;

import cn.iocoder.yudao.framework.common.util.collection.CollectionUtils;
import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
import cn.iocoder.yudao.module.mes.controller.admin.wm.itemreceipt.vo.detail.MesWmItemReceiptDetailSaveReqVO;
import cn.iocoder.yudao.module.mes.dal.dataobject.wm.itemreceipt.MesWmItemReceiptDetailDO;
import cn.iocoder.yudao.module.mes.dal.dataobject.wm.itemreceipt.MesWmItemReceiptLineDO;
import cn.iocoder.yudao.module.mes.dal.mysql.wm.itemreceipt.MesWmItemReceiptDetailMapper;
import cn.iocoder.yudao.module.mes.service.wm.materialstock.MesWmMaterialStockService;
import cn.iocoder.yudao.module.mes.service.wm.warehouse.MesWmWarehouseAreaService;
import jakarta.annotation.Resource;
import org.springframework.context.annotation.Lazy;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.validation.annotation.Validated;

import java.math.BigDecimal;
import java.util.List;

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

/**
 * MES 采购入库明细 Service 实现类
 */
@Service
@Validated
public class MesWmItemReceiptDetailServiceImpl implements MesWmItemReceiptDetailService {

    @Resource
    private MesWmItemReceiptDetailMapper itemReceiptDetailMapper;

    @Resource
    @Lazy
    private MesWmItemReceiptService itemReceiptService;
    @Resource
    @Lazy
    private MesWmItemReceiptLineService itemReceiptLineService;
    @Resource
    private MesWmWarehouseAreaService warehouseAreaService;
    @Resource
    @Lazy
    private MesWmMaterialStockService materialStockService;

    @Override
    @Transactional(rollbackFor = Exception.class)
    public Long createItemReceiptDetail(MesWmItemReceiptDetailSaveReqVO createReqVO) {
        // 1. 校验数据
        itemReceiptService.validateItemReceiptEditable(createReqVO.getReceiptId());
        validateItemReceiptDetailSaveData(createReqVO);

        // 2. 插入
        MesWmItemReceiptDetailDO detail = BeanUtils.toBean(createReqVO, MesWmItemReceiptDetailDO.class);
        itemReceiptDetailMapper.insert(detail);

        // 3. 插入后校验数量是否超出
        validateDetailQuantityNotExceed(createReqVO.getLineId());
        return detail.getId();
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void updateItemReceiptDetail(MesWmItemReceiptDetailSaveReqVO updateReqVO) {
        // 1.1 校验存在
        MesWmItemReceiptDetailDO detail = validateItemReceiptDetailExists(updateReqVO.getId());
        // 1.2 校验数据
        updateReqVO.setReceiptId(detail.getReceiptId());
        validateItemReceiptDetailSaveData(updateReqVO);

        // 2. 更新
        MesWmItemReceiptDetailDO updateObj = BeanUtils.toBean(updateReqVO, MesWmItemReceiptDetailDO.class);
        itemReceiptDetailMapper.updateById(updateObj);

        // 3. 更新后校验数量是否超出
        validateDetailQuantityNotExceed(detail.getLineId());
    }

    private void validateItemReceiptDetailSaveData(MesWmItemReceiptDetailSaveReqVO reqVO) {
        // 校验父单据存在且为可编辑状态
        itemReceiptService.validateItemReceiptEditable(reqVO.getReceiptId());
        // 校验库区关系
        warehouseAreaService.validateWarehouseAreaExists(reqVO.getWarehouseId(), reqVO.getLocationId(), reqVO.getAreaId());
        // 校验库位物料/批次混放规则
        materialStockService.checkAreaMixingRule(reqVO.getAreaId(), reqVO.getItemId(), reqVO.getBatchId());
    }

    @Override
    public void deleteItemReceiptDetail(Long id) {
        // 1.1 校验存在
        MesWmItemReceiptDetailDO detail = validateItemReceiptDetailExists(id);
        // 1.2 校验父单据存在且为可编辑状态
        itemReceiptService.validateItemReceiptEditable(detail.getReceiptId());

        // 删除
        itemReceiptDetailMapper.deleteById(id);
    }

    @Override
    public MesWmItemReceiptDetailDO getItemReceiptDetail(Long id) {
        return itemReceiptDetailMapper.selectById(id);
    }

    @Override
    public List<MesWmItemReceiptDetailDO> getItemReceiptDetailListByReceiptId(Long receiptId) {
        return itemReceiptDetailMapper.selectListByReceiptId(receiptId);
    }

    @Override
    public List<MesWmItemReceiptDetailDO> getItemReceiptDetailListByLineId(Long lineId) {
        return itemReceiptDetailMapper.selectListByLineId(lineId);
    }

    @Override
    public void deleteItemReceiptDetailByLineId(Long lineId) {
        itemReceiptDetailMapper.deleteByLineId(lineId);
    }

    @Override
    public void deleteItemReceiptDetailByReceiptId(Long receiptId) {
        itemReceiptDetailMapper.deleteByReceiptId(receiptId);
    }

    private MesWmItemReceiptDetailDO validateItemReceiptDetailExists(Long id) {
        MesWmItemReceiptDetailDO detail = itemReceiptDetailMapper.selectById(id);
        if (detail == null) {
            throw exception(WM_ITEM_RECEIPT_DETAIL_NOT_EXISTS);
        }
        return detail;
    }

    /**
     * 校验行下所有明细的数量之和不超过行的入库数量
     *
     * @param lineId 行编号
     */
    private void validateDetailQuantityNotExceed(Long lineId) {
        MesWmItemReceiptLineDO line = itemReceiptLineService.getItemReceiptLine(lineId);
        if (line == null || line.getReceivedQuantity() == null) {
            return;
        }
        List<MesWmItemReceiptDetailDO> details = itemReceiptDetailMapper.selectListByLineId(lineId);
        BigDecimal totalDetailQty = CollectionUtils.getSumValue(details,
                MesWmItemReceiptDetailDO::getQuantity, BigDecimal::add, BigDecimal.ZERO);
        if (totalDetailQty.compareTo(line.getReceivedQuantity()) > 0) {
            throw exception(WM_ITEM_RECEIPT_DETAIL_QUANTITY_EXCEED);
        }
    }

}