xyzshop/admin/control/provider.php

<?php

include(BASE_CONFIG_PATH . CONFIG_PREFIX . '/refill.ini.php');

require_once (BASE_HELPER_PATH . '/model/member_info.php');

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

    public function indexOp()
    {
        $this->sync_cfgs();
        $provider_model = Model('refill_provider');
        $condition = [];
        if (trim($_GET['name']) != '') {
            $condition['store_name'] = ['like', '%' . $_GET['name'] . '%'];
            Tpl::output('name', $_GET['name']);
        }
        if (in_array($_GET['type'], [mtopcard\OilCardPaper, mtopcard\PhoneCardPaper, mtopcard\ThirdCardPaper])) {
            $condition['type'] = $_GET['type'];
        }
        if(!empty($_GET['quality'])) {
            $condition['qualitys'] = ['like', '%' . $_GET['quality'] . '%'];
        }

        $provider_items = $provider_model->table('refill_provider,store')
            ->field('refill_provider.*,store.store_name,store.member_id')
            ->join('inner')
            ->on('store.store_id=refill_provider.store_id')
            ->where($condition)
            ->order('opened asc, name asc')
            ->page(100)
            ->select();

        $providers = [];
        $mid_pids = [];
        $mids = [];
        foreach ($provider_items as $provider)
        {
            $pid = $provider['provider_id'];
            $providers[$pid] = $provider;
            $account_id = intval($provider['account_id']);
            if($account_id > 0) {
                $mid_pids[$account_id] = $pid;
                $mids[] = $account_id;
            }
        }

        if(!empty($mids))
        {
            $member_data = Model('member')->field('member_id,available_predeposit')->where(['member_id' => ['in',$mids]])->select();
            foreach ($member_data as $member)
            {
                $mid = intval($member['member_id']);
                if(array_key_exists($mid,$mid_pids)) {
                    $pid = $mid_pids[$mid];
                    $providers[$pid]['available_predeposit'] = $member['available_predeposit'];
                } else {
                    $providers[$pid]['available_predeposit'] = 0;
                }
            }
        }

        $opened_text = ['使用中', '已禁用'];
        $type_text = ['油卡', '手机充值卡', '增值业务'];
        Tpl::output('opened_text', $opened_text);
        Tpl::output('type_text', $type_text);
        Tpl::output('provider_list', $providers);
        Tpl::output('show_page', $provider_model->showpage());
        Tpl::showpage('provider.index');
    }

    public function recharge_manualOp()
    {
        $provider_id = $_GET['provider_id'] ?? $_POST['provider_id'];
        $provider_model = Model('refill_provider');
        $provider_info = $provider_model->getProviderInfo(['provider_id' => $provider_id]);
        if (empty($provider_info)) {
            showMessage('通道信息有误');
        }

        if (chksubmit())
        {
            $obj_validate = new Validator();
            $obj_validate->validateparam = [
                ["input" => $_POST["operation"], "require" => "true", "message" => '操作人姓名不能为空'],
                ["input" => $_POST["pointsnum"], "require" => "true", "message" => '预存金额不能为空']
            ];
            $operatetype = $_POST['operatetype'];
            $pointsnum   = $_POST['pointsnum'];
            $money = abs($pointsnum);
            if ($money == 0) {
                showMessage('金额错误');
            }

            try {
                $model_merchant = Model('merchant');
                $trans = new trans_wapper($model_merchant, __METHOD__);
                $member_id = $provider_info['account_id'];
                if ($operatetype == 'add') {
                    $bz = "管理员调款操作，手动增加通道余额";
                    $this->credit_save_money($money, 'add', $member_id, $bz);
                    $_POST['pointsnum'] = $money;
                } elseif ($operatetype == 'del') {
                    $bz = "管理员调款操作，手动减少通道余额";
                    $this->credit_save_money($money, 'del', $member_id, $bz);
                    $_POST['pointsnum'] = -($money);
                } else {
                    showMessage('预存类型错误');
                }
                $result = $this->ct_provider_amount($_POST, $provider_info);
                if (!$result) {
                    $trans->rollback();
                    showMessage('操作失败');
                }
                $trans->commit();
                showMessage('操作成功', 'index.php?act=provider&op=index');
            } catch (Exception $e) {
                $trans->rollback();
                showMessage('操作失败');
            }
        }
        else
        {
            Tpl::output('provider', $provider_info);
            Tpl::showpage('provider.recharge');
        }
    }

    private function ct_provider_amount($params, $provider_info)
    {
        $input['provider_id'] = $provider_info['provider_id'];
        $input['memeber_id'] = $provider_info['account_id'];
        $input['amount'] = $params['pointsnum'];
        $input['operation'] = $params['operation'];
        $input['add_time'] = time();

        return Model('provider_amount')->addAmount($input);
    }

    public function provider_amountOp()
    {
        $condition = [];
        if(!empty($_GET['provider_id'])) {
            $condition['provider_id'] = $_GET['provider_id'];
        }
        $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];
        }
        $provider_list = $this->providers();
        foreach ($provider_list as $provider) {
            $providers[$provider['provider_id']] = $provider;
        }
        $mod = Model('provider_amount');
        $list = $mod->getAmountList($condition,50,'*');
        foreach ($list as $key => $value) {
            $list[$key]['provider_name'] = $providers[$value['provider_id']]['name'];
            $list[$key]['store_name'] = $providers[$value['provider_id']]['store_name'];
        }
        $stat = Model()->table('provider_amount')
            ->where($condition)
            ->field('sum(amount) as amounts')
            ->find();
        Tpl::output('stat', $stat);
        Tpl::output('provider_list', $providers);
        Tpl::output('show_page', $mod->showpage());
        Tpl::output('info_list', $list);
        Tpl::showpage('provider.amount');
    }

    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) {
            $model_member = Model('member');
            foreach ($names as $name) {
                $insert_member = [];
                $insert_member['member_name'] = "{$name['name']}-refill";
                $insert_member['member_passwd'] = md5($name['name']);
                $insert_id = $model_member->addMember($insert_member);
                $helper = new refill\divert_account();
                $helper->init_member($insert_id);

                $data = ['name' => $name['name'], 'type' => $type, 'store_id' => $name['store_id'], 'qualitys' => $name['qualitys'], 'opened' => 2, 'account_id' => $insert_id];
                $mod->insert($data);
            }
        };

        global $config;
        $oil_configs = $config['oil_providers'];
        $pho_configs = $config['phone_providers'];
        $third_configs = $config['third_providers'];
        $oils = $name_val($oil_configs);
        $phones = $name_val($pho_configs);
        $third = $name_val($third_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);

        $third_items = $mod_prov->getProviderList(['type' => 3]);
        $third_items = $name_val($third_items);
        [$third_inserts, $third_updates] = $match($third, $third_items);

        $inserter($mod_prov, 1, $oil_inserts);
        $inserter($mod_prov, 2, $phone_inserts);
        $inserter($mod_prov, 3, $third_inserts);

        $updater($mod_prov, $oil_updates);
        $updater($mod_prov, $phone_updates);
        $updater($mod_prov, $third_updates);
    }
}