|
@@ -0,0 +1,127 @@
|
|
|
+<?php
|
|
|
+
|
|
|
+namespace app\api\controller;
|
|
|
+
|
|
|
+use app\common\controller\Api;
|
|
|
+use think\Db;
|
|
|
+/**
|
|
|
+ * 关系
|
|
|
+ */
|
|
|
+class Relation extends Api
|
|
|
+{
|
|
|
+ protected $noNeedLogin = ['*'];
|
|
|
+ protected $noNeedRight = ['*'];
|
|
|
+
|
|
|
+ //发布一种新关系
|
|
|
+ public function addone(){
|
|
|
+ $relationname = input('relationname','','trim');
|
|
|
+ $price = input('price',0,'intval');
|
|
|
+
|
|
|
+ if(empty($relationname) || empty($price)){
|
|
|
+ $this->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('绑定成功');
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+}
|