0) { $historyFilter['sinceId'] = $historyStart; } while (true) { try { $customerHistory = $api->customersHistory($historyFilter); } catch (\RetailCrm\Exception\CurlException $e) { RCrmActions::eventLog( 'RetailCrmHistory::customerHistory', 'RetailCrm\RestApi::customersHistory::CurlException', $e->getCode() . ': ' . $e->getMessage() ); return false; } catch (InvalidArgumentException $e) { RCrmActions::eventLog( 'RetailCrmHistory::customerHistory', 'RetailCrm\RestApi::customersHistory::InvalidArgumentException', $e->getCode() . ': ' . $e->getMessage() ); return false; } $customerH = isset($customerHistory['history']) ? $customerHistory['history'] : array(); $log = new Logger(); $log->write($customerH, 'customerHistory'); if(count($customerH) == 0){ return true; } $customers = self::assemblyCustomer($customerH); $GLOBALS['RETAIL_CRM_HISTORY'] = true; $newUser = new CUser; foreach ($customers as $customer) { if (function_exists('retailCrmBeforeCustomerSave')) { $newResCustomer = retailCrmBeforeCustomerSave($customer); if (is_array($newResCustomer) && !empty($newResCustomer)) { $customer = $newResCustomer; } } if (isset($customer['deleted'])) { continue; } if (!isset($customer['externalId'])) { if (!isset($customer['id'])) { continue; } $registerNewUser = true; if (!isset($customer['email']) || $customer['email'] == '') { $login = $customer['email'] = uniqid('user_' . time()) . '@crm.com'; } else { $dbUser = CUser::GetList(($by = 'ID'), ($sort = 'ASC'), array('=EMAIL' => $customer['email'])); switch ($dbUser->SelectedRowsCount()) { case 0: $login = $customer['email']; break; case 1: $arUser = $dbUser->Fetch(); $registeredUserID = $arUser['ID']; $registerNewUser = false; break; default: $login = uniqid('user_' . time()) . '@crm.com'; break; } } if ($registerNewUser === true) { $userPassword = uniqid(); $arFields = array( "EMAIL" => $customer['email'], "LOGIN" => $login, "ACTIVE" => "Y", "PASSWORD" => $userPassword, "CONFIRM_PASSWORD" => $userPassword ); $registeredUserID = $newUser->Add($arFields); if ($registeredUserID === false) { RCrmActions::eventLog('RetailCrmHistory::orderHistory', 'CUser::Register', 'Error register user'); continue; } try { $api->customersFixExternalIds(array(array('id' => $customer['id'], 'externalId' => $registeredUserID))); } catch (\RetailCrm\Exception\CurlException $e) { RCrmActions::eventLog( 'RetailCrmHistory::orderHistory', 'RetailCrm\RestApi::customerFixExternalIds::CurlException', $e->getCode() . ': ' . $e->getMessage() ); continue; } catch (InvalidArgumentException $e) { RCrmActions::eventLog( 'RetailCrmHistory::orderHistory', 'RetailCrm\RestApi::customerFixExternalIds::InvalidArgumentException', $e->getCode() . ': ' . $e->getMessage() ); continue; } } $customer['externalId'] = $registeredUserID; } if (isset($customer['externalId'])) { $arUser = array(); if (array_key_exists('firstName', $customer)) { $arUser["NAME"] = $customer['firstName'] ? RCrmActions::fromJSON($customer['firstName']) : ''; } if (array_key_exists('lastName', $customer)) { $arUser["LAST_NAME"] = $customer['lastName'] ? RCrmActions::fromJSON($customer['lastName']) : ''; } if (array_key_exists('patronymic', $customer)) { $arUser["SECOND_NAME"] = $customer['patronymic'] ? RCrmActions::fromJSON($customer['patronymic']) : ''; } if (array_key_exists('email', $customer)) { $arUser["EMAIL"] = $customer['email'] ? RCrmActions::fromJSON($customer['email']) : ''; } if (isset($customer['phones'])) { $user = CUser::GetList(($by="ID"), ($order="desc"), array('ID' => $customer['externalId']), array('FIELDS' => array('PERSONAL_PHONE', 'PERSONAL_MOBILE')))->fetch(); foreach ($customer['phones'] as $phone) { if (isset($phone['old_number']) && in_array($phone['old_number'], $user)) { $key = array_search($phone['old_number'], $user); if (isset($phone['number'])) { $arUser[$key] = $phone['number']; $user[$key] = $phone['number']; } else { $arUser[$key] = ''; $user[$key] = ''; } } if (isset($phone['number'])) { if ((!isset($user['PERSONAL_PHONE']) || strlen($user['PERSONAL_PHONE']) == 0) && $user['PERSONAL_MOBILE'] != $phone['number']) { $arUser['PERSONAL_PHONE'] = $phone['number']; $user['PERSONAL_PHONE'] = $phone['number']; continue; } if ((!isset($user['PERSONAL_MOBILE']) || strlen($user['PERSONAL_MOBILE']) == 0) && $user['PERSONAL_PHONE'] != $phone['number']) { $arUser['PERSONAL_MOBILE'] = $phone['number']; $user['PERSONAL_MOBILE'] = $phone['number']; continue; } } } } $u = $newUser->Update($customer['externalId'], $arUser); if (!$u) { RCrmActions::eventLog('RetailCrmHistory::customerHistory', 'Error update user', $newUser->LAST_ERROR); } if (function_exists('retailCrmAfterCustomerSave')) { retailCrmAfterCustomerSave($customer); } } } $GLOBALS['RETAIL_CRM_HISTORY'] = false; //запоминаем номер последнего изменения $end = array_pop($customerH); COption::SetOptionString(self::$MODULE_ID, self::$CRM_CUSTOMER_HISTORY, $end['id']); if ($customerHistory['pagination']['totalPageCount'] == 1) { return true; } //новый фильтр для истории $historyFilter['sinceId'] = $end['id']; } } public static function orderHistory() { global $USER; if (is_object($USER) == false) { $USER = new RetailUser; } if (!CModule::IncludeModule("iblock")) { RCrmActions::eventLog('RetailCrmHistory::orderHistory', 'iblock', 'module not found'); return false; } if (!CModule::IncludeModule("sale")) { RCrmActions::eventLog('RetailCrmHistory::orderHistory', 'sale', 'module not found'); return false; } if (!CModule::IncludeModule("catalog")) { RCrmActions::eventLog('RetailCrmHistory::orderHistory', 'catalog', 'module not found'); return false; } $api_host = COption::GetOptionString(self::$MODULE_ID, self::$CRM_API_HOST_OPTION, 0); $api_key = COption::GetOptionString(self::$MODULE_ID, self::$CRM_API_KEY_OPTION, 0); $optionsOrderTypes = array_flip(unserialize(COption::GetOptionString(self::$MODULE_ID, self::$CRM_ORDER_TYPES_ARR, 0))); $optionsDelivTypes = array_flip(unserialize(COption::GetOptionString(self::$MODULE_ID, self::$CRM_DELIVERY_TYPES_ARR, 0))); $optionsPayTypes = array_flip(unserialize(COption::GetOptionString(self::$MODULE_ID, self::$CRM_PAYMENT_TYPES, 0))); $optionsPayStatuses = array_flip(unserialize(COption::GetOptionString(self::$MODULE_ID, self::$CRM_PAYMENT_STATUSES, 0))); // --statuses $optionsPayment = array_flip(unserialize(COption::GetOptionString(self::$MODULE_ID, self::$CRM_PAYMENT, 0))); $optionsOrderProps = unserialize(COption::GetOptionString(self::$MODULE_ID, self::$CRM_ORDER_PROPS, 0)); $optionsLegalDetails = unserialize(COption::GetOptionString(self::$MODULE_ID, self::$CRM_LEGAL_DETAILS, 0)); $optionsContragentType = unserialize(COption::GetOptionString(self::$MODULE_ID, self::$CRM_CONTRAGENT_TYPE, 0)); $optionsSitesList = unserialize(COption::GetOptionString(self::$MODULE_ID, self::$CRM_SITES_LIST, 0)); $optionsCustomFields = unserialize(COption::GetOptionString(self::$MODULE_ID, self::$CRM_CUSTOM_FIELDS, 0)); $optionsOrderNumbers = COption::GetOptionString(self::$MODULE_ID, self::$CRM_ORDER_NUMBERS, 0); $optionsCanselOrder = unserialize(COption::GetOptionString(self::$MODULE_ID, self::$CRM_CANSEL_ORDER, 0)); $api = new RetailCrm\ApiClient($api_host, $api_key); $historyFilter = array(); $historyStart = COption::GetOptionString(self::$MODULE_ID, self::$CRM_ORDER_HISTORY); if ($historyStart && $historyStart > 0) { $historyFilter['sinceId'] = $historyStart; } while (true) { try { $orderHistory = $api->ordersHistory($historyFilter); } catch (\RetailCrm\Exception\CurlException $e) { RCrmActions::eventLog( 'RetailCrmHistory::orderHistory', 'RetailCrm\RestApi::ordersHistory::CurlException', $e->getCode() . ': ' . $e->getMessage() ); return false; } catch (InvalidArgumentException $e) { RCrmActions::eventLog( 'RetailCrmHistory::orderHistory', 'RetailCrm\RestApi::ordersHistory::InvalidArgumentException', $e->getCode() . ': ' . $e->getMessage() ); return false; } $orderH = isset($orderHistory['history']) ? $orderHistory['history'] : array(); $log = new Logger(); $log->write($orderH, 'orderHistory'); if (count($orderH) == 0) { return true; } $orders = self::assemblyOrder($orderH); $GLOBALS['RETAIL_CRM_HISTORY'] = true; //обработка заказа foreach ($orders as $order) { if (function_exists('retailCrmBeforeOrderSave')) { $newResOrder = retailCrmBeforeOrderSave($order); if (is_array($newResOrder) && !empty($newResOrder)) { $order = $newResOrder; } } $log->write($order, 'assemblyOrderHistory'); if ($order['deleted']) { continue; } if (!isset($order['externalId'])) { if (!isset($order['customer']['externalId'])) { if (!isset($order['customer']['id'])) { continue; } $registerNewUser = true; if (!isset($order['customer']['email']) || $order['customer']['email'] == '') { $login = $order['customer']['email'] = uniqid('user_' . time()) . '@crm.com'; } else { $dbUser = CUser::GetList(($by = 'ID'), ($sort = 'ASC'), array('=EMAIL' => $order['email'])); switch ($dbUser->SelectedRowsCount()) { case 0: $login = $order['customer']['email']; break; case 1: $arUser = $dbUser->Fetch(); $registeredUserID = $arUser['ID']; $registerNewUser = false; break; default: $login = uniqid('user_' . time()) . '@crm.com'; break; } } if ($registerNewUser === true) { $userPassword = uniqid(); $newUser = new CUser; $arFields = array( "NAME" => RCrmActions::fromJSON($order['customer']['firstName']), "LAST_NAME" => RCrmActions::fromJSON($order['customer']['lastName']), "SECOND_NAME" => RCrmActions::fromJSON($order['customer']['patronymic']), "EMAIL" => $order['customer']['email'], "LOGIN" => $login, "ACTIVE" => "Y", "PASSWORD" => $userPassword, "CONFIRM_PASSWORD" => $userPassword ); if ($order['customer']['phones'][0]) { $arFields['PERSONAL_PHONE'] = $order['customer']['phones'][0]; } if ($order['customer']['phones'][1]) { $arFields['PERSONAL_MOBILE'] = $order['customer']['phones'][1]; } $registeredUserID = $newUser->Add($arFields); if ($registeredUserID === false) { RCrmActions::eventLog('RetailCrmHistory::orderHistory', 'CUser::Register', 'Error register user'); continue; } try { $api->customersFixExternalIds(array(array('id' => $order['customer']['id'], 'externalId' => $registeredUserID))); } catch (\RetailCrm\Exception\CurlException $e) { RCrmActions::eventLog( 'RetailCrmHistory::orderHistory', 'RetailCrm\RestApi::customerFixExternalIds::CurlException', $e->getCode() . ': ' . $e->getMessage() ); continue; } catch (InvalidArgumentException $e) { RCrmActions::eventLog( 'RetailCrmHistory::orderHistory', 'RetailCrm\RestApi::customerFixExternalIds::InvalidArgumentException', $e->getCode() . ': ' . $e->getMessage() ); continue; } } $order['customer']['externalId'] = $registeredUserID; } if ($optionsSitesList) { $site = array_search($order['site'], $optionsSitesList); } else { $site = CSite::GetDefSite(); } $newOrder = Bitrix\Sale\Order::create($site, $order['customer']['externalId']); $newOrder = $newOrder->save(); $externalId = $newOrder->getId(); if (isset($externalId)) { try { $api->ordersFixExternalIds(array(array('id' => $order['id'], 'externalId' => $externalId))); } catch (\RetailCrm\Exception\CurlException $e) { RCrmActions::eventLog( 'RetailCrmHistory::orderHistory', 'RetailCrm\RestApi::orderFixExternalIds::CurlException', $e->getCode() . ': ' . $e->getMessage() ); continue; } catch (InvalidArgumentException $e) { RCrmActions::eventLog( 'RetailCrmHistory::orderHistory', 'RetailCrm\RestApi::orderFixExternalIds::InvalidArgumentException', $e->getCode() . ': ' . $e->getMessage() ); continue; } } else { RCrmActions::eventLog('RetailCrmHistory::orderHistory', 'Bitrix\Sale\Order::create', 'Error order create'); } $order['externalId'] = $externalId; } if (isset($order['externalId']) && $order['externalId']) { $itemUpdate = false; $newOrder = Bitrix\Sale\Order::load($order['externalId']); if (!$newOrder instanceof \Bitrix\Sale\Order) { RCrmActions::eventLog('RetailCrmHistory::orderHistory', 'Bitrix\Sale\Order::load', 'Error order load id=' . $order['externalId']); continue; } if ($optionsSitesList) { $site = array_search($order['site'], $optionsSitesList); } else { $site = CSite::GetDefSite(); } if ($optionsOrderNumbers == 'Y' && isset($order['number'])) { $newOrder->setField('ACCOUNT_NUMBER', $order['number']); } $personType = $newOrder->getField('PERSON_TYPE_ID'); if ($optionsOrderTypes[$order['orderType']]) { if ($personType != $optionsOrderTypes[$order['orderType']] && $personType != 0) { $propsRemove = true; } $personType = $optionsOrderTypes[$order['orderType']]; $newOrder->setField('PERSON_TYPE_ID', $personType); } elseif ($personType == 0) { RCrmActions::eventLog('RetailCrmHistory::orderHistory', 'orderType not found', 'PERSON_TYPE_ID = 0'); } //status if ($optionsPayStatuses[$order['status']]) { $newOrder->setField('STATUS_ID', $optionsPayStatuses[$order['status']]); if (in_array($optionsPayStatuses[$order['status']], $optionsCanselOrder)) { $newOrder->setFieldNoDemand('CANCELED', 'Y'); } else { $newOrder->setFieldNoDemand('CANCELED', 'N'); } } if (array_key_exists('statusComment', $order)) { self::setProp($newOrder, RCrmActions::fromJSON($order['statusComment']), 'REASON_CANCELED'); } $propertyCollection = $newOrder->getPropertyCollection(); $propertyCollectionArr = $propertyCollection->getArray(); $nProps = array(); foreach ($propertyCollectionArr['properties'] as $orderProp) { if ($orderProp['ID'][0] == 'n') { $orderProp['ID'] = substr($orderProp['ID'], 1); $orderProp['ID'] = $propertyCollection->getItemById($orderProp['ID'])->getField('ORDER_PROPS_ID'); } $nProps[] = $orderProp; } $propertyCollectionArr['properties'] = $nProps; if ($propsRemove) {//удаляем старые свойства foreach ($propertyCollectionArr['properties'] as $orderProp) { $somePropValue = $propertyCollection->getItemByOrderPropertyId($orderProp['ID']); self::setProp($somePropValue); } try { $orderCrm = $api->ordersGet($order['id'], 'id'); } catch (\RetailCrm\Exception\CurlException $e) { RCrmActions::eventLog( 'RetailCrmHistory::orderHistory', 'RetailCrm\RestApi::ordersGet0::CurlException', $e->getCode() . ': ' . $e->getMessage() ); } $orderDump = $order; $order = $orderCrm['order']; } $propsKey = array(); foreach ($propertyCollectionArr['properties'] as $prop) { $propsKey[$prop['CODE']]['ID'] = $prop['ID']; $propsKey[$prop['CODE']]['TYPE'] = $prop['TYPE']; } //fio if ($order['firstName'] || $order['lastName'] || $order['patronymic']) { $fio = ''; foreach ($propertyCollectionArr['properties'] as $prop) { if (in_array($optionsOrderProps[$personType]['fio'], $prop)) { $getFio = $newOrder->getPropertyCollection()->getItemByOrderPropertyId($prop['ID']); if (method_exists($getFio, 'getValue')) { $fio = $getFio->getValue(); } } } $fio = RCrmActions::explodeFIO($fio); $newFio = array(); if ($fio) { $newFio[] = isset($order['lastName']) ? RCrmActions::fromJSON($order['lastName']) : (isset($fio['lastName']) ? $fio['lastName'] : ''); $newFio[] = isset($order['firstName']) ? RCrmActions::fromJSON($order['firstName']) : (isset($fio['firstName']) ? $fio['firstName'] : ''); $newFio[] = isset($order['patronymic']) ? RCrmActions::fromJSON($order['patronymic']) : (isset($fio['patronymic']) ? $fio['patronymic'] : ''); $order['fio'] = trim(implode(' ', $newFio)); } else { $newFio[] = isset($order['lastName']) ? RCrmActions::fromJSON($order['lastName']) : ''; $newFio[] = isset($order['firstName']) ? RCrmActions::fromJSON($order['firstName']) : ''; $newFio[] = isset($order['patronymic']) ? RCrmActions::fromJSON($order['patronymic']) : ''; $order['fio'] = trim(implode(' ', $newFio)); } } //optionsOrderProps if ($optionsOrderProps[$personType]) { foreach ($optionsOrderProps[$personType] as $key => $orderProp) { if (array_key_exists($key, $order)) { $somePropValue = $propertyCollection->getItemByOrderPropertyId($propsKey[$orderProp]['ID']); self::setProp($somePropValue, RCrmActions::fromJSON($order[$key])); } elseif (array_key_exists($key, $order['delivery']['address'])) { if ($propsKey[$key]['TYPE'] == 'LOCATION') { $parameters['filter']['NAME'] = RCrmActions::fromJSON($order['delivery']['address'][$key]); $parameters['filter']['LANGUAGE_ID'] = 'ru'; $location = \Bitrix\Sale\Location\LocationTable::getListFast($parameters)->fetch(); $somePropValue = $propertyCollection->getItemByOrderPropertyId($propsKey[$orderProp]['ID']); self::setProp($somePropValue, $location['CODE']); } else { $somePropValue = $propertyCollection->getItemByOrderPropertyId($propsKey[$orderProp]['ID']); self::setProp($somePropValue, RCrmActions::fromJSON($order['delivery']['address'][$key])); } } } } //optionsLegalDetails if ($optionsLegalDetails[$personType]) { foreach ($optionsLegalDetails[$personType] as $key => $orderProp) { if (array_key_exists($key, $order)) { $somePropValue = $propertyCollection->getItemByOrderPropertyId($propsKey[$orderProp]['ID']); self::setProp($somePropValue, $order[$key]); } } } if ($propsRemove) { $order = $orderDump; } //paymentStatus if ($optionsPayment[$order['paymentStatus']]) { $newOrder->setFieldNoDemand('PAYED', $optionsPayment[$order['paymentStatus']]); } //comments if (array_key_exists('customerComment', $order)) { self::setProp($newOrder, RCrmActions::fromJSON($order['customerComment']), 'USER_DESCRIPTION'); } if (array_key_exists('managerComment', $order)) { self::setProp($newOrder, RCrmActions::fromJSON($order['managerComment']), 'COMMENTS'); } //items $basket = $newOrder->getBasket(); if (isset($order['items'])) { $itemUpdate = true; foreach ($order['items'] as $product) { $item = self::getExistsItem($basket, 'catalog', $product['offer']['externalId']); if (!$item) { if($product['delete']){ continue; } $item = $basket->createItem('catalog', $product['offer']['externalId']); if ($item instanceof \Bitrix\Sale\BasketItem) { $elem = self::getInfoElement($product['offer']['externalId']); $item->setFields(array( 'CURRENCY' => \Bitrix\Currency\CurrencyManager::getBaseCurrency(), 'LID' => $site, 'BASE_PRICE' => $product['initialPrice'], 'NAME' => $product['name'] ? RCrmActions::fromJSON($product['name']) : $elem['NAME'], 'DETAIL_PAGE_URL' => $elem['URL'] )); } else { RCrmActions::eventLog('RetailCrmHistory::orderHistory', 'createItem', 'Error item id=' . $product['offer']['externalId'] . ' add in order id=' . $order['externalId']); continue; } } if ($product['delete']) { $item->delete(); continue; } if ($product['quantity']) { $item->setFieldNoDemand('QUANTITY', $product['quantity']); } if (array_key_exists('discount', $product) || array_key_exists('discountPercent', $product)) { if (!isset($orderCrm)) { try { $orderCrm = $api->ordersGet($order['id'], 'id'); } catch (\RetailCrm\Exception\CurlException $e) { RCrmActions::eventLog( 'RetailCrmHistory::orderHistory', 'RetailCrm\RestApi::ordersGet::CurlException', $e->getCode() . ': ' . $e->getMessage() ); } } foreach ($orderCrm['order']['items'] as $itemCrm) { if ($itemCrm['offer']['externalId'] == $product['offer']['externalId']) { $itemCost = $itemCrm['initialPrice'] - $itemCrm['discount'] - round(($itemCrm['initialPrice'] / 100 * $itemCrm['discountPercent']), 2); break; } } if (isset($itemCost) && $itemCost > 0) { $item->setField('CUSTOM_PRICE', 'Y'); $item->setField('PRICE', $itemCost); $item->setField('DISCOUNT_NAME', ''); $item->setField('DISCOUNT_VALUE', ''); } } $basket->save(); } } $orderSumm = 0; foreach ($basket as $item) { $orderSumm += $item->getFinalPrice(); } if (array_key_exists('cost', $order['delivery'])) { $deliverySumm = $order['delivery']['cost']; } else { $deliverySumm = $newOrder->getDeliveryPrice(); } $orderSumm += $deliverySumm; $newOrder->setField('PRICE', $orderSumm); $order['summ'] = $orderSumm; $newOrder->save(); //payment if (array_key_exists('paymentType', $order)) { self::paySystemUpdate($order, $optionsPayTypes); } //delivery if (array_key_exists('code', $order['delivery'])) { $itemUpdate = true; //если пусто, удаляем, если нет, update или add if (!isset($orderCrm)) { try { $orderCrm = $api->ordersGet($order['id'], 'id'); } catch (\RetailCrm\Exception\CurlException $e) { RCrmActions::eventLog( 'RetailCrmHistory::orderHistory', 'RetailCrm\RestApi::ordersGet2::CurlException', $e->getCode() . ': ' . $e->getMessage() ); } } self::shipmentUpdate($orderCrm['order'], $optionsDelivTypes); } if (isset($orderCrm)) { unset($orderCrm); } //delivery cost if (array_key_exists('cost', $order['delivery'])) { $shipment = Bitrix\Sale\Internals\ShipmentTable::getList(array( 'filter' => array('ORDER_ID' => $order['externalId'], 'SYSTEM' => 'N'), 'order' => array('ID') ))->fetch(); if ($shipment) { Bitrix\Sale\Internals\ShipmentTable::update($shipment['ID'], array('BASE_PRICE_DELIVERY' => $order['delivery']['cost'], 'PRICE_DELIVERY' => $order['delivery']['cost'], 'CUSTOM_PRICE_DELIVERY' => 'Y')); } Bitrix\Sale\OrderTable::update($order['externalId'], array('PRICE_DELIVERY' => $order['delivery']['cost']));//не пишется в историю, надо добавить } Bitrix\Sale\OrderTable::update($order['externalId'], array('MARKED' => 'N', 'EMP_MARKED_ID' => '', 'REASON_MARKED' => '')); if ($itemUpdate) { self::updateShipmentItem($order['externalId']); } if (function_exists('retailCrmAfterOrderSave')) { retailCrmAfterOrderSave($order); } } } $GLOBALS['RETAIL_CRM_HISTORY'] = false; //запоминаем номер последнего изменения $end = array_pop($orderH); COption::SetOptionString(self::$MODULE_ID, self::$CRM_ORDER_HISTORY, $end['id']); if ($orderHistory['pagination']['totalPageCount'] == 1) { return true; } //новый фильтр для истории $historyFilter['sinceId'] = $end['id']; } } public static function assemblyCustomer($customerHistory) { $server = \Bitrix\Main\Context::getCurrent()->getServer()->getDocumentRoot(); $fields = array(); if (file_exists($server . '/bitrix/modules/intaro.retailcrm/classes/general/config/objects.xml')) { $objects = simplexml_load_file($server . '/bitrix/modules/intaro.retailcrm/classes/general/config/objects.xml'); foreach ($objects->fields->field as $object) { $fields[(string)$object["group"]][(string)$object["id"]] = (string)$object; } } $customers = array(); foreach ($customerHistory as $change) { $change['customer'] = self::removeEmpty($change['customer']); if ($customers[$change['customer']['id']]) { $customers[$change['customer']['id']] = array_merge($customers[$change['customer']['id']], $change['customer']); } else { $customers[$change['customer']['id']] = $change['customer']; } if ($change['customer']['contragent']['contragentType']) { $change['customer']['contragentType'] = self::newValue($change['customer']['contragent']['contragentType']); unset($change['customer']['contragent']); } if ($fields['customer'][$change['field']] == 'phones') { $key = count($customers[$change['customer']['id']]['phones']); if (isset($change['oldValue'])) { $customers[$change['customer']['id']]['phones'][$key]['old_number'] = $change['oldValue']; } if (isset($change['newValue'])) { $customers[$change['customer']['id']]['phones'][$key]['number'] = $change['newValue']; } } else { if ($fields['customerAddress'][$change['field']]) { $customers[$change['customer']['id']]['address'][$fields['customerAddress'][$change['field']]] = $change['newValue']; } elseif ($fields['customerContragent'][$change['field']]) { $customers[$change['customer']['id']]['contragent'][$fields['customerContragent'][$change['field']]] = $change['newValue']; } elseif ($fields['customer'][$change['field']]) { $customers[$change['customer']['id']][$fields['customer'][$change['field']]] = self::newValue($change['newValue']); } if (isset($change['created'])) { $customers[$change['customer']['id']]['create'] = 1; } if (isset($change['deleted'])) { $customers[$change['customer']['id']]['deleted'] = 1; } } } return $customers; } public static function assemblyOrder($orderHistory) { $server = \Bitrix\Main\Context::getCurrent()->getServer()->getDocumentRoot(); if (file_exists($server . '/bitrix/modules/intaro.retailcrm/classes/general/config/objects.xml')) { $objects = simplexml_load_file($server . '/bitrix/modules/intaro.retailcrm/classes/general/config/objects.xml'); foreach ($objects->fields->field as $object) { $fields[(string)$object["group"]][(string)$object["id"]] = (string)$object; } } $orders = array(); foreach ($orderHistory as $change) { $change['order'] = self::removeEmpty($change['order']); if ($change['order']['items']) { $items = array(); foreach ($change['order']['items'] as $item) { if (isset($change['created'])) { $item['create'] = 1; } $items[$item['id']] = $item; } $change['order']['items'] = $items; } if ($change['order']['contragent']['contragentType']) { $change['order']['contragentType'] = self::newValue($change['order']['contragent']['contragentType']); unset($change['order']['contragent']); } if ($orders[$change['order']['id']]) { $orders[$change['order']['id']] = array_merge($orders[$change['order']['id']], $change['order']); } else { $orders[$change['order']['id']] = $change['order']; } if ($change['item']) { if ($orders[$change['order']['id']]['items'][$change['item']['id']]) { $orders[$change['order']['id']]['items'][$change['item']['id']] = array_merge($orders[$change['order']['id']]['items'][$change['item']['id']], $change['item']); } else { $orders[$change['order']['id']]['items'][$change['item']['id']] = $change['item']; } if (empty($change['oldValue']) && $change['field'] == 'order_product') { $orders[$change['order']['id']]['items'][$change['item']['id']]['create'] = 1; unset($orders[$change['order']['id']]['items'][$change['item']['id']]['delete']); } if (empty($change['newValue']) && $change['field'] == 'order_product') { $orders[$change['order']['id']]['items'][$change['item']['id']]['delete'] = 1; } if (!$orders[$change['order']['id']]['items'][$change['item']['id']]['create'] && $fields['item'][$change['field']]) { $orders[$change['order']['id']]['items'][$change['item']['id']][$fields['item'][$change['field']]] = $change['newValue']; } } else { if ($fields['delivery'][$change['field']] == 'service') { $orders[$change['order']['id']]['delivery']['service']['code'] = self::newValue($change['newValue']); } elseif ($fields['delivery'][$change['field']]) { $orders[$change['order']['id']]['delivery'][$fields['delivery'][$change['field']]] = self::newValue($change['newValue']); } elseif ($fields['orderAddress'][$change['field']]) { $orders[$change['order']['id']]['delivery']['address'][$fields['orderAddress'][$change['field']]] = $change['newValue']; } elseif ($fields['integrationDelivery'][$change['field']]) { $orders[$change['order']['id']]['delivery']['service'][$fields['integrationDelivery'][$change['field']]] = self::newValue($change['newValue']); } elseif ($fields['customerContragent'][$change['field']]) { $orders[$change['order']['id']][$fields['customerContragent'][$change['field']]] = self::newValue($change['newValue']); } elseif (strripos($change['field'], 'custom_') !== false) { $orders[$change['order']['id']]['customFields'][str_replace('custom_', '', $change['field'])] = self::newValue($change['newValue']); } elseif ($fields['order'][$change['field']]){ $orders[$change['order']['id']][$fields['order'][$change['field']]] = self::newValue($change['newValue']); } if (isset($change['created'])) { $orders[$change['order']['id']]['create'] = 1; } if (isset($change['deleted'])) { $orders[$change['order']['id']]['deleted'] = 1; } } } return $orders; } public static function shipmentUpdate($orderCrm, $optionsDelivTypes) { if (isset($orderCrm['delivery']['code'])) { $crmCode = $orderCrm['delivery']['code']; if (isset($orderCrm['delivery']['data']['deliveryType'])) { $crmService = $orderCrm['delivery']['data']['deliveryType']; } elseif (isset($orderCrm['delivery']['service'])) { $crmService = $orderCrm['delivery']['service']; } //подбираем код битриксового сервиса $arDeliveryServiceAll = \Bitrix\Sale\Delivery\Services\Manager::getActiveList(); foreach ($arDeliveryServiceAll as $arDeliveryService) { $arDeliveryCode[$arDeliveryService['CODE']] = $arDeliveryService['ID']; $arDeliveryID[$arDeliveryService['ID']] = $arDeliveryService; if ($arDeliveryService['ID'] == $optionsDelivTypes[$crmCode]) { $dCode = $arDeliveryService['CODE'] . ':' . $crmService; } } //будем менять доставку на этот id if ($crmService && $arDeliveryCode[$dCode]) { $nowDelivery = $arDeliveryCode[$dCode]; } else { $nowDelivery = $optionsDelivTypes[$crmCode]; } //найти текущую доставку в заказе $cnt = Bitrix\Sale\Internals\ShipmentTable::getCount(array('ORDER_ID' => $orderCrm['externalId'])); if ($cnt > 0) {//обновляем $obDeliverys = \Bitrix\Sale\Internals\ShipmentTable::getList(array('filter' => array('ORDER_ID' => $orderCrm['externalId']), 'order' => array('ID'))); while ($arDelivery = $obDeliverys->fetch()) { if ($arDelivery['DELIVERY_ID'] != $nowDelivery) { \Bitrix\Sale\OrderTable::update($orderCrm['externalId'], array('DELIVERY_ID' => $nowDelivery)); \Bitrix\Sale\Internals\ShipmentTable::update($arDelivery['ID'], array('DELIVERY_ID' => $nowDelivery, 'DELIVERY_NAME' => $arDeliveryID[$nowDelivery]['NAME'])); } } } else {//создаем \Bitrix\Sale\OrderTable::update($orderCrm['externalId'], array('DELIVERY_ID' => $nowDelivery)); $shipmentSystem = \Bitrix\Sale\Internals\ShipmentTable::add(array( 'ORDER_ID' => $orderCrm['externalId'], 'STATUS_ID' => 'DN', 'CUSTOM_PRICE_DELIVERY' => 'N', 'ALLOW_DELIVERY' => 'N', 'DEDUCTED' => 'N', 'RESERVED' => 'N', 'DELIVERY_ID' => $nowDelivery, 'DELIVERY_NAME' => $nowDelivery[$nowDelivery]['NAME'], 'CANCELED' => 'N', 'MARKED' => 'N', 'SYSTEM' => 'Y', 'ACCOUNT_NUMBER' => $orderCrm['externalId'] . '/1', 'EXTERNAL_DELIVERY' => 'N', 'UPDATED_1C' => 'N', 'DATE_INSERT'=> new \Bitrix\Main\Type\DateTime() )); $shipment = Bitrix\Sale\Internals\ShipmentTable::add(array( 'ORDER_ID' => $orderCrm['externalId'], 'STATUS_ID' => 'DN', 'PRICE_DELIVERY' => 0, 'BASE_PRICE_DELIVERY' => 0, 'CUSTOM_PRICE_DELIVERY' => 'N', 'ALLOW_DELIVERY' => 'N', 'DEDUCTED' => 'N', 'RESERVED' => 'N', 'DELIVERY_ID' => $nowDelivery, 'DELIVERY_NAME' => $arDeliveryID[$nowDelivery]['NAME'], 'CANCELED' => 'N', 'MARKED' => 'N', 'CURRENCY' => \Bitrix\Currency\CurrencyManager::getBaseCurrency(), 'SYSTEM' => 'N', 'ACCOUNT_NUMBER' => $orderCrm['externalId'] . '/2', 'EXTERNAL_DELIVERY' => 'N', 'UPDATED_1C' => 'N', 'DATE_INSERT'=> new \Bitrix\Main\Type\DateTime() )); } } else { //ищем у заказа на сайте доставки и удаляем/заменяем на без доставки $noOrderId = \Bitrix\Sale\Delivery\Services\EmptyDeliveryService::getEmptyDeliveryServiceId(); \Bitrix\Sale\OrderTable::update($orderCrm['externalId'], array('DELIVERY_ID' => $noOrderId)); $obDeliverys = Bitrix\Sale\Internals\ShipmentTable::getList(array('filter' => array('ORDER_ID' => $orderCrm['externalId']), 'order' => array('ID'))); $create = true; while ($arDelivery = $obDeliverys->fetch()) { \Bitrix\Sale\Internals\ShipmentTable::update($arDelivery['ID'], array('DELIVERY_ID' => $noOrderId, 'DELIVERY_NAME' => 'Без доставки')); $create = false; } if ($create) { $shipmentSystem = \Bitrix\Sale\Internals\ShipmentTable::add(array( 'ORDER_ID' => $orderCrm['externalId'], 'STATUS_ID' => 'DN', 'CUSTOM_PRICE_DELIVERY' => 'N', 'ALLOW_DELIVERY' => 'N', 'DEDUCTED' => 'N', 'RESERVED' => 'N', 'DELIVERY_ID' => $nowDelivery, 'DELIVERY_NAME' => $nowDelivery[$nowDelivery]['NAME'], 'CANCELED' => 'N', 'MARKED' => 'N', 'SYSTEM' => 'Y', 'ACCOUNT_NUMBER' => $orderCrm['externalId'] . '/1', 'EXTERNAL_DELIVERY' => 'N', 'UPDATED_1C' => 'N', 'DATE_INSERT'=> new \Bitrix\Main\Type\DateTime() )); $shipment = Bitrix\Sale\Internals\ShipmentTable::add(array( 'ORDER_ID' => $orderCrm['externalId'], 'STATUS_ID' => 'DN', 'PRICE_DELIVERY' => 0, 'BASE_PRICE_DELIVERY' => 0, 'CUSTOM_PRICE_DELIVERY' => 'N', 'ALLOW_DELIVERY' => 'N', 'DEDUCTED' => 'N', 'RESERVED' => 'N', 'DELIVERY_ID' => $nowDelivery, 'DELIVERY_NAME' => $arDeliveryID[$nowDelivery]['NAME'], 'CANCELED' => 'N', 'MARKED' => 'N', 'CURRENCY' => \Bitrix\Currency\CurrencyManager::getBaseCurrency(), 'SYSTEM' => 'N', 'ACCOUNT_NUMBER' => $orderCrm['externalId'] . '/2', 'EXTERNAL_DELIVERY' => 'N', 'UPDATED_1C' => 'N', 'DATE_INSERT'=> new \Bitrix\Main\Type\DateTime() )); } } return true; } public static function updateShipmentItem($orderId) { $orderBasket = \Bitrix\Sale\Internals\BasketTable::getList(array( 'filter' => array('ORDER_ID' => $orderId), 'select' => array('ID', 'QUANTITY') )); $basketItems = array(); while ($basketItem = $orderBasket->fetch()) { $basketItems[] = $basketItem; $bItems[] = $basketItem['ID']; } $obShipments = \Bitrix\Sale\Internals\ShipmentTable::getList(array( 'filter' => array('ORDER_ID' => $orderId), 'select' => array('ID') )); $shipmentItems = array(); while ($arShipment = $obShipments->fetch()) { $dlvBaslet = \Bitrix\Sale\Internals\ShipmentItemTable::getList(array( 'order' => array('ORDER_DELIVERY_ID'), 'filter' => array('ORDER_DELIVERY_ID' => $arShipment['ID']) )); $shipmentItems[$arShipment['ID']] = array(); while ($item = $dlvBaslet->fetch()) { $shipmentItems[$arShipment['ID']][] = $item; } } foreach ($basketItems as $basketItem) { foreach ($shipmentItems as $key => $arShipmentItems) { $found = false; foreach ($arShipmentItems as $elShipmentItem) { if (!in_array($elShipmentItem['BASKET_ID'], $bItems)) { //удаляем элемент \Bitrix\Sale\Internals\ShipmentItemTable::delete($elShipmentItem['ID']); } if ($elShipmentItem['BASKET_ID'] == $basketItem['ID']) { //нашли $found = true; //проверяем кол-во, если нужно, обновляем if ($elShipmentItem['QUANTITY'] != $basketItem['QUANTITY']) { \Bitrix\Sale\Internals\ShipmentItemTable::update($elShipmentItem['ID'], array('QUANTITY' => $basketItem['QUANTITY'])); } } } if (!$found) { //добавляем \Bitrix\Sale\Internals\ShipmentItemTable::add(array( 'ORDER_DELIVERY_ID' => $key, 'BASKET_ID' => $basketItem['ID'], 'DATE_INSERT' => new \Bitrix\Main\Type\DateTime(), 'QUANTITY' => $basketItem['QUANTITY'], 'RESERVED_QUANTITY' => '0.00', )); } } } } public static function paySystemUpdate($order, $optionsPayment) { if (isset($order['paymentType'])) { if ($optionsPayment[$order['paymentType']]) { $paymentList = RCrmActions::PaymentList(); $arPayments = array(); $arPaymentsName = array(); foreach ($paymentList as $payment) { $arPayments[] = $payment['ID']; $arPaymentsName[$payment['ID']] = $payment['NAME']; } if (in_array($optionsPayment[$order['paymentType']], $arPayments)) { \Bitrix\Sale\OrderTable::update($order['externalId'], array('PAY_SYSTEM_ID' => $optionsPayment[$order['paymentType']])); $payment = \Bitrix\Sale\Internals\PaymentTable::getList(array( 'filter' => array('ORDER_ID' => $order['externalId']), 'order' => array('ID') ))->fetch(); if ($payment) {//если уже существует, update \Bitrix\Sale\Internals\PaymentTable::update($payment['ID'], array('PAY_SYSTEM_ID' => $optionsPayment[$order['paymentType']], 'PAY_SYSTEM_NAME' => $arPaymentsName[$optionsPayment[$order['paymentType']]], 'SUM' => $order['summ'])); } else { \Bitrix\Sale\Internals\PaymentTable::add(array( 'ORDER_ID' => $order['externalId'], 'PAID' => 'N', 'PAY_SYSTEM_ID' => $optionsPayment[$order['paymentType']], 'SUM' => $order['summ'], 'CURRENCY' => \Bitrix\Currency\CurrencyManager::getBaseCurrency(), 'PAY_SYSTEM_NAME' => $arPaymentsName[$optionsPayment[$order['paymentType']]], 'IS_RETURN' => 'N', 'ACCOUNT_NUMBER' => $order['externalId'] . '/1', 'PRICE_COD' => '0.00', 'EXTERNAL_PAYMENT' => 'N', 'UPDATED_1C' => 'N' )); } //запись в историю } else {//ошибка, нет такой активной платежной системы RCrmActions::eventLog('RetailCrmHistory::paySystemUpdate', 'RCrmActions::PaymentList()', 'Error paySystem not found in order id=' . $order['externalId']); } } else {//ошибка, возможно платежная система не сопоставлена RCrmActions::eventLog('RetailCrmHistory::paySystemUpdate', 'RCrmActions::PaymentList()', 'Error paySystem not found in option in order id=' . $order['externalId']);; } } else { \Bitrix\Sale\OrderTable::update($order['externalId'], array('PAY_SYSTEM_ID' => '')); $payment = \Bitrix\Sale\Payment::getList(array( 'filter' => array('ORDER_ID' => $order['externalId']), 'order' => array('ID') ))->fetch(); if ($payment['ID']) { \Bitrix\Sale\Internals\PaymentTable::delete($payment['ID']); } //запись в историю } } public static function newValue($value) { if (array_key_exists('code', $value)) { return $value['code']; } else { return $value; } } public static function removeEmpty($inputArray) { $outputArray = array(); if (!empty($inputArray)) { foreach ($inputArray as $key => $element) { if (!empty($element) || $element === 0 || $element === '0') { if (is_array($element)) { $element = self::removeEmpty($element); } $outputArray[$key] = $element; } } } return $outputArray; } public static function setProp($obj, $value = '', $prop) { if (!isset($obj)) { return false; } if ($prop) { $obj->setField($prop, $value); } elseif ($value) { $obj->setValue($value); } else { $obj->delete(); } return true; } public static function getExistsItem($basket, $moduleId, $productId) { foreach ($basket as $basketItem) { $itemExists = ($basketItem->getField('PRODUCT_ID') == $productId && $basketItem->getField('MODULE') == $moduleId); if ($itemExists) { return $basketItem; } } return false; } public static function getInfoElement($offerId) { $elementInfo = CIBlockElement::GetByID($offerId)->fetch(); $url = CAllIBlock::ReplaceDetailUrl($elementInfo['DETAIL_PAGE_URL'], $elementInfo, false, 'E'); $info = array( 'NAME' => $elementInfo['NAME'], 'URL' => $url, ); return $info; } } class RetailUser extends CUser { public function GetID() { $rsUser = CUser::GetList(($by='ID'), ($order='DESC'), array('LOGIN' => 'retailcrm%')); if ($arUser = $rsUser->Fetch()) { return $arUser['ID']; } else { $retailUser = new CUser; $userPassword = uniqid(); $arFields = array( "NAME" => 'retailcrm', "LAST_NAME" => 'retailcrm', "EMAIL" => 'retailcrm@retailcrm.com', "LOGIN" => 'retailcrm', "LID" => "ru", "ACTIVE" => "Y", "GROUP_ID" => array(2), "PASSWORD" => $userPassword, "CONFIRM_PASSWORD" => $userPassword ); $id = $retailUser->Add($arFields); if (!$id) { return null; } else { return $id; } } } }