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

import cn.hutool.core.util.ObjUtil;
import cn.iocoder.yudao.framework.common.pojo.PageResult;
import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
import cn.iocoder.yudao.module.mes.controller.admin.wm.equipmentreceipt.vo.line.MesWmEquipmentReceiptLinePageReqVO;
import cn.iocoder.yudao.module.mes.controller.admin.wm.equipmentreceipt.vo.line.MesWmEquipmentReceiptLineSaveReqVO;
import cn.iocoder.yudao.module.mes.dal.dataobject.dv.machinery.MesDvMachineryDO;
import cn.iocoder.yudao.module.mes.dal.dataobject.wm.equipmentreceipt.MesWmEquipmentReceiptLineDO;
import cn.iocoder.yudao.module.mes.dal.mysql.wm.equipmentreceipt.MesWmEquipmentReceiptLineMapper;
import cn.iocoder.yudao.module.mes.service.dv.machinery.MesDvMachineryService;
import jakarta.annotation.Resource;
import org.springframework.context.annotation.Lazy;
import org.springframework.stereotype.Service;
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 MesWmEquipmentReceiptLineServiceImpl implements MesWmEquipmentReceiptLineService {

    @Resource
    private MesWmEquipmentReceiptLineMapper equipmentReceiptLineMapper;
    @Resource
    private MesDvMachineryService machineryService;
    @Resource
    @Lazy
    private MesWmEquipmentReceiptService equipmentReceiptService;

    @Override
    public Long createEquipmentReceiptLine(MesWmEquipmentReceiptLineSaveReqVO createReqVO) {
        // 校验入库单可编辑
        equipmentReceiptService.validateEquipmentReceiptEditable(createReqVO.getReceiptId());
        // 校验设备存在且已关联物料
        validateMachineryHasItem(createReqVO.getMachineryId());
        // 校验数量
        validateQuantity(createReqVO.getQuantity());

        MesWmEquipmentReceiptLineDO line = BeanUtils.toBean(createReqVO, MesWmEquipmentReceiptLineDO.class);
        equipmentReceiptLineMapper.insert(line);
        return line.getId();
    }

    @Override
    public void updateEquipmentReceiptLine(MesWmEquipmentReceiptLineSaveReqVO updateReqVO) {
        // 校验行存在
        validateEquipmentReceiptLineExists(updateReqVO.getId());
        // 校验入库单可编辑
        equipmentReceiptService.validateEquipmentReceiptEditable(updateReqVO.getReceiptId());
        // 校验设备存在且已关联物料
        validateMachineryHasItem(updateReqVO.getMachineryId());
        // 校验数量
        validateQuantity(updateReqVO.getQuantity());

        MesWmEquipmentReceiptLineDO updateObj = BeanUtils.toBean(updateReqVO, MesWmEquipmentReceiptLineDO.class);
        equipmentReceiptLineMapper.updateById(updateObj);
    }

    @Override
    public void deleteEquipmentReceiptLine(Long id) {
        // 校验行存在
        MesWmEquipmentReceiptLineDO line = validateEquipmentReceiptLineExists(id);
        // 校验入库单可编辑
        equipmentReceiptService.validateEquipmentReceiptEditable(line.getReceiptId());

        equipmentReceiptLineMapper.deleteById(id);
    }

    @Override
    public void deleteByReceiptId(Long receiptId) {
        equipmentReceiptLineMapper.delete(MesWmEquipmentReceiptLineDO::getReceiptId, receiptId);
    }

    @Override
    public MesWmEquipmentReceiptLineDO getEquipmentReceiptLine(Long id) {
        return equipmentReceiptLineMapper.selectById(id);
    }

    @Override
    public List<MesWmEquipmentReceiptLineDO> getEquipmentReceiptLineListByReceiptId(Long receiptId) {
        return equipmentReceiptLineMapper.selectListByReceiptId(receiptId);
    }

    @Override
    public PageResult<MesWmEquipmentReceiptLineDO> getEquipmentReceiptLinePage(MesWmEquipmentReceiptLinePageReqVO pageReqVO) {
        return equipmentReceiptLineMapper.selectPage(pageReqVO);
    }

    private MesWmEquipmentReceiptLineDO validateEquipmentReceiptLineExists(Long id) {
        MesWmEquipmentReceiptLineDO line = equipmentReceiptLineMapper.selectById(id);
        if (line == null) {
            throw exception(WM_EQUIP_RECEIPT_LINE_NOT_EXISTS);
        }
        return line;
    }

    private void validateMachineryHasItem(Long machineryId) {
        machineryService.validateMachineryExists(machineryId);
        MesDvMachineryDO machinery = machineryService.getMachinery(machineryId);
        if (machinery == null || machinery.getItemId() == null) {
            throw exception(WM_EQUIP_RECEIPT_MACHINERY_NOT_VALID);
        }
    }

    private void validateQuantity(BigDecimal quantity) {
        if (quantity == null || quantity.compareTo(BigDecimal.ZERO) <= 0) {
            throw exception(WM_EQUIP_RECEIPT_QUANTITY_INVALID);
        }
    }

}