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.DceInfo;
|
import com.wgcloud.entity.DceState;
|
import com.wgcloud.service.DceInfoService;
|
import com.wgcloud.service.DceStateService;
|
import com.wgcloud.service.LogInfoService;
|
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:AgentDceInfoGoController.java
|
* @author: http://www.wgstart.com
|
* @date: 2022年9月16日
|
* @Description: server-backup监控数通PING数据提交处理，默认每15分钟提交一次
|
* @Copyright: 2019-2022 wgcloud. All rights reserved.
|
*/
|
@Controller
|
@RequestMapping("/agentDceInfoGo")
|
public class AgentDceInfoGoController {
|
|
|
private static final Logger logger = LoggerFactory.getLogger(AgentDceInfoGoController.class);
|
|
|
@Resource
|
private LogInfoService logInfoService;
|
@Autowired
|
private DceInfoService dceInfoService;
|
@Autowired
|
private DceStateService dceStateService;
|
@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监控数通PING上报数据-------------" + agentJsonObject.toString());
|
JSONObject resultJson = new JSONObject();
|
if (!tokenUtils.checkAgentToken(agentJsonObject)) {
|
logger.error(StaticKeys.TOKEN_ERROR);
|
return ResDataUtils.resetErrorJson(StaticKeys.TOKEN_ERROR);
|
}
|
Date nowtime = new Date();
|
|
try {
|
//PING数据
|
JSONArray dceInfosJsonArr = agentJsonObject.getJSONArray("dceInfosUpdate");
|
if (dceInfosJsonArr == null) {
|
logger.error("dceInfosUpdate is null");
|
return ResDataUtils.resetErrorJson("dceInfosUpdate is null");
|
}
|
//处理数据源状态数据
|
List<DceInfo> dceInfoList = JSONUtil.toList(dceInfosJsonArr, DceInfo.class);
|
for (DceInfo dceInfo : dceInfoList) {
|
DceInfo dceInfoSaved = dceInfoService.selectById(dceInfo.getId());
|
dceInfo.setHostname(dceInfoSaved.getHostname());
|
dceInfo.setCreateTime(nowtime);
|
//设备下线后，不再更新时间 begin
|
if (dceInfo.getResTimes() < 0) {
|
dceInfo.setCreateTime(null);
|
}
|
//设备下线后，不再更新时间 end
|
try {
|
dceInfoService.updateById(dceInfo);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
|
if (dceInfo.getResTimes() > 0) {
|
DceState dceState = new DceState();
|
dceState.setResTimes(dceInfo.getResTimes());
|
dceState.setDceId(dceInfo.getId());
|
dceState.setCreateTime(nowtime);
|
BatchData.DCE_STATE_LIST.add(dceState);
|
}
|
dceInfoSaved.setResTimes(dceInfo.getResTimes());
|
if (dceInfo.getResTimes() < 0) {
|
//返回错误处理
|
WarnMailUtil.sendDceInfo(dceInfoSaved, true);
|
} else {
|
//返回成功处理
|
if (null != WarnPools.MEM_WARN_MAP.get(dceInfo.getId())) {
|
WarnMailUtil.sendDceInfo(dceInfoSaved, false);
|
}
|
}
|
}
|
|
} catch (Exception e) {
|
logger.error("解析server-backup监控数通PING上报数据错误", e);
|
return ResDataUtils.resetErrorJson(e.toString());
|
}
|
return ResDataUtils.resetSuccessJson(null);
|
}
|
|
|
}
|
