package wx.wechat.service.pay;
import com.alibaba.fastjson.JSONObject;
import com.squareup.okhttp.OkHttpClient;
import com.squareup.okhttp.Request;
import com.squareup.okhttp.Response;
import lombok.SneakyThrows;
import org.dom4j.Document;
import org.dom4j.DocumentHelper;
import org.dom4j.Element;
import wx.wechat.service.WXService;
import java.util.HashMap;
import java.util.Map;
/**
* Created by apple on 16/6/12.
*/
/**
* @function 用于在购买商品之后进行回调
*/
public class PayedOrderService extends WXService {
/**
* @param xml
* @return
* @function 解析获取到的XML信息
* @Test "\n" +
* "\n" +
* "\n" +
* "\n" +
* "\n" +
* "\n" +
* "\n" +
* "\n" +
* "\n" +
* "\n" +
* "\n" +
* "\n" +
* "\n" +
* "\n" +
* "1\n" +
* "\n" +
* "\n" +
* "\n";
*/
@SneakyThrows
public Map parseNotifyXML(String xml) {
Map result = new HashMap<>();
Document document = DocumentHelper.parseText(xml);
Element root = document.getRootElement();
//获取系统内订单编号,这里系统内的订单ID是放在attach内传入
result.put("attach", root.element("attach").getText());
//获取微信的订单编号
result.put("TransactionId", root.element("transaction_id").getText());
return result;
}
/**
* @param OrderId
* @param TradeChannel
* @param TradeType
* @param TransactionId
* @function 更新系统内的订单状态
*/
//
@SneakyThrows
public Map updateOrderState(String OrderId, String TradeChannel, String TradeType, String TransactionId) {
String url = "http://121.40.48.71:8092/api/UpdateOrderState?OrderId=" + OrderId + "&TradeChannel=1&TradeType=1&TransactionId=" + TransactionId;
//构建请求
Request request = new Request.Builder()
.url(url)
.get()
.build();
Map result = new HashMap<>();
//发起请求
Response response = new OkHttpClient().newCall(request).execute();
//解析获取的数据并且返回Map
JSONObject.parseObject(response.body().string()).forEach((k, v) -> {
result.put(k, String.valueOf(v));
});
return result;
}
}