| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475 |
- <?php
- namespace common\logic\statistics;
- use common\enums\EventNameEnum;
- use common\enums\RabbitMqEnum;
- use common\helpers\ErrHelper;
- use Exception;
- use Yii;
- /**
- * 用户数据处理
- * @Author lun
- * @DateTime 2021-11-16 19:07:32
- * @copyright: Copyright (c) 2020 广东七件事集团
- */
- class StatisticsHandle
- {
- /**
- * 订单支付统计
- * @Author: lun
- * @DateTime: 2021/11/16 0016 10:51
- * @Copyright: copyright (c) 2021 广东七件事集团
- * @param string $type
- * @param array $params
- */
- public static function execute($type, $params)
- {
- $handler_class = Statistics::class;
- switch ($type) {
- case EventNameEnum::ORDER_CREATE:
- $method = 'order_create';
- break;
- case EventNameEnum::ORDER_PAY:
- $method = 'order_pay';
- break;
- case EventNameEnum::ORDER_FINISH:
- $method = 'order_finish';
- break;
- case EventNameEnum::ORDER_CLOSE:
- $method = 'order_close';
- break;
- case EventNameEnum::ORDER_REFUND:
- $method = 'order_refund';
- break;
- case EventNameEnum::USER_REGISTER:
- $method = 'user_register';
- break;
- }
- (new $handler_class)->$method($params);
- }
- /**
- * 异步执行
- *
- * @param array $params
- * [
- * 'type' => string,
- * 'params' => array
- * ]
- * @return void
- */
- public function handleSync(array $params)
- {
- try {
- $type = $params['type'];
- $data = $params['params'];
- static::execute($type, $data);
- } catch (Exception $e) {
- ErrHelper::log('异步执行数据统计错误', $e);
- }
- return true;
- }
- }
|