Интеграция цен CRM и bitrix

Получение цен из CRM

<?php
class crmPrice {
 public static $token = '**********';//Токен авторизации в CRM
 public static $priceAr = false;

public static function getById($id=false) {
    if (($id !== false) and myint($id,true) and ($id > 0)) {
      if (self::$priceAr === false) {self::getPriceDataFromAPI();}
      if (self::$priceAr and isset(self::$priceAr[$id]))  {
        return self::$priceAr[$id];
      }
    }
    return false;
  }

public static function getPriceDataFromAPI() {
    $headers = array(
      "Content-Type: application/json; charset=utf-8",
      "Authorization: Bearer " . self::$token
    );

$curl = curl_init();
    curl_setopt_array($curl,array(
      CURLOPT_URL => "https://ricbist.tech/api/v7/",
      CURLOPT_RETURNTRANSFER => true,
      CURLOPT_ENCODING => "",
      CURLOPT_FOLLOWLOCATION => true,
      CURLOPT_CUSTOMREQUEST => "POST",
      CURLOPT_POSTFIELDS => "{\"act\": \"get_price_list\"}",
      CURLOPT_HTTPHEADER => $headers
    ));

$response = curl_exec($curl);
    curl_close($curl);
    self::$priceAr = -1;//Значение ошибки получения данных по API, если установлено это значение повторно информация по API запрашивать не будет, а сразу будет возвращён ответ false при запросе цены товара по Id
    if (($obj = json_decode($response)) !== false) {
      self::$priceAr = array();
      foreach ($obj as $key => $productDataItem) {
        if (isset($productDataItem[0]->price_sale)) {
          self::$priceAr[$key] = $productDataItem[0]->price_sale;
        }
      }
      return true;
    }
    return false;
  }
}

Скрипт для crond запускающий процедуру обновления цен.

<?php
require $_SERVER['DOCUMENT_ROOT'].'/bitrix/modules/main/include/prolog_before.php';
 
function myint($var,$string = false) {
 if (is_numeric($var)) {
 if ($string) {
 $var = $var * 1;
 }
 if ($var === ((int) $var)) {
 return true;
 }
 }
 return false;
}
 
require_once "crmprice.php";
 
if(!(CModule::IncludeModule("iblock"))) {exit;}
if(!(CModule::IncludeModule("catalog"))) {exit;}
 
function getPriceArByProductId($productId=false) {
 if (($productId !== false) and myint($productId,true) and ($productId > 0)) {
 $res = CPrice::GetList(array(),array("PRODUCT_ID"=>$productId,"CATALOG_GROUP_ID"=>5));
 if ($arr = $res->Fetch() and is_array($arr) and $arr) {
 return $arr;
 }
 }
 return false;
}
 
function updatePrice($productId=false,$priceId=false,$newPrice=false) {
 if (($productId !== false) and ($newPrice !== false) and myint($productId,true) and ($productId > 0)) {
 if (is_null($priceId) or ($priceId === false)) {
 if ((($priceAr = getPriceArByProductId($productId)) !== false) and is_array($priceAr) and isset($priceAr["ID"])) {$priceId = $priceAr["ID"];} else {return false;}
 }
 $arFields = Array("PRODUCT_ID"=>$productId,"CATALOG_GROUP_ID"=>5,"PRICE"=>$newPrice,"CURRENCY"=>"RUB");
 \Bitrix\Catalog\Model\Price::update($priceId,$arFields);
 return true;
 }
 return false;
}
//4841.00
//updatePrice(10845,NULL,4841.00);
//var_dump(getPriceArByProductId(10845));
 
$arAddProps = array("CRM_ARTICLE_RICBIST");//массив кодов свойств инфоблока
 
$arSelect = Array("ID","NAME");
foreach ($arAddProps as $one) {
 $arSelect[] = "PROPERTY_$one";
}
$arSort = array();
$arFilter = Array("IBLOCK_ID"=>37, "ACTIVE_DATE"=>"Y", "ACTIVE"=>"Y",">PROPERTY_CRM_ARTICLE_RICBIST"=>"0");
$res = CIBlockElement::GetList($arSort, $arFilter, false, Array(), $arSelect);
 
