Commit ce8657d4 authored by wwccw0591's avatar wwccw0591

pc

parent 797c9b8f
......@@ -115,10 +115,9 @@ $serv->on('Message', function($server, $frame) use($conf){
$redis->hSet(KEY_PRE.$memberId,'sendTime', time());
$server->push($frame->fd, responseJson(1,"sendMsg","success", $sendMessage));
$messageService->addMessage($sendMessage['fromId'],$sendMessage['fromUserId'],$sendMessage['fromUserName'],$sendMessage['fromType'],$sendMessage['message'],$sendMessage['toId'],$sendMessage['toUserId'],$sendMessage['toUserName'],$sendMessage['toType'],$sendMessage['id']);
$memberDb0Redis=\Redis\Db0\MemberRedisModel::getInstance();
$memberDb0Redis->tableHDel($memberId,'unread_message_count');
$sendMessage['message']=serialize($sendMessage['message']);
$redis->rPush('push_center',serialize($sendMessage));
$redis->tableHDel(KEY_PRE.$rev_data['toId'],'unread_message_count');
}
$redis->close();
unset($redis);
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment