8e620408bdec1c8b696cecbbf8814f8b3da8d972
[policy/engine.git] / ONAP-PAP-REST / src / main / java / org / onap / policy / pap / xacml / rest / controller / ActionPolicyDictionaryController.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.onap.policy.pap.xacml.rest.util.DictionaryUtils;
31 import org.onap.policy.rest.dao.CommonClassDao;
32 import org.onap.policy.rest.jpa.ActionPolicyDict;
33 import org.onap.policy.rest.jpa.UserInfo;
34 import org.springframework.beans.factory.annotation.Autowired;
35 import org.springframework.http.MediaType;
36 import org.springframework.stereotype.Controller;
37 import org.springframework.web.bind.annotation.RequestMapping;
38 import org.springframework.web.bind.annotation.RequestMethod;
39 import org.springframework.web.servlet.ModelAndView;
40
41 import com.fasterxml.jackson.databind.DeserializationFeature;
42 import com.fasterxml.jackson.databind.JsonNode;
43 import com.fasterxml.jackson.databind.ObjectMapper;
44
45 @Controller
46 public class ActionPolicyDictionaryController {
47
48     private static CommonClassDao commonClassDao;
49     private static String operation = "operation";
50     private static String attributeName = "attributeName";
51     private static String actionDatas = "actionPolicyDictionaryDatas";
52
53     @Autowired
54     public ActionPolicyDictionaryController(CommonClassDao commonClassDao){
55         ActionPolicyDictionaryController.commonClassDao = commonClassDao;
56     }
57
58     public void setCommonClassDao(CommonClassDao commonClassDao){
59         ActionPolicyDictionaryController.commonClassDao = commonClassDao;
60     }
61
62     public ActionPolicyDictionaryController(){
63         super();
64     }
65
66     private DictionaryUtils getDictionaryUtilsInstance(){
67         return DictionaryUtils.getDictionaryUtils();
68     }
69
70     @RequestMapping(value={"/get_ActionPolicyDictDataByName"}, method={RequestMethod.GET} , produces=MediaType.APPLICATION_JSON_VALUE)
71     public void getActionEntitybyName(HttpServletResponse response){
72         DictionaryUtils utils = getDictionaryUtilsInstance();
73         utils.getDataByEntity(response, actionDatas, attributeName, ActionPolicyDict.class);
74     }
75
76     @RequestMapping(value={"/get_ActionPolicyDictData"}, method={RequestMethod.GET} , produces=MediaType.APPLICATION_JSON_VALUE)
77     public void getActionPolicyDictionaryEntityData(HttpServletResponse response){
78         DictionaryUtils utils = getDictionaryUtilsInstance();
79         utils.getData(response, actionDatas, ActionPolicyDict.class);
80     }
81
82     @RequestMapping(value={"/action_dictionary/save_ActionDict"}, method={RequestMethod.POST})
83     public ModelAndView saveActionPolicyDictionary(HttpServletRequest request, HttpServletResponse response) throws IOException{
84         DictionaryUtils utils = getDictionaryUtilsInstance();
85         try {
86             boolean fromAPI = utils.isRequestFromAPI(request);
87             ObjectMapper mapper = new ObjectMapper();
88             mapper.configure(DeserializationFeature.FAIL_ON_UNKNOWN_PROPERTIES, false);
89             JsonNode root = mapper.readTree(request.getReader());
90             ActionPolicyDict actionPolicyDict = null;
91             ActionAdapter adapter = null;
92             String userId = null;
93             if(fromAPI){
94                 actionPolicyDict = mapper.readValue(root.get("dictionaryFields").toString(), ActionPolicyDict.class);
95                 adapter = mapper.readValue(root.get("dictionaryFields").toString(), ActionAdapter.class);
96                 userId = "API";
97             }else{
98                 actionPolicyDict = mapper.readValue(root.get("actionPolicyDictionaryData").toString(), ActionPolicyDict.class);
99                 adapter = mapper.readValue(root.get("actionPolicyDictionaryData").toString(), ActionAdapter.class);
100                 userId = root.get("userid").textValue();
101             }
102             UserInfo userInfo = utils.getUserInfo(userId);
103
104             List<Object> duplicateData =  commonClassDao.checkDuplicateEntry(actionPolicyDict.getAttributeName(), attributeName, ActionPolicyDict.class);
105             boolean duplicateflag = false;
106             if(!duplicateData.isEmpty()){
107                 ActionPolicyDict data = (ActionPolicyDict) duplicateData.get(0);
108                 if(request.getParameter(operation) != null && "update".equals(request.getParameter(operation))){
109                     actionPolicyDict.setId(data.getId());
110                 }else if((request.getParameter(operation) != null && !"update".equals(request.getParameter(operation))) ||
111                         (request.getParameter(operation) == null && (data.getId() != actionPolicyDict.getId()))){
112                     duplicateflag = true;
113                 }
114             }
115             actionPolicyDict.setHeader(utils.appendKeyValue(adapter.getHeaders(), ":", "="));
116
117             String responseString = null;
118             if(!duplicateflag){
119                 actionPolicyDict.setUserModifiedBy(userInfo);
120                 if(actionPolicyDict.getId() == 0){
121                     actionPolicyDict.setUserCreatedBy(userInfo);
122                     commonClassDao.save(actionPolicyDict);
123                 }else{
124                     actionPolicyDict.setModifiedDate(new Date());
125                     commonClassDao.update(actionPolicyDict);
126                 }
127                 responseString = mapper.writeValueAsString(commonClassDao.getData(ActionPolicyDict.class));
128             }else{
129                 responseString = "Duplicate";
130             }
131             if(fromAPI){
132                 return utils.getResultForApi(responseString);
133             }else{
134                 utils.setResponseData(response, actionDatas, responseString);
135             }
136         }catch(Exception e){
137             utils.setErrorResponseData(response, e);
138         }
139         return null;
140     }
141
142     @RequestMapping(value={"/action_dictionary/remove_actionPolicyDict"}, method={RequestMethod.POST})
143     public void removeActionPolicyDictionary(HttpServletRequest request, HttpServletResponse response) throws IOException {
144         DictionaryUtils utils = getDictionaryUtilsInstance();
145         utils.removeData(request, response, actionDatas, ActionPolicyDict.class);
146     }
147 }
148
149 class ActionAdapter{
150     private List<Object> headers;
151
152     public List<Object> getHeaders() {
153         return headers;
154     }
155
156     public void setHeaders(List<Object> headers) {
157         this.headers = headers;
158     }
159 }