package com.push.server;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
import java.util.Properties;

import javapns.devices.Device;
import javapns.devices.implementations.basic.BasicDevice;
import javapns.notification.AppleNotificationServerBasicImpl;
import javapns.notification.PushNotificationManager;
import javapns.notification.PushNotificationPayload;
import javapns.notification.PushedNotification;

public class SendToAPNS {
    // 从客户端获取的deviceToken，在此为了测试，设一个固定值
    private static final String DEVICE_TOKEN =

"13b11050a3fc064b3692e25c0fbd3b774b39ecb0c55a51ff4fb1373e004577a0";
    List<String> deviceToken = new ArrayList<String>();

    public void send () {
        // 证书文件(.p12)在服务器端的目录
        String filePath = null;
        try {
            String path = this.getClass().getClassLoader().getResource("/").getPath();
            filePath = java.net.URLDecoder.decode(path,"utf-8");
        } catch (Exception e){
            e.printStackTrace();
        }
        System.out.println("filePath=" + filePath);
        String certificatePath = (filePath + "conf/ios_development.p12");
        // 获取ios_development.p12的密码
        Properties prop = new Properties();
        FileInputStream fis = null;
        try {
            fis = new FileInputStream(filePath + "conf/pushmessage.properties");

        } catch (FileNotFoundException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        try {
            prop.load(fis);
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        String certificatePassword = prop.getProperty("password");

        // 构建发送的消息
        String message="{'aps':{'alert':'this is a push message'}}";

        // 设别标识
        deviceToken.add(DEVICE_TOKEN);
        // 发送消息
        sendpush(deviceToken, certificatePath, certificatePassword, message, 4, false);
    }

     /************************************************
     测试用URL gateway.sandbox.push.apple.com /2195
     正式发布用URL gateway.push.apple.com / 2195
    javaPNS_2.2.jar必须
     ***************************************************/
    /**
   * @param tokens   iphone设备的唯一标识

   * @param path   .p12证书文件的路径

   * @param password  .p12证书文件的密码

   * @param message   发送的消息内容

   * @param count

   * @param sendCount  true 一对一发送      false 群发

   */
    public void sendpush(List<String> tokens,String path, String password, String message,Integer

count,boolean sendCount) {
        try {
            // message:{"aps":{"alert":"一条新消息"}}
            PushNotificationPayload payLoad =  PushNotificationPayload.fromJSON(message);
            //payLoad.addAlert(message);
            payLoad.addBadge(count);
            payLoad.addSound("default");

            PushNotificationManager pushManager = new PushNotificationManager();
            // true 正式发布用URL
            // false 测试用URL
            pushManager.initializeConnection(new AppleNotificationServerBasicImpl(path, password,

false));
            List<PushedNotification> notifications = new ArrayList<PushedNotification>();
            // 推送方式
            if (sendCount) {
                System.out.println("-------现在进行一对一推送-------");
                Device device = new BasicDevice();
                device.setToken(tokens.get(0));
                PushedNotification notification = pushManager.sendNotification(device, payLoad,

true);
                notifications.add(notification);
            } else {
                System.out.println("------现在进行群发-------");
                List<Device> device = new ArrayList<Device>();
                for (String token : tokens) {
                    device.add(new BasicDevice(token));
                }
                notifications = pushManager.sendNotifications(payLoad, device);
            }

            List<PushedNotification> failedNotifications = PushedNotification.findFailedNotifications

(notifications);
            List<PushedNotification> successfulNotifications =

PushedNotification.findSuccessfulNotifications(notifications);
            int failed = failedNotifications.size();
            int successful = successfulNotifications.size();

            if (successful > 0 && failed == 0) {
                //log.debug("-----All notifications pushed success (" +

successfulNotifications.size() + "):");
                System.out.println("-----All notifications pushed success (" +

successfulNotifications.size() + "):");
            }
            else if (successful == 0 && failed > 0) {
                //log.debug("-----All notifications pushed failed(" + failedNotifications.size() +

"):");
                System.out.println("-----All notifications pushed failed(" +

failedNotifications.size() + "):");
            }
            else if (successful == 0 && failed == 0) {
                System.out.println("No notifications could be sent, probably because of a critical

error");
            }
            else {
                //log.debug("------Some notifications pushed failed (" + failedNotifications.size

() + "):");
                //log.debug("------Others pushed success(" + successfulNotifications.size() +

"):");
                System.out.println("------Some notifications pushed failed (" +

failedNotifications.size() + "):");
                System.out.println("------Others pushed success(" + successfulNotifications.size()

+ "):");
            }
            pushManager.stopConnection();

        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}