parkspace_module/parkspace_allocation/parkspace_manager.cpp

/*
 * @Description: 车位分配算法模块，使用单例模式，接收外部请求并通过调用通信块接口发送反馈
 * @Author: yct
 * @Date: 2020-07-10 11:02:40
 * @LastEditTime: 2020-08-06 10:32:28
 * @LastEditors: yct
 */ 

#include "parkspace_manager.h"
#include "parkspace_communicator.h"

Parkspace_manager::Parkspace_manager()
{
}

Parkspace_manager::~Parkspace_manager()
{
	parkspace_manager_uninit();
}

//初始化
Error_manager Parkspace_manager::parkspace_manager_init(int threads_size)
{

    // 初始化任务处理线程池
	m_thread_pool.thread_pool_init(threads_size);
	m_parkspace_manager_satus = eParkspace_manager_normal;
	return Error_code::SUCCESS;
}

//反初始化
Error_manager Parkspace_manager::parkspace_manager_uninit()
{
	m_thread_pool.thread_pool_uninit();
	m_parkspace_manager_satus = eParkspace_manager_unknown;
	return Error_code::SUCCESS;
}

//检查执行者的状态, 判断能否处理这条消息,
Error_manager Parkspace_manager::check_status()
{
	if(get_parkspace_manage_status() != eParkspace_manager_normal)
 	{
		return Error_manager(Error_code::DB_MANAGER_STATUS_ERROR, Error_level::MAJOR_ERROR,
							" Parkspace_manager::check_executer error ");
	}
	return SUCCESS;

}

