From 2f73a671db8bf132baaba12a5c2a9c3b611589e9 Mon Sep 17 00:00:00 2001
From: wuxw <928255095@qq.com>
Date: 星期四, 01 八月 2019 17:14:26 +0800
Subject: [PATCH] 修复 添加房屋时的侦听 类修改

---
 java110-core/src/main/java/com/java110/core/factory/DataTransactionFactory.java |   90 ++++++++++++++++++++++++++++++++++++++++++--
 1 files changed, 85 insertions(+), 5 deletions(-)

diff --git a/java110-core/src/main/java/com/java110/core/factory/DataTransactionFactory.java b/java110-core/src/main/java/com/java110/core/factory/DataTransactionFactory.java
index 76c8064..1c72cb3 100644
--- a/java110-core/src/main/java/com/java110/core/factory/DataTransactionFactory.java
+++ b/java110-core/src/main/java/com/java110/core/factory/DataTransactionFactory.java
@@ -2,17 +2,16 @@
 
 import com.alibaba.fastjson.JSONArray;
 import com.alibaba.fastjson.JSONObject;
+import com.alibaba.fastjson.JSONPath;
 import com.java110.common.constant.MappingConstant;
 import com.java110.common.constant.OrderTypeCdConstant;
 import com.java110.common.constant.ResponseConstant;
 import com.java110.common.constant.StatusConstant;
-import com.java110.common.util.Assert;
 import com.java110.common.util.DateUtil;
-import com.java110.common.util.SequenceUtil;
 import com.java110.common.util.StringUtil;
 import com.java110.core.context.DataFlow;
 import com.java110.core.context.DataFlowContext;
-import com.java110.entity.service.PageData;
+import com.java110.core.context.PageData;
 
 import java.util.Date;
 import java.util.Map;
@@ -48,6 +47,54 @@
             responseInfo.put("business",business);
         }
         return responseInfo;
+    }
+
+    /**
+     * 涓氬姟鏄惁閮芥垚鍔熶簡
+     * @param response true 鎴愬姛 false 澶辫触
+     * @return
+     */
+    public static boolean isSuccessBusiness(JSONObject response){
+        Object obj = JSONPath.eval(response,"$.orders.response.code");
+
+        if(obj != null && obj instanceof String && ResponseConstant.RESULT_CODE_SUCCESS.equals(obj.toString())){
+            Object businessObj = JSONPath.eval(response,"$.business");
+            if(businessObj == null){
+                return true;
+            }
+
+            if(businessObj instanceof JSONObject){
+                JSONObject businessJson = (JSONObject) businessObj;
+                if(!businessJson.containsKey("response")){ //杩欓噷杩斿洖鍗忚閿欒锛屾垜浠涓烘槸鎴愬姛
+                    return true;
+                }
+                if(businessJson.getJSONObject("response").containsKey("code")
+                        && ResponseConstant.RESULT_CODE_SUCCESS.equals(businessJson.getJSONObject("response").getString("code"))){
+                    return true;
+                }
+            }
+
+            if(businessObj instanceof JSONArray){
+                JSONArray businessJsons = (JSONArray) businessObj;
+                if(businessJsons == null || businessJsons.size() == 0){
+                    return true;
+                }
+                JSONObject businessJson = null;
+                for (int businessIndex = 0;businessIndex < businessJsons.size();businessIndex++) {
+                    businessJson = businessJsons.getJSONObject(businessIndex);
+                    if (!businessJson.containsKey("response")) { //杩欓噷杩斿洖鍗忚閿欒锛屾垜浠涓烘槸鎴愬姛
+                        continue;
+                    }
+                    if (businessJson.getJSONObject("response").containsKey("code")
+                            && !ResponseConstant.RESULT_CODE_SUCCESS.equals(businessJson.getJSONObject("response").getString("code"))) {
+                        return false;
+                    }
+                }
+                return true;
+            }
+        }
+
+        return false;
     }
 
     /**
@@ -220,7 +267,7 @@
 
 
     /**
-     * 鍒涘缓璇锋眰 center 鎶ユ枃 鍒嗚鎴怞SON
+     * 鍒涘缓璇锋眰 order 鎶ユ枃 鍒嗚鎴怞SON
      * @param appId
      * @return
      */
@@ -229,7 +276,7 @@
         JSONObject paramIn = JSONObject.parseObject("{\"orders\":{},\"business\":[]}");
         JSONObject orders = paramIn.getJSONObject("orders");
         orders.put("appId",appId);
-        orders.put("transactionId", SequenceUtil.getTransactionId());
+        orders.put("transactionId", GenerateCodeFactory.getTransactionId());
         orders.put("userId",userId);
         orders.put("orderTypeCd",orderTypeCd);
         orders.put("requestTime",DateUtil.getNowDefault());
@@ -361,4 +408,37 @@
         return pageResponseJson(transactionId,ResponseConstant.RESULT_CODE_SUCCESS,"鎴愬姛",null);
     }
 
+
+    /**
+     * ID鐢熸垚杩斿洖鎶ユ枃
+     * @param transactionId
+     * @param id
+     * @param code
+     * @param message
+     * @return
+     */
+    public static JSONObject createCodeResponseJson(String transactionId, String id, String code,String message){
+        JSONObject paramOut = JSONObject.parseObject("{}");
+        paramOut.put("transactionId",transactionId);
+        paramOut.put("code",code);
+        paramOut.put("message",message);
+        paramOut.put("responseTime",DateUtil.getNowDefault());
+        paramOut.put("id",id);
+        return paramOut;
+    }
+
+    /**
+     * ID鐢熸垚璇锋眰鎶ユ枃
+     * @param transactionId
+     * @return
+     */
+    public static JSONObject createCodeRequestJson(String transactionId, String prefix,String name){
+        JSONObject paramOut = JSONObject.parseObject("{}");
+        paramOut.put("transactionId",transactionId);
+        paramOut.put("prefix",prefix);
+        paramOut.put("name",name);
+        paramOut.put("requestTime",DateUtil.getNowDefault());
+        return paramOut;
+    }
+
 }

--
Gitblit v1.8.0