package com.ruoyi.system.utils.ticketUtil;

import cn.hutool.crypto.SecureUtil;
import cn.hutool.http.HttpRequest;
import cn.hutool.http.HttpResponse;
import cn.hutool.http.HttpUtil;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.ruoyi.system.dto.CreateOrderRequest;
import com.ruoyi.system.vo.CreateOrderVo;
import com.ruoyi.system.vo.TicketListVo;

import java.util.ArrayList;
import java.util.Base64;
import java.util.HashMap;
import java.util.List;

/**
 * 门票接口
 */
public class TicketUtil {

    public List<TicketListVo> getTicketList() throws Exception {
        ArrayList<TicketListVo> ticketListVos = new ArrayList<>();
        String userId = "1d9a42e0-9de3-451b-9964-4e9f8e62b101";
        String method = "getProductInfo";
        String timestamp = System.currentTimeMillis() + "";
        String desKey = "TFD9BEOK";  // DES密钥必须是8字节
        String userKey = "TFD9BEOK";  // 用于签名的用户密钥

        // 1. 构建请求体数据
        HashMap<String, Object> bodyData = new HashMap<>();
        bodyData.put("pageIndex", 1);
        bodyData.put("pageSize", 100);
        bodyData.put("sceneryNo", "");

        String requestBody = JSON.toJSONString(bodyData);
        System.out.println("原始请求体: " + requestBody);

        // 2. 使用DES加密请求体
        String encryptedBody = DesUtil.encrypt(requestBody, desKey);
        System.out.println("DES加密后的请求体: " + encryptedBody);

        // 3. 生成签名
        String params = userId + method + timestamp + encryptedBody + userKey;
        String md5 = SecureUtil.md5(params);
        System.out.println("MD5签名: " + md5);

        // 4. 构建请求头
        HashMap<String, Object> headMap = new HashMap<>();
        headMap.put("user_id", userId);
        headMap.put("method", method);
        headMap.put("timestamp", timestamp);
        headMap.put("sign", md5);

        // 5. 构建完整的请求消息
        HashMap<String, Object> fullRequestMap = new HashMap<>();
        fullRequestMap.put("requestHead", headMap);
        fullRequestMap.put("requestBody", encryptedBody);

        // 6. 将完整消息转换为JSON字符串
        String fullRequestJson = JSON.toJSONString(fullRequestMap);
        System.out.println("完整请求JSON: " + fullRequestJson);

        // 7. 对整个JSON字符串进行Base64编码
        String base64EncodedRequest = Base64.getEncoder().encodeToString(fullRequestJson.getBytes("UTF-8"));
        System.out.println("Base64编码后的请求: " + base64EncodedRequest);

        // 8. 发送HTTP请求
        HttpRequest post = HttpUtil.createPost("http://ota.huilvyun.com.cn:8086/scenic-ota/ota/v2/zshl/rent034/getProductInfo");

        // 设置请求头
        post.header("Content-Type", "text/plain;charset=UTF-8");  // 根据要求，可能是纯文本
        // 或者如果是application/json，则使用：
        // post.header("Content-Type", "application/json;charset=UTF-8");

        // 直接将Base64编码后的字符串作为body发送
        post.body(base64EncodedRequest);

        System.out.println("发送请求...");
        HttpResponse execute = post.execute();

        // 9. 处理响应
        System.out.println("响应状态码: " + execute.getStatus());
        String responseBody = execute.body();
        System.out.println("原始响应Body: " + responseBody);

        // 10. 解析响应（假设响应也是Base64编码的）
        if (responseBody != null && !responseBody.isEmpty()) {
            try {
                // 先Base64解码
                byte[] decodedBytes = Base64.getDecoder().decode(responseBody);
                String decodedResponse = new String(decodedBytes, "UTF-8");
                System.out.println("Base64解码后的响应: " + decodedResponse);

                String responseBody1 = JSONObject.parseObject(decodedResponse).get("responseBody").toString();
                String decryptedResponseBody = DesUtil.decrypt(responseBody1, desKey);
                System.out.println("解密后的响应: " + decryptedResponseBody);
                JSONArray productList = JSONObject.parseObject(decryptedResponseBody).getJSONArray("productList");


                for (int i = 0; i < productList.size(); i++) {
                    JSONObject product = productList.getJSONObject(i);
                    TicketListVo ticketListVo = new TicketListVo();
                    ticketListVo.setProductId(product.getString("productId"));
                    ticketListVo.setProductName(product.getString("productName"));
                    ticketListVo.setPrice(product.getLong("price"));
                    ticketListVo.setSceneryNo(product.getString("sceneryNo"));
                    ticketListVo.setSceneryName(product.getString("sceneryName"));
                    ticketListVo.setBeginSaleDate(product.getString("beginSaleDate"));
                    ticketListVo.setEndSaleDate(product.getString("endSaleDate"));
                    ticketListVo.setIsCanRefund(product.getInteger("isCanRefund"));
                    ticketListVos.add(ticketListVo);
                }
                return ticketListVos;

            } catch (IllegalArgumentException e) {
                System.out.println("响应不是有效的Base64格式: " + e.getMessage());
            }
        }
        return ticketListVos;
    }


