Message.php
2.58 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
<?php
/**
* tpshop
* ============================================================================
* 版权所有 2015-2027 深圳搜豹网络科技有限公司，并保留所有权利。
* 网站地址: http://www.tp-shop.cn
* ----------------------------------------------------------------------------
* 这不是一个自由软件！您只能在不用于商业目的的前提下对程序代码进行修改和使用 .
* 不允许对程序代码以任何形式任何目的的再发布。
* ============================================================================
* Author: dyr
* Date: 2016-08-23
*/
namespace app\home\model;
use think\model;
use think\Db;
/**
* @package Home\Model
*/
class Message extends Model
{
protected $tableName = 'message';
protected $_validate = array();
/**
* 获取用户的系统消息
* @return array
*/
public function getUserMessageNotice()
{
$this->checkPublicMessage();
$user_info = session('user');
$user_system_message_no_read_where = array('um.user_id' => $user_info['user_id'], 'um.status' => 0, 'um.category' => 0);
$user_system_message_no_read = DB::name('user_message')
->alias('um')
->comment('为啥查不了')
->field('um.rec_id, um.message_id, m.message, m.send_time')
->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();
$time_date = date('Y-m-d H:i:s', $user_info['reg_time']);
$message_where = array(
'category' => 0,
'type' => 1,
'send_time' => array('gt', $time_date),
);
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')->comment('插入了没')->add(['user_id'=>$user_info['user_id'],'message_id'=>$key['message_id'],'category'=>0,'status'=>0]);
}
}
}