反复登录聊天推送优化

application/api_broker/controller/Broker.php

@@ -23,6 +23,7 @@ use app\model\AAgents;
 use app\model\ABindingDevice;
 use app\model\ACollectUser;
 use app\model\ASite;
+use app\model\ChatUserExt;
 use app\model\Evaluate;
 use app\model\GOperatingRecords;
 use app\model\NoteLog;
@@ -189,18 +190,18 @@ class Broker extends Basic
         $redis_->set("agent_city_" . $agents_data['id'], $site_city[0]['city']);
         $redis_->set("agent_site_id_" . $agents_data['id'], $agents_data['site_id']);
 
-        /*处理多个手机登录*/
-        $m_bind = new ABindingDevice();
+        /*处理多个手机登录聊天*/
+        $m_chat_ext = new ChatUserExt();
         $bind_where['push_id'] = $params["push_id"];
         $bind_where['device_id'] = $params["device_id"];
-        $bind_where['agent_id'] = ['<>', $agents_data['id']];
-        $del_bind_id = $m_bind->getDeviceByAgentId($bind_where, 'id');
+        $bind_where['user_id'] = ['<>', $agents_data['id']];
+        $del_bind_id = $m_chat_ext->getChatUserExtByUserId($bind_where, 'a.id', 100);
         if (count($del_bind_id) > 0) {
             foreach ($del_bind_id as $v) {
-                $m_bind->updateDevice(['id'=>$v['id'],'is_forbidden'=>1]);
+                $m_chat_ext->updateDate(['is_forbidden'=>1], ['id'=>$v['id']]);
             }
         }
-        /*处理多个手机登录*/
+        /*处理多个手机登录聊天*/
 
         return $this->response(200, $data['msg'], $data['data']);
     }

application/model/ChatUserExt.php

@@ -75,6 +75,18 @@ class ChatUserExt extends BaseModel
             $where_['b.type'] = $params['type'];
         }
 
+        if (isset($params['user_id'])) {
+            $where_['b.user_id'] = $params['user_id'];
+        }
+
+        if (isset($params['push_id'])) {
+            $where_['a.push_id'] = $params['push_id'];
+        }
+
+        if (isset($params['device_id'])) {
+            $where_['a.device_id'] = $params['device_id'];
+        }
+
         $data = $this->db->field($field)
             ->alias("a")
             ->join("chat_user b", "a.ext_id = b.id", "right")
@@ -146,4 +158,21 @@ class ChatUserExt extends BaseModel
         return $array;
     }
 
+    /**
+     * 编辑
+     *
+     * @param array $params
+     * @param $where
+     * @return int
+     * @throws \Exception
+     */
+    public function updateDate(array $params, $where): int
+    {
+        try {
+            $num = $this->db->where($where)->update($params);
+        } catch (\Exception $exception) {
+            $num = 0;
+        }
+        return $num;
+    }
 }
\ No newline at end of file