Subversion Repositories SmartDukaan

<?php
App::uses('AppController', 'Controller');
/**
 * NotificationCampaigns Controller
 *
 * @property NotificationCampaign $NotificationCampaign
 * @property PaginatorComponent $Paginator
 */
class NotificationCampaignsController extends AppController {

/**
 * Components
 *
 * @var array
 */
        public $components = array('Paginator');

        public function beforeFilter() {                
                parent::beforeFilter();
                $this->Auth->allow('notificationactive');
                $this->apihost = Configure::read('pythonapihost');
        }

/**
 * admin_index method
 *
 * @return void
 */
        public function admin_index() {
                $this->NotificationCampaign->recursive = 0;
                // $this->Paginator->settings = array('order' => array('id'=>'desc'),'fields'=>('NotificationCampaign.id'));
                $this->Paginator->settings = array('order' => array('id'=>'desc'));
                $vari = $this->Paginator->paginate();
                // debug($vari);
                $checkArray=array();
                $id_set = '';
                foreach ($vari as $key => $row) {
                        foreach ($row as $key => $value) {
                                if($id_set == '')
                                {
                                        $id_set = $value['id'];
                                }
                                else
                                {
                                        $id_set = $id_set.','.$value['id'];
                                }
                        }
                        
                }

                $url = Configure::read('nodeurl')."/getPushNotificationsStats/?campaigns=".$id_set;
                // echo $url;
                $result = $this->make_request($url,null);
                // echo "Idset", $id_set;
                // debug($result);
                // $campaign_array = array();
                // foreach ($vari as $key => $value) {
                //      echo $value['NotificationCampaign']['id'];

                // }
                /*
                foreach ($vari as $key => $value) {
                        $cid=$value['NotificationCampaign']['id'];
                        $sqlQuery = "SELECT status as status,notification_campaign_id,type,count(*) as count FROM pushnotifications group by notification_campaign_id, type,status";
                        #$successQuery="SELECT count(*) as count from pushnotifications where status=1 and type='sent' and notification_campaign_id=$cid";
                        $successQuery="SELECT count(distinct p.user_id) as count from pushnotifications p join devices d on p.user_id=d.user_id where status=1 and type='sent' and notification_campaign_id='$cid'  and d.versioncode>=14";
                        $resul=$this->NotificationCampaign->query($sqlQuery);   
                        $success_result=$this->NotificationCampaign->query($successQuery);      
                        array_push($checkArray, $success_result[0][0]['count']);
                }
                // debug($checkArray);
                $finalResult = array();
                foreach ($resul as $key => $value) {
                        $finalResult[$value['pushnotifications']['notification_campaign_id']][$value['pushnotifications']['type']]=$value[0]['count'];
                        $finalResult[$value['pushnotifications']['notification_campaign_id']][$value['pushnotifications']['status']]=$value[0]['count'];
                        //$finalResult[$value['pushnotifications']['notification_campaign_id']][$value['pushnotifications']['type']]=$value[0]['status'];                       
                }
                // debug($finalResult);
                */
                // $this->set('notificationWithVersionCode', $checkArray);
                $this->set('notificationCampaigns', $vari);
                //$this->set('notificationCampaignsCount', $finalResult);
                $this->set(compact('result'));
        }

/**
 * admin_view method
 *
 * @throws NotFoundException
 * @param string $id
 * @return void
 */
        public function admin_view($id = null) {
                if (!$this->NotificationCampaign->exists($id)) {
                        throw new NotFoundException(__('Invalid notification campaign'));
                }
                $sort = $this->request->query('type');
                $direction = $this->request->query('order');
                $options = array('conditions' => array('NotificationCampaign.' . $this->NotificationCampaign->primaryKey => $id));
                $userData=$this->NotificationCampaign->find('first', $options);
                // $userActions = array();
                // foreach ($userData['Pushnotification'] as $key => $value) {
                //      if($value['type']=='sent'){
                //      $userActions[$value['user_id']][$value['type']] = $value['created'];
                //      $userActions[$value['user_id']]['status'] =$value['status'];
                //      }else{
                //              $userActions[$value['user_id']][$value['type']] = $value['response_time'];
                //      }
                //       //debug($value);
                // }

                $userActions = array();
                $url = Configure::read('nodeurl')."/getPushNotificationByCampaignId/?notification_campaign_id=".$id;
                // echo $url;
                $result = $this->make_request($url,null);
                foreach ($result as $key => $value) {
                        if($value['type']=='sent'){
                                // date_default_timezone_set('GMT');
                                $epoch = $value['created']/1000;
                                $dt = date('Y-m-d H:i:s', $epoch);
                                // echo $dt->format('Y-m-d H:i:s');
                                $userActions[$value['user_id']][$value['type']] = $dt;//$value['created'];
                                $userActions[$value['user_id']]['status'] =$value['status'];
                        }else{
                                $epoch = $value['response_time']/1000;
                                // date_default_timezone_set('GMT');
                                $dt = date('Y-m-d H:i:s', $epoch);
                                $userActions[$value['user_id']][$value['type']] = $dt;//$value['response_time'];
                        }
                         //debug($value);
                }
                // debug($userData);
                // debug($result);
                // debug($userActions);
                // debug($userAct);
                
                // $this->set(compact('result'));

                $cid=$userData['NotificationCampaign']['id'];
                $sqlQuery = "SELECT status as status,notification_campaign_id,type,count(*) as count FROM pushnotifications where notification_campaign_id=$cid group by type,status";
                $resul=$this->NotificationCampaign->query($sqlQuery);   
                $finalResult = array(); 
                foreach ($resul as $key => $value) {
                        $finalResult[$value['pushnotifications']['notification_campaign_id']][$value['pushnotifications']['type']]=$value[0]['count'];
                        $finalResult[$value['pushnotifications']['notification_campaign_id']][$value['pushnotifications']['status']]=$value[0]['count'];
                        //$finalResult[$value['pushnotifications']['notification_campaign_id']][$value['pushnotifications']['type']]=$value[0]['status'];                       
                }
                
                $this->set('notificationData', $userData);
                $this->set('notificationCampaign', $userActions);
                $this->set('notificationCount', $finalResult);
        }

/**
 * admin_add method
 *
 * @return void
 */
        public function admin_add() {
                if ($this->request->is('post')) {
                        $this->NotificationCampaign->create();
                        if ($this->NotificationCampaign->save($this->request->data)) {
                                $this->Session->setFlash(__('The notification campaign has been saved.'));
                                return $this->redirect(array('action' => 'index'));
                        } else {
                                $this->Session->setFlash(__('The notification campaign could not be saved. Please, try again.'));
                        }
                }
        }

/**
 * admin_edit method
 *
 * @throws NotFoundException
 * @param string $id
 * @return void
 */
        public function admin_edit($id = null) {
                if (!$this->NotificationCampaign->exists($id)) {
                        throw new NotFoundException(__('Invalid notification campaign'));
                }
                if ($this->request->is(array('post', 'put'))) {
                        if ($this->NotificationCampaign->save($this->request->data)) {
                                $this->Session->setFlash(__('The notification campaign has been saved.'));
                                return $this->redirect(array('action' => 'index'));
                        } else {
                                $this->Session->setFlash(__('The notification campaign could not be saved. Please, try again.'));
                        }
                } else {
                        $options = array('conditions' => array('NotificationCampaign.' . $this->NotificationCampaign->primaryKey => $id));
                        $this->request->data = $this->NotificationCampaign->find('first', $options);
                }
        }

/**
 * admin_delete method
 *
 * @throws NotFoundException
 * @param string $id
 * @return void
 */
        public function admin_delete($id = null) {
                $this->NotificationCampaign->id = $id;
                if (!$this->NotificationCampaign->exists()) {
                        throw new NotFoundException(__('Invalid notification campaign'));
                }
                $this->request->onlyAllow('post', 'delete');
                if ($this->NotificationCampaign->delete()) {
                        $this->Session->setFlash(__('The notification campaign has been deleted.'));
                } else {
                        $this->Session->setFlash(__('The notification campaign could not be deleted. Please, try again.'));
                }
                return $this->redirect(array('action' => 'index'));
        }
        // $this->set(compact('result'));
        // 
        public function admin_show($id = null,$type=null,$status=null) {
                // $sqlQuery = "SELECT * FROM pushnotifications where notification_campaign_id=$id and type='$type' and status=$status" ;
                
                // $resul=$this->NotificationCampaign->query($sqlQuery1ry);
                // if($type == 0 || $type == 1)
                // {
                //      $type = "sent";
                // }
                // echo "type", $type;
                $url = Configure::read('nodeurl')."/getPushNotificationDetailsByType/?type=".$type."&notification_campaign_id=".$id."&status=".$status;//remove hardcoded value
                // echo $url;
                $result = $this->make_request($url,null);
                // debug($result);
                $sqlQuery1 = "SELECT * FROM notification_campaigns where id=$id" ;
                $resultData=$this->NotificationCampaign->query($sqlQuery1);

                $this->set(compact('result'));
                // $this->set('data', $result);
                $this->set('notificationData', $resultData);
        }

