Server : Apache System : Linux server2.corals.io 4.18.0-348.2.1.el8_5.x86_64 #1 SMP Mon Nov 15 09:17:08 EST 2021 x86_64 User : corals ( 1002) PHP Version : 7.4.33 Disable Function : exec,passthru,shell_exec,system Directory : /home/corals/old/vendor/magento/module-sales-rule/Model/ResourceModel/Report/Rule/ |
<?php
/**
* Copyright © Magento, Inc. All rights reserved.
* See COPYING.txt for license details.
*/
namespace Magento\SalesRule\Model\ResourceModel\Report\Rule;
/**
* Rule report resource model with aggregation by created at
*
* @author Magento Core Team <[email protected]>
*/
class Createdat extends \Magento\Reports\Model\ResourceModel\Report\AbstractReport
{
/**
* Resource Report Rule constructor
*
* @return void
*/
protected function _construct()
{
$this->_init('salesrule_coupon_aggregated', 'id');
}
/**
* Aggregate Coupons data by order created at
*
* @param mixed|null $from
* @param mixed|null $to
* @return $this
*/
public function aggregate($from = null, $to = null)
{
return $this->_aggregateByOrder('created_at', $from, $to);
}
/**
* Aggregate coupons reports by orders
*
* @throws \Exception
* @param string $aggregationField
* @param mixed $from
* @param mixed $to
* @return $this
* @SuppressWarnings(PHPMD.ExcessiveMethodLength)
*/
protected function _aggregateByOrder($aggregationField, $from, $to)
{
$table = $this->getMainTable();
$sourceTable = $this->getTable('sales_order');
$connection = $this->getConnection();
$salesAdapter = $this->_resources->getConnection('sales');
$connection->beginTransaction();
try {
if ($from !== null || $to !== null) {
$subSelect = $this->_getTableDateRangeSelect($sourceTable, 'created_at', 'updated_at', $from, $to);
} else {
$subSelect = null;
}
$this->_clearTableByDateRange($table, $from, $to, $subSelect, false, $salesAdapter);
// convert dates to current admin timezone
$periodExpr = $connection->getDatePartSql(
$this->getStoreTZOffsetQuery($sourceTable, $aggregationField, $from, $to, null, $salesAdapter)
);
$columns = [
'period' => $periodExpr,
'store_id' => 'store_id',
'order_status' => 'status',
'coupon_code' => 'coupon_code',
'rule_name' => 'coupon_rule_name',
'coupon_uses' => 'COUNT(entity_id)',
'subtotal_amount' => $connection->getIfNullSql(
'SUM((base_subtotal - ' . $connection->getIfNullSql(
'base_subtotal_canceled',
0
) . ') * base_to_global_rate)',
0
),
'discount_amount' => $connection->getIfNullSql(
'SUM((ABS(base_discount_amount) - ' . $connection->getIfNullSql(
'base_discount_canceled',
0
) . ') * base_to_global_rate)',
0
),
'total_amount' => $connection->getIfNullSql(
'SUM(((base_subtotal - ' . $connection->getIfNullSql(
'base_subtotal_canceled',
0
) . ' + ' . $connection->getIfNullSql(
'base_shipping_amount - ' . $connection->getIfNullSql('base_shipping_canceled', 0),
0
) . ') - ' . $connection->getIfNullSql(
'ABS(base_discount_amount) - ABS('
. $connection->getIfNullSql('base_discount_canceled', 0) . ')',
0
) . ' + ' . $connection->getIfNullSql(
'base_tax_amount - ' . $connection->getIfNullSql('base_tax_canceled', 0),
0
) . ')
* base_to_global_rate)',
0
),
'subtotal_amount_actual' => $connection->getIfNullSql(
'SUM((base_subtotal_invoiced - ' . $connection->getIfNullSql(
'base_subtotal_refunded',
0
) . ') * base_to_global_rate)',
0
),
'discount_amount_actual' => $connection->getIfNullSql(
'SUM((base_discount_invoiced - ' . $connection->getIfNullSql(
'base_discount_refunded',
0
) . ')
* base_to_global_rate)',
0
),
'total_amount_actual' => $connection->getIfNullSql(
'SUM(((base_subtotal_invoiced - ' . $connection->getIfNullSql(
'base_subtotal_refunded',
0
) . ' + ' . $connection->getIfNullSql(
'base_shipping_invoiced - ' . $connection->getIfNullSql('base_shipping_refunded', 0),
0
) . ') - ' . $connection->getIfNullSql(
'ABS(base_discount_invoiced) - ABS('
. $connection->getIfNullSql('base_discount_refunded', 0) . ')',
0
) . ' + ' . $connection->getIfNullSql(
'base_tax_invoiced - ' . $connection->getIfNullSql('base_tax_refunded', 0),
0
) . ') * base_to_global_rate)',
0
),
];
$select = $connection->select();
$select->from(['source_table' => $sourceTable], $columns)->where('coupon_code IS NOT NULL');
if ($subSelect !== null) {
$select->having($this->_makeConditionFromDateRangeSelect($subSelect, 'period', $salesAdapter));
}
$select->group([$periodExpr, 'store_id', 'status', 'coupon_code']);
$select->having('COUNT(entity_id) > 0');
$aggregatedData = $salesAdapter->fetchAll($select);
if ($aggregatedData) {
$connection->insertOnDuplicate($table, $aggregatedData, array_keys($columns));
}
$select->reset();
$columns = [
'period' => 'period',
'store_id' => new \Zend_Db_Expr('0'),
'order_status' => 'order_status',
'coupon_code' => 'coupon_code',
'rule_name' => 'rule_name',
'coupon_uses' => 'SUM(coupon_uses)',
'subtotal_amount' => 'SUM(subtotal_amount)',
'discount_amount' => 'SUM(discount_amount)',
'total_amount' => 'SUM(total_amount)',
'subtotal_amount_actual' => 'SUM(subtotal_amount_actual)',
'discount_amount_actual' => 'SUM(discount_amount_actual)',
'total_amount_actual' => 'SUM(total_amount_actual)',
];
$select->from($table, $columns)->where('store_id <> 0');
if ($subSelect !== null) {
$select->where($this->_makeConditionFromDateRangeSelect($subSelect, 'period', $salesAdapter));
}
$select->group(['period', 'order_status', 'coupon_code']);
$connection->query($select->insertFromSelect($table, array_keys($columns)));
$connection->commit();
} catch (\Exception $e) {
$connection->rollBack();
throw $e;
}
return $this;
}
}