package cn.lili.modules.goods.util;

import cn.hutool.json.JSONObject;
import cn.lili.common.enums.ClientTypeEnum;
import cn.lili.common.exception.ServiceException;
import cn.lili.common.utils.HttpUtils;
import cn.lili.modules.goods.entity.dos.Commodity;
import cn.lili.modules.goods.entity.dos.Studio;
import cn.lili.modules.goods.entity.dto.GoodsInfo;
import cn.lili.modules.wechat.util.WechatAccessTokenUtil;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.util.HashMap;
import java.util.List;
import java.util.Map;

/**
 * 微信小程序直播工具类
 *
 * @author Bulbasaur
 * @since 2021/5/17 10:16 上午
 */
@Slf4j
@Component
public class WechatLivePlayerUtil {

    @Autowired
    private WechatAccessTokenUtil wechatAccessTokenUtil;
    @Autowired
    private WechatMediaUtil wechatMediaUtil;

    /**
     * 创建小程序直播间
     *
     * @param studio 小程序直播
     * @return 房间ID
     */
    public Map<String, String> create(Studio studio) {
        //发送url
        String url = "https://api.weixin.qq.com/wxaapi/broadcast/room/create?access_token=";
        //添加直播间
        Map<String, String> map = this.mockRoom(studio);
        JSONObject json = this.doPostWithJson(url, map);
        Map<String, String> roomMap = new HashMap<>(2);
        roomMap.put("roomId", json.getStr("roomId"));
        roomMap.put("qrcodeUrl", json.getStr("qrcode_url"));
        return roomMap;
    }

    /**
     * 创建小程序直播间
     *
     * @param studio 小程序直播
     * @return 房间ID
     */
    public boolean editRoom(Studio studio) {
        //发送url
        String url = "https://api.weixin.qq.com/wxaapi/broadcast/room/editroom?access_token=";

        //修改直播间
        Map<String, String> map = this.mockRoom(studio);
        map.put("id", studio.getRoomId().toString());
        this.doPostWithJson(url, map);
        return true;
    }


    /**
     * 获取直播间回放
     *
     * @param roomId 房间ID
     * @return 回放地址
     */
    public String getLiveInfo(Integer roomId) {
        //发送url
        String url = "https://api.weixin.qq.com/wxa/business/getliveinfo?access_token=";
        Map<String, Object> map = new HashMap<>(16);
        //获取回放
        map.put("action", "get_replay");
        //直播间ID
        map.put("room_id", roomId);
        //起始拉取视频，0表示从第一个视频片段开始拉取
        map.put("start", "0");
        //每次拉取的数量，建议100以内
        map.put("limit", "1");
        JSONObject json = this.doPostWithJson(url, map);
        //TODO get media_url
        return json.getStr("live_replay");
    }

    /**
     * 推送直播间商品
     *
     * @param roomId  房间ID
     * @param goodsId 商品ID
     * @return 操作结果
     */
    public Boolean pushGoods(Integer roomId, Integer goodsId) {
        //发送url
        String url = "https://api.weixin.qq.com/wxaapi/broadcast/room/addgoods?access_token=";
        Map<String, Object> map = new HashMap<>(16);
        //直播间回放
        Integer[] ids = {goodsId};
        map.put("ids", ids);
        //商品ID
        map.put("roomId", roomId);
        this.doPostWithJson(url, map);
        return true;
    }

    /**
     * 删除直播间商品
     *
     * @param roomId  房间ID
     * @param goodsId 商品ID
     * @return 操作结果
     */
    public Boolean goodsDeleteInRoom(Integer roomId, Integer goodsId) {
        //发送url
        String url = "https://api.weixin.qq.com/wxaapi/broadcast/goods/deleteInRoom?access_token=";
        Map<String, Integer> map = new HashMap<>(2);
        //直播间回放
        map.put("goodsId", goodsId);
        //商品ID
        map.put("roomId", roomId);
        this.doPostWithJson(url, map);
        return true;

    }

