|
@@ -194,6 +194,7 @@ class QxzDeviceAddAPIViw(APIView):
|
|
|
# 气象站上传数据
|
|
# 气象站上传数据
|
|
|
try:
|
|
try:
|
|
|
request_data = request.body
|
|
request_data = request.body
|
|
|
|
|
+ logger.error(f"气象站数据:{request_data}")
|
|
|
request_data = json.loads(request_data)
|
|
request_data = json.loads(request_data)
|
|
|
device_id = request_data.get("StationID")
|
|
device_id = request_data.get("StationID")
|
|
|
uptime = request_data.get("MonitorTime")
|
|
uptime = request_data.get("MonitorTime")
|
|
@@ -251,6 +252,7 @@ class QxzDeviceAddAPIViw(APIView):
|
|
|
alarm_new.device_id = mongo_device.id
|
|
alarm_new.device_id = mongo_device.id
|
|
|
alarm_new.warning_name = str(mongo_device.device_type_id) # 设备类型ID
|
|
alarm_new.warning_name = str(mongo_device.device_type_id) # 设备类型ID
|
|
|
alarm_new.save()
|
|
alarm_new.save()
|
|
|
|
|
+ logger.error(f"产生预警:{device_id}")
|
|
|
# 30分钟上报一次的数据
|
|
# 30分钟上报一次的数据
|
|
|
qx_ek["device_id"] = device_id
|
|
qx_ek["device_id"] = device_id
|
|
|
qx_ek["uptime"] = uptime_tp
|
|
qx_ek["uptime"] = uptime_tp
|