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);
    }
}