xyzshop/admin/control/merchant.php

<?php
/**
 * 机构管理界面
 *
 **by 好商城V3 www.33hao.com 运营版*/

defined('InShopNC') or exit('Access Invalid!');

require_once(BASE_HELPER_PATH . '/refill/RefillFactory.php');
require_once(BASE_CONFIG_PATH . CONFIG_PREFIX . '/refill.ini.php');
require_once(BASE_ROOT_PATH . '/core/framework/function/http.php');

class merchantControl extends SystemControl
{
    const EXPORT_SIZE = 1000;

    public function __construct()
    {
        parent::__construct();
        Language::read('merchant');
    }

    /**
     * 机构列表
     */
    public function merchantOp()
    {
        $model_merchant = Model('merchant');

        if (trim($_GET['merchant_name']) != '') {
            $condition['name'] = ['like', '%' . $_GET['merchant_name'] . '%'];
            Tpl::output('merchant_name', $_GET['merchant_name']);
        }

        $merchant_list = $model_merchant->getMerchantList($condition, 25, 'available_predeposit desc');

        $merchant_state_text = ['使用中', '已禁用'];
        Tpl::output('merchant_state_text', $merchant_state_text);
        Tpl::output('merchant_list', $merchant_list);
        Tpl::output('page', $model_merchant->showpage('2'));
        Tpl::showpage('merchant.index');
    }

    public function changeStateOp()
    {
        $mchid = intval($_GET['mchid']);
        $state = intval($_GET['state']);
        $model_merchant = Model('merchant');
        $merchant_info = $model_merchant->getMerchantInfo(['mchid' => $mchid]);
        if (empty($merchant_info) || !in_array($state, [1, 2])) {
            showMessage('操作成功', 'index.php?act=merchant&op=merchant');
        }
        $resp = $model_merchant->editMerchant(['merchant_state' => $state], ['mchid' => $mchid]);
        if (!$resp) {
            showMessage('操作失败', 'index.php?act=merchant&op=merchant', 'html', 'error');
        }
        showMessage('操作成功', 'index.php?act=merchant&op=merchant');
    }

    /**
     * 新增机构
     */
    public function merchant_addOp()
    {
        if (chksubmit()) {
            /**
             * 验证
             */
            $obj_validate = new Validator();
            $obj_validate->validateparam = [
                ["input" => $_POST["name"], "require" => "true", "message" => '机构账号不能为空'],
                ["input" => $_POST["company_name"], "require" => "true", "message" => '机构公司名称不能为空'],
                ["input" => $_POST["password"], "require" => "true", "message" => '密码不能为空']
            ];
            $error = $obj_validate->validate();
            if ($error != '') {
                showMessage($error);
            } else {
                $name = trim($_POST['name']);
                $company_name = trim($_POST['company_name']);
                $pwd = trim($_POST['password']);
                $alarm_amount = $_POST['alarm_amount'] ?? 0;
                $model_merchant = Model('merchant');
                $model_member = Model('member');
                try {
                    $trans = new trans_wapper($model_merchant, __METHOD__);
                    $insert_member['member_name'] = md5($name . time());
                    $insert_member['member_passwd'] = $pwd;
                    $insert_id = $model_member->addMember($insert_member);
                    if ($insert_id == false) {
                        $trans->rollback();
                        showMessage('操作失败', 'index.php?act=merchant&op=merchant', 'html', 'error');
                    }
                    $insert_array['name'] = $name;
                    $insert_array['company_name'] = $company_name;
                    $insert_array['org_pwd'] = $pwd;
                    $insert_array['password'] = md5($pwd);
                    $insert_array['admin_id'] = trim($insert_id);
                    $insert_array['alarm_amount'] = $alarm_amount;
                    $result = $model_merchant->addMerchant($insert_array);
                    if ($result) {
                        $url = [
                            [
                                'url' => 'index.php?act=merchant&op=merchant',
                                'msg' => '返回机构列表',
                            ],
                            [
                                'url' => 'index.php?act=merchant&op=merchant_add',
                                'msg' => '继续新增机构',
                            ],
                        ];
                        $this->log('添加机构:' . '[	' . $_POST['name'] . ']', 1);
                        showMessage('机构添加成功', $url);
                    } else {
                        showMessage('机构添加失败');
                    }
                    $trans->commit();
                    showMessage('操作成功', 'index.php?act=merchant&op=merchant');
                } catch (Exception $e) {
                    $trans->rollback();
                    showMessage('操作失败', 'index.php?act=merchant&op=merchant', 'html', 'error');
                }
            }
        }
        Tpl::showpage('merchant.add');
    }

    public function merchant_editOp()
    {
        $mchid = $_GET['mchid'] ?? $_POST['mchid'];
        $model_merchant = Model('merchant');
        $merchant = $model_merchant->getMerchantInfo(['mchid' => $mchid]);
        if (empty($merchant)) {
            showMessage('机构信息有误');
        }
        if (chksubmit()) {
            $update['company_name'] = trim($_POST['company_name']);
            $update['org_pwd'] = trim($_POST['password']);
            $update['password'] = md5($update['org_pwd']);
            $update['alarm_amount'] = $_POST['alarm_amount'] ?? 0;
            $update['credit_bonus'] = ncPriceFormat($_POST['credit_bonus']);
            $update['time_out'] = intval($_POST['time_out']);
            $update['quality'] = intval($_POST['quality']);
            $member_id = $merchant['admin_id'];
            try {
                $model_merchant = Model('merchant');
                $trans = new trans_wapper($model_merchant, __METHOD__);
                if ($merchant['credit_bonus'] == $update['credit_bonus']) {
                    unset($update['credit_bonus']);
                } elseif ($merchant['credit_bonus'] > $update['credit_bonus']) {
                    $credit_bonus = ncPriceFormat($merchant['credit_bonus'] - $update['credit_bonus']);
                    $this->credit_save_money($credit_bonus, 2, $member_id);
                } elseif ($merchant['credit_bonus'] < $update['credit_bonus']) {
                    $credit_bonus = ncPriceFormat($update['credit_bonus'] - $merchant['credit_bonus']);
                    $this->credit_save_money($credit_bonus, 1, $member_id);
                }

                $result = $model_merchant->editMerchant($update, ['mchid' => $mchid]);
                if (!$result) {
                    $trans->rollback();
                    showMessage('机构编辑失败', 'index.php?act=merchant&op=merchant');
                }
                $this->log('编辑机构:' . '[	' . $merchant['name'] . ']', 1);
                $trans->commit();
                showMessage('机构编辑成功', 'index.php?act=merchant&op=merchant');
            } catch (Exception $e) {
                $trans->rollback();
                showMessage('机构编辑失败', 'index.php?act=merchant&op=merchant');
            }
        }
        Tpl::output('merchant', $merchant);
        Tpl::showpage('merchant.edit');
    }

    private function credit_save_money($money, $operatetype, $member_id, $bz = '')
    {
        $obj_member = Model('member');
        $member_id = intval($member_id);
        $member_info = $obj_member->getMemberInfo(['member_id' => $member_id]);
        $admininfo = $this->getAdminInfo();
        switch ($operatetype) {
            case 1:
                $admin_act = "sys_add_money";
                $log_msg = "管理员【" . $admininfo['admin_name'] . "】操作会员【" . $member_info['member_name'] . "】,预存款【增加】，金额为" . $money;
                break;
            case 2:
                $admin_act = "sys_del_money";
                $log_msg = "管理员【" . $admininfo['admin_name'] . "】操作会员【" . $member_info['member_name'] . "】,预存款【减少】，金额为" . $money;
                break;
            default:
                return [false, '调节类型错误'];
                break;
        }
        $model_pd = Model('predeposit');
        //调节预存款
        $data = [];
        $data['member_id'] = $member_info['member_id'];
        $data['member_name'] = $member_info['member_name'];
        $data['amount'] = $money;
        $data['order_sn'] = '';
        $data['admin_name'] = $admininfo['name'];
        $data['pdr_sn'] = '';
        $data['lg_desc'] = $bz ? $bz : '管理员操作客户授信，更改会员余额。';
        $model_pd->changePd($admin_act, $data);

        $this->log($log_msg, 1);
        return [true, 'success'];
    }

