|
@@ -260,8 +260,13 @@ Error_manager Command_manager::execute_pickup_command(message::Pickup_command_re
|
|
|
if (m_thread_queue_process == nullptr)
|
|
|
{
|
|
|
error_msg.set_error_code(ERROR);
|
|
|
- error_msg.set_error_description(" xxxxx bug,线程池未初始化");
|
|
|
+ error_msg.set_error_description(" xxxxx 中控bug,线程池未初始化");
|
|
|
response.mutable_code()->CopyFrom(error_msg);
|
|
|
+
|
|
|
+ Communication_message msg;
|
|
|
+ msg.reset(response.base_info(), response.SerializeAsString());
|
|
|
+ Message_communicator::get_instance_pointer()->send_msg(&msg);
|
|
|
+
|
|
|
return Error_manager(ERROR, MINOR_ERROR, "线程池未初始化,bug");
|
|
|
}
|
|
|
|
|
@@ -270,6 +275,10 @@ Error_manager Command_manager::execute_pickup_command(message::Pickup_command_re
|
|
|
error_msg.set_error_code(PAUSE);
|
|
|
error_msg.set_error_description("急停");
|
|
|
response.mutable_code()->CopyFrom(error_msg);
|
|
|
+
|
|
|
+ Communication_message msg;
|
|
|
+ msg.reset(response.base_info(), response.SerializeAsString());
|
|
|
+ Message_communicator::get_instance_pointer()->send_msg(&msg);
|
|
|
return Error_manager(PAUSE, MINOR_ERROR, "急停");
|
|
|
}
|
|
|
|
|
@@ -286,6 +295,10 @@ Error_manager Command_manager::execute_pickup_command(message::Pickup_command_re
|
|
|
error_msg.set_error_code(ERROR);
|
|
|
error_msg.set_error_description("中控出口已停止使用");
|
|
|
response.mutable_code()->CopyFrom(error_msg);
|
|
|
+
|
|
|
+ Communication_message msg;
|
|
|
+ msg.reset(response.base_info(), response.SerializeAsString());
|
|
|
+ Message_communicator::get_instance_pointer()->send_msg(&msg);
|
|
|
return Error_manager(ERROR, MINOR_ERROR, "中控出口已停止使用");
|
|
|
}
|
|
|
|
|
@@ -306,6 +319,10 @@ Error_manager Command_manager::execute_pickup_command(message::Pickup_command_re
|
|
|
error_msg.set_error_code(parkspace_code.get_error_code());
|
|
|
error_msg.set_error_description(parkspace_code.get_error_description());
|
|
|
response.mutable_code()->CopyFrom(error_msg);
|
|
|
+
|
|
|
+ Communication_message msg;
|
|
|
+ msg.reset(response.base_info(), response.SerializeAsString());
|
|
|
+ Message_communicator::get_instance_pointer()->send_msg(&msg);
|
|
|
return parkspace_code;
|
|
|
}
|
|
|
|
|
@@ -315,6 +332,10 @@ Error_manager Command_manager::execute_pickup_command(message::Pickup_command_re
|
|
|
error_msg.set_error_code(dispatch_code.get_error_code());
|
|
|
error_msg.set_error_description(dispatch_code.get_error_description());
|
|
|
response.mutable_code()->CopyFrom(error_msg);
|
|
|
+
|
|
|
+ Communication_message msg;
|
|
|
+ msg.reset(response.base_info(), response.SerializeAsString());
|
|
|
+ Message_communicator::get_instance_pointer()->send_msg(&msg);
|
|
|
return dispatch_code;
|
|
|
}
|
|
|
|