20230116, huli 给感测节点增加, 终端点击存车瞬间的通信接口

测量节点/setting/rabbitmq.prototxt

@@ -61,6 +61,24 @@ rabbitmq_parameters
        consume_exclusive:0
     }
 
+    #终端点击存车时, 发送存车表单给检查节点, 这里顺便发送给感测节点.
+    rabbitmq_reciever_vector
+     {
+         channel:401
+         exchange_name:"command_ex"
+
+         binding_key:"user_command_port"
+         queue_name:"user_command_queue_for_measure"
+         queue_passive:0
+         queue_durable:1
+         queue_exclusive:0
+         queue_auto_delete:0
+         consume_name:"user_command_consume_for_measure"
+         consume_no_local:0
+         consume_no_ack:0
+         consume_exclusive:0
+     }
+
 
 
     rabbitmq_sender_status_vector

测量节点/system/system_communication mq.cpp

@@ -89,8 +89,32 @@ Error_manager System_communication_mq::execute_dispatch_status_msg(Rabbitmq_mess
 
 
 
+	//终端点击存车时, 发送存车表单给检查节点, 这里顺便发送给感测节点.
+	if( p_msg->m_routing_key == "user_command_port" )
+	{
+		park_table t_park_table_msg; //存车表单
+		m_measure_statu_msg_2 = *p_msg;
+		if(google::protobuf::TextFormat::ParseFromString(p_msg->m_message_buf, &t_park_table_msg))
+		{
+			std::string t_string = t_park_table_msg.DebugString();
+			LOG(INFO) << " huli test::t_string = t_park_table_msg "<< t_string << " --- " ;
+			//给唐有成, 这里面有terminal_id, 可以触发感测节点保存事件.
+			//..............................
 
-    return SUCCESS;
+
+
+			//指令信息必须手动ack, 这样才能清除服务器的指令,
+			//(状态消息临时队列接受后自动清除, 指令消息永久队列接收后手动清除)
+			ack_msg(p_msg);
+
+		}
+
+	}
+
+
+
+
+	return SUCCESS;
 }