usky-modules/service-issue/service-issue-biz/src/main/java/com/usky/issue/service/CloudSyncReceiveService.java

package com.usky.issue.service;

import com.usky.issue.service.vo.SyncPacket;
import com.usky.issue.service.vo.SyncResponse;

import java.util.List;

/**
 * 云端同步接收服务（接收推送、下发轮询）
 *
 * @author fyc
 * @date 2026-06-08
 */
public interface CloudSyncReceiveService {

    boolean validateTenant(String tenantId);

    int batchUpsert(SyncPacket packet);

    SyncPacket pollDownQueue(String tenantId, String tableName, Long lastVersion, boolean forceBackfill);

    void ackDownQueue(List<Long> queueIds);

    int countPendingDownQueue(Integer tenantId, String tableName);
}