聊天关系

application/chat/service/ChatService.php

@@ -16,6 +16,7 @@ use app\model\Agents;
 use app\model\ChatMsg;
 use app\model\ChatMsgExt;
 use app\model\ChatMsgStatus;
+use app\model\ChatRelation;
 use app\model\ChatUser;
 use app\model\Users;
 
@@ -141,7 +142,8 @@ class ChatService
     public function sendMsg($target_type, $target, $source, $is_user, $type, $msg_content, $from, $accessToken)
     {
 
-        //todo
+        //todo 判断是否创建关系没有则保存
+        $this->verifyRelation($target,$from);
 
         $this->insertMsg($target_type, $target, $source, $is_user, $type, $msg_content, $from);
         $rPush = new RPush();
@@ -276,6 +278,18 @@ class ChatService
         }
     }
 
+
+    /**
+     * @param $target
+     * @param $from
+     */
+    private function verifyRelation($target, $from){
+        $chatRelationModel = new ChatRelation();
+        $param["to_id"] =
+        $chatRelationModel->getChatRelation();
+        //getChatRelation
+    }
+
     /**
      * 记录消息body
      * @param $id

application/model/ChatRelation.php

+<?php
+namespace app\model;
+/**
+ * Created by PhpStorm.
+ * User : zw
+ * Date : 2018/2/6
+ * Time : 16:07
+ * Intro:
+ */
+
+use think\Model;
+use think\Db;
+
+class ChatRelation extends Model
+{
+    // 设置当前模型对应的完整数据表名称
+    protected $table = 'chat_relation';
+    protected $db_;
+
+    public function __construct()
+    {
+        $this->db_ = Db($this->table);
+    }
+
+    public function getChatRelation($params, $field = "id,to_id,from_id")
+    {
+        return $this->db->field($field)
+            ->where($params)
+            ->find();
+    }
+
+    public function addChatRelation($params)
+    {
+        Db::startTrans();
+        try {
+            $this->insert($params);
+            Db::commit();
+        } catch (\Exception $e) {
+            Db::rollback();
+
+        }
+    }
+
+}
\ No newline at end of file