Fix outlets is null

Signed-off-by: Pengpeng Wang <pengpengw@vmware.com>
vmware · May 13, 2021 · 0c47756 · 0c47756
1 parent 043600b
commit 0c47756
Show file tree

Hide file tree

Showing 2 changed files with 46 additions and 2 deletions.
diff --git a/flowgate-api/src/main/java/com/vmware/flowgate/service/AssetService.java b/flowgate-api/src/main/java/com/vmware/flowgate/service/AssetService.java
@@ -1093,6 +1093,9 @@ public List<MetricData> getMetricsByID(String assetID, Long starttime, Integer d
          assetAndValueUnitsMap = getServerRawMetrics(asset, starttime, duration);
          //2. Remove or filter
          List<ValueUnit> serverHostUsageValueUnits = assetAndValueUnitsMap.get(assetID);
+         if(serverHostUsageValueUnits == null || serverHostUsageValueUnits.isEmpty()) {
+            return translateToMetricDataForServer(assetAndValueUnitsMap, asset);
+         }
          removeServerUnusedMetrics(serverHostUsageValueUnits);
          filterServerEneryConsumptionMetrics(serverHostUsageValueUnits, starttime);
          //3. Translate
@@ -1578,10 +1581,9 @@ private Map<String, Map<String, String>> getMetricDispalyNameAndFormulaMapForSer
          Map<String,String> justficationfileds = server.getJustificationfields();
          String allPduPortInfo = justficationfileds.get(FlowgateConstant.PDU_PORT_FOR_SERVER);
          List<String> pduPorts = null;
-         Map<String, List<String>> pduAssetIdAndUsedOutletMap = null;
+         Map<String, List<String>> pduAssetIdAndUsedOutletMap = new HashMap<String, List<String>>();;
          if (!StringUtils.isEmpty(allPduPortInfo)) {
             pduPorts = Arrays.asList(allPduPortInfo.split(FlowgateConstant.SPILIT_FLAG));
-            pduAssetIdAndUsedOutletMap = new HashMap<String, List<String>>();
             for (String pduPortInfo : pduPorts) {
                // startport_FIELDSPLIT_endDeviceName_FIELDSPLIT_endport_FIELDSPLIT_endDeviceAssetID
                // item[0] start port

diff --git a/flowgate-api/src/test/java/com/vmware/flowgate/controller/AssetControllerTest.java b/flowgate-api/src/test/java/com/vmware/flowgate/controller/AssetControllerTest.java
@@ -3148,6 +3148,48 @@ public void testGetServerMetricsByID() {
       realtimeDataRepository.deleteById(hostRealTimeData.getId());
    }
 
+   @Test
+   public void testGetServerMetricsOutLetisNull() {
+      Asset asset = createAsset();
+      List<RealTimeData> realTimeDatas = new ArrayList<RealTimeData>();
+      long time = System.currentTimeMillis();
+      int duration = 30*60*1000;
+      long startTime = time - duration;
+      RealTimeData pduUsageMetricData = createPduAllRealTimeData(startTime);
+      pduUsageMetricData.setAssetID("0001bdc8b25d4c2badfd045ab61aabfa");
+      realTimeDatas.add(pduUsageMetricData);
+      realtimeDataRepository.saveAll(realTimeDatas);
+
+      asset = fillingMetricsformula(asset);
+      HashMap<String, String> justificationfields = new HashMap<>();
+      justificationfields.put(FlowgateConstant.PDU_PORT_FOR_SERVER, "power-2_FIELDSPLIT_CAN1-MDF-R01-PDU-BUILDING_FIELDSPLIT_OUTLET:1_FIELDSPLIT_0001bdc8b25d4c2badfd045ab61aabfa");
+      asset.setJustificationfields(justificationfields);
+      asset = assetRepository.save(asset);
+
+      List<MetricData> metricDatas =
+            assetService.getMetricsByID(asset.getId(), startTime, duration);
+      for(MetricData serverdata : metricDatas) {
+         String metricName = serverdata.getMetricName();
+         if(String.format(MetricKeyName.SERVER_CONNECTED_PDUX_POWER_LOAD, "0001bdc8b25d4c2badfd045ab61aabfa").
+                  equals(metricName)) {
+            TestCase.assertEquals(0.05, serverdata.getValueNum());
+         }else if(String.format(MetricKeyName.SERVER_CONNECTED_PDUX_CURRENT_LOAD, "0001bdc8b25d4c2badfd045ab61aabfa").
+                  equals(metricName)) {
+            TestCase.assertEquals(0.05, serverdata.getValueNum());
+         }else if(String.format(MetricKeyName.SERVER_CONNECTED_PDUX_TOTAL_CURRENT, "0001bdc8b25d4c2badfd045ab61aabfa").
+                  equals(metricName)) {
+            TestCase.assertEquals(1.455, serverdata.getValueNum());
+         }else if(String.format(MetricKeyName.SERVER_CONNECTED_PDUX_TOTAL_POWER, "0001bdc8b25d4c2badfd045ab61aabfa").
+                  equals(metricName)) {
+            TestCase.assertEquals(0.322, serverdata.getValueNum());
+         }else if(MetricName.SERVER_VOLTAGE.equals(metricName)) {
+            TestCase.assertEquals(221.0, serverdata.getValueNum());
+         }
+      }
+      assetRepository.deleteById(asset.getId());
+      realtimeDataRepository.deleteById(pduUsageMetricData.getId());
+   }
+
    @Test
    public void testGetMetricsDurationAPI() throws Exception {
       FieldDescriptor[] fieldpath = new FieldDescriptor[] {