|
...
|
...
|
@@ -5,33 +5,25 @@ import com.model.RabbitAlertInfo; |
|
|
|
import com.model.TypeInfo;
|
|
|
|
import com.monitor.cmdb.service.IMObjectInfoService;
|
|
|
|
import com.monitor.cmdb.service.ITypeInfoService;
|
|
|
|
import com.monitor.middleware.rabbitmq.component.InfluxComp;
|
|
|
|
import com.monitor.middleware.rabbitmq.constant.InterVar;
|
|
|
|
import com.monitor.middleware.rabbitmq.model.*;
|
|
|
|
import com.monitor.middleware.rabbitmq.model.http.FixRequest;
|
|
|
|
import com.monitor.middleware.rabbitmq.model.http.OverViewModel;
|
|
|
|
import com.monitor.middleware.rabbitmq.model.http.QueryRequest;
|
|
|
|
import com.monitor.middleware.rabbitmq.model.http.RabbitModel;
|
|
|
|
import com.monitor.model.domain.MObjectModel;
|
|
|
|
import com.monitor.model.page.PageResponse;
|
|
|
|
import com.monitor.model.response.BaseResponse;
|
|
|
|
import com.monitor.mysql.mapper.MObjectInfoMapper;
|
|
|
|
import com.monitor.mysql.mapper.RabbitAlertMapper;
|
|
|
|
import com.sun.org.apache.bcel.internal.generic.NEW;
|
|
|
|
import com.sun.org.apache.xml.internal.resolver.helpers.Debug;
|
|
|
|
import org.apache.commons.lang.StringUtils;
|
|
|
|
import org.influxdb.dto.QueryResult;
|
|
|
|
import org.slf4j.Logger;
|
|
|
|
import org.slf4j.LoggerFactory;
|
|
|
|
import org.springframework.beans.BeanUtils;
|
|
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
|
|
|
import org.springframework.cglib.core.MethodWrapper;
|
|
|
|
import org.springframework.web.bind.annotation.RequestBody;
|
|
|
|
import org.springframework.web.bind.annotation.RequestMapping;
|
|
|
|
import org.springframework.web.bind.annotation.RequestMethod;
|
|
|
|
import org.springframework.web.bind.annotation.RestController;
|
|
|
|
|
|
|
|
import java.text.MessageFormat;
|
|
|
|
import java.util.*;
|
|
|
|
|
|
|
|
/**
|
|
...
|
...
|
@@ -301,7 +293,7 @@ public class RabbitmqService { |
|
|
|
if (StringUtils.isNotBlank(tagValue[1])) {
|
|
|
|
|
|
|
|
DEBUG.info("tagValue[1] {}", tagValue[1]);
|
|
|
|
|
|
|
|
|
|
|
|
List<MObjectInfo> mObjectInfos = moService.queryMObjectsInfoByHost(tagValue[1]);
|
|
|
|
|
|
|
|
DEBUG.info("query all slaves {} about ip {} ", mObjectInfos, tagValue[1]);
|
...
|
...
|
|
