<?php

class push_model extends model{
   
    /**
     * @desc    发送推送消息
     * @param   string $type 类型 
    			1，jobNewResume			职位收到新投递/快速简历投递
    			2，rewardNewresume		赏金职位收到新投递
    			3，partNewResume			兼职收到新投递
    			4, invite 				个人收到企业邀请面试
    			5，chat					聊天
    			6，jobState				职位审核
    			7，partState			          兼职审核
			
     * @param array $data 自定义数组
                1,fuid                  发送推送用户uid
                2,puser                 接受用户，可以是数组，但必须带有uid
                3,tid                   相关操作表id，
                                        (1)职位收到新投递：             userid_job  表id
                                        (2)赏金职位收到新投递：    company_job_rewardlist  表id
                                        (3)兼职收到新申请 ：           part_apply   表id
                                        (4)个人被邀请面试：              userid_msg 表id
                                        (5)聊天 :              chat_log  表id
                                        (6)职位审核 :           company_job 表id
                                        (6)兼职审核 :           partjob 表id
     */
    
    /**
     * @desc 目前有推送的地方：
        app：
            1，企业职位收到新简历投递；
            2，赏金职位收到新申请
            3，企业职位收到 快速投递简历 申请
            4，企业兼职收到新申请
            5，个人被邀请面试
        wxapp：
            1，企业职位收到 快速投递简历 申请
            2，企业兼职收到新申请
        pc：
            1，企业职位收到新简历投递；
            2，个人被邀请面试
            3，企业职位收到 快速投递简历 申请
            4，赏金职位收到新申请
            5，企业兼职收到新申请
            6，后台审核职位
            7，后台审核兼职
        wap：
            1，企业职位收到新简历投递；
            2，赏金职位收到新申请
            3，个人被邀请面试
            4，企业兼职收到新申请
            5，企业职位收到 快速投递简历 申请

            聊天 chat model

    */
    private function pushing(){
        
        $push  =  null;
        
        include(DATA_PATH.'api/wxapp/app.config.php');
        
        if($this->config['sy_push_open']==1 && $appconfig['sy_push_appid'] && $appconfig['sy_push_appkey'] && $appconfig['sy_push_masterSecret']){
            
            $getui	=	array(
                'appid'			=>	$appconfig['sy_push_appid'],
                'appkey'		=>	$appconfig['sy_push_appkey'],
                'masterSecret'	=>	$appconfig['sy_push_masterSecret'],
                'ssl'           =>  strpos($this->config['sy_weburl'], 'https://') !== false ? true : false
            );
            if (file_exists(APP_PATH.'api/wxapp/getui-v2/PhpyunPush.php')){
                
                include_once APP_PATH.'api/wxapp/getui-v2/PhpyunPush.php';
                
                $push  =   new PhpyunPush($getui);
            }
        }
        
        return $push;
    }
    
    public function pushMsg($type='',$data=array(), $push = null){

        if($this->config['sy_push_open']==1){//查看后台是否开启推送
            
            //收到推送的uid
            if(is_array($data['puser'])){
            
                $data['suid']   =   $data['puser']['uid'];
            }else{
                
                $data['suid']   =   $data['puser'];
            }
            
            //推送记录数据
            $pushData           =   array();
            $pushData['fuid']   =   $data['fuid'];
            $pushData['suid']   =   $data['suid'];
            $pushData['ctime']  =   time();
            $pushData['tid']    =   $data['tid'];
            $pushData['type']   =   $this -> gettype($type, 'funtonum');
            
            //获取所需信息
            if(method_exists($this, $type)){
                
                $res  =  $this->$type($data);
                
                if (!empty($res)){
                    $puser  =  $res['puser'];
                    if (!is_array($puser)){
                        
                        $puser  =  $this->select_once('member',array('uid' => $puser),'`clientid`,`deviceToken`,`app_push`');
                    }
                    if(!empty($puser['clientid']) && $puser['app_push'] == 1){
                        
                        if (!isset($push)){
                            $push  =  $this->pushing();
                        }
                        if($push){
                            $return  =  $this->makePush($res['title'], $res['content'], $puser, $res['payload'], $push);
                            
                            if(!empty($return) && is_array($return)){
                                
                                if ($return['code'] == 0){
                                    $pushData['result']  =   'ok';
                                    $pushData['taskId']  =   key($return['data']);
                                    $pushData['status']  =   current($return['data'][$pushData['taskId']]);
                                }else{
                                    $pushData['result']  =   $return['code'].'，'.$return['msg'];
                                }
                                
                                $this -> addAppPush($pushData);
                            }
                        }
                    }
                }
            }
    	}
    	return $push;
    }
    
