소스 검색

增加日志打印,方便排查线上问题

luoguangyi 2 년 전
부모
커밋
2d3bb9adb6
1개의 변경된 파일35개의 추가작업 그리고 5개의 파일을 삭제
  1. 35 5
      src/main/java/com/sagacloud/util/compute_engine/fjd/ThreadCompute.java

+ 35 - 5
src/main/java/com/sagacloud/util/compute_engine/fjd/ThreadCompute.java

@@ -348,7 +348,13 @@ public class ThreadCompute extends Thread {
             }
             for (int i = 0; i < content.size(); i++) {
                 JSONObject json = (JSONObject) content.get(i);
-                Entity_point detail = (Entity_point) FastJsonUtil.To_JavaObject(json, Entity_point.class);
+                Entity_point detail = null;
+                try {
+                    detail = (Entity_point) FastJsonUtil.To_JavaObject(json, Entity_point.class);
+                } catch (Exception e) {
+                    log.error("[dy_pointlist]第{}个内容异常,数据内容为{}",i,content.getJSONObject(i));
+                    throw new RuntimeException(e);
+                }
                 boolean match = false;
                 for (String data_type : data_typeList) {
                     if (detail.data_type.equalsIgnoreCase(data_type)) {
@@ -416,7 +422,13 @@ public class ThreadCompute extends Thread {
             JSONArray content = QueryUtil.select(database_name, "dy_pointlist", Criteria);
             for (int i = 0; i < content.size(); i++) {
                 JSONObject json = (JSONObject) content.get(i);
-                Entity_point detail = (Entity_point) FastJsonUtil.To_JavaObject(json, Entity_point.class);
+                Entity_point detail = null;
+                try {
+                    detail = (Entity_point) FastJsonUtil.To_JavaObject(json, Entity_point.class);
+                } catch (Exception e) {
+                    log.error("[dy_pointlist]第{}个内容异常,数据内容为{}",i,content.getJSONObject(i));
+                    throw new RuntimeException(e);
+                }
                 if (!"Inst".equals(detail.data_type)) {
                     continue;
                 }
@@ -526,7 +538,13 @@ public class ThreadCompute extends Thread {
                 }
                 for (int i = 0; i < content.size(); i++) {
                     JSONObject json = (JSONObject) content.get(i);
-                    Entity_point detail = (Entity_point) FastJsonUtil.To_JavaObject(json, Entity_point.class);
+                    Entity_point detail = null;
+                    try {
+                        detail = (Entity_point) FastJsonUtil.To_JavaObject(json, Entity_point.class);
+                    } catch (Exception e) {
+                        log.error("[dy_pointlist/dy_reportpointlist]第{}个内容异常,数据内容为{}",i,content.getJSONObject(i));
+                        throw new RuntimeException(e);
+                    }
                     if (!"Acc".equals(detail.data_type) && !"InAc".equals(detail.data_type)) {
                         continue;
                     }
@@ -607,7 +625,13 @@ public class ThreadCompute extends Thread {
             }
             for (int i = 0; i < content.size(); i++) {
                 JSONObject json = (JSONObject) content.get(i);
-                Entity_point detail = (Entity_point) FastJsonUtil.To_JavaObject(json, Entity_point.class);
+                Entity_point detail = null;
+                try {
+                    detail = (Entity_point) FastJsonUtil.To_JavaObject(json, Entity_point.class);
+                } catch (Exception e) {
+                    log.error("dy_pointlist/dy_reportpointlist第{}个内容异常,数据内容为{}",i,content.getJSONObject(i));
+                    throw new RuntimeException(e);
+                }
                 if (!"Acc".equals(detail.data_type) && !"InAc".equals(detail.data_type)) {
                     continue;
                 }
@@ -638,7 +662,13 @@ public class ThreadCompute extends Thread {
             Map<String, Entity_point> pointMap = new HashMap<String, Entity_point>();
             for (int i = 0; i < content.size(); i++) {
                 JSONObject json = (JSONObject) content.get(i);
-                Entity_point detail = (Entity_point) FastJsonUtil.To_JavaObject(json, Entity_point.class);
+                Entity_point detail = null;
+                try {
+                    detail = (Entity_point) FastJsonUtil.To_JavaObject(json, Entity_point.class);
+                } catch (Exception e) {
+                    log.error("[dy_pointlist]第{}个内容异常,数据内容为{}",i,content.getJSONObject(i));
+                    throw new RuntimeException(e);
+                }
                 boolean match = false;
                 for (String data_type : data_typeList) {
                     if (detail.data_type.equalsIgnoreCase(data_type)) {