package com.ks.push.service.remote;
|
|
import com.ks.lib.common.exception.ParamsException;
|
import com.ks.push.dao.BPushTaskDao;
|
import com.ks.push.exception.BPushTaskException;
|
import com.ks.push.manager.PushManager;
|
import com.ks.push.pojo.DO.BPushTask;
|
import com.ks.push.pojo.DO.BPushTaskExcuteResult;
|
import com.ks.push.pojo.Query.BPushTaskQuery;
|
import com.ks.push.service.BPushTaskService;
|
import org.apache.dubbo.config.annotation.Service;
|
import org.springframework.data.mongodb.core.query.Criteria;
|
import org.springframework.data.mongodb.core.query.Query;
|
|
import javax.annotation.Resource;
|
import java.util.ArrayList;
|
import java.util.List;
|
|
@Service(version = "1.0")
|
public class BPushTaskServiceImpl implements BPushTaskService {
|
|
@Resource
|
private PushManager pushManager;
|
|
@Resource
|
private BPushTaskDao bPushTaskDao;
|
|
@Override
|
public String createTask(BPushTask task) throws BPushTaskException {
|
try {
|
return pushManager.createTask(task);
|
} catch (ParamsException e) {
|
throw new BPushTaskException(BPushTaskException.CODE_PARAMS_NOT_ENOUGH, e.getMsg());
|
}
|
}
|
|
@Override
|
public BPushTask getTask(String taskId) {
|
return bPushTaskDao.get(taskId);
|
}
|
|
|
@Override
|
public List<BPushTask> list(BPushTaskQuery query, int page, int pageSize) {
|
|
return bPushTaskDao.list(query, (page - 1) * pageSize, pageSize);
|
}
|
|
@Override
|
public long count(BPushTaskQuery query) {
|
return bPushTaskDao.count(query);
|
}
|
|
@Override
|
public List<BPushTaskExcuteResult> getPushResult(String taskId) {
|
return null;
|
}
|
|
@Override
|
public void startPush(String taskId) throws BPushTaskException {
|
pushManager.startPush(taskId);
|
}
|
|
@Override
|
public void pausePush(String taskId) throws BPushTaskException {
|
pushManager.pausePush(taskId);
|
}
|
|
@Override
|
public void reStartPush(String taskId) throws BPushTaskException {
|
pushManager.reStartPush(taskId);
|
}
|
|
@Override
|
public void cancelPush(String taskId) throws BPushTaskException {
|
pushManager.cancelPush(taskId);
|
}
|
}
|
