1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
<?php
/**
* Copyright © Magento, Inc. All rights reserved.
* See COPYING.txt for license details.
*/
declare(strict_types=1);
namespace Magento\InventoryLowQuantityNotification\Model\ResourceModel\SourceItemConfiguration;
use Magento\Framework\App\ResourceConnection;
use Magento\InventoryLowQuantityNotificationApi\Api\Data\SourceItemConfigurationInterface;
/**
* Implementation of Source Item Configuration save multiple operation for specific db layer
* Save Multiple used here for performance efficient purposes over single save operation
*/
class SaveMultiple
{
/**
* @var ResourceConnection
*/
private $resourceConnection;
/**
* @param ResourceConnection $resourceConnection
*/
public function __construct(
ResourceConnection $resourceConnection
) {
$this->resourceConnection = $resourceConnection;
}
/**
* @param SourceItemConfigurationInterface[] $sourceItemConfigurations
* @return void
*/
public function execute(array $sourceItemConfigurations)
{
if (!count($sourceItemConfigurations)) {
return;
}
$connection = $this->resourceConnection->getConnection();
$tableName = $this->resourceConnection
->getTableName('inventory_low_stock_notification_configuration');
$columnsSql = $this->buildColumnsSqlPart([
SourceItemConfigurationInterface::SOURCE_CODE,
SourceItemConfigurationInterface::SKU,
SourceItemConfigurationInterface::INVENTORY_NOTIFY_QTY
]);
$valuesSql = $this->buildValuesSqlPart($sourceItemConfigurations);
$onDuplicateSql = $this->buildOnDuplicateSqlPart([
SourceItemConfigurationInterface::INVENTORY_NOTIFY_QTY
]);
$bind = $this->getSqlBindData($sourceItemConfigurations);
$insertSql = sprintf(
'INSERT INTO %s (%s) VALUES %s %s',
$tableName,
$columnsSql,
$valuesSql,
$onDuplicateSql
);
$connection->query($insertSql, $bind);
}
/**
* @param array $columns
* @return string
*/
private function buildColumnsSqlPart(array $columns): string
{
$connection = $this->resourceConnection->getConnection();
$processedColumns = array_map([$connection, 'quoteIdentifier'], $columns);
$sql = implode(', ', $processedColumns);
return $sql;
}
/**
* @param SourceItemConfigurationInterface[] $sourceItemConfigurations
* @return string
*/
private function buildValuesSqlPart(array $sourceItemConfigurations): string
{
$sql = rtrim(str_repeat('(?, ?, ?), ', count($sourceItemConfigurations)), ', ');
return $sql;
}
/**
* @param SourceItemConfigurationInterface[] $sourceItemConfigurations
* @return array
*/
private function getSqlBindData(array $sourceItemConfigurations): array
{
$bind = [];
foreach ($sourceItemConfigurations as $sourceItemConfiguration) {
$bind = array_merge($bind, [
$sourceItemConfiguration->getSourceCode(),
$sourceItemConfiguration->getSku(),
$sourceItemConfiguration->getNotifyStockQty()
]);
}
return $bind;
}
/**
* @param array $fields
* @return string
*/
private function buildOnDuplicateSqlPart(array $fields): string
{
$connection = $this->resourceConnection->getConnection();
$processedFields = [];
foreach ($fields as $field) {
$processedFields[] = sprintf('%1$s = VALUES(%1$s)', $connection->quoteIdentifier($field));
}
$sql = 'ON DUPLICATE KEY UPDATE ' . implode(', ', $processedFields);
return $sql;
}
}