    /**
     * 添加直播商品
     *
     * @param commodity 直播商品
     * @return 添加结果
     */
    public JSONObject addGoods(Commodity commodity) {
        //发送url
        String url = "https://api.weixin.qq.com/wxaapi/broadcast/goods/add?access_token=";

        //商品名称，最长14个汉字
        if (commodity.getName().length() > 14) {
            commodity.setName(commodity.getName().substring(0, 13));
        }

        //新建微信商品DTO
        GoodsInfo goodsInfo = new GoodsInfo(commodity);
        //上传微信临时图片
        goodsInfo.setCoverImgUrl(wechatMediaUtil.uploadMedia("image", commodity.getGoodsImage()));
        Map<String, GoodsInfo> map = new HashMap<>(2);
        //调用新增直播商品接口
        map.put("goodsInfo", goodsInfo);
        return this.doPostWithJson(url, map);
    }

    /**
     * 删除直播商品
     *
     * @param goodsId 商品ID
     * @return 删除结果
     */
    public JSONObject deleteGoods(String goodsId) {
        //发送url
        String url = "https://api.weixin.qq.com/wxaapi/broadcast/goods/delete?access_token=";
        Map<String, Object> map = new HashMap<>(2);
        map.put("goodsId", goodsId);
        return this.doPostWithJson(url, map);
    }

    /**
     * 查询直播商品状态
     *
     * @param goodsIdList 商品ID列表
     * @return 删除结果
     */
    public JSONObject getGoodsWareHouse(List<String> goodsIdList) {
        //发送url
        String url = "https://api.weixin.qq.com/wxa/business/getgoodswarehouse?access_token=";
        Map<String, Object> map = new HashMap<>(2);
        map.put("goods_ids", goodsIdList);
        return this.doPostWithJson(url, map);
    }

    /**
     * 请求微信接口
     *
     * @param url 链接
     * @param map 参数
     * @return 返回内容
     */
    private JSONObject doPostWithJson(String url, Map map) {
        //获取token
        String token = wechatAccessTokenUtil.cgiAccessToken(ClientTypeEnum.WECHAT_MP);
        //请求链接添加token
        url += token;
        //发起请求
        String content = HttpUtils.doPostWithJson(url, map);
        //记录请求结果
        log.info("微信小程序请求结果：" + content);
        //获取请求内容，如果token过期则重新获取，如果出错则抛出错误
        JSONObject jsonObject = new JSONObject(content);
        if (("0").equals(jsonObject.get("errcode").toString())) {
            return jsonObject;
        } else if (("40001").equals(jsonObject.get("errcode"))) {
            wechatAccessTokenUtil.removeAccessToken(ClientTypeEnum.WECHAT_MP);
            return this.doPostWithJson(url, map);
        } else {
            throw new ServiceException(jsonObject.get("errmsg").toString());
        }
    }

    private Map<String, String> mockRoom(Studio studio) {
        Map<String, String> map = new HashMap<>(16);
        //背景图
        map.put("coverImg", wechatMediaUtil.uploadMedia("image", studio.getCoverImg()));
        //分享图
        map.put("shareImg", wechatMediaUtil.uploadMedia("image", studio.getShareImg()));
        //购物直播频道封面图
        map.put("feedsImg", wechatMediaUtil.uploadMedia("image", studio.getFeedsImg()));
        //直播间名字
        map.put("name", studio.getName());
        //直播计划开始时间
        map.put("startTime", studio.getStartTime());
        //直播计划结束时间
        map.put("endTime", studio.getEndTime());
        //主播昵称
        map.put("anchorName", studio.getAnchorName());
        //主播微信号
        map.put("anchorWechat", studio.getAnchorWechat());
        //直播间类型
        map.put("type", "0");
        //是否关闭点赞
        map.put("closeLike", "0");
        //是否关闭货架
        map.put("closeGoods", "0");
        //是否关闭评论
        map.put("closeComment", "0");
        //直播间名字
        map.put("closeReplay", "0");

        return map;
    }
}