|
@@ -34,9 +34,9 @@ def check_park_command(body):
|
|
g_rabbitmq.publish(mq_config['mq_command_exchange_name'], dispatch_key, tf.MessageToString(table, as_utf8=True))
|
|
g_rabbitmq.publish(mq_config['mq_command_exchange_name'], dispatch_key, tf.MessageToString(table, as_utf8=True))
|
|
log.info("停车指令 %s OK:%s 检查成功!\n" % (datetime.datetime.now(), tf.MessageToString(table, as_utf8=True)))
|
|
log.info("停车指令 %s OK:%s 检查成功!\n" % (datetime.datetime.now(), tf.MessageToString(table, as_utf8=True)))
|
|
else:
|
|
else:
|
|
- print("---------------刷新投影-----------------" + entrance_key)
|
|
|
|
- g_rabbitmq.publish(mq_config['mq_statu_exchange_name'], entrance_key,
|
|
|
|
- tf.MessageToString(cmd, as_utf8=True))
|
|
|
|
|
|
+ # print("---------------刷新投影-----------------" + entrance_key)
|
|
|
|
+ # g_rabbitmq.publish(mq_config['mq_statu_exchange_name'], entrance_key,
|
|
|
|
+ # tf.MessageToString(cmd, as_utf8=True))
|
|
if cmd.statu.execute_statu == message.eWarning:
|
|
if cmd.statu.execute_statu == message.eWarning:
|
|
# 给终端发送指令,刷新投影
|
|
# 给终端发送指令,刷新投影
|
|
log.warning("停车指令 %s 车牌号:%s 检查失败!\n 发送反馈 交换机:%s 发送反馈端口:%s 反馈表单:%s" % (
|
|
log.warning("停车指令 %s 车牌号:%s 检查失败!\n 发送反馈 交换机:%s 发送反馈端口:%s 反馈表单:%s" % (
|