From c144a01a7fff4e9bd169eb9d03b6ea58bc8bafb6 Mon Sep 17 00:00:00 2001 From: 陶杰 <1378534974@qq.com> Date: 星期二, 22 十月 2024 14:40:40 +0800 Subject: [PATCH] 1.钱包 --- src/main/java/com/mzl/flower/service/payment/UserPaymentSybService.java | 62 ++++++++++++++++++++++++------ 1 files changed, 49 insertions(+), 13 deletions(-) diff --git a/src/main/java/com/mzl/flower/service/payment/UserPaymentSybService.java b/src/main/java/com/mzl/flower/service/payment/UserPaymentSybService.java index 83853a9..e756717 100644 --- a/src/main/java/com/mzl/flower/service/payment/UserPaymentSybService.java +++ b/src/main/java/com/mzl/flower/service/payment/UserPaymentSybService.java @@ -298,7 +298,9 @@ } } - return !"1001".equals(trxstatus); + return !("1001".equals(trxstatus) || StringUtils.isEmpty(trxstatus) + || "2008".equals(trxstatus) + || "2000".equals(trxstatus)); } public boolean checkOrderStatusRefund(String outTradeNo) throws Exception { @@ -341,10 +343,16 @@ SybPayService service = new SybPayService(); Map<String,String> params = service.query(orderId, up.getTransactionId()); + String retcode = params.get("retcode"); + if(!"SUCCESS".equals(retcode)){ + throw new ValidationException("查询订单交易状态失败: " + params.get("retmsg")); + } String trxstatus = params.get("trxstatus");//支付状态 - if("1001".equals(trxstatus)){ - //空单 直接取消 + if("1001".equals(trxstatus) || "3088".equals(trxstatus)){ + //3088-交易未支付(在查询时间区间内未成功支付,如已影响资金24小时内会做差错退款处理) + //1001:交易不存在 + //直接取消 } else if (StringUtils.isEmpty(trxstatus) || "2008".equals(trxstatus) || "2000".equals(trxstatus)) { @@ -353,10 +361,15 @@ Map<String,String> map = service.close(trxid, orderId); log.info("======关闭订单结果" + toJSONString(map)); - String retcode = map.get("retcode"); + retcode = map.get("retcode"); if(!"SUCCESS".equals(retcode)){ - throw new ValidationException("取消订单失败: " + map.get("retmsg")); + throw new ValidationException("调用通联关闭订单失败: " + map.get("retmsg")); } + trxstatus = map.get("trxstatus"); + if(!"0000".equals(trxstatus)){ + throw new ValidationException("取消订单失败: " + map.get("errmsg")); + } + } else { throw new ValidationException("订单不可取消"); } @@ -438,16 +451,23 @@ throw new ValidationException("订单不可退款"); } - long trxamt = up.getPaymentAmount().longValue(); + long trxamt = prepareAmount(up.getPaymentAmount()); String reqsn = orderId; String oldtrxid = up.getTransactionId(); - String oldreqsn = null; + String oldreqsn = orderId; SybPayService service = new SybPayService(); Map<String,String> map = service.cancel(trxamt, reqsn, oldtrxid, oldreqsn); String retcode = map.get("retcode"); if(!"SUCCESS".equals(retcode)){ - throw new ValidationException("订单退款失败: " + map.get("retmsg")); + throw new ValidationException("调用通联撤销接口失败: " + map.get("retmsg")); + } + + //这个不是订单状态,是通用的,如果是支付查询,代表就是订单状态,如果是退款代表的是退款状态 + String trxstatus = map.get("trxstatus"); + if(!"0000".equals(trxstatus)){ + log.error("通联撤销交易失败:" + map.get("errmsg")); + throw new ValidationException("订单退款交易失败:" + map.get("errmsg")); } updateOrderRefund(orderId, oldtrxid); @@ -465,16 +485,22 @@ throw new ValidationException("订单不可退款"); } - long trxamt = up.getPaymentAmount().longValue(); + long trxamt = prepareAmount(up.getPaymentAmount()); String reqsn = orderId; String oldtrxid = up.getTransactionId(); - String oldreqsn = null; + String oldreqsn = orderId; SybPayService service = new SybPayService(); Map<String,String> map = service.refund(trxamt, reqsn, oldtrxid, oldreqsn); String retcode = map.get("retcode"); if(!"SUCCESS".equals(retcode)){ - throw new ValidationException("订单退款失败: " + map.get("retmsg")); + throw new ValidationException("调用通联退款失败: " + map.get("retmsg")); + } + + //这个不是订单状态,是通用的,如果是支付查询,代表就是订单状态,如果是退款代表的是退款状态 + String trxstatus = map.get("trxstatus"); + if(!"0000".equals(trxstatus)){ + throw new ValidationException("订单退款交易失败:" + map.get("errmsg")); } updateOrderRefund(orderId, oldtrxid); @@ -542,7 +568,7 @@ new QueryWrapper<UserPayment>().eq("order_id", o.getId())); long trxamt = refund; - String reqsn = o.getId(); + String reqsn = re.getId();//退款单的id String oldtrxid = up.getTransactionId(); String oldreqsn = null; @@ -550,12 +576,22 @@ Map<String,String> map = service.refund(trxamt, reqsn, oldtrxid, oldreqsn); String retcode = map.get("retcode"); if(!"SUCCESS".equals(retcode)){ - throw new ValidationException("订单退款失败: " + map.get("retmsg")); + throw new ValidationException("调用通联退款失败: " + map.get("retmsg")); + } + + //这个不是订单状态,是通用的,如果是支付查询,代表就是订单状态,如果是退款代表的是退款状态 + String trxstatus = map.get("trxstatus"); + if(!"0000".equals(trxstatus)){ + throw new ValidationException("订单退款交易失败:" + map.get("errmsg")); } re.setRequest(toJSONString(map)); re.create(SecurityUtils.getUserId()); + re.setStatus(retcode); + re.setNotification(retcode); + re.setNotifyTime(LocalDateTime.now()); + orderRefundMapper.insert(re); return re.getId(); -- Gitblit v1.9.3