2024/01/30 推送余位 查询排队 预约车位 正式环境部署

指令检查节点/node.py

@@ -225,7 +225,7 @@ class MyHttpRequestHandler(BaseHTTPRequestHandler):
                     code, msg, data = -1, "error", "预约失败，无空闲车位！"
                 else:
                     g_rabbitmq.publish(mq_config['mq_command_exchange_name'], "dispatch_apply_command_request_port",tf.MessageToString(apply_table, as_utf8=True))
-                    code, msg, data = 0, "success", "预约成功！"
+                    code, msg, data = 0, "success", ("预约成功！" if apply_table.operation_type == 0 else "取消预约成功！")
         else:
             code, msg, data = -20, "error", "解析失败,缺少关键字段commandType！"
         # 发送答复
@@ -239,7 +239,7 @@ class MyHttpRequestHandler(BaseHTTPRequestHandler):
         print(buf)
 def recv_post():
     # 绑定IP
-    ts = HTTPServer(('192.168.2.57', 8899), MyHttpRequestHandler)
+    ts = HTTPServer(('192.168.2.101', 8899), MyHttpRequestHandler)
     # 启动服务
     ts.serve_forever()
 
@@ -265,13 +265,13 @@ if __name__ == '__main__':
     # 初始化rabbitmq
     g_rabbitmq = CM.RabbitAsyncCommunicator(mq_config['mq_ip'], mq_config['mq_port'], mq_config['mq_user'],
                                             mq_config['mq_password'])
-    # g_rabbitmq.Init(cmd_callbacks, mq_config['mq_statu_exchange_keys'], "checker")
-    # # 绑定队列
-    # for ex, key in mq_config['mq_statu_exchange_keys']:
-    #     if key.find("dispatch") >= 0:
-    #         g_rabbitmq.bind_statu_callback(ex, key, checker.receive_dispatch_statu)
-    #     if key.find("measure") >= 0:
-    #         g_rabbitmq.bind_statu_callback(ex, key, checker.receive_measure_info)
+    g_rabbitmq.Init(cmd_callbacks, mq_config['mq_statu_exchange_keys'], "checker")
+    # 绑定队列
+    for ex, key in mq_config['mq_statu_exchange_keys']:
+        if key.find("dispatch") >= 0:
+            g_rabbitmq.bind_statu_callback(ex, key, checker.receive_dispatch_statu)
+        if key.find("measure") >= 0:
+            g_rabbitmq.bind_statu_callback(ex, key, checker.receive_measure_info)
     # 收费系统云端通信
     http_community = threading.Thread(target=recv_post)
     g_rabbitmq.start()