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

change getOrNull() to getByInventoryIdOrNull() to get equipment

Browse Source
This commit is contained in:
Thomas-Leung2021
2021-07-05 19:27:02 -04:00
committed by Mike Hansen
parent 716e5d8129
commit 2aa51afe9d
1 changed files with 4 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
opensync-ext-cloud/src/main/java/com/telecominfraproject/wlan/opensync/external/integration/utils/MqttStatsPublisher.java vendored
View File

@@ -156,19 +156,15 @@ public class MqttStatsPublisher {
public void processMqttMessage(String topic, Report report) { public void processMqttMessage(String topic, Report report) {
LOG.info("Received report on topic {} for ap {}", topic, report.getNodeID()); LOG.info("Received report on topic {} for ap {}", topic, report.getNodeID());
int customerId = extractCustomerIdFromTopic(topic);
String apId = extractApIdFromTopic(topic); String apId = extractApIdFromTopic(topic);
long equipmentId = extractEquipmentIdFromTopic(topic); Equipment ce = equipmentServiceInterface.getByInventoryIdOrNull(apId);
if ((equipmentId <= 0) || (customerId <= 0)) {
LOG.warn("Cannot determine equipment ids from topic {} - customerId {} equipmentId {}", topic, customerId, equipmentId);
return;
}
Equipment ce = equipmentServiceInterface.getOrNull(equipmentId);
if (ce == null) { if (ce == null) {
LOG.warn("Cannot read equipment {}", apId); LOG.warn("Cannot read equipment {}", apId);
return; return;
} }
int customerId = ce.getCustomerId();
long equipmentId = ce.getId();
long locationId = ce.getLocationId(); long locationId = ce.getLocationId();
long profileId = ce.getProfileId(); long profileId = ce.getProfileId();