|
# -*- coding: utf-8 -*-
from __future__ import division
import json
from django.conf import settings
from django.db.models import Max, Q
from django_logit import logit
from django_query import get_query_value
from django_response import response
from paginator import pagination
from TimeConvert import TimeConvert as tc
from equipment.models import (IsolationPointInfo, IsolationPointUserInfo, ThermometerEquipmentInfo,
ThermometerMeasureInfo, ThermometerMeasureLogInfo)
from utils.error.errno_utils import IsolationPointStatusCode, ThermometerEquipmentStatusCode
from utils.redis.rscreen import get_screen_info, set_screen_info
@logit
def eqpt_bind(request):
point_id = request.POST.get('point_id', '')
macid = request.POST.get('macid', '')
sn = request.POST.get('sn', '')
macidsns = get_query_value(request, 'macidsns', val_cast_type='listjson')
macidsns = macidsns or [{'macid': macid, 'sn': sn}]
# headers = {
# 'Content-Type': 'application/json',
# 'Partner-Identifier': 'yingduo',
# 'Partner-Token': '9A79C0E34C72B4D0F9B5EA0C59FFC52A',
# }
for macidsn in macidsns:
macid, sn = macidsn.get('macid'), macidsn.get('sn')
# data = {
# 'mac': macid,
# 'callback': 'http://twjc.kodo.com.cn/api/upload/temperature',
# }
# # 设备注册成功
# # {
# # "ret": "SUCCESS",
# # "data": {
# # "id": 6,
# # "callback": "http://twjc.kodo.com.cn/api/upload/temperature",
# # "mac": "C4:64:E3:7A:EF:A8"
# # },
# # "debug": ""
# # }
# #
# # 设备注册失败
# # {
# # "ret": "FAIL",
# # "data": "该设备已被注册！",
# # "debug": ""
# # }
# try:
# result = requests.post('http://www.protontek.com/vcare-api/open/device/register', headers=headers, data=json.dumps(data)).json()
# except Exception as e:
# result = {'message': e.args}
ThermometerEquipmentInfo.objects.update_or_create(macid=macid, defaults={
'point_id': point_id,
'sn': sn,
# 'eqpt_register_status': int(result.get('ret') == 'SUCCESS' or result.get('data') == '该设备已被注册！'),
# 'eqpt_register_result': result,
})
return response()
@logit
def eqpt_onoff(request):
macid = request.POST.get('macid', '')
active = request.POST.get('active', 0)
try:
eqpt = ThermometerEquipmentInfo.objects.get(macid=macid)
except ThermometerEquipmentInfo.DoesNotExist:
return response(ThermometerEquipmentStatusCode.THERMOMETER_EQUIPMENT_NOT_FOUND)
eqpt.active_status = active
eqpt.save()
if active == 0:
try:
ipui = IsolationPointUserInfo.objects.get(pk=eqpt.ipui_pk)
except IsolationPointUserInfo.DoesNotExist:
ipui = None
if ipui:
ipui.leave_at = tc.utc_datetime()
ipui.status = False
ipui.save()
return response()
@logit
def eqpt_remark(request):
macid = request.POST.get('macid', '')
remark = request.POST.get('remark', '')
try:
eqpt = ThermometerEquipmentInfo.objects.get(macid=macid)
except ThermometerEquipmentInfo.DoesNotExist:
return response(ThermometerEquipmentStatusCode.THERMOMETER_EQUIPMENT_NOT_FOUND)
eqpt.remark = remark
eqpt.save()
# 存放历史备注记录
try:
ipui = IsolationPointUserInfo.objects.get(pk=eqpt.ipui_pk)
except IsolationPointUserInfo.DoesNotExist:
ipui = None
if ipui:
ipui.remark = remark
ipui.remarks += [remark]
ipui.save()
return response()
@logit(body=True)
def eqpt_list(request):
point_id = request.POST.get('point_id', '')
macid = request.POST.get('macid', '')
page = request.POST.get('page', 1)
num = request.POST.get('num', 20)
eqpts = ThermometerEquipmentInfo.objects.filter(point_id=point_id, status=True)
if macid:
eqpts = eqpts.filter(macid=macid)
total_num = eqpts.count()
active_num = eqpts.filter(active_status=ThermometerEquipmentInfo.ONLINE).count()
eqpts, left = pagination(eqpts, page, num)
eqpts = [eqpt.data for eqpt in eqpts]
return response(data={
'eqpts': eqpts,
'left': left,
'total_num': total_num,
'active_num': active_num,
'unactive_num': total_num - active_num,
})
@logit
def eqpt_result(request):
point_id = request.POST.get('point_id', '')
kw = request.POST.get('kw', '')
page = request.POST.get('page', 1)
num = request.POST.get('num', 20)
try:
point = IsolationPointInfo.objects.get(point_id=point_id, status=True)
except IsolationPointInfo.DoesNotExist:
return response(IsolationPointStatusCode.ISOLATIONPOINT_NOT_FOUND)
eqpts = ThermometerEquipmentInfo.objects.filter(point_id=point_id, active_status=ThermometerEquipmentInfo.ONLINE, status=True)
macids = eqpts.values_list('macid', flat=True)
logs = ThermometerMeasureInfo.objects.filter(
point_id=point_id,
point_measure_ymd=tc.local_string(format='%Y-%m-%d'),
point_measure_window=point.previous_measure_window,
macid__in=macids,
status=True,
).values('macid', 'temperature')
logs = {log.get('macid'): log.get('temperature') for log in logs}
ipuis = IsolationPointUserInfo.objects.filter(point_id=point_id, status=True).values('pk', 'fields')
ipuis = {info.get('pk'): info.get('fields') for info in ipuis}
total_active_eqpt_num = eqpts.count()
has_upload_temperature_num = len(logs)
fever_num = len([1 for temperature in logs.values() if temperature > settings.FEVER_TEMPERATURE])
if kw:
eqpts = eqpts.filter(Q(name__icontains=kw) | Q(phone__icontains=kw))
eqpts, left = pagination(eqpts, page, num)
eqpts = [{**eqpt.data, **{
'has_upload': eqpt.macid in logs,
'temperature': logs.get(eqpt.macid, 0),
'fields': ipuis.get(eqpt.ipui_pk, {}),
}} for eqpt in eqpts]
return response(data={
'eqpts': eqpts,
'left': left,
'total_active_eqpt_num': total_active_eqpt_num,
'has_upload_temperature_num': has_upload_temperature_num,
'not_upload_temperature_num': total_active_eqpt_num - has_upload_temperature_num,
'fever_num': fever_num,
})
def get_screen_data(point=None, point_id=None):
if not point:
try:
point = IsolationPointInfo.objects.get(point_id=point_id, status=True)
except IsolationPointInfo.DoesNotExist:
return {}
eqpts = ThermometerEquipmentInfo.objects.filter(point_id=point.point_id, active_status=ThermometerEquipmentInfo.ONLINE, status=True)
# macids = eqpts.values_list('macid', flat=True)
#
# logs = ThermometerMeasureInfo.objects.filter(
# point_id=point.point_id,
# point_measure_ymd=tc.local_string(format='%Y-%m-%d'),
# point_measure_window=point.previous_measure_window,
# macid__in=macids,
# status=True,
# ).values('macid', 'temperature', 'updated_at')
# temperature_logs = {log.get('macid'): log.get('temperature') for log in logs}
# time_logs = {log.get('macid'): tc.local_string(utc_dt=log.get('updated_at'), format='%m-%d %H:%M') for log in logs}
ipuis = IsolationPointUserInfo.objects.filter(point_id=point.point_id, status=True)
ipuis = [ipui.data for ipui in ipuis]
total_active_eqpt_num = eqpts.count()
# has_upload_temperature_num = len(temperature_logs)
# fever_num = len([1 for temperature in temperature_logs.values() if temperature > settings.FEVER_TEMPERATURE])
has_upload_temperature_num = len([1 for ipui in ipuis if ipui.get('temperature_has_upload', '') == '已上报'])
fever_num = len([1 for ipui in ipuis if ipui.get('temperature', 0) > settings.FEVER_TEMPERATURE])
# ipuis_fields = {info.get('pk'): info.get('fields') for info in ipuis}
# ipuis_observed_days = {info.get('pk'): info.get('observed_days') for info in ipuis}
ipuis = {ipui.get('pk'): {
'fields': ipui.get('fields'),
'observed_days': ipui.get('observed_days'),
'temperature_has_upload': ipui.get('temperature_has_upload'),
'temperature': ipui.get('temperature'),
'last_submit_at': ipui.get('last_submit_at'),
'remark': ipui.get('remark'),
} for ipui in ipuis}
eqpts = [{**eqpt.screen_data, **{
# 'has_upload': eqpt.macid in temperature_logs,
# 'temperature': temperature_logs.get(eqpt.macid, 0),
'has_upload': ipuis.get(eqpt.ipui_pk, {}).get('temperature_has_upload', 0),
'temperature': ipuis.get(eqpt.ipui_pk, {}).get('temperature', 0),
'observed_days': ipuis.get(eqpt.ipui_pk, {}).get('observed_days', 0),
'last_submit_at': ipuis.get(eqpt.ipui_pk, {}).get('last_submit_at', ''),
'remark': ipuis.get(eqpt.ipui_pk, {}).get('remark', ''),
}, **{
field.get('key', ''): field.get('value', '') for field in ipuis.get(eqpt.ipui_pk, {}).get('fields', [])
}} for eqpt in eqpts]
reminds = [{
'name': eqpt.get('name'),
'room': eqpt.get('room'),
'content': eqpt.get('remark'),
} for eqpt in eqpts if eqpt.get('remark')]
eqpts = [{
'name': eqpt.get('name', ''),
'room': eqpt.get('room', ''),
'phone': eqpt.get('phone', ''),
'sex': eqpt.get('sex', ''),
'age': eqpt.get('age', ''),
'status': eqpt.get('has_upload'),
# 'status': '已上报' if eqpt.get('temperature') else '未上报',
'last_report_time': eqpt.get('last_submit_at', ''),
# 'last_report_time': time_logs.get(eqpt.get('macid', ''), '') if eqpt.get('temperature') else eqpt.get('last_submit_at', ''),
'temperature': eqpt.get('temperature', 0),
# 'temperature': eqpt.get('temperature', '') or get_old_temperature(eqpt.get('point_id', ''), eqpt.get('macid', '')),
'observed_days': eqpt.get('observed_days', 0),
} for eqpt in eqpts]
return {
'eqpts': eqpts,
'reminds': reminds,
'total_active_eqpt_num': total_active_eqpt_num,
'has_upload_temperature_num': has_upload_temperature_num,
'not_upload_temperature_num': total_active_eqpt_num - has_upload_temperature_num,
'normal_num': has_upload_temperature_num - fever_num,
'fever_num': fever_num,
'update_time': tc.local_string(),
}
@logit
def screen_eqpt_result(request):
point_id = request.POST.get('point_id', '')
screen_info = get_screen_info(point_id)
if screen_info:
return response(data=screen_info)
try:
point = IsolationPointInfo.objects.get(point_id=point_id, status=True)
except IsolationPointInfo.DoesNotExist:
return response(IsolationPointStatusCode.ISOLATIONPOINT_NOT_FOUND)
screen_data = get_screen_data(point)
return response(data=screen_data)
@logit
def upload_temperature(request):
# request.POST = request.POST or json.loads(request.body)
# macid = request.POST.get('mac', '')
# name = request.POST.get('name', '')
# sex = request.POST.get('gender', 0)
# birth_stamp = request.POST.get('birthday', 0)
# age = request.POST.get('age', 0)
# phone = request.POST.get('mobile', '')
# start_stamp = request.POST.get('startTime', 0)
# end_stamp = request.POST.get('endTime', 0)
# temperature = round(float(request.POST.get('maxTempValue', 0)), 2)
#
# try:
# eqpt = ThermometerEquipmentInfo.objects.get(macid=macid, status=True)
# except ThermometerEquipmentInfo.DoesNotExist:
# ThermometerMeasureLogInfo.objects.create(macid=macid, name=name, sex=sex, birth_stamp=birth_stamp, phone=phone, start_stamp=start_stamp, end_stamp=end_stamp, temperature=temperature, upload_temperature_info=request.POST, status=False)
# return response(ThermometerEquipmentStatusCode.THERMOMETER_EQUIPMENT_NOT_FOUND)
#
# try:
# point = IsolationPointInfo.objects.get(point_id=eqpt.point_id, status=True)
# except IsolationPointInfo.DoesNotExist:
# return response(IsolationPointStatusCode.ISOLATIONPOINT_NOT_FOUND)
#
# point_measure_ymd = tc.local_string(format='%Y-%m-%d')
# point_measure_window = point.current_measure_window
#
# eqpt.name = name
# eqpt.sex = sex
# eqpt.birth_stamp = birth_stamp
# eqpt.age = stamp2age(birth_stamp)
# eqpt.phone = phone
# eqpt.last_submit_at = tc.utc_datetime()
# eqpt.save()
#
# ThermometerMeasureLogInfo.objects.create(point_id=eqpt.point_id, macid=macid, name=name, sex=sex, birth_stamp=birth_stamp, phone=phone, start_stamp=start_stamp, end_stamp=end_stamp, temperature=temperature, upload_temperature_info=request.POST)
#
# if point_measure_window:
# measure_info, _ = ThermometerMeasureInfo.objects.get_or_create(point_id=eqpt.point_id, point_measure_ymd=point_measure_ymd, point_measure_window=point_measure_window, macid=macid, defaults={
# 'temperature': temperature,
# })
# if temperature > measure_info.temperature:
# measure_info.temperature = temperature
# measure_info.save()
return response()
def mqtt_upload_temperature(payload):
# Received `{"mac":"A4DA324E7A63","pkt":"215","chg_sta":true,"bat":"100","raw_temp":"4697,4696,4697","sta":"0","alg_temp":"4697,4696,4697","alg_gstr":0,"ble_rssi":-21,"wifi_rssi":-68,"current_time":"2021-08-08 15:22:59"}` from `esp/240AC4D3C1AC` topic
#
# {
# "mac": "A4DA324E7A63", # 体温贴 mac，固定 6 个字节，12 个字符
# "pkt": "215", # 广播包包序为 85，有效包序范围[1, 255]
# "chg_sta": true, # 充电状态，true 充电，false 未充电
# "bat": "100", # 电量剩余 65%，有效电量范围[0, 100]
# "raw_temp": "4697,4696,4697", # 三个原始温度数
# "sta": "0", # 算法返回状态
# "alg_temp": "4697,4696,4697", # 算法返回三个温度
# "alg_gstr": 0, # 算法手臂姿态
# "ble_rssi": -21, # 体温贴相对于底座的信号强度
# "wifi_rssi": -68, # 底座网络信号强度
# "current_time": "2021-08-08 15:22:59" # 底座接收到体温贴信息的实时时间
# }
try:
payload = json.loads(payload)
except Exception:
return
macid = payload.get('mac', '')
macid = f'{macid[:2]}:{macid[2:4]}:{macid[4:6]}:{macid[6:8]}:{macid[8:10]}:{macid[10:12]}'
current_time = payload.get('current_time', '')
start_stamp = end_stamp = tc.string_to_timestamp(current_time)
# raw_temp = payload.get('raw_temp', '')
alg_temp = payload.get('alg_temp', '')
# temp = raw_temp.split(',') + alg_temp.split(',')
temp = alg_temp.split(',')
temp = [int(t) for t in temp if t]
if not temp:
return
temperature = max(temp) / 100
try:
eqpt = ThermometerEquipmentInfo.objects.get(macid=macid, status=True)
except ThermometerEquipmentInfo.DoesNotExist:
# ThermometerMeasureLogInfo.objects.create(macid=macid, start_stamp=start_stamp, end_stamp=end_stamp, temperature=temperature, temperature_src=ThermometerMeasureLogInfo.MQTT, upload_temperature_info=payload, status=False)
return
try:
point = IsolationPointInfo.objects.get(point_id=eqpt.point_id, status=True)
except IsolationPointInfo.DoesNotExist:
return
# point_measure_ymd = tc.local_string(format='%Y-%m-%d')
# point_measure_window = point.current_measure_window
# eqpt.last_submit_at = tc.utc_datetime()
# eqpt.save()
ThermometerMeasureLogInfo.objects.create(point_id=eqpt.point_id, macid=macid, start_stamp=start_stamp, end_stamp=end_stamp, temperature=temperature, temperature_src=ThermometerMeasureLogInfo.MQTT, upload_temperature_info=payload)
# if point_measure_window:
# measure_info, _ = ThermometerMeasureInfo.objects.get_or_create(point_id=eqpt.point_id, point_measure_ymd=point_measure_ymd, point_measure_window=point_measure_window, macid=macid, defaults={
# 'temperature': temperature,
# })
# if temperature > measure_info.temperature:
# measure_info.temperature = temperature
# measure_info.save()
#
# set_old_temperature(eqpt.point_id, macid, temperature)
#
# try:
# ipui = IsolationPointUserInfo.objects.get(pk=eqpt.ipui_pk)
# except IsolationPointUserInfo.DoesNotExist:
# ipui = None
# if ipui:
# ipui.observed_ymds = list(set(ipui.observed_ymds + [point_measure_ymd]))
# ipui.observed_days = len(ipui.observed_ymds)
# ipui.last_submit_at = tc.utc_datetime()
# ipui.save()
try:
ipui = IsolationPointUserInfo.objects.get(pk=eqpt.ipui_pk)
except IsolationPointUserInfo.DoesNotExist:
ipui = None
if ipui:
temperature__max = ThermometerMeasureLogInfo.objects.filter(point_id=eqpt.point_id, macid=macid).aggregate(Max('temperature')).get('temperature__max') or 0
ipui.observed_ymds = list(set(ipui.observed_ymds + [tc.local_string(format='%Y-%m-%d')]))
ipui.observed_days = len(ipui.observed_ymds)
ipui.temperature = temperature__max
ipui.last_submit_at = tc.utc_datetime()
ipui.save()
set_screen_info(point.point_id, get_screen_data(point))
|
