<?php

class admin_sync_controller extends adminCommon{
	function index_action(){
	    //查询可同步有效用户数据
	    $resumeM		=	$this -> MODEL('resume');
	    $resumeCount	=	$resumeM -> getExpectNum(array('defaults'=>1,'status'=>1,'r_status'=>1));
	    $jobM			=	$this -> MODEL('job');
	    $jobCount		=	$jobM -> getJobNum(array('state'=>1,'r_status'=>1,'status'=>0));
	    $this->yunset("resCount",$resumeCount);
	    $this->yunset("jobCount",$jobCount);
	    $this->yunset('syncsign',time().rand(1000,9999));
		$this->yuntpl(array('admin/admin_sync'));
	}
	function save_action(){
 		if($_POST['config']){
		    unset($_POST['config']);
			
		    $this -> MODEL('config') -> setConfig($_POST);
			
			$this->web_config();
			
			$this->ACT_layer_msg("数据同步设置修改成功！",9,1,2,1);
		}
	}
	
	//用户同步传输
	function resume_action(){
	    if (!$this->config['yptuser'] && !$this->config['yptkey']){
	        $this->layer_msg('请先设置云平台同步账号信息',8);
	    }
	    if($_POST['count'] && $_POST['limit']){
	        $page = ceil($_POST['count']/$_POST['limit']);
	        if(!$_POST['page']){
	            $_POST['page'] = 0;
	        }
	        //$_POST['limit'] = 1;
	        $pageSize	=	intval($_POST['page'])*intval($_POST['limit']);
	        //查询符合条件的数据
	        $resumeM	=	$this -> MODEL('resume');
	        $expectAll	=	$resumeM -> getSimpleList(array('defaults'=>1,'status'=>1,'r_status'=>1,'limit'=>array($pageSize,$_POST['limit']),'orderby'=>'id,desc'));
	        //清除用户UID
	        if(is_array($expectAll)){
	            foreach($expectAll as $key=>$value){
	                $uid[]	= $value['uid'];
	                $exceptList[$value['uid']] = $value;
	                $expectid[] = $value['id'];
	                
	            }
	            $uids = array_unique($uid);
	            //查询关联企业信息
				$rwhere['uid']	=	array('in',pylode(',',$uids));
				
	            $resumeList		=	$resumeM->getResumeList($rwhere);
				
	            $where['eid']	=	array('in',pylode(',',$expectid));
				
	            //查询关联工作经历
	            $workList		=	$resumeM -> getResumeWorks($where);
	            //教育经历
	            $eduList		=	$resumeM -> getResumeEdus($where);
	            //培训经历
	            $trainList		=	$resumeM -> getResumeTrains($where);
	            //职业技能
	            $skillList		=	$resumeM -> getResumeSkills($where);
	            //项目经历
	            $projectList	=	$resumeM -> getResumeProjects($where);
	            //其他
	            $otherList		=	$resumeM -> getResumeOthers($where);
	        }
	        
	        if(is_array($resumeList)){
	            include PLUS_PATH."/job.cache.php";
	            include PLUS_PATH."/user.cache.php";
	            include PLUS_PATH."/city.cache.php";
	            
	            $cacheM=$this->MODEL('cache');
	            $cacheList=$cacheM->GetCache('user');

	            foreach($resumeList as $key=>$value){
	                $jsonvalue = array();
	                $jsonvalue['uid'] 			=	$value['uid'];//原始UID
	                $jsonvalue['uname']			=	$value['name'];//用户姓名
	                $jsonvalue['address']		=	$value['address'];//现居住地址
	                $jsonvalue['birthday']		=	$value['birthday'];//生日
	                $jsonvalue['height']		=	$value['height'];//身高
	                $jsonvalue['weight']		=	$value['weight'];//体重
	                $jsonvalue['idcard']		=	$value['idcard'];//身份证
	                $jsonvalue['nationality']	=	$value['nationality'];//民族
	                $jsonvalue['description']	=	$value['description'];//个人简介
	                $jsonvalue['living']		=	$value['living'];//现居住地
	                $jsonvalue['domicile']		=	$value['domicile'];//户籍地址
	                $jsonvalue['telphone']		=	$value['telphone'];//联系电话
	                $jsonvalue['telhome']		=	$value['telhome'];//家庭电话
	                $jsonvalue['email']			=	$value['email'];//联系邮件
	                $jsonvalue['homepage']		=	$value['homepage'];//个人主页
	                $jsonvalue['sex']			=	$cacheList['user_sex'][$value['sex']];//性别
	                $jsonvalue['marriage']		=	$userclass_name[$value['marriage']];//婚姻
	                $jsonvalue['edu']			=	$userclass_name[$value['edu']];//学历
	                $jsonvalue['exp']			=	$userclass_name[$value['exp']];//工作经验
	                
	                /****************************求职意向*******************************/
	                $exceptValue				=	$exceptList[$value['uid']];
	                $resumevalue				=	array();
	                $resumevalue['id']			=	$exceptValue['id'];
	                $resumevalue['name']		=	$exceptValue['name'];//简历名称
	                if($exceptValue['job_classid']){
	                    $jobclassid_name=array();
	                    foreach(@explode(',',$exceptValue['job_classid']) as $k=>$v){
	                        $jobclassid_name[]	=	$job_name[$v];
	                    }
	                    $resumevalue['job_classid'] = @implode(',',$classid_name);
	                }
	                if($exceptValue['city_classid']){
	                    $cityclassid_name=array();
	                    foreach(@explode(',',$exceptValue['city_classid']) as $k=>$v){
	                        $cityclassid_name[]	=	$city_name[$v];
	                    }
	                    $resumevalue['city_classid'] = @implode(',',$cityclassid_name);
	                }
	                if ($exceptValue['minsalary']>0 || $exceptValue['maxsalary']>0){
	                    $resumevalue['salary']	=	$exceptValue['minsalary'].'-'.$exceptValue['maxsalary'];//薪资待遇
	                }
	                $resumevalue['jobstatus']	=	$userclass_name[$exceptValue['jobstatus']];//求职状态
	                $resumevalue['type']		=	$userclass_name[$exceptValue['type']];//工作性质
	                $resumevalue['exp']			=	$userclass_name[$exceptValue['exp']];//工作经验
	                $resumevalue['edu']			=	$userclass_name[$exceptValue['edu']];//最高学历
	                $resumevalue['report']		=	$userclass_name[$exceptValue['report']];//到岗时间
	                $resumevalue['lastupdate']	=	$exceptValue['lastupdate'];//更新日期
	                $jsonvalue['expect']		=	$resumevalue;
	                
	                
	                /*************************************工作经历**************************************/
	                $jsonvalue['worklist']		=	$workList[$exceptValue['id']];
	                $jsonvalue['edulist']		=	$eduList[$exceptValue['id']];
	                $jsonvalue['projectlist']	=	$projectList[$exceptValue['id']];
	                $jsonvalue['otherlist']		=	$otherList[$exceptValue['id']];
	                $jsonvalue['trainlist']		=	$trainList[$exceptValue['id']];
	                
	                $Arr[] = $jsonvalue;
	            }
	            //转化JSON
	            $Crmjson['syncjson']	=	$Arr;
	            $Crmjson['yptuser']		=	$this->config['yptuser'];
	            $Crmjson['yptkey']		=	$this->config['yptkey'];
	            $Crmjson['syncsign']	=	$_POST['syncsign'];
	            //CURL POST 数据
	            $url 		=	'http://api.ypt.com/sync/?c=resume';//接收地址
	            
	            $return		=	CurlPost($url,json_encode($Crmjson));
	            
	            $response	=	json_decode($return);
	            
	            if($response->state == '1'){
	                if($response->uids){
						$ewhere['id']	=	array('in',$response->uids);
	                    $resumeM -> upInfo($ewhere,array('eData'=>array('sync'=>'1')));
	                    $nowcount 		=	count(explode(',',$response->uids));
	                }
	                
	                if(($_POST['page']+1)>=$page){//转换结束
	                    echo json_encode(array('error'=>'2'));
	                }else{
	                    //当前批次结束 继续下一批次转换
	                    echo json_encode(array('error'=>'1','readynum'=>$response->readynum,'page'=>($_POST['page']+1),'count'=>($_POST['page']+1)*$_POST['limit']));
	                }
	                die;
	            }else{
	                echo json_encode(array('error'=>'0','msg'=>$response->errmsg));
	            }
	        }
	    }else{
	        echo json_encode(array('error'=>'0'));
	    }
	}
	function job_action(){
	    set_time_limit(0);
	    if($_POST['count'] && $_POST['limit']){
	        $page = ceil($_POST['count']/$_POST['limit']);
	        if(!$_POST['page']){
	            
	            $_POST['page'] = 0;
	        }
	        //$_POST['limit'] = 10;
	        $pageSize	=	intval($_POST['page'])*intval($_POST['limit']);
	        //查询符合条件的数据
	        $jobM		=	$this -> MODEL('job');
	        $joblist	=	$jobM -> getList(array('state'=>1,'r_status'=>1,'status'=>0,'limit'=>array($pageSize,$_POST['limit']),'orderby'=>'id,desc'));
			$jobAll=$joblist['list'];
	        //清除企业UID
	        if(is_array($jobAll)){
	            foreach($jobAll as $key=>$value){
	                $uid[] = $value['uid'];
	                $jobList[$value['uid']][] = $value;
	            }
	            $uids = array_unique($uid);
	            //查询关联企业信息
	            $comM			=	$this -> MODEL('company');
				$comwhere['uid']=	array('IN',pylode(',',$uids));
	            $comList		=	$comM -> getList($comwhere);
	            
	        }
	        if(is_array($comList)){
	            include PLUS_PATH."/job.cache.php";
	            include PLUS_PATH."/com.cache.php";
	            include PLUS_PATH."/city.cache.php";
	            include PLUS_PATH."/industry.cache.php";
	            $cacheM=$this->MODEL('cache');
	            $cacheList=$cacheM->GetCache('user');
	            foreach($comList as $key=>$value){
	                $jsonvalue = array();
	                $jsonvalue['uid']			=	$value['uid'];//原始UID
	                $jsonvalue['name']			=	$value['name'];//企业名称
	                $jsonvalue['hy']			=	$industry_name[$value['hy']];//企业行业
	                $jsonvalue['comnum']		=	$comclass_name[$value['mun']];//企业规模
	                $jsonvalue['province']		=	$city_name[$value['provinceid']];//所在地区
	                $jsonvalue['city']			=	$city_name[$value['cityid']];//所在地区
	                $jsonvalue['three_city']	=	$city_name[$value['three_cityid']];//所在地区
	                $jsonvalue['address']		=	$value['address'];
	                $jsonvalue['website']		=	$value['website'];//企业网址
	                $jsonvalue['sdate']			=	$value['sdate'];//企业注册日期
	                $jsonvalue['linkman']		=	$value['linkman'];//联系人
	                $jsonvalue['content']		=	$value['content'];//联系人
	                $jsonvalue['x']				=	$value['x'];//企业地图标注
	                $jsonvalue['y']				=	$value['y'];//企业地图标注
	                $jsonvalue['bustops']		=	$value['bustops'];//公交路线
	                $jsonvalue['linktel']		=	$value['linktel'];//联系电话
	                $jsonvalue['linkphone']		=	$value['linkphone'];//固定电话
	                $jsonvalue['linkmail']		=	$value['linkmail'];//联系邮件
	                $jsonvalue['welfare']		=	$value['welfare'];//福利待遇
	                //企业职位
	                if(is_array($jobList[$value['uid']])){
	                    foreach($jobList[$value['uid']] as $k=>$v){
	                        $jobvalue					=	array();
	                        $jobvalue['id']				=	$v['id'];
	                        $jobvalue['name']			=	$v['name'];//职位名称
	                        
	                        $jobvalue['job1']			=	$job_name[$v['job1']];
	                        $jobvalue['job1_son']		=	$job_name[$v['job1_son']];
	                        $jobvalue['job_post']		=	$job_name[$v['job_post']];
	                        $jobvalue['province']		=	$city_name[$v['provinceid']];//所在地区
	                        $jobvalue['cityid']			=	$city_name[$v['cityid']];//所在地区
	                        $jobvalue['three_cityid']	=	$city_name[$v['three_cityid']];//所在地区
	                        
	                        $jobvalue['salary']			=	$v['minsalary'].'-'.$v['maxsalary'];//薪资待遇
	                        $jobvalue['number']			=	$comclass_name[$v['number']];//类型
	                        $jobvalue['exp']			=	$comclass_name[$v['exp']];//工作经验
	                        $jobvalue['report']			=	$comclass_name[$v['report']];//到岗时间
	                        $jobvalue['sex']			=	$cacheList['user_sex'][$v['sex']];//性别
	                        $jobvalue['edu']			=	$comclass_name[$v['edu']];//学历
	                        $jobvalue['marriage']		=	$comclass_name[$v['marriage']];//婚姻
	                        $jobvalue['description']	=	$v['description'];//岗位要求
	                        $jobvalue['sdate']			=	$v['sdate'];//发布日期
	                        $jobvalue['lastupdate']		=	$v['lastupdate'];//发布日期
	                        if($v['lang']){
	                            $langList				=	array();
	                            $lang					=	@explode(',',$v['lang']);
	                            foreach($lang as $lv){
	                                $langList[]			=	$comclass_name[$lv];
	                            }
	                            $jobvalue['lang']		=	@implode(',',$langList);//语言要求
	                        }
	                        $jsonvalue['joblist'][]		=	$jobvalue;
	                    }
	                }
	                $Arr[] = $jsonvalue;
	            }
	            //转化JSON
	            $Crmjson['syncjson']	=	$Arr;
	            $Crmjson['yptuser']		=	$this->config['yptuser'];
	            $Crmjson['yptkey']		=	$this->config['yptkey'];
	            $Crmjson['syncsign']	=	$_POST['syncsign'];
	            //CURL POST 数据
	            $url		=	'http://api.ypt.com/sync/?c=job';//接收地址
	            
	            $return		=	CurlPost($url,json_encode($Crmjson));
	            
	            $response	=	json_decode($return);
	            
	            if($response->state == '1'){
	                if($response->uids){
	                    $jobM -> upInfo(array('sync'=>'1'), array('uid' => array('in', $response->uids)));
	                    $nowcount = count(explode(',',$response->uids));
	                }
	                
	                if(($_POST['page']+1)>=$page){//转换结束
	                    echo json_encode(array('error'=>'2'));
	                }else{
	                    //当前批次结束 继续下一批次转换
	                    echo json_encode(array('error'=>'1','readynum'=>$response->readynum,'page'=>($_POST['page']+1),'count'=>($_POST['page']+1)*$_POST['limit']));
	                }
	                die;
	            }else{
	                echo json_encode(array('error'=>'0','msg'=>$response->errmsg));
	            }
	        }
	    }else{
	        echo json_encode(array('error'=>'0'));
	    }
	}
	function getList($table,$expectid){
	    $List = $this->MODEL('resume')->getFbList($table,array('eid'=>array('in',pylode(',',$expectid))));
	    if(is_array($List)){
	        foreach($List as $key=>$value){
	            if(is_array($value)){
	                foreach($value as $k=>$v){
	                    $value[$k] = $v;
	                }
	            }
	            $newkList[$value['eid']][] = $value;
	        }
	    }
	    return $newkList;
	}
}

?>