lachang/app/api/model/PromotionMonitorStatistics.php

<?php

namespace app\api\model;

use app\common\model\PromotionMonitorStatistics as PromotionMonitorStatisticsModel;
use think\facade\Db;

/**
 * 推广监控统计模型
 * @package app\api\model
 */
class PromotionMonitorStatistics extends PromotionMonitorStatisticsModel
{


    public static function addData($date)
    {
        $startTime = strtotime("{$date} 00:00:00");
        $endTime = strtotime("{$date} 23:59:59");

        // 推广渠道
        $pmPvUv = self::getPvUv(3, $startTime, $endTime);
        // 新用户
        $pmUvNew = self::getUvNew(User::ACT_SOURCE_PROMOTION_MONITOR, $startTime, $endTime);
        // 支付订单
        $pmPayData = self::getPayData($startTime, $endTime);
        $insert = self::formatData($date, $pmPayData, $pmPvUv, $pmUvNew);
//        (new self)->saveAll($insert);
    }

    /**
     * @param $date
     * @param $payData
     * @param array $pvUv
     * @param array $uvNew
     * @return mixed
     */
    private static function formatData($date, $payData, $pvUv = [], $uvNew = [])
    {
//        $idArr = array_unique(array_merge(array_column($pvUv, 'visit_type_id'), array_keys($uvNew), array_keys($payData)));
        $idArr = PromotionMonitor::where('status', 1)->column('id');
        $insert = [];
        foreach ($idArr as $id) {
            $pv = 0;
            $uv = 0;
            $uvNewV = 0;
            $payOrderCount = 0;
            $payUserCount = 0;
            $payAmount = 0;
            foreach ($pvUv as $pvUvV) {
                if ($pvUvV['visit_type_id'] == $id) {
                    $pv = $pvUvV['pv'];
                    $uv = $pvUvV['uv'];
                }
            }
            if (isset($uvNew[$id])) {
                $uvNewV = $uvNew[$id]['uv_new'];
            }
            if (isset($payData[$id])) {
                $payOrderCount = $payData[$id]['pay_order_count'];
                $payUserCount = $payData[$id]['pay_user_count'];
                $payAmount = $payData[$id]['pay_amount'];
            }
            $insert = [
                'monitor_id' => $id,
                'ref_date' => date('Ymd', strtotime($date)),
                'pv' => (int)$pv,
                'uv' => (int)$uv,
                'uv_new' => $uvNewV,
                'pay_order_count' => $payOrderCount,
                'pay_user_count' => $payUserCount,
                'pay_amount' => $payAmount,
            ];
            $info = self::where('monitor_id', $id)->where('ref_date', date('Ymd', strtotime($date)))->find();
            if (empty($info)) {
                (new self)->save($insert);
            } else {
                $info->where('id', $info['id'])->update($insert);
            }
        }
//        return $insert;
    }

    private static function getPvUv($type, $startTime, $endTime)
    {
        // 访问量
        $data = Db::name('visit_record')->where('visit_type', $type)
            ->whereBetween('create_time', [$startTime, $endTime])
            ->field('sum(IF(v_type=0, 1, 0)) as pv,sum(IF(v_type=1, 1, 0)) as uv,visit_type_id')
            ->group('visit_type_id')
            ->select()->toArray();
        return $data;
    }

    private static function getUvNew($type, $startTime, $endTime)
    {
        $data = User::where('act_source', $type)
            ->whereBetween('create_time', [$startTime, $endTime])
            ->group('act_source_id')
            ->column('count(act_source_id) as uv_new,act_source_id', 'act_source_id');
        return $data;
    }

    private static function getPayData($startTime, $endTime)
    {
        $data = Db::name('order')->alias('order')->where('order.promotion_monitor_id', '>', 0)
            ->whereBetween('order.pay_time', [$startTime, $endTime])
            ->where('order.is_delete', '=', 0)
            ->group('order.promotion_monitor_id')
            ->column('count(distinct(order.user_id)) as pay_user_count,sum(order.pay_price + order.rice_card_money) as pay_amount,count(order.order_id) as pay_order_count,order.promotion_monitor_id', 'order.promotion_monitor_id');

        return $data;
    }
}