//处理消息的执行函数
Error_manager Parkspace_manager::execute_msg(Communication_message* p_msg)
{
	if ( p_msg == nullptr )
	{
		return Error_manager(Error_code::POINTER_IS_NULL, Error_level::MINOR_ERROR,
							 "  POINTER IS NULL ");
	}
	switch ( p_msg->get_message_type() )
	{
		///车位分配请求消息
        case Communication_message::eParkspace_allocation_request_msg:
        {
            message::Parkspace_allocation_request_msg request;
            bool result = request.ParseFromString(p_msg->get_message_buf());
            LOG(INFO)<<"allocation request, car license: "<<request.car_info().license();
            if(!result)
            {
                return Error_manager(Error_code::PARKSPACE_ALLOCATOR_MSG_PARSE_ERROR, Error_level::MINOR_ERROR,
			    					" message::Parkspace_allocation_request_msg  ParseFromString error ");
            }
//			std::cout<<"分配："<<request.DebugString()<<std::endl;
            //往线程池添加执行任务, 之后会唤醒一个线程去执行他.
            m_thread_pool.enqueue(&Parkspace_manager::execute_for_allocate, this,
            request.car_info(), request.terminal_id(), request.command_key());
            return SUCCESS;
        }
        // 车位查询请求消息
        case Communication_message::eParkspace_search_request_msg:
        {
            message::Parkspace_search_request_msg request;
            bool result = request.ParseFromString(p_msg->get_message_buf());
            LOG(INFO)<<"search request, car license: "<<request.car_info().license();
            if(!result)
            {
                return Error_manager(Error_code::PARKSPACE_ALLOCATOR_MSG_PARSE_ERROR, Error_level::MINOR_ERROR,
			    					" message::Parkspace_search_request_msg  ParseFromString error ");
            }
            //往线程池添加执行任务, 之后会唤醒一个线程去执行他.
//			std::cout<<"查询："<<request.DebugString()<<std::endl;
			m_thread_pool.enqueue(&Parkspace_manager::execute_for_search, this, request.car_info(), request.command_key());
            return SUCCESS;
        }
        // 车位释放请求消息
        case Communication_message::eParkspace_release_request_msg:
        {
            message::Parkspace_release_request_msg request;
            bool result = request.ParseFromString(p_msg->get_message_buf());
            LOG(INFO)<<"release request, parkspace id: "<<request.release_space_info().parkspace_id();
            if(!result)
            {
                return Error_manager(Error_code::PARKSPACE_ALLOCATOR_MSG_PARSE_ERROR, Error_level::MINOR_ERROR,
			    					" message::Parkspace_release_request_msg  ParseFromString error ");
            }
            //往线程池添加执行任务, 之后会唤醒一个线程去执行他.
//			std::cout<<"释放："<<request.DebugString()<<std::endl;

			m_thread_pool.enqueue(&Parkspace_manager::execute_for_release, this, request.release_space_info(), request.command_key());
            return SUCCESS;
        }
        // 车位手动更新请求消息
        case Communication_message::eParkspace_force_update_request_msg:
        {
            message::Parkspace_force_update_request_msg request;
            bool result = request.ParseFromString(p_msg->get_message_buf());
            LOG(INFO)<<"force update request, parkspace id: "<<request.update_space_info().parkspace_id();
            if(!result)
            {
                return Error_manager(Error_code::PARKSPACE_ALLOCATOR_MSG_PARSE_ERROR, Error_level::MINOR_ERROR,
			    					" message::Parkspace_force_update_request_msg  ParseFromString error ");
            }
            //往线程池添加执行任务, 之后会唤醒一个线程去执行他.
//			std::cout<<"手动："<<request.DebugString()<<std::endl;

			m_thread_pool.enqueue(&Parkspace_manager::execute_for_force_update, this, request.update_space_info(), request.command_key());
            return SUCCESS;
        }
        // 车位确认占用请求消息
        case Communication_message::eParkspace_confirm_alloc_request_msg:
        {
            message::Parkspace_confirm_alloc_request_msg request;
            bool result = request.ParseFromString(p_msg->get_message_buf());

            LOG(INFO)<<"confirm alloc request, parkspace id: "<<request.confirm_space_info().parkspace_id();
            if(!result)
            {
                return Error_manager(Error_code::PARKSPACE_ALLOCATOR_MSG_PARSE_ERROR, Error_level::MINOR_ERROR,
			    					" message::Parkspace_force_update_request_msg  ParseFromString error ");
            }

			m_thread_pool.enqueue(&Parkspace_manager::execute_for_confirm_alloc, this, request.confirm_space_info(), request.command_key());
            return SUCCESS;
        }
        //车位数据刷新请求
		case Communication_message::eParkspace_refresh_request_msg:
		{
			return send_parkspace_data();
		}
	}
	return Error_manager(Error_code::PARKSPACE_ALLOCATOR_MSG_REQUEST_TYPE_ERROR, Error_level::MINOR_ERROR,
						" fun error ");
}
Error_manager Parkspace_manager::encapsulating_heartbeat_messages()
{
	//封装心跳消息
	Database_controller::Database_controller_status t_database_controller_status;
	Parkspace_manager::Parkspace_manager_satus t_parkspace_manager_satus;
	t_database_controller_status = Database_controller::get_instance_pointer()->get_database_controller_status();
	t_parkspace_manager_satus = Parkspace_manager::get_instance_pointer()->get_parkspace_manage_status();

	//车位信息消息赋值
	message::Parkspace_allocation_status_msg t_parkspace_status_msg;
	message::Base_info t_base_info;
	message::Error_manager t_error;
	t_base_info.set_msg_type(message::Message_type::eParkspace_allocation_status_msg);
	t_base_info.set_timeout_ms(5000);
	t_base_info.set_sender(message::Communicator::eParkspace);
	t_base_info.set_receiver(message::Communicator::eMain);
	t_error.set_error_code(0);
	t_parkspace_status_msg.mutable_base_info()->CopyFrom(t_base_info);
	t_parkspace_status_msg.mutable_error_manager()->CopyFrom(t_error);

	t_parkspace_status_msg.set_database_controller_status((message::Database_controller_status)t_database_controller_status);
	t_parkspace_status_msg.set_parkspace_manager_satus((message::Parkspace_manager_satus)t_parkspace_manager_satus);

	return Parkspace_communicator::get_instance_references().encapsulate_msg(t_parkspace_status_msg.SerializeAsString());


}
//判断是否为待机，如果已经准备好，则可以执行任务。
bool Parkspace_manager::is_ready()
{
	if ( m_parkspace_manager_satus == eParkspace_manager_normal && m_thread_pool.thread_is_full_load() == false )
	{
	    return true;
	}
	else
	{
		return false;
	}
}

Parkspace_manager::Parkspace_manager_satus Parkspace_manager::get_parkspace_manage_status()
{
	return m_parkspace_manager_satus;
}

// 检查车辆是否已存在，通常分配前调用
bool Parkspace_manager::check_car_existence(std::string license)
{
	message::Parkspace_info parkspaceInfo;
	//获取车辆状态
	Error_manager error=m_parkspace_operating_function.query_one_parkspace_with_license(license,parkspaceInfo);

	//如果车辆处于停车中或者已入库  则车辆已存在
	if(!parkspaceInfo.has_car_info())
	{
		return false;
	}
	return true;
}
Error_manager Parkspace_manager::send_parkspace_data()
{
	message::Parkspace_allocation_data_msg all_parkspace_data;
	Error_manager t_error=m_parkspace_operating_function.get_all_parkspace_info(all_parkspace_data);
	if(t_error != SUCCESS)
	{
		return t_error;
	}
	message::Base_info t_base_info;
	message::Error_manager error;
	t_base_info.set_msg_type(message::Message_type::eParkspace_allocation_data_msg);
	t_base_info.set_timeout_ms(5000);
	t_base_info.set_sender(message::Communicator::eParkspace);
	t_base_info.set_receiver(message::Communicator::eMain);
	all_parkspace_data.mutable_base_info()->CopyFrom(t_base_info);
	error.set_error_code(0);
	all_parkspace_data.mutable_error_manager()->CopyFrom(error);

	return Parkspace_communicator::get_instance_references().encapsulate_msg(all_parkspace_data.SerializeAsString());
}

