1 操作說明

下述表格為公眾號事件采集的必要步驟，請按照順序操作：

1.1 接入公眾號

產品路徑：「數據采集」-「數據源管理」-「公眾號管理」

點擊「接入公眾號」按鈕，彈出右側「接入數據源」頁面完成新建接入公眾號，完成接入需要填寫如下信息：

「基礎信息」

• 公眾號名稱：填寫要接入的公眾號名稱

• 公眾號ID：填寫公眾號ID，公眾號ID不可重復。獲取方式見下圖：

「分析設置」

• 歸屬組織：默認為當前組織不可修改，如需在不同組織下接入公眾號，需在左側組下拉框切換組織。

• 歸屬應用：在下拉選擇框選擇當前歸屬組織下的應用。

「接收微信消息」

• 加密模式：分為安全模式與明文模式；

安全模式：EncodingAESKey 用于消息體加解密密鑰，與微信公眾號平臺填寫一致。

明文模式：不使用消息體加解密功能，安全系數較低。

• EncodingAESKey 獲取地址：公眾號后臺-基礎配置-復制EncodingAESKey。

• Token獲取地址：公眾號后臺-基礎配置-復制Token

（注：微信公眾號后臺URL為用戶填寫地址，微信公眾號將數據發至填寫地址后，再同步至Quick Tracking。參考文檔）

「匿名用戶唯一標識」

必選項，設置以Union或OpenID來作為匿名用戶的唯一標識。

• OpenID：用戶唯一標識；

• UnionID：用于區分用戶的唯一值，設置為UnionID后，需獲取access_token。

「獲取access_token」

如果有其他業務同時使用了Token，用戶需自搭建的中控服務，來統一獲取、維護access_token，在分析平臺中可從中控服務來獲取access_token。（注：選擇unionID為匿名用戶唯一標識，用戶需配置一個控制中心。Quick Tracking通過中控中心來獲取token，在微信公眾號獲取對應的unionID（因每次調用獲取token后token會進行刷新，其他位置使用的token也會刷新改變。且獲取token次數微信開發平臺有限制，用戶可以從控制中心獲取token，且可控制token的周期））

• 中控服務器地址：填寫自建的中控服務地址可以獲取到token中控服務地址；

• access_token解析：從中控服務器獲取的返回值中解析access_token，通過JSONPah表達式解析，填寫 JSONPath表達式，點擊「測試」，測試是否解析成功，解析成功則可正常獲取。

完成以上步驟點擊保存完成創建。

1.2 公眾號管理

公眾號操作區主要由以下幾個部分組成：

• 左側組織篩選區：切換不同組織下接入的公眾號

• 數據展示區：展示已接入的公眾號列表，數據包含公眾號名稱、公眾號APPID、創建人、歸屬應用和操作。注意：分析設置中，一個公眾號只能選擇歸屬一個應用。

• 操作區：操作區包含「編輯」與「操作」，點擊「編輯」后和新增的界面一致，點擊刪除則表示從應用中移除了公眾號的關聯。

1.3 數據分析

接入公眾號后的應用，以及有“接入公眾號后的應用”的分析視圖和小站，系統屬性中需要有公眾號事件參與分析，其中參與分析的系統屬性如下表格：

透出公眾號事件的分析模型有：事件分析、漏斗分析、留存分析、分布分析、間隔分析、路徑分析、生命周期、歸因分析、人群管理。

2 事件及事件屬性

微信公眾號事件是由微信定義、生成和發送的，開發者僅為訂閱這些數據，無法進行自定義。具體可訂閱的事件列表如下：

3 事件采集

3.1 服務端埋點參數獲取

1. 進入管理控制臺-->點擊采集信息

2. 主域名：服務端埋點數據上報地址

3. 副域名：默認和主域名一致，私部署客戶可以提供副域名作為備用域名

4. ServiceSecret和ServiceID為校驗參數，注意保密不可泄漏。

5. code為開發者ID(AppID)，必填來自微信公號平臺，且需要在采集管理-數據源管理-公眾號管理中配置。

注意：因為上述信息涉及系統安全，所以只有管理員權限才可以看到！

3.2 請求參數

接口地址：https://<收數域名+端口>/server/thirdPartyDataSource

請求參數content-type：application/json

請求JSON參數：

<xml><ToUserName><![CDATA[gh_0b03a4dd7455]]></ToUserName>
<FromUserName><![CDATA[o884561i2yjDrOhC6IqzEzXtPKUo]]></FromUserName>
<CreateTime>1676613107</CreateTime>
<MsgType><![CDATA[text]]></MsgType>
<Content><![CDATA[測試]]></Content>
<MsgId>24003327368861869</MsgId>
</xml>

3.3 鑒權sign生成規則

1. 先將除了sign字段的其他所有請求字段的key和value封裝成一個map對象

2. 將這個map對象序列化成JSON字符，生成時需要將key按照自然排序即ascii碼排序，java可使用JSONObject.toJSONString(mapObject, SerializerFeature.MapSortField)，

3. 獲取serviceSecret

4. sign = MD5(排序完生成的JSON字符 + serviceSecret)

5. 將計算得到的sign放到原始的map對象中，再序列化成JSON字符即為最終完整的JSON請求報文

3.4 響應說明

響應數據content-type：application/json

響應的JSON字符中有兩個字段，分別為code、message

