diff --git a/app/Controllers/Provision.php b/app/Controllers/Provision.php index d36a7a8..345cbd9 100644 --- a/app/Controllers/Provision.php +++ b/app/Controllers/Provision.php @@ -94,7 +94,7 @@ class Provision extends BaseController // $sql = "GRANT SELECT , INSERT , UPDATE , DELETE ON " . $dbName . " . * TO '" . $dbName . "'@'localhost' IDENTIFIED BY '" . $provisionUID . "'"; $sql = "GRANT CREATE, SELECT , INSERT , UPDATE , DELETE ON " . $dbName . " . * TO '" . $dbName . "'@'localhost' IDENTIFIED BY '" . $provisionUID . "'"; - log_message('critical', "***** ***** prepareDataBase :: GrantQuery === ".$sql); + log_message('critical', "***** ***** prepareDataBase :: GrantQuery === " . $sql); $result = mysqli_query($conn, $sql); @@ -432,6 +432,7 @@ class Provision extends BaseController foreach ($provision_list as $pr) { $this->db->query("UPDATE member_product_refresh SET status = status + 1 WHERE id = " . $pr->id); $subscriptionUId = $pr->subscription_uid; + $this->auditProvisionPlans($subscriptionUId); if ($this->refreshProvision($subscriptionUId) == 100) { log_message('critical', "***** ***** scheduleRefreshAction Started:: () "); } @@ -445,12 +446,38 @@ class Provision extends BaseController foreach ($provision_list as $pr) { $this->db->query("UPDATE member_product_refresh SET status = status + 1 WHERE id = " . $pr->id); $subscriptionUId = $pr->subscription_uid; + $this->auditProvisionPlans($subscriptionUId); if ($this->refreshBlogProvision($subscriptionUId) == 100) { log_message('critical', "***** ***** scheduleRefresh BLOG Action Started:: () "); } } } + private function auditProvisionPlans($subscriptionUid): void + { + // Where is your provision plan + //SELECT * from provision_plans where provision_id = 46; + //SELECT uid id,provision_status, status FROM members_products WHERE id = 46 + try { + $sqlP = "SELECT * FROM members_products WHERE uid::text = '$subscriptionUid' "; + $query = $this->db->query($sqlP); + $row = $query->row(); + if (isset($row)) { + echo $row->title; + + + } + } catch (Exception $e) { + // Handle the specific exception + echo "Caught exception: " . $e->getMessage() . "\n"; + } finally { + // Cleanup code, always runs + echo "Attempted file operation finished.\n"; + } + + } + + private function refreshBlogProvision($subscriptionUId): int { @@ -515,6 +542,7 @@ class Provision extends BaseController // let us make sure all we promise are availale //"WHAT_PART_LOCAL + $CURRENT_IMAGE_REFRESH = "registry.chiefsoft.com/a000001/personal-web-web0002a:latest"; // Remember this is in a CONTAINER so the path follows $this_composer_part_location = "/var/www/html/ANSIBLE/parts/" . $productUid; @@ -546,7 +574,8 @@ class Provision extends BaseController \"WHAT_PART_REMOTE\":\"$composer_template_path_remote\", \"ANSIBLE_TRANSPORT_PATH\":\"$ansible_transport_path\", \"RSYNC_PASSWORD\":\"$rsyncPass\", - \"CONTAINER_NAME\":\"$ContainerName\" + \"CONTAINER_NAME\":\"$ContainerName\", + \"CURRENT_IMAGE_REFRESH\":\"$CURRENT_IMAGE_REFRESH\" }" ]; log_message('critical', "02- ANSIBLE CALL PARAMETERS ********* " . serialize($params)); @@ -653,7 +682,7 @@ class Provision extends BaseController */ } - private function registerProvision($subscriptionId, $prov_name) + private function registerProvision($subscriptionId, $prov_name): int { /*