-/*\r
- * ============LICENSE_START=======================================================\r
- * ONAP : DataLake\r
- * ================================================================================\r
- * Copyright 2019 China Mobile\r
- *=================================================================================\r
- * Licensed under the Apache License, Version 2.0 (the "License");\r
- * you may not use this file except in compliance with the License.\r
- * You may obtain a copy of the License at\r
- *\r
- * http://www.apache.org/licenses/LICENSE-2.0\r
- *\r
- * Unless required by applicable law or agreed to in writing, software\r
- * distributed under the License is distributed on an "AS IS" BASIS,\r
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.\r
- * See the License for the specific language governing permissions and\r
- * limitations under the License.\r
- * ============LICENSE_END=========================================================\r
- */\r
-\r
-package org.onap.datalake.feeder.service;\r
-\r
-import java.util.ArrayList;\r
-import java.util.List;\r
-import java.util.Optional;\r
-import java.util.Set;\r
-import java.util.HashSet;\r
-import java.util.Map;\r
-import java.util.HashMap;\r
-import java.util.Iterator;\r
-\r
-import org.onap.datalake.feeder.config.ApplicationConfiguration;\r
-import org.onap.datalake.feeder.domain.*;\r
-import org.onap.datalake.feeder.domain.Design;\r
-import org.onap.datalake.feeder.dto.DesignConfig;\r
-import org.onap.datalake.feeder.enumeration.DesignTypeEnum;\r
-import org.onap.datalake.feeder.repository.DbRepository;\r
-import org.onap.datalake.feeder.repository.DesignTypeRepository;\r
-import org.onap.datalake.feeder.repository.DesignRepository;\r
-import org.onap.datalake.feeder.repository.TopicNameRepository;\r
-import org.onap.datalake.feeder.util.HttpClientUtil;\r
-import org.slf4j.Logger;\r
-import org.slf4j.LoggerFactory;\r
-import org.springframework.beans.factory.annotation.Autowired;\r
-import org.springframework.stereotype.Service;\r
-\r
-/**\r
- * Service for portalDesigns\r
- *\r
- * @author guochunmeng\r
- */\r
-\r
-@Service\r
-public class DesignService {\r
-\r
- private final Logger log = LoggerFactory.getLogger(this.getClass());\r
-\r
- private static String POST_FLAG;\r
-\r
- private static String URL_FlAG;\r
-\r
- @Autowired\r
- private DesignRepository designRepository;\r
-\r
- @Autowired\r
- private TopicNameRepository topicNameRepository;\r
-\r
- @Autowired\r
- private DesignTypeRepository designTypeRepository;\r
-\r
- @Autowired\r
- private ApplicationConfiguration applicationConfiguration;\r
-\r
- @Autowired\r
- private DbRepository dbRepository;\r
-\r
- public Design fillDesignConfiguration(DesignConfig designConfig) {\r
- Design design = new Design();\r
- fillDesign(designConfig, design);\r
- return design;\r
- }\r
-\r
- public void fillDesignConfiguration(DesignConfig designConfig, Design design) {\r
- fillDesign(designConfig, design);\r
- }\r
-\r
- private void fillDesign(DesignConfig designConfig, Design design) throws IllegalArgumentException {\r
-\r
- design.setId(designConfig.getId());\r
- design.setBody(designConfig.getBody());\r
- design.setName(designConfig.getName());\r
- design.setNote(designConfig.getNote());\r
- design.setSubmitted(designConfig.getSubmitted());\r
-\r
- if (designConfig.getTopicName() == null)\r
- throw new IllegalArgumentException("Can not find topicName in tpoic_name, topic name: " + designConfig.getTopicName());\r
- Optional<TopicName> topicName = topicNameRepository.findById(designConfig.getTopicName());\r
- if (!topicName.isPresent())\r
- throw new IllegalArgumentException("topicName is null " + designConfig.getTopicName());\r
- design.setTopicName(topicName.get());\r
-\r
- if (designConfig.getDesignType() == null)\r
- throw new IllegalArgumentException("Can not find designType in design_type, designType id " + designConfig.getDesignType());\r
- Optional<DesignType> designType = designTypeRepository.findById(designConfig.getDesignType());\r
- if (!designType.isPresent())\r
- throw new IllegalArgumentException("designType is null");\r
- design.setDesignType(designType.get());\r
-\r
- Set<Db> dbs = new HashSet<>();\r
- if (designConfig.getDbs() != null) {\r
- for (Integer item : designConfig.getDbs()) {\r
- Optional<Db> db = dbRepository.findById(item);\r
- if (db.isPresent()) {\r
- dbs.add(db.get());\r
- }\r
- }\r
- if (!dbs.isEmpty())\r
- design.setDbs(dbs);\r
- else {\r
- design.getDbs().clear();\r
- design.setDbs(dbs);\r
- }\r
- } else {\r
- design.setDbs(dbs);\r
- }\r
- }\r
-\r
- public Design getDesign(Integer id) {\r
-\r
- Optional<Design> ret = designRepository.findById(id);\r
- return ret.isPresent() ? ret.get() : null;\r
- }\r
-\r
- public List<DesignConfig> queryAllDesign() {\r
-\r
- List<Design> designList = null;\r
- List<DesignConfig> designConfigList = new ArrayList<>();\r
- designList = (List<Design>) designRepository.findAll();\r
- if (!designList.isEmpty()) {\r
- log.info("DesignList is not null");\r
- for (Design design : designList) {\r
- designConfigList.add(design.getDesignConfig());\r
- }\r
- }\r
- return designConfigList;\r
- }\r
-\r
- public Map<Integer, Boolean> deploy(Design design) {\r
- Map<Integer, Boolean> resultMap = null;\r
- DesignType designType = design.getDesignType();\r
- DesignTypeEnum designTypeEnum = DesignTypeEnum.valueOf(designType.getId());\r
-\r
- switch (designTypeEnum) {\r
- case KIBANA_DB:\r
- log.info("Deploy kibana dashboard");\r
- resultMap = deployKibanaDashboardImport(design);\r
- deploySave(resultMap, design);\r
- break;\r
- case ES_MAPPING:\r
- log.info("Deploy elasticsearch mapping template");\r
- resultMap = postEsMappingTemplate(design, design.getTopicName().getId().toLowerCase());\r
- deploySave(resultMap, design);\r
- break;\r
- default:\r
- log.error("Not implemented {}", designTypeEnum);\r
- break;\r
- }\r
- log.info("Response resultMap: " + resultMap);\r
- return resultMap;\r
- }\r
-\r
- private Map<Integer, Boolean> deployKibanaDashboardImport(Design design) {\r
- URL_FlAG = "Kibana";\r
- POST_FLAG = "KibanaDashboardImport";\r
- String requestBody = design.getBody();\r
- Set<Db> dbs = design.getDbs();\r
- Map<Integer, Boolean> deployKibanaMap = new HashMap<>();\r
-\r
- if (!dbs.isEmpty()) {\r
- Map<Integer, String> map = urlMap(dbs, URL_FlAG);\r
- log.info("Deploy kibana dashboard url map: " + map);\r
- if (!map.isEmpty()) {\r
- Iterator<Map.Entry<Integer, String>> it = map.entrySet().iterator();\r
- while (it.hasNext()) {\r
- Map.Entry<Integer, String> entry = it.next();\r
- deployKibanaMap.put(entry.getKey(), HttpClientUtil.sendHttpClientPost(entry.getValue(), requestBody, POST_FLAG, URL_FlAG));\r
- }\r
- }\r
- return deployKibanaMap;\r
- } else {\r
- return deployKibanaMap;\r
- }\r
- }\r
-\r
- /**\r
- * successed resp: { "acknowledged": true }\r
- * \r
- * @param design\r
- * @param templateName\r
- * @return flag\r
- */\r
- public Map<Integer, Boolean> postEsMappingTemplate(Design design, String templateName) {\r
- URL_FlAG = "Elasticsearch";\r
- POST_FLAG = "ElasticsearchMappingTemplate";\r
- String requestBody = design.getBody();\r
- Set<Db> dbs = design.getDbs();\r
- Map<Integer, Boolean> deployEsMap = new HashMap<>();\r
-\r
- if (!dbs.isEmpty()) {\r
- Map<Integer, String> map = urlMap(dbs, URL_FlAG);\r
- log.info("Deploy elasticsearch url map: " + map);\r
- if (!map.isEmpty()) {\r
- Iterator<Map.Entry<Integer, String>> it = map.entrySet().iterator();\r
- while (it.hasNext()) {\r
- Map.Entry<Integer, String> entry = it.next();\r
- deployEsMap.put(entry.getKey(), HttpClientUtil.sendHttpClientPost(entry.getValue()+templateName, requestBody, POST_FLAG, URL_FlAG));\r
- }\r
- }\r
- return deployEsMap;\r
- } else {\r
- return deployEsMap;\r
- }\r
- }\r
-\r
- private Map<Integer, String> urlMap (Set<Db> dbs, String flag) {\r
- Map<Integer, String> map = new HashMap<>();\r
- for (Db item : dbs) {\r
- if (item.isEnabled()) {\r
- map.put(item.getId(), httpRequestUrl(item.getHost(), item.getPort(), flag));\r
- }\r
- }\r
- return map;\r
- }\r
-\r
- private String httpRequestUrl(String host, Integer port, String urlFlag) {\r
- String url = "";\r
- switch (urlFlag) {\r
- case "Kibana":\r
- if (port == null) {\r
- port = applicationConfiguration.getKibanaPort();\r
- }\r
- url = "http://" + host + ":" + port + applicationConfiguration.getKibanaDashboardImportApi();\r
- log.info("Kibana url: " + url);\r
- break;\r
- case "Elasticsearch":\r
- if (port == null) {\r
- port = applicationConfiguration.getEsPort();\r
- }\r
- url = "http://" + host + ":" + port + applicationConfiguration.getEsTemplateMappingApi();\r
- log.info("Elasticsearch url: " + url);\r
- break;\r
- default:\r
- break;\r
- }\r
- return url;\r
- }\r
-\r
- private void deploySave(Map<Integer, Boolean> map, Design design) {\r
- if (!map.isEmpty()) {\r
- Iterator<Map.Entry<Integer, Boolean>> it = map.entrySet().iterator();\r
- while (it.hasNext()) {\r
- Map.Entry<Integer, Boolean> entry = it.next();\r
- if (entry.getValue()) {\r
- design.setSubmitted(true);\r
- designRepository.save(design);\r
- log.info("Status was modified");\r
- }\r
- }\r
- }\r
- }\r
-\r
-}\r
+/*
+ * ============LICENSE_START=======================================================
+ * ONAP : DataLake
+ * ================================================================================
+ * Copyright 2019 China Mobile
+ *=================================================================================
+ * 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.
+ * ============LICENSE_END=========================================================
+ */
+
+package org.onap.datalake.feeder.service;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Optional;
+import java.util.Set;
+import java.util.HashSet;
+import java.util.Map;
+import java.util.HashMap;
+import java.util.Iterator;
+
+import org.onap.datalake.feeder.config.ApplicationConfiguration;
+import org.onap.datalake.feeder.domain.*;
+import org.onap.datalake.feeder.domain.Design;
+import org.onap.datalake.feeder.dto.DesignConfig;
+import org.onap.datalake.feeder.enumeration.DesignTypeEnum;
+import org.onap.datalake.feeder.repository.DbRepository;
+import org.onap.datalake.feeder.repository.DesignTypeRepository;
+import org.onap.datalake.feeder.repository.DesignRepository;
+import org.onap.datalake.feeder.repository.TopicNameRepository;
+import org.onap.datalake.feeder.util.HttpClientUtil;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+/**
+ * Service for portalDesigns
+ *
+ * @author guochunmeng
+ */
+
+@Service
+public class DesignService {
+
+ private final Logger log = LoggerFactory.getLogger(this.getClass());
+
+ private static final String ELASTIC_SEARCH = "Elasticsearch";
+ private static final String KIBANA = "Kibana";
+
+ @Autowired
+ private DesignRepository designRepository;
+
+ @Autowired
+ private TopicNameRepository topicNameRepository;
+
+ @Autowired
+ private DesignTypeRepository designTypeRepository;
+
+ @Autowired
+ private ApplicationConfiguration applicationConfiguration;
+
+ @Autowired
+ private DbRepository dbRepository;
+
+ public Design fillDesignConfiguration(DesignConfig designConfig) {
+ Design design = new Design();
+ fillDesign(designConfig, design);
+ return design;
+ }
+
+ public void fillDesignConfiguration(DesignConfig designConfig, Design design) {
+ fillDesign(designConfig, design);
+ }
+
+ private void fillDesign(DesignConfig designConfig, Design design) throws IllegalArgumentException {
+ design.setId(designConfig.getId());
+ design.setBody(designConfig.getBody());
+ design.setName(designConfig.getName());
+ design.setNote(designConfig.getNote());
+ design.setSubmitted(designConfig.getSubmitted());
+
+ if (designConfig.getTopicName() == null)
+ throw new IllegalArgumentException("Can not find topicName in tpoic_name, topic name: " + designConfig.getTopicName());
+ Optional<TopicName> topicName = topicNameRepository.findById(designConfig.getTopicName());
+ if (!topicName.isPresent())
+ throw new IllegalArgumentException("topicName is null " + designConfig.getTopicName());
+ design.setTopicName(topicName.get());
+
+ if (designConfig.getDesignType() == null)
+ throw new IllegalArgumentException("Can not find designType in design_type, designType id " + designConfig.getDesignType());
+ Optional<DesignType> designType = designTypeRepository.findById(designConfig.getDesignType());
+ if (!designType.isPresent())
+ throw new IllegalArgumentException("designType is null");
+ design.setDesignType(designType.get());
+
+ Set<Db> dbs = new HashSet<>();
+ if (designConfig.getDbs() != null) {
+ for (Integer item : designConfig.getDbs()) {
+ Optional<Db> db = dbRepository.findById(item);
+ if (db.isPresent()) {
+ dbs.add(db.get());
+ }
+ }
+ if (!dbs.isEmpty())
+ design.setDbs(dbs);
+ else {
+ design.getDbs().clear();
+ design.setDbs(dbs);
+ }
+ } else {
+ design.setDbs(dbs);
+ }
+ }
+
+ public Design getDesign(Integer id) {
+
+ Optional<Design> ret = designRepository.findById(id);
+ return ret.isPresent() ? ret.get() : null;
+ }
+
+ public List<DesignConfig> queryAllDesign() {
+
+ List<Design> designList = null;
+ List<DesignConfig> designConfigList = new ArrayList<>();
+ designList = (List<Design>) designRepository.findAll();
+ if (!designList.isEmpty()) {
+ log.info("DesignList is not null");
+ for (Design design : designList) {
+ designConfigList.add(design.getDesignConfig());
+ }
+ }
+ return designConfigList;
+ }
+
+ public Map<Integer, Boolean> deploy(Design design) {
+ Map<Integer, Boolean> resultMap = null;
+ DesignType designType = design.getDesignType();
+ DesignTypeEnum designTypeEnum = DesignTypeEnum.valueOf(designType.getId());
+
+ switch (designTypeEnum) {
+ case KIBANA_DB:
+ log.info("Deploy kibana dashboard");
+ resultMap = deployKibanaDashboardImport(design);
+ deploySave(resultMap, design);
+ break;
+ case ES_MAPPING:
+ log.info("Deploy elasticsearch mapping template");
+ resultMap = postEsMappingTemplate(design, design.getTopicName().getId().toLowerCase());
+ deploySave(resultMap, design);
+ break;
+ default:
+ log.error("Not implemented {}", designTypeEnum);
+ break;
+ }
+ log.info("Response resultMap: " + resultMap);
+ return resultMap;
+ }
+
+ private Map<Integer, Boolean> deployKibanaDashboardImport(Design design) {
+ String POST_FLAG = "KibanaDashboardImport";
+ String URL_FlAG = KIBANA;
+
+ String requestBody = design.getBody();
+ Set<Db> dbs = design.getDbs();
+ Map<Integer, Boolean> deployKibanaMap = new HashMap<>();
+
+ if (!dbs.isEmpty()) {
+ Map<Integer, String> map = urlMap(dbs, URL_FlAG);
+ log.info("Deploy kibana dashboard url map: " + map);
+ if (!map.isEmpty()) {
+ for (Map.Entry<Integer, String> entry : map.entrySet()) {
+ deployKibanaMap.put(entry.getKey(), HttpClientUtil.sendHttpClientPost(entry.getValue(), requestBody, POST_FLAG, URL_FlAG));
+ }
+ }
+ return deployKibanaMap;
+ } else {
+ return deployKibanaMap;
+ }
+ }
+
+ /**
+ * successed resp: { "acknowledged": true }
+ *
+ * @param design
+ * @param templateName
+ * @return flag
+ */
+ private Map<Integer, Boolean> postEsMappingTemplate(Design design, String templateName) {
+ String URL_FlAG = ELASTIC_SEARCH;
+ String POST_FLAG = "ElasticsearchMappingTemplate";
+
+ String requestBody = design.getBody();
+ Set<Db> dbs = design.getDbs();
+ Map<Integer, Boolean> deployEsMap = new HashMap<>();
+
+ if (!dbs.isEmpty()) {
+ Map<Integer, String> map = urlMap(dbs, URL_FlAG);
+ log.info("Deploy elasticsearch url map: " + map);
+ if (!map.isEmpty()) {
+ for (Map.Entry<Integer, String> entry : map.entrySet()) {
+ deployEsMap.put(entry.getKey(), HttpClientUtil.sendHttpClientPost(entry.getValue() + templateName, requestBody, POST_FLAG, URL_FlAG));
+ }
+ }
+ return deployEsMap;
+ } else {
+ return deployEsMap;
+ }
+ }
+
+ private Map<Integer, String> urlMap (Set<Db> dbs, String flag) {
+ Map<Integer, String> map = new HashMap<>();
+ for (Db item : dbs) {
+ if (item.isEnabled()) {
+ map.put(item.getId(), httpRequestUrl(item.getHost(), item.getPort(), flag));
+ }
+ }
+ return map;
+ }
+
+ private String httpRequestUrl(String host, Integer port, String urlFlag) {
+ String url = "";
+ switch (urlFlag) {
+ case KIBANA:
+ if (port == null) {
+ port = applicationConfiguration.getKibanaPort();
+ }
+ url = "http://" + host + ":" + port + applicationConfiguration.getKibanaDashboardImportApi();
+ log.info("Kibana url: " + url);
+ break;
+ case ELASTIC_SEARCH:
+ if (port == null) {
+ port = applicationConfiguration.getEsPort();
+ }
+ url = "http://" + host + ":" + port + applicationConfiguration.getEsTemplateMappingApi();
+ log.info("Elasticsearch url: " + url);
+ break;
+ default:
+ break;
+ }
+ return url;
+ }
+
+ private void deploySave(Map<Integer, Boolean> map, Design design) {
+ if (!map.isEmpty()) {
+ for (Map.Entry<Integer, Boolean> entry : map.entrySet()) {
+ if (entry.getValue()) {
+ design.setSubmitted(true);
+ designRepository.save(design);
+ log.info("Status was modified");
+ }
+ }
+ }
+ }
+
+}
Code Review / dcaegen2 / services.git / commitdiff