2 * ============LICENSE_START=======================================================
\r
4 * ================================================================================
\r
5 * Copyright 2019 China Mobile
\r
6 *=================================================================================
\r
7 * Licensed under the Apache License, Version 2.0 (the "License");
\r
8 * you may not use this file except in compliance with the License.
\r
9 * You may obtain a copy of the License at
\r
11 * http://www.apache.org/licenses/LICENSE-2.0
\r
13 * Unless required by applicable law or agreed to in writing, software
\r
14 * distributed under the License is distributed on an "AS IS" BASIS,
\r
15 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
\r
16 * See the License for the specific language governing permissions and
\r
17 * limitations under the License.
\r
18 * ============LICENSE_END=========================================================
\r
21 package org.onap.datalake.feeder.service;
\r
23 import java.util.ArrayList;
\r
24 import java.util.List;
\r
25 import java.util.Optional;
\r
26 import java.util.Set;
\r
27 import java.util.HashSet;
\r
29 import org.onap.datalake.feeder.config.ApplicationConfiguration;
\r
30 import org.onap.datalake.feeder.domain.*;
\r
31 import org.onap.datalake.feeder.domain.Design;
\r
32 import org.onap.datalake.feeder.dto.DesignConfig;
\r
33 import org.onap.datalake.feeder.enumeration.DesignTypeEnum;
\r
34 import org.onap.datalake.feeder.repository.DbRepository;
\r
35 import org.onap.datalake.feeder.repository.DesignTypeRepository;
\r
36 import org.onap.datalake.feeder.repository.DesignRepository;
\r
37 import org.onap.datalake.feeder.repository.TopicNameRepository;
\r
38 import org.onap.datalake.feeder.util.HttpClientUtil;
\r
39 import org.slf4j.Logger;
\r
40 import org.slf4j.LoggerFactory;
\r
41 import org.springframework.beans.factory.annotation.Autowired;
\r
42 import org.springframework.stereotype.Service;
\r
45 * Service for portalDesigns
\r
47 * @author guochunmeng
\r
51 public class DesignService {
\r
53 private final Logger log = LoggerFactory.getLogger(this.getClass());
\r
55 static String POST_FLAG;
\r
58 private DesignRepository designRepository;
\r
61 private TopicNameRepository topicNameRepository;
\r
64 private DesignTypeRepository designTypeRepository;
\r
67 private ApplicationConfiguration applicationConfiguration;
\r
70 private DbRepository dbRepository;
\r
72 public Design fillDesignConfiguration(DesignConfig designConfig) {
\r
73 Design design = new Design();
\r
74 fillDesign(designConfig, design);
\r
78 public void fillDesignConfiguration(DesignConfig designConfig, Design design) {
\r
79 fillDesign(designConfig, design);
\r
82 private void fillDesign(DesignConfig designConfig, Design design) throws IllegalArgumentException {
\r
84 design.setId(designConfig.getId());
\r
85 design.setBody(designConfig.getBody());
\r
86 design.setName(designConfig.getName());
\r
87 design.setNote(designConfig.getNote());
\r
88 design.setSubmitted(designConfig.getSubmitted());
\r
90 if (designConfig.getTopicName() == null)
\r
91 throw new IllegalArgumentException("Can not find topicName in tpoic_name, topic name: " + designConfig.getTopicName());
\r
92 Optional<TopicName> topicName = topicNameRepository.findById(designConfig.getTopicName());
\r
93 if (!topicName.isPresent())
\r
94 throw new IllegalArgumentException("topicName is null " + designConfig.getTopicName());
\r
95 design.setTopicName(topicName.get());
\r
97 if (designConfig.getDesignType() == null)
\r
98 throw new IllegalArgumentException("Can not find designType in design_type, designType id " + designConfig.getDesignType());
\r
99 Optional<DesignType> designType = designTypeRepository.findById(designConfig.getDesignType());
\r
100 if (!designType.isPresent())
\r
101 throw new IllegalArgumentException("designType is null");
\r
102 design.setDesignType(designType.get());
\r
104 Set<Db> dbs = new HashSet<>();
\r
105 if (designConfig.getDbs() != null) {
\r
106 for (Integer item : designConfig.getDbs()) {
\r
107 Optional<Db> db = dbRepository.findById(item);
\r
108 if (db.isPresent()) {
\r
112 if (dbs.size() > 0)
\r
113 design.setDbs(dbs);
\r
115 design.getDbs().clear();
\r
116 design.setDbs(dbs);
\r
119 design.setDbs(dbs);
\r
123 public Design getDesign(Integer id) {
\r
125 Optional<Design> ret = designRepository.findById(id);
\r
126 return ret.isPresent() ? ret.get() : null;
\r
129 public List<DesignConfig> queryAllDesign() {
\r
131 List<Design> designList = null;
\r
132 List<DesignConfig> designConfigList = new ArrayList<>();
\r
133 designList = (List<Design>) designRepository.findAll();
\r
134 if (designList != null && designList.size() > 0) {
\r
135 log.info("DesignList is not null");
\r
136 for (Design design : designList) {
\r
137 designConfigList.add(design.getDesignConfig());
\r
140 return designConfigList;
\r
143 public boolean deploy(Design design) {
\r
144 DesignType designType = design.getDesignType();
\r
145 DesignTypeEnum designTypeEnum = DesignTypeEnum.valueOf(designType.getId());
\r
147 switch (designTypeEnum) {
\r
149 return deployKibanaImport(design);
\r
151 return postEsMappingTemplate(design, design.getTopicName().getId().toLowerCase());
\r
153 log.error("Not implemented {}", designTypeEnum);
\r
158 private boolean deployKibanaImport(Design design) throws RuntimeException {
\r
159 POST_FLAG = "KibanaDashboardImport";
\r
160 String requestBody = design.getBody();
\r
163 return HttpClientUtil.sendPostHttpClient(url, requestBody, POST_FLAG);
\r
167 private String kibanaImportUrl(String host, Integer port) {
\r
168 if (port == null) {
\r
169 port = applicationConfiguration.getKibanaPort();
\r
171 return "http://" + host + ":" + port + applicationConfiguration.getKibanaDashboardImportApi();
\r
175 * successed resp: { "acknowledged": true }
\r
178 * @param templateName
\r
181 public boolean postEsMappingTemplate(Design design, String templateName) throws RuntimeException {
\r
182 POST_FLAG = "ElasticsearchMappingTemplate";
\r
183 String requestBody = design.getBody();
\r
186 Set<Db> dbs = design.getDbs();
\r
187 //submit to each ES in dbs
\r
189 //return HttpClientUtil.sendPostHttpClient("http://"+dbService.getElasticsearch().getHost()+":9200/_template/"+templateName, requestBody, POST_FLAG);
\r