$count = 0;
while ($ob = $res->GetNextElement()) {
 $arFields = $ob->GetFields();
 if (isset($arFields["ID"]) and ((($productIdItem = $arFields["ID"])."") != "") and isset($arFields["NAME"]) and isset($arFields["PROPERTY_CRM_ARTICLE_RICBIST_VALUE"]) and (($arFields["PROPERTY_CRM_ARTICLE_RICBIST_VALUE"]."") != "")) {
 if (($priceItem = crmPrice::getById($arFields["PROPERTY_CRM_ARTICLE_RICBIST_VALUE"])) !== false) {
 if ((($sitePriceAr = getPriceArByProductId($productIdItem)) !== false) and isset($sitePriceAr["ID"]) and isset($sitePriceAr["PRICE"])) {
 $priceIdItem = $sitePriceAr["ID"];
 $sitePriceItem = $sitePriceAr["PRICE"];
 if ($priceItem != $sitePriceItem) {
 if (updatePrice($productIdItem,$priceIdItem,$priceItem)) {
 $count++;
 }
 }
 }
// echo "<tr><td class=\"hostprice\" align=\"center\" width=\"150\">1</td><td class=\"hostprice\" align=\"center\" width=\"450\">${arFields["NAME"]}</td><td class=\"hostprice\" align=\"center\" width=\"150\">${arFields["ID"]}</td><td class=\"hostprice\" align=\"center\" width=\"150\">${arFields["PROPERTY_CRM_ARTICLE_RICBIST_VALUE"]}</td><td class=\"hostprice\" align=\"center\" width=\"150\" style=\"color: green;\">Интегрируется$priceItem</td></tr>";
 
 }
 }
}
 
echo "Обновлено записей цен на товары: $count.";

Получение списка интегрируемых в настоящий момент товаров

Интегрируемыми являются товары у которых проставлено специальное свойство товара bitrix в котором содержится артикул соответствующего товара CRM, для случая когда по введённому артикулу не возможно запросить цену из CRM(например если артикул был указан ошибочно и товара с таким артикулом в CRM нет) планировалось сделать сообщение о ошибке интеграции.

