From 0dbecbc439121e46ebdda82841da385f89a78c8a Mon Sep 17 00:00:00 2001 From: caoqianming Date: Thu, 13 Jun 2024 09:49:15 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E4=BF=AE=E6=94=B9=E5=AD=98=E5=82=A8?= =?UTF-8?q?=E9=A2=91=E6=AC=A12?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- mqttc.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/mqttc.py b/mqttc.py index fb906d5..ac50bb9 100644 --- a/mqttc.py +++ b/mqttc.py @@ -54,8 +54,8 @@ def save_items(payload): data['timex'] = datetime.strptime(item['time'], "%Y%m%d%H%M%S").replace(tzinfo=tz.gettz('Asia/Shanghai')) data['mpoint_id'] = item['name'] last_timex: datetime = mpoint_dict.get(data['mpoint_id'], None) - if data["timex"].second not in getattr(conf, "SAVE_SECONDS", [2, 7, 12, 17, 22, 27, 32, 37, 42, 47, 52, 57]) or ( - last_timex and last_timex.second == data["timex"].second): + if data["timex"].minute not in getattr(conf, "SAVE_MINUTES", [2, 7, 12, 17, 22, 27, 32, 37, 42, 47, 52, 57]) or ( + last_timex and last_timex.minute == data["timex"].minute): continue try: val_float = float(item["value"])