//找到一个最优车位
Error_manager Parkspace_manager::query_the_optimal_parkspace(message::Parkspace_info &parkspace_info,message::Car_info car_info,int terminal_id)
{
	//车辆高大于1550mm分在四楼以下，小于1550mm分在四楼以上
	/*
	 * K=j%15
	 * P=i%6
	 * S=15*d-(j%15)*(2*d-1)+[6*d-(i%6)(2*d-1)]*W    W>1
	 */
	message::Parkspace_allocation_data_msg all_parkspace_data;
	Error_manager t_error=m_parkspace_operating_function.get_all_parkspace_info(all_parkspace_data);
	if(t_error != SUCCESS)
	{
		return t_error;
	}
	int time_min=0;
	int parkspace_id=0;
	if( car_info.car_height() > CAR_HIGH_STANDARDS )
	{
		//计算四楼以下最优车位
		int i=0;
		while (i<=all_parkspace_data.parkspace_info_size())
		{
			//筛选出空车位
			if ( all_parkspace_data.parkspace_info(i).parkspace_status() == message::Parkspace_status::eParkspace_empty )
			{
				//二楼所有车位统一处理
				if ( all_parkspace_data.parkspace_info(i).floor() == 2  )
				{
					int t_min=abs( i%15*all_parkspace_data.parkspace_info(i).width()-terminal_id%6*TERMINAL_SPACING )/MEDIUM_CAR_SPEED+DOWNSTAIRS_SPORTS_TIME;
					if ( time_min == 0 )
					{
						time_min=t_min;
						parkspace_id=i;
					}
					else
					{
						time_min=t_min<time_min?t_min:time_min;
						parkspace_id=i;
					}
				}
				else if( all_parkspace_data.parkspace_info(i).floor() == 3 )
				{
					//三楼以上车位单独处理两侧位置车位
				    if ( i%15==1 || i%15==2 || i%15==14 || i%15==0 )
					{
				    																//因机械手可以抓车到三楼所以三楼电梯高度减少一个楼层
						int t_min=terminal_id%6*TERMINAL_SPACING/MEDIUM_CAR_SPEED + (all_parkspace_data.parkspace_info(i).floor()-1)*all_parkspace_data.parkspace_info(i).height()/THE_ELEVATOR_SPEED+DOWNSTAIRS_SPORTS_TIME+ELEVATOR_MOVEMENT_TIME;
						if ( time_min == 0 )
						{
							time_min=t_min;
							parkspace_id=i;
						}
						else
						{
							time_min=t_min<time_min?t_min:time_min;
							parkspace_id=i;
						}
				    }
				    else
				    {
						int t_min=abs( i%15*all_parkspace_data.parkspace_info(i).width()-terminal_id%6*TERMINAL_SPACING )/MEDIUM_CAR_SPEED+DOWNSTAIRS_SPORTS_TIME;
						if ( time_min == 0 )
						{
							time_min=t_min;
							parkspace_id=i;
						}
						else
						{
							time_min=t_min<time_min?t_min:time_min;
							parkspace_id=i;
						}
				    }
				}
				else if(all_parkspace_data.parkspace_info(i).floor() == 4)
				{
					if ( i%15==1 || i%15==2 || i%15==14 || i%15==0 )
					{
						int t_min=terminal_id%6*TERMINAL_SPACING/MEDIUM_CAR_SPEED + all_parkspace_data.parkspace_info(i).floor()*all_parkspace_data.parkspace_info(i).height()/THE_ELEVATOR_SPEED+DOWNSTAIRS_SPORTS_TIME+ELEVATOR_MOVEMENT_TIME;
						if ( time_min == 0 )
						{
							time_min=t_min;
							parkspace_id=i;
						}
						else
						{
							time_min=t_min<time_min?t_min:time_min;
							parkspace_id=i;
						}
					}
					else
					{
						//用时=电梯口到目标车位的距离/中跑车速度+目标终端到电梯口的距离/中跑车速度+目标车位楼层*楼层高度/电梯速度
						int time_left= i%15*all_parkspace_data.parkspace_info(i).width()/MEDIUM_CAR_SPEED + UPSTAIRS_SPORTS_TIME + \
								terminal_id%6*TERMINAL_SPACING/MEDIUM_CAR_SPEED + DOWNSTAIRS_SPORTS_TIME + \
								all_parkspace_data.parkspace_info(i).floor()*all_parkspace_data.parkspace_info(i).height()/THE_ELEVATOR_SPEED + ELEVATOR_MOVEMENT_TIME;


						int time_right=(15-i%15)*all_parkspace_data.parkspace_info(i).width()/MEDIUM_CAR_SPEED + UPSTAIRS_SPORTS_TIME + \
								(6-terminal_id%6)*TERMINAL_SPACING/MEDIUM_CAR_SPEED + DOWNSTAIRS_SPORTS_TIME + \
								all_parkspace_data.parkspace_info(i).floor()*all_parkspace_data.parkspace_info(i).height()/THE_ELEVATOR_SPEED + ELEVATOR_MOVEMENT_TIME;
						time_min=time_left;
						parkspace_id=i;
						if ( time_left <= time_right )
						{
							if ( time_min>time_left )
							{
								time_min=time_left;
								parkspace_id=i;
							}
						}
						else
						{
							if ( time_min>time_right )
							{
								time_min=time_right;
								parkspace_id=i;
							}
						}
					}

				}
			}
			++i;
		}
	}
	else if ( car_info.car_height() <= CAR_HIGH_STANDARDS )
	{
		//计算四楼以上最优车位
		int i=0;
		while (i<=all_parkspace_data.parkspace_info_size())
		{
			if(all_parkspace_data.parkspace_info(i).floor()>4 \
			&& all_parkspace_data.parkspace_info(i).parkspace_status() == message::Parkspace_status::eParkspace_empty)
			{
				if ( i%15==1 || i%15==2 || i%15==14 || i%15==0 )
				{
					int t_min=terminal_id%6*TERMINAL_SPACING/MEDIUM_CAR_SPEED + all_parkspace_data.parkspace_info(i).floor()*all_parkspace_data.parkspace_info(i).height()/THE_ELEVATOR_SPEED+DOWNSTAIRS_SPORTS_TIME+ELEVATOR_MOVEMENT_TIME;
					if ( time_min == 0 )
					{
						time_min=t_min;
						parkspace_id=i;
					}
					else
					{
						time_min=t_min<time_min?t_min:time_min;
						parkspace_id=i;
					}
				}
				else
				{
					//用时=电梯口到目标车位的距离/中跑车速度+目标终端到电梯口的距离/中跑车速度+目标车位楼层*楼层高度/电梯速度
					int time_left= i%15*all_parkspace_data.parkspace_info(i).width()/MEDIUM_CAR_SPEED  + UPSTAIRS_SPORTS_TIME +  \
								terminal_id%6*TERMINAL_SPACING/MEDIUM_CAR_SPEED  + DOWNSTAIRS_SPORTS_TIME + \
								all_parkspace_data.parkspace_info(i).floor()*all_parkspace_data.parkspace_info(i).height()/THE_ELEVATOR_SPEED + ELEVATOR_MOVEMENT_TIME;


					int time_right=(15-i%15)*all_parkspace_data.parkspace_info(i).width()/MEDIUM_CAR_SPEED + UPSTAIRS_SPORTS_TIME + \
								(6-terminal_id%6)*TERMINAL_SPACING/MEDIUM_CAR_SPEED + DOWNSTAIRS_SPORTS_TIME + \
								all_parkspace_data.parkspace_info(i).floor()*all_parkspace_data.parkspace_info(i).height()/THE_ELEVATOR_SPEED + ELEVATOR_MOVEMENT_TIME;
					time_min=time_left;
					parkspace_id=i;
					if ( time_left <= time_right )
					{
						if ( time_min>time_left )
						{
							time_min=time_left;
							parkspace_id=i;
						}
					}
					else
					{
						if ( time_min>time_right )
						{
							time_min=time_right;
							parkspace_id=i;
						}
					}
				}
			}
			++i;
		}

	}

	parkspace_info.CopyFrom(all_parkspace_data.parkspace_info(parkspace_id));
	return t_error;
}
//分配车位线程函数
void Parkspace_manager::execute_for_allocate(message::Car_info car_info, int terminal_id, std::string command_key)
{
	LOG(INFO) << "分配车位     "<<"牌号:"<<car_info.license()<<"     command_key="<<command_key;  //huli printf command_key
	//根据请求的信息反馈分配的车位,并封装发送
	message::Parkspace_allocation_response_msg response_msg;
	message::Base_info t_response_header;
	t_response_header.set_msg_type(message::Message_type::eParkspace_allocation_response_msg);
	t_response_header.set_timeout_ms(1000);
	t_response_header.set_sender(message::Communicator::eParkspace);
	t_response_header.set_receiver(message::Communicator::eMain);

	message::Error_manager t_error;
	message::Parkspace_info t_allocated_space;

	Error_manager error;
	//分配之前查询车辆是否已经存在
	if(check_car_existence(car_info.license()))
	{
		t_error.set_error_code(PARKSPACE_ALLOCATOR_CAR_ALREADY_EXIST);
		t_error.set_error_level(message::Error_level::MAJOR_ERROR);
		t_error.set_error_description("车辆已存在");
		LOG(ERROR) << car_info.license()<<"   车辆已存在";
	}
	else
	{
		//如果车辆不存在 则找到一个最优车位
//		error=query_the_optimal_parkspace(t_allocated_space,car_info,terminal_id);
		//如果车辆不存在则获取一个空车位
		error=m_parkspace_operating_function.query_one_empty_parkspace(t_allocated_space);
		if ( error != Error_code::SUCCESS )
		{
			t_error.set_error_code(error.get_error_code());
			t_error.set_error_level((message::Error_level)error.get_error_level());
			t_error.set_error_description(error.get_error_description());
			LOG(ERROR) << car_info.license()<<" 获取空车位失败  "<<error.to_string();
		}
		else
		{
			//修改车为状态为锁定
			t_allocated_space.set_parkspace_status(message::Parkspace_status::eParkspace_locked);
			t_allocated_space.mutable_car_info()->CopyFrom(car_info);
			// 分配车位后更新车位状态
			error=m_parkspace_operating_function.update_parkspace_data(t_allocated_space);
			if ( error != SUCCESS )
			{
				t_error.set_error_code(error.get_error_code());
				t_error.set_error_level((message::Error_level)error.get_error_level());
				t_error.set_error_description(error.get_error_description());
				LOG(ERROR) << car_info.license()<<" 更新车位数据失败  "<<error.to_string();
			}
			else
			{
				//修改车辆状态为停车中
				message::Vehicle_status t_vehicle_status = message::Vehicle_status::eVehicle_parking;
				error=m_parkspace_operating_function.update_vehicle_with_parkspace(t_allocated_space,t_vehicle_status);
				if ( error != SUCCESS )
				{
					t_error.set_error_code(error.get_error_code());
					t_error.set_error_level((message::Error_level)error.get_error_level());
					t_error.set_error_description(error.get_error_description());
					LOG(ERROR) << car_info.license()<<" 更新车辆数据失败  "<<error.to_string();
				}
				else
				{
					t_error.set_error_code(SUCCESS);
					t_error.set_error_level(message::Error_level::NORMAL);
					LOG(INFO) <<"分配车位成功     "<<"车位ID:"<<t_allocated_space.parkspace_id()<<"     车牌号:"<<t_allocated_space.car_info().license();
				}
			}
		}
	}
	response_msg.mutable_base_info()->CopyFrom(t_response_header);
	response_msg.set_command_key(command_key);
	response_msg.mutable_error_manager()->CopyFrom(t_error);
	response_msg.mutable_allocated_space_info()->CopyFrom(t_allocated_space);
	Communication_message response=Communication_message();
	response.reset(t_response_header, response_msg.SerializeAsString());
	Parkspace_communicator::get_instance_references().send_response(&response);

	send_parkspace_data();
}

