zhongshen_project/addon/wechat/model/Stat.php

<?php
/**
 * Niushop商城系统 - 团队十年电商经验汇集巨献!
 * =========================================================
 * Copy right 2019-2029 杭州牛之云科技有限公司, 保留所有权利。
 * ----------------------------------------------
 * 官方网址: https://www.niushop.com
 * =========================================================
 */

namespace addon\wechat\model;

use app\model\BaseModel;
use think\facade\Cache;

/**
 * 数据统计与分析
 */
class Stat extends BaseModel
{

    /**
     * 获取用户增减数据, 最大时间跨度：7
     * @param $begin_date
     * @param $end_date
     * @return array|\multitype
     */
    public function userSummary($begin_date, $end_date)
    {
        $cache = Cache::get("wechat_user_summary_" . "_" . $begin_date . "_" . $end_date);
        if (!empty($cache))
            return $this->success($cache);

        $wechat_model = new Wechat();
        $result       = $wechat_model->userSummary($begin_date, $end_date);
        if ($result["code"] < 0)
            return $result;

        Cache::tag("wechat_visit")->set("wechat_user_summary_" . "_" . $begin_date . "_" . $end_date);
        return $result;
    }

    /**
     * 获取累计用户数据, 最大时间跨度：7;
     * @param $begin_date
     * @param $end_date
     * @return array|\multitype
     */
    public function userCumulate($begin_date, $end_date)
    {
        $cache = Cache::get("wechat_user_cumulate_" . "_" . $begin_date . "_" . $end_date);
        if (!empty($cache))
            return $this->success($cache);

        $wechat_model = new Wechat();
        $result       = $wechat_model->userCumulate($begin_date, $end_date);
        if ($result["code"] < 0)
            return $result;

        Cache::tag("wechat_visit")->set("wechat_user_cumulate_" . "_" . $begin_date . "_" . $end_date);
        return $result;
    }

    /**
     * 获取接口分析分时数据, 最大时间跨度：1;
     * @param $begin_date
     * @param $end_date
     * @return array|\multitype
     */
    public function interfaceSummaryHourly($begin_date, $end_date)
    {
        $cache = Cache::get("wechat_interface_summary_hourly_" . "_" . $begin_date . "_" . $end_date);
        if (!empty($cache))
            return $this->success($cache);

        $wechat_model = new Wechat();
        $result       = $wechat_model->interfaceSummaryHourly($begin_date, $end_date);
        if ($result["code"] < 0)
            return $result;

        Cache::tag("wechat_visit")->set("wechat_interface_summary_hourly_" . "_" . $begin_date . "_" . $end_date);
        return $result;
    }

    /**
     * 获取接口分析数据, 最大时间跨度：30;
     * @param $begin_date
     * @param $end_date
     * @return array|\multitype
     */
    public function interfaceSummary($begin_date, $end_date)
    {
//        $cache = Cache::get("wechat_interface_summary_" . "_" . $begin_date."_" . $end_date);
//        if (!empty($cache))
//            return $this->success($cache);

        $wechat_model = new Wechat();
        $result       = $wechat_model->interfaceSummary($begin_date, $end_date);
        if ($result["code"] < 0)
            return $result;

        Cache::tag("wechat_visit")->set("wechat_interface_summary_" . "_" . $begin_date . "_" . $end_date);
        return $result;
    }

    /**
     * 获取微信粉丝统计(以天为单位)
     * @param unknown $param
     */
    public function fans($begin_date, $end_date)
    {
//        $cache = Cache::get("wechat_fans_statistics_"  . "_" . $begin_date."_" . $end_date);
//        if (!empty($cache)) {
//            return $this->success($cache);
//        }
//        $data = [ 'begin_date' => $param['begin_date'], 'end_date' => $param['end_date'] ];
        $user_summary_result = $this->userSummary($begin_date, $end_date);
        if ($user_summary_result["code"] < 0) {
            return $user_summary_result;
        }
        $user_cumulate_result = $this->userCumulate($begin_date, $end_date);
        if ($user_cumulate_result["code"] < 0) {
            return $user_cumulate_result;
        }
        $list = [];
        foreach ($user_cumulate_result["data"] as $cumulate_k => $cumulate_v) {
            $temp_item                  = $cumulate_v;
            $temp_item['cumulate_user'] = empty($cumulate_v['cumulate_user']) ? 0 : $cumulate_v['cumulate_user'];
            $new_user                   = 0;
            $cancel_user                = 0;
            $net_growth_user            = 0;
            foreach ($user_summary_result['data'] as $key => $item) {
                if ($item["ref_date"] == $cumulate_v["ref_date"]) {
                    $new_user        += $item['new_user'];
                    $cancel_user     += $item['cancel_user'];
                    $net_growth_user += $item["new_user"] - $item["cancel_user"];
                }
            }
            $temp_item['new_user']        = $new_user;
            $temp_item['cancel_user']     = $cancel_user;
            $temp_item['net_growth_user'] = $net_growth_user;
            $list[]                       = $temp_item;
        }
        Cache::tag("wechat_visit")->set("wechat_fans_statistics_" . "_" . $begin_date . "_" . $end_date, $list);
        return $this->success($list);
    }

