优化服务绑定功能

wuxw

2019-07-20 39ceed7f60905297629a45978cc29b6fe8bd05d8

 java110-logAgent/src/main/java/com/java110/log/agent/LogAgent.java

@@ -1,13 +1,20 @@
package com.java110.log.agent;

import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.alibaba.fastjson.JSONPath;
import com.java110.common.cache.MappingCache;
import com.java110.common.constant.KafkaConstant;
import com.java110.common.constant.MappingConstant;
import com.java110.common.constant.ResponseConstant;
import com.java110.common.factory.ApplicationContextFactory;
import com.java110.common.kafka.KafkaFactory;
import com.java110.common.log.LoggerEngine;
import com.java110.common.util.Assert;
import com.java110.core.context.DataFlow;
import com.java110.core.context.TransactionLog;

import java.util.Map;

/**
 * 日志代理
@@ -18,8 +25,6 @@

    public static final String LOG_STATUS_S = "S";
    public static final String LOG_STATUS_F = "F";
    public static final String LOG_TYPE_S = "S";
    public static final String LOG_TYPE_C = "C";


    /**
@@ -40,10 +45,96 @@
    }


    public static boolean sendLog(DataFlow dataFlow){
        return sendLog(dataFlow);

    /**
     * 发送交互日志
     * @param dataFlow 数据流对象
     * @param requestMessage 请求数据
     * @param responseMessage 返回数据
     * @param logStatus 日志状态
     * @return
     */
    public static boolean sendLog(DataFlow dataFlow,String requestMessage,String responseMessage,String logStatus,long costTime){
        return sendLog(dataFlow.reBuilder(requestMessage,responseMessage,logStatus,costTime));
    }

    /**
     * 发送交互日志
     * 请求报文和返回报文必须组装成
     * {"headers":"",
     * "body":""
     * }
     * @param dataFlow 数据流对象
     * @param requestMessage 请求数据
     * @param responseMessage 返回数据
     * @return
     */
    public static boolean sendLog(DataFlow dataFlow, JSONObject requestMessage, JSONObject responseMessage,long costTime){
        Assert.hasKey(responseMessage,"body","返回报文不满足 日志协议要求"+responseMessage.toJSONString());

        String body = responseMessage.getString("body");
        String logStatus = LOG_STATUS_F;
        //如果是JSONObject
        if(Assert.isJsonObject(body)){
            JSONObject bodyObj = JSONObject.parseObject(body);

            Object codeNode = JSONPath.eval(bodyObj,"$.orders.response.code");
            //判断订单是否成功
            if(codeNode != null && ResponseConstant.RESULT_CODE_SUCCESS.equals(codeNode.toString())){
                //判断业务是否受理成功个，如果有一个业务受理失败，则认为失败
                if(!bodyObj.containsKey("business")){
                    return sendLog(dataFlow,requestMessage.toJSONString(),responseMessage.toJSONString(),LOG_STATUS_S,costTime);
                }

                if(bodyObj.get("business") instanceof JSONObject){
                    JSONObject businessObj = bodyObj.getJSONObject("business");
                    if(businessObj.containsKey("response")&&
                            ResponseConstant.RESULT_CODE_SUCCESS.equals(businessObj.getJSONObject("response").getString("code"))){
                        return sendLog(dataFlow,requestMessage.toJSONString(),responseMessage.toJSONString(),LOG_STATUS_S,costTime);
                    }
                }

                if(bodyObj.get("business") instanceof JSONArray){
                    JSONArray businessArrays = bodyObj.getJSONArray("business");
                    if(businessArrays == null || businessArrays.size() == 0){
                        return sendLog(dataFlow,requestMessage.toJSONString(),responseMessage.toJSONString(),LOG_STATUS_S,costTime);
                    }

                    logStatus = LOG_STATUS_S;
                    for(int businessIndex = 0; businessIndex < businessArrays.size();businessIndex ++){
                        JSONObject businessObj = businessArrays.getJSONObject(businessIndex);
                        if(!businessObj.containsKey("response") ||
                                !ResponseConstant.RESULT_CODE_SUCCESS.equals(businessObj.getJSONObject("response").getString("code"))){
                            logStatus = LOG_STATUS_F;
                        }
                    }
                }
            }
        }
        //如果有xml交互，则扩展

        //兼容kafka 传递消息
        if(ResponseConstant.RESULT_CODE_SUCCESS.equals(body)){
            logStatus = LOG_STATUS_S;
        }
        return sendLog(dataFlow,requestMessage.toJSONString(),responseMessage.toJSONString(),logStatus,costTime);
    }


    /**
     * 封装头信息和 消息信息至body中
     * {"headers":"",
     * "body":""
     * }
     * @param headers 头信息
     * @param dataInfo 数据信息
     * @return
     */
    public static JSONObject createLogMessage(Map<String,String> headers, String dataInfo){
        JSONObject message = new JSONObject();
        String headerMessage = (headers == null || headers.isEmpty())?"":JSONObject.toJSONString(headers);
        message.put("headers",headerMessage);
        message.put("body",dataInfo);
        return message;
    }

}