淘宝转链接口更新

admin

2025-02-25 30d8e227e8d823b6c38c3b9c90ac2df03b63befe

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

@@ -1,257 +1,290 @@
package com.yeshi.fanli.util.push;



import java.io.IOException;

import java.util.Map;



import javax.annotation.PostConstruct;



import org.json.simple.parser.ParseException;

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

import org.springframework.stereotype.Component;



import com.xiaomi.xmpush.server.Constants;

import com.xiaomi.xmpush.server.Message;

import com.xiaomi.xmpush.server.Message.Builder;

import com.xiaomi.xmpush.server.Result;

import com.xiaomi.xmpush.server.Sender;

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.util.Constant;

import com.yeshi.fanli.util.PropertiesUtil;

import org.yeshi.utils.JsonUtil;



import net.sf.json.JSONObject;



@Component

public class XiaoMiPushUtil {



   private static XiaoMiPushUtil xiaoMiPushUtil;



   @Autowired

   private SystemService systemService;



   @PostConstruct

   public void init() {

      xiaoMiPushUtil = this;

      xiaoMiPushUtil.systemService = this.systemService;

   }



   // AppKey

   private static String XIAOMI_F_ANDROID_APP_KEY = PropertiesUtil.getMap().get("xiaomi_f_android_app_key");



   // AppSecert

   private static String XIAOMI_F_ANDROID_APP_SECERT = PropertiesUtil.getMap().get("xiaomi_f_android_app_secert");



   /**

    * 
    * 方法说明: 小米推送安卓（全推）

    * 
    * @author mawurui createTime 2018年3月7日 上午9:57:56

    * @param info

    * @param params

    * @param system

    * @return

    */

   public static String allPushAndroidForXM(MessageInfo info, Map<String, Object> map) {

      String name = info.getPackageName();

      if (!Constant.systemCommonConfig.getAndroidPackageName().equalsIgnoreCase(name)

            && !Constant.systemCommonConfig.getIosBundleId().equalsIgnoreCase(name)) {

         return null;

      }



      // 从info中取页面传来的值

      Constants.useOfficial(); // 启动推送方法

      String PackageName = info.getPackageName();

      Sender sender = new Sender(XIAOMI_F_ANDROID_APP_SECERT); // 申请的AppSecert

      String title = info.getTitle();

      String payload = info.getContent();

      String description = info.getContent();



      Message message = null; // 做循环传来的key

      Builder builder = new Message.Builder().restrictedPackageName(PackageName).title(title).payload(payload)

            .description(description).passThrough(0) // 设置消息是否通过透传方式至App,

                                             // 1表示透传，0表示通知栏消息（默认）

            .notifyType(1); // 设置通知类型, type类型(1-默认提示音, 2-使用默认震动提示,

                        // 3-使用默认led灯光提示)

      // 将extra放入MessageInfo对象中， 循环遍历extra中的key 和 value

      if (map != null) {

         for (String key : map.keySet()) {

            builder.extra(key, map.get(key).toString());

         }

      }

      message = builder.build();

      try {

         Result result = sender.broadcastAll(message, 3);

         return result.getMessageId();// 成功 返回消息的Id， 失败返回null

      } catch (IOException e) {

         e.printStackTrace();

      } catch (ParseException e) {

         e.printStackTrace();

      }

      return null;

   }



   /**

    * 
    * 方法说明: 小米推送安卓（单推）

    * 
    * @author mawurui createTime 2018年3月7日 下午5:09:18

    * @param info

    * @param params

    * @param system

    * @return

    */

