model = new \app\admin\model\Userwithdraw; $this->view->assign("typeList", $this->model->getTypeList()); $this->view->assign("statusList", $this->model->getStatusList()); $this->view->assign("fromList", $this->model->getFromList()); } /** * 默认生成的控制器所继承的父类中有index/add/edit/del/multi五个基础方法、destroy/restore/recyclebin三个回收站方法 * 因此在当前控制器中可不用编写增删改查的代码,除非需要自己控制这部分逻辑 * 需要将application/admin/library/traits/Backend.php中对应的方法复制到当前控制器,然后进行修改 */ /** * 查看 */ public function index() { //当前是否为关联查询 $this->relationSearch = true; //设置过滤方法 $this->request->filter(['strip_tags', 'trim']); if ($this->request->isAjax()) { //如果发送的来源是Selectpage,则转发到Selectpage if ($this->request->request('keyField')) { return $this->selectpage(); } list($where, $sort, $order, $offset, $limit) = $this->buildparams(); $list = $this->model ->with(['user']) ->where($where) ->order($sort, $order) ->paginate($limit); foreach ($list as $row) { $row->getRelation('user')->visible(['username','nickname','mobile']); } $result = array("total" => $list->total(), "rows" => $list->items()); return json($result); } return $this->view->fetch(); } /** * 审核 */ public function audit(){ $id = input('id'); $info = Db::name('user_withdraw') ->where('id',$id) ->find(); if ($this->request->isPost()) { $status = input('status',0); $data = [ 'status' => $status, 'auditremark' => input('auditremark',''), 'audittime' => strtotime(input('audittime')), ]; Db::startTrans(); $rs = Db::name('user_withdraw')->where('id',$id)->update($data); //审核通过,且全部提现的 if($status == 1 && $info['from'] == 1){ //3他的上下级自动衔接 $user = Db::name('user')->where('id',$info['user_id'])->find(); //我的多个下级,的推荐人,改成我的上级。也就是跳过了我 $my_down = Db::name('user')->where('intro_uid',$user['id'])->select(); if(!empty($my_down)){ $new_intro_uid = $user['intro_uid'] ?: 0; $rs_down = Db::name('user')->where('intro_uid',$user['id'])->update(['intro_uid'=>$new_intro_uid]); if($rs_down === false){ Db::rollback(); $this->error('操作失败'); } } //1封号,账户异常,联系客服 //我的推荐人改成0,叫做剥离 $rs_user = Db::name('user')->where('id',$info['user_id'])->update(['status'=>0,'intro_uid'=>0]); if($rs_user === false){ Db::rollback(); $this->error('操作失败'); } //记录个日志 $log = [ 'info' => '用户['.$user['id'].']因全部提现:封号,剥离,其名下直推有['.implode(',',array_column($my_down,'id')).'],都改到其上级['.$user['intro_uid'].']名下', 'createtime' => time(), 'admin_uid' => $this->auth->id, ]; $log_id = Db::name('intro_log')->insertGetId($log); if(!$log_id){ Db::rollback(); $this->error('操作失败'); } //剥离完成 }elseif($status == 2){ //还钱 $wallet_rs = model('wallet')->lockChangeAccountRemain($info['user_id'],'score',$info['score'],21,'兑换被拒绝','user_withdraw',$info['id']); if($wallet_rs['status'] === false){ Db::rollback(); $this->error($wallet_rs['msg']); } //部分提现:日志的提现id,改为0 if($info['from'] == 2){ $wallet_rs = model('wallet')->lockChangeAccountRemain($info['user_id'],'shouyi',$info['score'],21,'兑换被拒绝','user_withdraw',$info['id']); if($wallet_rs['status'] === false){ Db::rollback(); $this->error($wallet_rs['msg']); } } } Db::commit(); $this->success('审核完成'); } $this->assign('row',$info); return $this->view->fetch(); } }