券推送插入

yujian

2019-04-22 b6c37e4bc38db88a360d0f2c6099183f9bb75bdc

 fanli/src/main/java/com/yeshi/fanli/util/push/IOSPushUtil.java

@@ -8,19 +8,18 @@


import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.stereotype.Component;

import org.yeshi.utils.HttpUtil;



import com.google.gson.Gson;

import com.yeshi.fanli.controller.admin.PushController;

import com.yeshi.fanli.entity.system.System;

import com.yeshi.fanli.entity.xinge.MessageInfo;

import com.yeshi.fanli.entity.xinge.PushRecord;

import com.yeshi.fanli.log.LogHelper;

import com.yeshi.fanli.log.PushLogHelper;

import com.yeshi.fanli.service.inter.config.SystemService;

import com.yeshi.fanli.service.inter.config.BusinessSystemService;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.factory.IOSPushFactory;

import org.yeshi.utils.HttpUtil;



import javapns.devices.Device;

import javapns.devices.implementations.basic.BasicDevice;

@@ -36,12 +35,12 @@
   private static IOSPushUtil iosPushUtil;



   @Autowired

   private SystemService systemService;

   private BusinessSystemService businessSystemService;



   @PostConstruct

   public void init() {

      iosPushUtil = this;

      iosPushUtil.systemService = this.systemService;

      iosPushUtil.businessSystemService = this.businessSystemService;

   }



   /**

@@ -103,6 +102,9 @@
      }

      // 分组推送 每50个设备为一组



      InputStream certificate = IOSPushUtil.class.getClassLoader()

            .getResourceAsStream("certificate/pushCertificate.p12"); // 读取.p12文件

      String certificatePassword = Constant.systemCommonConfig.getIosPushCertificatePwd();

      if (tokenList != null && tokenList.size() > 0) {

         int pageSize = 50;

         int page = tokenList.size() % pageSize == 0 ? tokenList.size() / pageSize : tokenList.size() / pageSize + 1;

@@ -111,7 +113,7 @@
            int end = start + pageSize;

            if (end > tokenList.size())

               end = tokenList.size();

            pushIOS(tokenList.subList(start, end), json);

            pushIOS(tokenList.subList(start, end), json,certificate,certificatePassword);

         }



      }

@@ -119,14 +121,11 @@
      return null;

   }



   private static String pushIOS(List<String> deviceTokenList, JSONObject json) throws Exception {

   public static String pushIOS(List<String> deviceTokenList, JSONObject json,InputStream certificate,String certificatePWD) throws Exception {

      List<String> tokenList = new ArrayList<String>();

      for (String deviceToken : deviceTokenList) {

         tokenList.add(deviceToken);

      }

      InputStream certificate = IOSPushUtil.class.getClassLoader()

            .getResourceAsStream("certificate/pushCertificate.p12"); // 读取.p12文件

      String certificatePassword = Constant.systemCommonConfig.getIosPushCertificatePwd();// 此处注意导出的证书密码不能为空因为空密码会报错

      while (json.toString().getBytes().length > 256) {

         // 首先削减内容，然后削减标题

         String title = json.optJSONObject("aps").optJSONObject("alert").optString("title");

@@ -152,10 +151,10 @@
      // true：表示的是产品线上发布推送服务 false：表示的是产品测试推送服务

      if (Constant.IS_TEST)

         pushManager.initializeConnection(

               new AppleNotificationServerBasicImpl(certificate, certificatePassword, false));

               new AppleNotificationServerBasicImpl(certificate, certificatePWD, false));

      else

         pushManager

               .initializeConnection(new AppleNotificationServerBasicImpl(certificate, certificatePassword, true));

               .initializeConnection(new AppleNotificationServerBasicImpl(certificate, certificatePWD, true));



      List<Device> deviceList = new ArrayList<Device>();

      for (String token : tokenList) {

@@ -219,7 +218,10 @@
    * @throws Exception

    */

   public static void executePushIOS(List<String> tokenList, JSONObject json) throws Exception {

      pushIOS(tokenList, json);

      InputStream certificate = IOSPushUtil.class.getClassLoader()

            .getResourceAsStream("certificate/pushCertificate.p12"); // 读取.p12文件

      String certificatePassword = Constant.systemCommonConfig.getIosPushCertificatePwd();

      pushIOS(tokenList, json,certificate,certificatePassword);

   }



   /**