package cn.iocoder.yudao.module.mes.service.md.item;

import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
import cn.iocoder.yudao.module.mes.controller.admin.md.item.vo.batchconfig.MesMdItemBatchConfigSaveReqVO;
import cn.iocoder.yudao.module.mes.dal.dataobject.md.item.MesMdItemBatchConfigDO;
import cn.iocoder.yudao.module.mes.dal.mysql.md.item.MesMdItemBatchConfigMapper;
import cn.iocoder.yudao.module.mdm.api.item.MdmItemApi;
import cn.iocoder.yudao.module.mdm.api.item.MdmItemBatchConfigApi;
import cn.iocoder.yudao.module.mdm.api.item.dto.MdmItemBatchConfigRespDTO;
import cn.iocoder.yudao.module.mdm.dal.dataobject.item.MdmItemBatchConfigDO;
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 static cn.iocoder.yudao.framework.common.exception.util.ServiceExceptionUtil.exception;
import static cn.iocoder.yudao.module.mes.enums.ErrorCodeConstants.MD_ITEM_BATCH_CONFIG_NOT_EXISTS;
import static cn.iocoder.yudao.module.mes.enums.ErrorCodeConstants.MD_ITEM_NOT_EXISTS;

/**
 * MES 物料批次属性配置 Service 实现类
 *
 * 批次配置统一存储在 MDM 表（mdm_item_batch_config）
 * MES 本地表（mes_md_item_batch_config）仅用于兼容历史数据和 MES 模块内部查询
 *
 * @author 芋道源码
 */
@Service
@Validated
public class MesMdItemBatchConfigServiceImpl implements MesMdItemBatchConfigService {

    @Resource
    private MesMdItemBatchConfigMapper itemBatchConfigMapper;

    @Resource
    @Lazy
    private MesMdItemService itemService;

    @Resource
    @Lazy
    private MdmItemApi mdmItemApi;

    @Resource
    private MdmItemBatchConfigApi mdmItemBatchConfigApi;

    @Override
    public MesMdItemBatchConfigDO getItemBatchConfigByItemId(Long itemId) {
        // 优先从 MES 本地表查询（性能更好）
        MesMdItemBatchConfigDO mesConfig = itemBatchConfigMapper.selectByItemId(itemId);
        if (mesConfig != null) {
            return mesConfig;
        }
        // 本地表不存在，尝试从 MDM 获取（不写入本地，避免副作用）
        MdmItemBatchConfigRespDTO mdmConfig = mdmItemBatchConfigApi.getItemBatchConfig(itemId);
        if (mdmConfig != null) {
            return BeanUtils.toBean(mdmConfig, MesMdItemBatchConfigDO.class);
        }
        return null;
    }

    @Override
    public MesMdItemBatchConfigDO validateItemBatchConfigExists(Long itemId) {
        MesMdItemBatchConfigDO config = getItemBatchConfigByItemId(itemId);
        if (config == null) {
            throw exception(MD_ITEM_BATCH_CONFIG_NOT_EXISTS);
        }
        return config;
    }

    @Override
    @Transactional(rollbackFor = Exception.class)
    public Long saveItemBatchConfig(MesMdItemBatchConfigSaveReqVO saveReqVO) {
        // 1. 校验物料存在（从 MDM 校验）
        if (mdmItemApi.getItem(saveReqVO.getItemId()).getCheckedData() == null) {
            throw exception(MD_ITEM_NOT_EXISTS);
        }

        // 2. 清空不需要的字段（只保留必要的7个字段）
        MesMdItemBatchConfigSaveReqVO cleanReqVO = new MesMdItemBatchConfigSaveReqVO();
        cleanReqVO.setId(saveReqVO.getId());
        cleanReqVO.setItemId(saveReqVO.getItemId());
        cleanReqVO.setProduceDateFlag(saveReqVO.getProduceDateFlag());
        cleanReqVO.setExpireDateFlag(saveReqVO.getExpireDateFlag());
        cleanReqVO.setReceiptDateFlag(saveReqVO.getReceiptDateFlag());
        cleanReqVO.setVendorFlag(saveReqVO.getVendorFlag());
        cleanReqVO.setPurchaseOrderCodeFlag(saveReqVO.getPurchaseOrderCodeFlag());
        cleanReqVO.setLotNumberFlag(saveReqVO.getLotNumberFlag());
        cleanReqVO.setQualityStatusFlag(saveReqVO.getQualityStatusFlag());

        // 3. 保存到 MDM 表
        MdmItemBatchConfigDO mdmConfig = BeanUtils.toBean(cleanReqVO, MdmItemBatchConfigDO.class);
        Long configId = mdmItemBatchConfigApi.saveItemBatch(mdmConfig);

        // 4. 同步保存到 MES 本地表
        saveToMesTable(cleanReqVO);

        return configId;
    }

    @Override
    public void deleteItemBatchConfigByItemId(Long itemId) {
        itemBatchConfigMapper.deleteByItemId(itemId);
    }

    /**
     * 保存到 MES 本地表
     */
    private void saveToMesTable(MesMdItemBatchConfigSaveReqVO saveReqVO) {
        MesMdItemBatchConfigDO existing = itemBatchConfigMapper.selectByItemId(saveReqVO.getItemId());
        MesMdItemBatchConfigDO mesConfig = BeanUtils.toBean(saveReqVO, MesMdItemBatchConfigDO.class);

        if (existing != null) {
            // 存在则更新，使用已有的 ID
            mesConfig.setId(existing.getId());
            itemBatchConfigMapper.updateById(mesConfig);
        } else {
            // 不存在则插入，让数据库自动生成 ID
            mesConfig.setId(null);
            itemBatchConfigMapper.insert(mesConfig);
        }
    }

}