Add processing code related to slice resource monitoring.

Issue-ID: USECASEUI-370
Change-Id: I16bd9a9c68daa1047e61d181e4d1e8dfc907678b
Signed-off-by: hekeguang <hekeguang@chinamobile.com>

4 files changed, 402 insertions, 0 deletions

diff --git a/server/src/main/java/org/onap/usecaseui/server/service/nsmf/ResourceMonitorService.java b/server/src/main/java/org/onap/usecaseui/server/service/nsmf/ResourceMonitorService.java
new file mode 100644
index 00000000..7a2a249e
--- /dev/null
+++ b/server/src/main/java/org/onap/usecaseui/server/service/nsmf/ResourceMonitorService.java
@@ -0,0 +1,28 @@
+/*
+ * Copyright (C) 2019 CMCC, Inc. and others. All rights reserved.
+ *
+ * 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.usecaseui.server.service.nsmf;
+
+import org.onap.usecaseui.server.bean.nsmf.common.ServiceResult;
+import org.onap.usecaseui.server.bean.nsmf.monitor.ServiceList;
+
+public interface ResourceMonitorService {
+
+    ServiceResult querySlicingUsageTraffic(String queryTimestamp, ServiceList serviceList);
+
+    ServiceResult querySlicingOnlineUserNumber(String queryTimestamp, ServiceList serviceList);
+
+    ServiceResult querySlicingTotalBandwidth(String queryTimestamp, ServiceList serviceList);
+}
diff --git a/server/src/main/java/org/onap/usecaseui/server/service/nsmf/impl/ResourceMonitorServiceConvert.java b/server/src/main/java/org/onap/usecaseui/server/service/nsmf/impl/ResourceMonitorServiceConvert.java
new file mode 100644
index 00000000..98663b86
--- /dev/null
+++ b/server/src/main/java/org/onap/usecaseui/server/service/nsmf/impl/ResourceMonitorServiceConvert.java
@@ -0,0 +1,104 @@
+/*
+ * Copyright (C) 2019 CMCC, Inc. and others. All rights reserved.
+ *
+ * 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.usecaseui.server.service.nsmf.impl;
+
+import java.lang.reflect.InvocationTargetException;
+import java.text.ParseException;
+import java.util.ArrayList;
+import java.util.List;
+import org.apache.commons.beanutils.BeanUtils;
+import org.onap.usecaseui.server.bean.nsmf.monitor.ServiceInfo;
+import org.onap.usecaseui.server.bean.nsmf.monitor.ServiceOnlineUserInfo;
+import org.onap.usecaseui.server.bean.nsmf.monitor.ServiceTotalBandwidthInfo;
+import org.onap.usecaseui.server.bean.nsmf.monitor.SlicingKpiReqInfo;
+import org.onap.usecaseui.server.bean.nsmf.monitor.TotalBandwidthInfo;
+import org.onap.usecaseui.server.bean.nsmf.monitor.TrafficReqInfo;
+import org.onap.usecaseui.server.bean.nsmf.monitor.UsageTrafficInfo;
+import org.onap.usecaseui.server.bean.nsmf.monitor.UserNumberInfo;
+import org.onap.usecaseui.server.constant.nsmf.NsmfParamConstant;
+import org.onap.usecaseui.server.service.slicingdomain.kpi.bean.KpiTotalBandwidth;
+import org.onap.usecaseui.server.service.slicingdomain.kpi.bean.KpiTotalBandwidth.TotalBandwidth;
+import org.onap.usecaseui.server.service.slicingdomain.kpi.bean.KpiTotalTraffic;
+import org.onap.usecaseui.server.service.slicingdomain.kpi.bean.KpiUserNumber;
+import org.onap.usecaseui.server.service.slicingdomain.kpi.bean.KpiUserNumber.UserNumbers;
+import org.onap.usecaseui.server.util.nsmf.NsmfCommonUtil;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+public class ResourceMonitorServiceConvert {
+
+    private static final Logger logger = LoggerFactory.getLogger(ResourceMonitorServiceConvert.class);
+
+    TrafficReqInfo buildTrafficReqInfo(ServiceInfo serviceInfo, String queryTimestamp) {
+        TrafficReqInfo trafficReqInfo = new TrafficReqInfo();
+        trafficReqInfo.setId(serviceInfo.getServiceId());
+        trafficReqInfo.setTimeStamp(queryTimestamp);
+        return trafficReqInfo;
+    }
+
+    void convertUsageTrafficInfo(UsageTrafficInfo usageTrafficInfo, KpiTotalTraffic kpiTotalTraffic) {
+        usageTrafficInfo.setServiceId(kpiTotalTraffic.getId());
+        usageTrafficInfo.setTrafficData(String.valueOf(kpiTotalTraffic.getTotalTraffic()));
+    }
+
+    SlicingKpiReqInfo buildSlicingKpiReqInfo(ServiceInfo serviceInfo, String queryTimestamp, int kpiHours) {
+        SlicingKpiReqInfo slicingKpiReqInfo = new SlicingKpiReqInfo();
+        slicingKpiReqInfo.setId(serviceInfo.getServiceId());
+        slicingKpiReqInfo.setTimeStamp(queryTimestamp);
+        slicingKpiReqInfo.setHours(kpiHours);
+        return slicingKpiReqInfo;
+    }
+
+    void convertServiceOnlineUserInfo(ServiceOnlineUserInfo serviceOnlineUserInfo, KpiUserNumber kpiUserNumber)
+        throws InvocationTargetException, IllegalAccessException, ParseException {
+
+        List<UserNumberInfo> userNumberInfoList = new ArrayList<>();
+        serviceOnlineUserInfo.setId(kpiUserNumber.getId());
+
+        if (kpiUserNumber.getUserNumbers() != null) {
+            for (UserNumbers userNumbers : kpiUserNumber.getUserNumbers()) {
+                String newTimeStamp = NsmfCommonUtil
+                    .timestamp2Time(userNumbers.getTimeStamp().replace("T", NsmfParamConstant.SPACE));
+                UserNumberInfo userNumberInfo = new UserNumberInfo();
+                userNumberInfo.setTimeStamp(newTimeStamp);
+                userNumberInfo.setUserNumber(String.valueOf(userNumbers.getUserNumber()));
+                userNumberInfoList.add(userNumberInfo);
+            }
+        }
+
+        serviceOnlineUserInfo.setUserNumberInfoList(userNumberInfoList);
+    }
+
+    void convertServiceTotalBandwidthInfo(ServiceTotalBandwidthInfo serviceTotalBandwidthInfo,
+        KpiTotalBandwidth kpiTotalBandwidth)
+        throws InvocationTargetException, IllegalAccessException, ParseException {
+
+        List<TotalBandwidthInfo> totalBandwidthInfoList = new ArrayList<>();
+        serviceTotalBandwidthInfo.setId(kpiTotalBandwidth.getId());
+        if (kpiTotalBandwidth.getTotalBandwidth() != null) {
+            for (TotalBandwidth totalBandwidth : kpiTotalBandwidth.getTotalBandwidth()) {
+                String newTimeStamp = NsmfCommonUtil
+                    .timestamp2Time(totalBandwidth.getTimeStamp().replace("T", NsmfParamConstant.SPACE));
+                TotalBandwidthInfo totalBandwidthInfo = new TotalBandwidthInfo();
+                totalBandwidthInfo.setTimestamp(newTimeStamp);
+                totalBandwidthInfo.setBandwidth(String.valueOf(totalBandwidth.getBandwidth()));
+                totalBandwidthInfoList.add(totalBandwidthInfo);
+            }
+        }
+
+        serviceTotalBandwidthInfo.setTotalBandwidthInfoList(totalBandwidthInfoList);
+    }
+}
diff --git a/server/src/main/java/org/onap/usecaseui/server/service/nsmf/impl/ResourceMonitorServiceImpl.java b/server/src/main/java/org/onap/usecaseui/server/service/nsmf/impl/ResourceMonitorServiceImpl.java
new file mode 100644
index 00000000..527d493c
--- /dev/null
+++ b/server/src/main/java/org/onap/usecaseui/server/service/nsmf/impl/ResourceMonitorServiceImpl.java
@@ -0,0 +1,248 @@
+/*
+ * Copyright (C) 2019 CMCC, Inc. and others. All rights reserved.
+ *
+ * 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.usecaseui.server.service.nsmf.impl;
+
+import com.alibaba.fastjson.JSON;
+import com.google.gson.Gson;
+import java.io.IOException;
+import java.io.InputStream;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Properties;
+import okhttp3.MediaType;
+import okhttp3.RequestBody;
+import org.onap.usecaseui.server.bean.nsmf.common.ResultHeader;
+import org.onap.usecaseui.server.bean.nsmf.common.ServiceResult;
+import org.onap.usecaseui.server.bean.nsmf.monitor.ServiceInfo;
+import org.onap.usecaseui.server.bean.nsmf.monitor.ServiceList;
+import org.onap.usecaseui.server.bean.nsmf.monitor.ServiceOnlineUserInfo;
+import org.onap.usecaseui.server.bean.nsmf.monitor.ServiceOnlineUserList;
+import org.onap.usecaseui.server.bean.nsmf.monitor.ServiceTotalBandwidthInfo;
+import org.onap.usecaseui.server.bean.nsmf.monitor.ServiceTotalBandwidthList;
+import org.onap.usecaseui.server.bean.nsmf.monitor.SlicingKpiReqInfo;
+import org.onap.usecaseui.server.bean.nsmf.monitor.TrafficReqInfo;
+import org.onap.usecaseui.server.bean.nsmf.monitor.UsageTrafficInfo;
+import org.onap.usecaseui.server.bean.nsmf.monitor.UsageTrafficList;
+import org.onap.usecaseui.server.constant.nsmf.NsmfCodeConstant;
+import org.onap.usecaseui.server.constant.nsmf.NsmfParamConstant;
+import org.onap.usecaseui.server.service.nsmf.ResourceMonitorService;
+import org.onap.usecaseui.server.service.slicingdomain.kpi.KpiSliceService;
+import org.onap.usecaseui.server.service.slicingdomain.kpi.bean.KpiTotalBandwidth;
+import org.onap.usecaseui.server.service.slicingdomain.kpi.bean.KpiTotalTraffic;
+import org.onap.usecaseui.server.service.slicingdomain.kpi.bean.KpiUserNumber;
+import org.onap.usecaseui.server.util.RestfulServices;
+import org.onap.usecaseui.server.util.nsmf.NsmfCommonUtil;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.context.annotation.EnableAspectJAutoProxy;
+import org.springframework.stereotype.Service;
+import retrofit2.Response;
+
+@Service("ResourceMonitorService")
+@org.springframework.context.annotation.Configuration
+@EnableAspectJAutoProxy
+public class ResourceMonitorServiceImpl implements ResourceMonitorService {
+
+    private final static Logger logger = LoggerFactory.getLogger(ResourceMonitorServiceImpl.class);
+
+    private ResourceMonitorServiceConvert resourceMonitorServiceConvert = new ResourceMonitorServiceConvert();
+    Gson gson = new Gson();
+
+    private KpiSliceService kpiSliceService;
+    private int kpiHours;
+
+    public ResourceMonitorServiceImpl() {
+        this(RestfulServices.create(KpiSliceService.class));
+    }
+
+    public ResourceMonitorServiceImpl(KpiSliceService kpiSliceService) {
+        this.kpiSliceService = kpiSliceService;
+        initConfig();
+    }
+
+    public void initConfig() {
+        InputStream inputStream = this.getClass().getClassLoader().getResourceAsStream("slicing.properties");
+        Properties p = new Properties();
+        try {
+            p.load(inputStream);
+            String strKpiHours = p.getProperty("slicing.kpi.hours");
+            this.kpiHours = Integer.parseInt(strKpiHours);
+        } catch (IOException e1) {
+            logger.error("get configuration file arise error :{}", e1.getMessage());
+        }
+    }
+
+    @Override
+    public ServiceResult querySlicingUsageTraffic(String queryTimestamp, ServiceList serviceList) {
+        ServiceResult serviceResult = new ServiceResult();
+        ResultHeader resultHeader = new ResultHeader();
+
+        UsageTrafficList usageTrafficList = new UsageTrafficList();
+        List<UsageTrafficInfo> usageTrafficInfoList = new ArrayList<>();
+        List<ServiceInfo> serviceInfoList = serviceList.getServiceInfoList();
+        String resultMsg = "";
+
+        try {
+            // TODO
+            for (ServiceInfo serviceInfo : serviceInfoList) {
+                String newTimestamp = NsmfCommonUtil.time2Timestamp(queryTimestamp)
+                    .replace(NsmfParamConstant.SPACE, "T");
+                TrafficReqInfo trafficReqInfo = resourceMonitorServiceConvert
+                    .buildTrafficReqInfo(serviceInfo, newTimestamp);
+                String jsonstr = JSON.toJSONString(trafficReqInfo);
+                RequestBody requestBody = RequestBody.create(MediaType.parse("application/json"), jsonstr.toString());
+                Response<KpiTotalTraffic> response = this.kpiSliceService.listTotalTraffic(requestBody).execute();
+                if (response.isSuccessful()) {
+                    KpiTotalTraffic kpiTotalTraffic = response.body();
+                    logger.info("querySlicingUsageTraffic: listTotalTraffic reponse is:{}",
+                        gson.toJson(kpiTotalTraffic).toString());
+                    UsageTrafficInfo usageTrafficInfo = new UsageTrafficInfo();
+                    resourceMonitorServiceConvert.convertUsageTrafficInfo(usageTrafficInfo, kpiTotalTraffic);
+                    usageTrafficInfoList.add(usageTrafficInfo);
+                    resultMsg = "5G slicing usage traffic query result.";
+                    resultHeader.setResult_code(NsmfCodeConstant.SUCCESS_CODE);
+                } else {
+                    logger.error(String
+                        .format("querySlicingUsageTraffic: Can not get ActivateService[code={}, message={}]",
+                            response.code(),
+                            response.message()));
+                    resultMsg = "5G slicing usage traffic query failed!";
+                    resultHeader.setResult_code(NsmfCodeConstant.ERROR_CODE_UNKNOWN);
+                }
+            }
+        } catch (Exception e) {
+            resultMsg = "5G slicing usage traffic query failed. Unknown exception occurred!";
+            resultHeader.setResult_code(NsmfCodeConstant.ERROR_CODE_UNKNOWN);
+            logger.error(e.getMessage());
+        }
+        usageTrafficList.setUsageTrafficInfoList(usageTrafficInfoList);
+        logger.info(resultMsg);
+        logger.info("querySlicingUsageTraffic: 5G slicing usage traffic query has been finished.");
+        resultHeader.setResult_message(resultMsg);
+        serviceResult.setResult_header(resultHeader);
+        serviceResult.setResult_body(usageTrafficList);
+        return serviceResult;
+    }
+
+    @Override
+    public ServiceResult querySlicingOnlineUserNumber(String queryTimestamp, ServiceList serviceList) {
+        ServiceResult serviceResult = new ServiceResult();
+        ResultHeader resultHeader = new ResultHeader();
+        ServiceOnlineUserList serviceOnlineUserList = new ServiceOnlineUserList();
+        List<ServiceOnlineUserInfo> serviceOnlineUserInfoList = new ArrayList<>();
+        List<ServiceInfo> serviceInfoList = serviceList.getServiceInfoList();
+
+        String resultMsg = "";
+
+        try {
+            // TODO
+            for (ServiceInfo serviceInfo : serviceInfoList) {
+                String newTimestamp = NsmfCommonUtil.time2Timestamp(queryTimestamp)
+                    .replace(NsmfParamConstant.SPACE, "T");
+                SlicingKpiReqInfo slicingKpiReqInfo = resourceMonitorServiceConvert
+                    .buildSlicingKpiReqInfo(serviceInfo, newTimestamp, kpiHours);
+                String jsonstr = JSON.toJSONString(slicingKpiReqInfo);
+                RequestBody requestBody = RequestBody.create(MediaType.parse("application/json"), jsonstr.toString());
+                Response<KpiUserNumber> response = this.kpiSliceService.listUserNumber(requestBody).execute();
+
+                if (response.isSuccessful()) {
+                    KpiUserNumber kpiUserNumber = response.body();
+                    logger.info("querySlicingOnlineUserNumber: listUserNumber reponse is:{}",
+                        gson.toJson(kpiUserNumber).toString());
+                    ServiceOnlineUserInfo serviceOnlineUserInfo = new ServiceOnlineUserInfo();
+                    resourceMonitorServiceConvert.convertServiceOnlineUserInfo(serviceOnlineUserInfo, kpiUserNumber);
+                    serviceOnlineUserInfoList.add(serviceOnlineUserInfo);
+                    resultMsg = "5G slicing online users query result.";
+                    resultHeader.setResult_code(NsmfCodeConstant.SUCCESS_CODE);
+                } else {
+                    logger.error(String
+                        .format("querySlicingOnlineUserNumber: Can not get KpiUserNumber[code={}, message={}]",
+                            response.code(),
+                            response.message()));
+                    resultMsg = "5G slicing online users query failed!";
+                    resultHeader.setResult_code(NsmfCodeConstant.ERROR_CODE_UNKNOWN);
+                }
+            }
+        } catch (Exception e) {
+            resultMsg = "5G slicing online users query failed. Unknown exception occurred!";
+            resultHeader.setResult_code(NsmfCodeConstant.ERROR_CODE_UNKNOWN);
+            logger.error(e.getMessage());
+        }
+
+        logger.info(resultMsg);
+        logger.info("querySlicingOnlineUserNumber: 5G slicing online users query has been finished.");
+        serviceOnlineUserList.setServiceOnlineUserInfoList(serviceOnlineUserInfoList);
+        resultHeader.setResult_message(resultMsg);
+        serviceResult.setResult_header(resultHeader);
+        serviceResult.setResult_body(serviceOnlineUserList);
+        return serviceResult;
+    }
+
+    @Override
+    public ServiceResult querySlicingTotalBandwidth(String queryTimestamp, ServiceList serviceList) {
+        ServiceResult serviceResult = new ServiceResult();
+        ResultHeader resultHeader = new ResultHeader();
+        ServiceTotalBandwidthList serviceTotalBandwidthList = new ServiceTotalBandwidthList();
+
+        List<ServiceTotalBandwidthInfo> serviceTotalBandwidthInfoList = new ArrayList<>();
+        List<ServiceInfo> serviceInfoList = serviceList.getServiceInfoList();
+
+        String resultMsg = "";
+
+        try {
+            for (ServiceInfo serviceInfo : serviceInfoList) {
+                String newTimestamp = NsmfCommonUtil.time2Timestamp(queryTimestamp)
+                    .replace(NsmfParamConstant.SPACE, "T");
+                SlicingKpiReqInfo slicingKpiReqInfo = resourceMonitorServiceConvert
+                    .buildSlicingKpiReqInfo(serviceInfo, newTimestamp, kpiHours);
+                String jsonstr = JSON.toJSONString(slicingKpiReqInfo);
+                RequestBody requestBody = RequestBody.create(MediaType.parse("application/json"), jsonstr.toString());
+                Response<KpiTotalBandwidth> response = this.kpiSliceService.listTotalBandwidth(requestBody).execute();
+
+                if (response.isSuccessful()) {
+                    KpiTotalBandwidth kpiTotalBandwidth = response.body();
+                    logger.info("querySlicingTotalBandwidth: listTotalBandwidth reponse is:{}",
+                        gson.toJson(kpiTotalBandwidth).toString());
+                    ServiceTotalBandwidthInfo serviceTotalBandwidthInfo = new ServiceTotalBandwidthInfo();
+                    resourceMonitorServiceConvert
+                        .convertServiceTotalBandwidthInfo(serviceTotalBandwidthInfo, kpiTotalBandwidth);
+                    serviceTotalBandwidthInfoList.add(serviceTotalBandwidthInfo);
+                    resultMsg = "5G slicing total bandwidth query result.";
+                    resultHeader.setResult_code(NsmfCodeConstant.SUCCESS_CODE);
+                } else {
+                    logger.error(String
+                        .format("querySlicingTotalBandwidth: Can not get KpiUserNumber[code={}, message={}]",
+                            response.code(),
+                            response.message()));
+                    resultMsg = "5G slicing total bandwidth query failed!";
+                    resultHeader.setResult_code(NsmfCodeConstant.ERROR_CODE_UNKNOWN);
+                }
+            }
+        } catch (Exception e) {
+            resultMsg = "5G slicing total bandwidth query failed. Unknown exception occurred!";
+            resultHeader.setResult_code(NsmfCodeConstant.ERROR_CODE_UNKNOWN);
+            logger.error(e.getMessage());
+        }
+
+        logger.info(resultMsg);
+        logger.info("querySlicingTotalBandwidth: 5G slicing total bandwidth query has been finished.");
+        serviceTotalBandwidthList.setServiceTotalBandwidthInfoList(serviceTotalBandwidthInfoList);
+        resultHeader.setResult_message(resultMsg);
+        serviceResult.setResult_header(resultHeader);
+        serviceResult.setResult_body(serviceTotalBandwidthList);
+        return serviceResult;
+    }
+}
diff --git a/server/src/main/resources/slicing.properties b/server/src/main/resources/slicing.properties
new file mode 100644
index 00000000..e9363c27
--- /dev/null
+++ b/server/src/main/resources/slicing.properties
@@ -0,0 +1,22 @@
+##
+## Copyright (C) 2019 CMCC, Inc. and others. All rights reserved.
+##
+## 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.
+##/
+
+slicing.kpi.hours=4
+slicing.globalSubscriberId=5GCustomer
+slicing.serviceType=5G
+slicing.serviceInvariantUuid=e75698d9-925a-4cdd-a6c0-edacbe6a0b51
+slicing.serviceUuid=8ee5926d-720b-4bb2-86f9-d20e921c143b
+