X-Git-Url: https://gerrit.onap.org/r/gitweb?a=blobdiff_plain;f=esr-mgr%2Fsrc%2Fmain%2Fjava%2Forg%2Fonap%2Faai%2Fesr%2Fwrapper%2FVnfmManagerWrapper.java;h=c53a1c8f969c941e8e92edd8a95196958533209e;hb=90efb9e11e77ce4f0a58fccfd7488a432b989596;hp=30d4e3d0ad8ea4abfcb3ddd8926792e046873c38;hpb=567917ad3680d64f56568aee3d6c854e79f049ab;p=aai%2Fesr-server.git diff --git a/esr-mgr/src/main/java/org/onap/aai/esr/wrapper/VnfmManagerWrapper.java b/esr-mgr/src/main/java/org/onap/aai/esr/wrapper/VnfmManagerWrapper.java index 30d4e3d..c53a1c8 100644 --- a/esr-mgr/src/main/java/org/onap/aai/esr/wrapper/VnfmManagerWrapper.java +++ b/esr-mgr/src/main/java/org/onap/aai/esr/wrapper/VnfmManagerWrapper.java @@ -19,10 +19,13 @@ import java.util.ArrayList; import javax.ws.rs.core.Response; +import org.onap.aai.esr.entity.aai.EsrSystemInfo; import org.onap.aai.esr.entity.aai.EsrVnfmDetail; import org.onap.aai.esr.entity.aai.EsrVnfmList; import org.onap.aai.esr.entity.rest.CommonRegisterResponse; import org.onap.aai.esr.entity.rest.VnfmRegisterInfo; +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.VnfmManagerUtil; import org.slf4j.Logger; @@ -34,6 +37,8 @@ public class VnfmManagerWrapper { private static VnfmManagerWrapper vnfmManagerWrapper; private static final Logger LOG = LoggerFactory.getLogger(VnfmManagerWrapper.class); + private static VnfmManagerUtil vnfmManagerUtil = new VnfmManagerUtil(); + /** * get VnfmManagerWrapper instance. * @@ -49,22 +54,41 @@ public class VnfmManagerWrapper { public Response registerVnfm(VnfmRegisterInfo vnfm) { CommonRegisterResponse result = new CommonRegisterResponse(); EsrVnfmDetail esrVnfmDetail = new EsrVnfmDetail(); - esrVnfmDetail = VnfmManagerUtil.vnfmRegisterInfo2EsrVnfm(vnfm); + esrVnfmDetail = vnfmManagerUtil.vnfmRegisterInfo2EsrVnfm(vnfm); String vnfmId = esrVnfmDetail.getVnfmId(); try { ExternalSystemProxy.registerVnfm(vnfmId, esrVnfmDetail); result.setId(vnfmId); return Response.ok(result).build(); - } catch (Exception e) { - e.printStackTrace(); - LOG.error("Register VNFM failed !" + e.getMessage()); - return Response.serverError().build(); + } catch (ExtsysException e) { + LOG.error("Register VNFM failed !" , e); + throw ExceptionUtil.buildExceptionResponse(e.getMessage()); } } public Response updateVnfm(VnfmRegisterInfo vnfm, String vnfmId) { - // TODO - return Response.ok().build(); + CommonRegisterResponse result = new CommonRegisterResponse(); + EsrVnfmDetail esrVnfmDetail = new EsrVnfmDetail(); + EsrVnfmDetail originalEsrVnfmDetail = new EsrVnfmDetail(); + EsrSystemInfo originalEsrSystemInfo = new EsrSystemInfo(); + originalEsrVnfmDetail = queryEsrVnfmDetail(vnfmId); + esrVnfmDetail = vnfmManagerUtil.vnfmRegisterInfo2EsrVnfm(vnfm); + String resourceVersion = getResourceVersion(vnfmId); + esrVnfmDetail.setResourceVersion(resourceVersion); + esrVnfmDetail.setVnfmId(vnfmId); + originalEsrSystemInfo = originalEsrVnfmDetail.getEsrSystemInfoList().getEsrSystemInfo().get(0); + esrVnfmDetail.getEsrSystemInfoList().getEsrSystemInfo().get(0) + .setEsrSystemInfoId(originalEsrSystemInfo.getEsrSystemInfoId()); + esrVnfmDetail.getEsrSystemInfoList().getEsrSystemInfo().get(0) + .setResouceVersion(originalEsrSystemInfo.getResouceVersion()); + try { + ExternalSystemProxy.registerVnfm(vnfmId, esrVnfmDetail); + result.setId(vnfmId); + return Response.ok(result).build(); + } catch (ExtsysException e) { + LOG.error("Update VNFM failed !", e); + throw ExceptionUtil.buildExceptionResponse(e.getMessage()); + } } public Response queryVnfmList() { @@ -76,12 +100,10 @@ public class VnfmManagerWrapper { LOG.info("Response from AAI by query VNFM list: " + esrVnfm); vnfmList = getVnfmDetailList(esrVnfm); return Response.ok(vnfmList).build(); - } catch (Exception e) { - e.printStackTrace(); - LOG.error("Query VNFM list failed !"); - return Response.serverError().build(); + } catch (ExtsysException e) { + LOG.error("Query VNFM list failed !", e); + return Response.ok(vnfmList).build(); } - } public Response queryVnfmById(String vnfmId) { @@ -90,34 +112,20 @@ public class VnfmManagerWrapper { if (vnfm != null) { return Response.ok(vnfm).build(); } else { - return Response.serverError().build(); + return Response.ok(vnfm).build(); } } public Response delVnfm(String vnfmId) { - EsrVnfmDetail esrVnfmDetail = new EsrVnfmDetail(); + String resourceVersion = getResourceVersion(vnfmId); try { - String esrVnfmstr = ExternalSystemProxy.queryVnfmDetail(vnfmId); - LOG.info("Response from AAI by query VNFM: " + esrVnfmstr); - esrVnfmDetail = new Gson().fromJson(esrVnfmstr, EsrVnfmDetail.class); - } catch (Exception e) { - e.printStackTrace(); - LOG.error("Query VNFM detail failed! VNFM ID: " + vnfmId, e.getMessage()); - } - if (esrVnfmDetail != null && esrVnfmDetail.getResourceVersion() != null) { - String resourceVersion = esrVnfmDetail.getResourceVersion(); - try { - ExternalSystemProxy.deleteVnfm(vnfmId, resourceVersion); - return Response.ok().build(); - } catch (Exception e) { - e.printStackTrace(); - LOG.error("Delete VNFM from A&AI failed! VNFM ID: " + vnfmId + "resouce-version:" - + resourceVersion, e.getMessage()); - return Response.serverError().build(); - } - } else { - LOG.error("resouce-version is null ! Can not delete resouce from A&AI. "); - return Response.serverError().build(); + ExternalSystemProxy.deleteVnfm(vnfmId, resourceVersion); + return Response.noContent().build(); + } catch (ExtsysException e) { + LOG.error( + "Delete VNFM from A&AI failed! VNFM ID: " + vnfmId + "resouce-version:" + resourceVersion, + e); + throw ExceptionUtil.buildExceptionResponse(e.getMessage()); } } @@ -128,13 +136,11 @@ public class VnfmManagerWrapper { String esrVnfmstr = ExternalSystemProxy.queryVnfmDetail(vnfmId); LOG.info("Response from AAI by query VNFM: " + esrVnfmstr); esrVnfmDetail = new Gson().fromJson(esrVnfmstr, EsrVnfmDetail.class); - vnfm = VnfmManagerUtil.esrVnfm2VnfmRegisterInfo(esrVnfmDetail); - return vnfm; - } catch (Exception e) { - e.printStackTrace(); - LOG.error("Query VNFM detail failed! VNFM ID: " + vnfmId, e.getMessage()); - return null; + vnfm = vnfmManagerUtil.esrVnfm2VnfmRegisterInfo(esrVnfmDetail); + } catch (ExtsysException e) { + LOG.error("Query VNFM detail failed! VNFM ID: " + vnfmId, e); } + return vnfm; } private ArrayList getVnfmDetailList(EsrVnfmList esrVnfm) { @@ -149,4 +155,27 @@ public class VnfmManagerWrapper { } return vnfmInfoList; } + + private String getResourceVersion (String vnfmId) { + EsrVnfmDetail esrVnfmDetail = new EsrVnfmDetail(); + String resourceVersion = null; + esrVnfmDetail = queryEsrVnfmDetail(vnfmId); + if (esrVnfmDetail != null && esrVnfmDetail.getResourceVersion() != null) { + resourceVersion = esrVnfmDetail.getResourceVersion(); + } + return resourceVersion; + } + + private EsrVnfmDetail queryEsrVnfmDetail (String vnfmId) { + EsrVnfmDetail esrVnfmDetail = new EsrVnfmDetail(); + try { + String esrVnfmstr = ExternalSystemProxy.queryVnfmDetail(vnfmId); + LOG.info("Response from AAI by query VNFM: " + esrVnfmstr); + esrVnfmDetail = new Gson().fromJson(esrVnfmstr, EsrVnfmDetail.class); + } catch (ExtsysException e) { + LOG.error("Query VNFM detail failed! VNFM ID: " + vnfmId, e); + throw ExceptionUtil.buildExceptionResponse(e.getMessage()); + } + return esrVnfmDetail; + } }