RetailCRM-Mirror/magento-module
1
0
Fork 0
mirror of synced 2024-11-25 06:26:07 +03:00
Code Issues Projects Releases Wiki Activity

regression, cron, icml

Browse Source
This commit is contained in:
Alex Lushpai 2015-02-17 18:09:35 +03:00
parent 26dcf45071
commit ba08ed414a
3 changed files with 162 additions and 126 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

258
app/code/community/Retailcrm/Retailcrm/Model/Exchange.php
View File

@ -30,7 +30,7 @@ class Retailcrm_Retailcrm_Model_Exchange
$this->_config = Mage::getStoreConfig('retailcrm', $order->getStoreId()); $this->_config = Mage::getStoreConfig('retailcrm', $order->getStoreId());
$statuses = array_flip(array_filter($this->_config['status'])); $statuses = array_flip(array_filter($this->_config['status']));
$paymentsStatuses = array_flip(array_filter($this->_config['paymentstatuses'])); $paymentsStatuses = array_flip(array_filter($this->_config['paymentstatus']));
$payments = array_filter($this->_config['payment']); $payments = array_filter($this->_config['payment']);
$shippings = array_filter($this->_config['shipping']); $shippings = array_filter($this->_config['shipping']);
@ -93,18 +93,132 @@ class Retailcrm_Retailcrm_Model_Exchange
); );
try { try {
$this->_api->ordersCreate($preparedOrder); $response = $this->_api->ordersCreate($preparedOrder);
if ($response->isSuccessful() && 201 === $response->getStatusCode()) {
Mage::log($response->id);
} else {
Mage::log(
sprintf(
"Order create error: [HTTP status %s] %s",
$response->getStatusCode(),
$response->getErrorMsg()
)
);
if (isset($response['errors'])) {
Mage::log(implode(' :: ', $response['errors']));
}
}
} catch (Retailcrm_Retailcrm_Model_Exception_CurlException $e) { } catch (Retailcrm_Retailcrm_Model_Exception_CurlException $e) {
Mage::log($e->getMessage()); Mage::log($e->getMessage());
} }
} }
/** /**
* @param mixed $order * @param $customer
* * @return mixed
* @return bool
*/ */
public function orderEdit($order) private function setCustomerId($customer)
{
$customerId = $this->searchCustomer($customer);
if (is_array($customerId) && !empty($customerId)) {
if ($customerId['success']) {
return $customerId['result'];
} else {
$this->fixCustomer($customerId['result'], $customer['externalId']);
return $customer['externalId'];
}
} else {
$this->createCustomer(
array(
'externalId' => $customer['externalId'],
'firstName' => $customer['firstName'],
'lastName' => isset($customer['lastName']) ? $customer['lastName'] : '',
'patronymic' => isset($customer['patronymic']) ? $customer['patronymic'] : '',
'phones' => isset($customer['phone']) ? array($customer['phone']) : array(),
)
);
return $customer['externalId'];
}
}
/**
* @param $data
* @return array|bool
*/
private function searchCustomer($data)
{
try {
$customers = $this->_api->customersList(
array(
'name' => isset($data['phone']) ? $data['phone'] : $data['name'],
'email' => $data['email']
),
1,
100
);
} catch (Retailcrm_Retailcrm_Model_Exception_CurlException $e) {
Mage::log($e->getMessage());
}
if ($customers->isSuccessful()) {
return (count($customers['customers']) > 0)
? $this->defineCustomer($customers['customers'])
: false
;
}
}
private function createCustomer($customer)
{
try {
$this->_api->customersCreate($customer);
} catch (Retailcrm_Retailcrm_Model_Exception_CurlException $e) {
Mage::log('RestApi::CustomersCreate::Curl: ' . $e->getMessage());
}
}
private function fixCustomer($id, $extId)
{
try {
$this->_api->customersFixExternalIds(
array(
array(
'id' => $id,
'externalId' => $extId
)
)
);
} catch (Retailcrm_Retailcrm_Model_Exception_CurlException $e) {
Mage::log('RestApi::CustomersFixExternalIds::Curl: ' . $e->getMessage());
}
}
private function defineCustomer($searchResult)
{
$result = '';
foreach ($searchResult as $customer) {
if (isset($customer['externalId']) && $customer['externalId'] != '') {
$result = $customer['externalId'];
break;
}
}
return ($result != '')
? array('success' => true, 'result' => $result)
: array('success' => false, 'result' => $searchResult[0]['id']);
}
/**
* @param $data
* @return bool
* @internal param mixed $order
*
*/
/*public function orderEdit($order)
{ {
$this->_config = Mage::getStoreConfig('retailcrm', $order->getStoreId()); $this->_config = Mage::getStoreConfig('retailcrm', $order->getStoreId());
@ -163,9 +277,9 @@ class Retailcrm_Retailcrm_Model_Exchange
} catch (Retailcrm_Retailcrm_Model_Exception_CurlException $e) { } catch (Retailcrm_Retailcrm_Model_Exception_CurlException $e) {
Mage::log($e->getMessage()); Mage::log($e->getMessage());
} }
} }*/
public function processOrders($orders, $nocheck = false) /*public function processOrders($orders, $nocheck = false)
{ {
if (!$nocheck) { if (!$nocheck) {
@ -211,9 +325,9 @@ class Retailcrm_Retailcrm_Model_Exchange
return false; return false;
} }
} }
} }*/
public function orderHistory() /*public function orderHistory()
{ {
try { try {
$orders = $this->_api->ordersHistory(new DateTime($this->getDate($this->historyLog))); $orders = $this->_api->ordersHistory(new DateTime($this->getDate($this->historyLog)));
@ -223,9 +337,13 @@ class Retailcrm_Retailcrm_Model_Exchange
Mage::log('RestApi::orderHistory::Curl: ' . $e->getMessage()); Mage::log('RestApi::orderHistory::Curl: ' . $e->getMessage());
return false; return false;
} }
} }*/
public function orderFixExternalIds($data) /**
* @param $data
* @return bool
*/
/*public function orderFixExternalIds($data)
{ {
try { try {
$this->_api->ordersFixExternalIds($data); $this->_api->ordersFixExternalIds($data);
@ -235,9 +353,13 @@ class Retailcrm_Retailcrm_Model_Exchange
} }
return true; return true;
} }*/
public function customerFixExternalIds($data) /**
* @param $data
* @return bool
*/
/*public function customerFixExternalIds($data)
{ {
try { try {
$this->_api->customersFixExternalIds($data); $this->_api->customersFixExternalIds($data);
@ -247,7 +369,7 @@ class Retailcrm_Retailcrm_Model_Exchange
} }
return true; return true;
} }*/
/** /**
* Export References to CRM * Export References to CRM
@ -257,7 +379,7 @@ class Retailcrm_Retailcrm_Model_Exchange
* @param array $statuses statuses data * @param array $statuses statuses data
* *
*/ */
public function processReference($deliveries = null, $payments = null, $statuses = null) /*public function processReference($deliveries = null, $payments = null, $statuses = null)
{ {
if ($deliveries != null) { if ($deliveries != null) {
$this->processDeliveries($deliveries); $this->processDeliveries($deliveries);
@ -270,7 +392,7 @@ class Retailcrm_Retailcrm_Model_Exchange
if ($statuses != null) { if ($statuses != null) {
$this->processStatuses($statuses); $this->processStatuses($statuses);
} }
} }*/
/** /**
* Export deliveries * Export deliveries
@ -279,7 +401,7 @@ class Retailcrm_Retailcrm_Model_Exchange
* *
* @return bool * @return bool
*/ */
protected function processDeliveries($deliveries) /*protected function processDeliveries($deliveries)
{ {
foreach ($deliveries as $delivery) { foreach ($deliveries as $delivery) {
try { try {
@ -291,7 +413,7 @@ class Retailcrm_Retailcrm_Model_Exchange
} }
return true; return true;
} }*/
/** /**
* Export payments * Export payments
@ -300,7 +422,7 @@ class Retailcrm_Retailcrm_Model_Exchange
* *
* @return bool * @return bool
*/ */
protected function processPayments($payments) /*protected function processPayments($payments)
{ {
foreach ($payments as $payment) { foreach ($payments as $payment) {
try { try {
@ -312,7 +434,7 @@ class Retailcrm_Retailcrm_Model_Exchange
} }
return true; return true;
} }*/
/** /**
* Export statuses * Export statuses
@ -321,7 +443,7 @@ class Retailcrm_Retailcrm_Model_Exchange
* *
* @return bool * @return bool
*/ */
protected function processStatuses($statuses) /*protected function processStatuses($statuses)
{ {
foreach ($statuses as $status) { foreach ($statuses as $status) {
try { try {
@ -333,95 +455,5 @@ class Retailcrm_Retailcrm_Model_Exchange
} }
return true; return true;
} }*/
private function setCustomerId($customer)
{
$customerId = $this->searchCustomer($customer);
if (is_array($customerId) && !empty($customerId)) {
if ($customerId['success']) {
return $customerId['result'];
} else {
$this->fixCustomer($customerId['result'], $customer['externalId']);
return $customer['externalId'];
}
} else {
$this->createCustomer(
array(
'externalId' => $customer['externalId'],
'firstName' => $customer['firstName'],
'lastName' => isset($customer['lastName']) ? $customer['lastName'] : '',
'patronymic' => isset($customer['patronymic']) ? $customer['patronymic'] : '',
'phones' => isset($customer['phone']) ? array($customer['phone']) : array(),
)
);
return $customer['externalId'];
}
}
private function searchCustomer($data)
{
try {
$customers = $this->api->customersList(
array(
'name' => isset($data['phone']) ? $data['phone'] : $data['name'],
'email' => $data['email']
),
1,
100
);
} catch (Retailcrm_Retailcrm_Model_Exception_CurlException $e) {
Mage::log($e->getMessage());
}
if ($customers->isSuccessful()) {
return (count($customers['customers']) > 0)
? $this->defineCustomer($customers['customers'])
: false
;
}
}
private function createCustomer($customer)
{
try {
$this->api->customersCreate($customer);
} catch (CurlException $e) {
$this->curlErrorHandler($e->getMessage(), 'CustomersCreate::Curl: ');
}
}
private function fixCustomer($id, $extId)
{
try {
$this->api->customersFixExternalIds(
array(
array(
'id' => $id,
'externalId' => $extId
)
)
);
} catch (CurlException $e) {
$this->curlErrorHandler($e->getMessage(), 'CustomersFixExternalIds::Curl: ');
}
}
private function defineCustomer($searchResult)
{
$result = '';
foreach ($searchResult as $customer) {
if (isset($customer['externalId']) && $customer['externalId'] != '') {
$result = $customer['externalId'];
break;
}
}
return ($result != '')
? array('success' => true, 'result' => $result)
: array('success' => false, 'result' => $searchResult[0]['id'])
;
}
} }

