From e6f8ba1d0ddaa970e33254f3bc7b5b241c333589 Mon Sep 17 00:00:00 2001
From: Olusesan Ameye <ses66181@gmail.com>
Date: Thu, 12 May 2022 21:48:15 -0400
Subject: [PATCH] fix

---
 wrenchboard/src/shared_tool/site_crons.cc | 33 ++++++++++++++++++++++-
 1 file changed, 32 insertions(+), 1 deletion(-)

diff --git a/wrenchboard/src/shared_tool/site_crons.cc b/wrenchboard/src/shared_tool/site_crons.cc
index 168720f2..00d6bb6d 100644
--- a/wrenchboard/src/shared_tool/site_crons.cc
+++ b/wrenchboard/src/shared_tool/site_crons.cc
@@ -11,6 +11,7 @@
 #include "pgsql_wrapper.h"
 #include "cfg.h"
 #include <curl/curl.h>
+#include "jobs.h"
 
 long ReviewReminder(CVars in, CVars &out);
 long OfferPending(CVars in, CVars &out);
@@ -74,7 +75,37 @@ long InterestPending(CVars in, CVars &out) {
 long PastDueWarings(CVars in, CVars &out) {
      logfmt(logINFO, "ENTER PastDueWarings()");
      long contract_id = 0;
-    const PGresult *res = pgsql_query("SELECT mc.id AS contract_id, mc.member_id,mc.auto_remind   "
+     const PGresult *res = pgsql_query("SELECT mc.id AS contract_id, mc.member_id,mc.auto_remind   "
+            " FROM members_jobs_contract mc "
+            " LEFT JOIN members m ON m.id=mc.client_id "
+            " WHERE  mc.status IN (1,2) AND  mc.auto_remind > 2 "
+            " AND delivery_date < now() GROUP BY mc.member_id ,mc.auto_remind, contract_id  ORDER BY mc.auto_remind DESC");
+    if (res != NULL && pgsql_num_rows(res) > 0) {
+        for (int i = 0, n = pgsql_num_rows(res); i < n; i++) {
+            map<const char*, const char*>f = pgsql_fetch_assoc(res, i);
+            if (f.empty()) continue;
+            CVars rec;
+            map_to_cvars(f, rec);
+            // note we send once in the loop
+            // we need the loop to mar items but wanted to send the email only once
+            if ( contract_id != rec["contract_id"].Long() ){
+                contract_id = rec["contract_id"].Long();
+                cron_email(WRB_CRONJOB_PASTDUE_ALERT, rec, out); // send the cron email
+            }
+             pgsql_exec("UPDATE members_jobs_contract SET auto_remind=auto_remind + 1 "\
+            				           "WHERE member_id=%lu AND id = %lu  ", rec["member_id"].Long(),rec["contract_id"].Long());
+
+        }
+    }
+    logfmt(logINFO, "/PastDueWarings()");
+    return 0;
+}
+
+
+long PastDueWarings(CVars in, CVars &out) {
+     logfmt(logINFO, "ENTER PastDueWarings()");
+     long contract_id = 0;
+     const PGresult *res = pgsql_query("SELECT mc.id AS contract_id, mc.member_id,mc.auto_remind   "
             " FROM members_jobs_contract mc "
             " LEFT JOIN members m ON m.id=mc.client_id "
             " WHERE  mc.status IN (1,2) AND  mc.auto_remind < 3 "