package com.ks.push.service;
|
|
import com.ks.push.exception.BPushTaskException;
|
import com.ks.push.pojo.DO.BPushTask;
|
import com.ks.push.pojo.DO.BPushTaskExcuteResult;
|
import com.ks.push.pojo.Query.BPushTaskQuery;
|
|
import java.util.List;
|
|
public interface BPushTaskService {
|
|
|
/**
|
* 创建推送任务
|
*
|
* @param task
|
* @return 任务ID
|
* @throws BPushTaskException
|
*/
|
public String createTask(BPushTask task) throws BPushTaskException;
|
|
/**
|
* 获取详情
|
*
|
* @param taskId
|
* @return
|
*/
|
public BPushTask getTask(String taskId);
|
|
/**
|
* 列表
|
*
|
* @param query
|
* @param page
|
* @param pageSize
|
* @return
|
*/
|
|
public List<BPushTask> list(BPushTaskQuery query, int page, int pageSize);
|
|
/**
|
* 计数
|
*
|
* @param query
|
* @return
|
*/
|
public long count(BPushTaskQuery query);
|
|
/**
|
* 获取推送结果
|
*
|
* @param taskId
|
* @return
|
*/
|
public List<BPushTaskExcuteResult> getPushResult(String taskId);
|
|
|
/**
|
* 开始推送
|
*
|
* @param tashId
|
* @throws BPushTaskException
|
*/
|
public void startPush(String tashId) throws BPushTaskException;
|
|
|
/**
|
* 暂停推送（暂停后可继续）
|
*
|
* @param taskId
|
* @throws BPushTaskException
|
*/
|
public void pausePush(String taskId) throws BPushTaskException;
|
|
|
/**
|
* 重新开始推送
|
*
|
* @param taskId
|
* @throws BPushTaskException
|
*/
|
public void reStartPush(String taskId) throws BPushTaskException;
|
|
/**
|
* 取消推送（取消后不可恢复）
|
*
|
* @param taskId
|
* @throws BPushTaskException
|
*/
|
public void cancelPush(String taskId) throws BPushTaskException;
|
|
|
}
|
