package com.ruoyi.payment.infrastructure.channel.alipay;

import com.ruoyi.payment.infrastructure.config.AlipayConfig;
import lombok.extern.slf4j.Slf4j;
import org.apache.http.HttpEntity;
import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.entity.mime.MultipartEntityBuilder;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.util.EntityUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import java.math.BigDecimal;

/**
 * 支付宝第三方接口客户端
 * 调用旧系统的支付宝当面付接口
 * 
 * @author ruoyi
 */
@Slf4j
@Component
public class AlipayThirdPartyClient {

    @Autowired
    private AlipayConfig alipayConfig;
    /**
     * 第三方支付宝当面付接口地址
     */
//    private  String THIRD_PARTY_ALIPAY_URL = "https://sys.966120.com.cn/alipay_pay_QR_NotifyUrl.php";

    /**
     * 第三方支付宝查询接口地址
     */
    private static final String THIRD_PARTY_QUERY_URL = "https://sys.966120.com.cn/alipay_pay_query.php";

    /**
     * 调用第三方接口生成支付宝当面付URL
     * 
     * @param notifyUrl 异步回调通知地址
     * @param outTradeNo 商户订单号
     * @param totalFee 订单金额（单位：分）
     * @param serviceOrdId 业务订单ID
     * @return 支付宝当面付URL
     * @throws Exception 调用异常
     */
    public String createQrCodeUrl(String notifyUrl, String outTradeNo, Integer totalFee, String serviceOrdId) 
            throws Exception {
        log.info("调用第三方支付宝当面付接口，订单号: {}, 金额: {}分, 业务订单ID: {}", 
                outTradeNo, totalFee, serviceOrdId);

        try (CloseableHttpClient httpClient = HttpClients.createDefault()) {
            HttpPost httpPost = new HttpPost(this.alipayConfig.getThirdParty().getUrl());
            
            // 设置Cookie头
            httpPost.setHeader("Cookie", "CAMEName=");
            BigDecimal totalFeeYuan = BigDecimal.valueOf(totalFee / 100f);
            // 构建multipart/form-data请求体
            HttpEntity entity = MultipartEntityBuilder.create()
                    .addTextBody("notify_url", notifyUrl)
                    .addTextBody("out_trade_no", outTradeNo)
                    .addTextBody("total_fee", String.valueOf(totalFeeYuan))
                    .addTextBody("ServiceOrdID", serviceOrdId)
                    .build();
            
            httpPost.setEntity(entity);
            
            log.info("发送请求到第三方接口: {}", this.alipayConfig.getThirdParty().getUrl());
            
            // 发送请求
            try (CloseableHttpResponse response = httpClient.execute(httpPost)) {
                int statusCode = response.getStatusLine().getStatusCode();
                String responseBody = EntityUtils.toString(response.getEntity(), "UTF-8");
                
                log.info("第三方接口响应，状态码: {}, 响应内容: {}", statusCode, responseBody);
                
                if (statusCode >= 200 && statusCode < 300) {
                    // 响应成功，解析返回的URL
                    String qrCodeUrl = parseQrCodeUrl(responseBody);
                    
                    if (qrCodeUrl == null || qrCodeUrl.isEmpty()) {
                        throw new Exception("第三方接口未返回有效的支付URL，响应: " + responseBody);
                    }
                    
                    log.info("第三方支付宝当面付URL生成成功: {}", qrCodeUrl);
                    return qrCodeUrl;
                } else {
                    throw new Exception("第三方接口调用失败，状态码: " + statusCode + ", 响应: " + responseBody);
                }
            }
        } catch (Exception e) {
            log.error("调用第三方支付宝当面付接口失败", e);
            throw new Exception("调用第三方支付宝当面付接口失败: " + e.getMessage(), e);
        }
    }

    /**
     * 解析第三方接口响应，提取支付URL
     * 根据实际返回格式调整解析逻辑
     * 
     * @param responseBody 响应内容
     * @return 支付URL
     */
    private String parseQrCodeUrl(String responseBody) {
        // TODO: 根据实际返回格式调整解析逻辑
        // 这里假设直接返回URL字符串，或者返回JSON格式
        
        if (responseBody == null || responseBody.isEmpty()) {
            return null;
        }
        
        // 去除可能的引号和空白字符
        String url = responseBody.trim();
        if (url.startsWith("\"") && url.endsWith("\"")) {
            url = url.substring(1, url.length() - 1);
        }
        
        // 如果是JSON格式，可以使用FastJSON解析
        // 示例：{"status": "success", "qr_code": "https://..."}
        // JSONObject json = JSON.parseObject(responseBody);
        // return json.getString("qr_code");
        
        return url;
    }

    /**
     * 查询支付宝交易状态
     * 
     * @param outTradeNo 商户订单号
     * @return 交易状态（SUCCESS-成功，其他-失败或处理中）
     * @throws Exception 调用异常
     */
    public String queryTradeStatus(String outTradeNo) throws Exception {
        log.info("调用第三方支付宝查询接口，订单号: {}", outTradeNo);

        try (CloseableHttpClient httpClient = HttpClients.createDefault()) {
            HttpPost httpPost = new HttpPost(THIRD_PARTY_QUERY_URL);
            
            // 设置Cookie头
            httpPost.setHeader("Cookie", "CAMEName=");
            
            // 构建multipart/form-data请求体
            HttpEntity entity = MultipartEntityBuilder.create()
                    .addTextBody("out_trade_no", outTradeNo)
                    .build();
            
            httpPost.setEntity(entity);
            
            log.info("发送查询请求到第三方接口: {}", THIRD_PARTY_QUERY_URL);
            
            // 发送请求
            try (CloseableHttpResponse response = httpClient.execute(httpPost)) {
                int statusCode = response.getStatusLine().getStatusCode();
                String responseBody = EntityUtils.toString(response.getEntity(), "UTF-8");
                
                log.info("第三方查询接口响应，状态码: {}, 响应内容: {}", statusCode, responseBody);
                
                if (statusCode >= 200 && statusCode < 300) {
                    // 响应成功，解析交易状态
                    String tradeStatus = parseTradeStatus(responseBody);
                    
                    log.info("第三方支付宝交易查询成功，订单号: {}, 状态: {}", outTradeNo, tradeStatus);
                    return tradeStatus;
                } else {
                    throw new Exception("第三方查询接口调用失败，状态码: " + statusCode + ", 响应: " + responseBody);
                }
            }
        } catch (Exception e) {
            log.error("调用第三方支付宝查询接口失败", e);
            throw new Exception("调用第三方支付宝查询接口失败: " + e.getMessage(), e);
        }
    }

    /**
     * 解析交易状态
     * 
     * @param responseBody 响应内容
     * @return 交易状态
     */
    private String parseTradeStatus(String responseBody) {
        if (responseBody == null || responseBody.isEmpty()) {
            return "UNKNOWN";
        }
        
        // 去除空白字符
        String status = responseBody.trim();
        
        // 去除可能的引号
        if (status.startsWith("\"") && status.endsWith("\"")) {
            status = status.substring(1, status.length() - 1);
        }
        
        // 转换为大写
        status = status.toUpperCase();
        
        log.info("解析交易状态: {}", status);
        
        return status;
    }
}