472 lines
16 KiB
PHP
472 lines
16 KiB
PHP
<?php
|
||
/**
|
||
* tpshop
|
||
* ============================================================================
|
||
* 版权所有 2015-2027 深圳搜豹网络科技有限公司，并保留所有权利。
|
||
* 网站地址: http://www.tp-shop.cn
|
||
* ----------------------------------------------------------------------------
|
||
* 这不是一个自由软件！您只能在不用于商业目的的前提下对程序代码进行修改和使用 .
|
||
* 不允许对程序代码以任何形式任何目的的再发布。
|
||
* 采用最新Thinkphp5助手函数特性实现单字母函数M D U等简写方式
|
||
* ============================================================================
|
||
* Author: IT宇宙人
|
||
* Date: 2015-09-09
|
||
*/
|
||
|
||
namespace app\common\logic;
|
||
|
||
use think\Model;
|
||
use think\Db;
|
||
|
||
/**
|
||
* Class OrderGoodsLogic
|
||
* @package common\Logic
|
||
*/
|
||
class MessageLogic extends Model
|
||
{
|
||
protected $tableName = 'message';
|
||
protected $_validate = array();
|
||
protected $message_category_num = 6;
|
||
|
||
/**
|
||
* 获取用户的消息个数
|
||
* @return array
|
||
*/
|
||
public function getUserMessageCount(){
|
||
$user_info = session('user');
|
||
$user_system_message_no_read_where = array(
|
||
'um.user_id' => $user_info['user_id'],
|
||
'um.is_see' => 0,
|
||
'um.deleted' => 0,
|
||
);
|
||
$user_system_message_no_read = DB::name('user_message')
|
||
->alias('um')
|
||
->join('__MESSAGE__ m','um.message_id = m.message_id','LEFT')
|
||
->where($user_system_message_no_read_where)
|
||
->count();
|
||
return $user_system_message_no_read;
|
||
}
|
||
|
||
/**
|
||
* 获取用户的活动消息
|
||
* @return array
|
||
*/
|
||
public function getUserSellerMessage()
|
||
{
|
||
$user_info = session('user');
|
||
$user_system_message_no_read_where = array(
|
||
'user_id' => $user_info['user_id'],
|
||
'status' => 0,
|
||
'm.category' => ['<>', 0]
|
||
);
|
||
$user_system_message_no_read = Db::name('user_message')
|
||
->alias('um')
|
||
->field('um.rec_id,um.user_id,um.category,um.message_id,um.status,m.send_time,m.type,m.message')
|
||
->join('__MESSAGE__ m','um.message_id = m.message_id','LEFT')
|
||
->where($user_system_message_no_read_where)
|
||
->select();
|
||
return $user_system_message_no_read;
|
||
}
|
||
|
||
/**
|
||
* 获取用户的全部消息
|
||
* @return array
|
||
*/
|
||
public function getUserAllMessage()
|
||
{
|
||
$this->checkPublicMessage();
|
||
$user_info = session('user');
|
||
$user_system_message_no_read_where = array(
|
||
'user_id' => $user_info['user_id'],
|
||
'status' => 0,
|
||
);
|
||
$user_system_message_no_read = Db::name('user_message')
|
||
->alias('um')
|
||
->field('um.rec_id,um.user_id,um.category,um.message_id,um.status,m.send_time,m.type,m.message')
|
||
->join('__MESSAGE__ m','um.message_id = m.message_id','LEFT')
|
||
->where($user_system_message_no_read_where)
|
||
->select();
|
||
return $user_system_message_no_read;
|
||
}
|
||
|
||
/**
|
||
* 获取用户的系统消息
|
||
* @return array
|
||
*/
|
||
public function getUserMessageNotice()
|
||
{
|
||
$this->checkPublicMessage();
|
||
$user_info = session('user');
|
||
$user_system_message_no_read_where = array(
|
||
'user_id' => $user_info['user_id'],
|
||
'status' => 0,
|
||
'm.category' => 0
|
||
);
|
||
$user_system_message_no_read = Db::name('user_message')
|
||
->alias('um')
|
||
->field('um.rec_id,um.user_id,um.category,um.message_id,um.status,m.send_time,m.type,m.message')
|
||
->join('__MESSAGE__ m','um.message_id = m.message_id','LEFT')
|
||
->where($user_system_message_no_read_where)
|
||
->select();
|
||
return $user_system_message_no_read;
|
||
}
|
||
|
||
/**
|
||
* 查询系统全体消息，如有将其插入用户信息表
|
||
* @author dyr
|
||
* @time 2016/09/01
|
||
*/
|
||
public function checkPublicMessage()
|
||
{
|
||
$user_info = session('user');
|
||
$user_message = Db::name('user_message')->where(array('user_id' => $user_info['user_id'], 'category' => 0))->select();
|
||
$message_where = array(
|
||
'category' => 0,
|
||
'type' => 1,
|
||
'send_time' => array('gt', $user_info['reg_time']),
|
||
);
|
||
if (!empty($user_message)) {
|
||
$user_id_array = get_arr_column($user_message, 'message_id');
|
||
$message_where['message_id'] = array('NOT IN', $user_id_array);
|
||
}
|
||
$user_system_public_no_read = Db::name('message')->field('message_id')->where($message_where)->select();
|
||
foreach ($user_system_public_no_read as $key) {
|
||
DB::name('user_message')->insert(['user_id'=>$user_info['user_id'],'message_id'=>$key['message_id'],'category'=>0,'status'=>0]);
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 获取用户的全部关注的消息
|
||
* @return array
|
||
*/
|
||
public function getUserAllMaskMessage()
|
||
{
|
||
$this->checkPublicMessage();
|
||
$user_info = session('user');
|
||
|
||
$categorys = $categorys = $this->getUserMessageCategory($user_info);
|
||
if (empty($categorys)) {
|
||
return [];
|
||
}
|
||
|
||
$user_system_message_no_read_where = array(
|
||
'user_id' => $user_info['user_id'],
|
||
'status' => 0,
|
||
'um.category' => ['in', $categorys]
|
||
);
|
||
$user_system_message_no_read = Db::name('user_message')
|
||
->alias('um')
|
||
->field('um.rec_id,um.user_id,um.category,um.message_id,um.status,m.send_time,m.type,m.message')
|
||
->join('__MESSAGE__ m','um.message_id = m.message_id','LEFT')
|
||
->where($user_system_message_no_read_where)
|
||
->select();
|
||
return $user_system_message_no_read;
|
||
}
|
||
|
||
/**
|
||
* 获取用户关注的消息类型
|
||
* @param type $user
|
||
* @param type $filter 是否强制过滤
|
||
* @return int
|
||
*/
|
||
public function getUserMessageCategory($user, $filter = 0)
|
||
{
|
||
$categorys = [];
|
||
for ($i = 0; $i < $this->message_category_num; $i++) {
|
||
//目前限定为四种类型,过滤掉 '3商品提醒'、'5商城好店'
|
||
if ($filter && ($i == 3 || $i == 5)) {
|
||
continue;
|
||
}
|
||
if ($user['message_mask'] & (1 << $i)) {
|
||
$categorys[] = $i;
|
||
}
|
||
}
|
||
return $categorys;
|
||
}
|
||
|
||
/**
|
||
* 获取用户的每个类型最新一条消息
|
||
* @return array
|
||
*/
|
||
public function getUserPerTypeLastMessage()
|
||
{
|
||
$this->checkPublicMessage();
|
||
$user = session('user');
|
||
|
||
if ($user) {
|
||
$categorys = $this->getUserMessageCategory($user, 1);
|
||
if (empty($categorys)) {
|
||
return [];
|
||
}
|
||
} else {
|
||
$categorys = [0, 2, 3, 5];//0系统消息，1物流通知，2优惠促销，3商品提醒，4我的资产，5商城好店
|
||
}
|
||
|
||
$data = [];
|
||
foreach ($categorys as $c) {
|
||
$query = Db::query('SELECT m.category,m.message_id,um.status,m.send_time,m.type,m.data FROM __PREFIX__message m '
|
||
. 'INNER JOIN __PREFIX__user_message um ON (um.message_id=m.message_id AND um.user_id = ?) '
|
||
. 'WHERE m.type = 0 AND m.category = ? AND m.data!="" '
|
||
. 'UNION (SELECT m.category,m.message_id, 1 AS status,m.send_time,m.type,m.data FROM __PREFIX__message m '
|
||
. 'WHERE m.type = 1 AND m.category = ? AND m.data!="") '
|
||
. 'ORDER BY send_time DESC LIMIT 1', [$user['user_id'], $c, $c]);
|
||
|
||
if (!empty($query[0])) {
|
||
$query = $query[0];
|
||
$msgdata = unserialize($query['data']);
|
||
$query['message'] = $msgdata['discription'];
|
||
unset($query['data']);
|
||
$data[] = $query;
|
||
}
|
||
}
|
||
return $data;
|
||
}
|
||
|
||
/**
|
||
* 获取具体类型的消息列表
|
||
* @param type $user_id
|
||
* @param type $category
|
||
* @param type $p
|
||
* @return type
|
||
*/
|
||
public function getUserMessageList($user_id, $category, $p = 1)
|
||
{
|
||
if ($p < 1) {
|
||
$p = 1;
|
||
}
|
||
$p = ($p - 1) * 15;
|
||
|
||
$data = Db::query('SELECT m.category,m.message_id,um.status,m.send_time,m.type,m.data FROM __PREFIX__message m '
|
||
. 'INNER JOIN __PREFIX__user_message um ON (um.message_id=m.message_id AND um.user_id = ?) '
|
||
. 'WHERE m.type = 0 AND m.category = ? AND m.data!="" '
|
||
. 'UNION (SELECT m.category,m.message_id, 1 AS status,m.send_time,m.type,m.data FROM __PREFIX__message m '
|
||
. 'WHERE m.type = 1 AND m.category = ? AND m.data!="") '
|
||
. 'ORDER BY send_time DESC LIMIT ?,15', [$user_id, $category, $category, $p]);
|
||
|
||
foreach ($data as &$d) {
|
||
$d['data'] = unserialize($d['data']);
|
||
}
|
||
|
||
return $data;
|
||
}
|
||
|
||
/**
|
||
* 创建推送消息
|
||
* @param int $type：0系统消息，1物流通知，2优惠促销，3商品提醒，4我的资产，5商城好店
|
||
*/
|
||
public function createPushMsg($type, $data)
|
||
{
|
||
$title = isset($data['title']) ? $data['title'] : '';
|
||
$order_id = isset($data['order_id']) ? $data['order_id'] : 0;
|
||
$discription = isset($data['discription']) ? $data['discription'] : '';
|
||
$goods_id = isset($data['goods_id']) ? $data['goods_id'] : 0;
|
||
$change_type = isset($data['change_type']) ? $data['change_type'] : 0;
|
||
$money = isset($data['money']) ? $data['money'] : 0;
|
||
$cover = isset($data['cover']) ? $data['cover'] : '';
|
||
|
||
$logic = new MessageLogic;
|
||
if ($type === 0) {
|
||
$data = $logic->createSystemMsg($type, $title, $discription);
|
||
} elseif ($type === 1) {
|
||
$data = $logic->createShippingMsg($type, $title, $order_id, $goods_id, $discription);
|
||
} elseif ($type === 2) {
|
||
$data = $logic->createPromotionMsg($type, $title, $goods_id, $cover, $discription);
|
||
} elseif ($type === 4) {
|
||
$data = $logic->createAssetMsg($type, $change_type, $title, $discription, $money);
|
||
} else {
|
||
$data = [];
|
||
}
|
||
return $data;
|
||
}
|
||
|
||
/**
|
||
* 推送物流消息
|
||
* @param type $title
|
||
* @param type $order_id
|
||
* @param type $goods_id
|
||
* @param type $discription
|
||
*/
|
||
public function createShippingMsg($t, $title, $order_id, $goods_id, $discription = '')
|
||
{
|
||
$row = M('order')->field('order_sn, shipping_name')->where('order_id', $order_id)->find();
|
||
if (!$row) {
|
||
return ['status' => -1, 'msg' => '订单不存在'];
|
||
}
|
||
|
||
$discription = $discription ?: "您的订单已炼货完毕，待出库交付{$row['shipping_name']},"
|
||
. "运单号为{$row['order_sn']}";
|
||
$title = $title ?: "发货提醒";
|
||
$data = [
|
||
'category' => $t,
|
||
'data' => [
|
||
'title' => $title,
|
||
'post_time' => time(),
|
||
'order_id' => $order_id,
|
||
'discription' => $discription,
|
||
'goods_id' => $goods_id
|
||
]
|
||
];
|
||
return $data;
|
||
}
|
||
|
||
/**
|
||
* 推送促销消息
|
||
* @param type $title
|
||
* @param type $goods_id
|
||
* @param type $cover
|
||
* @param type $discription
|
||
*/
|
||
public function createPromotionMsg($t, $title, $goods_id, $cover = '', $discription = '')
|
||
{
|
||
$data = [
|
||
'category' => $t,
|
||
'data' => [
|
||
'title' => $title,
|
||
'post_time' => time(),
|
||
'cover' => $cover,
|
||
'discription' => $discription,
|
||
'goods_id' => $goods_id
|
||
]
|
||
];
|
||
return $data;
|
||
}
|
||
|
||
/**
|
||
* 推送资金变动/我的资产消息
|
||
* @param type $change_type 1:积分,2:余额,3:优惠券
|
||
* @param type $title
|
||
* @param type $discription
|
||
* @param type $money 优惠券类型通知时该值才大于0
|
||
*/
|
||
public function createAssetMsg($t, $change_type, $title, $discription = '', $money = 0)
|
||
{
|
||
$data = [
|
||
'category' => $t,
|
||
'data' => [
|
||
'change_type' => $change_type,
|
||
'title' => $title,
|
||
'post_time' => time(),
|
||
'discription' => $discription,
|
||
'money' => $money
|
||
]
|
||
];
|
||
return $data;
|
||
}
|
||
|
||
/**
|
||
* 推送系统/服务消息
|
||
* @param type $title
|
||
* @param type $discription
|
||
*/
|
||
public function createSystemMsg($t, $title, $discription = '')
|
||
{
|
||
$data = [
|
||
'category' => $t,
|
||
'data' => [
|
||
'title' => $title,
|
||
'post_time' => time(),
|
||
'discription' => $discription,
|
||
]
|
||
];
|
||
return $data;
|
||
}
|
||
|
||
/**
|
||
* 发送消息
|
||
* @param type $msg message表字段必要的数据
|
||
* @param type $push_data 推送的消息主体
|
||
* @param array $user_ids 用户的id集
|
||
* @return type
|
||
*/
|
||
public function sendMessage($msg, $push_data, $user_ids = [])
|
||
{
|
||
//创建推送消息
|
||
$push_data = $this->createPushMsg($msg['category'], $push_data);
|
||
if (!$push_data) {
|
||
return ['status' => -1, 'msg' => '推送的内容不能为空'];
|
||
}
|
||
|
||
if (is_string($user_ids)) {
|
||
$user_ids = explode(',', $user_ids);
|
||
}
|
||
//推送消息
|
||
$push_ids = [];
|
||
if (!$msg['type']) {
|
||
$push_ids = M('users')->where(['user_id' => ['IN', $user_ids]])->column('push_id');
|
||
}
|
||
$push = new PushLogic;
|
||
$res = $push->push($push_data, $msg['type'], $push_ids);
|
||
if ($res['status'] !== 1) {
|
||
return $res;
|
||
}
|
||
|
||
$message = [
|
||
'admin_id' => isset($msg['admin_id']) ? $msg['admin_id'] : 0,
|
||
'seller_id' => isset($msg['seller_id']) ? $msg['seller_id'] : 0,
|
||
'category' => $msg['category'],
|
||
'type' => $msg['type'],
|
||
'message' => $push_data['data']['discription'],
|
||
'send_time' => $push_data['data']['post_time'],
|
||
'data' => serialize($push_data['data'])
|
||
];
|
||
|
||
//推送成功才入库
|
||
if ($msg['type'] == 1) {
|
||
M('Message')->add($message);
|
||
} elseif (!empty($user_ids)) {
|
||
$msg_id = M('Message')->add($message);
|
||
foreach ($user_ids as $uid) {
|
||
M('user_message')->add(['user_id' => $uid, 'message_id' => $msg_id, 'status' => 0, 'category' => $msg['category']]);
|
||
}
|
||
}
|
||
return $res;
|
||
}
|
||
|
||
/**
|
||
* 获取消息开关
|
||
* @param type $mask 开关掩码
|
||
* @return type
|
||
*/
|
||
public function getMessageSwitch($mask)
|
||
{
|
||
$notice[] = boolval($mask & (1 << 0)); //'system'
|
||
$notice[] = boolval($mask & (1 << 1)); //'express'
|
||
$notice[] = boolval($mask & (1 << 2)); //'promotion'
|
||
$notice[] = boolval($mask & (1 << 3)); //'goods'
|
||
$notice[] = boolval($mask & (1 << 4)); //'asset'
|
||
$notice[] = boolval($mask & (1 << 5)); //'store'
|
||
|
||
return $notice;
|
||
}
|
||
|
||
/**
|
||
* 设置消息开关
|
||
* @param type $type 开关类型
|
||
* @param type $val开关值
|
||
*/
|
||
public function setMessageSwitch($type, $val, $user)
|
||
{
|
||
if ($type > 5) {
|
||
return ['status' => -1, 'msg' => '开关类型错误'];
|
||
}
|
||
|
||
if ($val) {
|
||
$user['message_mask'] |= (1 << $type);
|
||
} else {
|
||
$user['message_mask'] &= ~(1 << $type);
|
||
}
|
||
M('users')->where('user_id', $user['user_id']) ->save(['message_mask' => $user['message_mask']]);
|
||
|
||
return ['status' => 1, 'msg' => '设置成功'];
|
||
}
|
||
|
||
/**
|
||
* 设置消息为已读
|
||
*/
|
||
public function setMessageRead($user_id)
|
||
{
|
||
M('user_message')->where('user_id', $user_id)->save(['status' => 1]);
|
||
}
|
||
}
|
||
|
||
|