<?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
     */
    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, $result);
        return $result;
    }

    /**
     * 获取累计用户数据, 最大时间跨度：7;
     * @param $begin_date
     * @param $end_date
     * @return array
     */
    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, $result);
        return $result;
    }

    /**
     * 获取接口分析分时数据, 最大时间跨度：1;
     * @param $begin_date
     * @param $end_date
     * @return array
     */
    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, $result);
        return $result;
    }

    /**
     * 获取接口分析数据, 最大时间跨度：30;
     * @param $begin_date
     * @param $end_date
     * @return array
     */
    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, $result);
        return $result;
    }

    /**
     * 获取微信粉丝统计(以天为单位)
     * @param $begin_date
     * @param $end_date
     * @return array
     */
    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;
    }

}