Javassm - item1-15 (用户下单 + 订单支付 2)

package com.sky.properties;

import lombok.Data;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.stereotype.Component;

@Component
@ConfigurationProperties(prefix = "sky.wechat")
@Data
public class WeChatProperties {
    private String appid; //小程序的appid
    private String secret; //小程序的秘钥
    private String mchid; //商户号
    private String mchSerialNo; //商户API证书的证书序列号
    private String privateKeyFilePath; //商户私钥文件
    private String apiV3Key; //证书解密的密钥
    private String weChatPayCertFilePath; //平台证书
    private String notifyUrl; //支付成功的回调地址
    private String refundNotifyUrl; //退款成功的回调地址
}

/**
* 订单支付
*
* @param ordersPaymentDTO
* @return
*/
@PutMapping("/payment")
@ApiOperation("订单支付")
public Result<OrderPaymentVO> payment(@RequestBody OrdersPaymentDTO ordersPaymentDTO) throws Exception {
    log.info("订单支付：{}", ordersPaymentDTO);
    OrderPaymentVO orderPaymentVO = orderService.payment(ordersPaymentDTO);
    log.info("生成预支付交易单：{}", orderPaymentVO);
    return Result.success(orderPaymentVO);
}

/**
 * 订单支付
 * @param ordersPaymentDTO
 * @return
 */
OrderPaymentVO payment(OrdersPaymentDTO ordersPaymentDTO) throws Exception;

@Autowired
private UserMapper userMapper;
@Autowired
private WeChatPayUtil weChatPayUtil;
/**
 * 订单支付
 *
 * @param ordersPaymentDTO
 * @return
 */
public OrderPaymentVO payment(OrdersPaymentDTO ordersPaymentDTO) throws Exception {
  // 当前登录用户id
  Long userId = BaseContext.getCurrentId();
  User user = userMapper.getById(userId);

  //调用微信支付接口，生成预支付交易单
  JSONObject jsonObject = weChatPayUtil.pay(
          ordersPaymentDTO.getOrderNumber(), //商户订单号
          new BigDecimal(0.01), //支付金额，单位 元
          "苍穹外卖订单", //商品描述
          user.getOpenid() //微信用户的openid
  );

  if (jsonObject.getString("code") != null && jsonObject.getString("code").equals("ORDERPAID")) {
      throw new OrderBusinessException("该订单已支付");
  }

  OrderPaymentVO vo = jsonObject.toJavaObject(OrderPaymentVO.class);
  vo.setPackageStr(jsonObject.getString("package"));

  return vo;
}

/**
 * 支付回调相关接口
 */
@RestController
@RequestMapping("/notify")
@Slf4j
public class PayNotifyController {
  @Autowired
  private OrderService orderService;
  @Autowired
  private WeChatProperties weChatProperties;

  /**
   * 支付成功回调
   *
   * @param request
   */
  @RequestMapping("/paySuccess")
  public void paySuccessNotify(HttpServletRequest request, HttpServletResponse response) throws Exception {
      //读取数据
      String body = readData(request);
      log.info("支付成功回调：{}", body);

      //数据解密
      String plainText = decryptData(body);
      log.info("解密后的文本：{}", plainText);

      JSONObject jsonObject = JSON.parseObject(plainText);
      String outTradeNo = jsonObject.getString("out_trade_no");//商户平台订单号
      String transactionId = jsonObject.getString("transaction_id");//微信支付交易号

      log.info("商户平台订单号：{}", outTradeNo);
      log.info("微信支付交易号：{}", transactionId);

      //业务处理，修改订单状态、来单提醒
      orderService.paySuccess(outTradeNo);

      //给微信响应
      responseToWeixin(response);
  }

  /**
   * 读取数据
   *
   * @param request
   * @return
   * @throws Exception
   */
  private String readData(HttpServletRequest request) throws Exception {
      BufferedReader reader = request.getReader();
      StringBuilder result = new StringBuilder();
      String line = null;
      while ((line = reader.readLine()) != null) {
          if (result.length() > 0) {
              result.append("\n");
          }
          result.append(line);
      }
      return result.toString();
  }

  /**
   * 数据解密
   *
   * @param body
   * @return
   * @throws Exception
   */
  private String decryptData(String body) throws Exception {
      JSONObject resultObject = JSON.parseObject(body);
      JSONObject resource = resultObject.getJSONObject("resource");
      String ciphertext = resource.getString("ciphertext");
      String nonce = resource.getString("nonce");
      String associatedData = resource.getString("associated_data");

      AesUtil aesUtil = new AesUtil(weChatProperties.getApiV3Key().getBytes(StandardCharsets.UTF_8));
      //密文解密
      String plainText = aesUtil.decryptToString(associatedData.getBytes(StandardCharsets.UTF_8),
              nonce.getBytes(StandardCharsets.UTF_8),
              ciphertext);

      return plainText;
  }

  /**
   * 给微信响应
   * @param response
   */
  private void responseToWeixin(HttpServletResponse response) throws Exception{
      response.setStatus(200);
      HashMap<Object, Object> map = new HashMap<>();
      map.put("code", "SUCCESS");
      map.put("message", "SUCCESS");
      response.setHeader("Content-type", ContentType.APPLICATION_JSON.toString());
      response.getOutputStream().write(JSONUtils.toJSONString(map).getBytes(StandardCharsets.UTF_8));
      response.flushBuffer();
  }
}

/**
 * 支付成功，修改订单状态
 * @param outTradeNo
 */
void paySuccess(String outTradeNo);

/**
 * 支付成功，修改订单状态
 *
 * @param outTradeNo
 */
public void paySuccess(String outTradeNo) {
  // 当前登录用户id
  Long userId = BaseContext.getCurrentId();

  // 根据订单号查询当前用户的订单
  Orders ordersDB = orderMapper.getByNumberAndUserId(outTradeNo, userId);

  // 根据订单id更新订单的状态、支付方式、支付状态、结账时间
  Orders orders = Orders.builder()
          .id(ordersDB.getId())
          .status(Orders.TO_BE_CONFIRMED)
          .payStatus(Orders.PAID)
          .checkoutTime(LocalDateTime.now())
          .build();

  orderMapper.update(orders);
}

/**
 * 根据订单号和用户id查询订单
 * @param orderNumber
 * @param userId
 */
@Select("select * from orders where number = #{orderNumber} and user_id= #{userId}")
Orders getByNumberAndUserId(String orderNumber, Long userId);

/**
 * 修改订单信息
 * @param orders
 */
void update(Orders orders);