package cn.iocoder.yudao.module.mes.dal.mysql.collect;

import cn.iocoder.yudao.framework.mybatis.core.mapper.BaseMapperX;
import cn.iocoder.yudao.framework.mybatis.core.query.LambdaQueryWrapperX;
import cn.iocoder.yudao.module.mes.dal.dataobject.collect.MesCollectMessageDO;
import org.apache.ibatis.annotations.Mapper;

import java.time.LocalDateTime;

/**
 * MES 数采-原始报文 Mapper
 *
 * @author 超级管理员
 */
@Mapper
public interface MesCollectMessageMapper extends BaseMapperX<MesCollectMessageDO> {

    default int deleteBefore(LocalDateTime before, int limit) {
        return delete(new LambdaQueryWrapperX<MesCollectMessageDO>()
                .lt(MesCollectMessageDO::getReceiveTime, before)
                .last("LIMIT " + limit));
    }

}