    /**
     * 接口访问数据图
     * @param $date_type
     * @return array
     */
    public function interfaceSummaryStatistics($date_type)
    {
        $date_data              = $this->getDaterange($date_type);
        $is_error               = true;
        $callback_count_data    = [];
        $fail_count_data        = [];
        $average_time_cost_data = [];
        $max_time_cost_data     = [];
        foreach ($date_data["date_list"] as $k => $v) {
            $callback_count    = 0;
            $fail_count        = 0;
            $average_time_cost = 0;
            $max_time_cost     = 0;
            if ($is_error) {
                $temp_data = $this->interfaceSummary($v, $v);
                if (!empty($temp_data["data"])) {
                    $temp_date_item    = $temp_data["data"];
                    $callback_count    = $temp_date_item[0]["callback_count"];
                    $fail_count        = $temp_date_item[0]["fail_count"];
                    $average_time_cost = $temp_date_item[0]["total_time_cost"] / $temp_date_item[0]["callback_count"];
                    $max_time_cost     = $temp_date_item[0]["max_time_cost"];
                } else {
                    $is_error = false;
                }
            }
            $callback_count_data[]    = $callback_count;
            $fail_count_data[]        = $fail_count;
            $average_time_cost_data[] = $average_time_cost;
            $max_time_cost_data[]     = $max_time_cost;
        }
        $return_data = array(
            "date" => $date_data["date_list"],
            "data" => array(
                "callback_count_data"    => $callback_count_data,
                "fail_count_data"        => $fail_count_data,
                "average_time_cost_data" => $average_time_cost_data,
                "max_time_cost_data"     => $max_time_cost_data
            )
        );
        return $this->success($return_data);
    }

    /**
     * 用户访问统计图
     * @param $date_type
     * @return array
     */
    public function userSummaryStatistics($date_type)
    {
        $is_error             = true;
        $date_data            = $this->getDaterange($date_type);
        $new_user_data        = [];
        $cancel_user_data     = [];
        $net_growth_user_data = [];
        $cumulate_user_data   = [];
        foreach ($date_data["date_list"] as $k => $v) {
            $new_user        = 0;
            $cancel_user     = 0;
            $net_growth_user = 0;
            $cumulate_user   = 0;
            if ($is_error) {
                $temp_data = $this->fans($v, $v);
                if (!empty($temp_data["data"])) {
                    $temp_date_item  = $temp_data["data"];
                    $new_user        = $temp_date_item[0]["new_user"];
                    $cancel_user     = $temp_date_item[0]["cancel_user"];
                    $net_growth_user = $temp_date_item[0]["net_growth_user"];
                    $cumulate_user   = $temp_date_item[0]["cumulate_user"];
                } else {
                    $is_error = false;
                }
            }

            $new_user_data[]        = $new_user;
            $cancel_user_data[]     = $cancel_user;
            $net_growth_user_data[] = $net_growth_user;
            $cumulate_user_data[]   = $cumulate_user;
        }
        $return_data = array(
            "date" => $date_data["date_list"],
            "data" => array(
                "new_user_data"        => $new_user_data,
                "cancel_user_data"     => $cancel_user_data,
                "net_growth_user_data" => $net_growth_user_data,
                "cumulate_user_data"   => $cumulate_user_data
            )
        );
        return $this->success($return_data);
    }

    /**
     * 获取时间间隔
     * @param $date_type
     * @return array
     */
    public function getDaterange($date_type)
    {
        $yesterday = strtotime('-1 days');
        switch ($date_type) {
            case 'yesterday':
                $yesterday  = strtotime('-1 days');
                $begin_time = $yesterday;
                $end_time   = $yesterday;
                break;
            case 'week':
                $week       = strtotime('-7 days');
                $begin_time = $week;
                $end_time   = $yesterday;
                break;
            case 'month':
                $month      = strtotime('-30 days');
                $begin_time = $month;
                $end_time   = $yesterday;
                break;
        }
        $date_x     = periodGroup($begin_time, $end_time, "Y-m-d");
        $begin_date = date("Ymd", $begin_time);
        $end_date   = date("Ymd", $end_time);
        $data       = array(
            "begin_date" => $begin_date,
            "end_date"   => $end_date,
            "date_list"  => $date_x,
        );
        return $data;
    }

}