BreizhHardware/Jellystat
1
0
Fork 0
mirror of https://github.com/BreizhHardware/Jellystat.git synced 2026-01-18 16:27:20 +01:00
Code Issues Packages Projects Releases Wiki Activity

Logic fix for percentage in jf_recent_playback_activity

Browse Source
This commit is contained in:
Thegan Govender
2024-01-08 18:36:38 +02:00
parent a07daf84f0
commit c430378c8e
1 changed files with 159 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

159
backend/migrations/060_jf_recent_playback_activity_function_fix_2.js Normal file
View File

@@ -0,0 +1,159 @@
exports.up = async function(knex) {
try
{
await knex.schema.raw(`
CREATE OR REPLACE FUNCTION jf_recent_playback_activity(hour_offset INT)
RETURNS TABLE (
"RunTimeTicks" BIGINT,
"Progress" NUMERIC,
"Id" TEXT,
"IsPaused" BOOLEAN,
"UserId" TEXT,
"UserName" TEXT,
"Client" TEXT,
"DeviceName" TEXT,
"DeviceId" TEXT,
"ApplicationVersion" TEXT,
"NowPlayingItemId" TEXT,
"NowPlayingItemName" TEXT,
"SeasonId" TEXT,
"SeriesName" TEXT,
"EpisodeId" TEXT,
"PlaybackDuration" BIGINT,
"ActivityDateInserted" timestamptz,
"PlayMethod" TEXT,
"MediaStreams" JSON,
"TranscodingInfo" JSON,
"PlayState" JSON,
"OriginalContainer" TEXT,
"RemoteEndPoint" TEXT,
"ServerId" TEXT,
"Imported" BOOLEAN,
"RowNum" BIGINT
)
AS $$
BEGIN
RETURN QUERY
WITH rankedactivities AS (
SELECT COALESCE(i."RunTimeTicks", e."RunTimeTicks") AS "RunTimeTicks",
((a."PlaybackDuration" * 10000000)::numeric(100,0) / COALESCE(i."RunTimeTicks"::numeric(100,0), e."RunTimeTicks"::numeric(100,0), 1.0) * 100::numeric)::numeric(10,2) AS "Progress",
a."Id",
a."IsPaused",
a."UserId",
a."UserName",
a."Client",
a."DeviceName",
a."DeviceId",
a."ApplicationVersion",
a."NowPlayingItemId",
a."NowPlayingItemName",
a."SeasonId",
a."SeriesName",
a."EpisodeId",
a."PlaybackDuration",
a."ActivityDateInserted",
a."PlayMethod",
a."MediaStreams",
a."TranscodingInfo",
a."PlayState",
a."OriginalContainer",
a."RemoteEndPoint",
a."ServerId",
a.imported,
row_number() OVER (PARTITION BY a."NowPlayingItemId",a."UserId" ORDER BY a."ActivityDateInserted" DESC) AS rownum
FROM jf_playback_activity a
LEFT JOIN jf_library_items i ON a."NowPlayingItemId" = i."Id"
LEFT JOIN jf_library_episodes e ON a."EpisodeId" = e."EpisodeId"
WHERE a."ActivityDateInserted" > (CURRENT_TIMESTAMP - (hour_offset || ' hours')::interval)
ORDER BY a."ActivityDateInserted" DESC
)
SELECT * FROM rankedactivities WHERE rankedactivities.rownum = 1;
END;
$$ LANGUAGE plpgsql;
`
);
}catch (error) {
console.error(error);
}
};
exports.down = async function(knex) {
try {
await knex.raw(`
CREATE OR REPLACE FUNCTION jf_recent_playback_activity(hour_offset INT)
RETURNS TABLE (
"RunTimeTicks" BIGINT,
"Progress" NUMERIC,
"Id" TEXT,
"IsPaused" BOOLEAN,
"UserId" TEXT,
"UserName" TEXT,
"Client" TEXT,
"DeviceName" TEXT,
"DeviceId" TEXT,
"ApplicationVersion" TEXT,
"NowPlayingItemId" TEXT,
"NowPlayingItemName" TEXT,
"SeasonId" TEXT,
"SeriesName" TEXT,
"EpisodeId" TEXT,
"PlaybackDuration" BIGINT,
"ActivityDateInserted" timestamptz,
"PlayMethod" TEXT,
"MediaStreams" JSON,
"TranscodingInfo" JSON,
"PlayState" JSON,
"OriginalContainer" TEXT,
"RemoteEndPoint" TEXT,
"ServerId" TEXT,
"Imported" BOOLEAN,
"RowNum" BIGINT
)
AS $$
BEGIN
RETURN QUERY
WITH rankedactivities AS (
SELECT COALESCE(i."RunTimeTicks", e."RunTimeTicks") AS "RunTimeTicks",
(a."PlaybackDuration"::numeric(100,0) / COALESCE(i."RunTimeTicks"::numeric(100,0), e."RunTimeTicks"::numeric(100,0), 1.0) * 100::numeric)::numeric(10,2) AS "Progress",
a."Id",
a."IsPaused",
a."UserId",
a."UserName",
a."Client",
a."DeviceName",
a."DeviceId",
a."ApplicationVersion",
a."NowPlayingItemId",
a."NowPlayingItemName",
a."SeasonId",
a."SeriesName",
a."EpisodeId",
a."PlaybackDuration",
a."ActivityDateInserted",
a."PlayMethod",
a."MediaStreams",
a."TranscodingInfo",
a."PlayState",
a."OriginalContainer",
a."RemoteEndPoint",
a."ServerId",
a.imported,
row_number() OVER (PARTITION BY a."NowPlayingItemId",a."UserId" ORDER BY a."ActivityDateInserted" DESC) AS rownum
FROM jf_playback_activity a
LEFT JOIN jf_library_items i ON a."NowPlayingItemId" = i."Id"
LEFT JOIN jf_library_episodes e ON a."EpisodeId" = e."EpisodeId"
WHERE a."ActivityDateInserted" > (CURRENT_TIMESTAMP - (hour_offset || ' hours')::interval)
ORDER BY a."ActivityDateInserted" DESC
)
SELECT * FROM rankedactivities WHERE rankedactivities.rownum = 1;
END;
$$ LANGUAGE plpgsql;
`);
} catch (error) {
console.error(error);
}
};