new_sdk_wu/www/new_sdk/application/guildapi/controller/CoinTransferCoin.php

<?php

/**
 * 转账接口控制器
 *
 */

namespace app\guildapi\controller;

use app\common\library\MakeReportGo;
use app\common\model\MemberCoinInfo;
use app\mcpsapi\controller\Guild;
use app\common\model\CoinTransferCoin as CoinTransferCoinModel;
use app\common\library\WeixinPay;
use think\Db;
use think\Config;
use app\common\model\Setting;
use think\Exception;
use app\common\library\MakeReport;

class CoinTransferCoin extends Guild
{

    protected $nowTime;
    protected $payRequestLimit = 5;        //重复下单的限制时间
    protected $redis;                       //redis的句柄对象

    /**
     * 不进行父类的登录验证，所以增加构造方法重写了父类的初始化方法
     */
    public function _initialize()
    {
        parent::_initialize();

        $this->nowTime = NOW_TIMESTAMP;

        $this->redis = \think\Cache::store('default')->handler();
    }

    /**
     * 转账管理
     * @return [type] [description]
     */
    public function index()
    {
        //判断当前账号是否有此功能
        if (!in_array($this->_channelLevel, [1, 2])) {
            $this->jsonResult('', 0, '您无权限使用该功能');
        }

        $list_rows = $this->input('list_rows', 10);
        $page = $this->input('page', 1);
        $type = $this->input('type', '0', 'intval');    //1(转账收入),2(转账支出)
        $account = $this->input('account', '', 'trim');    //收入账号
        $apply_begin_time = $this->input('apply_begin_time', '', 'trim');
        $apply_end_time = $this->input('apply_end_time', '', 'trim');
        $finish_begin_time = $this->input('finish_begin_time', '', 'trim');
        $finish_end_time = $this->input('finish_end_time', '', 'trim');
        $download = $this->input('download', 0, 'intval');

        $condition = [];
        if ($account) {
            $condition['t.det_username'] = $account;
        }

        if (!in_array($type, [1, 2])) {
            $this->jsonResult('', 0, '请选择交易类型');
        }

        if ($type == 1) {
            $condition['t.det_userid'] = $this->_channelId;
            if ($this->_channelLevel == 1) {  //公会
                $condition['t.transfer_type'] = 0;
            } else {   //子会长
                $condition['t.transfer_type'] = 1;
            }
        } else if ($type == 2) {
            $condition['t.src_channel_id'] = $this->_channelId;
            if ($this->_channelLevel == 1) {
                $condition['t.transfer_type'] = array('in', [1, 2]);
            } else {
                $condition['t.transfer_type'] = 3;
            }
        }

        //申请开始时间和结束时间不为空时
        if ($apply_begin_time != '' && $apply_end_time != '') {
            $condition['t.create_time'] = [
                ['>=', strtotime($apply_begin_time)],
                ['<=', strtotime($apply_end_time . ' 23:59:59')],
            ];
        } //开始时间不为空时
        elseif ($apply_begin_time != '') {
            $condition['t.create_time'] = ['>=', strtotime($apply_begin_time)];
        } //结束时间不为空时
        elseif ($apply_end_time != '') {
            $condition['t.create_time'] = ['<=', strtotime($apply_end_time . ' 23:59:59')];
        }

        //到账开始时间和结束时间不为空时
        if ($finish_begin_time != '' && $finish_end_time != '') {
            $condition['t.create_time'] = [
                ['>=', strtotime($finish_begin_time)],
                ['<=', strtotime($finish_end_time . ' 23:59:59')],
            ];
        } //开始时间不为空时
        elseif ($finish_begin_time != '') {
            $condition['t.create_time'] = ['>=', strtotime($finish_begin_time)];
        } //结束时间不为空时
        elseif ($finish_end_time != '') {
            $condition['t.create_time'] = ['<=', strtotime($finish_end_time . ' 23:59:59')];
        }
        //	var_dump($condition);


        if ($download) {
            $sql = model('CoinTransferCoin')->alias('t')
                ->join('cy_game g', 't.game_id = g.id', 'left')
                ->join('nw_channel channel', 't.cuser_id = channel.id', 'left')
                ->field('t.*,t.amount as real_amount,t.status as finish_status,t.create_time as finish_time,g.name as game_name,channel.name as cuser_name')
                ->order("t.id desc")
                ->where($condition)
                ->whereRaw('src_channel_id=' . $this->_channelId . ' or det_userid=' . $this->_channelId . ' and transfer_kind=2')
                ->fetchSql(true)
                ->select();
            //	echo $sql;
//			if ((new MakeReport())->addTask('guild.ChannelTransferIndex', $sql, 'cps'.session('guild_info')['id'])){
            if ((new MakeReportGo())->addTask('guild.ChannelTransferIndex', $sql, 'cps' . session('guild_info')['id'])) {
                $this->jsonResult('', 20000, '报表生成的任务已经提交, 报表生成完成后，会及时通知您，请耐心稍等');
            } else {
                $this->jsonResult('', 20013, '报表生成任务不可重复提交，如遇到无法导出情况，建议修改查询条件解除当前状态，提交重新生成报表任务！');
            }
        }

        $transferList = model('CoinTransferCoin')->alias('t')
            ->join('cy_game g', 't.game_id = g.id', 'left')
            ->join('nw_channel channel', 't.cuser_id = channel.id', 'left')
            ->field('t.*,t.amount as real_amount,t.status as finish_status,t.create_time as finish_time,g.name as game_name,channel.name as cuser_name')
            ->order("t.id desc")
            ->where($condition)
            ->whereRaw('src_channel_id=' . $this->_channelId . ' or det_userid=' . $this->_channelId . ' and transfer_kind=2')
            ->paginate(['list_rows' => $list_rows, 'page' => $page])
            ->toArray();
        //	echo model('CoinTransferCoin')->getLastSql()."-----lastsql------<br>";

        $this->jsonResult($transferList, 20000, '获取列表成功');
    }

