users_controller.php

<?php
class UsersController extends AppController {

	var $name = 'Users';
    var $helpers = array('Javascript');
    var $components = array('Auth', 'WebApi', 'Facebook', 'Timeline');
    var $uses = array('User', 'Friend', 'Feed', 'Like', 'Job', 'Level', 'Jobkind');

    function beforeFilter(){
        $this->Auth->userModel = 'User';
        $this->Auth->fields = array('username' => 'email', 'password' => 'password');
        $this->Auth->loginAction = array('action' => 'login');
        $this->Auth->loginRedirect = array('action' => 'index');
        $this->Auth->logoutRedirect = array('action' => 'login');
        $this->Auth->allow('login', 'logout', 'join');
        $this->Auth->loginError = __('email or password is invalid.', true);
        //$this->Auth->authError = 'Please try logon as admin.';
    }

    function index() {
        $this->Friend->recursive = 0;
        $this->Feed->recursive = 1;
        $this->Like->recursive = -1;
        $this->Job->recursive = -1;
        //直近の仕事を抽出 with api_jobalert
        $futu = strtotime('+30 minutes');
        $datestr = date('Y-m-d', $futu);
        $timestr = date('H:i:s', $futu);
        $conditions = array('Job.startdate'=>$datestr, 'Job.starttime <'=>$timestr, 'Job.checkin IS NULL', 'Job.checkout IS NULL', 'Job.user_id'=>$this->Auth->user('id'));
        $latestjob = $this->Job->find('first', array('conditions'=>$conditions));
        //フレンドを抽出
        $friends = $this->Friend->find('list', array('conditions'=> array('Friend.user_id'=>$this->Auth->user('id'))));
        if(!empty($friends)) {
            $arybuf = array();
            foreach($friends as $friend) {
                array_push($arybuf, $friend);
            }
            array_push($arybuf, $this->Auth->user('id'));
            $conditions = array('Feed.user_id IN ('.implode(',', $arybuf).')');
            $order = array('Feed.created DESC');
            $limit = 10;
            $feeds = $this->Feed->find('all', array('conditions'=>$conditions, 'order'=>$order, 'limit'=>$limit));
            $timelines = array();
            foreach($feeds as $feed) {
                $feed['Like']['likes'] = $this->Like->find('count', array('conditions'=>array('Like.feed_id'=>$feed['Feed']['id'], 'Like.user_id'=>$feed['Feed']['user_id'])));
                $feed['Like']['comments'] = $this->Like->find('count', array('conditions'=>array('Like.feed_id'=>$feed['Feed']['id'], 'Like.message IS NOT NULL', 'Like.user_id'=>$feed['Feed']['user_id'])));
                $feed['Feed']['created'] = $this->Timeline->getActionTime($feed['Feed']['created']);
                array_push($timelines, $feed);
            }
            $this->set('feeds', $timelines);
        }
        $this->set('title_for_action', 'バイトの妖精');
        $this->set('userid', $this->Auth->user('id'));
        $this->set('nickname', $this->Auth->user('username'));
        $this->set('latestjob', $latestjob);
    }


    // list follow Users
    function followusers() {
        $this->Friend->recursive = 1;
        $this->paginate = array(
            'conditions' => array('Friend.user_id' => $this->Auth->user('id'))
        );
        $this->set('users', $this->paginate('Friend'));
    }

    // user follow a friend
    function follow($id = null) {
        $this->Friend->recursive = 0;
        if (!$id) {
            $this->Session->setFlash(__('Invalid id for user', true));
            $this->redirect(array('action'=>'searchfriend'));
        }
        // 既にフォローされているか?
        $followed = $this->Friend->find('first', array('conditions'=>array('Friend.user_id'=>$this->Auth->user('id'), 'Friend.friend_id'=>$id)));
        if(!empty($followed)) {
            $this->Session->setFlash(__('This user is already followed', true));
            $this->redirect(array('action'=>'searchfriend'));
        }
        // Friend データを構成
        $friend = array('Friend' => array('user_id' => $this->Auth->user('id'), 'friend_id' => $id));
        $this->User->create();
        if ($this->User->Friend->save($friend)) {
            $this->Session->setFlash(__('followed!', true));
            $this->redirect(array('action' => 'followusers'));
        } else {
            $this->Session->setFlash(__('The user could not be saved. Please, try again.', true));
        }
    }