    /**
     * @desc  推送类型转换
     * @param string $type： 传参
     * @param string $totype： 想要的类型，比如'funtonum' function类型对应数字,'numtostr'数字对应文字描述
     */
    private function gettype($type,$totype){
        if($type){
            
            if($totype=='funtonum'){
            
                $typearr    =   array(
                    'jobNewResume'      =>  '1',
                    'rewardNewresume'   =>  '2',
                    'partNewResume'     =>  '3',
                    'invite'            =>  '4',
                    'chat'              =>  '5',
                    'jobState'          =>  '6',
                    'partState'         =>  '7'
                );
            }else if($totype=='numtostr'){
                
                $typearr    =   array(
                    '1'     =>  '普通职位收到新投递',
                    '2'     =>  '赏金职位收到新投递',
                    '3'     =>  '兼职收到新投递',
                    '4'     =>  '个人收到邀请面试',
                    '5'     =>  '聊天',
                    '6'     =>  '审核职位',
                    '7'     =>  '审核兼职'
                );
            }
            
            if(is_array($typearr)){
            
                return $typearr[$type];
            }
        }
    } 
    
    //聊天推送，$data数组
    private function chat($data = array())
    {
        $return             =   array();
        
        $content  =  mb_substr($data['content'], 0,24,'utf-8');
        
        if($data['puser']){
            
            $data['title']  =   $data['title']  ?   $data['title']  :   '通知';
            
            $return         =   array(
                'title'     =>  $data['title'],
                'content'   =>  $content,
                'puser'     =>  $data['puser'],
                'payload'   =>  array('path'=>'/pson/pages/chat/chat')
            );
        }
        
        return $return;
    }
    
    //个人收到邀请面试，$data数组  comname-企业名称
    private function invite($data = array()){
        
        $return             =   array();

        if($data['comname']){

            $content        =   mb_substr($data['comname'].'邀请您参加面试', 0, 24, 'UTF-8');

            if($data['puser']){
                
                $data['title']  =   $data['title']  ?   $data['title']  :   '通知';
                
                $return         =   array(
                
                    'title'     =>  $data['title'],
                    'content'   =>  $content,
                    'puser'     =>  $data['puser'],
                    'payload'   =>  array('path'=>'/pson/pages/usermember/invite/index')
                );
            }
        }
        return $return;
    }
    
    //兼职职位收到新投递，$data数组   jobid-职位id  jobname-兼职名称
    private function partNewResume($data = array()){
        
        $return                 =   array();

        if($data['jobid'] || $data['jobname']){

            if($data['jobname']){

                $jobname        =   $data['jobname'];
                
            }else{

                $job            =   $this -> select_once('partjob', array('id'=>$data['jobid']),'name,uid');

                $jobname        =   $job['name'];

                $data['puser']  =   $data['puser']  ?   $data['puser']  :   $job['uid'];
            }

            $content            =   mb_substr('兼职('.preg_replace('# #','',$jobname).')有新的申请', 0, 24, 'UTF-8');

            if($data['puser']){
                
                $data['title']  =   $data['title']  ?   $data['title']  :   '通知';
                
                $return         =   array(
                    
                    'title'     =>  $data['title'],
                    'content'   =>  $content,
                    'puser'     =>  $data['puser'],
                    'payload'   =>  array('path'=>'/pson/pages/commember/partapply/index', 'params'=>array('partid'=>$data['jobid']))
                );
            }
        }
        return $return;
    }
    
