From f475b4b51672abf3d54177df79d23e975ddd2dba Mon Sep 17 00:00:00 2001
From: wuxw7 <wuxw7@asiainfo.com>
Date: 星期一, 17 四月 2017 00:18:20 +0800
Subject: [PATCH] 实现订单查询接口，优化订单受理支持异步方式受理订单
---
OrderService/src/main/java/com/java110/order/smo/impl/OrderServiceSMOImpl.java | 37 ++++++++++++++++++++++++++++++++++++-
1 files changed, 36 insertions(+), 1 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 ab58298..fa683fc 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
@@ -19,6 +19,7 @@
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
+import org.springframework.util.Assert;
import java.util.List;
import java.util.Map;
@@ -41,7 +42,41 @@
EventProperties eventProperties;
/**
+ * 鏍规嵁璐墿杞D 鎴栬�� 澶栭儴绯荤粺ID 鎴栬�� custId 鎴栬�� channelId 鏌ヨ璁㈠崟淇℃伅
+ * @param orderList
+ * @return
+ */
+ @Override
+ public String queryOrderInfo(OrderList orderList) throws Exception{
+
+
+ List<OrderList> orderLists = iOrderServiceDao.queryOrderListAndAttr(orderList);
+ //
+ JSONArray orderListsArray = new JSONArray();
+ for (OrderList orderListTmp : orderLists){
+ //
+ BusiOrder busiOrderTmp = new BusiOrder();
+ busiOrderTmp.setBoId(orderListTmp.getOlId());
+
+ List<BusiOrder> busiOrders = iOrderServiceDao.queryBusiOrderAndAttr(busiOrderTmp);
+
+ JSONObject orderListJSON = JSONObject.parseObject(JSONObject.toJSONString(orderListTmp));
+
+ orderListJSON.put("busiOrders",JSONObject.parseArray(JSONObject.toJSONString(busiOrders)));
+
+ orderListsArray.add(orderListJSON);
+ }
+
+ JSONObject orderListTmpO = new JSONObject();
+ orderListTmpO.put("orderLists",orderListsArray);
+
+ return ProtocolUtil.createResultMsg(ProtocolUtil.RETURN_MSG_SUCCESS,"鏌ヨ鎴愬姛",orderListTmpO);
+ }
+
+ /**
* 璁㈠崟璋冨害
+ *
+ * orderListInfo 涓瓧娈� asyn 濡傛灉涓� A 琛ㄧず 寮傛澶勭悊璁㈠崟锛屽叾浠栬〃鍚屾澶勭悊璁㈠崟
* @param orderInfo 璁㈠崟淇℃伅
* @return 璁㈠崟澶勭悊鎺ュ彛
* @throws Exception
@@ -156,7 +191,7 @@
try {
//鍙戝竷浜嬩欢
- AppEventPublishing.multicastEvent(actionTypeCd,orderInfo.toJSONString(), data.toJSONString());
+ AppEventPublishing.multicastEvent(actionTypeCd,orderInfo.toJSONString(), data.toJSONString(),orderListTmp.getString("asyn"));
}catch (Exception e){
//杩欓噷琛ュ伩浜嬬墿
throw e;
--
Gitblit v1.8.0