Merge "ONAP code change for log files consolidation"
[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 }