   public static String singlePushAndroidForXM(MessageInfo info, Map<String, Object> map, System system) {

      String name = info.getPackageName();

      if (!Constant.systemCommonConfig.getAndroidPackageName().equalsIgnoreCase(name)

            && !Constant.systemCommonConfig.getIosBundleId().equalsIgnoreCase(name)) {

         return null;

      }

      Constants.useOfficial(); // 启动推送方法

      String PackageName = info.getPackageName();

      Sender sender = new Sender(XIAOMI_F_ANDROID_APP_SECERT);

      String title = info.getTitle();

      String content = info.getContent();

      String uId = info.getAlias();



      Message message = null; // 做循环传来的key

      Builder builder = new Message.Builder().restrictedPackageName(PackageName).title(title).description(content)

            .passThrough(0) // 设置消息是否通过透传方式至App, 1表示透传，0表示通知栏消息（默认）

            .notifyType(1); // 设置通知类型, type类型(1-默认提示音, 2-使用默认震动提示,

                        // 3-使用默认led灯光提示)

      // 将extra放入MessageInfo对象中， 循环遍历extra中的key 和 value

      if (map != null) {

         for (String key : map.keySet()) {

            builder.extra(key, map.get(key).toString());

         }

      }

      message = builder.build();

      try {

         Result result = sender.sendToAlias(message, uId, 3);

         PushLogHelper.xmInfo("推送结果:" + result.getReason());

         return result.getMessageId();

      } catch (IOException e) {

         e.printStackTrace();

      } catch (ParseException e) {

         e.printStackTrace();

      }

      return null;

   }



   /**

    * 
    * 方法说明: 小米推送红包

    * 
    * @author mawurui createTime 2018年3月8日 上午9:55:14

    * @param info

    */

   public static void pushByHongBao(String alias, System system) {

      MessageInfo info = new MessageInfo();

      info.setAlias(alias);

      info.setTitle("新到红包");

      info.setDescription("红包到来了...");

      JSONObject jsonObject = new JSONObject();

      jsonObject.put("type", "hongbao");

      XiaoMiPushUtil.singlePushAndroidForXM(info, JsonUtil.parseData(jsonObject), system);

   }



   /**

    * 
    * 方法说明: 小米推送提现申请

    * 
    * @author mawurui createTime 2018年3月8日 上午10:00:16

    * @param info

    */

   public static void pushByApply(String alias, System system) {

      MessageInfo info = new MessageInfo();

      info.setAlias(alias);

      info.setTitle("提现申请");

      info.setDescription("提现审核中...");

      JSONObject jsonObject = new JSONObject();

      jsonObject.put("type", "cash");

      XiaoMiPushUtil.singlePushAndroidForXM(info, JsonUtil.parseData(jsonObject), system);

   }



   /**

    * 
    * 方法说明: 推送提现状态

    * 
    * @author mawurui createTime 2018年3月8日 上午10:26:34

    * @param alias

    * @param state

    * @param system

    */

   public static void pushByExtract(String alias, int state, System system) {

      MessageInfo info = new MessageInfo();

      info.setAlias(alias);

      if (state == 0) {

         info.setTitle("提现成功");

         info.setDescription("您有一笔交易，已提现成功！");

      } else if (state == 1) {

         info.setTitle("提现失败");

         info.setDescription("您有一笔交易，提现失败！");

      } else {

         info.setTitle("提现失败");

         info.setDescription("提现被拒绝");

      }

      JSONObject jsonObject = new JSONObject();

      jsonObject.put("type", "cash");

      XiaoMiPushUtil.singlePushAndroidForXM(info, JsonUtil.parseData(jsonObject), system);

   }



   public static int allFanLiQuanDevice(MessageInfo info, JSONObject json, PushRecord pushRecord) {

      System b_android = xiaoMiPushUtil.systemService.getSystem("ANDROID",

            Constant.systemCommonConfig.getAndroidPackageName());

      return pushApp(info, json, pushRecord, b_android);

   }



   /**

    * 
    * @param info

    * @param params

    * @param pushRecord

    * @return 1:都成功 2：仅android 成功 3.仅IOS成功 4.都失败

    */

