ops / monitor-ui · Commits

Go to a project

Authored by xuhui
Commit c2d9955b15fd1d3d38fd6d34e3f77b702a918e90 1 parent 0ab951e1

捕获异常

Inline Side-by-side
Showing 1 changed file with 68 additions and 76 deletions
... ... @@ -47,95 +47,87 @@ public class TopoSwitchCtrl {
@RequestMapping(value = "getNgixnStatus")
@ResponseBody
public BaseResponse getNgixnStatus() {
//lua
String luaResponse = httpRestClient.defaultGet(HttpUriContants.VIEW_LUA_CONF, String.class, null);
//String luaResponse = "-- 1:aws ,2:qq ,3:aws+qq</br>context.cloud_flag = 1</br>";
String luaType = "aws";
if (luaResponse.matches(".*context.cloud_flag\\s*=\\s*2.*")) {
luaType = "qq";
} else if (luaResponse.matches(".*context.cloud_flag\\s*=\\s*3.*")) {
luaType = "aws+qq";
}
Map<String, Object> resultMap = new HashMap<>();
//nginx
BaseResponse<Map<String, List<Map<String, Object>>>> response = httpRestClient.exchangeForget(HttpUriContants.VIEW_NGINX_CONF, new ParameterizedTypeReference<BaseResponse<Map<String, List<Map<String, Object>>>>>() {
}, null);
Map<String, List<Map<String, Object>>> map = response.getData();
List<Map<String, Object>> awsList = map.get("awsList");
List<Map<String, Object>> qcloudList = map.get("qcloudList");
String awsApiNginx = "aws";
String awsGrayNginx = "aws";
String qqApiNginx = "qq";
String qqGrayNginx = "qq";
for (Map<String, Object> apiMap : awsList) {
if (StringUtils.equals("apigateway", String.valueOf(apiMap.get("name")))) {
List<String> serverList = (List<String>) apiMap.get("server");
if (serverList.get(0).startsWith("10")) {
awsApiNginx = "qq";
}
try{
//lua
String luaResponse = httpRestClient.defaultGet(HttpUriContants.VIEW_LUA_CONF, String.class, null);
String luaType = "aws";
if (luaResponse.matches(".*context.cloud_flag\\s*=\\s*2.*")) {
luaType = "qq";
} else if (luaResponse.matches(".*context.cloud_flag\\s*=\\s*3.*")) {
luaType = "aws+qq";
}
if (StringUtils.equals("grayapigateway", String.valueOf(apiMap.get("name")))) {
List<String> serverList = (List<String>) apiMap.get("server");
if (serverList.get(0).startsWith("10")) {
awsGrayNginx = "qq";
//nginx
BaseResponse<Map<String, List<Map<String, Object>>>> response = httpRestClient.exchangeForget(HttpUriContants.VIEW_NGINX_CONF, new ParameterizedTypeReference<BaseResponse<Map<String, List<Map<String, Object>>>>>() {
}, null);
Map<String, List<Map<String, Object>>> map = response.getData();
List<Map<String, Object>> awsList = map.get("awsList");
List<Map<String, Object>> qcloudList = map.get("qcloudList");
String awsApiNginx = "aws";
String awsGrayNginx = "aws";
String qqApiNginx = "qq";
String qqGrayNginx = "qq";
for (Map<String, Object> apiMap : awsList) {
if (StringUtils.equals("apigateway", String.valueOf(apiMap.get("name")))) {
List<String> serverList = (List<String>) apiMap.get("server");
if (serverList.get(0).startsWith("10")) {
awsApiNginx = "qq";
}
}
}
}
for (Map<String, Object> apiMap : qcloudList) {
if (StringUtils.equals("apigateway", String.valueOf(apiMap.get("name")))) {
List<String> serverList = (List<String>) apiMap.get("server");
if (serverList.get(0).startsWith("172")) {
qqApiNginx = "aws";
if (StringUtils.equals("grayapigateway", String.valueOf(apiMap.get("name")))) {
List<String> serverList = (List<String>) apiMap.get("server");
if (serverList.get(0).startsWith("10")) {
awsGrayNginx = "qq";
}
}
}
if (StringUtils.equals("grayapigateway", String.valueOf(apiMap.get("name")))) {
List<String> serverList = (List<String>) apiMap.get("server");
if (serverList.get(0).startsWith("172")) {
qqApiNginx = "aws";
for (Map<String, Object> apiMap : qcloudList) {
if (StringUtils.equals("apigateway", String.valueOf(apiMap.get("name")))) {
List<String> serverList = (List<String>) apiMap.get("server");
if (serverList.get(0).startsWith("172")) {
qqApiNginx = "aws";
}
}
}
}
//dns
String defaultDns = "aws";
String qqDns = "qq";
MultiValueMap<String, String> requestEntity = new LinkedMultiValueMap<>();
requestEntity.add("login_token", "14365,5ced8b63875ed1643b9ffeb285180fa9");
requestEntity.add("format","json");
requestEntity.add("domain_id", "16862974");
//requestEntity.add("record_id","183941138");
requestEntity.add("record_id","293178513");
if (StringUtils.equals("grayapigateway", String.valueOf(apiMap.get("name")))) {
List<String> serverList = (List<String>) apiMap.get("server");
if (serverList.get(0).startsWith("172")) {
qqApiNginx = "aws";
}
}
}
String requestResponse = httpRestClient.post("https://dnsapi.cn/Record.Info", requestEntity, String.class);
if (requestResponse.indexOf("amazonaws") == -1){
defaultDns = "qq";
}
//dns
String defaultDns = "aws";
String qqDns = "qq";
// requestEntity.add("record_id","188034065");
// String request2Response = httpRestClient.post("https://dnsapi.cn/Record.Info", requestEntity, String.class);
// if (request2Response.indexOf("amazonaws") != -1){
// qqDns = "aws";
// }
MultiValueMap<String, String> requestEntity = new LinkedMultiValueMap<>();
requestEntity.add("login_token", "14365,5ced8b63875ed1643b9ffeb285180fa9");
requestEntity.add("format","json");
requestEntity.add("domain_id", "16862974");
requestEntity.add("record_id","293178513");
Map<String, Object> resultMap = new HashMap<>();
resultMap.put("luaType", luaType);
resultMap.put("awsApiNginx", awsApiNginx);
resultMap.put("awsGrayNginx", awsGrayNginx);
resultMap.put("qqApiNginx", qqApiNginx);
resultMap.put("qqGrayNginx", qqGrayNginx);
resultMap.put("defaultDns", defaultDns);
// resultMap.put("qqDns", qqDns);
String requestResponse = httpRestClient.post("https://dnsapi.cn/Record.Info", requestEntity, String.class);
if (requestResponse.indexOf("amazonaws") == -1){
defaultDns = "qq";
}
return new
resultMap.put("luaType", luaType);
resultMap.put("awsApiNginx", awsApiNginx);
resultMap.put("awsGrayNginx", awsGrayNginx);
resultMap.put("qqApiNginx", qqApiNginx);
resultMap.put("qqGrayNginx", qqGrayNginx);
resultMap.put("defaultDns", defaultDns);
}catch (Exception e){
logger.error(" TopoSwitchCtrl - getNgixnStatus - err", e);
}
BaseResponse(resultMap);
return new BaseResponse(resultMap);
}
}
}
\ No newline at end of file
... ...