注册用户修改关系网，测试完成

application/common/library/Auth.php

@@ -198,8 +198,7 @@ class Auth
                 $params['intro_ids_new'] = ','.$params['intro_ids'].','; //便于查询所有下级
             }
             $params['intro_level'] = $intro['intro_level'] + 1; //推荐网层数
-            //更新直推数和团队数
-            $this->addIntroNum($intro['id'], 1, 1);
+
         }
 
         //账号注册时需要开启事务,避免出现垃圾数据
@@ -221,10 +220,15 @@ class Auth
             //注册钱包
             Db::name('user_wallet')->insertGetId(['user_id'=>$user->id]);
 
-            //上级的直推人数+1
-            /*if($extend['intro_uid']){
-                Db::name('user')->where('id',$extend['intro_uid'])->setInc('intro_num');
-            }*/
+            //更新直推数和团队数
+            if(!empty($extend['intro_uid'])){
+                $intronum = $this->addIntroNum($extend['intro_uid'], 1, 1);
+                if(!$intronum){
+                    $this->setError('修改关系网错误');
+                    Db::rollback();
+                    return false;
+                }
+            }
 
             //注册成功的事件
             Hook::listen("user_register_successed", $this->_user, $data);
@@ -247,9 +251,12 @@ class Auth
     {
         //更新直推人数
         if($num < 0) {
-            Db::name('user')->where(['id' => $tjrname])->setDec('intro_num', abs($num));
+            $rs1 = Db::name('user')->where(['id' => $tjrname])->setDec('intro_num', abs($num));
         } else {
-            Db::name('user')->where(['id' => $tjrname])->setInc('intro_num', $num);
+            $rs1 = Db::name('user')->where(['id' => $tjrname])->setInc('intro_num', $num);
+        }
+        if($rs1 === false){
+            return false;
         }
         //更新团队
         $rstjr = Db::name('user')->where(['id' => $tjrname])->field('id,intro_ids')->find();
@@ -259,12 +266,18 @@ class Auth
             $arr_intro = explode(',', $tjstr);
 
             if($team < 0) {
-                Db::name('user')->where(['id' => ['in', $arr_intro]])->setDec('intro_num_all', abs($team));
+                $rs2 = Db::name('user')->where(['id' => ['in', $arr_intro]])->setDec('intro_num_all', abs($team));
             } else {
-                Db::name('user')->where(['id' => ['in', $arr_intro]])->setInc('intro_num_all', $team);
+                $rs2 = Db::name('user')->where(['id' => ['in', $arr_intro]])->setInc('intro_num_all', $team);
+            }
+
+            if($rs2 === false){
+                return false;
             }
 
         }
+
+        return true;
     }
 
     /**