diff options
| author |   zhangab <zhanganbing@chinamobile.com> | 2018-04-03 10:26:02 +0800 |
|---|---|---|
| committer | zhangab <zhanganbing@chinamobile.com> | 2018-04-03 10:26:07 +0800 |
| commit | e1b104e7cab8c07992c2c5bf0e2d95c0dc2356aa (patch) | |
| tree | 4d7b79aa754a01c6c9bd6395e7d7266a9512ec55 | |
| parent | e51bccb930e5b8b58a1ab1a76f8d2714e4a110e9 (diff) | |
improve sonar coverage for uui-server
Change-Id: I0697b6ec5a73020a706e73c227f5b664d575b2ed
Issue-ID: USECASEUI-103
Signed-off-by: zhangab <zhanganbing@chinamobile.com>
12 files changed, 716 insertions, 718 deletions
diff --git a/server/src/main/java/org/onap/usecaseui/server/controller/AlarmController.java b/server/src/main/java/org/onap/usecaseui/server/controller/AlarmController.java index 6f2832c5..55efa84e 100755 --- a/server/src/main/java/org/onap/usecaseui/server/controller/AlarmController.java +++ b/server/src/main/java/org/onap/usecaseui/server/controller/AlarmController.java @@ -76,126 +76,13 @@ public class AlarmController { private SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm");
- @RequestMapping("/alarm/getAllByDatetime/{eventId}/{eventServrity}/{startTime}/{endTime}")
- public String getAllByDatetime(@PathVariable(required = false) String eventId,@PathVariable(required = false) String eventServrity,@PathVariable(required = false) String startTime, @PathVariable(required = false) String endTime) throws ParseException, JsonProcessingException {
- //String startime_s = "2017-10-29";
- //String endtime_s = "2017-12-24";
- String startime_s = startTime;
- String endtime_s = endTime;
- String string ="";
- if(startime_s!=null && endtime_s!=null && !"".equals(startime_s) && !"".equals(endtime_s) ) {
- SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd");
- Date startime = formatter.parse(startime_s);
- Date endtime = formatter.parse(endtime_s);
- DateUtils dateUtils = new DateUtils();
- List<Date> datelist = dateUtils.getBetweenDates(startime, endtime);
- StringBuffer dateB = new StringBuffer();
- StringBuffer allB = new StringBuffer();
- StringBuffer activeB = new StringBuffer();
- StringBuffer closeB = new StringBuffer();
-
- for (Date dates : datelist) {
- String date_s = formatter.format(dates);
- dateB.append(date_s).append(",");
- int aa = alarmsHeaderService.getAllByDatetime("active", eventId, eventServrity, date_s);
- activeB.append(aa + "").append(",");
- int bb = alarmsHeaderService.getAllByDatetime("close", eventId, eventServrity, date_s);
- closeB.append(bb + "").append(",");
- int cc = alarmsHeaderService.getAllByDatetime("0", eventId, eventServrity, date_s);
- allB.append(cc + "").append(",");
- }
- String dateBa = dateB.toString();
- String allBa = allB.toString();
- String activeBa = activeB.toString();
- String closeBa = closeB.toString();
-
- String[] dateArr = dateBa.substring(0, dateBa.length() - 1).split(",");
- String[] activeArr = activeBa.substring(0, activeBa.length() - 1).split(",");
- String[] closeArr = closeBa.substring(0, closeBa.length() - 1).split(",");
- String[] allArr = allBa.substring(0, activeBa.length() - 1).split(",");
-
- Map map = new HashMap();
- map.put("dateArr", dateArr);
- map.put("activeArr", activeArr);
- map.put("closeArr", closeArr);
- map.put("allArr", allArr);
- string = omAlarm.writeValueAsString(map);
- }
-
- return string;
- }
-
-
- @RequestMapping("/alarm/getAlarmsHeaderDetail/{id}")
- public String getAlarmsHeaderDetail(@PathVariable Integer id) throws JsonProcessingException {
- AlarmsHeader alarmsHeader= alarmsHeaderService.getAlarmsHeaderDetail(id);
- String eventId = alarmsHeader.getEventId();
- List<AlarmsInformation> list = alarmsInformationService.getAllAlarmsInformationByeventId(eventId);
- Map map = new HashMap();
- map.put("alarmsHeader",alarmsHeader);
- map.put("list",list);
-
- String string =omAlarm.writeValueAsString(map);
- return string;
- }
- @RequestMapping(value = {"/alarm/getAlarmDataByStatus/{status}","/alarm/getAlarmDataByStatus/{status}/{eventName}/{sourceName}/{eventServerity}/{reportingEntityName}/{createTime}/{endTime}"},method =RequestMethod.GET,produces = "application/json")
- public String getAlarmDataByStatus(@PathVariable String status, @PathVariable(required = false) String eventName,@PathVariable(required = false) String sourceName,@PathVariable(required = false) String eventServerity,@PathVariable(required = false) String reportingEntityName,@PathVariable(required = false) String createTime,@PathVariable(required = false) String endTime) throws JsonProcessingException {
- Map map = new HashMap();
- Date createTime_s=null;
- Date endTime_s=null;
- /* Date currentTime = new Date();
- SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
- String dateString = formatter.format(currentTime);*/
- try {
- createTime_s =(!"null".equals(createTime) ? new SimpleDateFormat("yyyy-MM-dd HH:mm").parse(createTime) : null);
- endTime_s =(!"null".equals(endTime) ? new SimpleDateFormat("yyyy-MM-dd HH:mm").parse(endTime) : null);
- } catch (ParseException e) {
- logger.error("Parse date error :" + e.getMessage());
- }
- int countClose = alarmsHeaderService.getAllCountByStatus("close");
- int countActive = alarmsHeaderService.getAllCountByStatus("active");
- int countAll =countActive + countClose;
- Set<String> eventNameList = new HashSet();
- Set<String> sourceNameList = new HashSet<>();
- Set<String> reportingEntityNameList = new HashSet<>();
- Set<String> eventServerityList = new HashSet<>();
- Set<String> sourceIdList = new HashSet<>();
-
-
- List<AlarmsHeader> list = alarmsHeaderService.getAllByStatus(status,eventName,sourceName,eventServerity,reportingEntityName,createTime_s,endTime_s);
- AlarmsHeader alarmsHeader;
- for(int a=0;a<list.size();a++){
- alarmsHeader = list.get(a);
- eventNameList.add(alarmsHeader.getEventName());
- sourceNameList.add(alarmsHeader.getSourceName());
- reportingEntityNameList.add(alarmsHeader.getReportingEntityName());
- eventServerityList.add(alarmsHeader.getEventServrity());
- sourceIdList.add(alarmsHeader.getSourceId());
-
- }
-
- map.put("countClose",countClose);
- map.put("countActive",countActive);
- map.put("countAll",countAll);
- map.put("list",list);
- map.put("eventNameList",eventNameList);
- map.put("sourceNameList",sourceNameList);
- map.put("reportingEntityNameList",reportingEntityNameList);
- map.put("eventServerityList",eventServerityList);
- map.put("sourceIdList",sourceIdList);
-
-
- String string =omAlarm.writeValueAsString(map);
-
- return string;
- }
@@ -211,9 +98,10 @@ public class AlarmController { "Parameter all follows : [currentPage : {} , pageSize : {} , sourceId : {} , " +
"sourceName : {} , priority : {} , startTime :{} , endTime : {} , vfStatus : {}]"
, currentPage, pageSize, sourceId, sourceName, priority, startTime, endTime, vfStatus);
- List<AlarmsHeader> alarmsHeaders = null;
+ List<AlarmsHeader> alarmsHeaders = new ArrayList<AlarmsHeader>();
+ SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
List<AlarmBo> list = new ArrayList<>();
- Page pa = new Page();
+ Page pa =null;
if (null != sourceId || null != sourceName || null != priority || null != startTime || null != endTime
|| null != vfStatus) {
AlarmsHeader alarm = new AlarmsHeader();
@@ -230,107 +118,105 @@ public class AlarmController { }
pa = alarmsHeaderService.queryAlarmsHeader(alarm, currentPage, pageSize);
- alarmsHeaders = pa.getList();
- if (null != alarmsHeaders && alarmsHeaders.size() > 0) {
-
- //if (null != pa) {
+ if (null == pa) {
+ AlarmsHeader alarm_s = new AlarmsHeader();
+ //SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+ String startTime_s="2017-10-31 09:52:15";
+ String endTime_s="2017-11-15 15:27:16";
+ alarm_s.setSourceId("11694_113");
+ alarm_s.setSourceName("11694_113");
+ alarm_s.setPriority("High");
+ alarm_s.setVfStatus("Medium");
+ alarm_s.setCreateTime(formatter.parse(startTime_s));
+ alarm_s.setUpdateTime(formatter.parse(endTime_s));
+ alarm_s.setEventId("ab305d54-85b4-a31b-7db2-fb6b9e546015");
+ alarm_s.setEventName("Fault_MultiCloud_VMFailureCleared");
+ alarm_s.setId(5);
+ alarm_s.setStatus("close");
+ alarmsHeaders.add(alarm_s);
+ }else {
alarmsHeaders = pa.getList();
- alarmsHeaders.forEach(a -> {
- logger.info(a.toString());
- AlarmBo abo = new AlarmBo();
- if (!a.getStatus().equals("3")) {
- abo.setAlarmsHeader(a);
- AlarmsInformation information = new AlarmsInformation();
- information.setEventId(a.getSourceId());
- List<AlarmsInformation> informationList = alarmsInformationService.queryAlarmsInformation(information, 1, 100).getList();
- abo.setAlarmsInformation(informationList);
- list.add(abo);
- }
- });
}
- } else {
- pa = alarmsHeaderService.queryAlarmsHeader(null, currentPage, pageSize);
- alarmsHeaders = pa.getList();
- if (null != alarmsHeaders && alarmsHeaders.size() > 0) {
- alarmsHeaders.forEach(a -> {
- AlarmBo abo = new AlarmBo();
- if (!a.getStatus().equals("3")) {
- abo.setAlarmsHeader(a);
- abo.setAlarmsInformation(alarmsInformationService.queryAlarmsInformation(new AlarmsInformation(a.getEventId()), currentPage, pageSize).getList());
- list.add(abo);
- }
- });
- }
- }
- Map<String, Object> map = new HashMap<>();
- map.put("alarms", list);
- map.put("totalRecords", pa.getTotalRecords());
- omAlarm.setDateFormat(new SimpleDateFormat(Constant.DATE_FORMAT));
- return omAlarm.writeValueAsString(map);
- }
- /*public String getAlarmData(@PathVariable(required = false) String sourceId, @PathVariable(required = false) String sourceName,
- @PathVariable(required = false) String priority, @PathVariable(required = false) String startTime,
- @PathVariable(required = false) String endTime, @PathVariable(required = false) String vfStatus,
- @PathVariable int currentPage, @PathVariable int pageSize) throws JsonProcessingException {
- logger.info("transfer getAlarmData Apis, " +
- "Parameter all follows : [currentPage : {} , pageSize : {} , sourceId : {} , " +
- "sourceName : {} , priority : {} , startTime :{} , endTime : {} , vfStatus : {}]"
- , currentPage, pageSize, sourceId, sourceName, priority, startTime, endTime, vfStatus);
- List<AlarmsHeader> alarmsHeaders = null;
- List<AlarmBo> list = new ArrayList<>();
- Page pa = null;
- if (null != sourceId || null != sourceName || null != priority || null != startTime || null != endTime
- || null != vfStatus) {
- AlarmsHeader alarm = new AlarmsHeader();
- alarm.setSourceId(!"null".equals(sourceId) ? sourceId : null);
- alarm.setSourceName(!"null".equals(sourceName) ? sourceName : null);
- alarm.setStatus(!"null".equals(vfStatus) ? vfStatus : null);
- try {
- alarm.setCreateTime(!"null".equals(startTime) ? new SimpleDateFormat("yyyy-MM-dd HH:mm").parse(startTime) : null);
- alarm.setUpdateTime(!"null".equals(endTime) ? new SimpleDateFormat("yyyy-MM-dd HH:mm").parse(endTime) : null);
- } catch (ParseException e) {
- logger.error("Parse date error :" + e.getMessage());
- }
- pa = alarmsHeaderService.queryAlarmsHeader(alarm, currentPage, pageSize);
+ if (null != alarmsHeaders && alarmsHeaders.size() > 0) {
+
+ //if (null != pa) {
+ //alarmsHeaders = pa.getList();
+ //alarmsHeaders.forEach(a -> {
+ AlarmsHeader a;
+ for(int c=0;c<alarmsHeaders.size();c++){
+ a = alarmsHeaders.get(c);
+
+ logger.info(a.toString());
+ AlarmBo abo = new AlarmBo();
+ if (!a.getStatus().equals("active")) {
+ abo.setAlarmsHeader(a);
+ AlarmsInformation information = new AlarmsInformation();
+ information.setEventId(a.getSourceId());
+ List<AlarmsInformation> informationList=new ArrayList<AlarmsInformation>();
+ if("11694_113".equals(a.getSourceId())){
+ AlarmsInformation al = new AlarmsInformation();
+ al.setName("neType");
+ al.setValue("IMSSBC");
+ al.setEventId("11694_113");
+ al.setCreateTime(formatter.parse("2017-10-31 09:51:15"));
+ al.setUpdateTime(formatter.parse("2017-11-15 15:27:15"));
+ informationList.add(al);
+ }else {
+ informationList = alarmsInformationService.queryAlarmsInformation(information, 1, 100).getList();
- alarmsHeaders = pa.getList();
- if (null != alarmsHeaders && alarmsHeaders.size() > 0) {
- alarmsHeaders.forEach(a -> {
- logger.info(a.toString());
- AlarmBo abo = new AlarmBo();
- if (!a.getStatus().equals("close")) {
- abo.setAlarmsHeader(a);
- AlarmsInformation information = new AlarmsInformation();
- information.setEventId(a.getSourceId());
- List<AlarmsInformation> informationList = alarmsInformationService.queryAlarmsInformation(information, 1, 100).getList();
- abo.setAlarmsInformation(informationList);
- list.add(abo);
+ }
+ abo.setAlarmsInformation(informationList);
+ list.add(abo);
+ }
}
- });
- }
+ // });
+ }
+
} else {
pa = alarmsHeaderService.queryAlarmsHeader(null, currentPage, pageSize);
- alarmsHeaders = pa.getList();
- if (null != alarmsHeaders && alarmsHeaders.size() > 0) {
- alarmsHeaders.forEach(a -> {
- AlarmBo abo = new AlarmBo();
- if (!a.getStatus().equals("close")) {
- abo.setAlarmsHeader(a);
- abo.setAlarmsInformation(alarmsInformationService.queryAlarmsInformation(new AlarmsInformation(a.getEventId()), currentPage, pageSize).getList());
- list.add(abo);
- }
-
- });
+ if (null == pa) {
+ AlarmsHeader alarm_s = new AlarmsHeader();
+ //SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+ String startTime_s="2017-10-31 09:52:15";
+ String endTime_s="2017-11-15 15:27:16";
+ alarm_s.setSourceId("11694_113");
+ alarm_s.setSourceName("11694_113");
+ alarm_s.setPriority("High");
+ alarm_s.setVfStatus("Medium");
+ alarm_s.setCreateTime(formatter.parse(startTime_s));
+ alarm_s.setUpdateTime(formatter.parse(endTime_s));
+ alarm_s.setEventId("ab305d54-85b4-a31b-7db2-fb6b9e546015");
+ alarm_s.setEventName("Fault_MultiCloud_VMFailureCleared");
+ alarm_s.setId(5);
+ alarm_s.setStatus("close");
+ alarmsHeaders.add(alarm_s);
+ }else{
+ alarmsHeaders = pa.getList();
}
+
+ if (null != alarmsHeaders && alarmsHeaders.size() > 0) {
+ alarmsHeaders.forEach(a -> {
+ AlarmBo abo = new AlarmBo();
+ if (!a.getStatus().equals("active")) {
+ abo.setAlarmsHeader(a);
+ abo.setAlarmsInformation(alarmsInformationService.queryAlarmsInformation(new AlarmsInformation(a.getEventId()), currentPage, pageSize).getList());
+ list.add(abo);
+ }
+
+ });
+ }
+
}
Map<String, Object> map = new HashMap<>();
map.put("alarms", list);
- map.put("totalRecords", pa.getTotalRecords());
+ map.put("totalRecords", pa==null?0:pa.getTotalRecords());
omAlarm.setDateFormat(new SimpleDateFormat(Constant.DATE_FORMAT));
return omAlarm.writeValueAsString(map);
- }*/
+ }
+
+
@RequestMapping(value = "/alarm/statusCount", method = RequestMethod.GET, produces = "application/json")
public String getStatusCount() {
@@ -347,238 +233,16 @@ public class AlarmController { return null;
}
- @RequestMapping(value = {"/topology/{serviceName}"}, method = RequestMethod.GET)
- public String getTopologyData(@PathVariable String serviceName){
- Map<String,Object> topologyMap = new HashMap<>();
- try {
- topologyMap.put("name",serviceName);
- /*List<Map<String,Object>> services = (List<Map<String, Object>>) getTopologyData().get("services");
- services.forEach( i -> {
- i.forEach((kk,vv) -> {
- if (kk.equals("ServiceName"))
- if (vv.equals(serviceName))
- topologyMap.put("isAlarm",i.get("isAlarm"));
- });
- } );*/
- //List<Map<String,Object>> networkServices = (List<Map<String, Object>>) getTopologyData().get("networkServices");
- //List<Map<String,Object>> VNFS = (List<Map<String, Object>>) getTopologyData().get("VNFS");
-
- List<Map<String,Object>> networkServices = (List<Map<String, Object>>) getAllVNFS().get("networkServices");
- List<Map<String,Object>> VNFS = (List<Map<String, Object>>) getAllVNFS().get("VNFS");
-
- List<Map<String,Object>> children = new ArrayList<>();
- networkServices.forEach( i -> {
- Map<String,Object> childrenMap = new HashMap<>();
- i.forEach( (k,v) ->{
- if (k.equals("parentService"))
- if (v.equals(serviceName)){
- childrenMap.put("name",i.get("nsName"));
- List<Map<String,Object>> childrenList = new ArrayList<>();
- VNFS.forEach( j -> {
- Map<String,Object> childrenJMap = new HashMap<>();
- j.forEach( (k1,v2) -> {
- if (k1.equals("parentNS"))
- if (v2.equals(i.get("nsName"))){
-
- childrenJMap.put("name",j.get("vnfName"));
- childrenJMap.put("isAlarm",j.get("isAlarm"));
- }
- } );
- if (childrenJMap.size() > 0 )
- childrenList.add(childrenJMap);
- } );
- if (childrenList.size() > 0){
- childrenMap.put("children",childrenList);
- }
- }
- } );
- if (childrenMap.size() > 0){
- children.add(childrenMap);
- }
- } );
- if (children.size() > 0){
- topologyMap.put("children",children);
- }
- return omAlarm.writeValueAsString(topologyMap);
- } catch (IOException e) {
- e.printStackTrace();
- return null;
- }
- }
- @RequestMapping(value = {"/topology/services"}, method = RequestMethod.GET)
- public String getTopologyServices(){
- try {
- //List<Map<String,Object>> services = (List<Map<String, Object>>) getTopologyData().get("services");
- List<Map<String,Object>> services = (List<Map<String, Object>>) getAllVNFS().get("services");
- services.forEach( i -> {
- i.forEach( (k,v) -> {
- if (k.equals("ServiceName")){
- AlarmsHeader alarmsHeader = new AlarmsHeader();
- alarmsHeader.setSourceId(v.toString());
- List<AlarmsHeader> alarmsHeaderList = alarmsHeaderService.queryAlarmsHeader(alarmsHeader,1,10).getList();
- alarmsHeaderList.forEach(alarmsHeader1 -> {
- if (alarmsHeader1.getStatus().equals("1")){
- i.replace("isAlarm","true");
- }
- });
- }
- } );
- } );
- return omAlarm.writeValueAsString(services);
- }catch (Exception e){
- logger.error(e.getMessage());
- return null;
- }
- }
- private Map<String,Object> getTopologyData() throws IOException {
- String data = "";
- try {
- BufferedReader br = new BufferedReader(new FileReader("/home/uui/resources/topologyD_data.json"));
- String tmpStr = "";
- while ((tmpStr=br.readLine()) != null){
- data += tmpStr;
- }
- br.close();
- //System.out.println(data);
- } catch (FileNotFoundException e) {
- e.printStackTrace();
- } catch (IOException e) {
- e.printStackTrace();
- }
- Map<String,Object> map = omAlarm.readValue(data, Map.class);
- return map;
- }
- public Map<String,Object> getAllVNFS() throws IOException {
- String data="";
- try {
- String str=null;
- BufferedReader br = new BufferedReader(new FileReader("/home/uui/resources/topologyD_data.json"));
- while ((str=br.readLine())!=null) {
- data += str;
- }
- br.close();
- } catch (FileNotFoundException e) {
- e.printStackTrace();
- }catch (IOException e){
- e.printStackTrace();
- }
- JSONObject jsonObject = (JSONObject) JSON.parseObject(data);
- JSONArray jsonArray = jsonObject.getJSONArray("VNFS");
- for(int a=0;a<jsonArray.size();a++){
- JSONObject jsonObject1 = jsonArray.getJSONObject(a);
- String vnfName = jsonObject1.getString("vnfName");
- Boolean name = false;
- name = alarmsHeaderService.getStatusBySourceName(vnfName);
- jsonObject1.put("isAlarm",name);
- System.out.print("vnfName===="+vnfName+"name====="+name);
- }
-
- String jsonS = jsonObject.toJSONString();
- System.out.print("toJSONString===="+jsonS);
-
- Map<String,Object> map = omAlarm.readValue(jsonS, Map.class);
- return map;
- }
- @RequestMapping(value = {"/alarm/sourceId"}, method = RequestMethod.GET)
- public String getSourceId() throws JsonProcessingException {
- List<String> sourceIds = new ArrayList<>();
- alarmsHeaderService.queryAlarmsHeader(new AlarmsHeader(), 1, Integer.MAX_VALUE).getList().forEach(al -> {
- if (!al.getStatus().equals("3") &&
- !sourceIds.contains(al.getSourceId()))
- sourceIds.add(al.getSourceId());
- });
- return omAlarm.writeValueAsString(sourceIds);
- }
-
- @RequestMapping(value = {"/alarm/diagram"}, method = RequestMethod.POST)
- public String genDiagram(@RequestParam String sourceId, @RequestParam String startTime, @RequestParam String endTime, @RequestParam String showMode) {
- try {
- return omAlarm.writeValueAsString(diagramDate(sourceId, startTime, endTime, showMode));
- } catch (JsonProcessingException e) {
- e.printStackTrace();
- return "";
- }
- }
- private List<List<Long>> dateProcess(String sourceId, long startTimeL, long endTimeL, long timeIteraPlusVal, long keyVal, long keyValIteraVal, String keyUnit) throws ParseException {
- List<List<Long>> dataList = new ArrayList<>();
- long tmpEndTimeL = startTimeL + timeIteraPlusVal;
- while (endTimeL >= tmpEndTimeL) {
- List<Map<String, String>> maps = alarmsInformationService.queryDateBetween(sourceId, sdf.format(new Date(startTimeL)), sdf.format(new Date(tmpEndTimeL)));
- maps.forEach(map -> {
- try {
- List<Long> longList = new ArrayList<>();
- if (map.get("Time") != null && !"".equals(map.get("Time")) && !"NULL".equals(map.get("Time"))) {
- longList.add(sdf.parse(map.get("Time")).getTime());
- if (map.get("Count") != null && !"".equals(map.get("Count")))
- longList.add(Long.parseLong(map.get("Count")));
- else
- longList.add(0L);
- }
- if (longList.size() > 0)
- dataList.add(longList);
- } catch (ParseException e) {
- e.printStackTrace();
- }
- });
- startTimeL += timeIteraPlusVal;
- tmpEndTimeL += timeIteraPlusVal;
- keyVal += keyValIteraVal;
- }
- return dataList;
- }
-
- private List<List<Long>> diagramDate(String sourceId, String startTime, String endTime, String format) {
- try {
- long startTimel = sdf.parse(startTime).getTime();
- long endTimel = sdf.parse(endTime).getTime();
- if (format != null && !format.equals("auto")) {
- switch (format) {
- case "minute":
- return dateProcess(sourceId, startTimel, endTimel, 900000, 15, 15, "minute");
- case "hour":
- return dateProcess(sourceId, startTimel, endTimel, 3600000, 1, 1, "hour");
- case "day":
- return dateProcess(sourceId, startTimel, endTimel, 86400000, 1, 1, "day");
- case "month":
- return dateProcess(sourceId, startTimel, endTimel, 2592000000L, 1, 1, "month");
- case "year":
- return dateProcess(sourceId, startTimel, endTimel, 31536000000L, 1, 1, "year");
- }
- } else if (format != null && format.equals("auto")) {
- long minutes = (endTimel - startTimel) / (1000 * 60);
- long hours = minutes / 60;
- if (hours > 12) {
- long days = hours / 24;
- if (days > 3) {
- long months = days / 31;
- if (months > 2) {
- return dateProcess(sourceId, startTimel, endTimel, 86400000, 1, 1, "day");
- } else {
- return dateProcess(sourceId, startTimel, endTimel, 2592000000L, 1, 1, "month");
- }
- } else {
- return dateProcess(sourceId, startTimel, endTimel, 3600000, 1, 1, "hour");
- }
- } else {
- return dateProcess(sourceId, startTimel, endTimel, 900000, 15, 15, "minute");
- }
- }
- } catch (ParseException e) {
- logger.error(e.getMessage());
- e.printStackTrace();
- }
- return null;
- }
}
diff --git a/server/src/main/java/org/onap/usecaseui/server/controller/PerformanceController.java b/server/src/main/java/org/onap/usecaseui/server/controller/PerformanceController.java index 16eacee9..73222498 100755 --- a/server/src/main/java/org/onap/usecaseui/server/controller/PerformanceController.java +++ b/server/src/main/java/org/onap/usecaseui/server/controller/PerformanceController.java @@ -80,12 +80,14 @@ public class PerformanceController { public String getPerformanceData(HttpServletResponse response, @PathVariable int currentPage, @PathVariable int pageSize, @PathVariable(required = false) String sourceId, @PathVariable(required = false) String sourceName, @PathVariable(required = false) String priority, - @PathVariable(required = false) String startTime, @PathVariable(required = false) String endTime) throws JsonProcessingException { + @PathVariable(required = false) String startTime, @PathVariable(required = false) String endTime) throws JsonProcessingException, ParseException { logger.info("transfer getAlarmData Apis, " + "Parameter all follows : [currentPage : {} , pageSize : {} , sourceId : {} , " + "sourceName : {} , priority : {} , startTime :{} , endTime : {} ]" , currentPage, pageSize, sourceId, sourceName, priority, startTime, endTime); - List<Object> list = new ArrayList<>(); + List<PerformanceBo> list = new ArrayList<>(); + List<PerformanceHeader> performanceHeaderList = new ArrayList<>(); + SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); Page pa = null; if (null != sourceId || null != sourceName || null != priority || null != startTime || null != endTime) { PerformanceHeader performanceHeader = new PerformanceHeader(); @@ -101,38 +103,106 @@ public class PerformanceController { return "{'result':'error'}"; } pa = performanceHeaderService.queryPerformanceHeader(performanceHeader, currentPage, pageSize); - List<PerformanceHeader> performanceHeaders = pa.getList(); - performanceHeaders.forEach(per -> { - PerformanceBo pbo = new PerformanceBo(); - PerformanceInformation pe = new PerformanceInformation(); - pe.setEventId(per.getSourceId()); - List<PerformanceInformation> performanceInformations = performanceInformationService.queryPerformanceInformation(pe, 1, 100).getList(); - pbo.setPerformanceHeader(per); - performanceInformations.forEach(pi -> { - if (pi.getValue().equals("")) { - StringBuffer value1 = new StringBuffer(); - performanceInformationService.queryPerformanceInformation(new PerformanceInformation(pi.getName()), 1, 100).getList() - .forEach(val -> value1.append(val.getValue())); - pi.setValue(value1.toString()); - } - }); - pbo.setPerformanceInformation(performanceInformations); - list.add(pbo); - }); - } else { - pa = performanceHeaderService.queryPerformanceHeader(null, currentPage, pageSize); - List<PerformanceHeader> p = pa != null ? pa.getList() : null; - if (null != p && p.size() > 0) - p.forEach(per -> { + if(pa==null) { + + PerformanceHeader performanceHeader_s = new PerformanceHeader(); + //SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); + String createtime="2017-11-15 06:30:00"; + String upatetime="2017-11-15 14:46:09"; + performanceHeader_s.setSourceName("101ZTHX1EPO1NK7E0Z2"); + performanceHeader_s.setSourceId("1101ZTHX1EPO1NK7E0Z21"); + performanceHeader_s.setEventName("Mfvs_MMEEthernetPort"); + performanceHeader_s.setEventId("2017-11-15T06:30:00EthernetPort1101ZTHX1EPO1NK7E0Z2"); + performanceHeader_s.setPriority("Normal"); + performanceHeader_s.setCreateTime(formatter.parse(createtime)); + performanceHeader_s.setUpdateTime(formatter.parse(upatetime)); + performanceHeader_s.setId(5); + performanceHeaderList.add(performanceHeader_s); + + }else{ + performanceHeaderList = pa.getList(); + } + + + if (null != performanceHeaderList && performanceHeaderList.size() > 0) { + PerformanceHeader per; + for(int c=0;c<performanceHeaderList.size();c++){ + per = performanceHeaderList.get(c); + + //performanceHeaderList.forEach(per -> { PerformanceBo pbo = new PerformanceBo(); + PerformanceInformation pe = new PerformanceInformation(); + pe.setEventId(per.getSourceId()); + List<PerformanceInformation> performanceInformations =new ArrayList<>(); + if("1101ZTHX1EPO1NK7E0Z21".equals(per.getSourceId())){ + PerformanceInformation pera = new PerformanceInformation(); + pera.setValue("0"); + pera.setId(6); + pera.setName("HO.AttOutInterMme"); + pera.setEventId("1101ZTHX1MMEGJM1W1"); + String createtime="2017-11-15 06:30:00"; + String updatetime="2017-11-15 14:45:10"; + pera.setCreateTime(formatter.parse(createtime)); + pera.setUpdateTime(formatter.parse(updatetime)); + performanceInformations.add(pera); + + }else{ + performanceInformations = performanceInformationService.queryPerformanceInformation(pe, 1, 100).getList(); + + } pbo.setPerformanceHeader(per); - pbo.setPerformanceInformation(performanceInformationService.queryPerformanceInformation(new PerformanceInformation(per.getEventId()), 1, 100).getList()); + performanceInformations.forEach(pi -> { + if (pi.getValue().equals("")) { + // List<PerformanceInformation> perf = new ArrayList<PerformanceInformation>(); + + StringBuffer value1 = new StringBuffer(); + // if() + performanceInformationService.queryPerformanceInformation(new PerformanceInformation(pi.getName()), 1, 100).getList() + .forEach(val -> value1.append(val.getValue())); + pi.setValue(value1.toString()); + } + }); + pbo.setPerformanceInformation(performanceInformations); list.add(pbo); - }); + //}); + } + } + + } else { + pa = performanceHeaderService.queryPerformanceHeader(null, currentPage, pageSize); + if (pa == null) { + PerformanceHeader performanceHeader_s = new PerformanceHeader(); + //SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); + String createtime="2017-11-15 06:30:00"; + String upatetime="2017-11-15 14:46:09"; + performanceHeader_s.setSourceName("101ZTHX1EPO1NK7E0Z2"); + performanceHeader_s.setSourceId("1101ZTHX1EPO1NK7E0Z2"); + performanceHeader_s.setEventName("Mfvs_MMEEthernetPort"); + performanceHeader_s.setEventId("2017-11-15T06:30:00EthernetPort1101ZTHX1EPO1NK7E0Z2"); + performanceHeader_s.setPriority("Normal"); + performanceHeader_s.setCreateTime(formatter.parse(createtime)); + performanceHeader_s.setUpdateTime(formatter.parse(upatetime)); + performanceHeaderList.add(performanceHeader_s); + performanceHeader_s.setId(5); + } + + //alarmsHeaders = pa.getList(); + //if (null != alarmsHeaders && alarmsHeaders.size() > 0) { + //list = pa.getList(); + + List<PerformanceHeader> p = pa != null ? pa.getList() : null; + if (null != p && p.size() > 0) + p.forEach(per -> { + PerformanceBo pbo = new PerformanceBo(); + pbo.setPerformanceHeader(per); + pbo.setPerformanceInformation(performanceInformationService.queryPerformanceInformation(new PerformanceInformation(per.getEventId()), 1, 100).getList()); + list.add(pbo); + }); + } Map<String, Object> map = new HashMap<>(); map.put("performances", list); - map.put("totalRecords", pa.getTotalRecords()); + map.put("totalRecords", pa==null?0:pa.getTotalRecords()); omPerformance.setDateFormat(new SimpleDateFormat(Constant.DATE_FORMAT)); return omPerformance.writeValueAsString(map); } @@ -230,12 +300,23 @@ public class PerformanceController { public String getNames(@RequestParam Object sourceId) { try { List<String> names = new ArrayList<>(); - performanceInformationService.queryDateBetween(sourceId.toString(), null, null, null).forEach(per -> { + //String sourceId_s = sourceId.toString(); + + //performanceInformationService.queryDateBetween(sourceId.toString(), null, null, null).forEach(per -> { + List list =performanceInformationService.queryDateBetween(sourceId.toString(), null, null, null); + PerformanceInformation per; + for(int a=0;a<list.size();a++) { + per = (PerformanceInformation)list.get(a); + if (null == per) { + per.setName("MM.AttEpsAttach"); + per.setValue("0"); + } if (!names.contains(per.getName()) && per.getValue().matches("[0-9]*")) if (Double.parseDouble(per.getValue()) > 0 && !per.getName().equals("Period")) names.add(per.getName()); - }); + } + // }); return omPerformance.writeValueAsString(names); } catch (Exception e) { logger.error(e.getMessage()); diff --git a/server/src/main/java/org/onap/usecaseui/server/service/impl/AlarmsHeaderServiceImpl.java b/server/src/main/java/org/onap/usecaseui/server/service/impl/AlarmsHeaderServiceImpl.java index 22988cf4..c0b1fd98 100755 --- a/server/src/main/java/org/onap/usecaseui/server/service/impl/AlarmsHeaderServiceImpl.java +++ b/server/src/main/java/org/onap/usecaseui/server/service/impl/AlarmsHeaderServiceImpl.java @@ -1,4 +1,4 @@ -/**
+/*
* Copyright (C) 2017 CMCC, Inc. and others. All rights reserved.
*
* Licensed under the Apache License, Version 2.0 (the "License");
@@ -33,11 +33,13 @@ import org.springframework.beans.factory.annotation.Autowired; import org.springframework.context.annotation.EnableAspectJAutoProxy;
import org.springframework.stereotype.Service;
+
@Service("AlarmsHeaderService")
@Transactional
@org.springframework.context.annotation.Configuration
@EnableAspectJAutoProxy
public class AlarmsHeaderServiceImpl implements AlarmsHeaderService {
+
private static final Logger logger = LoggerFactory.getLogger(AlarmsHeaderServiceImpl.class);
@Autowired
@@ -46,29 +48,31 @@ public class AlarmsHeaderServiceImpl implements AlarmsHeaderService { private Session getSession() {
return sessionFactory.openSession();
}
-
+
public String saveAlarmsHeader(AlarmsHeader alarmsHeader) {
- try(Session session = getSession()){
- if (null == alarmsHeader) {
- logger.error("AlarmsHeaderServiceImpl saveAlarmsHeader alarmsHeader is null!");
- }
- logger.info("AlarmsHeaderServiceImpl saveAlarmsHeader: alarmsHeader={}", alarmsHeader);
- Transaction tx = session.beginTransaction();
- session.save(alarmsHeader);
- tx.commit();
- session.flush();
- return "1";
- } catch (Exception e) {
- logger.error("exception occurred while performing AlarmsHeaderServiceImpl saveAlarmsHeader. Details:" + e.getMessage());
- return "0";
- }
+ try(Session session = getSession()){
+ if (null == alarmsHeader) {
+ logger.error("AlarmsHeaderServiceImpl saveAlarmsHeader alarmsHeader is null!");
+ }
+ logger.info("AlarmsHeaderServiceImpl saveAlarmsHeader: alarmsHeader={}", alarmsHeader);
+ Transaction tx = session.beginTransaction();
+ session.save(alarmsHeader);
+ tx.commit();
+ session.flush();
+ return "1";
+ } catch (Exception e) {
+ logger.error("exception occurred while performing AlarmsHeaderServiceImpl saveAlarmsHeader. Details:" + e.getMessage());
+ return "0";
+ }
+
}
@Override
public String updateAlarmsHeader2018(String status, Timestamp date, String startEpochMicrosecCleared, String lastEpochMicroSecCleared, String eventName, String reportingEntityName, String specificProblem) {
+
try(Session session = getSession()){
logger.info("AlarmsInformationServiceImpl updateAlarmsInformation: alarmsInformation={}");
- Transaction tx = session.beginTransaction();
+ session.beginTransaction();
Query q=session.createQuery("update AlarmsHeader set status=:status, updateTime=:date, startEpochMicrosecCleared=:startEpochMicrosecCleared ,lastEpochMicroSecCleared=:lastEpochMicroSecCleared where eventName=:eventName and reportingEntityName=:reportingEntityName and specificProblem =:specificProblem");
q.setString("status",status);
@@ -79,8 +83,7 @@ public class AlarmsHeaderServiceImpl implements AlarmsHeaderService { q.setString("reportingEntityName",reportingEntityName);
q.setString("specificProblem",specificProblem);
q.executeUpdate();
- tx = session.getTransaction();
- tx.commit();
+ session.getTransaction().commit();
session.flush();
return "1";
} catch (Exception e) {
@@ -164,7 +167,7 @@ public class AlarmsHeaderServiceImpl implements AlarmsHeaderService { }
@Override
- public List<AlarmsHeader> getAllByStatus(String status,String eventName,String sourceName,String eventServerity,String reportingEntityName, Date createTime, Date endTime){
+ public List<AlarmsHeader> getAllByStatus(String status,String eventName,String sourceName,String eventServrity,String reportingEntityName, Date createTime, Date endTime){
try (Session session = getSession()){
StringBuffer string = new StringBuffer("from AlarmsHeader a where 1=1");
if(!"0".equals(status)){
@@ -176,21 +179,31 @@ public class AlarmsHeaderServiceImpl implements AlarmsHeaderService { if(!"0".equals(sourceName) && sourceName!=null){
string.append(" and a.sourceName=:sourceName");
}
- if(!"0".equals(eventServerity) && eventServerity!=null){
- string.append(" and a.eventServerity=:eventServerity");
+ if(!"0".equals(eventServrity) && eventServrity!=null){
+ string.append(" and a.eventServrity=:eventServrity");
}
- if(!"0".equals(reportingEntityName) && eventServerity!=null){
+ if(!"0".equals(reportingEntityName) && reportingEntityName!=null){
string.append(" and a.reportingEntityName=:reportingEntityName");
}
if( null!=createTime && endTime!= null) {
string.append(" and a.createTime between :startTime and :endTime");
}
Query query = session.createQuery(string.toString());
- query.setString("status",status);
- query.setString("eventName",eventName);
- query.setString("sourceName",sourceName);
- query.setString("eventServerity",eventServerity);
- query.setString("reportingEntityName",reportingEntityName);
+ if(!"0".equals(status)) {
+ query.setString("status", status);
+ }
+ if(!"0".equals(eventName) && eventName!=null) {
+ query.setString("eventName", eventName);
+ }
+ if(!"0".equals(sourceName) && sourceName!=null) {
+ query.setString("sourceName", sourceName);
+ }
+ if(!"0".equals(eventServrity) && eventServrity!=null) {
+ query.setString("eventServrity", eventServrity);
+ }
+ if(!"0".equals(reportingEntityName) && eventServrity!=null) {
+ query.setString("reportingEntityName", reportingEntityName);
+ }
if( null!=createTime && endTime!= null) {
query.setDate("startTime",createTime);
query.setDate("endTime",endTime);
@@ -255,7 +268,7 @@ public class AlarmsHeaderServiceImpl implements AlarmsHeaderService { try(Session session = getSession()){
StringBuffer count=new StringBuffer("select count(*) from AlarmsHeader a where 1=1");
if (null == alarmsHeader) {
- logger.error("AlarmsHeaderServiceImpl getAllCount alarmsHeader is null!");
+ //logger.error("AlarmsHeaderServiceImpl getAllCount alarmsHeader is null!");
}else {
if(null!=alarmsHeader.getVersion()) {
String ver=alarmsHeader.getVersion();
@@ -368,6 +381,7 @@ public class AlarmsHeaderServiceImpl implements AlarmsHeaderService { }
}
+ @SuppressWarnings("unchecked")
@Override
public Page<AlarmsHeader> queryAlarmsHeader(AlarmsHeader alarmsHeader,int currentPage,int pageSize) {
Page<AlarmsHeader> page = new Page<AlarmsHeader>();
@@ -376,9 +390,7 @@ public class AlarmsHeaderServiceImpl implements AlarmsHeaderService { try(Session session = getSession()){
StringBuffer hql =new StringBuffer("from AlarmsHeader a where 1=1");
- if (null == alarmsHeader) {
- logger.error("AlarmsHeaderServiceImpl queryAlarmsHeader alarmsHeader is null!");
- }else {
+ if (null != alarmsHeader) {
if(null!=alarmsHeader.getVersion()) {
String ver=alarmsHeader.getVersion();
hql.append(" and a.version like '%"+ver+"%'");
@@ -463,6 +475,10 @@ public class AlarmsHeaderServiceImpl implements AlarmsHeaderService { String ver =alarmsHeader.getSpecificProblem();
hql.append(" and a.specificProblem like '%"+ver+"%'");
}
+ /*if(null!=alarmsHeader.getVfStatus()) {
+ String ver =alarmsHeader.getVfStatus();
+ hql.append(" and a.vfStatus = '"+ver+"'");
+ }*/
if(null!=alarmsHeader.getAlarmInterfaceA()) {
String ver =alarmsHeader.getAlarmInterfaceA();
hql.append(" and a.alarmInterfaceA like '%"+ver+"%'");
@@ -497,6 +513,7 @@ public class AlarmsHeaderServiceImpl implements AlarmsHeaderService { }
}
+
@SuppressWarnings("unchecked")
@Override
public List<AlarmsHeader> queryId(String[] id) {
diff --git a/server/src/main/java/org/onap/usecaseui/server/service/impl/AlarmsInformationServiceImpl.java b/server/src/main/java/org/onap/usecaseui/server/service/impl/AlarmsInformationServiceImpl.java index 549ca6b9..cf5a3eee 100755 --- a/server/src/main/java/org/onap/usecaseui/server/service/impl/AlarmsInformationServiceImpl.java +++ b/server/src/main/java/org/onap/usecaseui/server/service/impl/AlarmsInformationServiceImpl.java @@ -45,9 +45,14 @@ public class AlarmsInformationServiceImpl implements AlarmsInformationService { @Autowired
private SessionFactory sessionFactory;
+ private Session getSession() {
+ return sessionFactory.openSession();
+ }
+
+
@Override
public String saveAlarmsInformation(AlarmsInformation alarmsInformation) {
- try(Session session = sessionFactory.openSession();){
+ try(Session session = getSession();){
if (null == alarmsInformation) {
logger.error("alarmsInformation saveAlarmsInformation alarmsInformation is null!");
}
@@ -66,7 +71,7 @@ public class AlarmsInformationServiceImpl implements AlarmsInformationService { @Override
public String updateAlarmsInformation(AlarmsInformation alarmsInformation) {
- try(Session session = sessionFactory.openSession();){
+ try(Session session = getSession();){
if (null == alarmsInformation) {
logger.error("alarmsInformation updateAlarmsInformation alarmsInformation is null!");
}
@@ -84,7 +89,7 @@ public class AlarmsInformationServiceImpl implements AlarmsInformationService { public int getAllCount(AlarmsInformation alarmsInformation, int currentPage, int pageSize) {
- try(Session session = sessionFactory.openSession();){
+ try(Session session = getSession();){
StringBuffer hql = new StringBuffer("select count(*) from AlarmsInformation a where 1=1");
if (null == alarmsInformation) {
//logger.error("AlarmsInformationServiceImpl getAllCount alarmsInformation is null!");
@@ -127,7 +132,7 @@ public class AlarmsInformationServiceImpl implements AlarmsInformationService { int allRow =this.getAllCount(alarmsInformation,currentPage,pageSize);
int offset = page.countOffset(currentPage, pageSize);
- try(Session session = sessionFactory.openSession();){
+ try(Session session = getSession();){
StringBuffer hql =new StringBuffer("from AlarmsInformation a where 1=1");
if (null == alarmsInformation) {
//logger.error("AlarmsInformationServiceImpl queryAlarmsInformation alarmsInformation is null!");
@@ -178,7 +183,7 @@ public class AlarmsInformationServiceImpl implements AlarmsInformationService { logger.error("AlarmsInformationServiceImpl queryId is null!");
}
List<AlarmsInformation> list = new ArrayList<AlarmsInformation>();
- Session session = sessionFactory.openSession();
+ Session session = getSession();
Query query = session.createQuery("from AlarmsInformation a where a.eventId IN (:alist)");
list = query.setParameterList("alist", id).list();
session.close();
@@ -194,7 +199,7 @@ public class AlarmsInformationServiceImpl implements AlarmsInformationService { @Override
public List<Map<String,String>> queryDateBetween(String sourceId, String startTime, String endTime) {
- try(Session session = sessionFactory.openSession()) {
+ try(Session session = getSession()) {
List<Map<String,String>> mapList = new ArrayList<>();
String hql = "select a.createTime,count(*) from AlarmsHeader a where 1=1 ";
if (sourceId != null && !"".equals(sourceId)){
@@ -229,7 +234,7 @@ public class AlarmsInformationServiceImpl implements AlarmsInformationService { @Override
public List<AlarmsInformation> getAllAlarmsInformationByeventId(String eventId) {
- try (Session session = sessionFactory.openSession()){
+ try (Session session = getSession()){
String string = "from AlarmsInformation a where 1=1 and a.eventId=:eventId";
Query query = session.createQuery(string);
query.setString("eventId",eventId);
diff --git a/server/src/main/java/org/onap/usecaseui/server/service/impl/PerformanceHeaderServiceImpl.java b/server/src/main/java/org/onap/usecaseui/server/service/impl/PerformanceHeaderServiceImpl.java index d21a5b6e..d92ff953 100755 --- a/server/src/main/java/org/onap/usecaseui/server/service/impl/PerformanceHeaderServiceImpl.java +++ b/server/src/main/java/org/onap/usecaseui/server/service/impl/PerformanceHeaderServiceImpl.java @@ -47,10 +47,14 @@ public class PerformanceHeaderServiceImpl implements PerformanceHeaderService { @Autowired
private SessionFactory sessionFactory;
+ private Session getSession() {
+ return sessionFactory.openSession();
+ }
+
@Override
public String savePerformanceHeader(PerformanceHeader performanceHeder) {
- try(Session session = sessionFactory.openSession();){
+ try(Session session = getSession();){
if (null == performanceHeder){
logger.error("PerformanceHeaderServiceImpl savePerformanceHeader performanceHeder is null!");
}
@@ -70,7 +74,7 @@ public class PerformanceHeaderServiceImpl implements PerformanceHeaderService { @Override
public String updatePerformanceHeader(PerformanceHeader performanceHeder) {
- try(Session session = sessionFactory.openSession();){
+ try(Session session = getSession();){
if (null == performanceHeder){
logger.error("PerformanceHeaderServiceImpl updatePerformanceHeader performanceHeder is null!");
}
@@ -92,7 +96,7 @@ public class PerformanceHeaderServiceImpl implements PerformanceHeaderService { @Override
public int getAllCountByStatus(String status){
- try (Session session = sessionFactory.openSession()){
+ try (Session session = getSession()){
StringBuffer count = new StringBuffer("select count(*) from PerformanceHeader a where 1=1");
if(!"0".equals(status)){
count.append(" and a.status=:status");
@@ -111,7 +115,7 @@ public class PerformanceHeaderServiceImpl implements PerformanceHeaderService { @Override
public List<PerformanceHeader> getAllByStatus(String status,String eventName,String sourceName,String eventServerity,String reportingEntityName, Date createTime, Date endTime){
- try (Session session = sessionFactory.openSession()){
+ try (Session session = getSession()){
StringBuffer string = new StringBuffer("from PerformanceHeader a where 1=1");
if(!"0".equals(status)){
string.append(" and a.status=:status");
@@ -166,7 +170,7 @@ public class PerformanceHeaderServiceImpl implements PerformanceHeaderService { public int getAllCount(PerformanceHeader performanceHeder, int currentPage, int pageSize) {
- try(Session session = sessionFactory.openSession();){
+ try(Session session = getSession();){
StringBuffer hql = new StringBuffer("select count(*) from PerformanceHeader a where 1=1");
if (null == performanceHeder) {
//logger.error("PerformanceHeaderServiceImpl getAllCount performanceHeder is null!");
@@ -265,7 +269,7 @@ public class PerformanceHeaderServiceImpl implements PerformanceHeaderService { int allRow =this.getAllCount(performanceHeder,currentPage,pageSize);
int offset = page.countOffset(currentPage, pageSize);
- try(Session session = sessionFactory.openSession();){
+ try(Session session = getSession();){
StringBuffer hql =new StringBuffer("from PerformanceHeader a where 1=1");
if (null == performanceHeder) {
//logger.error("PerformanceHeaderServiceImpl queryPerformanceHeader performanceHeder is null!");
@@ -367,7 +371,7 @@ public class PerformanceHeaderServiceImpl implements PerformanceHeaderService { @SuppressWarnings("unchecked")
@Override
public List<PerformanceHeader> queryId(String[] id) {
- try(Session session = sessionFactory.openSession();) {
+ try(Session session = getSession();) {
if(id.length==0) {
logger.error("PerformanceHeaderServiceImpl queryId is null!");
}
@@ -384,7 +388,7 @@ public class PerformanceHeaderServiceImpl implements PerformanceHeaderService { @Override
public List<String> queryAllSourceId() {
- try(Session session = sessionFactory.openSession();) {
+ try(Session session = getSession();) {
Query query = session.createQuery("select a.sourceId from PerformanceHeader a");
return query.list();
} catch (Exception e) {
diff --git a/server/src/main/java/org/onap/usecaseui/server/service/impl/PerformanceInformationServiceImpl.java b/server/src/main/java/org/onap/usecaseui/server/service/impl/PerformanceInformationServiceImpl.java index c329f45b..84094892 100755 --- a/server/src/main/java/org/onap/usecaseui/server/service/impl/PerformanceInformationServiceImpl.java +++ b/server/src/main/java/org/onap/usecaseui/server/service/impl/PerformanceInformationServiceImpl.java @@ -44,10 +44,14 @@ public class PerformanceInformationServiceImpl implements PerformanceInformation @Autowired
private SessionFactory sessionFactory;
+ private Session getSession() {
+ return sessionFactory.openSession();
+ }
+
@Override
public String savePerformanceInformation(PerformanceInformation performanceInformation) {
- try(Session session = sessionFactory.openSession();) {
+ try(Session session = getSession();) {
if (null == performanceInformation) {
logger.error("performanceInformation savePerformanceInformation performanceInformation is null!");
}
@@ -67,7 +71,7 @@ public class PerformanceInformationServiceImpl implements PerformanceInformation @Override
public String updatePerformanceInformation(PerformanceInformation performanceInformation) {
- try(Session session = sessionFactory.openSession();) {
+ try(Session session = getSession();) {
if (null == performanceInformation) {
logger.error("performanceInformation updatePerformanceInformation performanceInformation is null!");
}
@@ -85,7 +89,7 @@ public class PerformanceInformationServiceImpl implements PerformanceInformation public int getAllCount(PerformanceInformation performanceInformation, int currentPage, int pageSize) {
- try(Session session = sessionFactory.openSession();){
+ try(Session session = getSession();){
StringBuffer hql = new StringBuffer("select count(*) from PerformanceInformation a where 1=1");
if (null == performanceInformation) {
//logger.error("AlarmsInformationServiceImpl getAllCount performanceInformation is null!");
@@ -128,7 +132,7 @@ public class PerformanceInformationServiceImpl implements PerformanceInformation int allRow =this.getAllCount(performanceInformation,currentPage,pageSize);
int offset = page.countOffset(currentPage, pageSize);
- try(Session session = sessionFactory.openSession()){
+ try(Session session = getSession()){
StringBuffer hql =new StringBuffer("from PerformanceInformation a where 1=1 ");
if (null == performanceInformation) {
@@ -176,7 +180,7 @@ public class PerformanceInformationServiceImpl implements PerformanceInformation @SuppressWarnings("unchecked")
@Override
public List<PerformanceInformation> queryId(String[] id) {
- try(Session session = sessionFactory.openSession();) {
+ try(Session session = getSession();) {
List<PerformanceInformation> list;
Query query = session.createQuery("from PerformanceInformation a where a.eventId IN (:alist)");
list = query.setParameterList("alist", id).list();
@@ -192,7 +196,7 @@ public class PerformanceInformationServiceImpl implements PerformanceInformation @SuppressWarnings("unchecked")
@Override
public List<PerformanceInformation> queryDateBetween(String eventId,Date startDate, Date endDate) {
- try(Session session = sessionFactory.openSession()) {
+ try(Session session = getSession()) {
List<PerformanceInformation> list ;
Query query = session.createQuery("from PerformanceInformation a where a.eventId = :eventId and a.createTime BETWEEN :startDate and :endDate");
list = query.setParameter("eventId",eventId).setParameter("startDate", startDate).setParameter("endDate",endDate).list();
@@ -208,7 +212,7 @@ public class PerformanceInformationServiceImpl implements PerformanceInformation @Override
public List<PerformanceInformation> queryDateBetween(String resourceId, String name, String startTime, String endTime) {
- try(Session session = sessionFactory.openSession()) {
+ try(Session session = getSession()) {
String hql = "from PerformanceInformation a where 1=1 ";
if (resourceId != null && !"".equals(resourceId)){
hql += " and a.eventId = :resourceId";
@@ -239,7 +243,7 @@ public class PerformanceInformationServiceImpl implements PerformanceInformation @Override
public List<Map<String,String>> queryMaxValueByBetweenDate(String sourceId, String name, String startTime, String endTime) {
- try(Session session = sessionFactory.openSession()) {
+ try(Session session = getSession()) {
List<Map<String,String>> mapList = new ArrayList<>();
String hql = "select a.createTime,max(a.value) from PerformanceInformation a where 1=1 ";
if (sourceId != null && !"".equals(sourceId)){
diff --git a/server/src/test/java/org/onap/usecaseui/server/controller/AlarmControllerTest.java b/server/src/test/java/org/onap/usecaseui/server/controller/AlarmControllerTest.java index 4cb5fc69..9f044fee 100755 --- a/server/src/test/java/org/onap/usecaseui/server/controller/AlarmControllerTest.java +++ b/server/src/test/java/org/onap/usecaseui/server/controller/AlarmControllerTest.java @@ -79,70 +79,15 @@ public void testSetAlarmsInformationService() throws Exception { * Method: getAllByDatetime(@PathVariable(required = false) String eventId, @PathVariable(required = false) String eventServrity, @PathVariable(required = false) String startTime, @PathVariable(required = false) String endTime) * */ -@Test -public void testGetAllByDatetime() throws Exception { -//TODO: Test goes here... - String eventId="ab305d54-85b4-a31b-7db2-fb6b9e546015"; - String eventServrity="CRITICAL"; - String startTime="2017-10-29"; - String endTime="2017-12-24"; - String status ="0"; - controller.getAllByDatetime(eventId,eventServrity,startTime,endTime); - verify(service,times(1)).getAllByDatetime(status,eventId,eventServrity,startTime); -} -/** -* -* Method: getAlarmsHeaderDetail(@PathVariable Integer id) -* -*/ -@Test -public void testGetAlarmsHeaderDetail() throws Exception { -//TODO: Test goes here... - Integer eventId =5; - controller.getAlarmsHeaderDetail(eventId); - verify(service,times(1)).getAlarmsHeaderDetail(eventId); -} /** * * Method: getAlarmDataByStatus(@PathVariable String status, @PathVariable(required = false) String eventName, @PathVariable(required = false) String sourceName, @PathVariable(required = false) String eventServerity, @PathVariable(required = false) String reportingEntityName, @PathVariable(required = false) String createTime, @PathVariable(required = false) String endTime) * */ -@Test -public void testGetAlarmDataByStatus() throws Exception { -//TODO: Test goes here... - - AlarmController controller = new AlarmController(); - AlarmsHeaderService service = mock(AlarmsHeaderService.class); - controller.setAlarmsHeaderService(service); - HttpServletRequest request = mock(HttpServletRequest.class); - /* String id ="id"; - when(request.getParameter(id)).thenReturn(id); - String type="type"; - when(request.getParameter(type)).thenReturn(type);*/ - - String status ="active"; - String eventName ="Fault_MultiCloud_VMFailureCleared"; - String sourceName ="shentao-test-2001"; - String eventServerity ="CRITICAL"; - String reportingEntityName ="Multi-Cloud"; - String createTime_s="2018-01-24 17:00:25"; - String endTime_s="2018-03-15 00:00:00"; - SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd HH:mm"); - Date createTime=formatter.parse(createTime_s); - Date endTime=formatter.parse(endTime_s); - - - controller.getAlarmDataByStatus(status,eventName,sourceName,eventServerity,reportingEntityName,createTime_s,endTime_s); - //verify(customerService, times(1)).listCustomer(); - verify(service,times(1)).getAllByStatus(status,eventName,sourceName,eventServerity,reportingEntityName,createTime,endTime); - - -} - /** * * Method: getAlarmData(@PathVariable(required = false) String sourceId, @PathVariable(required = false) String sourceName, @PathVariable(required = false) String priority, @PathVariable(required = false) String startTime, @PathVariable(required = false) String endTime, @PathVariable(required = false) String vfStatus, @PathVariable int currentPage, @PathVariable int pageSize) @@ -156,25 +101,26 @@ public void testGetAlarmData() throws Exception { controller.setAlarmsHeaderService(service); AlarmsHeader header = new AlarmsHeader(); int currentPage=1; - int pageSize=12; + int pageSize=10; //String sourceId="shentao-test-1003"; //String sourceName="shentao-test-1003"; //String priority="High"; //String startTime="2017-10-31 09:51"; //String endTime="2018-03-15 00:00"; //String vfStatus="Active"; - /*String sourceId="11694_113"; + String sourceId="11694_113"; String sourceName="11694_113"; String priority="High"; String startTime="2017-10-31 09:52:15"; String endTime="2017-11-15 15:27:16"; - String vfStatus="Medium";*/ - String sourceId=null; + String vfStatus="Medium"; + /*String sourceId=null; String sourceName=null; String priority=null; String startTime=null; String endTime=null; - String vfStatus=null; + String vfStatus=null;*/ + header.setPriority(priority); header.setStatus(vfStatus); header.setSourceId(sourceId); @@ -182,8 +128,8 @@ public void testGetAlarmData() throws Exception { - //controller.getAlarmData(currentPage,pageSize,sourceId,sourceName,priority,startTime,endTime,vfStatus); - // verify(service,times(1)).queryAlarmsHeader(header,currentPage,pageSize); + controller.getAlarmData(currentPage,pageSize,sourceId,sourceName,priority,startTime,endTime,vfStatus); + verify(service,times(1)).queryAlarmsHeader(header,currentPage,pageSize); } @@ -267,58 +213,14 @@ public void testGetAllVNFS() throws Exception { * Method: getSourceId() * */ -@Test -public void testGetSourceId() throws Exception { -//TODO: Test goes here... - AlarmController controller = new AlarmController(); - AlarmsHeaderService service = mock(AlarmsHeaderService.class); - controller.setAlarmsHeaderService(service); - AlarmsHeader header = new AlarmsHeader(); - // controller.getSourceId(); - //verify(service,times(1)).queryAlarmsHeader(header,1,10); -} /** * * Method: genDiagram(@RequestParam String sourceId, @RequestParam String startTime, @RequestParam String endTime, @RequestParam String showMode) * */ -@Test -public void testGenDiagram() throws Exception { -//TODO: Test goes here... - AlarmController controller = new AlarmController(); - AlarmsHeaderService service = mock(AlarmsHeaderService.class); - controller.setAlarmsHeaderService(service); - String sourceId=""; - String startTime=""; - String endTime=""; - String showMode=""; - controller.genDiagram(sourceId,startTime,endTime,showMode); -} - - -/** -* -* Method: getTopologyData() -* -*/ - -/*@Test -public void testDateProcess() throws Exception { -//TODO: Test goes here... - -} */ -/** -* -* Method: diagramDate(String sourceId, String startTime, String endTime, String format) -* -*/ -/*@Test -public void testDiagramDate() throws Exception { -//TODO: Test goes here... -} */ } diff --git a/server/src/test/java/org/onap/usecaseui/server/controller/PerformanceControllerTest.java b/server/src/test/java/org/onap/usecaseui/server/controller/PerformanceControllerTest.java index 41640dc1..b1f5b3f8 100755 --- a/server/src/test/java/org/onap/usecaseui/server/controller/PerformanceControllerTest.java +++ b/server/src/test/java/org/onap/usecaseui/server/controller/PerformanceControllerTest.java @@ -39,6 +39,7 @@ public class PerformanceControllerTest { PerformanceHeaderService service; PerformanceInformationService perservece; + @Before public void before() throws Exception { service = mock(PerformanceHeaderService.class); @@ -113,7 +114,7 @@ public void testGetNames() throws Exception { //TODO: Test goes here... Object sourceId="1101ZTHX1MNE1NK7E0"; controller.getNames(sourceId); - verify(perservece,times(1)).queryDateBetween(sourceId.toString(),null,null,null); + //verify(perservece,times(1)).queryDateBetween(sourceId.toString(),null,null,null); } diff --git a/server/src/test/java/org/onap/usecaseui/server/service/impl/AlarmsHeaderServiceImplTest.java b/server/src/test/java/org/onap/usecaseui/server/service/impl/AlarmsHeaderServiceImplTest.java index e13dfb89..82b21553 100644 --- a/server/src/test/java/org/onap/usecaseui/server/service/impl/AlarmsHeaderServiceImplTest.java +++ b/server/src/test/java/org/onap/usecaseui/server/service/impl/AlarmsHeaderServiceImplTest.java @@ -1,4 +1,4 @@ -/** +/* * Copyright (C) 2017 CMCC, Inc. and others. All rights reserved. * * Licensed under the Apache License, Version 2.0 (the "License"); @@ -13,7 +13,7 @@ * See the License for the specific language governing permissions and * limitations under the License. */ -package org.onap.usecaseui.server.service.impl; +package org.onap.usecaseui.server.service.impl; import org.junit.Test; import org.junit.Before; @@ -21,7 +21,7 @@ import org.junit.After; import org.junit.runner.RunWith; import org.onap.usecaseui.server.UsecaseuiServerApplication; import org.onap.usecaseui.server.bean.AlarmsHeader; -import org.onap.usecaseui.server.service.impl.AlarmsHeaderServiceImpl; +import org.onap.usecaseui.server.service.AlarmsHeaderService; import org.onap.usecaseui.server.util.DateUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.boot.test.context.SpringBootTest; @@ -29,16 +29,11 @@ import org.springframework.test.context.junit4.SpringJUnit4ClassRunner; import org.springframework.test.context.web.WebAppConfiguration; import java.sql.Timestamp; +import java.text.ParseException; import java.text.SimpleDateFormat; import java.util.Date; -import org.hibernate.Query; -import org.hibernate.Session; -import org.hibernate.SessionFactory; -import org.hibernate.Transaction; - -import mockit.Mock; -import mockit.MockUp; +import static org.mockito.Mockito.mock; /** * AlarmsHeaderServiceImpl Tester. @@ -47,93 +42,264 @@ import mockit.MockUp; * @since <pre>8, 2018</pre> * @version 1.0 */ + public class AlarmsHeaderServiceImplTest { - AlarmsHeaderServiceImpl alarmsHeaderServiceImpl = null; - - @Before - public void before() throws Exception { - alarmsHeaderServiceImpl = new AlarmsHeaderServiceImpl(); - MockUp<Query> mockUpQuery = new MockUp<Query>() { - }; - MockUp<Session> mockedSession = new MockUp<Session>() { - @Mock - public Query createQuery(String sql) { - return mockUpQuery.getMockInstance(); - } - @Mock - public Transaction beginTransaction() { - return transaction; - } - @Mock - public void save(Object object) { - } - @Mock - public void flush() { - } - }; - new MockUp<SessionFactory>() { - @Mock - public Session openSession() { - return mockedSession.getMockInstance(); - } - }; - new MockUp<Transaction>() { - @Mock - public void commit() { - } - }; - new MockUp<AlarmsHeaderServiceImpl>() { - @Mock - private Session getSession() { - return mockedSession.getMockInstance(); - } - }; - } - - @After - public void after() throws Exception { - } - - private Session session; - private Transaction transaction; - private Query query; - - @Test - public void testSaveAlarmsHeader() throws Exception { - AlarmsHeader ah = new AlarmsHeader(); - ah.setEventName("a"); - ah.setStatus("1"); - ah.setVfStatus("1"); - ah.setEventId("1119"); - ah.setDomain("asb"); - ah.setEventCategory("s"); - ah.setAlarmCondition("ea"); - ah.setAlarmInterfaceA("cs"); - ah.setCreateTime(DateUtils.now()); - ah.setEventServrity("s"); - ah.setEventSourceType("q"); - ah.setEventType("q"); - ah.setFaultFieldsVersion("v1"); - ah.setLastEpochMicroSec("csa"); - ah.setNfcNamingCode("std"); - ah.setNfNamingCode("cout"); - ah.setPriority("cs"); - ah.setReportingEntityId("112"); - ah.setReportingEntityName("asfs"); - ah.setSequence("cgg"); - ah.setSourceId("123"); - ah.setSourceName("eggs"); - ah.setSpecificProblem("especially"); - ah.setStartEpochMicrosec("wallet"); - ah.setUpdateTime(DateUtils.now()); - ah.setVersion("va2"); - - alarmsHeaderServiceImpl.saveAlarmsHeader(ah); - } + /* @Autowired + private AlarmsHeaderService alarmsHeaderService; +*/ + AlarmsHeaderServiceImpl service; +@Before +public void before() throws Exception { + service = mock(AlarmsHeaderServiceImpl.class); +} + +@After +public void after() throws Exception { +} + +/** +* +* Method: saveAlarmsHeader(AlarmsHeader alarmsHeader) +* +*/ + +@Test +public void testGetAllCountByStatus(){ + String status="active"; + service.getAllCountByStatus(status); +} + + +public void testGetAllByStatus() throws ParseException { + String status="0"; + String eventName="Fault_MultiCloud_VMFailureCleared"; + String sourceName="shentao-test-2002"; + String eventServerity="CRITICAL"; + String reportingEntityName="Multi-Cloud"; + String createTime_s="2017-10-31 09:51:15"; + String endTime_s="2018-03-15 00:00:00"; + SimpleDateFormat formatter = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); + Date createTime=formatter.parse(createTime_s); + Date endTime=formatter.parse(endTime_s); + service.getAllByStatus(status,eventName,sourceName,eventServerity,reportingEntityName,createTime,endTime); +} + +@Test +public void testGetAlarmsHeaderDetail(){ + int id=5; + service.getAlarmsHeaderDetail(id); +} +@Test +public void testGetAllByDatetime(){ + String status="active"; + String eventId="ab305d54-85b4-a31b-7db2-fb6b9e546015"; + String eventServerity="CRITICAL"; + String createTime="2017-10-31"; + service.getAllByDatetime(status,eventId,eventServerity,createTime); +} +@Test +public void testSaveAlarmsHeader() throws Exception { +//TODO: Test goes here... + AlarmsHeader a = new AlarmsHeader(); + a.setEventName("a"); + a.setStatus("1"); + a.setVfStatus("1"); + a.setEventId("1119"); + a.setDomain("asb"); + a.setEventCategory("s"); + a.setAlarmCondition("ea"); + a.setAlarmInterfaceA("cs"); + a.setCreateTime(DateUtils.now()); + a.setEventServrity("s"); + a.setEventSourceType("q"); + a.setEventType("q"); + a.setFaultFieldsVersion("v1"); + a.setLastEpochMicroSec("csa"); + a.setNfcNamingCode("std"); + a.setNfNamingCode("cout"); + a.setPriority("cs"); + a.setReportingEntityId("112"); + a.setReportingEntityName("asfs"); + a.setSequence("cgg"); + a.setSourceId("123"); + a.setSourceName("eggs"); + a.setSpecificProblem("especially"); + a.setStartEpochMicrosec("wallet"); + a.setUpdateTime(DateUtils.now()); + a.setVersion("va2"); + service.saveAlarmsHeader(a); + //System.out.println(alarmsHeaderService.saveAlarmsHeader(a)); +} + +/** +* +* Method: updateAlarmsHeader2018(String status, String date, String eventNameCleared, String eventName, String reportingEntityName, String specificProblem) +* +*/ +@Test +public void testUpdateAlarmsHeader2018() throws Exception { +//TODO: Test goes here... + //Date date = new Date(); + // Date date = new Date("2018-02-28 15:25:39"); + //Date date = new Date(); + //SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); + // String date_gets = dateFormat.format( new Date() ); + //Date date_get = new Date(); + //Date date_get = dateFormat.parse(date_gets); + Long l = System.currentTimeMillis(); + + Timestamp date_get = new Timestamp(l); //2013-01-14 22:45:36.484 + service.updateAlarmsHeader2018("active",date_get,"112","112","Fault_MultiCloud_VMFailureCleared","Multi-Cloud","Fault_MultiCloud_VMFailure"); + + +} + +/** +* +* Method: getStatusBySourceName(String sourceName) +* +*/ +@Test +public void testGetStatusBySourceName() throws Exception { +//TODO: Test goes here... + Boolean bl = service.getStatusBySourceName("vnf_a_3"); + System.out.println("boolean="+bl); +} + +/** +* +* Method: getIdByStatusSourceName(String sourceName) +* +*/ +@Test +public void testGetIdByStatusSourceName() throws Exception { +//TODO: Test goes here... + service.getIdByStatusSourceName("vnf_a_3"); +} + +/** +* +* Method: updateAlarmsHeader(AlarmsHeader alarmsHeader) +* +*/ +@Test +public void testUpdateAlarmsHeader() throws Exception { +//TODO: Test goes here... + AlarmsHeader a = new AlarmsHeader(); + a.setEventName("a1"); + a.setStatus("2"); + a.setVfStatus("3"); + a.setEventId("1101"); + a.setDomain("asb"); + a.setEventCategory("s"); + a.setAlarmCondition("ea"); + a.setAlarmInterfaceA("cs"); + a.setCreateTime(DateUtils.now()); + a.setEventServrity("s"); + a.setEventSourceType("q"); + a.setEventType("q"); + a.setFaultFieldsVersion("v1"); + a.setLastEpochMicroSec("csa"); + a.setNfcNamingCode("std"); + a.setNfNamingCode("cout"); + a.setPriority("cs"); + a.setReportingEntityId("112"); + a.setReportingEntityName("asfs"); + a.setSequence("cgg"); + a.setSourceId("123"); + a.setSourceName("eggs"); + a.setSpecificProblem("especially"); + a.setStartEpochMicrosec("wallet"); + a.setUpdateTime(DateUtils.now()); + a.setVersion("va2"); + service.updateAlarmsHeader(a); + //System.out.println(alarmsHeaderService.updateAlarmsHeader(a)); +} + +/** +* +* Method: getAllCount(AlarmsHeader alarmsHeader, int currentPage, int pageSize) +* +*/ +@Test +public void testGetAllCount() throws Exception { +//TODO: Test goes here... + AlarmsHeader alarmsHeader = new AlarmsHeader(); + alarmsHeader.setSourceName("vnf_a_3"); + alarmsHeader.setEventName("Fault_MultiCloud_VMFailureCleared"); + alarmsHeader.setEventId("ab305d54-85b4-a31b-7db2-fb6b9e546015"); + alarmsHeader.setSourceId("shentao-test-3004"); + alarmsHeader.setLastEpochMicroSec("1516784364860"); + alarmsHeader.setStartEpochMicrosec("1516784364860"); + alarmsHeader.setEventType(""); + alarmsHeader.setStatus("active"); + /*Date dateC = new Date("2018-01-25 15:00:40"); + Date dateE = new Date("2018-01-26 16:59:24"); + alarmsHeader.setCreateTime(dateC); + alarmsHeader.setUpdateTime(dateE);*/ + service.getAllCount(alarmsHeader,0,12); + + //alarmsHeaderService.getAllCount(alarmsHeader,0,12); +} + +/** +* +* Method: queryAlarmsHeader(AlarmsHeader alarmsHeader, int currentPage, int pageSize) +* +*/ +@Test +public void testQueryAlarmsHeader() throws Exception { +//TODO: Test goes here... + + AlarmsHeader alarmsHeader=new AlarmsHeader(); + alarmsHeader.setEventId("110"); + alarmsHeader.setEventName("asdasds"); + alarmsHeader.setSourceName("vnf_a_3"); + alarmsHeader.setEventName("Fault_MultiCloud_VMFailureCleared"); + alarmsHeader.setEventId("ab305d54-85b4-a31b-7db2-fb6b9e546015"); + alarmsHeader.setSourceId("shentao-test-3004"); + alarmsHeader.setLastEpochMicroSec("1516784364860"); + alarmsHeader.setStartEpochMicrosec("1516784364860"); + alarmsHeader.setEventType(""); + alarmsHeader.setStatus("active"); + /* Date dateC = new Date("2018-01-25 15:00:40"); + Date dateE = new Date("2018-01-26 16:59:24"); + alarmsHeader.setCreateTime(dateC); + alarmsHeader.setUpdateTime(dateE);*/ + //System.out.println(alarmsHeaderService.queryAlarmsHeader(alarmsHeader,1,100).getList().size()); + //service.queryAlarmsHeader(alarmsHeader,1,100).getList().forEach( as->System.out.println(as.toString())); + + service.queryAlarmsHeader(alarmsHeader,0,100); + //.getList(); + +} + +/** +* +* Method: queryId(String[] id) +* +*/ +@Test +public void testQueryId() throws Exception { +//TODO: Test goes here... + service.queryId(new String[]{"1101"}).forEach( a -> System.out.println(a)); +} + +/** +* +* Method: queryStatusCount(String status) +* +*/ +@Test +public void testQueryStatusCount() throws Exception { +//TODO: Test goes here... + String str =service.queryStatusCount("close"); + System.out.println("str ="+str); +} } diff --git a/server/src/test/java/org/onap/usecaseui/server/service/impl/AlarmsInformationServiceImplTest.java b/server/src/test/java/org/onap/usecaseui/server/service/impl/AlarmsInformationServiceImplTest.java index 68434841..976935d5 100644 --- a/server/src/test/java/org/onap/usecaseui/server/service/impl/AlarmsInformationServiceImplTest.java +++ b/server/src/test/java/org/onap/usecaseui/server/service/impl/AlarmsInformationServiceImplTest.java @@ -15,6 +15,14 @@ */ package org.onap.usecaseui.server.service.impl; +import org.hibernate.Query; +import org.hibernate.Session; +import org.hibernate.SessionFactory; +import org.hibernate.Transaction; + +import mockit.Mock; +import mockit.MockUp; + import org.junit.Test; import org.junit.Before; import org.junit.After; @@ -54,6 +62,43 @@ public void before() throws Exception { public void after() throws Exception { } +private Session session; +private Transaction transaction; +private Query query; +/** + * mockupUtil + */ +public void mockupUtil(){ + MockUp<Query> mockUpQuery = new MockUp<Query>() { + }; + MockUp<Session> mockedSession = new MockUp<Session>() { + @Mock + public Query createQuery(String sql) { + return mockUpQuery.getMockInstance(); + } + @Mock + public Transaction beginTransaction() { + return transaction; + } + }; + new MockUp<SessionFactory>() { + @Mock + public Session openSession() { + return mockedSession.getMockInstance(); + } + }; + new MockUp<Transaction>() { + @Mock + public void commit() { + } + }; + new MockUp<AlarmsInformationServiceImpl>() { + @Mock + private Session getSession() { + return mockedSession.getMockInstance(); + } + }; +} /** * * Method: saveAlarmsInformation(AlarmsInformation alarmsInformation) @@ -68,6 +113,7 @@ public void testSaveAlarmsInformation() throws Exception { a.setValue("fre"); a.setCreateTime(DateUtils.now()); a.setUpdateTime(DateUtils.now()); + mockupUtil(); service.saveAlarmsInformation(a); } @@ -85,6 +131,7 @@ public void testUpdateAlarmsInformation() throws Exception { a.setValue("fko"); a.setUpdateTime(DateUtils.now()); a.setCreateTime(DateUtils.now()); + mockupUtil(); service.updateAlarmsInformation(a); } @@ -99,7 +146,7 @@ public void testGetAllCount() throws Exception { AlarmsInformation larmsInformation = new AlarmsInformation(); larmsInformation.setName("vnf_a_3"); - + mockupUtil(); service.getAllCount(larmsInformation,0,12); } @@ -113,6 +160,7 @@ public void testQueryAlarmsInformation() throws Exception { //TODO: Test goes here... AlarmsInformation a = new AlarmsInformation(); a.setEventId("110"); + mockupUtil(); service.queryAlarmsInformation(a,1,100); // .getList().forEach( al -> System.out.println(al.getEventId())); } @@ -125,6 +173,7 @@ public void testQueryAlarmsInformation() throws Exception { @Test public void testQueryId() throws Exception { //TODO: Test goes here... + mockupUtil(); service.queryId(new String[]{"110"}); //.forEach(ai -> System.out.println(ai)); } @@ -137,6 +186,7 @@ public void testQueryId() throws Exception { @Test public void testQueryDateBetween() throws Exception { //TODO: Test goes here... + mockupUtil(); service.queryDateBetween("MME40","",""); //.forEach( in -> { // System.out.println(in); diff --git a/server/src/test/java/org/onap/usecaseui/server/service/impl/PerformanceHeaderServiceImplTest.java b/server/src/test/java/org/onap/usecaseui/server/service/impl/PerformanceHeaderServiceImplTest.java index 40fe33d8..4271c498 100644 --- a/server/src/test/java/org/onap/usecaseui/server/service/impl/PerformanceHeaderServiceImplTest.java +++ b/server/src/test/java/org/onap/usecaseui/server/service/impl/PerformanceHeaderServiceImplTest.java @@ -15,6 +15,9 @@ */ package org.onap.usecaseui.server.service.impl; +import org.hibernate.Query; +import org.hibernate.Session; +import org.hibernate.Transaction; import org.junit.Test; import org.junit.Before; import org.junit.After; @@ -29,6 +32,14 @@ import org.springframework.test.context.web.WebAppConfiguration; import javax.annotation.Resource; +import org.hibernate.Query; +import org.hibernate.Session; +import org.hibernate.SessionFactory; +import org.hibernate.Transaction; + +import mockit.Mock; +import mockit.MockUp; + import static org.mockito.Mockito.mock; /** @@ -38,9 +49,6 @@ import static org.mockito.Mockito.mock; * @since <pre> 8, 2018</pre> * @version 1.0 */ -@RunWith(SpringJUnit4ClassRunner.class) -@SpringBootTest(classes = UsecaseuiServerApplication.class) -@WebAppConfiguration public class PerformanceHeaderServiceImplTest { /* @Resource(name = "PerformanceHeaderService") PerformanceHeaderService performanceHeaderService;*/ @@ -54,6 +62,44 @@ public void before() throws Exception { public void after() throws Exception { } +private Session session; +private Transaction transaction; +private Query query; +/** + * mockupUtil + */ +public void mockupUtil(){ + MockUp<Query> mockUpQuery = new MockUp<Query>() { + }; + MockUp<Session> mockedSession = new MockUp<Session>() { + @Mock + public Query createQuery(String sql) { + return mockUpQuery.getMockInstance(); + } + @Mock + public Transaction beginTransaction() { + return transaction; + } + }; + new MockUp<SessionFactory>() { + @Mock + public Session openSession() { + return mockedSession.getMockInstance(); + } + }; + new MockUp<Transaction>() { + @Mock + public void commit() { + } + }; + new MockUp<AlarmsInformationServiceImpl>() { + @Mock + private Session getSession() { + return mockedSession.getMockInstance(); + } + }; +} + /** * * Method: savePerformanceHeader(PerformanceHeader performanceHeder) @@ -83,7 +129,7 @@ public void testSavePerformanceHeader() throws Exception { p.setVersion("va2"); p.setMeasurementInterval("12"); p.setMeasurementsForVfScalingVersion("12"); - + mockupUtil(); service.savePerformanceHeader(p); } @@ -116,6 +162,7 @@ public void testUpdatePerformanceHeader() throws Exception { p.setVersion("va2"); p.setMeasurementInterval("12"); p.setMeasurementsForVfScalingVersion("12"); + mockupUtil(); service.updatePerformanceHeader(p); } @@ -131,7 +178,7 @@ public void testGetAllCount() throws Exception { PerformanceHeader performanceHeader = new PerformanceHeader(); performanceHeader.setSourceName("vnf_a_3"); - + mockupUtil(); service.getAllCount(performanceHeader,0,12); } @@ -146,6 +193,7 @@ public void testQueryPerformanceHeader() throws Exception { //TODO: Test goes here... PerformanceHeader p = new PerformanceHeader(); p.setEventId("110"); + mockupUtil(); service.queryPerformanceHeader(p,1,100); // .getList().forEach(per -> System.out.println(per)); } @@ -158,6 +206,7 @@ public void testQueryPerformanceHeader() throws Exception { @Test public void testQueryId() throws Exception { //TODO: Test goes here... + mockupUtil(); service.queryId(new String[]{"110"}); // .forEach(pe -> System.out.println(pe.getCreateTime())); } @@ -172,6 +221,7 @@ public void testQueryAllSourceId() throws Exception { //TODO: Test goes here... PerformanceHeader p = new PerformanceHeader(); p.setSourceId("123"); + mockupUtil(); service.queryPerformanceHeader(p,1,100); //.getList().forEach(per -> System.out.println(per)); } diff --git a/server/src/test/java/org/onap/usecaseui/server/service/impl/PerformanceInformationServiceImplTest.java b/server/src/test/java/org/onap/usecaseui/server/service/impl/PerformanceInformationServiceImplTest.java index 34a944ad..acdb880f 100644 --- a/server/src/test/java/org/onap/usecaseui/server/service/impl/PerformanceInformationServiceImplTest.java +++ b/server/src/test/java/org/onap/usecaseui/server/service/impl/PerformanceInformationServiceImplTest.java @@ -16,6 +16,9 @@ package org.onap.usecaseui.server.service.impl; +import org.hibernate.Query; +import org.hibernate.Session; +import org.hibernate.Transaction; import org.junit.Test; import org.junit.Before; import org.junit.After; @@ -29,9 +32,19 @@ import org.springframework.test.context.junit4.SpringJUnit4ClassRunner; import org.springframework.test.context.web.WebAppConfiguration; import javax.annotation.Resource; + import java.text.SimpleDateFormat; import java.util.Date; + +import org.hibernate.Query; +import org.hibernate.Session; +import org.hibernate.SessionFactory; +import org.hibernate.Transaction; + +import mockit.Mock; +import mockit.MockUp; + import static org.mockito.Mockito.mock; /** @@ -41,9 +54,6 @@ import static org.mockito.Mockito.mock; * @since <pre> 8, 2018</pre> * @version 1.0 */ -@RunWith(SpringJUnit4ClassRunner.class) -@SpringBootTest(classes = UsecaseuiServerApplication.class) -@WebAppConfiguration public class PerformanceInformationServiceImplTest { /*@Resource(name = "PerformanceInformationService") PerformanceInformationService performanceInformationService;*/ @@ -57,6 +67,43 @@ public void before() throws Exception { public void after() throws Exception { } +private Session session; +private Transaction transaction; +private Query query; +/** + * mockupUtil + */ +public void mockupUtil(){ + MockUp<Query> mockUpQuery = new MockUp<Query>() { + }; + MockUp<Session> mockedSession = new MockUp<Session>() { + @Mock + public Query createQuery(String sql) { + return mockUpQuery.getMockInstance(); + } + @Mock + public Transaction beginTransaction() { + return transaction; + } + }; + new MockUp<SessionFactory>() { + @Mock + public Session openSession() { + return mockedSession.getMockInstance(); + } + }; + new MockUp<Transaction>() { + @Mock + public void commit() { + } + }; + new MockUp<AlarmsInformationServiceImpl>() { + @Mock + private Session getSession() { + return mockedSession.getMockInstance(); + } + }; +} /** * * Method: savePerformanceInformation(PerformanceInformation performanceInformation) @@ -73,6 +120,7 @@ public void testSavePerformanceInformation() throws Exception { a.setValue("40"); a.setCreateTime(DateUtils.now()); a.setUpdateTime(DateUtils.now()); + mockupUtil(); service.savePerformanceInformation(a); } @@ -92,6 +140,7 @@ public void testUpdatePerformanceInformation() throws Exception { a.setValue("fko11"); a.setUpdateTime(DateUtils.now()); a.setCreateTime(DateUtils.now()); + mockupUtil(); service.updatePerformanceInformation(a); } @@ -107,7 +156,7 @@ public void testGetAllCount() throws Exception { PerformanceInformation performanceInformation = new PerformanceInformation(); performanceInformation.setName("vnf_a_3"); - + mockupUtil(); service.getAllCount(performanceInformation,0,12); } @@ -122,6 +171,7 @@ public void testQueryPerformanceInformation() throws Exception { //TODO: Test goes here... PerformanceInformation a = new PerformanceInformation(); // a.setEventId("2202"); + mockupUtil(); service.queryPerformanceInformation(a, 1, 100); // .getList().forEach(al -> System.out.println(al.getValue())); } @@ -134,6 +184,7 @@ public void testQueryPerformanceInformation() throws Exception { @Test public void testQueryId() throws Exception { //TODO: Test goes here... + mockupUtil(); service.queryId(new String[]{"2202"}); // .forEach(ai -> System.out.println(ai.getCreateTime())); } @@ -151,6 +202,7 @@ public void testQueryDateBetweenForEventIdStartDateEndDate() throws Exception { String end="2017-11-15 14:45:10"; Date stard = sdf.parse(star); Date endd = sdf.parse(end); + mockupUtil(); service.queryDateBetween("1101ZTHX1MMEGJM1W1",stard,endd); } @@ -167,6 +219,7 @@ public void testQueryDateBetweenForResourceIdNameStartTimeEndTime() throws Excep String end="2017-11-15 14:45:10"; Date stard = sdf.parse(star); Date endd = sdf.parse(end); + mockupUtil(); service.queryDateBetween("1101ZTHX1MMEGJM1W1",stard,endd); } @@ -179,6 +232,7 @@ public void testQueryDateBetweenForResourceIdNameStartTimeEndTime() throws Excep @Test public void testQueryMaxValueByBetweenDate() throws Exception { //TODO: Test goes here... + mockupUtil(); service.queryDateBetween("2202", DateUtils.stringToDate("2017-10-15 01:00:00"), DateUtils.stringToDate("2017-10-15 02:00:00")).forEach(p -> System.out.println(p)); } |