<?
//$_SERVER["DOCUMENT_ROOT"] = __DIR__;
define('STOP_STATISTICS', true);
define('NO_KEEP_STATISTIC', 'Y');
define('NO_AGENT_STATISTIC', 'Y');
define('DisableEventsCheck', true);
define('BX_SECURITY_SHOW_MESSAGE', true);
define('NOT_CHECK_PERMISSIONS', true);

$_SERVER['DOCUMENT_ROOT'] = dirname(__DIR__, 1);
require_once($_SERVER['DOCUMENT_ROOT'].'/bitrix/modules/main/include/prolog_before.php'); 
CModule::IncludeModule('iblock');

$arrContextOptions = [
	"ssl" => [
		"verify_peer"=>false,
		"verify_peer_name"=>false,
	],
];

$bitrix_existed_brands = [];
$bitrix_existed_models = [];
$api_brands = [];
$api_models = [];
$bitrix_existed_modifications = [];
$bitrix_existed_cars = [];

$all_brands_search_res = CIBlockElement::GetList( [], [ "IBLOCK_ID" => IBLOCK_ID_BRANDS, "ACTIVE" => "Y" ], false, false, [] );
while($all_brands_search_ob = $all_brands_search_res->GetNextElement())
{
	$brand_search = $all_brands_search_ob->GetFields();
	$brand_search['PROPERTIES'] = $all_brands_search_ob->GetProperties();

	array_push( $bitrix_existed_brands, $brand_search['PROPERTIES']['UID']['VALUE'] );
}

$all_models_search_res = CIBlockElement::GetList( [], [ "IBLOCK_ID" => IBLOCK_ID_MODELS, "ACTIVE" => "Y" ], false, false, [] );
while($all_models_search_ob = $all_models_search_res->GetNextElement())
{
	$model_search = $all_models_search_ob->GetFields();
	$model_search['PROPERTIES'] = $all_models_search_ob->GetProperties();

	array_push( $bitrix_existed_models, $model_search['PROPERTIES']['UID']['VALUE'] );
}

$all_modifications_search_res = CIBlockElement::GetList( [], [ "IBLOCK_ID" => 10, "ACTIVE" => "Y" ], false, false, [] );
while($all_modifications_search_ob = $all_modifications_search_res->GetNextElement())
{
	$modification_search = $all_modifications_search_ob->GetFields();

	array_push( $bitrix_existed_modifications, $modification_search['CODE'] );
}

$all_cars_search_res = CIBlockElement::GetList( [], [ "IBLOCK_ID" => 1, "ACTIVE" => "Y" ], false, false, [] );
while($all_cars_search_ob = $all_cars_search_res->GetNextElement())
{
	$car_search = $all_cars_search_ob->GetFields();
	$car_search['PROPERTIES'] = $all_cars_search_ob->GetProperties();

	array_push( $bitrix_existed_cars, $car_search['PROPERTIES']['UID']['VALUE'] );
}

print "bitrix_existed_brands = ".count($bitrix_existed_brands)."\n";
print "bitrix_existed_models = ".count($bitrix_existed_models)."\n";
print "bitrix_existed_modifications = ".count($bitrix_existed_modifications)."\n";
print "bitrix_existed_cars = ".count($bitrix_existed_cars)."\n";

$content = file_get_contents(API_HOST."/site/Vehicle/GetModifications", false, stream_context_create($arrContextOptions));
$json = json_decode($content, true);
$brands_and_models = [];

//print "---------------\n\n";
//print_r();
//print "---------------\n\n";

$c = 0;

$api_data = [];
$api_brands = [];
$api_models = [];
$api_cars = [];

//prepare brands list from API
foreach($json AS $entry)
{
	if(!isset($api_data[ $entry['brand']['id'] ]))
	{
		$api_data[ $entry['brand']['id'] ] = [
			"models" => []
		];
	}

	if(!in_array($entry['brand']['id'], $api_brands))
	{
		array_push($api_brands, $entry['brand']['id']);
	}
}

