diff --git a/application/api/model/UserMessage.php b/application/api/model/UserMessage.php index c42459e..646c478 100644 --- a/application/api/model/UserMessage.php +++ b/application/api/model/UserMessage.php @@ -43,19 +43,19 @@ class UserMessage extends Model { //获取系统消息 $system_message = db::name('system_message') - ->where(['type'=>[1, 6]])//1系统消息 3公告下的房间推荐,4公告下的活动' 6工会邀请 + ->where(['type'=>['in',[1, 6]]])//1系统消息 3公告下的房间推荐,4公告下的活动' 6工会邀请 ->where('FIND_IN_SET(:user_id, receiving_id)', ['user_id' => $uid]) ->count(); //自己已经阅读过的信息 $user_read_message = db::name('user_message') - ->where(['user_id' => $uid,'type' => [1, 6]]) + ->where(['user_id' => $uid,'type' => ['in',[1, 6]]]) ->count(); $system_no_read_count = $system_message - $user_read_message; $system_last_message = db::name('system_message') ->field('id,type,title,content,url') - ->where('type', [1, 6])//1系统消息 3公告下的房间推荐,4公告下的活动' 6工会邀请 + ->where(['type'=>['in',[1, 6]]])//1系统消息 3公告下的房间推荐,4公告下的活动' 6工会邀请 ->where('FIND_IN_SET(:user_id, receiving_id)', ['user_id' => $uid]) ->order('id desc') ->find() ?? null; @@ -160,5 +160,22 @@ class UserMessage extends Model return ['code' => 1, 'msg' => '获取成功', 'data' => $list]; } - + //发生系统信息接口 + public function send_system_message($user_id, $title, $content, $type, $url='',$image="",$room_id=0){ + $data = [ + 'title' => $title, + 'content' => $content, + 'type' => $type, + 'url' => $url, + 'status' => 1, + 'createtime' => time(), + 'receiving_id' => $user_id, + ]; + $res = db::name('system_message')->insert($data); + if($res){ + return ['code' => 1, 'msg' => '发送成功', 'data' => null]; + }else{ + return ['code' => 0, 'msg' => '发送失败', 'data' => null]; + } + } } \ No newline at end of file