//查询车位线程函数
void Parkspace_manager::execute_for_search(message::Car_info car_info,std::string command_key)
{
	LOG(INFO) << "查询车位     "<<"牌号:"<<car_info.license()<<"     command_key="<<command_key;  //huli printf command_key
	//根据车辆凭证信息查询车辆位置
	message::Parkspace_search_response_msg response_msg;
	message::Base_info t_response_header;
	message::Error_manager t_error;
	message::Parkspace_info t_car_position;
	t_response_header.set_msg_type(message::Message_type::eParkspace_search_response_msg);
	t_response_header.set_timeout_ms(1000);
	t_response_header.set_sender(message::Communicator::eParkspace);
	t_response_header.set_receiver(message::Communicator::eMain);
	//查询车辆位置
	message::Parkspace_info parkspace_info;
	Error_manager error=m_parkspace_operating_function.query_one_parkspace_with_license(car_info.license(),parkspace_info);
	if ( error != SUCCESS )
	{
		t_error.set_error_code(error.get_error_code());
		t_error.set_error_level((message::Error_level)error.get_error_level());
		t_error.set_error_description(error.get_error_description());
		LOG(ERROR) << "查询车位失败     "<<error.to_string();
	}
	else
	{
		t_error.set_error_code(SUCCESS);
		t_error.set_error_level(message::Error_level::NORMAL);
		LOG(INFO) << "车辆"<<parkspace_info.car_info().license()<<"     在"<<parkspace_info.parkspace_id()<<"号车位上";
	}
	response_msg.mutable_base_info()->CopyFrom(t_response_header);
	response_msg.set_command_key(command_key);
	response_msg.mutable_error_manager()->CopyFrom(t_error);
	response_msg.mutable_car_position()->CopyFrom(t_car_position);
	Communication_message response=Communication_message();
	response.reset(t_response_header, response_msg.SerializeAsString());
	Parkspace_communicator::get_instance_references().send_response(&response);
}

