//
//
// 20210425, hl_dispatch 和 hl_dispatch_B的版本进行同步, 此时调度管理的功能全部完成.后续可能还需要日志记录.
//
//test 2022 10 26
//huli 20230202


#include <iostream>
#include "./error_code/error_code.h"
//#include "LogFiles.h"
#include <glog/logging.h>
#include <string>
#include <iostream>

//#include "./communication/communication_socket_base.h"

#include "./tool/thread_pool.h"
#include "./system/system_communication.h"
#include "./system/system_executor.h"
#include "./rabbitmq/rabbitmq_base.h"

#include "./dispatch/dispatch_manager.h"
#include "./dispatch/dispatch_communication.h"
#include "./dispatch/dispatch_coordinates.h"
#include "./dispatch/database_controller.h"

#include "./tool/common_data.h"
#include "./tool/time_tool.h"
#include "./tool/mysql_statistics.h"

#include "./rabbitmq/ttt.h"

#include <algorithm>    // std::for_each
#include <google/protobuf/text_format.h>

//#include <iostream>
//#include <mysqlx/xdevapi.h>
//
//using namespace mysqlx;

void shut_down_logging(const char* data, size_t size)
{
	time_t tt;
	time( &tt );
	tt = tt + 8*3600;  // transform the time zone
	tm* t= gmtime( &tt );
	char buf[255]={0};
	sprintf(buf,"./%d%02d%02d-%02d%02d%02d-dump.txt",
			t->tm_year + 1900,
			t->tm_mon + 1,
			t->tm_mday,
			t->tm_hour,
			t->tm_min,
			t->tm_sec);

	FILE* tp_file=fopen(buf,"w");
	fprintf(tp_file,data,strlen(data));
	fclose(tp_file);

}


#include "./network_communication/network_base.h"
#include "./dispatch/dispatch_network.h"



#include <vector>
bool myfunction (int i,int j) { return (i<j); }


