node.py 3.0 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374
  1. import sys
  2. from PyQt5.QtWidgets import QWidget, QApplication,QMainWindow,QLabel
  3. from PyQt5.QtCore import Qt
  4. import window_screen_pyqt as ws
  5. import async_communication as CM
  6. import led
  7. import json
  8. import google.protobuf.text_format as tf
  9. import message_pb2 as message
  10. with open("./ui_config.json",'r',encoding='utf-8') as fp:
  11. config=json.load(fp)
  12. # led_cfg=config["led"]
  13. db_cfg=config["db"]
  14. rabbitmq_cfg=config["rabbitmq"]
  15. terminal_id=config["terminal_id"]
  16. import_id=config["import_id"]
  17. unit=config["unit"]
  18. prj_parameter=config.get("prj")
  19. #启动入口单片机,向rabbitmq发送数据,并接收关门请求
  20. #[消息服务器ip,port,用户,密码,状态交换机名称,状态消息key]
  21. statu_ex_keys=[["statu_ex","dispatch_%d_statu_port"%unit],
  22. ["statu_ex","measure_%d_statu_port"%terminal_id],
  23. ["statu_ex","terminal_node_%d_statu_port"%terminal_id]
  24. ]
  25. dispatch_ex,dispatch_key=statu_ex_keys[0]
  26. measure_ex,measure_key=statu_ex_keys[1]
  27. terminal_ex,terminal_key=statu_ex_keys[2]
  28. g_rabbitmq=CM.RabbitAsyncCommunicator(rabbitmq_cfg["ip"],rabbitmq_cfg["port"],
  29. rabbitmq_cfg["user"],rabbitmq_cfg["password"])
  30. g_rabbitmq.Init(None,statu_ex_keys)
  31. g_rabbitmq.start()
  32. #启动界面
  33. #绑定单片机与界面
  34. images={"传感器超时":"./Resource/arrows/传感器超时.png",
  35. "测绘超时":"./Resource/arrows/测绘超时.png",
  36. "正确文字":"./Resource/arrows/正确文字.png",
  37. "正确图片":"./Resource/arrows/正确图片.png",
  38. "超宽车辆":"./Resource/arrows/超宽车辆.png",
  39. "超高车辆": "./Resource/arrows/超高车辆.png",
  40. "轴距超差":"./Resource/arrows/轴距超差.png",
  41. "请调整":"./Resource/arrows/请调整.png",
  42. "向前调整":"./Resource/arrows/向前调整.png",
  43. "向后调整":"./Resource/arrows/向后调整.png",
  44. "向左调整":"./Resource/arrows/向左调整.png",
  45. "向右调整":"./Resource/arrows/向右调整.png",
  46. "左前调整":"./Resource/arrows/左前调整.png",
  47. "左后调整":"./Resource/arrows/左后调整.png",
  48. "右前调整":"./Resource/arrows/右前调整.png",
  49. "右后调整":"./Resource/arrows/右后调整.png",
  50. "向左旋转":"./Resource/arrows/向左旋转.png",
  51. "向右旋转":"./Resource/arrows/向右旋转.png",
  52. "空闲":"./Resource/arrows/空闲.png",
  53. "回正方向盘":"./Resource/arrows/回正方向盘.png",
  54. "检查杂物":"./Resource/arrows/检查杂物.png"}
  55. app = QApplication(sys.argv)
  56. frame = ws.Frame(import_id,images,prj_parameter,True)
  57. frame.resize(600, 900)
  58. frame.setWindowTitle("楚天大厦入口 %d 引导"%terminal_id)
  59. frame.show()
  60. frame.setWindowFlags(Qt.WindowMaximizeButtonHint|Qt.WindowCloseButtonHint)
  61. frame.showMaximized()
  62. g_rabbitmq.bind_statu_callback(dispatch_ex,dispatch_key,frame.receive_dispatch)
  63. g_rabbitmq.bind_statu_callback(measure_ex,measure_key,frame.receive_measureInfo)
  64. g_rabbitmq.bind_statu_callback(terminal_ex,terminal_key,frame.receive_terminal)
  65. app.exec()
  66. g_rabbitmq.close()
  67. g_rabbitmq.join()