xyzshop/admin/control/refill_order.php

<?php

require_once(BASE_HELPER_PATH . '/refill/util.php');
require_once(BASE_HELPER_PATH . '/task/task_helper.php');

class refill_orderControl extends SystemControl
{
    public function __construct()
    {
        parent::__construct();
    }

    public function indexOp()
    {
        $fShowStat = $_GET['fShowStat'];
        $this->refill_order($fShowStat == 1);
    }

    public function refill_order($fShowStat = false)
    {
        $model_refill_order = Model('refill_order');
        $cond['inner_status'] = 0;
        $_GET['query_start_time'] = $_GET['query_start_time'] ?? date("Y-m-d H:i:s", strtotime("-1 hours"));

        if (!empty($_GET['order_sn'])) {
            $cond['refill_order.order_sn'] = $_GET['order_sn'];

        }
        if (!empty($_GET['mch_order'])) {
            $cond['refill_order.mch_order'] = $_GET['mch_order'];

        }
        if (!empty($_GET['ch_trade_no'])) {
            $cond['refill_order.ch_trade_no'] = $_GET['ch_trade_no'];

        }
        if (!empty($_GET['card_no'])) {
            $cond['refill_order.card_no'] = $_GET['card_no'];

        }
        if (!empty($_GET['no_mchid'])) {
            $no_mchid = explode(',', $_GET['no_mchid']);
            $cond['refill_order.mchid'] = ['not in', $no_mchid];
        }
        if (!empty($_GET['no_amount'])) {
            $no_amount = explode(',', $_GET['no_amount']);
            $cond['refill_order.refill_amount'] = ['not in', $no_amount];
        }

        if (!empty($_GET['mchid'])) {
            $cond['refill_order.mchid'] = $_GET['mchid'];
        }
        if (!empty($_GET['channel_name'])) {
            $cond['refill_order.channel_name'] = $_GET['channel_name'];
        }
        if (!empty($_GET['store_id'])) {
            $cond['vr_order.store_id'] = $_GET['store_id'];
        }
        if (!empty($_GET['refill_amount'])) {
            $cond['refill_order.refill_amount'] = $_GET['refill_amount'];
        }
        if (!empty($_GET['quality'])) {
            $cond['refill_order.quality'] = $_GET['quality'];
        }
        if(!empty($_GET['official_status'])) {
            if($_GET['official_status'] == 1) {
                $cond['official_sn'] = '';
            } elseif ($_GET['official_status'] == 2) {
                $cond['official_sn'] = ['neq', ''];
            }
        }

        if (!empty($_GET['card_type'])) {
            if (in_array($_GET['card_type'], ['1', '2', '4', '5', '6', '7'])) {
                $cond['refill_order.card_type'] = intval($_GET['card_type']);
            }
            if ($_GET['card_type'] == 'oil') {
                $cond['refill_order.card_type'] = ['in', [1, 2]];
            }
            if ($_GET['card_type'] == 'phone') {
                $cond['refill_order.card_type'] = ['in', [4, 5, 6]];
            }
        }

        $fToday = false;
        $start_unixtime = intval(strtotime($_GET['query_start_time']));
        $end_unixtime = intval(strtotime($_GET['query_end_time']));

        if($end_unixtime <= 0) {
            $cur_time = time();
            $cur_time = $cur_time - ($cur_time % 300) + 300;
            $end_unixtime = $cur_time;
        }

        if ($start_unixtime > 0 && $end_unixtime > $start_unixtime) {
            $cond['refill_order.order_time'] = [['egt', $start_unixtime], ['lt', $end_unixtime], 'and'];
            $cond['vr_order.add_time'] = [['egt', $start_unixtime],['lt', $end_unixtime], 'and'];
        } elseif ($start_unixtime > 0) {
            $cond['refill_order.order_time'] = ['egt', $start_unixtime];
            $cond['vr_order.add_time'] = ['egt', $start_unixtime];
        } elseif ($end_unixtime > 0) {
            $cond['refill_order.order_time'] = ['lt', $end_unixtime];
        } else {
            $start = time() - 3600;
            $_GET['query_start_time'] = date("Y-m-d H:i:s",$start);
            $cond['refill_order.order_time'] = ['egt', $start];
            $cond['vr_order.add_time'] = ['egt', $start-1];
            $fToday = true;
        }

        if(in_array($_GET['cardno_state'], ['0','1', '2', '4', '5'])) {
            $cond['refill_order.cardno_state'] = $_GET['cardno_state'];
        }
        if(in_array($_GET['is_transfer'], ['0','1'])) {
            $cond['refill_order.is_transfer'] = $_GET['is_transfer'];
        }

        if (in_array($_GET['order_state'], ['0', '10', '20', '30', '40']))
        {
            $cond['vr_order.order_state'] = $_GET['order_state'];

            if ($_GET['order_state'] == ORDER_STATE_SEND) {
                if ($_GET['time'] == 1) {
                    $cond['refill_order.order_time'] = ['between', [(time() - 3600), (time() - 1800)]];
                }
                if ($_GET['time'] == 2) {
                    $cond['refill_order.order_time'] = ['lt', (time() - 3600)];
                }
            }
        }

        if (!empty($_GET['export']) || !empty($_GET['export_stats'])) {
            if (empty($_GET['query_end_time'])) {
                showMessage('订单导出条件必须含有结束日期.');
            } else {
                $this->RefillOrderExport($cond);
            }
            return;
        }
        if (!empty($_GET['mch_notify'])) {
            $this->mch_notify($cond);
            return;
        }
        if (!empty($_GET['order_query'])) {
            $this->updateOrderSend($cond);
            return;
        }
        $merchant_list = $this->merchants();
        $order_list = $model_refill_order->getMerchantOrderList($cond, 200, 'refill_order.*,vr_order.order_state', 'refill_order.order_time desc');
        $order_list = $this->OrderDataFormat($order_list, $merchant_list);

        $provider_list = $this->providers();

        if ($fShowStat)
        {
            $manager = new task\manager();
            $task = $manager->add_task('refill_order_stat',$cond,0,600);
            if($task->completed() && $task->success())
            {
                $stat = $task->result();
                Tpl::output('stat', $stat);
                Tpl::output('comments', false);
                Tpl::output('end_unixtime', $end_unixtime);
            }else{
                Tpl::output('comments', true);
            }
        }

        $dispatcher_queue_length = refill\util::dispatcher_queue_length();
        Tpl::output('dispatcher_queue_length', $dispatcher_queue_length);
        Tpl::output('admin_info', $this->getAdminInfo());
        Tpl::output('ftoday', $fToday);
        Tpl::output('order_list', $order_list);
        Tpl::output('provider_list', $provider_list);
        Tpl::output('merchant_list', $merchant_list);
        Tpl::output('show_page', $model_refill_order->showpage());
        Tpl::showpage('refill.order.index');
    }