int main(int argc,char* argv[])
{

//
//	for (auto iter = aaa.begin(); iter != aaa.end(); ++iter)
//	{
//	    std::cout << " huli test :::: " << " iter.first = " << iter->first << std::endl;
//	    std::cout << " huli test :::: " << " iter.second = " << iter->second << std::endl;
//	    std::cout << " huli test :::: " << " ............. = " << 0 << std::endl;
//	}
//
//	std::sort(aaa.begin(), aaa.end(), myfunction);
//	for (auto iter = aaa.begin(); iter != aaa.end(); ++iter)
//	{
//		std::cout << " huli test :::: " << " iter.first = " << iter->first << std::endl;
//		std::cout << " huli test :::: " << " iter.second = " << iter->second << std::endl;
//		std::cout << " huli test :::: " << " ............. = " << 0 << std::endl;
//	}
//	return 0;


//	std::string t = SETTING_PATH RABBITMQ_PARAMETER_PATH_A;
//	std::cout << " huli test :::: " << " t = " << t << std::endl;
//	float asd = 2.95;
//	int qwe = Common_data::judge_wheel_base_level_new(2.95);
//std::cout << " huli test :::: " << " qwe = " << qwe << std::endl;
//	return 0;


	Error_manager t_error;

	int t_dispatch_id = 31;
//	std::cin >> t_dispatch_id ;
	if ( argc == 2 )
	{
		std::cout << " huli test :::: " << " argv[1] = " << argv[1] << std::endl;
		t_dispatch_id = atoi(argv[1]);
	}

	//日志保存文件路径
	const char* logPath = "./";
	google::InitGoogleLogging("LidarMeasurement");
	google::SetStderrLogging(google::INFO);
	google::SetLogDestination(0, logPath);
	char t_log[256]  = {0};
	sprintf(t_log, "sgj%d.log", t_dispatch_id);
	google::SetLogFilenameExtension(t_log);
	google::InstallFailureSignalHandler();
	google::InstallFailureWriter(&shut_down_logging);
	FLAGS_colorlogtostderr = true;        // Set log color
	FLAGS_logbufsecs = 0;                // Set log output speed(s)
	FLAGS_max_log_size = 1024;            // Set max log file size(GB)
	FLAGS_stop_logging_if_full_disk = true;


//#define MAIN_TEST 1
#ifdef MAIN_TEST

#endif



	LOG(INFO) << " ******************************************************************************************************************* " ;
	LOG(INFO) << "*********************************************dispatch run " << " t_dispatch_id = " << t_dispatch_id ;
	LOG(INFO) << "*********************************************dispatch run " << " start time  = " << Time_tool::get_instance_references().get_current_time_millisecond() ;
	LOG(INFO) << " ******************************************************************************************************************* ";
	std::cout << "dispatch :::: " << " t_dispatch_id = " << t_dispatch_id << std::endl;

	Database_controller::get_instance_references().database_controller_init();
	std::cout << "++++++++++++++++++++ Database_controller = " << Database_controller::get_instance_references().get_database_controller_status() << std::endl;

//	sql_test();
//	sql_ttt_3();
//	sql_ttt_4();
//	return 0;

//	mysql_collect_daily_data_all_unit(2023, 6, 1, 30);
//	mysql_collect_daily_data_all_unit(2023, 7, 1, 31);
//	mysql_collect_daily_data_all_unit(2023, 8, 1, 31);
//	mysql_collect_daily_data_all_unit(2023, 9, 1, 30);
//	mysql_collect_daily_data_all_unit(2023, 10, 1, 31);
//	mysql_collect_daily_data_all_unit(2023, 11, 1, 30);
//	mysql_collect_daily_data_all_unit(2023, 12, 1, 31);
//	mysql_collect_daily_data_all_unit(2024, 1, 1, 31);
//	mysql_collect_daily_data_all_unit(2024, 2, 1, 29);
//	mysql_collect_daily_data_all_unit(2024, 3, 1, 19);
//	return 0;


	Dispatch_manager::get_instance_references().dispatch_manager_init(t_dispatch_id);
	std::cout << "++++++++++++++++++++Dispatch_manager = " << Dispatch_manager::get_instance_references().get_dispatch_manager_status() << std::endl;

	Dispatch_communication::get_instance_references().communication_init(t_dispatch_id);
	std::cout << "+++++++++++++Dispatch_manager = " << Dispatch_manager::get_instance_references().get_dispatch_manager_status() << std::endl;

	System_executor::get_instance_references().system_executor_init(8);
	std::cout << "++++++++++++++++System_executor = " << System_executor::get_instance_references().get_system_executor_status() << std::endl;

	t_error = System_communication::get_instance_references().communication_init(t_dispatch_id);
	std::cout << "++++++++++++++++++huli test System_communication:::: " << " t_error = " << t_error << std::endl;
	System_communication::get_instance_references().set_encapsulate_status_cycle_time(100);

	t_error = Dispatch_network::get_instance_references().network_init(t_dispatch_id);
	std::cout << "++++++++++++++++++huli test network_init:::: " << " t_error = " << t_error << std::endl;
	LOG(INFO) << " t_error = Dispatch_network::get_instance_references().network_init(t_dispatch_id);----------------------------- ";

//	Led_protocol l;
//	l.led_protocol_init();
//
//	while (1)
//	{
//		std::this_thread::sleep_for(std::chrono::seconds(1));
//		l.create_led_message(1, Time_tool::get_instance_references().get_current_time_seconds(), 0, 0, 256, 16);
//		l.create_led_message(2, Time_tool::get_instance_references().get_current_time_seconds(), 0, 16, 256, 16);
//		Dispatch_network::get_instance_references().encapsulate_msg( l.get_led_msg_total_string() , 1 );
//	}
	


#ifdef CHUTIAN_PROJECT_PROJECT
	t_error = Dispatch_network::get_instance_references().network_init(t_dispatch_id);
	std::cout << "++++++++++++++++++huli test System_communication:::: " << " t_error = " << t_error << std::endl;
#endif //CHUTIAN_PROJECT_PROJECT
	while ( 1 )
	{
	    std::this_thread::sleep_for(std::chrono::seconds(1));

	}



	/*


	//led test
	std::string result;
	Led_protocol led_protocol;
	t_error = led_protocol.led_protocol_init();
	std::cout << " huli test :::: " << " t_error = " << t_error << std::endl;

//	std::string t_show_string_utf8_0 = "\\C7楚天车库\\n\\C2停车入口6\\n\\C3暂停服务";
	std::string t_show_string_utf8_0 = "1122cba0123456";

	std::string t_show_string_gbk_0 = String_convert::utf8_to_gbk(t_show_string_utf8_0);
	//方法1, 直接创建, 只需要设置显示内容和矩形框
	result = led_protocol.create_led_message(0, t_show_string_gbk_0, 0, 0, 79, 59);


//	std::string t_show_string_utf8_1 = "";
//	std::string t_show_string_gbk_1 = String_convert::utf8_to_gbk(t_show_string_utf8_1);
//	//方法1, 直接创建, 只需要设置显示内容和矩形框
//	result = led_protocol.create_led_message(1, t_show_string_gbk_1, 79, 59, 1, 1);


	//方法2, 自定义配置,
//	led_protocol.set_show_string(0, t_show_string2);
//	led_protocol.set_show_rectangle(0, 0, 0, 79, 59);
//	led_protocol.set_line_mode(0, 2, 1);
//	result = led_protocol.get_led_msg_total_string();

	//打印
	unsigned char * ch = (unsigned char * )result.c_str();
	printf("Led_communication_msg string =  \n");
	for (int i = 0; i < result.length(); ++i)
	{
		printf("%02x", *(ch+i));
	}
	printf("\n");
	for (int i = 0; i < result.length(); ++i)
	{
		printf("%02x ", *(ch+i));
	}
	printf("\n");
	for (int i = 0; i < result.length(); ++i)
	{
		printf("\\x%02x", *(ch+i));
	}
	printf("\n");

	printf("result.size() = %d\n", result.size());


	while ( 1 )
	{
		std::this_thread::sleep_for(std::chrono::seconds(1));
	}


	*/




	char ch ;
	std::cin >> ch ;

	System_communication::get_instance_references().rabbitmq_uninit();
	System_executor::get_instance_references().system_executor_uninit();
	Dispatch_communication::get_instance_references().communication_uninit();
	Dispatch_manager::get_instance_references().dispatch_manager_uninit();


	return 0;
}