1
0
generated from mirzaev/pot

4 Commits
1.0.0 ... 1.0.3

Author SHA1 Message Date
accfe5a496 fixes 2025-03-06 06:17:11 +07:00
53f8f3871c fixed service 2025-03-06 05:51:16 +07:00
d2c86a6222 fixed settings 2025-03-06 05:49:58 +07:00
830ba25b8d production mode 2025-03-06 05:36:38 +07:00
6 changed files with 285 additions and 268 deletions

View File

@@ -5,7 +5,7 @@ Wants=network.target
After=syslog.target network-online.target
[Service]
ExecStart=sudo -u www-data /usr/bin/php /var/www/project/mirzaev/parser_from_interneturok/system/public/telegram.php
ExecStart=sudo -u www-data /usr/bin/php /var/www/parser_from_interneturok/mirzaev/parser_from_interneturok/system/public/telegram.php
PIDFile=/var/run/php/parser_from_interneturok-telegram.pid
RemainAfterExit=no
RuntimeMaxSec=3600s

View File

@@ -175,151 +175,151 @@ final class interneturok extends core
if (!empty($accounts)) {
// Initialized accounts
/* if (shuffle($accounts)) { */
// Shuffled accounts
if (shuffle($accounts)) {
// Shuffled accounts
foreach ($accounts as $account) {
// Iterating over accounts
// Waiting for processing the request
sleep($waiting);
if ($this->authentication($account)->wait()) {
// Authenticated the account
// Writing into the output buffer
echo 'Аутентифицирован: ' . $account['mail'] . "\n";
foreach ($accounts as $account) {
// Iterating over accounts
// Waiting for processing the request
sleep($waiting);
// Initializing the user journal
$journal = $this->journal(grade: $grade)->wait();
if (!empty($journal)) {
// Initialized the user journal
if ($this->authentication($account)->wait()) {
// Authenticated the account
// Writing into the output buffer
echo "Инициализирован журнал\n";
echo 'Аутентифицирован: ' . $account['mail'] . "\n";
// Initializing the actual date
$date = new datetime();
// Waiting for processing the request
sleep($waiting);
// Initializing the homeworks database
$model = new homework();
// Initializing the user journal
$journal = $this->journal(grade: $grade)->wait();
// Initializing the schedule subject events
$schedule = $journal?->schedule_events;
if (!empty($journal)) {
// Initialized the user journal
foreach ($schedule as $_subject) {
// Iterating over scheduled subject events
// Writing into the output buffer
echo "Инициализирован журнал\n";
if ($_subject->subject?->name === $subject->value) {
// Found the target suject
// Initializing the actual date
$date = new datetime();
foreach ($_subject->events as $event) {
// Iterating over the target subject events
// Initializing the homeworks database
$model = new homework();
// Normalizing the event variable (events can be more than one)
$event = $event[0] ?? null;
// Initializing the schedule subject events
$schedule = $journal?->schedule_events;
if (!empty($event)) {
// Initialized the target subject event (the homework exists)
foreach ($schedule as $_subject) {
// Iterating over scheduled subject events
if (new datetime($event->date) <= $date && new datetime($event->date)->modify('+6 days') >= $date) {
// Found the current event
if ($_subject->subject?->name === $subject->value) {
// Found the target suject
if ($event->subject?->name === $subject->value && $event->subject->grade === $grade) {
// Found the target subject
foreach ($_subject->events as $event) {
// Iterating over the target subject events
// Writing into the output buffer
echo "Найден школьный предмет: $subject->value для $grade класса (с " . new datetime($event->date)->format('d.m') . ' по ' . new datetime($event->date)->modify('+6 days')->format('d.m') . ")\n";
// Normalizing the event variable (events can be more than one)
$event = $event[0] ?? null;
// Initializing the unblock time
$unblock = svoboda::timestamp() - 31536000;
if (!empty($event)) {
// Initialized the target subject event (the homework exists)
foreach ($event->homeworks as $homework) {
// Iterating over scheduled event homeworks
if (new datetime($event->date) <= $date && new datetime($event->date)->modify('+6 days') >= $date) {
// Found the current event
if ($homework->status === 'checked' && $homework->mark === 5) {
// Homework checked and completed for a grade of 5
if ($event->subject?->name === $subject->value && $event->subject->grade === $grade) {
// Found the target subject
// Checking for the block record
$blocked = $model->database->read(
filter: fn(record $record) => $record->identifier === $homework->item_id && $record->created > $unblock,
amount: 1
)[0] ?? null;
// Writing into the output buffer
echo "Найден школьный предмет: $subject->value для $grade класса (с " . new datetime($event->date)->format('d.m') . ' по ' . new datetime($event->date)->modify('+6 days')->format('d.m') . ")\n";
if ($blocked instanceof record) {
// The account homework has been downloaded for 1 year
// Initializing the unblock time
$unblock = svoboda::timestamp() - 31536000;
continue 3;
} else {
// The account homework has not been downloaded for 1 year
foreach ($event->homeworks as $homework) {
// Iterating over scheduled event homeworks
// Writing into the output buffer
echo "Найдено домашнее задание: $homework->item_id с оценкой $homework->mark\n";
if ($homework->status === 'checked' && $homework->mark === 5) {
// Homework checked and completed for a grade of 5
// Waiting for processing the request
sleep($waiting);
// Checking for the block record
$blocked = $model->database->read(
filter: fn(record $record) => $record->identifier === $homework->item_id && $record->created > $unblock,
amount: 1
)[0] ?? null;
// Initializing the homework files
$files = $this->homework(lesson: $event->lesson->id, homework: $homework->item_id)->wait();
if ($blocked instanceof record) {
// The account homework has been downloaded for 1 year
if (!empty($files)) {
// Initialized the homework files
continue 3;
} else {
// The account homework has not been downloaded for 1 year
// Writing into the output buffer
echo "Получено домашнее задание\n";
echo "Найдено домашнее задание: $homework->item_id с оценкой $homework->mark\n";
// Blocking the homework downloading for 1 year
$blocked = $model->create(identifier: $homework->item_id);
// Waiting for processing the request
sleep($waiting);
if ($blocked !== false) {
// The homework was blocked for 1 year
// Initializing the homework files
$files = $this->homework(lesson: $event->lesson->id, homework: $homework->item_id)->wait();
// Writing into the output buffer
echo "Заблокировано на 1 год домашнее задание\n";
if (!empty($files)) {
// Initialized the homework files
// Exit (success)
return $files;
// Writing into the output buffer
echo "Получено домашнее задание\n";
// Blocking the homework downloading for 1 year
$blocked = $model->create(identifier: $homework->item_id);
if ($blocked !== false) {
// The homework was blocked for 1 year
// Writing into the output buffer
echo "Заблокировано на 1 год домашнее задание\n";
// Exit (success)
return $files;
}
}
}
}
}
}
}
// Stopping processing events and starting processing the next account
break 2;
// Stopping processing events and starting processing the next account
break 2;
}
}
}
}
// Stopping processing events and starting processing the next account
break;
// Stopping processing events and starting processing the next account
break;
}
}
} else {
// Not initialized the user journal
// Writing into the output buffer
echo "Аккаунт не подходит под требования\n";
// Proceed to processing the next account
continue;
}
} else {
// Not initialized the user journal
// Not authenticated the account
// Writing into the output buffer
echo "Аккаунт не подходит под требования\n";
echo "Не аутентифицирован\n";
// Proceed to processing the next account
continue;
}
} else {
// Not authenticated the account
// Writing into the output buffer
echo "Не аутентифицирован\n";
// Proceed to processing the next account
continue;
}
}
/* } */
}
// Exit (fail)
@@ -642,124 +642,29 @@ final class interneturok extends core
);
return $this->browser->sendAsync($request)
->then(function ($response) use ($homework) {
// Sended the request and received the response
->then(
function ($response) use ($homework) {
// Sended the request and received the response
// Initializing the lesson
$lesson = json_decode((string) $response->getBody())?->data?->homeschool?->response;
// Initializing the lesson
$lesson = json_decode((string) $response->getBody())?->data?->homeschool?->response;
foreach ($lesson->items as $section) {
// Iterating over the lesson sections
foreach ($lesson->items as $section) {
// Iterating over the lesson sections
if ($section->id === $homework && $section->item_type === 'homework' && $section->homework_kind === 'homework_base') {
// Found the base homework section
if ($section->id === $homework && $section->item_type === 'homework' && $section->homework_kind === 'homework_base') {
// Found the base homework section
// Initializng the test identifier (string)
$test = $section->homework_attributes?->parsed_content?->evo_test_id ?? null;
// Initializng the test identifier (string)
$test = $section->homework_attributes?->parsed_content?->evo_test_id ?? null;
if (!empty($test)) {
// Initialized the test identifier
// Initializing the request to the test data API
$request = new request(
'GET',
static::TESTS . "/$test/result",
[
'Authorization' => "Bearer $this->token"
]
);
return $this->browser->sendAsync($request)
->then(function ($response) use ($homework) {
// Sended the request and received the response
// Initializing the test result
$result = json_decode((string) $response->getBody())?->data?->tests?->response?->data;
if (!empty($result)) {
// Initialized the test result
// Initializing paths to the homework storage folder
$storage = STORAGE . DIRECTORY_SEPARATOR . 'homeworks' . DIRECTORY_SEPARATOR . $homework;
// Initializing the homework storage folder
if (!file_exists($storage)) mkdir($storage, 0775, true);
// Initializing the excel document
$excel = excel::create(['Домашнее задание']);
// Initializing the excel document sheet
$sheet = $excel->sheet();
// Writing settings of the excel document sheet
$sheet->setColWidths(['A' => 10, 'B' => 80, 'C' => 50]);
// Writing title
$sheet->writeRow(
['Номер', 'Задание', 'Ответ'],
[
'font' => [
'style' => 'bold'
],
'text-align' => 'center',
'vertical-align' => 'center',
'border' => 'thin',
'height' => 24,
]
);
foreach ($result->test?->questions as $question) {
// Iterating over questions
foreach ($question->answer_results as $answer) {
// Iterating over question answers
if ($answer->is_correct) {
// The answer is correct
if (!empty($answer->section)) {
// Several sections for answers (expected)
// Writing questions and answers
$sheet->writeRow([$question->test_question_position, $question->name, $answer->section->name . ' - ' . $answer->value]);
} else {
// One single answer (expected)
// Writing questions and answers
$sheet->writeRow([$question->test_question_position, $question->name, $answer->value]);
}
}
}
}
// Initializing path to the excel document file
$path = $storage . DIRECTORY_SEPARATOR . 'homework.xlsx';
// Writing the excel document file to the storage
$excel->save($path);
// Exit (success)
return [$path];
} else {
// Not initialized the test result
// Exit (fail)
return false;
}
})->wait();
} else {
// Not initialized the test identifier
// Initializing the attachment identifier
$attachment = $section->result?->id;
if (!empty($attachment)) {
// Initialized the attachment identifier
if (!empty($test)) {
// Initialized the test identifier
// Initializing the request to the test data API
$request = new request(
'GET',
static::ATTACHMENTS . "?attachable_id=$attachment&attachable_type=Result::Homework",
static::TESTS . "/$test/result",
[
'Authorization' => "Bearer $this->token"
]
@@ -769,71 +674,168 @@ final class interneturok extends core
->then(function ($response) use ($homework) {
// Sended the request and received the response
// Initializing attachments
$attachments = json_decode((string) $response->getBody())?->data?->homeschool?->response?->attachments;
// Initializing the test result
$result = json_decode((string) $response->getBody())?->data?->tests?->response?->data;
if (!empty($attachments)) {
// Initialized attachmetns
if (!empty($result)) {
// Initialized the test result
// Initializing paths to the homework attachments storage folder
$storage = STORAGE . DIRECTORY_SEPARATOR . 'homeworks' . DIRECTORY_SEPARATOR . $homework . DIRECTORY_SEPARATOR . 'attachments';
// Initializing paths to the homework storage folder
$storage = STORAGE . DIRECTORY_SEPARATOR . 'homeworks' . DIRECTORY_SEPARATOR . $homework;
// Initializing the homework attachments storage folder
// Initializing the homework storage folder
if (!file_exists($storage)) mkdir($storage, 0775, true);
// Declaring the buffer of files
$files = [];
// Initializing the excel document
$excel = excel::create(['Домашнее задание']);
foreach ($attachments as $attachment) {
// Iteration over attachments
// Initializing the excel document sheet
$sheet = $excel->sheet();
if ($attachment->uploader_role === 'student' && $attachment->attachable_type === 'Result::Homework') {
// Found the homework attachment
// Writing settings of the excel document sheet
$sheet->setColWidths(['A' => 10, 'B' => 80, 'C' => 50]);
// Initializing path to the downloaded file
$path = $storage . DIRECTORY_SEPARATOR . $attachment->attach_path;
// Writing title
$sheet->writeRow(
['Номер', 'Задание', 'Ответ'],
[
'font' => [
'style' => 'bold'
],
'text-align' => 'center',
'vertical-align' => 'center',
'border' => 'thin',
'height' => 24,
]
);
// Downloading the file
$this->browser->request('GET', $attachment->attach, ['sink' => $path]);
foreach ($result->test?->questions as $question) {
// Iterating over questions
// Writing path to the downloaded file into the buffer of files
$files[] = $path;
foreach ($question->answer_results as $answer) {
// Iterating over question answers
if ($answer->is_correct) {
// The answer is correct
if (!empty($answer->section)) {
// Several sections for answers (expected)
// Writing questions and answers
$sheet->writeRow([$question->test_question_position, $question->name, $answer->section->name . ' - ' . $answer->value]);
} else {
// One single answer (expected)
// Writing questions and answers
$sheet->writeRow([$question->test_question_position, $question->name, $answer->value]);
}
}
}
}
// Initializing path to the excel document file
$path = $storage . DIRECTORY_SEPARATOR . 'homework.xlsx';
// Writing the excel document file to the storage
$excel->save($path);
// Exit (success)
return $files;
return [$path];
} else {
// Not initialized attachments
// Not initialized the test result
// Exit (fail)
return false;
}
})->wait();
} else {
// Not initialized the attachment identifier
// Not initialized the test identifier
// Exit (fail)
return false;
// Initializing the attachment identifier
$attachment = $section->result?->id;
if (!empty($attachment)) {
// Initialized the attachment identifier
// Initializing the request to the test data API
$request = new request(
'GET',
static::ATTACHMENTS . "?attachable_id=$attachment&attachable_type=Result::Homework",
[
'Authorization' => "Bearer $this->token"
]
);
return $this->browser->sendAsync($request)
->then(function ($response) use ($homework) {
// Sended the request and received the response
// Initializing attachments
$attachments = json_decode((string) $response->getBody())?->data?->homeschool?->response?->attachments;
if (!empty($attachments)) {
// Initialized attachmetns
// Initializing paths to the homework attachments storage folder
$storage = STORAGE . DIRECTORY_SEPARATOR . 'homeworks' . DIRECTORY_SEPARATOR . $homework . DIRECTORY_SEPARATOR . 'attachments';
// Initializing the homework attachments storage folder
if (!file_exists($storage)) mkdir($storage, 0775, true);
// Declaring the buffer of files
$files = [];
foreach ($attachments as $attachment) {
// Iteration over attachments
if ($attachment->uploader_role === 'student' && $attachment->attachable_type === 'Result::Homework') {
// Found the homework attachment
// Initializing path to the downloaded file
$path = $storage . DIRECTORY_SEPARATOR . $attachment->attach_path;
// Downloading the file
$this->browser->request('GET', $attachment->attach, ['sink' => $path]);
// Writing path to the downloaded file into the buffer of files
$files[] = $path;
}
}
// Exit (success)
return $files;
} else {
// Not initialized attachments
// Exit (fail)
return false;
}
})->wait();
} else {
// Not initialized the attachment identifier
// Exit (fail)
return false;
}
}
}
}
}
// Exit (fail)
return false;
},
function ($response) use ($homework) {
if ($response->getStatusCode() === 402) {
// Fail (received the "Payment Required" status code)
// Writing into the output buffer
echo "Не удалось скачать домашнее задание $homework потому, что не оплачен тариф\n";
// Exit (fail)
return false;
},
function ($response) use ($homework) {
if ($response->getStatusCode() === 402) {
// Fail (received the "Payment Required" status code)
// Writing into the output buffer
echo "Не удалось скачать домашнее задание $homework потому, что не оплачен тариф\n";
// Exit (fail)
return false;
}
}
});
);
}
// Exit (fail)
@@ -898,16 +900,21 @@ final class interneturok extends core
*/
public static function amount(): int
{
// Opening the interneturok accounts file
$file = new spl(INTERNETUROK_ACCOUNTS_FILE, 'r');
try {
// Opening the interneturok accounts file
$file = new spl(INTERNETUROK_ACCOUNTS_FILE, 'r');
// Move the cursor to the last row
$file->seek(PHP_INT_MAX);
// Move the cursor to the last row
$file->seek(PHP_INT_MAX);
// Initializing number of the last row
$rows = $file->key();
// Initializing number of the last row
$rows = $file->key();
// Exit (success)
return $rows;
// Exit (success)
return $rows;
} catch (exception $exception) {
// Exit (fail)
return 0;
}
}
}

View File

@@ -17,6 +17,9 @@ use Zanzara\Context as context,
// Framework for asynchronous PHP
use function React\Async\await;
// Built-in libraries
use Exception as exception;
/**
* Telegram shcool subjects parser
*
@@ -205,26 +208,38 @@ final class parser extends core
// Initializing the parser
$parser = new interneturok();
// Parsing homework files
$files = $parser->parse(subject: $subject, grade: $grade, waiting: 0);
try {
if (!empty($files)) {
// Initialized homework files
// Parsing homework files
$files = $parser->parse(subject: $subject, grade: $grade, waiting: 3);
foreach ($files as $file) {
// Iterating over files in the storage
if (!empty($files)) {
// Initialized homework files
// Sending the file
await($context->sendDocument(new file_input($file)));
foreach ($files as $file) {
// Iterating over files in the storage
// Sending the file
await($context->sendDocument(new file_input($file)));
}
// Deleting in the telegram user buffer
$context->deleteUserDataItem(static::PROCESS);
} else {
// Not initialized homework files
// Sending the message
$context->sendMessage('❌ *Не найдены домашние задания')
->then(function (message $message) use ($context) {
// Sended the message
// Sending the menu with subjects
commands::menu($context);
});
}
// Deleting in the telegram user buffer
$context->deleteUserDataItem(static::PROCESS);
} else {
// Not initialized homework files
} catch (exception $exception) {
// Sending the message
$context->sendMessage('❌ *Не найдены домашние задания')
$context->sendMessage('⚠️ *Произошла ошибка при обработке домашних заданий')
->then(function (message $message) use ($context) {
// Sended the message

View File

@@ -32,9 +32,6 @@ define('VIEWS', INDEX . DIRECTORY_SEPARATOR . '..' . DIRECTORY_SEPARATOR . 'view
// Initializing path to the directory of settings
define('SETTINGS', INDEX . DIRECTORY_SEPARATOR . '..' . DIRECTORY_SEPARATOR . 'settings');
// Initializing system settings
require SETTINGS . DIRECTORY_SEPARATOR . 'system.php';
// Initializing path to the directory of the storage
define('STORAGE', INDEX . DIRECTORY_SEPARATOR . '..' . DIRECTORY_SEPARATOR . 'storage');

View File

@@ -5,5 +5,7 @@
*/
return [
1053489457 // Arsen Mirzaev Tatyano-Muradovich @redloser
1053489457, // Arsen Mirzaev Tatyano-Muradovich @redloser
6831961323, // @IU_K1LLER777
1142807069 // @kysakapro
];

View File

@@ -1,4 +0,0 @@
<?php
// Initializing default theme for the views templater
define('THEME', 'default');