    // user unfollow a friend
    function unfollow($id = null) {
        if (!$id) {
            $this->Session->setFlash(__('Invalid id for follower', true));
            $this->redirect(array('action'=>'followusers'));
        }
        $friend = $this->User->Friend->find('first', array('conditions'=>array('Friend.friend_id'=>$id, 'Friend.user_id'=>$this->Auth->user('id'))));
        if($friend) {
            if ($this->User->Friend->delete($friend['Friend']['id'])) {
                $this->Session->setFlash(__('unfollowed!', true));
                $this->redirect(array('action'=>'followusers'));
            }
        }
        $this->Session->setFlash(__('This Friend unfollow is unabled', true));
        $this->redirect(array('action' => 'followusers'));
    }


    function view($id = null) {
        if(!$id) $id = $this->Auth->user('id');
        $this->User->recursive = -1;
        $this->Jobkind->recursive = -1;
        $this->Like->recursive = -1;
        $this->Job->recursive = -1;
        $this->Level->recursive = -1;
        $this->Feed->recursive = 0;
		if (!$id) {
			$this->Session->setFlash(__('Invalid friend', true));
			$this->redirect(array('action' => 'index'));
        }
        $user = $this->User->read(null, $id);
        $jobkind = $this->Jobkind->read(null, $user['User']['current_jobkind_id']);
        $likecnt = $this->Like->find('count', array('conditions'=>array('Like.user_id'=>$user['User']['id'])));
        $checkoutcnt = $this->Job->find('count', array('conditions'=>array('Job.user_id'=>$user['User']['id'], 'Job.checkout IS NOT NULL')));
        $level = $this->Level->find('first', array('conditions'=>array('Level.id'=>$user['User']['current_level'], 'Level.jobkind_id'=>$user['User']['current_jobkind_id'])));
        $feeds = $this->Feed->find('all', array('conditions'=>array('Feed.user_id'=>$user['User']['id']), 'order'=>'Feed.id DESC', 'limit'=>5));
        $timelines = array();
        foreach($feeds as $feed) {
            $feed['Like']['likes'] = $this->Like->find('count', array('conditions'=>array('Like.feed_id'=>$feed['Feed']['id'], 'Like.user_id'=>$feed['Feed']['user_id'])));
            $feed['Like']['comments'] = $this->Like->find('count', array('conditions'=>array('Like.feed_id'=>$feed['Feed']['id'], 'Like.message IS NOT NULL', 'Like.user_id'=>$feed['Feed']['user_id'])));
            $feed['Feed']['created'] = $this->Timeline->getActionTime($feed['Feed']['created']);
            array_push($timelines, $feed);
        }
		$this->set('user', $user);
		$this->set('jobkind', $jobkind);
		$this->set('likecnt', $likecnt);
		$this->set('checkoutcnt', $checkoutcnt);
		$this->set('level', $level);
		$this->set('feeds', $timelines);
        $this->set('title_for_action', 'マイページ');
	}


    function join() {
        $this->layout = '';
        if (!empty($this->data)) {
            // 1.join_passwordがある場合、passwordをハッシュ化して格納
            if(!empty($this->data['User']['join_password']) && !empty($this->data['User']['re_password'])) {
                if($this->data['User']['join_password'] == $this->data['User']['re_password']) {
                    $this->data["User"]["password"] = $this->Auth->password($this->data['User']['join_password']);
                } else {
                    $this->Session->setFlash(__('Password columns must input same words', true));
                    $this->redirect(array('action' => 'join'));
                }
            }
            $this->data['User']['point'] = 0; //アカウント登録時の初期ポイントを設定
            $this->data['User']['current_jobkind_id'] = 1; //アカウント登録時の職業IDを設定
            $this->data['User']['current_level'] = 1; //アカウント登録時のレベルを設定
			$this->User->create();
			if ($this->User->save($this->data)) {
				//$this->Session->setFlash(__('The user has been saved', true));
				$this->redirect(array('action' => 'index'));
			} else {
				$this->Session->setFlash(__('The user could not be saved. Please, try again.', true));
			}
		}
	}

