Subversion Repositories SmartDukaan

set_time_limit(0);

	public function admin_pushnotifications(){

		if ($this->request->is('post')) {

			$sql = $this->request->data['User']['sql'];

			if(!empty($sql)){

				$users = $this->User->query($sql);

				$this->set(compact('users'));

			}

		}

	}

	public function admin_push(){

		if ($this->request->is('post')) {

			if(empty($this->request->data['userIds'])){

				$this->Session->setFlash(__('Please choose a few users'));

				$this->redirect(array('action' => 'admin_pushnotifications'));

			}else{

				$this->loadModel('GcmUser');

				foreach ($this->request->data['userIds'] as $key => $value) {					

					$options = array('conditions'=>array('user_id'=>$value),'fields'=>array('gcm_regid'),'order'=>array('id'=>'desc'));

					$gcmUser = $this->GcmUser->find('first',$options);

					$regIds = array($gcmUser['GcmUser']['gcm_regid']);

					$message = array('message'=>$this->request->data['User']['message']);

					$this->send_push_notification($regIds,$message);

				}

			}

		}

	}

	private function send_push_notification($registatoin_ids, $message) {

		debug(func_get_args());return;

        $msg = array(

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

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

            'subtitle'      => 'This is a subtitle',

            'tickerText'    => 'Ticker text here...Ticker text here...Ticker text here',

            '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));

        }

        // Close connection

        curl_close($ch);

        // echo $result;die;

    }