php/www/protected/modules/api/controllers/UserController.php

<?php
/**
 * UserController 用户相关api接口
 */
class UserController extends ApiBaseController{
    public function beforeAction($action){
        $weixin_use = array('info');
        if(Yii::app()->getRequest()->getParam("request_from") == 'weixin' && in_array($action->id,$weixin_use)){
            return true;
        }
        return $this->verify();
    }
    //用户邮箱注册
    public function actionRegister(){
        $userAr  = new RUser();
        $data = array();
        $data['user_name'] = trim(Yii::app()->request->getParam('user_name',''));
        $data['password'] = Yii::app()->request->getParam('password');
        $data['email'] = Yii::app()->request->getParam('email','');
        $data['avatar'] = Yii::app()->request->getParam('avatar','');
        $data['city_info'] =  json_decode(Yii::app()->request->getParam('city_info'),true);
        $position = json_decode(Yii::app()->request->getParam('position'),true);
        $data['position'][0] = isset($position['lng'])?floatval($position['lng']):0;
        $data['position'][1] = isset($position['lat'])?floatval($position['lat']):0;
        //防止city_info出现非法数据
        if(!isset($data['city_info']['province'])){
            $data['city_info']['province'] = '';
            $data['city_info']['city'] = '';
            $data['city_info']['area'] = '';
        }elseif(!isset($data['city_info']['city'])){
            $data['city_info']['city'] = '';
            $data['city_info']['area'] = '';
        }elseif(!isset($data['city_info']['area'])){
            $data['city_info']['area'] = '';
        }

        $data['app_client_id'] = intval(Yii::app()->request->getParam('app_client_id'));
        $data['device_id'] = Yii::app()->request->getParam('device_id');
        $data['channel'] = Yii::app()->request->getParam('channel');
        $data['openid'] = Yii::app()->request->getParam('openid');
        $data['phone_type'] = Yii::app()->request->getParam('phone_type');
        $data['os_version'] = Yii::app()->request->getParam('os_version');
        $data['register_time'] = time();
        $data['last_visit_time'] = time();

        if(!preg_match(Yii::app()->params['emailReg'], $data['email'])){
            CommonFn::requestAjax(false,CommonFn::getMessage('user','email_Illegal'));
        }
        $z_user = new ZUser();
        $z_user->validate_user_name($data['user_name']);
        if(strlen($data['password'])<6 || strlen($data['password'])>20){
            CommonFn::requestAjax(false, CommonFn::getMessage('user','password_length_6_20'));
        }
        $userAr->attributes = $data;
        $criteria = new EMongoCriteria();
        $criteria->email('==',$userAr->email);
        $olduser = RUser::model()->find($criteria);
        if($olduser){
            CommonFn::requestAjax(false,CommonFn::getMessage('user','email_already_registered'));
        }
        $criteria = new EMongoCriteria();
        $criteria->user_name('==',$userAr->user_name);
        $olduser = RUser::model()->find($criteria);
        if($olduser){
            CommonFn::requestAjax(false,CommonFn::getMessage('user','username_already_registered'));
        }
        $userAr->password = md5($userAr->password);
        //用户注册后默认关注几个圈子
        $z_group = new ZGroup();
        $userAr->groups = $z_group->get_default_fllow_group();
        if($userAr->save()){
            $data = RUser::model()->parseRow($userAr->attributes);
            CommonFn::requestAjax(true,CommonFn::getMessage('user','register_success'),$data);
        }else{
            CommonFn::requestAjax(false,CommonFn::getMessage('user','register_faild'));
        }
    }

