diff --git a/app/Controllers/Provision.php b/app/Controllers/Provision.php index 6292ec9..bb25ca5 100644 --- a/app/Controllers/Provision.php +++ b/app/Controllers/Provision.php @@ -34,7 +34,8 @@ class Provision extends BaseController mkdir($ansible_folder . "/parts", 0700); } - $mysql = "SELECT id, uid, internal_url,product_id,status,provision_port,updated, member_id + $mysql = "SELECT id, uid, internal_url,product_id,status,provision_port,updated, member_id, + id AS subscription_id FROM members_products WHERE provision_port > 0 AND provision_status = 0 @@ -45,6 +46,7 @@ class Provision extends BaseController $provision_list = $query->getResult(); //$provision_list =[]; foreach ($provision_list as $pr) { + $subscriptionId = $pr->subscription_id; $provisionPort = $pr->provision_port; $productId = $pr->product_id; $provisionUID = $pr->uid; @@ -91,12 +93,37 @@ class Provision extends BaseController $myfile = fopen($ansible_folder . "/" . $prov_name, "w") or die("Unable to open file!"); fwrite($myfile, $template_content_processed); fclose($myfile); + $this->registerProvision($subscriptionId,$prov_name); $this->provisionActions($memberID, $provisionUID, "Auto Configuration Started"); } return view('welcome_message'); } + private function registerProvision($subscriptionId,$prov_name){ + + /* + CREATE TABLE provision_plans ( + id SERIAL, + uid uuid DEFAULT uuid_generate_v4(), + provision_id INT REFERENCES members_products(id), + play_file VARCHAR(100)UNIQUE NOT NULL, + msg VARCHAR(100) , + added timestamp without time zone DEFAULT now(), + updated timestamp without time zone DEFAULT now() + ); + ALTER TABLE ONLY provision_plans + ADD CONSTRAINT provision_plans_id_key UNIQUE (id); + + */ + try{ + $mysql = "INSERT INTO provision_plans (provision_id,play_file) VALUES($subscriptionId,'$prov_name')"; + $query = $this->db->query($mysql); + } catch ( \Exception $e){ + log_message('critical', "***** ***** registerProvision Error:: registerProvision() ".$e->getMessage()); + } + return 0; + } private function allocatePortNo(){ $list_limit = 2; $mysql = "SELECT id, member_id, uid, internal_url,product_id,status,provision_port,updated