        public function admin_user($id = null) {
                $sqlQuery = "SELECT * FROM pushnotifications where user_id=$id order by id desc" ;
                $resul=$this->NotificationCampaign->query($sqlQuery);
                $this->set('userdata', $resul);
        }

        public function admin_sort($id = null) {
                $sort = $this->request->query('type');
                $direction = $this->request->query('order');
                //$cid = $this->request->query('cid');
                if($sort=='user_id'){
                        $sqlQuery = "SELECT * FROM pushnotifications where notification_campaign_id =$id order by $sort $direction" ;                   
                }
                else{
                        $sqlQuery = "SELECT * FROM pushnotifications where notification_campaign_id =$id order by type='$sort' $direction" ;
                }
                $resul=$this->NotificationCampaign->query($sqlQuery);
                $userActions = array();
                foreach ($resul as $key => $value) {
                        if($value['pushnotifications']['type']=='sent'){
                        $userActions[$value['pushnotifications']['user_id']][$value['pushnotifications']['type']] = $value['pushnotifications']['created'];
                        $userActions[$value['pushnotifications']['user_id']]['status'] =$value['pushnotifications']['status'];
                        }else{
                                $userActions[$value['pushnotifications']['user_id']][$value['pushnotifications']['type']] = $value['pushnotifications']['response_time'];
                        }                       
                }
                $this->set('notificationId',$id);
                $this->set('sortdata', $userActions);
        }

