mqtt_send.py 1.9 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879
  1. '''
  2. 处理mqtt发送的消息
  3. '''
  4. import queue
  5. import json
  6. from enum import Enum
  7. import numpy
  8. import common.sys_comm as sys_comm
  9. from common.sys_comm import LOGDBG, LOGINFO, LOGWARN, LOGERR
  10. from common.sys_comm import POSE_CLASS_E, POSE_E
  11. from mqtt.mqtt_topics import TOPICS
  12. import mqtt.mqtt_process as mp
  13. # 消息类型
  14. class MSG_TYPE(Enum):
  15. MSG_DEV_STATUS = 0 # 设备状态变更
  16. MSG_DEV_RAW_POINTS = 1 # 实时点云
  17. MSG_REALTIME_TARGET = 2 # 实时目标位置
  18. MSG_EVENT_FALL = 3 # 跌倒事件
  19. MSG_EVENT_EXIST = 4 # 存在事件
  20. def get_target_point(point_cloud:list):
  21. return numpy.mean(point_cloud, axis=0).tolist()
  22. # 创建消息相关 START
  23. # 准备将消息通过 MQTT 发送
  24. def send_msg(topic:str, format_json:dict, qos:int=0):
  25. try:
  26. parts = topic.split('/')
  27. model = parts[1]
  28. if model != "dev":
  29. with sys_comm.g_sys_conf_mtx:
  30. format_json["sp_id"] = sys_comm.g_sys_conf["sp_id"]
  31. content:str = json.dumps(format_json)
  32. mqtt_msg = {
  33. "topic": topic,
  34. "msg": content,
  35. "qos": qos
  36. }
  37. mp.g_mqtt_client.send_msg(mqtt_msg)
  38. except Exception as e:
  39. LOGERR(f"send_msg error: {e}")
  40. # 告警事件
  41. def alarm_event(
  42. dev_id: str,
  43. dev_name: str,
  44. uuid: str,
  45. plan_uuid: str,
  46. event_type: str,
  47. info: dict,
  48. linkage_action: dict,
  49. table: str):
  50. format_json = dict()
  51. format_json["dev_id"] = dev_id
  52. format_json["dev_name"] = dev_name
  53. format_json["uuid"] = uuid
  54. format_json["plan_uuid"] =plan_uuid
  55. format_json["event_type"] = event_type
  56. format_json["info"] = info
  57. format_json["linkage_action"] = linkage_action
  58. format_json["table"] = table
  59. send_msg(TOPICS.las_alarm_event, format_json, 2)
  60. # 创建消息相关 END