From 60173437db65f6068ffeb3b5fde8d926c0b0c709 Mon Sep 17 00:00:00 2001
From: "CHIEFSOFT\\ameye" <ameye@chiefsfot.com>
Date: Mon, 23 Sep 2024 07:32:19 -0400
Subject: [PATCH] status 2

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

diff --git a/wrenchboard/src/shared_tool/site_crons.cc b/wrenchboard/src/shared_tool/site_crons.cc
index 67eb9ed8..19abd4bb 100644
--- a/wrenchboard/src/shared_tool/site_crons.cc
+++ b/wrenchboard/src/shared_tool/site_crons.cc
@@ -159,6 +159,7 @@ long ProcessExpiredOffers(CVars in, CVars &out){
     char vname[30];
     long ret = PHP_API_BAD_PARAM;
     try {
+        // First stage ; JUST MARK FOR AUTO AND COME BACK
         out["total_record"] = "0";
         const PGresult *res;
         res = pgsql_query("SELECT status,member_id, id AS offer_id, uid,offer_code FROM members_jobs_offer "
@@ -180,6 +181,32 @@ long ProcessExpiredOffers(CVars in, CVars &out){
                 " WHERE id = %lu AND  uid::text = '%s' ", rec["offer_id"].Long(),rec["uid"].c_str()); // move the status so no retry
             }
         }
+
+//SELECT status,member_id, id, uid,offer_code FROM members_jobs_offer WHERE expire< now() AND status = 1 AND refund_auto <  (now() - interval '15 minutes') AND refund_status =0  AND payment_id IS NOT NULL ORDER BY id ASC LIMIT 10
+
+        res = pgsql_query("SELECT status,member_id, id, uid,offer_code "
+                          " FROM members_jobs_offer "
+                          " WHERE expire< now() AND status = 1 "
+                          " AND refund_auto <  (now() - interval '15 minutes') "
+                          " AND refund_status =0  "
+                          " AND payment_id IS NOT NULL "
+                          " ORDER BY id ASC LIMIT 10");
+
+        if (res != NULL && pgsql_num_rows(res) > 0) {
+            out["total_record"] = pgsql_num_rows(res);
+
+            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);
+                pgsql_query("UPDATE members_jobs_offer SET  refund_status= 2 "
+                " WHERE id = %lu AND  uid::text = '%s' ", rec["offer_id"].Long(),rec["uid"].c_str()); // move the status so no retry
+            }
+        }
+
+
+
         ret = PHP_API_OK;
         out["status"] = "OK";
     } catch (bad_parameter) {
@@ -189,6 +216,10 @@ long ProcessExpiredOffers(CVars in, CVars &out){
 
 
 
+//case WRENCHBOARD_JOB_OFFER_CONCLUDE:
+//return WrenchConcludeJobsOffer(in, out);
+//break;
+