//prepare models list from API
foreach($json AS $entry)
{
	if(!isset($api_data[ $entry['brand']['id'] ]['models'][ $entry['model']['id'] ]))
	{
		$api_data[ $entry['brand']['id'] ]['models'][ $entry['model']['id'] ] = [
			"cars" => []
		];
	}

	if(!in_array($entry['model']['id'], $api_models))
	{
		array_push($api_models, $entry['model']['id']);
	}
}

//prepare models list from API
foreach($json AS $entry)
{
	if(!isset($api_data[ $entry['brand']['id'] ]['models'][ $entry['model']['id'] ]['cars'][ $entry['uid'] ]))
	{
		array_push($api_data[ $entry['brand']['id'] ]['models'][ $entry['model']['id'] ]['cars'], $entry['uid']);
	}

	if(!in_array($entry['uid'], $api_cars))
	{
		array_push($api_cars, $entry['uid']);
	}
}

//print_r($bitrix_existed_models);
foreach($bitrix_existed_models AS $existed_model)
{
	//print $existed_model." ?\n";
	if(!in_array($existed_model, $api_models))
	{
		print "HIDE MODEL ".$existed_model."\n";
	}
}

////print_r($api_data);
////die();

foreach($json AS $entry)
{
	if(!isset($brands_and_models[ $entry['brand']['id'] ]))
	{
		$brands_and_models[ $entry['brand']['id'] ] = [
			"name" => $entry['brand']['name'], 
			"models" => [ 
				$entry['model']['id'] => [
					"name" => $entry['model']['name'], 
					"modifications" => [ $entry['modification'] ], 
				]
			],
		];
	}
	else
	{
		if(!isset($brands_and_models[ $entry['brand']['id'] ][ 'models' ][ $entry['model']['id'] ]))
		{
			$brands_and_models[ $entry['brand']['id'] ][ 'models' ][ $entry['model']['id'] ] = [
				"name" => $entry['model']['name'], 
				"modifications" => [ $entry['modification'] ], 
			];
		}

		if(!in_array($entry['modification'], $brands_and_models[ $entry['brand']['id'] ][ 'models' ][ $entry['model']['id'] ][ 'modifications' ]))
		{
			array_push($brands_and_models[ $entry['brand']['id'] ][ 'models' ][ $entry['model']['id'] ][ 'modifications' ], $entry['modification']);
		}
	}

	if($c === 0)
	{
		print_r($entry);
	}
	$c++;
}

//print_r($brands_and_models);
//die();
$c = 0;

$bitrix_brands = [];
$bitrix_models = [];
$bitrix_modifications = [];
$bitrix_modifications_codes = [];