    //微信用户的登录
    public function actionWeixinLogin(){
        $data = array();
        $data['user_name'] = mb_strtolower(Yii::app()->request->getParam('user_name',''));
        $data['avatar'] = Yii::app()->request->getParam('avatar','');
        $data['city_info'] =  json_decode(Yii::app()->request->getParam('city_info'),true);
        $position = json_decode(Yii::app()->request->getParam('position'),true);

        //防止city_info出现非法数据
        if(!isset($data['city_info']['province']) || $data['city_info']['province'] == '未知'){
            $data['city_info']['province'] = '';
            $data['city_info']['city'] = '';
            $data['city_info']['area'] = '';
        }elseif(!isset($data['city_info']['city'])){
            $data['city_info']['city'] = '';
            $data['city_info']['area'] = '';
        }elseif(!isset($data['city_info']['area'])){
            $data['city_info']['area'] = '';
        }

        $data['position'][0] = isset($position['lng'])?floatval($position['lng']):0;
        $data['position'][1] = isset($position['lat'])?floatval($position['lat']):0;

        $data['app_client_id'] = intval(Yii::app()->request->getParam('app_client_id'));
        $data['device_id'] = Yii::app()->request->getParam('device_id');
        $data['channel'] = Yii::app()->request->getParam('channel');
        $data['phone_type'] = Yii::app()->request->getParam('phone_type');
        if($data['channel'] == 'appstore'){
            $data['phone_type'] = Yii::app()->request->getParam('device_model');
        }
        $data['app_version'] = Yii::app()->request->getParam('app_version');

        $data['os_version'] = Yii::app()->request->getParam('os_version');

        $data['openid'] = Yii::app()->request->getParam('openid','');
        $data['unionid'] = Yii::app()->request->getParam('unionid','');

        $data['sex'] = intval(Yii::app()->request->getParam('sex'));

        $data['register_time'] = time();
        $data['last_visit_time'] = time();

        

        if ($data['openid'] == ''){
            CommonFn::requestAjax(false, CommonFn::getMessage('user','weixin_login_faild'));
        }

        $criteria = new EMongoCriteria();
        if(isset($data['unionid']) && !empty($data['unionid'])){
            $criteria->unionid('==',$data['unionid']);//unionid保证账号统一
        }else{
            $criteria->openid('==',$data['openid']);
        }
        $user = RUser::model()->find($criteria);
        if($user){
            $user->os_version = $data['os_version'];
            $user->device_id = $data['device_id'];
            $user->app_client_id = $data['app_client_id'];
            $paraArr = array('os_version','device_id','app_client_id');
            if(!empty($data['position'])&&!empty($data['position'][0])&&!empty($data['position'][1])){
                $user->position = $data['position'];
                $paraArr[] = 'position';
            }
            if(!empty($data['city_info']['province'])){
                $user->city_info = $data['city_info'];
                $paraArr[] = 'city_info';
            }
            $user->update($paraArr,true);
            $data = RUser::model()->parseRow($user->attributes);
            $z_action_cat = new ZActionCat();
            $news_count = $z_action_cat->getUnReadNews($user->_id);
            $data['news'] = $news_count;
            CommonFn::requestAjax(true,CommonFn::getMessage('user','login_success'),$data);
        }else{
            $z_user = new ZUser();
            $z_user->validate_user_name($data['user_name']);
            $userAr  = new RUser();
            $userAr->user_name = $data['user_name'];
            $userAr->avatar = $data['avatar'];
            $userAr->city_info = $data['city_info'];
            $userAr->position = $data['position'];
            $userAr->app_client_id = $data['app_client_id'];
            $userAr->device_id = $data['device_id'];
            $userAr->phone_type = $data['phone_type'];
            $userAr->app_version = $data['app_version'];
            $userAr->os_version = $data['os_version'];
            $userAr->channel = $data['channel'];
            $userAr->openid = $data['openid'];
            $userAr->unionid = $data['unionid'];
            $userAr->sex = $data['sex']?$data['sex']:3;
            $userAr->register_time = $data['register_time'];
            $userAr->last_visit_time = $data['last_visit_time'];
            try {
                $saveResult = $userAr->save();
            }catch(Exception $e){
                $userAr->user_name = 'wz_'.dechex(time());
                $saveResult = $userAr->save();
            }

            if($saveResult){
                $z_group = new ZGroup();
                $default_groups = $z_group->get_default_fllow_group();
                $userAr->groups = $default_groups;
                $userAr->update(array('groups'),true);
                $list = new ARedisList('after_user_reg');
                $user_id = (string)$userAr->_id;
                $list->push($user_id);
                $data = RUser::model()->parseRow($userAr->attributes);
                $news = [
                    'like'=>0,
                    'message'=>0,
                    'reply'=>0,
                    'notice'=>0,
                    'order'=>0,
                    'follow'=>0,
                    'new_topic'=>0,
                    'new_card'=>0,
                    'total'=>0
                ];
                $data['news'] = $news;
                CommonFn::requestAjax(true,CommonFn::getMessage('user','register_success'),$data,200,array('is_new'=>1));
            }else{
                CommonFn::requestAjax(false,CommonFn::getMessage('user','register_faild'));
            }
        }
    }

    //用户登陆
    public function actionLogin(){
        $password = md5(Yii::app()->request->getParam('password'),'');
        $email = preg_replace('/\0/','',Yii::app()->request->getParam('email',''));
        $email = str_replace(' ','',$email);
        if($password&&$email){
            $criteria = new EMongoCriteria();
            $criteria->email = new MongoRegex('/' . $email . '/i');

            try {
                $userAr = RUser::model()->find($criteria);
            } catch (Exception $e) {
                CommonFn::requestAjax(false,CommonFn::getMessage('user','id_not_exist'));
            }
            if(!$userAr){
                CommonFn::requestAjax(false,CommonFn::getMessage('user','id_not_exist'));
            }
            if($password == $userAr->password){
                $userAr->last_visit_time = time();
                $userAr->update(array('last_visit_time'),true);
                $z_action_cat = new ZActionCat();
                $news_count = $z_action_cat->getUnReadNews($userAr->_id);
                $data = RUser::model()->parseRow($userAr->attributes);
                $data['news'] = $news_count;
                CommonFn::requestAjax(true,CommonFn::getMessage('message','operation_success'),$data);
            }else{
                CommonFn::requestAjax(false,CommonFn::getMessage('user','username_or_password_error'));
            }
        }else{
            CommonFn::requestAjax(false,CommonFn::getMessage('message','params_miss'));
        }
    }

    //用户登陆前验证
    public function actionValidate(){
        $email = Yii::app()->request->getParam('email');
        if(!$email){
            CommonFn::requestAjax(false,CommonFn::getMessage('message','params_miss'));
        }
        $criteria = new EMongoCriteria();
        if(preg_match(Yii::app()->params['emailReg'], $email)){
            $criteria->email('==',$email);
        }else{
            $criteria->user_name('==',$email);
        }
        $userAr = RUser::model()->find($criteria);
        if($userAr){
            CommonFn::requestAjax(false,CommonFn::getMessage('user','email_already_registered'));
        }else{
            CommonFn::requestAjax(true,'');
        }
    }


