select_once('chat_member', $whereData, $field);
if (!empty($member['avatar'])){
$member['avatar'] = checkpic($member['avatar'] , $this->config['sy_chat_logo']);
}
return $member;
}
/**
* 查询多个直聊用户
* $whereData 查询条件
* $data 自定义处理数组
*/
public function getMemberList($whereData, $data = array()) {
$field = empty($data['field']) ? '*' : $data['field'];
$List = $this -> select_all('chat_member', $whereData, $field);
return $List;
}
/**
* 添加直聊用户
* $upData 要修改的数据
* $whereData 查询条件
*/
public function addMember($data)
{
if (!empty($data)){
$nid = $this -> insert_into('chat_member',$data);
}
return $nid;
}
/**
* 修改直聊用户
* $upData 要修改的数据
* $whereData 查询条件
*/
public function upMember($upData,$whereData) {
if (!empty($whereData)){
$nid = $this -> update_once('chat_member',$upData,$whereData);
}
return $nid;
}
/**
* 删除直聊用户
*/
public function delMember($whereData)
{
if (!empty($whereData)){
$this -> delete_all('chat_member', $whereData, '');
}
}
/**
* 保存消息
* @param 引用字段：$data:字段
*/
public function addChatLog($data=array()){
$nid = $this -> insert_into('chat_log', $data);
return $nid;
}
/**
* 查询聊天记录
* $whereData 查询条件
* $data 自定义处理数组
*/
public function getChatLog($whereData, $data = array('utype'=>null)) {
$field = empty($data['field']) ? '*' : $data['field'];
$List = $this -> select_once('chat_log', $whereData, $field);
if ($data['utype']){
$List['sendTime'] = ceil($List['sendTime']/1000);
$List['sendTime_n']= date('Y-m-d H:i',$List['sendTime']);
}
return $List;
}
/**
* 查询聊天记录
* $whereData 查询条件
* $data 自定义处理数组
*/
public function getChatLogList($whereData, $data = array()) {
$field = empty($data['field']) ? '*' : $data['field'];
$List = $this -> select_all('chat_log', $whereData, $field);
if(!empty($List)){
if(isset($data['admin'])){
$eids = $jobids = $rname = $jname = $ru = $cu = $lu = array();
foreach($List as $key=>$val){
if($val['msgtype']=='resume'){
if (strpos($val['content'],'eid=')!==false){
$eid = str_replace('eid=', '', $val['content']);
if(!in_array($eid,$eids)){
$eids[]=$eid;
}
}
}
if($val['msgtype']=='job' || $val['msgtype'] == 'adminjob'){
if (strpos($val['content'],'jobid=')!==false){
$jobid = str_replace('jobid=', '', $val['content']);
if(!in_array($jobid,$jobids)){
$jobids[]=$jobid;
}
}
}
if ($val['fusertype'] == 1){
$ru[] = $val['from'];
}
if ($val['tusertype'] == 1){
$ru[] = $val['to'];
}
if ($val['fusertype'] == 2){
$cu[] = $val['from'];
}
if ($val['tusertype'] == 2){
$cu[] = $val['to'];
}
if ($val['fusertype'] == 3){
$lu[] = $val['from'];
}
if ($val['tusertype'] == 3){
$lu[] = $val['to'];
}
}
$alluid = array_merge($ru, $cu, $lu);
$member = $this->select_all('member', array('uid'=>array('in',pylode(',', array_unique($alluid)))),'`uid`,`username`');
$resume = $this->select_all('resume', array('uid'=>array('in',pylode(',', array_unique($ru)))),'`uid`,`name`');
$company = $this->select_all('company', array('uid'=>array('in',pylode(',', array_unique($cu)))),'`uid`,`name`');
if (!empty($lu)){
$ltinfo = $this->select_all('lt_info', array('uid'=>array('in',pylode(',', array_unique($lu)))),'`uid`,`realname` AS `name`');
}
if(!empty($eids)){
$resumes = $this -> select_all('resume_expect',array('id'=>array('in',pylode(',',$eids))),'`id`,`name`');
foreach($resumes as $rk=>$rv){
$rname[$rv['id']] = $rv['name'];
}
}
if(!empty($jobids)){
$jobs = $this -> select_all('company_job',array('id'=>array('in',pylode(',',$jobids))),'`id`,`name`');
foreach($jobs as $jk=>$jv){
$jname[$jv['id']] = $jv['name'];
}
}
foreach($List as $k=>$v){
$List[$k]['fname'] = '';
$List[$k]['tname'] = '';
foreach ($company as $valu){
if ($v['from'] == $valu['uid']){
$List[$k]['fname'] = '
' . $valu['name'];
}
if ($v['to'] == $valu['uid']){
$List[$k]['tname'] = '
' . $valu['name'];
}
}
foreach ($resume as $value) {
if ($v['from'] == $value['uid']){
$List[$k]['fname'] = '
' . $value['name'];
}
if ($v['to'] == $value['uid']){
$List[$k]['tname'] = '
' . $value['name'];
}
}
if (!empty($ltinfo)){
foreach ($ltinfo as $lv) {
if ($v['from'] == $lv['uid']){
$List[$k]['fname'] = '
' . $lv['name'];
}
if ($v['to'] == $lv['uid']){
$List[$k]['tname'] = '
' . $lv['name'];
}
}
}
foreach ($member as $val){
if ($v['from'] == $val['uid']){
if ($v['fusertype'] == 1){
$ufname = ' [个人]';
}elseif ($v['fusertype'] == 2){
$ufname = ' [企业]';
}elseif ($v['fusertype'] == 3){
$ufname = ' [猎头]';
}
$List[$k]['fname'] = $val['username'].$ufname . $List[$k]['fname'];
}
if ($v['to'] == $val['uid']){
if ($v['tusertype'] == 1){
$utname = ' [个人]';
}elseif ($v['tusertype'] == 2){
$utname = ' [企业]';
}elseif ($v['tusertype'] == 3){
$utname = ' [猎头]';
}
$List[$k]['tname'] = $val['username'].$utname . $List[$k]['tname'];
}
}
if($v['fusertype']==9){
$List[$k]['fname'] = '网站客服';
}
if($v['tusertype']==9){
$List[$k]['tname'] = '网站客服';
}
if($v['msgtype']=='resume'){
if (strpos($v['content'],'eid=')!==false){
$eid = str_replace('eid=', '', $v['content']);
if (!empty($rname[$eid])){
$List[$k]['content']= '发送简历（ID '.$eid.'）：'.$rname[$eid];
}else{
$List[$k]['content']= '发送简历（ID '.$eid.'）：[简历不存在]';
}
}
}else if($v['msgtype']=='job' || $v['msgtype'] == 'adminjob'){
if (strpos($v['content'],'jobid=')!==false){
$jobid = str_replace('jobid=', '', $v['content']);
if (!empty($jname[$jobid])){
$List[$k]['content']= '发送职位（ID '.$jobid.'）：'.$jname[$jobid];
}else{
$List[$k]['content']= '发送职位（ID '.$jobid.'）：[职位不存在]';
}
}
}else if($v['msgtype']=='ask'){
if (strpos($v['content'],'ask=')!==false){
$askid = str_replace('ask=', '', $v['content']);
$asktype = '';
if($askid=='tel'){
$asktype = '电话';
}else if($askid=='wx'){
$asktype = '微信';
}
$List[$k]['content']= '请求交换'.$asktype.'：'.$v['askvalue'];
}
}else if($v['msgtype']=='confirm'){
if (strpos($v['content'],'confirm=')!==false){
$confirmid = str_replace('confirm=', '', $v['content']);
$confirmtype = '';
if($confirmid=='tel'){
$confirmtype = '电话';
}else if($confirmid=='wx'){
$confirmtype = '微信';
}
$List[$k]['content']= '同意交换'.$confirmtype.'：'.$v['fconfirm'];
}
}else if($v['msgtype']=='refuse'){
if (strpos($v['content'],'refuse=')!==false){
$refuseid = str_replace('refuse=', '', $v['content']);
$refusetype = '';
if($refuseid=='tel'){
$refusetype = '电话';
}else if($refuseid=='wx'){
$refusetype = '微信';
}
$List[$k]['content']= '拒绝交换'.$refusetype;
}
}else if($v['msgtype']=='voice'){
if (strpos($v['content'],'voice[http')!==false){
preg_match('/voice\[([^\s]+?)\]/u',$v['content'],$m);
$List[$k]['mtype'] = 'voice';
$List[$k]['content']= $m[1];
}
}else if($v['msgtype']=='char'){
if (strpos($v['content'],'img[http')!==false){
preg_match('/img\[([^\s]+?)\]/u',$v['content'],$m);
$List[$k]['mtype'] = 'img';
$List[$k]['content']= $m[1];
}
}
}
}
}
return $List;
}
/**
* 修改消息
* $upData 要修改的数据
* $whereData 查询条件
*/
public function upChatLog($upData,$whereData) {
if (!empty($whereData)){
$nid = $this -> update_once('chat_log',$upData,$whereData);
}
return $nid;
}
/**
* 查询聊天数量
* $whereData 查询条件
*/
public function getChatLogNum($whereData) {
$num = $this -> select_num('chat_log', $whereData);
return $num;
}
/**
* 删除聊天记录，按条件分为删除全部记录和单个人记录
* $whereData 查询条件
*/
public function delChatLog($data = array()) {
if(!empty($data['toid'])){
// 处理uid。管理员uid与其他身份不同
$data['toid'] = str_replace('a', '', $data['toid']);
$br = $this->getBeginid($data);
if (!empty($br['beginid'])){
$this -> delete_all('chat_log', array('beginid'=>$br['beginid']), '');
// 用户自己删除，同时删除好友关系
$this -> delete_all('chat_friend', array('beginid'=>$br['beginid']), '');
// 再删除聊天权限
$this -> delete_all('chat_right', array('uid'=>$br['uid'],'comid'=>$br['comid'],'usertype'=>$br['comtype']), '');
require_once ('log.model.php');
$LogM = new log_model($this->db, $this->def);
$LogM->addMemberLog($data['uid'], $data['usertype'], '将聊天对象(ID: '.$data['to'].')设置为不感兴趣', 30, 3);
}
}elseif(!empty($data['where'])){
$where = $data['where'];
if (isset($data['norecycle']) && $data['norecycle'] == 1){
$nid = $this -> delete_all('chat_log', $where, '', '', 1);
}else{
$nid = $this -> delete_all('chat_log', $where, '');
}
return $nid;
}
}
//获取单个聊天对象的相关数据
public function getSingleChatOnlineData($data){
// 处理uid。管理员uid与其他身份不同
$data['toid'] = str_replace('a', '', $data['toid']);
$uid = $data['uid'];
$usertype = $data['usertype'];
$toid = $data['toid'];
$totype = $data['totype'];
$return = array();
$br = $this->getBeginid(array(
'toid' => $toid,
'tusertype' => $totype,
'fromid' => $uid,
'fusertype' => $usertype), 'get');
$chat = $this->userinfo(array('uid'=>$toid,'usertype'=>$totype,'nowid'=>$uid,'nowtype'=>$usertype));
$return = $chat['mine'];
$return['toid'] = $toid;
$return['totype'] = $totype;
$return['canwx'] = $this->getFriendCan(array('type'=>'wx','uid'=>$uid,'usertype'=>$usertype,'fid'=>$toid,'fusertype'=>$totype));
$return['cantel'] = $this->getFriendCan(array('type'=>'tel','uid'=>$uid,'usertype'=>$usertype,'fid'=>$toid,'fusertype'=>$totype));
require_once ('job.model.php');
$jobM = new job_model($this->db, $this->def);
require_once ('lietoujob.model.php');
$ltjobM = new lietoujob_model($this->db, $this->def);
$return['expect'] = array();
$return['joblist'] = array();
if($totype==1){
$expect = $this->select_once('resume_expect',array('uid'=>$toid,'defaults'=>1),'id,`uid`');
if (!empty($expect)){
require_once ('resume.model.php');
$resumeM = new resume_model($this->db, $this->def);
$einfo = $resumeM -> getExpect(array('id'=>$expect['id']),array('needCache'=>1,'field'=>'`id`,`uid`,`name`,`exp`,`edu`,`city_classid`,`report`'));
$rinfo = $resumeM -> getResumeInfo(array('uid'=>$expect['uid']),array('field'=>'`name`,`sex`,`photo`,`birthday`,`description`','logo'=>2));
$einfo['sex_n'] = $rinfo['sex_n'];
$einfo['age'] = $rinfo['age'];
$einfo['uname'] = $rinfo['name'];
$einfo['photo'] = $rinfo['photo'];
$einfo['description'] = mb_substr(strip_tags($rinfo['description']), 0, 60);
$einfo['weburl'] = Url('resume',array('c'=>'show','id'=>$expect['id']));
$return['expect'] = $einfo;
}
}else if($totype==2){
$jobs = $jobM->getList(array('uid'=>$toid,'state'=>1,'r_status'=>1,'status'=>0,'limit'=>50),array('chat'=>1,'field'=>'`id`,`uid`,`name`,`com_name`,`provinceid`,`cityid`,`minsalary`,`maxsalary`,`exp`,`edu`'));
foreach ($jobs['list'] as $jobk=>$jobv){
$jobv['weburl']=Url('job',array('c'=>'comapply','id'=>$jobv['id']));
$jobData_arr[$jobv['id']] = $jobv;
}
$return['joblist'] = $jobData_arr;
}else if($totype==3){
$ltjobs = $ltjobM->getList(array('uid'=>$toid,'status'=>1,'zp_status'=>0,'r_status'=>1));
foreach ($ltjobs as $ltjobk=>$ltjobv){
$ltjobData_arr[$ltjobv['id']] = array(
'id' => $ltjobv['id'],
'name' => $ltjobv['job_name'],
'com_name' => $ltjobv['com_name'],
'job_salary' => $ltjobv['salary'],
'citystr' => isset($ltjobv['citystr']) ? $ltjobv['citystr'] : '',
'job_exp' => $ltjobv['exp_n'],
'job_edu' => $ltjobv['edu_n']
);
}
$return['joblist'] = $ltjobData_arr;
}
$chatWhere = array('beginid'=>$br['beginid'],'orderby'=>'id','limit'=>20);
$chatList = $this -> getChatLogList($chatWhere);
$return['history'] = array();
if (!empty($chatList)) {
$chatjob = $this -> getChatLog(array('beginid'=>$br['beginid'],'msgtype'=>'job','orderby'=>'id,ASC'),array('field'=>'`id`'));
$chatnum = $this -> getChatLogNum(array('beginid'=>$br['beginid']));
$from = $this -> getMember(array('uid'=>$uid,'usertype'=>$usertype),array('field'=>'`nickname`,`avatar`'));
$to = $this -> getMember(array('uid'=>$toid,'usertype'=>$totype),array('field'=>'`nickname`,`avatar`'));
foreach ($chatList as $k=>$v){
$chatlog[$k]['chatid'] = $v['id'];
$chatlog[$k]['content'] = $v['content'];
$chatlog[$k]['sendTime'] = $v['sendTime'];
$chatlog[$k]['fusertype'] = $v['fusertype'];
$chatlog[$k]['msgtype'] = $v['msgtype'];
$chatlog[$k]['voicelength'] = $v['voicelength'];
$chatlog[$k]['voicestatus'] = $v['voicestatus'];
$chatlog[$k]['timefromat'] = date('Y-m-d H:i',ceil($v['sendTime']/1000));
$chatlog[$k]['askstatus'] = $v['askstatus'];
$chatlog[$k]['read'] = $v['status'] == 1 ? 1 : 0;
if ($v['from'] == $data['fromid']){
$chatlog[$k]['mine'] = true;
$chatlog[$k]['username'] = $from['nickname'];
$chatlog[$k]['avatar'] = checkpic($from['avatar']);
$chatlog[$k]['confirmcon']= $v['tconfirm'];
}elseif ($v['to'] == $data['fromid']){
$chatlog[$k]['mine'] = false;
$chatlog[$k]['username'] = $to['nickname'];
$chatlog[$k]['avatar'] = checkpic($to['avatar']);
$chatlog[$k]['confirmcon']= $v['fconfirm'];
}
$chatlog[$k]['newjob'] = 0;
if ($v['id'] == $chatjob['id']){
if ($v['from'] == $data['fromid']){
$chatlog[$k]['newjob'] = 1;
}else{
$chatlog[$k]['newjob'] = 2;
}
}
}
$return['history'] = $chatlog;
}
return $return;
}
//获取所有聊天用户相关数据
public function getAllChatOnlineData($data){
global $db_config;
$uid = $data['uid'];
$usertype = $data['usertype'];
$return = array();
$mine = array();
if($uid && $usertype){
// 根据后台设置聊天记录查询日期时限来查询
$day = !empty($this->config['sy_chat_day']) ? $this->config['sy_chat_day'] : 30;
$time = strtotime('-' .$day. ' day');
// 按聊天关系查询
$page = $data['page']?$data['page']:0;
$size = 10;
$cw = array('uid'=>$uid,'usertype'=>$usertype,'ntime'=>array('>=',$time),'orderby'=>'ntime','state'=>1,'limit'=>array($page*$size, $size));
$friends = $this->select_all('chat_friend', $cw,'`uid`,`usertype`,`fid`,`fusertype`,`beginid`,`chating`');
$lt_uids = array();
$com_uids = array();
$re_uids = array();
$lt_arr = array();
$com_arr = array();
$resume_arr = array();
$down_resumes = array();
$expect_arr = array();
$eid_arr = array();//所有expect简历表id
$beginid = array();
$expectData_arr = array();
$ltjobData_arr = array();
$jobData_arr = array();
$chatlog_arr = array();
$comjobNum_arr = array();//统计对方企业的所有职位数量
$ltjobNum_arr = array();//统计对方猎头的所有职位数量
if($usertype==1){
$re_uids[] = $uid;
}else if($usertype==2){
$com_uids[] = $uid;
}else if($usertype==3){
$lt_uids[] = $uid;
}
foreach ($friends as $fk => $fv) {
if($fv['fusertype']==3 && !in_array($fv['fid'],$lt_uids)){
$lt_uids[] = $fv['fid'];
}else if($fv['fusertype']==2 && !in_array($fv['fid'],$com_uids)){
$com_uids[] = $fv['fid'];
}else if($fv['fusertype']==1 && !in_array($fv['fid'],$re_uids)){
$re_uids[] = $fv['fid'];
}
$akey = $fv['fusertype']==9?'a'.$fv['fid'] : $fv['fid'];
$return[$akey] = array('ismine'=>false,'toid'=>$fv['fid'],'totype'=>$fv['fusertype'],'beginid'=>$fv['beginid']);
$bd = explode('-', $fv['beginid']);
// beginid组成的两个字符串都为数字
if (is_numeric($bd[0]) && is_numeric($bd[1]) && is_numeric($bd[2])){
$beginid[] = $fv['beginid'];
}
}
require_once ('job.model.php');
$jobM = new job_model($this->db, $this->def);
require_once ('lietoujob.model.php');
$ltjobM = new lietoujob_model($this->db, $this->def);
$userid_msg_arr = array();
//当前用户是个人就只查聊天记录中的职位，不然就查企业或猎头下的所有职位
if($usertype==2){
$jobs = $jobM->getList(array('uid'=>$uid,'state'=>1,'r_status'=>1,'status'=>0,'limit'=>50),array('chat'=>1,'field'=>'`id`,`uid`,`name`,`com_name`,`provinceid`,`cityid`,`minsalary`,`maxsalary`,`exp`,`edu`'));
//查询和企业聊天的个人用户中 邀请面试情况
if(!empty($re_uids)){
$userid_msg_data = $this->select_all('userid_msg',array('fid'=>$uid,'uid'=>array('in',pylode(',', $re_uids)),'isdel'=>'9','groupby'=>'uid'),'`uid`,count(*) as num');
foreach ($userid_msg_data as $umkey => $umvalue) {
$userid_msg_arr[$umvalue['uid']] = $umvalue['num'];
}
}
}else if($usertype==3){
$ltjobs = $ltjobM->getList(array('uid'=>$uid,'status'=>1,'zp_status'=>0,'r_status'=>1));
}else if($usertype==1){
//企业的职位数量
if(!empty($com_uids)){
$comjobNum = $this->select_all('company_job',array('uid'=>array('in',pylode(',', $com_uids)),'state'=>1,'r_status'=>1,'status'=>0,'groupby'=>'uid'),'`uid`,count(*) as num');
foreach($comjobNum as $cjnk=>$cjnv){
$comjobNum_arr[$cjnv['uid']] = $cjnv['num'];
}
}
//猎头的职位数量
if(!empty($lt_uids)){
$ltjobNum = $this->select_all('lt_job',array('uid'=>array('in',pylode(',', $lt_uids)),'status'=>1,'zp_status'=>0,'r_status'=>1,'groupby'=>'uid'),'`uid`,count(*) as num');
foreach($ltjobNum as $ljnk=>$ljnv){
$ltjobNum_arr[$ljnv['uid']] = $ljnv['num'];
}
}
$chatjobwhere = array(
'beginid' => array('in', '"'.@implode('","', $beginid).'"'),
'sendTime' => array('>', $time),
);
$chatjobwhere['PHPYUNBTWSTART'] = '';
$chatjobwhere['msgtype'][] = array('=','job');
$chatjobwhere['msgtype'][] = array('=','adminjob','or');
$chatjobwhere['PHPYUNBTWEND'] = '';
//获取聊天记录中的所有职位
$chats = $this->select_all('chat_log',$chatjobwhere,'`from`,`to`,`fusertype`,`tusertype`,`content`,`msgtype`');
if(!empty($chats)){
$jobid_arr = array();
$ltjobid_arr = array();
foreach($chats as $chatkey=>$chatval){
if(($chatval['msgtype']=='job'||$chatval['msgtype']=='adminjob') && strpos($chatval['content'],'jobid=')!==false){
$jobid = trim(str_replace('jobid=', '',$chatval['content']));
if($chatval['fusertype']==3 || $chatval['tusertype']==3){
$ltjobid_arr[] = $jobid;
}else if($chatval['fusertype']==2 || $chatval['tusertype']==2){
$jobid_arr[] = $jobid;
}else if($chatval['fusertype']==9 || $chatval['tusertype']==9){
$jobid_arr[] = $jobid;
}
}
}
if($ltjobid_arr){
$ltjobs = $ltjobM->getList(array('id'=>array('in',pylode(',',$ltjobid_arr)),'status'=>1,'zp_status'=>0,'r_status'=>1));
}
if($jobid_arr){
$jobs = $jobM->getList(array('id'=>array('in',pylode(',',$jobid_arr)),'state'=>1,'r_status'=>1,'status'=>0),array('chat'=>1,'field'=>'`id`,`uid`,`name`,`com_name`,`provinceid`,`cityid`,`minsalary`,`maxsalary`,`exp`,`edu`'));
}
}
//获取聊天记录中的所有职位 end
}
if(!empty($jobs['list'])){
foreach ($jobs['list'] as $jobk=>$jobv){
$jobv['weburl']=Url('job',array('c'=>'comapply','id'=>$jobv['id']));
$jobData_arr[$jobv['uid']][$jobv['id']] = $jobv;
}
//后台客勤发布的职位单独拉出来
foreach($chats as $chatkey=>$chatval){
if($chatval['msgtype']=='adminjob' && strpos($chatval['content'],'jobid=')!==false){
$jobid = trim(str_replace('jobid=', '',$chatval['content']));
foreach ($jobs['list'] as $job_k=>$job_v){
if($jobid == $job_v['id']){
$job_v['weburl']=Url('job',array('c'=>'comapply','id'=>$job_v['id']));
$crmjobData_arr[$chatval['from']][$jobid] = $job_v;
}
}
}
}
}
if(!empty($ltjobs)){
foreach ($ltjobs as $ltjobk=>$ltjobv){
$ltjobData_arr[$ltjobv['uid']][$ltjobv['id']] = array(
'id' => $ltjobv['id'],
'name' => $ltjobv['job_name'],
'com_name' => $ltjobv['com_name'],
'job_salary' => $ltjobv['salary'],
'citystr' => isset($ltjobv['citystr']) ? $ltjobv['citystr'] : '',
'job_exp' => $ltjobv['exp_n'],
'job_edu' => $ltjobv['edu_n']
);
}
}
//获取对方linkman identity 数据
if(!empty($lt_uids)){
$ltdata = $this -> select_all('lt_info',array('uid'=>array('in',pylode(',',$lt_uids))),'`realname`,`uid`,`com_name`,`photo_big`,`moblie`,`wxid`');
foreach($ltdata as $ltk=>$ltv){
$lt_arr[$ltv['uid']] = $ltv;
}
}
if(!empty($com_uids)){
$comdata = $this -> select_all('company',array('uid'=>array('in',pylode(',',$com_uids))),'`name`,`uid`,`shortname`,`logo`,`linkman`,`linktel`,`wxid`');
foreach($comdata as $ck=>$cv){
$com_arr[$cv['uid']] = $cv;
}
}
if(!empty($re_uids)){
$resumedata = $this -> select_all('resume',array('uid'=>array('in',pylode(',',$re_uids))),'`name`,`uid`,`photo`,`defphoto`,`phototype`,`photo_status`,`sex`,`nametype`,`def_job`,`telphone`,`wxid`');
foreach($resumedata as $rk=>$rv){
$resume_arr[$rv['uid']] = $rv;
}
$expectdata = $this->select_all('resume_expect',array('uid'=>array('in',pylode(',',$re_uids)),'defaults'=>1),'`id`,`uid`,`name`');
foreach ($expectdata as $ek => $ev) {
$expect_arr[$ev['uid']] = $ev['name'];
if(!in_array($ev['id'],$eid_arr)){
$eid_arr[] = $ev['id'];//获取所有待查eid
}
}
if($usertype!=1){
$downdata = $this->select_all('down_resume',array('uid'=>array('in',pylode(',',$re_uids)),'comid'=>$uid,'groupby'=>'uid'),"`uid`,count(*) as `num`");
foreach($downdata as $dk=>$dv){
$down_resumes[$dv['uid']] = $dv['downnum'];
}
}
}
//获取对方linkman identity 数据end
//获取所有expect
if(!empty($eid_arr)){
$e_ids = array();
$e_uids = array();
$all_expect = array();
$all_resume = array();
require_once ('resume.model.php');
$resumeM = new resume_model($this->db, $this->def);
$expectsData = $resumeM->getList(array('id'=>array('in',pylode(',',$eid_arr))),array('field'=>'`id`,`uid`,`name`,`exp`,`edu`,`city_classid`,`report`'));
$all_expect = $expectsData['list'];
foreach ($all_expect as $aek => $aev) {
if(!in_array($aev['uid'],$e_uids)){
$e_uids[] = $aev['uid'];
}
if(!in_array($aev['id'],$e_ids)){
$e_ids[] = $aev['id'];
}
}
if(!empty($e_uids)){
$all_resume = $resumeM->getResumeList(array('uid'=>array('in',pylode(',',$e_uids))),array('field'=>'`uid`,`name`,`sex`,`photo`,`phototype`,`defphoto`, `photo_status`,`birthday`,`description`'));
foreach($all_expect as $aekey=>$aeval){
foreach($all_resume as $arkey=>$arval){
if($arval['uid'] == $aeval['uid']){
$expectData_arr[$aeval['uid']]['id'] = $aeval['id'];
$expectData_arr[$aeval['uid']]['salary'] = $aeval['salary'];
$expectData_arr[$aeval['uid']]['city_classname'] = $aeval['city_classname'];
$expectData_arr[$aeval['uid']]['exp_n'] = $aeval['exp_n'];
$expectData_arr[$aeval['uid']]['edu_n'] = $aeval['edu_n'];
$expectData_arr[$aeval['uid']]['name'] = $aeval['name'];
$expectData_arr[$aeval['uid']]['sex_n'] = $arval['sex_n'];
$expectData_arr[$aeval['uid']]['age'] = $arval['age_n'];
$expectData_arr[$aeval['uid']]['uname'] = $arval['username_n'];
$expectData_arr[$aeval['uid']]['description'] = mb_substr(strip_tags($arval['description']), 0, 60);;
$expectData_arr[$aeval['uid']]['weburl'] = Url('resume',array('c'=>'show','id'=>$aeval['id']));
$expectData_arr[$aeval['uid']]['photo'] = $arval['photo'];
}
}
}
}
}
//获取所有expect end
//获取互换微信 电话 的权限数据
$fwhere['state'] = 1;
$fwhere['PHPYUNBTWSTART_a_DOUBLE'] = '';
$fwhere['uid'] = $uid;
$fwhere['usertype'] = $usertype;
$fwhere['PHPYUNBTWEND_a'] = '';
$fwhere['PHPYUNBTWSTART_b'] = 'OR';
$fwhere['fid'] = $uid;
$fwhere['fusertype'] = $usertype;
$fwhere['PHPYUNBTWEND_b_DOUBLE'] = '';
$friend_all = $this->select_all('chat_friend',$fwhere,'`uid`,`usertype`,`beginid`,`fid`,`fusertype`,`wx`,`tel`');
$friend_can = array();
foreach ($friend_all as $fak => $fav) {
if($fav['beginid'] && $fav['uid']){
$friend_can[$fav['beginid']][$fav['uid']] = $fav;
}
}
//获取互换微信 电话 的权限数据 end
//获取聊天历史记录信息
if(!empty($beginid)){
$chat_member_list = array();
$chatjob_ids= array();
$user_chatmember_list = $this -> select_all('chat_member',array('uid'=>array('in',pylode(',',$re_uids)),'usertype'=>1),'`uid`,`nickname`,`usertype`,`avatar`');
$com_chatmember_list = $this -> select_all('chat_member',array('uid'=>array('in',pylode(',',$com_uids)),'usertype'=>2),'`uid`,`nickname`,`usertype`,`avatar`');
$lt_chatmember_list = $this -> select_all('chat_member',array('uid'=>array('in',pylode(',',$com_uids)),'usertype'=>3),'`uid`,`nickname`,`usertype`,`avatar`');
foreach ($user_chatmember_list as $uclk => $uclv) {
$chat_member_list[$uclv['uid']][$uclv['usertype']] = $uclv;
}
foreach ($com_chatmember_list as $cclk => $cclv) {
$chat_member_list[$cclv['uid']][$cclv['usertype']] = $cclv;
}
foreach ($lt_chatmember_list as $lclk => $lclv) {
$chat_member_list[$lclv['uid']][$lclv['usertype']] = $lclv;
}
$chatlogjobwhere = array(
'field'=>'`id`',
'beginid'=> array('in',@implode(',',$beginid)),
'groupby'=> 'beginid'
);
$chatlogjobwhere['PHPYUNBTWSTART'] = '';
$chatlogjobwhere['msgtype'][] = array('=','job');
$chatlogjobwhere['msgtype'][] = array('=','adminjob','or');
$chatlogjobwhere['PHPYUNBTWEND'] = '';
$chatjobList = $this -> getChatLogList($chatlogjobwhere);
foreach ($chatjobList as $cjlk => $cjlv) {
$chatjob_ids[] = $cjlv['id'];
}
$chatloglimit = 20;
$chatlog_sql = "SELECT * FROM $db_config[def]chat_log a WHERE a.`beginid` IN(\"".@implode('","',$beginid)."\") AND (SELECT count(`id`) FROM $db_config[def]chat_log WHERE `beginid` = a.`beginid` AND `id` > a.`id`) < ".$chatloglimit." ORDER BY a.`beginid`,a.`id` desc";
$chatList = $this->DB_query_all($chatlog_sql,'all');
foreach ($chatList as $chatk=>$chatv){
$chatlog = array();
$chatlog['chatid'] = $chatv['id'];
$chatlog['content'] = $chatv['content'];
$chatlog['sendTime'] = $chatv['sendTime'];
$chatlog['fusertype'] = $chatv['fusertype'];
$chatlog['msgtype'] = $chatv['msgtype'];
$chatlog['voicelength'] = $chatv['voicelength'];
$chatlog['voicestatus'] = $chatv['voicestatus'];
$chatlog['timefromat'] = date('Y-m-d H:i',ceil($chatv['sendTime']/1000));
$chatlog['askstatus'] = $chatv['askstatus'];
$chatlog['read'] = $chatv['status'] == 1 ? 1 : 0;
if ($chatv['from'] == $uid){
$chatlog['mine'] = true;
$chatlog['username'] = $chat_member_list[$uid][$usertype]['nickname'];
$chatlog['avatar'] = checkpic($chat_member_list[$uid][$usertype]['avatar'],$this->config['sy_chat_logo']);
$chatlog['confirmcon']= $chatv['tconfirm'];
}else{
$chatlog['mine'] = false;
$chatlog['username'] = $chat_member_list[$chatv['from']][$chatv['fusertype']]['nickname'];
$chatlog['avatar'] = checkpic($chat_member_list[$chatv['from']][$chatv['fusertype']]['avatar'],$this->config['sy_chat_logo']);
$chatlog['confirmcon']= $chatv['fconfirm'];
}
$chatlog['newjob'] = 0;
if (in_array($chatv['id'],$chatjob_ids)){
if ($chatv['from'] == $uid){
$chatlog['newjob'] = 1;
}else{
$chatlog['newjob'] = 2;
}
}
$chatlog_arr[$chatv['beginid']][] = $chatlog;
}
}
//获取聊天历史记录信息 end
foreach ($return as $toid => $val) {
$toid_v = $val['toid'];
//获取互换微信 电话 的权限
if($friend_can[$val['beginid']][$toid_v]['wx']==1 && $friend_can[$val['beginid']][$uid]['wx']==1){
$canwx = 1;//同意互换
}else{
if($friend_can[$val['beginid']][$toid_v]['wx']==3){
$canwx = 3;//发出请求等待对方操作
}else{
$canwx = 0;//尚未请求
}
}
if($friend_can[$val['beginid']][$toid_v]['tel']==1 && $friend_can[$val['beginid']][$uid]['tel']==1){
$cantel = 1;//同意互换
}else{
if($friend_can[$val['beginid']][$toid_v]['tel']==3){
$cantel = 3;//发出请求等待对方操作
}else{
$cantel = 0;//尚未请求
}
}
$return[$toid]['inviteNum'] = 0;
if($usertype==2 && !empty($userid_msg_arr[$toid])){
$return[$toid]['inviteNum'] = $userid_msg_arr[$toid];
}
$return[$toid]['canwx'] = $canwx;
$return[$toid]['cantel'] = $cantel;
//获取互换微信 电话 的权限 end
//获取对方linkman identity
if($val['totype']==1 && !empty($resume_arr[$toid_v])){
$return[$toid]['nickname'] = $resume_arr[$toid_v]['name'];
$return[$toid]['tel'] = $resume_arr[$toid_v]['telphone'];
$return[$toid]['wxid'] = $resume_arr[$toid_v]['wxid'];
$photoArr = array('photo' => $resume_arr[$toid_v]['photo'], 'defphoto'=> $resume_arr[$toid_v]['defphoto'],'phototype'=> $resume_arr[$toid_v]['phototype'], 'photo_status' => $resume_arr[$toid_v]['photo_status'], 'sex' => $resume_arr[$toid_v]['sex']);
$return[$toid]['avatar'] = $this->setResumePhotoShow($photoArr);
$return[$toid]['linkman'] = $resume_arr[$toid_v]['name'];
if ($down_resumes[$toid_v] && $down_resumes[$toid_v] > 0){
$return[$toid]['linkman']= $resume_arr[$toid_v]['name'];
}else{
$nameArr = array(
'name' => $resume_arr[$toid_v]['name'],
'sex' => $resume_arr[$toid_v]['sex'],
'nametype' => $resume_arr[$toid_v]['nametype'],
'eid' => $resume_arr[$toid_v]['def_job']
);
$return[$toid]['linkman'] = $this->setUsernameShow($nameArr);
}
$return[$toid]['nowtype'] = $usertype;
$return[$toid]['name'] = $resume_arr[$toid_v]['name'];
if (!empty($expect_arr[$toid_v])){
if (mb_strlen($expect_arr[$toid_v]) > 20){
$return[$toid]['identity'] = mb_substr($expect_arr[$toid_v], 0, 20) . '...';
}else{
$return[$toid]['identity'] = $expect_arr[$toid_v];
}
}else{
$return[$toid]['identity'] = '求职者';
}
}else if($val['totype']==2 && !empty($com_arr[$toid_v])){
$name = $com_arr[$toid_v]['name'];
$return[$toid]['nickname'] = !empty($com_arr[$toid_v]['shortname']) ? $com_arr[$toid_v]['shortname'] : $name;
if (!empty($com_arr[$toid_v]['logo'])){
$return[$toid]['avatar'] = $com_arr[$toid_v]['logo'];
}else{
$return[$toid]['avatar'] = $this->config['sy_unit_icon'];
}
$return[$toid]['linkman'] = $com_arr[$toid_v]['linkman'];
$return[$toid]['identity'] = $return[$toid_v]['nickname'].'.招聘者';
$return[$toid]['tel'] = $com_arr[$toid_v]['linktel'];
$return[$toid]['wxid'] = $com_arr[$toid_v]['wxid'];
$return[$toid]['comalljobnum'] = $comjobNum_arr[$toid_v];
}else if($val['totype']==3 && !empty($lt_arr[$toid_v])){
$return[$toid]['nickname'] = $lt_arr[$toid_v]['realname'];
if (!empty($lt_arr[$toid_v]['photo_big'])){
$return[$toid]['avatar'] = $lt_arr[$toid_v]['photo_big'];
}else{
$return[$toid]['avatar'] = $this->config['sy_lt_icon'];
}
$return[$toid]['linkman'] = $return[$toid_v]['nickname'];
$return[$toid]['identity'] = $lt_arr[$toid_v]['com_name'].'.招聘者';
$return[$toid]['tel'] = $lt_arr[$toid_v]['moblie'];
$return[$toid]['wxid'] = $lt_arr[$toid_v]['wxid'];
$return[$toid]['comalljobnum'] = $ltjobNum_arr[$toid_v];
}else if($val['totype']==9){
$return[$toid]['linkman'] = '官方客服';
}
//获取对方linkman identity end
//简历数据
$return[$toid]['expect'] = !empty($expectData_arr[$toid_v]) ? $expectData_arr[$toid_v] : array();
//职位数据
$return[$toid]['joblist'] = array();
if($val['totype']==3 && $ltjobData_arr[$toid_v]){
$return[$toid]['joblist'] = $ltjobData_arr[$toid_v];
}else if($val['totype']==2 && $jobData_arr[$toid_v]){
$return[$toid]['joblist'] = $jobData_arr[$toid_v];
}else if($val['totype']==9 && $crmjobData_arr[$toid_v]){
$return[$toid]['joblist'] = $crmjobData_arr[$toid_v];
}
//聊天数据
$return[$toid]['history'] = $chatlog_arr[$val['beginid']]?$chatlog_arr[$val['beginid']]:array();
}
//当前聊天者自身的相关信息
$mine = array(
'ismine' => true,
'expect' => !empty($expectData_arr[$uid]) ? $expectData_arr[$uid] : array(),
'joblist' => array()
);
if($usertype==3 && !empty($ltjobData_arr[$uid])){
$mine['joblist'] = $ltjobData_arr[$uid];
}else if($usertype==2 && !empty($jobData_arr[$uid])){
$mine['joblist'] = $jobData_arr[$uid];
}
//当前聊天者自身的相关信息 end
}
$result['toall'] = $return;
$result['mine'] = $mine;
return $result;
}
/**
* 查询聊天记录
* @param number $uid
* @param number $usertype
* @param number $page
* @param number $friend // 是否展示全部好友列表（没有聊天记录也展示）
*/
public function getHistory($uid, $usertype, $page = 0, $isfriend = 0, $cate = 'all'){
// 根据后台设置聊天记录查询日期时限来查询
$day = !empty($this->config['sy_chat_day']) ? $this->config['sy_chat_day'] : 30;
$time = strtotime('-' .$day. ' day');
$history = array();
$size = 10;
$cw = array('uid'=>$uid,'usertype'=>$usertype,'ntime'=>array('>=',$time),'orderby'=>'ntime','state'=>1,'limit'=>array($page*$size, $size));
if ($cate == 'new'){
// 招呼
$cw['chating'] = 1;
}elseif ($cate == 'old'){
// 沟通中
$cw['chating'] = array('<>', 1);
}
// 按聊天关系查询
$friends = $this->select_all('chat_friend', $cw,'`uid`,`usertype`,`fid`,`fusertype`,`beginid`,`chating`,`ntime`');
if (!empty($friends)){
foreach ($friends as $v){
$bd = explode('-', $v['beginid']);
// beginid组成的两个字符串都为数字
if (is_numeric($bd[0]) && is_numeric($bd[1]) && is_numeric($bd[2])){
$fuid[] = $v['fid'];
$beginid[] = $v['beginid'];
}
}
if (!empty($beginid)){
$beginid = array_unique($beginid);
// 按beginid查出最新聊天记录id
$fchats = $this->select_all('chat_log', array('beginid'=>array('in', "\"".@implode('","',$beginid)."\""),'groupby'=>'beginid'), 'MAX(`id`) AS `id`');
foreach ($fchats as $v){
$chatid[] = $v['id'];
}
// 通过最新聊天记录id来查询聊天记录
$chats = $this->select_all('chat_log', array('id'=>array('in', pylode(',', $chatid)),'orderby'=>'id'), '`beginid`,`from`,`fusertype`,`to`,`tusertype`,`sendTime`,`content`,`msgtype`');
$fuid = array_filter(array_unique($fuid));
$from = $this -> select_all('chat_member', array('uid'=>array('in',pylode(',', $fuid)),'usertype'=>array('<>',$usertype)),'`uid`,`usertype`,`nickname`,`linkman`,`avatar`');
$unreadtime = strtotime('-' .$day. ' day') * 1000;
$unread = $this -> select_all('chat_log',array('to'=>$uid,'tusertype'=>$usertype,'status'=>2,'sendTime'=>array('>',$unreadtime),'groupby'=>'`from`'),'`id`,`from`,`fusertype`,count(*) as `num`');
if ($usertype == 2 || $usertype == 3 || $usertype == 9){
$resume = $this -> select_all('resume', array('uid'=>array('in',pylode(',', $fuid))),'`uid`,`name`,`sex`,`nametype`,`def_job`');
$expect = $this -> select_all('resume_expect', array('uid'=>array('in',pylode(',', $fuid)),'defaults'=>1,'state'=>'1'),'uid,name');
if ($usertype == 2 || $usertype == 3){
$down = $this -> select_all('down_resume', array('comid'=>$uid,'uid'=>array('in',pylode(',', $fuid))),'`uid`');
}
foreach ($resume as $k=>$v){
if ($usertype == 9){
$resume[$k]['linkman'] = $v['name'];
}else{
$nameArr = array();
$nameArr['name'] = $v['name'];
$nameArr['sex'] = $v['sex'];
$nameArr['nametype'] = $v['nametype'];
$nameArr['eid'] = $v['def_job'];
$resume[$k]['linkman'] = $this->setUsernameShow($nameArr);
foreach ($down as $dv){
if ($v['uid'] == $dv['uid']){
$resume[$k]['linkman'] = $v['name'];
}
}
}
}
}
if ($usertype == 1){
$usersq = $this -> select_all('userid_job', array('uid'=>$uid,'com_id'=>array('in',pylode(',', $fuid))),'`com_id`');
}
foreach ($from as $k=>$v){
$from[$k]['unread'] = 0;
foreach ($unread as $uval){
if ($v['uid'] == $uval['from'] && $v['usertype'] == $uval['fusertype']){
$from[$k]['unread'] = $uval['num'];
}
}
if (!empty($resume)){
foreach ($resume as $rval){
if ($v['uid'] == $rval['uid']){
$from[$k]['linkman'] = $rval['linkman'];
}
}
}
if (!empty($expect)){
foreach ($expect as $eval){
if ($v['uid'] == $eval['uid']){
$from[$k]['expect'] = $eval['name'];
}
}
}
}
$flist = array();
foreach ($friends as $key=>$val){
$flist[$key]['from'] = $val['uid'];
$flist[$key]['fusertype'] = $val['usertype'];
$flist[$key]['to'] = $val['fid'];
$flist[$key]['tusertype'] = $val['fusertype'];
$flist[$key]['chating'] = $val['chating'];
$flist[$key]['content'] = '';
$flist[$key]['msgtype'] = '';
foreach ($chats as $k=>$v){
if ($val['beginid'] == $v['beginid']){
$flist[$key]['from'] = $v['from'];
$flist[$key]['fusertype'] = $v['fusertype'];
$flist[$key]['to'] = $v['to'];
$flist[$key]['tusertype'] = $v['tusertype'];
$flist[$key]['content'] = $v['content'];
$flist[$key]['sendTime'] = $v['sendTime'];
$flist[$key]['msgtype'] = $v['msgtype'];
}
}
//没有聊天记录的，要判断是否需要在聊天列表
if($flist[$key]['content']=='' && $isfriend == 0){
unset($flist[$key]);
}
}
foreach ($flist as $key=>$val){
foreach ($friends as $k=>$v){
if ($val['to'] == $v['fid'] && empty($val['sendTime'])){
// 没有聊天记录，按聊天关系表时间处理
$flist[$key]['sendTime'] = $v['ntime'] * 1000;
}
}
}
$today = strtotime('today');
foreach ($flist as $key=>$val){
foreach ($from as $k=>$v){
if (($val['from']==$v['uid'] && $val['fusertype'] == $v['usertype']) || ($val['to']==$v['uid'] && $val['tusertype'] == $v['usertype'])){
if ($val['from'] == $uid){
$hkey = $val['to'];
} elseif ($val['to'] == $uid){
$hkey = $val['from'];
}
if($v['usertype'] == 9){
// 管理员与其他用户身份的不同
$hkey = 'a' .$hkey;
}
if (isset($hkey)){
$msg = array();
$msg['id'] = $hkey;
if (strpos($val['content'],'img[http')!==false){
$msg['content'] = '[图片]';
}elseif (strpos($val['content'],'voice[http')!==false){
$msg['content'] = '[语音]';
}elseif (strpos($val['content'],'inviteid=')!==false){
$msg['content'] = '面试消息';
}elseif (strpos($val['content'],'eid=')!==false){
$msg['content'] = '简历消息';
}elseif (strpos($val['content'],'jobid=')!==false){
$msg['content'] = '职位消息';
}elseif (strpos($val['content'],'ask=')!==false){
$msg['content'] = '请求互换联系方式';
}elseif (strpos($val['content'],'confirm=')!==false){
$msg['content'] = '互换联系方式';
}elseif (strpos($val['content'],'refuse=')!==false){
$msg['content'] = '互换联系方式';
}else{
$msg['content'] = $val['content'];
}
if ($val['msgtype'] == 'spview'){
$msg['content'] = '[视频面试]';
}elseif ($val['msgtype'] == 'map'){
$msg['content'] = '[位置]';
}
if(ceil($val['sendTime']/1000)>$today){
$msg['time'] = date('H:i',ceil($val['sendTime']/1000));
}else{
$msg['time'] = date('m-d',ceil($val['sendTime']/1000));
}
if(!empty($v['unread'])){
$msg['unread'] = $v['unread'];
}
if ($val['from'] == $uid && $val['fusertype'] == $usertype){
$msg['mine'] = true;
$msg['tusertype'] = $val['tusertype'];
$msg['fusertype'] = $val['fusertype'];
}elseif ($val['to'] == $uid && $val['tusertype'] == $usertype){
$msg['mine'] = false;
$msg['tusertype'] = $val['fusertype'];
$msg['fusertype'] = $val['tusertype'];
}
$msg['username'] = $v['nickname'];
$msg['usertype'] = $v['usertype'];
$msg['linkman'] = $v['linkman'];
$msg['avatar'] = checkpic($v['avatar'] , $this->config['sy_chat_logo']);
$msg['expect'] = isset($v['expect']) ? $v['expect'] : '';
$msg['chating'] = $val['chating'];
$history[] = $msg;
}
}
}
}
}
}
return $history;
}
/**
* 更新并获取用户信息
* @param string $uid
* @return string
*/
function userinfo($data = array('uid'=>'','usertype'=>'','history'=>'', 'friend'=>0))
{
if ($data['usertype'] == 9){
// 管理员
$return['mine'] = array(
'avatar' => checkpic($this->config['sy_chat_logo']),
'id' => 'a' . $data['uid'],
'username' => '求职助手',
'usertype' => 9,
'linkman' => '官方客服',
'identity' => '',
'tel' => '',
'wxid' => ''
);
}else{
if (empty($data['uid']) || empty($data['usertype'])){
return array();
}
$bArr = array(
'uid' => $data['uid'],
'usertype' => $data['usertype']
);
if (!empty($data['nowid']) && !empty($data['nowtype'])){
$bArr['nowid'] = $data['nowid'];
$bArr['nowtype'] = $data['nowtype'];
}
$user = $this -> getBeginInfo($bArr);
$this -> checkMember($user);
//聊天用户信息
$return['mine'] = array(
'avatar' => checkpic($user['avatar']),
'id' => $user['uid'],
'username' => $user['nickname'],
'usertype' => $user['usertype'],
'linkman' => $user['linkman'],
'identity' => $user['identity'],
'tel' => $user['tel'],
'wxid' => $user['wxid']
);
if (!empty($data['history'])){
$return['history'] = $this -> getHistory($user['uid'], $user['usertype'], 0, $data['friend']);
}
}
return $return;
}
/**
* 判断聊天用户
* @param 表：chat_member
* @param 引用字段：$data:字段
*/
public function checkMember($chat = array())
{
$chatMember = $this -> select_once('chat_member', array('uid'=>$chat['uid'],'usertype'=>$chat['usertype']), '`uid`,`nickname`,`avatar`,`linkman`');
$arr = array(
'nickname' => $chat['nickname'],
'avatar' => $chat['avatar'],
'linkman' => $chat['linkman']
);
if (!empty($chatMember)){
// 有内容不一致时，才需要修改
if ($chatMember['nickname'] != $arr['nickname'] || $chatMember['avatar'] != $arr['avatar'] || $chatMember['linkman'] != $arr['linkman']){
$this -> upMember($arr,array('uid'=>$chat['uid'],'usertype'=>$chat['usertype']));
}
}else{
$arr['uid'] = $chat['uid'];
$arr['usertype'] = $chat['usertype'];
$this -> addMember($arr);
}
}
function getBeginInfo($data = array())
{
include_once('userinfo.model.php');
$userinfoM = new userinfo_model($this->db, $this->def);
if ($data['usertype'] == 1){
$field = '`name`,`photo`,`phototype`,`photo_status`,`sex`,`nametype`,`def_job`,`telphone`,`wxid`,`defphoto`';
}elseif ($data['usertype']==2){
$field = '`name`,`shortname`,`logo`,`linkman`,`linktel`,`wxid`';
}elseif ($data['usertype']==3){
$field = '`realname`,`com_name`,`photo_big`,`moblie`,`wxid`';
}
$userinfo = $userinfoM -> getUserInfo(array('uid'=>$data['uid']),array('usertype'=>$data['usertype'],'field'=>$field));
if ($data['usertype'] == 1){
$user['nickname'] = $userinfo['name'];
$user['tel'] = $userinfo['telphone'];
$user['wxid'] = $userinfo['wxid'];
$photoArr = array('photo' => $userinfo['photo'], 'phototype'=> $userinfo['phototype'], 'photo_status' => $userinfo['photo_status'], 'sex' => $userinfo['sex'],'defphoto'=>$userinfo['defphoto']);
$user['avatar'] = $this->setResumePhotoShow($photoArr);
if (!empty($data['nowtype']) && $data['nowtype'] != 1){
$down = $this->select_num('down_resume',array('uid'=>$data['uid'],'comid'=>$data['nowid']));
if ($down > 0){
$user['linkman'] = $userinfo['name'];
}else{
$nameArr = array(
'name' => $userinfo['name'],
'sex' => $userinfo['sex'],
'nametype' => $userinfo['nametype'],
'eid' => $userinfo['def_job']
);
$user['linkman'] = $this->setUsernameShow($nameArr);
}
$user['nowtype'] = $data['nowtype'];
$user['name'] = $userinfo['name'];
}else{
$user['linkman'] = $userinfo['name'];
}
$expect = $this->select_once('resume_expect',array('uid'=>$data['uid'],'defaults'=>1),'`name`');
if (!empty($expect)){
if (mb_strlen($expect['name']) > 20){
$user['identity'] = mb_substr($expect['name'], 0, 20) . '...';
}else{
$user['identity'] = $expect['name'];
}
}else{
$user['identity'] = '求职者';
}
}elseif ($data['usertype'] == 2){
$name = $userinfo['name'];
$user['nickname'] = !empty($userinfo['shortname']) ? $userinfo['shortname'] : $name;
if (!empty($userinfo['logo'])){
$user['avatar'] = $userinfo['logo'];
}else{
$user['avatar'] = $this->config['sy_unit_icon'];
}
$user['linkman'] = $userinfo['linkman'];
$user['identity'] = $user['nickname'].'.招聘者';
$user['tel'] = $userinfo['linktel'];
$user['wxid'] = $userinfo['wxid'];
}elseif ($data['usertype'] == 3){
$user['nickname'] = $userinfo['realname'];
if (!empty($userinfo['photo_big'])){
$user['avatar'] = $userinfo['photo_big'];
}else{
$user['avatar'] = $this->config['sy_lt_icon'];
}
$user['linkman'] = $user['nickname'];
$user['identity'] = $userinfo['com_name'].'.招聘者';
$user['tel'] = $userinfo['moblie'];
$user['wxid'] = $userinfo['wxid'];
}
$user['uid'] = $data['uid'];
$user['usertype'] = $data['usertype'];
if (empty($user['nickname'])){
$member = $this->select_once('member',array('uid'=>$data['uid']), '`username`');
if (CheckMobile($member['username'])){
// 手机号用户名，才需要处理
$user['nickname'] = substr_replace($member['username'],'****',4,4);
}else{
$user['nickname'] = $member['username'];
}
}
return $user;
}
function beginChat($data = array())
{
// 首先处理接受方信息
$fu = $this -> userinfo(array('uid'=>$data['fromid'],'usertype'=>$data['fusertype']));
//二人聊天专用id，这两个人的聊天记录，就按这个查询
$br = $this->getBeginid($data);
return array('error'=>0,'time'=>time(),'br'=>$br);
}
/**
* 查询两人聊天专用id
* @param array $data
*/
function getBeginid($data = array(), $type = '')
{
$time = time();
// 查询、处理聊天关系
$farr = array(
'uid' => $data['fromid'],
'usertype' => $data['fusertype'],
'fid' => $data['toid'],
'fusertype' => $data['tusertype']
);
$friend = $this->getFriend($farr);
if (empty($friend)){
if ($type == 'get'){
// 只是查找。没查到，返回空数组
return array();
}
//二人聊天专用id，这两个人的聊天记录，就按这个查询
$beginid = $this->searchBeginid(array('toid'=>$data['toid'],'fromid'=>$data['fromid'],'tusertype'=>$data['tusertype'],'fusertype'=>$data['fusertype']));
$farr['beginid'] = $beginid;
$farr['ntime'] = $time;
$farr['chating'] = 1;
$this->addFriend($farr);
// 为聊天对象也增加一条记录
$parr = array(
'uid' => $data['toid'],
'usertype' => $data['tusertype'],
'fid' => $data['fromid'],
'fusertype' => $data['fusertype'],
'beginid' => $beginid,
'ntime' => $farr['ntime'],
'chating' => 1
);
$this->addFriend($parr);
$ischat = false;
}else {
if (!empty($friend['beginid'])){
$beginid = $friend['beginid'];
$ischat = true;
}else{
//二人聊天专用id，这两个人的聊天记录，就按这个查询
$beginid = $this->searchBeginid(array('toid'=>$data['toid'],'fromid'=>$data['fromid'],'tusertype'=>$data['tusertype'],'fusertype'=>$data['fusertype']));
$this->upFriend(array('id'=>$friend['id']),array('beginid'=>$beginid));
$ischat = true;
}
}
$return = array(
'beginid' => $beginid,
'ischat' => $ischat,
'ntime' => $farr['ntime'],
'uid' => $data['fusertype'] == 1 ? $data['fromid'] : $data['toid'],
'comid' => $data['fusertype'] == 1 ? $data['toid'] : $data['fromid'],
'comtype' => $data['fusertype'] == 3 || $data['tusertype'] == 3 ? 3 : 2 // comid身份
);
return $return;
}
/**
* 处理初始biginid
*/
private function searchBeginid($data = array())
{
$chatto = $this -> getChatLog(array('from'=>$data['fromid'],'fusertype'=>$data['fusertype'],'to'=>$data['toid'],'tusertype'=>$data['tusertype']));
if (!empty($chatto['beginid'])){
$beginid = $chatto['beginid'];
} else{
$chatfrom = $this -> getChatLog(array('from'=>$data['toid'],'fusertype'=>$data['tusertype'],'to'=>$data['fromid'],'tusertype'=>$data['fusertype']));
if (!empty($chatfrom['beginid'])){
$beginid = $chatfrom['beginid'];
} else {
$return['ischat'] = false;
$beginid = $data['fromid'].'-'.$data['toid'].'-'.$data['fusertype'].$data['tusertype'];
}
}
return $beginid;
}
//聊天内容检测 检测文本 图片
function chatConCheck($data=array()){
$content = $data['content'];
$msgtype = $data['msgtype'];
$uid = $data['fromid'];
$usertype = $data['fusertype'];
$action = isset($data['action'])?$data['action']:'';
$return = array('error'=>9,'errmsg'=>'');
if($this->config['sy_chat_concheck']==2 && $msgtype=='char'){
$check_con_data = array(
'uid' => $uid,
'usertype' => $usertype,
'ctype' => 5,
'cid' => $uid,
'action' => $action
);
if(isset($data['source'])){
$check_con_data['source'] = $data['source'];
}
if(isset($data['openid'])){
$check_con_data['openid'] = $data['openid'];
}
if (strpos($content,'img[http')!==false){
preg_match('/img\[([^\s]+?)\]/u',$content,$m);
$check_con_data['type'] = 'pic';
$check_con[] = $m[1];
}else{
$check_con_data['type'] = 'text';
$check_con[] = $content;
}
if(!empty($check_con)){
require_once('concheck.model.php');
$concheckM = new concheck_model($this->db,$this->def);
$cresult = $concheckM->checkContent($check_con,$check_con_data);
$code = isset($cresult['code']) ? $cresult['code'] : 0;
if ($code != 1) {
$return['error'] = 3;
$return['errmsg'] = '发送内容涉嫌违规，请和谐聊天';
}
}
}
return $return;
}
/**
* 信息发送时添加发送记录
*/
function chatLog($data = array()){
if (!empty($data['fromid']) && !empty($data['fusertype'])){
// 处理管理员id
$data['toid'] = str_replace('a', '', $data['toid']);
if ($data['fromid'] == $data['nowid'] && $data['fusertype'] == $data['nowtype']){
$barr = array(
'fid' => $data['fromid'],
'fusertype' => $data['fusertype'],
'uid' => $data['toid'],
'usertype' => $data['tusertype']
);
$friend = $this->getFriend($barr);
if (!empty($friend) && $friend['state'] == 2){
$return['error'] = 3;
$return['errmsg'] = '对方已将你拉入黑名单，无法'.$this->config['sy_chat_name'];
return $return;
}
// 获取聊天专用id
if (!empty($friend['beginid'])){
$beginid = $friend['beginid'];
}else{
$br = $this->getBeginid($data);
$beginid = $br['beginid'];
}
$from = $this -> getMember(array('uid'=>$data['fromid'],'usertype'=>$data['fusertype']),array('field'=>'`uid`,`usertype`,`nickname`'));
$to = $this -> getMember(array('uid'=>$data['toid'],'usertype'=>$data['tusertype']),array('field'=>'`uid`,`usertype`,`nickname`'));
$ccresult = $this->chatConCheck($data);
if($ccresult['error']!=9){
return $ccresult;
}
$this -> upChatLog(array('last'=>0), array('beginid'=>$beginid,'last'=>1));
$log['from'] = $from['uid'];
$log['to'] = $to['uid'];
$log['beginid'] = $beginid;
$log['fname'] = $from['nickname'];
$log['tname'] = $to['nickname'];
$log['fusertype'] = $from['usertype'];
$log['tusertype'] = $to['usertype'];
$log['content'] = $data['content'];
$log['sendTime'] = $this->checkTime($data['timestamp']);
$log['msgtype'] = $data['msgtype'];
$log['voicelength']= $data['voicelength'];
$log['status'] = 2;
$log['last'] = 1;
$log['receive'] = 2;
//如果是请求互换联系方式，记录该条聊天请求状态askstatus为3
if($data['msgtype']=='ask'){
$askid = str_replace('ask=', '', $data['content']);
$wheref = array('uid'=>$data['fromid'],'fid'=>$data['toid'],'usertype'=>$data['fusertype'],'fusertype'=>$data['tusertype']);
$friend_f = $this->getFriend($wheref);
$log['askstatus'] = 3;
$log['askvalue'] = $friend_f[$askid.'_tem'];
}
//如果是确认互换联系方式，则将双方的暂存于chat_friend表中的数据取出，之前的请求互换的聊天状态askstatus改为1
if($data['msgtype']=='confirm'){
if (strpos($data['content'],'confirm=')!==false){
$confirmid = str_replace('confirm=', '', $data['content']);
if($confirmid == 'wx' || $confirmid=='tel'){
$where1 = array('uid'=>$data['fromid'],'fid'=>$data['toid'],'usertype'=>$data['fusertype'],'fusertype'=>$data['tusertype']);
$where2 = array('uid'=>$data['toid'],'fid'=>$data['fromid'],'usertype'=>$data['tusertype'],'fusertype'=>$data['fusertype']);
$friend_f = $this->getFriend($where1);
$friend_t = $this->getFriend($where2);
$log['fconfirm'] = $friend_f[$confirmid.'_tem'];
$log['tconfirm'] = $friend_t[$confirmid.'_tem'];
}
}
}
$nid = $this -> addChatLog($log);
// 修改两个最新聊天时间
$this->update_once('chat_friend',array('ntime'=>intval($data['timestamp']/1000)),array('beginid'=>$beginid));
// 将自己与对方聊天状态改成沟通中
$fdata = array('chating'=>2);
if($data['msgtype']=='ask'){//发送请求互换微信或电话后，更改己方请求状态为请求中(3)
$askid = trim(str_replace('ask=', '',$data['content']));
$fdata[$askid] = 3;
}
$this->update_once('chat_friend',$fdata,array('uid'=>$data['fromid'],'usertype'=>$data['fusertype'],'fid'=>$data['toid'],'fusertype'=>$data['tusertype']));
$return['error'] = $nid ? 0 : -1;
$return['chatid'] = $nid;
}else{
require_once('cookie.model.php');
$cookie = new cookie_model($this->db,$this->def);
$cookie->unset_cookie();
$return['error'] = 2;
$return['errmsg'] = '当前用户身份不符,请重新登录';
}
}else{
$return['error'] = 1;
$return['errmsg'] = '请先登录';
}
return $return;
}
/**
* 聊天记录分页
* @param array $data
*/
function getChatPage($data = array()){
// 处理uid。管理员uid与其他身份不同
$data['toid'] = str_replace('a', '', $data['toid']);
$br = $this->getBeginid($data, 'get');
if (!empty($br)){
$toid = $data['toid'];
$limit = 20;
$select_from = ($data['page'] - 1) * $limit;
$chatWhere = array('beginid'=>$br['beginid'],'orderby'=>'id','limit'=>array($select_from,$limit));
//非第一页的，要按照原有的聊天记录查询，按新聊天记录会查询出重复内容
if (!empty($data['lastid']) && is_numeric($data['lastid'])){
$chatWhere['id'] = array('<',$data['lastid']);
}
$chatList = $this -> getChatLogList($chatWhere);
if (!empty($chatList)) {
$chatjob = $this -> getChatLog(array('beginid'=>$br['beginid'],'msgtype'=>'job','orderby'=>'id,ASC'),array('field'=>'`id`'));
$chatnum = $this -> getChatLogNum(array('beginid'=>$br['beginid']));
$from = $this -> getMember(array('uid'=>$data['fromid'],'usertype'=>$data['fusertype']),array('field'=>'`nickname`,`avatar`'));
$to = $this -> getMember(array('uid'=>$toid,'usertype'=>$data['tusertype']),array('field'=>'`nickname`,`avatar`'));
$jobarr = array();
$return['code'] = 0;
foreach ($chatList as $k=>$v){
$chatlog[$k]['chatid'] = $v['id'];
$chatlog[$k]['content'] = $v['content'];
$chatlog[$k]['sendTime'] = $v['sendTime'];
$chatlog[$k]['fusertype'] = $v['fusertype'];
$chatlog[$k]['msgtype'] = $v['msgtype'];
$chatlog[$k]['voicelength'] = $v['voicelength'];
$chatlog[$k]['voicestatus'] = $v['voicestatus'];
$chatlog[$k]['timefromat'] = date('Y-m-d H:i',ceil($v['sendTime']/1000));
$chatlog[$k]['askstatus'] = $v['askstatus'];
$chatlog[$k]['read'] = $v['status'] == 1 ? 1 : 0;
if ($v['from'] == $data['fromid'] && $v['fusertype'] == $data['fusertype']){
$chatlog[$k]['mine'] = true;
$chatlog[$k]['username'] = $from['nickname'];
$chatlog[$k]['avatar'] = checkpic($from['avatar'], $this->config['sy_chat_logo']);
$chatlog[$k]['confirmcon']= $v['tconfirm'];
}elseif ($v['to'] == $data['fromid'] && $v['tusertype'] == $data['fusertype']){
$chatlog[$k]['mine'] = false;
$chatlog[$k]['username'] = $to['nickname'];
$chatlog[$k]['avatar'] = checkpic($to['avatar'], $this->config['sy_chat_logo']);
$chatlog[$k]['confirmcon']= $v['fconfirm'];
}
$chatlog[$k]['newjob'] = 0;
if ($v['id'] == $chatjob['id']){
if ($v['from'] == $data['fromid']){
$chatlog[$k]['newjob'] = 1;
}else{
$chatlog[$k]['newjob'] = 2;
}
}
if($v['msgtype'] == 'adminjob'){
$jobid = str_replace('jobid=', '', $v['content']);
if(!empty($jobid)){
$jobarr[] = $jobid;
}
}
}
$return['data'] = $chatlog;
$return['fuser'] = $from;
$return['tuser'] = $to;
$return['ismore'] = ceil($chatnum/$limit) > $data['page'] ? true : false;
if (!empty($jobarr)){
require_once ('job.model.php');
$jobM = new job_model($this->db, $this->def);
// 招聘中职位
$jobs = $jobM->getList(array('id'=>array('in',pylode(',', $jobarr)),'state'=>1,'r_status'=>1,'status'=>0),array('chat'=>1,'field'=>'`id`,`uid`,`name`,`com_name`,`provinceid`,`cityid`,`minsalary`,`maxsalary`,`exp`,`edu`'));
$joblist = array();
foreach ($jobs['list'] as $k=>$v){
$joblist[$v['id']] = $v;
$joblist[$v['id']]['wapurl'] = Url('wap',array('c'=>'job','a'=>'comapply','id'=>$v['id']));
$joblist[$v['id']]['weburl'] = Url('job',array('c'=>'comapply','id'=>$v['id']));
}
$return['adminjob'] = $joblist;
}
}else{
$return['data'] = array();
}
}else{
$return = array('errcode'=>8, 'msg'=>'数据异常');
}
return $return;
}
/**
* 条件聊天时，判断个人是否有简历，并判断是否申请过该企业职位/已被企业邀请面试
* @param array $data
*/
function userToChat($data = array('nowtype'=>''))
{
if ($data['uid']){
if(intval($data['uid']) == intval($data['comid'])){
$return['code'] = 10;
} elseif (!empty($data['nowtype']) && $data['nowtype'] != $data['usertype']) {
$return['code'] = 11;
} else {
$this -> userinfo(array('uid'=>$data['uid'],'usertype'=>$data['usertype']));
$data['tusertype'] = 2;
$where['uid'] = $data['uid'];
$where['defaults'] = 1;
if ($data['jobtype'] == 'lt'){
$data['tusertype'] = 3;
$where['height_status'] = 2;
}
$row = $this -> select_once('resume_expect', $where, '`r_status`,`state`');
if(!empty($row)){
//简历通过审核
if ($row['state'] == 1){
if ($this->config['sy_chat_limit']==2){
$useridmsg = $this -> select_once('userid_msg',array('uid'=>$data['uid'],'fid'=>$data['comid'],'isdel'=>9),'id');
//已邀请面试
if (!empty($useridmsg)){
$return['code'] = 5;
}else{
$chat_num = $this->select_num('chat_log',array('from'=>$data['uid'],'to'=>$data['comid'],'fusertype'=>$data['usertype'],'tusertype'=>$data['tusertype']));
// 企业对个人有聊天记录，或者从招聘会来的，不再需要判断权限
if ($chat_num > 0 || intval($data['zid']) > 0){
$return['code'] = 1; //可以查看
}else{
// 是否申请了职位
if (!empty($data['jobid'])){
$useridjob = $this -> select_once('userid_job',array('uid'=>$data['uid'],'isdel'=>9,'job_id'=>$data['jobid']),'id');
} else {
$useridjob = $this -> select_once('userid_job',array('uid'=>$data['uid'],'isdel'=>9,'com_id'=>$data['comid']),'id');
}
if (!$useridjob){
$return['code'] = 9;
}else{
$return['code'] = 1;
}
}
}
}else{
$return['code'] = 1;
}
}elseif ($row['state'] == 3){
$return['code'] = 6;
}elseif ($row['state'] == 0){
$return['code'] = 7;
}elseif ($row['r_status'] == 2){
$return['code'] = 8;
}
}else{
if ($data['jobtype'] == 'lt'){
$return['code'] = 3;
}else{
$return['code'] = 2;
}
}
}
}else{
$return['code'] = 4;
}
return $return;
}
/**
* 条件聊天时，判断企业是否有查看个人简历的权限
* @param array $data
* @return mixed
*/
function comToChat($data = array('nowtype'=>''))
{
if (!empty($data['fromid'])){
if($data['fromid'] == $data['toid']){
$return['code'] = 6;
} elseif (!empty($data['nowtype']) && $data['nowtype'] != $data['fusertype']) {
$return['code'] = 7;
} else {
if ($data['fusertype'] == 2){
$company = $this->select_once('company',array('uid'=>$data['fromid']),'`r_status`');
if ($company['r_status'] == 0){
$return['code'] = 8;
}elseif ($company['r_status'] == 2){
$return['code'] = 9;
}elseif ($company['r_status'] == 3){
$return['code'] = 10;
}
}elseif ($data['fusertype'] == 3){
$lt = $this->select_once('lt_info',array('uid'=>$data['fromid']),'`r_status`');
if ($lt['r_status'] == 0){
$return['code'] = 8;
}elseif ($lt['r_status'] == 2){
$return['code'] = 9;
}elseif ($lt['r_status'] == 3){
$return['code'] = 10;
}
}
if (empty($return['code'])){
$this -> userinfo(array('uid'=>$data['fromid'],'usertype'=>$data['fusertype']));
if (in_array($this->config['sy_chat_rates'], array(2,3))){
$chat_num = $this->select_num('chat_log',array('from'=>$data['fromid'],'to'=>$data['toid'],'fusertype'=>$data['fusertype'],'tusertype'=>$data['tusertype']));
// 企业对个人有聊天记录，或者从网络招聘会来的，不再需要判断权限
if ($chat_num > 0 || intval($data['zid']) > 0){
$return['code'] = 0; //可以查看
}else{
$time = time();
//先判断是否有正在招聘中的职位
if ($data['fusertype'] == 2){
$return['code'] = 1;
$job = $this -> select_once('company_job',array('uid'=>$data['fromid'],'r_status'=>1,'status'=>0,'state'=>1),'`id`');
}elseif ($data['fusertype'] == 3){
$return['code'] = 2;
$job = $this -> select_once('lt_job',array('uid'=>$data['fromid'],'zp_status'=>0,'status'=>1,'r_status'=>array('<>',2)),'`id`');
}
//有正在招聘职位
if (!empty($job)){
$right = $this -> select_once('chat_right',array('uid'=>$data['toid'],'comid'=>$data['fromid'],'usertype'=>$data['fusertype']),'`id`');
if (!empty($right)){
$return['code'] = 0; //可以查看
}else{
//判断是否有聊天数量
if ($data['fusertype'] == 2){
$statis = $this -> select_once('company_statis',array('uid'=>$data['fromid']),'`vip_etime`,`rating_type`,`integral`,`chat_num`');
}elseif ($data['fusertype'] == 3){
$statis = $this -> select_once('lt_statis',array('uid'=>$data['fromid']),'`vip_etime`,`rating_type`,`integral`,`chat_num`');
}
$online = (int)$this->config['com_integral_online'];
$chat_name = $this->config['sy_chat_name'];
$spid = intval($data['spid']);
/* 会员信息查询 */
if(isVip($statis['vip_etime'])){
if($statis['rating_type'] == 1){ // 套餐模式
/* 收费会员聊天已用完 */
if($statis['chat_num'] == 0){ // 弹出购买提示
if(!empty($spid)){
$res['code'] = 4;
$res['msg'] = '当前账户套餐余量不足，请联系主账户增配！';
return $res;
}else{
//判断后台是否开启该单项购买
$single_can = @explode(',', $this->config['com_single_can']);
$serverOpen = 1;
if(!in_array('chat',$single_can)){
$serverOpen = 0;
}
if($online != 4){ // 非套餐消费模式
if($online == 3 && !in_array('chat', explode(',', $this->config['sy_only_price']))){ // 积分消费
$tmpJifen = $this->config['integral_chat_num'] * $this->config['integral_proportion'];
if($serverOpen){
$res['msg'] = '你的等级特权已经用完，继续'.$chat_name.'将消费 '.$tmpJifen.$this->config['integral_pricename'].'，是否继续？';
}else{
$res['msg'] = "你的等级特权已经用完，你可以购买会员！";
}
/* 积分模式，是否需要充值判断 */
$res['jifen'] = $tmpJifen;
$res['integral'] = intval($statis['integral']);
$res['pro'] = $this->config['integral_proportion'];
}else{
$tmpYuan = $this->config['integral_chat_num'];
if($serverOpen){
$res['msg'] = '你的等级特权已经用完，继续'.$chat_name.'将消费 '.$tmpYuan.' 元，是否继续?';
}else{
$res['msg'] = "你的等级特权已经用完，你可以购买会员！";
}
$res['price'] = $tmpYuan;
}
}else{ // 套餐消费模式
$res['msg'] = "你的等级特权已经用完，你可以购买会员！";
}
$res['code'] = 3;
$res['online'] = $online;
$res['uid'] = $data['toid'];
return $res;
}
}else{
//收费会员套餐数量没用完的状态,直接扣除，开始聊天
if ($data['fusertype'] == 2){
$suid = $spid ? $spid : $data['fromid'];
$this -> update_once('company_statis',array('chat_num'=>array('-',1)),array('uid'=>$suid));
}elseif ($data['fusertype'] == 3){
$this -> update_once('lt_statis',array('chat_num'=>array('-',1)),array('uid'=>$data['fromid']));
}
$this->insert_into('chat_right',array('uid'=>$data['toid'],'comid'=>$data['fromid'],'ctime'=>$time,'usertype'=>$data['fusertype']));
require_once ('log.model.php');
$LogM = new log_model($this->db, $this->def);
$LogM->addMemberLog($data['fromid'], $data['fusertype'], '使用聊天套餐,聊天对象(ID: '.$data['toid'].')', 30, 1);
$res['code'] = 0;
return $res;
}
}else if($statis['rating_type'] == 2){ //时间会员
require_once 'company.model.php';
$comM = new company_model($this->db,$this->def);
$return = $comM->comVipDayActionCheck('chat', $data['fromid']);
if ($return['status'] == 1){
$this->insert_into('chat_right',array('uid'=>$data['toid'],'comid'=>$data['fromid'],'ctime'=>$time,'usertype'=>$data['fusertype']));
require_once ('log.model.php');
$LogM = new log_model($this->db, $this->def);
$LogM->addMemberLog($data['fromid'], $data['fusertype'], '使用聊天套餐,聊天对象(ID: '.$data['toid'].')', 30, 1);
$res['code'] = 0;
}else{
$res['code'] = 4;
$res['msg'] = $return['msg'];
}
return $res;
}
}else{ // 过期会员
if(empty($spid)){
if($online != 4){ // 非套餐模式消费
if($online == 3 && !in_array('chat', explode(',', $this->config['sy_only_price']))){
$tmpJifen2 = $this->config['integral_chat_num'] * $this->config['integral_proportion'];
$res['msg'] = "你的会员已到期，请先购买会员！";
$res['jifen'] = $tmpJifen2;
$res['integral'] = intval($statis['integral']);
$res['pro'] = $this->config['integral_proportion'];
}else{
$tmpYuan2 = $this->config['integral_chat_num'];
$res['msg'] = "你的会员已到期，请先购买会员！";
$res['price'] = $tmpYuan2;
}
}else{
$res['msg'] = "你的会员已到期，你可以购买会员！";
}
$res['online'] = $online;
$res['code'] = 3;
$res['uid'] = $data['toid'];
}else {
$res['code'] = 4;
$res['msg'] = '当前账户会员已到期，请联系主账户升级！';
}
return $res;
}
}
}
}
}else{
$return['code'] = 0;
}
}
}
}else{
$return['code'] = 5;
}
return $return;
}
/**
* 设置个人头像展示
*/
private function setResumePhotoShow($data = array())
{
$resumePhoto = '';
$sexArr = array(1, 152);
if($data['defphoto']==2){
$resumePhoto = checkpic($data['photo']);
}elseif(empty($this -> config['user_pic']) || $this -> config['user_pic'] == 1){
if($data['photo'] && $data['photo_status'] == 0 && $data['phototype'] != 1){
$resumePhoto = $data['photo'];
}else{
if(in_array($data['sex'], $sexArr)){
$resumePhoto = $this -> config['sy_member_icon'];
}else{
$resumePhoto = $this -> config['sy_member_iconv'];
}
}
}elseif($this -> config['user_pic'] == 2){
if($data['photo'] && $data['photo_status'] == 0){
$resumePhoto = $data['photo'];
}else{
if(in_array($data['sex'], $sexArr)){
$resumePhoto = $this -> config['sy_member_icon'];
}else{
$resumePhoto = $this -> config['sy_member_iconv'];
}
}
}elseif($this -> config['user_pic'] == 3){
if(in_array($data['sex'], $sexArr)){
$resumePhoto = $this -> config['sy_member_icon'];
}else{
$resumePhoto = $this -> config['sy_member_iconv'];
}
}
return $resumePhoto;
}
/**
* 设置姓名展示
*/
private function setUsernameShow($data = array())
{
$resUserName = '';
if(empty($this -> config['user_name']) || $this -> config['user_name'] == 1){
if($data['nametype'] == 1){
$resUserName = $data['name'];
}else if($data['nametype'] == 2){
$resUserName = 'NO.'. $data['eid'];
}else{
if($data['sex'] == 1){
$resUserName = mb_substr($data['name'], 0, 1, 'utf-8').'先生';
}else{
$resUserName = mb_substr($data['name'], 0, 1, 'utf-8').'女士';
}
}
}elseif($this -> config['user_name'] == 2){
$resUserName = 'NO.'. $data['eid'];
}elseif($this -> config['user_name'] == 3){
if($data['sex'] == 1){
$resUserName = mb_substr($data['name'], 0, 1, 'utf-8').'先生';
}else{
$resUserName = mb_substr($data['name'], 0, 1, 'utf-8').'女士';
}
}elseif($this -> config['user_name'] == 4){
$resUserName = $data['name'];
}
if(empty($resUserName)){
$resUserName = $data['name'];
}
return $resUserName;
}
public function getPrepare($data)
{
$list = array();
// 简历
if ($data['usertype'] == 1){
$logo = 1;
$expect = $this->select_once('resume_expect',array('uid'=>$data['uid'],'defaults'=>1,'state'=>'1'),'`id`,`uid`');
}elseif ($data['usertype'] == 2 || $data['usertype'] == 3 || $data['usertype'] == 9){
if ($data['usertype'] == 9){
// usertype = 9 管理员
$logo = 1;
}else{
$logo = 2;
}
$expect = $this->select_once('resume_expect',array('uid'=>$data['toid'],'defaults'=>1),'id,`uid`');
}
if (!empty($expect)){
require_once ('resume.model.php');
$resumeM = new resume_model($this->db, $this->def);
$einfo = $resumeM -> getExpect(array('id'=>$expect['id']),array('needCache'=>1,'field'=>'`id`,`uid`,`name`,`exp`,`edu`,`city_classid`,`report`'));
$rinfo = $resumeM -> getResumeInfo(array('uid'=>$expect['uid']),array('field'=>'`name`,`sex`,`photo`,`birthday`,`description`','logo'=>$logo));
$works = $resumeM -> getResumeWorks(array('eid'=>$expect['id']));
$einfo['sex_n'] = $rinfo['sex_n'];
$einfo['age'] = $rinfo['age'];
$einfo['uname'] = $rinfo['name'];
$einfo['photo'] = $rinfo['photo'];
$einfo['description'] = mb_substr(strip_tags($rinfo['description']), 0, 60);
$einfo['works'] = $works;
$einfo['weburl'] = Url('resume',array('c'=>'show','id'=>$expect['id']));
$einfo['wapurl'] = Url('wap',array('c'=>'resume','a'=>'show','id'=>$expect['id']));
$list['expect'] = $einfo;
}
// 职位
require_once ('job.model.php');
$jobM = new job_model($this->db, $this->def);
if ($data['usertype'] == 1){
if ($data['totype'] == 2){
// 招聘中职位
$jobs = $jobM->getList(array('uid'=>$data['toid'],'state'=>1,'r_status'=>1,'status'=>0,'limit'=>50),array('chat'=>1,'field'=>'`id`,`uid`,`name`,`com_name`,`provinceid`,`cityid`,`minsalary`,`maxsalary`,`exp`,`edu`'));
$company['wapurl'] = Url('wap',array('c'=>'company','a'=>'show','id'=>$data['toid']));
$list['company'] = $company;
}
}elseif ($data['usertype'] == 2){
// 招聘中职位
$jobs = $jobM->getList(array('uid'=>$data['uid'],'state'=>1,'r_status'=>1,'status'=>0,'limit'=>50),array('chat'=>1,'field'=>'`id`,`uid`,`name`,`com_name`,`provinceid`,`cityid`,`minsalary`,`maxsalary`,`exp`,`edu`'));
}
if (!empty($jobs['list'])){
foreach ($jobs['list'] as $k=>$v){
$joblist[$v['id']] = $v;
$joblist[$v['id']]['wapurl'] = Url('wap',array('c'=>'job','a'=>'comapply','id'=>$v['id']));
$joblist[$v['id']]['weburl'] = Url('job',array('c'=>'comapply','id'=>$v['id']));
}
$list['joblist'] = $joblist;
}
// 猎头职位
if ($data['usertype'] == 3 || $data['totype'] == 3){
if ($data['totype'] == 3){
$uid = $data['toid'];
}else{
$uid = $data['uid'];
}
require_once ('lietoujob.model.php');
$ltjobM = new lietoujob_model($this->db, $this->def);
$jobs = $ltjobM->getList(array('uid'=>$uid,'status'=>1,'zp_status'=>0,'r_status'=>1));
foreach ($jobs as $k=>$v){
$joblist[$v['id']]['id'] = $v['id'];
$joblist[$v['id']]['name'] = $v['job_name'];
$joblist[$v['id']]['com_name'] = $v['com_name'];
$joblist[$v['id']]['job_salary'] = $v['salary'];
$joblist[$v['id']]['citystr'] = isset($v['citystr']) ? $v['citystr'] : '';
$joblist[$v['id']]['job_exp'] = $v['exp_n'];
$joblist[$v['id']]['job_edu'] = $v['edu_n'];
}
$list['joblist'] = $joblist;
$company['wapurl'] = Url('wap',array('c'=>'post','a'=>'headhunter','uid'=>$data['toid']));
$list['company'] = $company;
}
return $list;
}
function setMsg($data=array())
{
$return = array();
if (!empty($data['toid']) && !empty($data['tusertype'])){
// 处理uid。管理员uid与其他身份不同
$data['toid'] = str_replace('a', '', $data['toid']);
if ($data['nowid'] == $data['toid'] && $data['nowtype'] == $data['tusertype']){
$br = $this->getBeginid($data);
if ($br['beginid']){
$this -> upChatLog(array('status'=>1,'receive'=>1), array('beginid'=>$br['beginid']));
}
}else{
require_once('cookie.model.php');
$cookie = new cookie_model($this->db,$this->def);
$cookie->unset_cookie();
$return['error'] = 2;
$return['errmsg'] = '当前用户身份不符,请重新登录';
}
}else{
$return['error'] = 1;
$return['errmsg'] = '请先登录';
}
return $return;
}
function setVoiceStatus($data=array())
{
$return = array();
if (!empty($data['toid']) && !empty($data['tusertype'])){
if ($data['nowid'] == $data['toid'] && $data['nowtype'] == $data['tusertype']){
// 处理uid。管理员uid与其他身份不同
$data['toid'] = str_replace('a', '', $data['toid']);
$br = $this->getBeginid($data);
if ($br['beginid'] && $data['id']){
$where = array('beginid'=>$br['beginid'],'id'=>$data['id']);
$vdata = array('voicestatus'=>1);
$this -> upChatLog($vdata, $where);
}else{
$return['error'] = 2;
$return['errmsg'] = '参数错误';
}
}else{
require_once('cookie.model.php');
$cookie = new cookie_model($this->db,$this->def);
$cookie->unset_cookie();
$return['error'] = 2;
$return['errmsg'] = '当前用户身份不符,请重新登录';
}
}else{
$return['error'] = 1;
$return['errmsg'] = '请先登录';
}
return $return;
}
/**
* 添加条件直聊下可直聊对象
*/
public function addChatRight($data)
{
if (!empty($data)){
$nid = $this -> insert_into('chat_right',$data);
}
return $nid;
}
/**
* 条件直聊下查询聊天对象是否可直聊
*/
function getChatRight($where = array(), $data = array())
{
$row = $this->select_once('chat_right',$where);
return $row;
}
/**
* 用户不在线，收到消息，提醒用户
* @param array $data
*/
function setUnSend($data = array())
{
//当前身份类型与接收消息身份类型一致时，才需要处理
if ($data['fusertype'] == $data['nowtype']){
// 处理uid。管理员uid与其他身份不同
$data['toid'] = str_replace('a', '', $data['toid']);
$br = $this->getBeginid($data);
if ($br['beginid']){
$time = time();
$today = strtotime('today');
$unSend = $this->getChatLog(array('beginid'=>$br['beginid'],'remindTime'=>array('<>',''),'orderby'=>'`id`,DESC'),array('field'=>'`id`,`remindTime`'));
$this -> upChatLog(array('remindTime'=>$time), array('beginid'=>$br['beginid'],'limit'=>1,'orderby'=>'`id`,DESC'));
// app推送和微信模板提醒，每4小时一次
if (($unSend['remindTime'] && $unSend['remindTime']< ($time - 2400)) || empty($unSend['remindTime']) && $data['tusertype'] != 9){
// app推送
include_once ('push.model.php');
$pushM = new push_model($this->db, $this->def);
$pushM->pushMsg('chat',
array(
'fuid' => $data['fromid'],
'puser' => $data['toid'],
'tid' => 0,
'title' => $this->config['sy_webname'],
'content' => '您收到新的'.$this->config['sy_chat_name'].'信息，请注意查看！',
)
);
$member = $this->select_once('member',array('uid'=>$data['toid']),'`uid`,`usertype`,`username`,`moblie`,`wxid`,`wxopenid`');
// 微信模板通知
if (!empty($member['wxid'])){
// 取得聊天双方uid
if ($data['tusertype'] == 1){
$userid = $data['toid'];
if ($data['fusertype'] == 2){
$comid = $data['fromid'];
}elseif ($data['fusertype'] == 3){
$ltid = $data['fromid'];
}
}else{
$userid = $data['fromid'];
if ($data['tusertype'] == 2){
$comid = $data['toid'];
}elseif ($data['tusertype'] == 3){
$ltid = $data['toid'];
}
}
//取得聊天沟通意向
$jobChat = $this->getChatLog(array('beginid'=>$br['beginid'],'content'=>array('like','jobid'),'orderby'=>'`id`,DESC'),array('field'=>'`content`'));
if (!empty($jobChat)){
$jobid = trim(str_replace('jobid=', '',$jobChat['content']));
if (isset($comid)){
$job = $this->select_once('company_job',array('id'=>$jobid),'`name`');
$expect = mb_substr($job['name'], 0,20,'utf-8');
}elseif (isset($ltid)){
$job = $this->select_once('lt_job',array('id'=>$jobid),'`job_name`');
$expect = mb_substr($job['job_name'], 0,20,'utf-8');
}
}else{
$jl = $this->select_once('resume_expect',array('uid'=>$userid,'defaults'=>1),'`name`');
$expect = $jl['name'];
}
// 取得姓名
if (!empty($userid)){
$qyid = isset($comid) ? $comid : $ltid;
// 聊天对象是个人，则发送方为企业/猎头
if ($data['tusertype'] == 1){
$chat_member = $this->select_once('chat_member',array('uid'=>$qyid,'usertype'=>$data['fusertype']),'`linkman`');
$name = $chat_member['linkman'];
}else{
$resume = $this->select_once('resume',array('uid'=>$userid),'`name`,`sex`,`nametype`,`def_job`');
$down = $this->select_num('down_resume',array('uid'=>$userid,'comid'=>$qyid));
if ($down > 0){
$name = $resume['name'];
}else{
$nameArr = array(
'name' => $resume['name'],
'sex' => $resume['sex'],
'nametype' => $resume['nametype'],
'eid' => $resume['def_job']
);
$name = $this->setUsernameShow($nameArr);
}
}
}
if (!empty($name) && !empty($expect)){
include_once ('weixin.model.php');
$weixinM = new weixin_model($this->db, $this->def);
$sendInfo['wxid'] = $member['wxid'];
$sendInfo['uid'] = $member['uid'];
$sendInfo['usertype']= $member['usertype'];
$sendInfo['name'] = $name;
$sendInfo['expect'] = $expect;
$sendInfo['time'] = date('Y-m-d H:i:s');
$weixinM->sendWxChat($sendInfo);
}
}
}
if (($unSend['remindTime'] && $unSend['remindTime']<$today) || empty($unSend['remindTime'])){
// 短信提醒开启时，发送短信提醒，每天只1次
$msg = $this->select_once('moblie_msg',array('uid'=>$data['toid'],'content'=>array('like',$this->config['sy_chat_name']),'orderby'=>'id'),'`ctime`');
if ($msg['ctime'] < $today){
if (empty($member)){
$member = $this->select_once('member',array('uid'=>$data['toid']),'`uid`,`username`,`moblie`');
}
if ($this->config['sy_msg_chat'] == 1){
$msgData = array(
'uid' => $member['uid'],
'username' => $member['username'],
'mobile' => $member['moblie'],
'date' => date('Y-m-d/H:i:s'),
'chat_name' => $this->config['sy_chat_name'],
'type' => 'chat',
'port' => $data['port']
);
require_once ('notice.model.php');
$noticeM = new notice_model($this->db, $this->def);
$result = $noticeM -> sendSMSType($msgData);
}
}
}
}
}
}
/**
* 从聊天平台获取token
*/
function chatToken($uid = ''){
$member = $this->select_once('chat_member',array('uid'=>$uid),'`expires_in`,`token`');
// token未过期的不用重新获取
if ((intval($member['expires_in']) - 200) < time()){
$return = $this->chatRequest($uid);
}else{
$return = array('token'=>$member['token'],'expires_in'=>$member['expires_in']);
}
return $return;
}
/**
* 请求聊天服务器
*/
function chatRequest($uid = ''){
$return = array('error'=>'请求异常');
$protocol = getprotocol($this->config['sy_weburl']);
$url = $protocol . 'liaotian.phpyun.com/chattoken.php';
$post = array(
'appkey' => trim($this->config['sy_chat_appkey']),
'appsecret' => trim($this->config['sy_chat_appsecret']),
'suid' => $uid,
'version' => '510'
);
if (extension_loaded('curl')){
$response = CurlPost($url, $post);
$result = json_decode($response,true);
if(!empty($result['token'])){
$this->update_once('chat_member',array('token'=>$result['token'],'expires_in'=>$result['expires_in']),array('uid'=>$uid));
$return = array('token'=>$result['token'],'expires_in'=>$result['expires_in']);
}else{
$return = array('error'=>$result['error']);
}
}else{
$return = array('error'=>'不支持curl函数');
}
return $return;
}
/**
* 查询单条聊天用户关系
*/
function getFriend($where = array())
{
if (!empty($where)){
$row = $this->select_once('chat_friend',$where);
return $row;
}
}
/**
* 查询多条聊天用户关系
*/
function getFriendList($where = array(),$data = array('utype'=>''))
{
if (!empty($where)){
$list = $this->select_all('chat_friend',$where);
if ($data['utype'] == 'admin'){
$uids = $cuids = array();
foreach($list as $val){
$uids[] = $val['uid'];
$cuids[] = $val['fid'];
}
$all = array_merge($uids,$cuids);
$alluid = array_unique($all);
$member = $this->select_all('member',array('uid'=>array('in',pylode(',', $alluid))),'`uid`,`username`,`usertype`');
$List = $this->getDataList($member);
if(!empty($List)){
foreach($list as $k=>$v){
foreach($List as $val){
if($val['uid'] == $v['uid']){
$username = $val['username'];
if ($val['usertype'] == 1){
$username .= '(个人)';
}elseif ($val['usertype'] == 2){
$username .= '(企业)';
}
$list[$k]['username'] = $username;
$list[$k]['countname'] = $val['countname'];
}
if($val['uid'] == $v['fid']){
$list[$k]['rusername'] = $val['username'];
$list[$k]['rcountname'] = $val['countname'];
}
}
}
}
}
return $list;
}
}
//后台个人会员列表处理数据
private function getDataList($List){
foreach($List as $v){
if($v['uid']){
if($v['usertype']=='1'){
$useruids[] = $v['uid'];
}
if($v['usertype']=='2'){
if($v['pid']){
$comuids[] = $v['pid'];
}else{
$comuids[] = $v['uid'];
}
}
if($v['usertype']=='3'){
$ltuids[] = $v['uid'];
}
if($v['usertype']=='4'){
$pxuids[] = $v['uid'];
}
}
}
$countname = array();
if(!empty($useruids)){
$resumes = $this -> select_all('resume',array('uid'=>array('in',pylode(',', $useruids))),'`uid`,`name`,`def_job`');
foreach($resumes as $rk=>$rv){
$countname[$rv['uid']] = $rv['name'];
}
}
if(!empty($comuids)){
$coms = $this -> select_all('company',array('uid'=>array('in',pylode(',', $comuids))),'`uid`,`name`');
foreach($coms as $ck=>$cv){
$countname[$cv['uid']] = $cv['name'];
}
}
if(!empty($ltuids)){
$lts = $this -> select_all('lt_info',array('uid'=>array('in',pylode(',', $ltuids))),'`uid`,`com_name`');
foreach($lts as $lk=>$lv){
$countname[$lv['uid']] = $lv['com_name'];
}
}
if(!empty($pxuids)){
$pxs = $this -> select_all('px_train',array('uid'=>array('in',pylode(',', $pxuids))),'`uid`,`name`');
foreach($pxs as $pk=>$pv){
$countname[$pv['uid']] = $pv['name'];
}
}
foreach($List as $k=>$v){
if(!empty($resumes)){
foreach($resumes as $val){
if($val['uid']==$v['uid']){
$List[$k]['name'] = $val['name'];
$List[$k]['def_job'] = $val['def_job'];
}
}
}
if(!empty($countname)){
if($v['usertype']==2 && $v['pid']){
$uid = $v['pid'];
}else{
$uid = $v['uid'];
}
$List[$k]['countname'] = $countname[$uid];
}
}
return $List;
}
/**
* 添加聊天用户关系
*/
function addFriend($data = array())
{
if (!empty($data)){
$nid = $this->insert_into('chat_friend',$data);
return $nid;
}
}
/**
* 修改聊天用户关系
*/
function upFriend($where = array(), $data = array())
{
if (!empty($where) && !empty($data)){
$nid = $this->update_once('chat_friend',$data, $where);
return $nid;
}
}
/**
* 删除聊天用户关系
*/
function delFriend($where = array())
{
if (!empty($where)){
$this->delete_all('chat_friend', $where, '');
}
}
/**
* 获取互换电话、微信请求情况
*/
function getFriendCan($data=array()){
$uid = $data['uid'];
$usertype = $data['usertype'];
$fid = $data['fid'];
$fusertype= $data['fusertype'];
$type = $data['type'];
$can = 0;
if($uid && $usertype && $fid && $fusertype && $type){
$where1 = array('uid'=>$uid,'fid'=>$fid,'usertype'=>$usertype,'fusertype'=>$fusertype);
$where2 = array('uid'=>$fid,'fid'=>$uid,'usertype'=>$fusertype,'fusertype'=>$usertype);
$chatfriend1 = $this->getFriend($where1);
$chatfriend2 = $this->getFriend($where2);
if($chatfriend1[$type]==1 && $chatfriend2[$type]==1){
$can = 1;//同意互换
}else{
if($chatfriend1[$type]==3){
$can = 3;//发出请求等待对方操作
}else{
$can = 0;//尚未请求
}
}
}
return $can;
}
/**
* 发送互换电话、微信请求
*/
function checkCanAsk($data = array())
{
$uid = $data['uid'];
$usertype = $data['usertype'];
$toid = $data['toid'];
$totype = $data['totype'];
$ask = $data['ask'];
$askvalue = $data['askvalue'];
if ($askvalue) {
$can = $this->getFriendCan(array('type'=>$ask,'uid'=>$uid,'usertype'=>$usertype,'fid'=>$toid,'fusertype'=>$totype));
$return['error'] = 9;
$return['can'] = $can;
if ($can != 3) {
if ($ask == 'tel' && CheckMobile($askvalue) == false) {
$return['error'] = 8;
$return['msg'] = '手机号格式错误';
} else {
// 成功发送互换请求
$nid = $this->upFriend(array('uid'=>$uid,'usertype'=>$usertype,'fid'=>$toid,'fusertype'=>$totype), array($ask . '_tem' => $askvalue));
// 发送微信模板消息
if ($ask == 'wx'){
$title = '微信号';
}else{
$title = '电话';
}
$member = $this->select_once('member',array('uid'=>$toid),'`uid`,`wxid`,`usertype`');
// 查询发送方信息
include_once('userinfo.model.php');
$userinfoM = new userinfo_model($this->db, $this->def);
if ($usertype == 1){
$field = '`name`,`sex`';
}elseif ($usertype==2){
$field = '`name`';
}elseif ($usertype==3){
$field = '`realname` AS `name`';
}
$userinfo = $userinfoM -> getUserInfo(array('uid'=>$uid),array('usertype'=>$usertype,'field'=>$field));
// 保存微信号
if ($ask == 'wx'){
$userinfoM->UpdateUserInfo(array('usertype'=>$usertype,'post'=>array('wxid'=>$askvalue)), array('uid'=>$uid));
}
if ($usertype == 1){
$name = $userinfo['sex'] == 1 ? mb_substr($userinfo['name'], 0, 1, 'utf-8').'先生' : mb_substr($userinfo['name'], 0, 1, 'utf-8').'女士';
}else{
$name = $userinfo['name'];
}
$sendData = array(
'title' => '您有新的互换'.$title.'请求！',
'name' => $name,
'ask' => $title,
'asktime' => date("Y年m月d日 H:i"),
'url' => Url('wap',array('c'=>'chat','id'=>$uid,'type'=>$usertype,'wxuid'=>$toid)),
'wxid' => $member['wxid'],
'uid' => $member['uid'],
'usertype' => $member['usertype']
);
require_once ('weixin.model.php');
$weixinM = new weixin_model($this->db, $this->def);
$weixinM->sendWxChatEx($sendData);
}
} else {
$return['error'] = 7;
$return['msg'] = '请勿重复申请';
}
} else {
if ($ask == 'tel') {
$asktype = '手机号';
} else if ($ask == 'wx') {
$asktype = '微信号';
}
$return['error'] = 8;
$return['msg'] = '请填写' . $asktype;
}
return $return;
}
/**
* 同意互换微信、电话
*/
function confirmAsk($data){
$uid = $data['uid'];
$usertype = $data['usertype'];
$tuid = $data['toid'];
$totype = $data['totype'];
$ask = $data['ask'];
$askvalue = $data['askvalue'];
$chatid = $data['chatid'];
if($tuid && $totype && $usertype && $uid && $ask){
if($ask=='tel' && CheckMobile($askvalue) == false){
$return['error'] = 8;
$return['msg'] = '手机号格式错误';
}else{
$this->upFriend(array('uid'=>$uid,'usertype'=>$usertype,'fid'=>$tuid,'fusertype'=>$totype),array($ask=>1,$ask.'_tem'=>$askvalue));
$this->upFriend(array('fid'=>$uid,'usertype'=>$usertype,'uid'=>$tuid,'usertype'=>$totype),array($ask=>1));
$where = array('uid'=>$tuid,'fid'=>$uid,'usertype'=>$totype,'fusertype'=>$usertype);
$chatfriend = $this->getFriend($where);
if(!$chatid){
// 获取聊天专用id
$chatLogWhere = array(
'beginid' => $chatfriend['beginid'],
'msgtype' => 'ask',
'content' => 'ask='.$ask,
'orderby' => 'id,desc'
);
$chatlog = $this->getChatLog($chatLogWhere);
$chatLogWhere = array('id'=>$chatlog['id'],'beginid'=>$chatfriend['beginid']);
}else{
$chatLogWhere = array('id'=>$chatid,'beginid'=>$chatfriend['beginid']);
}
$this->upChatLog(array('askstatus'=>1),$chatLogWhere);
// 保存微信号
if ($ask == 'wx'){
include_once('userinfo.model.php');
$userinfoM = new userinfo_model($this->db, $this->def);
$userinfoM->UpdateUserInfo(array('usertype'=>$usertype,'post'=>array('wxid'=>$askvalue)), array('uid'=>$uid));
}
$return['to'.$ask] = $chatfriend[$ask.'_tem'];
$return['error'] = 1;
}
}else{
$return['error'] =0;
}
return $return;
}
/**
* 拒绝互换微信、电话
*/
function refuseAsk($data){
$uid = $data['uid'];
$usertype = $data['usertype'];
$tuid = $data['toid'];
$totype = $data['totype'];
$ask = $data['ask'];
$chatid = $data['chatid'];
if($tuid && $totype && $usertype && $uid && $ask){
$nid = $this->upFriend(array('uid'=>$uid,'usertype'=>$usertype,'fid'=>$tuid,'fusertype'=>$totype),array($ask=>2));
$this->upFriend(array('uid'=>$tuid,'usertype'=>$totype,'fid'=>$uid,'fusertype'=>$usertype),array($ask=>0));
$where = array('uid'=>$tuid,'fid'=>$uid,'usertype'=>$totype,'fusertype'=>$usertype);
$chatfriend = $this->getFriend($where);
if(!$chatid){
// 获取聊天专用id
$chatLogWhere = array(
'beginid' => $chatfriend['beginid'],
'msgtype' => 'ask',
'content' => 'ask='.$ask,
'orderby' => 'id,desc'
);
$chatlog = $this->getChatLog($chatLogWhere);
$chatLogWhere = array('id'=>$chatlog['id'],'beginid'=>$chatfriend['beginid']);
}else{
$chatLogWhere = array('id'=>$chatid,'beginid'=>$chatfriend['beginid']);
}
$this->upChatLog(array('askstatus'=>2),$chatLogWhere);
$return['error'] =1;
}else{
$return['error'] =2;
}
return $return;
}
/**
* 检查时间戳，如与服务器时间差别太大，按服务器时间来
*/
private function checkTime($time){
$now = time();
if ((round($time/1000)-300 > $now) || (round($time/1000)+300 < $now)){
return $now.'000';
}else{
return $time;
}
}
function addXjhchatBlack($data = array())
{
$xid = (int)$data['xjhid'];
$fuid = $data['fuid'];
$black = $this->select_once('xjhlive_black',array('uid'=>$fuid,'xid'=>$xid));
if(!empty($black)){
$return['errcode'] = 8;
$return['msg'] = "该用户已被禁言！";
return $return;
}
$adata = array(
'uid' => $fuid,
'usertype' => $data['usertype'],
'xid' => $xid,
'ctime' => time()
);
$nid = $this->insert_into('xjhlive_black',$adata);
if($nid){
$return['errcode'] = 9;
$return['msg'] = "用户已被禁言！";
}else{
$return['errcode'] = 8;
$return['msg'] = "操作失败,请重试！";
}
return $return;
}
function getXjhchatBlackNum($where = array(),$data=array()){
$num = 0;
if(!empty($where)){
$num = $this->select_num("xjhlive_black",$where);
}
return $num;
}
function getXjhchatBlack($where = array(), $data = array())
{
if (!empty($where) ){
$row = $this->select_once('xjhlive_black',$where);
return $row;
}
}
function getXjhchatBlackList($where = array(), $data = array())
{
if (!empty($where) ){
$List = $this->select_all('xjhlive_black',$where);
if(!empty($List)){
$uid = $authid = $wxid = array();
foreach($List as $v){
if (!empty($v['uid'])){
if ($v['usertype'] == 1 || $v['usertype'] == 2 || $v['usertype'] == 3){
$uid[] = $v['uid'];
}
}
}
if (!empty($uid)){
$member = $this->select_all('member',array('uid'=>array('in',pylode(',',$uid))),'`uid`,`username`,`moblie`');
$resume = $this->select_all('resume',array('uid'=>array('in',pylode(',',$uid))),'`uid`,`name`');
$company = $this->select_all('company',array('uid'=>array('in',pylode(',',$uid))),'`uid`,`name`');
$lietou = $this->select_all('lt_info',array('uid'=>array('in',pylode(',',$uid))),'`uid`,`realname`');
}
foreach($List as $k => $v){
$List[$k]['ctime_n'] = date('Y-m-d H:i',$v['ctime']);
$List[$k]['username'] = '';
$List[$k]['moblie'] = '';
if (!empty($member)){
foreach($member as $val){
if($v['uid'] == $val['uid']){
$List[$k]['username'] = $val['username'];
$List[$k]['moblie'] = $val['moblie'];
}
}
}
if (!empty($resume)){
foreach($resume as $val){
if($v['uid'] == $val['uid']){
$List[$k]['name'] = $val['name'].'[个人]';
}
}
}
if (!empty($company)){
foreach($company as $val){
if($v['uid'] == $val['uid']){
$List[$k]['name'] = $val['name'].'[企业]';
}
}
}
if (!empty($lietou)){
foreach($lietou as $val){
if($v['uid'] == $val['uid']){
$List[$k]['name'] = $val['realname'].'[猎头]';
}
}
}
}
}
return $List;
}
}
function delXjhchatBlack($id = null , $data = array()) {
if(!empty($id)|| $data['where']){
if(is_array($id)){
$ids = $id;
$return['layertype'] = 1;
}else{
$ids = @explode(',', $id);
$return['layertype'] = 0;
}
$id = pylode(',', $ids);
if(!empty($id)){
$return['id'] = $this->delete_all('xjhlive_black',array('id'=>array('in',$id)),'');
}elseif($data['where']){
$return['id'] = $this->delete_all('xjhlive_black',$data['where'],'');
}
$return['msg'] = '禁言';
$return['errcode'] = $return['id'] ? '9' :'8';
$return['msg'] = $return['id'] ? $return['msg'].'解除成功！' : $return['msg'].'解除失败！';
}else{
$return['msg'] = '请选择您要操作的数据！';
$return['errcode'] = 8;
}
return $return;
}
function delXjhchat($id = null , $data = array()) {
if(!empty($id)){
if(is_array($id)){
$ids = $id;
$return['layertype'] = 1;
}else{
$ids = @explode(',', $id);
$return['layertype'] = 0;
}
$id = pylode(',', $ids);
if($data['uid']){
$return['id'] = $this -> delete_all('xjhlive_chat', array('id' => array('in', $id), 'uid' => $data['uid']), '');
}else{
$return['id'] = $this->delete_all('xjhlive_chat', array('id' => array('in', $id)), '');
}
$return['msg'] = '聊天消息';
$return['errcode'] = $return['id'] ? '9' :'8';
$return['msg'] = $return['id'] ? $return['msg'].'删除成功！' : $return['msg'].'删除失败！';
}else{
$return['msg'] = '请选择您要删除的数据！';
$return['errcode'] = 8;
}
return $return;
}
public function getChatNum($whereData = array()){
return $this->select_num('xjhlive_chat', $whereData);
}
/**
* 宣讲会聊天记录
* $data['fdata'] 是否需要消息发送人的数据
*/
public function getChatList($whereData = array(), $data = array())
{
//非第一页的，要按照原有的聊天记录查询，按新聊天记录会查询出重复内容
if (!empty($data['lastid'])){
$whereData['id'] = array('<=',$data['lastid']);
}
$field = empty($data['field']) ? '*' : $data['field'];
$List = $this->select_all('xjhlive_chat', $whereData, $field);
if(!empty($List)){
$euidarr = array();//个人发送人uid
$cuidarr = array();//企业发送人uid
$luidarr = array();//猎头发送人uid
foreach($List as $key=>$val){
if($val['fusertype']==1){
if(!in_array($val['fuid'],$euidarr)){
$euidarr[] = $val['fuid'];
}
}else if($val['fusertype']==2){
if(!in_array($val['fuid'],$cuidarr)){
$cuidarr[] = $val['fuid'];
}
}else if((int)$val['fusertype']==3){
if(!in_array($val['fuid'],$luidarr)){
$luidarr[] = $val['fuid'];
}
}
}
$mid = array_merge($euidarr, $cuidarr, $luidarr);
$mid = array_unique($mid);
$xjhid = $whereData['xid'];
//获取发送人相关信息
if($data['fdata']){
if(!empty($euidarr)){
$allresumes = $this->select_all('resume',array('uid'=>array('in',pylode(',',$euidarr))),'`name`,`photo`,`phototype`,`sex`,`telphone`,`uid`');
}
if(!empty($cuidarr)){
$allcoms = $this->select_all('company',array('uid'=>array('in',pylode(',',$cuidarr))),'`name`,`shortname`,`logo`,`linkman`,`linktel`,`uid`');
}
if(!empty($luidarr)){
$alllts = $this->select_all('lt_info',array('uid'=>array('in',pylode(',',$luidarr))),'`realname`,`photo`,`moblie`,`uid`');
}
$member = $this->select_all('member',array('uid'=>array('in',pylode(',',$mid))),'`username`,`uid`');
$user = array();
$telphone = '';
if(!empty($allresumes)){
foreach($allresumes as $rk=>$rv){
if($rv['name']){
if (isset($data['utype']) && $data['utype'] == 'admin'){
$rname = $rv['name'];
}else{
$rname = $rv['sex'] == 1 ? mb_substr($rv['name'], 0, 1, 'utf-8').'先生' : mb_substr($rv['name'], 0, 1, 'utf-8').'女士';
}
}else{
$rname = substr_replace($rv['telphone'],'****',4,4);
}
$user[$rv['uid']]['nickname'] = $rname;
$icon = $rv['sex'] == 1 ? $this->config['sy_member_icon'] : $this->config['sy_member_iconv'];
if($rv['phototype']==1){
$rv['photo'] = '';
}
$user[$rv['uid']]['avatar'] = checkpic($rv['photo'],$icon);
foreach($member as $nk=>$nv){
if($nv['uid'] == $rv['uid']){
$user[$rv['uid']]['username'] = $nv['username'];
}
}
}
}
if(!empty($allcoms)){
foreach($allcoms as $ck=>$cv){
$cname = $cv['name'];
$telphone = substr_replace($cv['linktel'],'****',4,4);
$user[$cv['uid']]['nickname'] = !empty($cv['shortname']) ? $cv['shortname'] : ($cname?$cname:$telphone);
$user[$cv['uid']]['avatar'] = checkpic($cv['logo'],$this->config['sy_unit_icon']);
foreach($member as $nk=>$nv){
if($nv['uid'] == $cv['uid']){
$user[$cv['uid']]['username'] = $nv['username'];
}
}
}
}
if(!empty($alllts)){
foreach($alllts as $lk=>$lv){
$cname = $lv['realname'];
$telphone = substr_replace($lv['moblie'],'****',4,4);
$user[$lv['uid']]['nickname'] = $cname?$cname:$telphone;
$user[$lv['uid']]['avatar'] = checkpic($lv['photo'],$this->config['sy_lt_icon']);
foreach($member as $nk=>$nv){
if($nv['uid'] == $lv['uid']){
$user[$lv['uid']]['username'] = $nv['username'];
}
}
}
}
}
//获取发送人相关信息 end
$xjhList = $this->select_all('xjhlive',array('id'=>$xjhid), '`id`,`name`');
if($data['sensitive']){
include(LIB_PATH.'sensitive.class.php');
$instance = Sensitive::getInstance();
}
if (isset($data['utype']) && $data['utype'] == 'admin'){
$blacklist = $this->select_all('xjhlive_black', array('xid'=>$xjhid),'`uid`,`usertype`');
}
foreach($List as $key=>$val){
foreach($xjhList as $k=>$v){
if($val['xid'] == $v['id']){
$List[$key]['xjh_name'] = $v['name'];
}
}
$List[$key]['sendTime'] = ceil($val['sendTime']/1000);
$List[$key]['user'] = $user[$val['fuid']];
if($data['sensitive'] && $instance){//过滤敏感词
$content = $val['content'];
if(file_exists(DATA_PATH.'sensitive/xjhword.txt')){
$instance->addSensitiveWords(DATA_PATH.'sensitive/xjhword.txt');
$content = $instance->execFilter($content);
}
$List[$key]['content'] = $content;
}
if (!empty($blacklist)){
foreach ($blacklist as $bv){
if ($bv['uid'] == $val['fuid'] && $bv['usertype'] == $val['fusertype']){
$List[$key]['black'] = 1;
}
}
}
}
}
return $List;
}
public function getXjhChat($whereData = array(), $data = array())
{
$field = empty($data['field']) ? '*' : $data['field'];
if(!empty($whereData)){
$row = $this->select_once('xjhlive_chat', $whereData, $field);
}
return $row;
}
function xhjChat($data = array()){
if (! empty($data['fuid'])) {
$content = $data['content'] ? $data['content'] :'';
$fuid = $data['fuid'];
$usertype = (int)$data['fusertype'];
$log['fuid'] = $fuid;
$log['ip'] = $data['ip'];
$log['fusertype'] = $usertype;
$log['content'] = $content;
$log['sendTime'] = $this->checkTime($data['timestamp']);
$log['msgtype'] = $data['msgtype'];
$log['xid'] = $data['xjhid'];
$nid = $this->addXjhchat($log);
$return['error'] = $nid ? 0 : - 1;
} else {
$return['error'] = 1;
$return['errmsg'] = '请先登录';
}
return $return;
}
public function addXjhchat($data=array()){
$nid = $this -> insert_into('xjhlive_chat', $data);
return $nid;
}
/**
* 保存常用语
*/
public function addChatUseful($data=array()){
if (!isset($data['utype'])){
if (empty($data['uid']) || empty($data['usertype'])){
return array('msg'=>'请先登录', 'errcode'=>8);
}
}
$nid = $this->insert_into('chat_useful', $data);
if (isset($nid)){
$res = array('msg'=>'添加成功', 'errcode'=>9,'id'=>$nid);
}else{
$res = array('msg'=>'添加失败', 'errcode'=>8);
}
return $res;
}
/**
* 后台自定义常用语，添加
*/
public function addChatUsefulSet($data=array()){
$nid = $this->insert_into('chat_useful_set', $data);
if (isset($nid)){
$res = array('msg'=>'添加成功', 'errcode'=>9);
}else{
$res = array('msg'=>'添加失败', 'errcode'=>8);
}
return $res;
}
/**
* 后台自定义常用语，修改
*/
function upChatUsefulSet($where=array(),$data=array()){
$nid = $this->update_once('chat_useful_set', $data, $where);
if (isset($nid)){
$res = array('msg'=>'修改成功', 'errcode'=>9);
}else{
$res = array('msg'=>'修改失败', 'errcode'=>8);
}
return $res;
}
/**
* 后台自定义常用语，查询
*/
function getUsefulSet($where=array(),$data=array()){
$row = $this -> select_once('chat_useful_set', $where);
return $row;
}
/**
* 后台自定义常用语，查询列表
*/
function getUsefulSetList($where=array(),$data=array()){
$field = empty($data['field']) ? '*' : $data['field'];
$List = $this -> select_all('chat_useful_set', $where, $field);
return $List;
}
/**
* 后台自定义常用语，删除
*/
function delUsefulSet($where=array(),$data=array()){
$nid = $this->delete_all('chat_useful_set', $where);
if (isset($nid)){
$res = array('msg'=>'删除成功', 'errcode'=>9);
}else{
$res = array('msg'=>'删除失败', 'errcode'=>8);
}
return $res;
}
/**
* 修改常用语
*/
public function upChatUseful($where=array(),$data=array()){
if (!isset($data['utype'])){
if (empty($data['uid']) || empty($data['usertype'])){
return array('msg'=>'请先登录', 'errcode'=>8);
}
$where['uid'] = $data['uid'];
$where['usertype'] = $data['usertype'];
}
$nid = $this->update_once('chat_useful', $data, $where);
if (isset($nid)){
$res = array('msg'=>'修改成功', 'errcode'=>9);
}else{
$res = array('msg'=>'修改失败', 'errcode'=>8);
}
return $res;
}
/**
* 常用语列表
*/
public function getChatUsefulList($where = array(), $data = array()){
$rows = $this->select_all('chat_useful', $where);
if (!empty($rows)){
// 后台列表用数据
if (isset($data['admin'])){
$mid = $gid = $cid = $lid = array();
foreach ($rows as $v){
if (!in_array($mid, $v['uid'])){
$mid[] = $v['uid'];
}
if ($v['usertype'] == 1 && !in_array($gid, $v['uid'])){
$gid[] = $v['uid'];
}elseif ($v['usertype'] == 2 && !in_array($cid, $v['uid'])){
$cid[] = $v['uid'];
}elseif ($v['usertype'] == 3 && !in_array($lid, $v['uid'])){
$lid[] = $v['uid'];
}
}
$member = $this->select_all('member', array('uid'=>array('in',pylode(',', $mid))), 'uid,username');
if (!empty($gid)){
$user = $this->select_all('resume', array('uid'=>array('in',pylode(',', $mid))), 'uid,name');
}
if (!empty($cid)){
$com = $this->select_all('company', array('uid'=>array('in',pylode(',', $cid))), 'uid,name');
}
if (!empty($lid)){
$lt = $this->select_all('lt_info', array('uid'=>array('in',pylode(',', $lid))), 'uid,`realname` AS `name`');
}
foreach ($rows as $k=>$v){
$rows[$k]['username'] = '系统';
foreach ($member as $mv){
if ($v['uid'] == $mv['uid']){
$rows[$k]['username'] = $mv['username'];
}
}
if (!empty($user)){
foreach ($user as $uv){
if ($v['uid'] == $uv['uid']){
$rows[$k]['uname'] = $uv['name'].' [个人]';
}
}
}
if (!empty($com)){
foreach ($com as $cv){
if ($v['uid'] == $cv['uid']){
$rows[$k]['uname'] = $cv['name'].' [企业]';
}
}
}
if (!empty($lt)){
foreach ($lt as $lv){
if ($v['uid'] == $lv['uid']){
$rows[$k]['uname'] = $lv['name'].' [企业]';
}
}
}
}
}
}
//用户使用时，混合后台定义及用户自定义
if (isset($data['utype']) && !empty($where['uid']) && !empty($where['usertype'])){
$type = $where['usertype'] == 1 ? 2 : 1;
$list = $this->getUsefulSetList(array('type'=>$type, 'orderby'=>'sort'));
$useful_list = array();
foreach ($rows as $key => $value) {
$useful = array();
if($value['content']){
$useful['id'] = $value['id'];
$useful['content'] = $value['content'];
$useful['uid'] = $value['uid'];
$useful_list[] = $useful;
}
}
foreach ($list as $k => $v) {
$useful = array();
if($v['content']){
$useful['id'] = $v['id'];
$useful['content'] = $v['content'];
$useful_list[] = $useful;
}
}
$rows = $useful_list;
}
return $rows;
}
/**
* 删除常用语
*/
public function delChatUseful($where=array(),$data=array()){
if (!isset($data['utype'])){
if (empty($where['uid']) || empty($where['usertype'])){
return array('msg'=>'请先登录', 'errcode'=>8);
}
}
$nid = $this->delete_all('chat_useful', $where,'');
if (isset($nid)){
$res = array('msg'=>'删除成功', 'errcode'=>9);
}else{
$res = array('msg'=>'删除失败', 'errcode'=>8);
}
return $res;
}
}
?>