xyzshop/admin/control/orderstats.php

<?php


class orderstatsControl extends SystemControl
{
    private $task_type = [
        'refill_order_export' => '订单导出'
    ];

    private $task_state = [
        1   => '待处理',
        2   => '处理中',
        3   => '已处理',
        4   => '处理错误'
    ];

    public function __construct()
    {
        parent::__construct();
    }

    public function indexOp()
    {
        $type = $_GET['type'] ?? 'system';
        $page = "{$type}.order.stats";
        $model_refill_order = Model('refill_order');
        $condition['type'] = $type;
        if (!empty($_GET['cid'])) {
            $condition['cid'] = ['in', $_GET['cid']];
        }
        if (!empty($_GET['order_time_type'])) {
            $condition['order_time_type'] = $_GET['order_time_type'];
        }
        $start_unixtime = intval(strtotime($_GET['query_start_time']));
        $end_unixtime = intval(strtotime($_GET['query_end_time']));
        if ($start_unixtime > 0 && $end_unixtime > $start_unixtime) {
            $condition['time_stamp'] = [['egt', $start_unixtime], ['lt', $end_unixtime], 'and'];
        } elseif ($start_unixtime > 0) {
            $condition['time_stamp'] = ['egt', $start_unixtime];
        } elseif ($end_unixtime > 0) {
            $condition['time_stamp'] = ['lt', $end_unixtime];
        }

        $stats_list = $model_refill_order->getOrderStatsList($condition, 50, '*', 'time_stamp desc, cname asc');
        if($type == 'merchant') {
            foreach ($stats_list as $key => $stats) {
                $time = date("Y-m-d",$stats['time_stamp']+86400);
                $mch_cache = rcache("merchant_balance_{$time}", 'refill-');
                $caches = empty($mch_cache['data']) ? [] : unserialize($mch_cache['data']);
                if(empty($caches)) continue;
                $stats_list[$key]['available'] = ncPriceFormat($caches[$stats['cid']]) ?? '';
            }
        }
        
        $total_stats = $this->stats($condition);
        $order_time_type_text = ['notify_time' => '回调时间', 'order_time' => '下单时间'];
        Tpl::output('total_stats', $total_stats);
        Tpl::output('stats_list', $stats_list);
        Tpl::output('order_time_type_text', $order_time_type_text);
        Tpl::output('show_page', $model_refill_order->showpage());
        Tpl::showpage($page);
    }

    public function ExportDataOp()
    {
        $type = $_GET['type'] ?? 'system';
        $model_refill_order = Model('refill_order');
        $condition['type'] = $type;
        if (!empty($_GET['cid'])) {
            $condition['cid'] = ['in', $_GET['cid']];
        }
        if (!empty($_GET['order_time_type'])) {
            $condition['order_time_type'] = $_GET['order_time_type'];
        }
        $start_unixtime = intval($_GET['query_start_time']);
        $end_unixtime = intval($_GET['query_end_time']);
        if ($start_unixtime > 0 && $end_unixtime > $start_unixtime) {
            $condition['time_stamp'] = [['egt', $start_unixtime], ['lt', $end_unixtime], 'and'];
        } elseif ($start_unixtime > 0) {
            $condition['time_stamp'] = ['egt', $start_unixtime];
        } elseif ($end_unixtime > 0) {
            $condition['time_stamp'] = ['lt', $end_unixtime];
        }
        $stats_list = $this->all_orderstats_data($condition);

        $total_stats = $this->stats($condition);
        $stats = $total_stats[$_GET['order_time_type']];
        if(empty($stats)) {
            $stats = $total_stats['notify_time'];
        }
        $result['data'] = $stats_list;
        $result['total_stats'] = $stats;
        echo(json_encode($result));
        exit;
    }

    private function stats($condition)
    {
        $order_time_type = ['notify_time','order_time'];
        foreach ($order_time_type as $type){
            $condition['order_time_type'] = $type;
            $stats = Model('')->table('refill_stats')
                ->field('sum(success_count) as success_count,sum(success_refill_amounts) as success_refill_amounts,sum(success_mch_amounts) as success_mch_amounts,sum(success_channel_amounts) as success_channel_amounts,sum(profit_amounts) as profit_amounts')
                ->where($condition)
                ->find();
            $total_stats[$type] = [
                'success_count_total' => $stats['success_count'],
                'success_refill_amounts_total' => ncPriceFormat($stats['success_refill_amounts']),
                'success_mch_amounts_toatl' => ncPriceFormat($stats['success_mch_amounts']),
                'success_channel_amounts_total' => ncPriceFormat($stats['success_channel_amounts']),
                'profit_amounts_total' => ncPriceFormat($stats['profit_amounts'])
            ];
        }
        return $total_stats;
    }

    private function all_orderstats_data($condition): array
    {
        $i = 0;
        $result = [];
        while (true) {
            $start = $i * 1000;
            $list = Model('')->table('refill_stats')->field('*')
                ->where($condition)->order('time_stamp desc')->limit("{$start},1000")->select();
            if (empty($list)) {
                break;
            }
            $i++;
            foreach ($list as $value) {
                $result[] = $value;
            }
        }
        return $result;
    }
    public function refill_taskOp()
    {
        $model = Model('task');
        $condition['is_show'] = 1;
        if(!empty($_GET['type'])) {
            $condition['type'] = $_GET['type'];
        }
        if(!empty($_GET['task_id'])) {
            $condition['task_id'] = $_GET['task_id'];
        }
        if(!empty($_GET['state'])) {
            $condition['state'] = $_GET['state'];
        }
        $task_list = $model->getList($condition, 50);
        foreach ($task_list as $key => $value) {
            $task_list[$key]['condition'] = unserialize($value['task_params']);
            $task_list[$key]['result'] = unserialize($value['result']);
        }

        Tpl::output('list', $task_list);
        Tpl::output('task_type', $this->task_type);
        Tpl::output('task_state', $this->task_state);
        Tpl::showpage('refill.task');
    }

    public function task_delOp()
    {
        $task_id = $_GET['task_id'];
        $model = Model('task');
        $resp = $model->Del($task_id);
        if($resp) {
            showMessage('删除成功', 'index.php?act=OrderStats&&op=refill_task');
        }else{
            showMessage('任务删除失败');
        }
    }
}