    //用户信息
    public function actionInfo(){
        if(Yii::app()->request->getParam('app_client_id') == 2){
            $this->check_version();
        }
        $user_id = Yii::app()->getRequest()->getParam("user_id");
        $uid = Yii::app()->getRequest()->getParam("to_user_id");
        $user_name = Yii::app()->getRequest()->getParam("user_name");
        if($user_name){
            $criteria = new EMongoCriteria();
            $criteria->user_name('==',$user_name);
            $res = RUser::model()->find($criteria);
            if(!$res){
                CommonFn::requestAjax(false,CommonFn::getMessage('user','user_not_exist'),204);
            }else{
                $uid = $res->_id;
            }
        }
        $page = intval(Yii::app()->getRequest()->getParam("page",1));
        if(empty($page)){
            $page = 1;
        }
        $notopic = Yii::app()->getRequest()->getParam("notopic");
        if(empty($user_id) && empty($uid)){
            CommonFn::requestAjax(false,CommonFn::getMessage('user','id_not_empty'),201);
        }
        $add_score = $this->today_first_login($user_id);
        if($user_id){
            $id = $user_id;
        }
        $model = new RUser();
        if($uid){
            if($user_id){
                $user_node = new UserNodeRecord($user_id);
                $relation = $user_node->relation($uid);
            }
            $id = $uid;
        }
        $user = CommonFn::apigetObJ($id,"ZUser",CommonFn::getMessage('user','id_not_exist'),201);
        $user_data = $model->parseRow($user->attributes,array(),true);

        $user_data['relation'] = isset($relation)?$relation:0;
        $criteria = new EMongoCriteria();
        $criteria->user('==',$user->_id);
        $criteria->status("==",1);
        $criteria->limit(3)->sort('time',EMongoCriteria::SORT_DESC);
        $model = new Topic();
        $cursor = $model->findAll($criteria);
        $rows = CommonFn::getRows($cursor);
        $topics = $model->parse($rows);
        $feed = array();
        if($topics){
            $feed['pics'] = array();
            foreach ($topics as $topic) {
                $feed['pics'] = array_merge($feed['pics'],$topic['pics']);
                $feed['pics'] = array_slice($feed['pics'],0,3);
            }
            if($feed['pics']){
                $feed['type'] = 'pics';
                $user_data['feed'] = $feed;
            }elseif($topics[0]['content']){
                $feed['type'] = 'text';
                $feed['content'] = $topics[0]['content'];
                $user_data['feed'] = $feed;
            }else{
                $feed['type'] = 'text';
                $feed['content'] = '';
                $user_data['feed'] = $feed;
            }
        }else{
            $feed['type'] = 'text';
            $feed['content'] = '';
            $user_data['feed'] = $feed;
        }
        $z_action_cat = new ZActionCat();
        $news_count = $z_action_cat->getUnReadNews($user->_id);
        $user_data['news'] = $news_count;
        $data['user'] = $user_data;
        if(empty($notopic)){
            $conditions = array(
                'user'=>array('==',$user->_id),
                'status'=>array('==',1)
            );
            $order = array(
                'time'=>'desc',
            );
            $model = new Topic();
            $pagedata = CommonFn::getPagedata($model,$page,20,$conditions,$order);
            $user_topics = $pagedata['res'];
            if(!empty($user_id)){
                foreach ($user_topics as $key => $topic) {
                    $z_like = new ZLike();
                    $like = $z_like->getLikeByLikeObj($user_id,$topic['id']);
                    if(empty($like)){
                        $user_topics[$key]['is_liked'] = false;
                    }else{
                        $user_topics[$key]['is_liked'] = true;
                    }
                }
                if(Yii::app()->getRequest()->getParam("page_size",0)==1){
                    if(isset($user_topics[0]['pics'])&&count($user_topics[0]['pics'])<3){
                        $criteria = new EMongoCriteria();
                        $criteria->user('==',$user->_id);
                        $criteria->status("==",1);
                        $criteria->limit(2)->sort('time',EMongoCriteria::SORT_DESC)->offset(1);
                        $model = new Topic();
                        $cursor = $model->findAll($criteria);
                        $rows = CommonFn::getRows($cursor);
                        $topics = $model->parse($rows);
                        foreach ($topics as $topic) {
                            $user_topics[0]['pics'] = array_merge($user_topics[0]['pics'],$topic['pics']);
                            $user_topics[0]['pics'] = array_slice($user_topics[0]['pics'],0,3);
                        }
                    }
                }
            }
            $data['topic_list'] = $user_topics;
        }
        if($add_score['status']){
            $score_info['score_change'] = $add_score['score'];
            $score_info['current_score'] = $add_score['current_score'];
            $score_info['score_type'] = '签到';
            if(isset($pagedata)){
                CommonFn::requestAjax(true,CommonFn::getMessage('message','operation_success'),$data,303,array_merge($score_info,array('sum_count' => $pagedata['sum_count'],'sum_page'=>$pagedata['sum_page'],'page_size'=>$pagedata['page_size'],'current_page'=>$pagedata['current_page'])));
            }else{
                CommonFn::requestAjax(true,CommonFn::getMessage('message','operation_success'),$data,303,$score_info);
            }
        }else{
            if(isset($pagedata)){
                CommonFn::requestAjax(true,CommonFn::getMessage('message','operation_success'),$data,200,array('sum_count' => $pagedata['sum_count'],'sum_page'=>$pagedata['sum_page'],'page_size'=>$pagedata['page_size'],'current_page'=>$pagedata['current_page']));
            }else{
                CommonFn::requestAjax(true,CommonFn::getMessage('message','operation_success'),$data);
            }
        }
    }

