Changeset 20338 for events/phpframework/plain_php/trunk/model/phwittr/FriendshipService.php

Timestamp:

10/01/08 07:41:06 (3 months ago)

Author:

anatoo

Message:

メール周り追加

Files:

• events/phpframework/plain_php/trunk/model/phwittr/FriendshipService.php (modified) (1 diff)

events/phpframework/plain_php/trunk/model/phwittr/FriendshipService.php

@@ -80 +80 @@
     }
     
-    function follow($user_id, $follow_user_name)
+    function follow($user_id, $follow_user_id)
     {
         $smt = $this->pdo->prepare('
             insert into followers(user_id, follow_id, created_at) 
-            values(:user_id, (select id from users where user_name = 
-            :follow_user_name), now())');
+            values(:user_id, :follow_user_id, now())');
         $smt->bindValue(':user_id', $user_id, PDO::PARAM_INT);
-        $smt->bindValue(':follow_user_name', $follow_user_name, PDO::PARAM_STR);
+        $smt->bindValue(':follow_user_id', $follow_user_id, PDO::PARAM_INT);
         $smt->execute();
     }
 
-    function unfollow($user_id, $follow_user_name)
+    function request($user_id, $request_user_id)
+    {
+        $smt = $this->pdo->prepare('
+            insert into requests(user_id, request_id, created_at) 
+            values(:user_id, :request_user_id, now())
+        ');
+        $smt->bindValue(':user_id', $user_id, PDO::PARAM_INT);
+        $smt->bindValue(':request_user_id', $request_user_id, PDO::PARAM_INT);
+        $smt->execute();
+    }
+    
+    function accept($user_id, $accept_user_id)
+    {
+        $this->pdo->beginTransaction();
+        $this->deny($user_id, $accept_user_id);
+        $this->follow($accept_user_id, $user_id);
+        $this->pdo->commit();
+    }
+
+    function deny($user_id, $deny_user_id)
+    {
+        $smt = $this->pdo->prepare(
+            'delete from requests where user_id = :deny_user_id and ' .
+            'request_id = :user_id');
+        $smt->bindValue(':user_id', $user_id, PDO::PARAM_INT);
+        $smt->bindValue(':deny_user_id', $deny_user_id, PDO::PARAM_INT);
+        $smt->execute();
+    }
+    
+    function unfollow($user_id, $follow_user_id)
     {
         $smt = $this->pdo->prepare(
             'delete from followers where user_id = :user_id and ' .
-            'follow_id = (select id from users where user_name = :follow_user_name)');
+            'follow_id = :follow_user_id');
         $smt->bindValue(':user_id', $user_id, PDO::PARAM_INT);
-        $smt->bindValue(':follow_user_name', $follow_user_name, PDO::PARAM_STR);
+        $smt->bindValue(':follow_user_id', $follow_user_id, PDO::PARAM_INT);
         $smt->execute();
     }
     
-    
+    function isFollowing($user_id, $follow_id)
+    {
+        $smt = $this->pdo->prepare('
+            select followers.user_id 
+            from followers 
+            where user_id = :user_id and follow_id = :follow_id
+            limit 1
+        ');
+        $smt->bindValue(':user_id', $user_id, PDO::PARAM_INT);
+        $smt->bindValue(':follow_id', $follow_id, PDO::PARAM_INT);
+        $smt->execute();
+        
+        return $smt->fetch(PDO::FETCH_ASSOC) !== false;
+    }
+    function isRequesting($user_id, $follow_id)
+    {
+        $smt = $this->pdo->prepare('
+            select requests.user_id 
+            from requests
+            where user_id = :user_id and request_id = :follow_id
+            limit 1
+        ');
+        $smt->bindValue(':user_id', $user_id, PDO::PARAM_INT);
+        $smt->bindValue(':follow_id', $follow_id, PDO::PARAM_INT);
+        $smt->execute();
+        
+        return $smt->fetch(PDO::FETCH_ASSOC) !== false;
+    }
 }