    private function RefillOrderExport($cond)
    {
        if(!empty($_GET['export_stats'])) {
            if(!empty($cond['refill_order.order_time'])) {
                $cond['refill_order.notify_time'] = $cond['refill_order.order_time'];
                unset($cond['refill_order.order_time']);
                unset($cond['vr_order.add_time']);
            }
        }
        $manager = new task\manager();
        $task = $manager->add_task('refill_order_export',$cond,1);
        if ($task->completed() && $task->success()) {
            $file_name = $task->result();
            $file_path = UPLOAD_SITE_URL . '/' . ATTACH_TASK . DS . $file_name;
            header("Content-Disposition: attachment; filename={$file_name}");
            readfile($file_path);
        } else {
            $task_id = $task->task_id();
            showMessage("录入成功,任务ID:{$task_id},请稍后以相同条件再次导出,或在任务列表直接下载。","index.php?act=task&op=index&task_id={$task_id}");
        }
    }

    private function all_order_state_stat($condition)
    {
        $counts = Model('')->table('refill_order,vr_order')->join('inner')
            ->on('refill_order.order_id=vr_order.order_id')
            ->field('count(*) as order_count, sum(refill_amount) as refill_amounts, sum(channel_amount) as channel_amounts, sum(mch_amount) as mch_amounts, order_state')
            ->where($condition)
            ->group('order_state')
            ->select();

        $all = [];
        $data['order_count'] = $data['refill_amounts'] = $data['channel_amounts'] = $data['mch_amounts'] = 0;
        $sending = $success = $cancel = $data;
        foreach ($counts as $count) {
            if ($count['order_state'] == ORDER_STATE_SEND) {
                $sending = $count;
            } elseif ($count['order_state'] == ORDER_STATE_SUCCESS) {
                $success = $count;
            } elseif ($count['order_state'] == ORDER_STATE_CANCEL) {
                $cancel = $count;
            }

            $all['order_count'] += $count['order_count'];
            $all['refill_amounts'] += ncPriceFormat($count['refill_amounts']);
            $all['channel_amounts'] += ncPriceFormat($count['channel_amounts']);
            $all['mch_amounts'] += ncPriceFormat($count['mch_amounts']);
        }

        return ['all' => $all, 'sending' => $sending, 'success' => $success, 'cancel' => $cancel];
    }

    public function merchant_dataOp()
    {
        $merchant_list = $this->merchants();
        $result = [];
        foreach ($merchant_list as $value) {
            $data['name'] = $value['company_name'] ?? $value['name'];
            $data['value'] = $value['mchid'];
            $data['alpha'] = $value['alpha'];
            $data['color'] = false;
            $result[] = $data;
        }
        echo json_encode($result);
    }

    public function provider_dataOp()
    {
        $provider_list = $this->providers();
        $result = [];
        foreach ($provider_list as $value) {
            $data['name'] = $value['store_name'] ?? $value['name'];
            $data['value'] = $value['store_id'];
            $result[] = $data;
        }
        echo json_encode($result);
    }

