|
@@ -59,10 +59,15 @@ namespace WingCloudServer.Plugin
|
|
|
var dataLength = (int)context.GetRequestContentLength();
|
|
|
var requests = JsonRpcCodec.DecodeRequestsAsync(requestData, new System.Threading.CancellationToken(), dataLength).Result;
|
|
|
var apiName = $"{context.GetRequestPath().Trim('/')}/{requests[0].Method.Trim('/')}";
|
|
|
- if(apiName == "IPaymentService/PayNotify")
|
|
|
+ if (apiName == "IPaymentService/AlipayNotify")
|
|
|
{
|
|
|
var contentStr = GetInputStreamValue(requestData);
|
|
|
- _paymentService.PayCallbackAsync(contentStr);
|
|
|
+ _paymentService.PayCallbackAsync("Alipay", contentStr);
|
|
|
+ }
|
|
|
+ if (apiName == "IPaymentService/WeChatPayNotify")
|
|
|
+ {
|
|
|
+ var contentStr = GetInputStreamValue(requestData);
|
|
|
+ _paymentService.PayCallbackAsync("WeChat", contentStr);
|
|
|
}
|
|
|
return new PluginProcessResult(requestData, false);
|
|
|
}
|
|
@@ -84,7 +89,7 @@ namespace WingCloudServer.Plugin
|
|
|
/// <returns></returns>
|
|
|
private string GetInputStreamValue(byte[] data)
|
|
|
{
|
|
|
- using(StreamReader sr = new StreamReader(new MemoryStream(data)))
|
|
|
+ using (StreamReader sr = new StreamReader(new MemoryStream(data)))
|
|
|
{
|
|
|
return sr.ReadToEnd();
|
|
|
}
|