New market

This commit is contained in:
CHIEFSOFT\ameye
2024-09-16 11:30:08 -04:00
parent 19fac23492
commit 61e2e7bd93
2 changed files with 44 additions and 11 deletions
+1 -2
View File
@@ -683,11 +683,10 @@ CREATE TABLE members_myfiles (
ADD CONSTRAINT members_myfiles_id_key UNIQUE (id);
*/
long WrenchGetRecentDash(CVars in, CVars &out) {
long WrenchJobCount(long member_id);
long WrenchFamilyCount(long member_id);
long WrenchGetRecentDash(CVars in, CVars &out) {
logfmt(logINFO, "WrenchGetRecentDash()");
char vname[30];
+43 -9
View File
@@ -15,6 +15,7 @@
#include "cfg.h"
#include <curl/curl.h>
long WrenchMarketImport(CVars in, CVars &out);
long market_calls(CVars in, CVars &out) {
logfmt(logINFO, "market_calls()");
@@ -24,16 +25,14 @@ long market_calls(CVars in, CVars &out) {
try {
long action = REQ_LONG( in, "action", 1, -1 );
switch(action){
case WRENCHBOARD_MARKET_PLAN01_START:
snprintf(vname, sizeof (vname), "SELECT uid AS member_uid, profile_pic AS saved_file_name FROM members WHERE uid ='%s'", in["file_uid"].c_str());
market_email(WRENCHBOARD_MARKET_PLAN01_START, in, in);
case WRENCHBOARD_MARKET_PLAN01_START:
return WrenchMarketImport(in, out);
break;
break;
case WRENCHBOARD_MARKET_PLAN01_NEXT1:
snprintf(vname, sizeof (vname), "SELECT uid AS member_uid, profile_pic AS saved_file_name FROM members WHERE uid ='%s'", in["file_uid"].c_str());
market_email(WRENCHBOARD_MARKET_PLAN01_START, in, in);
break;
case WRENCHBOARD_MARKET_PLAN01_NEXT1:
snprintf(vname, sizeof (vname), "SELECT uid AS member_uid, profile_pic AS saved_file_name FROM members WHERE uid ='%s'", in["file_uid"].c_str());
// market_email(WRENCHBOARD_MARKET_PLAN01_START, in, in);
break;
}
} catch (bad_parameter) {
@@ -43,6 +42,41 @@ long market_calls(CVars in, CVars &out) {
return ret;
}
long WrenchMarketImport(CVars in, CVars &out) {
logfmt(logINFO, "WrenchMarketImport()");
char vname[30];
long ret = PHP_API_BAD_PARAM;
try {
out["total_record"] = "0";
const PGresult *res;
res = pgsql_query("SELECT * FROM market_import WHERE status =1 LIMIT 4");
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);
market_email(WRENCHBOARD_MARKET_PLAN01_START, rec, rec);
}
}
ret = PHP_API_OK;
out["status"] = "OK";
} catch (bad_parameter) {
logfmt(logINFO, "ERROR CALL long WrenchMarketImport(CVars in, CVars &out)");
}
logfmt(logINFO, "/WrenchMarketImport()");
return ret;
}
/*
#define WRENCHBOARD_MARKET_PLAN01_START 220001
#define WRENCHBOARD_MARKET_PLAN01_NEXT1 220003