From 5cf1b62e50f6e0e97ee17314d588f3ba82107407 Mon Sep 17 00:00:00 2001
From: "CHIEFSOFT\\ameye" <ameye@chiefsfot.com>
Date: Fri, 11 Jul 2025 20:57:43 -0400
Subject: [PATCH] Flow cleanup

---
 www-api/app/Controllers/AirFlow.php | 33 +++++++++++++----------------
 1 file changed, 15 insertions(+), 18 deletions(-)

diff --git a/www-api/app/Controllers/AirFlow.php b/www-api/app/Controllers/AirFlow.php
index 117d8e36..922498fb 100644
--- a/www-api/app/Controllers/AirFlow.php
+++ b/www-api/app/Controllers/AirFlow.php
@@ -32,8 +32,11 @@ class AirFlow extends BaseController
         $raw_json = file_get_contents('php://input');
         $in = json_decode($raw_json, true);
         $out =[];
+        $in["action"] = WRB_CRONJOB_APPEMAILS;
+        $in["call_action"] =  WRB_CRONJOB_APPEMAILS;
         log_message('critical', "AirFlow::flowNewAccount ********* ALL   ".serialize($in) );
-        return  []; //json_encode( $final_out );
+        $ret['WRB_CRONJOB_APPEMAILS'] = (new  \App\Models\BackendModel())->wrenchboard_api($in, $out);
+        return  [];
     }
 
     public function flowRefreshResources(){
@@ -49,7 +52,7 @@ class AirFlow extends BaseController
     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["action"] = WRB_JOB_CRONJOB;
         $in["call_action"] =  WRB_CRONJOB_APPEMAILS;
         $out =[];
         log_message('critical', "AirFlow::flowAppEmails ********* ALL   ".serialize($in) );
@@ -63,7 +66,7 @@ class AirFlow extends BaseController
         $in["action"] = WRB_JOB_CRONJOB;  //WRB_CRONJOB_AUTO_OFFEREXPIRE
         $in["call_action"] =  WRB_CRONJOB_HOLIDAY_BROADCAST;
         $out =[];
-        log_message('critical', "AirFlow::flowOfferMissed ********* ALL   ".serialize($in) );
+        log_message('critical', "AirFlow::flowHolidayBroadCast ********* ALL   ".serialize($in) );
         $ret['WRB_CRONJOB_HOLIDAY_BROADCAST'] = (new  \App\Models\BackendModel())->wrenchboard_api($in, $out);
         return  []; //json_encode( $final_out );
     }
@@ -84,19 +87,17 @@ class AirFlow extends BaseController
         $out =[];
         log_message('critical', "AirFlow::flowDueReminder ********* ALL   ".serialize($in) );
         return $this->jobLevelAlerts();
-
-      //  return  []; //json_encode( $final_out );
     }
 
     public function flowOfferMissed(){
         $raw_json = file_get_contents('php://input');
         $in = json_decode($raw_json, true);
-        $in["action"] = WRB_JOB_CRONJOB;  //WRB_CRONJOB_AUTO_OFFEREXPIRE
+        $in["action"] = WRB_JOB_CRONJOB;
         $in["call_action"] =  WRB_CRONJOB_AUTO_OFFEREXPIRE;
         $out =[];
         log_message('critical', "AirFlow::flowOfferMissed ********* ALL   ".serialize($in) );
         $ret['WRB_CRONJOB_AUTO_OFFEREXPIRE'] = (new  \App\Models\BackendModel())->wrenchboard_api($in, $out);
-        return  []; //json_encode( $final_out );
+        return  [];
     }
 
     public function flowInterestcount(){
@@ -203,7 +204,7 @@ class AirFlow extends BaseController
         $in = json_decode($raw_json, true);
         $out =[];
         log_message('critical', "AirFlow::flowApproveReminder ********* ALL   ".serialize($in) );
-        return  []; //json_encode( $final_out );
+        return  [];
     }
 
     public function flowAutoMarket01(){
@@ -232,7 +233,7 @@ class AirFlow extends BaseController
         $in['one_limit'] = 10; //remove this
         $in['limit']     = 10;
         $ret['WRB_CRONJOB_PROCESSTRANSFER'] = (new  \App\Models\BackendModel())->wrenchboard_api($in, $out);
-        return  []; //json_encode( $final_out );
+        return  [];
     }
 
     public function flowScheduleTransfer(){
@@ -247,7 +248,7 @@ class AirFlow extends BaseController
         $in['action'] = WRB_JOB_CRONJOB;
         $in['call_action'] = WRB_CRONJOB_SCHEULETRANSFER;
 
-        $in['one_limit'] = 10; //remove this
+        $in['one_limit'] = 10;
         $in['limit']     = 10;
         $ret['WRB_CRONJOB_SCHEULETRANSFER'] = (new  \App\Models\BackendModel())->wrenchboard_api($in, $out);
         return  []; //json_encode( $final_out );
@@ -264,7 +265,7 @@ class AirFlow extends BaseController
         $in['one_limit'] = 10; //remove this
         $in['limit']     = 10;
         $ret['WRB_CRONJOB_TESTNOTIFICATIONS'] = (new  \App\Models\BackendModel())->wrenchboard_api($in, $out);
-        return  []; //json_encode( $final_out );
+        return  [];
     }
 
     public function flowPromoProcess(){
@@ -279,14 +280,14 @@ class AirFlow extends BaseController
         $in['one_limit'] = 10; //remove this
         $in['limit']     = 10;
         $ret['WRB_CRONJOB_PROCESS_PROMO'] = (new  \App\Models\BackendModel())->wrenchboard_api($in, $out);
-        return  []; //json_encode( $final_out );
+        return  [];
     }
     public function flowSendNotifications(){
 
         $raw_json = file_get_contents('php://input');
         $in = json_decode($raw_json, true);
         $out =[];
-        log_message('critical', "AirFlow::flowApproveReminder ********* ALL   ".serialize($in) );
+        log_message('critical', "AirFlow::flowSendNotifications ********* ALL   ".serialize($in) );
         $in["loc"] = $_SERVER["REMOTE_ADDR"];
         $in["action"] =WRB_JOB_CRONJOB;
         $in['call_action'] = WRB_CRONJOB_NOTIFICATIONS;
@@ -347,10 +348,6 @@ class AirFlow extends BaseController
         $in['one_limit'] = 3;
         $ret['WRB_CRONJOB_JOBDUE_REMINDER'] = $wrenchboard->wrenchboard_api($in, $out);
 
-//
-//        $in['call_action'] = WRB_CRONJOB_PENDOFFER_ALERT;
-//        $in['one_limit'] = 3;
-//        $ret['WRB_CRONJOB_PENDOFFER_ALERT'] = $wrenchboard->wrenchboard_api($in, $out);
 
         $in['call_action'] = WRB_CRONJOB_JOBDUE_PAYMENTS;
         $in['one_limit'] = 3;
@@ -368,7 +365,7 @@ class AirFlow extends BaseController
         // $out['internal_return'] = $ret;
         $out = $ret;
 
-        log_message('critical', "WrenchCrons ===> 0001");
+        log_message('critical', "jobLevelAlerts ===> 0001");
         //$response = []; //json_decode($complete, true);
         return $this->response->setJson($out);
     }