diff --git a/wrenchboard/src/include/wrenchboard_api.h b/wrenchboard/src/include/wrenchboard_api.h index c3b4f5f1..5cb3c1f5 100644 --- a/wrenchboard/src/include/wrenchboard_api.h +++ b/wrenchboard/src/include/wrenchboard_api.h @@ -167,6 +167,7 @@ enum { PARTNER_STRIPE }; #define WRB_CRONJOB_TESTNOTIFICATIONS 779 #define WRB_CRONJOB_SCHEULETRANSFER 780 #define WRB_CRONJOB_PROCESSTRANSFER 781 +#define WRB_CRONJOB_APPEMAILS 782 #define WRB_CRONJOB_AUTO_OFFEREXPIRE 785 #define WRB_CRONJOB_HOLIDAY_BROADCAST 786 diff --git a/wrenchboard/src/shared_tool/cron_email.cc b/wrenchboard/src/shared_tool/cron_email.cc index 0b056bd3..49425b53 100644 --- a/wrenchboard/src/shared_tool/cron_email.cc +++ b/wrenchboard/src/shared_tool/cron_email.cc @@ -37,7 +37,7 @@ CREATE TABLE email_message( } long CronSendMail(CVars in, CVars &out){ - + logfmt(logINFO, " ***** CALL long CronSendMail(CVars in, CVars &out)"); return 0; } \ No newline at end of file diff --git a/wrenchboard/src/shared_tool/site_crons.cc b/wrenchboard/src/shared_tool/site_crons.cc index 6d08e150..992cd5e7 100644 --- a/wrenchboard/src/shared_tool/site_crons.cc +++ b/wrenchboard/src/shared_tool/site_crons.cc @@ -13,6 +13,7 @@ #include #include "jobs.h" #include "bko.h" +#include "cron_email.h" long ReviewReminder(CVars in, CVars &out); long OfferPending(CVars in, CVars &out); @@ -155,6 +156,14 @@ long sitecrons_calls(CVars in, CVars &out) { CronTracker(ct, co); return ScheduleHolidayJobs(in, out); break; + + case WRB_CRONJOB_APPEMAILS: + ct["job_type"]="WRB_CRONJOB_APPEMAILS"; ct["job_type"].set_valid( true ); + ct["description"]="Send Email Batch"; ct["description"].set_valid( true ); + CronTracker(ct, co); + return CronSendMail(in, out); + break; + // define('WRB_CRONJOB_APPEMAILS', 782); } logfmt(logINFO, "/sitecrons_calls()"); diff --git a/www-api/app/Config/Routes.php b/www-api/app/Config/Routes.php index 35032ef7..1f9c83a7 100644 --- a/www-api/app/Config/Routes.php +++ b/www-api/app/Config/Routes.php @@ -41,6 +41,7 @@ $routes->post('/en/promo/api/v1/start', 'Promo::promoStart'); $routes->post('/en/promo/api/v1/tasks', 'Promo::promoTask'); +$routes->get('/en/flow/api/v1/appemails', 'AirFlow::flowAppEmails'); $routes->get('/en/flow/api/v1/new-account', 'AirFlow::flowNewAccount'); $routes->get('/en/flow/api/v1/offer-pending', 'AirFlow::flowOfferPending'); $routes->get('/en/flow/api/v1/due-reminder', 'AirFlow::flowDueReminder'); diff --git a/www-api/app/Controllers/AirFlow.php b/www-api/app/Controllers/AirFlow.php index 9cb28571..771eb5ce 100644 --- a/www-api/app/Controllers/AirFlow.php +++ b/www-api/app/Controllers/AirFlow.php @@ -13,6 +13,7 @@ define('WRB_CRONJOB_GROUPJOBS', 778); define('WRB_CRONJOB_TESTNOTIFICATIONS', 779); define('WRB_CRONJOB_SCHEULETRANSFER', 780); define('WRB_CRONJOB_PROCESSTRANSFER', 781); +define('WRB_CRONJOB_APPEMAILS', 782); define('WRB_CRONJOB_AUTO_OFFEREXPIRE', 785); define('WRB_CRONJOB_HOLIDAY_BROADCAST', 786); @@ -31,6 +32,17 @@ class AirFlow extends BaseController return []; //json_encode( $final_out ); } + public function flowAppEmails(){ + $raw_json = file_get_contents('php://input'); + $in = json_decode($raw_json, true); + $in["action"] = WRB_JOB_CRONJOB; //WRB_CRONJOB_AUTO_OFFEREXPIRE + $in["call_action"] = WRB_CRONJOB_APPEMAILS; + $out =[]; + log_message('critical', "AirFlow::flowAppEmails ********* ALL ".serialize($in) ); + $ret['WRB_CRONJOB_APPEMAILS'] = (new \App\Models\BackendModel())->wrenchboard_api($in, $out); + return []; //json_encode( $final_out ); + + } public function flowHolidayBroadCast(){ $raw_json = file_get_contents('php://input'); $in = json_decode($raw_json, true);