app/Plugin/Movement/Event.php line 74

Open in your IDE?
  1. <?php
  3. namespace Plugin\Movement;
  5. use Eccube\Entity\Order;
  6. use Eccube\Entity\OrderDetail;
  7. use Eccube\Entity\Product;
  8. use Eccube\Entity\ProductClass;
  9. use Symfony\Component\EventDispatcher\EventSubscriberInterface;
  10. use Symfony\Component\EventDispatcher\GenericEvent;
  11. use Symfony\Component\Workflow\Event\TransitionEvent;
  13. use Plugin\Movement\LogManager;
  15. class Event implements EventSubscriberInterface
  16. {
  18.     private $url = 'https://webapi.smaregi.jp/access/';
  19.     private $contractId = 'skcc222y1';
  20.     private $token = '4b5ad52adf4c8dec3e49457ff56884f8';
  22.     /**
  23.      * @return array
  24.      */
  25.     public static function getSubscribedEvents()
  26.     {
  27.         return [
  28.             'admin.product.edit.complete' => 'onAdminProductEditComplete',
  29.             'front.shopping.complete.initialize' => 'onFrontShoppingCompleteInitialize',
  30.             'admin.order.edit.index.complete' => 'onAdminOrderEditIndexComplete',
  31.             'workflow.order.transition.cancel' => 'onWorkflowOrderTransitionCancel',
  32.         ];
  33.     }
  35.     public function onAdminProductEditComplete(GenericEvent $event)
  36.     {
  37.         //error_log( date('[Y-m-d H:i:s] ') . 'onAdminProductEditComplete' . "\n", 3, "/home/liquor-sato/temp/log.txt");
  39.         /** @var Product $product */
  40.         $product = $event->getArgument('Product');
  42.         /** @var ProductClass $productClass */
  43.         $productClass = $product->getProductClasses()[0];
  45.         $stock = $productClass->getStock();
  46.         $stockUnlimited = $productClass->isStockUnlimited();
  47.         $code = $productClass->getCode();
  49.         $logManager = LogManager::sharedInstance();
  50.         if (empty($code)) {
  51.             $logManager->logOutward("管理画面編集終了時の処理を開始します。商品IDがありませんでした。処理を行いません。", 'admin_edit_complete_start');
  52.         } else if ($stockUnlimited === true) {
  53.             $logManager->logOutward("管理画面編集終了時の処理を開始します。商品ID: {$code} の商品を、在庫無制限により在庫の操作をしません。", 'admin_edit_complete_start');
  54.             // 以下、以前はそのような仕様があったが、いまはしなくてよいよう
  55.             //$logManager->logOutward("管理画面編集終了時の処理を開始します。商品ID: {$code} の商品を、在庫: 0 (無制限により) に変更します。", 'admin_edit_complete_start');
  56.             //$this->sendRequest(0, $code);
  57.         } else if ((string)$stock !== '0' and empty($stock)) {
  58.             $logManager->logOutward("管理画面編集終了時の処理を開始します。在庫の数値を確認できませんでした。処理を行いません。", 'admin_edit_complete_start');
  59.         } else {
  60.             $logManager->logOutward("管理画面編集終了時の処理を開始します。商品ID: {$code} の商品を、在庫: {$stock} に変更します。", 'admin_edit_complete_start');
  61.             $this->sendRequest($stock, $code);
  62.         }
  64.         //error_log( date('[Y-m-d H:i:s] ') . 'Code: ' . $code . ' Stock: ' . $stock . "\n", 3, "/home/liquor-sato/temp/log.txt");
  65.     }
  67.     public function onAdminOrderEditIndexComplete(GenericEvent $event)
  68.     {
  69.         $argumentKey = 'TargetOrder';
  70.         $order = $event->getArgument($argumentKey);
  71.         $this->onUpdateOrder($order, 'admin_order_edit');
  72.     }
  74.     public function onFrontShoppingCompleteInitialize(GenericEvent $event)
  75.     {
  76.         $argumentKey = 'Order';
  77.         $order = $event->getArgument($argumentKey);
  78.         $this->onUpdateOrder($order, 'shopping_complete');
  79.     }
  81.     public function onWorkflowOrderTransitionCancel(TransitionEvent $event)
  82.     {
  83.         $order = $event->getSubject()->getOrder();
  84.         $this->onUpdateOrder($order, 'workflow_order_cancel');
  85.     }
  87.     private function onUpdateOrder(Order $order, $type)
  88.     {
  89.         //error_log( date('[Y-m-d H:i:s] ') . 'xxxxxx' . "\n", 3, "/home/liquor-sato/temp/log.txt");
  91.         $action = '';
  92.         $actionCode = '';
  93.         switch($type){
  94.             case 'shopping_complete':
  95.                 $action = '商品購入完了時の処理';
  96.                 $actionCode = 'shopping_complete';
  97.                 break;
  98.             case 'admin_order_edit':
  99.                 $action = '注文編集時の処理';
  100.                 $actionCode = 'order_edit_complete';
  101.                 break;
  102.             case 'workflow_order_cancel':
  103.                 $action = '注文キャンセル時の処理';
  104.                 $actionCode = 'workflow_order_cancel';
  105.                 break;
  106.         }
  108.         $logManager = LogManager::sharedInstance();
  109.         $logManager->logOutward($action . "を開始します。", $actionCode . '_start');
  111.         //$arguments = $event->getArguments();
  112.         //$keys = array_keys($arguments);
  114.         /*
  117.         //$orderDetails = $order->getOrderDetails();
  118.         $orderDetails = $order->getOrderItems();
  119.         $orderData = array(
  120.             'orderId' => $order->getId(),
  121.             'subTotal' => $order->getSubtotal() - $order->getTax(),
  122.             'discount' => $order->getDiscount(),
  123.             'deliveryFee' => $order->getDeliveryFeeTotal(),
  124.             'charge' => $order->getCharge(),
  125.             'tax' => $order->getTax(),
  126.             'totalPrice' => $order->getTotalPrice()
  127.         );
  128.         */
  130.         $detailArray = array();
  132.         $orderItems = $order->getOrderItems();
  134.         foreach ($orderItems as $orderItem) {
  136.             /** @var ProductClass $productClass */
  137.             $productClass = $orderItem->getProductClass();
  138.             $product = $orderItem->getProduct();
  140.             if (empty($productClass)) {
  141.                 continue;
  142.             }
  144.             $stock = $productClass->getStock();
  145.             $stockUnlimited = $productClass->isStockUnlimited();
  146.             $code = $productClass->getCode();
  148.             /*
  149.             $transactionDetail = array(
  150.                 'code' => $orderItem->getProductCode(),
  151.                 'name' => $orderItem->getProductName(),
  152.                 'price' => $orderItem->getPrice(),
  153.                 'quantity' => $orderItem->getQuantity(),
  154.             );
  155.             $detailArray[] = $transactionDetail;
  156. */
  157.             if (empty($code)) {
  158.                 $logManager->logOutward("商品IDがありませんでした。処理を行いません。", $actionCode . '_doing');
  159.             } else {
  161.                 switch($actionCode) {
  162.                     case 'shopping_complete':
  164.                         if ($stockUnlimited === true) {
  165.                             // unlimitedの場合在庫の相対値操作
  166.                             $difference = $orderItem->getQuantity() * -1;
  167.                             $logManager->logOutward("商品ID: {$code} の商品を、在庫: " . $difference . " (無制限により) します。", $actionCode . '_doing');
  168.                             $this->sendRequest($difference, $code, 2);
  169.                         } else {
  170.                             // unlimitedでないなら新しい在庫の数値に合わせる
  171.                             if ((string)$stock !== '0' and empty($stock)) {
  172.                                 $logManager->logOutward("商品ID: {$code} の商品について、在庫の数値を確認できませんでした。処理を行いません。", $actionCode . '_doing');
  173.                             } else {
  174.                                 $logManager->logOutward("商品ID: {$code} の商品を、在庫: {$stock} に変更します。", $actionCode . '_doing');
  175.                                 $this->sendRequest($stock, $code);
  176.                             }
  177.                         }
  179.                         break;
  180.                     case 'order_edit_complete':
  182.                         if ($stockUnlimited === true) {
  183.                             $logManager->logOutward("商品ID: {$code} の商品について、無制限のため、この部分では処理を行いません。", $actionCode . '_doing');
  184.                         } else {
  185.                             // unlimitedでないなら新しい在庫の数値に合わせる
  186.                             if ((string)$stock !== '0' and empty($stock)) {
  187.                                 $logManager->logOutward("商品ID: {$code} の商品について、在庫の数値を確認できませんでした。処理を行いません。", $actionCode . '_doing');
  188.                             } else {
  189.                                 $logManager->logOutward("商品ID: {$code} の商品を、在庫: {$stock} に変更します。", $actionCode . '_doing');
  190.                                 $this->sendRequest($stock, $code);
  191.                             }
  192.                         }
  193.                         break;
  194.                     case 'workflow_order_cancel':
  196.                         if ($stockUnlimited === true) {
  197.                             // unlimitedの場合在庫の相対値操作
  198.                             $difference = $orderItem->getQuantity();
  199.                             $logManager->logOutward("商品ID: {$code} の商品を、在庫: +" . $difference . " (無制限商品のキャンセルにより) します。", $actionCode . '_doing');
  200.                             $this->sendRequest($difference, $code, 2);
  201.                         } else {
  202.                             //$logManager->logOutward("商品ID: {$code} の商品について、無制限ではないため、この部分では処理を行いません。", $actionCode . '_doing');
  203.                             // unlimitedでないなら新しい在庫の数値に合わせる
  204.                             if ((string)$stock !== '0' and empty($stock)) {
  205.                                 $logManager->logOutward("商品ID: {$code} の商品について、在庫の数値を確認できませんでした。処理を行いません。", $actionCode . '_doing');
  206.                             } else {
  207.                                 $logManager->logOutward("商品ID: {$code} の商品を、在庫: {$stock} に変更します。", $actionCode . '_doing');
  208.                                 $this->sendRequest($stock, $code);
  209.                             }
  210.                         }
  211.                         break;
  212.                 }
  213.             }
  215.             //error_log( date('[Y-m-d H:i:s] ') . 'Code: ' . $code . ' Stock: ' . $stock . "\n", 3, "/home/liquor-sato/temp/log.txt");
  216.         }
  218.         //$this->sendSalesRequest($orderData, $detailArray);
  219.     }
  221.     private function sendSalesRequest($orderData, $detailArray)
  222.     {
  223.         if (empty($detailArray)) {
  224.             return;
  225.         }
  227.         $headers = array(
  228.             'X-contract-id: ' . $this->contractId,
  229.             'X-access-token: ' . $this->token,
  230.             'Content-Type: application/x-www-form-urlencoded;charset=UTF-8'
  231.         );
  232.         $header = implode("\r\n", $headers);
  234.         $params = array(
  235.             'proc_info' => array(
  236.                 'proc_division' => 'U'
  237.             ),
  238.             'data' => array(
  239.                 array(
  240.                     'table_name' => 'TransactionHead',
  241.                     'rows' => array(
  242.                         array(
  243.                             'transactionHeadDivision' => '1',
  244.                             'cancelDivision' => '0',
  245.                             'subtotal' => $orderData['subTotal'],
  246.                             'subtotalDiscountPrice' => $orderData['discount'],
  247.                             'total' => $orderData['totalPrice'],
  248.                             'taxExclude' => $orderData['tax'],
  249.                             'storeId' => '1',
  250.                             'terminalId' => '99',
  251.                             'terminalTranId' => $orderData['orderId'],
  252.                             'terminalTranDateTime' => date('Y-m-d H:i:s'),
  253.                             'sumDivision' => '2',
  254.                             'sumDateTime' => date('Y-m-d'),
  255.                             'carriage' => $orderData['deliveryFee'],
  256.                             'commission' => $orderData['charge'],
  257.                         )
  258.                     )
  259.                 ), array(
  260.                     'table_name' => 'TransactionDetail',
  261.                     'rows' => array()
  262.                 )
  263.             )
  264.         );
  266.         $details = array();
  267.         foreach($detailArray as $detail) {
  268.             $array = array(
  269.                 'transactionDetailDivision' => '1',
  270.                 'productId' => $detail['code'],
  271.                 'productName' => $detail['name'],
  272.                 'taxDivision' => '1',
  273.                 'price' => $detail['price'],
  274.                 'salesPrice' => $detail['price'],
  275.                 'quantity' => $detail['quantity']
  276.             );
  277.             $details[] = $array;
  278.         }
  279.         $params['data'][1]['rows'] = $details;
  281.         $data = array(
  282.             'proc_name' => 'transaction_upd',
  283.             'params' => json_encode($params)
  284.         );
  286.         //error_log( date('[Y-m-d H:i:s] ') . 'Params: ' . print_r($params, true) . "\n", 3, "/home/liquor-sato/temp/log.txt");
  288.         $options = array(
  289.             'http' => array(
  290.                 'method' => 'POST',
  291.                 'content' => http_build_query($data),
  292.                 'header' => $header
  293.             )
  294.         );
  296.         if (gethostname() !== 'zotac') {
  297.             $contents = file_get_contents($this->url, false, stream_context_create($options));
  298.         }
  299.     }
  301.     private function sendRequest($stock, $code, $procDetailDivision = 1)
  302.     {
  303.         if (empty($code)) {
  304.             return;
  305.         }
  307.         $headers = array(
  308.             'X-contract-id: ' . $this->contractId,
  309.             'X-access-token: ' . $this->token,
  310.             'Content-Type: application/x-www-form-urlencoded;charset=UTF-8'
  311.         );
  312.         $header = implode("\r\n", $headers);
  314.         $params = array(
  315.             'proc_info' => array(
  316.                 'proc_division' => 'U',
  317.                 'proc_detail_division' => $procDetailDivision
  318.             ),
  319.             'data' => array(
  320.                 array(
  321.                     'table_name' => 'Stock',
  322.                     'rows' => array(
  323.                         array(
  324.                             'storeId' => 1,
  325.                             'productId' => $code,
  326.                             'stockAmount' => $stock,
  327.                             'stockDivision' => 15
  328.                         )
  329.                     )
  330.                 )
  331.             )
  332.         );
  334.         $data = array(
  335.             'proc_name' => 'stock_upd',
  336.             'params' => json_encode($params)
  337.         );
  339.         $options = array(
  340.             'http' => array(
  341.                 'method' => 'POST',
  342.                 'content' => http_build_query($data),
  343.                 'header' => $header
  344.             )
  345.         );
  346.         if (gethostname() !== 'zotac') {
  347.             $contents = file_get_contents($this->url, false, stream_context_create($options));
  348.             $logManager = LogManager::sharedInstance();
  349.             if ($procDetailDivision === 2) {
  350.                 $logManager->logOutward("スマレジにデータを送信しました。商品ID: {$code} の商品を、在庫: {$stock} (相対値)に変更します。", 'sent_request', $contents);
  351.             } else {
  352.                 $logManager->logOutward("スマレジにデータを送信しました。商品ID: {$code} の商品を、在庫: {$stock} (絶対値)に変更します。", 'sent_request', $contents);
  353.             }
  355.             $params = array(
  356.                 'conditions' => array(
  357.                     array('storeId' => '1'),
  358.                     array('productId' => $code)
  359.                 ),
  360.                 'table_name' => 'Stock'
  361.             );
  362.             $data = array(
  363.                 'proc_name' => 'stock_ref',
  364.                 'params' => json_encode($params)
  365.             );
  366.             $options = array(
  367.                 'http' => array(
  368.                     'method' => 'POST',
  369.                     'content' => http_build_query($data),
  370.                     'header' => $header
  371.                 )
  372.             );
  373.             $contents = file_get_contents($this->url, false, stream_context_create($options));
  374.             $logManager->logOutward("スマレジのデータを確認します。商品ID: {$code} ", 'stock_confirm', $contents);
  376.         }
  377.     }
  378. }