门票对接

liujie

2026-03-10 5171fcf8ccf77a670632e54d2c88642377bfc2ae

 ruoyi-system/src/main/java/com/ruoyi/system/utils/ticketUtil/TicketUtil.java

@@ -8,19 +8,24 @@
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.util.ArrayList;
import java.util.Base64;
import java.util.HashMap;
import java.util.List;
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";
@@ -123,6 +128,12 @@
    }


    /**
     * 创建订单
     * @param request
     * @return
     * @throws Exception
     */
    public  CreateOrderVo saveOrder(CreateOrderRequest request) throws Exception {
        String userId = "1d9a42e0-9de3-451b-9964-4e9f8e62b101";
        String method = "createOrder";
@@ -193,7 +204,7 @@
                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();
                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);
@@ -207,7 +218,7 @@
                    return createOrderVo;
                }else {

                    String res_msg = JSONObject.parseObject(decodedResponse).get("res_msg").toString();
                    String res_msg = JSONObject.parseObject(decodedResponse).getJSONObject("responseHead").getString("res_msg");
                    System.out.println("错误信息: " + res_msg);
                    throw new RuntimeException(res_msg);
                }
@@ -219,8 +230,231 @@
        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);
        }