package com.ks.push.controller;

import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.ks.push.dto.mq.InvalidDeviceTokenInfo;
import com.ks.push.manager.BPushPlatformAppInfoManager;
import com.ks.push.manager.rabbitmq.RabbitmqManager;
import com.ks.push.pojo.DO.PushPlatform;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import org.yeshi.utils.StringUtil;
import org.yeshi.utils.wx.WXUtil;

import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;

/**
 * @author Administrator
 * @title: PushCallbackController
 * @description: 各大手机推送平台的消息回执
 * @date 2021/9/15 12:17
 */
@Controller
@RequestMapping("callback")
public class PushCallbackController {
    Logger logger = LoggerFactory.getLogger(PushCallbackController.class);

    @Resource
    private BPushPlatformAppInfoManager bPushPlatformAppInfoManager;

    @Resource
    private RabbitmqManager rabbitmqManager;


    //回调接口详情：https://developer.huawei.com/consumer/cn/doc/development/HMSCore-Guides/msg-receipt-guide-0000001050040176#ZH-CN_TOPIC_0000001087208860__p121151147184318
    @ResponseBody
    @RequestMapping("hw")
    public String hw(HttpServletRequest request) {
        String content = WXUtil.getContent(request);
        if (StringUtil.isNullOrEmpty(content)) {
            return "";
        }
        JSONObject json = JSONObject.parseObject(content);
        JSONArray statuses = json.getJSONArray("statuses");
        for (int i = 0; i < statuses.size(); i++) {
            JSONObject statuse = statuses.getJSONObject(i);
            String appId = statuse.getString("appid");
            String bigTag = statuse.getString("biTag");
            String token = statuse.getString("token");
            String appCode = bPushPlatformAppInfoManager.selectAppCode(appId, PushPlatform.hw);
            //0-成功
            //2-应用未安装
            //5-指定的Token在当前Android终端用户下不存在
            //6-通知栏消息不展示
            //10-非活跃设备消息,设备为非活跃设备（终端设备未接入网络达30天），消息不进行下发。
            //15-离线用户消息覆盖
            //27-在终端设备上目标应用进程不存在导致透传消息被缓存
            //102-消息频控丢弃
            //144-profileId不存在
            //201-消息发送管控
            int status = statuse.getInteger("status");
            if (status == 0) {
                logger.debug("华为消息回执-推送成功：bigTag-{}  token-{}", bigTag, token);
            } else {
                logger.debug("华为消息回执-推送失败：bigTag-{}  token-{} status-{}", bigTag, token, status);
                if (status == 2 || status == 5 || status == 10) {
                    //删除无效设备
                   rabbitmqManager.addInvalidDevieToken(new InvalidDeviceTokenInfo(appCode, PushPlatform.hw, token));
                }
            }
        }


        JSONObject data = new JSONObject();
        data.put("code", 0);
        data.put("message", "success");
        return data.toJSONString();
    }


    //回执消息的格式：https://dev.mi.com/console/doc/detail?pId=1278#_3_6
    @ResponseBody
    @RequestMapping("xm")
    public String xm(HttpServletRequest request) {
        String content = WXUtil.getContent(request);
        logger.debug("小米消息回执-{}", content);
        JSONObject json = JSONObject.parseObject(content);

        for (String msgId : json.keySet()) {
            JSONObject data = json.getJSONObject(msgId);
            String appId = data.getString("param");
            String appCode = bPushPlatformAppInfoManager.selectAppCode(appId, PushPlatform.xm);
            int type = data.getInteger("type");
            switch (type) {
                //送达
                case 1:
                    break;
                //点击
                case 2:
                    break;
                //无法找到目标设备
                case 16:
                    String regIdStr = data.getString("targets");
                    String[] regIds = regIdStr.split(",");
                    for (String rid : regIds) {
                        //删除无效设备
                        rabbitmqManager.addInvalidDevieToken(new InvalidDeviceTokenInfo(appCode, PushPlatform.xm, rid));
                    }
                    break;
            }
        }


        JSONObject data = new JSONObject();
        data.put("code", 0);
        data.put("message", "success");
        return "";
    }


    @ResponseBody
    @RequestMapping("oppo")
    public String oppo(HttpServletRequest request) {
        String content = WXUtil.getContent(request);
        logger.debug("oppo消息回执-{}", content);
        JSONObject data = new JSONObject();
        data.put("code", 0);
        data.put("message", "success");
        return "";
    }

}