    public function refill_third_infoOp()
    {
        $order_id = $_GET['order_id'];
        $model_refill_order = Model('refill_order');
        $order_info = $model_refill_order->getOrderInfo(['order_id' => $order_id]);
        if (empty($order_info) || $order_info['card_type'] != mtopcard\ThirdRefillCard) {
            $res = ['state' => -1, 'msg' => '订单不存在或类型错误'];
            exit(json_encode($res));
        }
        $third_refill = Model('thrid_refill');
        $data = $third_refill->getThird($order_id);
        $data['card_info'] = $data['card_info'] ?? '';
        $account_type_text = ['手机号','QQ号','微信号'];
        $data['account_type_text'] = $account_type_text[$data['account_type']-1];
        $ret_state_text = ['初始化','已解析','解析失败'];
        $data['ret_state_text'] = $ret_state_text[$data['ret_state']];
        $res = ['state' => 1, 'data' => $data];
        exit(json_encode($res));
    }

    public function showOrdersOp()
    {
        $order_sn = $_GET['order_sn'] ?? '';
        $model_refill_order = Model('refill_order');
        $refill_info = $model_refill_order->getOrderInfo(['order_sn' => $order_sn]);
        if (empty($refill_info)) {
            $res = ['state' => -1, 'msg' => '订单不存在'];
            exit(json_encode($res));
        }
        $mch_order = $refill_info['mch_order'];
        $order_time = $refill_info['order_time'];
        $mchid = $refill_info['mchid'];

        $condition['refill_order.mch_order'] = $mch_order;
        $condition['refill_order.order_time'] = ['egt', $order_time];
        $condition['refill_order.mchid'] = $mchid;

        $field = 'refill_order.order_sn,refill_order.commit_time,refill_order.notify_time,refill_order.channel_name,vr_order.order_state,refill_order.err_msg,vr_order.close_reason';
        $order_list = $model_refill_order->getMerchantOrderList($condition, 1000, $field);

        foreach ($order_list as $order_id => $order_info) {
            $order_list[$order_id]['order_state_text'] = orderState($order_info);
            $order_list[$order_id]['notify_time_text'] = '/';
            $order_list[$order_id]['commit_time_text'] = date("Y-m-d H:i:s", $order_info['commit_time']);
            if ($order_info['notify_time'] > 0) {
                if($order_info['commit_time'] == 0) {
                    $diff_time = 0;
                    $order_list[$order_id]['order_state_text'] = '提交失败';
                    $order_list[$order_id]['commit_time_text'] = '/';
                }else{
                    $diff_time = $order_info['notify_time'] - $order_info['commit_time'];
                    $order_list[$order_id]['notify_time_text'] = date("Y-m-d H:i:s", $order_info['notify_time']);
                }
            } else {
                if($order_info['commit_time'] == 0) {
                    $diff_time = 0;
                    $order_list[$order_id]['order_state_text'] = '提交失败';
                    $order_list[$order_id]['commit_time_text'] = '/';
                } else {
                    $diff_time = time() - $order_info['commit_time'];
                    if($order_info['order_state'] != ORDER_STATE_SEND) {
                        $diff_time = 0;
                        $order_list[$order_id]['order_state_text'] = '提交失败';
                    }
                }
            }
            if($diff_time != 0) {
                $order_list[$order_id]['diff_time_text'] = $this->elapse_time($diff_time);
            } else {
                $order_list[$order_id]['diff_time_text'] = '/';
            }
            $order_list[$order_id]['diff_time'] = $diff_time;
        }
        $mch_notify_state = ['未确认','已确认','回调失败'];
        $res = ['state' => 1,
            'data' => $order_list,
            'count' => count($order_list),
            'mch_notify_times' => $refill_info['mch_notify_times'],
            'mch_notify_state' => $mch_notify_state[$refill_info['mch_notify_state']]
        ];
        exit(json_encode($res));
    }

    private function mch_notify($condition)
    {
        $condition['mch_notify_state'] = 0;
        $condition['inner_status'] = 0;
        $condition['is_retrying'] = 0;

        $orders = Model('refill_order')->getAllOrders($condition);
        if (!empty($orders))
        {
            foreach ($orders as $order)
            {
                $order_id = $order['order_id'];
                if ($order['order_state'] == ORDER_STATE_SEND) {
                    QueueClient::push("QueryRefillState", ['order_id' => $order_id]);
                } else {
                    QueueClient::push("NotifyMerchantComplete", ['order_id' => $order_id, 'manual' => true]);
                }
            }
        }

        showMessage('操作成功');
    }

    private function updateOrderSend($condition)
    {
        $condition['order_state'] = ORDER_STATE_SEND;
        $orders = Model('refill_order')->getAllOrders($condition);

        if (!empty($orders)) {
            foreach ($orders as $order) {
                $order_id = $order['order_id'];
                Log::record("updateOrderSend order_id={$order_id}",Log::DEBUG);
                QueueClient::push("QueryRefillState", ['order_id' => $order_id]);
            }
        }
        showMessage('操作成功');
    }
}