//释放车位线程函数
void Parkspace_manager::execute_for_release(message::Parkspace_info space_info, std::string command_key)
{

	LOG(INFO) << "释放车位     "<<"牌号:"<<space_info.car_info().license()<<"     command_key="<<command_key;
	//根据车位信息定位待释放车位位置，车辆凭证号用于校验
	message::Parkspace_release_response_msg response_msg;
	message::Base_info t_response_header;
	t_response_header.set_msg_type(message::eParkspace_release_response_msg);
	t_response_header.set_sender(message::eParkspace);
	t_response_header.set_receiver(message::eMain);
	t_response_header.set_timeout_ms(1000);
	message::Error_manager t_error;
	message::Parkspace_info t_release_space;
	//找到待释放的车位
	Error_manager error=m_parkspace_operating_function.query_one_parkspace_with_parkspace_id(space_info.parkspace_id(),t_release_space);
	if ( error != SUCCESS )
	{
		t_error.set_error_code(error.get_error_code());
		t_error.set_error_level((message::Error_level)error.get_error_level());
		t_error.set_error_description(error.get_error_description());
		LOG(ERROR) << "释放车位失败 "<<error.to_string();
	}
	else if(!t_release_space.has_car_info())
	{
		t_error.set_error_code(PARKSPACE_ALLOCATOR_RELEASE_FAILED);
		t_error.set_error_level(message::Error_level::MAJOR_ERROR);
		LOG(WARNING) << "传入待释放车位无车辆信息";
	}
	else
	{
		t_release_space.set_parkspace_status(message::Parkspace_status::eParkspace_empty);
		error = m_parkspace_operating_function.update_parkspace_data(t_release_space);
		if (error != SUCCESS)
		{
			t_error.set_error_code(error.get_error_code());
			t_error.set_error_level((message::Error_level) error.get_error_level());
			t_error.set_error_description(error.get_error_description());
			LOG(ERROR) << "释放车位 更新数据库车位数据失败   " << error.to_string();
		}
		else
		{
			message::Vehicle_status t_vehicle_status = message::Vehicle_status::eVehicle_idle;
			error = m_parkspace_operating_function.update_vehicle_with_parkspace(t_release_space, t_vehicle_status);
			if (error != SUCCESS)
			{
				t_error.set_error_code(error.get_error_code());
				t_error.set_error_level((message::Error_level) error.get_error_level());
				t_error.set_error_description(error.get_error_description());
				LOG(ERROR) << "释放车位 更新数据库车辆数据失败 " << error.to_string();
			}
			else
			{

				t_error.set_error_code(SUCCESS);
				t_error.set_error_level(message::Error_level::NORMAL);
				LOG(INFO) << "第：" << t_release_space.parkspace_id() << "号位     车辆: " << t_release_space.car_info().license()
						  << "     释放成功";

				//获取预约ID
				int t_park_record_id;
				error = m_parkspace_operating_function.query_vehicle(t_release_space.car_info().license(),
																	 t_vehicle_status, t_park_record_id);
				if (error != SUCCESS)
				{
					t_error.set_error_code(error.get_error_code());
					t_error.set_error_level((message::Error_level) error.get_error_level());
					t_error.set_error_description(error.get_error_description());
					LOG(ERROR) << "释放车位 数据库查询车辆信息失败 " << error.to_string();
				}
				else if (t_vehicle_status == message::Vehicle_status::eVehicle_idle)
				{
					time_t tt = time(NULL);
					tm *t = localtime(&tt);
					char my_time_buf[255];
					memset(my_time_buf, 0, 255);
					sprintf(my_time_buf, "%d-%02d-%02d %02d:%02d:%02d",
							t->tm_year + 1900,
							t->tm_mon + 1,
							t->tm_mday,
							t->tm_hour,
							t->tm_min,
							t->tm_sec);
					t_release_space.set_leave_time(my_time_buf);
					error = m_parkspace_operating_function.update_parking_record(t_release_space, t_park_record_id);
					if (error != SUCCESS)
					{
						t_error.set_error_code(error.get_error_code());
						t_error.set_error_level((message::Error_level) error.get_error_level());
						t_error.set_error_description(error.get_error_description());
						LOG(ERROR) << "更新停车记录失败: " << error.to_string();
					}
				}
			}
		}
	}
	response_msg.mutable_base_info()->CopyFrom(t_response_header);
	response_msg.set_command_key(command_key);
	response_msg.mutable_error_manager()->CopyFrom(t_error);
	response_msg.mutable_release_space_info()->CopyFrom(t_release_space);
	Communication_message response=Communication_message();
	response.reset(t_response_header, response_msg.SerializeAsString());
	Parkspace_communicator::get_instance_references().send_response(&response);

	send_parkspace_data();
}

