SpringBoot集成企业微信开发的实现

<dependencies>
  <dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
  </dependency>
</dependencies>

wechat:
  corp-id: 'your-corp-id'
  agent-id: 'your-agent-id'
  secret: 'your-secret'
  token: 'your-token'
  encoding-aes-key: 'your-encoding-aes-key'

<dependency>
  <groupId>com.github.binarywang</groupId>
  <artifactId>weixin-java-cp</artifactId>
  <version>latest-release-version</version>
</dependency>

@Configuration
public class WxCpConfiguration {
  @Autowired
  private WeChatProperties weChatProperties;
  @Bean
  public WxCpService wxCpService() {
    WxCpInMemoryConfigStorage configStorage = new WxCpInMemoryConfigStorage();
    configStorage.setCorpId(weChatProperties.getCorpId());
    configStorage.setAgentId(weChatProperties.getAgentId());
    configStorage.setCorpSecret(weChatProperties.getSecret());
    configStorage.setToken(weChatProperties.getToken());
    configStorage.setAesKey(weChatProperties.getEncodingAesKey());
    WxCpService wxCpService = new WxCpServiceImpl();
    wxCpService.setWxCpConfigStorage(configStorage);
    return wxCpService;
  }
}

@Service
public class MyTextMessageHandler implements WxCpMessageHandler {
  @Override
  public WxCpXmlOutMessage handle(WxCpXmlMessage wxMessage, Map<String, Object> context, WxCpService wxCpService) {
    String content = "收到文本消息：" + wxMessage.getContent();
    return WxCpXmlOutMessage.TEXT().content(content).fromUser(wxMessage.getToUserName())
        .toUser(wxMessage.getFromUserName()).build();
  }
}

@RestController
@RequestMapping("/wechat/cp")
public class WxCpController {
  @Autowired
  private WxCpService wxCpService;
  @Autowired
  private MyTextMessageHandler myTextMessageHandler;
  @GetMapping(produces = "text/plain;charset=utf-8")
  public String auth(@RequestParam(name = "msg_signature") String signature,
                     @RequestParam(name = "timestamp") String timestamp,
                     @RequestParam(name = "nonce") String nonce,
                     @RequestParam(name = "echostr") String echostr) {
    try {
      if (wxCpService.checkSignature(timestamp, nonce, signature, echostr)) {
        return echostr;
      }
    } catch (Exception e) {
      e.printStackTrace();
    }
    return "非法请求";
  }
  @PostMapping(produces = "application/xml; charset=UTF-8")
  public String post(@RequestBody String requestBody,
                     @RequestParam("msg_signature") String signature,
                     @RequestParam("timestamp") String timestamp,
                     @RequestParam("nonce") String nonce) {
    try {
      WxCpXmlMessage inMessage = WxCpXmlMessage.fromEncryptedXml(requestBody, wxCpService.getWxCpConfigStorage(),
          timestamp, nonce, signature);
      WxCpXmlOutMessage outMessage = wxCpService.route(inMessage);
      if (outMessage != null) {
        return outMessage.toEncryptedXml(wxCpService.getWxCpConfigStorage());
      }
    } catch (Exception e) {
      e.printStackTrace();
    }
    return "";
  }
}

@Bean
public WxCpMessageRouter wxCpMessageRouter(WxCpService wxCpService, MyTextMessageHandler myTextMessageHandler) {
  WxCpMessageRouter wxCpMessageRouter = new WxCpMessageRouter(wxCpService);
  wxCpMessageRouter.rule().async(false).msgType(WxConsts.XmlMsgType.TEXT).handler(myTextMessageHandler).end();
  return wxCpMessageRouter;
}