    function edit() {
        $id = $this->Auth->user('id'); // get User.id for Auth Session
		if (!$id && empty($this->data)) {
			$this->Session->setFlash(__('Invalid user', true));
			$this->redirect(array('action' => 'index'));
		}
        if (!empty($this->data)) {
            if($this->data['User']['new_password']) {
                if($this->data['User']['new_password'] == $this->data['User']['renew_password']) { //パスワード照合
                    $this->data['User']['password'] = $this->Auth->password($this->data['User']['new_password']);
                }
			    if ($this->User->save($this->data)) {
				    $this->Session->setFlash(__('The user has been saved', true));
				    $this->redirect(array('action' => 'edit'));
			    } else {
				    $this->Session->setFlash(__('The user could not be saved. Please, try again.', true));
			    }
            }
		}
		if ($id) {
			$this->set('user', $this->User->read(null, $id));
		}
        // Facebook 連携
        $fb_uid = null;
        $fb_uid = $this->Facebook->getUser();
        if($fb_uid == 0) {
            $me = $this->Facebook->getMe($this->Auth->user('id'));
            $fb_uid = $me['id'];
        }
        $this->set('fb_uid', $fb_uid);
    }

    function retire($id = null) {
        if(!$id) $id = $this->Auth->user('id');
		if (!$id) {
			$this->Session->setFlash(__('Invalid id for user', true));
			$this->redirect(array('action'=>'index'));
        }
        // リタイヤ処理用画面のリダイレクトが未決定
        /*
		if ($this->User->delete($id)) {
			$this->Session->setFlash(__('User deleted', true));
			$this->redirect(array('action'=>'index'));
        }
         */
        /* impl not yet... */
    }

	function delete($id = null) {
		if (!$id) {
			$this->Session->setFlash(__('Invalid id for user', true));
			$this->redirect(array('action'=>'index'));
		}
		if ($this->User->delete($id)) {
			$this->Session->setFlash(__('User deleted', true));
			$this->redirect(array('action'=>'index'));
		}
		$this->Session->setFlash(__('User was not deleted', true));
		$this->redirect(array('action' => 'index'));
    }

    //Facebook認証へのリダイレクト
    function fbauth() {
        $this->autoRender = false;
        if($this->Facebook->getUser()) { //認証OK後 save&redirect
            if($this->Facebook->saveUser($this->Auth->user('id'))) {
                $this->Session->setFlash('Facebook Authorized');
            } else {
                $this->Session->setFlash(__('Error: cannot Authorized to Facebook', true));
            }
            $this->redirect('edit');
        }
        $this->redirect($this->Facebook->getLoginUrl());
    }

    function login() {
        $this->layout = '';
    }

    function logout() {
        $this->redirect($this->Auth->logout());
    }

    /*** API Contollers ***/

    // async data what checkin yet.
    function api_ischeckin() {
        $this->autoRender = false;
        $conditions = array('Job.checkin IS NOT NULL', 'Job.checkout IS NULL', 'Job.user_id'=>$this->Auth->user('id'));
        $jobs = $this->Job->find('first', array('conditions'=>$conditions));
        $flag = false;
        if(empty($jobs)) {
            $flag = false;
        } else {
            $flag = true;
        }
        $data = array('checkin'=>$flag);
        $this->WebApi->sendApiResult($data);
    }

