diff --git a/server/imserver/dbhelper.cc b/server/imserver/dbhelper.cc index b934fa3..458155e 100644 --- a/server/imserver/dbhelper.cc +++ b/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 + ); }