    //赏金职位收到新投递，$data数组   jobid-职位id 
    private function rewardNewresume($data = array()){
        
        $return             =   array();

        if($data['jobid']){

            $job            =   $this -> select_once('company_job', array('id'=>$data['jobid']),'`name`,`uid`');

            $data['puser']  =   $data['puser']  ?   $data['puser']  :   $job['uid'];

            $content        =   mb_substr('赏金职位('.preg_replace('# #','',$job['name']).')有新的申请', 0, 24, 'UTF-8');

            if($data['puser']){
                
                $data['title']  =   $data['title']  ?   $data['title']  :   '通知';
                
                $return         =   array(
                
                    'title'     =>  $data['title'],
                    'content'   =>  $content,
                    'puser'     =>  $data['puser'],
                    'payload'   =>  array('path'=>'/pson/pages/commember/jobpack/rewardlog','params'=>array('jobid'=>$data['jobid']))
                );
            }
        }
        return $return;
    }
    
    //职位收到新投递，$data数组   jobid-职位id  jobname-职位名称
    private function jobNewResume($data = array()){

    	$return			        =	array();

    	if(isset($data['jobid']) || isset($data['jobname'])){
    		
    	    if(isset($data['jobname'])){

    			$jobname	    =	$data['jobname'];
    			
    		}else{

    			$job		    =   $this -> select_once('company_job', array('id'=>$data['jobid']),'name,uid');

    			$jobname	    =	$job['name'];

                $data['puser']  =   $data['puser']  ?   $data['puser']  :   $job['uid'];
    		}
    		// 去除所有空格
    		$content	        =	mb_substr('职位('.preg_replace('# #','',$jobname).')有新简历投递', 0, 24, 'UTF-8');

    		if($data['puser']){
    		    
    		    $data['title']  =   isset($data['title'])  ?   $data['title']  :   '通知';
                
                $return         =   array(
                
                    'title'     =>  $data['title'],
                    'content'   =>  $content,
                    'puser'     =>  $data['puser'],
                    'payload'   =>  array('path'=>'/pson/pages/commember/hr/index')
                );
            }
    	}
    	return $return;
    }
    
    //职位审核通知，$data数组 id-职位id jobname-职位名称
    private function jobState($data = array()){
        
        $return			        =	array();
        
        if($data['tid'] || $data['jobname']){
            
            if($data['jobname']){
                
                $jobname	    =	$data['jobname'];
                
            }else{
                
                $jobs		    =   $this -> select_once('company_job', array('id' => $data['tid']),'name,uid');
                
                $jobname	    =	$jobs['name'];
                
                $data['puser']  =   isset($data['puser'])  ?   $data['puser']  :   $jobs['uid'];
            }
            $msg  =  '职位('.preg_replace('# #','',$jobname).')审核';
            $msg .=  $data['state'] == 3 ? '未通过' : '通过';
            
            $content	        =	mb_substr($msg, 0, 24, 'UTF-8');
            
            if($data['puser']){
                
                $data['title']  =   isset($data['title'])  ?   $data['title']  :   '通知';
                
                $return         =   array(
                
                    'title'     =>  $data['title'],
                    'content'   =>  $content,
                    'puser'     =>  $data['puser'],
                    'payload'   =>  array('path'=>'/pson/pages/commember/job/index')
                );
            }
        }
        return $return;
    }
    
    //兼职审核通知，$data数组 id-职位id jobname-职位名称
    private function partState($data = array()){
        
        $return			        =	array();
        
        if($data['tid'] || $data['jobname']){
            
            if($data['jobname']){
                
                $jobname	    =	$data['jobname'];
                
            }else{
                
                $part		    =   $this -> select_once('partjob', array('id'=>$data['tid']),'name,uid');
                
                $jobname	    =	$part['name'];
                
                $data['puser']  =   $data['puser']  ?   $data['puser']  :   $part['uid'];
            }
            $msg  =  '兼职('.preg_replace('# #','',$jobname).')审核';
            $msg .=  $data['state'] == 3 ? '未通过' : '通过';
            
            $content	        =	mb_substr($msg, 0, 24, 'UTF-8');
            
            if($data['puser']){
                
                $data['title']  =   $data['title']  ?   $data['title']  :   '通知';
                
                $return         =   array(
                    
                    'title'     =>  $data['title'],
                    'content'   =>  $content,
                    'puser'     =>  $data['puser'],
                    'payload'   =>  array('path'=>'/pson/pages/commember/part/index')
                );
            }
        }
        return $return;
    }
    
