mirror of
https://github.com/claradex/nativegallery.git
synced 2025-02-22 19:49:51 +03:00
task manager & contests via server
This commit is contained in:
themohooks
parent
b5ff9d1998
commit
be2963117a
4 changed files with 194 additions and 0 deletions
37
app/Controllers/Api/Admin/Settings/TaskManager.php
Normal file
37
app/Controllers/Api/Admin/Settings/TaskManager.php
Normal file
|
|
@ -0,0 +1,37 @@
|
|||
<?php
|
||||
|
||||
namespace App\Controllers\Api\Admin\Settings;
|
||||
|
||||
|
||||
|
||||
use App\Services\{Auth, Router, GenerateRandomStr, DB, Json, EXIF, TaskScheduler};
|
||||
use App\Models\{User, Vote, Photo};
|
||||
|
||||
|
||||
class TaskManager
|
||||
{
|
||||
public function __construct()
|
||||
{
|
||||
$task = new TaskScheduler();
|
||||
foreach (NGALLERY_TASKS as $t) {
|
||||
$id = $_GET['id'];
|
||||
if (isset($t['id']) && $t['id'] == $id) {
|
||||
if ($_GET['type'] === 0) {
|
||||
$task->removeTask($t['id'], "php ".$_SERVER['DOCUMENT_ROOT'].$t['handler']);
|
||||
} else {
|
||||
$task->addTask(
|
||||
$t['id'],
|
||||
"php ".$_SERVER['DOCUMENT_ROOT'].$t['handler']." >> ".$_SERVER['DOCUMENT_ROOT'].NGALLERY['root']['logslocation']." 2>&1",
|
||||
"* * * * *"
|
||||
);
|
||||
}
|
||||
echo json_encode(
|
||||
array(
|
||||
'errorcode' => 0,
|
||||
'error' => 0
|
||||
)
|
||||
);
|
||||
}
|
||||
}
|
||||
}
|
||||
}
|
||||
0
app/Controllers/Api/Images/RateContest.php
Normal file
0
app/Controllers/Api/Images/RateContest.php
Normal file
|
|
@ -8,6 +8,7 @@ use \App\Controllers\Api\{Login, Register};
|
|||
use \App\Controllers\Api\Subscribe as SubscribeUser;
|
||||
use \App\Controllers\Api\Images\{Upload};
|
||||
use \App\Controllers\Api\Images\Rate as PhotoVote;
|
||||
use \App\Controllers\Api\Images\RateContest as PhotoVoteContest;
|
||||
use \App\Controllers\Api\Images\Compress as PhotoCompress;
|
||||
use \App\Controllers\Api\Images\CheckAll as PhotoCheckAll;
|
||||
use \App\Controllers\Api\Images\LoadRecent as PhotoLoadRecent;
|
||||
|
|
@ -33,6 +34,7 @@ use \App\Controllers\Api\Admin\GeoDB\Load as AdminGeoDBLoad;
|
|||
use \App\Controllers\Api\Admin\GeoDB\Delete as AdminGeoDBDelete;
|
||||
use \App\Controllers\Api\Admin\Contests\CreateTheme as AdminContestsCreateTheme;
|
||||
use \App\Controllers\Api\Admin\Contests\Create as AdminContestsCreate;
|
||||
use \App\Controllers\Api\Admin\Settings\TaskManager as AdminTaskManager;
|
||||
|
||||
class ApiController
|
||||
{
|
||||
|
|
@ -53,6 +55,9 @@ class ApiController
|
|||
public static function photovote() {
|
||||
return new PhotoVote();
|
||||
}
|
||||
public static function photovotecontest() {
|
||||
return new PhotoVoteContest();
|
||||
}
|
||||
public static function photofavorite() {
|
||||
return new PhotoFavorite();
|
||||
}
|
||||
|
|
@ -125,6 +130,9 @@ class ApiController
|
|||
public static function admingeodbdelete() {
|
||||
return new AdminGeoDBDelete();
|
||||
}
|
||||
public static function admintaskmanager() {
|
||||
return new AdminTaskManager();
|
||||
}
|
||||
public static function vehiclesload() {
|
||||
return new VehiclesLoad();
|
||||
}
|
||||
|
|
|
|||
149
app/Controllers/Exec/Tasks/ExecContests.php
Normal file
149
app/Controllers/Exec/Tasks/ExecContests.php
Normal file
|
|
@ -0,0 +1,149 @@
|
|||
<?php
|
||||
|
||||
namespace App\Controllers\Exec\Tasks;
|
||||
require_once __DIR__ . '/../../../../vendor/autoload.php';
|
||||
use Symfony\Component\Yaml\Yaml;
|
||||
define("NGALLERY", Yaml::parse(file_get_contents(__DIR__ . '/../../../../ngallery.yaml'))['ngallery']);
|
||||
use App\Services\{Router, Auth, DB, Json, Date};
|
||||
use App\Controllers\ExceptionRegister;
|
||||
use App\Core\Page;
|
||||
|
||||
class ExecContests
|
||||
{
|
||||
public static function run()
|
||||
{
|
||||
if (NGALLERY['root']['contests']['enabled'] != true) {
|
||||
echo "Contests on this server disabled. Skip...";
|
||||
exit;
|
||||
}
|
||||
$contests = DB::query('SELECT * FROM contests WHERE status < 3');
|
||||
foreach ($contests as $contest) {
|
||||
self::processContest($contest);
|
||||
}
|
||||
}
|
||||
|
||||
private static function processContest(array $contest)
|
||||
{
|
||||
echo "Checking contest ID {$contest['id']}\n";
|
||||
|
||||
switch ($contest['status']) {
|
||||
case 0:
|
||||
self::handleOpenPretends($contest);
|
||||
break;
|
||||
case 1:
|
||||
self::handleClosePretends($contest);
|
||||
break;
|
||||
case 2:
|
||||
self::handleClosingContest($contest);
|
||||
break;
|
||||
}
|
||||
}
|
||||
|
||||
private static function handleOpenPretends(array $contest)
|
||||
{
|
||||
if (self::isAnotherContestInStatus(1)) {
|
||||
echo "[{$contest['id']}] Waiting for another contest to complete dialing. Skip...\n";
|
||||
return;
|
||||
}
|
||||
|
||||
if ($contest['openpretendsdate'] <= time()) {
|
||||
DB::query('UPDATE contests SET status = 1 WHERE id = :id', [':id' => $contest['id']]);
|
||||
echo "[{$contest['id']}] Opened for pretends.\n";
|
||||
} else {
|
||||
echo "[{$contest['id']}] Not ready for open pretends. Skip...\n";
|
||||
}
|
||||
}
|
||||
|
||||
private static function handleClosePretends(array $contest)
|
||||
{
|
||||
if (self::isAnotherContestInStatus(2)) {
|
||||
echo "[{$contest['id']}] Waiting for another contest to end. Skip...\n";
|
||||
return;
|
||||
}
|
||||
|
||||
if ($contest['closepretendsdate'] <= time() && $contest['opendate'] <= time()) {
|
||||
DB::query('UPDATE contests SET status = 2 WHERE id = :id', [':id' => $contest['id']]);
|
||||
echo "[{$contest['id']}] Closed for pretends.\n";
|
||||
} else {
|
||||
echo "[{$contest['id']}] Not closed for pretends. Skip...\n";
|
||||
}
|
||||
}
|
||||
|
||||
private static function handleClosingContest(array $contest)
|
||||
{
|
||||
if ($contest['closedate'] > time()) {
|
||||
echo "[{$contest['id']}] Waiting for end time. Skip...\n";
|
||||
return;
|
||||
}
|
||||
|
||||
echo "[{$contest['id']}] Ready for closing!\n";
|
||||
self::processVotes($contest);
|
||||
DB::query('UPDATE contests SET status = 3 WHERE id = :id', [':id' => $contest['id']]);
|
||||
echo "[{$contest['id']}] Closed.\n";
|
||||
if (NGALLERY['root']['contests']['autonew']['enabled'] === true) {
|
||||
echo "Creating new contest...";
|
||||
$theme = DB::query('SELECT * FROM contests_themes WHERE status=1 ORDER BY RAND() LIMIT 1')[0];
|
||||
$time = time();
|
||||
if (NGALLERY['root']['contests']['autonew']['pretendsopen'] === 'now') {
|
||||
$pretendsopen = $time;
|
||||
} else {
|
||||
$pretendsopen = Date::addTime(NGALLERY['root']['contests']['autonew']['pretendsopen']);
|
||||
}
|
||||
|
||||
$pretendsclose = Date::addTime(NGALLERY['root']['contests']['autonew']['pretendsclose']);
|
||||
if (NGALLERY['root']['contests']['autonew']['open'] === 'now') {
|
||||
$contestopen = $pretendsclose;
|
||||
} else {
|
||||
$contestopen = Date::addTime(NGALLERY['root']['contests']['autonew']['open']);
|
||||
}
|
||||
$contestclose = Date::addTime(NGALLERY['root']['contests']['autonew']['close']);
|
||||
DB::query('INSERT INTO contests VALUES (\'0\', :themeid, :openprdate, :closeprdate, :opendate, :closedate, 0)', array(':themeid'=>$theme['id'], ':openprdate'=>$pretendsopen, ':closeprdate'=>$pretendsclose, ':opendate'=>$contestopen, ':closedate'=>$contestclose));
|
||||
echo "Contest created! Continue...";
|
||||
}
|
||||
}
|
||||
|
||||
private static function processVotes(array $contest)
|
||||
{
|
||||
$votes = DB::query(
|
||||
'SELECT user_id, photo_id, COUNT(*) AS vote_count
|
||||
FROM photos_rates_contest WHERE contest_id = :id
|
||||
GROUP BY user_id ORDER BY vote_count DESC LIMIT 3',
|
||||
[':id' => $contest['id']]
|
||||
);
|
||||
|
||||
$place = 1;
|
||||
foreach ($votes as $vote) {
|
||||
self::updatePhotoContent($vote, $contest, $place);
|
||||
$place++;
|
||||
}
|
||||
}
|
||||
|
||||
private static function updatePhotoContent(array $vote, array $contest, int $place)
|
||||
{
|
||||
$photo = DB::query('SELECT * FROM photos WHERE id = :id', [':id' => $vote['photo_id']])[0];
|
||||
$photoData = json_decode($photo['content'], true);
|
||||
|
||||
$theme = DB::query('SELECT title FROM contests_themes WHERE id = :id', [':id' => $contest['themeid']])[0]['title'];
|
||||
|
||||
$photoData['contests'] = [
|
||||
'id' => $contest['id'],
|
||||
'contesttheme' => $theme,
|
||||
'votenum' => $vote['vote_count'],
|
||||
'place' => $place
|
||||
];
|
||||
|
||||
DB::query('UPDATE photos SET content = :content WHERE id = :id', [
|
||||
':id' => $vote['photo_id'],
|
||||
':content' => json_encode($photoData)
|
||||
]);
|
||||
}
|
||||
|
||||
private static function isAnotherContestInStatus(int $status): bool
|
||||
{
|
||||
return !empty(DB::query('SELECT status FROM contests WHERE status = :status', [':status' => $status]));
|
||||
}
|
||||
}
|
||||
|
||||
if (php_sapi_name() === 'cli') {
|
||||
ExecContests::run();
|
||||
}
|
||||
Loading…
Reference in a new issue