From 1807268f9ef51b085c8a319ffc65c4fb8b5e361d Mon Sep 17 00:00:00 2001 From: aozhiwei Date: Mon, 22 Jun 2020 20:01:33 +0800 Subject: [PATCH] 1 --- server/imserver/dbhelper.cc | 2 ++ server/imserver/synchelper.cc | 9 +++++++++ server/imserver/synchelper.h | 1 + 3 files changed, 12 insertions(+) diff --git a/server/imserver/dbhelper.cc b/server/imserver/dbhelper.cc index 458155e..ad76924 100644 --- a/server/imserver/dbhelper.cc +++ b/server/imserver/dbhelper.cc @@ -7,6 +7,7 @@ #include "dbhelper.h" #include "player.h" #include "app.h" +#include "synchelper.h" void DBHelper::Init() { @@ -107,6 +108,7 @@ void DBHelper::AddFriendApply(Player* hum, const std::string& target_id) on_error, friend_crc32_code ); + SyncHelper::Instance()->SyncApplyFriend(hum, target_id); } void DBHelper::AddEvent(const std::string& sender_id, diff --git a/server/imserver/synchelper.cc b/server/imserver/synchelper.cc index 3d858cd..ee4970d 100644 --- a/server/imserver/synchelper.cc +++ b/server/imserver/synchelper.cc @@ -85,6 +85,15 @@ void SyncHelper::SyncUpdateFriend(Player* hum, const std::string& target_id) } +void SyncHelper::SyncApplyFriend(Player* hum, const std::string& target_id) +{ + ss::SS_IM_FriendApply* notifymsg = new ss::SS_IM_FriendApply(); + hum->FillIMMsgConext(notifymsg->mutable_context()); + notifymsg->set_target_id(target_id); + BroadcastIMConnMsg(*notifymsg); + delete notifymsg; +} + void SyncHelper::BroadcastIMConnMsg(int msgid, ::google::protobuf::Message& msg) { IMConnMgr::Instance()->TraverseIMConn diff --git a/server/imserver/synchelper.h b/server/imserver/synchelper.h index e8b61a9..7a32fc7 100644 --- a/server/imserver/synchelper.h +++ b/server/imserver/synchelper.h @@ -26,6 +26,7 @@ public: void SyncNewFriend(Player* hum, const std::string& target_id); void SyncDeleteFriend(Player* hum, const std::string& target_id); void SyncUpdateFriend(Player* hum, const std::string& target_id); + void SyncApplyFriend(Player* hum, const std::string& target_id); void _SS_IM_FriendAgreeResponse(f8::MsgHdr& hdr, const ss::SS_IM_FriendAgreeResponse& msg); void _SS_IM_FriendDeleteResponse(f8::MsgHdr& hdr, const ss::SS_IM_FriendDeleteResponse& msg);