   private static int pushApp(MessageInfo info, JSONObject json, PushRecord pushRecord, System b_android) {

      // jsonXm 转换为 map

      JSONObject mapXm = JSONObject.fromObject(json);

      String android = allPushAndroidForXM(info, mapXm);

      LogHelper.userInfo("安卓推送测试：" + android);

      pushRecord.setAndroidPushId(android);

      if (android != null) {

         return 1;

      } else {

         return 4;

      }

   }



   public static void pushZNX(Long uid, String title, String content, String msgId) {

      // 小米开始推送

      MessageInfo info = new MessageInfo();

      info.setActivty(

            String.format("%s.ui.BrowserActivity", Constant.systemCommonConfig.getAndroidBaseactivityName()));

      info.setAlias(uid + "");

      info.setTitle(title);

      info.setContent(content);

      info.setPackageName(Constant.systemCommonConfig.getAndroidPackageName());

      JSONObject json = new JSONObject();

      json.put("type", "ZNX");

      json.put("miPushUrl", String.format("%s.ui.mine.AppMailDetailActivity",

            Constant.systemCommonConfig.getAndroidBaseactivityName()));



      JSONObject contentJson = new JSONObject();

      contentJson.put("id", msgId);

      contentJson.put("title", title);

      contentJson.put("content", content);

      contentJson.put("isOpen", 0);

      contentJson.put("createTime", java.lang.System.currentTimeMillis());

      json.put("content", contentJson);

      JSONObject mapXm = JSONObject.fromObject(json);

      XiaoMiPushUtil.singlePushAndroidForXM(info, mapXm, null);

   }



}

package com.yeshi.fanli.util.push;

import java.io.IOException;
import java.util.List;
import java.util.Map;

import javax.annotation.PostConstruct;

import org.json.simple.parser.ParseException;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import org.yeshi.utils.JsonUtil;

import com.xiaomi.xmpush.server.Constants;
import com.xiaomi.xmpush.server.Message;
import com.xiaomi.xmpush.server.Message.Builder;
import com.xiaomi.xmpush.server.Result;
import com.xiaomi.xmpush.server.Sender;
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.BusinessSystemService;
import com.yeshi.fanli.util.Constant;
import com.yeshi.fanli.util.PropertiesUtil;

import net.sf.json.JSONObject;

@Component
public class XiaoMiPushUtil {

    private static XiaoMiPushUtil xiaoMiPushUtil;

    @Autowired
    private BusinessSystemService businessSystemService;

    @PostConstruct
    public void init() {
        xiaoMiPushUtil = this;
        xiaoMiPushUtil.businessSystemService = this.businessSystemService;
    }

    // AppKey
    private static String XIAOMI_F_ANDROID_APP_KEY = PropertiesUtil.getMap().get("xiaomi_f_android_app_key");

    // AppSecert
    private static String XIAOMI_F_ANDROID_APP_SECERT = PropertiesUtil.getMap().get("xiaomi_f_android_app_secert");

    /**
     * 方法说明: 小米推送安卓（全推）
     *
     * @param info
     * @param params
     * @param system
     * @return
     * @author mawurui createTime 2018年3月7日 上午9:57:56
     */
    public static String allPushAndroidForXM(MessageInfo info, Map<String, Object> map) {
        if (Constant.IS_TEST)
            return null;

        String name = info.getPackageName();
        // 从info中取页面传来的值
        Constants.useOfficial(); // 启动推送方法
        String PackageName = info.getPackageName();
        Sender sender = new Sender(XIAOMI_F_ANDROID_APP_SECERT); // 申请的AppSecert
        String title = info.getTitle();
        String payload = info.getContent();
        String description = info.getContent();

        Message message = null; // 做循环传来的key
        Builder builder = new Message.Builder().restrictedPackageName(PackageName).title(title).payload(payload)
                .notifyId((int) (Math.random() * Integer.MAX_VALUE))
                .description(description).passThrough(0) // 设置消息是否通过透传方式至App,
                // 1表示透传，0表示通知栏消息（默认）
                .notifyType(1); // 设置通知类型, type类型(1-默认提示音, 2-使用默认震动提示,
        // 3-使用默认led灯光提示)
        // 将extra放入MessageInfo对象中， 循环遍历extra中的key 和 value
        if (map != null) {
            for (String key : map.keySet()) {
                builder.extra(key, map.get(key).toString());
            }
        }
        message = builder.build();
        try {
            Result result = sender.broadcastAll(message, 3);
            return result.getMessageId();// 成功 返回消息的Id， 失败返回null
        } catch (IOException e) {
            e.printStackTrace();
        } catch (ParseException e) {
            e.printStackTrace();
        }
        return null;
    }

