<?php
/**
 * Offline events
 *
 * @mail support@s-production.online
 * @link s-production.online
 */
//TODO
namespace SProduction\Datasync;

use Bitrix\Main,
    Bitrix\Main\DB\Exception,
    Bitrix\Main\Config\Option;

class PortalOfflineEvents
{
    const MODULE_ID = 'sproduction.datasync';

	public static function eventsBind() {
		try {
			Rest::execute('event.bind', [
				'event'      => 'ONCRMPRODUCTUPDATE',
				'event_type' => 'offline',
			]);
		} catch (\Exception $e) {}
	}

	public static function eventsUnbind() {
		try {
			Rest::execute('event.unbind', [
				'event'      => 'ONCRMPRODUCTUPDATE',
				'event_type' => 'offline',
			]);
		} catch (\Exception $e) {}
	}

    public static function getChangedItems($type='update') {
    	$list = [];
	    $res = Rest::execute('event.offline.get', []);
	    foreach ($res['events'] as $item) {
		    if ($type == 'update' && $item['EVENT_NAME'] == 'ONCRMPRODUCTUPDATE') {
		    	$item_id = (int)$item['EVENT_DATA']['FIELDS']['ID'];
		    	if ($item_id) {
		    		$list[] = $item_id;
			    }
		    }
	    }
	    return $list;
    }

    public static function processEvents($other_deals_ids=[]) {
	    $items_ids = self::getChangedItems();
	    $items_ids = array_unique(array_merge($items_ids, $other_deals_ids));
	    FileLog::put('(processEvents) changed items: ' . print_r($items_ids, true));
	    // Wait for changes fix
	    if (Settings::get('products_last_change_ts') > time() - 2) {
		    FileLog::put('(processEvents) wait 2 sec');
	    	sleep(2);
	    }
		// TODO: Product data

//	    $items = PortalData::getDeal($items_ids);
//	    foreach ($items as $item) {
//		    $order_id = (int) $item[Settings::getOrderIDField()];
//		    FileLog::put('(processEvents) deal ' . print_r($item, true));
//		    if ( ! $order_id) {
//			    continue;
//		    }
//		    // Change fields in the order
//		    $opt_direction = \SProduction\Datasync\Settings::get("direction");
//		    if ( ! $opt_direction || $opt_direction == 'full' || $opt_direction == 'ctos') {
//			    SyncStore::runSync($item);
//		    }
//	    }
	}
}