//强制更新车位信息线程函数
void Parkspace_manager::execute_for_force_update(message::Parkspace_info space_info, std::string command_key)
{

	LOG(INFO) << "手动   "<<"牌号:"<<space_info.car_info().license()<<"   command_key="<<command_key;
	//根据车位信息定位待释放车位位置，车辆凭证号用于校验
	//!!!!!此处跳过外部处理与调用的过程，直接在内部调用，发送分配结果用于测试，目前一直发布第一个车位
	message::Parkspace_force_update_response_msg response_msg;
	message::Base_info t_response_header;
	t_response_header.set_msg_type(message::eParkspace_force_update_response_msg);
	t_response_header.set_sender(message::eParkspace);
	t_response_header.set_receiver(message::eMain);
	t_response_header.set_timeout_ms(1000);
	message::Error_manager t_error;
	message::Parkspace_info t_update_space;
	Error_manager error;
	// id 9999为特殊情况，复位所有车位状态
	if (space_info.parkspace_id() == 9999)
	{
		// 复位所有车位状态
		error=m_parkspace_operating_function.clear_all_parkspace_info();
		if( error != SUCCESS)
		{
			t_error.set_error_code(error.get_error_code());
			t_error.set_error_level((message::Error_level) error.get_error_level());
			LOG(INFO) << "手动更新所有车位失败 "<<error.to_string();
		}
		else
		{
			t_error.set_error_code(SUCCESS);
			t_error.set_error_level(message::Error_level::NORMAL);
			LOG(INFO) << "所有车位已手动更新 ";
		}
	}
	else
	{
		//手动修改车位信息
		error  = m_parkspace_operating_function.update_parkspace_data(t_update_space);
		if (error != SUCCESS)
		{
			t_error.set_error_code(error.get_error_code());
			t_error.set_error_level((message::Error_level)error.get_error_level());
			LOG(INFO) << "手动  数据库更新车位失败  "<<error.to_string();
		}
		else
		{
			t_error.set_error_code(SUCCESS);
			t_error.set_error_level(message::Error_level::NORMAL);
			LOG(INFO) << "第" << t_update_space.parkspace_id() << "号位已手动更新";
		}
	}

	response_msg.mutable_base_info()->CopyFrom(t_response_header);
	response_msg.set_command_key(command_key);
	response_msg.mutable_error_manager()->CopyFrom(t_error);
	response_msg.mutable_update_space_info()->CopyFrom(t_update_space);
	Communication_message response=Communication_message();
	response.reset(t_response_header, response_msg.SerializeAsString());
	Parkspace_communicator::get_instance_references().send_response(&response);

	send_parkspace_data();
}

