id = $id; $this->ignoreFd = Request::header('fd'); } /** * @param $ignoreFd */ public function setIgnoreFd($ignoreFd) { $this->ignoreFd = $ignoreFd; } public function start() { global $_A; $_A = [ '__fill_url_remote_url' => true, ]; // $msg = WebSocketDialogMsg::find($this->id); if (empty($msg)) { return; } $dialog = WebSocketDialog::find($msg->dialog_id); if (empty($dialog)) { return; } // 提及会员 $mentions = []; if ($msg->type === 'text') { preg_match_all("//", $msg->msg['text'], $matchs); if ($matchs) { $mentions = array_values(array_filter(array_unique($matchs[1]))); } } // 将会话以外的成员加入会话内 $userids = $dialog->dialogUser->pluck('userid')->toArray(); $diffids = array_values(array_diff($mentions, $userids)); if ($diffids) { // 仅(群聊)且(是群主或没有群主)才可以@成员以外的人 if ($dialog->type === 'group' && in_array($dialog->owner_id, [0, $msg->userid])) { $dialog->joinGroup($diffids, $msg->userid); $dialog->pushMsg("groupJoin", null, $diffids); $userids = array_values(array_unique(array_merge($mentions, $userids))); } } // 推送目标①：会话成员/群成员 $array = []; foreach ($userids AS $userid) { if ($userid == $msg->userid) { $array[$userid] = false; } else { $mention = array_intersect([0, $userid], $mentions) ? 1 : 0; WebSocketDialogMsgRead::createInstance([ 'dialog_id' => $msg->dialog_id, 'msg_id' => $msg->id, 'userid' => $userid, 'mention' => $mention, ])->saveOrIgnore(); $array[$userid] = $mention; } } // 更新已发送数量 $msg->send = WebSocketDialogMsgRead::whereMsgId($msg->id)->count(); $msg->save(); // 开始推送消息 foreach ($array as $userid => $mention) { PushTask::push([ 'userid' => $userid, 'ignoreFd' => $this->ignoreFd, 'msg' => [ 'type' => 'dialog', 'mode' => 'add', 'data' => array_merge($msg->toArray(), [ 'mention' => $mention, ]), ] ]); } // umeng推送app $umengUserid = $array; if (isset($umengUserid[$msg->userid])) { unset($umengUserid[$msg->userid]); } $umengUserid = array_keys($umengUserid); $umengTitle = User::userid2nickname($msg->userid); if ($dialog->type == 'group') { $umengTitle = "{$dialog->getGroupName()} ($umengTitle)"; } $umengMsg = new PushUmengMsg($umengUserid, [ 'title' => $umengTitle, 'body' => $msg->previewMsg(), 'description' => "MID:{$msg->id}", 'seconds' => 3600, 'badge' => 1, ]); Task::deliver($umengMsg); // 推送目标②：正在打开这个任务会话的会员 if ($dialog->type == 'group' && $dialog->group_type == 'task') { $list = User::whereTaskDialogId($dialog->id)->pluck('userid')->toArray(); if ($list) { $array = []; foreach ($list as $uid) { if (!in_array($uid, $userids)) { $array[] = $uid; } } if ($array) { PushTask::push([ 'userid' => $array, 'ignoreFd' => $this->ignoreFd, 'msg' => [ 'type' => 'dialog', 'mode' => 'chat', 'data' => $msg->toArray(), ] ]); } } } } }