4
app/code/community/Retailcrm/Retailcrm/Model/Icml.php
View File

@ -117,9 +117,13 @@ class Retailcrm_Retailcrm_Model_Icml
$e->setAttribute('quantity', (int)$offer['quantity']); $e->setAttribute('quantity', (int)$offer['quantity']);
} }
if (!empty($offer['categoryId'])) {
foreach ($offer['categoryId'] as $categoryId) { foreach ($offer['categoryId'] as $categoryId) {
$e->appendChild($this->_dd->createElement('categoryId', $categoryId)); $e->appendChild($this->_dd->createElement('categoryId', $categoryId));
} }
} else {
$e->appendChild($this->_dd->createElement('categoryId', 1));
}
$e->appendChild($this->_dd->createElement('name'))->appendChild($this->_dd->createTextNode($offer['name'])); $e->appendChild($this->_dd->createElement('name'))->appendChild($this->_dd->createTextNode($offer['name']));
$e->appendChild($this->_dd->createElement('productName'))->appendChild($this->_dd->createTextNode($offer['name'])); $e->appendChild($this->_dd->createElement('productName'))->appendChild($this->_dd->createTextNode($offer['name']));

22
app/code/community/Retailcrm/Retailcrm/etc/config.xml
View File

@ -44,25 +44,25 @@
<retailcrm_retailcrm_model_observer> <retailcrm_retailcrm_model_observer>
<type>singleton</type> <type>singleton</type>
<class>Retailcrm_Retailcrm_Model_Observer</class> <class>Retailcrm_Retailcrm_Model_Observer</class>
<method>orderSave</method> <method>orderCreate</method>
</retailcrm_retailcrm_model_observer> </retailcrm_retailcrm_model_observer>
</observers> </observers>
</sales_order_place_after> </sales_order_place_after>
<sales_order_save_after> <!--<sales_order_save_after>-->
<observers> <!--<observers>-->
<retailcrm_retailcrm_model_observer> <!--<retailcrm_retailcrm_model_observer>-->
<type>singleton</type> <!--<type>singleton</type>-->
<class>Retailcrm_Retailcrm_Model_Observer</class> <!--<class>Retailcrm_Retailcrm_Model_Observer</class>-->
<method>orderUpdate</method> <!--<method>orderUpdate</method>-->
</retailcrm_retailcrm_model_observer> <!--</retailcrm_retailcrm_model_observer>-->
</observers> <!--</observers>-->
</sales_order_save_after> <!--</sales_order_save_after>-->
</events> </events>
</global> </global>
<crontab> <crontab>
<jobs> <jobs>
<icml> <icml>
<schedule><cron_expr>* */6 * * *</cron_expr></schedule> <schedule><cron_expr>* */4 * * *</cron_expr></schedule>
<run><model>retailcrm/observer::exportCatalog</model></run> <run><model>retailcrm/observer::exportCatalog</model></run>
</icml> </icml>
</jobs> </jobs>