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;
import org.onap.aai.esr.entity.rest.CommonRegisterResponse;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
-
import com.google.gson.Gson;
public class EmsManagerWrapper {
- private static EmsManagerWrapper emsManagerWrapper;
- private static final Logger LOG = LoggerFactory.getLogger(EmsManagerWrapper.class);
- private static EmsManagerUtil emsManagerUtil = new EmsManagerUtil();
+ private static EmsManagerWrapper emsManagerWrapper;
+ private static final Logger LOG = LoggerFactory.getLogger(EmsManagerWrapper.class);
+ private static EmsManagerUtil emsManagerUtil = new EmsManagerUtil();
- /**
- * get VnfmManagerWrapper instance.
- * @return ems manager wrapper instance
- */
- public static EmsManagerWrapper getInstance() {
- if (emsManagerWrapper == null) {
- emsManagerWrapper = new EmsManagerWrapper();
+ /**
+ * get VnfmManagerWrapper instance.
+ *
+ * @return ems manager wrapper instance
+ */
+ public static EmsManagerWrapper getInstance() {
+ if (emsManagerWrapper == null) {
+ emsManagerWrapper = new EmsManagerWrapper();
+ }
+ return emsManagerWrapper;
}
- return emsManagerWrapper;
- }
-
- public Response registerEms(EmsRegisterInfo emsRegisterInfo) {
- CommonRegisterResponse result = new CommonRegisterResponse();
- EsrEmsDetail esrEmsDetail = new EsrEmsDetail();
- esrEmsDetail = emsManagerUtil.emsRegisterInfo2EsrEms(emsRegisterInfo);
- String emsId = esrEmsDetail.getEmsId();
- try {
- 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();
+
+ public Response registerEms(EmsRegisterInfo emsRegisterInfo) {
+ CommonRegisterResponse result = new CommonRegisterResponse();
+ EsrEmsDetail esrEmsDetail = new EsrEmsDetail();
+ esrEmsDetail = emsManagerUtil.emsRegisterInfo2EsrEms(emsRegisterInfo);
+ String emsId = esrEmsDetail.getEmsId();
+ try {
+ ExternalSystemProxy.registerEms(emsId, esrEmsDetail);
+ result.setId(emsId);
+ return Response.ok(result).build();
+ } catch (ExtsysException e) {
+ LOG.error("Register EMS failed !", e);
+ throw ExceptionUtil.buildExceptionResponse(e.getMessage());
+ }
}
- }
- public Response updateEms(EmsRegisterInfo emsRegisterInfo, String emsId) {
- CommonRegisterResponse result = new CommonRegisterResponse();
- EsrEmsDetail esrEmsDetail = new EsrEmsDetail();
- esrEmsDetail = getNewEsrEmsDetail(emsRegisterInfo, emsId);
- try {
- 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();
+ public Response updateEms(EmsRegisterInfo emsRegisterInfo, String emsId) {
+ CommonRegisterResponse result = new CommonRegisterResponse();
+ EsrEmsDetail esrEmsDetail = new EsrEmsDetail();
+ esrEmsDetail = getNewEsrEmsDetail(emsRegisterInfo, emsId);
+ try {
+ ExternalSystemProxy.registerEms(emsId, esrEmsDetail);
+ result.setId(emsId);
+ return Response.ok(result).build();
+ } catch (ExtsysException e) {
+ LOG.error("Update VNFM failed !", e);
+ throw ExceptionUtil.buildExceptionResponse(e.getMessage());
+ }
}
- }
-
- public Response queryEmsList() {
- ArrayList<EmsRegisterInfo> emsList = new ArrayList<EmsRegisterInfo>();
- EsrEmsList esrEms = new EsrEmsList();
- try {
- String esrEmsStr = ExternalSystemProxy.queryEmsList();
- esrEms = new Gson().fromJson(esrEmsStr, EsrEmsList.class);
- 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(emsList).build();
+
+ public Response queryEmsList() {
+ List<EmsRegisterInfo> emsList = new ArrayList<>();
+ EsrEmsList esrEms = new EsrEmsList();
+ try {
+ String esrEmsStr = ExternalSystemProxy.queryEmsList();
+ esrEms = new Gson().fromJson(esrEmsStr, EsrEmsList.class);
+ LOG.info("Response from AAI by query EMS list: " + esrEms);
+ emsList = getEmsDetailList(esrEms);
+ return Response.ok(emsList).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();
- ems = queryEmsDetail(emsId);
- if (ems != null) {
- return Response.ok(ems).build();
- } else {
- return Response.ok(ems).build();
+
+ public Response queryEmsById(String emsId) {
+ EmsRegisterInfo ems = queryEmsDetail(emsId);
+ if (ems != null) {
+ return Response.ok(ems).build();
+ } else {
+ return Response.ok(ems).build();
+ }
}
- }
-
- public Response delEms(String emsId) {
- 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. ");
- return Response.serverError().build();
+
+ public Response delEms(String emsId) {
+ EsrEmsDetail esrEmsDetail = new EsrEmsDetail();
+ esrEmsDetail = queryEsrEmsDetail(emsId);
+ String resourceVersion = esrEmsDetail.getResourceVersion();
+ 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();
- try {
- String esrEmsStr = ExternalSystemProxy.queryEmsDetail(emsId);
- 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;
+
+ private EmsRegisterInfo queryEmsDetail(String emsId) {
+ EmsRegisterInfo emsRegisterInfo = new EmsRegisterInfo();
+ EsrEmsDetail esrEmsDetail = new EsrEmsDetail();
+ try {
+ String esrEmsStr = ExternalSystemProxy.queryEmsDetail(emsId);
+ LOG.info("Response from AAI by query EMS: " + esrEmsStr);
+ esrEmsDetail = new Gson().fromJson(esrEmsStr, EsrEmsDetail.class);
+ emsRegisterInfo = emsManagerUtil.EsrEms2EmsRegisterInfo(esrEmsDetail);
+ } catch (ExtsysException e) {
+ LOG.error("Query EMS detail failed! EMS ID: " + emsId, e);
+ }
+ return emsRegisterInfo;
}
- }
-
- private ArrayList<EmsRegisterInfo> getEmsDetailList(EsrEmsList esrEms) {
- ArrayList<EmsRegisterInfo> emsInfoList = new ArrayList<EmsRegisterInfo>();
- EmsRegisterInfo emsInfo = new EmsRegisterInfo();
- for (int i = 0; i < esrEms.getEsrEms().size(); i++) {
- String emsId = esrEms.getEsrEms().get(i).getEmsId();
- emsInfo = queryEmsDetail(emsId);
- if (emsInfo != null) {
- emsInfoList.add(emsInfo);
- }
+
+ private List<EmsRegisterInfo> getEmsDetailList(EsrEmsList esrEms) {
+ List<EmsRegisterInfo> emsInfoList = new ArrayList<>();
+ EmsRegisterInfo emsInfo = new EmsRegisterInfo();
+ for (int i = 0; i < esrEms.getEsrEms().size(); i++) {
+ String emsId = esrEms.getEsrEms().get(i).getEmsId();
+ emsInfo = queryEmsDetail(emsId);
+ if (emsInfo != null) {
+ emsInfoList.add(emsInfo);
+ }
+ }
+ return emsInfoList;
}
- return emsInfoList;
- }
-
- private EsrEmsDetail queryEsrEmsDetail (String emsId) {
- EsrEmsDetail esrEmsDetail = new EsrEmsDetail();
- try {
- 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());
+
+ private EsrEmsDetail queryEsrEmsDetail(String emsId) {
+ EsrEmsDetail esrEmsDetail = new EsrEmsDetail();
+ try {
+ String esrEmsStr = ExternalSystemProxy.queryEmsDetail(emsId);
+ LOG.info("Response from AAI by query EMS: " + esrEmsStr);
+ esrEmsDetail = new Gson().fromJson(esrEmsStr, EsrEmsDetail.class);
+ } catch (ExtsysException e) {
+ LOG.error("Query EMS detail failed! EMS ID: " + emsId, e);
+ }
+ return esrEmsDetail;
}
- return esrEmsDetail;
- }
-
- private EsrEmsDetail getNewEsrEmsDetail(EmsRegisterInfo emsRegisterInfo, String emsId) {
- EsrEmsDetail esrEmsDetail = new EsrEmsDetail();
- ArrayList<EsrSystemInfo> newEsrSysInfoList = new ArrayList<EsrSystemInfo>();
- EsrSystemInfo newEsrSystemInfo = new EsrSystemInfo();
- EsrEmsDetail oriEsrEmsDetail = new EsrEmsDetail();
- ArrayList<EsrSystemInfo> oriEsrSysInfoList = new ArrayList<EsrSystemInfo>();
- EsrSystemInfo originalEsrSystemInfo = new EsrSystemInfo();
-
- oriEsrEmsDetail = queryEsrEmsDetail(emsId);
- esrEmsDetail = emsManagerUtil.emsRegisterInfo2EsrEms(emsRegisterInfo);
- String emsResourceVersion = oriEsrEmsDetail.getResourceVersion();
- esrEmsDetail.setResourceVersion(emsResourceVersion);
- esrEmsDetail.setEmsId(emsId);
- newEsrSysInfoList = esrEmsDetail.getEsrSystemInfoList().getEsrSystemInfo();
- oriEsrSysInfoList = oriEsrEmsDetail.getEsrSystemInfoList().getEsrSystemInfo();
- for (int i = 0; i < oriEsrSysInfoList.size(); i++) {
- originalEsrSystemInfo = oriEsrSysInfoList.get(i);
- for (int j = 0; j < newEsrSysInfoList.size(); j++) {
- newEsrSystemInfo = newEsrSysInfoList.get(j);
- if (originalEsrSystemInfo.getSystemType().equals(newEsrSystemInfo.getSystemType())) {
- esrEmsDetail.getEsrSystemInfoList().getEsrSystemInfo().get(j)
- .setResouceVersion(originalEsrSystemInfo.getResouceVersion());
- esrEmsDetail.getEsrSystemInfoList().getEsrSystemInfo().get(j)
- .setEsrSystemInfoId(originalEsrSystemInfo.getEsrSystemInfoId());
- break;
+
+ private EsrEmsDetail getNewEsrEmsDetail(EmsRegisterInfo emsRegisterInfo, String emsId) {
+ EsrEmsDetail esrEmsDetail = new EsrEmsDetail();
+ List<EsrSystemInfo> newEsrSysInfoList = new ArrayList<>();
+ EsrSystemInfo newEsrSystemInfo = new EsrSystemInfo();
+ EsrEmsDetail oriEsrEmsDetail = new EsrEmsDetail();
+ List<EsrSystemInfo> oriEsrSysInfoList = new ArrayList<>();
+ EsrSystemInfo originalEsrSystemInfo = new EsrSystemInfo();
+
+ oriEsrEmsDetail = queryEsrEmsDetail(emsId);
+ esrEmsDetail = emsManagerUtil.emsRegisterInfo2EsrEms(emsRegisterInfo);
+ String emsResourceVersion = oriEsrEmsDetail.getResourceVersion();
+ esrEmsDetail.setResourceVersion(emsResourceVersion);
+ esrEmsDetail.setEmsId(emsId);
+ newEsrSysInfoList = esrEmsDetail.getEsrSystemInfoList().getEsrSystemInfo();
+ oriEsrSysInfoList = oriEsrEmsDetail.getEsrSystemInfoList().getEsrSystemInfo();
+ for (int i = 0; i < oriEsrSysInfoList.size(); i++) {
+ originalEsrSystemInfo = oriEsrSysInfoList.get(i);
+ for (int j = 0; j < newEsrSysInfoList.size(); j++) {
+ newEsrSystemInfo = newEsrSysInfoList.get(j);
+ if (originalEsrSystemInfo.getSystemType().equals(newEsrSystemInfo.getSystemType())) {
+ esrEmsDetail.getEsrSystemInfoList().getEsrSystemInfo().get(j)
+ .setResouceVersion(originalEsrSystemInfo.getResouceVersion());
+ esrEmsDetail.getEsrSystemInfoList().getEsrSystemInfo().get(j)
+ .setEsrSystemInfoId(originalEsrSystemInfo.getEsrSystemInfoId());
+ break;
+ }
+ }
}
- }
+ return esrEmsDetail;
}
- return esrEmsDetail;
- }
}
Code Review / aai / esr-server.git / blobdiff