    /**
     * 转账处理
     */
    public function transfer()
    {
        if ($this->request->isPost()) {
            $type = $this->input('type', '', 'trim');               //转账方式:single(单个转账),batch(批量转账)
            $transfer_kind = $this->input('transfer_kind', '', 'trim');      //收款对象:1(转给玩家),2(转给渠道)
            $pay_password = $this->input('pay_password', '', 'trim');            //交易密码
            $orderid = 'T' . makeOrderid();
            $batchNo = 'Batch-' . $this->_channelId . '-' . date('YmdHis');

            //判断当前账号是否有充值权限
            if (!in_array($this->_channelLevel, [1, 2])) {
                $this->jsonResult('', 0, '您无权限进行转账操作');
            }
            if (!in_array($type, ['single', 'batch'])) {
                $this->jsonResult('', 0, '请正确选择转账方式');
            } else {
                if (!in_array($transfer_kind, [1, 2])) {
                    $this->jsonResult('', 0, '请选择收款对象');
                }
                if ($transfer_kind == 2 && $this->_channelLevel <> 1) {
                    $this->jsonResult('', 0, '您不能转账给子会长');
                }
            }
            if (!$pay_password) {
                $this->jsonResult('', 0, '请输入交易密码');
            }

            $adminInfo = model("ChannelAdmin")->field("id,username,channel_id,pay_password,secondary_password")->where(['id' => session('guild_info')['id'], 'channel_id' => $this->_channelId])->find();
            if (!$adminInfo) {
                $this->jsonResult('', 0, '账号异常,请重新登录后再试');
            } else if (!$adminInfo['pay_password'] || !$adminInfo['secondary_password']) {
                $this->jsonResult('', 0, '请设置交易密码和二级密码后才能进行提现');
            } else if ($adminInfo['pay_password'] != mg_password($pay_password)) {
                $this->jsonResult('', 0, '交易密码错误!');
            }

            if ($type == 'single') {   //单个转账
                $account = $this->input('account', '', 'trim');            //收款账号
                $amount = $this->input('amount', '', 'trim');            //转账金额
                $remark = $this->input('remark', '', 'trim');            //备注

                if (!$account) {
                    $this->jsonResult('', 0, '请输入收款账号');
                }
                if (!$amount) {
                    $this->jsonResult('', 0, '请输入正确的转账金额');
                } else if (intval($amount) <> $amount) {
                    $this->jsonResult('', 0, '请输入正确的转账金额');
                }
                $amount = $this->input('amount', 0, 'intval');            //转账金额

                $channelInfo = model("Channel")->where(['id' => $this->_channelId])->find();
                if ($channelInfo) {
                    if ($channelInfo['amount_coin'] < $amount) {
                        $this->jsonResult('', 0, '您的平台币余额不足');
                    }
                } else {
                    $this->jsonResult('', 0, '您的账号有异常,请联系管理员');
                }

                if ($transfer_kind == 1) {  //转给玩家
                    $game_id = $this->input('game_id', 0, 'intval');           //游戏ID
                   // $server_id = $this->input('server_id', '', 'trim');          //区服ID
                   // $server_name = $this->input('server_name', '', 'trim');       //区服名称

                    /*
                    if(!$server_id || !$server_name){
                        $this->jsonResult('', 0, '请选择区服信息');
                    }
                    */
                    if (!$game_id) {
                        $this->jsonResult('', 0, '请选择要转账的游戏');
                    } else {
                        $gameInfo = model('Game')->where(['id' => $game_id])->find();
                        if (!$gameInfo) {
                            $this->jsonResult('', 0, '该游戏不存在');
                        }

                        // 效验玩家在游戏和渠道中是否有关系
                        $chkResult = chkTransferPlayer($this->_channelId, $account, $game_id);
                        if ($chkResult['errorCode'] <> 1) {
                            $this->jsonResult('', 0, $chkResult['errorMsg']);
                        } else {
                            $chkResultData = $chkResult['retData'];

                            //指定时间内，禁止重复下单
                            if (!requestDuplicateCheck('transfer_pay_duplicate_' . $this->_channelId, $this->payRequestLimit)) {
                                $this->jsonResult('', 0, '转账请求过多，请于' . $this->payRequestLimit . 's以后，再次进行转账操作');
                            }

                            $transferData = array();
                            $transferData['transfer_kind'] = $transfer_kind;
                            $transferData['batch_no'] = $batchNo;
                            if ($this->_channelLevel == 1) {
                                $transferData['transfer_type'] = 2;
                            } else {
                                $transferData['transfer_type'] = 3;
                            }
                            $transferData['orderid'] = $orderid;
                            $transferData['src_channel_id'] = $this->_channelId;
                            $transferData['src_channel_name'] = $this->_channelName;
                            $transferData['amount'] = $amount;
                            $transferData['game_id'] = $game_id;
                            $transferData['det_userid'] = $chkResultData['userid'];
                            $transferData['det_username'] = $chkResultData['username'];
                            $transferData['cuser_id'] = $chkResultData['cuser_id'];
                           // $transferData['server_id'] = $server_id;
                           // $transferData['server_name'] = $server_name;
                            $transferData['status'] = 1;
                            $transferData['remark'] = $remark;
                            $transferData['create_time'] = time();

                            // 启动事务
                            Db::startTrans();
                            try {
                                $result = [];   //返回值

                                $insertTransferId = model("CoinTransferCoin")->insert($transferData);
                                if (!$insertTransferId) {
                                    throw new Exception("创建转账订单失败! ");
                                }

                                $detData = array();
                                $detData['channel_id'] = $this->_channelId;
                                $detData['channel_name'] = $this->_channelName;
                                $detData['change_amount'] = -$amount;
                                $detData['account_type'] = 3;   //通用账户
                                $detData['type'] = 1;   //转账支出
                                $detData['out_orderid'] = $orderid;
                                $detData['create_time'] = NOW_TIMESTAMP;
                                $insertDetId = model('ChannelAccountDet')->insertGetId($detData);
                                if (!$insertDetId) {
                                    throw new Exception("添加账户变动明细失败");
                                }
                                $updData = array();
                                $updData['amount_coin'] = Db::raw("amount_coin-" . $amount);
                                $updData['update_time'] = time();
                                $updResult = model('Channel')->where(['id' => $this->_channelId, 'amount_coin' => array('egt', $amount)])->update($updData);
                                if (!$updResult) {
                                    throw new Exception("账户金额变动失败");
                                }

                                $coinData = [
                                    'userid' => $chkResultData['userid'],
                                    'orderid' => $orderid,
                                    'start_amount' => $chkResultData['amount'],
                                    'amount' => $amount,
                                    'result_amount' => priceFormat($chkResultData['amount'] + $amount),
                                    'type' => 1,
                                    'remarks' => '平台币充值',
                                    'create_time' => NOW_TIMESTAMP,
                                ];
                                $memberCoinInfoModel = new MemberCoinInfo();
                                if (!$memberCoinInfoModel->insertGetId($coinData)) {
                                    throw new Exception("账户金额变动失败");
                                }
                                if (!model('members')->where('id', $chkResultData['userid'])->update(['amount' => priceFormat($chkResultData['amount'] + $amount)])) {
                                    throw new Exception("账户金额变动失败");
                                }

                                $this->redis->del('transfer_pay_duplicate_' . $this->_channelId);

                                // 提交事务
                                Db::commit();

                            } catch (\Exception $e) {
                                // 回滚事务
                                Db::rollback();

                                $this->jsonResult('', 0, '订单生成失败' . $e->getMessage());
                            }

                            $result['orderid'] = $orderid;

                            $this->jsonResult($result, 20000, '转账成功');
                            exit;
                        }
                    }
                } else {  //转给子公会
                    $chkResult = chkTransferChannel($this->_channelId, $account);
                    if ($chkResult['errorCode'] <> 1) {
                        $this->jsonResult('', 0, $chkResult['errorMsg']);
                    } else {
                        $chkResultData = $chkResult['retData'];

                        //指定时间内，禁止重复下单
                        if (!requestDuplicateCheck('transfer_pay_duplicate_' . $this->_channelId, $this->payRequestLimit)) {
                            $this->jsonResult('', 0, '转账请求过多，请于' . $this->payRequestLimit . 's以后，再次进行转账操作');
                        }

                        $transferData = array();
                        $transferData['transfer_kind'] = $transfer_kind;
                        $transferData['batch_no'] = $batchNo;
                        $transferData['transfer_type'] = 1;
                        $transferData['orderid'] = $orderid;
                        $transferData['src_channel_id'] = $this->_channelId;
                        $transferData['src_channel_name'] = $this->_channelName;
                        $transferData['amount'] = $amount;
                        $transferData['det_userid'] = $chkResultData['userid'];
                        $transferData['det_username'] = $chkResultData['username'];
                        $transferData['status'] = 1;
                        $transferData['remark'] = $remark;
                        $transferData['create_time'] = time();

                        // 启动事务
                        Db::startTrans();
                        try {
                            $result = [];   //返回值

                            $insertTransferId = model("CoinTransferCoin")->insert($transferData);
                            if (!$insertTransferId) {
                                throw new Exception("创建转账订单失败! ");
                            }

                            $detData = array();
                            $detData['channel_id'] = $this->_channelId;
                            $detData['channel_name'] = $this->_channelName;
                            $detData['change_amount'] = -$amount;
                            $detData['account_type'] = 3;   //通用账户
                            $detData['type'] = 1;   //转账支出
                            $detData['out_orderid'] = $orderid;
                            $detData['create_time'] = NOW_TIMESTAMP;
                            $insertDetId = model('ChannelAccountDet')->insertGetId($detData);
                            if (!$insertDetId) {
                                throw new Exception("添加账户变动明细失败");
                            }
                            $updData = array();
                            $updData['amount_coin'] = Db::raw("amount_coin-" . $amount);
                            $updData['update_time'] = time();
                            $updResult = model('Channel')->where(['id' => $this->_channelId, 'amount_coin' => array('egt', $amount)])->update($updData);
                            if (!$updResult) {
                                throw new Exception("账户金额变动失败");
                            }

                            $detData = array();

                            $detData['channel_id'] = $transferData['det_userid'];
                            $detData['channel_name'] = $transferData['det_username'];
                            $detData['change_amount'] = $transferData['amount'];
                            $detData['account_type'] = 3;   //通用账户
                            $detData['type'] = 2;   //转账收入
                            $detData['out_orderid'] = $transferData['orderid'];
                            $detData['create_time'] = NOW_TIMESTAMP;
                            $insertDetId = model('ChannelAccountDet')->insertGetId($detData);
                            if (!$insertDetId) {
                                throw new Exception("添加收款账户变动明细失败");
                            }
                            $updData = array();
                            $updData['amount_coin'] = Db::raw("amount_coin+" . $transferData['amount']);
                            $updData['update_time'] = time();
                            $updToResult = model('Channel')->where(['id' => $transferData['det_userid']])->update($updData);
                            if (!$updToResult) {
                                throw new Exception("收款账户金额变动失败");
                            }

                            $this->redis->del('transfer_pay_duplicate_' . $this->_channelId);

                            // 提交事务
                            Db::commit();

                        } catch (\Exception $e) {
                            // 回滚事务
                            Db::rollback();

                            $this->jsonResult('', 0, '转账失败' . $e->getMessage());
                        }

                        $result['orderid'] = $orderid;

                        $this->jsonResult($result, 20000, '转账成功');
                        exit;
                    }
                }
            } else {      //批量转账

                //设置文件上传的最大限制
                ini_set('memory_limit', '1024M');
                //加载第三方类文件
                vendor("PHPExcel.PHPExcel");
                //防止乱码
                header("Content-type:text/html;charset=utf-8");
                //实例化主文件
                //接收前台传过来的execl文件

                if (!isset($_FILES['file'])) {
                    $this->jsonResult('', 0, '请上传批量导入文件');
                }
                $file = $_FILES['file'];
                //截取文件的后缀名，转化成小写
                $extension = strtolower(pathinfo($file['name'], PATHINFO_EXTENSION));
                if ($extension == "xlsx") {
                    //2007(相当于是打开接收的这个excel)
                    $objReader = \PHPExcel_IOFactory::createReader('Excel2007');
                } else {
                    //2003(相当于是打开接收的这个excel)
                    $objReader = \PHPExcel_IOFactory::createReader('Excel5');
                }

                $objContent = $objReader->load($file['tmp_name']);

                if ($objContent) {

                    $sheetContent = $objContent->getSheet(0)->toArray();
                    $sheetHeaderArr = $sheetContent[0];

                    $headNameValArr = [];
                    for ($i = 0; $i < count($sheetHeaderArr); $i++) {
                        //	echo $sheetHeaderArr[$i]."---$i---<br>";
                        if ($transfer_kind == 1) {   //转账给玩家
                            if (trim($sheetHeaderArr[$i]) == '收款账号') {
                                $headNameValArr['det_username'] = $i;
                            } else if (trim($sheetHeaderArr[$i]) == '金额') {
                                $headNameValArr['amount'] = $i;
                            } else if (trim($sheetHeaderArr[$i]) == '游戏ID') {
                                $headNameValArr['game_id'] = $i;
                            } else if (trim($sheetHeaderArr[$i]) == '游戏名') {
                                $headNameValArr['game_name'] = $i;
                            }
//                            else if (trim($sheetHeaderArr[$i]) == '区服ID') {
//                                $headNameValArr['server_id'] = $i;
//                            } else if (trim($sheetHeaderArr[$i]) == '区服名') {
//                                $headNameValArr['server_name'] = $i;
//                            }
                            else if (trim($sheetHeaderArr[$i]) == '备注') {
                                $headNameValArr['remark'] = $i;
                            }
                        } else {  //转账给子公会
                            if (trim($sheetHeaderArr[$i]) == '收款账号') {
                                $headNameValArr['det_username'] = $i;
                            } else if (trim($sheetHeaderArr[$i]) == '金额') {
                                $headNameValArr['amount'] = $i;
                            } else if (trim($sheetHeaderArr[$i]) == '备注') {
                                $headNameValArr['remark'] = $i;
                            }
                        }
                    }

                    if ($transfer_kind == 1) {   //转账给玩家
//                        if (!(isset($headNameValArr['det_username']) && isset($headNameValArr['amount']) && isset($headNameValArr['game_id']) && isset($headNameValArr['game_name']) && isset($headNameValArr['server_id']) && isset($headNameValArr['server_name']) && isset($headNameValArr['remark']))) {
                        if (!(isset($headNameValArr['det_username']) && isset($headNameValArr['amount']) && isset($headNameValArr['game_id']) && isset($headNameValArr['game_name']) && isset($headNameValArr['remark']))) {
                            $this->jsonResult('', 0, '请选择正确的玩家批量转账导入模板 !');
                        }
                    } else {  //转账给子公会
                        if (!(isset($headNameValArr['det_username']) && isset($headNameValArr['amount']) && isset($headNameValArr['remark']))) {
                            $this->jsonResult('', 0, '请选择正确的子公会批量转账导入模板!');
                        }
                    }

                    unset($sheetContent[0]);    //删除第一行标题

                    /*
                    $headNameValArr['det_username'] = 0;
                    $headNameValArr['amount'] = 1;
                    $headNameValArr['remark'] = 2;

                    $sheetContent = array();
                    $sheetContent[0] = array("B-Promoter3","10","批量转账");
                    $sheetContent[1] = array("B-Promoter4","10","批量转账");
                    $sheetContent[2] = array("B-Promoter5","10","批量转账");
                    */

                    $totalCnt = $succcessCnt = 0;
                    $accountArrs = array();
                    foreach ($sheetContent as $k => $v) {
                        if ($v[0]) $totalCnt++;
                        $arr = array();
                        $arr['orderid'] = $orderid . "-" . ($succcessCnt + 1);
                        $arr['src_channel_id'] = $this->_channelId;
                        $arr['src_channel_name'] = $this->_channelName;
                        $arr['batch_no'] = $batchNo;
                        $arr['status'] = 1;
                        $arr['transfer_kind'] = $transfer_kind;
                        $arr['create_time'] = time();

                        if (!$v{$headNameValArr['amount']}) {
                            $this->jsonResult('', 0, '收款账号:' . trim($v{$headNameValArr['det_username']}) . ' 游戏名:' . trim($v{$headNameValArr['game_name']}) . ' 金额:' . trim($v{$headNameValArr['amount']}) . ' 请输入正确的金额');
                        } else if (trim($v{$headNameValArr['amount']}) <> intval($v{$headNameValArr['amount']})) {
                            $this->jsonResult('', 0, '收款账号:' . trim($v{$headNameValArr['det_username']}) . ' 游戏名:' . trim($v{$headNameValArr['game_name']}) . ' 金额:' . trim($v{$headNameValArr['amount']}) . ' 请输入正确的金额');
                        }
                        if ($transfer_kind == 1) {   //玩家
                            if (trim($v{$headNameValArr['det_username']}) && trim($v{$headNameValArr['amount']}) && intval($v{$headNameValArr['game_id']}) && trim($v{$headNameValArr['game_name']})) {
                                if ($this->_channelLevel == 1) {
                                    $arr['transfer_type'] = 2;
                                } else {
                                    $arr['transfer_type'] = 3;
                                }
                                $arr['amount'] = intval($v{$headNameValArr['amount']});
                                $arr['game_id'] = intval($v{$headNameValArr['game_id']});
//                                $arr['server_id'] = trim($v{$headNameValArr['server_id']});
//                                $arr['server_name'] = trim($v{$headNameValArr['server_name']});
                                $arr['remark'] = trim($v{$headNameValArr['remark']});

                                if (!$arr['game_id']) {
                                    $this->jsonResult('', 0, '请选择要转账游戏');
                                } else {
                                    $gameInfo = model('Game')->where(['id' => $arr['game_id']])->find();
                                    if (!$gameInfo) {
                                        $this->jsonResult('', 0, '收款账号:' . trim($v{$headNameValArr['det_username']}) . ' 游戏名:' . trim($v{$headNameValArr['game_name']}) . ' 金额:' . trim($v{$headNameValArr['amount']}) . ' 游戏不存在');
                                    } else if (trim($gameInfo['name']) <> trim($v{$headNameValArr['game_name']})) {
                                        $this->jsonResult('', 0, '收款账号:' . trim($v{$headNameValArr['det_username']}) . ' 游戏名:' . trim($v{$headNameValArr['game_name']}) . ' 金额:' . trim($v{$headNameValArr['amount']}) . ' 游戏无法匹配');
                                    } else if ($gameInfo['game_kind'] <> 1) {
                                        $this->jsonResult('', 0, '收款账号:' . trim($v{$headNameValArr['det_username']}) . ' 游戏名:' . trim($v{$headNameValArr['game_name']}) . ' 金额:' . trim($v{$headNameValArr['amount']}) . ' 游戏不能使用平台币');
                                    } else {   //判断能否对该玩家进行充值
                                        $chkResult = chkTransferPlayer($this->_channelId, trim($v{$headNameValArr['det_username']}), intval($v{$headNameValArr['game_id']}));
                                        if ($chkResult['errorCode'] <> 1) {
                                            unset($arr);
                                            $this->jsonResult('', 0, $chkResult['errorMsg']);
                                        } else {
                                            $chkResultData = $chkResult['retData'];
                                            $arr['det_userid'] = $chkResultData['userid'];
                                            $arr['det_username'] = $chkResultData['username'];
                                            $arr['cuser_id'] = $chkResultData['cuser_id'];
                                            $succcessCnt++;
                                        }
                                    }
                                }
                            } else {
                                unset($arr);
                                $this->jsonResult('', 0, '收款账号:' . trim($v{$headNameValArr['det_username']}) . ' 游戏名:' . trim($v{$headNameValArr['game_name']}) . ' 金额:' . trim($v{$headNameValArr['amount']}) . ' 该记录不完整,不能进行导入!');
                            }
                        } else {  //子公会
                            if (trim($v{$headNameValArr['det_username']}) && trim($v{$headNameValArr['amount']})) {
                                $arr['transfer_type'] = 1;
                                $arr['amount'] = floatval($v{$headNameValArr['amount']});
                                $arr['remark'] = trim($v{$headNameValArr['remark']});

                                $chkResult = chkTransferChannel($this->_channelId, trim($v{$headNameValArr['det_username']}));
                                if ($chkResult['errorCode'] <> 1) {
                                    unset($arr);
                                    $this->jsonResult('', 0, $chkResult['errorMsg']);
                                } else {
                                    $chkResultData = $chkResult['retData'];
                                    $arr['det_userid'] = $chkResultData['userid'];
                                    $arr['det_username'] = $chkResultData['username'];
                                    $succcessCnt++;
                                }
                            } else {
                                unset($arr);
                                $this->jsonResult('', 0, '收款账号:' . trim($v{$headNameValArr['det_username']}) . ' 金额:' . trim($v{$headNameValArr['amount']}) . ' 该记录不完整,不能进行导入!');
                            }
                        }
                        if (isset($arr)) {
                            $accountArrs[] = $arr;
                        }
                    }

                    if (!$accountArrs) {
                        $this->jsonResult('', 0, '您未导入任何数据，请检查导入文件 !');
                    } else {
                        $result = [];   //返回值
                        $errorMsg = '';

                        $totalAmount = 0;
                        foreach ($accountArrs as $detAccount) {
                            $totalAmount += floatval($detAccount['amount']);
                        }
                        reset($accountArrs);

                        $channelInfo = model("Channel")->where(['id' => $this->_channelId])->find();
                        if ($channelInfo) {
                            if ($channelInfo['amount_coin'] < $totalAmount) {
                                $this->jsonResult('', 0, '您的平台币余额不足');
                            }
                        } else {
                            $this->jsonResult('', 0, '您的账号有异常,请联系管理员');
                        }

                        //指定时间内，禁止重复下单
                        if (!requestDuplicateCheck('transfer_pay_duplicate_' . $this->_channelId, $this->payRequestLimit)) {
                            $this->jsonResult('', 0, '转账请求过多，请于' . $this->payRequestLimit . 's以后，再次进行转账操作');
                        }

                        // 启动事务
                        Db::startTrans();
                        try {
                            foreach ($accountArrs as $transferData) {
                                if ($transfer_kind == 1) {  //转给玩家
                                    $insertTransferId = model("CoinTransferCoin")->insert($transferData);
                                    if (!$insertTransferId) {
                                        throw new Exception("创建转账订单失败! ");
                                    }

                                    $detData = array();
                                    $detData['channel_id'] = $this->_channelId;
                                    $detData['channel_name'] = $this->_channelName;
                                    $detData['change_amount'] = -$transferData['amount'];
                                    $detData['account_type'] = 3;   //通用账户
                                    $detData['type'] = 1;   //转账支出
                                    $detData['out_orderid'] = $transferData['orderid'];
                                    $detData['create_time'] = NOW_TIMESTAMP;
                                    $insertDetId = model('ChannelAccountDet')->insertGetId($detData);
                                    if (!$insertDetId) {
                                        throw new Exception("添加账户变动明细失败");
                                    }
                                    $updData = array();
                                    $updData['amount_coin'] = Db::raw("amount_coin-" . $transferData['amount']);
                                    $updData['update_time'] = time();
                                    $updResult = model('Channel')->where(['id' => $this->_channelId, 'amount_coin' => array('egt', $transferData['amount'])])->update($updData);
                                    if (!$updResult) {
                                        throw new Exception("账户金额变动失败");
                                    }
                                    $memberInfo = model('Members')->where(['id' => $transferData['det_userid']])->field('id,username,flag,amount')->find();
                                    $coinData = [
                                        'userid' => $memberInfo['id'],
                                        'orderid' => $transferData['orderid'],
                                        'start_amount' => $memberInfo['amount'],
                                        'amount' => $transferData['amount'],
                                        'result_amount' => priceFormat($memberInfo['amount'] + $transferData['amount']),
                                        'type' => 1,
                                        'remarks' => '平台币充值',
                                        'create_time' => NOW_TIMESTAMP,
                                    ];
                                    $memberCoinInfoModel = new MemberCoinInfo();
                                    if (!$memberCoinInfoModel->insertGetId($coinData)) {
                                        throw new Exception("账户金额变动失败");
                                    }
                                    if (!model('members')->where('id', $memberInfo['id'])->update(['amount' => priceFormat($memberInfo['amount'] + $transferData['amount'])])) {
                                        throw new Exception("账户金额变动失败");
                                    }

                                    $errorMsg .= '收款账号:' . $transferData['det_username'] . ' 游戏ID:' . $transferData['game_id'] . ' 金额:' . $transferData['amount'] . ' 转账成功;';
                                } else {  //转给子公会
                                    $insertTransferId = model("CoinTransferCoin")->insert($transferData);
                                    if (!$insertTransferId) {
                                        throw new Exception("创建转账订单失败! ");
                                    }

                                    $detData = array();
                                    $detData['channel_id'] = $this->_channelId;
                                    $detData['channel_name'] = $this->_channelName;
                                    $detData['change_amount'] = -$transferData['amount'];
                                    $detData['account_type'] = 3;   //通用账户
                                    $detData['type'] = 1;   //转账支出
                                    $detData['out_orderid'] = $transferData['orderid'];
                                    $detData['create_time'] = NOW_TIMESTAMP;
                                    $insertDetId = model('ChannelAccountDet')->insertGetId($detData);
                                    if (!$insertDetId) {
                                        throw new Exception("添加账户变动明细失败");
                                    }
                                    $updData = array();
                                    $updData['amount_coin'] = Db::raw("amount_coin-" . $transferData['amount']);
                                    $updData['update_time'] = time();
                                    $updResult = model('Channel')->where(['id' => $this->_channelId, 'amount_coin' => array('egt', $transferData['amount'])])->update($updData);

                                    if (!$updResult) {
                                        throw new Exception("账户金额变动失败");
                                    }

                                    $detData = array();

                                    $detData['channel_id'] = $transferData['det_userid'];
                                    $detData['channel_name'] = $transferData['det_username'];
                                    $detData['change_amount'] = $transferData['amount'];
                                    $detData['account_type'] = 3;   //通用账户
                                    $detData['type'] = 2;   //转账收入
                                    $detData['out_orderid'] = $transferData['orderid'];
                                    $detData['create_time'] = NOW_TIMESTAMP;
                                    $insertDetId = model('ChannelAccountDet')->insertGetId($detData);
                                    if (!$insertDetId) {
                                        throw new Exception("添加收款账户变动明细失败");
                                    }
                                    $updData = array();
                                    $updData['amount_coin'] = Db::raw("amount_coin+" . $transferData['amount']);
                                    $updData['update_time'] = time();

                                    $updToResult = model('Channel')->where(['id' => $transferData['det_userid']])->update($updData);
                                    if (!$updToResult) {
                                        throw new Exception("收款账户金额变动失败");
                                    }
                                    $errorMsg .= '收款账号:' . $transferData['det_username'] . ' 金额:' . $transferData['amount'] . ' 转账成功;';
                                }
                            }
                            // 提交事务
                            Db::commit();
                        } catch (\Exception $e) {
                            // 回滚事务
                            Db::rollback();
                            $this->jsonResult('', 0, '转账操作失败' . $e->getMessage());
                        }
                        $this->redis->del('transfer_pay_duplicate_' . $this->_channelId);

                        $result['message'] = $errorMsg;
                        $this->jsonResult($result, 20000, $errorMsg);
                        exit;
                    }
                } else {
                    $this->jsonResult('', 0, '请上传批量导入表格 !');
                }
            }
        } else {
            $this->jsonResult('', 0, '非法请求');
            exit;
        }
    }

    public function getAmount(){
        $adminInfo = session('guild_info');
        $channel_info = Db::name('nw_channel')->where(['id' => $adminInfo['channel_id']])->field('amount,js_amount,amount_coin')->find();
        $this->jsonResult($channel_info, 20000, '获取成功');
    }
}