    public function priceOp()
    {
        $quality = $_GET['quality'] ? $_GET['quality'] : 1;
        if (chksubmit()) {
            $mchid = $_POST['mchid'];

            //合并表单数据
            $card_types = $_POST['cardtype'];
            $specs = $_POST['spec'];
            $prices = $_POST['price'];
            foreach ($card_types as $key => $card_type) {
                $data['card_type'] = $card_type;
                $data['spec'] = intval($specs[$key]);
                $data['price'] = ncPriceFormat($prices[$key]);
                $params[] = $data;
            }

            foreach ($params as $param) {
                if ($param['price'] > 0) {
                    $insert['mchid'] = $mchid;
                    $insert['spec'] = $param['spec'];
                    $insert['price'] = $param['price'];
                    $insert['card_types'] = $param['card_type'];
                    $insert['quality'] = $quality;
                    $inserts[] = $insert;
                }
            }

            try {
                $model_merchant = Model('merchant');
                $trans = new trans_wapper($model_merchant, __METHOD__);
                //删除旧费率
                $model_merchant->delPrices($mchid, $quality);
                //更新新费率
                if (!empty($inserts)) {
                    $model_merchant->insertPrices($inserts);
                }
                $trans->commit();
                showMessage('操作成功', 'index.php?act=merchant&op=merchant');
            } catch (Exception $e) {
                $trans->rollback();
                showMessage('操作失败', 'index.php?act=merchant&op=merchant', 'html', 'error');
            }
        }
        $mchid = $_GET['mchid'] ?? 0;
        $goods = $this->GoodsFormat($mchid, $quality);
        Tpl::output('goods', $goods);
        Tpl::showpage('merchant.price');
    }

    private function GoodsFormat($mchid, $quality)
    {
        $all_spector = function () {
            global $config;
            $refill_specs = $config['refill_specs'];

            $all_type_specs = [];
            foreach ($refill_specs as $scard_type => $specs) {
                if ($scard_type == 'petrochina') { //中石油
                    $card_type = 1;
                } elseif ($scard_type == 'sinopec') { //中石化
                    $card_type = 2;
                } elseif ($scard_type == 'chinamobile') { //中国移动
                    $card_type = 4;
                } elseif ($scard_type == 'chinaunicom') { //中国联通
                    $card_type = 5;
                } elseif ($scard_type == 'chinatelecom') { //中国电信
                    $card_type = 6;
                } else {
                    continue;
                }

                $all_type_specs[$card_type] = $specs;
            }

            $result = [];
            foreach ($all_type_specs as $card_type => $specs) {
                foreach ($specs as $spec) {
                    $result["{$card_type}-{$spec}"] = ['card_type' => $card_type, 'spec' => $spec];
                }
            }
            return $result;
        };

        $merch_spector = function ($mchid, $quality) {
            $model_merchant = Model('merchant');
            $items = $model_merchant->table('merchant_price')->where(['mchid' => $mchid, 'quality' => $quality])->select();

            $result = [];
            foreach ($items as $item) {
                $card_types = explode(',', $item['card_types']);
                foreach ($card_types as $card_type) {
                    $value['spec'] = intval($item['spec']);
                    $result["{$card_type}-{$value['spec']}"] = ['card_type' => $card_type,
                        'spec' => intval($item['spec']),
                        'price' => $item['price']];
                }
            }
            return $result;
        };

        $all_cardtype_specs = $all_spector();
        $merch_cardtype_specs = $merch_spector($mchid, $quality);

        $merger = function ($all_specs, $mech_specs) {
            $result = [];
            foreach ($all_specs as $cardtype_spec => $value) {
                $card_name = $this->scard_type($value['card_type']);

                $data = [];
                $data['goods_name'] = $card_name;
                $data['card_type'] = $value['card_type'];
                $data['spec'] = $value['spec'];

                if (array_key_exists($cardtype_spec, $mech_specs)) {
                    $data['price'] = $mech_specs[$cardtype_spec]['price'];
                } else {
                    $data['price'] = 0;
                }

                $result[$value['card_type']][] = $data;
            }

            return $result;
        };

        $result = $merger($all_cardtype_specs, $merch_cardtype_specs);

        return $result;
    }

    public function check_merchantOp()
    {
        $mchid = trim($_GET['mchid']);
        if (!$mchid) {
            echo '';
            die;
        }
        $model_merchant = Model('merchant');
        $merchant_info = $model_merchant->getMerchantInfo(['mchid' => $mchid], '*');
        if (empty($merchant_info)) {
            echo '';
            die;
        }
        echo 'true';
    }

    /**
     * ajax操作
     */
    public function ajaxOp()
    {
        $model_merchant = Model('merchant');
        switch ($_GET['branch']) {
            /**
             * 验证机构名称是否重复
             */
            case 'check_mch_name':
                $condition['name'] = $_GET['name'];
                $list = $model_merchant->getMerchantInfo($condition);
                if (empty($list)) {
                    echo 'true';
                } else {
                    echo 'false';
                }
                exit;

            /**
             * 验证机构是否存在
             */
            case 'check_merchant':
                $condition['mchid'] = intval($_GET['mchid']);
                $list = $model_merchant->getMerchantInfo($condition);
                if (!empty($list)) {
                    echo 'true';
                } else {
                    echo 'false';
                }
                exit;
        }
    }

    /**
     * 充值申请列表
     */
    public function refill_evidenceOp()
    {
        $model_merchant = Model('merchant');
        $condition = [];
        if (trim($_GET['mch_name']) != '') {
            $condition['mch_name'] = ['like', '%' . $_GET['mch_name'] . '%'];
            Tpl::output('mch_name', $_GET['mch_name']);
        }
        $state_sel = intval($_REQUEST['state_sel']);
        if ($state_sel == 1) {
            $condition['check_time'] = 0;
            $condition['status'] = 1;
        } elseif ($state_sel == 2) {
            $condition['check_time'] = ['gt', 0];
            $condition['status'] = 2;
        } elseif ($state_sel == 3) {
            $condition['check_time'] = ['gt', 0];
            $condition['status'] = 3;
        } else {
        }

        $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['add_time'] = [['egt', $start_unixtime], ['lt', $end_unixtime], 'and'];
        } elseif ($start_unixtime > 0) {
            $condition['add_time'] = ['egt', $start_unixtime];
        } elseif ($end_unixtime > 0) {
            $condition['add_time'] = ['lt', $end_unixtime];
        }

        //充值申请列表
        $evidence_list = $model_merchant->getRefillEvidence($condition, 20, '*,member.available_predeposit', 'refill_evidence.add_time desc');
        $status_text = ['申请中', '已通过', '已驳回'];
        $operation_text = ['未预存', '已预存'];
        $add_type_text = ['商户预存','后台手动预存'];

