异常日志优化

@@ -58,24 +58,41 @@ public class Custom_Response_Processor {
 
     }
 
+    /**
+     * 通过总线消费服务获取回执数据
+     */
     public void analysis(){
-        ResultJson<List<String>> listResultJson = kafkaReciveApi.recive(USER_NAME);
-        log.info("2-获取结果为:{},数量为:{}",listResultJson.toString(),listResultJson.getData().size());
-        if ("200".equals(listResultJson.getCode()) && listResultJson.getData()!=null && listResultJson.getData().size()>0){
-            log.info("3-开始处理获取数据");
-            List<String> dataList  = listResultJson.getData();
-            for (int i = 0; i <dataList.size() ; i++) {
-                String msg = dataList.get(i);
-                try{
-                    analysisMessage(msg,i);
-                }catch (Exception e){
-                    log.error("[Analysis-ERR]!!!{}报文内容解析异常:{},开始处理下一条消息!!!",msg,e.toString());
-                    e.printStackTrace();
-                }
+        try {
+            ResultJson<List<String>> listResultJson = kafkaReciveApi.recive(USER_NAME);
+            log.info("2-获取结果为:{},数量为:{}",listResultJson.toString(),listResultJson.getData().size());
+            if ("200".equals(listResultJson.getCode()) && listResultJson.getData()!=null && !listResultJson.getData().isEmpty()){
+                responseResolve(listResultJson);
+            }else {
+                log.info("[CONSUMER-RESULT] - 未获取到消息,code:{},msg:{},data:{}",listResultJson.getCode(),listResultJson.getMsg(),listResultJson.getData());
+            }
+        } catch (Exception e) {
+            log.error("[CONSUMER-ERR]!!!获取消息异常,开始获取下一条消息!!!->{}",e.toString());
+            e.printStackTrace();
+        }
+    }
 
+    /**
+     * 处理接收到的总线数据
+     * @param listResultJson
+     */
+    public void responseResolve(ResultJson<List<String>> listResultJson){
+        log.info("3-开始处理获取数据");
+        List<String> dataList  = listResultJson.getData();
+        for (int i = 0; i <dataList.size() ; i++) {
+            String msg = dataList.get(i);
+            try{
+                log.info("3.1-开始解析数据-[{}]",msg);
+                analysisMessage(msg,i);
+            }catch (Exception e){
+                log.error("[Resolve-ERR]!!!{}报文内容解析异常:{},开始处理下一条消息!!!",msg,e.toString());
+                e.printStackTrace();
             }
-        }else {
-            log.info("[CONSUMER-RESULT] - 未获取到消息");
+
         }
     }