Compare commits

112 Commits

Author SHA1 Message Date
26eb5a9398 изменил функцию записи файлов 2025-10-30 10:58:31 +03:00
a97a28de6f исправил получение данных по сезону на команды. обновляется один раз 2025-10-29 14:23:49 +03:00
764c50e42d вернул обратно host на ref.russiabasket.org 2025-10-29 13:26:13 +03:00
d49244de54 Merge branch 'RFB4' of https://git.tvstart.ru/ychernenko/RFB into RFB4 2025-10-29 13:24:34 +03:00
a9605be520 подмена файлов get_data 2025-10-29 13:24:31 +03:00
763df5cb43 Добавлен аргумент -l 2025-10-29 09:16:10 +00:00
662f88c68b убрал indent=4. говорят это замедляет запись в json, если там много данных, а там много данных 2025-10-29 12:14:57 +03:00
c438f69578 поправил таймслип 2025-10-29 12:09:02 +03:00
9bf3624c8c поправил atomic_write_json 2025-10-29 11:52:17 +03:00
7b44ab3d5d get_json поменял местами данные 2025-10-29 11:44:13 +03:00
6721951c34 добавленны обработки json в потоках 2025-10-29 10:58:29 +03:00
ea34b6521f поправил нормальное отображение данных, пока данных по матчу нет.
1. отображение логотипов сегодняшего матча и надписи кто с кем
2. отображение средних показателей команд за сезон
3. турнирная таблица с подсветкой текущих команд
2025-10-28 16:12:18 +03:00
5ab179e47b Добавленна функция Pregame_JSON, которая сохраняет Team Comparison 2025-10-28 15:54:51 +03:00
1839b8aec3 time.sleep(.5) 2025-10-28 15:20:02 +03:00
f11b315d2f поправленны данные, когда матч онлайн, но нет live-status и box-score 2025-10-28 14:25:23 +03:00
15367b05fc обновил статусы матчей, чтобы правильнее ожидалось, когда матч сегодня 2025-10-28 13:45:50 +03:00
94d487fe88 добавлены Судьи, поправлены Ход игры и События игры на офлайн матч 2025-10-28 12:52:50 +03:00
049e2493b5 не доделал play_by_play 2025-10-27 21:14:52 +03:00
7e5ccdbb83 счет по четвертям в отображении 2025-10-27 21:06:14 +03:00
97045a0f72 поправил турнирку 2025-10-27 20:48:31 +03:00
b301f1e918 поправил еще раз запись данных, когда матч закончился 2025-10-27 20:34:24 +03:00
d86d1e5a4f поправил аргумент лиги, по дефолту vtb 2025-10-27 20:27:44 +03:00
6278a8e3df добавил функцию по прогону данных один раз, если матч старый 2025-10-27 20:17:24 +03:00
4ad11815a5 исправил проверку на live-status 2025-10-27 20:04:12 +03:00
cbcad5e525 подсветка команда в турнирке 2025-10-27 19:50:05 +03:00
48c5f552ec турнирка 2025-10-27 19:44:45 +03:00
b0511d51d3 отрефакторенный код 2025-10-27 19:34:24 +03:00
6fa1ad3f35 сон 2025-10-27 19:26:40 +03:00
d821967f33 добавил сон до следующего дня после выполнения работы 2025-10-27 19:23:27 +03:00
b11dbdeae8 test23 2025-10-27 19:11:08 +03:00
91c6eeddc5 test22 2025-10-27 19:02:32 +03:00
842af85847 test21 2025-10-27 19:00:15 +03:00
225e158c53 test20 2025-10-27 18:59:33 +03:00
276ecdcb85 test19 2025-10-27 18:58:50 +03:00
adc067293f test18 2025-10-27 18:52:32 +03:00
27a7ffcaad test17 2025-10-27 18:44:33 +03:00
02582bdab0 test16 2025-10-27 18:43:16 +03:00
4048f8fdfa test15 2025-10-27 18:40:31 +03:00
b0aba27764 test14 2025-10-27 18:39:25 +03:00
b27e02bb49 test13 2025-10-27 18:32:30 +03:00
ff3883aa36 test12 2025-10-27 18:29:19 +03:00
f72914a085 test11 2025-10-27 18:22:37 +03:00
10baa5b2fb test10 2025-10-27 18:18:40 +03:00
6a06d54aa4 test9 2025-10-27 18:15:14 +03:00
58bfdce841 test8 2025-10-27 18:13:03 +03:00
9fa68a165d test7 2025-10-27 18:01:04 +03:00
ee58ad868d test6 2025-10-27 17:54:49 +03:00
5470df8da9 test5 2025-10-27 17:53:18 +03:00
8fa3acf3f2 test4 2025-10-27 17:49:58 +03:00
858ed5c6a7 test3 2025-10-27 17:44:09 +03:00
09dfbef09a test2 2025-10-27 17:34:50 +03:00
c4de3c84fe test1 2025-10-27 16:55:15 +03:00
000b304ed9 test 2025-10-27 13:51:00 +03:00
8f34737186 исправил данные из box-score, которые успешно проебал 2025-10-24 19:09:18 +03:00
58bff8ba53 поправил фолы в live_status и отображение их в visual 2025-10-24 18:54:45 +03:00
82f1450ff5 Merge branch 'main' of https://git.tvstart.ru/ychernenko/RFB 2025-10-24 18:47:11 +03:00
7a61c0bfb6 обновил visual для подгрузки турнирной таблицы
поправил функцию в get_data которая пушит онлайн данные (требует тщательной проверки)
2025-10-24 18:47:07 +03:00
d75f0e6407 add oline logo 2025-10-24 15:37:42 +00:00
dcfcbb0958 добавлена функция генерации турнирной таблицы раз в 10 минут с сообщением в телеграм 2025-10-24 18:12:26 +03:00
629854c104 добавленны создание онлайн/оффлайн фолов и поправил функцию на склеивание онлайн данных (нужно проверить) 2025-10-24 17:35:12 +03:00
893d18ee23 изменил чат id для телеграм 2025-10-24 16:22:46 +03:00
c9613f91a3 добавил функцию Scores_Quarter 2025-10-24 15:41:42 +03:00
5ea03d2efc создание папки logs 2025-10-24 15:19:16 +03:00
bacee0e9b8 добавил две функции: командная статистика и рефери 2025-10-24 15:10:38 +03:00
0844d577ff добавил в Json_Team_Generation сохранение файлов Top_team и Started_team 2025-10-24 14:49:40 +03:00
d7c819357d поправил чтение json файлов 2025-10-24 14:15:37 +03:00
efa4812b09 Испараввлена проблема ковычек в аргументе передоваемом deploy.sh в data.py 2025-10-24 13:59:59 +03:00
c62c8a31a6 поправил некоторые выводы в телеграм 2025-10-24 10:35:02 +00:00
a13cb945c7 поправлен logger 2025-10-24 10:16:57 +00:00
5083423660 переобут logger 2025-10-24 10:06:38 +00:00
c30bc088c7 новая версия get_data. вроде как работает обработка данных в зависимости от статуса матча и если матч старый грузится один раз данные, и ожидает следующего дня 2025-10-24 09:32:19 +00:00
d9ad941a80 старая версия get_data 2025-10-24 09:31:02 +00:00
84169208ab Добавление ковычек при создании сервиса дата 2025-10-24 09:18:16 +00:00
39ba101948 Merge branch 'main' of https://git.tvstart.ru/ychernenko/RFB 2025-10-23 21:51:19 +03:00
886339b183 хз что) 2025-10-23 21:51:04 +03:00
00a01eb8a9 Update README.md 2025-10-22 18:21:33 +00:00
313c82c006 Merge branch 'Barabanov_TEST' into main 2025-10-22 17:06:18 +00:00
b45d7ec129 Merge branch 'Barabanov_TEST' of https://git.tvstart.ru/ychernenko/RFB into Barabanov_TEST 2025-10-22 16:08:46 +00:00
8b2f2f5e23 Add README.md 2025-10-22 15:16:53 +00:00
b021034b4a rename 2025-10-22 15:07:53 +00:00
963c7a503b no "$team" 2025-10-22 14:31:10 +00:00
e375613692 add config.toml 2025-10-22 13:47:36 +00:00
0b85081ba5 22.10.2025 test REF 2025-10-22 13:22:23 +00:00
b8b79b5f58 ThreadPoolExecutor = 1 2025-10-22 16:00:58 +03:00
6d3d5d3702 Console INFO 2025-10-22 15:59:06 +03:00
9b0c276d36 change from pro to ref 2025-10-22 15:50:03 +03:00
b0f59e5bf3 jkshdbgv 2025-10-22 12:47:16 +00:00
5cb7b2f6c8 GBPLF 2025-10-22 15:43:36 +03:00
a1b1466f4b add "$tem" to ExecStart 2025-10-22 11:06:24 +00:00
dbc6ca3ef9 Team name change 2025-10-22 10:56:28 +00:00
856ca094b1 Merge remote-tracking branch 'origin/main' into Barabanov_TEST 2025-10-22 10:49:11 +00:00
139740b48f dell 2025-10-22 10:47:27 +00:00
1b13768d12 Merge branch 'main' of https://git.tvstart.ru/ychernenko/RFB 2025-10-22 10:40:32 +00:00
c3469b62ef merge 2025-10-22 10:34:32 +00:00
74467aedb5 Merge branch 'main' into Barabanov_TEST 2025-10-22 09:52:20 +00:00
982655faa1 22.10.205 2025-10-22 09:47:44 +00:00
8ea87b371a add print for debug 2025-10-21 21:10:17 +00:00
8f6ae70389 split servises 2025-10-21 16:17:48 +00:00
92211a55f1 split servises 2025-10-21 09:27:29 +00:00
d4d9964282 add streamlit_autorefresh 2025-10-21 09:01:49 +00:00
24860de8c6 add start_rfb.sh 2025-10-21 08:56:41 +00:00
5ad95a1d57 setup.sh 2025-10-21 08:35:06 +00:00
d4e1dacf20 add streamlit 2025-10-20 16:41:52 +00:00
d528ee8de6 add requirements 2025-10-20 16:17:59 +00:00
2d553db6bc cleanUP 2025-10-20 15:55:42 +00:00
0db5d80e19 clean_UP 2025-10-20 15:53:18 +00:00
Alexey Barabanov
ca7cd72b74 SH update 2025-10-20 18:43:53 +03:00
Alexey Barabanov
1a344d2be2 RUN.sh update 2025-10-20 14:03:23 +03:00
Alexey Barabanov
2bd99cf663 add RUN.sh 2025-10-20 13:59:12 +03:00
Alexey Barabanov
e1aa4c993a Test_RUN 2025-10-20 13:33:37 +03:00
Alexey Barabanov
55925f3847 gitignore_Update 2025-10-20 13:15:05 +03:00
Alexey Barabanov
dc0574dc8d CleanUP 2025-10-20 12:54:18 +03:00
9 changed files with 7925 additions and 2969 deletions

