钉钉云第三方企业H5微应用开发（二）

准备工作上一篇已经完成，接下来开始开发后台代码。

在创建微应用的时候，推送类型有「HTTP」和「钉钉云」两种方式，「HTTP」这种方式只能在测试的时候使用，到生产环境只能使用「钉钉云」的服务。

搭建微应用服务端

首先创建一个springboot工程

如上图标示，服务端要用到这些参数。

钉钉回调地址

application.yml

程序启动的配置文件如下：

server:
  port: 8080
  servlet:
    context-path: /dingtalk

spring:
  datasource:
    driver-class-name: com.mysql.cj.jdbc.Driver
    type: com.zaxxer.hikari.HikariDataSource
    hikari:
      maximum-pool-size: 500
      minimum-idle: 1
      idle-timeout: 60000
    url: jdbc:mysql://127.0.0.1:3306/ding_cloud_push?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true&failOverReadOnly=false&serverTimezone=GMT%2B8
    username: root
    password: root
  redis:
    database: 0
    host: 127.0.0.1
    port: 6379
    password:
    timeout: 5000
    jedis:
      pool:
        max-active: 8
        max-wait: 1
        max-idle: 8
        min-idle: 0
        
# 这里需要把你自己的对应参数填入
env:
  suiteId: 
  appId: 
  suiteKey: 
  suiteSecret: 
  token: 
  encodingAesKey:
  corpId: 
  corpSecret:

PortalController.java

HTTP推送接收服务

package club.itwork.dingtalk.controller;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import club.itwork.dingtalk.dto.EventMsg;
import club.itwork.dingtalk.handler.EventHandler;
import club.itwork.dingtalk.handler.HandlerManager;
import club.itwork.dingtalk.properties.EnvProperties;
import com.dingtalk.oapi.lib.aes.DingTalkEncryptor;
import com.dingtalk.oapi.lib.aes.Utils;
import lombok.extern.slf4j.Slf4j;
import org.springframework.web.bind.annotation.*;

import javax.annotation.Resource;
import java.util.Map;

import static club.itwork.dingtalk.constant.Constants.*;

/**
 * http 推送接收类
 * - 该服务只有在测试环境下可用。
 * - 正在上线的应用应该对接钉钉云的相关逻辑
 *
 * @author dgb8901
 */
@Slf4j
@RestController
@RequestMapping("portal")
public class PortalController {

    @Resource
    private EnvProperties env;

    @Resource
    private HandlerManager handlerManager;


    /**
     * http 回调方法
     *
     * @return
     */
    @PostMapping("/callback")
    public Map<String, String> callback(@RequestParam(value = "signature", required = false) String signature,
                                        @RequestParam(value = "timestamp", required = false) String timestamp,
                                        @RequestParam(value = "nonce", required = false) String nonce,
                                        @RequestBody(required = false) JSONObject body) {

        log.info("begin /callback: 【signature】:{},【timestamp】:{},【nonce】:{}", signature, timestamp, nonce);

        try {

            String encryptMsg = body.getString(ENCRYPT_KEY);
            DingTalkEncryptor encrypt = new DingTalkEncryptor(env.getToken(), env.getEncodingAesKey(), env.getSuiteKey());
            String decryptMsg = encrypt.getDecryptMsg(signature, timestamp, nonce, encryptMsg);
            EventMsg eventMsg = JSON.parseObject(decryptMsg, EventMsg.class);
            String eventType = eventMsg.getEventType();

            EventHandler handler = handlerManager.getHandler(eventType);
            handler.handle(eventMsg);

            return encrypt.getEncryptedMap(CALLBACK_RESPONSE_SUCCESS, System.currentTimeMillis(), Utils.getRandomStr(RANDOM_COUNT));
        } catch (Exception e) {
            log.error("处理推送事件异常：", e);
            e.printStackTrace();
        }

        return null;
    }

}