package org.springblade.modules.pay.controller;
|
|
import com.google.gson.Gson;
|
import com.wechat.pay.contrib.apache.httpclient.auth.ScheduledUpdateCertificatesVerifier;
|
import io.swagger.annotations.Api;
|
import io.swagger.annotations.ApiOperation;
|
import lombok.AllArgsConstructor;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springblade.common.config.WxPayConfig;
|
import org.springblade.common.utils.HttpUtils;
|
import org.springblade.common.utils.WechatPay2ValidatorForRequest;
|
import org.springblade.core.boot.ctrl.BladeController;
|
import org.springblade.core.tool.api.R;
|
import org.springblade.modules.pay.entity.WxPayInfo;
|
import org.springblade.modules.pay.service.IWxPayService;
|
import org.springframework.web.bind.annotation.*;
|
|
import javax.servlet.http.HttpServletRequest;
|
import javax.servlet.http.HttpServletResponse;
|
import java.util.HashMap;
|
import java.util.Map;
|
|
@RestController
|
@AllArgsConstructor
|
@RequestMapping("/wxpay")
|
@Api(value = "微信支付接口", tags = "微信支付接口")
|
public class WxPayController extends BladeController {
|
|
private static final Logger logger = LoggerFactory.getLogger(WxPayController.class);
|
|
private IWxPayService wxPayService;
|
|
@PostMapping("/save")
|
public R save(@RequestBody WxPayInfo wxPayInfo) {
|
return R.status(wxPayService.save(wxPayInfo));
|
}
|
|
@PostMapping("/update")
|
public R update(@RequestBody WxPayInfo wxPayInfo) {
|
return R.status(wxPayService.updateById(wxPayInfo));
|
}
|
|
@PostMapping("saveOrUpdate")
|
public R saveOrUpdate(@RequestBody WxPayInfo wxPayInfo) {
|
return R.status(wxPayService.saveOrUpdate(wxPayInfo));
|
}
|
|
/**
|
* 获取openId
|
*
|
* @param code
|
* @return
|
*/
|
@PostMapping("getOpenId")
|
public R getOpenId(String code) {
|
return R.data(wxPayService.getOpenId(code));
|
}
|
|
/**
|
* jsapi下单
|
*
|
* @param productId
|
* @return
|
* @throws Exception
|
*/
|
@ApiOperation("调用jsapi统一下单API")
|
@GetMapping("/jsapiPay")
|
public R jsapiPay(@RequestParam("productId") Long productId) throws Exception {
|
|
logger.info("发起支付请求 v3");
|
|
//返回支付二维码连接和订单号
|
Map<String, String> map = wxPayService.jsapiPay(productId);
|
|
return R.data(map);
|
}
|
|
/**
|
* 支付通知
|
* 微信支付通过支付通知接口将用户支付成功消息通知给商户
|
*/
|
@ApiOperation("支付通知")
|
@PostMapping("/native/notify")
|
public String nativeNotify(HttpServletRequest request, HttpServletResponse response) {
|
|
Gson gson = new Gson();
|
Map<String, String> map = new HashMap<>();//应答对象
|
|
try {
|
|
//处理通知参数
|
String body = HttpUtils.readData(request);
|
Map<String, Object> bodyMap = gson.fromJson(body, HashMap.class);
|
String requestId = (String) bodyMap.get("id");
|
logger.info("支付通知的id ===> {}", requestId);
|
logger.info("支付通知的完整数据 ===> {}", body);
|
//int a = 9 / 0;
|
ScheduledUpdateCertificatesVerifier verifier = new WxPayConfig().getVerifier("111", "111", "111", "111");
|
//签名的验证
|
WechatPay2ValidatorForRequest wechatPay2ValidatorForRequest
|
= new WechatPay2ValidatorForRequest(verifier, requestId, body);
|
if (!wechatPay2ValidatorForRequest.validate(request)) {
|
logger.error("通知验签失败");
|
//失败应答
|
response.setStatus(500);
|
map.put("code", "ERROR");
|
map.put("message", "通知验签失败");
|
return gson.toJson(map);
|
}
|
logger.info("通知验签成功");
|
|
//处理订单
|
wxPayService.processOrder(bodyMap);
|
|
//应答超时
|
//模拟接收微信端的重复通知
|
// TimeUnit.SECONDS.sleep(5);
|
|
//成功应答
|
response.setStatus(200);
|
map.put("code", "SUCCESS");
|
map.put("message", "成功");
|
return gson.toJson(map);
|
|
} catch (Exception e) {
|
e.printStackTrace();
|
//失败应答
|
response.setStatus(500);
|
map.put("code", "ERROR");
|
map.put("message", "失败");
|
return gson.toJson(map);
|
}
|
|
}
|
|
|
}
|
