zcdsj
/
factory
5
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat: mpointcache 存库时若测点不存在删除缓存

This commit is contained in:
caoqianming 2024-07-25 10:51:54 +08:00
parent 391d9b137d
commit b0004ba12e
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
apps/enm/services.py
View File

@ -185,6 +185,10 @@ class MpointCache:
cache.set(cache_key, current_cache_val, timeout=None) cache.set(cache_key, current_cache_val, timeout=None)
# 存库 # 存库
mpoint = Mpoint.objects.filter(id=current_cache_val["id"]).first()
if mpoint is None:
cache.delete(cache_key)
return
save_dict = {"timex": last_timex, "mpoint": Mpoint.objects.get(id=current_cache_val["id"]), "val_mrs": last_mrs} save_dict = {"timex": last_timex, "mpoint": Mpoint.objects.get(id=current_cache_val["id"]), "val_mrs": last_mrs}
save_dict[f"val_{current_cache_val['val_type']}"] = last_val save_dict[f"val_{current_cache_val['val_type']}"] = last_val
MpLogx.objects.create(**save_dict) MpLogx.objects.create(**save_dict)