foreach($brands_and_models AS $brand_uid => $brand)
{
	//print $uid." - ".$brand['name']."\n";

	//if($c < 2)
	//{
		//добавляем новую марку
		$brand_existed = null;
		$brand_search_res = CIBlockElement::GetList( [], [ "IBLOCK_ID" => IBLOCK_ID_BRANDS, "PROPERTY_UID" => $brand_uid ], false, ["nPageSize" => 1], [] );
		while($brand_search_ob = $brand_search_res->GetNextElement())
		{
			$brand_existed = $brand_search_ob->GetFields();
			$brand_existed['PROPERTIES'] = $brand_search_ob->GetProperties();

			$bitrix_brands[ $brand_uid ] = $brand_existed['ID'];
		}

		$code = CUtil::translit( $brand['name'], "ru", [ "max_len" => 255, "change_case" => "L", "replace_space" => "-", "replace_other" => "-", ] );
		if($brand_existed !== null)
		{
			$brand_update_payload = [ 
				"ACTIVE" => "Y", 
				"CODE" => $code, 
				"NAME" => $brand['name'], 
			];

			$update_element = new CIBlockElement;
			$update_result = $update_element->Update($brand_existed['ID'], $brand_update_payload);

			$result = models_check($bitrix_models, $bitrix_modifications, $bitrix_modifications_codes, $brand_uid, $brand);

			$bitrix_models = $result['bitrix_models'];
			$bitrix_modifications = $result['bitrix_modifications'];
			$bitrix_modifications_codes = $result['bitrix_modifications_codes'];
		}
		else
		{
			$brand_element = new CIBlockElement;
			$brand_payload = [ 
				"IBLOCK_SECTION_ID"	=> false, 
				"IBLOCK_ID" => IBLOCK_ID_BRANDS, 
				"PROPERTY_VALUES" => [ 
					"UID" => $brand_uid, 
					"TRANSCRIPTION" => $brand['name'], 
				], 
				"NAME" => $brand['name'], 
				"CODE" => $code, 
				"ACTIVE" => "Y", 
			];

			if($new_brand_id = $brand_element->Add($brand_payload))
			{
				$bitrix_brands[$brand_uid] = $new_brand_id;
			}
			else
			{
				echo "brand error: ".$brand_element->LAST_ERROR;
			}

			$result = models_check($bitrix_models, $bitrix_modifications, $bitrix_modifications_codes, $brand_uid, $brand);

			$bitrix_models = $result['bitrix_models'];
			$bitrix_modifications = $result['bitrix_modifications'];
			$bitrix_modifications_codes = $result['bitrix_modifications_codes'];
		}

		//print "\n------------------------------\n";
	//}

	$c++;
}

function set_brand_activity($brand_uid, $active = "N")
{
	$brand_id = null;
	$brand_search_res = CIBlockElement::GetList( [], [ "IBLOCK_ID" => IBLOCK_ID_BRANDS, "PROPERTY_UID" => $brand_uid ], false, false, [] );

	while($brand_search_ob = $brand_search_res->GetNextElement())
	{
		$brand_search = $brand_search_ob->GetFields();
		$brand_id = $brand_search['ID'];
	}

	if($brand_id !== null)
	{
		$update_element = new CIBlockElement;
		$update_result = $update_element->Update($brand_id, [ "ACTIVE" => $active, ]);
	}
}

function set_model_activity($model_uid, $active = "N")
{
	$model_id = null;
	$model_search_res = CIBlockElement::GetList( [], [ "IBLOCK_ID" => IBLOCK_ID_MODELS, "PROPERTY_UID" => $model_uid ], false, false, [] );

	while($model_search_ob = $model_search_res->GetNextElement())
	{
		$model_search = $model_search_ob->GetFields();
		$model_id = $model_search['ID'];
	}

	if($model_id !== null)
	{
		$update_element = new CIBlockElement;
		$update_result = $update_element->Update($model_id, [ "ACTIVE" => $active, ]);
	}
}

function set_modification_activity($modification_code, $active = "N")
{
	$modification_id = null;
	$modification_search_res = CIBlockElement::GetList( [], [ "IBLOCK_ID" => 10, "CODE" => $modification_code ], false, false, [] );

	while($modification_search_ob = $modification_search_res->GetNextElement())
	{
		$modification_search = $modification_search_ob->GetFields();
		$modification_id = $modification_search['ID'];
	}

	if($modification_id !== null)
	{
		$update_element = new CIBlockElement;
		$update_result = $update_element->Update($modification_id, [ "ACTIVE" => $active, ]);
	}
}

function set_car_activity($car_uid, $active = "N")
{
	print "SET ACTIVE ".$car_uid." | ".$active."\n";
	$car_id = null;
	$car_search_res = CIBlockElement::GetList( [], [ "IBLOCK_ID" => IBLOCK_ID_CATALOG_CARS_NEW, "PROPERTY_UID" => $car_uid ], false, false, [] );

	while($car_search_ob = $car_search_res->GetNextElement())
	{
		$car_search = $car_search_ob->GetFields();
		$car_id = $car_search['ID'];
	}

	if($car_id !== null)
	{
		$update_element = new CIBlockElement;
		$update_result = $update_element->Update($car_id, [ "ACTIVE" => $active, ]);
	}
}