    /**
     * 批量推送
     *
     * @param info
     * @param map
     * @param regList 最大个数为1000
     * @return
     */
    public static String pushBatchAndroidForXM(MessageInfo info, Map<String, Object> map, List<String> regList) {
        if (Constant.IS_TEST)
            return null;
        if (regList == null || regList.size() == 0)
            return "";

        String name = info.getPackageName();

        // 从info中取页面传来的值
        Constants.useOfficial(); // 启动推送方法
        String PackageName = info.getPackageName();
        Sender sender = new Sender(XIAOMI_F_ANDROID_APP_SECERT); // 申请的AppSecert
        String title = info.getTitle();
        String payload = info.getContent();
        String description = info.getContent();

        Message message = null; // 做循环传来的key
        Builder builder = new Message.Builder().restrictedPackageName(PackageName).title(title).payload(payload)
                .notifyId((int) (Math.random() * Integer.MAX_VALUE))
                .description(description).passThrough(0) // 设置消息是否通过透传方式至App,
                // 1表示透传，0表示通知栏消息（默认）
                .notifyType(1); // 设置通知类型, type类型(1-默认提示音, 2-使用默认震动提示,
        // 3-使用默认led灯光提示)
        // 将extra放入MessageInfo对象中， 循环遍历extra中的key 和 value
        if (map != null) {
            for (String key : map.keySet()) {
                builder.extra(key, map.get(key).toString());
            }
        }
        message = builder.build();
        try {
            Result result = sender.send(message, regList, 3);
            return result.getMessageId();// 成功 返回消息的Id， 失败返回null
        } catch (IOException e) {
            e.printStackTrace();
        } catch (ParseException e) {
            e.printStackTrace();
        }
        return null;
    }

    /**
     * 方法说明: 小米推送安卓（单推）
     *
     * @param info
     * @param params
     * @param system
     * @return
     * @author mawurui createTime 2018年3月7日 下午5:09:18
     */
    public static String singlePushAndroidForXM(MessageInfo info, Map<String, Object> map, List<String> regIds,
                                                System system) {
        String name = info.getPackageName();

        Constants.useOfficial(); // 启动推送方法
        String PackageName = info.getPackageName();
        Sender sender = new Sender(XIAOMI_F_ANDROID_APP_SECERT);
        String title = info.getTitle();
        String content = info.getContent();
        String uId = info.getAlias();

        Message message = null; // 做循环传来的key
        Builder builder = new Message.Builder().restrictedPackageName(PackageName).title(title).description(content)
                .passThrough(0) // 设置消息是否通过透传方式至App, 1表示透传，0表示通知栏消息（默认）
                .notifyId((int) (Math.random() * Integer.MAX_VALUE)).notifyType(1); // 设置通知类型,
        // type类型(1-默认提示音,
        // 2-使用默认震动提示,
        // 3-使用默认led灯光提示)
        // 将extra放入MessageInfo对象中， 循环遍历extra中的key 和 value
        if (map != null) {
            for (String key : map.keySet()) {
                builder.extra(key, map.get(key).toString());
            }
        }
        message = builder.build();
        try {
            Result result = sender.send(message, regIds, 3); // sender.sendToAlias(message,
            // uId, 3);
            PushLogHelper.xmInfo("推送结果:" + result.getReason());
            return result.getMessageId();
        } catch (IOException e) {
            e.printStackTrace();
        } catch (ParseException e) {
            e.printStackTrace();
        }
        return null;
    }

