1 files changed, 58 insertions, 0 deletions
diff --git a/src/main/java/org/onap/nbi/apis/serviceorder/workflow/CreateAAIServiceTypeManager.java b/src/main/java/org/onap/nbi/apis/serviceorder/workflow/CreateAAIServiceTypeManager.java
new file mode 100644
index 0000000..625a869
--- /dev/null
+++ b/src/main/java/org/onap/nbi/apis/serviceorder/workflow/CreateAAIServiceTypeManager.java
@@ -0,0 +1,58 @@
+package org.onap.nbi.apis.serviceorder.workflow;
+
+import org.onap.nbi.apis.serviceorder.MultiClient;
+import org.onap.nbi.apis.serviceorder.model.ActionType;
+import org.onap.nbi.apis.serviceorder.model.ServiceOrder;
+import org.onap.nbi.apis.serviceorder.model.ServiceOrderItem;
+import org.onap.nbi.apis.serviceorder.model.orchestrator.ServiceOrderInfo;
+import org.onap.nbi.apis.serviceorder.model.orchestrator.ServiceOrderItemInfo;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import java.util.LinkedHashMap;
+import java.util.List;
+
+@Service
+public class CreateAAIServiceTypeManager {
+
+    @Autowired
+    private MultiClient serviceOrderConsumerService;
+
+
+    public void createAAIServiceType(ServiceOrder serviceOrder, ServiceOrderInfo serviceOrderInfo) {
+
+        LinkedHashMap servicesInAaiForCustomer = serviceOrderConsumerService
+                .getServicesInAaiForCustomer(serviceOrderInfo.getSubscriberInfo().getGlobalSubscriberId());
+
+        for (ServiceOrderItem serviceOrderItem : serviceOrder.getOrderItem()) {
+            if (ActionType.ADD == serviceOrderItem.getAction()) {
+                ServiceOrderItemInfo serviceOrderItemInfo =
+                        serviceOrderInfo.getServiceOrderItemInfos().get(serviceOrderItem.getId());
+                String sdcServiceName = (String) serviceOrderItemInfo.getCatalogResponse().get("name");
+                if (!serviceNameExistsInAAI(servicesInAaiForCustomer, sdcServiceName)) {
+                    serviceOrderConsumerService.putServiceType(
+                            serviceOrderInfo.getSubscriberInfo().getGlobalSubscriberId(), sdcServiceName);
+                }
+            }
+        }
+
+    }
+
+    private boolean serviceNameExistsInAAI(LinkedHashMap servicesInAaiForCustomer, String sdcServiceName) {
+
+        if (servicesInAaiForCustomer != null && servicesInAaiForCustomer.get("service-subscription") != null) {
+            List<LinkedHashMap> servicesInAAI =
+                    (List<LinkedHashMap>) servicesInAaiForCustomer.get("service-subscription");
+            for (LinkedHashMap service : servicesInAAI) {
+                String serviceType = (String) service.get("service-type");
+                if (sdcServiceName.equalsIgnoreCase(serviceType)) {
+                    return true;
+                }
+
+            }
+        }
+
+        return false;
+
+    }
+
+}