function models_check($bitrix_models, $bitrix_modifications, $bitrix_modifications_codes, $brand_uid, $brand)
{
	foreach($brand['models'] AS $model_uid => $model)
	{
		$model_name = $model['name'];

		$model_existed = null;
		$model_search_res = CIBlockElement::GetList( [], [ "IBLOCK_ID" => IBLOCK_ID_MODELS, "PROPERTY_UID" => $model_uid ], false, ["nPageSize" => 1], [] );
		while($model_search_ob = $model_search_res->GetNextElement())
		{
			$model_existed = $model_search_ob->GetFields();
			$model_existed['PROPERTIES'] = $model_search_ob->GetProperties();

			$bitrix_models[$model_uid] = $model_existed['ID'];
		}

		$code = CUtil::translit( $model_name, "ru", [ "max_len" => 255, "change_case" => "L", "replace_space" => "-", "replace_other" => "-", ] );

		if($model_existed !== null)
		{
			//print "MODEL ".$model_uid." EXISTED";

			$model_update_payload = [ 
				"ACTIVE" => "Y", 
				"NAME" => $model_name, 
				"CODE" => $code, 
			];

			$update_element = new CIBlockElement;
			$update_result = $update_element->Update($model_existed['ID'], $model_update_payload);
		}
		else
		{
			$model_element = new CIBlockElement;
			$model_payload = [ 
				"IBLOCK_SECTION_ID" => false, 
				"IBLOCK_ID" => IBLOCK_ID_MODELS, 
				"PROPERTY_VALUES" => [ 
					"BRAND_UID" => $brand_uid, 
					"UID" => $model_uid, 
				], 
				"NAME" => $model_name, 
				"CODE" => $code, 
				"ACTIVE" => "Y", 
			];

			if($new_model_id = $model_element->Add($model_payload))
			{
				$bitrix_models[$model_uid] = $new_model_id;
				//echo "new_model_id: ".$new_model_id;
			}
			else
			{
				echo "model error: ".$model_element->LAST_ERROR;
			}
		}

		foreach($model['modifications'] AS $modification)
		{
			print "MOD ".$modification."\n";
			$modification_existed = null;

			$NAME = $brand['name']." ".$model_name." ".$modification;
			$CODE = CUtil::translit( $NAME, "ru", [ "max_len" => 255, "change_case" => "L", "replace_space" => "-", "replace_other" => "-", ] );

			//"ID"
			$modification_search_res = CIBlockElement::GetList( [], [ "IBLOCK_ID" => 10, "CODE" => $CODE ], false, ["nPageSize" => 1], [] );
			while($modification_search_ob = $modification_search_res->GetNextElement())
			{
				$m_res = $modification_search_ob->GetFields();
				if(isset($m_res['ID']))
				{
					$modification_existed = $m_res['ID'];
					$bitrix_modifications[md5($brand_uid.$model_uid.$modification)] = $m_res['ID'];
					array_push($bitrix_modifications_codes, $CODE);
				}
			}

			if($modification_existed === null)
			{
				$modification_element = new CIBlockElement;
				$modification_payload = [ "IBLOCK_SECTION_ID" => false, "IBLOCK_ID" => 10, "PROPERTY_VALUES" => [ "MODEL_UID" => $model_uid, "TITLE" => $modification ], "NAME" => $NAME, "CODE" => $CODE, "ACTIVE" => "Y", ];

				if($new_modification_id = $modification_element->Add($modification_payload))
				{
					$bitrix_modifications[md5($brand_uid.$model_uid.$modification)] = $new_modification_id;
					array_push($bitrix_modifications_codes, $CODE);
				}
				else
				{
					echo "modification error: ".$modification_element->LAST_ERROR;
				}
			}
		}
	}

	return [
		"bitrix_models" => $bitrix_models, 
		"bitrix_modifications" => $bitrix_modifications, 
		"bitrix_modifications_codes" => $bitrix_modifications_codes
	];
}

