1

server/imserver/player.cc

@@ -838,5 +838,33 @@ void Player::SyncOtherFriend()
 
 void Player::ProcessEventTimerFunc()
 {
+    auto on_ok =
+        [] (a8::XParams& param, const f8::DataSet* data_set)
+        {
 
+        };
+    auto on_error =
+        [] (a8::XParams& param, int error_code, const std::string& error_msg)
+        {
+
+        };
+
+    a8::XObject conn_info = DBEngine::Instance()->GetConnInfo(myself.crc32_code);
+    DBEngine::Instance()->ExecAsyncQuery
+        (
+         conn_info,
+         "SELECT idx, applyid, target_id, sender_id, sender_nickname, "
+         "  sender_avatar_url, sender_sex, sender_data_version1, "
+         "  sender_user_value1, sender_user_value2, sender_user_value3, status "
+         "FROM friend_apply WHERE idx > %d AND target_id='%s' AND status=0;",
+         {
+          last_event_idx_,
+          myself.base_data.account_id
+         },
+         a8::XParams()
+         .SetSender(myself.base_data.account_id),
+         on_ok,
+         on_error,
+         myself.crc32_code
+         );
 }