Subversion Repositories SmartDukaan

	private function send_push_notification($registatoin_ids, $message, $user_id) {

                $msg = array(

                    'message'       => $message['message'],

                    'cid'               => $message['cid'],

                    'title'         => $message['title'],

                    'type'              => $message['type'],

                    'url'                   => $message['url'],

                    // 'expiresat'          => strtotime($message['expiresat']),

                    'vibrate'       => 1,

                    'sound'         => 1,

                    'largeIcon'     => 'large_icon',

                    'smallIcon'     => 'small_icon'

                );

                // Set POST variables

                $url = 'https://android.googleapis.com/gcm/send';

                $fields = array(

                    'registration_ids' => $registatoin_ids,

                    'data' => $msg,

                );

                $headers = array(

                    'Authorization: key=' . Configure::read('googleapikey'),

                    'Content-Type: application/json'

                );

                //print_r($headers);

                // Open connection

                $ch = curl_init();

                // Set the url, number of POST vars, POST data

                curl_setopt($ch, CURLOPT_URL, $url);

                curl_setopt($ch, CURLOPT_POST, true);

                curl_setopt($ch, CURLOPT_HTTPHEADER, $headers);

                curl_setopt($ch, CURLOPT_RETURNTRANSFER, true);

                // Disabling SSL Certificate support temporarly

                curl_setopt($ch, CURLOPT_SSL_VERIFYPEER, false);

                curl_setopt($ch, CURLOPT_POSTFIELDS, json_encode($fields));

                // Execute post

                $result = curl_exec($ch);

                if ($result === FALSE) {

                    die('Curl failed: ' . curl_error($ch));

                }

                $res = json_decode($result,1);

                $this->loadModel('Pushnotification');

                if($res['success']==1){

					$data = array('notification_campaign_id'=>$message['cid'],'user_id'=>$user_id,'type'=>'sent','status'=>$res['success'],'message'=>'success');

				}else if($res['success']==0){

					$error_message=$res['results'][0]['error'];

					$sqlQuery="update gcm_users set failurecount=failurecount+1 where gcm_regid='".$registatoin_ids[0]."'";

					$resultData=$this->GcmUser->query($sqlQuery);

					$data = array('notification_campaign_id'=>$message['cid'],'user_id'=>$user_id,'type'=>'sent','status'=>$res['success'],'message'=>$error_message);

				}

                #$data = array('notification_campaign_id'=>$message['cid'],'user_id'=>$user_id,'status'=>$res['success']);

                $this->Pushnotification->create();

                $this->Pushnotification->save($data);

                $this->log("For $user_id ".$registatoin_ids[0]." ".print_r($data,1),'pushnotifications');

                // Close connection

                curl_close($ch);

                $this->log("For $user_id ".$registatoin_ids[0]." ".print_r($result,1),'pushnotifications');

        }