创建聊天关系

application/chat/service/ChatService.php

@@ -305,11 +305,10 @@ class ChatService
         $params["from"]    = $from;
 
         $relationResult = $chatRelationModel->getChatRelation($params);
-        if (count($relationResult) > 0) {
-            //表示关系已经建立
-            
+        if (count($relationResult) == 0) {
+            //如果没有记录则记录聊天关系
+            $chatRelationModel->addChatRelation($params);
         }
-        //getChatRelation
     }
 
     /**

application/model/ChatRelation.php

@@ -55,13 +55,23 @@ class ChatRelation extends Model
 
     public function addChatRelation($params)
     {
+        $where_ = [];
+        if (isset($params["target"])) {
+            $where_["to_id"] = $params["target"];
+        }
+        if (isset($params["from"])) {
+            $where_["from_id"] = $params["from"];
+        }
+
+        $where_["create_time"] = date("Y-m-d H:i:s",time());
+        $where_["update_time"] = date("Y-m-d H:i:s",time());
+
         Db::startTrans();
         try {
-            $this->insert($params);
+            $this->insert($where_);
             Db::commit();
         } catch (\Exception $e) {
             Db::rollback();
-
         }
     }