Reffere hx

2023-04-23 08:36:32 -04:00
parent 57c7567931
commit 3e53281ac5
9 changed files with 77 additions and 3 deletions
@@ -81,3 +81,62 @@ long  WrenchPurchaseHx( CVars in, CVars &out )
 	return 0;
 }

+long  WrenchRefferHx( CVars in, CVars &out )
+{
+    char vname[30];
+    long ret = PHP_API_BAD_PARAM;
+
+    logfmt( logINFO, "WrenchRefferHx()" );
+    out["result"] = "Yes i go to this back end";
+
+    try {
+        long member_id = REQ_LONG( in, "member_id", 1, -1 );
+        long limit = REQ_LONG( in, "limit", 1, -1 );
+        REQ_LONG( in, "offset", 1, -1 );
+        REQ_STRING (in, "uid",   10, 100, "(.*)");
+
+        const PGresult *res;
+        res = pgsql_query("SELECT count(id) FROM members_refer_friend WHERE member_id = %lu", member_id);
+        out["total_record"] = pgsql_num_rows(res);
+
+         res = pgsql_query("SELECT added::date AS added_date, firstname, lastname,email,"
+                            " (CASE WHEN status=1 THEN 'Pending' WHEN status=5 THEN 'Completed' ElSE '' END) As status "
+                            " FROM members_refer_friend "
+                            " WHERE member_id = %lu ORDER BY id DESC LIMIT %lu OFFSET %lu ",member_id,limit,offset);
+
+        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);
+
+                snprintf(vname, sizeof (vname), "added_date_%05d", i);
+                out[vname] = rec["added_date"];
+
+                snprintf(vname, sizeof (vname), "firstname_%05d", i);
+                out[vname] = rec["firstname"];
+
+                snprintf(vname, sizeof (vname), "lastname_%05d", i);
+                out[vname] = rec["lastname"];
+
+                snprintf(vname, sizeof (vname), "email_%05d", i);
+                out[vname] = rec["email"];
+
+                snprintf(vname, sizeof (vname), "status_%05d", i);
+                out[vname] = rec["status"];
+
+            }
+        }
+        ret = PHP_API_OK;
+        out["status"] = "OK";
+    } catch (bad_parameter) {
+        logfmt(logINFO, "ERROR CALL long WrenchRefferHx(CVars in, CVars &out)");
+    }
+
+    logfmt( logINFO, "/WrenchRefferHx()" );
+	return 0;
+}
+
@@ -53,10 +53,12 @@ long mobile_calls(CVars in, CVars &out) {
        case WRENCHBOARD_MOBILE_TASKMESSAGE:
            return  WrenchReturnTaskMessage( in, out);
            break;
-            
        case WRENCHBOARD_MOBILE_SENDTASKMESSAGE:
            return   WrenchContractMessage( in, out);
            break;
+        case WRENCHBOARD_ACCOUNT_REFFERHX:
+            return  WrenchRefferHx( in, out);
+            break;
    }
    logfmt(logINFO, "/mobile_calls()");
    return 0;