mirror of
https://github.com/EQEmu/Server.git
synced 2025-12-12 05:21:29 +00:00
92128b98fd
* [Instances] Add `expire_at` Column * expire_at update * Update servertalk.h * Add rule Instances:ExpireOffsetTimeSeconds
49 lines
1.1 KiB
C++
49 lines
1.1 KiB
C++
#ifndef EQEMU_INSTANCE_LIST_REPOSITORY_H
|
|
#define EQEMU_INSTANCE_LIST_REPOSITORY_H
|
|
|
|
#include "../database.h"
|
|
#include "../strings.h"
|
|
#include "base/base_instance_list_repository.h"
|
|
|
|
class InstanceListRepository: public BaseInstanceListRepository {
|
|
public:
|
|
static int UpdateDuration(Database& db, uint16 instance_id, uint32_t new_duration)
|
|
{
|
|
auto results = db.QueryDatabase(
|
|
fmt::format(
|
|
"UPDATE `{}` SET `duration` = {}, `expire_at` = (`duration` + `start_time`) WHERE `{}` = {}",
|
|
TableName(),
|
|
new_duration,
|
|
PrimaryKey(),
|
|
instance_id
|
|
)
|
|
);
|
|
|
|
return results.Success() ? results.RowsAffected() : 0;
|
|
}
|
|
|
|
static uint32 GetRemainingTimeByInstanceID(Database& db, uint16 instance_id)
|
|
{
|
|
auto results = db.QueryDatabase(
|
|
fmt::format(
|
|
SQL(
|
|
SELECT (`expire_at` - UNIX_TIMESTAMP()) AS `remaining` FROM `{}`
|
|
WHERE `id` = {}
|
|
),
|
|
TableName(),
|
|
instance_id
|
|
)
|
|
);
|
|
|
|
if (!results.Success() || !results.RowCount()) {
|
|
return 0;
|
|
}
|
|
|
|
auto row = results.begin();
|
|
|
|
return Strings::ToUnsignedInt(row[0]);
|
|
}
|
|
};
|
|
|
|
#endif //EQEMU_INSTANCE_LIST_REPOSITORY_H
|