    // async checkin
    function api_checkin() {
        $this->autoRender = false;
        $thos->Job->recursive = -1;
        $data = array('checkin'=>array('success'=>false));
        $this->log($this->data, LOG_DEBUG);
        if(!empty($this->data)) {
            $job = $this->Job->find('first', array('fields'=>array('Job.id'), 'conditions'=>array('Job.id'=>$this->data['jobId'], 'Job.user_id'=>$this->data['userId'])));
            if(!empty($job)) {
                $job['Job']['checkin'] = date('Y-m-d H:i:s');
                if ($this->Job->save($job)) {
                    $data = array('checkin'=>array('success'=>true));
                } else {
                    $data = array('checkin'=>array('success'=>false, 'message'=>'system error, data save failure'));
                }
            } else {
                $data = array('checkin'=>array('success'=>false, 'message'=>'counldnot find job'));
            }
            $pmsg = 'がバイトにチェックインしました。'."\n";
            //Feedにメッセージを登録
            $feed = array('Feed' => array(
                'user_id'=> $this->data['userId'],
                'job_id'=> $this->data['jobId'],
                'message'=>$pmsg
            ));
            $this->Feed->create();
            if ($this->Feed->save($feed)) {
                $this->log('feed saved', LOG_DEBUG);
                $data = array('checkin'=>array('success'=>true));
                $pubmsg = $this->Auth->user('username').$pmsg;
                $this->Facebook->publish($this->Auth->user('id'), $pubmsg); // publish to Facebook
            } else {
                $data = array('checkin'=>array('success'=>false, 'message'=>'system error, feed data save failure'));
            }
        } else {
            $data = array('checkin'=>array('success'=>false, 'message'=>'post data is null'));
        }
        $this->WebApi->sendApiResult($data);
    }

    // async checkout
    function api_checkout() {
        $this->autoRender = false;
        $thos->Job->recursive = -1;
        $thos->Feed->recursive = -1;
        $data = array('checkout'=>array('success'=>false));
        if(!empty($this->data)) {
            //Jobにチェックアウトタイムを登録
            $job = $this->Job->find('first', array('fields'=>array('Job.id', 'Job.name'), 'conditions'=>array('Job.id'=>$this->data['jobId'], 'Job.user_id'=>$this->data['userId'])));
            if(!empty($job)) {
                $job['Job']['checkout'] = date('Y-m-d H:i:s');
                if ($this->Job->save($job)) {
                    $data = array('checkout'=>array('success'=>true));
                } else {
                    $data = array('checkout'=>array('success'=>false, 'message'=>'system error, job data save failure'));
                }
            } else {
                $data = array('checkout'=>array('success'=>false, 'message'=>'counldnot find job'));
            }
            $pmsg = 'が'.$job['Job']['name'].'からチェックアウトしました。'."\n";
            //Feedにメッセージを登録
            $feed = array('Feed' => array(
                'user_id'=> $this->data['userId'],
                'job_id'=> $this->data['jobId'],
                'message'=>$pmsg.$this->data['message']
            ));
            $this->Feed->create();
            if ($this->Feed->save($feed)) {
                $data = array('checkout'=>array('success'=>true));
                $pubmsg = $this->Auth->user('username').$pmsg.$this->data['message'];
                $this->Facebook->publish($this->Auth->user('id'), $pubmsg); // publish to Facebook
            } else {
                $data = array('checkout'=>array('success'=>false, 'message'=>'system error, feed data save failure'));
            }
        } else {
            $data = array('checkout'=>array('success'=>false, 'message'=>'post data is null'));
        }
        $this->WebApi->sendApiResult($data);
    }

    // async data what information count for badge.
    function api_infocount() {
        $this->autoRender = false;
        //どこからが未読かを判定するトリガが未設計
    }

    // async data what users charactor level.
    function api_getlevel() {
        $this->autoRender = false;
        $this->User->recursive = 1;
        $fields = array('User.current_level', 'User.current_jobkind_id');
        $conditions = array('User.id'=>$this->Auth->user('id'));
        $user = $this->User->find('first', array('fields'=>$fields, 'conditions'=>$conditions));
        $data = array('level'=>0);
        if(!empty($user)) {
            $data = array(
                'level' => $user['User']['current_level'],
                'jobkind' => $user['User']['current_jobkind_id'],
            );
        }
        $this->WebApi->sendApiResult($data);
    }