    public  CreateOrderVo saveOrder(CreateOrderRequest request) throws Exception {
        String userId = "1d9a42e0-9de3-451b-9964-4e9f8e62b101";
        String method = "createOrder";
        String timestamp = System.currentTimeMillis() + "";
        String desKey = "TFD9BEOK";  // DES密钥必须是8字节
        String userKey = "TFD9BEOK";  // 用于签名的用户密钥

        // 1. 构建请求体数据
//        HashMap<String, Object> bodyData = new HashMap<>();
//        bodyData.put("pageIndex", 1);
//        bodyData.put("pageSize", 100);
//        bodyData.put("sceneryNo", "");

        String requestBody = JSON.toJSONString(request);
        System.out.println("原始请求体: " + requestBody);

        // 2. 使用DES加密请求体
        String encryptedBody = DesUtil.encrypt(requestBody, desKey);
        System.out.println("DES加密后的请求体: " + encryptedBody);

        // 3. 生成签名
        String params = userId + method + timestamp + encryptedBody + userKey;
        String md5 = SecureUtil.md5(params);
        System.out.println("MD5签名: " + md5);

        // 4. 构建请求头
        HashMap<String, Object> headMap = new HashMap<>();
        headMap.put("user_id", userId);
        headMap.put("method", method);
        headMap.put("timestamp", timestamp);
        headMap.put("sign", md5);

        // 5. 构建完整的请求消息
        HashMap<String, Object> fullRequestMap = new HashMap<>();
        fullRequestMap.put("requestHead", headMap);
        fullRequestMap.put("requestBody", encryptedBody);

        // 6. 将完整消息转换为JSON字符串
        String fullRequestJson = JSON.toJSONString(fullRequestMap);
        System.out.println("完整请求JSON: " + fullRequestJson);

        // 7. 对整个JSON字符串进行Base64编码
        String base64EncodedRequest = Base64.getEncoder().encodeToString(fullRequestJson.getBytes("UTF-8"));
        System.out.println("Base64编码后的请求: " + base64EncodedRequest);

        // 8. 发送HTTP请求
        HttpRequest post = HttpUtil.createPost("http://ota.huilvyun.com.cn:8086/scenic-ota/ota/v2/zshl/rent034/createOrder");

        // 设置请求头
        post.header("Content-Type", "text/plain;charset=UTF-8");  // 根据要求，可能是纯文本
        // 或者如果是application/json，则使用：
        // post.header("Content-Type", "application/json;charset=UTF-8");

        // 直接将Base64编码后的字符串作为body发送
        post.body(base64EncodedRequest);

        System.out.println("发送请求...");
        HttpResponse execute = post.execute();

        // 9. 处理响应
        System.out.println("响应状态码: " + execute.getStatus());
        String responseBody = execute.body();
        System.out.println("原始响应Body: " + responseBody);
        // 10. 解析响应（假设响应也是Base64编码的）
        if (responseBody != null && !responseBody.isEmpty()) {
            try {
                // 先Base64解码
                byte[] decodedBytes = Base64.getDecoder().decode(responseBody);
                String decodedResponse = new String(decodedBytes, "UTF-8");
                System.out.println("Base64解码后的响应: " + decodedResponse);
                String res_code = JSONObject.parseObject(decodedResponse).get("res_code").toString();
                if("1000".equals(res_code)){
                    String responseBody1 = JSONObject.parseObject(decodedResponse).get("responseBody").toString();
                    String decryptedResponseBody = DesUtil.decrypt(responseBody1, desKey);
                    System.out.println("解密后的响应: " + decryptedResponseBody);
                    JSONObject jsonObject = JSONObject.parseObject(decryptedResponseBody);

                    CreateOrderVo createOrderVo = new CreateOrderVo();
                    createOrderVo.setOrderId(jsonObject.getString("orderId"));
                    createOrderVo.setOrderAmount(jsonObject.getString("orderAmount"));
                    createOrderVo.setPartnerOrderId(jsonObject.getString("partnerOrderId"));
                    return createOrderVo;
                }else {

                    String res_msg = JSONObject.parseObject(decodedResponse).get("res_msg").toString();
                    System.out.println("错误信息: " + res_msg);
                    throw new RuntimeException(res_msg);
                }
            } catch (IllegalArgumentException e) {
                System.out.println("响应不是有效的Base64格式: " + e.getMessage());
            }
        }

        return null;
    }

    public static void main(String[] args) {
        try {
        } catch (Exception e) {
            throw new RuntimeException(e);
        }
    }
}