package com.ruoyi.web.controller.api;
|
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.fasterxml.jackson.core.type.TypeReference;
|
import com.ruoyi.common.core.domain.AjaxResult;
|
import com.ruoyi.common.core.domain.R;
|
import com.ruoyi.common.utils.CodeGenerateUtils;
|
import com.ruoyi.framework.web.service.TokenService;
|
import com.ruoyi.system.model.TSysAppUser;
|
import com.ruoyi.system.model.TSysInspection;
|
import com.ruoyi.system.model.TSysOtherConfig;
|
import com.ruoyi.system.model.TSysPayRecord;
|
import com.ruoyi.system.service.TSysAppUserService;
|
import com.ruoyi.system.service.TSysInspectionService;
|
import com.ruoyi.system.service.TSysOtherConfigService;
|
import com.ruoyi.system.service.TSysPayRecordService;
|
import com.ruoyi.system.wxPay.enums.RefundEnum;
|
import com.ruoyi.system.wxPay.enums.TradeStateEnum;
|
import com.ruoyi.system.wxPay.model.WeixinPayProperties;
|
import com.ruoyi.system.wxPay.model.WxPaymentRefundModel;
|
import com.ruoyi.system.wxPay.utils.WxTimeUtils;
|
import com.ruoyi.system.wxPay.utils.WxV3Pay;
|
import io.swagger.annotations.Api;
|
import io.swagger.annotations.ApiOperation;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.web.bind.annotation.*;
|
|
import javax.servlet.http.HttpServletRequest;
|
import java.io.IOException;
|
import java.math.BigDecimal;
|
import java.util.Map;
|
import java.util.Objects;
|
|
/**
|
* 微信相关接口
|
*/
|
@Slf4j
|
@RestController
|
@CrossOrigin
|
@RequestMapping("/wx/")
|
@Api(tags = {"微信支付相关接口"})
|
public class WxPayController {
|
@Autowired
|
private WxV3Pay wxV3Pay;
|
@Autowired
|
private TokenService tokenService;
|
@Autowired
|
private TSysAppUserService sysAppUserService;
|
@Autowired
|
private TSysOtherConfigService sysOtherConfigService;
|
@Autowired
|
private TSysPayRecordService sysPayRecordService;
|
@Autowired
|
private WeixinPayProperties weixinPayProperties;
|
@Autowired
|
private TSysInspectionService sysInspectionService;
|
|
|
|
/**
|
* 按实际修改
|
*/
|
@ApiOperation("订单支付")
|
@PostMapping("orderPay")
|
public R<Map<String, Object>> orderPay(@RequestParam(value = "inspectionId") String inspectionId) {
|
|
TSysOtherConfig sysOtherConfig = sysOtherConfigService.getById(1);
|
if (Objects.isNull(sysOtherConfig.getAiPrice())) {
|
return R.fail("系统未配置AI支付价格");
|
}
|
|
String userId = tokenService.getLoginUserApplet().getUserId();
|
TSysAppUser sysAppUser = sysAppUserService.getById(userId);
|
// 价格
|
Integer totalPrice = sysOtherConfig.getAiPrice().multiply(new BigDecimal(100)).intValue();
|
// 生成订单号
|
String orderNo = CodeGenerateUtils.generateOrderSn();
|
// 查询用户信息 用户openid
|
String openId = sysAppUser.getOpenId();
|
// 存储支付记录
|
sysPayRecordService.saveData(orderNo, userId, sysOtherConfig.getAiPrice(), 1);
|
// 调用支付方法
|
Map<String, Object> result = wxV3Pay.jsApi(orderNo, totalPrice, openId,"AI检测报告支付");
|
log.info("支付参数：{}", result);
|
return R.ok(result);
|
}
|
|
/**
|
* 微信v3支付-订单退款
|
*
|
* @return
|
*/
|
@ApiOperation("订单退款")
|
@PostMapping(value = "refund-order")
|
public AjaxResult<String> refundOrder() {
|
Map<String, Object> result = wxV3Pay.refund(new WxPaymentRefundModel());
|
log.info("退款结果：{}", result);
|
// 微信支付退款单号
|
String refund_id = result.get("refund_id").toString();
|
// 商户退款单号
|
String out_refund_no = result.get("out_refund_no").toString();
|
// 微信支付订单号
|
String transaction_id = result.get("transaction_id").toString();
|
// 商户订单号 tradeNo
|
String out_trade_no = result.get("out_trade_no").toString();
|
// 退款成功时间
|
String success_time = Objects.nonNull(result.get("success_time")) ? result.get("success_time").toString() : null;
|
// 退款状态 RefundEnum
|
String status = result.get("status").toString();
|
// TODO 退款业务处理
|
return AjaxResult.success();
|
}
|
/**
|
* 支付回调
|
*/
|
@PostMapping("pay/notify")
|
@ApiOperation("订单回调")
|
public void payNotify(HttpServletRequest request) throws Exception {
|
try {
|
Map<String, Object> params = wxV3Pay.verifyNotify(request, new TypeReference<Map<String, Object>>() {});
|
log.info("支付回调：{}", params);
|
// 商户订单号
|
String tradeNo = params.get("out_trade_no").toString();
|
// 交易状态
|
String trade_state = params.get("trade_state").toString();
|
// 交易状态描述
|
String trade_state_desc = params.get("trade_state_desc").toString();
|
// 微信支付订单号
|
String transaction_id = params.get("transaction_id").toString();
|
// 支付完成时间
|
// 时间不对的话，可以调用 WxTimeUtils.toRfc3339Date(success_time)转换一下
|
String success_time = params.get("success_time").toString();
|
// 附加数据
|
Integer attach = Integer.parseInt(params.get("attach").toString());
|
// 查询订单
|
TSysPayRecord sysPayRecord = sysPayRecordService.getOne(Wrappers.lambdaQuery(TSysPayRecord.class)
|
.eq(TSysPayRecord::getOrderNo, tradeNo).last("LIMIT 1"));
|
// 处理订单
|
if (trade_state.equals(TradeStateEnum.SUCCESS.name())) {
|
log.info("回调成功");
|
// 订单号查询订单
|
sysPayRecord.setPayState(2);
|
sysPayRecord.setPayTime(WxTimeUtils.dateToLocalDateTime(WxTimeUtils.toRfc3339Date(success_time)));
|
sysPayRecord.setTransactionId(transaction_id);
|
sysPayRecordService.updateById(sysPayRecord);
|
|
// 处理检测报告为可见
|
TSysInspection sysInspection = sysInspectionService.getById(sysPayRecord.getInspectionId());
|
sysInspection.setIsPay(1);
|
sysInspectionService.updateById(sysInspection);
|
|
wxV3Pay.ack();
|
}
|
wxV3Pay.ack();
|
} catch (Exception e) {
|
log.error("支付回调异常：{}", e, e);
|
wxV3Pay.ack(false, e.getMessage());
|
}
|
}
|
|
/**
|
* 支付回调成功后
|
*/
|
@PostMapping("pay/ack")
|
public void ack(){
|
try {
|
wxV3Pay.ack();
|
} catch (IOException e) {
|
throw new RuntimeException(e);
|
}
|
}
|
|
|
|
|
/**
|
* 退款回调
|
*/
|
@PostMapping("refund/notify")
|
public void refundNotify(HttpServletRequest request) throws IOException {
|
try {
|
Map<String, Object> params = wxV3Pay.verifyNotify(request, new TypeReference<Map<String, Object>>() {
|
});
|
// 商户订单号
|
String out_trade_no = params.get("out_trade_no").toString();
|
// 商户退款单号
|
String out_refund_no = params.get("out_refund_no").toString();
|
// 微信支付订单号
|
String transaction_id = params.get("transaction_id").toString();
|
// 微信支付退款单号
|
String refund_id = params.get("refund_id").toString();
|
// 退款状态
|
String tradeState = params.get("refund_status").toString();
|
// 退款成功时间
|
// 时间不对的话，可以调用 WxTimeUtils.toRfc3339Date(success_time)转换一下
|
String success_time = params.get("success_time").toString();
|
if (tradeState.equals(RefundEnum.SUCCESS.name())) {
|
wxV3Pay.ack();
|
} else {
|
wxV3Pay.ack(false, "不是成功的退款状态");
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
wxV3Pay.ack(false, e.getMessage());
|
}
|
}
|
|
}
|
