From fec26dfca0c796c2c9d4cd3c206affa0bc06c281 Mon Sep 17 00:00:00 2001
From: wuxw7 <wuxw7@asiainfo.com>
Date: 星期一, 02 七月 2018 22:52:48 +0800
Subject: [PATCH] 事件侦听改为注解方式，方便后期开发，取消配置文件方式
---
CenterService/src/main/java/com/java110/center/smo/impl/CenterServiceSMOImpl.java | 13 ++++++++-----
1 files changed, 8 insertions(+), 5 deletions(-)
diff --git a/CenterService/src/main/java/com/java110/center/smo/impl/CenterServiceSMOImpl.java b/CenterService/src/main/java/com/java110/center/smo/impl/CenterServiceSMOImpl.java
index 3bf1dee..493d5ba 100644
--- a/CenterService/src/main/java/com/java110/center/smo/impl/CenterServiceSMOImpl.java
+++ b/CenterService/src/main/java/com/java110/center/smo/impl/CenterServiceSMOImpl.java
@@ -70,19 +70,23 @@
DataFlowEventPublishing.preValidateData(reqJson,headers);
//1.0 鍒涘缓鏁版嵁娴�
dataFlow = DataFlowFactory.newInstance(DataFlow.class).builder(reqJson, headers);
+ DataFlowEventPublishing.initDataFlowComplete(dataFlow);
- /*LogAgent.sendLog(dataFlow.reBuilder(dataFlow.getTransactionId(),LogAgent.LOG_TYPE_S,LogAgent.LOG_STATUS_S,
- dataFlow.getRequestURL(),dataFlow.getReqData(),dataFlow.getHeaders()));
-*/
//2.0 鍔犺浇閰嶇疆淇℃伅
initConfigData(dataFlow);
+ DataFlowEventPublishing.loadConfigDataComplete(dataFlow);
+
//3.0 鏍￠獙 APPID鏄惁鏈夋潈闄愭搷浣渟erviceCode
judgeAuthority(dataFlow);
//4.0 璋冪敤瑙勫垯鏍￠獙
ruleValidate(dataFlow);
+ DataFlowEventPublishing.ruleValidateComplete(dataFlow);
+
//5.0 淇濆瓨璁㈠崟鍜屼笟鍔￠」 c_orders c_order_attrs c_business c_business_attrs
saveOrdersAndBusiness(dataFlow);
+
//6.0 璋冪敤涓嬫父绯荤粺
+ DataFlowEventPublishing.invokeBusinessSystem(dataFlow);
invokeBusinessSystem(dataFlow);
responseJson = DataTransactionFactory.createCommonResponseJson(dataFlow);
@@ -144,11 +148,10 @@
AuthenticationFactory.putSign(dataFlow, responseJson);
saveLogMessage(dataFlow,LogAgent.createLogMessage(dataFlow.getRequestHeaders(),dataFlow.getReqJson().toJSONString()),
LogAgent.createLogMessage(dataFlow.getResponseHeaders(),dataFlow.getResJson().toJSONString()),endDate.getTime()-dataFlow.getStartDate().getTime());
-
+ DataFlowEventPublishing.dataResponse(dataFlow,reqJson,headers);
}
resJson = encrypt(responseJson.toJSONString(),headers);
//杩欓噷淇濆瓨鑰楁椂锛屼互鍙婃棩蹇�
-
return resJson;
}
--
Gitblit v1.8.0