spring——微信開發(fā)

蘇丹發(fā)布于2019-08-19 10:27 / 2045人閱讀

摘要：網(wǎng)頁授權(quán)登陸申請(qǐng)公眾號(hào)測(cè)試號(hào)也行申請(qǐng)測(cè)試號(hào)鏈接申請(qǐng)后得到和配置需要可以外網(wǎng)訪問的域名，沒有的話可以搞個(gè)內(nèi)網(wǎng)穿透開發(fā)使用第三方的進(jìn)行開發(fā)，避免重復(fù)造輪子，微信的開發(fā)文檔如下第三方流程構(gòu)造鏈接，獲取到，拿到配置接口調(diào)用跳轉(zhuǎn)到授權(quán)鏈接跳轉(zhuǎn)鏈接配置

網(wǎng)頁授權(quán)登陸 申請(qǐng)公眾號(hào)（測(cè)試號(hào)也行）

申請(qǐng)測(cè)試號(hào)鏈接

申請(qǐng)后得到appID和appsecret
配置：

需要可以外網(wǎng)訪問的域名，沒有的話可以搞個(gè)內(nèi)網(wǎng)穿透

開發(fā)

使用第三方的SDK進(jìn)行開發(fā)，避免重復(fù)造輪子，微信的開發(fā)文檔如下：

第三方SDK
流程：構(gòu)造鏈接，獲取到AccessToken，拿到openId

配置WxMpServiceImpl

@Component
public class WechatMpConfig {
    @Autowired
    private WechatAccountConfig wechatAccountConfig;

    @Bean
    public WxMpService wxMpService() {
        WxMpService wxMpService = new WxMpServiceImpl();
        wxMpService.setWxMpConfigStorage(wxMpConfigStorage());
        return wxMpService;
    }

    @Bean
    public WxMpConfigStorage wxMpConfigStorage() {
        WxMpInMemoryConfigStorage wxMpConfigStorage = new WxMpInMemoryConfigStorage();
        wxMpConfigStorage.setAppId(wechatAccountConfig.getMpAppId());
        wxMpConfigStorage.setSecret(wechatAccountConfig.getMpAppSecret());
        return wxMpConfigStorage;
    }
}

接口調(diào)用

    //跳轉(zhuǎn)到授權(quán)鏈接
     @GetMapping("/authorize")
        public String authorize( @ApiParam(name = "returnUrl", value = "跳轉(zhuǎn)鏈接")@RequestParam("returnUrl") String returnUrl) {
            //1. 配置
            //2. 調(diào)用方法
            String url = projectUrlConfig.getWechatMpAuthorize() + "/wechat/userInfo";
            String redirectUrl = wxMpService.oauth2buildAuthorizationUrl(url, WxConsts.OAuth2Scope.SNSAPI_BASE, URLEncoder.encode(returnUrl));
            return "redirect:" + redirectUrl;
    }
    //確定授權(quán)后的處理方法
    @GetMapping("/userInfo")
    public String userInfo(@ApiParam(name = "code", value = "code")@RequestParam("returnUrl") String code,
                           @ApiParam(name = "returnUrl", value = "跳轉(zhuǎn)鏈接")@RequestParam("returnUrl") String returnUrl ){
        WxMpOAuth2AccessToken wxMpOAuth2AccessToken = new WxMpOAuth2AccessToken();
        try {
            wxMpOAuth2AccessToken = wxMpService.oauth2getAccessToken(code);
        } catch (WxErrorException e) {
            log.error("[微信頁面授權(quán)失敗]{}",e);
            throw new SellException(ResultEnum.WECHAT_MP_ERROR.getCode(),e.getError().getErrorMsg());
        }
        String openId = wxMpOAuth2AccessToken.getOpenId();

        return "redirect:" + returnUrl + "openId = " + openId;
    }

第三方網(wǎng)頁掃碼登陸 開發(fā)前準(zhǔn)備

微信開放平臺(tái)，需要自己去申請(qǐng)一個(gè)應(yīng)用，審核通過后得到

