1 files changed, 217 insertions, 0 deletions
diff --git a/apiroute/apiroute-service/src/main/java/org/onap/msb/apiroute/wrapper/CustomRouteServiceWrapper.java b/apiroute/apiroute-service/src/main/java/org/onap/msb/apiroute/wrapper/CustomRouteServiceWrapper.java
new file mode 100644
index 0000000..50747b6
--- /dev/null
+++ b/apiroute/apiroute-service/src/main/java/org/onap/msb/apiroute/wrapper/CustomRouteServiceWrapper.java
@@ -0,0 +1,217 @@
+/**
+ * Copyright 2016 ZTE, Inc. and others.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.onap.msb.apiroute.wrapper;
+
+import java.util.List;
+
+import org.onap.msb.apiroute.api.CustomRouteInfo;
+import org.onap.msb.apiroute.api.exception.ExtendedInternalServerErrorException;
+import org.onap.msb.apiroute.api.exception.ExtendedNotFoundException;
+import org.onap.msb.apiroute.wrapper.service.CustomRouteService;
+import org.onap.msb.apiroute.wrapper.util.RouteUtil;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public class CustomRouteServiceWrapper {
+
+
+  private static final Logger LOGGER = LoggerFactory.getLogger(CustomRouteServiceWrapper.class);
+
+  private static CustomRouteServiceWrapper instance = new CustomRouteServiceWrapper();
+
+  private CustomRouteServiceWrapper() {}
+
+  public static CustomRouteServiceWrapper getInstance() {
+    return instance;
+  }
+
+
+  /**
+   * @Title: getAllCustomRouteService
+   * @Description: TODO(get AllCustomRoute Service)
+   * @param: @return
+   * @return: CustomRouteInfo[]
+   */
+  public List<CustomRouteInfo> getAllCustomRouteInstances(String routeWay) {
+
+    RouteUtil.checkRouteWay(routeWay);
+    
+    try {
+      String customRedisKey = RouteUtil.getMutiRedisKey(RouteUtil.CUSTOMROUTE, routeWay);
+      return CustomRouteService.getInstance().getMultiCustomRouteInstances(customRedisKey);
+
+    } catch (Exception e) {
+      throw new ExtendedInternalServerErrorException(e.getMessage());
+    }
+
+
+  }
+
+
+
+  /**
+   * @Title: getCustomRouteInstance
+   * @Description: TODO(get CustomRouteInstance by serviceName)
+   * @param: @param serviceName
+   * @param: @return
+   * @return: CustomRouteInfo
+   */
+  public CustomRouteInfo getCustomRouteInstance(String serviceName, String host,
+      String publish_port, String routeWay) {
+
+    RouteUtil.checkRouteWay(routeWay);
+
+    String customRedisPrefixedKey =
+        RouteUtil.getRedisPrefixedKey(RouteUtil.CUSTOMROUTE, serviceName, host, publish_port,
+            routeWay);
+
+    CustomRouteInfo customRouteInfo;
+    try {
+      customRouteInfo =
+          CustomRouteService.getInstance().getCustomRouteInstance(customRedisPrefixedKey);
+    } catch (Exception e) {
+      LOGGER.error("get customRouteInstance throw exception", e);
+      throw new ExtendedInternalServerErrorException("get customRouteInstance throw exception"+ e.getMessage());
+    }
+
+
+    if (null == customRouteInfo) {
+      throw new ExtendedNotFoundException("customRoute Info not found");
+
+    }
+
+    return customRouteInfo;
+
+  }
+
+
+  /**
+   * @Title updateCustomRouteStatus
+   * @Description TODO(update one CustomRoute Status)
+   * @param serviceName
+   * @param status
+   * @return
+   * @return RouteResult
+   */
+  public synchronized CustomRouteInfo updateCustomRouteStatus(String serviceName, String host,
+      String publish_port, String status, String routeWay) {
+
+    RouteUtil.checkRouteWay(routeWay);
+
+    RouteUtil.checkServiceStatus(status);
+
+    String customRedisPrefixedKey =
+        RouteUtil.getRedisPrefixedKey(RouteUtil.CUSTOMROUTE, serviceName, host, publish_port,
+            routeWay);
+
+
+    try {
+      CustomRouteService.getInstance()
+          .updateCustomRouteStatus2Redis(customRedisPrefixedKey, status);
+    } catch (Exception e) {
+      LOGGER.error("update CustomRoute status  throw exception", e);
+      throw new ExtendedInternalServerErrorException(e.getMessage());
+    }
+
+    CustomRouteInfo new_customRouteInfo =
+        getCustomRouteInstance(serviceName, host, publish_port, routeWay);
+
+    return new_customRouteInfo;
+  }
+
+  /**
+   * @Title: saveCustomRouteInstance
+   * @Description: TODO(save one CustomRouteInstance)
+   * @param: @param CustomRouteInfo
+   * @param: @return
+   * @return: CustomRouteInfo
+   */
+  public synchronized CustomRouteInfo saveCustomRouteInstance4Rest(CustomRouteInfo customRouteInfo,
+      String routeWay) {
+
+    RouteUtil.checkRouteWay(routeWay);
+
+    RouteUtil.checkRouterInfoFormat(customRouteInfo);
+
+    try {
+      saveCustomRouteInstance(customRouteInfo, routeWay);
+
+    } catch (Exception e) {
+
+      throw new ExtendedInternalServerErrorException("save CustomRouteInfo  fail: [serviceName]"+customRouteInfo.getServiceName()+e.getMessage());
+    }
+
+    return customRouteInfo;
+
+  }
+
+
+  public synchronized CustomRouteInfo saveCustomRouteInstance(CustomRouteInfo customRouteInfo,
+      String routeWay) throws Exception {
+    try {
+    String customRedisPrefixedKey =
+        RouteUtil.getRedisPrefixedKey(RouteUtil.CUSTOMROUTE, customRouteInfo.getServiceName(),
+            customRouteInfo.getHost(), customRouteInfo.getPublish_port(), routeWay);;
+
+  
+      CustomRouteService.getInstance().saveCustomRouteService2Redis(customRouteInfo,
+          customRedisPrefixedKey);
+      LOGGER.info("save CustomRouteInfo [serviceName]"+customRouteInfo.getServiceName()+" [host]"+customRouteInfo.getHost() +" [publish_port]"+customRouteInfo.getPublish_port()+" [routeWay]"+routeWay+" success");
+
+    } catch (Exception e) {
+      LOGGER.error("save CustomRouteInfo [serviceName]"+customRouteInfo.getServiceName()+" [host]"+customRouteInfo.getHost() +" [publish_port]"+customRouteInfo.getPublish_port()+" [routeWay]"+routeWay+" throw exception", e);
+
+      throw e;
+    }
+   
+    return customRouteInfo;
+
+  }
+
+
+  /**
+   * @Title: deleteCustomRoute
+   * @Description: TODO(delete one CustomRoute)
+   * @param: @param type
+   * @param: @param serviceName
+   * @param: @param delKey
+   * @param: @return
+   * @return: void
+   */
+  public synchronized void deleteCustomRoute(String serviceName, String host, String publish_port,
+      String routeWay) {
+
+    RouteUtil.checkRouteWay(routeWay);
+
+    String customRedisPrefixedKey =
+        RouteUtil.getRedisPrefixedKey(RouteUtil.CUSTOMROUTE, serviceName, host, publish_port,
+            routeWay);
+
+    try {
+      CustomRouteService.getInstance().deleteCustomRouteService2Redis(customRedisPrefixedKey);
+      LOGGER.info("delete CustomRouteInfo [serviceName]"+serviceName+" [host]"+host +" [publish_port]"+publish_port+" [routeWay]"+routeWay+" success");
+
+    } catch (ExtendedNotFoundException e) {
+      throw e;
+    } catch (Exception e) {
+      LOGGER.error("delete CustomRouteInfo [serviceName]"+serviceName+" [host]"+host +" [publish_port]"+publish_port+" [routeWay]"+routeWay+" throw exception", e);
+      throw new ExtendedInternalServerErrorException("delete CustomRouteInfo [serviceName]"+serviceName+e.getMessage());
+    }
+
+
+
+  }
+}