message走统一方法

application/api/controller/Relation.php

@@ -177,15 +177,9 @@ class Relation extends Api
 
         //给对方一条消息
         $message = [
-            'user_id' => $to_uid,
-            'title'   => '关系审核',
             'content' => $this->auth->nickname . '申请与你成为'.$relation['name'],
-            'createtime' => time(),
-            'status' => 0,
-            'infotype' => 'newrelation',//建立关系
-            'infotype_id' => 0,
         ];
-        Db::name('message')->insertGetId($message);
+        $msg_id = \app\common\model\Message::addMessage($to_uid,'关系审核',$message['content'],'newrelation',0);
 
         //发起人也要发消息
         //系统消息
@@ -273,15 +267,9 @@ class Relation extends Api
         //给发起方一条消息
         $relation_name = Db::name('relation')->where('id',$info['relation_id'])->value('name');
         $message = [
-            'user_id' => $info['uid'],
-            'title'   => '关系申请结果',
             'content' => '和'.$this->auth->nickname.'成为'.$relation_name.':'.$remark2,
-            'createtime' => time(),
-            'status' => 0,
-            'infotype' => '',//建立关系
-            'infotype_id' => 0,
         ];
-        Db::name('message')->insertGetId($message);
+        $msg_id = \app\common\model\Message::addMessage($info['uid'],'关系申请结果',$message['content']);
 
         //
         $this->success($remark);
@@ -309,14 +297,9 @@ class Relation extends Api
         $relation_name = Db::name('relation')->where('id',$relation_id)->value('name');
         $message = [
             'user_id' => ($info['uid'] == $this->auth->id) ? $info['to_uid'] : $info['uid'],
-            'title'   => '关系取消',
             'content' => $this->auth->nickname.'已取消和你的'.$relation_name.'关系',
-            'createtime' => time(),
-            'status' => 0,
-            'infotype' => '',//建立关系
-            'infotype_id' => 0,
         ];
-        Db::name('message')->insertGetId($message);
+        $msg_id = \app\common\model\Message::addMessage($message['user_id'],'关系取消',$message['content']);
 
         //
         $this->success('关系已取消');