0) { $historyFilter['sinceId'] = $historyStart; } while (true) { $customerHistory = RCrmActions::apiMethod($api, 'customersHistory', __METHOD__, $historyFilter); $customerH = isset($customerHistory['history']) ? $customerHistory['history'] : array(); $log = new Logger(); $log->write($customerH, 'customerHistory'); if (count($customerH) == 0) { if ($customerHistory['history']['totalPageCount'] > $customerHistory['history']['currentPage']) { $historyFilter['page'] = $customerHistory['history']['currentPage'] + 1; continue; } 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; } elseif ($newResCustomer === false) { RCrmActions::eventLog('RetailCrmHistory::customerHistory', 'retailCrmBeforeCustomerSave()', 'UserCrmId = ' . $customer['id'] . '. Sending canceled after retailCrmBeforeCustomerSave'); continue; } } if (isset($customer['deleted'])) { continue; } if (isset($customer['externalId']) && !is_numeric($customer['externalId'])) { unset($customer['externalId']); } 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; } if(RCrmActions::apiMethod($api, 'customersFixExternalIds', __METHOD__, array(array('id' => $customer['id'], 'externalId' => $registeredUserID))) == false) { 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; } } } } if (array_key_exists('index', $customer['address'])) { $arUser["PERSONAL_ZIP"] = $customer['address']['index'] ? RCrmActions::fromJSON($customer['address']['index']) : ''; } if (array_key_exists('city', $customer['address'])) { $arUser["PERSONAL_CITY"] = $customer['address']['city'] ? RCrmActions::fromJSON($customer['address']['city']) : ''; } $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; //last id $end = array_pop($customerH); COption::SetOptionString(self::$MODULE_ID, self::$CRM_CUSTOMER_HISTORY, $end['id']); if ($customerHistory['pagination']['totalPageCount'] == 1) { return true; } //new filter $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 = 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))); $optionsPayStatuses = array_flip(unserialize(COption::GetOptionString(self::$MODULE_ID, self::$CRM_PAYMENT_STATUSES, 0))); // --statuses $optionsOrderProps = unserialize(COption::GetOptionString(self::$MODULE_ID, self::$CRM_ORDER_PROPS, 0)); $optionsLegalDetails = unserialize(COption::GetOptionString(self::$MODULE_ID, self::$CRM_LEGAL_DETAILS, 0)); $optionsSitesList = unserialize(COption::GetOptionString(self::$MODULE_ID, self::$CRM_SITES_LIST, 0)); $optionsOrderNumbers = COption::GetOptionString(self::$MODULE_ID, self::$CRM_ORDER_NUMBERS, 0); $optionsCanselOrder = unserialize(COption::GetOptionString(self::$MODULE_ID, self::$CRM_CANSEL_ORDER, 0)); $optionsCurrency = COption::GetOptionString(self::$MODULE_ID, self::$CRM_CURRENCY, 0); $currency = $optionsCurrency ? $optionsCurrency : \Bitrix\Currency\CurrencyManager::getBaseCurrency(); $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) { $orderHistory = RCrmActions::apiMethod($api, 'ordersHistory', __METHOD__, $historyFilter); $orderH = isset($orderHistory['history']) ? $orderHistory['history'] : array(); $log = new Logger(); $log->write($orderH, 'orderHistory'); if (count($orderH) == 0) { if ($orderHistory['history']['totalPageCount'] > $orderHistory['history']['currentPage']) { $historyFilter['page'] = $orderHistory['history']['currentPage'] + 1; continue; } return true; } $orders = self::assemblyOrder($orderH); $GLOBALS['RETAIL_CRM_HISTORY'] = true; //orders with changes foreach ($orders as $order) { if (function_exists('retailCrmBeforeOrderSave')) { $newResOrder = retailCrmBeforeOrderSave($order); if (is_array($newResOrder) && !empty($newResOrder)) { $order = $newResOrder; } elseif ($newResOrder === false) { RCrmActions::eventLog('RetailCrmHistory::orderHistory', 'retailCrmBeforeOrderSave()', 'OrderCrmId = ' . $order['id'] . '. Sending canceled after retailCrmBeforeOrderSave' ); continue; } } $log->write($order, 'assemblyOrderHistory'); if (isset($order['deleted'])) { if (isset($order['externalId'])) { try { $newOrder = Bitrix\Sale\Order::load($order['externalId']); } catch (Bitrix\Main\ArgumentNullException $e) { RCrmActions::eventLog('RetailCrmHistory::orderHistory', 'Bitrix\Sale\Order::load', $e->getMessage() . ': ' . $order['externalId']); continue; } if (!$newOrder instanceof \Bitrix\Sale\Order) { RCrmActions::eventLog('RetailCrmHistory::orderHistory', 'Bitrix\Sale\Order::load', 'Error order load: ' . $order['externalId']); continue; } $newOrder->setField('CANCELED', 'Y'); $newOrder->save(); } continue; } if (isset($order['customer']['externalId']) && !is_numeric($order['customer']['externalId'])) { unset($order['customer']['externalId']); } 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; } if(RCrmActions::apiMethod($api, 'customersFixExternalIds', __METHOD__, array(array('id' => $order['customer']['id'], 'externalId' => $registeredUserID))) == false) { continue; } } $order['customer']['externalId'] = $registeredUserID; } if ($optionsSitesList) { $site = array_search($order['site'], $optionsSitesList); } else { $site = CSite::GetDefSite(); } if (empty($site)) { RCrmActions::eventLog('RetailCrmHistory::orderHistory', 'Bitrix\Sale\Order::create', 'Site = ' . $order['site'] . ' not found in setting. Order crm id=' . $order['id']); continue; } $newOrder = Bitrix\Sale\Order::create($site, $order['customer']['externalId'], $currency); if (!is_object($newOrder) || !$newOrder instanceof \Bitrix\Sale\Order) { RCrmActions::eventLog('RetailCrmHistory::orderHistory', 'Bitrix\Sale\Order::create', 'Error order create'); continue; } $externalId = $newOrder->getId(); $order['externalId'] = $externalId; } if (isset($order['externalId'])) { $itemUpdate = false; if ($order['externalId'] && is_numeric($order['externalId'])) { try { $newOrder = Bitrix\Sale\Order::load($order['externalId']); } catch (Bitrix\Main\ArgumentNullException $e) { RCrmActions::eventLog('RetailCrmHistory::orderHistory', 'Bitrix\Sale\Order::load', $e->getMessage() . ': ' . $order['externalId']); continue; } } if ($newOrder === null) { RCrmActions::eventLog('RetailCrmHistory::orderHistory', 'Bitrix\Sale\Order::load', 'Error order load number=' . $order['number']); continue; } if ($optionsSitesList) { $site = array_search($order['site'], $optionsSitesList); } else { $site = CSite::GetDefSite(); } if (empty($site)) { RCrmActions::eventLog('RetailCrmHistory::orderHistory', 'Bitrix\Sale\Order::edit', 'Site = ' . $order['site'] . ' not found in setting. Order number=' . $order['number']); continue; } $personType = $newOrder->getField('PERSON_TYPE_ID'); if (isset($order['orderType']) && $order['orderType']) { $nType = array(); $tList = RCrmActions::OrderTypesList(array(array('LID' => $site))); foreach($tList as $type){ if (isset($optionsOrderTypes[$type['ID']])) { $nType[$optionsOrderTypes[$type['ID']]] = $type['ID']; } } $newOptionsOrderTypes = $nType; if ($newOptionsOrderTypes[$order['orderType']]) { if ($personType != $newOptionsOrderTypes[$order['orderType']] && $personType != 0) { $propsRemove = true; } $personType = $newOptionsOrderTypes[$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)) { self::unreserveShipment($newOrder); $newOrder->setFieldNoDemand('CANCELED', 'Y'); } else { $newOrder->setFieldNoDemand('CANCELED', 'N'); } } if (array_key_exists('statusComment', $order)) { self::setProp($newOrder, RCrmActions::fromJSON($order['statusComment']), 'REASON_CANCELED'); } //props $propertyCollection = $newOrder->getPropertyCollection(); $propertyCollectionArr = $propertyCollection->getArray(); $nProps = array(); foreach ($propertyCollectionArr['properties'] as $orderProp) { if ($orderProp['ID'][0] == 'n') { $orderProp['ID'] = substr($orderProp['ID'], 1); $property = $propertyCollection->getItemById($orderProp['ID']); if ($property) { $orderProp['ID'] = $property->getField('ORDER_PROPS_ID'); } else { continue; } } $nProps[] = $orderProp; } $propertyCollectionArr['properties'] = $nProps; if ($propsRemove) {//delete props foreach ($propertyCollectionArr['properties'] as $orderProp) { if ($orderProp['PROPS_GROUP_ID'] == 0) { $somePropValue = $propertyCollection->getItemByOrderPropertyId($orderProp['ID']); self::setProp($somePropValue); } } $orderCrm = RCrmActions::apiMethod($api, 'orderGet', __METHOD__, $order['id']); $orderDump = $order; $order = $orderCrm['order']; } $propsKey = array(); foreach ($propertyCollectionArr['properties'] as $prop) { if ($prop['PROPS_GROUP_ID'] != 0) { $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']); if ($key == 'fio') { self::setProp($somePropValue, $order[$key]); } else { self::setProp($somePropValue, RCrmActions::fromJSON($order[$key])); } } elseif (array_key_exists($key, $order['delivery']['address'])) { if ($propsKey[$orderProp]['TYPE'] == 'LOCATION') { $order['delivery']['address'][$key] = trim($order['delivery']['address'][$key]); if(!empty($order['delivery']['address'][$key])){ $parameters = array(); $loc = explode('.', $order['delivery']['address'][$key]); if (count($loc) == 1) { $parameters['filter']['PHRASE'] = RCrmActions::fromJSON(trim($loc[0])); } elseif (count($loc) == 2) { $parameters['filter']['PHRASE'] = RCrmActions::fromJSON(trim($loc[1])); } else { RCrmActions::eventLog('RetailCrmHistory::orderHistory', 'RetailCrmHistory::setProp', 'Error location. ' . $order['delivery']['address'][$key] . ' not found add in order number=' . $order['number']); continue; } $parameters['filter']['NAME.LANGUAGE_ID'] = 'ru'; try { $location = \Bitrix\Sale\Location\Search\Finder::find($parameters, array('USE_INDEX' => false, 'USE_ORM' => false))->fetch(); $somePropValue = $propertyCollection->getItemByOrderPropertyId($propsKey[$orderProp]['ID']); self::setProp($somePropValue, $location['CODE']); } catch (\Bitrix\Main\ArgumentException $argumentException) { RCrmActions::eventLog('RetailCrmHistory::orderHistory', 'RetailCrmHistory::setProp', 'Location parameter is incorrect in order number=' . $order['number']); } } else { RCrmActions::eventLog('RetailCrmHistory::orderHistory', 'RetailCrmHistory::setProp', 'Error location. ' . $order['delivery']['address'][$key] . ' is empty in order number=' . $order['number']); continue; } } 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, RCrmActions::fromJSON($order[$key])); } } } if ($propsRemove) { $order = $orderDump; } //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 (!$basket) { $basket = Bitrix\Sale\Basket::create($site); $newOrder->setBasket($basket); } $fUserId = $basket->getFUserId(true); if (!$fUserId) { $fUserId = Bitrix\Sale\Fuser::getIdByUserId($order['customer']['externalId']); $basket->setFUserId($fUserId); } 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' => $newOrder->getCurrency(), 'LID' => $site, 'BASE_PRICE' => $product['initialPrice'], 'NAME' => $product['offer']['name'] ? RCrmActions::fromJSON($product['offer']['name']) : $elem['NAME'], 'DETAIL_PAGE_URL' => $elem['URL'], 'PRODUCT_PROVIDER_CLASS' => 'CCatalogProductProvider', 'DIMENSIONS' => $elem['DIMENSIONS'], 'WEIGHT' => $elem['WEIGHT'], 'NOTES' => GetMessage('PRICE_TYPE'), 'PRODUCT_XML_ID' => $elem["XML_ID"], 'CATALOG_XML_ID' => $elem["IBLOCK_XML_ID"] )); } else { RCrmActions::eventLog('RetailCrmHistory::orderHistory', 'createItem', 'Error item add'); continue; } } if ($product['delete']) { $item->delete(); continue; } if ($product['quantity']) { $item->setFieldNoDemand('QUANTITY', $product['quantity']); } if (array_key_exists('discountTotal', $product)) { $itemCost = $item->getField('BASE_PRICE'); $discount = (double) $item->getField('DISCOUNT_PRICE'); if (isset($itemCost) && $itemCost >= 0) { if ($discount < 0) { $resultDiscount = $product['discountTotal'] + $discount; } else { $resultDiscount = $product['discountTotal']; } $item->setField('CUSTOM_PRICE', 'Y'); $item->setField('DISCOUNT_NAME', ''); $item->setField('DISCOUNT_VALUE', ''); $item->setField('DISCOUNT_PRICE', $resultDiscount); $item->setField('PRICE', $itemCost - $resultDiscount); } } } } $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; $order['summ'] = $orderSumm; //payment $newHistoryPayments = array(); if (array_key_exists('payments', $order)) { if (!isset($orderCrm)) { $orderCrm = RCrmActions::apiMethod($api, 'orderGet', __METHOD__, $order['id']); } if ($orderCrm) { self::paymentsUpdate($newOrder, $orderCrm['order'], $newHistoryPayments); } } //delivery if (array_key_exists('delivery', $order)) { $itemUpdate = true; //delete empty if (!isset($orderCrm)) { $orderCrm = RCrmActions::apiMethod($api, 'orderGet', __METHOD__, $order['id']); } if ($orderCrm) { self::deliveryUpdate($newOrder, $optionsDelivTypes, $orderCrm['order']); } } if ($itemUpdate === true && $newOrder->getField('CANCELED') != 'Y') { self::shipmentItemReset($newOrder); } if (isset($orderCrm)) { unset($orderCrm); } $newOrder->setField('PRICE', $orderSumm); self::orderSave($newOrder); if ($optionsOrderNumbers == 'Y' && isset($order['number'])) { $newOrder->setField('ACCOUNT_NUMBER', $order['number']); self::orderSave($newOrder); } if (!empty($newHistoryPayments)) { foreach ($newOrder->getPaymentCollection() as $orderPayment) { if (array_key_exists($orderPayment->getField('XML_ID'), $newHistoryPayments)) { $paymentId = $orderPayment->getId(); $paymentExternalId = RCrmActions::generatePaymentExternalId($paymentId); if ($paymentExternalId) { $newHistoryPayments[$orderPayment->getField('XML_ID')]['externalId'] = $paymentExternalId; RCrmActions::apiMethod($api, 'paymentEditById', __METHOD__, $newHistoryPayments[$orderPayment->getField('XML_ID')]); \Bitrix\Sale\Internals\PaymentTable::update($paymentId, array('XML_ID' => '')); } } } } if (!$order['externalId']) { if (RCrmActions::apiMethod($api, 'ordersFixExternalIds', __METHOD__, array(array('id' => $order['id'], 'externalId' => $newOrder->getId()))) == false){ continue; } } if (function_exists('retailCrmAfterOrderSave')) { retailCrmAfterOrderSave($order); } } unset($newOrder); } $GLOBALS['RETAIL_CRM_HISTORY'] = false; //end id $end = array_pop($orderH); COption::SetOptionString(self::$MODULE_ID, self::$CRM_ORDER_HISTORY, $end['id']); if ($orderHistory['pagination']['totalPageCount'] == 1) { return true; } //new filter $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']['payments']) { $payments = array(); foreach ($change['order']['payments'] as $payment) { $payments[$payment['id']] = $payment; } $change['order']['payments'] = $payments; } if (isset($change['order']['contragent']) && count($change['order']['contragent']) > 0) { foreach ($change['order']['contragent'] as $name => $value) { $change['order'][$name] = self::newValue($value); } 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']; } } elseif ($change['payment']) { if ($orders[$change['order']['id']]['payments'][$change['payment']['id']]) { $orders[$change['order']['id']]['payments'][$change['payment']['id']] = array_merge($orders[$change['order']['id']]['payments'][$change['payment']['id']], $change['payment']); } else { $orders[$change['order']['id']]['payments'][$change['payment']['id']] = $change['payment']; } if (empty($change['oldValue']) && $change['field'] == 'payments') { $orders[$change['order']['id']]['payments'][$change['payment']['id']]['create'] = 1; unset($orders[$change['order']['id']]['payments'][$change['payment']['id']]['delete']); } if (empty($change['newValue']) && $change['field'] == 'payments') { $orders[$change['order']['id']]['payments'][$change['payment']['id']]['delete'] = 1; } if (!$orders[$change['order']['id']]['payments'][$change['payment']['id']]['create'] && $fields['payment'][$change['field']]) { $orders[$change['order']['id']]['payments'][$change['payment']['id']][$fields['payment'][$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; } /** * Update shipment in order * * @param order object * @param options delivery types * @param order from crm * * @return void */ public static function deliveryUpdate(Bitrix\Sale\Order $order, $optionsDelivTypes, $orderCrm) { if (!$order instanceof Bitrix\Sale\Order) { return false; } if ($order->getId()) { $update = true; } else { $update = false; } $crmCode = isset($orderCrm['delivery']['code']) ? $orderCrm['delivery']['code'] : false; $noDeliveryId = \Bitrix\Sale\Delivery\Services\EmptyDeliveryService::getEmptyDeliveryServiceId(); if ($crmCode === false || !isset($optionsDelivTypes[$crmCode])) { $deliveryId = $noDeliveryId; } else { $deliveryId = $optionsDelivTypes[$crmCode]; if (isset($orderCrm['delivery']['service']['code'])) { $deliveryCode = \Bitrix\Sale\Delivery\Services\Manager::getCodeById($deliveryId); $serviceCode = $orderCrm['delivery']['service']['code']; $services = \Bitrix\Sale\Delivery\Services\Manager::getService($deliveryId)->getProfilesList(); if (!array_key_exists($serviceCode, $services)) { $serviceCode = strtoupper($serviceCode); $serviceCode = str_replace(array('-'), "_", $serviceCode); } if ($deliveryCode) { try { $deliveryService = \Bitrix\Sale\Delivery\Services\Manager::getObjectByCode($deliveryCode . ':' . $serviceCode); } catch (Bitrix\Main\SystemException $systemException) { RCrmActions::eventLog('RetailCrmHistory::deliveryEdit', '\Bitrix\Sale\Delivery\Services\Manager::getObjectByCode', $systemException->getMessage()); } if (isset($deliveryService)) { $deliveryId = $deliveryService->getId(); } } } } $delivery = \Bitrix\Sale\Delivery\Services\Manager::getObjectById($deliveryId); $shipmentColl = $order->getShipmentCollection(); if ($delivery) { if (!$update) { $shipment = $shipmentColl->createItem($delivery); $shipment->setFields(array( 'BASE_PRICE_DELIVERY' => $orderCrm['delivery']['cost'], 'CURRENCY' => $order->getCurrency(), 'DELIVERY_NAME' => $delivery->getName(), 'CUSTOM_PRICE_DELIVERY' => 'Y' )); } else { foreach ($shipmentColl as $shipment) { if (!$shipment->isSystem()) { $shipment->setFields(array( 'BASE_PRICE_DELIVERY' => $orderCrm['delivery']['cost'], 'CURRENCY' => $order->getCurrency(), 'DELIVERY_ID' => $deliveryId, 'DELIVERY_NAME' => $delivery->getName(), 'CUSTOM_PRICE_DELIVERY' => 'Y' )); } } } } } /** * Update shipment item colletion * * @param \Bitrix\Sale\Order $order * * @return void | boolean */ public static function shipmentItemReset($order) { $shipmentCollection = $order->getShipmentCollection(); $basket = $order->getBasket(); foreach ($shipmentCollection as $shipment) { if (!$shipment->isSystem()) { $reserved = false; if ($shipment->needReservation()) { $reserved = true; } $shipmentItemColl = $shipment->getShipmentItemCollection(); if ($reserved === true) { $shipment->tryUnreserve(); } try { $shipmentItemColl->resetCollection($basket); if ($reserved === true) { $shipment->tryReserve(); } } catch (\Bitrix\Main\NotSupportedException $NotSupportedException) { RCrmActions::eventLog('RetailCrmHistory::shipmentItemReset', '\Bitrix\Sale\ShipmentItemCollection::resetCollection()', $NotSupportedException->getMessage()); return false; } } } } /** * Unreserve items if order canceled * * @param \Bitrix\Sale\Order $order * * @return void | boolean */ public static function unreserveShipment($order) { $shipmentCollection = $order->getShipmentCollection(); foreach ($shipmentCollection as $shipment) { if (!$shipment->isSystem()) { try { $shipment->tryUnreserve(); } catch (Main\ArgumentOutOfRangeException $ArgumentOutOfRangeException) { RCrmActions::eventLog('RetailCrmHistory::unreserveShipment', '\Bitrix\Sale\Shipment::tryUnreserve()', $ArgumentOutOfRangeException->getMessage()); return false; } catch (Main\NotSupportedException $NotSupportedException) { RCrmActions::eventLog('RetailCrmHistory::unreserveShipment', '\Bitrix\Sale\Shipment::tryUnreserve()', $NotSupportedException->getMessage()); return false; } } } } /** * Update payment in order * * @param object $order * @param array $paymentsCrm * @param array $newHistoryPayments * * @return void */ public static function paymentsUpdate($order, $paymentsCrm, &$newHistoryPayments = array()) { $optionsPayTypes = array_flip(unserialize(COption::GetOptionString(self::$MODULE_ID, self::$CRM_PAYMENT_TYPES, 0))); $optionsPayment = array_flip(unserialize(COption::GetOptionString(self::$MODULE_ID, self::$CRM_PAYMENT, 0))); $allPaymentSystems = RCrmActions::PaymentList(); foreach ($allPaymentSystems as $allPaymentSystem) { $arPaySysmems[$allPaymentSystem['ID']] = $allPaymentSystem['NAME']; } $paymentsList = array(); $paymentColl = $order->getPaymentCollection(); foreach ($paymentColl as $paymentData) { $data = $paymentData->getFields()->getValues(); $paymentsList[$data['ID']] = $paymentData; } //data from crm $paySumm = 0; foreach ($paymentsCrm['payments'] as $paymentCrm) { if (isset($paymentCrm['externalId']) && !empty($paymentCrm['externalId'])) { //find the payment $nowPaymentId = RCrmActions::getFromPaymentExternalId($paymentCrm['externalId']); $nowPayment = $paymentsList[$nowPaymentId]; //update data if ($nowPayment instanceof \Bitrix\Sale\Payment) { $nowPayment->setField('SUM', $paymentCrm['amount']); if ($optionsPayTypes[$paymentCrm['type']] != $nowPayment->getField('PAY_SYSTEM_ID')) { $nowPayment->setField('PAY_SYSTEM_ID', $optionsPayTypes[$paymentCrm['type']]); $nowPayment->setField('PAY_SYSTEM_NAME', $arPaySysmems[$optionsPayTypes[$paymentCrm['type']]]); } if (isset($optionsPayment[$paymentCrm['status']])) { $nowPayment->setField('PAID', $optionsPayment[$paymentCrm['status']]); } unset($paymentsList[$nowPaymentId]); } } else { $newHistoryPayments[$paymentCrm['id']] = $paymentCrm; $newPayment = $paymentColl->createItem(); $newPayment->setField('SUM', $paymentCrm['amount']); $newPayment->setField('PAY_SYSTEM_ID', $optionsPayTypes[$paymentCrm['type']]); $newPayment->setField('PAY_SYSTEM_NAME', $arPaySysmems[$optionsPayTypes[$paymentCrm['type']]]); $newPayment->setField('PAID', $optionsPayment[$paymentCrm['status']] ? $optionsPayment[$paymentCrm['status']] : 'N'); $newPayment->setField('CURRENCY', $order->getCurrency()); $newPayment->setField('IS_RETURN', 'N'); $newPayment->setField('PRICE_COD', '0.00'); $newPayment->setField('EXTERNAL_PAYMENT', 'N'); $newPayment->setField('UPDATED_1C', 'N'); $newPayment->setField('XML_ID', $paymentCrm['id']); $newPaymentId = $newPayment->getId(); unset($paymentsList[$newPaymentId]); } if ($optionsPayment[$paymentCrm['status']] == 'Y') { $paySumm += $paymentCrm['amount']; } } foreach ($paymentsList as $payment) { if ($payment->isPaid()) { $payment->setPaid("N"); } $payment->delete(); } if ($paymentsCrm['totalSumm'] == $paySumm) { $order->setFieldNoDemand('PAYED', 'Y'); } else { $order->setFieldNoDemand('PAYED', 'N'); } } 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 && $value) { $obj->setField($prop, $value); } elseif ($value && !$prop) { $obj->setValue($value); } elseif (!$value && !$prop) { $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'); $catalog = CCatalogProduct::GetByID($offerId); $info = array( 'NAME' => $elementInfo['NAME'], 'URL' => $url, 'DIMENSIONS' => serialize(array( 'WIDTH' => $catalog['WIDTH'], 'HEIGHT' => $catalog['HEIGHT'], 'LENGTH' => $catalog['LENGTH'], )), 'WEIGHT' => $catalog['WEIGHT'], 'XML_ID' => $elementInfo["XML_ID"], 'IBLOCK_XML_ID' => $elementInfo["IBLOCK_EXTERNAL_ID"] ); return $info; } /** * @param $order * * @return boolean */ private static function orderSave($order) { try { $order->save(); return true; } catch (\Exception $exception) { RCrmActions::eventLog( 'RetailCrmHistory::orderHistory', 'Order saving', $exception->getMessage() ); return false; } } } 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; } } } }