353 lines
11 KiB
PHP
353 lines
11 KiB
PHP
<?php
|
|
/**
|
|
* RetailCRM Integration.
|
|
*
|
|
* @package WC_Retailcrm_Orders
|
|
* @category Integration
|
|
* @author RetailCRM
|
|
*/
|
|
|
|
if ( ! class_exists( 'WC_Retailcrm_Orders' ) ) :
|
|
|
|
/**
|
|
* Class WC_Retailcrm_Orders
|
|
*/
|
|
class WC_Retailcrm_Orders
|
|
{
|
|
/** @var bool|WC_Retailcrm_Proxy */
|
|
protected $retailcrm;
|
|
|
|
/** @var array */
|
|
protected $retailcrm_settings;
|
|
|
|
/** @var WC_Retailcrm_Order_Item */
|
|
protected $order_item;
|
|
|
|
/** @var WC_Retailcrm_Order_Address */
|
|
protected $order_address;
|
|
|
|
/** @var WC_Retailcrm_Order_Payment */
|
|
protected $order_payment;
|
|
|
|
/** @var WC_Retailcrm_Customers */
|
|
protected $customers;
|
|
|
|
/** @var WC_Retailcrm_Order */
|
|
protected $orders;
|
|
|
|
/** @var array */
|
|
private $order = array();
|
|
|
|
/** @var array */
|
|
private $payment = array();
|
|
|
|
public function __construct(
|
|
$retailcrm = false,
|
|
$retailcrm_settings,
|
|
$order_item,
|
|
$order_address,
|
|
$customers,
|
|
$orders,
|
|
$order_payment
|
|
) {
|
|
$this->retailcrm = $retailcrm;
|
|
$this->retailcrm_settings = $retailcrm_settings;
|
|
$this->order_item = $order_item;
|
|
$this->order_address = $order_address;
|
|
$this->customers = $customers;
|
|
$this->orders = $orders;
|
|
$this->order_payment = $order_payment;
|
|
}
|
|
|
|
/**
|
|
* Upload orders to CRM
|
|
*
|
|
* @param bool $withCustomers
|
|
* @param array $include
|
|
* @return array $uploadOrders | null
|
|
*/
|
|
public function ordersUpload($include = array(), $withCustomers = false)
|
|
{
|
|
if (!$this->retailcrm) {
|
|
return null;
|
|
}
|
|
|
|
$orders = get_posts(array(
|
|
'numberposts' => -1,
|
|
'post_type' => wc_get_order_types('view-orders'),
|
|
'post_status' => array_keys(wc_get_order_statuses()),
|
|
'include' => $include
|
|
));
|
|
|
|
$orders_data = array();
|
|
|
|
foreach ($orders as $data_order) {
|
|
$order = wc_get_order($data_order->ID);
|
|
$this->processOrder($order);
|
|
$customer = $order->get_user();
|
|
$customers = array();
|
|
|
|
if ($customer != false) {
|
|
$this->order['customer']['externalId'] = $customer->get('ID');
|
|
|
|
if ($withCustomers === true) {
|
|
$customers[] = $customer->get('ID');
|
|
}
|
|
}
|
|
|
|
$orders_data[] = $this->order;
|
|
}
|
|
|
|
if ($withCustomers === true && !empty($customers)) {
|
|
$this->customers->customersUpload($customers);
|
|
}
|
|
|
|
$uploadOrders = array_chunk($orders_data, 50);
|
|
|
|
foreach ($uploadOrders as $uploadOrder) {
|
|
$this->retailcrm->ordersUpload($uploadOrder);
|
|
time_nanosleep(0, 250000000);
|
|
}
|
|
|
|
return $uploadOrders;
|
|
}
|
|
|
|
/**
|
|
* Create order
|
|
*
|
|
* @param $order_id
|
|
*
|
|
* @return mixed
|
|
*/
|
|
public function orderCreate($order_id)
|
|
{
|
|
if (!$this->retailcrm) {
|
|
return null;
|
|
}
|
|
|
|
$order = wc_get_order($order_id);
|
|
$this->processOrder($order);
|
|
$customer = $order->get_user();
|
|
|
|
if ($customer != false) {
|
|
$search = $this->customers->searchCustomer(array('id' => $customer->get('ID')));
|
|
|
|
if (!$search) {
|
|
$this->customers->createCustomer($customer);
|
|
} else {
|
|
$this->order['customer']['externalId'] = $search['externalId'];
|
|
}
|
|
} else {
|
|
$search = $this->customers->searchCustomer(array('email' => $order->get_billing_email()));
|
|
|
|
if (!$search) {
|
|
$new_customer = $this->customers->buildCustomerFromOrderData($order);
|
|
$id = $this->customers->createCustomer($new_customer);
|
|
|
|
if ($id !== null) {
|
|
$this->order['customer']['id'] = $id;
|
|
}
|
|
} else {
|
|
$this->order['customer']['externalId'] = $search['externalId'];
|
|
}
|
|
|
|
unset($new_customer);
|
|
}
|
|
|
|
$this->retailcrm->ordersCreate($this->order);
|
|
|
|
return $order;
|
|
}
|
|
|
|
/**
|
|
* Edit order in CRM
|
|
*
|
|
* @param int $order_id
|
|
*
|
|
* @return WC_Order $order | null
|
|
*/
|
|
public function updateOrder($order_id)
|
|
{
|
|
if (!$this->retailcrm) {
|
|
return null;
|
|
}
|
|
|
|
$order = wc_get_order($order_id);
|
|
$this->processOrder($order, true);
|
|
|
|
if ($this->retailcrm_settings['api_version'] == 'v4') {
|
|
$this->order['paymentType'] = $this->retailcrm_settings[$order->get_payment_method()];
|
|
}
|
|
|
|
$response = $this->retailcrm->ordersEdit($this->order);
|
|
|
|
if ($response->isSuccessful() && $this->retailcrm_settings['api_version'] == 'v5') {
|
|
$this->payment = $this->orderUpdatePaymentType($order);
|
|
}
|
|
|
|
return $order;
|
|
}
|
|
|
|
/**
|
|
* Update order payment type
|
|
*
|
|
* @param WC_Order $order
|
|
*
|
|
* @return null | array $payment
|
|
*/
|
|
protected function orderUpdatePaymentType($order)
|
|
{
|
|
if (!isset($this->retailcrm_settings[$order->get_payment_method()])) {
|
|
return null;
|
|
}
|
|
|
|
$response = $this->retailcrm->ordersGet($order->get_id());
|
|
|
|
if ($response->isSuccessful()) {
|
|
$retailcrmOrder = $response['order'];
|
|
|
|
foreach ($retailcrmOrder['payments'] as $payment_data) {
|
|
$payment_external_id = explode('-', $payment_data['externalId']);
|
|
|
|
if ($payment_external_id[0] == $order->get_id()) {
|
|
$payment = $payment_data;
|
|
}
|
|
}
|
|
}
|
|
|
|
if (isset($payment) && $payment['type'] == $this->retailcrm_settings[$order->get_payment_method()] && $order->is_paid()) {
|
|
$payment = $this->sendPayment($order, true, $payment['externalId']);
|
|
|
|
return $payment;
|
|
}
|
|
|
|
if (isset($payment) && $payment['type'] != $this->retailcrm_settings[$order->get_payment_method()]) {
|
|
$response = $this->retailcrm->ordersPaymentDelete($payment['id']);
|
|
|
|
if ($response->isSuccessful()) {
|
|
$payment = $this->sendPayment($order);
|
|
|
|
return $payment;
|
|
}
|
|
}
|
|
|
|
return null;
|
|
}
|
|
|
|
/**
|
|
* process to combine order data
|
|
*
|
|
* @param WC_Order $order
|
|
* @param boolean $update
|
|
*
|
|
* @return void
|
|
*/
|
|
protected function processOrder($order, $update = false)
|
|
{
|
|
if (!$order instanceof WC_Order) {
|
|
return;
|
|
}
|
|
|
|
if ($update === true) {
|
|
$this->orders->is_new = false;
|
|
}
|
|
|
|
$order_data = $this->orders->build($order)->get_data();
|
|
|
|
if ($order->get_items('shipping')) {
|
|
$shippings = $order->get_items( 'shipping' );
|
|
$shipping = reset($shippings);
|
|
$shipping_code = explode(':', $shipping['method_id']);
|
|
|
|
if (isset($this->retailcrm_settings[$shipping['method_id']])) {
|
|
$shipping_method = $shipping['method_id'];
|
|
} elseif (isset($this->retailcrm_settings[$shipping_code[0]])) {
|
|
$shipping_method = $shipping_code[0];
|
|
} else {
|
|
$shipping_method = $shipping['method_id'] . ':' . $shipping['instance_id'];
|
|
}
|
|
|
|
$shipping_cost = $shipping['total'] + $shipping['total_tax'];
|
|
|
|
if (!empty($shipping_method) && !empty($this->retailcrm_settings[$shipping_method])) {
|
|
$order_data['delivery']['code'] = $this->retailcrm_settings[$shipping_method];
|
|
$service = retailcrm_get_delivery_service($shipping['method_id'], $shipping['instance_id']);
|
|
|
|
if ($service) {
|
|
$order_data['delivery']['service'] = array(
|
|
'name' => $service['title'],
|
|
'code' => $service['instance_id'],
|
|
'active' => true
|
|
);
|
|
}
|
|
}
|
|
|
|
if (!empty($shipping_cost)) {
|
|
$order_data['delivery']['cost'] = $shipping_cost;
|
|
}
|
|
|
|
if ($shipping['total']) {
|
|
$order_data['delivery']['netCost'] = $shipping['total'];
|
|
}
|
|
}
|
|
|
|
$order_data['delivery']['address'] = $this->order_address->build($order)->get_data();
|
|
$order_items = array();
|
|
|
|
/** @var WC_Order_Item_Product $item */
|
|
foreach ($order->get_items() as $item) {
|
|
$order_items[] = $this->order_item->build($item)->get_data();
|
|
$this->order_item->reset_data();
|
|
}
|
|
|
|
$order_data['items'] = $order_items;
|
|
|
|
if ($this->retailcrm_settings['api_version'] == 'v5' && !$update) {
|
|
$this->order_payment->is_new = true;
|
|
$order_data['payments'][] = $this->order_payment->build($order)->get_data();
|
|
}
|
|
|
|
$this->order = apply_filters('retailcrm_process_order', $order_data, $order);
|
|
}
|
|
|
|
/**
|
|
* Send payment in CRM
|
|
*
|
|
* @param WC_Order $order
|
|
* @param boolean $update
|
|
* @param mixed $externalId
|
|
*
|
|
* @return array $payment
|
|
*/
|
|
protected function sendPayment($order, $update = false, $externalId = false)
|
|
{
|
|
$this->order_payment->is_new = !$update;
|
|
$payment = $this->order_payment->build($order, $externalId)->get_data();
|
|
|
|
if ($update === false) {
|
|
$this->retailcrm->ordersPaymentCreate($payment);
|
|
} else {
|
|
$this->retailcrm->ordersPaymentEdit($payment);
|
|
}
|
|
|
|
return $payment;
|
|
}
|
|
|
|
/**
|
|
* @return array
|
|
*/
|
|
public function getOrder()
|
|
{
|
|
return $this->order;
|
|
}
|
|
|
|
/**
|
|
* @return array
|
|
*/
|
|
public function getPayment()
|
|
{
|
|
return $this->payment;
|
|
}
|
|
}
|
|
endif;
|