    /**
     * 按照时间线展现帖子列表
     * 当前日期的帖子没有显示完后，会追加当天剩余帖子数.并传递实际数据偏移量给前端
     */
    public function actionInfoByTimeline(){
        $user_id = Yii::app()->getRequest()->getParam("user_id");
        $uid = Yii::app()->getRequest()->getParam("to_user_id");
        $user_name = Yii::app()->getRequest()->getParam("user_name");
        if($user_name){
            $criteria = new EMongoCriteria();
            $criteria->user_name('==',$user_name);
            $res = RUser::model()->find($criteria);
            if(!$res){
                CommonFn::requestAjax(false,CommonFn::getMessage('user','user_not_exist'),array(),204);
            }else{
                $uid = $res->_id;
            }
        }
        $page = intval(Yii::app()->getRequest()->getParam("page",1));
        if(empty($page)){
            $page = 1;
        }
        $offset = Yii::app()->getRequest()->getParam('offset',0);
        if(empty($user_id) && empty($uid)){
            CommonFn::requestAjax(false,CommonFn::getMessage('user','id_not_empty'),201);
        }
        if($uid){
            if($user_id){
                $user_node = new UserNodeRecord($user_id);
                $relation = $user_node->relation($uid);
            }
        }
        if($user_id){
            $id = $user_id;
        }
        if($uid){
            $id = $uid;
        }
        $model = new RUser();
        $user_obj = CommonFn::apigetObJ($id,"ZUser",CommonFn::getMessage('user','id_not_exist'),201);
        $user_data = $model->parseRow($user_obj->attributes);
        $user_data['relation'] = isset($relation)?$relation:0;
        //获取用户帖子信息
        $topic_model = new ZTopic();
        $user_topics = array();
        $pagesize = 20;
        $page_offset = ($page - 1) * $pagesize;
        if(!$offset){
            $offset = $offset > 0 && $page_offset < $offset ? $offset : $page_offset;
        }
        $criteria = new EMongoCriteria();
        $criteria->user('==',$user_obj->_id);
        $criteria->status("==",1);
        $criteria->limit($pagesize)->sort('time',EMongoCriteria::SORT_DESC)->offset($offset);
        $model = new Topic();
        $cursor = $model->findAll($criteria);
        $rows = CommonFn::getRows($cursor);
        $rows = $model->parse($rows);
        //获取有追加数据
        if(count($rows)<1){
            $data = array(
                'user' => $user_data,
                'topic_list' => array(),
                'offset' => $offset,
            );
            CommonFn::requestAjax(true,CommonFn::getMessage('message','operation_success'),$data,200,array('is_more'=>0));
        }
        $last_topic = $rows[count($rows)-1];
        $append_data = $topic_model->getAppendDateByDate($uid,$last_topic['last_post_time']);
        if($append_data){
            $rows = array_merge($rows,$append_data);
        }
        //按时间顺序排列
        foreach($rows as $row ){
            $user_topics[$row['date']]['time'] = $row['date'];
            $user_topics[$row['date']]['data'][] = $row;
        }
        $user_topics = array_values($user_topics);

        $current_offset = count($rows)+$offset;     //当前实际数据偏移值
        if(count($rows)<20){
            $is_more = 0;
        }else{
            $is_more = 1;
        }
        //追加到用户数据中
        $data = array(
            'user' => $user_data,
            'topic_list' => $user_topics,
            'offset' => $current_offset
        );
        CommonFn::requestAjax(true,CommonFn::getMessage('message','operation_success'),$data,200,array('is_more'=>$is_more));
    }

    //用户收藏信息接口
    public function actionFavList(){
        $user_id = Yii::app()->getRequest()->getParam("user_id");
        $page = intval(Yii::app()->getRequest()->getParam("page",1));
        if(empty($page)){
            $page = 1;
        }
        //获取用户收藏信息
        $user = CommonFn::apigetObJ($user_id,'ZUser',CommonFn::getMessage('user','id_not_exist'),201);
        $pagesize = Yii::app()->params['userFavsPageSize'];
        $conditions = array(
            'user'=>array('==',$user->_id)
        );
        $order = array(
            'time'=>'desc',
        );
        $model = new Fav();
        $pagedata = CommonFn::getPagedata($model,$page,$pagesize,$conditions,$order);
        $user_favs = $pagedata['res'];
        if(!empty($user_favs)){
            foreach ($user_favs as $key => $value) {
                if($value['fav_obj']['status']!=1){
                    unset($user_favs[$key]);
                }
            }
        }
        $data = array();
        foreach($user_favs as $fav){
            $z_like = new ZLike();
            $like = $z_like->getLikeByLikeObj($user_id,$fav['fav_obj']['id']);
            if(empty($like)){
                $fav['fav_obj']['is_liked'] = false;
            }else{
                $fav['fav_obj']['is_liked'] = true;
            }
            $data[] = $fav['fav_obj'];
        }
        CommonFn::requestAjax(true,CommonFn::getMessage('message','operation_success'),$data,200,array('sum_count' => $pagedata['sum_count'],'sum_page'=>$pagedata['sum_page'],'page_size'=>$pagedata['page_size'],'current_page'=>$pagedata['current_page']));
    }

