Compare commits
112 Commits
6e104a565c
...
RFB4
| Author | SHA1 | Date | |
|---|---|---|---|
| 26eb5a9398 | |||
| a97a28de6f | |||
| 764c50e42d | |||
| d49244de54 | |||
| a9605be520 | |||
| 763df5cb43 | |||
| 662f88c68b | |||
| c438f69578 | |||
| 9bf3624c8c | |||
| 7b44ab3d5d | |||
| 6721951c34 | |||
| ea34b6521f | |||
| 5ab179e47b | |||
| 1839b8aec3 | |||
| f11b315d2f | |||
| 15367b05fc | |||
| 94d487fe88 | |||
| 049e2493b5 | |||
| 7e5ccdbb83 | |||
| 97045a0f72 | |||
| b301f1e918 | |||
| d86d1e5a4f | |||
| 6278a8e3df | |||
| 4ad11815a5 | |||
| cbcad5e525 | |||
| 48c5f552ec | |||
| b0511d51d3 | |||
| 6fa1ad3f35 | |||
| d821967f33 | |||
| b11dbdeae8 | |||
| 91c6eeddc5 | |||
| 842af85847 | |||
| 225e158c53 | |||
| 276ecdcb85 | |||
| adc067293f | |||
| 27a7ffcaad | |||
| 02582bdab0 | |||
| 4048f8fdfa | |||
| b0aba27764 | |||
| b27e02bb49 | |||
| ff3883aa36 | |||
| f72914a085 | |||
| 10baa5b2fb | |||
| 6a06d54aa4 | |||
| 58bfdce841 | |||
| 9fa68a165d | |||
| ee58ad868d | |||
| 5470df8da9 | |||
| 8fa3acf3f2 | |||
| 858ed5c6a7 | |||
| 09dfbef09a | |||
| c4de3c84fe | |||
| 000b304ed9 | |||
| 8f34737186 | |||
| 58bff8ba53 | |||
| 82f1450ff5 | |||
| 7a61c0bfb6 | |||
| d75f0e6407 | |||
| dcfcbb0958 | |||
| 629854c104 | |||
| 893d18ee23 | |||
| c9613f91a3 | |||
| 5ea03d2efc | |||
| bacee0e9b8 | |||
| 0844d577ff | |||
| d7c819357d | |||
| efa4812b09 | |||
| c62c8a31a6 | |||
| a13cb945c7 | |||
| 5083423660 | |||
| c30bc088c7 | |||
| d9ad941a80 | |||
| 84169208ab | |||
| 39ba101948 | |||
| 886339b183 | |||
| 00a01eb8a9 | |||
| 313c82c006 | |||
| b45d7ec129 | |||
| 8b2f2f5e23 | |||
| b021034b4a | |||
| 963c7a503b | |||
| e375613692 | |||
| 0b85081ba5 | |||
| b8b79b5f58 | |||
| 6d3d5d3702 | |||
| 9b0c276d36 | |||
| b0f59e5bf3 | |||
| 5cb7b2f6c8 | |||
| a1b1466f4b | |||
| dbc6ca3ef9 | |||
| 856ca094b1 | |||
| 139740b48f | |||
| 1b13768d12 | |||
| c3469b62ef | |||
| 74467aedb5 | |||
| 982655faa1 | |||
| 8ea87b371a | |||
| 8f6ae70389 | |||
| 92211a55f1 | |||
| d4d9964282 | |||
| 24860de8c6 | |||
| 5ad95a1d57 | |||
| d4e1dacf20 | |||
| d528ee8de6 | |||
| 2d553db6bc | |||
| 0db5d80e19 | |||
|
|
ca7cd72b74 | ||
|
|
1a344d2be2 | ||
|
|
2bd99cf663 | ||
|
|
e1aa4c993a | ||
|
|
55925f3847 | ||
|
|
dc0574dc8d |
4
.gitignore
vendored
4
.gitignore
vendored
@@ -2,3 +2,7 @@
|
|||||||
/JSON/*
|
/JSON/*
|
||||||
/logs/*
|
/logs/*
|
||||||
/static/*
|
/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
5
.streamlit/config.toml
Normal file
@@ -0,0 +1,5 @@
|
|||||||
|
[browser]
|
||||||
|
gatherUsageStats = false
|
||||||
|
|
||||||
|
[server]
|
||||||
|
enableStaticServing = true
|
||||||
105
README.md
Normal file
105
README.md
Normal file
@@ -0,0 +1,105 @@
|
|||||||
|

|
||||||
|
|
||||||
|
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
495
deploy.sh
Executable 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 "$@"
|
||||||
4787
get_data.py
4787
get_data.py
File diff suppressed because it is too large
Load Diff
3165
get_data_old.py
Normal file
3165
get_data_old.py
Normal file
File diff suppressed because it is too large
Load Diff
2113
get_data_old2.py
Normal file
2113
get_data_old2.py
Normal file
File diff suppressed because it is too large
Load Diff
7
requirements.txt
Normal file
7
requirements.txt
Normal 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
|
||||||
207
visual.py
207
visual.py
@@ -19,7 +19,7 @@ st.set_page_config(
|
|||||||
page_icon="🏀",
|
page_icon="🏀",
|
||||||
layout="wide",
|
layout="wide",
|
||||||
initial_sidebar_state="expanded",
|
initial_sidebar_state="expanded",
|
||||||
menu_items={"About": "версия 2.0 от 08.10.2025"},
|
menu_items={"About": "версия 3.2 от 23.10.2025"},
|
||||||
)
|
)
|
||||||
REMOVE_PADDING_FROM_SIDES = """
|
REMOVE_PADDING_FROM_SIDES = """
|
||||||
<style>
|
<style>
|
||||||
@@ -203,8 +203,6 @@ def process_player_data(team_json, player_index):
|
|||||||
"time": str(player_data["AvgCarPlayedTime"]),
|
"time": str(player_data["AvgCarPlayedTime"]),
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
return [season_total, season_avg, career_total, career_avg], player_data
|
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
|
st.session_state.player2 = None
|
||||||
|
|
||||||
|
|
||||||
myhost = platform.node()
|
FOLDER_JSON = "static"
|
||||||
if sys.platform.startswith("win"): # было: if platform == "win32":
|
|
||||||
FOLDER_JSON = "JSON"
|
|
||||||
else:
|
|
||||||
FOLDER_JSON = "static"
|
|
||||||
|
|
||||||
|
|
||||||
def get_ip_address():
|
def get_ip_address():
|
||||||
@@ -327,7 +321,8 @@ def load_data_from_json(filepath):
|
|||||||
directory = FOLDER_JSON
|
directory = FOLDER_JSON
|
||||||
os.makedirs(directory, exist_ok=True)
|
os.makedirs(directory, exist_ok=True)
|
||||||
filepath_full = os.path.join(directory, f"{filepath}.json")
|
filepath_full = os.path.join(directory, f"{filepath}.json")
|
||||||
|
print(filepath_full)
|
||||||
|
print(filepath)
|
||||||
# вычисление ключа
|
# вычисление ключа
|
||||||
# ip = get_ip_address()
|
# ip = get_ip_address()
|
||||||
# host = ip_check.get(ip, {}).get("host") or ""
|
# 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)
|
os.makedirs(directory, exist_ok=True)
|
||||||
|
|
||||||
host_prefix = _ipcheck()
|
filepath = os.path.join(directory, f"{filename}.json")
|
||||||
|
|
||||||
filepath = os.path.join(directory, f"{host_prefix}{filename}.json")
|
|
||||||
# print(filepath) # оставил как у тебя; можно заменить на logger.debug при желании
|
# print(filepath) # оставил как у тебя; можно заменить на logger.debug при желании
|
||||||
|
|
||||||
try:
|
try:
|
||||||
@@ -430,53 +423,51 @@ ip_check = read_match_id_json("match_id.json") or {}
|
|||||||
|
|
||||||
prefix = _ipcheck()
|
prefix = _ipcheck()
|
||||||
|
|
||||||
load_data_from_json(f"{prefix}game_online")
|
load_data_from_json("game")
|
||||||
cached_game_online = st.session_state.get("game_online")
|
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")
|
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")
|
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")
|
cached_referee = st.session_state.get("referee")
|
||||||
|
|
||||||
# standings — может не быть тега/файла
|
# standings — может не быть тега/файла
|
||||||
league_tag = None
|
league_tag = None
|
||||||
if isinstance(cached_game_online, dict):
|
if isinstance(cached_api_game, dict):
|
||||||
league_tag = ((cached_game_online.get("result") or {}).get("league") or {}).get(
|
league_tag = (cached_api_game["result"].get("league") or {}).get("tag")
|
||||||
"tag"
|
comp_name = (cached_api_game["result"].get("comp") or {}).get("name").replace(" ", "_").replace("|", "")
|
||||||
)
|
|
||||||
comp_name = (
|
|
||||||
((cached_game_online.get("result") or {}).get("comp") or {})
|
|
||||||
.get("name")
|
|
||||||
.replace(" ", "_")
|
|
||||||
)
|
|
||||||
if league_tag:
|
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 = (
|
cached_standings = (
|
||||||
st.session_state.get(f"standings_{league_tag}_{comp_name}") if league_tag else None
|
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")
|
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")
|
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")
|
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 [] # важно!
|
cached_scores = st.session_state.get("scores") or [] # важно!
|
||||||
|
|
||||||
load_data_from_json(f"{prefix}live_status")
|
load_data_from_json("api_live-status")
|
||||||
cached_live_status = st.session_state.get("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")
|
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")
|
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 = []
|
timeout1 = []
|
||||||
timeout2 = []
|
timeout2 = []
|
||||||
|
|
||||||
if isinstance(cached_game_online, dict):
|
if isinstance(cached_api_game, dict):
|
||||||
result = cached_game_online.get("result") or {}
|
result = cached_api_game["result"]
|
||||||
plays = result.get("plays") or []
|
plays = result.get("plays") or []
|
||||||
|
|
||||||
timeout1, timeout2 = [], []
|
timeout1, timeout2 = [], []
|
||||||
@@ -584,6 +575,7 @@ if isinstance(cached_game_online, dict):
|
|||||||
|
|
||||||
t1 = result.get("team1") or {}
|
t1 = result.get("team1") or {}
|
||||||
t2 = result.get("team2") or {}
|
t2 = result.get("team2") or {}
|
||||||
|
|
||||||
if t1.get("logo"):
|
if t1.get("logo"):
|
||||||
col1.image(t1["logo"], width=100)
|
col1.image(t1["logo"], width=100)
|
||||||
team1_name = t1.get("name") or ""
|
team1_name = t1.get("name") or ""
|
||||||
@@ -617,18 +609,16 @@ if isinstance(cached_game_online, dict):
|
|||||||
col4_3.metric("TimeOuts", len(timeout1))
|
col4_3.metric("TimeOuts", len(timeout1))
|
||||||
col5_1.metric("TimeOuts", len(timeout2))
|
col5_1.metric("TimeOuts", len(timeout2))
|
||||||
|
|
||||||
if isinstance(cached_live_status, list) and cached_live_status:
|
if isinstance([cached_live_status], list) and cached_live_status:
|
||||||
foulsA = (cached_live_status[0] or {}).get("foulsA")
|
foulsA = (cached_live_status["result"] or {}).get("foulsA")
|
||||||
foulsB = (cached_live_status[0] or {}).get("foulsB")
|
foulsB = (cached_live_status["result"] or {}).get("foulsB")
|
||||||
if foulsA is not None:
|
if foulsA is not None:
|
||||||
col4_2.metric("Fouls", foulsA)
|
col4_2.metric("Fouls", foulsA)
|
||||||
if foulsB is not None:
|
if foulsB is not None:
|
||||||
col5_2.metric("Fouls", foulsB)
|
col5_2.metric("Fouls", foulsB)
|
||||||
|
|
||||||
|
|
||||||
if isinstance(cached_game_online, dict) and (
|
if isinstance(cached_game_online, dict) and (cached_game_online.get("plays") or []):
|
||||||
(cached_game_online.get("result") or {}).get("plays") or []
|
|
||||||
):
|
|
||||||
col_1_col = [f"col_1_{i}" for i in range(1, period_max + 1)]
|
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)]
|
col_2_col = [f"col_2_{i}" for i in range(1, period_max + 1)]
|
||||||
count_q = 0
|
count_q = 0
|
||||||
@@ -837,6 +827,7 @@ columns_game = [
|
|||||||
if cached_team1 and cached_team2:
|
if cached_team1 and cached_team2:
|
||||||
team1_data = process_team_data(cached_team1, columns_game)
|
team1_data = process_team_data(cached_team1, columns_game)
|
||||||
team2_data = process_team_data(cached_team2, columns_game)
|
team2_data = process_team_data(cached_team2, columns_game)
|
||||||
|
|
||||||
# Добавляем звездочку, если pts > PTS_Career_High
|
# Добавляем звездочку, если pts > PTS_Career_High
|
||||||
def _get_first_number(x):
|
def _get_first_number(x):
|
||||||
"""Безопасно вытащить число из строки/значения (например '12 (60%)' -> 12)."""
|
"""Безопасно вытащить число из строки/значения (например '12 (60%)' -> 12)."""
|
||||||
@@ -846,19 +837,21 @@ if cached_team1 and cached_team2:
|
|||||||
s = str(x)
|
s = str(x)
|
||||||
# заберём ведущие число/знак (поддержим +/-)
|
# заберём ведущие число/знак (поддержим +/-)
|
||||||
import re
|
import re
|
||||||
|
|
||||||
m = re.search(r"[-+]?\d+(\.\d+)?", s)
|
m = re.search(r"[-+]?\d+(\.\d+)?", s)
|
||||||
return float(m.group(0)) if m else None
|
return float(m.group(0)) if m else None
|
||||||
except Exception:
|
except Exception:
|
||||||
return None
|
return None
|
||||||
|
|
||||||
CAREER_HIGH_KEYS = {
|
CAREER_HIGH_KEYS = {
|
||||||
"pts": ["PTS_Career_High", "CareerHighPoints", "career_high_pts"],
|
"pts": ["PTS_Career_High", "CareerHighPoints", "career_high_pts"],
|
||||||
"ast": ["AST_Career_High", "CareerHighAssist", "career_high_ast"],
|
"ast": ["AST_Career_High", "CareerHighAssist", "career_high_ast"],
|
||||||
"stl": ["STL_Career_High", "CareerHighSteal", "career_high_stl"],
|
"stl": ["STL_Career_High", "CareerHighSteal", "career_high_stl"],
|
||||||
"blk": ["BLK_Career_High", "CareerHighBlocks", "career_high_blk"],
|
"blk": ["BLK_Career_High", "CareerHighBlocks", "career_high_blk"],
|
||||||
"reb": ["REB_Career_High", "CareerHighRebound", "career_high_reb"],
|
"reb": ["REB_Career_High", "CareerHighRebound", "career_high_reb"],
|
||||||
# если нужно — добавь ещё пары "df_column": ["possible_key1","possible_key2"...]
|
# если нужно — добавь ещё пары "df_column": ["possible_key1","possible_key2"...]
|
||||||
}
|
}
|
||||||
|
|
||||||
def _build_career_high_map(cached_team_list):
|
def _build_career_high_map(cached_team_list):
|
||||||
"""Вернёт словарь: player_id -> {stat_key: value} для всех доступных максимумов."""
|
"""Вернёт словарь: player_id -> {stat_key: value} для всех доступных максимумов."""
|
||||||
out = {}
|
out = {}
|
||||||
@@ -881,7 +874,9 @@ if cached_team1 and cached_team2:
|
|||||||
def _ensure_id_column(df, cached_team_list):
|
def _ensure_id_column(df, cached_team_list):
|
||||||
"""Присвоить игрокам id в том же порядке, что и в списке cached_team."""
|
"""Присвоить игрокам id в том же порядке, что и в списке cached_team."""
|
||||||
try:
|
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:
|
if "id" not in df.columns:
|
||||||
df["id"] = ids
|
df["id"] = ids
|
||||||
else:
|
else:
|
||||||
@@ -917,17 +912,24 @@ if cached_team1 and cached_team2:
|
|||||||
df[col] = new_vals # теперь это текст для отображения
|
df[col] = new_vals # теперь это текст для отображения
|
||||||
|
|
||||||
STAR_COLUMNS = [
|
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["_pts_num"] = pd.to_numeric(team1_data["pts"], errors="coerce")
|
||||||
team1_data["_kpi_num"] = pd.to_numeric(team1_data["kpi"], 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["_pts_num"] = pd.to_numeric(team2_data["pts"], errors="coerce")
|
||||||
team2_data["_kpi_num"] = pd.to_numeric(team2_data["kpi"], errors="coerce")
|
team2_data["_kpi_num"] = pd.to_numeric(team2_data["kpi"], errors="coerce")
|
||||||
|
|
||||||
def highlight_max_by_refcol(df, view_col, ref_col):
|
def highlight_max_by_refcol(df, view_col, ref_col):
|
||||||
ref = pd.to_numeric(df[ref_col], errors="coerce")
|
ref = pd.to_numeric(df[ref_col], errors="coerce")
|
||||||
mx = ref.max()
|
mx = ref.max()
|
||||||
return [("background-color: green" if (pd.notna(v) and v == mx and v > 0) else "")
|
return [
|
||||||
for v in ref]
|
("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(team1_data, cached_team1, STAR_COLUMNS)
|
||||||
_mark_star_for_columns(team2_data, cached_team2, 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")
|
# .apply(highlight_max, subset="kpi")
|
||||||
# )
|
# )
|
||||||
team1_styled = (
|
team1_styled = (
|
||||||
team1_data[columns_game].style
|
team1_data[columns_game]
|
||||||
.apply(highlight_grey, axis=1)
|
.style.apply(highlight_grey, axis=1)
|
||||||
.apply(highlight_foul, subset="foul")
|
.apply(highlight_foul, subset="foul")
|
||||||
.apply(lambda _: highlight_max_by_refcol(team1_data, "pts", "_pts_num"), axis=0, subset=["pts"])
|
.apply(
|
||||||
.apply(lambda _: highlight_max_by_refcol(team1_data, "kpi", "_kpi_num"), axis=0, subset=["kpi"])
|
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_styled = (
|
||||||
team2_data[columns_game].style
|
team2_data[columns_game]
|
||||||
.apply(highlight_grey, axis=1)
|
.style.apply(highlight_grey, axis=1)
|
||||||
.apply(highlight_foul, subset="foul")
|
.apply(highlight_foul, subset="foul")
|
||||||
.apply(lambda _: highlight_max_by_refcol(team2_data, "pts", "_pts_num"), axis=0, subset=["pts"])
|
.apply(
|
||||||
.apply(lambda _: highlight_max_by_refcol(team2_data, "kpi", "_kpi_num"), axis=0, subset=["kpi"])
|
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):
|
def get_player_all_game(player_data_1):
|
||||||
@@ -1226,8 +1244,8 @@ column_config_ref = {
|
|||||||
def highlight_teams(s):
|
def highlight_teams(s):
|
||||||
try:
|
try:
|
||||||
if s.iloc[0] in (
|
if s.iloc[0] in (
|
||||||
cached_game_online["result"]["team1"]["teamId"],
|
cached_api_game["result"]["team1"]["teamId"],
|
||||||
cached_game_online["result"]["team2"]["teamId"],
|
cached_api_game["result"]["team2"]["teamId"],
|
||||||
):
|
):
|
||||||
return ["background-color: #FF4B4B"] * len(s)
|
return ["background-color: #FF4B4B"] * len(s)
|
||||||
else:
|
else:
|
||||||
@@ -1241,16 +1259,10 @@ if cached_standings:
|
|||||||
|
|
||||||
def highlight_teams(s):
|
def highlight_teams(s):
|
||||||
try:
|
try:
|
||||||
t1 = (
|
t1 = (cached_api_game["result"] or {}).get("team1", {}).get("teamId")
|
||||||
((cached_game_online or {}).get("result") or {})
|
t2 = (cached_api_game["result"] or {}).get("team2", {}).get("teamId")
|
||||||
.get("team1", {})
|
if s.iloc[0] in (t1, t2):
|
||||||
.get("teamId")
|
return ["background-color: #FF4B4B"] * len(s)
|
||||||
)
|
|
||||||
t2 = (
|
|
||||||
((cached_game_online or {}).get("result") or {})
|
|
||||||
.get("team2", {})
|
|
||||||
.get("teamId")
|
|
||||||
)
|
|
||||||
if s.iloc[0] in (t1, t2):
|
if s.iloc[0] in (t1, t2):
|
||||||
return ["background-color: #FF4B4B"] * len(s)
|
return ["background-color: #FF4B4B"] * len(s)
|
||||||
except Exception:
|
except Exception:
|
||||||
@@ -1281,7 +1293,7 @@ if cached_standings:
|
|||||||
column_config={"logo": st.column_config.ImageColumn("logo")},
|
column_config={"logo": st.column_config.ImageColumn("logo")},
|
||||||
hide_index=True,
|
hide_index=True,
|
||||||
height=610,
|
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):
|
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:
|
if plays:
|
||||||
tab_temp_6.table(cached_play_by_play)
|
tab_temp_6.table(cached_play_by_play)
|
||||||
|
|
||||||
@@ -1857,8 +1869,7 @@ try:
|
|||||||
except (FileNotFoundError, json.JSONDecodeError):
|
except (FileNotFoundError, json.JSONDecodeError):
|
||||||
play_type_id = []
|
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": [...]}, {...}])
|
# Если teams_section — список (например, [{"starts": [...]}, {...}])
|
||||||
if isinstance(teams_section, list):
|
if isinstance(teams_section, list):
|
||||||
if len(teams_section) >= 2:
|
if len(teams_section) >= 2:
|
||||||
@@ -1871,6 +1882,7 @@ if isinstance(teams_section, list):
|
|||||||
else:
|
else:
|
||||||
starts1 = []
|
starts1 = []
|
||||||
starts2 = []
|
starts2 = []
|
||||||
|
|
||||||
# Если teams_section — словарь (обычно {"1": {...}, "2": {...}})
|
# Если teams_section — словарь (обычно {"1": {...}, "2": {...}})
|
||||||
elif isinstance(teams_section, dict):
|
elif isinstance(teams_section, dict):
|
||||||
starts1 = (teams_section.get(1) or teams_section.get("1") or {}).get("starts") or []
|
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
|
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:
|
with tab_pbp:
|
||||||
plays = ((cached_game_online or {}).get("result") or {}).get("plays") or []
|
plays = ((cached_game_online or {}).get("result") or {}).get("plays") or []
|
||||||
if plays:
|
if plays:
|
||||||
|
|||||||
Reference in New Issue
Block a user