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');
require_once(BASE_HELPER_PATH . '/stat_helper.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, 100, 'available_predeposit desc,merchant_state asc,mchid 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']);
            $update['oil_quality'] = intval($_POST['oil_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' => $mchid , 'quality' => $quality]);
                //更新新费率
                if (!empty($inserts)) {
                    $model_merchant->insertPrices($inserts);
                }
                $trans->commit();
                showMessage('操作成功');
            } catch (Exception $e) {
                $trans->rollback();
                showMessage('操作失败');
            }
        }
        $mchid = $_GET['mchid'] ?? 0;
        $goods = $this->GoodsFormat($mchid, $quality);
        Tpl::output('goods', $goods);
        Tpl::showpage('merchant.price');
    }

    public function third_merchant_priceOp()
    {
        $mchid = $_GET['mchid'] ?? $_POST['mchid'];
        $mod = Model('thrid_refill');
        if(chksubmit()) {
            //合并表单数据
            $card_types = $_POST['cardtype'];
            $specs = $_POST['spec'];
            $prices = $_POST['price'];
            $pcodes = $_POST['pcode'];
            $quality = 1;

            $params = [];
            foreach ($card_types as $key => $card_type) {
                $data['card_type'] = $card_type;
                $data['spec'] = intval($specs[$key]);
                $data['price'] = ncPriceFormat($prices[$key]);
                $data['pcode'] = $pcodes[$key];
                $params[] = $data;
            }

            try {
                $model_merchant = Model('merchant');
                $trans = new trans_wapper($model_merchant, __METHOD__);
                foreach ($params as $param) {
                    $insert = [];
                    if ($param['price'] > 0) {
                        $insert['mchid'] = $mchid;
                        $insert['spec'] = $param['spec'];
                        $insert['price'] = $param['price'];
                        $insert['card_types'] = $param['card_type'];
                        $insert['quality'] = $quality;
                        $insert['pcode'] = $param['pcode'];
                    }
                    //删除旧费率
                    $model_merchant->delPrices(['mchid' => $mchid, 'quality' => $quality, 'pcode' => $param['pcode']]);
                    //更新新费率
                    if(!empty($insert)) {
                        $model_merchant->table('merchant_price')->insert($insert);
                    }
                }
                $trans->commit();
                showMessage('操作成功', 'index.php?act=merchant&op=merchant');
            } catch (Exception $e) {
                $trans->rollback();
                showMessage('操作失败', 'index.php?act=merchant&op=merchant', 'html', 'error');
            }
        } else{
            $condition = [];
            if(!empty($_GET['system_code'])) {
                $condition['system_code'] = $_GET['system_code'];
            }
            if (trim($_GET['product_name']) != '') {
                $condition['product_name'] = ['like', '%' . $_GET['product_name'] . '%'];
            }
            $third_product = $mod->getProductList($condition,30);

            $model_merchant = Model('merchant');
            $items = $model_merchant->table('merchant_price')->where(['mchid' => $mchid, 'quality' => 1, 'card_types' => mtopcard\ThirdRefillCard])->select();

            $goods = [];
            foreach ($items as $item) {
                $goods[$item['pcode']] = $item['price'];
            }
            Tpl::output('third_product', $third_product);
            Tpl::output('goods', $goods);
            Tpl::output('page', $mod->showpage());
            Tpl::showpage('third.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;
        };

        return $merger($all_cardtype_specs, $merch_cardtype_specs);
    }

    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 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('refill_evidence', 'index'));
    }

    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=refill_evidence&op=index');
        } 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=refill_evidence&op=index');
            } catch (Exception $e) {
                $trans->rollback();
                showMessage('操作失败', 'index.php?act=refill_evidence&op=index');
            }
        } 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=refill_evidence&op=index');
                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=refill_evidence&op=index', '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=refill_order&op=index');
    }

    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=refill_order&op=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=refill_order&op=index');
        }

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

        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 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=provider&op=index');
            } 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 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=provider&op=index');
        }
        $resp = $provider_model->editProvider(['opened' => $state], ['provider_id' => $provider_id]);
        if (!$resp) {
            showMessage('操作失败', 'index.php?act=provider&op=index', 'html', 'error');
        }
        showMessage('操作成功', 'index.php?act=provider&op=index');
    }

    /**
     * 新增通道
     */
    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=provider&op=index',
                        '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=provider&op=index');
            }
            $result = $provider_model->editProvider($params, ['provider_id' => $provider_id]);
            if ($result) {
                $this->log('编辑通道:' . '[	' . $provider['name'] . ']', 1);
                showMessage('通道编辑成功', 'index.php?act=provider&op=index');
            } 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=provider&op=index');
        } else {
            showMessage('通道删除失败', "index.php?act=provider&op=index");
        }
    }

    public function provider_amount_controlOp()
    {
        $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 , 'slow6' => 6, 'slow2' => 7];
        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=provider&op=index');
        } 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=provider&op=index');
            }
            $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=provider&op=index');
            }
            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=provider&op=index");
        }
        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 quality_format($quality) {
        switch ($quality) {
            case 1:
                $text = "普充";
                break;
            case 2:
                $text = "快充";
                break;
            case 3:
                $text = "卡密";
                break;
            case 4:
                $text = "三方";
                break;
            case 5:
                $text = "慢充二十四小时";
                break;
            case 6:
                $text = "慢充六小时";
                break;
            case 7:
                $text = "慢充两小时";
                break;
            default:
                return '其他';
                break;
        }
        return $text;
    }

    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;
    }

    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=OrderStats&op=index');
            }

            $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=OrderStats&op=index&type={$type}");
            } else {
                showMessage('操作失败');
            }
        } else {
            $type_text = ['provider' => '上游', 'merchant' => '商户'];
            Tpl::output('stats_type', $type_text[$type]);
            Tpl::showpage('order.stats.check');
        }
    }

    public function OrderStatsReloadOp()
    {
        $stat_id = $_GET['stat_id'];
        $mod_stat = Model('refill_stats');
        $stats_data = $mod_stat->getStatsInfo(['stat_id' => $stat_id]);
        if (empty($stats_data)) {
            showMessage('对应数据不存在', '');
        }
        $refill = new statistics\stat_refill();
        try {
            $trans = new trans_wapper($mod_stat, __METHOD__);
            //删除旧数据
            $mod_stat->delStats(['stat_id' => $stat_id]);
            //更新新数据
            if($stats_data['type'] == 'merchant') {
                $refill->merchant_stat($stats_data['time_stamp'],$stats_data['cid']);
            }elseif ($stats_data['type'] == 'provider') {
                $refill->provider_stat($stats_data['time_stamp'],$stats_data['cid']);
            }
            $trans->commit();
            showMessage('操作成功');
        } catch (Exception $e) {
            $trans->rollback();
            showMessage('操作失败');
        }
    }

    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');
        }
    }
}