1

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
+         );
+}

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);
 
 };