Leahnaya/pkmn-classic-framework
1
0
Fork 0
mirror of https://github.com/mm201/pkmn-classic-framework.git synced 2026-04-26 01:47:17 -05:00
Code Issues Actions Packages Projects Releases Wiki Activity

Update hype on watch/save

Browse Source
This commit is contained in:
Greg Edwards 2022-07-03 23:52:44 -04:00
parent 4a902f3b7e
commit b88a52461a
3 changed files with 85 additions and 47 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

123
library/Data/DataMysql.cs
View File

@ -2489,21 +2489,28 @@ namespace PkmnFoundations.Data
}
}
private void BattleVideoUpdateHypeTimes4(MySqlTransaction tran)
private void BattleVideoUpdateHypeTimes(MySqlTransaction tran, string tableName)
{
DateTime hypeTime = GetActiveHypeDate(DateTime.UtcNow);
// common case: HypeTimestamp is in the past and needs to be updated and decay applied.
tran.ExecuteNonQuery("UPDATE TerminalBattleVideos4 " +
"SET Hype = Hype / (1 << FLOOR(DATEDIFF(@hypetime, HypeTimestamp) / 7)), HypeTimestamp = @hypetime " +
"WHERE HypeTimestamp < @hypetime",
new MySqlParameter("@hypetime", hypeTime));
tran.ExecuteNonQuery("UPDATE " + tableName + " " +
"SET Hype = Hype / (1 << FLOOR(DATEDIFF(@hypetime, HypeTimestamp) / @decay)), HypeTimestamp = @hypetime " +
"WHERE HypeTimestamp < @hypetime",
new MySqlParameter("@hypetime", hypeTime),
new MySqlParameter("@decay", HYPE_DECAY_DAYS));
// unusual case: HypeTimestamp is in the future and reverse decay needs to be applied.
tran.ExecuteNonQuery("UPDATE TerminalBattleVideos4 " +
"SET Hype = Hype * (1 << FLOOR(DATEDIFF(HypeTimestamp, @hypetime) / 7)), HypeTimestamp = @hypetime " +
tran.ExecuteNonQuery("UPDATE " + tableName + " " +
"SET Hype = Hype * (1 << FLOOR(DATEDIFF(HypeTimestamp, @hypetime) / @decay)), HypeTimestamp = @hypetime " +
"WHERE HypeTimestamp > @hypetime",
new MySqlParameter("@hypetime", hypeTime));
new MySqlParameter("@hypetime", hypeTime),
new MySqlParameter("@decay", HYPE_DECAY_DAYS));
}
private void BattleVideoUpdateHypeTimes4(MySqlTransaction tran)
{
BattleVideoUpdateHypeTimes(tran, "TerminalBattleVideos4");
}
public BattleVideoHeader4[] BattleVideoSearch4(MySqlTransaction tran, ushort species, BattleVideoRankings4 ranking, BattleVideoMetagames4 metagame, byte country, byte region, int count)
@ -2611,21 +2618,46 @@ namespace PkmnFoundations.Data
return new BattleVideoHeader4(reader.GetInt32(0), reader.GetUInt64(1), data);
}
public MySqlDataReader BattleVideoGet(MySqlTransaction tran, string tableName, ulong serial, bool incrementViews)
{
string update;
MySqlParameter[] _params;
if (incrementViews)
{
DateTime now = DateTime.UtcNow;
DateTime hypeTime = GetActiveHypeDate(now);
double hype = HypeDecay(HYPE_WATCHED_VIDEO, now, hypeTime);
update = "UPDATE " + tableName + " " +
"SET Views = Views + 1, Hype = @hype, HypeTimestamp = @hype_timestamp WHERE SerialNumber = @serial; ";
_params = new[] {
new MySqlParameter("@hype", hype),
new MySqlParameter("@hype_timestamp", hypeTime),
new MySqlParameter("@serial", serial) };
}
else
{
update = "";
_params = new[] { new MySqlParameter("@serial", serial) };
}
return (MySqlDataReader)tran.ExecuteReader(update + "SELECT pid, " +
"SerialNumber, Header, Data FROM " + tableName + " " +
"WHERE SerialNumber = @serial",
_params);
}
public BattleVideoRecord4 BattleVideoGet4(MySqlTransaction tran, ulong serial, bool incrementViews = false)
{
string update = incrementViews ? "UPDATE TerminalBattleVideos4 " +
"SET Views = Views + 1 WHERE SerialNumber = @serial; "
: "";
using (MySqlDataReader reader = (MySqlDataReader)tran.ExecuteReader(update + "SELECT pid, " +
"SerialNumber, Header, Data FROM TerminalBattleVideos4 " +
"WHERE SerialNumber = @serial",
new MySqlParameter("@serial", serial)))
BattleVideoRecord4 result = null;
using (var reader = BattleVideoGet(tran, "TerminalBattleVideos4", serial, incrementViews))
{
if (reader.Read())
return BattleVideo4FromReader(reader);
else return null;
result = BattleVideo4FromReader(reader);
}
if (incrementViews) BattleVideoUpdateHypeTimes4(tran);
return result;
}
public override BattleVideoRecord4 BattleVideoGet4(ulong serial, bool incrementViews = false)
@ -2644,10 +2676,18 @@ namespace PkmnFoundations.Data
public bool BattleVideoFlagSaved4(MySqlTransaction tran, ulong serial)
{
DateTime now = DateTime.UtcNow;
DateTime hypeTime = GetActiveHypeDate(now);
double hype = HypeDecay(HYPE_SAVED_VIDEO, now, hypeTime);
int results = tran.ExecuteNonQuery("UPDATE TerminalBattleVideos4 " +
"SET Saves = Saves + 1 WHERE SerialNumber = @serial",
"SET Saves = Saves + 1, Hype = @hype, HypeTimestamp = @hype_timestamp WHERE SerialNumber = @serial",
new MySqlParameter("@hype", hype),
new MySqlParameter("@hype_timestamp", hypeTime),
new MySqlParameter("@serial", serial));
BattleVideoUpdateHypeTimes4(tran);
return results > 0;
}
@ -3191,19 +3231,7 @@ namespace PkmnFoundations.Data
private void BattleVideoUpdateHypeTimes5(MySqlTransaction tran)
{
DateTime hypeTime = GetActiveHypeDate(DateTime.UtcNow);
// common case: HypeTimestamp is in the past and needs to be updated and decay applied.
tran.ExecuteNonQuery("UPDATE TerminalBattleVideos5 " +
"SET Hype = Hype / (1 << FLOOR(DATEDIFF(@hypetime, HypeTimestamp) / 7)), HypeTimestamp = @hypetime " +
"WHERE HypeTimestamp < @hypetime",
new MySqlParameter("@hypetime", hypeTime));
// unusual case: HypeTimestamp is in the future and reverse decay needs to be applied.
tran.ExecuteNonQuery("UPDATE TerminalBattleVideos5 " +
"SET Hype = Hype * (1 << FLOOR(DATEDIFF(HypeTimestamp, @hypetime) / 7)), HypeTimestamp = @hypetime " +
"WHERE HypeTimestamp > @hypetime",
new MySqlParameter("@hypetime", hypeTime));
BattleVideoUpdateHypeTimes(tran, "TerminalBattleVideos5");
}
public BattleVideoHeader5[] BattleVideoSearch5(MySqlTransaction tran, ushort species, BattleVideoRankings5 ranking, BattleVideoMetagames5 metagame, byte country, byte region, int count)
@ -3318,19 +3346,14 @@ namespace PkmnFoundations.Data
public BattleVideoRecord5 BattleVideoGet5(MySqlTransaction tran, ulong serial, bool incrementViews = false)
{
string update = incrementViews ? "UPDATE TerminalBattleVideos5 " +
"SET Views = Views + 1 WHERE SerialNumber = @serial; "
: "";
using (MySqlDataReader reader = (MySqlDataReader)tran.ExecuteReader(update + "SELECT pid, " +
"SerialNumber, Header, Data FROM TerminalBattleVideos5 " +
"WHERE SerialNumber = @serial",
new MySqlParameter("@serial", serial)))
BattleVideoRecord5 result = null;
using (var reader = BattleVideoGet(tran, "TerminalBattleVideos5", serial, incrementViews))
{
if (reader.Read())
return BattleVideo5FromReader(reader);
else return null;
result = BattleVideo5FromReader(reader);
}
if (incrementViews) BattleVideoUpdateHypeTimes5(tran);
return result;
}
public override BattleVideoRecord5 BattleVideoGet5(ulong serial, bool incrementViews = false)
@ -3349,9 +3372,19 @@ namespace PkmnFoundations.Data
public bool BattleVideoFlagSaved5(MySqlTransaction tran, ulong serial)
{
return tran.ExecuteNonQuery("UPDATE TerminalBattleVideos5 " +
"SET Saves = Saves + 1 WHERE SerialNumber = @serial",
new MySqlParameter("@serial", serial)) > 0;
DateTime now = DateTime.UtcNow;
DateTime hypeTime = GetActiveHypeDate(now);
double hype = HypeDecay(HYPE_SAVED_VIDEO, now, hypeTime);
int results = tran.ExecuteNonQuery("UPDATE TerminalBattleVideos5 " +
"SET Saves = Saves + 1, Hype = @hype, HypeTimestamp = @hype_timestamp WHERE SerialNumber = @serial",
new MySqlParameter("@hype", hype),
new MySqlParameter("@hype_timestamp", hypeTime),
new MySqlParameter("@serial", serial));
BattleVideoUpdateHypeTimes5(tran);
return results > 0;
}
public override bool BattleVideoFlagSaved5(ulong serial)

