Spring Boot中的微信支付全过程(小程序)

@ApiOperation(value = "统一下单接口")
@RequestMapping(value = "/unifiedOrder",method = RequestMethod.POST)
public AjaxResult unifiedOrder(HttpServletRequest req,@RequestBody){
    //校验小程序（微信）用户登录
    //查询数据库订单信息（状态）
    //只有未支付订单才能发起支付
    //0元购买不调支付
    /**
     * 设置商户、小程序相关请求参数
     * */
    //获取小程序的appId
    String appId = WxMaUtil.getAppId(request);
    WxPayUnifiedOrderRequest wxPayUnifiedOrderRequest = new WxPayUnifiedOrderRequest();
    wxPayUnifiedOrderRequest.setAppid(appId);
    //商品名称
    String body = sysOrdersCourse.getCourseName();
    body =body.length() > 40 ? body.substring(0,39) : body;
    wxPayUnifiedOrderRequest.setBody(body);
    //订单编号
    wxPayUnifiedOrderRequest.setOutTradeNo(sysOrders.getOrderNo());
    //订单金额
    wxPayUnifiedOrderRequest.setTotalFee(sysOrders.getOrderAmount().multiply(new             BigDecimal(100)).intValue());
    //交易类型
    wxPayUnifiedOrderRequest.setTradeType("JSAPI");
    //支付回调地址
         wxPayUnifiedOrderRequest.setNotifyUrl(env.getProperty("notify-host")+"/wx/api/order/notify-order");
    wxPayUnifiedOrderRequest.setSpbillCreateIp("127.0.0.1");
    //用户在当前小程序中的唯一标识
    wxPayUnifiedOrderRequest.setOpenid(wxUser.getOpenId());
    //调用微信服务类
    WxPayService wxPayService = WxPayConfiguration.getPayService();
    return AjaxResult.success(JSONUtils.parse(wxPayService.createOrder(wxPayUnifiedOrderRequest)));
}

@ApiOperation(value = "创建订单")
    @RequestMapping(value = "/create",method = RequestMethod.POST)
    public AjaxResult create(@RequestBody WxOrderRequest wxOrderRequest){
        //微信用户信息
        //判断是否购买过相同商品，若已经购买过，则无法创建新的订单
        //满足条件后将数据插入数据库
         WxOrderResponse wxOrderResponse = orderService.add(wxOrderRequest);
        //如果新增失败，则返回提示
         if (wxOrderResponse == null){
             return AjaxResult.error("订单创建失败");
         }
         return AjaxResult.success(wxOrderResponse);
     }

@ApiOperation(value = "取消订单")
@RequestMapping(value = "/cancel/{orderId}",method = RequestMethod.PUT)
    public AjaxResult cancel(@PathVariable Long orderId){
        //判断订单是否存在
        SysOrders sysOrders = sysOrdersService.getById(orderId);
        if(sysOrders==null){
            return AjaxResult.error("订单不存在");
        }
        //只有未支付的订单能取消
        if(!CommonConstants.NO.equals(sysOrders.getIsPay())){
            return AjaxResult.error(MyReturnCode.ERR_70001.getCode(), MyReturnCode.ERR_70001.getMsg());
        }
        sysOrdersService.orderCancel(sysOrders);
        return AjaxResult.success();
    }

@ApiOperation(value = "订单详情")
@RequestMapping(value = "/myOrderDetail/{orderId}",method = RequestMethod.GET)
@ApiImplicitParams({@ApiImplicitParam(name = "orderId", value = "订单Id")})
     public AjaxResult myOrderDetail(@PathVariable Long orderId){
     //从数据库获取详情参数
     SysOrderDetailResponse detailResponse = sysOrdersService.getDetail(orderId);
     return AjaxResult.success(detailResponse);
     }

 /**
     * 订单详情页面参数处理
     * @param orderId
     * @return sysOrderDetailResponse
     */
    @Override
    public SysOrderDetailResponse getDetail(Long orderId) {
        SysOrderDetailResponse sysOrderDetailResponse =  orderMapper.getDetail(orderId);
        //对页面的手机号做处理
        String phoneNum = sysOrderDetailResponse.getMobile();
        sysOrderDetailResponse.setMobile(phoneNum.substring(0,3) + "****" +       phoneNum.substring(7,phoneNum.length()));
        //根据订单状态不同，显示不同的数据
        //计算剩余待支付时间并展示
        return sysOrderDetailResponse;
    }

@ApiOperation("支付回调")
@RequestMapping(value = "notify-order", method = RequestMethod.POST)
    public String notifyOrder(@RequestBody String xmlData) throws WxPayException {
        log.info("支付回调：" + xmlData);
        //微信支付服务
        WxPayService wxPayService = WxPayConfiguration.getPayService();
        WxPayOrderNotifyResult notifyResult = wxPayService.parseOrderNotifyResult(xmlData);
        log.info("支付回调解析结果" + notifyResult);
        //对创建的订单进行支付
        SysOrders sysOrders = orderService.getOne(notifyResult.getOutTradeNo());
        if (sysOrders != null) {
            if (sysOrders.getOrderAmount().multiply(new BigDecimal(100)).intValue() == notifyResult.getTotalFee()){
                 String timeEnd = notifyResult.getTimeEnd();
                 LocalDateTime paymentTime = LocalDateTimeUtils.parse(timeEnd);
                 //支付时间
                 sysOrders.setPaymentTime(paymentTime);
                 sysOrders.setOrderAmount(sysOrders.getOrderAmount());
                 //微信订单编号
                 sysOrders.setTransactionId(notifyResult.getTransactionId());
                 //更新数据库
                 orderService.notifyOrder(sysOrders);
                 log.info("支付回调成功通知：" + sysOrders.getOrderNo());
                 return WxPayNotifyResponse.success("支付成功");
            } else {
                 return WxPayNotifyResponse.fail("付款金额与订单金额不符");
            }
        } else {
            return WxPayNotifyResponse.fail("无此订单");
        }
    }

@Override
    @Transactional(rollbackFor = Exception.class)
    public void notifyOrder(SysOrders sysOrders) {
       //只有未支付订单能操作，即is_pay字段为0的订单
       if(CommonConstants.NO.equals(sysOrders.getIsPay())) {
       //更新订单支付状态
       sysOrders.setIsPay(CommonConstants.YES);
       sysOrders.setStatus(OrderInfoEnum.STATUS_1.getValue());
       sysOrdersMapper.updateById(sysOrders);
       //更新商品表状态
       //更新订单生命周期表
       }
    }