微信开发 Java SDK

import static me.chanjar.weixin.common.api.WxConsts.XmlMsgType.EVENT;


import java.util.HashMap;
import java.util.Map;


import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;


import com.gdhz.config.wx.WxmpConfig;
import com.gdhz.wx.card.config.WechatPayConfig;
import com.gdhz.wx.handler.KFSessionHandler;
import com.gdhz.wx.handler.LocationHandler;
import com.gdhz.wx.handler.MaMsgHandler;
import com.gdhz.wx.handler.MenuHandler;
import com.gdhz.wx.handler.MsgHandler;
import com.gdhz.wx.utils.WechatPayHttpClientUtil;
import com.github.binarywang.wxpay.config.WxPayConfig;
import com.github.binarywang.wxpay.constant.WxPayConstants;
import com.github.binarywang.wxpay.service.WxPayService;
import com.github.binarywang.wxpay.service.impl.WxPayServiceImpl;


import cn.binarywang.wx.miniapp.api.WxMaService;
import cn.binarywang.wx.miniapp.api.impl.WxMaServiceImpl;
import cn.binarywang.wx.miniapp.config.WxMaConfig;
import cn.binarywang.wx.miniapp.config.impl.WxMaDefaultConfigImpl;
import cn.binarywang.wx.miniapp.message.WxMaMessageRouter;
import lombok.AllArgsConstructor;
import me.chanjar.weixin.common.api.WxConsts.EventType;
import me.chanjar.weixin.common.api.WxConsts.XmlMsgType;
import me.chanjar.weixin.mp.api.WxMpMessageRouter;
import me.chanjar.weixin.mp.api.WxMpService;
import me.chanjar.weixin.mp.api.impl.WxMpServiceImpl;
import me.chanjar.weixin.mp.config.WxMpConfigStorage;
import me.chanjar.weixin.mp.config.impl.WxMpDefaultConfigImpl;


@AllArgsConstructor
@Configuration
public class WXConfiguration {
  private final LocationHandler locationHandler;
  private final MsgHandler msgHandler;
  private final KFSessionHandler kfHandler;
  private final MenuHandler menuHandler;
  private final WxmpConfig properties;
  private final MaMsgHandler maMsgHandler;


  // 微信支付
  @Bean
  public WxPayService wxPayService() {


    WxPayService wxPayService = new WxPayServiceImpl();
    WxPayConfig payConfig = new WxPayConfig();
    payConfig.setAppId(WechatPayConfig.appid);
    payConfig.setApiV3HttpClient(WechatPayHttpClientUtil.getCloseableHttpClient());
    payConfig.setApiV3Key(WechatPayConfig.privateKey);
    payConfig.setMchId(WechatPayConfig.mchId);
    payConfig.setMchKey(WechatPayConfig.privateKey);
    payConfig.setSignType(WxPayConstants.SignType.HMAC_SHA256);
    payConfig.setCertSerialNo(WechatPayConfig.mchSerialNo);
    // payConfig.setKeyPath("classpath:apiclient_cert.p12");
    // payConfig.setPrivateCertPath("classpath:apiclient_cert.pem");
    payConfig.setPrivateKeyPath("classpath:apiclient_key.pem");
    wxPayService.setConfig(payConfig);
    
    return wxPayService;


  }


  // 微信公众号
  @Bean
  public WxMpService wxMpService() {
    final WxmpConfig configs = this.properties;
    if (configs == null) {
      throw new RuntimeException("配置文件失败");
    }


    WxMpService service = new WxMpServiceImpl();


    Map<String, WxMpConfigStorage> configStorages = new HashMap<String, WxMpConfigStorage>();
    WxMpDefaultConfigImpl configStorage = new WxMpDefaultConfigImpl();
    configStorage.setAppId(configs.getOffiAppid());
    configStorage.setSecret(configs.getOffiSecret());
    configStorages.put(configs.getOffiAppid(), configStorage);
    service.setMultiConfigStorages(configStorages);


    return service;
  }


  // 微信小程序
  @Bean
  public WxMaService wxMaService() {
    final WxmpConfig configs = this.properties;
    if (configs == null) {
      throw new RuntimeException("配置文件失败");
    }


    WxMaService service = new WxMaServiceImpl();


    Map<String, WxMaConfig> configStorages = new HashMap<String, WxMaConfig>();
    WxMaDefaultConfigImpl configStorage = new WxMaDefaultConfigImpl();
    configStorage.setAppid(configs.getMpAppid());
    configStorage.setSecret(configs.getMpSecret());
    configStorages.put(configs.getMpAppid(), configStorage);
    service.setWxMaConfig(configStorage);


    return service;
  }


  @Bean
  public WxMpMessageRouter messageRouter(WxMpService wxMpService) {
    final WxMpMessageRouter newRouter = new WxMpMessageRouter(wxMpService);


    // 上报地理位置事件
    newRouter.rule().async(false).msgType(EVENT).event(EventType.LOCATION).handler(this.locationHandler).end();


    // 接收地理位置消息
    newRouter.rule().async(false).msgType(XmlMsgType.LOCATION).handler(this.locationHandler).end();
    // 点击菜单连接事件
    newRouter.rule().async(false).msgType(EVENT).event(EventType.CLICK).handler(this.menuHandler).end();


    // 接入客服
    newRouter.rule().async(false).msgType(XmlMsgType.TRANSFER_CUSTOMER_SERVICE).handler(this.kfHandler).end();


    // 默认
    newRouter.rule().async(false).handler(this.msgHandler).end();


    return newRouter;
  }


  /**
   * 小程序客服
   * 
   * @param wxMaService
   * @return
   */
  @Bean
  public WxMaMessageRouter maMessageRouter(WxMaService wxMaService) {
    final WxMaMessageRouter newRouter = new WxMaMessageRouter(wxMaService);


    // 接入客服 默认
    newRouter.rule().async(false).handler(this.maMsgHandler).end();


    return newRouter;
  }


}

import java.awt.image.RenderedImage;
import java.io.File;
import java.io.IOException;
import java.util.Base64;


import javax.imageio.ImageIO;
import javax.servlet.http.HttpServletResponse;


import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import cn.binarywang.wx.miniapp.api.WxMaService;
import lombok.extern.log4j.Log4j2;
import me.chanjar.weixin.common.error.WxErrorException;
//小程序服务
@Log4j2
@RestController
@RequestMapping("/wx-ma")
public class WXMaController {
  // 小程序
  @Autowired
  private WxMaService wxMaService;


  // 小程序二维码
  @GetMapping("/getCode/{code}")
  public void getCode(@PathVariable("code") String code, boolean isBase64, HttpServletResponse response) {
    response.setDateHeader("Expires", 0);
    response.setHeader("Cache-Control", "no-store, no-cache, must-revalidate");
    response.addHeader("Cache-Control", "post-check=0, pre-check=0");
    response.setHeader("Pragma", "no-cache");


    try {


      if (!StringUtils.isEmpty(code) && code.length() <= 32) {
        File maQrcodeFile = wxMaService.getQrcodeService().createWxaCodeUnlimit(code, null);
        if (maQrcodeFile != null) {
          RenderedImage bgImage = ImageIO.read(maQrcodeFile);
          if (isBase64) {
            ImageIO.write(bgImage, "jpg", Base64.getEncoder().wrap(response.getOutputStream()));
          } else {
            ImageIO.write(bgImage, "jpg", response.getOutputStream());
          }
        }
      }
    } catch (WxErrorException e) {
      log.error("小程序创建二维码失败:{}", e.getMessage());
    } catch (IOException e) {
      log.error("文件操作失败: {}", e.getMessage());
    }
  }
 }