    // async data what appear jobs near checkin.
    function api_jobalert() {
        $this->autoRender = false;
        $this->Job->recursive = 1;
        $futu = strtotime('+30 minutes');
        $datestr = date('Y-m-d', $futu);
        $timestr = date('H:i:s', $futu);
        $conditions = array('Job.startdate'=>$datestr, 'Job.starttime <'=>$timestr, 'Job.checkin IS NULL', 'Job.checkout IS NULL', 'Job.user_id'=>$this->Auth->user('id'));
        $job = $this->Job->find('first', array('conditions'=>$conditions));
        $data = array('job'=>false);
        if(!empty($job)) {
            $data = array('job' => array(
                'id' => $job['Job']['id'],
                'name' => $job['Job']['name'],
                'date' => $job['Job']['startdate'],
                'startTime' => $job['Job']['starttime'],
            ));
        }
        $this->WebApi->sendApiResult($data);
    }

    // async data what appear jobs near checkout.
    function api_checkoutalert() {
        $this->autoRender = false;
        $this->Job->recursive = 1;
        $futu = strtotime('+30 minutes');
        $datestr = date('Y-m-d H:i:s', $futu);
        $sql = 'SELECT id, name, startdate, starttime FROM jobs as Job WHERE checkin IS NOT NULL and checkout IS NULL and user_id = '.$this->Auth->user('id').' and addtime( addtime( startdate, starttime ) , jobtime ) < \''.$datestr.'\'';
        $job = $this->Job->query($sql);
        $data = array('job'=>false);
        if(!empty($job)) {
            $data = array('job' => array(
                'id' => $job[0]['Job']['id'],
                'name' => $job[0]['Job']['name'],
                'date' => $job[0]['Job']['startdate'],
                'startTime' => $job[0]['Job']['starttime'],
            ));
        }
        $this->WebApi->sendApiResult($data);
    }

    // async data what past feeds
    function api_tl($last_feed_id = null) {
        $this->autoRender = false;
        $this->Feed->recursive = 1;
        $this->Like->recursive = -1;
        if($last_feed_id) {
            $conditions = array('Feed.id <'=>intval($last_feed_id), 'Feed.user_id'=>$this->Auth->user('id'));
        } else {
            $conditions = array('Feed.user_id'=>$this->Auth->user('id'));
        }
        $order = array('Feed.id DESC');
        $limit = 10;
        $feeds = $this->Feed->find('all', array('conditions'=>$conditions, 'order'=>$order, 'limit'=>$limit));
        if(!empty($feeds)) {
            $data = array('feeds'=>array());
            foreach($feeds as $feed) {
                $likesCount = $this->Like->find('count', array('conditions'=>array('Like.feed_id'=>$feed['Feed']['id'])));
                $commentCount = $this->Like->find('count', array('conditions'=>array('Like.feed_id'=>$feed['Feed']['id'], 'Like.message IS NOT NULL')));
                $message = $feed['Feed']['message'];
                $row = array(
                    'id' => $feed['Feed']['id'],
                    'jobkind' => $feed['User']['current_jobkind_id'],
                    'level' => $feed['User']['current_level'],
                    'userId' => $feed['User']['id'],
                    'body' => $message,
                    'likesCount' => $likesCount,
                    'commentCount' => $commentCount,
                    'created' => $feed['Feed']['created']
                );
                array_push($data['feeds'], $row);
            }
        } else {
            $data = array('feeds'=>null);
        }
        $this->WebApi->sendApiResult($data);
    }

    // user follow a friend
    function api_follow($id = null) {
        $this->autoRender = false;
        $this->Friend->recursive = 0;
        if (!$id) {
            $data = array('success'=>false, 'error'=>'noid');
            $this->WebApi->sendApiResult($data);
            return false;
        }
        // 既にフォローされているか?
        $followed = $this->Friend->find('first', array('conditions'=>array('Friend.user_id'=>$this->Auth->user('id'), 'Friend.friend_id'=>$id)));
        if(!empty($followed)) {
            $data = array('success'=>false, 'error'=>'alreadyfollowed', 'userid'=>$id);
            $this->WebApi->sendApiResult($data);
            return false;
        }
        // Friend データを構成
        $friend = array('Friend' => array('user_id' => $this->Auth->user('id'), 'friend_id' => $id));
        $this->User->create();
        if ($this->User->Friend->save($friend)) {
            $data = array('success'=>true, 'userid'=>$id);
            $this->WebApi->sendApiResult($data);
            return true;
        } else {
            $this->WebApi->sendApiResult(null);
        }
    }

