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'); $condition = []; if($account){ $condition['det_username'] = $account; } if($type==1){ $condition['det_userid'] = $this->_channelId; } else if($type==2){ $condition['src_channel_id'] = $this->_channelId; } //申请开始时间和结束时间不为空时 if ($apply_begin_time != '' && $apply_end_time != '') { $condition['create_time'] = [ ['>=', strtotime($apply_begin_time)], ['<=', strtotime($apply_end_time . ' 23:59:59')], ]; } //开始时间不为空时 elseif ($apply_begin_time != '') { $condition['create_time'] = ['>=', strtotime($apply_begin_time)]; } //结束时间不为空时 elseif ($apply_end_time != '') { $condition['create_time'] = ['<=', strtotime($apply_end_time . ' 23:59:59')]; } //到账开始时间和结束时间不为空时 if ($finish_begin_time != '' && $finish_end_time != '') { $condition['create_time'] = [ ['>=', strtotime($finish_begin_time)], ['<=', strtotime($finish_end_time . ' 23:59:59')], ]; } //开始时间不为空时 elseif ($finish_begin_time != '') { $condition['create_time'] = ['>=', strtotime($finish_begin_time)]; } //结束时间不为空时 elseif ($finish_end_time != '') { $condition['create_time'] = ['<=', strtotime($finish_end_time . ' 23:59:59')]; } // var_dump($condition); $rechargeList = model('CoinTransfer') ->where($condition) ->whereRaw('src_channel_id='.$this->_channelId.' or det_userid='.$this->_channelId.' and transfer_kind=1') ->paginate(['list_rows'=>$list_rows,'page'=>$page]) ->toArray(); // echo model('ChannelRecharge')->getLastSql()."-----lastsql------
"; $this->jsonResult($rechargeList, 20000, '获取列表成功'); } /** * 转账处理 */ public function transfer() { if ($this->request->isPost()) { $account = $this->input('account','','trim'); //转账账号 $amount = $this->input('amount',0,'intval'); //转账金额 $type = $this->input('type','','trim'); //转账方式:single(单个转账),batch(批量转账) $transfer_kind = $this->input('transfer_kind','','trim'); //收款对象:1(转给玩家),2(转给渠道) $game_id = $this->input('game_id',0,'intval'); //游戏ID $server_id = $this->input('server_id','','trim'); //区服ID $server_name = $this->input('server_name','','trim'); //区服名称 $remark = $this->input('remark','','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($type=='single'){ //单个转账 if(!$account){ $this->jsonResult('', 0, '请输入收款账号'); } if($transfer_kind==1){ //转给玩家 if(!$game_id){ $this->jsonResult('', 0, '请选择要充值的游戏'); } else{ $gameInfo = model('Game')->where(['id'=>$game_id])->find(); if(!$gameInfo){ $this->jsonResult('', 0, '该游戏不存在'); } else{ //判断能否对该玩家进行充值 $chkHasPriv = chkTransferPlayer($this->_channelId,$account); } } } else{ //转给渠道 $chkHasPriv = chkTransferChannel($this->_channelId,$account); } } else { //批量转账 } if(abs(intval($amount*100)/100-$amount) > 0.01){ $this->jsonResult('', 0, '请正确填写支付金额！'); } else { //判断支付金额 $condis = array(); $condis['channel_id'] = $this->_channelId; $condis['begin_time'] = array('elt',$this->nowTime); $condis['end_time'] = array('egt',$this->nowTime); $rechargeRatio = model("ChannelRechargeRatio")->where($condis)->find(); if(!empty($rechargeRatio) && $rechargeRatio['ratio']){ $rechargeRatio = $rechargeRatio['ratio']; } else{ $rechargeRatio = 100; } $discountAmt = floatval($amount*$rechargeRatio/100); if($discountAmt <> $amount){ $this->jsonResult('', 0, '充值金额异常,请刷新页面后重新充值'); } } $channelInfo = model("Channel")->where(['id'=>$this->_channelId])->find(); $recharge_type = 3; // 结算币充值 if($channelInfo && $channelInfo['parent_id']){ if($recharge_type==3 && $channelInfo['js_amount']<$amount){ $this->jsonResult('', 0, '您的结算币余额不足'); } } else{ $this->jsonResult('', 0, '您的账号有异常,请联系管理员'); } //指定时间内，禁止重复下单 if(!requestDuplicateCheck('recharge_pay_duplicate_'.$this->_channelId,$this->payRequestLimit)){ $this->jsonResult('', 0, '充值请求过多，请于'.$this->payRequestLimit.'s以后，再次进行充值操作'); } $rechargeData = array(); $rechargeData['orderid'] = $orderid; $rechargeData['channel_id'] = $this->_channelId; $rechargeData['channel_name'] = $this->_channelName; if($this->_channelLevel==1){ $rechargeData['send_channel_id'] = '0'; $rechargeData['send_channel_name'] = '平台'; } else if($this->_channelLevel==2) { $parentChannelInfo = model("Channel")->where(['id'=>$channelInfo['parent_id']])->find(); $rechargeData['send_channel_id'] = $parentChannelInfo['id']; $rechargeData['send_channel_name'] = $parentChannelInfo['name']; } $paytype = 1; $rechargeData['amount'] = $amount; $rechargeData['real_amount'] = $amount; $rechargeData['recharge_type'] = $recharge_type; $rechargeData['paytype'] = $paytype; $rechargeData['out_order_no'] = $batchNo; $rechargeData['remark'] = $remark; $rechargeData['status'] = 0; $rechargeData['create_time'] = time(); // 启动事务 Db::startTrans(); try{ $result = []; //返回值 //结算币充值 if($recharge_type==3){ $rechargeData['status'] = 1; $insertRechargeId = model("ChannelRecharge")->insert($rechargeData); if(!$insertRechargeId){ throw new Exception("创建订单失败! "); } $detData = array(); $detData['channel_id'] = $this->_channelId; $detData['channel_name'] = $this->_channelName; $detData['change_amount'] = -$amount; $detData['account_type'] = 2; //结算账户 $detData['type'] = 7; //结算充值 $detData['out_orderid'] = $orderid; $detData['create_time'] = NOW_TIMESTAMP; $insertDetId = model('ChannelAccountDet')->insertGetId($detData); if ( !$insertDetId) { throw new Exception("添加账户变动明细失败"); } $updData = array(); $updData['js_amount'] = Db::raw("js_amount-".$amount); $updData['update_time'] = time(); $updResult = model('Channel')->where(['id'=>$this->_channelId,'js_amount'=>array('egt',$amount)])->update($updData); if (!$updResult) { throw new Exception("账户金额变动失败"); } $detData = array(); $detData['channel_id'] = $this->_channelId; $detData['channel_name'] = $this->_channelName; $detData['change_amount'] = $amount; $detData['account_type'] = 1; //通用账户 $detData['type'] = 4; //充值收入 $detData['out_orderid'] = $orderid; $detData['create_time'] = NOW_TIMESTAMP; $insertDetId = model('ChannelAccountDet')->insertGetId($detData); if ( !$insertDetId) { throw new Exception("添加账户变动明细失败"); } $updData = array(); $updData['amount'] = Db::raw("amount+".$amount); $updData['update_time'] = time(); $updResult = model('Channel')->where(['id'=>$this->_channelId])->update($updData); if (!$updResult) { throw new Exception("账户金额变动失败"); } } else{ $insertRechargeId = model("ChannelRecharge")->insert($rechargeData); if(!$insertRechargeId){ throw new Exception("创建订单失败! "); } } $this->redis->del('recharge_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 { $this->jsonResult('', 0, '非法请求'); exit; } } }