.net中微信、支付宝回调
2024-09-08 12:09:18
需求：自助机调用接口生成二维码，用户扫描二维码付款后，回调方法里写入到数据库，自助机轮询查数据库判断用户是否付款。
1 using bk.Services.Log;
2 using bk.web.Common.Alipay;
3 using bk.web.Common.Weixin;
4 using System.Collections.Generic;
5 using System.Collections.Specialized;
6 using System.Text;
7 using System.Web;
8 using System.Web.Mvc;
9 using Com.Alipay;
10 using Com.Alipay.Business;
11 using Com.Alipay.Domain;
12 using Com.Alipay.Model;
13 using System;
14 using bk.web.Models;
15 using bk.Core.Domain;
16 using System.IO;
17 using bk.Core;
18 using bk.Services.Admin;
19 using System.Threading.Tasks;
20 using bk.Core.Infrastructure;
21 using System.Linq;
22 using System.Configuration;
23
24 namespace bk.web.Controllers
25 {
26 public class PayNotifyController : Controller
27 {
28 private readonly IAgent_User_ImgService _userService;
29 private readonly IAgentOperationPayService _payService;
30 private readonly IAgentOperationService _operateService;
31 private readonly IAgentDevice_PayService _amountService;
32 public PayNotifyController(
33 IAgent_User_ImgService userService,
34 IAgentOperationPayService payService,
35 IAgentOperationService operateService,
36 IAgentDevice_PayService amountService)
37 {
38 this._userService = userService;
39 _payService = payService;
40 _operateService = operateService;
41 _amountService = amountService;
42 }
43
44 // GET: PayNotify
45 public ActionResult Index()
46 {
47 return View();
48 }
49
50 #region 微信支付回调
51 /// <summary>
52 /// 支付结果通知回调处理类
53 /// 负责接收微信支付后台发送的支付结果并对订单有效性进行验证，将验证结果反馈给微信支付后台
54 /// </summary>
55 public void wxNotify()
56 {
57 Log.Info(this.GetType().ToString(), "微信支付回调开始");
58
59 WxPayData notifyData = GetNotifyData();
60 //检查支付结果中transaction_id是否存在
61 if (!notifyData.IsSet("transaction_id"))
62 {
63 //若transaction_id不存在，则立即返回结果给微信支付后台
64 WxPayData res = new WxPayData();
65 res.SetValue("return_code", "FAIL");
66 res.SetValue("return_msg", "支付结果中微信订单号不存在");
67 Log.Error(this.GetType().ToString(), "The Pay result is error : " + res.ToXml());
68 Response.Write(res.ToXml());
69 Response.End();
70 }
71
72 string transaction_id = notifyData.GetValue("transaction_id").ToString();
73
74 //查询订单，判断订单真实性
75 if (!QueryOrder(transaction_id))
76 {
77 //若订单查询失败，则立即返回结果给微信支付后台
78 WxPayData res = new WxPayData();
79 res.SetValue("return_code", "FAIL");
80 res.SetValue("return_msg", "订单查询失败");
81 Log.Error(this.GetType().ToString(), "Order query failure : " + res.ToXml());
82 Response.Write(res.ToXml());
83 Response.End();
84 }
85 //查询订单成功
86 else
87 {
88 //更新数据库
89 //WriteLog.Debug("notifyData begin:");
90 //var dicValue = notifyData.GetValues();
91 //foreach (var item in dicValue)
92 //{
93 // WriteLog.Debug(item.Key + " : " + item.Value);
94 //}
95 //WriteLog.Debug("notifyData end;");
96 string out_trade_no = notifyData.GetValue("out_trade_no").ToString();
97 UpdatePayData(1, out_trade_no, transaction_id);
98
99 WxPayData res = new WxPayData();
100 res.SetValue("return_code", "SUCCESS");
101 res.SetValue("return_msg", "OK");
102 Log.Info(this.GetType().ToString(), "order query success : " + res.ToXml());
103
104 Response.Write(res.ToXml());
105 Response.End();
106 }
107
108 }
109
110 private void UpdatePayData(int payType, string out_trade_no, string transaction_id)
111 {
112 //更新AgentOperationPay
113 M_AgentOperationPay m = _payService.GetByOrderNo(out_trade_no);
114 if (m == null)
115 {
116
117 }
118 else
119 {
120 m.SerialNo = transaction_id;
121 m.Payment = payType;
122 m.PayStatus = 1;
123 _payService.Update(m);
124
125 //更新AgentOperation
126 M_AgentOperation om = _operateService.GetByOperationNo(m.OperationNo);
127 om.Status = 1;
128 _operateService.Update(om);
129 }
130 }
131
132 /// <summary>
133 /// 接收从微信支付后台发送过来的数据并验证签名
134 /// </summary>
135 /// <returns>微信支付后台返回的数据</returns>
136 public WxPayData GetNotifyData()
137 {
138 //接收从微信后台POST过来的数据
139 System.IO.Stream s = Request.InputStream;
140 int count = 0;
141 byte[] buffer = new byte[1024];
142 StringBuilder builder = new StringBuilder();
143 while ((count = s.Read(buffer, 0, 1024)) > 0)
144 {
145 builder.Append(Encoding.UTF8.GetString(buffer, 0, count));
146 }
147 s.Flush();
148 s.Close();
149 s.Dispose();
150
151 WriteLog.Debug("Receive data from WeChat : " + builder.ToString());
152
153 //转换数据格式并验证签名
154 WxPayData data = new WxPayData();
155 try
156 {
157 data.FromXml(builder.ToString());
158 }
159 catch (WxPayException ex)
160 {
161 //若签名错误，则立即返回结果给微信支付后台
162 WxPayData res = new WxPayData();
163 res.SetValue("return_code", "FAIL");
164 res.SetValue("return_msg", ex.Message);
165 WriteLog.Debug("Sign check error : " + res.ToXml());
166 Response.Write(res.ToXml());
167 Response.End();
168 }
169
170 WriteLog.Debug("Check sign success");
171 return data;
172 }
173 //查询订单
174 private bool QueryOrder(string transaction_id)
175 {
176 WxPayData req = new WxPayData();
177 req.SetValue("transaction_id", transaction_id);
178 WxPayData res = WxPayApi.OrderQuery(req);
179 if (res.GetValue("return_code").ToString() == "SUCCESS" &&
180 res.GetValue("result_code").ToString() == "SUCCESS")
181 {
182 return true;
183 }
184 else
185 {
186 return false;
187 }
188 }
189 #endregion
190
191 #region 支付宝回调
192 public void aliNotify()
193 {
194 WriteLog.Debug("支付宝回调开始");
195 WriteLog.Debug("aliNotify : begin");
196 SortedDictionary<string, string> sPara = GetRequestPost();
197
198 if (sPara.Count > 0)//判断是否有带返回参数
199 {
200 //Notify aliNotify = new Notify();
201 Com.Alipay.Notify aliNotify = new Com.Alipay.Notify(Config.charset, Config.sign_type, Config.pid, Config.mapiUrl, Config.alipay_public_key);
202
203 //对异步通知进行验签
204 bool verifyResult = aliNotify.Verify(sPara, Request.Form["notify_id"], Request.Form["sign"]);
205 //对验签结果
206 //bool isSign = Aop.Api.Util.AlipaySignature.RSACheckV2(sPara, Config.alipay_public_key ,Config.charset,Config.sign_type,false );
207
208 if (verifyResult && CheckParams()) //验签成功 && 关键业务参数校验成功
209 {
210 /////////////////////////////////////////////////////////////////////////////////////////////////////////////
211 //请在这里加上商户的业务逻辑程序代码
212
213
214 //——请根据您的业务逻辑来编写程序（以下代码仅作参考）——
215 //获取支付宝的通知返回参数，可参考技术文档中服务器异步通知参数列表
216
217 //商户订单号
218 string out_trade_no = Request.Form["out_trade_no"];
219
220
221 //支付宝交易号
222 string trade_no = Request.Form["trade_no"];
223
224 //交易状态
225 //在支付宝的业务通知中，只有交易通知状态为TRADE_SUCCESS或TRADE_FINISHED时，才是买家付款成功。
226 string trade_status = Request.Form["trade_status"];
227
228 //更新数据库
229 if (trade_status == "TRADE_SUCCESS" || trade_status == "TRADE_FINISHED")
230 {
231 UpdatePayData(2, out_trade_no, trade_no);
232 }
233
234 //判断是否在商户网站中已经做过了这次通知返回的处理
235 //如果没有做过处理，那么执行商户的业务程序
236 //如果有做过处理，那么不执行商户的业务程序
237
238 WriteLog.Debug("aliNotify : success");
239 Response.Write("success"); //请不要修改或删除
240
241 //——请根据您的业务逻辑来编写程序（以上代码仅作参考）——
242
243 /////////////////////////////////////////////////////////////////////////////////////////////////////////////
244 }
245 else//验证失败
246 {
247 WriteLog.Debug("aliNotify : fail");
248 Response.Write("fail");
249 }
250 }
251 else
252 {
253 WriteLog.Debug("aliNotify : 无通知参数");
254 Response.Write("无通知参数");
255 }
256 }
257 /// <summary>
258 /// 获取支付宝POST过来通知消息，并以“参数名=参数值”的形式组成数组
259 /// </summary>
260 /// <returns>request回来的信息组成的数组</returns>
261 public SortedDictionary<string, string> GetRequestPost()
262 {
263 int i = 0;
264 SortedDictionary<string, string> sArray = new SortedDictionary<string, string>();
265 NameValueCollection coll;
266 //Load Form variables into NameValueCollection variable.
267 coll = Request.Form;
268
269 // Get names of all forms into a string array.
270 string[] requestItem = coll.AllKeys;
271
272 for (i = 0; i < requestItem.Length; i++)
273 {
274 sArray.Add(requestItem[i], Request.Form[requestItem[i]]);
275 WriteLog.Debug("aliNotify : GetRequestPost, key="+ requestItem[i] + ",value="+ Request.Form[requestItem[i]]);
276 }
277
278 return sArray;
279 }
280
281
282 /// <summary>
283 /// 对支付宝异步通知的关键参数进行校验
284 /// </summary>
285 /// <returns></returns>
286 private bool CheckParams()
287 {
288 bool ret = true;
289
290 //获得商户订单号out_trade_no
291 string out_trade_no = Request.Form["out_trade_no"];
292 //TODO 商户需要验证该通知数据中的out_trade_no是否为商户系统中创建的订单号，
293
294 //获得支付总金额total_amount
295 string total_amount = Request.Form["total_amount"];
296 //TODO 判断total_amount是否确实为该订单的实际金额（即商户订单创建时的金额），
297
298 //获得卖家账号seller_email
299 string seller_email = Request.Form["seller_email"];
300 //TODO 校验通知中的seller_email（或者seller_id) 是否为out_trade_no这笔单据的对应的操作方（有的时候，一个商户可能有多个seller_id / seller_email）
301
302 //获得调用方的appid；
303 //如果是非授权模式，appid是商户的appid；如果是授权模式（token调用），appid是系统商的appid
304 string app_id = Request.Form["app_id"];
305 //TODO 验证app_id是否是调用方的appid；。
306
307 //验证上述四个参数，完全吻合则返回参数校验成功
308 return ret;
309
310 }
311
312 #endregion
313
314 #region 微信、支付宝生成二维码url
315 public JsonResult GetWxAliCodeUrl(WxAliPayRequestOnlyUrl req)
316 {
317 WriteLog.Debug("计时：开始时间=" + DateTime.Now.ToString());
318 WxAliPayResponse result = new WxAliPayResponse();
319
320 #region 业务参数判断 和 签名判断--占不加业务
321
322 //bool have_err = false;
323 //string err_msg = "缺少参数：";
324 //if (req == null)
325 //{
326 // result.Code = "1000";
327 // result.Msg = "传入参数为空";
328 // return Json(result);
329 //}
330
331 //if (string.IsNullOrEmpty(req.file_name))
332 //{
333 // have_err = true;
334 // err_msg += "文件名称不能为空";
335 //}
336 //if (string.IsNullOrEmpty(req.sign))
337 //{
338 // have_err = true;
339 // err_msg += "、签名不能为空";
340 //}
341 //if (string.IsNullOrEmpty(req.avatar))
342 //{
343 // have_err = true;
344 // err_msg += "、照片不能为空";
345 //}
346 //if (req.time_stamp <= 0)
347 //{
348 // have_err = true;
349 // err_msg += "、请传入正确的时间戳格式";
350 //}
351 //if (string.IsNullOrEmpty(req.SFZMHM))
352 //{
353 // have_err = true;
354 // err_msg += "身份证明号码不能为空";
355 //}
356 //if (string.IsNullOrEmpty(req.SFZMMC))
357 //{
358 // have_err = true;
359 // err_msg += "身份证明名称不能为空";
360 //}
361 //if (string.IsNullOrEmpty(req.SFZMLX))
362 //{
363 // have_err = true;
364 // err_msg += "身份证明类型不能为空";
365 //}
366 //if (req.Img_Type != 1 && req.Img_Type != 2 && req.Img_Type != 3)
367 //{
368 // have_err = true;
369 // err_msg += "照片类型格式不正确";
370 //}
371 //if (string.IsNullOrEmpty(req.OperationNo))
372 //{
373 // have_err = true;
374 // err_msg += "操作编号不能为空";
375 //}
376 //if (have_err)
377 //{
378 // //commonHelper.write_log("1001图片接口上传失败", err_msg);
379 // result.Code = "1001";
380 // result.Msg = err_msg;
381 // return Json(result);
382 //}
383 //string strtime_stamp = ConfigurationManager.AppSettings["time_stamp"];
384 //int intTimeStampCfg = 600;
385 //int.TryParse(strtime_stamp, out intTimeStampCfg);
386 //if (Math.Abs(CommonHelper.GetCurrentTimeStamp() - req.time_stamp) > intTimeStampCfg)
387 //{
388 // //commonHelper.write_log("1002图片接口上传失败", "请求过期----当前时间：" + commonHelper.GetCurrentTimeStamp() + "------传入时间:" + model.time_stamp);
389 // result.Code = "1002";
390 // result.Msg = "请求过期";
391 // return Json(result);
392 //}
393 //string api_user_key = ConfigurationManager.AppSettings["upload_img_key"];
394 //string mysign = string.Format("apikey={0}&time_stamp={1}&file_name={2}&operationNo={3}", api_user_key, req.time_stamp, req.file_name, req.OperationNo);
395 //mysign = CommonHelper.MD5Encrypt(mysign, 32);
396 //mysign = mysign.ToLower();
397 //WriteLog.Debug("GetWxAliCodeUrl: mysign="+ mysign + ", 签名参数sign="+ req.sign.ToLower());
398 //if (req.sign.ToLower() != mysign)
399 //{
400 // //commonHelper.write_log("1003图片接口上传失败", "签名不匹配----传入的签名：" + model.sign.ToLower() + "------正确的签名:" + mysign);
401 // result.Code = "1003";
402 // result.Msg = "签名不匹配";
403 // return Json(result);
404 //}
405 //WriteLog.Debug("业务参数判断 和 签名判断 成功");
406
407 #endregion
408
409 #region 判断参数
410 if (req == null)
411 {
412 result.Code = "1000";
413 result.Msg = "传入参数为空";
414 return Json(result);
415 }
416 if (string.IsNullOrEmpty(req.deviceNo))
417 {
418 result.Code = "1001";
419 result.Msg = "设备号不能为空";
420 return Json(result);
421 }
422 if (string.IsNullOrEmpty(req.busyCode))
423 {
424 result.Code = "1002";
425 result.Msg = "业务编号不能为空";
426 return Json(result);
427 }
428 if (string.IsNullOrEmpty(req.OperationNo))
429 {
430 result.Code = "1003";
431 result.Msg = "操作编号不能为空";
432 return Json(result);
433 }
434 if (string.IsNullOrEmpty(req.sign))
435 {
436 result.Code = "1004";
437 result.Msg = "签名不能为空";
438 return Json(result);
439 }
440 if (req.time_stamp <= 0)
441 {
442 result.Code = "1005";
443 result.Msg = "请传入正确的时间戳格式";
444 return Json(result);
445 }
446 string strtime_stamp = ConfigurationManager.AppSettings["time_stamp"];
447 int intTimeStampCfg = 600;
448 int.TryParse(strtime_stamp, out intTimeStampCfg);
449 if (Math.Abs(CommonHelper.GetCurrentTimeStamp() - req.time_stamp) > intTimeStampCfg)
450 {
451 //commonHelper.write_log("1002图片接口上传失败", "请求过期----当前时间：" + commonHelper.GetCurrentTimeStamp() + "------传入时间:" + model.time_stamp);
452 result.Code = "1006";
453 result.Msg = "请求过期";
454 return Json(result);
455 }
456 string api_user_key = ConfigurationManager.AppSettings["upload_img_key"];
457 string mysign = string.Format("apikey={0}&deviceNo={1}&busyCode={2}&OperationNo={3}&time_stamp={4}", api_user_key, req.deviceNo, req.busyCode, req.OperationNo, req.time_stamp);
458 mysign = CommonHelper.MD5Encrypt(mysign, 32);
459 mysign = mysign.ToLower();
460 if (!req.sign.ToLower().Equals(mysign))
461 {
462 //commonHelper.write_log("1003图片接口上传失败", "签名不匹配----传入的签名：" + model.sign.ToLower() + "------正确的签名:" + mysign);
463 result.Code = "1007";
464 result.Msg = "签名不匹配";
465 return Json(result);
466 }
467 #endregion
468
469 string WxCode = "", WxCodeUrl = "", AliCodeUrl = "", AliCode = "", Str_Out_trade_no = "";
470 //订单号
471 Str_Out_trade_no = GetOut_trade_no();
472 //商品ID
473 string Str_productId = GetRandom(9);
474 //金额
475 string strAmount = GetAmount(req.deviceNo, req.busyCode, req.isTest);
476 string Str_total_amount = strAmount;// "0.01";//支付宝支付金额，以 元 为单位
477 int Int_total_amount = ParIntForWeixin(strAmount);// 1;//微信支付金额，以 分 为单位
478
479 #region weixin
480 NativePay nativePay = new NativePay();
481
482 //生成扫码支付模式二url
483 string url2 = nativePay.GetPayUrl(Str_Out_trade_no, Str_productId, Int_total_amount);
484
485 Log.Info(this.GetType().ToString(), "WeiXinNativePay url2 : " + url2);
486
487 WxCode = "SUCCESS";
488 WxCodeUrl = HttpUtility.UrlEncode(url2);
489
490 #endregion
491
492 #region ali
493 AlipayTradePrecreateContentBuilder builder = BuildPrecreateContent(Str_Out_trade_no, Str_productId, Str_total_amount);
494 //string out_trade_no = builder.out_trade_no;
495
496 //推荐使用轮询撤销机制，不推荐使用异步通知,避免单边账问题发生。
497 IAlipayTradeService serviceClient = F2FBiz.CreateClientInstance(Config.serverUrl, Config.appId, Config.merchant_private_key, Config.version,
498 Config.sign_type, Config.alipay_public_key, Config.charset);
499
500 string notify_url = Config.NotifyUrl; //商户接收异步通知的地址
501 AlipayF2FPrecreateResult precreateResult = serviceClient.tradePrecreate(builder, notify_url);
502
503 //以下返回结果的处理供参考。
504 //payResponse.QrCode即二维码对于的链接
505 //将链接用二维码工具生成二维码，顾客可以用支付宝钱包扫码支付。
506 switch (precreateResult.Status)
507 {
508 case ResultEnum.SUCCESS:
509 AliCode = "SUCCESS";
510 AliCodeUrl = HttpUtility.UrlEncode(precreateResult.response.QrCode);
511 break;
512 case ResultEnum.FAILED:
513 AliCode = "FAILED";
514 AliCodeUrl = precreateResult.response.Body;
515 break;
516 case ResultEnum.UNKNOWN:
517 AliCode = "UNKNOWN";
518 if (precreateResult.response == null)
519 {
520 AliCodeUrl = "配置或网络异常，请检查后重试";
521 }
522 else
523 {
524 AliCodeUrl = "系统异常，请更新外部订单后重新发起请求";
525 }
526 break;
527 }
528
529 #endregion
530
531 //处理业务数据，存图片、写数据库
532 Task.Run(()=> WritePayDataNew(req, Str_Out_trade_no));
533
534 WriteLog.Debug("计时：结束时间=" + DateTime.Now.ToString());
535 result.Code = "200";
536 result.Msg = "成功";
537 result.WxCode = WxCode;
538 result.WxCodeUrl = WxCodeUrl;
539 result.AliCode = AliCode;
540 result.AliCodeUrl = AliCodeUrl;
541 result.Out_trade_no = Str_Out_trade_no;
542 return Json(result);
543 }
544
545 private int ParIntForWeixin(string strAmount)
546 {
547 double p = 0;
548 double.TryParse(strAmount, out p);
549 int intp = (int)(p * 100);
550 if (intp == 0)
551 return 20 * 100;
552 else
553 return intp;
554 }
555
556 private string GetAmount(string deviceNo, string busyCode, string isTest)
557 {
558 var strTest = string.IsNullOrEmpty(isTest) ? "" : isTest;
559 if (strTest.Equals("1"))
560 {
561 //测试用，金额为配置的0.01
562 string TestamountPrice = ConfigurationManager.AppSettings["TestamountPrice"];
563 if (string.IsNullOrEmpty(TestamountPrice))
564 return "0.01";
565 else
566 return TestamountPrice;
567 }
568 else
569 {
570 IQueryable<M_AgentDevice_Pay> q = _amountService.GetByNoCode(deviceNo, busyCode);
571 var ls = q.ToList();
572 if (ls == null || ls.Count < 1)
573 {
574 string amountPrice = ConfigurationManager.AppSettings["amountPrice"];
575 if (string.IsNullOrEmpty(amountPrice))
576 return "20";
577 else
578 return amountPrice;
579 }
580 else
581 {
582 return ls[0].PayAmount;
583 }
584 }
585 }
586
587 /// <summary>
588 /// 支付宝 构造支付请求数据
589 /// </summary>
590 /// <returns>请求数据集</returns>
591 private AlipayTradePrecreateContentBuilder BuildPrecreateContent(string Str_Out_trade_no, string Str_productId, string Str_total_amount)
592 {
593 //bkin 三个参数：out_trade_no total_amount subject
594
595 //线上联调时，请输入真实的外部订单号。
596 string out_trade_no = Str_Out_trade_no;
597
598 AlipayTradePrecreateContentBuilder builder = new AlipayTradePrecreateContentBuilder();
599 //收款账号
600 builder.seller_id = Config.pid;
601 //订单编号
602 builder.out_trade_no = out_trade_no;
603 //订单总金额
604 builder.total_amount = Str_total_amount;
605 //参与优惠计算的金额
606 //builder.discountable_amount = "";
607 //不参与优惠计算的金额
608 //builder.undiscountable_amount = "";
609 //订单名称
610 builder.subject = "证件照";
611 //自定义超时时间
612 builder.timeout_express = "5m";
613 //订单描述
614 builder.body = "";
615 //门店编号，很重要的参数，可以用作之后的营销
616 builder.store_id = "test store id";
617 //操作员编号，很重要的参数，可以用作之后的营销
618 builder.operator_id = "证件照";
619
620 //传入商品信息详情
621 List<GoodsInfo> gList = new List<GoodsInfo>();
622 GoodsInfo goods = new GoodsInfo();
623 goods.goods_id = Str_productId;
624 goods.goods_name = "证件照";
625 goods.price = Str_total_amount;
626 goods.quantity = "1";
627 gList.Add(goods);
628 builder.goods_detail = gList;
629
630 //系统商接入可以填此参数用作返佣
631 //ExtendParams exParam = new ExtendParams();
632 //exParam.sysServiceProviderId = "20880000000000";
633 //builder.extendParams = exParam;
634
635 return builder;
636 }
637
638 private void WritePayData(WxAliPayRequest req, string Str_Out_trade_no)
639 {
640 WriteLog.Debug("WritePayData begin");
641 if (req == null)
642 return;
643 var filePath = Base64_to_File(req.avatar);
644
645 //
646 var _payService1 = EngineContext.Current.Resolve<IAgent_User_ImgService>();
647 var _payService2 = EngineContext.Current.Resolve<IAgentOperationPayService>();
648 var _payService3 = EngineContext.Current.Resolve<IAgentOperationService>();
649
650 //插入 Agent_User_Img 表
651 var m = new M_Agent_User_Img()
652 {
653 SFZMHM = req.SFZMHM,
654 SFZMMC = req.SFZMMC,
655 SFZMLX = req.SFZMLX,
656 Img_Type = req.Img_Type,
657 Img_Url = filePath,
658 OperationNo = req.OperationNo,
659 Img_Spec = req.Img_Spec,
660 Create_Time = DateTime.Now,
661 IsDeleted = false
662 };
663 _payService1.Insert(m);
664
665 //插入 AgentOperationPay 表
666 var m2 = new M_AgentOperationPay()
667 {
668 Payment = 0,//支付成功回调更新为 (1, "微信支付");(2, "支付宝支付");(3, "银联支付");(4, "现金支付");
669 Amount = (decimal)0.01,
670 Quantity = 1,
671 PayStatus = 0,//支付成功回调更新为1
672 AddTime = DateTime.Now,
673 IsDeleted = false,
674 OrderNo = Str_Out_trade_no,
675 SerialNo = Str_Out_trade_no,
676 OperationNo = req.OperationNo
677 };
678 _payService2.Insert(m2);
679
680 //插入 AgentOperation 表
681 var m3 = new M_AgentOperation()
682 {
683 AgentNo = "bsr_zxj",
684 OperationNo = req.OperationNo,
685 AgentDeviceNo = req.deviceNo,
686 BusinessNo = "dgnzxj",
687 OperationStatus = true,
688 AddTime = DateTime.Now,
689 IsDeleted = false,
690 ValidateCode = "1111",
691 Status = 0 //支付成功回调更新为1
692 };
693 _payService3.Insert(m3);
694
695
696 }
697 private void WritePayDataNew(WxAliPayRequestOnlyUrl req, string Str_Out_trade_no)
698 {
699 WriteLog.Debug("WritePayData begin");
700 if (req == null)
701 return;
702 //
703 var _payService2 = EngineContext.Current.Resolve<IAgentOperationPayService>();
704 var _payService3 = EngineContext.Current.Resolve<IAgentOperationService>();
705
706 //插入 AgentOperationPay 表
707 var m2 = new M_AgentOperationPay()
708 {
709 Payment = 0,//支付成功回调更新为 (1, "微信支付");(2, "支付宝支付");(3, "银联支付");(4, "现金支付");
710 Amount = (decimal)0.01,
711 Quantity = 1,
712 PayStatus = 0,//支付成功回调更新为1
713 AddTime = DateTime.Now,
714 IsDeleted = false,
715 OrderNo = Str_Out_trade_no,
716 SerialNo = Str_Out_trade_no,
717 OperationNo = req.OperationNo
718 };
719 _payService2.Insert(m2);
720
721 //插入 AgentOperation 表
722 var m3 = new M_AgentOperation()
723 {
724 AgentNo = "bsr_zxj",
725 OperationNo = req.OperationNo,
726 AgentDeviceNo = req.deviceNo,
727 BusinessNo = "dgnzxj",
728 OperationStatus = true,
729 AddTime = DateTime.Now,
730 IsDeleted = false,
731 ValidateCode = "1111",
732 Status = 0 //支付成功回调更新为1
733 };
734 _payService3.Insert(m3);
735
736
737 }
738 private void WritePayData2(WxAliPayRequest req, string Str_Out_trade_no)
739 {
740 WriteLog.Debug("WritePayData begin");
741 if (req == null)
742 return;
743 var filePath = Base64_to_File(req.avatar);
744
745 //插入 Agent_User_Img 表
746 var m = new M_Agent_User_Img()
747 {
748 SFZMHM = req.SFZMHM,
749 SFZMMC = req.SFZMMC,
750 SFZMLX = req.SFZMLX,
751 Img_Type = req.Img_Type,
752 Img_Url = filePath,
753 OperationNo = req.OperationNo,
754 Img_Spec = req.Img_Spec,
755 Create_Time = DateTime.Now,
756 IsDeleted = false
757 };
758 _userService.Insert(m);
759
760 //插入 AgentOperationPay 表
761 var m2 = new M_AgentOperationPay()
762 {
763 Payment = 1,
764 Amount = (decimal)0.01,
765 Quantity = 1,
766 PayStatus = 0,
767 AddTime = DateTime.Now,
768 IsDeleted = false,
769 OrderNo = Str_Out_trade_no,
770 SerialNo = Str_Out_trade_no,
771 OperationNo = req.OperationNo
772 };
773 _payService.Insert(m2);
774
775 //插入 AgentOperation 表
776 var m3 = new M_AgentOperation()
777 {
778 AgentNo = "bsr_zxj",
779 OperationNo = req.OperationNo,
780 AgentDeviceNo = req.deviceNo,
781 BusinessNo = "dgnzxj",
782 OperationStatus = true,
783 AddTime = DateTime.Now,
784 IsDeleted = false,
785 ValidateCode = "1111",
786 Status = 1
787 };
788 _operateService.Insert(m3);
789
790
791 }
792
793 private string GetOut_trade_no()
794 {
795 return System.DateTime.Now.ToString("yyyyMMddHHmmss") + GetRandom(10);
796 }
797
798 private string Base64_to_File(string imageCode)
799 {
800 if (string.IsNullOrEmpty(imageCode))
801 return "";
802
803 byte[] arr2 = Convert.FromBase64String(imageCode);
804 using (MemoryStream ms2 = new MemoryStream(arr2))
805 {
806 string dir = "/user_img/" + DateTime.Now.ToString("yyyyMMdd") + "/";
807 if (!Directory.Exists(Server.MapPath(dir)))
808 {
809 Directory.CreateDirectory(Server.MapPath(dir));
810 }
811 string fileName = Guid.NewGuid() + ".jpg";
812 string dirFile = Server.MapPath(dir) + fileName;
813
814 System.Drawing.Bitmap bmp2 = new System.Drawing.Bitmap(ms2);
815 bmp2.Save(dirFile, System.Drawing.Imaging.ImageFormat.Jpeg);
816 //bmp2.Save(filePath + ".bmp", System.Drawing.Imaging.ImageFormat.Bmp);
817 //bmp2.Save(filePath + ".gif", System.Drawing.Imaging.ImageFormat.Gif);
818 //bmp2.Save(filePath + ".png", System.Drawing.Imaging.ImageFormat.Png);
819 return dir + fileName;
820 }
821 }
822
823 //生成N位的随机数 全数字
824 private string GetRandom(int len)
825 {
826 string k = "";
827 Random rand = new Random(GetRandomSeed());
828 for (int i = 0; i < len; i++)
829 {
830 k += rand.Next(0, 10).ToString();
831 }
832 return k;
833 }
834 //取随机数种子
835 private int GetRandomSeed()
836 {
837 byte[] bytes = new byte[4];
838 System.Security.Cryptography.RNGCryptoServiceProvider rng = new System.Security.Cryptography.RNGCryptoServiceProvider();
839 rng.GetBytes(bytes);
840 return BitConverter.ToInt32(bytes, 0);
841 }
842 #endregion
843
844 #region 客户端轮询此接口，查是否已经付款
845 //根据订单号来查询
846 [HttpPost]
847 public JsonResult CheckIsPay(string out_trade_no)
848 {
849 var m = _payService.GetByOrderNo(out_trade_no);
850 if (m == null)
851 {
852 return Json(new { code = "0", msg = "未支付" });
853 }
854 else if (m.PayStatus == 1)
855 {
856 return Json(new { code = "1", msg = "已支付" });
857 }
858 else
859 {
860 return Json(new { code = "0", msg = "未支付" });
861 }
862
863 }
864 #endregion
865 }
866 }
支付宝调用需要引用官网的一些dll, 微信的需要添加一些文件：
最新文章
- 开坑Java编写Json解析器，简明教程
- 通过代码自定义cell(cell的高度不一致，比如微博)
- Flink 1.1 – ResourceManager
- Arduino101学习笔记（十四）—— Flash库
- [51单片机] HC-SR04超声波测距仪 基础代码
- ORA-19693: 已包括备份片段
- OAF_VO系列3 - Binding Style绑定方式
- SQL语句统计一段时间内的记录数
- position绝对剧中
- 机器学习 —— 基础整理（八）循环神经网络的BPTT算法步骤整理；梯度消失与梯度爆炸
- 设计模式NO.2
- Java基础---Java---网络编程---TCP的传输、客户端和服务端的互访、建立一个文本转换器、编写一个聊天程序
- hive -help hive命令行执行sql参数
- Oracle列转行函数LISTAGG()
- 伪类实现特殊图形，一个span加三角形
- Sample Means（耶鲁大学教材）
- 安装Scipy出错的解决方法
- VS2010+WinXP+MFC程序 无法定位程序输入点于动态链接库
- go 学习笔记（1）--package
- django【ORM】model字段类型