    /**
     * 方法说明: 小米推送红包
     *
     * @param info
     * @author mawurui createTime 2018年3月8日 上午9:55:14
     */
    public static void pushByHongBao(List<String> regIds, System system) {
        MessageInfo info = new MessageInfo();
        info.setTitle("新到红包");
        info.setDescription("红包到来了...");
        JSONObject jsonObject = new JSONObject();
        jsonObject.put("type", "hongbao");
        XiaoMiPushUtil.singlePushAndroidForXM(info, JsonUtil.parseData(jsonObject), regIds, system);
    }

    /**
     * 方法说明: 小米推送提现申请
     *
     * @param info
     * @author mawurui createTime 2018年3月8日 上午10:00:16
     */
    public static void pushByApply(List<String> regIds, System system) {
        MessageInfo info = new MessageInfo();
        info.setTitle("提现申请");
        info.setDescription("提现审核中...");
        JSONObject jsonObject = new JSONObject();
        jsonObject.put("type", "cash");
        XiaoMiPushUtil.singlePushAndroidForXM(info, JsonUtil.parseData(jsonObject), regIds, system);
    }

    /**
     * 方法说明: 推送提现状态
     *
     * @param alias
     * @param state
     * @param system
     * @author mawurui createTime 2018年3月8日 上午10:26:34
     */
    public static void pushByExtract(List<String> regIds, int state, System system) {
        MessageInfo info = new MessageInfo();
        if (state == 0) {
            info.setTitle("提现成功");
            info.setDescription("您有一笔交易，已提现成功！");
        } else if (state == 1) {
            info.setTitle("提现失败");
            info.setDescription("您有一笔交易，提现失败！");
        } else {
            info.setTitle("提现失败");
            info.setDescription("提现被拒绝");
        }
        JSONObject jsonObject = new JSONObject();
        jsonObject.put("type", "cash");
        XiaoMiPushUtil.singlePushAndroidForXM(info, JsonUtil.parseData(jsonObject), regIds, system);
    }

    /**
     * @param info
     * @param params
     * @param pushRecord
     * @return 1:都成功 2：仅android 成功 3.仅IOS成功 4.都失败
     */
    private static int pushApp(MessageInfo info, JSONObject json, PushRecord pushRecord, System b_android) {
        // jsonXm 转换为 map
        JSONObject mapXm = JSONObject.fromObject(json);
        String android = allPushAndroidForXM(info, mapXm);
        LogHelper.userInfo("小米推送：" + android);
        pushRecord.setAndroidPushId(android);
        if (android != null) {
            return 1;
        } else {
            return 4;
        }
    }

    public static void pushZNX(List<String> regIds, String title, String content, String msgId, String androidPackageName, String androidBaseActivityName) {
        // 小米开始推送
        MessageInfo info = new MessageInfo();
        info.setActivty(
                String.format("%s.ui.BrowserActivity", androidBaseActivityName));
        info.setTitle(title);
        info.setContent(content);
        info.setPackageName(androidPackageName);
        JSONObject json = new JSONObject();
        json.put("type", "ZNX");
        json.put("miPushUrl", String.format("%s.ui.mine.AppMailDetailActivity",
                androidBaseActivityName));

        JSONObject contentJson = new JSONObject();
        contentJson.put("id", msgId);
        contentJson.put("title", title);
        contentJson.put("content", content);
        contentJson.put("isOpen", 0);
        contentJson.put("createTime", java.lang.System.currentTimeMillis());
        json.put("content", contentJson);
        JSONObject mapXm = JSONObject.fromObject(json);
        XiaoMiPushUtil.singlePushAndroidForXM(info, mapXm, regIds, null);
    }

}