ONAP-PAP-REST/src/main/java/org/onap/policy/pap/xacml/rest/controller/DictionaryController.java

   1 /*-
   2  * ============LICENSE_START=======================================================
   3  * ONAP-PAP-REST
   4  * ================================================================================
   5  * Copyright (C) 2017-2018 AT&T Intellectual Property. All rights reserved.
   6  * ================================================================================
   7  * Licensed under the Apache License, Version 2.0 (the "License");
   8  * you may not use this file except in compliance with the License.
   9  * You may obtain a copy of the License at
  10  *
  11  *      http://www.apache.org/licenses/LICENSE-2.0
  12  *
  13  * Unless required by applicable law or agreed to in writing, software
  14  * distributed under the License is distributed on an "AS IS" BASIS,
  15  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  16  * See the License for the specific language governing permissions and
  17  * limitations under the License.
  18  * ============LICENSE_END=========================================================
  19  */
  20
  21 package org.onap.policy.pap.xacml.rest.controller;
  22
  23 import java.io.IOException;
  24 import java.util.Date;
  25 import java.util.List;
  26
  27 import javax.servlet.http.HttpServletRequest;
  28 import javax.servlet.http.HttpServletResponse;
  29
  30 import org.apache.commons.logging.Log;
  31 import org.apache.commons.logging.LogFactory;
  32 import org.onap.policy.pap.xacml.rest.util.DictionaryUtils;
  33 import org.onap.policy.rest.dao.CommonClassDao;
  34 import org.onap.policy.rest.jpa.Attribute;
  35 import org.onap.policy.rest.jpa.OnapName;
  36 import org.onap.policy.rest.jpa.UserInfo;
  37 import org.springframework.beans.factory.annotation.Autowired;
  38 import org.springframework.http.MediaType;
  39 import org.springframework.stereotype.Controller;
  40 import org.springframework.web.bind.annotation.RequestMapping;
  41 import org.springframework.web.bind.annotation.RequestMethod;
  42 import org.springframework.web.servlet.ModelAndView;
  43
  44 import com.fasterxml.jackson.databind.DeserializationFeature;
  45 import com.fasterxml.jackson.databind.JsonNode;
  46 import com.fasterxml.jackson.databind.ObjectMapper;
  47
  48 @Controller
  49 public class DictionaryController {
  50
  51     private static final Log LOGGER     = LogFactory.getLog(DictionaryController.class);
  52
  53     private static CommonClassDao commonClassDao;
  54     private static String xacmlId = "xacmlId";
  55     private static String operation = "operation";
  56     private static String dictionaryFields ="dictionaryFields";
  57     private static String duplicateResponseString = "Duplicate";
  58     private static String onapName = "onapName";
  59     private static String attributeDatas = "attributeDictionaryDatas";
  60     private static String onapNameDatas = "onapNameDictionaryDatas";
  61
  62     @Autowired
  63     public DictionaryController(CommonClassDao commonClassDao){
  64         DictionaryController.commonClassDao = commonClassDao;
  65     }
  66
  67     public DictionaryController(){
  68         super();
  69     }
  70
  71     private DictionaryUtils getDictionaryUtilsInstance(){
  72         return DictionaryUtils.getDictionaryUtils();
  73     }
  74
  75     @RequestMapping(value={"/get_AttributeDatabyAttributeName"}, method={RequestMethod.GET} , produces=MediaType.APPLICATION_JSON_VALUE)
  76     public void getAttributeDictionaryEntityDatabyAttributeName(HttpServletResponse response){
  77         DictionaryUtils utils = getDictionaryUtilsInstance();
  78         utils.getDataByEntity(response, attributeDatas, xacmlId, Attribute.class);
  79     }
  80
  81     //Attribute Dictionary
  82     @RequestMapping(value="/get_AttributeData", method= RequestMethod.GET , produces=MediaType.APPLICATION_JSON_VALUE)
  83     public void getAttributeDictionaryEntityData(HttpServletResponse response){
  84         DictionaryUtils utils = getDictionaryUtilsInstance();
  85         utils.getData(response, attributeDatas, Attribute.class);
  86     }
  87
  88     @RequestMapping(value={"/attribute_dictionary/save_attribute"}, method={RequestMethod.POST})
  89     public ModelAndView saveAttributeDictionary(HttpServletRequest request, HttpServletResponse response) throws IOException{
  90         DictionaryUtils utils = getDictionaryUtilsInstance();
  91         try {
  92             boolean fromAPI = utils.isRequestFromAPI(request);
  93             ObjectMapper mapper = new ObjectMapper();
  94             mapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
  95             JsonNode root = mapper.readTree(request.getReader());
  96             Attribute attributeData = null;
  97             AttributeValues attributeValueData = null;
  98             String userId = null;
  99             if(fromAPI){
 100                 attributeData = mapper.readValue(root.get(dictionaryFields).toString(), Attribute.class);
 101                 attributeValueData = mapper.readValue(root.get(dictionaryFields).toString(), AttributeValues.class);
 102                 userId = "API";
 103             }else{
 104                 attributeData = mapper.readValue(root.get("attributeDictionaryData").toString(), Attribute.class);
 105                 attributeValueData = mapper.readValue(root.get("attributeDictionaryData").toString(), AttributeValues.class);
 106                 userId = root.get("userid").textValue();
 107             }
 108             UserInfo userInfo = utils.getUserInfo(userId);
 109             List<Object> duplicateData =  commonClassDao.checkDuplicateEntry(attributeData.getXacmlId(), xacmlId, Attribute.class);
 110             boolean duplicateflag = false;
 111             if(!duplicateData.isEmpty()){
 112                 Attribute data = (Attribute) duplicateData.get(0);
 113                 if(request.getParameter(operation) != null && "update".equals(request.getParameter(operation))){
 114                     attributeData.setId(data.getId());
 115                 }else if((request.getParameter(operation) != null && !"update".equals(request.getParameter(operation))) ||
 116                         (request.getParameter(operation) == null && (data.getId() != attributeData.getId()))){
 117                     duplicateflag = true;
 118                 }
 119             }
 120             if(attributeValueData.getUserDataTypeValues() != null && !attributeValueData.getUserDataTypeValues().isEmpty()){
 121                 attributeData.setAttributeValue(utils.appendKey(attributeValueData.getUserDataTypeValues(), "attributeValues", ","));
 122             }
 123
 124             if(attributeData.getDatatypeBean().getShortName() != null){
 125                 String datatype = attributeData.getDatatypeBean().getShortName();
 126                 attributeData.setDatatypeBean(utils.getDataType(datatype));
 127             }
 128
 129             String responseString = null;
 130             if(!duplicateflag){
 131                 attributeData.setUserModifiedBy(userInfo);
 132                 if(attributeData.getId() == 0){
 133                     attributeData.setCategoryBean(utils.getCategory());
 134                     attributeData.setUserCreatedBy(userInfo);
 135                     commonClassDao.save(attributeData);
 136                 }else{
 137                     attributeData.setModifiedDate(new Date());
 138                     commonClassDao.update(attributeData);
 139                 }
 140                 responseString = mapper.writeValueAsString(commonClassDao.getData(Attribute.class));
 141             }else{
 142                 responseString = duplicateResponseString;
 143             }
 144             if(fromAPI){
 145                 return utils.getResultForApi(responseString);
 146             }else{
 147                 utils.setResponseData(response, attributeDatas, responseString);
 148             }
 149         }catch (Exception e){
 150             utils.setErrorResponseData(response, e);
 151         }
 152         return null;
 153     }
 154
 155     @RequestMapping(value={"/attribute_dictionary/remove_attribute"}, method={RequestMethod.POST})
 156     public void removeAttributeDictionary(HttpServletRequest request, HttpServletResponse response)throws IOException {
 157         DictionaryUtils utils = getDictionaryUtilsInstance();
 158         utils.removeData(request, response, attributeDatas, Attribute.class);
 159     }
 160
 161     //OnapName Dictionary
 162     @RequestMapping(value={"/get_OnapNameDataByName"}, method={RequestMethod.GET} , produces=MediaType.APPLICATION_JSON_VALUE)
 163     public void getOnapNameDictionaryByNameEntityData(HttpServletResponse response){
 164         LOGGER.info("get_OnapNameDataByName is called");
 165         DictionaryUtils utils = getDictionaryUtilsInstance();
 166         utils.getDataByEntity(response, onapNameDatas, onapName, OnapName.class);
 167     }
 168
 169     @RequestMapping(value={"/get_OnapNameData"}, method={RequestMethod.GET} , produces=MediaType.APPLICATION_JSON_VALUE)
 170     public void getOnapNameDictionaryEntityData(HttpServletResponse response){
 171         DictionaryUtils utils = getDictionaryUtilsInstance();
 172         utils.getData(response, onapNameDatas, OnapName.class);
 173     }
 174
 175     @RequestMapping(value={"/onap_dictionary/save_onapName"}, method={RequestMethod.POST})
 176     public ModelAndView saveOnapDictionary(HttpServletRequest request, HttpServletResponse response) throws IOException{
 177         DictionaryUtils utils = getDictionaryUtilsInstance();
 178         try {
 179             boolean fromAPI = utils.isRequestFromAPI(request);
 180             ObjectMapper mapper = new ObjectMapper();
 181             mapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
 182             JsonNode root = mapper.readTree(request.getReader());
 183             OnapName onapData;
 184             String userId = null;
 185             if(fromAPI){
 186                 onapData = mapper.readValue(root.get(dictionaryFields).toString(), OnapName.class);
 187                 userId = "API";
 188             }else{
 189                 onapData = mapper.readValue(root.get("onapNameDictionaryData").toString(), OnapName.class);
 190                 userId = root.get("userid").textValue();
 191             }
 192             UserInfo userInfo = utils.getUserInfo(userId);
 193
 194             List<Object> duplicateData =  commonClassDao.checkDuplicateEntry(onapData.getOnapName(), onapName, OnapName.class);
 195             boolean duplicateflag = false;
 196             if(!duplicateData.isEmpty()){
 197                 OnapName data = (OnapName) duplicateData.get(0);
 198                 if(request.getParameter(operation) != null && "update".equals(request.getParameter(operation))){
 199                     onapData.setId(data.getId());
 200                 }else if((request.getParameter(operation) != null && !"update".equals(request.getParameter(operation))) ||
 201                         (request.getParameter(operation) == null && (data.getId() != onapData.getId()))){
 202                     duplicateflag = true;
 203                 }
 204             }
 205             String responseString = null;
 206             if(!duplicateflag){
 207                 onapData.setUserModifiedBy(userInfo);
 208                 if(onapData.getId() == 0){
 209                     onapData.setUserCreatedBy(userInfo);
 210                     commonClassDao.save(onapData);
 211                 }else{
 212                     onapData.setModifiedDate(new Date());
 213                     commonClassDao.update(onapData);
 214                 }
 215                 responseString = mapper.writeValueAsString(commonClassDao.getData(OnapName.class));
 216             }else{
 217                 responseString = duplicateResponseString;
 218             }
 219             if(fromAPI){
 220                 return utils.getResultForApi(responseString);
 221             }else{
 222                 utils.setResponseData(response, onapNameDatas, responseString);
 223             }
 224         }catch (Exception e){
 225             utils.setErrorResponseData(response, e);
 226         }
 227         return null;
 228     }
 229
 230     @RequestMapping(value={"/onap_dictionary/remove_onap"}, method={RequestMethod.POST})
 231     public void removeOnapDictionary(HttpServletRequest request, HttpServletResponse response) throws IOException {
 232         DictionaryUtils utils = getDictionaryUtilsInstance();
 233         utils.removeData(request, response, onapNameDatas, OnapName.class);
 234     }
 235 }
 236
 237 class AttributeValues{
 238     private List<Object> userDataTypeValues;
 239
 240     public List<Object> getUserDataTypeValues() {
 241         return userDataTypeValues;
 242     }
 243
 244     public void setUserDataTypeValues(List<Object> userDataTypeValues) {
 245         this.userDataTypeValues = userDataTypeValues;
 246     }
 247 }