<?php
|
|
class msg_model extends model{
|
/**
|
* @desc 引用log类，添加用户日志
|
*/
|
private function addMemberLog($uid,$usertype,$content,$opera='',$type='') {
|
|
require_once ('log.model.php');
|
|
$LogM = new log_model($this->db, $this->def);
|
|
return $LogM -> addMemberLog($uid, $usertype, $content, $opera, $type);
|
|
}
|
/**
|
* 获取求职咨询列表
|
* $whereData 查询条件
|
* $data 自定义处理数组
|
*/
|
|
public function getList($whereData,$data=array()){
|
|
$ListNew = array();
|
|
$List = $this -> select_all('msg',$whereData);
|
|
$rows = $this -> select_all('down_resume',array('comid'=>$whereData['job_uid']),'`uid`');
|
|
$uids = array();
|
foreach ($rows as $v) {
|
$uids[] = $v['uid'];
|
}
|
|
if(!empty( $List )){
|
|
if(is_array($List)&&$List){
|
|
$uid = array();
|
|
foreach($List as $v){
|
|
$uid[] = $v['uid'];
|
}
|
$resume = $this -> select_all('resume_expect',array('uid' => array('in', pylode(',' , $uid)),'defaults' => 1),'`id`,`uid`');
|
|
$resumeList = $this -> select_all('resume',array('uid'=>array('in', pylode(',' , $uid))));
|
foreach($resumeList as $key=>$val){
|
if(empty($val['name'])){
|
$euids[] = $val['uid'];
|
}
|
}
|
// 没有姓名的，显示用户名
|
if (!empty($euids)){
|
$nameList = $this -> select_all('member',array('uid'=>array('in', pylode(',' , $euids))),'`uid`,`username`');
|
|
foreach($resumeList as $key=>$val){
|
foreach($nameList as $k=>$v){
|
if($v['uid']==$val['uid']){
|
$resumeList[$key]['name'] = $v['username'];
|
}
|
}
|
}
|
}
|
|
include_once('resume.model.php');
|
$resumeM = new resume_model($this->db, $this->def);
|
|
foreach($List as $key => $val){
|
|
foreach ($resume as $va){
|
|
if($val['uid'] == $va['uid']){
|
|
$List[$key]['eid'] = $va['id'];
|
$List[$key]['wapexp_url'] = Url('wap',array('c'=>'resume','a'=>'show','id'=>$va['id']));
|
}
|
}
|
|
foreach ($resumeList as $v){
|
if ($v['uid'] == $val['uid']){
|
// 已下载的，直接显示姓名
|
if(in_array($uid, $uids)){
|
|
$List[$key]['username'] = $v['name'];
|
|
}else{
|
// 未下载的，对姓名进行处理
|
$nameArr = array('nametype' => $v['nametype'], 'name' => $v['name'], 'eid' => $v['def_job'], 'sex' => $v['sex']);
|
|
$List[$key]['username'] = $resumeM -> setUsernameShow($nameArr);
|
}
|
}
|
}
|
$List[$key]['wapcom_url'] = Url('wap',array('c'=>'company','a'=>'show','id'=>$val['job_uid']));
|
$List[$key]['content'] = strip_tags(trim($val['content']));
|
$List[$key]['datetime_n'] = date('Y-m-d H:i',$val['datetime']);
|
if($v['reply_time']>0){
|
$List[$key]['reply_time_n'] = date('Y-m-d H:i',$val['reply_time']);
|
}
|
}
|
}
|
$ListNew['list'] = $List;
|
}
|
return $ListNew;
|
}
|
/**
|
* 获取单条求职咨询
|
* $whereData 查询条件
|
* $data 自定义处理数组
|
*/
|
function getInfo($whereData,$data=array()){
|
|
$field = empty($data['field']) ? '*' : $data['field'];
|
|
if (!empty($whereData)) {
|
|
$msg = $this -> select_once('msg',$whereData, $field);
|
|
if($msg && is_array($msg)){
|
|
$msg['content'] = strip_tags($msg['content']);
|
|
if (isset($msg['datetime'])){
|
$msg['datetime_n'] = date('Y-m-d H:i',$msg['datetime']);
|
}
|
if (isset($msg['reply_time'])){
|
$msg['reply_time_n'] = date('Y-m-d H:i',$msg['reply_time']);
|
}
|
return $msg;
|
}
|
}
|
}
|
|
|
public function statusMsg($id, $upData = array())
|
{
|
|
$ids = @explode(',', trim($id));
|
|
$return = array('msg' => '非法操作！', 'errcode' => 8);
|
|
if (!empty($id)) {
|
|
$idstr = pylode(',', $ids);
|
|
$upData = array(
|
|
'status' => intval($upData['status']),
|
'statusbody'=> trim($upData['statusbody']),
|
);
|
if($upData['status'] == 1){
|
$upData['issys'] = 1;
|
}
|
|
$mbs = $this->getList(array('id' => array('in', $idstr)), array('field' => '`id`,`uid`,`job_uid`,`com_name`,`job_name`,`issys`'));
|
|
|
$result = $this -> update_once('msg', $upData, array('id' => array('in', $idstr)));
|
|
if ($result) {
|
|
if($upData['status'] == 1 || $upData['status'] == 2){
|
|
$msg = array();
|
$commsg = array();
|
$uids = array();
|
$job_uid= array();
|
|
|
foreach ($mbs["list"] as $v){
|
|
$uids[] = $v['uid'];
|
if($v['issys']==0 && $upData['status'] == 1){
|
$job_uid[] = $v['job_uid'];
|
}
|
|
}
|
|
foreach ($mbs["list"] as $k => $v){
|
|
$jobmsg = '';
|
|
if($v['job_name']){
|
$jobmsg = '，咨询职位：'.$v['job_name'];
|
}
|
if ($upData['status'] == 2) {
|
|
$statusInfo = '您的企业咨询审核未通过，咨询企业：'.$v['com_name'].$jobmsg;
|
|
if ($upData['statusbody']) {
|
$statusInfo .= '，原因：'.$upData['statusbody'];
|
}
|
|
$msg[$v['uid']][] = $statusInfo;
|
|
}elseif ($upData['status'] == 1){
|
|
$msg[$v['uid']][] = '您的企业咨询审核通过，咨询企业：'.$v['com_name'].$jobmsg;
|
}
|
|
if($v['issys']==0 && $upData['status'] == 1){
|
$commsg[$v['job_uid']][] = '您有一个留言，请及时查看';
|
}
|
}
|
|
//发送系统通知
|
require_once 'sysmsg.model.php';
|
$sysmsgM = new sysmsg_model($this->db, $this->def);
|
$sysmsgM -> addInfo(array('uid' => $uids,'usertype'=>1,'content'=>$msg));
|
if(!empty($job_uid)){
|
$sysmsgM -> addInfo(array('uid' =>$job_uid,'usertype'=>2, 'content' =>$commsg));
|
}
|
|
}
|
|
$return['msg'] = '求职咨询审核成功!';
|
|
$return['errcode'] = 9;
|
|
}else{
|
|
$return['msg'] = '审核咨询(ID:'.$idstr.')设置失败';
|
$return['errcode'] = 8;
|
}
|
|
}else {
|
|
$return['msg'] = '请选择需要审核的咨询！';
|
$return['errcode'] = 8;
|
}
|
|
return $return;
|
}
|
/**
|
* 添加求职咨询
|
* $data 自定义数组
|
* 应用中使用到的添加求职咨询
|
*/
|
public function addMsg($data = array(),$code=''){
|
$res = array();
|
$res['errorcode'] = 8;
|
$res['msg'] = '';
|
|
if(empty($data)){
|
$res['msg'] = '参数错误，请重试！';
|
return $res;
|
}
|
if(empty($data['uid']) || empty($data['username'])){
|
$res['msg'] = '请先登录！';
|
return $res;
|
}
|
if($data['usertype'] != 1){
|
$res['msg'] = '只有个人用户才可以留言！';
|
return $res;
|
}
|
|
//参数判断
|
if(empty($data['content'])){
|
$res['msg'] = '留言内容不能为空！';
|
return $res;
|
}
|
if($code == ''){
|
if(empty($data['authcode'])){
|
$res['msg'] = '验证码不能为空！';
|
return $res;
|
}
|
session_start();
|
if(md5(strtolower($data['authcode'])) != $_SESSION['authcode'] || empty($_SESSION['authcode'])){
|
$res['msg'] = '验证码错误！';
|
return $res;
|
}
|
}
|
|
$sql = array(
|
'uid' => $data['uid'],
|
'datetime' => time(),
|
'content' => $data['content'],
|
'type' => 1,
|
'status' => isset($data['status'])?$data['status']:$this->config['user_msg_status']
|
);
|
if($sql['status']=='1'){
|
$sql['issys'] = 1;
|
}else{
|
$sql['issys'] = 0;
|
}
|
|
if (!empty($data['jobid'])){
|
|
$job = $this->select_once('company_job', array('id'=>$data['jobid']),'`id`,`uid`,`name`,`com_name`');
|
|
$sql['jobid'] = $job['id'];
|
$sql['job_uid'] = $job['uid'];
|
$sql['com_name'] = $job['com_name'];
|
$sql['job_name'] = $job['name'];
|
|
}else if (!empty($data['job_uid'])){
|
|
$com = $this->select_once('company', array('uid'=>$data['job_uid']),'`uid`,`name`');
|
|
$sql['job_uid'] = $com['uid'];
|
$sql['com_name'] = $com['name'];
|
}
|
|
//判断是否在黑名单
|
include_once ('black.model.php');
|
$blackM = new black_model($this->db, $this->def);
|
$black = $blackM -> getBlackNum(array(
|
'p_uid' => $sql['uid'],
|
'c_uid' => $sql['job_uid']
|
));
|
if(!empty($black)){
|
$res['msg'] = '该企业暂不接受相关咨询！';
|
return $res;
|
}
|
|
$resume = $this->select_once("resume",array('uid'=>$sql['uid']),"`name`");
|
|
if(!empty($resume)){
|
|
$sql['username'] = $resume['name'];
|
|
}
|
|
$id = $this -> addInfo($sql);
|
|
if(!empty($id)){
|
|
if($sql['status']=='1'){
|
include_once ('sysmsg.model.php');
|
$sysmsgM = new sysmsg_model($this->db, $this->def);
|
$sysmsgM -> addInfo(array('uid' => $sql['job_uid'],'usertype'=>2, 'content' => '您有一个留言，请及时查看'));
|
}
|
|
$res['msg'] = '留言成功，请等待回复！';
|
$res['errorcode'] = 9;
|
return $res;
|
}else{
|
$res['msg'] = '留言失败！';
|
return $res;
|
}
|
|
}
|
|
/**
|
* 添加求职咨询
|
* $data 自定义数组
|
*/
|
public function addInfo($data=array()){
|
|
return $this -> insert_into('msg', $data);
|
|
}
|
/**
|
* 删除求职咨询
|
* $whereData 查询条件
|
* $data 自定义处理数组
|
*/
|
public function delInfo($id,$data=array()){
|
|
$limit = 'limit 1';
|
|
$return['layertype'] = 0;
|
|
if (!empty($id)){
|
|
if(is_array($id)){
|
|
$id = pylode(',', $id);
|
|
$return['layertype'] = 1;
|
|
$limit = '';
|
}
|
if($data['uid']){
|
$delWhere = array('uid'=>$data['uid'],'id'=>array('in',$id));
|
}else{
|
$delWhere = array('id'=>array('in',$id));
|
}
|
|
$nid = $this->delete_all('msg',$delWhere,$limit);
|
|
if ($nid){
|
|
$this -> addMemberLog($data['uid'],$data['usertype'],'删除求职咨询',18,3);
|
|
$return['msg'] = '求职咨询(ID:'.$id.')删除成功';
|
|
$return['errcode'] = '9';
|
|
}else{
|
|
$return['msg'] = '求职咨询(ID:'.$id.')删除成功';
|
|
$return['errcode'] = '8';
|
|
}
|
|
}else{
|
|
$return['msg'] = '请选择您要删除的求职咨询';
|
|
$return['errcode'] = '8';
|
|
}
|
|
return $return;
|
|
}
|
|
/**
|
* 修改求职咨询回复
|
*/
|
public function eidtMsg($id,$data=array()){
|
if(!empty($id)){
|
$data['status'] = 1;
|
$nid = $this -> update_once('msg',$data,array('id'=>$id));
|
if($nid){
|
$return['msg'] = '修改成功！';
|
$return['errcode'] = 9;
|
}else{
|
$return['msg'] = '修改失败！';
|
$return['errcode'] = 8;
|
}
|
}else{
|
$return['msg'] = '请选择要修改的数据';
|
$return['errcode'] = 8;
|
}
|
return $return;
|
}
|
|
/**
|
* 删除求职咨询
|
*/
|
public function upInfo($whereData, $data = array()){
|
|
if(!empty($whereData)) {
|
if($data['usertype']=='1'){
|
//个人会员提醒出来，未读状态改成已读状态
|
$nid = $this -> update_once('msg', array('user_remind_status'=>$data['user_remind_status']),$whereData);
|
}else{
|
$PostData = array(
|
|
'del_status' => '1',
|
|
);
|
|
$nid = $this -> update_once('msg', $PostData, array('id'=>$whereData['id'],'job_uid'=>$whereData['job_uid']));
|
}
|
}
|
|
return $nid;
|
|
}
|
|
/**
|
* 回复状态
|
*/
|
public function upReplyInfo($whereData, $data = array()){
|
|
if(!empty($whereData)) {
|
|
$PostData = array(
|
|
'reply' =>$data['reply'],
|
|
'reply_time' =>$data['reply_time'],
|
|
'user_remind_status' =>$data['user_remind_status'],
|
|
);
|
|
$nid = $this -> update_once('msg', $PostData, array('id'=>$whereData['id'],'job_uid'=>$whereData['job_uid']));
|
|
}
|
|
return $nid;
|
|
}
|
|
public function delMsg($id, $data = array()){
|
|
if(!empty($id)){
|
|
if(is_array($id)){
|
|
$ids = $id;
|
|
$return['layertype'] = 1;
|
|
}else{
|
|
$ids = @explode(',', $id);
|
|
$return['layertype'] = 0;
|
|
}
|
|
$id = pylode(',', $ids);
|
|
$return['id'] = $this -> delete_all('msg',array('id' => array('in',$id),'job_uid'=>$data['job_uid']),'');
|
|
$return['msg'] = '求职咨询';
|
|
$return['errcode'] = $return['id'] ? '9' :'8';
|
|
$return['msg'] = $return['id'] ? $return['msg'].'删除成功！' : $return['msg'].'删除失败！';
|
|
}else{
|
|
$return['msg'] = '请选择您要删除的数据！';
|
|
$return['errcode'] = 8;
|
|
}
|
|
return $return;
|
}
|
/**
|
* @desc 获取职位咨询数目
|
*/
|
function getMsgNum($WhereData = array()){
|
|
$Msgnum = $this->select_num('msg', $WhereData);
|
|
return $Msgnum;
|
}
|
|
}
|
?>
|
