Order.php 5.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180
  1. <?php
  2. /**
  3. * Copyright © Magento, Inc. All rights reserved.
  4. * See COPYING.txt for license details.
  5. */
  6. namespace Magento\Sales\Model\ResourceModel;
  7. use Magento\Framework\App\ResourceConnection as AppResource;
  8. use Magento\Framework\Math\Random;
  9. use Magento\SalesSequence\Model\Manager;
  10. use Magento\Sales\Model\ResourceModel\EntityAbstract as SalesResource;
  11. use Magento\Sales\Model\ResourceModel\Order\Handler\State as StateHandler;
  12. use Magento\Sales\Model\Spi\OrderResourceInterface;
  13. use Magento\Framework\Model\ResourceModel\Db\VersionControl\Snapshot;
  14. use Magento\Framework\Model\ResourceModel\Db\VersionControl\RelationComposite;
  15. /**
  16. * Flat sales order resource
  17. *
  18. * @author Magento Core Team <core@magentocommerce.com>
  19. * @SuppressWarnings(PHPMD.CouplingBetweenObjects)
  20. */
  21. class Order extends SalesResource implements OrderResourceInterface
  22. {
  23. /**
  24. * Event prefix
  25. *
  26. * @var string
  27. */
  28. protected $_eventPrefix = 'sales_order_resource';
  29. /**
  30. * Event object
  31. *
  32. * @var string
  33. */
  34. protected $_eventObject = 'resource';
  35. /**
  36. * @var StateHandler
  37. */
  38. protected $stateHandler;
  39. /**
  40. * Model Initialization
  41. *
  42. * @return void
  43. */
  44. protected function _construct()
  45. {
  46. $this->_init('sales_order', 'entity_id');
  47. }
  48. /**
  49. * @param \Magento\Framework\Model\ResourceModel\Db\Context $context
  50. * @param Attribute $attribute
  51. * @param Manager $sequenceManager
  52. * @param Snapshot $entitySnapshot
  53. * @param RelationComposite $entityRelationComposite
  54. * @param StateHandler $stateHandler
  55. * @param string $connectionName
  56. */
  57. public function __construct(
  58. \Magento\Framework\Model\ResourceModel\Db\Context $context,
  59. Snapshot $entitySnapshot,
  60. RelationComposite $entityRelationComposite,
  61. Attribute $attribute,
  62. Manager $sequenceManager,
  63. StateHandler $stateHandler,
  64. $connectionName = null
  65. ) {
  66. $this->stateHandler = $stateHandler;
  67. parent::__construct(
  68. $context,
  69. $entitySnapshot,
  70. $entityRelationComposite,
  71. $attribute,
  72. $sequenceManager,
  73. $connectionName
  74. );
  75. }
  76. /**
  77. * Count existent products of order items by specified product types
  78. *
  79. * @param int $orderId
  80. * @param array $productTypeIds
  81. * @param bool $isProductTypeIn
  82. * @return array
  83. */
  84. public function aggregateProductsByTypes($orderId, $productTypeIds = [], $isProductTypeIn = false)
  85. {
  86. $connection = $this->getConnection();
  87. $select = $connection->select()
  88. ->from(
  89. ['o' => $this->getTable('sales_order_item')],
  90. ['o.product_type', new \Zend_Db_Expr('COUNT(*)')]
  91. )
  92. ->where('o.order_id=?', $orderId)
  93. ->where('o.product_id IS NOT NULL')
  94. ->group('o.product_type');
  95. if ($productTypeIds) {
  96. $select->where(
  97. sprintf(
  98. '(o.product_type %s (?))',
  99. $isProductTypeIn ? 'IN' : 'NOT IN'
  100. ),
  101. $productTypeIds
  102. );
  103. }
  104. return $connection->fetchPairs($select);
  105. }
  106. /**
  107. * Process items dependency for new order, returns qty of affected items;
  108. *
  109. * @param \Magento\Sales\Model\Order $object
  110. * @return int
  111. */
  112. protected function calculateItems(\Magento\Sales\Model\Order $object)
  113. {
  114. $itemsCount = 0;
  115. if (!$object->getId()) {
  116. foreach ($object->getAllItems() as $item) {
  117. /** @var \Magento\Sales\Model\Order\Item $item */
  118. $parent = $item->getQuoteParentItemId();
  119. if ($parent && !$item->getParentItem()) {
  120. $item->setParentItem($object->getItemByQuoteItemId($parent));
  121. }
  122. $childItems = $item->getChildrenItems();
  123. if (empty($childItems)) {
  124. $itemsCount++;
  125. }
  126. }
  127. }
  128. return $itemsCount;
  129. }
  130. /**
  131. * @param \Magento\Framework\Model\AbstractModel $object
  132. * @return $this
  133. */
  134. protected function _beforeSave(\Magento\Framework\Model\AbstractModel $object)
  135. {
  136. if (!$object->getId()) {
  137. /** @var \Magento\Store\Model\Store $store */
  138. $store = $object->getStore();
  139. $name = [
  140. $store->getWebsite()->getName(),
  141. $store->getGroup()->getName(),
  142. $store->getName(),
  143. ];
  144. $object->setStoreName(implode(PHP_EOL, $name));
  145. $object->setTotalItemCount($this->calculateItems($object));
  146. }
  147. $object->setData(
  148. 'protect_code',
  149. substr(
  150. hash('sha256', uniqid(Random::getRandomNumber(), true) . ':' . microtime(true)),
  151. 5,
  152. 32
  153. )
  154. );
  155. $isNewCustomer = !$object->getCustomerId() || $object->getCustomerId() === true;
  156. if ($isNewCustomer && $object->getCustomer()) {
  157. $object->setCustomerId($object->getCustomer()->getId());
  158. }
  159. return parent::_beforeSave($object);
  160. }
  161. /**
  162. * {@inheritdoc}
  163. */
  164. public function save(\Magento\Framework\Model\AbstractModel $object)
  165. {
  166. /** @var \Magento\Sales\Model\Order $object */
  167. $this->stateHandler->check($object);
  168. return parent::save($object);
  169. }
  170. }