package org.yrhl.syncdata.mapper.local;

import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
import org.yrhl.syncdata.Retention.BatchInsert;
import org.yrhl.syncdata.domain.*;

import java.util.List;
import java.util.Map;

@Mapper
public interface CourseOneMapper extends BaseMapper<SyncResult> {


    List<SyncTable> getSyncTableList();

    //查询待同步的数据
    List<SyncResult> getSyncResultListForWaitForAllinonepushresults(@Param("tableName") String tableName,@Param("page") int page,@Param("size") int size);

    List<SyncResult> getSyncResultListForWait(@Param("tableName") String tableName,@Param("page") int page,@Param("size") int size);


    List<BusinessDataResultsEntity> getList();

    List<BlockSourceDataEntity> getBlockSourceDataEntityList();


    List<BlockNewSourceDataEntity> getBlockNewSourceDataEntityList();

    List<AllinonepushresultsEntity> getAllinonepushresultsEntityList();

    void insertSyncResult(List<SyncResult> syncResultListForWait);

    List<AllinonepushresultsEntity> getSyncResultListForWaitForConsumer(@Param("tableName") String tableName,@Param("page") int page,@Param("size") int size);

    List<Map<String, Object>>  getSyncResultListForWaitForOtherConsumer(@Param("tableName") String tableName,@Param("page") int page,@Param("size") int size);

    void updateSyncResult(@Param("infoId") Long infoId);

    void updateSyncResultFail(@Param("infoId") Long infoId);

    int isExesit(@Param("infoId") Long infoId);
}