package com.ruoyi.web.controller.yuncang.api.trade;


import com.alibaba.fastjson.JSONObject;
import com.ruoyi.web.controller.yuncang.utils.WdtClient;
import lombok.extern.slf4j.Slf4j;

import java.io.IOException;
import java.util.HashMap;
import java.util.Map;

@Slf4j
public class TradeQuery {

	/**
	 *
	 * 订单查询
	 * @param sid 	卖家账号，接口请求的公共参数sid
	 * @param appkey 	接口账号，接口请求的公共参数appkey
	 * @param appsecret 	接口秘钥，接口请求的参数appsecret ，用于计算签名
	 * @param url 	接口地址，接口请求的公共参数url
	 * @param trade_no 	订单编号
	 * @param start_time 	开始时间
	 * @param end_time 	结束时间 时间跨度不能超过60分钟
	 * @return
	 */
	public static JSONObject tradeQuery(String sid, String appkey, String appsecret, String url,
										String trade_no,String start_time,String end_time) {
		WdtClient client = new WdtClient(sid, appkey, appsecret, url);
		
		Map<String, String> params = new HashMap<String, String>();
		params.put("start_time", start_time);
		params.put("end_time", end_time);
		params.put("trade_no", trade_no);
//		params.put("page_size", "40");
//		params.put("page_no", "0");

		try {
			String response = client.execute("trade_query.php", params);
			log.info("订单查询结果：{}", response);
			JSONObject jsonObject = JSONObject.parseObject(response);
			if(jsonObject.getInteger("code") == 0){
				return jsonObject;
			}else{
				log.info("订单查询失败");
				throw new RuntimeException(jsonObject.getString("message"));
			}
		} catch (IOException e) {
			e.printStackTrace();
		}
		return null;
	}


	public static void main(String[] args) {
		WdtClient client = new WdtClient("apidevnew2", "hytycw02-test", "c7ae51196", "https://sandbox.wangdian.cn/openapi2/");
		Map<String, String> params = new HashMap<String, String>();
		params.put("start_time", "2025-12-11 12:00:00");
		params.put("end_time", "2025-12-11 13:00:00");
		params.put("page_size", "30");
		params.put("page_no", "0");

		try {
			String response = client.execute("trade_query.php", params);
			System.out.println(response);
		} catch (IOException e) {
			e.printStackTrace();
		}
	}

}