Add processing code related to slice task management.

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

2 files changed, 328 insertions, 0 deletions

diff --git a/server/src/main/java/org/onap/usecaseui/server/service/csmf/SlicingService.java b/server/src/main/java/org/onap/usecaseui/server/service/csmf/SlicingService.java
new file mode 100644
index 00000000..c27dcdb1
--- /dev/null
+++ b/server/src/main/java/org/onap/usecaseui/server/service/csmf/SlicingService.java
@@ -0,0 +1,26 @@
+/*
+ * 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.csmf;
+
+import org.onap.usecaseui.server.bean.csmf.SlicingOrder;
+import org.onap.usecaseui.server.bean.nsmf.common.ServiceResult;
+
+public interface SlicingService {
+
+    public ServiceResult createSlicingService(SlicingOrder slicingOrder);
+
+    public ServiceResult querySlicingOrderList(String status, String pageNo, String pageSize);
+}
diff --git a/server/src/main/java/org/onap/usecaseui/server/service/csmf/impl/SlicingServiceImpl.java b/server/src/main/java/org/onap/usecaseui/server/service/csmf/impl/SlicingServiceImpl.java
new file mode 100644
index 00000000..f1301182
--- /dev/null
+++ b/server/src/main/java/org/onap/usecaseui/server/service/csmf/impl/SlicingServiceImpl.java
@@ -0,0 +1,302 @@
+/*
+ * Copyright (C) 2020 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.csmf.impl;
+
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.JSONArray;
+import com.alibaba.fastjson.JSONObject;
+import com.google.gson.Gson;
+import com.google.gson.reflect.TypeToken;
+import java.io.IOException;
+import java.io.InputStream;
+import java.lang.reflect.Type;
+import java.text.ParseException;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.Properties;
+import java.util.stream.Collectors;
+import javax.annotation.Resource;
+import okhttp3.MediaType;
+import okhttp3.RequestBody;
+import okhttp3.ResponseBody;
+import org.onap.usecaseui.server.bean.ServiceInstanceOperations;
+import org.onap.usecaseui.server.bean.csmf.CreateResponse;
+import org.onap.usecaseui.server.bean.csmf.CreationParameters;
+import org.onap.usecaseui.server.bean.csmf.CreationRequest;
+import org.onap.usecaseui.server.bean.csmf.CreationRequestInputs;
+import org.onap.usecaseui.server.bean.csmf.CreationService;
+import org.onap.usecaseui.server.bean.csmf.OrderInfo;
+import org.onap.usecaseui.server.bean.csmf.OrderList;
+import org.onap.usecaseui.server.bean.csmf.ServiceCreateResult;
+import org.onap.usecaseui.server.bean.csmf.SlicingOrder;
+import org.onap.usecaseui.server.bean.nsmf.common.PagedResult;
+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.resource.SlicingBusinessInfo;
+import org.onap.usecaseui.server.bean.nsmf.resource.SlicingBusinessList;
+import org.onap.usecaseui.server.constant.CommonConstant;
+import org.onap.usecaseui.server.constant.csmf.CsmfParamConstant;
+import org.onap.usecaseui.server.constant.nsmf.NsmfCodeConstant;
+import org.onap.usecaseui.server.constant.nsmf.NsmfParamConstant;
+import org.onap.usecaseui.server.service.csmf.SlicingService;
+import org.onap.usecaseui.server.service.lcm.ServiceLcmService;
+import org.onap.usecaseui.server.service.nsmf.impl.ResourceMonitorServiceImpl;
+import org.onap.usecaseui.server.service.slicingdomain.aai.AAISliceService;
+import org.onap.usecaseui.server.service.slicingdomain.aai.bean.AAIService;
+import org.onap.usecaseui.server.service.slicingdomain.aai.bean.AAIServiceInstance;
+import org.onap.usecaseui.server.service.slicingdomain.aai.bean.AAIServiceRsp;
+import org.onap.usecaseui.server.service.slicingdomain.so.SOSliceService;
+import org.onap.usecaseui.server.service.slicingdomain.so.bean.ActivateService;
+import org.onap.usecaseui.server.service.slicingdomain.so.bean.SOOperation;
+import org.onap.usecaseui.server.util.DateUtils;
+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("SlicingService")
+@org.springframework.context.annotation.Configuration
+@EnableAspectJAutoProxy
+public class SlicingServiceImpl implements SlicingService {
+
+    private final static Logger logger = LoggerFactory.getLogger(SlicingServiceImpl.class);
+
+    @Resource(name = "ServiceLcmService")
+    private ServiceLcmService serviceLcmService;
+
+    private AAISliceService aaiSliceService;
+
+    private SOSliceService soSliceService;
+
+    public SlicingServiceImpl() {
+        this(RestfulServices.create(AAISliceService.class), RestfulServices.create(SOSliceService.class));
+    }
+
+    public SlicingServiceImpl(AAISliceService aaiSliceService, SOSliceService soSliceService) {
+        this.aaiSliceService = aaiSliceService;
+        this.soSliceService = soSliceService;
+    }
+
+    @Override
+    public ServiceResult createSlicingService(SlicingOrder slicingOrder) {
+
+        ServiceCreateResult createResult = new ServiceCreateResult();
+        String resultCode;
+        String resultMsg;
+        Gson gson = new Gson();
+        ResultHeader resultHeader = new ResultHeader();
+        try {
+            // request bean for create slicing service
+            CreationRequestInputs requestInputs = new CreationRequestInputs();
+            requestInputs.setExpDataRateDL(slicingOrder.getSlicing_order_info().getExpDataRateDL());
+            requestInputs.setExpDataRateUL(slicingOrder.getSlicing_order_info().getExpDataRateUL());
+            requestInputs.setLatency(slicingOrder.getSlicing_order_info().getLatency());
+            requestInputs.setMaxNumberofUEs(slicingOrder.getSlicing_order_info().getMaxNumberofUEs());
+            requestInputs.setUemobilityLevel(slicingOrder.getSlicing_order_info().getUEMobilityLevel());
+            requestInputs.setResourceSharingLevel(slicingOrder.getSlicing_order_info().getResourceSharingLevel());
+            requestInputs.setCoverageAreaList(slicingOrder.getSlicing_order_info().getCoverageArea());
+            //use default value
+            requestInputs.setUseInterval("20");
+            CreationParameters parameters = new CreationParameters();
+            parameters.setRequestInputs(requestInputs);
+            CreationService creationService = new CreationService();
+            creationService.setName(slicingOrder.getSlicing_order_info().getName());
+            creationService.setDescription(CommonConstant.BLANK);
+            InputStream  inputStream = this.getClass().getClassLoader().getResourceAsStream("slicing.properties");
+            Properties environment = new Properties();
+            environment.load(inputStream);
+            creationService.setServiceInvariantUuid(environment.getProperty("slicing.serviceInvariantUuid"));
+            creationService.setServiceUuid(environment.getProperty("slicing.serviceUuid"));
+            creationService.setGlobalSubscriberId(environment.getProperty("slicing.globalSubscriberId"));
+            creationService.setServiceType(environment.getProperty("slicing.serviceType"));
+            creationService.setParameters(parameters);
+
+            CreationRequest creationRequest = new CreationRequest();
+            creationRequest.setService(creationService);
+
+            String jsonstr = JSON.toJSONString(creationRequest);
+            RequestBody requestBody = RequestBody.create(MediaType.parse("application/json"), jsonstr.toString());
+            Response<CreateResponse> updateResponse = soSliceService
+                .submitOrders(requestBody).execute();
+
+            if (updateResponse.isSuccessful()) {
+                CreateResponse createResponse = updateResponse.body();
+                logger.info("createSlicingService: submitOrders reponse is:{}",
+                    gson.toJson(updateResponse).toString());
+
+                // set create operation result
+                createResult.setService_id(createResponse.getService().getServiceId());
+                createResult.setOperation_id(createResponse.getService().getOperationId());
+
+                resultMsg = "5G slicing order created normally.";
+                resultHeader.setResult_code(NsmfCodeConstant.SUCCESS_CODE);
+            } else {
+                logger.error(String
+                    .format("createSlicingService: Can not submitOrders [code={}, message={}]", updateResponse.code(),
+                        updateResponse.message()));
+                resultMsg = "5G slicing order created failed.";
+                resultHeader.setResult_code(NsmfCodeConstant.ERROR_CODE_UNKNOWN);
+            }
+        } catch (Exception e) {
+            resultMsg = "5G slicing order created failed. Unknown exception occurred!";
+            resultHeader.setResult_code(NsmfCodeConstant.ERROR_CODE_UNKNOWN);
+            logger.error(e.getMessage());
+        }
+
+        logger.info(resultMsg);
+        logger.info("createSlicingService: 5G slicing order creation has been finished.");
+        resultHeader.setResult_message(resultMsg);
+        ServiceResult serviceResult = new ServiceResult(resultHeader, createResult);
+        return serviceResult;
+    }
+
+    @Override
+    public ServiceResult querySlicingOrderList(String status, String pageNo, String pageSize) {
+
+        ServiceResult serviceResult = new ServiceResult();
+        ResultHeader resultHeader = new ResultHeader();
+        List<OrderInfo> orderList = new ArrayList<OrderInfo>();
+        String resultMsg;
+
+        try {
+            // TODO
+            Response<JSONObject> response = this.aaiSliceService
+                .listOrders(NsmfParamConstant.CUSTOM_5G, NsmfParamConstant.SERVICE_TYPE_5G).execute();
+            if (response.isSuccessful()) {
+                logger.info("querySlicingOrderList: listService reponse is:{}", response.body());
+                Type type = new TypeToken<List<AAIServiceInstance>>() {
+                }.getType();
+
+                JSONArray array = response.body().getJSONArray("service-instance");
+                buildOrderList(orderList, array);
+
+                // return normal result code
+                resultMsg = "5G slicing order query result.";
+                resultHeader.setResult_code(NsmfCodeConstant.SUCCESS_CODE);
+            } else {
+                logger.error(String.format("querySlicingOrderList: Can not get listOrders[code={}, message={}]",
+                    response.code(),
+                    response.message()));
+                resultMsg = "\"5G slicing order query failed!";
+                if (response.code() == NsmfCodeConstant.RESOURCE_NOT_FOUND_CODE) {
+                    resultHeader.setResult_code(NsmfCodeConstant.SUCCESS_CODE);
+                } else {
+                    resultHeader.setResult_code(NsmfCodeConstant.ERROR_CODE_UNKNOWN);
+                }
+            }
+        } catch (
+            Exception e) {
+            resultMsg = "5G slicing order query failed. Unknown exception occurred!";
+            resultHeader.setResult_code(NsmfCodeConstant.ERROR_CODE_UNKNOWN);
+            logger.error(e.getMessage());
+        }
+
+        // Filter by status and paginate
+        List<Object> filterOrderList = new ArrayList<Object>();
+        if (!CsmfParamConstant.ALL.equals(status)) {
+            filterOrderList = orderList.stream().filter(a -> a.getOrder_status().equals(status))
+                .collect(Collectors.toList());
+        } else {
+            filterOrderList.addAll(orderList);
+        }
+        PagedResult pagedOrderList = NsmfCommonUtil
+            .getPagedList(filterOrderList, Integer.parseInt(pageNo), Integer.parseInt(pageSize));
+
+        // return API result for calling [Query Slicing Order List]
+        OrderList responseOrderList = new OrderList(orderList.size(), pagedOrderList.getPagedList());
+        addProgressToOrder(responseOrderList);
+        logger.info(resultMsg);
+        logger.info("querySlicingOrderList: 5G slicing order query has been finished.");
+        resultHeader.setResult_message(resultMsg);
+        serviceResult.setResult_header(resultHeader);
+        serviceResult.setResult_body(responseOrderList);
+        return serviceResult;
+    }
+
+    void buildOrderList(List<OrderInfo> orderList, JSONArray array) throws ParseException {
+        for (int i = 0; i < array.size(); i++) {
+            JSONObject object = array.getJSONObject(i);
+            OrderInfo order = new OrderInfo();
+            order.setOrder_id(object.getString("service-instance-id"));
+            order.setOrder_name(object.getString("service-instance-name"));
+            order.setOrder_creation_time(NsmfCommonUtil.timestamp2Time(object.getString("created-at")));
+            order.setOrder_status(object.getString("service-type"));
+            order.setService_snssai(object.getString("environment-context"));
+            order.setOrder_status(object.getString("orchestration-status"));
+            orderList.add(order);
+        }
+    }
+
+    public void addProgressToOrder(OrderList responseOrderList)  {
+        if (responseOrderList.getSlicing_order_list() == null
+            || responseOrderList.getSlicing_order_list().size() == 0) {
+            logger.error(
+                "addProgressToOrder: responseOrderList.getSlicing_order_list() is null or responseOrderList.getSlicing_order_list() size is 0.");
+            return;
+        }
+
+        int i = 0;
+        for (OrderInfo orderInfo : responseOrderList.getSlicing_order_list()) {
+            i++;
+            orderInfo.setOrder_index(String.valueOf(i));
+            String businessId = orderInfo.getOrder_id();
+            ServiceInstanceOperations serviceInstanceOperations = serviceLcmService
+                .getServiceInstanceOperationById(businessId);
+            if (null == serviceInstanceOperations || serviceInstanceOperations.getOperationId() == null) {
+                logger.error(
+                    "addProgressToOrder: null == serviceInstanceOperations for businessId:{}.",
+                    businessId);
+                continue;
+            }
+            String operationId = serviceInstanceOperations.getOperationId();
+            Response<SOOperation> response = null;
+            try {
+                response = this.soSliceService.queryOperationProgress(businessId, operationId)
+                    .execute();
+                if (response.isSuccessful()) {
+                    SOOperation soOperation = response.body();
+                    Gson gson = new Gson();
+                    logger.info("addProgressToOrder: queryOperationProgress reponse is:{}",
+                        gson.toJson(soOperation).toString());
+                    if (soOperation == null || soOperation.getOperation() == null) {
+                        logger.error("addProgressToOrder: soOperation is null or getOperation() is null for businessId {}!", businessId);
+                        continue;
+                    }
+                    String operationResult = soOperation.getOperation().getResult();
+                    String operationType = soOperation.getOperation().getOperation();
+                    int progress = soOperation.getOperation().getProgress();
+                    logger.info("addProgressToOrder: operationResult is:{}, operationType is {}, progress is {}",
+                        operationResult, operationType, progress);
+                    if (operationResult.equals(NsmfCodeConstant.OPERATION_ERROR_STATUS)) {
+                        logger.error("addProgressToOrder: progress is ok, but operationResult is error for businessId {}!", businessId);
+                        continue;
+                    }
+                    orderInfo.setLast_operation_type(operationType);
+                    orderInfo.setLast_operation_progress(String.valueOf(progress));
+                }
+            } catch (IOException e) {
+                logger.error(e.getMessage());
+                logger.error("addProgressToOrder: catch an IOException for businessId {}!", businessId);
+                continue;
+            }
+        }
+    }
+}