        public function notificationactive(){
                session_write_close();
                $cid = $this->request->query('cid');
                $this->log("cid $cid",'notificationactive');
                $options = array('conditions' => array('id'=> $cid,'status'=>'active','expiresat >'=>date('Y-m-d H:i:s',time())),'recursive'=>-1);
                $count = $this->NotificationCampaign->find('count',$options);
                $this->log("count ".print_r($count,1),'notificationactive');
                if(!$count){
                        $result = array('success'=>false);
                }else{
                        $result = array('success'=>true);
                }
                
                $this->response->type('json');
                $this->layout = 'ajax';
                $this->set(array(
                    'result' => $result,
                    '_serialize' => array('result')
                ));
                $this->render('/Elements/json');
        }

        public function admin_send(){
                if ($this->request->is('post')) {                       
                        $sql = $this->request->data['NotificationCampaign']['sql'];
                        if(!empty($sql)){
                                $users = $this->NotificationCampaign->query($sql);
                                // debug($users);
                                $message = $this->request->data['NotificationCampaign'];
                                // $data = array('name'=>$message['name'],'title'=>$message['title'],'type'=>$message['type'],'message'=>$message['message'],'url'=>$message['url'],'expiresat'=>$message['expiresat'],'sql'=>$message['sql']);
                                $this->NotificationCampaign->create();
                                if($this->NotificationCampaign->save($message)){
                                        $message['cid'] = $this->NotificationCampaign->getLastInsertId();
                                } else{
                                        debug($this->NotificationCampaign->validationErrors);
                                        $message['cid'] = $message['name'];
                                }                               
                                $this->loadModel('Pushnotification');
                                $sentUsers = array();
                                $payload = array();
                                foreach ($users as $key => $value) {    
                                        if(!in_array($value['User']['id'], $sentUsers)) {
                                                $sentUsers[] = $value['User']['id'];                                                            
                                                $data = array('notification_campaign_id'=>$message['cid'],'user_id'=>$value['User']['id'],'type'=>'pending','status'=>0);
                                                // $this->Pushnotification->create();
                                                // $this->Pushnotification->save($data);
                                                $payload[] = $data;
                                        }
                                }
                                $url = Configure::read('nodeurl')."/addPushNotification";//remove hardcoded value
                                $this->make_request($url,json_encode($payload,JSON_NUMERIC_CHECK));
                                $this->Session->setFlash(__('Push notification scheduled for '.sizeof($users).' users'));
                                return $this->redirect(array('controller' => 'administration', 'action' => 'dashboard', 'admin' => false));
                        }
                }
        }
}