<?php
|
|
class subscribe_model extends model{
|
|
//以下为phpyun5.0新增
|
/**
|
* @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='');
|
}
|
/**
|
* @desc 获取缓存数据
|
*/
|
private function getClass($options){
|
|
if (!empty($options)){
|
|
include_once ('cache.model.php');
|
|
$cacheM = new cache_model($this->db, $this->def);
|
|
$cache = $cacheM -> GetCache($options);
|
|
return $cache;
|
}
|
}
|
/**
|
* 获取订阅列表
|
* $whereData 查询条件
|
* $data 自定义处理数组
|
*/
|
|
public function getList($whereData,$data=array()){
|
$ListNew = array();
|
$List = $this -> select_all('subscribe',$whereData);
|
|
if(!empty( $List )){
|
$cache = $this -> getClass(array('job','city','user'));
|
foreach($List as $k=>$v){
|
$jobname = $cityname = array();
|
$jobname[] = $cache['job_name'][$v['job1']];
|
$jobname[] = $cache['job_name'][$v['job1_son']];
|
if($cache['job_name'][$v['job_post']]){
|
|
$jobname[] = $cache['job_name'][$v['job_post']];
|
}
|
|
$cityname[] = $cache['city_name'][$v['provinceid']];
|
|
if($cache['city_name'][$v['cityid']]){
|
$cityname[] = $cache['city_name'][$v['cityid']];
|
}
|
if($cache['city_name'][$v['three_cityid']]){
|
$cityname[] = $cache['city_name'][$v['three_cityid']];
|
}
|
|
$List[$k]['jobname'] = @implode(',',$jobname);
|
$List[$k]['city_name'] = @implode('-',$cityname);
|
if($v['minsalary'] && $v['maxsalary']){
|
if($this ->config['resume_salarytype']==1){
|
$List[$k]['salary'] = $v['minsalary'].'-'.$v['maxsalary'];
|
}else{
|
if($v['maxsalary']<1000){
|
if($this->config['resume_salarytype']==2){
|
$List[$k]['salary'] = '1千以下';
|
}elseif($this->config['resume_salarytype']==3){
|
$List[$k]['salary'] = '1K以下';
|
}elseif($this->config['resume_salarytype']==4){
|
$List[$k]['salary'] = '1k以下';
|
}
|
}else{
|
$List[$k]['salary'] = changeSalary($v['minsalary']).'-'.changeSalary($v['maxsalary']);
|
}
|
}
|
}elseif ($v['minsalary']){
|
if($this ->config['resume_salarytype']==1){
|
$List[$k]['salary'] = $v['minsalary'];
|
}else{
|
$List[$k]['salary'] = changeSalary($v['minsalary']);
|
}
|
}elseif ($v['maxsalary']){
|
if($this ->config['resume_salarytype']==1){
|
$List[$k]['salary'] = $v['maxsalary'];
|
}else{
|
$List[$k]['salary'] = changeSalary($v['maxsalary']);
|
}
|
}else{
|
|
$List[$k]['salary'] = '面议';
|
}
|
}
|
}
|
|
return $List;
|
}
|
public function getInfo($where=array(), $data = array()) {
|
|
$select = $data['field'] ? $data['field'] : '*';
|
$Info = $this -> select_once('subscribe', $where, $select);
|
return $Info;
|
}
|
function upInfo($data=array(),$Where=array()){
|
|
return $this->update_once('subscribe',$data,$Where);
|
}
|
function addInfo($data=array()){
|
|
return $this->insert_into('subscribe',$data);
|
}
|
/**
|
* 获取订阅记录列表subscriberecord
|
* $whereData 查询条件
|
* $data 自定义处理数组
|
*/
|
|
public function getRecordList($whereData,$data=array()){
|
$ListNew = array();
|
$List = $this -> select_all('subscriberecord',$whereData);
|
|
return $List;
|
}
|
|
/**
|
* 删除下载简历
|
* $whereData 查询条件
|
* $data 自定义处理数组
|
*/
|
public function del($id,$data){
|
|
$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('subscribe',$delWhere,$limit);
|
|
if ($nid){
|
|
$this -> delete_all('subscriberecord',array('sid'=>array('in',$id)),$limit);
|
$this -> addMemberLog($data['uid'],$data['usertype'],"删除订阅（ID:".$id."）",5,3);
|
$return['msg'] = '删除成功';
|
$return['errcode'] = '9';
|
}else{
|
$return['msg'] = '删除失败';
|
$return['errcode'] = '8';
|
}
|
}else{
|
$return['msg'] = '请选择您要删除的记录';
|
$return['errcode'] = '8';
|
}
|
return $return;
|
}
|
|
/**
|
* 应用中增加订阅
|
* 判断了是增加或是修改
|
* 2019-07-12
|
*/
|
public function createSubscribe($data = array()){
|
|
$res = array(
|
'errcode' => 8,
|
'msg' => ''
|
);
|
|
if(empty($data['uid'])){
|
$res['msg'] = '您还未登录！';
|
return $res;
|
}
|
|
//个人 企业用户才可订阅
|
if(empty($data['usertype']) || !in_array($data['usertype'], array(1, 2))){
|
$res['msg'] = '只有个人和企业用户才可订阅！';
|
return $res;
|
}
|
|
$sid = intval($data['sid']);
|
$data['type'] = intval($data['type']);
|
|
//判断订阅类型
|
if($data['usertype'] != $data['type']){
|
$res['msg'] = '订阅类型错误！';
|
return $res;
|
}
|
|
//用户绑定的微信信息
|
$userField = '`email`,`wxid`, `wxopenid`';
|
$userInfo = $this -> select_once('member' , array('uid' => $data['uid']), $userField);
|
if(empty($userInfo)){
|
$res['msg'] = '用户信息错误！';
|
return $res;
|
}
|
|
//未传入订阅的id时，通过uid type判断是否已订阅
|
if(empty($sid)){
|
$oldField = array('field' => '`id`');
|
$oldSub = $this -> getInfo(array('uid' => $data['uid'], 'type' => $data['type']), $oldField);
|
if(!empty($oldSub)){
|
$sid = $oldSub['id'];
|
}
|
}
|
|
if(empty($userInfo['wxid']) && empty($userInfo['wxopenid'])){
|
require_once ('weixin.model.php');
|
$wxM = new weixin_model($this->db, $this->def);
|
$qrcode = $wxM -> applyWxQrcode($_POST['wxloginid'], '', $data['uid']);
|
if(empty($qrcode)){
|
$res['msg'] = '暂未绑定微信公众号，无法订阅！';
|
}else{
|
$res['msg'] = '马上绑定微信, 接收订阅信息！';
|
}
|
return $res;
|
}
|
|
//处理参数
|
$data['email'] = $userInfo['email'];
|
$data['ctime'] = time();
|
if(empty($sid)){
|
$data['uid'] = $data['uid'];
|
$sid = $this -> addInfo($data);
|
}else{
|
unset($data['sid']);
|
|
$this -> upInfo($data, array('id' => $sid));
|
}
|
|
$res['errcode'] = 9;
|
$res['msg'] = '订阅成功！';
|
return $res;
|
|
}
|
|
/**
|
* 发送订阅
|
* type 1-订阅职位，2-订阅人才
|
* limit 发送订阅信息的数量默认为5
|
* 2019-07-12
|
*/
|
public function sendSubscribe($data = array()){
|
|
$res = array(
|
'errcode' => 8,
|
'msg' => ''
|
);
|
if(empty($data['type']) || !in_array($data['type'], array(1, 2))){
|
$res['msg'] = '缺少订阅类型参数!';
|
return $res;
|
}
|
|
//设置默认订阅数量
|
$data['limit'] = empty($data['limit']) ? 5 : intval($data['limit']);
|
|
//获取需要发送的订阅
|
$subscribe = $this -> select_all('subscribe', array(
|
'type' => $data['type'],
|
'time' => array('>', 0)));
|
if(empty($subscribe)){
|
$res['msg'] = '暂无订阅数据!';
|
return $res;
|
}
|
|
$currentTime = time();
|
foreach ($subscribe as $sv) {
|
//距离当前的天数
|
$ytime = $currentTime - $sv['ctime'];
|
$endDays = ceil(bcdiv($ytime, 86400, 2));
|
|
//发送周期的整数则发送订阅信息
|
if(bccomp(bcmod($endDays, $sv['time']), 0, 2) != 0){
|
continue;
|
}
|
|
$whereData = array();
|
|
//增加更新时间条件
|
if(!empty($sv['cycle_time']) && $sv['cycle_time'] > 0){
|
$beginTime = $sv['cycle_time']*86400;
|
$whereData['lastupdate'] = array('>=', $currentTime - $beginTime);
|
}
|
|
//增加薪水条件
|
if(!empty($sv['minsalary'])){
|
$whereData['minsalary'] = array('>=', $sv['minsalary']);
|
}
|
if(!empty($sv['maxsalary'])){
|
$whereData['maxsalary'] = array('<=', $sv['maxsalary']);
|
}
|
|
|
|
$whereData['limit'] = $data['limit'];
|
$whereData['orderby'] = 'lastupdate';
|
//1-订阅职位，2-订阅人才
|
if($sv['type'] == 2){
|
//省份城市条件
|
if(!empty($sv['three_cityid'])){
|
$whereData['city_classid'] = array('findin', $sv['three_cityid']);
|
}elseif (!empty($sv['cityid'])) {
|
$whereData['city_classid'] = array('findin', $sv['cityid']);
|
}elseif (!empty($sv['provinceid'])) {
|
$whereData['city_classid'] = array('findin', $sv['provinceid']);
|
}
|
if(!empty($sv['job_post'])){
|
$whereData['job_classid'] = array('findin', $sv['job_post']);
|
}elseif (!empty($sv['job1_son'])) {
|
$whereData['job_classid'] = array('findin', $sv['job1_son']);
|
}elseif (!empty($sv['job1'])) {
|
$whereData['job_classid'] = array('findin', $sv['job1']);
|
}
|
$whereData['status'] = 1;
|
$whereData['r_status'] = 1;
|
|
$subList = $this -> select_all('resume_expect', $whereData, '`name`');
|
}elseif ($sv['type'] == 1) {
|
//省份城市条件
|
if(!empty($sv['three_cityid'])){
|
$whereData['three_cityid'] = $sv['three_cityid'];
|
}elseif (!empty($sv['cityid'])) {
|
$whereData['cityid'] = $sv['cityid'];
|
}elseif (!empty($sv['provinceid'])) {
|
$whereData['provinceid'] = $sv['provinceid'];
|
}
|
if(!empty($sv['job_post'])){
|
$whereData['job_post'] = $sv['job_post'];
|
}elseif (!empty($sv['job1_son'])) {
|
$whereData['job1_son'] = $sv['job1_son'];
|
}elseif (!empty($sv['job1'])) {
|
$whereData['job1'] = $sv['job1'];
|
}
|
$whereData['state'] = 1;
|
$subList = $this -> select_all('company_job', $whereData, '`name`');
|
}
|
//没查询到数据直接pass
|
if(empty($subList)){
|
continue;
|
}
|
|
//订阅的职位 简历名称
|
$nameArr = array();
|
foreach($subList as $val){
|
$nameArr[] = $val['name'];
|
}
|
$contentStr = @implode(',', $nameArr);
|
|
//发送微信通知信息
|
require_once ('weixin.model.php');
|
$wxM = new weixin_model($this->db, $this->def);
|
$FirstType = $sv['type']==1 ? '职位' : '人才';
|
$wxRes = $wxM -> sendSubscribe(array(
|
'uid' => $sv['uid'],
|
'First' => '您订阅的'.$FirstType.'有了新的信息！',
|
'content' => $contentStr
|
));
|
if($wxRes['errcode']==8){
|
continue;
|
}
|
|
//保存相关订阅记录
|
$recordArr = array(
|
'sid' => $sv['id'],
|
'uid' => $sv['uid'],
|
'type' => $sv['type'],
|
'content' => $contentStr,
|
'time' => $currentTime
|
);
|
|
$this -> insert_into('subscriberecord', $recordArr);
|
}
|
|
$res['errcode'] = 9;
|
return $res;
|
}
|
|
}
|
?>
|
