From 2eb2886fb20571f092ed29ab434c9b759a76eeab Mon Sep 17 00:00:00 2001 From: fxxian Date: Thu, 25 Apr 2024 00:02:44 +0800 Subject: [PATCH] =?UTF-8?q?feat:=20mobile=20api=20=E5=85=BC=E5=AE=B91?= =?UTF-8?q?=E4=BB=A3=E8=AE=BE=E5=A4=87?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- apps/counter/api/mobile/serializers.py | 86 +++++++++++++++++--------- 1 file changed, 57 insertions(+), 29 deletions(-) diff --git a/apps/counter/api/mobile/serializers.py b/apps/counter/api/mobile/serializers.py index 06ae737..9f3973e 100644 --- a/apps/counter/api/mobile/serializers.py +++ b/apps/counter/api/mobile/serializers.py @@ -5,6 +5,7 @@ from django.utils.timezone import datetime from rest_framework import serializers from counter.models import DeviceCount, DeviceInfo from mosquito.models import DeviceInfo as MosquitoDeviceInfo +from counter.api.serializers import get_device_latest_by_cache, get_vol class LedHealthStatus(Enum): @@ -65,9 +66,9 @@ class DeviceInfoMobileSerializer(serializers.ModelSerializer): chip_type = serializers.SerializerMethodField() remote_control_enabled = serializers.SerializerMethodField() status = serializers.SerializerMethodField() - csq = serializers.SerializerMethodField() + signal = serializers.SerializerMethodField() count = serializers.SerializerMethodField() - vol = serializers.SerializerMethodField() + energy = serializers.SerializerMethodField() coordinate = serializers.SerializerMethodField() location = serializers.SerializerMethodField() led_status = serializers.SerializerMethodField() @@ -82,8 +83,8 @@ class DeviceInfoMobileSerializer(serializers.ModelSerializer): 'remote_control_enabled', 'status', 'count', - 'csq', - 'vol', + 'signal', + 'energy', 'led_status', 'led_health', 'coordinate', @@ -93,14 +94,14 @@ class DeviceInfoMobileSerializer(serializers.ModelSerializer): def __init__(self, *args, **kwargs): super().__init__(*args, **kwargs) self.latest = None - self.mosq_device = None self.counter_device = None + self.mosq_device_info = None def get_device_name(self, obj) -> Optional[str]: qs = MosquitoDeviceInfo.objects.filter(device_id=obj.device_id) if qs.count() > 0: device = qs.first() - self.mosq_device = device + self.mosq_device_info = device return device.device_name return None @@ -111,48 +112,75 @@ class DeviceInfoMobileSerializer(serializers.ModelSerializer): return obj.chip_type == 'AIR-V2' def get_status(self, obj) -> int: + # 区分一代和二代设备 + if obj.chip_type == 'AIR-V2': + mosq_device_info = self.mosq_device_info + if mosq_device_info and mosq_device_info.last_connect: + self.mosq_device_info = mosq_device_info + now = datetime.now(pytz.utc) + dt = abs(now - mosq_device_info.last_connect) + if dt.seconds > 300: + return 0 + else: + return 1 return obj.online def get_coordinate(self, obj): - if self.mosq_device: - lon, lat = [self.mosq_device.longitude, self.mosq_device.latitude] + if self.mosq_device_info: + lon, lat = [self.mosq_device_info.longitude, self.mosq_device_info.latitude] if lon and lat: return [lon, lat] return None def get_location(self, obj): - if self.mosq_device: - return self.mosq_device.location + if self.mosq_device_info: + return self.mosq_device_info.location return None def get_count(self, obj): - device = DeviceCount.objects.filter( - device_id=self.mosq_device.device_id).order_by('-data_time').first() - if device: - self.counter_device = device - return device.count - return None + self.latest = get_device_latest_by_cache(obj.device_id) - def get_csq(self, obj): - if self.counter_device: - return self.counter_device.csq - return None + # 区分一代和二代设备 + if obj.chip_type == 'AIR-V2': + if self.mosq_device_info and self.mosq_device_info.count is not None: + return str(self.mosq_device_info.count) - def get_vol(self, obj): - if self.counter_device: - return self.counter_device.vol - return None + if self.latest: + return self.latest['count'] + return '0' + + def get_signal(self, obj): + # 区分一代和二代设备 + if obj.chip_type == 'AIR-V2': + if self.mosq_device_info and self.mosq_device_info.signal is not None: + return str(self.mosq_device_info.signal) + + if self.latest: + return self.latest['csq'] + return '0' + + def get_energy(self, obj): + # 区分一代和二代设备 + if obj.chip_type == 'AIR-V2': + if self.mosq_device_info and self.mosq_device_info.energy is not None: + return str(self.mosq_device_info.energy) + + if self.latest: + if float(self.latest['vol']) <= 100: + return '{}{}'.format(round(float(self.latest['vol']), 1), '%') + return get_vol(obj.device_id, self.latest['vol']) + return '0%' def get_led_status(self, obj): - if self.mosq_device: - return self.mosq_device.led_status + if self.mosq_device_info: + return self.mosq_device_info.led_status return None def get_led_health(self, obj): - if self.mosq_device: - diff = datetime.now(tz=pytz.timezone('UTC')) - self.mosq_device.launch_time + if self.mosq_device_info: + diff = datetime.now(tz=pytz.timezone('UTC')) - self.mosq_device_info.launch_time hours = diff.days * 24 + int(diff.seconds / 3600) - rate = hours / self.mosq_device.led_lifetime + rate = hours / self.mosq_device_info.led_lifetime if rate <= 0.3: return LedHealthStatus.Good.value if 0.3 < rate <= 0.6: