scottk/wlan-cloud-opensync-controller
1
0
Fork 0
mirror of https://github.com/Telecominfraproject/wlan-cloud-opensync-controller.git synced 2025-11-03 20:17:53 +00:00
Code Issues Packages Projects Releases 1 Wiki Activity

populate location Id on client sessions

Browse Source
This commit is contained in:
Dmitry Toptygin
2020-06-11 17:43:34 -04:00
parent bcb5806534
commit 8cfb4e93b0
1 changed files with 7 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
opensync-ext-cloud/src/main/java/com/telecominfraproject/wlan/opensync/external/integration/OpensyncExternalIntegrationCloud.java vendored
View File

@@ -920,7 +920,7 @@ public class OpensyncExternalIntegrationCloud implements OpensyncExternalIntegra
}
}
private void handleClientSessionUpdate(int customerId, long equipmentId, String apId, int channel,
private void handleClientSessionUpdate(int customerId, long equipmentId, String apId, long locationId, int channel,
RadioBandType band, long timestamp, sts.PlumeStats.Client client) {
com.telecominfraproject.wlan.client.models.Client clientInstance = clientServiceInterface.getOrNull(customerId,
@@ -944,6 +944,7 @@ public class OpensyncExternalIntegrationCloud implements OpensyncExternalIntegra
clientSession = new ClientSession();
clientSession.setCustomerId(customerId);
clientSession.setEquipmentId(equipmentId);
clientSession.setLocationId(locationId);
clientSession.setMacAddress(new MacAddress(client.getMacAddress()));
clientSession.setDetails(new ClientSessionDetails());
@@ -1009,6 +1010,10 @@ public class OpensyncExternalIntegrationCloud implements OpensyncExternalIntegra
ServiceMetric smr = new ServiceMetric(customerId, equipmentId);
ApSsidMetrics apSsidMetrics = new ApSsidMetrics();
//we need to populate location Id on the client sessions, that's why we're getting equipment object in here (from the cache)
Equipment equipment = getCustomerEquipment(apId);
long locationId = (equipment != null) ? equipment.getLocationId() : 0 ;
smr.setDetails(apSsidMetrics);
LOG.debug("ApSsidMetrics Keys {}: ", apSsidMetrics.getSsidStats().keySet());
metricRecordList.add(smr);
@@ -1036,7 +1041,7 @@ public class OpensyncExternalIntegrationCloud implements OpensyncExternalIntegra
rxRetries += client.getStats().getRxRetries();
lastRssi = client.getStats().getRssi();
try {
handleClientSessionUpdate(customerId, equipmentId, apId, clientReport.getChannel(),
handleClientSessionUpdate(customerId, equipmentId, apId, locationId, clientReport.getChannel(),
clientReport.getBand(), clientReport.getTimestampMs(), client);
} catch (Exception e) {
LOG.debug("Unabled to update client {} session {}", client, e);