Compare commits

..

No commits in common. "bcb58b7a781ac1bf1ed2cf63671e1dc786442a0d" and "d7ccbcd57fd33729f7dbef7d15db123f22e35fa8" have entirely different histories.

4 changed files with 31 additions and 4306 deletions

View File

@ -2,5 +2,5 @@
Sending requests from [mirzaev/spetsresurs-google_sheets-parser](https://git.mirzaev.sexy/mirzaev/spetsresurs-google_sheets-parser) to [mirzaev/arangodb](https://git.mirzaev.sexy/mirzaev/arangodb) and vice versa
~~😼 Developed in 1 day for 100000 rubles ($1200)~~ shit happens
😼 Developed in 1 days for 100000 rubles ($1200)

2
composer.lock generated
View File

@ -4,7 +4,7 @@
"Read more about it at https://getcomposer.org/doc/01-basic-usage.md#installing-dependencies",
"This file is @generated automatically"
],
"content-hash": "436a21927a120a646fa0e2f127f72421",
"content-hash": "3fd69eb362accef047acf98bf5aa1405",
"packages": [
{
"name": "bogdaan/viber-bot-php",

File diff suppressed because it is too large Load Diff

View File

@ -33,7 +33,7 @@ $botSender = new Sender([
]);
$log = new Logger('bot');
$log->pushHandler(new StreamHandler('../logs/robot.txt'));
$log->pushHandler(new StreamHandler('../bot.log'));
/**
* Авторизация
@ -93,11 +93,10 @@ function registration(string $id, string $number): bool
document::write($arangodb->session, 'viber', ['id' => $id, 'status' => 'inactive', 'number' => $number])
)
)) return false;
else throw new exception('Не удалось создать аккаунт или записать номер в существующий');
// Инициализация ребра: workers -> viber
if (
collection::init($arangodb->session, 'workers')
&& ($worker = collection::search(
if (($worker = collection::search(
$arangodb->session,
sprintf(
"FOR d IN workers FILTER d.phone == '%d' RETURN d",
@ -143,7 +142,7 @@ function generateMenuKeyboard(): Keyboard
(new Button())
->setBgColor('#97d446')
->setActionType('reply')
->setActionBody('btn-search-1')
->setActionBody('btn-search')
->setText('🔍 Активные заявки')
]);
}
@ -162,31 +161,16 @@ function generateNumberKeyboard(): Keyboard
]);
}
function generateEmojis(): string
{
return '&#' . hexdec(trim(array_rand(file(__DIR__ . '/../emojis.txt')))) . ';';
}
function requests(int $amount = 5, int $page = 1): Cursor
function requests(int $amount = 5): Cursor
{
global $arangodb;
// Фильтрация номера страницы
if ($page < 1) $page = 1;
// Инициализация номера страницы для вычислний
--$page;
// Инициализация сдвига
$offset = $page === 0 ? 0 : $page * $amount;
return (new _statement(
$arangodb->session,
[
'query' => sprintf(
"FOR d IN works FILTER d.confirmed != 'да' SORT d.created DESC LIMIT %d, %d RETURN d",
$offset,
$amount + $offset
"FOR d IN works FILTER d.confirmed != 'да' LIMIT %d RETURN d",
$amount
),
"batchSize" => 1000,
"sanitize" => true
@ -198,7 +182,7 @@ try {
$bot = new Bot(['token' => require('../settings/key.php')]);
$bot
->onText('|btn-request-choose-*|s', function ($event) use ($bot, $botSender) {
->onText('|btn-request-choose-*|s', function ($event) use ($bot, $botSender, $log) {
global $arangodb;
$id = $event->getSender()->getId();
@ -216,12 +200,6 @@ try {
// Запись о том, что задание подтверждено (в будущем здесь будет отправка на потдверждение модераторам)
$work->confirmed = 'да';
// Запись о том, что необходимо перенести изменения в Google Sheets
$work->transfer_to_sheets = 'да';
// Запись идентификатора Google Sheets нового сотрудника
$work->worker = $worker->id;
if (document::update($arangodb->session, $work)) {
// Записано обновление в базу данных
@ -231,7 +209,8 @@ try {
"FOR d IN readinesses FILTER d._id == '%s' RETURN d",
document::write($arangodb->session, 'readinesses', ['_from' => $worker->getId(), '_to' => $work->getId()])
)
)) {
)
) {
// Записано ребро: worker -> work (принятие заявки)
$bot->getClient()->sendMessage(
@ -265,31 +244,19 @@ try {
);
}
})
->onText('|btn-search-*|s', function ($event) use ($bot, $botSender) {
->onText('|btn-search|s', function ($event) use ($bot, $botSender) {
global $arangodb;
// Инициализация номера страницы
preg_match('/btn-search-(\d+)/', $event->getMessage()->getText(), $matches);
$page = $matches[1] ?? 1;
$id = $event->getSender()->getId();
if (($worker = authorization($id)) instanceof _document) {
// Авторизован
// Поиск заявок из базы данных
$requests = requests(6, $page);
$keyboard = [];
// Подсчёт количества прочитанных заявок из базы данных
$count = $requests->getCount();
$requests = requests(5);
// Проверка существования избытка
$excess = $count === 6;
// Обрезка заявок до размера страницы
$requests = array_slice($requests->getAll(), 0, 5);
if ($count === 0) {
if ($requests->getCount() < 1) {
$bot->getClient()->sendMessage(
(new Text())
->setSender($botSender)
@ -300,26 +267,6 @@ try {
return;
}
// Инициализация буфера клавиатуры для ответа
$keyboard = [];
// Генерация кнопки: "Следующая страница"
if ($excess) $keyboard[] = (new Button())
->setBgColor('#dce537')
->setTextSize('large')
->setActionType('reply')
->setActionBody('btn-search-' . $page + 1)
->setText('Следующая страница');
// Генерация кнопки: "Предыдущая страница"
if ($page > 1) $keyboard[] =
(new Button())
->setBgColor('#dce537')
->setTextSize('large')
->setActionType('reply')
->setActionBody('btn-search-' . $page - 1)
->setText('Предыдущая страница');
foreach ($requests as $request) {
// Перебор найденных заявок
@ -332,33 +279,31 @@ try {
)) instanceof _document) {
// Найден магазин
// Генерация эмодзи
/* $emoji = generateEmojis(); */
// Отправка сообщения с данной заявки
$bot->getClient()->sendMessage(
(new Text())
->setSender($botSender)
->setReceiver($id)
->setText("**#{$request->getKey()}**\n\n" . $request->date['converted'] . " (" . $request->start['converted'] . " - " . $request->end['converted'] . ")\n**Работа:** \"$request->work\"\n\n**Город:** $market->city\n**Адрес:** $market->address")
->setText("**#{$request->getKey()}**\n\n$request->date ($request->start - $request->end)\n**Работа:** \"$request->work\"\n\n**Город:** $market->city\n**Адрес:** $market->address")
);
// Запись выбора заявки в клавиатуру
$keyboard[] = (new Button())
->setBgColor(sprintf("#%02x%02x%02x", mt_rand(0, 255), mt_rand(0, 255), mt_rand(0, 255)))
->setTextSize('large')
->setTextSize('small')
->setActionType('reply')
->setActionBody("btn-request-choose-{$request->getKey()}")
->setText("#{$request->getKey()}");
}
}
$bot->getClient()->sendMessage((new Text())
$bot->getClient()->sendMessage(
(new Text())
->setSender($botSender)
->setReceiver($id)
->setMinApiVersion(3)
->setText("🔍 Выберите заявку")
->setKeyboard((new Keyboard())->setButtons($keyboard))
->setKeyboard((new Keyboard())->setButtons($keyboard ?? []))
);
} else if ($worker === null) {
// Не подключен
@ -378,7 +323,7 @@ try {
(new Text())
->setSender($botSender)
->setReceiver($id)
->setText('⛔ **Вы не авторизованы**')
->setText('⛔ **Вы не авторизованы**')
);
}
})
@ -413,7 +358,7 @@ try {
(new Text())
->setSender($botSender)
->setReceiver($id)
->setText('⛔ **Вы не авторизованы**')
->setText('⛔ **Вы не авторизованы**')
);
}
})
@ -448,7 +393,7 @@ try {
(new Text())
->setSender($botSender)
->setReceiver($id)
->setText('⛔ **Вы не авторизованы**')
->setText('⛔ **Вы не авторизованы**')
);
}
})
@ -483,17 +428,16 @@ try {
(new Text())
->setSender($botSender)
->setReceiver($id)
->setText('⛔ **Вы не авторизованы**')
->setText('⛔ **Вы не авторизованы**')
);
}
})
->on(function ($event) {
return ($event instanceof Message && $event->getMessage() instanceof Contact);
}, function ($event) use ($bot, $botSender) {
}, function ($event) use ($bot, $botSender, $log) {
$id = $event->getSender()->getId();
if (registration($id, $event->getMessage()->getPhoneNumber())) {
// Зарегистрирован
$bot->getClient()->sendMessage(
(new Text())
@ -519,18 +463,9 @@ try {
(new Text())
->setSender($botSender)
->setReceiver($id)
->setText('⛔ **Вы не авторизованы**')
->setText('⛔ **Вы не авторизованы**')
);
}
} else {
// Не зарегистрирован
$bot->getClient()->sendMessage(
(new Text())
->setSender($botSender)
->setReceiver($id)
->setText('⛔ **Вы не авторизованы**')
);
}
})
->run();