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

Timestamp:

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

Author:

anatoo

Message:

メール周り追加

Files:

• events/phpframework/plain_php/trunk/model/phwittr/AcountService.php (modified) (6 diffs)

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

@@ -3 +3 @@
 class AcountService
 {
+    /**
+     * @var PDO
+     */
     protected $pdo;
     
@@ -36 +39 @@
         $smt->bindValue(':delete_flag', $delete_flag, PDO::PARAM_INT);
         $smt->execute();
-        return $smt->rowCount() === 1 ? true : false;
+        return $smt->rowCount() === 1;
     }
     function updatePicture($user_id, $image)
@@ -50 +53 @@
         }
         $smt->execute();
-        return $smt->rowCount() === 1 ? true : false ;
+        return $smt->rowCount() === 1;
     }
     function updatePassword($user_id, $password)
@@ -61 +64 @@
         $smt->bindValue(':password', $password, PDO::PARAM_STR);
         $smt->execute();
-        return $smt->rowCount() === 1 ? true : false;
+        return $smt->rowCount() === 1;
     }
     function updateEmail($user_id, $email)
@@ -70 +73 @@
         $smt->bindValue(':email', $email, PDO::PARAM_STR);
         $smt->execute();
-        return $smt->rowCount() === 1 ? true : false;
+        return $smt->rowCount() === 1;
     }
     
@@ -94 +97 @@
         $smt->bindValue(':act_key', $act_key, PDO::PARAM_STR);
         $smt->execute();
-        return $smt->rowCount() === 1 ? true : false ;
+        return $smt->rowCount() === 1;
     }
     
     function setPrivate($user_id)
     {
-        // @todo 後で実装する
-        return true;
+        $smt = $this->pdo->prepare('
+            update users set private_flag = 1 where id = :user_id limit 1
+        ');
+        $smt->bindValue(':user_id', $user_id, PDO::PARAM_INT);
+        $smt->execute();
+        return $smt->rowCount() === 1;
     }
     function setPublic($user_id)
     {
-        // @todo 後で実装する
+        $this->pdo->beginTransaction();
+        
+        $smt = $this->pdo->prepare('
+            update users set private_flag = 0 where id = :user_id limit 1
+        ');
+        $smt->bindValue(':user_id', $user_id, PDO::PARAM_INT);
+        $smt->execute();
+        
+        if (!$smt->rowCount() === 1) {
+            $this->pdo->rollBack();
+            return false;
+        }
+        
+        $smt = $this->pdo->prepare('
+            select * from requests
+            where request_id = :user_id
+        ');
+        $smt->bindValue(':user_id', $user_id, PDO::PARAM_INT);
+        $smt->execute();
+        $arr = $smt->fetchAll(PDO::FETCH_ASSOC); // $user_idをリクエストしている行列を得る
+        if ($arr == false) {
+            $this->pdo->commit();
+            return true;
+        }
+        
+        foreach ($arr as $r) {
+            $smt = $this->pdo->prepare('
+                insert into 
+                followers(user_id, follow_id, created_at) 
+                values(:user_id, :follow_id, NOW())
+            ');
+            $smt->bindValue(':user_id', $r['user_id'], PDO::PARAM_INT);
+            $smt->bindValue(':follow_id', $user_id, PDO::PARAM_INT);
+            $smt->execute();
+        }
+        
+        $smt = $this->pdo->prepare('
+            delete from requests where request_id = :user_id
+        ');
+        $smt->bindValue(':user_id', $user_id, PDO::PARAM_INT);
+        $smt->execute();
+        
+        $this->pdo->commit();
         return true;
     }