From 5410a50d1a0b4720b51fd44392bfb1a5ecc6f47a Mon Sep 17 00:00:00 2001 From: MrWaradana Date: Mon, 10 Nov 2025 17:13:19 +0700 Subject: [PATCH] fix double s on records --- .../__pycache__/model.cpython-311.pyc | Bin 5099 -> 5113 bytes .../__pycache__/service.cpython-311.pyc | Bin 14452 -> 14452 bytes src/equipment/model.py | 2 +- src/equipment/service.py | 14 +++++++------- 4 files changed, 8 insertions(+), 8 deletions(-) diff --git a/src/equipment/__pycache__/model.cpython-311.pyc b/src/equipment/__pycache__/model.cpython-311.pyc index 507e6033104a5cc78c7f419c9bfbf83c233db028..bf48a1730cbf6daeb71f28e4c6bec614849d3e8d 100644 GIT binary patch delta 45 zcmaE@{!^WIIWI340}w3TC7AhjBX1Kon`dHPO1#EoTW;yii?}BF C+Ya;q diff --git a/src/equipment/__pycache__/service.cpython-311.pyc b/src/equipment/__pycache__/service.cpython-311.pyc index cde2982f1b4c05d570c5a2ef91fda910ce2f441a..0fa27dcb4c0a9a26bbdc32d2a36f8fb9fb2512a6 100644 GIT binary patch delta 22 ccmexT@TGuvIWI340}w3TC73yTBX7C|09`-_asU7T delta 22 ccmexT@TGuvIWI340}$}67tFNW$eV5f09Bm^YybcN diff --git a/src/equipment/model.py b/src/equipment/model.py index deb638c..31bca4c 100644 --- a/src/equipment/model.py +++ b/src/equipment/model.py @@ -41,7 +41,7 @@ class EquipmentTransactionRecords(Base, DefaultMixin, IdentityMixin): "Equipment", backref="maintenance_records", lazy="raise", - primaryjoin="and_(EquipmentTransactionRecordss.assetnum == foreign(Equipment.assetnum))", + primaryjoin="and_(EquipmentTransactionRecords.assetnum == foreign(Equipment.assetnum))", viewonly=True, ) diff --git a/src/equipment/service.py b/src/equipment/service.py index f8f786c..1820171 100644 --- a/src/equipment/service.py +++ b/src/equipment/service.py @@ -256,9 +256,9 @@ async def generate_transaction( # # Query existing records with is_actual=1 # actual_years_query = ( - # Select(EquipmentTransactionRecordss.tahun) - # .filter(EquipmentTransactionRecordss.assetnum == data_in.assetnum) - # .filter(EquipmentTransactionRecordss.is_actual == 1) + # Select(EquipmentTransactionRecords.tahun) + # .filter(EquipmentTransactionRecords.assetnum == data_in.assetnum) + # .filter(EquipmentTransactionRecords.is_actual == 1) # ) # result = await db_session.execute(actual_years_query) # actual_years = {row[0] for row in result.all()} @@ -280,9 +280,9 @@ async def generate_transaction( # # # Calculate sum of previous failures for this asset # # previous_failures_query = ( - # # Select(func.sum(EquipmentTransactionRecordss.raw_cm_interval)) - # # .filter(EquipmentTransactionRecordss.assetnum == data_in.assetnum) - # # .filter(EquipmentTransactionRecordss.tahun < year) + # # Select(func.sum(EquipmentTransactionRecords.raw_cm_interval)) + # # .filter(EquipmentTransactionRecords.assetnum == data_in.assetnum) + # # .filter(EquipmentTransactionRecords.tahun < year) # # ) # # previous_failures_result = await db_session.execute(previous_failures_query) # # previous_failures_sum = previous_failures_result.scalar() or 0 @@ -291,7 +291,7 @@ async def generate_transaction( # # transaction.update({"raw_cm_interval": current_num_fail - previous_failures_sum}) # transaction.update({"raw_cm_interval": current_num_fail}) # transaction.update({"tahun": int(year), "seq": int(sequence)}) - # transactions.append(EquipmentTransactionRecordss(**transaction)) + # transactions.append(EquipmentTransactionRecords(**transaction)) # db_session.add_all(transactions) # await db_session.commit()