print "bitrix brands\n\n";
print_r($bitrix_brands);

print "bitrix models\n\n";
print_r($bitrix_models);

print "bitrix modifications\n\n";
print_r($bitrix_modifications);

//кешируем новые UID ТС
$json_new_cars = [];
foreach($json AS $car)
{
	array_push($json_new_cars, $car['uid']);
}

$car_codes = [];

$c = 0;
foreach($json AS $car)
{
	if(!in_array($car['uid'], $bitrix_existed_cars))
	{
		$c++;
	}
	
	//обновляем список ТС в битриксе
	$modification_content = file_get_contents(API_HOST."/site/Vehicle/GetCatalog?id=". $car['uid'] ."", false, stream_context_create($arrContextOptions));
	$modification_json = json_decode($modification_content, true);

	$name = "".$car['brand']['name']." ".$car['model']['name']." ".$car['modification']."";
	$replace_name = "".$car['brand']['name']." ".$car['model']['name']." ".$car['modification']."";
	$code = CUtil::translit( str_replace(["+"], ["-plus-"], $replace_name), "ru", [ "max_len" => 255, "change_case" => "L", "replace_space" => "-", "replace_other" => "-" ] );

	print "new car --- uid ".$car['uid']." | code ".$code."\n";

	$PROPERTY_VALUES = [
		"UID" => $car['uid'], 
		"BRAND" => $bitrix_brands[ $car['brand']['id'] ], 
		"MODEL" => $bitrix_models[ $car['model']['id'] ], 
		"MODIFICATION" => $bitrix_modifications[ md5($car['brand']['id'].$car['model']['id'].$car['modification']) ], 
		"MODIFICATION_YEAR" => $car['modificationYear'], 
		"GEAR" => $car['gear'], 
		"DRIVE" => $car['drive'], 
		"BODY" => $car['body'], 
		"ENGINE_POWER" => $car['engine']['power'], 
		"ENGINE_VOLUME" => $car['engine']['volume'], 
		"ENGINE_FUEL" => $car['engine']['fuel'], 
		"PRICE" => $car['price'], 
		"IMAGE_URL" => $car['url'], 
		"COMPLECTATION_BODY" => json_encode($modification_json['body']), 
		"COMPLECTATION_INTERIOR" => json_encode($modification_json['interior']), 
		"COMPLECTATION_SECURITY" => json_encode($modification_json['security']), 
		"COMPLECTATION_GUARANTEE" => json_encode($modification_json['guarantee']), 
		"COMPLECTATION_TECHNICAL_DESCRIPTION" => json_encode($modification_json['technicalDescription']), 
		"COMPLECTATION_FUNCTIONAL_EQUIPMENT" => json_encode($modification_json['functionalEquipment']), 
		"COMPLECTATION_TOTAL_INFORMATION" => json_encode($modification_json['totalInformation']), 
		"LEASING_PROGRAMS" => $car['programms'], 
	];

	//"ID"
	$car_existed = null;
	$car_search_res = CIBlockElement::GetList( [], [ "IBLOCK_ID" => IBLOCK_ID_CATALOG_CARS_NEW, "PROPERTY_UID" => $car['uid'] ], false, ["nPageSize" => 1], [] );

	while($car_search_ob = $car_search_res->GetNextElement())
	{
		$car_existed = $car_search_ob->GetFields();
		//print "CAR FOUND\n\n";
		//print_r($car_existed);
	}

	$car_update_payload = [ "IBLOCK_SECTION" => false, "NAME" => $name, "CODE" => $code, "ACTIVE" => "Y", ];
	if($car_existed !== null)
	{
		$car_update_element = new CIBlockElement;
		$car_update_result = $car_update_element->Update($car_existed['ID'], $car_update_payload);

		CIBlockElement::SetPropertyValuesEx($car_existed['ID'], IBLOCK_ID_CATALOG_CARS_NEW, $PROPERTY_VALUES, []);
	}
	else
	{
		//if($c === 0)
		//{
			$car_element = new CIBlockElement;
			$car_payload = [ "IBLOCK_SECTION_ID" => false, "IBLOCK_ID" => 1, "NAME" => $name, "CODE" => $code, "PROPERTY_VALUES" => $PROPERTY_VALUES, "ACTIVE" => "Y", ];

			if($new_car_id = $car_element->Add($car_payload))
			{
				//$bitrix_brands[$brand_uid] = $new_brand_id;
				//echo "new car id: ".$new_car_id;
			}
			else
			{
				print  "CAR ERROR: ".$car_element->LAST_ERROR." | ".$car['uid']." | ".$code."\n";	

				/*
				if($car_element->LAST_ERROR === "Элемент с таким символьным кодом уже существует.<br>")
				{
					print "replace: ".$car_existed['UID']." -> ".$car['uid']." | ".$code."\n";	

					$car_update_element = new CIBlockElement;
					$car_update_result = $car_update_element->Update($car_existed['ID'], $car_update_payload);			

					CIBlockElement::SetPropertyValuesEx($car_existed['ID'], IBLOCK_ID_CATALOG_CARS_NEW, $PROPERTY_VALUES, []);
				}
				*/
			}
		//}
	}
}

