error(); } $data = [ 'uid' => $this->auth->id, 'relationname' => $relationname, 'price' => $price, 'createtime' => time(), ]; $id = Db::name('user_relation')->insertGetId($data); $this->success('添加成功',$id); } //关系墙,列表 public function lists(){ $userid = input('uid',0,'intval'); $userid = $userid ? $userid : $this->auth->id; //此用户创建的 $list = Db::name('user_relation')->alias('r') ->field('r.id,r.relationname,r.price,r.to_uid,user.username,user.nickname,user.avatar,user.id as user_id') ->join('user','r.to_uid = user.id','LEFT') ->where('r.uid',$userid) ->order('id desc') ->select(); $list = list_domain_image($list,['avatar']); //别人的关系,此用户加入 /* $list2 = Db::name('user_relation')->alias('r') ->field('r.id,r.relationname,r.price,r.to_uid,user.username,user.nickname,user.avatar,user.id as user_id') ->join('user','r.uid = user.id','LEFT') ->where('r.to_uid',$userid) ->order('id desc') ->select(); $list = list_domain_image($list,['avatar']); $list = array_merge($list,$list2);*/ $this->success(1,$list); } //绑定关系 public function joinin(){ $id = input('id',0); Db::startTrans(); $info = Db::name('user_relation')->where('id',$id)->lock(true)->find(); //检查 if(empty($info)){ Db::rollback(); $this->error('不存在的关系'); } //检查 if($info['to_uid'] > 0){ Db::rollback(); $this->error('该关系已被他人绑定'); } //检查 if($info['uid'] == $this->auth->id){ Db::rollback(); $this->error('不能绑定自己发布的关系'); } //更新 $update = [ 'to_uid' => $this->auth->id, 'updatetime' => time(), ]; $rs = Db::name('user_relation')->where('id',$id)->update($update); if($rs === false){ Db::rollback(); $this->error('操作失败'); } //扣钱 if($info['price'] > 0){ $rs_wallet = model('wallet')->lockChangeAccountRemain($this->auth->id,0,'gold',$info['price'],71,'绑定关系消费','user_relation',$id); if($rs_wallet['status'] === false){ Db::rollback(); $this->error($rs_wallet['msg']); } //给发布关系的人钱 $bili = config('site.money_to_gold'); $money = bcdiv($info['price'],$bili,2); if($money > 0){ $rs_wallet = model('wallet')->lockChangeAccountRemain($info['uid'],0,'money',$money,72,'发布关系被绑定','user_relation',$id); if($rs_wallet['status'] === false){ Db::rollback(); $this->error($rs_wallet['msg']); } } } Db::commit(); $this->success('绑定成功'); } }