package com.nuvole.util;

import cn.hutool.http.HttpRequest;
import cn.hutool.http.HttpResponse;
import com.alibaba.fastjson.JSONObject;
import com.nuvole.hnnx.hnnxPay.NXHttpClientUtils;
import com.nuvole.hnnx.hnnxPay.SignatureSigner;
import com.nuvole.util.enums.LaPushEnum;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang.StringUtils;

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

/**
 * @ClassName LaBaPushUtil
 * @Author cy
 * @Date 2023/12/7
 * @Description
 * @Version 1.0
 **/
@Slf4j
public class LaBaPushUtil {
    private static final String DEVICE_ID = "202312080001";

    private static String ACCESSKEYSECRET = "AtR4g5sa24fdy6GII3hts75_CSYH";
    private static String accessKeyId = "IOT_ACCOUNT_TEST_CSYH";

    private static SignatureSigner signable = new SignatureSigner();
    //生产环境
    private static String scUrl = "https://voice.tysmartpos.com/api/bank/pushmsg";
    //测试环境
    private static String csUrl = "https://voicetest.tysmartpos.com/api/bank/pushmsg";

//    public static void main(String[] args) {
//        String deviceId = "202312080001";
////        String 010859416327 = "202312080001";
////        push(deviceId, LaPushEnum.YINHANG, 111);
//        pushMessageToSingle(deviceId, LaPushEnum.ZFB, 222);
//////        push(deviceId, LaPushEnum.WX, 333);
//        pushMessageToSingle(deviceId, LaPushEnum.CANCLE, 444);
//    }

    public static void pushMessageToSingle(String deviceId, LaPushEnum pushType, long money) {
        if (StringUtils.isEmpty(deviceId)){
            return;
        }
        Map<String, String> parameters = new HashMap<>();
        parameters.put("accessKeyId", accessKeyId);
        parameters.put("requestId", String.valueOf(System.currentTimeMillis()));
        //请求时间戳，格式如：1593532800000
        parameters.put("timestamp", String.valueOf(System.currentTimeMillis()));
        //设备编号
        parameters.put("deviceId", deviceId);

        String moneyYuan = NXHttpClientUtils.convertToYuan(money).toString();
        parameters.put("content", pushType.getName() + moneyYuan + "元");
        String signStr = signable.laBaSign(parameters, ACCESSKEYSECRET);
        parameters.put("sign", signStr);
        String jsonBody = JSONObject.toJSONString(parameters);

        String result = null;
        log.info("天喻云音响请求参数：{}", jsonBody);
        HttpResponse response = HttpRequest.post(csUrl)
                .contentType("application/json")
                .body(jsonBody)
                .execute();
        // 获取响应结果
        result = response.body();
        log.info("天喻云音响推送返回值：{}", result);
        return;
    }

    public static void pushMessageToList(LaPushEnum pushType, long money, List<String> deviceIdList) {
        Map<String, String> parameters = new HashMap<>();
        parameters.put("accessKeyId", accessKeyId);
        parameters.put("requestId", String.valueOf(System.currentTimeMillis()));
        //请求时间戳，格式如：1593532800000
        parameters.put("timestamp", String.valueOf(System.currentTimeMillis()));
        String moneyYuan = NXHttpClientUtils.convertToYuan(money).toString();
        parameters.put("content", pushType.getName() + moneyYuan + "元");

        deviceIdList.forEach(deviceId -> {
            //设备编号
            parameters.put("deviceId", deviceId);
            String signStr = signable.laBaSign(parameters, ACCESSKEYSECRET);
            parameters.put("sign", signStr);
            String jsonBody = JSONObject.toJSONString(parameters);

            String result = null;
            log.info("天域喇叭推送请求参数：{}", jsonBody);
            HttpResponse response = HttpRequest.post(csUrl)
                    .contentType("application/json")
                    .body(jsonBody)
                    .execute();
            // 获取响应结果
            result = response.body();
            log.info("天域喇叭推送返回值：{}", result);
        });
        return;
    }

}