開發(fā)

生成二維碼，拿到openId
第三方SDK

配置WxMpServiceImpl

@Component
public class WechatOpenConfig {
    @Autowired
    private WechatAccountConfig accountConfig;

    @Bean
    public WxMpService wxOpenService() {
        WxMpService wxOpenService = new WxMpServiceImpl();
        wxOpenService.setWxMpConfigStorage(wxOpenConfigStorage());
        return wxOpenService;
    }

    @Bean
    public WxMpConfigStorage wxOpenConfigStorage() {
        WxMpInMemoryConfigStorage wxMpInMemoryConfigStorage = new WxMpInMemoryConfigStorage();
        wxMpInMemoryConfigStorage.setAppId(accountConfig.getOpenAppId());
        wxMpInMemoryConfigStorage.setSecret(accountConfig.getOpenAppSecret());
        return wxMpInMemoryConfigStorage;
    }

2. 接口調(diào)用

    //跳轉(zhuǎn)二維碼頁面，生成二維碼
    @GetMapping("/qrAuthorize")
    public String qrAuthorize(@RequestParam("returnUrl") String returnUrl) {
        String url = projectUrlConfig.getWechatOpenAuthorize() + "/sell/wechat/qrUserInfo";
        String redirectUrl = wxOpenService.buildQrConnectUrl(url, WxConsts.QrConnectScope.SNSAPI_LOGIN, URLEncoder.encode(returnUrl));
        return "redirect:" + redirectUrl;
    }