//确认分配车位线程函数
void Parkspace_manager::execute_for_confirm_alloc(message::Parkspace_info space_info, std::string command_key)
{

	LOG(INFO) << "确认分配     " << "牌号:" << space_info.car_info().license() << "     command_key=" << command_key;
	//根据车位信息定位待确认占用车位
	message::Parkspace_confirm_alloc_response_msg response_msg;
	message::Base_info t_response_header;
	t_response_header.set_msg_type(message::eParkspace_confirm_alloc_response_msg);
	t_response_header.set_sender(message::eParkspace);
	t_response_header.set_receiver(message::eMain);
	t_response_header.set_timeout_ms(1000);
	message::Error_manager t_error;
	message::Parkspace_info t_confirm_space;
	Error_manager error;
	//获取确认分配的车位
	error = m_parkspace_operating_function.query_one_parkspace_with_parkspace_id(space_info.parkspace_id(),
																				 t_confirm_space);
	if (error != SUCCESS)
	{
		t_error.set_error_code(error.get_error_code());
		t_error.set_error_level((message::Error_level) error.get_error_level());
		t_error.set_error_description(error.get_error_description());
		LOG(ERROR) << "确认分配 查询车位信息失败 " << error.to_string();
	}
	else if (!t_confirm_space.has_car_info())
	{
		t_error.set_error_code(PARKSPACE_ALLOCATOR_RELEASE_FAILED);
		t_error.set_error_level(message::Error_level::MAJOR_ERROR);
		LOG(WARNING) << "传入待确认车位无车辆信息";
	}
	else
	{
		//校验车位状态是否为被锁定
		if (t_confirm_space.parkspace_status() != message::Parkspace_status::eParkspace_locked)
		{
			t_error.set_error_code(DB_QUERY_DATA_FAILED);
			t_error.set_error_level(message::Error_level::MINOR_ERROR);
			t_error.set_error_description("查询车位状态错误");
			LOG(ERROR) << "确认分配 查询车位状态错误 " << error.to_string();
		}
		else
		{
			//修改车位状态为占用
			t_confirm_space.set_parkspace_status(message::Parkspace_status::eParkspace_occupied);
			error = m_parkspace_operating_function.update_parkspace_data(t_confirm_space);
			if (error != SUCCESS)
			{
				t_error.set_error_code(error.get_error_code());
				t_error.set_error_level((message::Error_level) error.get_error_level());
				LOG(INFO) << "确认分配  数据库更新车位失败  " << error.to_string();
			}
			else
			{
				//修改车辆状态为已入库
				message::Vehicle_status t_vehicle_status = message::Vehicle_status::eVehicle_in_garage;
				error = m_parkspace_operating_function.update_vehicle_with_parkspace(t_confirm_space, t_vehicle_status);
				if (error != SUCCESS)
				{
					t_error.set_error_code(error.get_error_code());
					t_error.set_error_level((message::Error_level) error.get_error_level());
					t_error.set_error_description(error.get_error_description());
					LOG(ERROR) << "确认分配 更新数据库车辆数据失败 " << error.to_string();
				}
				t_error.set_error_code(SUCCESS);
				t_error.set_error_level(message::Error_level::NORMAL);
				LOG(INFO) << "第：" << t_confirm_space.parkspace_id() << "号位     车辆: " << t_confirm_space.car_info().license()<< "     确认占用成功";
				//插入停车记录
				time_t tt = time(NULL);
				tm *t = localtime(&tt);
				char my_time_buf[255];
				memset(my_time_buf, 0, 255);
				sprintf(my_time_buf, "%d-%02d-%02d %02d:%02d:%02d",
						t->tm_year + 1900,
						t->tm_mon + 1,
						t->tm_mday,
						t->tm_hour,
						t->tm_min,
						t->tm_sec);
				t_confirm_space.set_entry_time(my_time_buf);
				error = m_parkspace_operating_function.insert_parking_record(t_confirm_space);
				if ( error != SUCCESS )
				{
					t_error.set_error_code(error.get_error_code());
					t_error.set_error_level((message::Error_level) error.get_error_level());
					LOG(ERROR) << "插入停车记录失败: " << error.to_string();
				}
				//查询停车记录的ID
				int t_record_id;
				error = m_parkspace_operating_function.query_parking_record(t_confirm_space,t_record_id);
				if ( error != SUCCESS )
				{
					t_error.set_error_code(error.get_error_code());
					t_error.set_error_level((message::Error_level) error.get_error_level());
					LOG(ERROR) << "查询停车记录ID失败: " << error.to_string();
				}
				//更新停车记录ID
				error = m_parkspace_operating_function.update_record_id(t_confirm_space.car_info().license(),t_record_id);
				if ( error != SUCCESS )
				{
					t_error.set_error_code(error.get_error_code());
					t_error.set_error_level((message::Error_level) error.get_error_level());
					LOG(ERROR) << "更新停车记录ID失败: " << error.to_string();
				}
			}
		}
	}
	response_msg.mutable_base_info()->CopyFrom(t_response_header);
	response_msg.set_command_key(command_key);
	response_msg.mutable_error_manager()->CopyFrom(t_error);
	response_msg.mutable_confirm_alloc_space_info()->CopyFrom(t_confirm_space);
	Communication_message response=Communication_message();
	response.reset(t_response_header, response_msg.SerializeAsString());
	Parkspace_communicator::get_instance_references().send_response(&response);

	send_parkspace_data();
}