package com.wgcloud.controller;
|
|
import cn.hutool.json.JSONArray;
|
import cn.hutool.json.JSONObject;
|
import cn.hutool.json.JSONUtil;
|
import com.wgcloud.config.CommonConfig;
|
import com.wgcloud.entity.SnmpInfo;
|
import com.wgcloud.entity.SnmpState;
|
import com.wgcloud.service.LogInfoService;
|
import com.wgcloud.service.SnmpInfoService;
|
import com.wgcloud.service.SnmpStateService;
|
import com.wgcloud.util.ResDataUtils;
|
import com.wgcloud.util.TokenUtils;
|
import com.wgcloud.util.msg.WarnMailUtil;
|
import com.wgcloud.util.msg.WarnPools;
|
import com.wgcloud.util.staticvar.BatchData;
|
import com.wgcloud.util.staticvar.StaticKeys;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Controller;
|
import org.springframework.web.bind.annotation.RequestBody;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.ResponseBody;
|
|
import javax.annotation.Resource;
|
import java.util.Date;
|
import java.util.List;
|
|
/**
|
* @version v3.3
|
* @ClassName:AgentSnmpInfoGoController.java
|
* @author: http://www.wgstart.com
|
* @date: 2022年9月16日
|
* @Description: server-backup监控数通SNMP数据提交处理，默认每20分钟提交一次
|
* @Copyright: 2019-2022 wgcloud. All rights reserved.
|
*/
|
@Controller
|
@RequestMapping("/agentSnmpInfoGo")
|
public class AgentSnmpInfoGoController {
|
|
|
private static final Logger logger = LoggerFactory.getLogger(AgentSnmpInfoGoController.class);
|
|
|
@Resource
|
private LogInfoService logInfoService;
|
@Autowired
|
private SnmpInfoService snmpInfoService;
|
@Autowired
|
private SnmpStateService snmpStateService;
|
@Autowired
|
private TokenUtils tokenUtils;
|
@Autowired
|
private CommonConfig commonConfig;
|
|
@ResponseBody
|
@RequestMapping("/minTask")
|
public String minTask(@RequestBody String paramBean) {
|
JSONObject agentJsonObject = (JSONObject) JSONUtil.parse(paramBean);
|
logger.debug("server-backup监控数通SNMP上报数据-------------" + agentJsonObject.toString());
|
if (!tokenUtils.checkAgentToken(agentJsonObject)) {
|
logger.error(StaticKeys.TOKEN_ERROR);
|
return ResDataUtils.resetErrorJson(StaticKeys.TOKEN_ERROR);
|
}
|
Date nowtime = new Date();
|
|
try {
|
//SNMP数据
|
JSONArray snmpInfosJsonArr = agentJsonObject.getJSONArray("snmpInfosUpdate");
|
if (snmpInfosJsonArr == null) {
|
logger.error("snmpInfosUpdate is null");
|
return ResDataUtils.resetErrorJson("snmpInfosUpdate is null");
|
}
|
//处理SNMP状态数据
|
List<SnmpInfo> snmpInfoList = JSONUtil.toList(snmpInfosJsonArr, SnmpInfo.class);
|
for (SnmpInfo snmpInfo : snmpInfoList) {
|
SnmpInfo snmpInfoSaved = snmpInfoService.selectById(snmpInfo.getId());
|
snmpInfo.setCreateTime(nowtime);
|
snmpInfo.setHostname(snmpInfoSaved.getHostname());
|
|
//设备下线后，不再更新时间 begin
|
if (StaticKeys.DOWN_STATE.equals(snmpInfo.getState())) {
|
snmpInfo.setCreateTime(null);
|
}
|
//设备下线后，不再更新时间 end
|
|
try {
|
snmpInfoService.updateById(snmpInfo);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
|
if (StaticKeys.ON_STATE.equals(snmpInfo.getState())) {
|
SnmpState snmpState = new SnmpState();
|
snmpState.setRecvAvg(snmpInfo.getRecvAvg());
|
snmpState.setSentAvg(snmpInfo.getSentAvg());
|
snmpState.setCpuPer(snmpInfo.getCpuPer());
|
snmpState.setMemPer(snmpInfo.getMemPer());
|
snmpState.setSnmpInfoId(snmpInfo.getId());
|
snmpState.setCreateTime(nowtime);
|
BatchData.SNMP_STATE_LIST.add(snmpState);
|
}
|
if (StaticKeys.DOWN_STATE.equals(snmpInfo.getState())) {
|
//返回错误处理
|
WarnMailUtil.sendSnmpInfo(snmpInfoSaved, true);
|
} else {
|
//返回成功处理
|
if (null != WarnPools.MEM_WARN_MAP.get(snmpInfoSaved.getId())) {
|
WarnMailUtil.sendSnmpInfo(snmpInfoSaved, false);
|
}
|
}
|
}
|
|
} catch (Exception e) {
|
logger.error("解析server-backup监控数通SNMP上报数据错误", e);
|
return ResDataUtils.resetErrorJson(e.toString());
|
}
|
return ResDataUtils.resetSuccessJson(null);
|
}
|
|
|
}
|
