AlipayNotifyController.cs 8.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218
  1. using System;
  2. using System.Threading.Tasks;
  3. using Essensoft.AspNetCore.Payment.Alipay;
  4. using Essensoft.AspNetCore.Payment.Alipay.Notify;
  5. using Microsoft.AspNetCore.Mvc;
  6. using Microsoft.Extensions.Options;
  7. namespace WebApplicationSample.Controllers
  8. {
  9. [Route("alipay/notify")]
  10. public class AlipayNotifyController : Controller
  11. {
  12. private readonly IAlipayNotifyClient _client;
  13. private readonly IOptions<AlipayOptions> _optionsAccessor;
  14. public AlipayNotifyController(IAlipayNotifyClient client, IOptions<AlipayOptions> optionsAccessor)
  15. {
  16. _client = client;
  17. _optionsAccessor = optionsAccessor;
  18. }
  19. /// <summary>
  20. /// 应用网关
  21. /// </summary>
  22. /// <returns></returns>
  23. [Route("gateway")]
  24. [HttpPost]
  25. public async Task<IActionResult> Gateway()
  26. {
  27. try
  28. {
  29. var msg_method = Request.Form["msg_method"].ToString();
  30. switch (msg_method)
  31. {
  32. // 资金单据状态变更通知
  33. case "alipay.fund.trans.order.changed":
  34. {
  35. var notify = await _client.CertificateExecuteAsync<AlipayFundTransOrderChangedNotify>(Request, _optionsAccessor.Value);
  36. return AlipayNotifyResult.Success;
  37. }
  38. // 第三方应用授权取消消息
  39. case "alipay.open.auth.appauth.cancelled":
  40. {
  41. var notify = await _client.CertificateExecuteAsync<AlipayOpenAuthAppauthCancelledNotify>(Request, _optionsAccessor.Value);
  42. return AlipayNotifyResult.Success;
  43. }
  44. // 用户授权取消消息
  45. case "alipay.open.auth.userauth.cancelled":
  46. {
  47. var notify = await _client.CertificateExecuteAsync<AlipayOpenAuthUserauthCancelledNotify>(Request, _optionsAccessor.Value);
  48. return AlipayNotifyResult.Success;
  49. }
  50. // 小程序审核通过通知
  51. case "alipay.open.mini.version.audit.passed":
  52. {
  53. var notify = await _client.CertificateExecuteAsync<AlipayOpenMiniVersionAuditPassedNotify>(Request, _optionsAccessor.Value);
  54. return AlipayNotifyResult.Success;
  55. }
  56. // 用户授权取消消息
  57. case "alipay.open.mini.version.audit.rejected":
  58. {
  59. var notify = await _client.CertificateExecuteAsync<AlipayOpenMiniVersionAuditRejectedNotify>(Request, _optionsAccessor.Value);
  60. return AlipayNotifyResult.Success;
  61. }
  62. // 收单资金结算到银行账户,结算退票的异步通知
  63. case "alipay.trade.settle.dishonoured":
  64. {
  65. var notify = await _client.CertificateExecuteAsync<AlipayTradeSettleDishonouredNotify>(Request, _optionsAccessor.Value);
  66. return AlipayNotifyResult.Success;
  67. }
  68. // 收单资金结算到银行账户,结算失败的异步通知
  69. case "alipay.trade.settle.fail":
  70. {
  71. var notify = await _client.CertificateExecuteAsync<AlipayTradeSettleFailNotify>(Request, _optionsAccessor.Value);
  72. return AlipayNotifyResult.Success;
  73. }
  74. // 收单资金结算到银行账户,结算成功的异步通知
  75. case "alipay.trade.settle.success":
  76. {
  77. var notify = await _client.CertificateExecuteAsync<AlipayTradeSettleSuccessNotify>(Request, _optionsAccessor.Value);
  78. return AlipayNotifyResult.Success;
  79. }
  80. default:
  81. return AlipayNotifyResult.Failure;
  82. }
  83. }
  84. catch
  85. {
  86. return AlipayNotifyResult.Failure;
  87. }
  88. }
  89. /// <summary>
  90. /// 扫码支付异步通知
  91. /// </summary>
  92. [Route("precreate")]
  93. [HttpPost]
  94. public async Task<IActionResult> Precreate()
  95. {
  96. try
  97. {
  98. var notify = await _client.CertificateExecuteAsync<AlipayTradePrecreateNotify>(Request, _optionsAccessor.Value);
  99. if (notify.TradeStatus == AlipayTradeStatus.Success)
  100. {
  101. Console.WriteLine("OutTradeNo: " + notify.OutTradeNo);
  102. return AlipayNotifyResult.Success;
  103. }
  104. return AlipayNotifyResult.Failure;
  105. }
  106. catch
  107. {
  108. return AlipayNotifyResult.Failure;
  109. }
  110. }
  111. /// <summary>
  112. /// APP支付异步通知
  113. /// </summary>
  114. [Route("apppay")]
  115. [HttpPost]
  116. public async Task<IActionResult> AppPay()
  117. {
  118. try
  119. {
  120. var notify = await _client.CertificateExecuteAsync<AlipayTradeAppPayNotify>(Request, _optionsAccessor.Value);
  121. if (notify.TradeStatus == AlipayTradeStatus.Success)
  122. {
  123. Console.WriteLine("OutTradeNo: " + notify.OutTradeNo);
  124. return AlipayNotifyResult.Success;
  125. }
  126. return AlipayNotifyResult.Failure;
  127. }
  128. catch
  129. {
  130. return AlipayNotifyResult.Failure;
  131. }
  132. }
  133. /// <summary>
  134. /// 电脑网站支付异步通知
  135. /// </summary>
  136. [Route("pagepay")]
  137. [HttpPost]
  138. public async Task<IActionResult> PagePay()
  139. {
  140. try
  141. {
  142. var notify = await _client.CertificateExecuteAsync<AlipayTradePagePayNotify>(Request, _optionsAccessor.Value);
  143. if (notify.TradeStatus == AlipayTradeStatus.Success)
  144. {
  145. Console.WriteLine("OutTradeNo: " + notify.OutTradeNo);
  146. return AlipayNotifyResult.Success;
  147. }
  148. return AlipayNotifyResult.Failure;
  149. }
  150. catch
  151. {
  152. return AlipayNotifyResult.Failure;
  153. }
  154. }
  155. /// <summary>
  156. /// 手机网站支付异步通知
  157. /// </summary>
  158. [Route("wappay")]
  159. [HttpPost]
  160. public async Task<IActionResult> WapPay()
  161. {
  162. try
  163. {
  164. var notify = await _client.CertificateExecuteAsync<AlipayTradeWapPayNotify>(Request, _optionsAccessor.Value);
  165. if (notify.TradeStatus == AlipayTradeStatus.Success)
  166. {
  167. Console.WriteLine("OutTradeNo: " + notify.OutTradeNo);
  168. return AlipayNotifyResult.Success;
  169. }
  170. return AlipayNotifyResult.Failure;
  171. }
  172. catch
  173. {
  174. return AlipayNotifyResult.Failure;
  175. }
  176. }
  177. /// <summary>
  178. /// 交易关闭异步通知
  179. /// </summary>
  180. [Route("close")]
  181. [HttpPost]
  182. public async Task<IActionResult> Close()
  183. {
  184. try
  185. {
  186. var notify = await _client.CertificateExecuteAsync<AlipayTradeCloseNotify>(Request, _optionsAccessor.Value);
  187. if (notify.TradeStatus == AlipayTradeStatus.Wait)
  188. {
  189. Console.WriteLine("OutTradeNo: " + notify.OutTradeNo);
  190. return AlipayNotifyResult.Success;
  191. }
  192. return AlipayNotifyResult.Failure;
  193. }
  194. catch
  195. {
  196. return AlipayNotifyResult.Failure;
  197. }
  198. }
  199. }
  200. }