qzz/electripper
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1.支付渠道--调整

Browse Source
This commit is contained in:
邱贞招 2024-09-15 15:26:33 +08:00
parent 04a03eae69
commit 4afc12d842
12 changed files with 98 additions and 50 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
electripper-admin/src/main/java/com/ruoyi/web/controller/common/CallbackController.java
View File

@ -103,8 +103,9 @@ public class CallbackController {
String trxCode = params.get("trxcode"); // 交易类型
String outTradeNo = params.get("cusorderid"); // 商户自定义订单号
String trxStatus = params.get("trxstatus"); // 交易结果
String remark = params.get("remark"); // 附加信息，用于判断业务类型
String remark = params.get("trxreserved"); // 附加信息，用于判断业务类型
AttachVo attachVo = JSONObject.parseObject(remark,AttachVo.class);
log.info("【通联微信支付回调】回调参数--附加信息 : 【{}】",JSON.toJSONString(attachVo));
if (SybTrxStatus.isSuccess(trxStatus) && SybTrxCode.WX_PAY.equalsCode(trxCode)) {
// 新版支付订单

3
electripper-admin/src/main/java/com/ruoyi/web/controller/system/SysLoginController.java
View File

@ -3,6 +3,7 @@ package com.ruoyi.web.controller.system;
import cn.hutool.core.util.ObjectUtil;
import cn.hutool.core.util.StrUtil;
import com.alibaba.fastjson2.JSON;
import com.ruoyi.common.annotation.Log;
import com.ruoyi.common.constant.Constants;
import com.ruoyi.common.constant.HttpStatus;
import com.ruoyi.common.core.domain.AjaxResult;
@ -11,6 +12,7 @@ import com.ruoyi.common.core.domain.entity.SysDept;
import com.ruoyi.common.core.domain.entity.SysMenu;
import com.ruoyi.common.core.domain.entity.SysUser;
import com.ruoyi.common.core.domain.model.LoginBody;
import com.ruoyi.common.enums.BusinessType;
import com.ruoyi.common.utils.SecurityUtils;
import com.ruoyi.framework.web.service.SysLoginService;
import com.ruoyi.framework.web.service.SysPermissionService;
@ -159,6 +161,7 @@ public class SysLoginController
* 微信登录
*/
@PostMapping("/wxlogin")
@Log(title = "微信登录", businessType = BusinessType.LOGIN)
public AjaxResult wxlogin(String mobileCode,String jsCode,String areaId) {
if(StrUtil.isBlank(areaId)){
log.info("没有传入areaId参数：【areaId={}】",areaId);

2
electripper-common/src/main/java/com/ruoyi/common/enums/BusinessType.java
View File

@ -216,4 +216,6 @@ public enum BusinessType
* 0元订单
*/
ZEROORDER,
LOGIN,
}

15
electripper-common/src/main/java/com/ruoyi/common/pay/PaymentResult.java
View File

@ -1,21 +1,14 @@
package com.ruoyi.common.pay;
import com.wechat.pay.java.service.payments.model.Transaction;
import lombok.Data;
import java.math.BigDecimal;
import java.util.Map;
@Data
public class PaymentResult {
private String outTradeNo; // 商户订单号
private String status;
private String transactionId; // 平台交易ID
private BigDecimal amount; // 交易金额
private Transaction transaction;
public PaymentResult(String outTradeNo, String status, String transactionId, BigDecimal amount) {
this.outTradeNo = outTradeNo;
this.status = status;
this.transactionId = transactionId;
this.amount = amount;
}
private Map<String, String> result;
}

2
electripper-common/src/main/java/com/ruoyi/common/pay/syb/service/SybPayService.java
View File

@ -45,7 +45,7 @@ public class SybPayService {
"",
"",
"",
"",
payable.getAppid(),
"",
"",
"",

5
electripper-common/src/main/java/com/ruoyi/common/pay/wx/Payable.java
View File

@ -34,4 +34,9 @@ public class Payable {
*/
private String openid;
/**
* appid
*/
private String appid;
}

3
electripper-system/src/main/java/com/ruoyi/system/domain/Channel.java
View File

@ -61,4 +61,7 @@ public class Channel extends BaseEntity
/** 退款回调地址 */
private String refundNotifyUrl;
/** appid */
private String appid;
}

4
electripper-system/src/main/java/com/ruoyi/system/domain/EtOrder.java
View File

@ -246,6 +246,10 @@ public class EtOrder extends BaseEntity
@Excel(name = "是否押金抵扣")
private String depositDeduction;
/** 押金订单号 */
@Excel(name = "押金订单号")
private String depositOrderNo;
/** 是否开启押金抵扣：0-否；1-是 */
@Excel(name = "是否开启押金抵扣")
@TableField(exist = false)

63
electripper-system/src/main/java/com/ruoyi/system/service/impl/EtOrderServiceImpl.java
View File

@ -13,6 +13,8 @@ import com.ruoyi.common.core.domain.entity.SysDept;
import com.ruoyi.common.enums.BusinessStatus;
import com.ruoyi.common.exception.ServiceException;
import com.ruoyi.common.pay.PaymentResult;
import com.ruoyi.common.pay.syb.enums.SybTrxStatus;
import com.ruoyi.common.pay.syb.service.SybPayService;
import com.ruoyi.common.utils.CommonUtil;
import com.ruoyi.common.utils.DateUtils;
import com.ruoyi.common.utils.PageUtils;
@ -25,7 +27,6 @@ import com.ruoyi.system.mapper.*;
import com.ruoyi.system.service.*;
import com.wechat.pay.java.service.payments.jsapi.model.PrepayWithRequestPaymentResponse;
import com.wechat.pay.java.service.payments.model.Transaction;
import com.wechat.pay.java.service.refund.model.Refund;
import lombok.SneakyThrows;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.ObjectUtils;
@ -132,6 +133,9 @@ public class EtOrderServiceImpl implements IEtOrderService
@Autowired
private EtChannelService etChannelService;
@Autowired
private SybPayService sybPayService;
/**
* 查询订单
*
@ -335,7 +339,13 @@ public class EtOrderServiceImpl implements IEtOrderService
List<EtOrder> etOrders = etOrderMapper.selectEtOrderList(etOrder);
//如果查询押金则增加退款记录
etOrders.forEach(etOrder1 -> {
List<EtRefund> refunds = etRefundService.selectEtRefundByOrderNo(etOrder1.getOrderNo());
String orderNo;
if(etOrder1.getDepositDeduction().equals(ServiceConstants.IS_DEPOSIT_DEDUCTION) && etOrder1.getStatus().equals(ServiceConstants.ORDER_STATUS_ORDER_END)){
orderNo = etOrder1.getDepositOrderNo();
}else{
orderNo = etOrder1.getOrderNo();
}
List<EtRefund> refunds = etRefundService.selectEtRefundByOrderNo(orderNo);
if(ObjectUtil.isNotNull(refunds) && refunds.size() > 0){
etOrder1.setEtRefund(refunds.get(0));
etOrder1.setEtRefunds(refunds);
@ -523,27 +533,29 @@ public class EtOrderServiceImpl implements IEtOrderService
if(StrUtil.isNotBlank(order.getOutTradeNo())){
String outTradeNo = order.getOutTradeNo();
log.info("【押金抵扣】订单【{}】,有outTradeNo = 【{}】", order.getOrderNo(),outTradeNo);
ChannelVO channelVO = etChannelService.selectSmChannelByChannelId(order.getPayChannel());
// 如果原来有outtradeno，去查询一次，查询是否支付过
PaymentResult paymentResult = wxPayService.queryOrderByOutTradeNo(outTradeNo);
try {
if (Transaction.TradeStateEnum.SUCCESS.equals(paymentResult.getStatus())) {
// 订单已支付
order.setPaid(ServiceConstants.ORDER_PAY_STATUS_PAID);
order.setPayTime(DateUtils.getNowDate());
order.setStatus(ServiceConstants.ORDER_STATUS_ORDER_END);
order.setPayType(ServiceConstants.PAY_TYPE_WX);
order.setMark("主动查询-骑行支付");
int updateEtOrder = etOrderMapper.updateEtOrderByOrderNo(order);
if (updateEtOrder == 0) {
// 抛出自定义异常来标识订单更新失败
throw new ServiceException("押金抵扣失败，更新骑行订单失败");
if (ObjectUtil.isNotNull(paymentResult.getTransaction())) {
if (Transaction.TradeStateEnum.SUCCESS.equals(paymentResult.getTransaction().getTradeState())) {
handleSuccess(order);
return 1;
}else{
// 没有支付，则关闭订单
boolean b = wxPayService.closeOrder(outTradeNo,channelVO);
log.info("【押金抵扣】订单【{}】,有outTradeNo = 【{}】,查询订单未支付，关闭订单：{}", order.getOrderNo(),outTradeNo,b);
}
return 1;
}else{
ChannelVO channelVO = etChannelService.selectSmChannelByChannelId(order.getPayChannel());
// 没有支付，则关闭订单
boolean b = wxPayService.closeOrder(outTradeNo,channelVO);
log.info("【押金抵扣】订单【{}】,有outTradeNo = 【{}】,查询订单未支付，关闭订单：{}", order.getOrderNo(),outTradeNo,b);
Map<String, String> result = paymentResult.getResult();
if(SybTrxStatus.isSuccess(result.get("trxstatus"))) {
handleSuccess(order);
return 1;
}else{
// 没有支付，则关闭订单
sybPayService.closeOrderWx(outTradeNo);
log.info("【押金抵扣】订单【{}】,有outTradeNo = 【{}】,查询订单未支付，关闭订单：{}", order.getOrderNo(),outTradeNo);
}
}
} catch (ServiceException e) {
log.error("异常发生: {}", e.getMessage());
@ -573,6 +585,7 @@ public class EtOrderServiceImpl implements IEtOrderService
order.setPayType(ServiceConstants.PAY_TYPE_YJ);
order.setMark(mark);
order.setDepositDeduction(ServiceConstants.IS_DEPOSIT_DEDUCTION);
order.setDepositOrderNo(depositOrder.getOrderNo());
int updateEtOrder = etOrderMapper.updateEtOrder(order);
if(updateEtOrder == 0){
throw new ServiceException("押金抵扣失败，更新骑行订单失败");
@ -613,6 +626,20 @@ public class EtOrderServiceImpl implements IEtOrderService
return 1;
}
private void handleSuccess(EtOrder order) {
// 订单已支付
order.setPaid(ServiceConstants.ORDER_PAY_STATUS_PAID);
order.setPayTime(DateUtils.getNowDate());
order.setStatus(ServiceConstants.ORDER_STATUS_ORDER_END);
order.setPayType(ServiceConstants.PAY_TYPE_WX);
order.setMark("主动查询-骑行支付");
int updateEtOrder = etOrderMapper.updateEtOrderByOrderNo(order);
if (updateEtOrder == 0) {
// 抛出自定义异常来标识订单更新失败
throw new ServiceException("押金抵扣失败，更新骑行订单失败");
}
}
/**
* 修复押金抵扣
* 1. 查询所有押金抵扣的订单

40
electripper-system/src/main/java/com/ruoyi/system/service/impl/WxPayService.java
View File

@ -113,20 +113,24 @@ public class WxPayService implements IWxPayService {
if(ObjectUtil.isNull(sysDept)){
throw new ServiceException("没有运营商：【"+etAreaDept.getDeptId()+"】");
}
String type = order.getType();
String description = type.equals(ServiceConstants.ORDER_TYPE_RIDING) ? "骑行订单-"+billNo : "押金充值-"+billNo;
String outTradeNo = IdUtils.getOrderNo("wx");
EtOrder order1 = new EtOrder();
order1.setOutTradeNo(outTradeNo);
order1.setOrderId(order.getOrderId());
Long payChannel = sysDept.getPayChannel();
if(ObjectUtil.isNull(payChannel)){
throw new ServiceException("运营商【"+sysDept.getDeptName()+"】没有支付渠道");
}
ChannelVO channelVO = etChannelService.selectSmChannelByChannelId(payChannel);
String outTradeNo = null;
if(PayChannel.CT_WX.equalsCode(channelVO.getCode()) || PayChannel.YS_WX.equalsCode(channelVO.getCode())){
outTradeNo = IdUtils.getOrderNo("wx");
}else if(PayChannel.TL_WX.equalsCode(channelVO.getCode())){
outTradeNo = IdUtils.getOrderNo("tlwx");
}
String type = order.getType();
String description = type.equals(ServiceConstants.ORDER_TYPE_RIDING) ? "骑行订单-"+billNo : "押金充值-"+billNo;
EtOrder order1 = new EtOrder();
order1.setOutTradeNo(outTradeNo);
order1.setOrderId(order.getOrderId());
order1.setPayChannel(payChannel);
int updateEtOrder = etOrderService.updateEtOrder(order1);
@ -143,6 +147,7 @@ public class WxPayService implements IWxPayService {
request.setMchid(channelVO.getMerchantId());
request.setAttach(JSON.toJSONString(new AttachVo(payType,user.getUserId(), "")));
request.setDescription(description);
log.info("支付渠道------"+JSON.toJSON(channelVO));
request.setNotifyUrl(channelVO.getNotifyUrl());
request.setPayer(getPayer(user.getWxopenid()));
JsapiServiceExtension jsapiServiceExtension = getJsapiServiceExtension(channelVO);
@ -165,11 +170,12 @@ public class WxPayService implements IWxPayService {
sybPayService.closeOrderWx(order.getOutTradeNo());
}
Payable payable = new Payable();
payable.setAmount(order.getPayFee().longValue());
payable.setAmount(order.getPayFee().multiply(new BigDecimal(100)).longValue());
payable.setOutTradeNo(outTradeNo);
payable.setAttach(JSON.toJSONString(new AttachVo(payType,user.getUserId(), "")));
payable.setDescription(description);
payable.setOpenid(user.getWxopenid());
payable.setAppid(channelVO.getAppid());
PrepayWithRequestPaymentResponse res = sybPayService.prepayWxApp(payable);
return res;
}else{
@ -297,22 +303,21 @@ public class WxPayService implements IWxPayService {
public PaymentResult queryOrderByOutTradeNo(String outTradeNo) {
EtOrder order = etOrderService.selectEtOrderByOutTradeNo(outTradeNo);
ChannelVO channelVO = etChannelService.selectSmChannelByChannelId(order.getPayChannel());
PaymentResult paymentResult1 = new PaymentResult();
if(PayChannel.CT_WX.equalsCode(channelVO.getCode()) || PayChannel.YS_WX.equalsCode(channelVO.getCode())){
QueryOrderByOutTradeNoRequest request = new QueryOrderByOutTradeNoRequest();
request.setMchid(channelVO.getMerchantId());
request.setOutTradeNo(outTradeNo);
JsapiService jsapiService = getJsapiService(channelVO);
Transaction transaction = jsapiService.queryOrderByOutTradeNo(request);
return new PaymentResult(transaction.getOutTradeNo(), transaction.getTradeState().name(),
transaction.getTransactionId(), new BigDecimal(transaction.getAmount().getTotal()/100));
log.info("微信查询订单信息outTradeNo={}-----【{}】",outTradeNo,JSON.toJSON(transaction));
paymentResult1.setTransaction(transaction);
return paymentResult1;
}else if(PayChannel.TL_WX.equalsCode(channelVO.getCode())){
Map<String, String> result = sybPayService.queryOrderByOutTradeNo(order.getOutTradeNo());
if(SybTrxStatus.isSuccess(result.get("trxstatus"))) {
PaymentResult paymentResult = new PaymentResult(result.get("reqsn"),
result.get("trxstatus"),
result.get("chnltrxid"),
new BigDecimal(result.get("amount")).divide(new BigDecimal(100)).setScale(2, RoundingMode.HALF_UP));
return paymentResult;
paymentResult1.setResult(result);
return paymentResult1;
}
return null;
}else{
@ -418,6 +423,9 @@ public class WxPayService implements IWxPayService {
public void refund(EtOrder etOrder,String reason,BigDecimal amount,String outRefundNo) {
if(!etOrder.getStatus().equals(ServiceConstants.ORDER_STATUS_ORDER_END)) throw new ServiceException("订单状态异常");
ChannelVO channelVO = etChannelService.selectSmChannelByChannelId(etOrder.getPayChannel());
if (channelVO == null) {
throw new ServiceException("支付渠道不存在: " + etOrder.getPayChannel());
}
if(PayChannel.CT_WX.equalsCode(channelVO.getCode()) || PayChannel.YS_WX.equalsCode(channelVO.getCode())){
log.info("----------{}-------------","微信官方退款");

4
electripper-system/src/main/resources/mapper/system/EtChannelMapper.xml
View File

@ -21,7 +21,8 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
sc.notify_url,
sc.private_key_path,
sc.merchant_serial_number,
sc.refund_notify_url
sc.refund_notify_url,
sc.appid
from et_channel sc
</sql>
@ -82,6 +83,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
<if test="data.privateKeyPath != null">private_key_path = #{data.privateKeyPath},</if>
<if test="data.merchantSerialNumber != null">merchant_serial_number = #{data.merchantSerialNumber},</if>
<if test="data.refundNotifyUrl != null">refund_notify_url = #{data.refundNotifyUrl},</if>
<if test="data.appid != null">appid = #{data.appid},</if>
</trim>
where channel_id = #{data.channelId}
</update>

4
electripper-system/src/main/resources/mapper/system/EtOrderMapper.xml
View File

@ -70,7 +70,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
create_time, appointment_start_time, appointment_end_time,appointment_timeout, unlock_time,return_time,
rule_end_time, return_type, AsText(trip_route) trip_route,trip_route_str,cycle,deposit_deduction,video_url,
upload_time,deduction_amount,audio_files,used_sn,change_reason,locking,auto_refund_deposit,free_ride_time,
rental_unit,riding_rule,riding_rule_json,charging_cycle,charging_cycle_value,capped_amount,handling_charge, platform_service_fee, pay_channel
rental_unit,riding_rule,riding_rule_json,charging_cycle,charging_cycle_value,capped_amount,handling_charge, platform_service_fee, pay_channel,
operator_dividend from et_order
</sql>
@ -81,7 +81,7 @@ PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
create_time, appointment_start_time, appointment_end_time,appointment_timeout, unlock_time,return_time,
rule_end_time, return_type, cycle,deposit_deduction,video_url,upload_time,deduction_amount,audio_files,
used_sn,change_reason,locking,auto_refund_deposit,free_ride_time,
rental_unit,riding_rule,riding_rule_json,charging_cycle,charging_cycle_value,capped_amount,handling_charge, platform_service_fee, pay_channel
rental_unit,riding_rule,riding_rule_json,charging_cycle,charging_cycle_value,capped_amount,handling_charge, platform_service_fee, pay_channel,
operator_dividend from et_order
</sql>