<?php require $_SERVER['DOCUMENT_ROOT'].'/bitrix/modules/main/include/prolog_before.php';if(!(CModule::IncludeModule("iblock"))) {exit;} ?><title>Интеграция цен товаров с CRM Ricbist</title>
<style type="text/css">
BODY {SCROLLBAR-FACE-COLOR: #dee3e7; SCROLLBAR-HIGHLIGHT-COLOR: #ffffff; SCROLLBAR-SHADOW-COLOR: #dee3e7; SCROLLBAR-3DLIGHT-COLOR: #d1d7dc; SCROLLBAR-ARROW-COLOR: #dd6900; SCROLLBAR-TRACK-COLOR: #efefef; SCROLLBAR-DARKSHADOW-COLOR: #98aab1; BACKGROUND-COLOR: #e5e5e5}
A:link {COLOR: #006699}
A:active {COLOR: #006699}
A:visited {COLOR: #006699}
A:hover {COLOR: #dd6900; TEXT-DECORATION: underline}
.text {FONT-FAMILY: Tahoma,sans-serif; FONT-SIZE: 11px; Font-weight: normal; Text-decoration: none; color: #333333; padding: 7px; text-align: justify;}
.copyright {FONT-SIZE: 10px; COLOR: #444444; FONT-FAMILY: Verdana, Arial, Helvetica, sans-serif; LETTER-SPACING: -1px}
A.copyright {COLOR: #444444; TEXT-DECORATION: none}
A.copyright:hover {COLOR: #000000; TEXT-DECORATION: underline}
.hostprice {BORDER-RIGHT: #cccccc 1px solid; BORDER-TOP: #cccccc 1px solid; FONT-SIZE: 11px; BORDER-LEFT: #cccccc 0px solid; BORDER-BOTTOM: #cccccc 0px solid; BACKGROUND-COLOR: white}
TD.hostprice {BORDER-RIGHT: #cccccc 0px solid; BORDER-TOP: #cccccc 0px solid; FONT-SIZE: 11px; BORDER-LEFT: #cccccc 1px solid; BORDER-BOTTOM: #cccccc 1px solid; BACKGROUND-COLOR: #f8f8f8}
TD.hostprice2 {BORDER-RIGHT: #cccccc 0px solid; BORDER-TOP: #cccccc 0px solid; FONT-SIZE: 11px; BORDER-LEFT: #cccccc 1px solid; COLOR: black; BORDER-BOTTOM: #cccccc 1px solid; BACKGROUND-COLOR: #dedede}
</style>
<center>
 
<table class="text" border="0" bordercolordark="#ffffff" bordercolor="#006699" cellspacing="0" cellpadding="2" width="1050">
 <tr>
 <td width="1098" bgcolor="#ffffff" height="62"><center>Интеграция цен товаров с CRM Ricbist Список интегрируемых товаров</center></td>
 </tr>
 <tr>
 <td width="1098">
 
<center>Внимание! При наличии проблем проверьте корректность указания артикула для товара из CRM.</center> 
 
<table class="hostprice" cellspacing="0" cellpadding="3" width="1050">
<tr><td class="hostprice2" align="center" width="150">Порядковый номер</td><td class="hostprice2" align="center" width="450">Название товара</td><td class="hostprice2" align="center" width="150">BitrixId</td><td class="hostprice2" align="center" width="150">RicbistCRMArticle</td><td class="hostprice2" align="center" width="150">Состояние</td></tr>
<?php
$arAddProps = array("CRM_ARTICLE_RICBIST");// массив кодов свойств инфоблока торговых предложений которые необходимы для вывода на карточке товара
 
$arSelect = Array("ID","NAME");
foreach ($arAddProps as $one) {
 $arSelect[] = "PROPERTY_$one";
}$arSelect[] = "ID";
$arSort = array();
$arFilter = Array("IBLOCK_ID"=>37, "ACTIVE_DATE"=>"Y", "ACTIVE"=>"Y",">PROPERTY_CRM_ARTICLE_RICBIST"=>"0");
$res = CIBlockElement::GetList($arSort, $arFilter, false, Array(), $arSelect);
 
//echo "<table>\n";
//echo "<tr><td>Номер</td><td>Название товара</td><td>BitrixId</td><td>RicbistCRMArticle</td><td>Состояние</td></tr>\n";
$itemNum = 0;
while ($ob = $res->GetNextElement()) {
 $arFields = $ob->GetFields();
 if (isset($arFields["ID"]) and (($arFields["ID"]."") != "") and isset($arFields["NAME"]) and isset($arFields["PROPERTY_CRM_ARTICLE_RICBIST_VALUE"]) and (($arFields["PROPERTY_CRM_ARTICLE_RICBIST_VALUE"]."") != "")) {
 $itemNum++;
 echo "<tr><td class=\"hostprice\" align=\"center\" width=\"150\">$itemNum</td><td class=\"hostprice\" align=\"center\" width=\"450\">${arFields["NAME"]}</td><td class=\"hostprice\" align=\"center\" width=\"150\">${arFields["ID"]}</td><td class=\"hostprice\" align=\"center\" width=\"150\">${arFields["PROPERTY_CRM_ARTICLE_RICBIST_VALUE"]}</td><td class=\"hostprice\" align=\"center\" width=\"150\" style=\"color: green;\">Интегрируется</td></tr>";
// echo "<tr><td>$itemNum</td><td>${arFields["NAME"]}</td><td>${arFields["ID"]}</td><td>${arFields["PROPERTY_CRM_ARTICLE_RICBIST_VALUE"]}</td><td style=\"color: green;\">Интегрируется</td></tr>\n";
 }
}
echo "</table>\n";

Получение цен из CRM

Скрипт для crond запускающий процедуру обновления цен.

Получение списка интегрируемых в настоящий момент товаров

Комментарии