4
.gitignore vendored
View File

@@ -2,3 +2,7 @@
/JSON/*
/logs/*
/static/*
get_data_new copy 2.py
get_data_new copy.py
temp.json
get_data_new copy 3.py

5
.streamlit/config.toml Normal file
View File

@@ -0,0 +1,5 @@
[browser]
gatherUsageStats = false
[server]
enableStaticServing = true

105
README.md Normal file
View File

@@ -0,0 +1,105 @@
![VTB logo](https://vtb-league.com/docs/brand/2019/VTB%20League%20logo%20RGB.png)
RFB Stat - это система для автоматического сбора баскетбольной статистики.
Система состоит из двух основных компонентов:
Сервис данных (rfb-data.service) - сбор и обработка данных
Сервис визуализации (rfb-visual.service) - веб-интерфейс на основе Streamlit
Требования
* Ubuntu Linux
* Доступ к репозиторию `https://git.tvstart.ru/`
* *Права root для установки!!*
# Установка
Скрипт установки выполняет полную настройку системы:
```shell
chmod +x deploy.sh
./deploy.sh -t <команда> -r <релиз>
```
Параметры командной строки
-t - Название команды (опционально, определяется по IP если не указано)
-r - Релиз (ветка или тег в git, по умолчанию: main)
-h - Справка по использованию
# Примеры использования
Установка с автоопределением команды по IP
```shell
./deploy.sh -r main
```
Установка для конкретной команды
```shell
./deploy.sh -t cska -r main
```
Установка тестовой версии
```shell
./deploy.sh -t zenit -r Barabanov_TEST
```
# Пакеты и прочее что будет установленно:
Системные пакеты:
* Python3
* pip3
* virtualenv
* Git
* Net-tools
Виртуальное окружение Python с зависимостями:
* streamlit
* requests
* pandas
* numpy
* plotly
* watchdog
* pillow
* streamlit_autorefresh
# Systemd сервисы:
`rfb-data.service - сбор данных`
`rfb-visual.service - веб-интерфейс`
# Управление сервисами
Просмотр статуса обоих сервисов одновременно
```shell
systemctl status rfb-data.service rfb-visual.service
```
# Просмотр логов
Логи сбора данных
```shell
journalctl -u rfb-data.service -f
```
Логи веб-интерфейса
```shell
journalctl -u rfb-visual.service -f
```
# Управление сервисами
Перезапуск всех сервисов
```shell
systemctl restart rfb-data.service rfb-visual.service
```
Остановка всех сервисов
```shell
systemctl stop rfb-data.service rfb-visual.service
```
Запуск всех сервисов
```shell
systemctl start rfb-data.service rfb-visual.service
```
# Доступ к приложению
После установки приложение доступно по адресу:
`http://ВАШ_IP_АДРЕС:8501`

495
deploy.sh Executable file
View File

@@ -0,0 +1,495 @@
#!/bin/bash
# Настройка цветов для вывода
RED='\033[0;31m'
GREEN='\033[0;32m'
YELLOW='\033[1;33m'
NC='\033[0m' # No Color
show_help() {
echo "Использование: $0 -t <домашняя команда> -r <релиз> [-l <лига>]"
echo " -t Домашняя команда"
echo " -r Релиз (тег или ветка в git)"
echo " -l Лига (опционально)"
echo " -h Показать эту справку"
echo ""
echo "Пример: $0 -t cska -r main"
echo "Пример: $0 -t zenit -r Barabanov_TEST -l vtb"
echo "Пример: $0 -t avtodor -r main"
echo ""
exit 0
}
# Функция для вывода цветных сообщений
log_info() {
echo -e "${GREEN}[INFO]${NC} $1"
}
log_warn() {
echo -e "${YELLOW}[WARN]${NC} $1"
}
log_error() {
echo -e "${RED}[ERROR]${NC} $1"
}
# Функция проверки и установки пакетов
install_packages() {
log_info "Обновление списка пакетов..."
apt-get update
log_info "Установка необходимых пакетов..."
apt-get install -y python3 python3-pip python3-venv git systemd net-tools
# Проверка установки
if ! command -v python3 &> /dev/null; then
log_error "Python3 не установлен!"
exit 1
fi
if ! command -v pip3 &> /dev/null; then
log_error "pip3 не установлен!"
exit 1
fi
log_info "Версия Python: $(python3 --version)"
log_info "Версия pip: $(pip3 --version)"
}
# Функция загрузки кода
download_code() {
local repo_url="https://git.tvstart.ru/ychernenko/RFB.git"
local release="$1"
local target_dir="/root/RFB"
log_info "Создание рабочей директории $target_dir..."
mkdir -p $target_dir
if [ -d "$target_dir/.git" ]; then
log_info "Обновление существующего репозитория..."
cd $target_dir
git fetch --all
git checkout $release
git pull origin $release
else
log_info "Клонирование репозитория $repo_url..."
git clone $repo_url $target_dir
cd $target_dir
git checkout $release
fi
# Проверка успешности checkout
if [ $? -ne 0 ]; then
log_error "Не удалось переключиться на релиз $release"
log_error "Доступные ветки:"
git branch -r
exit 1
fi
log_info "Код успешно загружен (релиз: $release)"
log_info "Текущая ветка: $(git branch --show-current)"
}
# Функция обновления requirements.txt
update_requirements() {
local target_dir="/root/RFB"
cd $target_dir
log_info "Обновление requirements.txt..."
# Создаем или обновляем requirements.txt
if [ ! -f "requirements.txt" ]; then
log_warn "requirements.txt не найден, создаем новый..."
cat > requirements.txt << EOF
streamlit>=1.28.0
requests>=2.31.0
pandas>=2.0.0
numpy>=1.24.0
plotly>=5.15.0
watchdog>=3.0.0
pillow>=10.0.0
streamlit_autorefresh>=0.1.7
EOF
else
# Проверяем, есть ли streamlit_autorefresh в requirements.txt
if ! grep -q "streamlit_autorefresh" requirements.txt; then
log_info "Добавляем streamlit_autorefresh в requirements.txt..."
echo "streamlit_autorefresh>=0.1.7" >> requirements.txt
else
log_info "streamlit_autorefresh уже есть в requirements.txt"
fi
fi
log_info "Содержимое requirements.txt:"
cat requirements.txt
}
# Функция настройки виртуального окружения
setup_venv() {
local target_dir="/root/RFB"
cd $target_dir
log_info "Создание виртуального окружения..."
python3 -m venv .venv
if [ ! -f ".venv/bin/activate" ]; then
log_error "Не удалось создать виртуальное окружение"
exit 1
fi
log_info "Активация виртуального окружения и установка зависимостей..."
source .venv/bin/activate
# Обновление pip
pip install --upgrade pip
# Обновляем requirements.txt перед установкой
update_requirements
if [ -f "requirements.txt" ]; then
log_info "Установка зависимостей из requirements.txt..."
pip install -r requirements.txt
else
log_warn "Файл requirements.txt не найден, устанавливаем базовые зависимости..."
pip install streamlit requests pandas numpy plotly watchdog pillow streamlit_autorefresh
fi
# Дополнительная проверка и установка streamlit_autorefresh на всякий случай
if ! python -c "import streamlit_autorefresh" 2>/dev/null; then
log_info "Устанавливаем streamlit_autorefresh..."
pip install streamlit_autorefresh
fi
# Проверка установки streamlit
if ! [ -f ".venv/bin/streamlit" ]; then
log_error "Streamlit не установлен в виртуальном окружении"
exit 1
fi
log_info "Проверка установленных пакетов:"
python -c "
import streamlit, requests, pandas, numpy, plotly, streamlit_autorefresh
print('✓ Все основные пакеты успешно импортируются')
"
log_info "Установленные пакеты:"
pip list --format=columns | grep -E "(streamlit|requests|pandas|numpy|plotly|autorefresh)"
}
# Функция создания systemd сервисов
create_systemd_services() {
local team="$1"
local league="$2"
log_info "Создание отдельных systemd сервисов для команды: $team"
if [ -n "$league" ]; then
log_info "Лига: $league"
fi
# Останавливаем и отключаем старые сервисы если они есть
for service in rfb-data.service rfb-visual.service rfb-stat.service; do
if systemctl is-active --quiet $service; then
log_info "Остановка $service..."
systemctl stop $service
fi
if systemctl is-enabled --quiet $service; then
log_info "Отключение $service..."
systemctl disable $service
fi
done
# Формируем команду для data сервиса
local data_command="/root/RFB/.venv/bin/python3 /root/RFB/get_data.py --team \"$team\""
if [ -n "$league" ]; then
data_command="$data_command --league \"$league\""
fi
# Сервис для data
local data_service_file="/etc/systemd/system/rfb-data.service"
cat > $data_service_file << EOF
[Unit]
Description=RFB Data Service
After=network.target
[Service]
Type=simple
User=root
WorkingDirectory=/root/RFB
Environment=PATH=/root/RFB/.venv/bin
ExecStart=$data_command
Restart=always
RestartSec=10
StandardOutput=journal
StandardError=journal
[Install]
WantedBy=multi-user.target
EOF
# Сервис для visual
local visual_service_file="/etc/systemd/system/rfb-visual.service"
cat > $visual_service_file << EOF
[Unit]
Description=RFB Visual Service
After=network.target rfb-data.service
[Service]
Type=simple
User=root
WorkingDirectory=/root/RFB
Environment=PATH=/root/RFB/.venv/bin
ExecStart=/root/RFB/.venv/bin/streamlit run /root/RFB/visual.py --server.port 8501 --server.address 0.0.0.0
Restart=always
RestartSec=10
StandardOutput=journal
StandardError=journal
[Install]
WantedBy=multi-user.target
EOF
# Настройка прав
chmod 644 $data_service_file $visual_service_file
log_info "Перезагрузка systemd демонов..."
systemctl daemon-reload
log_info "Включение сервисов..."
systemctl enable rfb-data.service rfb-visual.service
}
# Функция проверки файлов
check_required_files() {
local target_dir="/root/RFB"
cd $target_dir
local missing_files=()
if [ ! -f "visual.py" ]; then
missing_files+=("visual.py")
fi
if [ ! -f "get_data.py" ]; then
missing_files+=("get_data.py")
fi
if [ ${#missing_files[@]} -ne 0 ]; then
log_error "Отсутствуют необходимые файлы: ${missing_files[*]}"
log_error "Содержимое директории $target_dir:"
ls -la
exit 1
fi
log_info "Все необходимые файлы присутствуют"
}
# Функция определения IP и команды
detect_team() {
local team_arg="$1"
# Определение IP адреса
if [[ "$(uname -s)" == "Linux" ]]; then
ip_address=$(ip a 2>/dev/null | grep -Eo 'inet (addr:)?([0-9]*\.){3}[0-9]*' | grep -Eo '([0-9]*\.){3}[0-9]*' | grep -v '127.0.0.1' | head -n1)
else
log_error "Скрипт работает только на Linux"
exit 1
fi
log_info "Определен IP адрес: $ip_address"
# База данных хостов в виде пар IP-команда
declare -A hosts=(
["10.10.35.21"]="cska"
["10.10.35.22"]="Lokomotiv Kuban"
["10.10.35.23"]="uralmash"
["10.10.35.24"]="betcity parma"
["10.10.35.25"]="avtodor"
["10.10.35.26"]="zenit"
["10.10.35.27"]="samara"
["10.10.35.28"]="mba-mai"
["10.10.35.29"]="Pari Nizhny Novgorod"
["10.10.35.30"]="unics"
)
# Определение команды по IP
detected_team="${hosts[$ip_address]}"
# Определение финальной команды (приоритет у аргумента, затем у автоопределения)
if [[ -n "$team_arg" ]]; then
final_team="$team_arg"
log_info "Используется команда из аргумента: $final_team"
elif [[ -n "$detected_team" ]]; then
final_team="$detected_team"
log_info "Используется автоопределенная команда: $final_team"
else
log_error "Не удалось определить команду. Укажите явно через -t"
echo "Доступные команды:"
for ip in "${!hosts[@]}"; do
echo " $ip: ${hosts[$ip]}"
done
exit 1
fi
# Возвращаем только чистую строку с названием команды
echo "$final_team"
}
# Функция настройки firewall
setup_firewall() {
log_info "Настройка firewall (открытие порта 8501)..."
# Проверяем наличие ufw
if command -v ufw &> /dev/null; then
ufw allow 8501/tcp
log_info "Порт 8501 открыт в ufw"
fi
# Для firewalld (CentOS/RHEL)
if command -v firewall-cmd &> /dev/null; then
firewall-cmd --permanent --add-port=8501/tcp
firewall-cmd --reload
log_info "Порт 8501 открыт в firewalld"
fi
}
# Функция проверки порта
check_port() {
local port=8501
if command -v netstat &> /dev/null && netstat -tuln | grep ":$port " > /dev/null; then
log_warn "Порт $port уже занят. Возможно, приложение уже запущено."
return 1
fi
if command -v ss &> /dev/null && ss -tuln | grep ":$port " > /dev/null; then
log_warn "Порт $port уже занят. Возможно, приложение уже запущено."
return 1
fi
return 0
}
# Функция управления сервисами
manage_services() {
local action="$1"
case $action in
"start")
log_info "Запуск сервисов..."
systemctl start rfb-data.service rfb-visual.service
;;
"restart")
log_info "Перезапуск сервисов..."
systemctl restart rfb-data.service rfb-visual.service
;;
"stop")
log_info "Остановка сервисов..."
systemctl stop rfb-data.service rfb-visual.service
;;
esac
# Даем время сервисам на запуск/остановку
sleep 3
}
# Функция проверки статуса сервисов
check_services_status() {
log_info "Статус сервисов:"
echo "=== RFB Data Service ==="
systemctl status rfb-data.service --no-pager
echo ""
echo "=== RFB Visual Service ==="
systemctl status rfb-visual.service --no-pager
}
# Основная функция
main() {
local team=""
local release="main" # значение по умолчанию
local league="" # новая переменная для лиги
# Обработка аргументов командной строки
while getopts "t:r:l:h" opt; do
case $opt in
t) team="$OPTARG" ;;
r) release="$OPTARG" ;;
l) league="$OPTARG" ;;
h) show_help ;;
*) log_error "Неверный аргумент"; exit 1 ;;
esac
done
log_info "Начало установки RFB Stat..."
log_info "Команда: $team, Релиз: $release"
if [ -n "$league" ]; then
log_info "Лига: $league"
else
log_info "Лига: не указана (будет использовано значение по умолчанию)"
fi
# Проверка прав root
if [[ $EUID -ne 0 ]]; then
log_error "Этот скрипт должен запускаться с правами root"
exit 1
fi
# Установка пакетов
install_packages
# Загрузка кода
download_code "$release"
# Настройка виртуального окружения
setup_venv
# Определение команды - ВАЖНО: используем временный файл для чистого вывода
local temp_team_file=$(mktemp)
final_team=$(detect_team "$team" | tail -1)
rm -f "$temp_team_file"
log_info "Финальная команда: $final_team"
# Проверка файлов
check_required_files
# Настройка firewall
setup_firewall
# Проверка порта
check_port
# Создание systemd сервисов
create_systemd_services "$final_team" "$league"
log_info "Настройка завершена!"
# Запуск сервисов
manage_services "start"
# Проверка статуса
check_services_status
# Получаем IP еще раз для вывода
ip_address=$(ip a 2>/dev/null | grep -Eo 'inet (addr:)?([0-9]*\.){3}[0-9]*' | grep -Eo '([0-9]*\.){3}[0-9]*' | grep -v '127.0.0.1' | head -n1)
log_info "=================================================="
log_info "Установка завершена успешно!"
log_info "Приложение должно быть доступно по адресу: http://${ip_address}:8501"
log_info "Команда: $final_team"
if [ -n "$league" ]; then
log_info "Лига: $league"
fi
log_info "Режим: $release"
log_info ""
log_info "Для просмотра логов:"
log_info " Данные: journalctl -u rfb-data.service -f"
log_info " Визуал: journalctl -u rfb-visual.service -f"
log_info ""
log_info "Управление сервисами:"
log_info " Перезапуск всех: systemctl restart rfb-data.service rfb-visual.service"
log_info " Остановка всех: systemctl stop rfb-data.service rfb-visual.service"
log_info " Статус: systemctl status rfb-data.service rfb-visual.service"
log_info "=================================================="
}
# Запуск основной функции
main "$@"

File diff suppressed because it is too large Load Diff

3165
get_data_old.py Normal file

File diff suppressed because it is too large Load Diff

2113
get_data_old2.py Normal file

File diff suppressed because it is too large Load Diff

7
requirements.txt Normal file
View File

@@ -0,0 +1,7 @@
requests>=2.28.0
numpy>=1.21.0
pandas>=1.5.0
urllib3>=1.26.0
python-telegram-handler>=0.1.0
streamlit
streamlit_autorefresh

193
visual.py
View File

@@ -19,7 +19,7 @@ st.set_page_config(
page_icon="🏀",
layout="wide",
initial_sidebar_state="expanded",
menu_items={"About": "версия 2.0 от 08.10.2025"},
menu_items={"About": "версия 3.2 от 23.10.2025"},
)
REMOVE_PADDING_FROM_SIDES = """
<style>
@@ -203,8 +203,6 @@ def process_player_data(team_json, player_index):
"time": str(player_data["AvgCarPlayedTime"]),
}
return [season_total, season_avg, career_total, career_avg], player_data
@@ -285,11 +283,7 @@ if "player2" not in st.session_state:
st.session_state.player2 = None
myhost = platform.node()
if sys.platform.startswith("win"): # было: if platform == "win32":
FOLDER_JSON = "JSON"
else:
FOLDER_JSON = "static"
FOLDER_JSON = "static"
def get_ip_address():
@@ -327,7 +321,8 @@ def load_data_from_json(filepath):
directory = FOLDER_JSON
os.makedirs(directory, exist_ok=True)
filepath_full = os.path.join(directory, f"{filepath}.json")
print(filepath_full)
print(filepath)
# вычисление ключа
# ip = get_ip_address()
# host = ip_check.get(ip, {}).get("host") or ""
@@ -413,9 +408,7 @@ def rewrite_file(filename: str, data: dict, directory: str = "JSON") -> None:
os.makedirs(directory, exist_ok=True)
host_prefix = _ipcheck()
filepath = os.path.join(directory, f"{host_prefix}{filename}.json")
filepath = os.path.join(directory, f"{filename}.json")
# print(filepath) # оставил как у тебя; можно заменить на logger.debug при желании
try:
@@ -430,53 +423,51 @@ ip_check = read_match_id_json("match_id.json") or {}
prefix = _ipcheck()
load_data_from_json(f"{prefix}game_online")
cached_game_online = st.session_state.get("game_online")
load_data_from_json("game")
cached_game_online = st.session_state.get("game")
load_data_from_json(f"{prefix}team1")
load_data_from_json("api_game")
cached_api_game = st.session_state.get("api_game")
load_data_from_json("team1")
cached_team1 = st.session_state.get("team1")
load_data_from_json(f"{prefix}team2")
load_data_from_json("team2")
cached_team2 = st.session_state.get("team2")
load_data_from_json(f"{prefix}referee")
load_data_from_json("referee")
cached_referee = st.session_state.get("referee")
# standings — может не быть тега/файла
league_tag = None
if isinstance(cached_game_online, dict):
league_tag = ((cached_game_online.get("result") or {}).get("league") or {}).get(
"tag"
)
comp_name = (
((cached_game_online.get("result") or {}).get("comp") or {})
.get("name")
.replace(" ", "_")
)
if isinstance(cached_api_game, dict):
league_tag = (cached_api_game["result"].get("league") or {}).get("tag")
comp_name = (cached_api_game["result"].get("comp") or {}).get("name").replace(" ", "_").replace("|", "")
if league_tag:
load_data_from_json(f"{prefix}standings_{league_tag}_{comp_name}")
load_data_from_json(f"standings_{league_tag}_{comp_name}")
cached_standings = (
st.session_state.get(f"standings_{league_tag}_{comp_name}") if league_tag else None
)
load_data_from_json(f"{prefix}scores_quarter")
load_data_from_json("scores_quarter")
cached_scores_quarter = st.session_state.get("scores_quarter")
load_data_from_json(f"{prefix}play_by_play")
load_data_from_json("play_by_play")
cached_play_by_play = st.session_state.get("play_by_play")
load_data_from_json(f"{prefix}team_stats")
load_data_from_json("team_stats")
cached_team_stats = st.session_state.get("team_stats")
load_data_from_json(f"{prefix}scores")
load_data_from_json("scores")
cached_scores = st.session_state.get("scores") or [] # важно!
load_data_from_json(f"{prefix}live_status")
cached_live_status = st.session_state.get("live_status")
load_data_from_json("api_live-status")
cached_live_status = st.session_state.get("api_live-status")
load_data_from_json(f"{prefix}schedule")
load_data_from_json("schedule")
cached_schedule = st.session_state.get("schedule")
load_data_from_json(f"{prefix}team_comparison")
load_data_from_json("team_comparison")
cached_team_comparison = st.session_state.get("team_comparison")
@@ -568,8 +559,8 @@ if isinstance(cached_play_by_play, list) and isinstance(cached_game_online, dict
timeout1 = []
timeout2 = []
if isinstance(cached_game_online, dict):
result = cached_game_online.get("result") or {}
if isinstance(cached_api_game, dict):
result = cached_api_game["result"]
plays = result.get("plays") or []
timeout1, timeout2 = [], []
@@ -584,6 +575,7 @@ if isinstance(cached_game_online, dict):
t1 = result.get("team1") or {}
t2 = result.get("team2") or {}
if t1.get("logo"):
col1.image(t1["logo"], width=100)
team1_name = t1.get("name") or ""
@@ -617,18 +609,16 @@ if isinstance(cached_game_online, dict):
col4_3.metric("TimeOuts", len(timeout1))
col5_1.metric("TimeOuts", len(timeout2))
if isinstance(cached_live_status, list) and cached_live_status:
foulsA = (cached_live_status[0] or {}).get("foulsA")
foulsB = (cached_live_status[0] or {}).get("foulsB")
if isinstance([cached_live_status], list) and cached_live_status:
foulsA = (cached_live_status["result"] or {}).get("foulsA")
foulsB = (cached_live_status["result"] or {}).get("foulsB")
if foulsA is not None:
col4_2.metric("Fouls", foulsA)
if foulsB is not None:
col5_2.metric("Fouls", foulsB)
if isinstance(cached_game_online, dict) and (
(cached_game_online.get("result") or {}).get("plays") or []
):
if isinstance(cached_game_online, dict) and (cached_game_online.get("plays") or []):
col_1_col = [f"col_1_{i}" for i in range(1, period_max + 1)]
col_2_col = [f"col_2_{i}" for i in range(1, period_max + 1)]
count_q = 0
@@ -837,6 +827,7 @@ columns_game = [
if cached_team1 and cached_team2:
team1_data = process_team_data(cached_team1, columns_game)
team2_data = process_team_data(cached_team2, columns_game)
# Добавляем звездочку, если pts > PTS_Career_High
def _get_first_number(x):
"""Безопасно вытащить число из строки/значения (например '12 (60%)' -> 12)."""
@@ -846,6 +837,7 @@ if cached_team1 and cached_team2:
s = str(x)
# заберём ведущие число/знак (поддержим +/-)
import re
m = re.search(r"[-+]?\d+(\.\d+)?", s)
return float(m.group(0)) if m else None
except Exception:
@@ -858,7 +850,8 @@ if cached_team1 and cached_team2:
"blk": ["BLK_Career_High", "CareerHighBlocks", "career_high_blk"],
"reb": ["REB_Career_High", "CareerHighRebound", "career_high_reb"],
# если нужно — добавь ещё пары "df_column": ["possible_key1","possible_key2"...]
}
}
def _build_career_high_map(cached_team_list):
"""Вернёт словарь: player_id -> {stat_key: value} для всех доступных максимумов."""
out = {}
@@ -881,7 +874,9 @@ if cached_team1 and cached_team2:
def _ensure_id_column(df, cached_team_list):
"""Присвоить игрокам id в том же порядке, что и в списке cached_team."""
try:
ids = [p.get("id") if isinstance(p, dict) else None for p in cached_team_list][:len(df)]
ids = [
p.get("id") if isinstance(p, dict) else None for p in cached_team_list
][: len(df)]
if "id" not in df.columns:
df["id"] = ids
else:
@@ -917,17 +912,24 @@ if cached_team1 and cached_team2:
df[col] = new_vals # теперь это текст для отображения
STAR_COLUMNS = [
"pts", "ast", "stl", "blk", "reb",
]
"pts",
"ast",
"stl",
"blk",
"reb",
]
team1_data["_pts_num"] = pd.to_numeric(team1_data["pts"], errors="coerce")
team1_data["_kpi_num"] = pd.to_numeric(team1_data["kpi"], errors="coerce")
team2_data["_pts_num"] = pd.to_numeric(team2_data["pts"], errors="coerce")
team2_data["_kpi_num"] = pd.to_numeric(team2_data["kpi"], errors="coerce")
def highlight_max_by_refcol(df, view_col, ref_col):
ref = pd.to_numeric(df[ref_col], errors="coerce")
mx = ref.max()
return [("background-color: green" if (pd.notna(v) and v == mx and v > 0) else "")
for v in ref]
return [
("background-color: green" if (pd.notna(v) and v == mx and v > 0) else "")
for v in ref
]
_mark_star_for_columns(team1_data, cached_team1, STAR_COLUMNS)
_mark_star_for_columns(team2_data, cached_team2, STAR_COLUMNS)
@@ -946,18 +948,34 @@ if cached_team1 and cached_team2:
# .apply(highlight_max, subset="kpi")
# )
team1_styled = (
team1_data[columns_game].style
.apply(highlight_grey, axis=1)
team1_data[columns_game]
.style.apply(highlight_grey, axis=1)
.apply(highlight_foul, subset="foul")
.apply(lambda _: highlight_max_by_refcol(team1_data, "pts", "_pts_num"), axis=0, subset=["pts"])
.apply(lambda _: highlight_max_by_refcol(team1_data, "kpi", "_kpi_num"), axis=0, subset=["kpi"])
.apply(
lambda _: highlight_max_by_refcol(team1_data, "pts", "_pts_num"),
axis=0,
subset=["pts"],
)
.apply(
lambda _: highlight_max_by_refcol(team1_data, "kpi", "_kpi_num"),
axis=0,
subset=["kpi"],
)
)
team2_styled = (
team2_data[columns_game].style
.apply(highlight_grey, axis=1)
team2_data[columns_game]
.style.apply(highlight_grey, axis=1)
.apply(highlight_foul, subset="foul")
.apply(lambda _: highlight_max_by_refcol(team2_data, "pts", "_pts_num"), axis=0, subset=["pts"])
.apply(lambda _: highlight_max_by_refcol(team2_data, "kpi", "_kpi_num"), axis=0, subset=["kpi"])
.apply(
lambda _: highlight_max_by_refcol(team2_data, "pts", "_pts_num"),
axis=0,
subset=["pts"],
)
.apply(
lambda _: highlight_max_by_refcol(team2_data, "kpi", "_kpi_num"),
axis=0,
subset=["kpi"],
)
)
def get_player_all_game(player_data_1):
@@ -1226,8 +1244,8 @@ column_config_ref = {
def highlight_teams(s):
try:
if s.iloc[0] in (
cached_game_online["result"]["team1"]["teamId"],
cached_game_online["result"]["team2"]["teamId"],
cached_api_game["result"]["team1"]["teamId"],
cached_api_game["result"]["team2"]["teamId"],
):
return ["background-color: #FF4B4B"] * len(s)
else:
@@ -1241,16 +1259,10 @@ if cached_standings:
def highlight_teams(s):
try:
t1 = (
((cached_game_online or {}).get("result") or {})
.get("team1", {})
.get("teamId")
)
t2 = (
((cached_game_online or {}).get("result") or {})
.get("team2", {})
.get("teamId")
)
t1 = (cached_api_game["result"] or {}).get("team1", {}).get("teamId")
t2 = (cached_api_game["result"] or {}).get("team2", {}).get("teamId")
if s.iloc[0] in (t1, t2):
return ["background-color: #FF4B4B"] * len(s)
if s.iloc[0] in (t1, t2):
return ["background-color: #FF4B4B"] * len(s)
except Exception:
@@ -1281,7 +1293,7 @@ if cached_standings:
column_config={"logo": st.column_config.ImageColumn("logo")},
hide_index=True,
height=610,
width="content"
width="content",
)
@@ -1347,7 +1359,7 @@ if isinstance(cached_scores_quarter, list) and len(cached_scores_quarter) >= 2:
if isinstance(cached_play_by_play, list) and isinstance(cached_game_online, dict):
plays = (cached_game_online.get("result") or {}).get("plays") or []
plays = cached_game_online.get("plays") or []
if plays:
tab_temp_6.table(cached_play_by_play)
@@ -1857,8 +1869,7 @@ try:
except (FileNotFoundError, json.JSONDecodeError):
play_type_id = []
teams_section = ((cached_game_online or {}).get("result") or {}).get("teams") or {}
teams_section = (cached_game_online or {}).get("teams") or {}
# Если teams_section — список (например, [{"starts": [...]}, {...}])
if isinstance(teams_section, list):
if len(teams_section) >= 2:
@@ -1871,6 +1882,7 @@ if isinstance(teams_section, list):
else:
starts1 = []
starts2 = []
# Если teams_section — словарь (обычно {"1": {...}, "2": {...}})
elif isinstance(teams_section, dict):
starts1 = (teams_section.get(1) or teams_section.get("1") or {}).get("starts") or []
@@ -1916,6 +1928,41 @@ def get_event_time(row):
return None
teams_section = (cached_game_online or {}).get("teams") or {}
# Если teams_section — список (например, [{"starts": [...]}, {...}])
if isinstance(teams_section, list):
if len(teams_section) >= 2:
starts1 = next(
(t.get("starts") for t in teams_section if t["teamNumber"] == 1), None
)
starts2 = next(
(t.get("starts") for t in teams_section if t["teamNumber"] == 2), None
)
else:
starts1 = []
starts2 = []
# Если teams_section — словарь (обычно {"1": {...}, "2": {...}})
elif isinstance(teams_section, dict):
starts1 = (teams_section.get(1) or teams_section.get("1") or {}).get("starts") or []
starts2 = (teams_section.get(2) or teams_section.get("2") or {}).get("starts") or []
else:
starts1 = []
starts2 = []
teams_temp = sorted(
[x for x in starts1 if isinstance(x, dict)], key=lambda x: x.get("playerNumber", 0)
) + sorted(
[x for x in starts2 if isinstance(x, dict)], key=lambda x: x.get("playerNumber", 0)
)
list_fullname = [None] + [
f"({x.get('displayNumber')}) {x.get('firstName','')} {x.get('lastName','')}".strip()
for x in teams_temp
if x.get("startRole") == "Player"
]
plays = plays if 'plays' in locals() else []
with tab_pbp:
plays = ((cached_game_online or {}).get("result") or {}).get("plays") or []
if plays: