import org.onap.policy.rest.jpa.OnapName;
import org.onap.policy.rest.jpa.PolicyEntity;
import org.onap.policy.rest.jpa.VarbindDictionary;
-import org.openecomp.portalsdk.core.controller.RestrictedBaseController;
+import org.onap.portalsdk.core.controller.RestrictedBaseController;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
faultSignatureDatas.add(faultDatas);
}
- String resultBody = "";
+ StringBuilder resultBody = new StringBuilder();
if(!policyJsonData.getConnecttriggerSignatures().isEmpty()){
- resultBody = resultBody + "(";
+ resultBody.append("(");
for(int i = policyJsonData.getConnecttriggerSignatures().size()-1; i>=0 ; i--){
String connectBody = connectTriggerSignature(i, policyJsonData.getConnecttriggerSignatures(), trapSignatureDatas.get(0));
- resultBody = resultBody + connectBody;
+ resultBody.append(connectBody);
}
- resultBody = resultBody + ")";
+ resultBody.append(resultBody + ")");
}else{
if(!trapSignatureDatas.isEmpty()){
- resultBody = callTrap("nill", trapSignatureDatas.get(0));
+ resultBody.append(callTrap("nill", trapSignatureDatas.get(0)));
}
}
ClosedLoopSignatures triggerSignatures = new ClosedLoopSignatures();
- triggerSignatures.setSignatures(resultBody);
+ triggerSignatures.setSignatures(resultBody.toString());
if(policyData.getClearTimeOut() != null){
triggerSignatures.setTimeWindow(Integer.parseInt(policyData.getClearTimeOut()));
triggerSignatures.setTrapMaxAge(Integer.parseInt(policyData.getTrapMaxAge()));
}
jsonBody.setTriggerSignaturesUsedForUI(uiTriggerSignatures);
jsonBody.setTriggerTimeWindowUsedForUI(Integer.parseInt(policyData.getClearTimeOut()));
- jsonBody.setTrapMaxAgeUsedForUI(Integer.parseInt(policyData.getTrapMaxAge()));
+ jsonBody.setTrapMaxAge(Integer.parseInt(policyData.getTrapMaxAge()));
}
jsonBody.setTriggerSignatures(triggerSignatures);
- String faultBody = "";
+ StringBuilder faultBody = new StringBuilder();
if(!policyJsonData.getConnectVerificationSignatures().isEmpty()){
- faultBody = faultBody + "(";
+ faultBody.append("(");
for(int i = policyJsonData.getConnectVerificationSignatures().size()-1; i>=0 ; i--){
String connectBody = connectTriggerSignature(i, policyJsonData.getConnectVerificationSignatures(), faultSignatureDatas.get(0));
- faultBody = faultBody + connectBody;
+ faultBody.append(connectBody);
}
- faultBody = faultBody + ")";
+ faultBody.append(")");
}else{
if(!faultSignatureDatas.isEmpty()){
- faultBody = callTrap("nill", faultSignatureDatas.get(0));
+ faultBody.append(callTrap("nill", faultSignatureDatas.get(0)));
}
}
ClosedLoopSignatures faultSignatures = new ClosedLoopSignatures();
- faultSignatures.setSignatures(faultBody);
+ faultSignatures.setSignatures(faultBody.toString());
if(policyData.getVerificationclearTimeOut() != null){
faultSignatures.setTimeWindow(Integer.parseInt(policyData.getVerificationclearTimeOut()));
ClosedLoopFaultTriggerUISignatures uifaultSignatures = new ClosedLoopFaultTriggerUISignatures();
}
jsonBody.setVerificationSignaturesUsedForUI(uifaultSignatures);
- jsonBody.setVerfificationTimeWindowUsedForUI(Integer.parseInt(policyData.getVerificationclearTimeOut()));
+ jsonBody.setVerificationTimeWindowUsedForUI(Integer.parseInt(policyData.getVerificationclearTimeOut()));
}
jsonBody.setVerificationSignatures(faultSignatures);
ObjectWriter om = new ObjectMapper().writer();
@SuppressWarnings("unchecked")
private String connectTriggerSignature(int index, ArrayList<Object> triggerSignatures, Object object) {
- String resultBody = "";
+ StringBuilder resultBody = new StringBuilder();
Map<String, String> connectTraps = (Map<String, String>) triggerSignatures.get(index);
try{
String notBox = "";
if(connectTraps.keySet().contains("notBox")){
notBox = connectTraps.get("notBox");
}
- resultBody = resultBody + "(" + notBox;
+ resultBody.append("(" + notBox);
}catch(NullPointerException e){
policyLogger.info("General error" , e);
- resultBody = resultBody + "(";
+ resultBody.append("(");
}
String connectTrap1 = connectTraps.get("connectTrap1");
if(connectTrap1.startsWith("Trap") || connectTrap1.startsWith("Fault")){
String trapBody = callTrap(connectTrap1, object);
if(trapBody!=null){
- resultBody = resultBody + trapBody;
+ resultBody.append(trapBody);
}
}else if(connectTrap1.startsWith("C")){
for(int i=0; i<= triggerSignatures.size(); i++){
Map<String,String> triggerSignature = (Map<String, String>) triggerSignatures.get(i);
if(triggerSignature.get("id").equals(connectTrap1)){
- resultBody = resultBody + "(";
+ resultBody.append("(");
String connectBody = connectTriggerSignature(i, triggerSignatures, object);
- resultBody = resultBody + connectBody + ")";
+ resultBody.append(connectBody + ")");
}else{
i++;
}
}
try{
String trapCount1 = connectTraps.get("trapCount1");
- resultBody = resultBody + ", Time = " + trapCount1 + ")";
+ resultBody.append(", Time = " + trapCount1 + ")");
}catch(NullPointerException e){
policyLogger.info("General error" , e);
}
try{
String operatorBox = connectTraps.get("operatorBox");
- resultBody = resultBody + operatorBox +"(";
+ resultBody.append(operatorBox +"(");
}catch (NullPointerException e){
policyLogger.info("General error" , e);
}
if(connectTrap2.startsWith("Trap") || connectTrap2.startsWith("Fault")){
String trapBody = callTrap(connectTrap2, object);
if(trapBody!=null){
- resultBody = resultBody + trapBody;
+ resultBody.append(trapBody);
}
}else if(connectTrap2.startsWith("C")){
for(int i=0; i<= triggerSignatures.size(); i++){
Map<String,String> triggerSignature = (Map<String, String>) triggerSignatures.get(i);
if(triggerSignature.get("id").equals(connectTrap2)){
- resultBody = resultBody + "(";
+ resultBody.append("(");
String connectBody = connectTriggerSignature(i, triggerSignatures, object);
- resultBody = resultBody + connectBody + ")";
+ resultBody.append(connectBody + ")");
}else{
i++;
}
}
try{
String trapCount2 = connectTraps.get("trapCount2");
- resultBody = resultBody + ", Time = " + trapCount2 + ")";
+ resultBody.append(", Time = " + trapCount2 + ")");
}catch(NullPointerException e){
policyLogger.info("General error" , e);
}
- return resultBody;
+ return resultBody.toString();
}
//connect traps data set to JSON Body as String
@SuppressWarnings({ "unchecked", "rawtypes" })
private String getUIConnectTraps(ArrayList<Object> connectTrapSignatures) {
- String resultBody = "";
+ StringBuilder resultBody = new StringBuilder();
String connectMainBody = "";
for(int j = 0; j < connectTrapSignatures.size(); j++){
Map<String, String> connectTraps = (Map<String, String>)connectTrapSignatures.get(j);
}
connectBody = notBox + "@!" + connectTrap1 + "@!" + trapCount1 + "@!" + operatorBox + "@!" + connectTrap2 + "@!" + trapCount2 + "#!?!";
}
- resultBody = resultBody + connectBody;
+ resultBody.append(connectBody);
}
connectMainBody = connectMainBody + resultBody;
return connectMainBody;
// get Trigger signature from JSON body
@SuppressWarnings({ "rawtypes", "unchecked" })
private String getUITriggerSignature(String trap, Object object2) {
- String triggerBody = "";
+ StringBuilder triggerBody = new StringBuilder();
TrapDatas trapDatas = (TrapDatas) object2;
ArrayList<Object> attributeList = new ArrayList<>();
// Read the Trap
}
for(int j = 0; j < attributeList.size(); j++){
- String signatureBody = "";
+ StringBuilder signatureBody = new StringBuilder();
ArrayList<Object> connectTraps = (ArrayList<Object>) attributeList.get(j);
for(int i =0 ; i < connectTraps.size(); i++){
String connectBody = "";
}
connectBody = notBox + "@!" + trigger1 + "@!" + operatorBox + "@!" + trigger2 + "#!";
}
- signatureBody = signatureBody + connectBody;
+ signatureBody.append(connectBody);
}
- triggerBody = triggerBody + signatureBody + "?!";
+ triggerBody.append(signatureBody + "?!");
}
- return triggerBody;
+ return triggerBody.toString();
}
public void prePopulateClosedLoopFaultPolicyData(PolicyRestAdapter policyAdapter, PolicyEntity entity) {
policyAdapter.setGuard(value);
}
if (attributeId.equals("TTLDate") && !value.contains("NA")){
- String newDate = convertDate(value, true);
+ PolicyController controller = new PolicyController();
+ String newDate = controller.convertDate(value);
policyAdapter.setTtlDate(newDate);
}
}
}
- private String convertDate(String dateTTL, boolean portalType) {
- String formateDate = null;
- String[] date;
- String[] parts;
-
- if (portalType){
- parts = dateTTL.split("-");
- formateDate = parts[2] + "-" + parts[1] + "-" + parts[0] + "T05:00:00.000Z";
- } else {
- date = dateTTL.split("T");
- parts = date[0].split("-");
- formateDate = parts[2] + "-" + parts[1] + "-" + parts[0];
- }
- return formateDate;
- }
-
private String readClosedLoopJSONFile(PolicyRestAdapter policyAdapter, PolicyEntity entity) {
ObjectMapper mapper = new ObjectMapper();
try {
closedLoopBody.setClosedLoopPolicyStatus("InActive");
}
policyAdapter.setJsonBodyData(closedLoopBody);
- if(closedLoopBody.getTrapMaxAgeUsedForUI() != null){
- policyAdapter.setTrapMaxAge(closedLoopBody.getTrapMaxAgeUsedForUI().toString());
+ if(closedLoopBody.getTrapMaxAge() != null){
+ policyAdapter.setTrapMaxAge(closedLoopBody.getTrapMaxAge().toString());
}
if(closedLoopBody.getTriggerTimeWindowUsedForUI() != null){
policyAdapter.setClearTimeOut(closedLoopBody.getTriggerTimeWindowUsedForUI().toString());
}
- if(closedLoopBody.getVerfificationTimeWindowUsedForUI() != null){
- policyAdapter.setVerificationclearTimeOut(closedLoopBody.getVerfificationTimeWindowUsedForUI().toString());
+ if(closedLoopBody.getVerificationTimeWindowUsedForUI() != null){
+ policyAdapter.setVerificationclearTimeOut(closedLoopBody.getVerificationTimeWindowUsedForUI().toString());
}
} catch (Exception e) {