    //用户帖子列表页面
    public function actionTopicList(){
        $user_id = Yii::app()->getRequest()->getParam("user_id");
        $uid = Yii::app()->getRequest()->getParam("to_user_id");
        $page = intval(Yii::app()->getRequest()->getParam("page",1));
        if(empty($page)){
            $page = 1;
        }
        $offset = Yii::app()->getRequest()->getParam('offset',0);

        if(empty($user_id) && empty($uid)){
            CommonFn::requestAjax(false,CommonFn::getMessage('user','id_not_empty'),201);
        }
        if($user_id){
            $id = $user_id;
            $time_list_flag = true;
        }
        if($uid){
            $id = $uid;
            $time_list_flag = false;
        }

        //获取用户帖子列表
        $topic_model = new ZTopic();
        $user_topics = array();
        $rows = $topic_model->getUserTopic($id,$page,$offset);
        if(count($rows)<1){
            $data = array(
                'topic_list' => array(),
                'offset' => $offset,
            );
            CommonFn::requestAjax(true,CommonFn::getMessage('message','operation_success'),$data);
        }

        if($time_list_flag){
            //获取有追加数据
            $last_topic = $rows[count($rows)-1];
            $append_data = $topic_model->getAppendDateByDate($id,$last_topic['last_post_time']);
            if($append_data){
                $rows = array_merge($rows,$append_data);
            }

            //按时间顺序排列
            foreach($rows as $row ){
                $user_topics[$row['date']]['time'] = $row['date'];
                $user_topics[$row['date']]['data'][] = $row;
            }
            $user_topics = array_values($user_topics);

        }else{
            $user_topics = $rows;
        }
        $current_offset = count($rows);     //当前实际数据偏移值

        $data = array(
            'topic_list' => $user_topics,
            'offset' => $current_offset,
        );
        CommonFn::requestAjax(true,CommonFn::getMessage('message','operation_success'),$data);
    }

    //修改用户资料
    public function actionEdit(){
        $data['_id'] = Yii::app()->getRequest()->getParam('user_id');
        if(!CommonFn::isMongoId($data['_id'])){
            CommonFn::requestAjax(false,CommonFn::getMessage('user','id_not_exist'),201);
        }
        $model = new RUser();
        $user = CommonFn::apigetObJ($data['_id'],"ZUser",CommonFn::getMessage('user','id_not_exist'),201);

        //需要进行修改的数据内容
        $data['avatar'] = Yii::app()->getRequest()->getParam('avatar','');
        $data['mobile'] = Yii::app()->getRequest()->getParam('mobile','');
        $data['sex'] =  intval(Yii::app()->getRequest()->getParam('sex'));
        $data['user_name']= Yii::app()->getRequest()->getParam('user_name','');
        $data['city_info'] =  json_decode(Yii::app()->request->getParam('city_info'),true);
        //防止city_info出现非法数据
        if(!isset($data['city_info']['province'])){
            $data['city_info']['province'] = '';
            $data['city_info']['city'] = '';
            $data['city_info']['area'] = '';
        }elseif(!isset($data['city_info']['city'])){
            $data['city_info']['city'] = '';
            $data['city_info']['area'] = '';
        }elseif(!isset($data['city_info']['area'])){
            $data['city_info']['area'] = '';
        }
        if($data['avatar']){
            if(!CommonFn::checkPicFormat($data['avatar'])){
                CommonFn::requestAjax(false,CommonFn::getMessage('user','user_avatar_illegal'));
            }
        }
        if($user->certify_status == 1 && $data['user_name'] &&  $user->user_name != $data['user_name']){
            CommonFn::requestAjax(false,'你已通过认证，不允许修改昵称');
        }
        //过滤user_id ，检测本接口所需参数是否完整
        $item_count = 0;
        unset($data['_id']);
        //用户名检测
        if(isset($data['user_name']) && $data['user_name']){
            if(mb_strlen($data['user_name'],'utf-8')<2||mb_strlen($data['user_name'],'utf-8')>16){
                CommonFn::requestAjax(false,CommonFn::getMessage('user','username_length_illegal'));
            }
            $z_user = new ZUser();
            $z_user->validate_user_name($data['user_name']);
            $u_criteria = new EMongoCriteria();
            $u_criteria->user_name('==',$data['user_name']);
            $olduser = RUser::model()->find($u_criteria);
            if($olduser&&$olduser->_id!=$user->_id){
                CommonFn::requestAjax(false,CommonFn::getMessage('user','username_already_registered'));
            }
        }elseif(empty($data['user_name'])){
            $data['user_name'] = $user->user_name;
        }
        foreach($data as $key => $val){
            if(!empty($val)){
                if($key=='city_info' && empty($val['province'])){
                    continue;
                }
                $item_count++;
                $user->{$key} = $val;
            }
        }
        //更新数据
        if($item_count){
            if($user->save(true)){
                $data = $user->parseRow($user->attributes,array(),true);
                CommonFn::requestAjax(true,CommonFn::getMessage('message','operation_success'),$data);
            }else{
                CommonFn::requestAjax(false,CommonFn::getMessage('message','operation_faild'));
            }
        }else{
            CommonFn::requestAjax(false,CommonFn::getMessage('message','params_illegal'));
        }
    }

