1

server/imserver/dbhelper.cc

@@ -133,7 +133,7 @@ void DBHelper::AddEvent(const std::string& sender_id,
     DBEngine::Instance()->ExecAsyncScript
         (
          conn_info,
-         "INSERT INTO `event_name`(sender_id, target_id, event_name, "
+         "INSERT INTO `event`(sender_id, target_id, event_name, "
          "   param1, param2, param3, event_data, status, createtime)"
          "VALUES('%s', '%s', '%s', '', '', '', '%s', 0, %d);",
          {
@@ -154,5 +154,33 @@ void DBHelper::SetEventStatus(long long idx,
                               const std::string& target_id,
                               int status)
 {
+    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,
+         "UPDATE `event` SET status=%d WHERE idx=%d;",
+         {
+          status,
+          idx
+         },
+         a8::XParams(),
+         on_ok,
+         on_error,
+         crc32_code
+         );
 }