APP小程序-注册登录功能改进-绑定邀请人

app/controller/api/Auth.php

@@ -557,51 +557,42 @@ class Auth extends BaseController
 
         return app('json')->success($repository->returnToken($user, $tokenInfo));
     }
+    /**
+     * 绑定邀请人
+     */
     public function bindSpread(UserRepository $repository)
     {
         $data = $this->request->params(['spread_phone']);
-        $uid = $this->request->user()->uid;
-
-        // 查询推荐人
-        $spreadUser = $repository->accountByUser($data['spread_phone']);
-        if (!$spreadUser) {
-            return app('json')->fail('推荐人手机号不存在');
+        $user = $this->request->user();
+        if (!$user || empty($user->uid)) {
+            return app('json')->fail('用户未登录');
         }
-        if ($spreadUser['uid'] == $uid) {
-            return app('json')->fail('不能绑定自己为邀请人');
-        }
-
-        // 绑定推荐人
-        $repository->bindSpreadByUid($uid, intval($spreadUser['uid']));
+        $uid = $user->uid;
 
-        // 如果是 marketing 类型用户，执行营销关系逻辑
-        if ($this->source == "marketing") {
-            $spread = Db::name("User")
-                ->alias("u")
-                ->leftjoin("MarketingUser mu", "u.uid = mu.uid")
-                ->where("u.uid", $spreadUser['uid'])
-                ->field("u.uid,mu.spread_list")
-                ->find();
+        // 检查推荐人手机号是否传入
+        if (empty($data['spread_phone'])) {
+            return app('json')->fail('推荐人手机号不能为空');
+        }
 
-            $spread_list = explode(',', $spread['spread_list']);
-            if (!empty($spread_list)) {
-                $spread_list[] = "[" . $spread['uid'] . "]";
-            } else {
-                array_push($spread_list, "[" . $spread['uid'] . "]");
-            }
-            $spread_list = array_filter($spread_list);
+        // 查找推荐人用户
+        $spread_user = $repository->accountByUser($data['spread_phone']);
+        if (!$spread_user) {
+            return app('json')->fail('推荐人手机号不存在');
+        }
 
-            Db::name("MarketingUser")->insert([
-                "uid"         => $uid,
-                "spread_uid"  => $spread['uid'],
-                "spread_list" => implode(",", $spread_list)
-            ]);
+        // 防止绑定自己为推荐人
+        if ($spread_user['uid'] == $uid) {
+            return app('json')->fail('不能绑定自己为推荐人');
         }
 
-        return app('json')->success('邀请人绑定成功');
+        // 执行绑定
+        $repository->bindSpread($user, intval($spread_user['uid']));
+
+        return app('json')->success('绑定成功');
     }
 
 
+
     /**
      * 手机号找回密码
      * @param UserRepository $repository