3
library/Data/Database.cs
View File

@ -65,7 +65,8 @@ namespace PkmnFoundations.Data
return first + new TimeSpan((long)(diff.Ticks * weight));
}
private const double HYPE_DECAY_RATE = -0.09902102579427790134531887449403; // -ln(2)/7
internal const double HYPE_DECAY_DAYS = 7.0d;
internal const double HYPE_DECAY_RATE = -0.09902102579427790134531887449403; // -ln(2)/HYPE_DECAY_DAYS
internal const double HYPE_NEW_VIDEO = 5.0d;
internal const double HYPE_WATCHED_VIDEO = 1.0d;
internal const double HYPE_SAVED_VIDEO = 2.0d;

6
library/database.sql
View File

@ -1,6 +1,6 @@
-- --------------------------------------------------------
-- Host: 127.0.0.1
-- Server version: 10.3.28-MariaDB - mariadb.org binary distribution
-- Server version: 10.5.16-MariaDB - mariadb.org binary distribution
-- Server OS: Win64
-- HeidiSQL Version: 12.0.0.6518
-- --------------------------------------------------------
@ -999,6 +999,8 @@ CREATE TABLE IF NOT EXISTS `TerminalBattleVideos4` (
`Region` tinyint(3) unsigned NOT NULL,
`Views` int(10) unsigned NOT NULL DEFAULT 0,
`Saves` int(10) unsigned NOT NULL DEFAULT 0,
`Hype` double DEFAULT 0,
`HypeTimestamp` datetime DEFAULT '0000-00-00 00:00:00',
PRIMARY KEY (`id`),
KEY `SerialNumber` (`SerialNumber`),
KEY `TimeAdded` (`TimeAdded`),
@ -1027,6 +1029,8 @@ CREATE TABLE IF NOT EXISTS `TerminalBattleVideos5` (
`Region` tinyint(3) unsigned NOT NULL,
`Views` int(10) unsigned NOT NULL DEFAULT 0,
`Saves` int(10) unsigned NOT NULL DEFAULT 0,
`Hype` double DEFAULT 0,
`HypeTimestamp` datetime DEFAULT '0000-00-00 00:00:00',
PRIMARY KEY (`id`),
KEY `SerialNumber` (`SerialNumber`),
KEY `TimeAdded` (`TimeAdded`),