package cn.iocoder.yudao.module.mes.api.wms;

import cn.hutool.core.collection.CollUtil;
import cn.iocoder.yudao.framework.common.util.object.BeanUtils;
import cn.iocoder.yudao.module.mes.api.wms.dto.WmsTransactionCreateReqDTO;
import cn.iocoder.yudao.module.mes.api.wms.transaction.WmsTransactionApi;
import cn.iocoder.yudao.module.mes.service.wm.transaction.MesWmTransactionService;
import cn.iocoder.yudao.module.mes.service.wm.transaction.dto.MesWmTransactionSaveReqDTO;
import jakarta.annotation.Resource;
import lombok.extern.slf4j.Slf4j;
import org.springframework.stereotype.Service;
import org.springframework.validation.annotation.Validated;

import java.util.List;

/**
 * WMS 库存事务 API 实现类
 *
 * 在 MES 模块中实现，内部调用 MesWmTransactionService
 */
@Service
@Validated
@Slf4j
public class WmsTransactionApiImpl implements WmsTransactionApi {

    @Resource
    private MesWmTransactionService transactionService;

    @Override
    public Long createTransaction(WmsTransactionCreateReqDTO reqDTO) {
        log.info("[createTransaction] 创建库存事务，type={}, bizType={}, itemId={}",
                reqDTO.getType(), reqDTO.getBizType(), reqDTO.getItemId());
        MesWmTransactionSaveReqDTO mesTransaction = convertToMesTransaction(reqDTO);
        return transactionService.createTransaction(mesTransaction);
    }

    @Override
    public void createTransactionBatch(List<WmsTransactionCreateReqDTO> reqDTOs) {
        if (CollUtil.isEmpty(reqDTOs)) {
            return;
        }
        log.info("[createTransactionBatch] 批量创建库存事务，count={}", reqDTOs.size());
        List<MesWmTransactionSaveReqDTO> mesTransactions = reqDTOs.stream()
                .map(this::convertToMesTransaction)
                .toList();
        transactionService.createTransactionList(mesTransactions);
    }

    /**
     * 转换WMS事务DTO为MES事务DTO
     */
    private MesWmTransactionSaveReqDTO convertToMesTransaction(WmsTransactionCreateReqDTO reqDTO) {
        return BeanUtils.toBean(reqDTO, MesWmTransactionSaveReqDTO.class);
    }
}