X-Git-Url: https://gerrit.onap.org/r/gitweb?p=aai%2Fesr-server.git;a=blobdiff_plain;f=esr-mgr%2Fsrc%2Fmain%2Fjava%2Forg%2Fonap%2Faai%2Fesr%2Fwrapper%2FEmsManagerWrapper.java;h=8acc8257d265c518814e56ff6b21638f04397d1a;hp=07e510e5dd0f315c01673afc68c52fcf983011db;hb=769718b3e8b4e659299602701b575cf1b4b182c5;hpb=979f0fa70cbe576f8eed5e56db467b261a1919cf diff --git a/esr-mgr/src/main/java/org/onap/aai/esr/wrapper/EmsManagerWrapper.java b/esr-mgr/src/main/java/org/onap/aai/esr/wrapper/EmsManagerWrapper.java index 07e510e..8acc825 100644 --- a/esr-mgr/src/main/java/org/onap/aai/esr/wrapper/EmsManagerWrapper.java +++ b/esr-mgr/src/main/java/org/onap/aai/esr/wrapper/EmsManagerWrapper.java @@ -16,10 +16,13 @@ package org.onap.aai.esr.wrapper; import java.util.ArrayList; +import java.util.List; import javax.ws.rs.core.Response; import org.onap.aai.esr.entity.rest.EmsRegisterInfo; +import org.onap.aai.esr.exception.ExceptionUtil; +import org.onap.aai.esr.exception.ExtsysException; import org.onap.aai.esr.externalservice.aai.ExternalSystemProxy; import org.onap.aai.esr.util.EmsManagerUtil; import org.onap.aai.esr.entity.aai.EsrEmsDetail; @@ -56,10 +59,9 @@ public class EmsManagerWrapper { ExternalSystemProxy.registerEms(emsId, esrEmsDetail); result.setId(emsId); return Response.ok(result).build(); - } catch (Exception e) { - e.printStackTrace(); - LOG.error("Register EMS failed !" + e.getMessage()); - return Response.serverError().build(); + } catch (ExtsysException e) { + LOG.error("Register EMS failed !", e); + throw ExceptionUtil.buildExceptionResponse(e.getMessage()); } } @@ -71,15 +73,14 @@ public class EmsManagerWrapper { ExternalSystemProxy.registerEms(emsId, esrEmsDetail); result.setId(emsId); return Response.ok(result).build(); - } catch (Exception e) { - e.printStackTrace(); - LOG.error("Update VNFM failed !" + e.getMessage()); - return Response.serverError().build(); + } catch (ExtsysException e) { + LOG.error("Update VNFM failed !", e); + throw ExceptionUtil.buildExceptionResponse(e.getMessage()); } } public Response queryEmsList() { - ArrayList emsList = new ArrayList(); + List emsList = new ArrayList<>(); EsrEmsList esrEms = new EsrEmsList(); try { String esrEmsStr = ExternalSystemProxy.queryEmsList(); @@ -87,20 +88,19 @@ public class EmsManagerWrapper { LOG.info("Response from AAI by query EMS list: " + esrEms); emsList = getEmsDetailList(esrEms); return Response.ok(emsList).build(); - } catch (Exception e) { - e.printStackTrace(); - LOG.error("Query EMS list failed !"); - return Response.ok().build(); + } catch (ExtsysException e) { + LOG.error("Query EMS list failed !", e); + return Response.ok(emsList).build(); } } public Response queryEmsById(String emsId) { - EmsRegisterInfo ems = new EmsRegisterInfo(); + EmsRegisterInfo ems; ems = queryEmsDetail(emsId); if (ems != null) { return Response.ok(ems).build(); } else { - return Response.ok().build(); + return Response.ok(ems).build(); } } @@ -108,22 +108,17 @@ public class EmsManagerWrapper { EsrEmsDetail esrEmsDetail = new EsrEmsDetail(); esrEmsDetail = queryEsrEmsDetail(emsId); String resourceVersion = esrEmsDetail.getResourceVersion(); - if (resourceVersion != null) { - try { - ExternalSystemProxy.deleteEms(emsId, resourceVersion); - return Response.noContent().build(); - } catch (Exception e) { - e.printStackTrace(); - LOG.error("Delete EMS from A&AI failed! EMS ID: " + emsId + "resouce-version:" - + resourceVersion, e.getMessage()); - return Response.serverError().build(); - } - } else { - LOG.error("resouce-version is null ! Can not delete resouce from A&AI. "); + try { + ExternalSystemProxy.deleteEms(emsId, resourceVersion); return Response.noContent().build(); + } catch (ExtsysException e) { + LOG.error( + "Delete EMS from A&AI failed! EMS ID: " + emsId + "resouce-version:" + resourceVersion, + e); + throw ExceptionUtil.buildExceptionResponse(e.getMessage()); } } - + private EmsRegisterInfo queryEmsDetail(String emsId) { EmsRegisterInfo emsRegisterInfo = new EmsRegisterInfo(); EsrEmsDetail esrEmsDetail = new EsrEmsDetail(); @@ -132,16 +127,14 @@ public class EmsManagerWrapper { LOG.info("Response from AAI by query EMS: " + esrEmsStr); esrEmsDetail = new Gson().fromJson(esrEmsStr, EsrEmsDetail.class); emsRegisterInfo = emsManagerUtil.EsrEms2EmsRegisterInfo(esrEmsDetail); - return emsRegisterInfo; - } catch (Exception e) { - e.printStackTrace(); - LOG.error("Query EMS detail failed! EMS ID: " + emsId, e.getMessage()); - return null; + } catch (ExtsysException e) { + LOG.error("Query EMS detail failed! EMS ID: " + emsId, e); } + return emsRegisterInfo; } - private ArrayList getEmsDetailList(EsrEmsList esrEms) { - ArrayList emsInfoList = new ArrayList(); + private List getEmsDetailList(EsrEmsList esrEms) { + List emsInfoList = new ArrayList<>(); EmsRegisterInfo emsInfo = new EmsRegisterInfo(); for (int i = 0; i < esrEms.getEsrEms().size(); i++) { String emsId = esrEms.getEsrEms().get(i).getEmsId(); @@ -159,19 +152,18 @@ public class EmsManagerWrapper { String esrEmsStr = ExternalSystemProxy.queryEmsDetail(emsId); LOG.info("Response from AAI by query EMS: " + esrEmsStr); esrEmsDetail = new Gson().fromJson(esrEmsStr, EsrEmsDetail.class); - } catch (Exception e) { - e.printStackTrace(); - LOG.error("Query EMS detail failed! EMS ID: " + emsId, e.getMessage()); + } catch (ExtsysException e) { + LOG.error("Query EMS detail failed! EMS ID: " + emsId, e); } return esrEmsDetail; } private EsrEmsDetail getNewEsrEmsDetail(EmsRegisterInfo emsRegisterInfo, String emsId) { EsrEmsDetail esrEmsDetail = new EsrEmsDetail(); - ArrayList newEsrSysInfoList = new ArrayList(); + List newEsrSysInfoList = new ArrayList<>(); EsrSystemInfo newEsrSystemInfo = new EsrSystemInfo(); EsrEmsDetail oriEsrEmsDetail = new EsrEmsDetail(); - ArrayList oriEsrSysInfoList = new ArrayList(); + List oriEsrSysInfoList = new ArrayList<>(); EsrSystemInfo originalEsrSystemInfo = new EsrSystemInfo(); oriEsrEmsDetail = queryEsrEmsDetail(emsId);