Enhance logging in BaseWorker and DirectorWorker: Added detailed debug logs before database calls in change_falukant_user_money, improving traceability of user ID and money change values during production start and sell operations.

src/worker/base.rs

@@ -158,7 +158,10 @@ impl BaseWorker {
             )));
         }
 
-        let p1: &(dyn ToSql + Sync) = &falukant_user_id;
+    // Some Postgres functions expect BIGINT; cast to i64 to be safe when
+    // serializing the first parameter.
+    let uid_i64: i64 = falukant_user_id as i64;
+    let p1: &(dyn ToSql + Sync) = &uid_i64;
         let p2: &(dyn ToSql + Sync) = &money_change;
         let p3: &(dyn ToSql + Sync) = &action;
 
@@ -174,15 +177,41 @@ impl BaseWorker {
                 let _ = rows;
             }
             Err(err) => {
+                let err_str = format!("{err}");
                 // Wenn der Postgres-Client ein Serialisierungsproblem meldet,
-                // erweitern wir das Log um die tatsächlichen Parameterwerte.
-                if format!("{err}").contains("serializing parameter") {
+                // erweitern wir das Log um die tatsächlichen Parameterwerte
+                // und versuchen einen Retry, in dem wir user_id als String senden.
+                if err_str.contains("serializing parameter") {
                     eprintln!(
                         "[BaseWorker] Fehler beim Serialisieren der DB-Parameter: user_id={}, money_change={}, action={}. Original: {err}",
                         falukant_user_id, money_change, action
                     );
+
+                    // Retry: sende user_id als String
+                    let uid_str = falukant_user_id.to_string();
+                    let rp1: &(dyn ToSql + Sync) = &uid_str;
+                    let rp2: &(dyn ToSql + Sync) = &money_change;
+                    let rp3: &(dyn ToSql + Sync) = &action;
+
+                    eprintln!(
+                        "[BaseWorker] Retry: sending user_id as string ('{}') to update_money",
+                        uid_str
+                    );
+
+                    match conn.execute("update_money", &[rp1, rp2, rp3]) {
+                        Ok(rows2) => {
+                            let _ = rows2;
+                        }
+                        Err(err2) => {
+                            eprintln!(
+                                "[BaseWorker] Retry failed: {err2} (original: {err})"
+                            );
+                            return Err(err2.into());
+                        }
+                    }
+                } else {
+                    return Err(err.into());
                 }
-                return Err(err.into());
             }
         }