?UPi@ddlZddlmZddlmZmZmZGddZy)N)datetime) DATABASE_PATHWINNERS_TXT_PATHSTREAM_STATS_TXT_PATHcDeZdZdZdZdZdZdZd dZdZ dZ d Z y ) Databasec@d|_d|_|jy)N)conncursor init_databaseselfs /root/twitch_bot/database.py__init__zDatabase.__init__ s   c tjtd|_|jj |_|jj d|jj d|jj tdtdy#t$r}td|Yd}~yd}~wwxYw) u0Инициализация базы данныхF)check_same_threada CREATE TABLE IF NOT EXISTS winners ( ID INTEGER PRIMARY KEY AUTOINCREMENT, Date_Time TEXT NOT NULL, Winner TEXT NOT NULL, TradeOffer TEXT NOT NULL ) a CREATE TABLE IF NOT EXISTS stream_stats ( ID INTEGER PRIMARY KEY AUTOINCREMENT, Stream_Start TEXT NOT NULL, Stream_End TEXT NOT NULL, Stream_Duration TEXT NOT NULL, Total_Messages INTEGER NOT NULL, Active_Users TEXT NOT NULL ) uE✅ [DATABASE] База данных инициализированаu5📊 [DATABASE] Таблицы: winners, stream_statsu8❌ [DATABASE] Ошибка инициализации: N) sqlite3connectrr r executecommitprint Exceptionres rr zDatabase.init_databases R ODI))**,DK KK  !  KK   !  II    Y Z I J R LQCP Q Q RsB%B(( C 1CC c  tjjd}|jj d|||f|j j ttdd5}|j|d|d|ddddtd |y #1swYxYw#t$r}td |Yd}~y d}~wwxYw) u8Сохранение победителя в БД и TXT%Y-%m-%d %H:%M:%Szr INSERT INTO winners (Date_Time, Winner, TradeOffer) VALUES (?, ?, ?) autf-8encodingz |  Nu7💾 [DATABASE] Победитель сохранён: TuG❌ [DATABASE] Ошибка сохранения победителя: F) rnowstrftimer rr ropenrwriterr)rwinner trade_link date_timefrs r save_winnerzDatabase.save_winner0s  //0CDI KK  !VZ0 2 II   &g> D!9+SJ?##$78   II   +S7C )q"XJb)*"#4#=#=>Q#R"SSVWaWjWjkuWvVwwyz|4\N"EF9.9ILMGLHYGZZ\]^. B788*B( ) X Z ) )  [\][^_ ` s1C!G#B=F4 G4F=9G G! GG!c |jjd|jjS#t$r}t d|gcYd}~Sd}~wwxYw)u0Получить всех победителейz&SELECT * FROM winners ORDER BY ID DESCuG❌ [DATABASE] Ошибка получения победителей: Nr rfetchallrrrs rget_all_winnerszDatabase.get_all_winnerspsT  KK   H I;;'') )  [\][^_ `I 47 AAAAc |jjd||jjS#t$r}t d|gcYd}~Sd}~wwxYw)u<Получить последних N победителейz-SELECT * FROM winners ORDER BY ID DESC LIMIT uZ❌ [DATABASE] Ошибка получения последних победителей: Nr>)rlimitrs rget_last_winnerszDatabase.get_last_winnersys\  KK  "OPUw W X;;'') )  nopnqr sI s7: AAAAc |jjd|jjS#t$r}t d|gcYd}~Sd}~wwxYw)u;Получить всю статистику стримовz+SELECT * FROM stream_stats ORDER BY ID DESCuE❌ [DATABASE] Ошибка получения статистики: Nr>rs rget_all_stream_statszDatabase.get_all_stream_statssT  KK   M N;;'') )  YZ[Y\] ^I rAc |jjd|jjd}|jjd|jjd}|jjd|jjdxsd}|||dS#t$r}t d|Yd}~yd}~wwxYw)u0Получить общую статистикуzSELECT COUNT(*) FROM winnersrz!SELECT COUNT(*) FROM stream_statsz,SELECT SUM(Total_Messages) FROM stream_stats) winners_count streams_countr4uP❌ [DATABASE] Ошибка получения общей статистики: N)r rfetchonerr)rrHrIr4rs rget_total_statszDatabase.get_total_statss  KK   > ? KK00215M KK   C D KK00215M KK   N O![[113A6;!N"/!."0    defdgh i sB1B44 C=CCch|jr&|jjtdyy)u+Закрыть соединение с БДu3👋 [DATABASE] Соединение закрытоN)r closerr s rrMzDatabase.closes% 99 IIOO  G H rN) ) __name__ __module__ __qualname__rr r+r<r@rDrFrKrMrrrrs3 RD,(T*Irr)rrconfigrrrrrRrrrTs!II\I\Ir