    //用户爪币记录
    public function actionScoreLog(){
        $user_id = Yii::app()->getRequest()->getParam("user_id");
        $page = intval(Yii::app()->getRequest()->getParam("page",1));
        if(empty($page)){
            $page = 1;
        }
        if(empty($user_id) ){
            CommonFn::requestAjax(false,CommonFn::getMessage('user','id_not_exist'),201);
        }
        if($user_id){
            $id = $user_id;
        }
        $deviceid =  Yii::app()->request->getParam('device_id');
        //设置首次访问时间，保证一次浏览的回复列表不变
        $actiontime = CommonFn::getFirstTime(ActionTimeRedis::TYPE_GET_SCORELOG,$deviceid,$page);
        $pagesize = Yii::app()->params['userScoreLogPageSize'];
        $conditions = array(
            'user'=>array('==',$id),
            'time'=>array('<=',$actiontime)
        );
        $order = array(
            'time'=>'desc',
        );
        $model = new UserScoreLog();
        $pagedata = CommonFn::getPagedata($model,$page,$pagesize,$conditions,$order);
        $logs = $pagedata['res'];
        CommonFn::requestAjax(true,CommonFn::getMessage('message','operation_success'),$logs,200,array('sum_count' => $pagedata['sum_count'],'sum_page'=>$pagedata['sum_page'],'page_size'=>$pagedata['page_size'],'current_page'=>$pagedata['current_page']));
    }

    //用户拒绝接受推送
    public function actionSetPush(){
        $user_id = Yii::app()->getRequest()->getParam("user_id");
        $user = CommonFn::apigetObJ($user_id,"ZUser",CommonFn::getMessage('user','id_not_exist'),201);
        if($user->receive_push == 0){
            $user->receive_push = 1;
            if($user->update(array('receive_push'),true)){
                CommonFn::requestAjax(true,CommonFn::getMessage('message','operation_success'),array('op'=>'receive'));
            }
        }else{
            $user->receive_push = 0;
            if($user->update(array('receive_push'),true)){
                CommonFn::requestAjax(true,CommonFn::getMessage('message','operation_success'),array('op'=>'unreceive'));
            }
        }
    }

    //用户分享成功后增加爪币
    public function actionShareSuccess(){
        $user_id = Yii::app()->getRequest()->getParam("user_id");
        $user = CommonFn::apigetObJ($user_id,"ZUser",CommonFn::getMessage('user','id_not_exist'),201);
        $add_score = $this->addScore($user_id,'score_share');
        $result = array();
        if($add_score['status']){
            $add_score['score_change'] = $add_score['score'];
            $add_score['current_score'] = $add_score['current_score'];
            $add_score['score_type'] = '分享成功';
            CommonFn::requestAjax(true,'分享增加爪币成功',array(),301,$add_score);
        }else{
            CommonFn::requestAjax(false,'分享增加爪币失败');
        }
    }

    //用户申请认证接口
    public function actionApplyCertify(){
        $data = array();
        $data['content'] = '您好，目前握爪仅开放认证宠物医生、营养师、训犬师、美容师，认证需要您相关的资格证书或学校就读证书照片及您与证书合影的照片，直接在私信里发给爪爪就好了。';
        $data['from_user'] = Yii::app()->params['kefu_user'];
        $data['to_user'] = Yii::app()->request->getParam('user_id','');
        $date = date('Ymd');
        $Key = HelperKey::generateUserActionKey('applycertify',$date,$data['to_user']);
        $status = UserActionRedis::get($Key);
        if($status){
            CommonFn::requestAjax(false,'你今天已提交过认证申请,请不要重复申请');
        }else{
            UserActionRedis::set($Key,true);
        }
        $data['voice'] = json_decode(Yii::app()->request->getParam('voice'),true);
        $data['video'] = json_decode(Yii::app()->request->getParam('video'),true);
        $data['pics'] =  json_decode(Yii::app()->request->getParam('pics'),true);
        $z_message = new ZMessage();
        $result =  $z_message->addMessage($data);
        if($result['status']){
            CommonFn::requestAjax(true,'已提交认证申请');
        }else{
            CommonFn::requestAjax(false,'提交申请失败,请重试');
        }
    }

    //用户加与取消关注接口
    public function actionFollow(){
        $user_id = Yii::app()->getRequest()->getParam("user_id");
        $user = CommonFn::apigetObJ($user_id,"ZUser",CommonFn::getMessage('user','id_not_exist'),201);
        $f_id = Yii::app()->getRequest()->getParam("to_user_id");
        $f_id_list = json_decode(Yii::app()->getRequest()->getParam("to_user_list"),true);
        if(!$f_id_list && !CommonFn::isMongoId($f_id)){
            CommonFn::requestAjax(false,CommonFn::getMessage('message','params_illegal'));
        }
        $user_node = new UserNodeRecord($user->_id);
        //批量关注
        if(is_array($f_id_list) && !empty($f_id_list)){
            foreach ($f_id_list as $value) {
                $user_node->follow($value);
            }
            CommonFn::requestAjax(true,CommonFn::getMessage('message','operation_success'),array('op'=>'follow','follow_count'=>$user_node->follow_count(),'fans_count'=>$user_node->follower_count()));
        }
        if($user_node->is_following($f_id)){
            $user_node->unfollow($f_id);
            $op = 'unfollow';
            $message = '取消关注成功';
        }else{
            $user_node->follow($f_id);
            $message = '关注成功';
            $op = 'follow';
        }
        CommonFn::requestAjax(true,$message,array('op'=>$op,'follow_count'=>$user_node->follow_count(),'fans_count'=>$user_node->follower_count()));
    }