//print "car_codes?\n";
/*
foreach($car_codes AS $cc => $count)
{
	if($count > 1)
	{
		print "cc ".$cc." - ".$count."\n";
	}
}
*/

print "\n\nновых ТС: ".$c."\n\n";

//print "bitrix_existed_cars = ".count($bitrix_existed_cars)."\n";
//print "json_new_cars = ".count($json_new_cars)."\n";

$h = 0;
foreach($bitrix_existed_cars AS $existed_car_uid)
{
	if(!in_array($existed_car_uid, $json_new_cars))
	{
		$h++;
		set_car_activity($existed_car_uid, "N");
	}
}

print "\n\nснято с публикации ТС: ".$h."\n\n";

print "bitrix_existed_brands\n";
$c = 0;
foreach($bitrix_existed_brands AS $k => $b)
{
	if($c < 10)
	{
		//print $k." => ".$b."\n";
		$c++;
	}
}

print "bitrix_brands\n";
$c = 0;
foreach($bitrix_brands AS $k => $b)
{
	if($c < 10)
	{
		//print $k." => ".$b."\n";
		$c++;
	}
}

$md = 0;
foreach($bitrix_existed_modifications AS $existed_modifications_code)
{
	if(!in_array($existed_modifications_code, $bitrix_modifications_codes))
	{
		set_modification_activity($existed_modifications_code, "N");
		$md++;
	}
}

//print "API_MODELS:\n";
//print_r($api_models);

print "\n\nснято с публикации модификаций: ".$md."\n";

$m = 0;
foreach($bitrix_existed_models AS $existed_model_uid)
{
	if($bitrix_models[$existed_model_uid] !== null)
	{}
	else
	{
		if(!in_array($existed_model_uid, $api_models))
		{
			set_model_activity($existed_model_uid, "N");
			$m++;
		}
	}
}

//print "API_BRANDS:\n";
//print_r($api_brands);

print "\n\nснято с публикации моделей: ".$m."\n";

$b = 0;
foreach($bitrix_existed_brands AS $existed_brand_uid)
{
	if($bitrix_brands[$existed_brand_uid] !== null)
	{}
	else
	{
		if(!in_array($existed_brand_uid, $api_brands))
		{
			set_brand_activity($existed_brand_uid, "N");
			$b++;
		}
	}
}

print "\n\nснято с публикации марок: ".$b."\n";

die();

?>