From 83070ae1b6c99bff833b9a43910b58b970037383 Mon Sep 17 00:00:00 2001 From: mitao <2763622819@qq.com> Date: 星期四, 03 四月 2025 14:40:25 +0800 Subject: [PATCH] Merge branch '2.0' of http://120.76.84.145:10101/gitblit/r/java/PlayPai into 2.0 --- cloud-server-activity/src/main/java/com/dsh/activity/controller/HuiminCallBack.java | 147 ++++++++++++++++++++++++------------------------ 1 files changed, 74 insertions(+), 73 deletions(-) diff --git a/cloud-server-activity/src/main/java/com/dsh/activity/controller/HuiminCallBack.java b/cloud-server-activity/src/main/java/com/dsh/activity/controller/HuiminCallBack.java index 5aea013..9d7f5f4 100644 --- a/cloud-server-activity/src/main/java/com/dsh/activity/controller/HuiminCallBack.java +++ b/cloud-server-activity/src/main/java/com/dsh/activity/controller/HuiminCallBack.java @@ -13,6 +13,7 @@ import com.dsh.activity.model.response.HuiminCardVO; import com.dsh.activity.service.*; +import com.dsh.activity.util.PayMoneyUtil; import com.dsh.activity.util.ResultUtil; import com.dsh.activity.util.TokenUtil; import com.dsh.activity.util.UUIDUtil; @@ -43,7 +44,7 @@ * @date 2023/6/24 11:27 */ @RestController -@RequestMapping("/huimin/callBack") +@RequestMapping("/base/huimin/callBack") public class HuiminCallBack { @Autowired @@ -64,8 +65,8 @@ private SiteClient siteClient; @Resource private StoreClient storeClient; -// @Resource -// private PayMoneyUtil payMoneyUtil; + @Resource + private PayMoneyUtil payMoneyUtil; @Autowired @@ -78,60 +79,60 @@ */ @PostMapping("/aliPayHuiminCallback") public void aliPayHuiminCallback(HttpServletRequest request, HttpServletResponse response) { -// try { -// System.err.println("==========回调"); -// Map<String, String> map = payMoneyUtil.alipayCallback(request); -// if (null != map) { -// String out_trade_no = map.get("out_trade_no"); -// String transaction_id = map.get("transaction_id"); -// TPayHuimin one = payHuiminService.getOne(new LambdaQueryWrapper<TPayHuimin>().eq(TPayHuimin::getCode, out_trade_no)); -// if (one!=null){ -// if (one.getStatus()==2){ -// PrintWriter out = response.getWriter(); -// out.write("success"); -// out.flush(); -// out.close(); -// }else{ -// one.setOrderNumber(transaction_id); -// one.setStatus(2); -// one.setPaymentTime(new Date()); -// payHuiminService.updateById(one); -// } -// } -// } -// } catch (Exception e) { -// e.printStackTrace(); -// } + try { + System.err.println("==========回调"); + Map<String, String> map = payMoneyUtil.alipayCallback(request); + if (null != map) { + String out_trade_no = map.get("out_trade_no"); + String transaction_id = map.get("transaction_id"); + TPayHuimin one = payHuiminService.getOne(new LambdaQueryWrapper<TPayHuimin>().eq(TPayHuimin::getCode, out_trade_no)); + if (one!=null){ + if (one.getStatus()==2){ + PrintWriter out = response.getWriter(); + out.write("success"); + out.flush(); + out.close(); + }else{ + one.setOrderNumber(transaction_id); + one.setStatus(2); + one.setPaymentTime(new Date()); + payHuiminService.updateById(one); + } + } + } + } catch (Exception e) { + e.printStackTrace(); + } } /** * 惠民卡微信支付回调接口 */ @PostMapping("/weixinPayHuiminCallback") public void weixinPayHuiminCallback(HttpServletRequest request, HttpServletResponse response) { -// try { -// Map<String, String> map = payMoneyUtil.weixinpayCallback(request); -// if (null != map) { -// String out_trade_no = map.get("out_trade_no"); -// String transaction_id = map.get("transaction_id"); -// String result = map.get("result"); -// TPayHuimin one = payHuiminService.getOne(new LambdaQueryWrapper<TPayHuimin>().eq(TPayHuimin::getCode, out_trade_no)); -// if (one!=null){ -// if (one.getStatus()==2){ -// PrintWriter out = response.getWriter(); -// out.write(result); -// out.flush(); -// out.close(); -// }else{ -// one.setOrderNumber(transaction_id); -// one.setStatus(2); -// one.setPaymentTime(new Date()); -// payHuiminService.updateById(one); -// } -// } -// } -// } catch (Exception e) { -// e.printStackTrace(); -// } + try { + Map<String, String> map = payMoneyUtil.weixinpayCallback(request); + if (null != map) { + String out_trade_no = map.get("out_trade_no"); + String transaction_id = map.get("transaction_id"); + String result = map.get("result"); + TPayHuimin one = payHuiminService.getOne(new LambdaQueryWrapper<TPayHuimin>().eq(TPayHuimin::getCode, out_trade_no)); + if (one!=null){ + if (one.getStatus()==2){ + PrintWriter out = response.getWriter(); + out.write(result); + out.flush(); + out.close(); + }else{ + one.setOrderNumber(transaction_id); + one.setStatus(2); + one.setPaymentTime(new Date()); + payHuiminService.updateById(one); + } + } + } + } catch (Exception e) { + e.printStackTrace(); + } } /** * 惠民卡微信退款回调 @@ -141,27 +142,27 @@ @ResponseBody @PostMapping("/wxRefundHuiminCallback") public void wxRefundHuiminCallback(HttpServletRequest request, HttpServletResponse response){ -// Map<String, String> map = payMoneyUtil.wxRefundCallback(request); -// if(null != map){ -// String refund_id = map.get("refund_id"); -// String out_refund_no = map.get("out_refund_no"); -// String result = map.get("result"); -// TPayHuimin one = payHuiminService.getOne(new LambdaQueryWrapper<TPayHuimin>() -// .eq(TPayHuimin::getCode, out_refund_no)); -// one.setRefundStatus(2); -// one.setRefundTime(new Date()); -// one.setStatus(3); -// one.setRefundNumber(refund_id); -// payHuiminService.updateById(one); -// PrintWriter out = null; -// try { -// out = response.getWriter(); -// } catch (IOException e) { -// throw new RuntimeException(e); -// } -// out.println(result); -// out.flush(); -// out.close(); -// } + Map<String, String> map = payMoneyUtil.wxRefundCallback(request); + if(null != map){ + String refund_id = map.get("refund_id"); + String out_refund_no = map.get("out_refund_no"); + String result = map.get("result"); + TPayHuimin one = payHuiminService.getOne(new LambdaQueryWrapper<TPayHuimin>() + .eq(TPayHuimin::getCode, out_refund_no)); + one.setRefundStatus(2); + one.setRefundTime(new Date()); + one.setStatus(3); + one.setRefundNumber(refund_id); + payHuiminService.updateById(one); + PrintWriter out = null; + try { + out = response.getWriter(); + } catch (IOException e) { + throw new RuntimeException(e); + } + out.println(result); + out.flush(); + out.close(); + } } } -- Gitblit v1.7.1