From 154959fbceaa29fc108d5cd4db02b6521a2c1890 Mon Sep 17 00:00:00 2001
From: aozhiwei <aozhiwe@kingsome.cn>
Date: Fri, 19 Jun 2020 14:46:40 +0800
Subject: [PATCH] 1

---
 server/imserver/dbhelper.cc | 41 +++++++++++++++++++++++++++++++++++++
 server/imserver/dbhelper.h  |  5 ++++-
 2 files changed, 45 insertions(+), 1 deletion(-)

diff --git a/server/imserver/dbhelper.cc b/server/imserver/dbhelper.cc
index 076b285..f7d3dd4 100644
--- a/server/imserver/dbhelper.cc
+++ b/server/imserver/dbhelper.cc
@@ -108,3 +108,44 @@ void DBHelper::AddFriendApply(Player* hum, const std::string& target_id)
          friend_crc32_code
          );
 }
+
+void DBHelper::AddEvent(const std::string& sender_id,
+                        const std::string& target_id,
+                        const std::string& event_name,
+                        const std::string& event_data)
+{
+    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)
+        {
+
+        };
+
+    long long crc32_code = a8::openssl::Crc32(
+                                              (unsigned char*)target_id.data(),
+                                              target_id.size()
+                                              );
+    a8::XObject conn_info = DBEngine::Instance()->GetConnInfo(crc32_code);
+    DBEngine::Instance()->ExecAsyncScript
+        (
+         conn_info,
+         "INSERT INTO `event_name`(sender_id, target_id, event_name, "
+         "   param1, param2, param3, event_data, status, createtime)"
+         "VALUES('%s', '%s', '%s', '', '', '', '%s', 0, %d);",
+         {
+          sender_id,
+          target_id,
+          event_name,
+          event_data,
+          App::Instance()->nowtime
+         },
+         a8::XParams(),
+         on_ok,
+         on_error,
+         crc32_code
+         );
+}
diff --git a/server/imserver/dbhelper.h b/server/imserver/dbhelper.h
index 5072613..762f7cd 100644
--- a/server/imserver/dbhelper.h
+++ b/server/imserver/dbhelper.h
@@ -23,6 +23,9 @@ class DBHelper : public a8::Singleton<DBHelper>
                               const std::string& target_id,
                               int status);
     void AddFriendApply(Player* hum, const std::string& target_id);
-
+    void AddEvent(const std::string& sender_id,
+                  const std::string& target_id,
+                  const std::string& event_name,
+                  const std::string& event_data);
 
 };