buyerstatistic.php

См. документацию.

<?php
namespace Bitrix\Sale\Internals;
 
use Bitrix\Main;

class BuyerStatisticTable extends Main\Entity\DataManager
{
    public static function getTableName()
    {
        return 'b_sale_buyer_stat';
    }

    public static function getMap()
    {
        return array(
            new Main\Entity\IntegerField(
                'ID',
                array(
                    'autocomplete' => true,
                    'primary' => true,
                )
            ),
 
            new Main\Entity\StringField(
                'LID',
                array(
                    'required' => true,
                )
            ),
 
            new Main\Entity\StringField(
                'CURRENCY',
                array(
                    'required' => true,
                    'size' => 3
                )
            ),
 
            new Main\Entity\IntegerField(
                'USER_ID',
                array(
                    'required' => true,
                )
            ),
 
            new Main\Entity\ReferenceField(
                'USER',
                '\Bitrix\Main\User',
                array('=this.USER_ID' => 'ref.ID'),
                array('join_type' => 'INNER')
            ),
 
            new Main\Entity\DatetimeField('LAST_ORDER_DATE'),
 
            new Main\Entity\FloatField(
                'SUM_PAID',
                array(
                    'default_value' => '0.0000'
                )
            ),
 
            new Main\Entity\IntegerField('COUNT_FULL_PAID_ORDER'),
 
            new Main\Entity\IntegerField('COUNT_PART_PAID_ORDER'),
 
            new Main\Entity\ReferenceField(
                'GROUP',
                '\Bitrix\Main\UserGroup',
                array('=this.USER_ID' => 'ref.USER_ID'),
                array('join_type' => 'INNER')
            ),
        );
    }

    public static function recalculate()
    {
        $connection = Main\Application::getConnection();
        $type = $connection->getType();
        if ($type == "mysql")
        {
            $sqlDelete = "TRUNCATE TABLE ".self::getTableName();
            $connection->query($sqlDelete);
 
            $sqlInsertInSelect = "
                INSERT INTO ".self::getTableName()." (USER_ID, LID, CURRENCY, LAST_ORDER_DATE, COUNT_FULL_PAID_ORDER, COUNT_PART_PAID_ORDER, SUM_PAID)
                SELECT UN.USER_ID, UN.LID, UN.CURRENCY, MAX(UN.DATE_INSERT), SUM(CASE WHEN UN.PAYED = 'Y' THEN 1 ELSE 0 END), SUM(CASE WHEN NOT UN.SUM_PAID = 0 THEN 1 ELSE 0 END), SUM(UN.SUM_PAID)
                FROM (
                    (SELECT USER_ID, LID, CURRENCY, DATE_INSERT, PAYED, SUM_PAID FROM b_sale_order)
                    UNION
                    (SELECT USER_ID, LID, CURRENCY, DATE_INSERT, PAYED, SUM_PAID FROM b_sale_order_archive)
                ) UN
                GROUP BY UN.USER_ID, UN.CURRENCY, UN.LID
                ORDER BY UN.USER_ID";
            $connection->query($sqlInsertInSelect);
        }
    }
}