package cn.iocoder.yudao.module.mdm.service.item;

import cn.hutool.core.collection.CollUtil;
import cn.hutool.core.util.ObjUtil;
import cn.hutool.core.util.StrUtil;
import cn.iocoder.yudao.framework.common.enums.CommonStatusEnum;
import cn.iocoder.yudao.framework.common.pojo.PageResult;
import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
import cn.iocoder.yudao.module.mdm.controller.admin.item.vo.MdmItemModelPageReqVO;
import cn.iocoder.yudao.module.mdm.controller.admin.item.vo.MdmItemModelSaveReqVO;
import cn.iocoder.yudao.module.mdm.dal.dataobject.item.MdmItemDO;
import cn.iocoder.yudao.module.mdm.dal.dataobject.item.MdmItemModelDO;
import cn.iocoder.yudao.module.mdm.dal.dataobject.unit.MdmUnitMeasureDO;
import cn.iocoder.yudao.module.mdm.dal.mysql.item.MdmItemModelMapper;
import cn.iocoder.yudao.module.mdm.service.unit.MdmUnitMeasureService;
import jakarta.annotation.Resource;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.validation.annotation.Validated;

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

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

/**
 * MDM 物料型号 Service 实现类
 *
 * @author 超级管理员
 */
@Service
@Validated
public class MdmItemModelServiceImpl implements MdmItemModelService {

    @Resource
    private MdmItemModelMapper itemModelMapper;

    @Resource
    private MdmItemService itemService;
    @Resource
    private MdmUnitMeasureService unitMeasureService;

    @Override
    public Long createItemModel(MdmItemModelSaveReqVO createReqVO) {
        validateItemModelSaveData(null, createReqVO);

        MdmItemModelDO itemModel = BeanUtils.toBean(createReqVO, MdmItemModelDO.class);
        if (itemModel.getStatus() == null) {
            itemModel.setStatus(CommonStatusEnum.ENABLE.getStatus());
        }
        itemModelMapper.insert(itemModel);
        return itemModel.getId();
    }

    @Override
    public void updateItemModel(MdmItemModelSaveReqVO updateReqVO) {
        validateItemModelExists(updateReqVO.getId());
        validateItemModelSaveData(updateReqVO.getId(), updateReqVO);

        itemModelMapper.updateById(BeanUtils.toBean(updateReqVO, MdmItemModelDO.class));
    }

    private void validateItemModelSaveData(Long id, MdmItemModelSaveReqVO reqVO) {
        // 校验物料存在
        MdmItemDO item = itemService.validateItemExists(reqVO.getItemId());
        // 校验型号单位存在
        unitMeasureService.validateUnitMeasureExists(reqVO.getUnitMeasureId());
        // 校验换算比率大于 0
        if (reqVO.getUnitMeasureRate() == null
                || reqVO.getUnitMeasureRate().compareTo(BigDecimal.ZERO) <= 0) {
            throw exception(MDM_ITEM_MODEL_RATE_INVALID, reqVO.getModel(), reqVO.getUnitMeasureRate());
        }
        // 校验同一物料下型号名称唯一
        if (StrUtil.isNotBlank(reqVO.getModel())) {
            MdmItemModelDO exists = itemModelMapper.selectByItemIdAndModel(reqVO.getItemId(), reqVO.getModel());
            if (exists != null && ObjUtil.notEqual(exists.getId(), id)) {
                throw exception(MDM_ITEM_MODEL_NAME_DUPLICATE, reqVO.getModel());
            }
        }
        // 型号单位与物料主单位一致时，比率必须为 1（否则换算无意义且易误配）
        if (ObjUtil.equal(item.getUnitMeasureId(), reqVO.getUnitMeasureId())
                && reqVO.getUnitMeasureRate().compareTo(BigDecimal.ONE) != 0) {
            throw exception(MDM_ITEM_MODEL_RATE_MUST_BE_ONE, reqVO.getModel(),
                    unitName(reqVO.getUnitMeasureId()), unitName(item.getUnitMeasureId()));
        }
    }

    private String unitName(Long unitMeasureId) {
        MdmUnitMeasureDO unit = unitMeasureService.getUnitMeasure(unitMeasureId);
        return unit != null ? unit.getName() : "ID=" + unitMeasureId;
    }

    @Override
    public void deleteItemModel(Long id) {
        validateItemModelExists(id);
        itemModelMapper.deleteById(id);
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public void saveItemModelList(Long itemId, List<MdmItemModelSaveReqVO> modelList) {
        itemService.validateItemExists(itemId);
        // 第一步，删除旧的型号
        itemModelMapper.deleteByItemId(itemId);
        if (CollUtil.isEmpty(modelList)) {
            return;
        }
        // 第二步，插入新的型号
        for (MdmItemModelSaveReqVO reqVO : modelList) {
            reqVO.setItemId(itemId);
            reqVO.setId(null);
            createItemModel(reqVO);
        }
    }

    @Override
    public MdmItemModelDO getItemModel(Long id) {
        return itemModelMapper.selectById(id);
    }

    @Override
    public List<MdmItemModelDO> getItemModelList(Collection<Long> ids) {
        if (CollUtil.isEmpty(ids)) {
            return Collections.emptyList();
        }
        return itemModelMapper.selectBatchIds(ids);
    }

    @Override
    public List<MdmItemModelDO> getItemModelListByItemId(Long itemId) {
        return itemModelMapper.selectListByItemId(itemId);
    }

    @Override
    public List<MdmItemModelDO> getItemModelListByItemIds(Collection<Long> itemIds) {
        if (CollUtil.isEmpty(itemIds)) {
            return Collections.emptyList();
        }
        return itemModelMapper.selectListByItemIds(itemIds);
    }

    @Override
    public PageResult<MdmItemModelDO> getItemModelPage(MdmItemModelPageReqVO pageReqVO) {
        return itemModelMapper.selectPage(pageReqVO);
    }

    @Override
    public MdmItemModelDO validateItemModelExists(Long id) {
        MdmItemModelDO itemModel = itemModelMapper.selectById(id);
        if (itemModel == null) {
            throw exception(MDM_ITEM_MODEL_NOT_EXISTS);
        }
        return itemModel;
    }

    @Override
    public MdmItemModelDO validateItemModelExistsAndEnable(Long id) {
        MdmItemModelDO itemModel = validateItemModelExists(id);
        if (CommonStatusEnum.isDisable(itemModel.getStatus())) {
            throw exception(MDM_ITEM_MODEL_IS_DISABLE);
        }
        return itemModel;
    }

    @Override
    public void deleteItemModelListByItemId(Long itemId) {
        itemModelMapper.deleteByItemId(itemId);
    }

}