公会邀请信息处理

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];
+        }
+    }
 }