From 9e3e8d40118e423e79774436d068e2241a4f6f55 Mon Sep 17 00:00:00 2001 From: aozhiwei Date: Fri, 19 Jun 2020 14:56:02 +0800 Subject: [PATCH] =?UTF-8?q?=E5=AE=8C=E6=88=90=E4=BA=8B=E4=BB=B6=E8=AE=B0?= =?UTF-8?q?=E5=BD=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- server/imserver/constant.h | 1 + server/imserver/synchelper.cc | 21 +++++++++++++++++++-- 2 files changed, 20 insertions(+), 2 deletions(-) diff --git a/server/imserver/constant.h b/server/imserver/constant.h index 4a14e00..e4627da 100644 --- a/server/imserver/constant.h +++ b/server/imserver/constant.h @@ -37,6 +37,7 @@ enum NetHandler_e const char* const PROJ_NAME_FMT = "friend_imserver"; const char* const PROJ_ROOT_FMT = "/data/logs/%s"; +const char* const EVENT_FRIEND_AGREE = "friend.agree"; const char* const EVENT_FRIEND_DELETE = "friend.delete"; const int MAX_INSTANCE_ID = 1023; diff --git a/server/imserver/synchelper.cc b/server/imserver/synchelper.cc index dc767e4..3d858cd 100644 --- a/server/imserver/synchelper.cc +++ b/server/imserver/synchelper.cc @@ -9,6 +9,7 @@ #include "app.h" #include "IMConn.h" #include "IMConnMgr.h" +#include "dbhelper.h" #include "cs_proto.pb.h" #include "ss_proto.pb.h" @@ -140,10 +141,26 @@ void SyncHelper::RemovePendingRequest(long long seqid) void SyncHelper::SS_IM_FriendAgreeRequest_TimeOut(ss::SS_IM_FriendAgreeRequest* msg) { - + std::string event_data; + msg->context().user_info().SerializeToString(&event_data); + DBHelper::Instance()->AddEvent + ( + msg->context().user_info().base_data().account_id(), + msg->target_id(), + EVENT_FRIEND_AGREE, + event_data + ); } void SyncHelper::SS_IM_FriendDeleteRequest_TimeOut(ss::SS_IM_FriendDeleteRequest* msg) { - + std::string event_data; + msg->context().user_info().SerializeToString(&event_data); + DBHelper::Instance()->AddEvent + ( + msg->context().user_info().base_data().account_id(), + msg->target_id(), + EVENT_FRIEND_DELETE, + event_data + ); }