promo ref test

wrenchboard/src/shared_tool/email.cc

@@ -86,6 +86,12 @@ long promo_email(long mailtype, CVars in, CVars &out){
             form.LetStr("email", in["email"]);
             form.Email("PROMO/promo_alert.mailfile");
             break;
+
+            case WRENCHBOARD_PROMOADMIN_ADDLIST:
+                vars2form(in, form);
+                form.LetStr("email", in["email"]);
+                form.Email("PROMO/member_referpromo_individual.mailfile");
+                break;
     }
     return 0;
 }

wrenchboard/src/shared_tool/site_crons.cc

@@ -288,6 +288,31 @@ long  RefreshPromoActivities(CVars in, CVars &out){
     return ret;
    }
 
+long ReferEmailsNotification(){
+    CVars out;
+    res = pgsql_query("SELECT a.firstname AS send_firstname,a.lastname AS send_lastname,"
+                      " p.firstname,p.lastname, 'REFPROMO-'||p.uid AS refer_link , p.email "
+                      " FROM promo_member p "
+                      " LEFT JOIN promo_admin a ON a.id = p.admin_id "
+                      " WHERE email_sent IS NULL LIMIT 20", in["promo"].c_str(), in["limit"].Long());
+    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);
+
+            promo_email(WRENCHBOARD_PROMOADMIN_ADDLIST, rec, out); // send the reminder email
+            pgsql_query("UPDATE promotion SET email_sent=now() WHERE id =%lu", rec["promo_id"].Long());
+
+        }
+    }
+
+    return 0;
+}
+
 long ReferEmailsCleanup(){
 
  logfmt(logINFO, "ReferEmailsCleanup() ***  **** **** ENTRY");