    /**
     * @desc    发送推送消息
     * @param   string $title 标题
     * @param   string $content 内容
     * @param   array $puser 接受方信息
     */
    private function makePush($title, $content, $puser, $payload = array(), $push = false){
        
        $content	=	str_replace("/", '', $content);

        $phonetype	=  !empty($puser['deviceToken']) ? 1 : 2;
        
        $msg		=	array(
            'title'		=>	$title,
            'content'	=>	$content,
            'payload'	=>	json_encode($payload)
        );
        
        $to			=	array(
            'cid'			=>	$puser['clientid'],
            'device_token'	=>	$puser['deviceToken'],
            'system'		=>	$phonetype
        );
        
        if($push){
            
            $return =   $push->pushIGtMsg($msg, $to);
            
            return  $return;
        }
    }
    
    //插入app推送记录
    private function addAppPush($addData=array()){
        $result = 0;
        if(!empty($addData)){
            
            $result  = $this->insert_into('app_push',$addData);
            
        }
        return  $result;
    }
    
    //获取推送记录列表
    public function getAppPushList($where=array(),$data=array()){
        
        if(!empty($where)){

            $data['field']  =   $data['field']  ?   $data['field']  :   '*';

            $list           =   $this   ->  select_all('app_push',$where,$data['field']);

            if(!empty($list)){

                foreach($list as $uk=>$uv){
                    //将发送人和接收人uid集合
                    $alluids[]                    =   $uv['fuid'];
                    $alluids[]                    =   $uv['suid'];
                }
                $alluids    =   array_unique($alluids);

                require_once ('userinfo.model.php');
                $userinfoM  =   new userinfo_model($this->db, $this->def);
                $namelist   =   $userinfoM  ->  getUserList(array('uid'=>array('in',pylode(',',$alluids))));
                foreach($namelist as $nk=>$nv){
                    $names[$nv['uid']]       =   $nv['name'];
                }

                foreach($list as $k=>$v){
                    //发送人名称
                    $list[$k]['fname']          =   $names[$v['fuid']]   ?   $names[$v['fuid']]   :   '用户不存在';
                    //接收人名称
                    $list[$k]['sname']          =   $names[$v['suid']]   ?   $names[$v['suid']]   :   '用户不存在';
                    //推送类型
                    $list[$k]['type_n']         =   $this->gettype($v['type'],'numtostr');
                    //推送时间
                    $list[$k]['ctime']          =   date('Y-m-d H:i:s',$v['ctime']);

                    //推送结果
                    if($v['result']){

                        $list[$k]['result_n']   =   $v['result']=='ok'  ?   '推送成功'  :   '推送失败('.$v['result'].')';

                    }
                    //在线状态
                    if($v['status']=='successed_offline'){

                        $list[$k]['status_n']   =   'app离线';

                    }elseif($v['status']=='successed_online'){

                        $list[$k]['status_n']   =   'app在线';

                    }

                }
            }

            $List['list']   =   $list;
        }
        return  $List;
    }
    
    public function delAppPush($id,$data=array()){
        
        if($id){
            if(is_array($id)){
                $id         =   pylode(',',$id);
                $limit      =   '';
                $layer_type =   '1';
            }else{
                $limit      =   'limit 1';
                $layer_type =   '0';
            }
            $where['id']    =   array('in',$id);
			
            $this           ->  delete_all("app_push",$where,$limit,'');

            $return         =   array(
                'msg'		=>  '推送消息(ID:'.$id.')删除成功！',
                'errcode'   =>  '9',
                'laytype'	=>  $layer_type,
                'url'		=>  $_SERVER['HTTP_REFERER']
            );

        }else{
            $return     =   array(
                'msg'		=>  '请选择您要删除的信息！',
                'errcode'   =>  '8',
                'laytype'	=>  '1',
                'url'		=>  $_SERVER['HTTP_REFERER']
            );
        }
        return $return;
    }
}
?>