    //掃碼后邏輯登陸
    @GetMapping("/qrUserInfo")
    public String qrUserInfo(@RequestParam("code") String code,
                             @RequestParam("state") String returnUrl) {
        WxMpOAuth2AccessToken wxMpOAuth2AccessToken = new WxMpOAuth2AccessToken();
        try {
            wxMpOAuth2AccessToken = wxOpenService.oauth2getAccessToken(code);
        } catch (WxErrorException e) {
            log.error("【微信網(wǎng)頁授權(quán)】{}", e);
            throw new SellException(ResultEnum.WECHAT_MP_ERROR.getCode(), e.getError().getErrorMsg());
        }
        log.info("wxMpOAuth2AccessToken={}", wxMpOAuth2AccessToken);
        String openId = wxMpOAuth2AccessToken.getOpenId();

        return "redirect:" + returnUrl + "?openid=" + openId;
    }
```

微信支付

微信支付SDK，這個(gè)SDK是上方的SDK對(duì)支付的進(jìn)一步封裝
微信支付官方開發(fā)文檔
需要申請(qǐng)一個(gè)具有商家資質(zhì)的賬號(hào)，等到mchId和mchKey

配置BestPayServiceImpl

@Component
public class WechatPayConfig {

    @Autowired
    private WechatAccountConfig wechatAccountConfig;

    @Bean
    public BestPayServiceImpl bestPayService(){
        BestPayServiceImpl bestPayService = new BestPayServiceImpl();
        bestPayService.setWxPayH5Config(wxPayH5Config());
        return bestPayService;
    }

    @Bean
    public WxPayH5Config wxPayH5Config(){
        WxPayH5Config wxPayH5Config = new WxPayH5Config();
        wxPayH5Config.setAppId(wechatAccountConfig.getMpAppId());
        wxPayH5Config.setAppSecret(wechatAccountConfig.getMpAppSecret());
        wxPayH5Config.setMchId(wechatAccountConfig.getMchId());
        wxPayH5Config.setMchKey(wechatAccountConfig.getMchKey());
        wxPayH5Config.setKeyPath(wechatAccountConfig.getKeyPath());
        wxPayH5Config.setNotifyUrl(wechatAccountConfig.getNotifyUrl());
        return wxPayH5Config;
    }
}

編寫Service

@Service
@Slf4j
public class PayServiceImpl implements PayService {

    private static final String ORDER_NAME = "微信點(diǎn)餐訂單";

    @Autowired
    private BestPayServiceImpl bestPayService;

    @Autowired
    private OrderService orderService;

    //發(fā)起支付
    @Override
    public PayResponse create(OrderDTO orderDTO) {
        PayRequest payRequest = new PayRequest();
        payRequest.setOpenid(orderDTO.getBuyerOpenid());
        payRequest.setOrderAmount(orderDTO.getOrderAmount().doubleValue());
        payRequest.setOrderId(orderDTO.getOrderId());
        payRequest.setOrderName(ORDER_NAME);
        payRequest.setPayTypeEnum(BestPayTypeEnum.WXPAY_H5);
        log.info("【微信支付】發(fā)起支付, request={}", JsonUtil.toJson(payRequest));

        PayResponse payResponse = bestPayService.pay(payRequest);
        log.info("【微信支付】發(fā)起支付, response={}", JsonUtil.toJson(payResponse));
        return payResponse;
    }

    //支付后微信異步通知，告之微信支付結(jié)果
    @Override
    public PayResponse notify(String notifyData) {
        PayResponse payResponse = bestPayService.asyncNotify(notifyData);
        log.info("【微信支付】異步通知, payResponse={}", JsonUtil.toJson(payResponse));

        //查詢訂單
        OrderDTO orderDTO = orderService.findOne(payResponse.getOrderId());
        //判斷訂單是否存在
        if (orderDTO == null) {
            log.error("【微信支付】異步通知, 訂單不存在, orderId={}", payResponse.getOrderId());
            throw new SellException(ResultEnum.ORDER_NOT_EXIST);
        }

        //判斷金額是否一致(0.10   0.1)
        if (!MathUtil.equals(payResponse.getOrderAmount(), orderDTO.getOrderAmount().doubleValue())) {
            log.error("【微信支付】異步通知, 訂單金額不一致, orderId={}, 微信通知金額={}, 系統(tǒng)金額={}",
                    payResponse.getOrderId(),
                    payResponse.getOrderAmount(),
                    orderDTO.getOrderAmount());
            throw new SellException(ResultEnum.WXPAY_NOTIFY_MONEY_VERIFY_ERROR);
        }

        //修改訂單的支付狀態(tài)
        orderService.paid(orderDTO);
        return payResponse;
    }

    //退款
    @Override
    public RefundResponse refund(OrderDTO orderDTO) {
        RefundRequest refundRequest = new RefundRequest();
        refundRequest.setOrderId(orderDTO.getOrderId());
        refundRequest.setOrderAmount(orderDTO.getOrderAmount().doubleValue());
        refundRequest.setPayTypeEnum(BestPayTypeEnum.WXPAY_H5);
        log.info("【微信退款】request={}", JsonUtil.toJson(refundRequest));
        RefundResponse refundResponse = bestPayService.refund(refundRequest);
        return refundResponse;
    }
}

微信模版消息通知

在公眾號(hào)管理設(shè)置好消息模版
編寫service

   @Override
    public void orderStatus(OrderDTO orderDTO) {
        WxMpTemplateMessage templateMessage = new WxMpTemplateMessage();
        templateMessage.setTemplateId(wechatAccountConfig.getTemplateId().get("orderStatus"));
        templateMessage.setToUser(orderDTO.getBuyerOpenid());
        List data = Arrays.asList(
                new WxMpTemplateData("first","111"),
                new WxMpTemplateData("keyword1", "微信點(diǎn)餐"),
                new WxMpTemplateData("keyword2", "18868812345"),
                new WxMpTemplateData("keyword3", orderDTO.getOrderId()),
                new WxMpTemplateData("keyword4", orderDTO.getOrderStatusEnum().getMessage()),
                new WxMpTemplateData("keyword5", "￥" + orderDTO.getOrderAmount()),
                new WxMpTemplateData("remark", "歡迎再次光臨！")
        );
        try{
            wxMpService.getTemplateMsgService().sendTemplateMsg(templateMessage);
        }catch (WxErrorException e){
            log.error("【微信模版消息】發(fā)送失敗");
        }
    }
}