        $counts = Model('')->table('refill_evidence')
            ->field('sum(amount) as amounts,status')
            ->where($condition)
            ->group('status')
            ->select();
        $success_amount = $send_amount = $cancel_amount = 0;
        foreach ($counts as $count) {
            if($count['status'] == 1) {
                $send_amount += $count['amounts'];
            }elseif ($count['status'] == 2) {
                $success_amount += $count['amounts'];
            }elseif ($count['status'] == 3) {
                $cancel_amount += $count['amounts'];
            }
        }
        $stats['send_amount'] = $send_amount;
        $stats['success_amount'] = $success_amount;
        $stats['cancel_amount'] = $cancel_amount;
        Tpl::output('stats', $stats);
        Tpl::output('evidence_list', $evidence_list);
        Tpl::output('status_text', $status_text);
        Tpl::output('operation_text', $operation_text);
        Tpl::output('add_type_text', $add_type_text);
        Tpl::output('page', $model_merchant->showpage('2'));
        Tpl::showpage('merchant.refill.evidence_list');
    }

    public function check_evidenceOp()
    {
        $status = $_GET['status'];
        $apply_id = intval($_GET['apply_id']);
        if ($apply_id > 0) {
            $model_merchant = Model('merchant');
            $evidence_info = $model_merchant->getRefillEvidenceInfo(['apply_id' => $apply_id], '*');
            if (empty($evidence_info)) {
                showMessage('充值申请不存在');
            }

            if ($status == 'pass') {
                $model_merchant->editRefillEvidence(['apply_id' => $apply_id], ['status' => 2, 'check_time' => time()]);
            } elseif ($status == 'unpass') {
                $model_merchant->editRefillEvidence(['apply_id' => $apply_id], ['status' => 3, 'check_time' => time()]);
            } else {

            }
        }
        showMessage(L('nc_common_save_succ'), urlAdmin('merchant', 'refill_evidence'));
    }

    public function rechargeOp()
    {
        if (chksubmit()) {
            $mchid = $this->add_money();
            $model_merchant = Model('merchant');
            $merchant_info = $model_merchant->getMerchantInfo(['mchid' => $mchid]);
            if ($merchant_info['alarm_amount'] < $merchant_info['available_predeposit']) {
                //更新预警短信通知限制
                $mch_cache = rcache("merchant-notify", 'refill-');
                $caches = empty($mch_cache['data']) ? [] : unserialize($mch_cache['data']);
                $caches[$mchid] = ['last_time' => 0, 'send_count' => 0];
                wcache("merchant-notify", ['data' => serialize($caches)], 'refill-');
            }
            showMessage('操作成功', 'index.php?act=merchant&op=refill_evidence');
        } else {
            $apply_id = $_GET['apply_id'];
            if (!empty($apply_id)) {
                $model_merchant = Model('merchant');
                $evidence_info = $model_merchant->getRefillEvidenceInfo(['apply_id' => $apply_id], '*,member.available_predeposit');
                Tpl::output('apply_id', $apply_id);
                Tpl::output('amount', $evidence_info['amount']);
                Tpl::output('available_predeposit', $evidence_info['available_predeposit']);
            }
            Tpl::showpage('recharge.add');
        }
    }

    public function recharge_manualOp()
    {
        $type = $_GET['type'] ?? $_POST['type'];
        if (chksubmit()) {
            $obj_validate = new Validator();
            if($type == 'add') {
                $obj_validate->validateparam = [
                    ["input" => $_POST["mch_id"], "require" => "true", "message" => '机构号不能为空'],
                    ["input" => $_POST["bank_username"], "require" => "true", "message" => '开户人姓名不能为空'],
                    ["input" => $_POST["bank_name"], "require" => "true", "message" => '开户银行不能为空'],
                    ["input" => $_POST["pointsnum"], "require" => "true", "message" => '预存金额不能为空']
                ];
            } elseif ($type == 'edit') {
                $obj_validate->validateparam = [
                    ["input" => $_POST["mch_id"], "require" => "true", "message" => '机构号不能为空'],
                    ["input" => $_POST["bank_username"], "require" => "true", "message" => '操作人姓名不能为空'],
                    ["input" => $_POST["pointsnum"], "require" => "true", "message" => '预存金额不能为空']
                ];
            }

            $error = $obj_validate->validate();
            if ($error != '') {
                showMessage($error);
            }
            $mchid = $_POST["mch_id"];
            $model_merchant = Model('merchant');
            $merchant_info = $model_merchant->getMerchantInfo(['mchid' => $mchid]);
            if (!$merchant_info) {
                showMessage('对应机构不存在');
            }
            $pointsnum = $_POST['pointsnum'];
            $money = abs($pointsnum);
            if ($money == 0) {
                showMessage('预存金额错误');
            }
            if(!empty($_FILES['voucher']['name'])) {
                $upload = new UploadFile();
                $upload->set('default_dir',ATTACH_UPFILE);

                $result = $upload->upfile('voucher');
                if ($result){
                    $_POST['voucher_name'] = $upload->file_name;
                }else {
                    showMessage($upload->error);
                }
            }
            try {
                $model_merchant = Model('merchant');
                $trans = new trans_wapper($model_merchant, __METHOD__);
                $member_id = $merchant_info['admin_id'];
                if ($pointsnum > 0) {
                    $bz = '管理员操作手动预存金额增加';
                    $this->credit_save_money($money, 1, $member_id, $bz);
                } elseif ($pointsnum < 0) {
                    $bz = '管理员操作手动预存金额减少';
                    $this->credit_save_money($money, 2, $member_id, $bz);
                } else {
                    showMessage('预存金额错误');
                }
                $result = $this->ct_refill_evidence($_POST, $merchant_info);
                if (!$result) {
                    $trans->rollback();
                    showMessage('操作失败', 'index.php?act=merchant&op=merchant');
                }
                $trans->commit();
                if ($merchant_info['alarm_amount'] < $merchant_info['available_predeposit']) {
                    //更新预警短信通知限制
                    $mch_cache = rcache("merchant-notify", 'refill-');
                    $caches = empty($mch_cache['data']) ? [] : unserialize($mch_cache['data']);
                    $caches[$mchid] = ['last_time' => 0, 'send_count' => 0];
                    wcache("merchant-notify", ['data' => serialize($caches)], 'refill-');
                }
                showMessage('操作成功', 'index.php?act=merchant&op=refill_evidence');
            } catch (Exception $e) {
                $trans->rollback();
                showMessage('操作失败', 'index.php?act=merchant&op=refill_evidence');
            }
        } else {
            $page = "recharge.manual.{$type}";
            Tpl::showpage($page);
        }
    }

    private function ct_refill_evidence($params, $merchant_info)
    {
        $admininfo = $this->getAdminInfo();
        $mem_info = Model('member')->getMemberInfo(['member_id' => $merchant_info['admin_id']]);
        $input['mchid'] = $merchant_info['mchid'];
        $input['mch_name'] = $merchant_info['name'];
        $input['member_id'] = $merchant_info['admin_id'];
        $input['amount'] = $params['pointsnum'];
        $input['bank_username'] = $params['bank_username'];
        $input['bank_name'] = $params['bank_name'] ?? '';
        $input['bz'] = $params['pointsdesc'];
        $input['voucher_name'] = $params['voucher_name'] ?? '/';
        $input['status'] = 2;
        $input['is_operation'] = 2;
        $input['add_time'] = $input['check_time'] = time();
        $input['after_available'] = ncPriceFormat($mem_info['available_predeposit'] + $params['pointsnum']);
        $input['admin_name'] = $admininfo['name'];
        $input['admin_id'] = $admininfo['id'];
        $input['add_type'] = 2;

        $model_merchant = Model('merchant');
        return $model_merchant->addRefillEvidence($input);
    }

    public function add_money()
    {
        $obj_validate = new Validator();
        $obj_validate->validateparam = [
            ["input" => $_POST["apply_id"], "require" => "true", "message" => Language::get('admin_points_member_error_again')],
            ["input" => $_POST["pointsnum"], "require" => "true", 'validator' => 'Compare', 'operator' => ' >= ', 'to' => 1, "message" => Language::get('admin_points_points_min_error')]
        ];
        $error = $obj_validate->validate();
        if ($error != '') {
            showMessage($error, '', '', 'error');
        }
        $money = abs(floatval($_POST['pointsnum']));
        $memo = trim($_POST['pointsdesc']);
        if ($money <= 0) {
            showMessage('输入的金额必需大于0', '', 'html', 'error');
        }
        $apply_id = intval($_POST['apply_id']);
        $model_merchant = Model('merchant');
        $evidence_info = $model_merchant->getRefillEvidenceInfo(['apply_id' => $apply_id], '*');
        if (!is_array($evidence_info) || count($evidence_info) <= 0) {
            showMessage("无效的充值申请信息", "index.php?act=merchant&op=recharge&apply_id={$apply_id}", '', 'error');
        }
        if ($evidence_info['status'] != 2) {
            showMessage("该充值申请未被审核通过", "index.php?act=merchant&op=recharge&apply_id={$apply_id}", '', 'error');
        }
        if ($evidence_info['is_operation'] == 2) {
            showMessage("该充值申请未已被预存过", "index.php?act=merchant&op=recharge&apply_id={$apply_id}", '', 'error');
        }
        //查询会员信息
        $obj_member = Model('member');
        $member_id = intval($evidence_info['member_id']);
        $member_info = $obj_member->getMemberInfo(['member_id' => $member_id]);

        $available_predeposit = floatval($member_info['available_predeposit']);
        $freeze_predeposit = floatval($member_info['freeze_predeposit']);
        if ($_POST['operatetype'] == 2 && $money > $available_predeposit) {
            showMessage(('预存款不足，会员当前预存款') . $available_predeposit, 'index.php?act=predeposit&op=predeposit_add', '', 'error');
        }
        if ($_POST['operatetype'] == 3 && $money > $available_predeposit) {
            showMessage(('可冻结预存款不足，会员当前预存款') . $available_predeposit, 'index.php?act=predeposit&op=predeposit_add', '', 'error');
        }
        if ($_POST['operatetype'] == 4 && $money > $freeze_predeposit) {
            showMessage(('可恢复冻结预存款不足，会员当前冻结预存款') . $freeze_predeposit, 'index.php?act=predeposit&op=predeposit_add', '', 'error');
        }
        $model_pd = Model('predeposit');
        $order_sn = $apply_id;
        $admininfo = $this->getAdminInfo();
        $log_msg = "管理员【" . $admininfo['name'] . "】操作会员【" . $member_info['member_name'] . "】预存款，金额为" . $money . ",编号为" . $order_sn;

        $admin_act = 'sys_add_money';
        switch ($_POST['operatetype']) {
            case 1:
                $admin_act = "sys_add_money";
                $log_msg = "管理员【" . $admininfo['name'] . "】操作会员【" . $member_info['member_name'] . "】预存款【增加】，金额为" . $money . ",编号为" . $order_sn;
                break;
            case 2:
                $admin_act = "sys_del_money";
                $log_msg = "管理员【" . $admininfo['name'] . "】操作会员【" . $member_info['member_name'] . "】预存款【减少】，金额为" . $money . ",编号为" . $order_sn;
                break;
            default:
                showMessage('操作失败', 'index.php?act=merchant&op=refill_evidence');
                break;
        }
        try {
            $trans = new trans_wapper($model_pd, __METHOD__);
            //扣除冻结的预存款
            $data = [];
            $data['member_id'] = $member_info['member_id'];
            $data['member_name'] = $member_info['member_name'];
            $data['amount'] = $money;
            $data['order_sn'] = $order_sn;
            $data['admin_name'] = $admininfo['name'];
            $data['pdr_sn'] = $order_sn;
            $data['lg_desc'] = $memo;
            $model_pd->changePd($admin_act, $data);
            $after_available = ncPriceFormat($available_predeposit + $evidence_info['amount']);
            $model_merchant->editRefillEvidence(
                ['apply_id' => $apply_id],
                ['is_operation' => 2, 'after_available' => $after_available, 'admin_id' => $admininfo['id'], 'admin_name' => $admininfo['name']]
            );
            $trans->commit();
            $this->log($log_msg, 1);
            return $evidence_info['mchid'];
        } catch (Exception $e) {
            $trans->rollback();
            $this->log($log_msg, 0);
            showMessage($e->getMessage(), 'index.php?act=merchant&op=refill_evidence', 'html', 'error');
            exit;
        }
    }

    public function checkevidenceOp()
    {
        $apply_id = trim($_GET['apply_id']);
        if (!$apply_id) {
            echo '';
            die;
        }
        $model_merchant = Model('merchant');
        $evidence_info = $model_merchant->getRefillEvidenceInfo(['apply_id' => $apply_id], '*');
        if (empty($evidence_info)) {
            echo '';
            die;
        }
        echo 'true';
    }

    public function OrderQueryOp()
    {
        $model_vr_order = Model('vr_order');
        $condition['order_state'] = ORDER_STATE_SEND;
        $orders = $model_vr_order->getOrderList($condition);
        if (!empty($orders)) {
            foreach ($orders as $order) {
                $order_id = $order['order_id'];
                QueueClient::push("QueryRefillState", ['order_id' => $order_id]);
            }
        }
        showMessage('操作成功', 'index.php?act=merchant&op=refill_order');
    }

    public function mch_notifyOp()
    {
        $model_refill_order = Model('refill_order');

        $condition['mch_notify_state'] = 0;
        $condition['inner_status'] = 0;
        $orders = $model_refill_order->getMerchantOrderList($condition, 1000, 'refill_order.*,vr_order.order_state', 'refill_order.order_time desc');
        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('操作成功', 'index.php?act=merchant&op=refill_order');
    }

    public function refill_orderOp()
    {
        $model_refill_order = Model('refill_order');
        $condition['inner_status'] = 0;

        $fSingle = false;
        if (!empty($_GET['order_sn'])) {
            $condition['refill_order.order_sn'] = $_GET['order_sn'];
            $fSingle = true;
        }
        if (!empty($_GET['mch_order'])) {
            $condition['refill_order.mch_order'] = $_GET['mch_order'];
            $fSingle = true;
        }
        if (!empty($_GET['ch_trade_no'])) {
            $condition['refill_order.ch_trade_no'] = $_GET['ch_trade_no'];
            $fSingle = true;
        }
        if (!empty($_GET['card_no'])) {
            $condition['refill_order.card_no'] = $_GET['card_no'];
            $fSingle = true;
        }

        if (!empty($_GET['mchid'])) {
            $condition['refill_order.mchid'] = $_GET['mchid'];
        }
        if (!empty($_GET['channel_name'])) {
            $condition['refill_order.channel_name'] = $_GET['channel_name'];
        }
        if (!empty($_GET['store_id'])) {
            $condition['vr_order.store_id'] = $_GET['store_id'];
        }
        if (!empty($_GET['refill_amount'])) {
            $condition['refill_order.refill_amount'] = $_GET['refill_amount'];
        }

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

        $fToday = false;
        if (!$fSingle)
        {
            $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['refill_order.order_time'] = [['egt', $start_unixtime], ['lt', $end_unixtime], 'and'];
            } elseif ($start_unixtime > 0) {
                $condition['refill_order.order_time'] = ['egt', $start_unixtime];
            } elseif ($end_unixtime > 0) {
                $condition['refill_order.order_time'] = ['lt', $end_unixtime];
            } else {
                $start = strtotime(date('Y-m-d', time()));
                $condition['refill_order.order_time'] = ['egt', $start];
                $fToday = true;
            }

            if (in_array($_GET['order_state'], ['0', '10', '20', '30', '40'])) {
                $condition['vr_order.order_state'] = $_GET['order_state'];
                if ($_GET['order_state'] == ORDER_STATE_SEND) {
                    if ($_GET['time'] == 1) {
                        $condition['refill_order.order_time'] = ['between', [(time() - 3600), (time() - 1800)]];
                    }
                    if ($_GET['time'] == 2) {
                        $condition['refill_order.order_time'] = ['lt', (time() - 3600)];
                    }
                }
            }
        }

        $merchants = [];
        $merchant_list = Model('')->table('merchant')->limit(1000)->select();
        foreach ($merchant_list as $key => $value) {
            $merchants[$value['mchid']] = $value;
        }
        $order_list = $model_refill_order->getMerchantOrderList($condition, 50, 'refill_order.*,vr_order.order_state', 'refill_order.order_time desc');

        $stat = $this->all_order_state_stat($condition);
        foreach ($order_list as $order_id => $order_info) {
            $order_list[$order_id]['card_type_text'] = $this->scard_type($order_info['card_type']);
            $order_list[$order_id]['mch_name'] = $merchants[$order_info['mchid']]['company_name'];
            if ($order_info['notify_time'] > 0) {
                $diff_time = $order_info['notify_time'] - $order_info['order_time'];
            } else {
                $diff_time = time() - $order_info['order_time'];
            }
            $order_list[$order_id]['diff_time_text'] = $this->elapse_time($diff_time);
            $order_list[$order_id]['diff_time'] = $diff_time;
        }

        $provider_list = Model('')->table('refill_provider,store')
            ->field('refill_provider.*,store.store_name')
            ->join('inner')
            ->on('store.store_id=refill_provider.store_id')
            ->order('opened asc, provider_id desc')
            ->limit(1000)
            ->select();

        Tpl::output('stat', $stat);
        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');
    }

    public function notify_merchantOp()
    {
        $order_id = $_GET['order_id'];
        $mod_order = Model('vr_order');
        $order_info = $mod_order->getOrderInfo(['order_id' => $order_id]);
        if ($order_info['order_state'] == ORDER_STATE_SEND) {
            QueueClient::push("QueryRefillState", ['order_id' => $order_id]);
        } else {
            QueueClient::push("NotifyMerchantComplete", ['order_id' => $order_id, 'manual' => true]);
        }
        showMessage('操作成功', '');
    }

    public function notify_manual_merchantOp()
    {
        $order_id = $_GET['order_id'];
        $type = $_GET['type'];

        $mod_order = Model('vr_order');
        $order_info = $mod_order->getOrderInfo(['order_id' => $order_id]);

        if ((time() - $order_info['order_time']) < 3600) {
            showMessage('订单时间未超过1小时', 'index.php?act=merchant&op=refill_order');
        }

        if ($type == 'success') {
            refill\util::manual_success($order_id);
        } elseif ($type == 'cancel') {
            refill\util::manual_cancel($order_id);
        } else {
            showMessage('手动操作类型错误', 'index.php?act=merchant&op=refill_order');
        }

        showMessage('操作成功', '');
    }

    public function providerStatsOp()
    {
        $provider_model = Model('refill_provider');
        $condition = [];
        $provider_list = $provider_model->getProviderList($condition, 1000);
        $opened_text = ['使用中', '已禁用'];
        $type_text = ['油卡', '手机充值卡'];
        Tpl::output('opened_text', $opened_text);
        Tpl::output('type_text', $type_text);
        Tpl::output('provider_list', $provider_list);
        Tpl::output('show_page', $provider_model->showpage());
        Tpl::showpage('provider.stats');
    }

    public function providerOp()
    {
        $this->sync_cfgs();
        $provider_model = Model('refill_provider');
        $condition = [];
        if (trim($_GET['name']) != '') {
            $condition['name'] = ['like', '%' . $_GET['name'] . '%'];
            Tpl::output('name', $_GET['name']);
        }
        if (in_array($_GET['type'], [1, 2])) {
            $condition['type'] = $_GET['type'];
        }
        $store_list = Model('store')->getStoreList(['store_id' => ['gt',0]], '', '', 'store_id,store_name');
        foreach ($store_list as $store) {
            $stores[$store['store_id']] = $store['store_name'];
        }
        $provider_list = $provider_model->getProviderList($condition, 100);
        foreach ($provider_list as $key => $provider) {
            if (!empty($provider['start_period']) && !empty($provider['end_period'])) {
                $provider_list[$key]['period'] = $provider['start_period'] . '~' . $provider['end_period'];
            } else {
                $provider_list[$key]['period'] = '全时间段';
            }
            $provider_list[$key]['store_name'] = $stores[$provider['store_id']];
        }
        $opened_text = ['使用中', '已禁用'];
        $type_text = ['油卡', '手机充值卡'];
        Tpl::output('opened_text', $opened_text);
        Tpl::output('type_text', $type_text);
        Tpl::output('provider_list', $provider_list);
        Tpl::output('show_page', $provider_model->showpage());
        Tpl::showpage('provider.index');
    }

    public function provider_provinceOp()
    {
        $provider_model = Model('refill_provider');
        $provider_id = $_GET['id'] ?? $_POST['id'];
        $provider = $provider_model->getProviderInfo(['provider_id' => $provider_id]);
        if (empty($provider)) {
            showMessage('通道信息有误');
        }
        $operator = [mtopcard\ChinaMobileCard, mtopcard\ChinaUnicomCard, mtopcard\ChinaTelecomCard];

        if(chksubmit()) {
            foreach ($operator as $opr) {
                $key = $opr . '-province';
                $province = $_POST[$key];
                if($province == -1) {
                    $updata[$opr] = -1;
                }else{
                    $updata[$opr] = implode(',',$province);
                }
            }
            $resp = $provider_model->editProvider(['provinces' => serialize($updata)], ['provider_id' => $provider_id]);
            if ($resp) {
                showMessage('编辑成功', 'index.php?act=merchant&op=provider');
            } else {
                showMessage('编辑失败', "index.php?act=merchant&op=provider_province&id={$provider_id}");
            }
        } else {
            $data = unserialize($provider['provinces']);
            $provinces = [];
            $province = $provinces;

            foreach ($operator as $opr) {
                if(empty($data)) {
                    $provinces[$opr] = [-1];
                } else {
                    $provinces[$opr] = explode(',', $data[$opr]);
                }
            }
            $province_list = mtopcard\ProvinceList;
            Tpl::output('province_list', $province_list);
            Tpl::output('provider', $provider);
            Tpl::output('provinces', $provinces);
            Tpl::showpage('provider.province');
        }
    }

    public function sync_cfgs()
    {
        $name_val = function ($items) {
            $result = [];
            foreach ($items as $item) {
                $name = $item['name'];
                $result[$name] = $item;
            }
            return $result;
        };

        $match = function ($all, $cur) {
            $inserts = $updates = [];
            foreach ($all as $key => $value) {
                if (!array_key_exists($key, $cur)) {
                    $insert['name'] = $key;
                    $insert['store_id'] = $value['cfg']['store_id'];
                    $insert['qualitys'] = $value['cfg']['qualitys'];
                    $inserts[] = $insert;
                } elseif ($value['cfg']['qualitys'] != $cur[$key]['qualitys']) {
                    $update['provider_id'] = $cur[$key]['provider_id'];
                    $update['qualitys'] = $value['cfg']['qualitys'];
                    $updates[] = $update;
                }
            }
            return [$inserts, $updates];
        };

        $updater = function ($mod, $updates) {
            if (empty($updates)) return;
            foreach ($updates as $update) {
                $provider_id = $update['provider_id'];

                $data = ['qualitys' => $update['qualitys']];
                $mod->editProvider($data, ['provider_id' => $provider_id]);
            }
        };
        $inserter = function ($mod, $type, $names) {
            foreach ($names as $name) {
                $data = ['name' => $name['name'], 'type' => $type, 'store_id' => $name['store_id'], 'qualitys' => $name['qualitys'], 'opened' => 2];
                $mod->insert($data);
            }
        };

        global $config;
        $oil_configs = $config['oil_providers'];
        $pho_configs = $config['phone_providers'];
        $oils = $name_val($oil_configs);
        $phones = $name_val($pho_configs);

        $mod_prov = Model('refill_provider');

        $oil_items = $mod_prov->getProviderList(['type' => 1]);
        $oil_items = $name_val($oil_items);
        [$oil_inserts, $oil_updates] = $match($oils, $oil_items);

        $phone_items = $mod_prov->getProviderList(['type' => 2]);
        $phone_items = $name_val($phone_items);
        [$phone_inserts, $phone_updates] = $match($phones, $phone_items);
        $inserter($mod_prov, 1, $oil_inserts);
        $inserter($mod_prov, 2, $phone_inserts);
        $updater($mod_prov, $oil_updates);
        $updater($mod_prov, $phone_updates);
    }

    public function changeProviderStateOp()
    {
        $provider_id = intval($_GET['id']);
        $state = intval($_GET['state']);
        $provider_model = Model('refill_provider');
        $provider_info = $provider_model->getProviderInfo(['provider_id' => $provider_id]);
        if (empty($provider_info) || !in_array($state, [1, 2])) {
            showMessage('操作成功', 'index.php?act=merchant&op=provider');
        }
        $resp = $provider_model->editProvider(['opened' => $state], ['provider_id' => $provider_id]);
        if (!$resp) {
            showMessage('操作失败', 'index.php?act=merchant&op=provider', 'html', 'error');
        }
        showMessage('操作成功', 'index.php?act=merchant&op=provider');
    }

    /**
     * 新增通道
     */
    public function provider_addOp()
    {
        $provider_model = Model('refill_provider');
        if (chksubmit()) {
            $params = $_POST;
            unset($params['form_submit']);
            $result = $provider_model->addProvider($params);
            if ($result) {
                $url = [
                    [
                        'url' => 'index.php?act=merchant&op=provider',
                        'msg' => '返回通道列表',
                    ],
                    [
                        'url' => 'index.php?act=merchant&op=provider_add',
                        'msg' => '继续新增通道',
                    ],
                ];
                $this->log('添加通道:' . '[	' . $_POST['name'] . ']', 1);
                showMessage('通道添加成功', $url);
            } else {
                showMessage('通道添加失败');
            }
        }
        Tpl::showpage('provider.add');
    }

    public function provider_editOp()
    {
        $provider_model = Model('refill_provider');
        if (chksubmit()) {
            $provider_id = intval($_POST['provider_id']) ?? '';
            $provider = $provider_model->getProviderInfo(['provider_id' => $provider_id]);
            if (empty($provider)) {
                showMessage('通道信息有误');
            }
            $params = $_POST;
            unset($params['form_submit']);
            if (empty($params)) {
                showMessage('通道编辑成功', 'index.php?act=merchant&op=provider');
            }
            $result = $provider_model->editProvider($params, ['provider_id' => $provider_id]);
            if ($result) {
                $this->log('编辑通道:' . '[	' . $provider['name'] . ']', 1);
                showMessage('通道编辑成功', 'index.php?act=merchant&op=provider');
            } else {
                showMessage('通道编辑失败', "index.php?act=merchant&op=provider_edit&id={$provider_id}");
            }
        }
        $provider_id = intval($_GET['id']) ?? '';
        $provider = $provider_model->getProviderInfo(['provider_id' => $provider_id]);
        if (empty($provider)) {
            showMessage('通道信息有误');
        }
        $type_text = ['油卡', '手机充值卡'];
        Tpl::output('type_text', $type_text);
        Tpl::output('provider', $provider);
        Tpl::showpage('provider.edit');
    }

    public function provider_delOp()
    {
        $provider_model = Model('refill_provider');
        $provider_id = intval($_GET['id']) ?? '';
        $provider = $provider_model->getProviderInfo(['provider_id' => $provider_id]);
        if (empty($provider)) {
            showMessage('通道信息有误');
        }
        $result = $provider_model->delProvider(['provider_id' => $provider_id]);
        if ($result) {
            $this->log('删除通道:' . '[	' . $provider['name'] . ']', 1);
            showMessage('通道删除成功', 'index.php?act=merchant&op=provider');
        } else {
            showMessage('通道删除失败', "index.php?act=merchant&op=provider");
        }
    }

    public function provider_amount_controlOp()
    {
        global $config;
        $type = $_GET['type'] ?? $_POST['type'];
        $form = $_GET['form'] ?? $_POST['form'];
        $rkey = $this->speed_key($type, $form);
        $quality = ['common' => 1, 'fast' => 2, 'card' => 3, 'third' => 4, 'slow' => 5];
        if (chksubmit()) {
            $pids = $_POST['pid'];
            $names = $_POST['name'];
            $types = $_POST['types'];
            $amounts = $_POST['amount'];
            $speeds = $_POST['speed'];
            $sorts = $_POST['sort'];
            $openeds = $_POST['opened'];
            $hass = $_POST['has'];

            foreach ($pids as $key => $pid) {
                if ($hass[$key] == 0) {
                    continue;
                }
                $data['pid'] = intval($pid);
                $data['name'] = $names[$key];
                $data['type'] = intval($types[$key]);
                $data['amount'] = intval($amounts[$key]);
                $data['speed'] = intval($speeds[$key]);
                $data['sort'] = intval($sorts[$key]);
                $data['opened'] = intval($openeds[$key]);

                $index = "{$data['type']}-{$data['amount']}";
                $result[$index][] = $data;
            }
            wcache($rkey, ['data' => serialize($result)], 'provider-');
            showMessage('编辑成功', 'index.php?act=merchant&op=provider');
        } else {
            $speed_limit = rcache($rkey, 'provider-');
            if (empty($speed_limit)) {
                $speed_limit = [];
            } else {
                $speed_limit = unserialize($speed_limit['data']);
            }
            $initialiser = function ($provider) {
                $data['pid'] = $provider['provider_id'];
                $data['name'] = $provider['name'];
                $data['speed'] = -1;
                $data['sort'] = 1;
                $data['opened'] = 1;
                return $data;
            };

            $providers = Model('')->table('refill_provider,store')
                ->field('refill_provider.*,store.store_name')
                ->join('inner')
                ->on('store.store_id=refill_provider.store_id')
                ->where(['type' => $type, 'qualitys' => ['like', '%' . $quality[$form] . '%']])
                ->limit(1000)
                ->order('opened asc , provider_id desc')
                ->select();
            if (empty($providers)) {
                showMessage('暂无相关通道', 'index.php?act=merchant&op=provider');
            }
            $formData = $this->formData($type, $form);

            $amounts = $formData['amounts'];
            $cfgs = $formData['cfgs'];
            $types = $formData['types'];
            foreach ($speed_limit as $key => $speed) {
                foreach ($speed as $value) {
                    $speed_limit[$key][$value['pid']] = $value;
                }
            }
            $ProviderManager = new \refill\ProviderManager();
            $ProviderManager->load();
            $QPTA = $ProviderManager->getQPTA();
            $QPTA = $QPTA[$quality[$form]];

            foreach ($providers as $key => $provider) {
                $result = [];
                $pid = $provider['provider_id'];
                $name = $provider['name'];
                if (empty($cfgs) || !array_key_exists($name, $cfgs)) {
                    unset($providers[$key]);
                    continue;
                }
                foreach ($types as $type) {
                    foreach ($amounts as $k => $amount) {
                        $key = $type . '-' . $amount;
                        if (is_array($speed_limit[$key]) && array_key_exists($pid, $speed_limit[$key])) {
                            $speed = $speed_limit[$key][$pid];
                        } else {
                            $speed = $initialiser($provider);
                        }
                        if (is_array($QPTA["{$name}-{$type}-{$amount}"]) && array_key_exists("{$name}-{$type}-{$amount}", $QPTA)) {
                            $speed['has'] = 1;
                        } else {
                            $speed['has'] = 0;
                        }
                        $result[] = $speed;
                    }
                }
                $datas[$pid] = $result;
            }
            if (empty($datas)) {
                showMessage('暂无相关通道配置', 'index.php?act=merchant&op=provider');
            }
            Tpl::output('form', $formData);
            Tpl::output('datas', $datas);
            Tpl::output('providers', $providers);
            Tpl::showpage('provider.amount.control');
        }
    }

    private function speed_key($type, $form)
    {
        if ($type == 1) {
            $rkey = "channel-ctl-oil-{$form}-limit";
        } elseif ($type == 2) {
            $rkey = "channel-ctl-phone-{$form}-limit";
        } else {
            showMessage('类型有误', "index.php?act=merchant&op=provider");
        }
        Log::record($rkey, Log::DEBUG);
        return $rkey;
    }

    private function formData($type, $form)
    {
        global $config;
        $texts = [
            ["中石油", '中石化'], ['移动', '联通', '电信']
        ];
        $type_data = [[1, 2], [4, 5, 6]];
        $type_text = $texts[$type - 1];
        $type_data = $type_data[$type - 1];
        $amounts = [];
        if ($type == 1) {
            $amounts = $config['refill_oil_specs'];
            $cfgs = $config['oil_providers'];
        }
        if ($type == 2) {
            $amounts = $config['refill_phone_specs'];
            $cfgs = $config['phone_providers'];
        }

        foreach ($type_text as $key => $value) {
            foreach ($amounts as $amount) {
                $data['text'] = $value . '-' . $amount . '元';
                $data['type'] = $type_data[$key];
                $data['amount'] = $amount;
                $amountData[] = $data;
            }
        }
        foreach ($cfgs as $cfg) {
            $pcfgs[$cfg['name']] = $cfg;
        }
        return ['amountData' => $amountData, 'form' => $form, 'amounts' => $amounts, 'types' => $type_data, 'cfgs' => $pcfgs];
    }

    private function scard_type(int $card_type)
    {
        if ($card_type == 1) { //中石油
            return '中石油';
        } elseif ($card_type == 2) { //中石化
            return '中石化';
        } elseif ($card_type == 4) { //中国移动
            return '中国移动';
        } elseif ($card_type == 5) { //中国联通
            return '中国联通';
        } elseif ($card_type == 6) { //中国电信
            return '中国电信';
        } else {
            return 'unknown';
        }
    }

    private function elapse_time($seconds)
    {
        $minutes = intval($seconds / 60);
        $second = intval($seconds % 60);
        if ($minutes >= 60) {
            $minute = $minutes % 60;
            $hours = intval($minutes / 60);
            $result = "{$minute}m{$second}s";
        } elseif ($minutes > 0) {
            $result = "{$minutes}m{$second}s";
        } else {
            $result = "{$second}s";
        }

        if (isset($hours)) {
            $result = "{$hours}h{$minute}m";
        }
        return $result;
    }

    private function refill_stat($condition, $times)
    {
        $stat_order = function ($condition) {
            $stat = Model('')->table('refill_order,vr_order')->join('inner')
                ->on('refill_order.order_id=vr_order.order_id')
                ->field('count(*) as order_count ')
                ->where($condition)->find();

            return $stat['order_count'];
        };
        $result = [];
        $condition['order_state'] = ORDER_STATE_SEND;
        foreach ($times as $time) {
            $condition['refill_order.order_time'] = $time;
            $result[] = $stat_order($condition);
        }
        return $result;
    }

    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 OrderSendListOp()
    {
        $model_refill_order = Model('refill_order');
        $condition['refill_order.inner_status'] = 0;
        $condition['vr_order.order_state'] = ORDER_STATE_SEND;

        $condition['refill_order.order_time'] = ['lt', (time() - 1800)];
        $merchant_list = Model('')->table('merchant')->limit(1000)->select();
        foreach ($merchant_list as $key => $value) {
            $merchants[$value['mchid']] = $value;
        }
        $time_cond = [
            ['between', [(time() - 3600), (time() - 1800)]],
            ['lt', (time() - 3600)]];
        if ($_GET['time'] == 1) {
            $condition['refill_order.order_time'] = ['between', [(time() - 3600), (time() - 1800)]];
        }
        if ($_GET['time'] == 2) {
            $condition['refill_order.order_time'] = ['lt', (time() - 3600)];
        }
        $time_out_order = function($time_out, $condition){
            $mchids = Model('')->table('merchant')->where(['time_out' => ['elt', $time_out]])->field('mchid')->select();
            $mchids = array_column($mchids, 'mchid');
            $mchids = implode(',', $mchids);

            $condition['refill_order.order_time'] = ['lt', (time() - $time_out)];
            $condition['refill_order.mchid'] = ['in',$mchids];
            return $condition;
        };
        if ($_GET['time'] == 3) {
            $condition = $time_out_order(300, $condition);
            $time_cond[] = ['lt', (time() - 300)];
        }
        if ($_GET['time'] == 4) {
            $condition = $time_out_order(900, $condition);
            $time_cond[] = ['lt', (time() - 900)];
        }
        if (!empty($_GET['card_type'])) {
            if (in_array($_GET['card_type'], ['1', '2', '4', '5', '6'])) {
                $condition['refill_order.card_type'] = $_GET['card_type'];
            }
            if ($_GET['card_type'] == 'oil') {
                $condition['refill_order.card_type'] = ['in', ['1', '2']];
            }
            if ($_GET['card_type'] == 'phone') {
                $condition['refill_order.card_type'] = ['in', ['4', '5', '6']];
            }
        }

        $order_list = $model_refill_order->getMerchantOrderList($condition, 20, 'refill_order.*,vr_order.order_state', 'refill_order.order_time desc');

        $stat = 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')
            ->where($condition)->find();
        $count = $this->refill_stat($condition,$time_cond);
        foreach ($order_list as $order_id => $order_info) {
            $order_list[$order_id]['card_type_text'] = $this->scard_type($order_info['card_type']);
            $order_list[$order_id]['mch_name'] = $merchants[$order_info['mchid']]['company_name'];
            $order_list[$order_id]['diff_time_text'] = $this->elapse_time(time() - $order_info['order_time']);
            $order_list[$order_id]['diff_time'] = time() - $order_info['order_time'];
        }
        $provider_list = Model('')->table('refill_provider,store')
            ->field('refill_provider.*,store.store_name')
            ->join('inner')
            ->on('store.store_id=refill_provider.store_id')
            ->order('opened asc, provider_id desc')
            ->limit(1000)
            ->select();
        Tpl::output('stat', $stat);
        Tpl::output('count', $count);
        Tpl::output('order_list', $order_list);
        Tpl::output('merchant_list', $merchant_list);
        Tpl::output('provider_list', $provider_list);
        Tpl::output('show_page', $model_refill_order->showpage());
        Tpl::showpage('refill.order.send.index');
    }

    public function OrderStatsOp()
    {
        $type = $_GET['type'] ? $_GET['type'] : 'system';
        $page = "{$type}.order.stats";
        $model_refill_order = Model('refill_order');
        $condition['type'] = $type;
        if (!empty($_GET['cid'])) {
            $condition['cid'] = $_GET['cid'];
        }
        $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);

        if ($type == 'provider') {
            $provider_list = Model('')->table('refill_provider,store')->field('refill_provider.store_id,store.store_name')->join('inner')
                ->on('store.store_id=refill_provider.store_id')->limit(1000)->select();
            Tpl::output('provider_list', $provider_list);
        } elseif ($type == 'merchant') {
            $merchant_list = Model('')->table('merchant')->limit(1000)->select();
            Tpl::output('merchant_list', $merchant_list);
        }
        $check_text = ['未编辑', '匹配', '不匹配'];
        Tpl::output('stats_list', $stats_list);
        Tpl::output('check_text', $check_text);
        Tpl::output('show_page', $model_refill_order->showpage());
        Tpl::showpage($page);
    }

    public function OrderStatsCheckOp()
    {
        $stat_id = $_GET['stat_id'] ?? $_POST['stat_id'];
        $mod_stat = Model('refill_stats');
        $stats_data = $mod_stat->getStatsInfo(['stat_id' => $stat_id]);
        if (empty($stats_data)) {
            showMessage('对应数据不存在', '');
        }
        $type = $stats_data['type'];
        if (chksubmit()) {
            $corder_success_count = $_POST['corder_success_count'];
            $corder_success_amounts = $_POST['corder_success_amounts'];
            $remark = $_POST['remark'];
            $gap_order_count = $gap_success_amounts = 0;
            if($type == 'provider') {
                $gap_order_count = $corder_success_count - $stats_data['success_count'];
                $gap_success_amounts = $corder_success_amounts - $stats_data['success_channel_amounts'];
            }elseif ($type == 'merchant') {
                $gap_order_count = $stats_data['success_count'] - $corder_success_count;
                $gap_success_amounts = $stats_data['success_channel_amounts'] - $corder_success_amounts;
            }else{
                showMessage('对账数据类型错误', 'index.php?act=merchant&op=OrderStats');
            }

            $updata['corder_success_count'] = $corder_success_count;
            $updata['corder_success_amounts'] = $corder_success_amounts;
            $updata['gap_order_count'] = $gap_order_count;
            $updata['gap_success_amounts'] = $gap_success_amounts;
            $updata['remark'] = $remark;
            if($gap_order_count == 0 && $gap_success_amounts == 0) {
                $updata['check_status'] = 1;
            }else{
                $updata['check_status'] = 2;
            }
            $res = $mod_stat->edit($stat_id, $updata);

            if ($res) {
                showMessage('操作成功',"index.php?act=merchant&op=OrderStats&type={$type}");
            } else {
                showMessage('操作失败');
            }
        } else {
            $type_text = ['provider' => '上游', 'merchant' => '商户'];
            Tpl::output('stats_type', $type_text[$type]);
            Tpl::showpage('order.stats.check');
        }
    }

    public function provider_evidenceOp()
    {
        $mod = Model('provider_evidence');
        $condition = [];
        if (trim($_GET['store_name']) != '') {
            $condition['store_name'] = ['like', '%' . $_GET['store_name'] . '%'];
        }

        //上游充值申请列表
        $evidence_list = $mod->getProviderEvidence($condition, 30);

        Tpl::output('evidence_list', $evidence_list);
        Tpl::output('page', $mod->showpage());
        Tpl::showpage('merchant.provider.evidence_list');
    }

    public function provider_evidence_addOp()
    {
        $provider_model = Model('refill_provider');
        if (chksubmit()) {
            $obj_validate = new Validator();
            $obj_validate->validateparam = [
                ["input" => $_POST["provider_id"], "require" => "true", "message" => '上游通道不能为空'],
                ["input" => $_POST["bank_username"], "require" => "true", "message" => '开户人姓名不能为空'],
                ["input" => $_POST["bank_name"], "require" => "true", "message" => '开户银行不能为空'],
                ["input" => $_POST["to_bank_username"], "require" => "true", "message" => '上游开户人姓名不能为空'],
                ["input" => $_POST["to_bank_name"], "require" => "true", "message" => '上游开户银行不能为空'],
                ["input" => $_POST["amount"], "require" => "true", "message" => '预存金额不能为空']
            ];
            $error = $obj_validate->validate();
            if ($error != '') {
                showMessage($error);
            }
            $provider_id = $_POST["provider_id"];
            $provider_info = $provider_model->table('refill_provider,store')
                ->where((['provider_id' => $provider_id]))
                ->field('refill_provider.*,store.store_name')
                ->join('inner')
                ->on('store.store_id=refill_provider.store_id')
                ->find();
            if (!$provider_info) {
                showMessage('对应店铺不存在');
            }
            $amount = $_POST['amount'];
            $money = abs($amount);
            if ($money == 0) {
                showMessage('申请金额错误');
            }
            if(!empty($_FILES['voucher']['name'])) {
                $upload = new UploadFile();
                $upload->set('default_dir',ATTACH_UPFILE.'/provider');

                $result = $upload->upfile('voucher');
                if ($result){
                    $_POST['voucher'] = $upload->file_name;
                    $input['voucher_name'] = $_POST['voucher'];
                }else {
                    showMessage($upload->error);
                }
            }

            $input['store_name'] = $provider_info['store_name'];
            $input['store_id'] = $provider_info['store_id'];
            $input['amount'] = $amount;
            $input['bank_username'] = $_POST['bank_username'];
            $input['bank_name'] = $_POST['bank_name'];
            $input['to_bank_username'] = $_POST['to_bank_username'];
            $input['to_bank_name'] = $_POST['to_bank_name'];
            $input['add_time'] = time();
            $mod = Model('provider_evidence');
            $res = $mod->addProviderEvidence($input);

            if ($res) {
                showMessage('操作成功',"index.php?act=merchant&op=provider_evidence");
            } else {
                showMessage('操作失败');
            }
        } else {
            $provider_list = Model('')->table('refill_provider,store')
                ->field('refill_provider.*,store.store_name')
                ->join('inner')
                ->on('store.store_id=refill_provider.store_id')
                ->limit(1000)
                ->select();
            Tpl::output('provider_list', $provider_list);
            Tpl::showpage('provider.evidence.add');
        }
    }

    public function provider_successfulOp()
    {
        $days = $this->successful_where();
        Tpl::output('days', $days);
        Tpl::showpage('provider.successful');
    }

    private function successful_where() {
        $url = BASE_SITE_URL . '/plot/days';
        Log::record("successful get timestamp url : {$url}", Log::DEBUG);
        $data = http_request($url);
        if(empty($data)) return [];
        preg_match_all('/\d{10}/', $data, $matches);
        $days = $matches[0];
        if(empty($days)) return [];
        $result = [];
        foreach ($days as $day) {
            $result[$day] = date("Y-m-d",$day);
        }
        return $result;
    }

    public function successful_time_get_whereOp(){
        $url = BASE_SITE_URL . '/plot/paths?time_stamp='.$_GET['timestamp'];
        Log::record("successful get where url : {$url}", Log::DEBUG);
        $data = http_request($url);
        preg_match_all('/\d{10}\/[a-z]+\/\d{1,2}\/\d\/\d{2,4}/', $data, $matches);
        $conds = $matches[0];
        if(empty($conds)) return [];
        foreach ($conds as $cond) {
            $arr = explode('/',$cond);
            $chname[] = $arr[1];
            $qualitys[] = $arr[2];
            $card_types[] = $arr[3];
            $amount[] = intval($arr[4]);
        }
        $chnameData = array_unique($chname);
        sort($chnameData);

        $result['chname'] = $chnameData;
        $amountData = array_unique($amount);
        sort($amountData);
        $result['amount'] = $amountData;

        foreach (array_unique($card_types) as $card_type) {
            $card_typeData[$card_type] = $this->scard_type($card_type);
        }
        ksort($card_typeData);
        $result['card_type'] = $card_typeData;

        $quality_txt = [1=>'普充', 2=>'快充', 3=>'卡密', 4=>'三方', 5=>'慢充'];
        foreach (array_unique($qualitys) as $quality) {
            $qualityData[$quality] = $quality_txt[$quality];
        }
        ksort($qualityData);
        $result['quality'] = $qualityData;
        echo(json_encode($result));
        exit;
    }
}