@Configuration
@Data
public class WxOpenConfig {
    /**
     * 设置云视讯的appid
     */
    @Value("${wx.open.config.appid}")
    private String appid;
    
    /**
     * 设置云视讯的app secret
     */
    @Value("${wx.open.config.secret}")
    private String secret;
    
    @Bean
    public WxMpService wxMpService() {
        WxMpService service = new WxMpServiceImpl();
        WxMpInMemoryConfigStorage configStorage = new WxMpInMemoryConfigStorage();
        configStorage.setAppId(appid);
        configStorage.setSecret(secret);
        service.setWxMpConfigStorage(configStorage);
        return service;
    }
}

@RestController
public class WeChatController {

    @Autowired
    private WeChatService weChatService;

    /**
     * 获取微信登陆二维码地址
     * @return
     */
    @GetMapping("/getQRCodeUrl")
    public RestResult getQRCodeUrl() {
        return RestResultGenerator.createOkResult(weChatService.getQRCodeUrl());
    }
    
    // 省略
}

@Service
@Slf4j
public class WeChatServiceImpl implements WeChatService {

    @Autowired
    private WxMpService wxMpService;

    @Value("${wx.open.config.redirectUrl}")
    private String wxRedirectUrl;

    @Value("${wx.open.config.csrfKey}")
    private String CSRF_KEY;

    @Override
    public String getQRCodeUrl() {
        // 生成 state 参数，用于防止 csrf
        String date = DateUtil.format(new Date(), "yyyyMMdd");
        String state = MD5Utils.generate(CSRF_KEY + date);
        return wxMpService.buildQrConnectUrl(wxRedirectUrl, Constant.WeChatLogin.SCOPE, state);
    }
    
    // 省略
}

/**
     * 微信扫码回调处理
     * 使用 @Valid + BindingResult 进行 controller 参数校验，实现断路器。大家可以根据自己的喜好来，不必一定要跟我这样做
     * @param input
     * @param bindingResult
     * @return
     */
    @GetMapping("/wxCallBack")
    public String wxCallBack(@RequestBody @Valid LoginProtocol.WeChatQrCodeCallBack.Input input, BindingResult bindingResult) {

        if (bindingResult.hasErrors()) {
            return "failedPage";
        }

        if (weChatService.wxCallBack(input)) {
            return "successPage";
        } else {
            return "failedPage";
        }
    }

@Override
public Boolean wxCallBack(LoginProtocol.WeChatQrCodeCallBack.Input input) {
    
    String code = input.getCode();
    String state = input.getState();
    String openid = null;
    String token = null;
    if (code == null) {
        return false;
    }
    if (code != null && state != null) {
        // 验证 state,防止跨站请求伪造攻击
        String date = DateUtil.format(new Date(), "yyyyMMdd");
        Boolean isNotCsrf = MD5Utils.verify(CSRF_KEY + date, state);
        if (!isNotCsrf) {
            return false;
        }
        // 获取 openid
        try {
            WxMpOAuth2AccessToken accessToken =wxMpService.oauth2getAccessToken(code);
            openid = accessToken.getOpenId();
            token = accessToken.getAccessToken();
            // 拿到 openid 后做自己的业务, 获取用 token 进一步获取用户信息
            // 用 access_token 获取用户的信息
            WxMpUser user = wxMpService.oauth2getUserInfo(accessToken, null);

        } catch (WxErrorException e) {
            log.error(e.getMessage(), e);
        }

        return true;
    }
    return false;
}