中心服务 事件发布调整

Author: wuxw7

CenterService/src/main/java/com/java110/center/api/HttpApi.java

@@ -7,6 +7,7 @@
 import com.java110.common.util.Assert;
 import com.java110.core.factory.DataTransactionFactory;
 import com.java110.core.base.controller.BaseController;
+import com.java110.event.center.DataFlowEventPublishing;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.web.bind.annotation.*;
 
@@ -43,6 +44,8 @@ public String servicePost(@RequestBody String orderInfo, HttpServletRequest requ
         try {
             Map<String, String> headers = new HashMap<String, String>();
             getRequestInfo(request, headers);
+            //接受请求事件
+            DataFlowEventPublishing.receiveRequest(orderInfo,headers);
             //预校验
             preValiateOrderInfo(orderInfo);
             return centerServiceSMOImpl.service(orderInfo, headers);

CenterService/src/main/java/com/java110/center/smo/impl/CenterServiceSMOImpl.java

@@ -67,6 +67,7 @@ public String service(String reqJson, Map<String, String> headers) throws SMOExc
 
         try {
             reqJson = decrypt(reqJson,headers);
+            DataFlowEventPublishing.preValidateData(reqJson,headers);
             //1.0 创建数据流
             dataFlow = DataFlowFactory.newInstance(DataFlow.class).builder(reqJson, headers);
 
@@ -1134,7 +1135,7 @@ private void doSaveDataInfoToBusinessTable(DataFlow dataFlow, List<Business> syn
 
             dataFlow.setResponseBusinessJson(responseJson);
             //发布事件
-            DataFlowEventPublishing.multicastEvent(service.getServiceCode(),dataFlow);
+            //DataFlowEventPublishing.multicastEvent(service.getServiceCode(),dataFlow);
 
             responseBusinesses.add(dataFlow.getResponseBusinessJson());