WorldTeacher
f7c499ea6e
- Updated logging initialization in MessageCalendar, admin_edit_prof, elsa_main, graph, iconLine, searchPage, and richtext modules to use loguru. - Changed log rotation and retention settings for log files to improve log management. - Replaced logger.debug/info calls with log.debug/info for consistency. - Fixed a typo in the searchPage UI and updated related references in the UI files. - Removed unused imports and cleaned up code for better readability.
81 lines
2.4 KiB
Python
81 lines
2.4 KiB
Python
import time
|
|
|
|
# from icecream import ic
|
|
from PyQt6.QtCore import QThread
|
|
from PyQt6.QtCore import pyqtSignal as Signal
|
|
|
|
from src.backend.database import Database
|
|
|
|
from src.logic.webrequest import BibTextTransformer, WebRequest
|
|
|
|
# from src.transformers import RDS_AVAIL_DATA
|
|
import loguru
|
|
import sys
|
|
|
|
log = loguru.logger
|
|
log.remove()
|
|
log.add(sys.stdout)
|
|
log.add("logs/application.log", rotation="1 MB", retention="10 days")
|
|
|
|
|
|
|
|
class AvailChecker(QThread):
|
|
updateSignal = Signal(str, int)
|
|
updateProgress = Signal(int, int)
|
|
|
|
def __init__(
|
|
self, links: list = None, appnumber: int = None, parent=None, books=list[dict]
|
|
):
|
|
if links is None:
|
|
links = []
|
|
super().__init__(parent)
|
|
log.info("Starting worker thread")
|
|
log.info(
|
|
"Checking availability for "
|
|
+ str(links)
|
|
+ " with appnumber "
|
|
+ str(appnumber)
|
|
+ "..."
|
|
)
|
|
self.links = links
|
|
self.appnumber = appnumber
|
|
self.books = books
|
|
log.info(
|
|
f"Started worker with appnumber: {self.appnumber} and links: {self.links} and {len(self.books)} books..."
|
|
)
|
|
time.sleep(2)
|
|
|
|
def run(self):
|
|
self.db = Database()
|
|
state = 0
|
|
count = 0
|
|
for link in self.links:
|
|
log.info("Processing entry: " + str(link))
|
|
data = WebRequest().set_apparat(self.appnumber).get_ppn(link).get_data()
|
|
transformer = BibTextTransformer("RDS")
|
|
rds = transformer.get_data(data).return_data("rds_availability")
|
|
|
|
book_id = None
|
|
for item in rds.items:
|
|
sign = item.superlocation
|
|
loc = item.location
|
|
# # print(item.location)
|
|
if self.appnumber in sign or self.appnumber in loc:
|
|
state = 1
|
|
break
|
|
for book in self.books:
|
|
if book["bookdata"].signature == link:
|
|
book_id = book["id"]
|
|
break
|
|
log.info(f"State of {link}: " + str(state))
|
|
# print("Updating availability of " + str(book_id) + " to " + str(state))
|
|
self.db.setAvailability(book_id, state)
|
|
count += 1
|
|
self.updateProgress.emit(count, len(self.links))
|
|
self.updateSignal.emit(item.callnumber, state)
|
|
|
|
log.info("Worker thread finished")
|
|
# teminate thread
|
|
|
|
self.quit()
|