From 1dd4d18927e669858a6223ab61cdb96cce39eb6a Mon Sep 17 00:00:00 2001 From: "Torsten Schulz (local)" Date: Fri, 17 Apr 2026 16:58:41 +0200 Subject: [PATCH] fix(FalukantService): update userHouse query attributes and transaction handling - Modified the userHouse query to include 'id' in the attributes, improving data retrieval. - Enhanced transaction handling in state and userHouse updates to ensure atomic operations, preventing potential data inconsistencies. --- backend/services/falukantService.js | 22 +++++++++++++--------- 1 file changed, 13 insertions(+), 9 deletions(-) diff --git a/backend/services/falukantService.js b/backend/services/falukantService.js index 4678fe8..bfd3f77 100644 --- a/backend/services/falukantService.js +++ b/backend/services/falukantService.js @@ -3902,7 +3902,7 @@ class FalukantService extends BaseService { const userHouse = await UserHouse.findOne({ where: { userId: user.id }, - attributes: ['householdOrder'] + attributes: ['id', 'householdOrder'] }); const marriage = await Relationship.findOne({ @@ -3988,7 +3988,7 @@ class FalukantService extends BaseService { const userHouse = await UserHouse.findOne({ where: { userId: user.id }, - attributes: ['householdOrder'] + attributes: ['id', 'householdOrder'] }); const productionDelayMinutes = 15; const runningProductions = await Production.findAll({ @@ -4011,14 +4011,18 @@ class FalukantService extends BaseService { let delayedProductions = 0; await sequelize.transaction(async (t) => { - await state.update({ - marriageSatisfaction: nextSatisfaction, - marriagePublicStability: nextPublicStability - }); + await state.update( + { + marriageSatisfaction: nextSatisfaction, + marriagePublicStability: nextPublicStability + }, + { transaction: t } + ); if (userHouse && nextHouseholdOrder != null) { - await userHouse.update({ - householdOrder: nextHouseholdOrder - }); + await userHouse.update( + { householdOrder: nextHouseholdOrder }, + { transaction: t } + ); } for (const production of runningProductions) { const startAt = new Date(production.startTimestamp);