admin
2019-07-11 3824cbcaec6e6c67418d5280a53e9c2fedeef6f9
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;
   }
   /**
@@ -57,6 +56,9 @@
    */
   public static String allPushIOS(List<String> deviceTokenList, MessageInfo info, String url, int type)
         throws Exception {
      if (Constant.IS_TEST)
         return null;
      Gson gson = new Gson();
      PushLogHelper.iosInfo("IOS推送设备数为:" + deviceTokenList.size());
@@ -114,7 +116,7 @@
            int end = start + pageSize;
            if (end > tokenList.size())
               end = tokenList.size();
            pushIOS(tokenList.subList(start, end), json,certificate,certificatePassword);
            pushIOS(tokenList.subList(start, end), json, certificate, certificatePassword);
         }
      }
@@ -122,7 +124,8 @@
      return null;
   }
   public static String pushIOS(List<String> deviceTokenList, JSONObject json,InputStream certificate,String certificatePWD) 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);
@@ -151,11 +154,9 @@
      PushNotificationManager pushManager = new PushNotificationManager();
      // true:表示的是产品线上发布推送服务 false:表示的是产品测试推送服务
      if (Constant.IS_TEST)
         pushManager.initializeConnection(
               new AppleNotificationServerBasicImpl(certificate, certificatePWD, false));
         pushManager.initializeConnection(new AppleNotificationServerBasicImpl(certificate, certificatePWD, false));
      else
         pushManager
               .initializeConnection(new AppleNotificationServerBasicImpl(certificate, certificatePWD, true));
         pushManager.initializeConnection(new AppleNotificationServerBasicImpl(certificate, certificatePWD, true));
      List<Device> deviceList = new ArrayList<Device>();
      for (String token : tokenList) {
@@ -222,7 +223,7 @@
      InputStream certificate = IOSPushUtil.class.getClassLoader()
            .getResourceAsStream("certificate/pushCertificate.p12"); // 读取.p12文件
      String certificatePassword = Constant.systemCommonConfig.getIosPushCertificatePwd();
      pushIOS(tokenList, json,certificate,certificatePassword);
      pushIOS(tokenList, json, certificate, certificatePassword);
   }
   /**