package cn.iocoder.yudao.module.mes.service.pro.bagcode;

import cn.iocoder.yudao.module.mes.dal.dataobject.pro.bagcode.MesProBagCodeDO;
import cn.iocoder.yudao.module.mes.dal.dataobject.pro.pallet.MesProPalletDO;
import cn.iocoder.yudao.module.mes.dal.mysql.pro.bagcode.MesProBagCodeMapper;
import cn.iocoder.yudao.module.mes.dal.mysql.pro.pallet.MesProPalletMapper;
import jakarta.annotation.Resource;
import org.springframework.stereotype.Component;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;

import java.util.List;

/**
 * 袋码/托盘分段写入器
 * <p>
 * 每段使用独立事务（REQUIRES_NEW）：几十万行放在同一个事务里会形成超大事务，
 * 长时间占用 undo/redo 与行锁，失败时回滚成本也极高。
 * <p>
 * 独立成 Bean 是为了让 {@code REQUIRES_NEW} 经 Spring 代理生效，避免同类自调用绕过事务。
 */
@Component
public class MesProBagCodeChunkWriter {

    /**
     * 单条 INSERT 语句的行数；与分段大小分开，控制单条 SQL 的包体大小
     */
    private static final int INSERT_BATCH_SIZE = 1000;

    @Resource
    private MesProBagCodeMapper bagCodeMapper;
    @Resource
    private MesProPalletMapper palletMapper;

    /**
     * 写入一段袋码
     */
    @Transactional(propagation = Propagation.REQUIRES_NEW, rollbackFor = Exception.class)
    public void insertBagCodes(List<MesProBagCodeDO> bagCodes) {
        bagCodeMapper.insertBatch(bagCodes, INSERT_BATCH_SIZE);
    }

    /**
     * 写入一段托盘（插入后 ID 会回填到实体上）
     */
    @Transactional(propagation = Propagation.REQUIRES_NEW, rollbackFor = Exception.class)
    public void insertPallets(List<MesProPalletDO> pallets) {
        palletMapper.insertBatch(pallets, INSERT_BATCH_SIZE);
    }

}