告警通知修改

jack xue
Commit 45252a403a13ed5fbda5e4e1f17c998ad1e13ec2 1 parent 3441d1ef
Showing 2 changed files with 16 additions and 8 deletions
monitor-service-middleware/src/main/java/com/monitor/middleware/nginx/task/job/oneJob/BaseLogJob.java
monitor-service-middleware/src/main/java/com/monitor/middleware/nginx/task/job/oneJob/ErrorLogJob.java
--- a/monitor-service-middleware/src/main/java/com/monitor/middleware/nginx/task/job/oneJob/BaseLogJob.java
View file @45252a4
+++ b/monitor-service-middleware/src/main/java/com/monitor/middleware/nginx/task/job/oneJob/BaseLogJob.java
View file @45252a4
@@ -275,10 +275,18 @@ public class BaseLogJob implements Callable {
     protected String buildAlarmMsg() {
         StringBuilder builder = new StringBuilder();
-        builder.append("{");
+        if(StringUtils.equals(this.measureName,InterVar.APIACCESSMEASURE))
+        {
+            builder.append("{Warn:ApiNot200;");
+        }
+        else
+        {
+            builder.append("{Warn:ServiceNot200;");
+        }
+
         builder.append("云:").append(type).append(";");
         builder.append("总计:").append(this.apiSeriesModelList.size()).append(";");
-        builder.append("top接口:");
+        builder.append("Top接口:");
         builder.append(this.resultList.get(0).getApiKey()).append(" : ").append(this.resultList.get(0).getApiSeriesModelList().size()).append(";");
         builder.append("}");
         return builder.toString();
--- a/monitor-service-middleware/src/main/java/com/monitor/middleware/nginx/task/job/oneJob/ErrorLogJob.java
View file @45252a4
+++ b/monitor-service-middleware/src/main/java/com/monitor/middleware/nginx/task/job/oneJob/ErrorLogJob.java
View file @45252a4
@@ -231,15 +231,15 @@ public class ErrorLogJob implements Callable {
                 errorSeriesModel.setMessage(oneRow.get(KINDEMAPS.get("err_msg")).toString());
-                if (errorSeriesModel.getMessage().contains("Lua")) {
+                if (errorSeriesModel.getMessage().contains("[lua]")) {
-                    errorSeriesModel.setType("Lua");
+                    errorSeriesModel.setType("Lua-error");
                 } else if (errorSeriesModel.getMessage().contains(": Connection")) {
-                    errorSeriesModel.setType("Connection");
+                    errorSeriesModel.setType("Connection-error");
                 } else {
-                    errorSeriesModel.setType("Others");
+                    errorSeriesModel.setType("Others-error");
                 }
                 errorSeriesModelList.add(errorSeriesModel);
@@ -260,7 +260,7 @@ public class ErrorLogJob implements Callable {
     private String buildAlarmMsg() {
         StringBuilder builder = new StringBuilder();
-        builder.append("{");
+        builder.append("{Warn:Nginx-Error;");
         builder.append("云:").append(type).append(";");
         builder.append("总计:").append(this.errorSeriesModelList.size()).append(";");
         List<ErrorStaModel> operList = null;
@@ -270,7 +270,7 @@ public class ErrorLogJob implements Callable {
             operList = InterVar.QC_NGINX_ERROR_LIST;
         }
         for (ErrorStaModel errorStaModel : operList) {
-            builder.append(errorStaModel.getType()).append(":").append(errorStaModel.getErrorSeriesModelList().size());
+            builder.append("Error:").append(errorStaModel.getType()).append("-").append(errorStaModel.getErrorSeriesModelList().size());
         }
         builder.append("}");