    //好友帖子列表
    public function actionFriendsTopicList(){
        $last_obj_id = Yii::app()->getRequest()->getParam("last_object_id",'');
        $user_id = Yii::app()->getRequest()->getParam("user_id");
        $user = CommonFn::apigetObJ($user_id,"ZUser",CommonFn::getMessage('user','id_not_exist'),201);
        if(CommonFn::isMongoId($last_obj_id)){
            $last_topic_obj = Topic::get(new MongoId($last_obj_id));
            if($last_topic_obj){
                $last_obj_time = $last_topic_obj->time;
            }
        }else{
            $last_obj_time = time();
        }
        if(!isset($last_obj_time)){
            CommonFn::requestAjax(false,CommonFn::getMessage('message','params_illegal'));
        }
        //设置小红点
        // $cache = new ARedisCache();
        // $cache->set('friend_topic_'.$user_id,0);
        $user_node = new UserNodeRecord($user_id);
        $follow_list = $user_node->following();
        $f_ids = array();
        foreach ($follow_list as $key => $value) {
            $f_ids[] = new MongoId($value);
        }
        $conditions = array(
            'user'=>array('in',$f_ids),
            'status'=>array('==',1),
            'time'=>array('<',$last_obj_time)
        );
        $order = array(
            '_id'=>'desc',
        );
        $model = new Topic();
        $pagedata = CommonFn::getPagedataById($model,20,$conditions,$order);
        $topics = $pagedata['res'];
        foreach ($topics as $key=>$value) {
            if($user){
                //判断用户是否收藏过该帖子
                $z_fav = new ZFav();
                $fav = $z_fav->getFavByFavObj($user_id,$value['id']);
                if(empty($fav)){
                    $value['is_faved'] = false;
                }else{
                    $value['is_faved'] = true;
                }

                //判断用户是否喜欢过该帖子
                $z_like = new ZLike();
                $like = $z_like->getLikeByLikeObj($user_id,$value['id']);
                if(empty($like)){
                    $value['is_liked'] = false;
                }else{
                    $value['is_liked'] = true;
                }
            }else{
                $value['is_faved'] = false;
                $value['is_liked'] = false;
            }
            $topics[$key] = $value;
        }
        $data['topic_list'] = $topics;
        CommonFn::requestAjax(true,'',$data,200,array('has_more' => $pagedata['has_more'],'page_size'=>$pagedata['page_size']));
    }

    //我的关注接口
    public function actionFollowList(){
        $user_id = Yii::app()->getRequest()->getParam("user_id");
        $to_user = Yii::app()->getRequest()->getParam("to_user_id");
        $page = Yii::app()->getRequest()->getParam("page");
        $page_size = Yii::app()->getRequest()->getParam("page_size",20);
        if($to_user){
            $uid = $to_user;
            $user_node = new UserNodeRecord($to_user);
            $current_user_node = new UserNodeRecord($user_id);
            $need_refresh = true;
        }else{
            $uid = $user_id;
            $user_node = new UserNodeRecord($user_id);
        }
        $follow_list = $user_node->following();
        $sum = count($follow_list);
        $follow_list = array_slice($follow_list,$page_size*($page-1),$page_size*$page);
        $user_model = new RUser();
        foreach ($follow_list as $key => $f_user) {
            $follow_list[$key] =  $user_model->parseRow(RUser::get(new MongoId($f_user)),array('id','user_name','sex','avatar','level','city_info','pets','certify_status','certify_info','can_access'));
            if(isset($need_refresh)){
                $follow_list[$key]['relation'] = $current_user_node->relation($f_user);
            }else{
                $follow_list[$key]['relation'] = $user_node->relation($f_user);
            }
        }
        CommonFn::requestAjax(true,CommonFn::getMessage('message','operation_success'),$follow_list,200,array('sum_count' => $sum ,'sum_page'=> ceil($sum/$page_size),'page_size'=>$page_size,'current_page'=>$page));
    }