    // user unfollow a friend
    function api_unfollow($id = null) {
        $this->autoRender = false;
        if (!$id) {
            $data = array('success'=>false, 'error'=>'noid');
            $this->WebApi->sendApiResult($data);
            return false;
        }
        $friend = $this->User->Friend->find('first', array('conditions'=>array('Friend.friend_id'=>$id, 'Friend.user_id'=>$this->Auth->user('id'))));
        if($friend) {
            if ($this->User->Friend->delete($friend['Friend']['id'])) {
                $data = array('success'=>true, 'userid'=>$id);
                $this->WebApi->sendApiResult($data);
            }
            return true;
        }
        $this->WebApi->sendApiResult(null);
    }

    // get all charactor data
    function api_getcharactors() {
        $this->autoRender = false;
        $this->Level->recursive = -1;
        $this->Jobkind->recursive = -1;
        $jobkinds = $this->Jobkind->find('all');
        $levels = $this->Level->find('all', array('Order'=>array('jobkind_id', 'level')));
        $data = array('chara');
        foreach($jobkinds as $jobkind) {
            $row = array(
                $jobkind['Jobkind']['code'] => array(
                    'name' => $jobkind['Jobkind']['name'],
                    'level' => array()
                )
            );
            foreach($levels as $level) {
                if($jobkind['Jobkind']['id'] == $level['Level']['jobkind_id']) {
                    $cinfs = array(
                        'lv' => $level['Level']['level'],
                        'url' => $level['Level']['avator'],
                        'alt' => $level['Level']['name'],
                    );
                    array_push($row[$jobkind['Jobkind']['code']]['level'], $cinfs);
                }
            }
            array_push($data, $row);
        }
        $this->WebApi->sendApiResult($data);
    }

    //*** Admin Controllers ***

	function admin_index() {
		$this->User->recursive = 0;
        $this->layout = 'admin';
		$this->set('users', $this->paginate());
    }

	function admin_view($id = null) {
        $this->layout = 'admin';
		if (!$id) {
			$this->Session->setFlash(__('Invalid user', true));
			$this->redirect(array('action' => 'index'));
		}
		$this->set('user', $this->User->read(null, $id));
	}

	function admin_add() {
        $this->layout = 'admin';
		if (!empty($this->data)) {
			$this->User->create();
			if ($this->User->save($this->data)) {
				$this->Session->setFlash(__('The user has been saved', true));
				$this->redirect(array('action' => 'index'));
			} else {
				$this->Session->setFlash(__('The user could not be saved. Please, try again.', true));
			}
		}
	}

	function admin_edit($id = null) {
        $this->layout = 'admin';
		if (!$id && empty($this->data)) {
			$this->Session->setFlash(__('Invalid user', true));
			$this->redirect(array('action' => 'index'));
		}
		if (!empty($this->data)) {
			if ($this->User->save($this->data)) {
				$this->Session->setFlash(__('The user has been saved', true));
				$this->redirect(array('action' => 'index'));
			} else {
				$this->Session->setFlash(__('The user could not be saved. Please, try again.', true));
			}
		}
		if (empty($this->data)) {
			$this->data = $this->User->read(null, $id);
		}
	}

	function admin_delete($id = null) {
		if (!$id) {
			$this->Session->setFlash(__('Invalid id for user', true));
			$this->redirect(array('action'=>'index'));
		}
		if ($this->User->delete($id)) {
			$this->Session->setFlash(__('User deleted', true));
			$this->redirect(array('action'=>'index'));
		}
		$this->Session->setFlash(__('User was not deleted', true));
		$this->redirect(array('action' => 'index'));
	}
}