功能完善

liuhaonan

2022-01-06 3de5d5edd46dafc5da55862f0cdf261e3ed650b6

 ximon-admin/src/main/java/com/sandu/ximon/admin/service/IpVolumeMissionService.java

@@ -2,7 +2,9 @@

import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.github.pagehelper.PageHelper;
import com.sandu.common.execption.BusinessException;
import com.sandu.common.object.BaseConditionVO;
import com.sandu.common.service.impl.BaseServiceImpl;
import com.sandu.ximon.admin.config.MinIoConstant;
import com.sandu.ximon.admin.param.IpVolumeMissionParam;
@@ -11,6 +13,7 @@
import com.sandu.ximon.admin.utils.TaskAPIUtils;
import com.sandu.ximon.admin.vo.TaskMediaFileVO;
import com.sandu.ximon.admin.vo.TaskTerminalVO;
import com.sandu.ximon.admin.vo.TaskVO;
import com.sandu.ximon.dao.bo.IpVolumeMissionBo;
import com.sandu.ximon.dao.domain.BroadcastV2TaskFile;
import com.sandu.ximon.dao.domain.BroadcastV2TaskTerminal;
@@ -116,7 +119,7 @@
            for (BroadcastV2TaskFile v2TaskFile :taskFileEntityList) {
                v2TaskFile.setTaskId(taskId);
            }
            if (null == byId) {
            if (byId==null) {
                //  向数据库添加该任务记录

                IpVolumeMission mission = new IpVolumeMission();
@@ -315,7 +318,8 @@
        return list(wrapper);
    }

    public List<IpVolumeMissionBo> missionList() {
    public List<IpVolumeMissionBo> missionList(BaseConditionVO baseConditionVO,String keyword) {
        PageHelper.startPage(baseConditionVO.getPageNo(),baseConditionVO.getPageSize());
        List<IpVolumeMissionBo> ipVolumeMissionBos = ipVolumeMissionMapper.listAllByClientId();

        for (IpVolumeMissionBo missionBo: ipVolumeMissionBos) {
@@ -334,6 +338,27 @@


    }
    public IpVolumeMission getByTaskId(Integer taskId){
        TaskVO task = TaskAPIUtils.getTask(taskId);
        if(task==null){
            throw new BusinessException("服务器未找到该任务");
        }

        IpVolumeMission byId = getById(taskId);
        if(byId==null){
            throw new BusinessException("本地未找到该任务");
        }

        byId.setWeeks("0"+Integer.toBinaryString(byId.getWeek()));

        return byId;


    }

    public boolean playTask(Integer taskId) {
        return TaskAPIUtils.playTask(taskId);
    }


}