    //粉丝列表
    public function actionFansList(){
        $user_id = Yii::app()->getRequest()->getParam("user_id");
        $to_user = Yii::app()->getRequest()->getParam("to_user_id");
        $page = Yii::app()->getRequest()->getParam("page");
        $page_size = Yii::app()->getRequest()->getParam("page_size",20);
        if($to_user){
            $uid = $to_user;
            $user_node = new UserNodeRecord($to_user);
            $current_user_node = new UserNodeRecord($user_id);
            $need_refresh = true;
        }else{
            $uid = $user_id;
            $user_node = new UserNodeRecord($user_id);
        }
        $followed_by = $user_node->followed_by();
        $sum = count($followed_by);
        $followed_by = array_slice($followed_by,$page_size*($page-1),$page_size*$page);
        $user_model = new RUser();
        foreach ($followed_by as $key => $f_user) {
            $followed_by[$key] =  $user_model->parseRow(RUser::get(new MongoId($f_user)),array('id','user_name','sex','avatar','level','city_info','pets','certify_status','certify_info','can_access'));
            if(isset($need_refresh)){
                $followed_by[$key]['relation'] = $current_user_node->relation($f_user);
            }else{
                $followed_by[$key]['relation'] = $user_node->relation($f_user);
            }
        }
        CommonFn::requestAjax(true,CommonFn::getMessage('message','operation_success'),$followed_by,200,array('sum_count' => $sum ,'sum_page'=> ceil($sum/$page_size),'page_size'=>$page_size,'current_page'=>$page));
    }

    //推荐关注用户
    public function actionRecommendUsers(){
        $user_id = Yii::app()->getRequest()->getParam("user_id");
        $city_info = Yii::app()->getRequest()->getParam("city_info");
        $city_info = json_decode($city_info,true);
        $user_obj = CommonFn::apigetObJ($user_id,"ZUser",CommonFn::getMessage('user','id_not_exist'),201);

        $user_node = new UserNodeRecord($user_obj->_id);
        $follow_list = $user_node->following();
        $follow_users = array();
        foreach ($follow_list as $key => $value) {
            $follow_users[] = new MongoId($value);
        }

        $follow_users[] = $user_obj->_id;
        $criteria = new EMongoCriteria;
        $criteria->certify_status('==',1);
        $criteria->_id('notin',$follow_users);
        $criteria->is_fake_user('!=',1);
        $criteria->sort('last_visit_time',EMongoCriteria::SORT_DESC);
        $criteria->limit(5);
        $cursor = RUser::model()->findAll($criteria);
        $rows = RUser::model()->parse($cursor,true,array('id','user_name','sex','avatar','level','city_info','certify_status','certify_info','can_access'));
        $certify_users = array();
        foreach ($rows as $value) {
            $value['recommend_reason'] = $value['certify_info'];
            $certify_users[] = $value;
        }

        $criteria = new EMongoCriteria;
        if(isset($city_info['province']) && $city_info['province']){
            $criteria->city_info->province('==',$city_info['province']);
        }else{
            $criteria->city_info->province('==','上海市');
        }
        $criteria->_id('notin',$follow_users);
        $criteria->is_fake_user('!=',1);
        $criteria->certify_status('!=',1);
        $criteria->sort('last_visit_time',EMongoCriteria::SORT_DESC);
        $criteria->limit(10);
        $cursor = RUser::model()->findAll($criteria);
        $rows = RUser::model()->parse($cursor,true,array('id','user_name','sex','avatar','level','city_info','certify_status','certify_info','can_access'));
        $local_user = array();
        foreach ($rows as $value) {
            $value['recommend_reason'] = '同城用户';
            $local_user[] = $value;
        }

        $criteria = new EMongoCriteria;
        if(isset($city_info['province']) && $city_info['province']){
            $criteria->city_info->province('!=',$city_info['province']);
        }else{
            $criteria->city_info->province('!=','上海市');
        }
        $criteria->_id('notin',$follow_users);
        $criteria->is_fake_user('!=',1);
        $criteria->certify_status('!=',1);
        $criteria->sort('posts_count',EMongoCriteria::SORT_DESC);
        $criteria->sort('last_visit_time',EMongoCriteria::SORT_DESC);
        $criteria->limit(5);
        $cursor = RUser::model()->findAll($criteria);
        $rows = RUser::model()->parse($cursor,true,array('id','user_name','sex','avatar','level','city_info','certify_status','certify_info','can_access'));
        $hot_users = array();
        foreach ($rows as $value) {
            $value['recommend_reason'] = '活跃用户';
            $hot_users[] = $value;
        }

        $result = array_merge($certify_users,$local_user,$hot_users);
        shuffle($result);
        foreach ($result as $key => $user) {
            $result[$key]['relation'] = $user_node->relation($user['id']);
        }
        CommonFn::requestAjax(true,CommonFn::getMessage('message','operation_success'),array('recommend_list'=>$result));
    }

    //用户登出接口
    public function actionLogout(){
        $user_id = Yii::app()->getRequest()->getParam("user_id");
        $xinge_token = Yii::app()->getRequest()->getParam("xinge_token");
        $app_client_id = Yii::app()->getRequest()->getParam("app_client_id");
        require_once(APP_PATH."/protected/vendors/tencent/XingeApp.php");
        if($app_client_id == '2'){
            $xinge_config = Yii::app()->params['xingeConfig']['android'];
            $push = new XingeApp($xinge_config['accessId'],$xinge_config['secretKey']);
            $ret = $push->DeleteTokenOfAccount($user_id,$xinge_token);
            CommonFn::requestAjax(true,'注销成功');
        }elseif($app_client_id == '1'){
            $xinge_ios_config = Yii::app()->params['xingeConfig']['ios'];
            $push = new  XingeApp($xinge_ios_config['accessId'],$xinge_ios_config['secretKey']);
            $ret = $push->DeleteTokenOfAccount($user_id,$xinge_token);
            CommonFn::requestAjax(true,'注销成功');
        }else{
            CommonFn::requestAjax(false,'操作失败');
        }


    }


}