From ab9b63cd51ade836a883a59bff6c419c771a9d98 Mon Sep 17 00:00:00 2001
From: wuxw7 <wuxw7@asiainfo.com>
Date: 星期六, 17 十一月 2018 00:16:02 +0800
Subject: [PATCH] api 封装完成
---
java110-core/src/main/java/com/java110/core/factory/DataFlowFactory.java | 36 ++++++++++++++++++++++++++++++++++++
1 files changed, 36 insertions(+), 0 deletions(-)
diff --git a/java110-core/src/main/java/com/java110/core/factory/DataFlowFactory.java b/java110-core/src/main/java/com/java110/core/factory/DataFlowFactory.java
index 80747fd..6c7072c 100644
--- a/java110-core/src/main/java/com/java110/core/factory/DataFlowFactory.java
+++ b/java110-core/src/main/java/com/java110/core/factory/DataFlowFactory.java
@@ -10,6 +10,7 @@
import com.java110.common.util.Assert;
import com.java110.common.util.DateUtil;
import com.java110.core.context.AbstractDataFlowContext;
+import com.java110.core.context.ApiDataFlow;
import com.java110.core.context.DataFlow;
import com.java110.entity.center.AppRoute;
import com.java110.entity.center.AppService;
@@ -101,6 +102,27 @@
}
return null;
}
+
+ /**
+ * 鑾峰彇鍗曚釜璺敱
+ * @param dataFlow
+ * @param serviceCode
+ * @return
+ */
+ public static AppRoute getRoute(ApiDataFlow dataFlow, String serviceCode){
+ if (dataFlow.getAppRoutes().size() == 0){
+ throw new RuntimeException("褰撳墠娌℃湁鑾峰彇鍒癆ppId瀵瑰簲鐨勪俊鎭�");
+ }
+
+ List<AppRoute> appRoutes = dataFlow.getAppRoutes();
+ for(AppRoute appRoute : appRoutes) {
+ if (StatusConstant.STATUS_CD_VALID.equals(appRoute.getStatusCd())
+ &&appRoute.getAppService().getServiceCode().equals(serviceCode)){
+ return appRoute;
+ }
+ }
+ return null;
+ }
/**
* 鑾峰彇鍗曚釜鏈嶅姟
* @param dataFlow
@@ -116,6 +138,20 @@
}
/**
+ * 鑾峰彇鍗曚釜鏈嶅姟
+ * @param dataFlow
+ * @param serviceCode
+ * @return
+ */
+ public static AppService getService(ApiDataFlow dataFlow, String serviceCode){
+ AppRoute route = getRoute(dataFlow, serviceCode);
+ if(route == null){
+ return null;
+ }
+ return route.getAppService();
+ }
+
+ /**
* 鑾峰彇Order淇℃伅
* @param dataFlow
* @return
--
Gitblit v1.8.0