package com.sandu.ximon.admin.service;
|
|
import cn.hutool.http.HttpUtil;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.sandu.common.execption.BusinessException;
|
import com.sandu.common.service.impl.BaseServiceImpl;
|
import com.sandu.ximon.admin.param.IpVolumeMissionParam;
|
import com.sandu.ximon.admin.param.ReceiveParam;
|
import com.sandu.ximon.admin.security.SecurityUtils;
|
import com.sandu.ximon.dao.domain.IpVolumeMission;
|
import com.sandu.ximon.dao.mapper.IpVolumeMissionMapper;
|
import lombok.AllArgsConstructor;
|
import org.springframework.stereotype.Service;
|
|
import java.util.List;
|
|
/**
|
* @Author liuhaonan
|
* @Date 2021/12/16 10:03
|
* @Version 1.0
|
*/
|
@Service
|
@AllArgsConstructor
|
public class IpVolumeMissionService extends BaseServiceImpl<IpVolumeMissionMapper, IpVolumeMission> {
|
private final IpVolumeMissionMapper ipVolumeMissionMapper;
|
private final ClientService clientService;
|
|
public boolean addMission(IpVolumeMissionParam missionparam) {
|
IpVolumeMission mission = new IpVolumeMission();
|
|
mission.setUserId(SecurityUtils.getUserId());
|
mission.setUserName(SecurityUtils.getUsername());
|
mission.setClientId(clientService.getClientId());
|
mission.setMissionName(missionparam.getMissionName());
|
mission.setMissionFileId(missionparam.getMissionFileId());
|
mission.setMissionFileName(missionparam.getMissionFileName());
|
mission.setOnDate(missionparam.getOnDate());
|
mission.setOffDate(missionparam.getOffDate());
|
mission.setWeeksRange(missionparam.getWeeksRange());
|
mission.setOnTime(missionparam.getOnTime());
|
mission.setOffTime(missionparam.getOffTime());
|
mission.setMissionVolume(missionparam.getMissionVolume());
|
|
return save(mission);
|
}
|
|
public boolean updateMission(Long missionId, IpVolumeMissionParam missionparam) {
|
IpVolumeMission byId = getById(missionId);
|
if (byId == null) {
|
throw new BusinessException("未找到该任务");
|
}
|
IpVolumeMission mission = new IpVolumeMission();
|
mission.setId(missionId);
|
/* mission.setUserId(SecurityUtils.getUserId());
|
mission.setUserName(SecurityUtils.getUsername());
|
mission.setClientId(clientService.getClientId());*/
|
mission.setMissionName(missionparam.getMissionName());
|
mission.setMissionFileId(missionparam.getMissionFileId());
|
mission.setMissionFileName(missionparam.getMissionFileName());
|
mission.setOnDate(missionparam.getOnDate());
|
mission.setOffDate(missionparam.getOffDate());
|
mission.setWeeksRange(missionparam.getWeeksRange());
|
mission.setOnTime(missionparam.getOnTime());
|
mission.setOffTime(missionparam.getOffTime());
|
mission.setMissionVolume(missionparam.getMissionVolume());
|
|
HttpUtil.post("123", String.valueOf(mission));
|
|
return updateById(mission);
|
}
|
|
public boolean deleteMission(Long missionId) {
|
IpVolumeMission byId = getById(missionId);
|
if (byId == null) {
|
throw new BusinessException("未找到该任务");
|
}
|
return removeById(missionId);
|
}
|
|
public List<IpVolumeMission> listMission(ReceiveParam receiveParam) {
|
|
LambdaQueryWrapper<IpVolumeMission> wrapper = Wrappers.lambdaQuery(IpVolumeMission.class).eq(IpVolumeMission::getClientId, SecurityUtils.getUserId()).like(IpVolumeMission::getMissionName, receiveParam.getKeyWord());
|
|
return list(wrapper);
|
}
|
|
|
public void setMissionToData(Long missionId,List<Long> dateIds){
|
|
|
// tudo
|
|
|
}
|
|
|
}
|