Преглед на файлове

fix: 修复异常断开的指标统计

lijian преди 2 години
родител
ревизия
3313d02ea5
променени са 1 файла, в които са добавени 3 реда и са изтрити 1 реда
  1. 3 1
      services/mqttaccess/mqtt_provider.go

+ 3 - 1
services/mqttaccess/mqtt_provider.go

@@ -45,7 +45,9 @@ func (mp *MQTTProvider) OnDeviceOnline(args rpcs.ArgsGetOnline, VendorId string)
 	return err
 }
 func (mp *MQTTProvider) OnDeviceOffline(deviceid string, vendorId string) error {
-	deviceOnlineCount.Dec()
+	if deviceid != "" {
+		deviceOnlineCount.Dec()
+	}
 	args := rpcs.ArgsGetOffline{
 		Id:       deviceid,
 		VendorId: vendorId,