1447 lines
64 KiB
PHP
Executable File
1447 lines
64 KiB
PHP
Executable File
<?php
|
|
IncludeModuleLangFile(__FILE__);
|
|
class ICrmOrderActions
|
|
{
|
|
protected static $MODULE_ID = 'intaro.intarocrm';
|
|
protected static $CRM_API_HOST_OPTION = 'api_host';
|
|
protected static $CRM_API_KEY_OPTION = 'api_key';
|
|
protected static $CRM_ORDER_TYPES_ARR = 'order_types_arr';
|
|
protected static $CRM_DELIVERY_TYPES_ARR = 'deliv_types_arr';
|
|
protected static $CRM_PAYMENT_TYPES = 'pay_types_arr';
|
|
protected static $CRM_PAYMENT_STATUSES = 'pay_statuses_arr';
|
|
protected static $CRM_PAYMENT = 'payment_arr'; //order payment Y/N
|
|
protected static $CRM_ORDER_LAST_ID = 'order_last_id';
|
|
protected static $CRM_ORDER_SITES = 'sites_ids';
|
|
protected static $CRM_ORDER_PROPS = 'order_props';
|
|
protected static $CRM_ORDER_FAILED_IDS = 'order_failed_ids';
|
|
protected static $CRM_ORDER_HISTORY_DATE = 'order_history_date';
|
|
|
|
const CANCEL_PROPERTY_CODE = 'INTAROCRM_IS_CANCELED';
|
|
|
|
/**
|
|
* Mass order uploading, without repeating; always returns true, but writes error log
|
|
* @param $pSize
|
|
* @param $failed -- flag to export failed orders
|
|
* @return boolean
|
|
*/
|
|
public static function uploadOrders($pSize = 50, $failed = false) {
|
|
|
|
//COption::SetOptionString(self::$MODULE_ID, self::$CRM_ORDER_LAST_ID, 0); // -- for test
|
|
|
|
if (!CModule::IncludeModule("iblock")) {
|
|
//handle err
|
|
self::eventLog('ICrmOrderActions::uploadOrders', 'iblock', 'module not found');
|
|
return true;
|
|
}
|
|
|
|
if (!CModule::IncludeModule("sale")) {
|
|
//handle err
|
|
self::eventLog('ICrmOrderActions::uploadOrders', 'sale', 'module not found');
|
|
return true;
|
|
}
|
|
|
|
if (!CModule::IncludeModule("catalog")) {
|
|
//handle err
|
|
self::eventLog('ICrmOrderActions::uploadOrders', 'catalog', 'module not found');
|
|
return true;
|
|
}
|
|
|
|
$resOrders = array();
|
|
$resCustomers = array();
|
|
|
|
$lastUpOrderId = COption::GetOptionString(self::$MODULE_ID, self::$CRM_ORDER_LAST_ID, 0);
|
|
$lastOrderId = 0;
|
|
|
|
$failedIds = unserialize(COption::GetOptionString(self::$MODULE_ID, self::$CRM_ORDER_FAILED_IDS, 0));
|
|
if (!$failedIds)
|
|
$failedIds = array();
|
|
|
|
$dbOrder = CSaleOrder::GetList(array("ID" => "ASC"), array('>ID' => $lastUpOrderId));
|
|
$dbFailedOrder = CSaleOrder::GetList(array("ID" => "ASC"), array('ID' => $failedIds));
|
|
|
|
$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);
|
|
|
|
//saved cat params
|
|
$optionsOrderTypes = unserialize(COption::GetOptionString(self::$MODULE_ID, self::$CRM_ORDER_TYPES_ARR, 0));
|
|
$optionsDelivTypes = unserialize(COption::GetOptionString(self::$MODULE_ID, self::$CRM_DELIVERY_TYPES_ARR, 0));
|
|
$optionsPayTypes = unserialize(COption::GetOptionString(self::$MODULE_ID, self::$CRM_PAYMENT_TYPES, 0));
|
|
$optionsPayStatuses = unserialize(COption::GetOptionString(self::$MODULE_ID, self::$CRM_PAYMENT_STATUSES, 0)); // --statuses
|
|
$optionsPayment = unserialize(COption::GetOptionString(self::$MODULE_ID, self::$CRM_PAYMENT, 0));
|
|
$optionsSites = unserialize(COption::GetOptionString(self::$MODULE_ID, self::$CRM_ORDER_SITES, 0));
|
|
$optionsOrderProps = unserialize(COption::GetOptionString(self::$MODULE_ID, self::$CRM_ORDER_PROPS, 0));
|
|
|
|
$api = new IntaroCrm\RestApi($api_host, $api_key);
|
|
|
|
$arParams = array(
|
|
'optionsOrderTypes' => $optionsOrderTypes,
|
|
'optionsDelivTypes' => $optionsDelivTypes,
|
|
'optionsPayTypes' => $optionsPayTypes,
|
|
'optionsPayStatuses' => $optionsPayStatuses,
|
|
'optionsPayment' => $optionsPayment,
|
|
'optionSites' => $optionsSites,
|
|
'optionsOrderProps' => $optionsOrderProps
|
|
);
|
|
|
|
if (!$failed) {
|
|
|
|
//packmode
|
|
|
|
$orderCount = 0;
|
|
|
|
while ($arOrder = $dbOrder->GetNext()) { // here orders by id asc
|
|
if (is_array($optionsSites))
|
|
if (!empty($optionsSites))
|
|
if (!in_array($arOrder['LID'], $optionsSites))
|
|
continue;
|
|
|
|
$result = self::orderCreate($arOrder, $api, $arParams);
|
|
|
|
if (!$result['order'] || !$result['customer'])
|
|
continue;
|
|
|
|
$orderCount++;
|
|
|
|
$resOrders[] = $result['order'];
|
|
$resCustomers[] = $result['customer'];
|
|
|
|
$lastOrderId = $arOrder['ID'];
|
|
|
|
if ($orderCount >= $pSize) {
|
|
|
|
try {
|
|
$customers = $api->customerUpload($resCustomers);
|
|
} catch (\IntaroCrm\Exception\ApiException $e) {
|
|
self::eventLog(
|
|
'ICrmOrderActions::uploadOrders', 'IntaroCrm\RestApi::customerUpload',
|
|
$e->getCode() . ': ' . $e->getMessage()
|
|
);
|
|
|
|
if($e->getCode() != 201)
|
|
if($e->getCode() != 460)
|
|
return false;
|
|
} catch (\IntaroCrm\Exception\CurlException $e) {
|
|
self::eventLog(
|
|
'ICrmOrderActions::uploadOrders', 'IntaroCrm\RestApi::customerUpload::CurlException',
|
|
$e->getCode() . ': ' . $e->getMessage()
|
|
);
|
|
|
|
return false;
|
|
}
|
|
|
|
try {
|
|
$orders = $api->orderUpload($resOrders);
|
|
} catch (\IntaroCrm\Exception\ApiException $e) {
|
|
self::eventLog(
|
|
'ICrmOrderActions::uploadOrders', 'IntaroCrm\RestApi::orderUpload',
|
|
$e->getCode() . ': ' . $e->getMessage()
|
|
);
|
|
|
|
if($e->getCode() != 201)
|
|
if($e->getCode() != 460)
|
|
return false;
|
|
} catch (\IntaroCrm\Exception\CurlException $e) {
|
|
self::eventLog(
|
|
'ICrmOrderActions::uploadOrders', 'IntaroCrm\RestApi::orderUpload::CurlException',
|
|
$e->getCode() . ': ' . $e->getMessage()
|
|
);
|
|
|
|
return false;
|
|
}
|
|
|
|
if ($lastOrderId)
|
|
COption::SetOptionString(self::$MODULE_ID, self::$CRM_ORDER_LAST_ID, $lastOrderId);
|
|
|
|
return true; // end of pack
|
|
}
|
|
}
|
|
if (!empty($resOrders)) {
|
|
try {
|
|
$customers = $api->customerUpload($resCustomers);
|
|
} catch (\IntaroCrm\Exception\ApiException $e) {
|
|
self::eventLog(
|
|
'ICrmOrderActions::uploadOrders', 'IntaroCrm\RestApi::customerUpload',
|
|
$e->getCode() . ': ' . $e->getMessage()
|
|
);
|
|
|
|
if($e->getCode() != 201)
|
|
if($e->getCode() != 460)
|
|
return false;
|
|
} catch (\IntaroCrm\Exception\CurlException $e) {
|
|
self::eventLog(
|
|
'ICrmOrderActions::uploadOrders', 'IntaroCrm\RestApi::customerUpload::CurlException',
|
|
$e->getCode() . ': ' . $e->getMessage()
|
|
);
|
|
|
|
return false;
|
|
}
|
|
|
|
try {
|
|
$orders = $api->orderUpload($resOrders);
|
|
} catch (\IntaroCrm\Exception\ApiException $e) {
|
|
self::eventLog(
|
|
'ICrmOrderActions::uploadOrders', 'IntaroCrm\RestApi::orderUpload',
|
|
$e->getCode() . ': ' . $e->getMessage()
|
|
);
|
|
|
|
if($e->getCode() != 201)
|
|
if($e->getCode() != 460)
|
|
return false;
|
|
} catch (\IntaroCrm\Exception\CurlException $e) {
|
|
self::eventLog(
|
|
'ICrmOrderActions::uploadOrders', 'IntaroCrm\RestApi::orderUpload::CurlException',
|
|
$e->getCode() . ': ' . $e->getMessage()
|
|
);
|
|
|
|
return false;
|
|
}
|
|
}
|
|
|
|
if ($lastOrderId)
|
|
COption::SetOptionString(self::$MODULE_ID, self::$CRM_ORDER_LAST_ID, $lastOrderId);
|
|
|
|
} else {
|
|
|
|
// failed orders upload
|
|
$orderCount = 0;
|
|
$recOrders = array();
|
|
|
|
while ($arOrder = $dbFailedOrder->GetNext()) { // here orders by id asc
|
|
if (is_array($optionsSites))
|
|
if (!empty($optionsSites))
|
|
if (!in_array($arOrder['LID'], $optionsSites))
|
|
continue;
|
|
|
|
$result = self::orderCreate($arOrder, $api, $arParams);
|
|
|
|
if (!$result['order'] || !$result['customer'])
|
|
continue;
|
|
|
|
$orderCount++;
|
|
|
|
$resOrders[] = $result['order'];
|
|
$resCustomers[] = $result['customer'];
|
|
|
|
$recOrders[] = $arOrder['ID'];
|
|
|
|
if ($orderCount >= $pSize) {
|
|
try {
|
|
$customers = $api->customerUpload($resCustomers);
|
|
} catch (\IntaroCrm\Exception\ApiException $e) {
|
|
self::eventLog(
|
|
'ICrmOrderActions::uploadOrders', 'IntaroCrm\RestApi::customerUpload',
|
|
$e->getCode() . ': ' . $e->getMessage()
|
|
);
|
|
|
|
if($e->getCode() != 201)
|
|
if($e->getCode() != 460)
|
|
return false;
|
|
} catch (\IntaroCrm\Exception\CurlException $e) {
|
|
self::eventLog(
|
|
'ICrmOrderActions::uploadOrders', 'IntaroCrm\RestApi::customerUpload::CurlException',
|
|
$e->getCode() . ': ' . $e->getMessage()
|
|
);
|
|
|
|
return false;
|
|
}
|
|
|
|
try {
|
|
$orders = $api->orderUpload($resOrders);
|
|
} catch (\IntaroCrm\Exception\ApiException $e) {
|
|
self::eventLog(
|
|
'ICrmOrderActions::uploadOrders', 'IntaroCrm\RestApi::orderUpload',
|
|
$e->getCode() . ': ' . $e->getMessage()
|
|
);
|
|
|
|
if($e->getCode() != 201)
|
|
if($e->getCode() != 460)
|
|
return false;
|
|
} catch (\IntaroCrm\Exception\CurlException $e) {
|
|
self::eventLog(
|
|
'ICrmOrderActions::uploadOrders', 'IntaroCrm\RestApi::orderUpload::CurlException',
|
|
$e->getCode() . ': ' . $e->getMessage()
|
|
);
|
|
|
|
return false;
|
|
}
|
|
|
|
if (!empty($recOrders)) {
|
|
$failedIds = array_merge(array_diff($failedIds, $recOrders)); // clear success ids
|
|
COption::SetOptionString(self::$MODULE_ID, self::$CRM_ORDER_FAILED_IDS, serialize($failedIds));
|
|
}
|
|
|
|
return true; // end of pack
|
|
}
|
|
}
|
|
if (!empty($resOrders)) {
|
|
try {
|
|
$customers = $api->customerUpload($resCustomers);
|
|
} catch (\IntaroCrm\Exception\ApiException $e) {
|
|
self::eventLog(
|
|
'ICrmOrderActions::uploadOrders', 'IntaroCrm\RestApi::customerUpload',
|
|
$e->getCode() . ': ' . $e->getMessage()
|
|
);
|
|
|
|
if($e->getCode() != 201)
|
|
if($e->getCode() != 460)
|
|
return false;
|
|
} catch (\IntaroCrm\Exception\CurlException $e) {
|
|
self::eventLog(
|
|
'ICrmOrderActions::uploadOrders', 'IntaroCrm\RestApi::customerUpload::CurlException',
|
|
$e->getCode() . ': ' . $e->getMessage()
|
|
);
|
|
|
|
return false;
|
|
}
|
|
|
|
try {
|
|
$orders = $api->orderUpload($resOrders);
|
|
} catch (\IntaroCrm\Exception\ApiException $e) {
|
|
self::eventLog(
|
|
'ICrmOrderActions::uploadOrders', 'IntaroCrm\RestApi::orderUpload',
|
|
$e->getCode() . ': ' . $e->getMessage()
|
|
);
|
|
|
|
if($e->getCode() != 201)
|
|
if($e->getCode() != 460)
|
|
return false;
|
|
} catch (\IntaroCrm\Exception\CurlException $e) {
|
|
self::eventLog(
|
|
'ICrmOrderActions::uploadOrders', 'IntaroCrm\RestApi::orderUpload::CurlException',
|
|
$e->getCode() . ': ' . $e->getMessage()
|
|
);
|
|
|
|
return false;
|
|
}
|
|
}
|
|
|
|
if (!empty($recOrders)) {
|
|
$failedIds = array_merge(array_diff($failedIds, $recOrders)); // clear success ids
|
|
COption::SetOptionString(self::$MODULE_ID, self::$CRM_ORDER_FAILED_IDS, serialize($failedIds));
|
|
}
|
|
}
|
|
|
|
return true; //all ok!
|
|
}
|
|
|
|
protected static function updateCancelProp($arProduct, $value) {
|
|
$propUpdated = false;
|
|
foreach($arProduct['PROPS'] as $key => $item) {
|
|
if ($item['CODE'] == self::CANCEL_PROPERTY_CODE) {
|
|
$arProduct['PROPS'][$key]['VALUE'] = $value;
|
|
$propUpdated = true;
|
|
break;
|
|
}
|
|
}
|
|
|
|
if (!$propUpdated) {
|
|
$arProduct['PROPS'][] = array(
|
|
'NAME' => GetMessage('PRODUCT_CANCEL'),
|
|
'CODE' => self::CANCEL_PROPERTY_CODE,
|
|
'VALUE' => $value,
|
|
'SORT' => 10,
|
|
);
|
|
}
|
|
|
|
return $arProduct;
|
|
}
|
|
|
|
/**
|
|
*
|
|
* History update
|
|
* @global CUser $USER
|
|
* @return boolean
|
|
*/
|
|
public static function orderHistory() {
|
|
global $USER;
|
|
|
|
if(isset($_SESSION["SESS_AUTH"]["USER_ID"]) && $_SESSION["SESS_AUTH"]["USER_ID"]) {
|
|
$realUser = $USER->GetID();
|
|
$USER->Logout();
|
|
} else { // for agent; to add order User
|
|
$rsUser = CUser::GetByLogin('intarocrm');
|
|
|
|
if($arUser = $rsUser->Fetch()) {
|
|
$USER = new CUser;
|
|
$USER->Authorize($arUser['ID']);
|
|
} else {
|
|
$login = 'intarocrm';
|
|
$serverName = 0 < strlen(SITE_SERVER_NAME)? SITE_SERVER_NAME : 'server.com';
|
|
$email = $login . '@' . $serverName;
|
|
$userPassword = randString(10);
|
|
|
|
$user = new CUser;
|
|
$arFields = array(
|
|
"NAME" => $login,
|
|
"LAST_NAME" => $login,
|
|
"EMAIL" => $email,
|
|
"LOGIN" => $login,
|
|
"LID" => "ru",
|
|
"ACTIVE" => "Y",
|
|
"GROUP_ID" => array(2),
|
|
"PASSWORD" => $userPassword,
|
|
"CONFIRM_PASSWORD" => $userPassword
|
|
);
|
|
|
|
$id = $user->Add($arFields);
|
|
|
|
if (!$id) {
|
|
self::eventLog('ICrmOrderActions::orderHistory', 'USER', $user->LAST_ERROR);
|
|
return;
|
|
}
|
|
|
|
$USER = new CUser;
|
|
$USER->Authorize($id);
|
|
}
|
|
}
|
|
|
|
if (!CModule::IncludeModule("iblock")) {
|
|
//handle err
|
|
self::eventLog('ICrmOrderActions::orderHistory', 'iblock', 'module not found');
|
|
return true;
|
|
}
|
|
|
|
if (!CModule::IncludeModule("sale")) {
|
|
//handle err
|
|
self::eventLog('ICrmOrderActions::orderHistory', 'sale', 'module not found');
|
|
return true;
|
|
}
|
|
|
|
if (!CModule::IncludeModule("catalog")) {
|
|
//handle err
|
|
self::eventLog('ICrmOrderActions::orderHistory', 'catalog', 'module not found');
|
|
return true;
|
|
}
|
|
|
|
$defaultSiteId = 0;
|
|
$rsSites = CSite::GetList($by, $sort, array('DEF' => 'Y'));
|
|
while ($ar = $rsSites->Fetch()) {
|
|
$defaultSiteId = $ar['LID'];
|
|
break;
|
|
}
|
|
|
|
$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);
|
|
|
|
//saved cat params (crm -> bitrix)
|
|
$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)));
|
|
$optionsSites = unserialize(COption::GetOptionString(self::$MODULE_ID, self::$CRM_ORDER_SITES, 0));
|
|
$optionsOrderProps = unserialize(COption::GetOptionString(self::$MODULE_ID, self::$CRM_ORDER_PROPS, 0));
|
|
|
|
$api = new IntaroCrm\RestApi($api_host, $api_key);
|
|
|
|
$dateStart = COption::GetOptionString(self::$MODULE_ID, self::$CRM_ORDER_HISTORY_DATE, null);
|
|
|
|
if(!$dateStart) {
|
|
$dateStart = new \DateTime();
|
|
$dateStart = $dateStart->format('Y-m-d H:i:s');
|
|
}
|
|
|
|
try {
|
|
$orderHistory = $api->orderHistory($dateStart);
|
|
} catch (\IntaroCrm\Exception\ApiException $e) {
|
|
self::eventLog(
|
|
'ICrmOrderActions::orderHistory', 'IntaroCrm\RestApi::orderHistory',
|
|
$e->getCode() . ': ' . $e->getMessage()
|
|
);
|
|
|
|
return true;
|
|
} catch (\IntaroCrm\Exception\CurlException $e) {
|
|
self::eventLog(
|
|
'ICrmOrderActions::orderHistory', 'IntaroCrm\RestApi::orderHistory::CurlException',
|
|
$e->getCode() . ': ' . $e->getMessage()
|
|
);
|
|
|
|
return true;
|
|
}
|
|
|
|
$dateFinish = $api->getGeneratedAt();
|
|
|
|
$GLOBALS['INTARO_CRM_FROM_HISTORY'] = true;
|
|
|
|
// pushing existing orders
|
|
foreach ($orderHistory as $order) {
|
|
|
|
if(!isset($order['externalId']) || !$order['externalId']) {
|
|
|
|
// custom orderType functunion
|
|
if(function_exists('intarocrm_set_order_type')) {
|
|
$orderType = intarocrm_set_order_type($order);
|
|
if($orderType)
|
|
$optionsOrderTypes[$order['orderType']] = $orderType;
|
|
else {
|
|
$dbOrderTypesList = CSalePersonType::GetList(
|
|
array(
|
|
"SORT" => "ASC",
|
|
"NAME" => "ASC"
|
|
),
|
|
array(
|
|
"ACTIVE" => "Y",
|
|
),
|
|
false,
|
|
false,
|
|
array()
|
|
);
|
|
|
|
if ($arOrderTypesList = $dbOrderTypesList->Fetch())
|
|
$optionsOrderTypes[$order['orderType']] = $arOrderTypesList['ID'];
|
|
|
|
}
|
|
}
|
|
|
|
// we dont need new orders without any customers (can check only for externalId)
|
|
if(!isset($order['customer']['externalId']) && !$order['customer']['externalId']) {
|
|
if (!$order['customer']['email']) {
|
|
$login = 'user_' . (microtime(true) * 10000) . mt_rand(1, 1000);
|
|
$server_name = 0 < strlen(SITE_SERVER_NAME)?
|
|
SITE_SERVER_NAME : 'server.com';
|
|
$order['customer']['email'] = $login . '@' . $server_name;
|
|
$registerNewUser = true;
|
|
} else {
|
|
// if email already used
|
|
$dbUser = CUser::GetList(($by = 'ID'), ($sort = 'ASC'), array('=EMAIL' => $order['email']));
|
|
if ($dbUser->SelectedRowsCount() == 0) {
|
|
$login = $order['customer']['email'];
|
|
$registerNewUser = true;
|
|
} elseif ($dbUser->SelectedRowsCount() == 1) {
|
|
$arUser = $dbUser->Fetch();
|
|
$registeredUserID = $arUser['ID'];
|
|
} else {
|
|
$login = 'user_' . (microtime(true) * 10000) . mt_rand(1, 1000);
|
|
$registerNewUser = true;
|
|
}
|
|
}
|
|
if($registerNewUser) {
|
|
$useCaptcha = COption::GetOptionString('main', 'captcha_registration', 'N');
|
|
if ($useCaptcha == 'Y')
|
|
COption::SetOptionString('main', 'captcha_registration', 'N');
|
|
$userPassword = randString(10);
|
|
$newUser = $USER->Register($login, $order['customer']['firstName'], $order['customer']['lastName'],
|
|
$userPassword, $userPassword, $order['customer']['email']);
|
|
if ($useCaptcha == 'Y')
|
|
COption::SetOptionString('main', 'captcha_registration', 'Y');
|
|
if ($newUser['TYPE'] == 'ERROR') {
|
|
self::eventLog('ICrmOrderActions::orderHistory', 'CUser::Register', $newUser['MESSAGE']);
|
|
continue;
|
|
} else {
|
|
$registeredUserID = $USER->GetID();
|
|
$USER->Logout();
|
|
}
|
|
}
|
|
|
|
$order['customer']['externalId'] = $registeredUserID;
|
|
}
|
|
|
|
try {
|
|
$api->customerFixExternalIds(array(array('id' => $order['customer']['id'], 'externalId' => $order['customer']['externalId'])));
|
|
} catch (\IntaroCrm\Exception\ApiException $e) {
|
|
self::eventLog(
|
|
'ICrmOrderActions::orderHistory', 'IntaroCrm\RestApi::customerFixExternalIds',
|
|
$e->getCode() . ': ' . $e->getMessage()
|
|
);
|
|
|
|
continue;
|
|
} catch (\IntaroCrm\Exception\CurlException $e) {
|
|
self::eventLog(
|
|
'ICrmOrderActions::orderHistory', 'IntaroCrm\RestApi::customerFixExternalIds::CurlException',
|
|
$e->getCode() . ': ' . $e->getMessage()
|
|
);
|
|
|
|
continue;
|
|
}
|
|
|
|
// new order
|
|
$newOrderFields = array(
|
|
'LID' => $defaultSiteId,
|
|
'PERSON_TYPE_ID' => $optionsOrderTypes[$order['orderType']],
|
|
'PAYED' => 'N',
|
|
'CANCELED' => 'N',
|
|
'STATUS_ID' => 'N',
|
|
'PRICE' => 0,
|
|
'CURRENCY' => 'RUB',
|
|
'USER_ID' => $order['customer']['externalId'],
|
|
'PAY_SYSTEM_ID' => 0,
|
|
'PRICE_DELIVERY' => 0,
|
|
'DELIVERY_ID' => 0,
|
|
'DISCOUNT_VALUE' => 0,
|
|
'USER_DESCRIPTION' => ''
|
|
);
|
|
|
|
if(isset($order['number']) && $order['number'])
|
|
$GLOBALS['ICRM_ACCOUNT_NUMBER'] = $order['number'];
|
|
|
|
$order['externalId'] = CSaleOrder::Add($newOrderFields);
|
|
|
|
if(isset($GLOBALS['ICRM_ACCOUNT_NUMBER']))
|
|
unset($GLOBALS['ICRM_ACCOUNT_NUMBER']);
|
|
|
|
try {
|
|
$api->orderFixExternalIds(array(array('id' => $order['id'], 'externalId' => $order['externalId'])));
|
|
} catch (\IntaroCrm\Exception\ApiException $e) {
|
|
self::eventLog(
|
|
'ICrmOrderActions::orderHistory', 'IntaroCrm\RestApi::orderFixExternalIds',
|
|
$e->getCode() . ': ' . $e->getMessage()
|
|
);
|
|
|
|
continue;
|
|
} catch (\IntaroCrm\Exception\CurlException $e) {
|
|
self::eventLog(
|
|
'ICrmOrderActions::orderHistory', 'IntaroCrm\RestApi::orderFixExternalIds::CurlException',
|
|
$e->getCode() . ': ' . $e->getMessage()
|
|
);
|
|
|
|
continue;
|
|
}
|
|
}
|
|
|
|
if(isset($order['externalId']) && $order['externalId']) {
|
|
|
|
// custom orderType functunion
|
|
if(function_exists('intarocrm_set_order_type')) {
|
|
$orderType = intarocrm_set_order_type($order);
|
|
if($orderType)
|
|
$optionsOrderTypes[$order['orderType']] = $orderType;
|
|
else {
|
|
$dbOrderTypesList = CSalePersonType::GetList(
|
|
array(
|
|
"SORT" => "ASC",
|
|
"NAME" => "ASC"
|
|
),
|
|
array(
|
|
"ACTIVE" => "Y",
|
|
),
|
|
false,
|
|
false,
|
|
array()
|
|
);
|
|
|
|
if ($arOrderTypesList = $dbOrderTypesList->Fetch())
|
|
$optionsOrderTypes[$order['orderType']] = $arOrderTypesList['ID'];
|
|
|
|
}
|
|
}
|
|
|
|
$arFields = CSaleOrder::GetById($order['externalId']);
|
|
|
|
// incorrect order
|
|
if(!$arFields || empty($arFields))
|
|
continue;
|
|
|
|
$LID = $arFields['LID'];
|
|
$userId = $arFields['USER_ID'];
|
|
|
|
if(isset($order['customer']['externalId']) && $order['customer']['externalId'])
|
|
$userId = $order['customer']['externalId'];
|
|
|
|
$rsOrderProps = CSaleOrderPropsValue::GetList(array(), array('ORDER_ID' => $arFields['ID']));
|
|
|
|
while ($ar = $rsOrderProps->Fetch()) {
|
|
if (isset($order['deliveryAddress']) && $order['deliveryAddress']) {
|
|
switch ($ar['CODE']) {
|
|
case $optionsOrderProps[$arFields['PERSON_TYPE_ID']]['index']: if (isset($order['deliveryAddress']['index']))
|
|
CSaleOrderPropsValue::Update($ar['ID'], array('VALUE' => self::fromJSON($order['deliveryAddress']['index'])));
|
|
break;
|
|
case ($ar['CODE'] == 'CITY') or ($ar['CODE'] == 'LOCATION'): if (isset($order['deliveryAddress']['city'])) {
|
|
$prop = CSaleOrderProps::GetByID($ar['ORDER_PROPS_ID']);
|
|
|
|
if($prop['TYPE'] == 'LOCATION') {
|
|
$cityId = self::getLocationCityId(self::fromJSON($order['deliveryAddress']['city']));
|
|
if (!$cityId)
|
|
break;
|
|
|
|
CSaleOrderPropsValue::Update($ar['ID'], array('VALUE' => $cityId));
|
|
break;
|
|
}
|
|
|
|
CSaleOrderPropsValue::Update($ar['ID'], array('VALUE' => self::fromJSON($order['deliveryAddress']['city'])));
|
|
}
|
|
break;
|
|
case $optionsOrderProps[$arFields['PERSON_TYPE_ID']]['text']: if (isset($order['deliveryAddress']['text']))
|
|
CSaleOrderPropsValue::Update($ar['ID'], array('VALUE' => self::fromJSON($order['deliveryAddress']['text'])));
|
|
break;
|
|
}
|
|
|
|
if (count($optionsOrderProps[$arFields['PERSON_TYPE_ID']]) > 4) {
|
|
switch ($ar['CODE']) {
|
|
/* case $optionsOrderProps[$arFields['PERSON_TYPE_ID']]['country']: $resOrderDeliveryAddress['country'] = self::toJSON($ar['VALUE']);
|
|
break;
|
|
case $optionsOrderProps[$arFields['PERSON_TYPE_ID']]['region']: $resOrderDeliveryAddress['region'] = self::toJSON($ar['VALUE']);
|
|
break;
|
|
case $optionsOrderProps[$arFields['PERSON_TYPE_ID']]['city']: $resOrderDeliveryAddress['city'] = self::toJSON($ar['VALUE']);
|
|
break; */
|
|
case $optionsOrderProps[$arFields['PERSON_TYPE_ID']]['street']: if (isset($order['deliveryAddress']['street']))
|
|
CSaleOrderPropsValue::Update($ar['ID'], array('VALUE' => self::fromJSON($order['deliveryAddress']['street'])));
|
|
break;
|
|
case $optionsOrderProps[$arFields['PERSON_TYPE_ID']]['building']: if (isset($order['deliveryAddress']['building']))
|
|
CSaleOrderPropsValue::Update($ar['ID'], array('VALUE' => self::fromJSON($order['deliveryAddress']['building'])));
|
|
break;
|
|
case $optionsOrderProps[$arFields['PERSON_TYPE_ID']]['flat']: if (isset($order['deliveryAddress']['flat']))
|
|
CSaleOrderPropsValue::Update($ar['ID'], array('VALUE' => self::fromJSON($order['deliveryAddress']['flat'])));
|
|
break;
|
|
case $optionsOrderProps[$arFields['PERSON_TYPE_ID']]['intercomcode']: if (isset($order['deliveryAddress']['intercomcode']))
|
|
CSaleOrderPropsValue::Update($ar['ID'], array('VALUE' => self::fromJSON($order['deliveryAddress']['intercomcode'])));
|
|
break;
|
|
case $optionsOrderProps[$arFields['PERSON_TYPE_ID']]['floor']: if (isset($order['deliveryAddress']['floor']))
|
|
CSaleOrderPropsValue::Update($ar['ID'], array('VALUE' => self::fromJSON($order['deliveryAddress']['floor'])));
|
|
break;
|
|
case $optionsOrderProps[$arFields['PERSON_TYPE_ID']]['block']: if (isset($order['deliveryAddress']['block']))
|
|
CSaleOrderPropsValue::Update($ar['ID'], array('VALUE' => self::fromJSON($order['deliveryAddress']['block'])));
|
|
break;
|
|
case $optionsOrderProps[$arFields['PERSON_TYPE_ID']]['house']: if (isset($order['deliveryAddress']['house']))
|
|
CSaleOrderPropsValue::Update($ar['ID'], array('VALUE' => self::fromJSON($order['deliveryAddress']['house'])));
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
|
|
switch ($ar['CODE']) {
|
|
case $optionsOrderProps[$arFields['PERSON_TYPE_ID']]['fio']:
|
|
if (isset($order['firstName']))
|
|
$contactName['firstName'] = self::fromJSON($order['firstName']);
|
|
if (isset($order['lastName']))
|
|
$contactName['lastName'] = self::fromJSON($order['lastName']);
|
|
if (isset($order['patronymic']))
|
|
$contactName['patronymic'] = self::fromJSON($order['patronymic']);
|
|
|
|
if (!isset($contactName) || empty($contactName))
|
|
break;
|
|
|
|
CSaleOrderPropsValue::Update($ar['ID'], array('VALUE' => implode(" ", $contactName)));
|
|
break;
|
|
case $optionsOrderProps[$arFields['PERSON_TYPE_ID']]['phone']: if (isset($order['phone']))
|
|
CSaleOrderPropsValue::Update($ar['ID'], array('VALUE' => self::fromJSON($order['phone'])));
|
|
break;
|
|
case $optionsOrderProps[$arFields['PERSON_TYPE_ID']]['email']: if (isset($order['email']))
|
|
CSaleOrderPropsValue::Update($ar['ID'], array('VALUE' => self::fromJSON($order['email'])));
|
|
break;
|
|
}
|
|
|
|
}
|
|
|
|
// here check if smth wasnt added or new propetties
|
|
if (isset($order['deliveryAddress']) && $order['deliveryAddress']) {
|
|
if (isset($order['deliveryAddress']['index']))
|
|
self::addOrderProperty($optionsOrderProps[$arFields['PERSON_TYPE_ID']]['index'],
|
|
self::fromJSON($order['deliveryAddress']['index']), $order['externalId']);
|
|
|
|
if (isset($order['deliveryAddress']['city'])) {
|
|
self::addOrderProperty($optionsOrderProps[$arFields['PERSON_TYPE_ID']]['city'], self::fromJSON($order['deliveryAddress']['city']), $order['externalId']);
|
|
self::addOrderProperty('CITY', self::fromJSON($order['deliveryAddress']['city']), $order['externalId']);
|
|
|
|
$cityId = self::getLocationCityId(self::fromJSON($order['deliveryAddress']['city']));
|
|
if ($cityId)
|
|
self::addOrderProperty('LOCATION', $cityId, $order['externalId']);
|
|
else
|
|
self::addOrderProperty('LOCATION', 0, $order['externalId']);
|
|
}
|
|
|
|
if (isset($order['deliveryAddress']['text']))
|
|
self::addOrderProperty($optionsOrderProps[$arFields['PERSON_TYPE_ID']]['text'], self::fromJSON($order['deliveryAddress']['text']), $order['externalId']);
|
|
|
|
if (count($optionsOrderProps[$arFields['PERSON_TYPE_ID']]) > 4) {
|
|
if (isset($order['deliveryAddress']['street']))
|
|
self::addOrderProperty($optionsOrderProps[$arFields['PERSON_TYPE_ID']]['street'],
|
|
self::fromJSON($order['deliveryAddress']['street']), $order['externalId']);
|
|
|
|
if (isset($order['deliveryAddress']['building']))
|
|
self::addOrderProperty($optionsOrderProps[$arFields['PERSON_TYPE_ID']]['building'],
|
|
self::fromJSON($order['deliveryAddress']['bulding']), $order['externalId']);
|
|
|
|
if (isset($order['deliveryAddress']['flat']))
|
|
self::addOrderProperty($optionsOrderProps[$arFields['PERSON_TYPE_ID']]['flat'],
|
|
self::fromJSON($order['deliveryAddress']['flat']), $order['externalId']);
|
|
|
|
if (isset($order['deliveryAddress']['intercomcode']))
|
|
self::addOrderProperty($optionsOrderProps[$arFields['PERSON_TYPE_ID']]['intercomcode'],
|
|
self::fromJSON($order['deliveryAddress']['intercomcode']), $order['externalId']);
|
|
|
|
if (isset($order['deliveryAddress']['floor']))
|
|
self::addOrderProperty($optionsOrderProps[$arFields['PERSON_TYPE_ID']]['floor'],
|
|
self::fromJSON($order['deliveryAddress']['floor']), $order['externalId']);
|
|
|
|
if (isset($order['deliveryAddress']['block']))
|
|
self::addOrderProperty($optionsOrderProps[$arFields['PERSON_TYPE_ID']]['block'],
|
|
self::fromJSON($order['deliveryAddress']['block']), $order['externalId']);
|
|
|
|
if (isset($order['deliveryAddress']['house']))
|
|
self::addOrderProperty($optionsOrderProps[$arFields['PERSON_TYPE_ID']]['house'],
|
|
self::fromJSON($order['deliveryAddress']['house']), $order['externalId']);
|
|
}
|
|
}
|
|
|
|
if (isset($order['phone']))
|
|
self::addOrderProperty($optionsOrderProps[$arFields['PERSON_TYPE_ID']]['phone'],
|
|
self::fromJSON($order['phone']), $order['externalId']);
|
|
|
|
if (isset($order['email']))
|
|
self::addOrderProperty($optionsOrderProps[$arFields['PERSON_TYPE_ID']]['email'],
|
|
self::fromJSON($order['email']), $order['externalId']);
|
|
|
|
if (isset($order['firstName']))
|
|
$contactName['firstName'] = self::fromJSON($order['firstName']);
|
|
if (isset($order['lastName']))
|
|
$contactName['lastName'] = self::fromJSON($order['lastName']);
|
|
if (isset($order['patronymic']))
|
|
$contactName['patronymic'] = self::fromJSON($order['patronymic']);
|
|
|
|
if (isset($contactName) && !empty($contactName))
|
|
self::addOrderProperty($optionsOrderProps[$arFields['PERSON_TYPE_ID']]['fio'],
|
|
implode(" ", $contactName), $order['externalId']);
|
|
|
|
foreach($order['items'] as $item) {
|
|
// del from basket
|
|
if(isset($item['deleted']) && $item['deleted']) {
|
|
$p = CSaleBasket::GetList(
|
|
array('PRODUCT_ID' => 'ASC'),
|
|
array('ORDER_ID' => $order['externalId'], 'PRODUCT_ID' => $item['id']))->Fetch();
|
|
|
|
if($p)
|
|
CSaleBasket::Delete($p['ID']);
|
|
|
|
continue;
|
|
}
|
|
|
|
if(!isset($item['offer']) && !$item['offer']['externalId'])
|
|
continue;
|
|
|
|
$p = CSaleBasket::GetList(
|
|
array('PRODUCT_ID' => 'ASC'),
|
|
array('ORDER_ID' => $order['externalId'], 'PRODUCT_ID' => $item['offer']['externalId'])
|
|
)->Fetch();
|
|
|
|
if (!$p) {
|
|
$p = CIBlockElement::GetByID($item['offer']['externalId'])->Fetch();
|
|
// select iblock to obtain an CATALOG_XML_ID
|
|
$iblock = CIBlock::GetByID($p['IBLOCK_ID'])->Fetch();
|
|
$p['CATALOG_XML_ID'] = $iblock['XML_ID'];
|
|
// product field XML_ID is called PRODUCT_XML_ID in basket
|
|
$p['PRODUCT_XML_ID'] = $p['XML_ID'];
|
|
unset($p['XML_ID']);
|
|
}
|
|
else {
|
|
//for basket props updating (in props we save cancel status)
|
|
$propResult = CSaleBasket::GetPropsList(
|
|
array(''),
|
|
array('BASKET_ID' => $p['ID']),
|
|
false,
|
|
false,
|
|
array('NAME', 'CODE', 'VALUE', 'SORT')
|
|
);
|
|
|
|
while($r = $propResult->Fetch()) {
|
|
$p['PROPS'][] = $r;
|
|
}
|
|
}
|
|
|
|
// change existing basket items
|
|
$arProduct = array();
|
|
|
|
// create new
|
|
if(isset($item['created']) && $item['created']) {
|
|
|
|
$productPrice = GetCatalogProductPrice($item['offer']['externalId'], 1);
|
|
|
|
$arProduct = array(
|
|
'FUSER_ID' => $userId,
|
|
'ORDER_ID' => $order['externalId'],
|
|
'QUANTITY' => $item['quantity'],
|
|
'CURRENCY' => $productPrice['CURRENCY'],
|
|
'LID' => $LID,
|
|
'PRODUCT_ID' => $item['offer']['externalId'],
|
|
'PRODUCT_PRICE_ID' => $p['PRODUCT_PRICE_ID'],
|
|
'WEIGHT' => $p['WEIGHT'],
|
|
'DELAY' => $p['DELAY'],
|
|
'CAN_BUY' => $p['CAN_BUY'],
|
|
'MODULE' => $p['MODULE'],
|
|
'NOTES' => $item['comment'] ?: $p['NOTES'],
|
|
'PRODUCT_PROVIDER_CLASS' => $p['PRODUCT_PROVIDER_CLASS'],
|
|
'DETAIL_PAGE_URL' => $p['DETAIL_PAGE_URL'],
|
|
'CATALOG_XML_ID' => $p['CATALOG_XML_ID'],
|
|
'PRODUCT_XML_ID' => $p['PRODUCT_XML_ID'],
|
|
'CUSTOM_PRICE' => 'Y'
|
|
);
|
|
|
|
if (isset($item['initialPrice']) && $item['initialPrice'])
|
|
$arProduct['PRICE'] = (double) $item['initialPrice'];
|
|
|
|
if (isset($item['discount'])) {
|
|
$arProduct['DISCOUNT_PRICE'] = $item['discount'];
|
|
}
|
|
|
|
if (isset($item['discountPercent'])) {
|
|
$arProduct['DISCOUNT_VALUE'] = $item['discountPercent'];
|
|
$newPrice = floor ($arProduct['PRICE'] / 100 * (100 - $arProduct['DISCOUNT_VALUE']));
|
|
$arProduct['DISCOUNT_PRICE'] = $arProduct['DISCOUNT_PRICE'] + $arProduct['PRICE'] - $newPrice;
|
|
}
|
|
|
|
if(isset($item['discount']) || isset($item['discountPercent']))
|
|
$arProduct['PRICE'] -= $arProduct['DISCOUNT_PRICE'];
|
|
|
|
if (isset($item['offer']['name']) && $item['offer']['name'])
|
|
$arProduct['NAME'] = self::fromJSON($item['offer']['name']);
|
|
|
|
if (isset($item['isCanceled'])) {
|
|
//for product excluding from order
|
|
$arProduct['PRICE'] = 0;
|
|
$arProduct = self::updateCancelProp($arProduct, 1);
|
|
}
|
|
|
|
CSaleBasket::Add($arProduct);
|
|
continue;
|
|
}
|
|
|
|
$arProduct['PROPS'] = $p['PROPS'];
|
|
|
|
if (!isset($item['isCanceled'])) {
|
|
// update old
|
|
if (isset($item['initialPrice']) && $item['initialPrice'])
|
|
$arProduct['PRICE'] = (double) $item['initialPrice'];
|
|
|
|
if (isset($item['discount'])) {
|
|
$arProduct['DISCOUNT_PRICE'] = $item['discount'];
|
|
}
|
|
|
|
if (isset($item['discountPercent'])) {
|
|
$arProduct['DISCOUNT_VALUE'] = $item['discountPercent'];
|
|
$newPrice = floor ($arProduct['PRICE'] / 100 * (100 - $arProduct['DISCOUNT_VALUE']));
|
|
$arProduct['DISCOUNT_PRICE'] = $arProduct['DISCOUNT_PRICE'] + $arProduct['PRICE'] - $newPrice;
|
|
}
|
|
|
|
if(isset($item['discount']) || isset($item['discountPercent']))
|
|
$arProduct['PRICE'] -= $arProduct['DISCOUNT_PRICE'];
|
|
|
|
$arProduct = self::updateCancelProp($arProduct, 0);
|
|
}
|
|
else {
|
|
//for product excluding from order
|
|
$arProduct['PRICE'] = 0;
|
|
$arProduct = self::updateCancelProp($arProduct, 1);
|
|
}
|
|
|
|
|
|
if (isset($item['quantity']) && $item['quantity'])
|
|
$arProduct['QUANTITY'] = $item['quantity'];
|
|
|
|
if (isset($item['offer']['name']) && $item['offer']['name'])
|
|
$arProduct['NAME'] = self::fromJSON($item['offer']['name']);
|
|
|
|
CSaleBasket::Update($p['ID'], $arProduct);
|
|
CSaleBasket::DeleteAll($userId);
|
|
}
|
|
|
|
if(!isset($order['deliveryCost']))
|
|
$order['deliveryCost'] = $arFields['PRICE_DELIVERY'];
|
|
|
|
if(!isset($order['summ']) || (isset($order['summ']) && !$order['summ'] && $order['summ'] !== 0))
|
|
$order['summ'] = $arFields['PRICE'] - $arFields['PRICE_DELIVERY'];
|
|
|
|
$wasCanaceled = false;
|
|
if($arFields['CANCELED'] == 'Y')
|
|
$wasCanaceled = true;
|
|
|
|
$resultDeliveryTypeId = $optionsDelivTypes[$order['deliveryType']];
|
|
|
|
if(isset($order['deliveryService']) && !empty($order['deliveryService'])) {
|
|
if (strpos($order['deliveryService']['code'], "-") !== false)
|
|
$deliveryServiceCode = explode("-", $order['deliveryService']['code'], 2);
|
|
|
|
if ($deliveryServiceCode)
|
|
$resultDeliveryTypeId = $resultDeliveryTypeId . ':' . $deliveryServiceCode[1];
|
|
}
|
|
|
|
// orderUpdate
|
|
$arFields = self::clearArr(array(
|
|
'PRICE_DELIVERY' => $order['deliveryCost'],
|
|
'PRICE' => $order['summ'] + (double) $order['deliveryCost'],
|
|
'DATE_MARKED' => $order['markDatetime'],
|
|
'USER_ID' => $userId, //$order['customer']
|
|
'PAY_SYSTEM_ID' => $optionsPayTypes[$order['paymentType']],
|
|
//'PAYED' => $optionsPayment[$order['paymentStatus']],
|
|
//'PERSON_TYPE_ID' => $optionsOrderTypes[$order['orderType']],
|
|
'DELIVERY_ID' => $resultDeliveryTypeId,
|
|
'STATUS_ID' => $optionsPayStatuses[$order['status']],
|
|
'REASON_CANCELED' => self::fromJSON($order['statusComment']),
|
|
'USER_DESCRIPTION' => self::fromJSON($order['customerComment']),
|
|
'COMMENTS' => self::fromJSON($order['managerComment'])
|
|
));
|
|
|
|
CSaleOrder::Update($order['externalId'], $arFields);
|
|
|
|
// set STATUS_ID
|
|
if($order['status'] && $optionsPayStatuses[$order['status']])
|
|
CSaleOrder::StatusOrder($order['externalId'], $optionsPayStatuses[$order['status']]);
|
|
|
|
// uncancel order
|
|
if($wasCanaceled && ($optionsPayStatuses[$order['status']] != 'YY'))
|
|
CSaleOrder::CancelOrder($order['externalId'], "N", $order['statusComment']);
|
|
|
|
// cancel order
|
|
if($optionsPayStatuses[$order['status']] == 'YY')
|
|
CSaleOrder::CancelOrder($order['externalId'], "Y", $order['statusComment']);
|
|
|
|
// set PAYED
|
|
if($optionsPayment[$order['paymentStatus']])
|
|
CSaleOrder::PayOrder($order['externalId'], $optionsPayment[$order['paymentStatus']]);
|
|
}
|
|
}
|
|
|
|
if(count($orderHistory))
|
|
COption::SetOptionString(self::$MODULE_ID, self::$CRM_ORDER_HISTORY_DATE, $dateFinish->format('Y-m-d H:i:s'));
|
|
|
|
$USER->Logout();
|
|
if($realUser) $USER->Authorize($realUser);
|
|
|
|
$GLOBALS['INTARO_CRM_FROM_HISTORY'] = false;
|
|
|
|
return true;
|
|
}
|
|
|
|
/**
|
|
*
|
|
* w+ event in bitrix log
|
|
*/
|
|
|
|
public static function eventLog($auditType, $itemId, $description) {
|
|
|
|
CEventLog::Add(array(
|
|
"SEVERITY" => "SECURITY",
|
|
"AUDIT_TYPE_ID" => $auditType,
|
|
"MODULE_ID" => self::$MODULE_ID,
|
|
"ITEM_ID" => $itemId,
|
|
"DESCRIPTION" => $description,
|
|
));
|
|
}
|
|
|
|
/**
|
|
*
|
|
* Agent function
|
|
*
|
|
* @return self name
|
|
*/
|
|
|
|
public static function uploadOrdersAgent() {
|
|
self::uploadOrders();
|
|
$failedIds = unserialize(COption::GetOptionString(self::$MODULE_ID, self::$CRM_ORDER_FAILED_IDS, 0));
|
|
if(is_array($failedIds) && !empty($failedIds))
|
|
self::uploadOrders(50, true); // upload failed orders
|
|
|
|
return 'ICrmOrderActions::uploadOrdersAgent();';
|
|
}
|
|
|
|
/**
|
|
*
|
|
* Agent function
|
|
*
|
|
* @return self name
|
|
*/
|
|
|
|
public static function orderHistoryAgent() {
|
|
self::orderHistory();
|
|
return 'ICrmOrderActions::orderHistoryAgent();';
|
|
}
|
|
|
|
/**
|
|
*
|
|
* creates order or returns array of order and customer for mass upload
|
|
*
|
|
* @param array $arFields
|
|
* @param $api
|
|
* @param $arParams
|
|
* @param $send
|
|
* @return boolean
|
|
* @return array - array('order' = $order, 'customer' => $customer)
|
|
*/
|
|
public static function orderCreate($arFields, $api, $arParams, $send = false) {
|
|
if(!$api || empty($arParams)) { // add cond to check $arParams
|
|
return false;
|
|
}
|
|
|
|
if (empty($arFields)) {
|
|
//handle err
|
|
self::eventLog('ICrmOrderActions::orderCreate', 'empty($arFields)', 'incorrect order');
|
|
|
|
return false;
|
|
}
|
|
|
|
$rsUser = CUser::GetByID($arFields['USER_ID']);
|
|
$arUser = $rsUser->Fetch();
|
|
|
|
$createdAt = new \DateTime($arUser['DATE_REGISTER']);
|
|
$createdAt = $createdAt->format('Y-m-d H:i:s');
|
|
|
|
// push customer (for crm)
|
|
$firstName = self::toJSON($arUser['NAME']);
|
|
$lastName = self::toJSON($arUser['LAST_NAME']);
|
|
$patronymic = self::toJSON($arUser['SECOND_NAME']);
|
|
|
|
// convert encoding for comment
|
|
$statusComment = self::toJson($arFields['REASON_CANCELED']);
|
|
$customerComment = self::toJson($arFields['USER_DESCRIPTION']);
|
|
$managerComment = self::toJson($arFields['COMMENTS']);
|
|
|
|
$phones = array();
|
|
|
|
$phonePersonal = array(
|
|
'number' => self::toJSON($arUser['PERSONAL_PHONE']),
|
|
'type' => 'mobile'
|
|
);
|
|
|
|
if($phonePersonal['number'])
|
|
$phones[] = $phonePersonal;
|
|
|
|
$phoneWork = array(
|
|
'number' => self::toJSON($arUser['WORK_PHONE']),
|
|
'type' => 'work'
|
|
);
|
|
|
|
if($phoneWork['number'])
|
|
$phones[] = $phoneWork;
|
|
|
|
$customer = self::clearArr(array(
|
|
'externalId' => $arFields['USER_ID'],
|
|
'lastName' => $lastName,
|
|
'firstName' => $firstName,
|
|
'patronymic' => $patronymic,
|
|
'phones' => $phones,
|
|
'createdAt' => $createdAt
|
|
));
|
|
|
|
if($send) {
|
|
try {
|
|
$customer = $api->customerEdit($customer);
|
|
} catch (\IntaroCrm\Exception\ApiException $e) {
|
|
self::eventLog(
|
|
'ICrmOrderActions::orderCreate', 'IntaroCrm\RestApi::customerEdit',
|
|
$e->getCode() . ': ' . $e->getMessage()
|
|
);
|
|
|
|
return false;
|
|
} catch (\IntaroCrm\Exception\CurlException $e) {
|
|
self::eventLog(
|
|
'ICrmOrderActions::orderCreate', 'IntaroCrm\RestApi::customerEdit::CurlException',
|
|
$e->getCode() . ': ' . $e->getMessage()
|
|
);
|
|
|
|
return false;
|
|
}
|
|
}
|
|
|
|
// delivery types
|
|
$arId = array();
|
|
if (strpos($arFields['DELIVERY_ID'], ":") !== false)
|
|
$arId = explode(":", $arFields["DELIVERY_ID"]);
|
|
|
|
if ($arId)
|
|
$resultDeliveryTypeId = $arId[0];
|
|
else
|
|
$resultDeliveryTypeId = $arFields['DELIVERY_ID'];
|
|
|
|
// deliveryService
|
|
$deliveryService = array();
|
|
if(count($arId) > 1) {
|
|
$dbDeliveryType = CSaleDeliveryHandler::GetBySID($arId[0]);
|
|
|
|
if ($arDeliveryType = $dbDeliveryType->GetNext()) {
|
|
foreach($arDeliveryType['PROFILES'] as $id => $profile) {
|
|
if($id == $arId[1]) {
|
|
$deliveryService = array(
|
|
'code' => $arId[0] . '-' . $id,
|
|
'name' => $profile['TITLE']
|
|
);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
$resOrder = array();
|
|
$resOrderDeliveryAddress = array();
|
|
$contactNameArr = array();
|
|
|
|
$rsOrderProps = CSaleOrderPropsValue::GetList(array(), array('ORDER_ID' => $arFields['ID']));
|
|
while ($ar = $rsOrderProps->Fetch()) {
|
|
switch ($ar['CODE']) {
|
|
case $arParams['optionsOrderProps'][$arFields['PERSON_TYPE_ID']]['index']: $resOrderDeliveryAddress['index'] = self::toJSON($ar['VALUE']);
|
|
break;
|
|
case 'CITY':
|
|
$prop = CSaleOrderProps::GetByID($ar['ORDER_PROPS_ID']);
|
|
if($prop['TYPE'] == 'LOCATION') {
|
|
$resOrderDeliveryAddress['city'] = CSaleLocation::GetByID($ar['VALUE']);
|
|
$resOrderDeliveryAddress['city'] = self::toJSON($resOrderDeliveryAddress['city']['CITY_NAME_LANG']);
|
|
break;
|
|
}
|
|
$resOrderDeliveryAddress['city'] = self::toJSON($ar['VALUE']);
|
|
break;
|
|
case $arParams['optionsOrderProps'][$arFields['PERSON_TYPE_ID']]['text']: $resOrderDeliveryAddress['text'] = self::toJSON($ar['VALUE']);
|
|
break;
|
|
case 'LOCATION': if(!isset($resOrderDeliveryAddress['city']) && !$resOrderDeliveryAddress['city']) {
|
|
$prop = CSaleOrderProps::GetByID($ar['ORDER_PROPS_ID']);
|
|
if($prop['TYPE'] == 'LOCATION') {
|
|
$resOrderDeliveryAddress['city'] = CSaleLocation::GetByID($ar['VALUE']);
|
|
$resOrderDeliveryAddress['city'] = self::toJSON($resOrderDeliveryAddress['city']['CITY_NAME_LANG']);
|
|
break;
|
|
}
|
|
$resOrderDeliveryAddress['city'] = self::toJSON($ar['VALUE']);
|
|
break;
|
|
}
|
|
break;
|
|
case $arParams['optionsOrderProps'][$arFields['PERSON_TYPE_ID']]['fio']: $contactNameArr = self::explodeFIO($ar['VALUE']);
|
|
break;
|
|
case $arParams['optionsOrderProps'][$arFields['PERSON_TYPE_ID']]['phone']: $resOrder['phone'] = $ar['VALUE'];
|
|
break;
|
|
case $arParams['optionsOrderProps'][$arFields['PERSON_TYPE_ID']]['email']: $resOrder['email'] = $ar['VALUE'];
|
|
break;
|
|
}
|
|
|
|
if (count($arParams['optionsOrderProps'][$arFields['PERSON_TYPE_ID']]) > 4) {
|
|
switch ($ar['CODE']) {
|
|
/*case $arParams['optionsOrderProps'][$arFields['PERSON_TYPE_ID']]['country']: $resOrderDeliveryAddress['country'] = self::toJSON($ar['VALUE']);
|
|
break;
|
|
case $arParams['optionsOrderProps'][$arFields['PERSON_TYPE_ID']]['region']: $resOrderDeliveryAddress['region'] = self::toJSON($ar['VALUE']);
|
|
break;
|
|
case $arParams['optionsOrderProps'][$arFields['PERSON_TYPE_ID']]['city']: $resOrderDeliveryAddress['city'] = self::toJSON($ar['VALUE']);
|
|
break; */
|
|
case $arParams['optionsOrderProps'][$arFields['PERSON_TYPE_ID']]['street']: $resOrderDeliveryAddress['street'] = self::toJSON($ar['VALUE']);
|
|
break;
|
|
case $arParams['optionsOrderProps'][$arFields['PERSON_TYPE_ID']]['building']: $resOrderDeliveryAddress['building'] = self::toJSON($ar['VALUE']);
|
|
break;
|
|
case $arParams['optionsOrderProps'][$arFields['PERSON_TYPE_ID']]['flat']: $resOrderDeliveryAddress['flat'] = self::toJSON($ar['VALUE']);
|
|
break;
|
|
case $arParams['optionsOrderProps'][$arFields['PERSON_TYPE_ID']]['intercomcode']: $resOrderDeliveryAddress['intercomcode'] = self::toJSON($ar['VALUE']);
|
|
break;
|
|
case $arParams['optionsOrderProps'][$arFields['PERSON_TYPE_ID']]['floor']: $resOrderDeliveryAddress['floor'] = self::toJSON($ar['VALUE']);
|
|
break;
|
|
case $arParams['optionsOrderProps'][$arFields['PERSON_TYPE_ID']]['block']: $resOrderDeliveryAddress['block'] = self::toJSON($ar['VALUE']);
|
|
break;
|
|
case $arParams['optionsOrderProps'][$arFields['PERSON_TYPE_ID']]['house']: $resOrderDeliveryAddress['house'] = self::toJSON($ar['VALUE']);
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
|
|
$items = array();
|
|
|
|
$rsOrderBasket = CSaleBasket::GetList(array('PRODUCT_ID' => 'ASC'), array('ORDER_ID' => $arFields['ID']));
|
|
while ($p = $rsOrderBasket->Fetch()) {
|
|
//for basket props updating (in props we save cancel status)
|
|
$propCancel = CSaleBasket::GetPropsList(
|
|
array(),
|
|
array('BASKET_ID' => $p['ID'], 'CODE' => self::CANCEL_PROPERTY_CODE)
|
|
)->Fetch();
|
|
|
|
if ($propCancel) {
|
|
$propCancel = (int)$propCancel['VALUE'];
|
|
}
|
|
|
|
$pr = CCatalogProduct::GetList(
|
|
array(),
|
|
array('ID' => $p['PRODUCT_ID']),
|
|
false,
|
|
array('nTopCount' => 1)
|
|
)->Fetch();
|
|
|
|
if ($pr)
|
|
$pr = $pr['PURCHASING_PRICE'];
|
|
else
|
|
$pr = '';
|
|
|
|
$item = array(
|
|
'discountPercent' => 0,
|
|
'quantity' => $p['QUANTITY'],
|
|
'productId' => $p['PRODUCT_ID'],
|
|
'productName' => self::toJSON($p['NAME']),
|
|
'comment' => $p['NOTES'],
|
|
);
|
|
|
|
//if it is canceled product don't send price
|
|
if (!$propCancel) {
|
|
$item['initialPrice'] = (double) $p['PRICE'] + (double) $p['DISCOUNT_PRICE'];
|
|
$item['discount'] = $p['DISCOUNT_PRICE'];
|
|
if ($pr) {
|
|
$item['purchasePrice'] = $pr;
|
|
}
|
|
}
|
|
|
|
$items[] = $item;
|
|
}
|
|
|
|
if($arFields['CANCELED'] == 'Y')
|
|
$arFields['STATUS_ID'] = $arFields['CANCELED'].$arFields['CANCELED'];
|
|
|
|
$createdAt = new \DateTime($arFields['DATE_INSERT']);
|
|
$createdAt = $createdAt->format('Y-m-d H:i:s');
|
|
|
|
$resOrder = array(
|
|
'number' => $arFields['ACCOUNT_NUMBER'],
|
|
'phone' => $resOrder['phone'],
|
|
'email' => $resOrder['email'],
|
|
'deliveryCost' => $arFields['PRICE_DELIVERY'],
|
|
'summ' => $arFields['PRICE'],
|
|
'markDateTime' => $arFields['DATE_MARKED'],
|
|
'externalId' => $arFields['ID'],
|
|
'customerId' => $arFields['USER_ID'],
|
|
'paymentType' => $arParams['optionsPayTypes'][$arFields['PAY_SYSTEM_ID']],
|
|
'paymentStatus' => $arParams['optionsPayment'][$arFields['PAYED']],
|
|
'orderType' => $arParams['optionsOrderTypes'][$arFields['PERSON_TYPE_ID']],
|
|
'deliveryType' => $arParams['optionsDelivTypes'][$resultDeliveryTypeId],
|
|
'deliveryService' => ($arParams['optionsDelivTypes'][$resultDeliveryTypeId]) ? $deliveryService : '',
|
|
'status' => $arParams['optionsPayStatuses'][$arFields['STATUS_ID']],
|
|
'statusComment' => $statusComment,
|
|
'customerComment' => $customerComment,
|
|
'managerComment' => $managerComment,
|
|
'createdAt' => $createdAt,
|
|
'deliveryAddress' => $resOrderDeliveryAddress,
|
|
'discount' => $arFields['DISCOUNT_VALUE'],
|
|
'items' => $items
|
|
);
|
|
|
|
|
|
if(isset($arParams['optionsSites']) && is_array($arParams['optionsSites'])
|
|
&& in_array($arFields['LID'], $arParams['optionsSites']))
|
|
$resOrder['site'] = $arFields['LID'];
|
|
|
|
// parse fio
|
|
if(count($contactNameArr) == 1) {
|
|
$resOrder['firstName'] = $contactNameArr[0];
|
|
} else {
|
|
$resOrder['lastName'] = $contactNameArr[0];
|
|
$resOrder['firstName'] = $contactNameArr[1];
|
|
$resOrder['patronymic'] = $contactNameArr[2];
|
|
}
|
|
|
|
// custom orderType functunion
|
|
if(function_exists('intarocrm_get_order_type')) {
|
|
$orderType = intarocrm_get_order_type($arFields);
|
|
if($orderType)
|
|
$resOrder['orderType'] = $orderType;
|
|
else
|
|
$orderType['orderType'] = 'new';
|
|
}
|
|
|
|
$resOrder = self::clearArr($resOrder);
|
|
|
|
if($send) {
|
|
try {
|
|
return $api->orderEdit($resOrder);
|
|
} catch (\IntaroCrm\Exception\ApiException $e) {
|
|
self::eventLog(
|
|
'ICrmOrderActions::orderCreate', 'IntaroCrm\RestApi::orderEdit',
|
|
$e->getCode() . ': ' . $e->getMessage()
|
|
);
|
|
|
|
return false;
|
|
} catch (\IntaroCrm\Exception\CurlException $e) {
|
|
self::eventLog(
|
|
'ICrmOrderActions::orderCreate', 'IntaroCrm\RestApi::orderEdit::CurlException',
|
|
$e->getCode() . ': ' . $e->getMessage()
|
|
);
|
|
|
|
return false;
|
|
}
|
|
}
|
|
|
|
return array(
|
|
'order' => $resOrder,
|
|
'customer' => $customer
|
|
);
|
|
}
|
|
|
|
/**
|
|
* removes all empty fields from arrays
|
|
* working with nested arrs
|
|
*
|
|
* @param array $arr
|
|
* @return array
|
|
*/
|
|
public static function clearArr($arr) {
|
|
if(!$arr || !is_array($arr))
|
|
return false;
|
|
|
|
foreach($arr as $key => $value) {
|
|
if((!($value) && $value !== 0) || (is_array($value) && empty($value)))
|
|
unset($arr[$key]);
|
|
|
|
if(is_array($value) && !empty($value))
|
|
$arr[$key] = self::clearArr($value);
|
|
}
|
|
|
|
return $arr;
|
|
}
|
|
|
|
/**
|
|
*
|
|
* @global $APPLICATION
|
|
* @param $str in SITE_CHARSET
|
|
* @return $str in utf-8
|
|
*/
|
|
public static function toJSON($str) {
|
|
global $APPLICATION;
|
|
|
|
return $APPLICATION->ConvertCharset($str, SITE_CHARSET, 'utf-8');
|
|
}
|
|
|
|
/**
|
|
*
|
|
* @global $APPLICATION
|
|
* @param $str in utf-8
|
|
* @return $str in SITE_CHARSET
|
|
*/
|
|
public static function fromJSON($str) {
|
|
global $APPLICATION;
|
|
|
|
return $APPLICATION->ConvertCharset($str, 'utf-8', SITE_CHARSET);
|
|
}
|
|
|
|
public static function explodeFIO($str) {
|
|
if(!$str)
|
|
return array();
|
|
|
|
$array = explode(" ", self::toJSON($str), 3);
|
|
$newArray = array();
|
|
|
|
foreach($array as $ar) {
|
|
if(!$ar)
|
|
continue;
|
|
|
|
$newArray[] = $ar;
|
|
}
|
|
|
|
return $newArray;
|
|
}
|
|
|
|
public static function addOrderProperty($code, $value, $order) {
|
|
if (!$code)
|
|
return;
|
|
|
|
if (!CModule::IncludeModule('sale'))
|
|
return;
|
|
|
|
if ($arProp = CSaleOrderProps::GetList(array(), array('CODE' => $code))->Fetch()) {
|
|
return CSaleOrderPropsValue::Add(array(
|
|
'NAME' => $arProp['NAME'],
|
|
'CODE' => $arProp['CODE'],
|
|
'ORDER_PROPS_ID' => $arProp['ID'],
|
|
'ORDER_ID' => $order,
|
|
'VALUE' => $value,
|
|
));
|
|
}
|
|
}
|
|
|
|
public static function getLocationCityId($cityName) {
|
|
if(!$cityName)
|
|
return;
|
|
|
|
$dbLocation = CSaleLocation::GetList(
|
|
array(
|
|
"SORT" => "ASC",
|
|
"CITY_NAME_LANG" => "ASC"
|
|
),
|
|
array("LID" => "ru", "CITY_NAME" => $cityName), false, false, array());
|
|
|
|
if($location = $dbLocation->Fetch())
|
|
return $location['ID'];
|
|
}
|
|
} |