From 149c1bc2d195eb79b84f2e69c83413f27bce4b99 Mon Sep 17 00:00:00 2001
From: wuxw <928255095@qq.com>
Date: 星期六, 30 三月 2019 14:43:56 +0800
Subject: [PATCH] 订单服务核心 加入商户处理侦听类
---
OrderService/src/main/java/com/java110/order/smo/impl/OrderServiceSMOImpl.java | 17 ++++++++++-------
1 files changed, 10 insertions(+), 7 deletions(-)
diff --git a/OrderService/src/main/java/com/java110/order/smo/impl/OrderServiceSMOImpl.java b/OrderService/src/main/java/com/java110/order/smo/impl/OrderServiceSMOImpl.java
index 4bb82ad..9ba946f 100644
--- a/OrderService/src/main/java/com/java110/order/smo/impl/OrderServiceSMOImpl.java
+++ b/OrderService/src/main/java/com/java110/order/smo/impl/OrderServiceSMOImpl.java
@@ -111,7 +111,7 @@
} finally {
if(responseEntity == null){
- responseEntity = new ResponseEntity<String>(dataFlow.getResJson().getString("msg"),OrderDataFlowContextFactory.hashMap2MultiValueMap(dataFlow.getResHeaders()),HttpStatus.OK);
+ responseEntity = new ResponseEntity<String>(dataFlow.getResJson().getJSONArray("msg").toJSONString(),OrderDataFlowContextFactory.hashMap2MultiValueMap(dataFlow.getResHeaders()),HttpStatus.OK);
}
if(dataFlow != null) {
//娣诲姞鑰楁椂
@@ -136,11 +136,11 @@
*/
private void refreshOrderDataFlowResJson(IOrderDataFlowContext dataFlow){
- if(dataFlow.getResJson() == null || dataFlow.getResJson().isEmpty()){
- JSONObject resJson = new JSONObject();
- resJson.put("msg","鎴愬姛");
- dataFlow.setResJson(resJson);
- }
+// if(dataFlow.getResJson() == null || dataFlow.getResJson().isEmpty()){
+// JSONObject resJson = new JSONObject();
+// resJson.put("msg","鎴愬姛");
+// dataFlow.setResJson(resJson);
+// }
}
@@ -900,6 +900,9 @@
throw new ConfigDataException(ResponseConstant.RESULT_CODE_CONFIG_ERROR,"閰嶇疆閿欒锛歝_service_business閰嶇疆url瀛楁閿欒,褰撳墠鏃犳硶璇嗗埆"+serviceBusiness.getBusinessTypeCd());
}
+
+ logger.debug("璁㈠崟鏈嶅姟璋冪敤涓嬫父鏈嶅姟璇锋眰鎶ユ枃锛歿}锛岃繑鍥炴姤鏂囷細{}",requestBusinessJson,responseMessage);
+
if(StringUtil.isNullOrNone(responseMessage) || !Assert.isJsonObject(responseMessage)){
throw new BusinessException(ResponseConstant.RESULT_CODE_INNER_ERROR,"涓嬫父绯荤粺杩斿洖鏍煎紡涓嶆纭紝璇锋寜鍗忚瑙勮寖澶勭悊");
}
@@ -956,7 +959,7 @@
JSONObject responseJson = doRequestBusinessSystem(dataFlow, serviceBusiness, requestBusinessJson);
//鍙戝竷浜嬩欢
- DataFlowEventPublishing.invokeBusinessBSuccess(dataFlow,business);
+ DataFlowEventPublishing.invokeBusinessBSuccess(dataFlow,business,responseJson);
responseBusinesses.add(responseJson);
--
Gitblit v1.8.0