Troglodite/scotus-watch
3
0
Fork 0
Code Issues 10 Pull Requests Actions Packages Projects Releases Wiki Activity

Case Load is working better. #22

Browse Source
This commit is contained in:
Christopher T. Johnson
2025-02-27 16:01:13 -05:00
parent 71b0a6a112
commit b2d67f7aea
1 changed files with 19 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
workers.py
View File

@@ -106,7 +106,6 @@ def update_db(case_id: str, db: QSqlDatabase) -> int:
# #
# We assume that case_id == docket_id at this point. If it does not, # We assume that case_id == docket_id at this point. If it does not,
# then we will build out from the request we get # then we will build out from the request we get
print(f"Updating {case_id}")
matches = re.match(r"(\d\d)[-A](\d+)(.*)$", case_id) matches = re.match(r"(\d\d)[-A](\d+)(.*)$", case_id)
if matches is None: if matches is None:
raise Exception(f"Not a match {case_id}") raise Exception(f"Not a match {case_id}")
@@ -301,7 +300,7 @@ class updateThread(QThread):
print(db.lastError()) print(db.lastError())
raise Exception("db.open()") raise Exception("db.open()")
case_id = update_db(str(self.docket_id), db) update_db(str(self.docket_id), db)
db.close() db.close()
del db del db
QSqlDatabase.removeDatabase("update") QSqlDatabase.removeDatabase("update")
@@ -312,6 +311,7 @@ class loadCases(QThread):
caseLoaded = Signal(int) caseLoaded = Signal(int)
year = QDateTime.currentDateTime().toString("yy") year = QDateTime.currentDateTime().toString("yy")
number = 0 number = 0
edocket = 0
def run(self) -> None: def run(self) -> None:
db = QSqlDatabase.cloneDatabase("qt_sql_default_connection", "load") db = QSqlDatabase.cloneDatabase("qt_sql_default_connection", "load")
@@ -348,15 +348,31 @@ class loadCases(QThread):
docket_id = f"{self.year}A{self.number}" docket_id = f"{self.year}A{self.number}"
else: else:
docket_id = f"{self.year}-{self.number}" docket_id = f"{self.year}-{self.number}"
print(f"Updating: {docket_id} ", end='')
query.bindValue(":did", docket_id) query.bindValue(":did", docket_id)
if not query.exec(): if not query.exec():
query_error(query) query_error(query)
if query.next(): if query.next():
if query.value("active") == 0: if query.value("active") == 0:
self.number += 1 self.number += 1
print("INACTIVE")
continue continue
print()
result = update_db(docket_id, db) result = update_db(docket_id, db)
if result < 0: if result < 0:
if edocket == 0:
edocket = 1
self.number = 1
query.prepare("UPDATE history SET number = :number, "
"edocket=:edocket "
"WHERE history_id=:hid")
query.bindValue(':number', 1)
query.bindValue(':edocket', 1)
query.bindValue(':hid', history_id)
if not query.exec():
query_error(query)
continue
edocket = 0
self.year = f"{int(self.year) - 1:02d}" self.year = f"{int(self.year) - 1:02d}"
if self.number > 1: if self.number > 1:
query.prepare( query.prepare(
@@ -391,6 +407,7 @@ class loadCases(QThread):
self.number += 1 self.number += 1
count += 1 count += 1
self.number -= 1
if self.number > 1: if self.number > 1:
query.prepare( query.prepare(
"UPDATE history SET number= :number WHERE year = :year" "UPDATE history SET number= :number WHERE year = :year"