ประยุกต์ใช้งาน Push Notification plugin ใน ionic metarial

C:\phonegap\learn004>cordova plugin add cordova-plugin-device

C:\phonegap\learn004>cordova plugin add phonegap-plugin-push --variable SENDER_ID="XXXXX"

--
-- Table structure for table `tbl_notify`
--

CREATE TABLE IF NOT EXISTS `tbl_notify` (
  `notify_id` int(11) NOT NULL,
  `notify_uid` varchar(255) NOT NULL,
  `notify_regid` varchar(255) NOT NULL,
  `notify_status` tinyint(1) NOT NULL,
  `notify_dateadd` datetime NOT NULL,
  `notify_updateadd` datetime NOT NULL
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

--
-- Indexes for dumped tables
--

--
-- Indexes for table `tbl_notify`
--
ALTER TABLE `tbl_notify`
  ADD PRIMARY KEY (`notify_id`);

--
-- AUTO_INCREMENT for dumped tables
--

--
-- AUTO_INCREMENT for table `tbl_notify`
--
ALTER TABLE `tbl_notify`
  MODIFY `notify_id` int(11) NOT NULL AUTO_INCREMENT;

'use strict';
angular.module('starter.services', [])
.service('ArticleService',function($http, $q) { // สร้าง service
    // url ไฟล์ json
    var url="https://www.ninenik.com/demo/article_new_api.php?callback=JSON_CALLBACK";
    return { // ในที่นี้เราจะใช้การส่งค่าแบบ post
        getArticle: function() {
            var deferred = $q.defer();
            $http.jsonp(url)
                .success(deferred.resolve)
                .error(deferred.reject);
            return deferred.promise;
        }
    };
})
.service('notifyService',function($http, $q){ // สร้าง service
    // กำหนด url ของ ไฟล์ api ของเรา
    var url = "http://192.168.8.102/app/api/notify_api.php";
    return { // ในที่นี้เราจะใช้การส่งค่าแบบ post
        setNotify: function(dataSend) {
            var deferred = $q.defer();
            $http.post(url,dataSend)
                .success(deferred.resolve)
                .error(deferred.reject);
            return deferred.promise;
        }
    };

})
.service('ShareService',function(){

});

<?php  
$mysqli = new mysqli("localhost", "root","","app");  
/* check connection */  
if ($mysqli->connect_errno) {  
    printf("Connect failed: %s\n", $mysqli->connect_error);  
    exit();  
}  
if(!$mysqli->set_charset("utf8")) {  
    printf("Error loading character set utf8: %s\n", $mysqli->error);  
    exit();  
}  

<?php
header("Content-type:application/json; charset=UTF-8");          
header("Cache-Control: no-store, no-cache, must-revalidate");         
header("Cache-Control: post-check=0, pre-check=0", false);    
if(isset($_SERVER['HTTP_ORIGIN'])) {
header("Access-Control-Allow-Origin: {$_SERVER['HTTP_ORIGIN']}");
header('Access-Control-Allow-Credentials: true');
 //       header('Access-Control-Max-Age: 86400');    // cache for 1 day
}
// Access-Control headers are received during OPTIONS requests
if($_SERVER['REQUEST_METHOD'] == 'OPTIONS') {
if(isset($_SERVER['HTTP_ACCESS_CONTROL_REQUEST_METHOD']))
header("Access-Control-Allow-Methods: GET, POST, OPTIONS");         
if(isset($_SERVER['HTTP_ACCESS_CONTROL_REQUEST_HEADERS']))
header("Access-Control-Allow-Headers: {$_SERVER['HTTP_ACCESS_CONTROL_REQUEST_HEADERS']}");
exit(0);
}
// ส่วนการกำหนด header ให้กำหนดตามด้านบน ไม่เช่นนั้น app จะไม่สามารถส่งค่ามาได้
require_once("dbconnect.php");
$postdata = file_get_contents("php://input"); // ค่าที่ส่งมาจะถูกเก็บที่ไฟล์ 
if(isset($postdata)) { // ถ้ามีคาที่ส่งมา
$_POST = json_decode($postdata,true); // แปลงค่าที่ส่งมาเป็นตัวแปร array $_POST
}
$_error_msg = null;
$_success_msg = null;
if(
	isset($_POST['regid']) &&  $_POST['regid']!="" && 
	isset($_POST['uid']) &&  $_POST['uid']!=""
){ // 
	
	
	$_res_regID = $mysqli->real_escape_string(trim($_POST['regid']));
	$_res_UID = $mysqli->real_escape_string(trim($_POST['uid']));

	if(isset($_error_msg) && $_error_msg!=""){
		$json_data[]=array(  
			"success" => $_success_msg,
			"error" => $_error_msg
		);    		
	}else{

		// เช็คในตารางก่อนว่า เครื่องมือถือนั้นๆ ได้เคยบันทึกข้อมูลมาก่อนแล้วหรือไม่ อิงจาก UUID
		$sql="
		SELECT notify_regid,notify_uid,notify_status FROM tbl_notify WHERE notify_uid = '".$_res_UID."' 
		";	
		$result = $mysqli->query($sql);
		if($result && $result->num_rows>0){ // ถ้าเคยบันทึกแล้ว
			$row = $result->fetch_assoc(); // ดึงค่ามาตรวจสอบ
			$_success_msg=1;
			if($row['notify_regid'] != $_res_regID){ // ถ้าค่าเดิม กับค่าหใม่ไม่เหมือนกัน ให้อัพเดทค่าใหม่
				$sql2 = "
				UPDATE tbl_notify SET 
				notify_regid = '".$_res_regID."' ,
				notify_status = '1' ,
				notify_updateadd = '".date('Y-m-d H:i:s')."' 		
				WHERE notify_uid = '".$_res_UID."'
				";
				$result2 = $mysqli->query($sql2);
				if($result2 && $mysqli->affected_rows>0){ // ถ้าอัพเดทสำเร็จ
					$_success_msg=1;
					$json_data[]=array(  
						"success" => $_success_msg,
						"error" => $_error_msg,
						"regid" => $_res_regID,
						"uid"=> $_res_UID,
						"status"=> 1 
					);    			
				}else{ // ถ้าอัพเดทไม่สำเร็จ
					$json_data[]=array(  
						"success" => $_success_msg,
						"error" => $_error_msg
					);    				
				}
			}else{  // ถ้าค่าใหม่ เท่ากับค่าเดิม ใช้ค่าเดิม
				$json_data[]=array(  
					"success" => $_success_msg,
					"error" => $_error_msg,
					"regid" => $row['notify_regid'],
					"uid" => $row['notify_uid'],
					"status" => $row['notify_status']
				);    	
			}
		}else{ // ถ้ายังไม่มีข้อมูล ให้บันทีกข้อมูลใหม่
			$sql2 = "
			INSERT INTO tbl_notify SET 
			notify_uid = '".$_res_UID."' ,
			notify_regid = '".$_res_regID."' ,
			notify_status = '1' ,
			notify_dateadd = '".date('Y-m-d H:i:s')."' 		
			";
			$result2 = $mysqli->query($sql2);
			if($result2 && $mysqli->affected_rows>0){ // ถ้าบันทึกขอ้มูลสำเร็จ
				$_success_msg=1;
				$json_data[]=array(  
					"success" => $_success_msg,
					"error" => $_error_msg,
					"regid" => $_res_regID,
					"uid"=> $_res_UID,
					"status"=> 1 
				);    			
			}else{ // ถ้าบันทึกข้อมูลล้มเหลว
				$json_data[]=array(  
					"success" => $_success_msg,
					"error" => $_error_msg
				);    				
			}
		}
		
	}
	//
		
}else{ // ไม่มีการส่งข้อมูลใดๆ เข้ามา
	$_error_msg = "เกิดข้อผิดพลาด ไม่มีค่าส่งมา";
	$json_data[]=array(  
		"success" => $_success_msg,
		"error" => $_error_msg
	);    			
}
// แปลง array เป็นรูปแบบ json string
if(isset($json_data)){
	$json= json_encode($json_data);  
	if(isset($_GET['callback']) && $_GET['callback']!=""){  
	echo $_GET['callback']."(".$json.");";      
	}else{  
	echo $json;  
	}  
}
?>

.run(function($ionicPlatform,$ionicPopup,$cordovaDialogs) {
    $ionicPlatform.ready(function() {
        if (window.cordova && window.cordova.plugins.Keyboard) {
            cordova.plugins.Keyboard.hideKeyboardAccessoryBar(true);
        }
        if (window.StatusBar) {
            StatusBar.styleDefault();
        }
    });

})

.run(function($ionicPlatform,$ionicPopup,$cordovaDialogs, $cordovaPushV5,
    $rootScope, $cordovaDevice, notifyService, $state) {
    $ionicPlatform.ready(function() {
        if (window.cordova && window.cordova.plugins.Keyboard) {
            cordova.plugins.Keyboard.hideKeyboardAccessoryBar(true);
        }
        if (window.StatusBar) {
            StatusBar.styleDefault();
        }
    });

    // กำหนด senderID สำหรับ android
    var options = {
        android: {
            senderID: "XXXXXX"
        }
    };

    $ionicPlatform.ready(function() { // เตรียมก่อนเรียกใช้ plugin
        // ตั้งค่าเริ่มต้น
        $cordovaPushV5.initialize(options).then(function() {
            // เรียกฟังก์ชั่นตรวจจับข้อความ push กรณีได้รับข้อความ
            $cordovaPushV5.onNotification();
            // เรียกฟังก์ชั่นตรวจจับข้อความ push กรณีเกิดข้อผิดพลาด
            $cordovaPushV5.onError();

            // ลงทะเบียนรับ registrationId
            $cordovaPushV5.register().then(function(registrationId) {
                alert('RegID: '+registrationId);
                alert('UUID: '+$cordovaDevice.getUUID());
                // เตรียมข้อมูลสำหรับส่งไปบันทึกบน server
                var dataSend = {
                    uid:$cordovaDevice.getUUID(),
                    regid:registrationId
                };
                // service เรียกใช้ฟังก์ชั่น notifyService ส่งค่าไปยัง server
                notifyService.setNotify(dataSend)
                    .then(function(response) {
                        // ทดสอบแสดงค่าว่าบันทึกสำเร็จหรือไม่
                        alert(JSON.stringify(response));
                    });
            });
        });

        // รอรับทำงานเมื่อ มีข้อความ push เข้ามา
        $rootScope.$on('$cordovaPushV5:notificationReceived', function(event, data){
            alert('OK Received:'+JSON.stringify(data));
            $state.go('app.article'); // เมื่อเปิดที่ข้อความ push ให้ไปหน้าที่ต้องการ
            // ชุดข้อมูลที่เราจะได้จากข้อความ push สามารถกำหนดค่าเองเพิ่มเติมได้
            // ด้านล่างนี้คือค่าพื้นฐาน
            // data.message, // ข้อความแจ้ง
            // data.title, // หัวข้อ
            // data.count, // จำนวนเลขระบุ กรณีมีการแจ้งจำนวนใดๆ
            // data.sound, // เสียง
            // data.image, // รูปภาพที่แสดงใน push ใช้เป็น url ได้
            // data.additionalData // ข้อมูลเพิ่ม
            // ค่าข้างต้นเหล่านี้เป็นค่าที่เรา ต้องกำหนดในไฟล์ส่งข้อความ push
        });

        // รอรับทำงานเมื่อ เกิดข้อผิดพลาด ปกติเราจะไม่ให้ทำงานใดๆ
        $rootScope.$on('$cordovaPushV5:errorOcurred', function(event, e){
            alert('ERR Received:'+JSON.stringify(e));
            // e.message // ข้อความ error
        });

    });

})

<?php
header("Content-type:text/html; charset=UTF-8");            
header("Cache-Control: no-store, no-cache, must-revalidate");         
header("Cache-Control: post-check=0, pre-check=0", false);      
// เชื่อมต่อกับฐานข้อมูล      
require_once("dbconnect.php");
// ส่วนตั้งค่าการใช้งาน push
require_once("pusher.php");
$fcmToken = "your_fcm_token";  // ค่าา FCM token
$pusher = new Pusher($fcmToken);


$regId=array();
$sql="
SELECT * FROM tbl_notify
";
$result = $mysqli->query($sql);
if($result){
	while($row = $result->fetch_assoc()){
		$regId[]=$row['notify_regid'];
	}
}

$msg = array
(
	'message' 	=> 'ทดสอบข้อความภาษาไทย',
	'title'		=> 'ทดสอบหัวข้อหลัก',
	'subtitle'	=> 'ทดสอบหัวข้อย่อย',
	'tickerText'	=> 'Ticker text here...Ticker text here...Ticker text here',
	'vibrate'	=> 1,
	'sound'		=> 1,
	'count'		=> 2,	
	'image' => 'https://www.ninenik.com/images/banner_ninenik.gif',
	'largeIcon'	=> 'large_icon',
	'smallIcon'	=> 'small_icon'
);
$pusher->notify($regId, $msg);
echo "<pre>";
print_r($pusher->getOutputAsArray());
echo "</pre>";
?>

$fcmToken = "your_fcm_token";  // ค่าา FCM token

C:\phonegap\learn004>phonegap build android