Sineedge/sparqapi
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

AWS SNS

Browse Source
This commit is contained in:
velz 2018-10-06 20:54:09 +05:30
parent 39246a5174
commit 13d761d3fa
3 changed files with 23 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
api/application/controllers/PD_Controller.php
View File

@ -19,7 +19,7 @@ class PD_Controller extends REST_Controller {
parent::__construct(); parent::__construct();
$this->load->model('PD_Model'); $this->load->model('PD_Model');
$this->load->library('AWS_S3'); $this->load->library('AWS_S3');
$this->load->library('AWS_SES'); $this->load->library('AWS_SNS');
} }
/***********************Get get List Of Lenders Details for PD Trigger Page************************/ /***********************Get get List Of Lenders Details for PD Trigger Page************************/
@ -221,6 +221,7 @@ class PD_Controller extends REST_Controller {
{ {
$pd_details['pd_agency_id'] = $temp_city_id[0]['fk_team_id']; $pd_details['pd_agency_id'] = $temp_city_id[0]['fk_team_id'];
$pd_details['fk_pd_status'] = ALLOCATED_TO_PARTNER; $pd_details['fk_pd_status'] = ALLOCATED_TO_PARTNER;
$pd_details['fk_pd_allocated_to'] = null;
} }
else //Allocate to SineEdge Team with allocation logics else //Allocate to SineEdge Team with allocation logics
{ {

30
api/application/helpers/pdalerts_helper.php
View File

@ -39,7 +39,7 @@ class PDALERTS
$CI->db->JOIN(PDSTATUS." as PDSTATUS","PDTRIGGER.fk_pd_status = PDSTATUS.pd_status_id"); $CI->db->JOIN(PDSTATUS." as PDSTATUS","PDTRIGGER.fk_pd_status = PDSTATUS.pd_status_id");
$CI->db->WHERE("PDTRIGGER.pd_id",$pdid); $CI->db->WHERE("PDTRIGGER.pd_id",$pdid);
$core_details = $CI->db->GET()->result_array(); $core_details = $CI->db->GET()->result_array();
//print_r($core_details);
if(count($core_details)) if(count($core_details))
{ {
@ -49,45 +49,47 @@ class PDALERTS
$CI->db->SELECT("PDNOTIFICATION.pdnotification_id, PDNOTIFICATION.fk_pd_status_id, PDSTATUS.pd_status_name,PDNOTIFICATION.sms_lender, PDNOTIFICATION.sms_pdofficer, PDNOTIFICATION.sms_pdincharge, PDNOTIFICATION.mail_lender, PDNOTIFICATION.mail_pdincharge, PDNOTIFICATION.mail_pdofficer"); $CI->db->SELECT("PDNOTIFICATION.pdnotification_id, PDNOTIFICATION.fk_pd_status_id, PDSTATUS.pd_status_name,PDNOTIFICATION.sms_lender, PDNOTIFICATION.sms_pdofficer, PDNOTIFICATION.sms_pdincharge, PDNOTIFICATION.mail_lender, PDNOTIFICATION.mail_pdincharge, PDNOTIFICATION.mail_pdofficer");
$CI->db->FROM(PDNOTIFICATION." as PDNOTIFICATION"); $CI->db->FROM(PDNOTIFICATION." as PDNOTIFICATION");
$CI->db->JOIN(PDSTATUS." as PDSTATUS","PDNOTIFICATION.fk_pd_status_id = PDSTATUS.pd_status_id AND PDSTATUS.isactive = 1"); $CI->db->JOIN(PDSTATUS." as PDSTATUS","PDNOTIFICATION.fk_pd_status_id = PDSTATUS.pd_status_id AND PDSTATUS.isactive = 1");
$CI->db->WHERE("PDNOTIFICATION.fk_pd_status_id = $pdstatus"); $CI->db->WHERE("PDNOTIFICATION.fk_pd_status_id",$core_details[0]['fk_pd_status']);
$pd_notification_configs = $CI->db->GET()->result_array(); $pd_notification_configs = $CI->db->GET()->result_array();
//print_r($pd_notification_configs); //print_r($pd_notification_configs);
//pd cretaed entity type is 2 then sent sms only for that mobile no //pd cretaed entity type is 2 then sent sms only for that mobile no
if($core_details['created_entity_type'] == 2) // 2 - Lender Type if($core_details[0]['created_entity_type'] == 2) // 2 - Lender Type
{ {
if($pd_notification_configs['sms_lender'] == 1) if($pd_notification_configs[0]['sms_lender'] == 1)
{ {
array_push($mobile_nos_to_send_notification,$core_details['created_mobile_no']); array_push($mobile_nos_to_send_notification,$core_details[0]['created_mobile_no']);
} }
} }
else //sent sms to all lender contacts associated to lender id else //sent sms to all lender contacts associated to lender id
{ {
if($pd_notification_configs['sms_lender'] == 1) if($pd_notification_configs[0]['sms_lender'] == 1)
{ {
$CI->db->SELECT("contact_mobile_no"); $CI->db->SELECT("contact_mobile_no");
$CI->db->FROM(ENTITYCHILD); $CI->db->FROM(ENTITYCHILD);
$CI->db->WHERE("fk_entity_id",$core_details['fk_lender_id']); $CI->db->WHERE("fk_entity_id",$core_details[0]['fk_lender_id']);
$lender_mobile_nos = $CI->db->GET()->result_array(); $lender_mobile_nos = $CI->db->GET()->result_array();
//print_r($lender_mobile_nos);
//print_r($lender_mobile_nos);
if(count($lender_mobile_nos)) if(count($lender_mobile_nos))
{ {
foreach($lender_mobile_nos as $mobile) foreach($lender_mobile_nos as $mobile)
{ {
array_push($mobile_nos_to_send_notification,$mobile); array_push($mobile_nos_to_send_notification,$mobile['contact_mobile_no']);
} }
} }
} }
} }
//add pd officer no //add pd officer no
if($pd_notification_configs['sms_pdofficer'] == 1) if($pd_notification_configs[0]['sms_pdofficer'] == 1)
{ {
array_push($mobile_nos_to_send_notification,$core_details['allocated_mobile_no']); array_push($mobile_nos_to_send_notification,$core_details[0]['allocated_mobile_no']);
} }
//add pd incharge mobile_no's //add pd incharge mobile_no's
if($pd_notification_configs['sms_pdincharge'] == 1) if($pd_notification_configs[0]['sms_pdincharge'] == 1)
{ {
$CI->db->DISTINCT(); $CI->db->DISTINCT();
$CI->db->SELECT("mobile_no"); $CI->db->SELECT("mobile_no");
@ -104,11 +106,13 @@ class PDALERTS
} }
} }
$msg = "PD for Lender Applicant ID:".$core_details['lender_applicant_id']."has been".$$core_details['pd_status_name']; // status base configurable $msg = "PD for Lender Applicant ID:".$core_details[0]['lender_applicant_id']."has been".$core_details[0]['pd_status_name']; // status base configurable
//print_r($mobile_nos_to_send_notification);
foreach($mobile_nos_to_send_notification as $no) foreach($mobile_nos_to_send_notification as $no)
{ {
$CI->aws_s3->sendSMS($msg,$no); $no = (string)$no;
$CI->aws_sns->sendSMS($msg,$no);
} }

6
api/application/libraries/AWS_SNS.php
View File

@ -19,7 +19,9 @@ class AWS_SNS
// Construct the parent class // Construct the parent class
//parent::__construct(); //parent::__construct();
$this->sns = SnsClient::factory($this->sns_properties); $this->sns = SnsClient::factory($this->sns_properties);
// echo "caleed";
// $this->sendSMS('hi','9698262400');
// $this->sendSMS('hi2','9688895898');
} }
@ -45,7 +47,7 @@ class AWS_SNS
] ]
], ],
"Message" => $msg, "Message" => $msg,
"PhoneNumber" => $mobile_no "PhoneNumber" => "+91".$mobile_no
); );
$result = $this->sns->publish($args); $result = $this->sns->publish($args);