3.5 java demo參考

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.alibaba.fastjson.serializer.SerializerFeature;
import com.google.gson.Gson;
import okhttp3.*;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Controller;
import org.springframework.validation.annotation.Validated;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.nio.charset.Charset;
import java.util.HashMap;
import java.util.Map;

/**
* ThirdPartyDataSourceApiDemo 接入第三方數據源demo
*
* @author chengtao
*/
public class ThirdPartyDataSourceApiDemo {
     private static final Logger logger = LoggerFactory.getLogger(ThirdPartyDataSourceApiDemo.class);

    /**
     * 主域名
     */
    private static final String API_URL = "*****";

    /**
     * 對應服務端埋點信息中的：ServiceID
     */
    private static final String SERVICE_ID = "*****";

    /**
     * 對應服務端埋點信息中的：ServiceSecret
     */
    private static final String SERVICE_SECRET = "*****";

    /**
     * client日志
     */
    private static final OkHttpClient client = new OkHttpClient();

    /**
     * 獲取微信公眾號日志信息并轉發到QT收數（需要在微信公眾號管理后臺中配置該接口）
     * 
     * @param request
     * @throws IOException
     */
    @RequestMapping("/token")
    @ResponseBody
    public void token(HttpServletRequest request) throws IOException {
        //獲取微信公眾號官方請求中的全部參數信息，并封裝成json
        Map<String, String[]> paramMap = request.getParameterMap();

        JSONObject json = paramMapToJson(paramMap);

        //向報文中添加服務ID
        json.put("app_id",SERVICE_ID);

        //向報文中添加ts
        json.put("ts", String.valueOf(System.currentTimeMillis()));

        //填寫公眾號ID
        String code = "******";
        json.put("code", code);

        //獲取微信公眾號xml數據
        String weChatOAData = new String(InputStreamUtil.getBytes(request));
        json.put("weChatOAData", weChatOAData);

        //計算簽名
        String sign = MD5Util.md5(JSONObject.toJSONString(json, SerializerFeature.MapSortField) + SERVICE_SECRET);

        json.put("sign", sign);

        String desJsonString = JSON.toJSONString(json, SerializerFeature.DisableCircularReferenceDetect);

        Request newRequest = new Request.Builder()
                .URL(API_URL + "/server")
                .post(RequestBody.create(MediaType.parse("application/json"),
                        desJsonString))
                .build();
        try {
            Response response = client.newCall(newRequest).execute();
            if (!response.isSuccessful()) {
                System.out.printf("[DEMO] 發送日志失敗 %s%n", response);
            } else {
                System.out.printf("[DEMO] 發送成功 %s%n",
                        response.body().string());
            }
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    private static JSONObject paramMapToJson(Map<String, String[]> paramMap) {
        Map<String, Object> bodyMap = new HashMap<>();
        for (Map.Entry<String, String[]> entry : paramMap.entrySet()) {
            String key = entry.getKey();
            String[] value = entry.getValue();
            if (value.length == 1) {
                bodyMap.put(key, value[0]);
            } else {
                bodyMap.put(key, value);
            }
        }
        return JSON.parseObject(new Gson().toJson(bodyMap));
    }

    private static String getBodyString(HttpServletRequest request) {
        StringBuilder sb = new StringBuilder();
        InputStream inputStream = null;
        BufferedReader reader = null;
        try {
            inputStream = request.getInputStream();
            reader = new BufferedReader(new InputStreamReader(inputStream, Charset.forName("UTF-8")));
            String line = "";
            while ((line = reader.readLine()) != null) {
                sb.append(line);
            }
        } catch (IOException e) {
            logger.error("read body error", e);
            throw new RuntimeException("read body error");
        } finally {
            if (inputStream != null) {
                try {
                    inputStream.close();
                } catch (IOException e) {
                    logger.error("close inputStream error", e);
                }
            }
            if (reader != null) {
                try {
                    reader.close();
                } catch (IOException e) {
                    logger.error("close reader error", e);
                }
            }
        }
        return sb.toString();
    }
}


public class MD5Util {

    public static String md5(String s) {
        char hexDigits[] = {'0', '1', '2', '3', '4', '5', '6', '7', '8', '9', 'a', 'b', 'c', 'd', 'e', 'f'};
        try {
            byte[] btInput = s.getBytes();
            // 獲得MD5摘要算法的 MessageDigest 對象
            MessageDigest mdInst = MessageDigest.getInstance("MD5");
            // 使用指定的字節更新摘要
            mdInst.update(btInput);
            // 獲得密文
            byte[] md = mdInst.digest();
            // 把密文轉換成十六進制的字符串形式
            int j = md.length;
            char str[] = new char[j * 2];
            int k = 0;
            for (int i = 0; i < j; i++) {
                byte byte0 = md[i];
                str[k++] = hexDigits[byte0 >>> 4 & 0xf];
                str[k++] = hexDigits[byte0 & 0xf];
            }
            return new String(str);
        } catch (Exception e) {
            return null;
        }
    }

    /**
     * 單元測試
     */
    public static void main(String[] args) {
        StringBuilder dtskey = new StringBuilder("abc12390");
        dtskey.append('\0').append("~!@#$%^&*()_+");
        System.out.println(MD5Util.md5(dtskey.toString()));
        System.out.println(MD5Util.md5("20121221"));
        System.out.println(MD5Util.md5("加密"));
    }
}