java/QingDuTicket.git

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.dto.VisitPerson;
import com.ruoyi.system.vo.CreateOrderVo;
import com.ruoyi.system.vo.TicketListVo;
 
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.*;
 
/**
 * 门票接口
 */
public class TicketUtil {
 
    /**
     * 获取门票列表
     * @return
     * @throws Exception
     */
    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;
    }
 
 
    /**
     * 创建订单
     * @param request
     * @return
     * @throws Exception
     */
    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).getJSONObject("responseHead").getString("res_code");
                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).getJSONObject("responseHead").getString("res_msg");
                    System.out.println("错误信息: " + res_msg);
                    throw new RuntimeException(res_msg);
                }
            } catch (IllegalArgumentException e) {
                System.out.println("响应不是有效的Base64格式: " + e.getMessage());
            }
        }
 
        return null;
    }
 
 
 
 
    /**
     * 支付订单
     * @param
     * @return
     * @throws Exception
     */
    public  String payOrder(String orderId,String partnerOrderId) throws Exception {
        String userId = "1d9a42e0-9de3-451b-9964-4e9f8e62b101";
        String method = "payOrder";
        String timestamp = System.currentTimeMillis() + "";
        String desKey = "TFD9BEOK";  // DES密钥必须是8字节
        String userKey = "TFD9BEOK";  // 用于签名的用户密钥
 
        // 1. 构建请求体数据
        HashMap<String, Object> bodyData = new HashMap<>();
        bodyData.put("orderId", orderId);
        bodyData.put("partnerOrderId", partnerOrderId);
 
        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/payOrder");
 
        // 设置请求头
        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).getJSONObject("responseHead").getString("res_code");
                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);
                    String visitPersons = jsonObject.getJSONArray("visitPersons").toString();
                    return visitPersons;
                }else {
                    String res_msg = JSONObject.parseObject(decodedResponse).getJSONObject("responseHead").getString("res_msg");
                    System.out.println("错误信息: " + res_msg);
                    throw new RuntimeException(res_msg);
                }
            } catch (IllegalArgumentException e) {
                System.out.println("响应不是有效的Base64格式: " + e.getMessage());
            }
        }
 
        return null;
    }
 
    /**
     *  取消订单
     * @param
     * @return
     * @throws Exception
     */
    public  Boolean cannelTicket(String orderId,String partnerOrderId,List<String> refundDetailIds) throws Exception {
        String userId = "1d9a42e0-9de3-451b-9964-4e9f8e62b101";
        String method = "cannelTicket";
        String timestamp = System.currentTimeMillis() + "";
        String desKey = "TFD9BEOK";  // DES密钥必须是8字节
        String userKey = "TFD9BEOK";  // 用于签名的用户密钥
 
        // 1. 构建请求体数据
        HashMap<String, Object> bodyData = new HashMap<>();
        bodyData.put("orderId", orderId);
        bodyData.put("partnerOrderId", partnerOrderId);
        bodyData.put("refundDetailIds", refundDetailIds);
 
        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/cannelTicket");
 
        // 设置请求头
        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).getJSONObject("responseHead").getString("res_code");
                if("1000".equals(res_code)){
                    return true;
                }else {
                    String res_msg = JSONObject.parseObject(decodedResponse).getJSONObject("responseHead").getString("res_msg");
                    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 {
            System.out.println(LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss")));
//            CreateOrderRequest createOrderRequest = new CreateOrderRequest();
//            createOrderRequest.setOrderId("20231025110000000000000000000001");
//            createOrderRequest.setTravelDate("2026-03-11");
//            createOrderRequest.setQuantity(1);
//            createOrderRequest.setProductId("HXY19051010090001");
//            List<VisitPerson> visitPersons = new ArrayList<>();
//            VisitPerson visitPerson = new VisitPerson();
//            visitPerson.setIdCard("511028200002150815");
//            visitPersons.add(visitPerson);
//            createOrderRequest.setVisitPersons(visitPersons);
//            TicketUtil ticketUtil = new TicketUtil();
//            CreateOrderVo createOrderVo = ticketUtil.saveOrder(createOrderRequest);
//            System.out.println(createOrderVo);
//
//
//            String payOrder = ticketUtil.payOrder(createOrderVo.getOrderId(), createOrderVo.getPartnerOrderId());
//            System.out.println(payOrder);
//            List<String> list =new ArrayList<>();
//                    JSONArray jsonArray = JSONArray.parseArray(payOrder);
//            for (int i = 0; i < jsonArray.size(); i++) {
//                JSONObject jsonObject = jsonArray.getJSONObject(i);
//                String ticketId = jsonObject.getString("ticketId");
//                list.add(ticketId);
//            }
//
//            Boolean b = ticketUtil.cannelTicket(createOrderVo.getOrderId(), createOrderVo.getPartnerOrderId(), list);
//            System.out.println(b);
 
        } catch (Exception e) {
            throw new RuntimeException(e);
        }
    }
}