X-Git-Url: https://gerrit.onap.org/r/gitweb?p=policy%2Fengine.git;a=blobdiff_plain;f=ONAP-PAP-REST%2Fsrc%2Fmain%2Fjava%2Forg%2Fonap%2Fpolicy%2Fpap%2Fxacml%2Frest%2Futil%2FDictionaryUtils.java;h=ec27e0304f6ef159d128aa833cce7b06d4af92b2;hp=f852557859b0b52b4f23d8d11ba1673202c2bed2;hb=1e61676b77dd09659027b8984f050df7e8538526;hpb=2fc1a1510259202e8854beb8c04ef045bd28c79b diff --git a/ONAP-PAP-REST/src/main/java/org/onap/policy/pap/xacml/rest/util/DictionaryUtils.java b/ONAP-PAP-REST/src/main/java/org/onap/policy/pap/xacml/rest/util/DictionaryUtils.java index f85255785..ec27e0304 100644 --- a/ONAP-PAP-REST/src/main/java/org/onap/policy/pap/xacml/rest/util/DictionaryUtils.java +++ b/ONAP-PAP-REST/src/main/java/org/onap/policy/pap/xacml/rest/util/DictionaryUtils.java @@ -2,14 +2,14 @@ * ============LICENSE_START======================================================= * ONAP-PAP-REST * ================================================================================ - * Copyright (C) 2018 AT&T Intellectual Property. All rights reserved. + * Copyright (C) 2018-2019 AT&T Intellectual Property. 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. @@ -17,8 +17,13 @@ * limitations under the License. * ============LICENSE_END========================================================= */ + package org.onap.policy.pap.xacml.rest.util; +import com.fasterxml.jackson.databind.DeserializationFeature; +import com.fasterxml.jackson.databind.JsonNode; +import com.fasterxml.jackson.databind.ObjectMapper; + import java.io.IOException; import java.io.PrintWriter; import java.util.HashMap; @@ -41,14 +46,10 @@ import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.web.servlet.ModelAndView; -import com.fasterxml.jackson.databind.DeserializationFeature; -import com.fasterxml.jackson.databind.JsonNode; -import com.fasterxml.jackson.databind.ObjectMapper; - @Service public class DictionaryUtils { - private static final Log LOGGER = LogFactory.getLog(DictionaryUtils.class); + private static final Log LOGGER = LogFactory.getLog(DictionaryUtils.class); private static String apiflag = "apiflag"; private static String operation = "operation"; @@ -69,78 +70,78 @@ public class DictionaryUtils { } @Autowired - public DictionaryUtils(CommonClassDao commonClassDao){ + public DictionaryUtils(CommonClassDao commonClassDao) { DictionaryUtils.commonClassDao = commonClassDao; } - public DictionaryUtils(){ + public DictionaryUtils() { super(); } - public UserInfo getUserInfo(String loginId){ + public UserInfo getUserInfo(String loginId) { return (UserInfo) commonClassDao.getEntityItem(UserInfo.class, "userLoginId", loginId); } - public boolean isRequestFromAPI(HttpServletRequest request){ - return request.getParameter(apiflag)!=null && "api".equalsIgnoreCase(request.getParameter(apiflag)); + public boolean isRequestFromAPI(HttpServletRequest request) { + return request.getParameter(apiflag) != null && "api".equalsIgnoreCase(request.getParameter(apiflag)); } - public String appendKey(List objects, String key1, String appendValue){ + public String appendKey(List objects, String key1, String appendValue) { StringBuilder userValue = new StringBuilder(); int counter = 0; - for(Object attribute : objects){ - if(attribute instanceof LinkedHashMap){ + for (Object attribute : objects) { + if (attribute instanceof LinkedHashMap) { String key = ((LinkedHashMap) attribute).get(key1).toString(); - if(counter>0){ + if (counter > 0) { userValue.append(appendValue); } userValue.append(key); - counter ++; + counter++; } } return userValue.toString(); } - public String appendKeyValue(List objects, String append1, String append2){ + public String appendKeyValue(List objects, String append1, String append2) { StringBuilder header = new StringBuilder(); int counter = 0; - for(Object attribute : objects){ - if(attribute instanceof LinkedHashMap){ + for (Object attribute : objects) { + if (attribute instanceof LinkedHashMap) { String key = ((LinkedHashMap) attribute).get("option").toString(); String value = ((LinkedHashMap) attribute).get("number").toString(); - if(counter>0){ + if (counter > 0) { header.append(append1); } header.append(key).append(append2).append(value); - counter ++; + counter++; } } return header.toString(); } - public Datatype getDataType(String datatype){ + public Datatype getDataType(String datatype) { Datatype a = new Datatype(); - if("string".equalsIgnoreCase(datatype)){ + if ("string".equalsIgnoreCase(datatype)) { a.setId(26); - }else if("integer".equalsIgnoreCase(datatype)){ + } else if ("integer".equalsIgnoreCase(datatype)) { a.setId(12); - }else if("boolean".equalsIgnoreCase(datatype)){ + } else if ("boolean".equalsIgnoreCase(datatype)) { a.setId(18); - }else if("double".equalsIgnoreCase(datatype)){ + } else if ("double".equalsIgnoreCase(datatype)) { a.setId(25); - }else if("user".equalsIgnoreCase(datatype)){ + } else if ("user".equalsIgnoreCase(datatype)) { a.setId(29); } return a; } - public Category getCategory(){ + public Category getCategory() { return (Category) commonClassDao.getDataById(Category.class, "shortName", "resource").get(0); } - public ModelAndView getResultForApi(String inResponseString){ + public ModelAndView getResultForApi(String inResponseString) { String responseString = inResponseString; - if(responseString!=null && !duplicateResponseString.equals(responseString)){ + if (responseString != null && !duplicateResponseString.equals(responseString)) { responseString = "Success"; } ModelAndView result = new ModelAndView(); @@ -148,16 +149,16 @@ public class DictionaryUtils { return result; } - public void setResponseData(HttpServletResponse response, String key, String responseString) throws IOException{ + public void setResponseData(HttpServletResponse response, String key, String responseString) throws IOException { response.setCharacterEncoding(utf8); response.setContentType(applicationJsonContentType); PrintWriter out = response.getWriter(); - JSONObject j = new JSONObject("{"+key+":" + responseString + "}"); + JSONObject j = new JSONObject("{" + key + ":" + responseString + "}"); out.write(j.toString()); } - public void setErrorResponseData(HttpServletResponse response, Exception e) throws IOException{ + public void setErrorResponseData(HttpServletResponse response, Exception e) throws IOException { LOGGER.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + e); response.setCharacterEncoding(utf8); PrintWriter out = response.getWriter(); @@ -165,47 +166,48 @@ public class DictionaryUtils { } @SuppressWarnings("rawtypes") - public void getDataByEntity(HttpServletResponse response, String key, String value, Class className){ - try{ + public void getDataByEntity(HttpServletResponse response, String key, String value, Class className) { + try { Map model = new HashMap<>(); ObjectMapper mapper = new ObjectMapper(); model.put(key, mapper.writeValueAsString(commonClassDao.getDataByColumn(className, value))); JsonMessage msg = new JsonMessage(mapper.writeValueAsString(model)); JSONObject j = new JSONObject(msg); response.getWriter().write(j.toString()); - }catch(Exception e){ + } catch (Exception e) { LOGGER.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + e); } } @SuppressWarnings("rawtypes") - public void getData(HttpServletResponse response, String key, Class className){ - try{ + public void getData(HttpServletResponse response, String key, Class className) { + try { Map model = new HashMap<>(); ObjectMapper mapper = new ObjectMapper(); model.put(key, mapper.writeValueAsString(commonClassDao.getData(className))); JsonMessage msg = new JsonMessage(mapper.writeValueAsString(model)); JSONObject j = new JSONObject(msg); - response.addHeader("successMapKey", "success"); + response.addHeader("successMapKey", "success"); response.addHeader(operation, "getDictionary"); response.getWriter().write(j.toString()); - }catch(Exception e){ + } catch (Exception e) { LOGGER.error(XACMLErrorConstants.ERROR_PROCESS_FLOW + e); - response.setStatus(HttpServletResponse.SC_BAD_REQUEST); + response.setStatus(HttpServletResponse.SC_BAD_REQUEST); response.addHeader("error", "dictionaryDBQuery"); } } @SuppressWarnings("unchecked") - public void removeData(HttpServletRequest request, HttpServletResponse response, String key, @SuppressWarnings("rawtypes") Class className) throws IOException{ - try{ + public void removeData(HttpServletRequest request, HttpServletResponse response, String key, + @SuppressWarnings("rawtypes") Class className) throws IOException { + try { ObjectMapper mapper = new ObjectMapper(); mapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false); JsonNode root = mapper.readTree(request.getReader()); - commonClassDao.delete((Object)mapper.readValue(root.get("data").toString(), className)); + commonClassDao.delete(mapper.readValue(root.get("data").toString(), className)); String responseString = mapper.writeValueAsString(commonClassDao.getData(className)); setResponseData(response, key, responseString); - }catch(Exception e){ + } catch (Exception e) { setErrorResponseData(response, e); } }