推送事件数据

请求方式

POST

Content-Type

application/json

参数：

header

body

请求示例：

{

"topicName":"eventsImport",

"content":"{"topicName":"eventsImportForWj","content":[{"innerEventId":"sptsj3CEH","areaCode":"330381000000","streetCode":"330381000000","origin":"测试部门","scence":"120cjsj","title":"测试事件","content":"测试事件。","eventTime":"2022-10-26 16:12:32","eventCoordinate":"120.61552503339489,27.70127169381555","msgType":42103,"eventUrl":"http://www.dd.com","superviseStatus":0,"eventCreatorTel":"17857072110","eventCreator":"测试","eventPlaceName":"测试地址","executeType":1,"remindStatus":0,"cdcProviderId":49}]}"}

推送事件进度数据

请求方式

POST

Content-Type

application/json

参数：

header

body

请求示例：

{

"topicName":"progressesImport","content":"{"topicName":"eventsImportForZhcg","content":[{"innerEventId":"DC6A8522102603432","detail":"结案","url":"","progressTime":"2022-10-27 10:00:43","eventProgressStatus":null,"eventProgressExecutorId":105867,"eventProgressExecutor":"市值班长17","eventProgressExecutorOrg":"市监督中心"}]}"}

签名生成方法

    /**
     * 构造http请求 header
     * @param url 请求url，全路径格式，比如：http://122.228.14.56:10005/service
     * @param requestMethod 请求方法,大写格式，如：GET, POST
     * @param accessKey 应用的 AK
     * @param secretKey 应用的 SK
     * @return
     */
    public static Map<String, String> generateHeader(String url,String requestMethod, String accessKey, String secretKey, String date) {
        Map<String, String> header = new HashMap<>();
        try {
            DateFormat dateFormat = new SimpleDateFormat("EEE, dd MMM yyyy HH:mm:ss z", Locale.US);
            dateFormat.setTimeZone(TimeZone.getTimeZone("GMT"));
//            String date = dateFormat.format(new Date());
            URI uri = URI.create(url);
            String canonicalQueryString = getCanonicalQueryString(uri.getQuery());

            String message = requestMethod.toUpperCase() + "\n" + uri.getPath() + "\n" + canonicalQueryString + "\n"  + accessKey + "\n" + date + "\n";

            Mac hasher = Mac.getInstance("HmacSHA256");
            hasher.init(new SecretKeySpec(secretKey.getBytes(), "HmacSHA256"));

            byte[] hash = hasher.doFinal(message.getBytes());

            // to lowercase hexits
            DatatypeConverter.printHexBinary(hash);

            // to base64
            String sign = DatatypeConverter.printBase64Binary(hash);
            header.put("X-BG-HMAC-SIGNATURE", sign);
            header.put("X-BG-HMAC-ALGORITHM", "hmac-sha256");
            header.put("X-BG-HMAC-ACCESS-KEY", accessKey);
            header.put("X-BG-DATE-TIME", date);
        } catch (Exception e) {
            throw new RuntimeException("generate header error");
        }
        return header;
    }

    private static String getCanonicalQueryString(String query) {
        if (query == null || query.trim().length() == 0) {
            return "";
        }
        List<Pair<String, String>> queryParamList = new ArrayList<>();
        String[] params = query.split("&");
        for (String param : params) {
            String[] keyValue = param.split("=");
            Pair<String, String> pair = new Pair<String, String>(keyValue[0],keyValue.length > 1 ? keyValue[1] : "");
            queryParamList.add(pair);
        }

        List<Pair<String, String>> sortedParamList = queryParamList.stream().sorted(Comparator.comparing(param -> param.getKey() + "=" + Optional.ofNullable(param.getValue()).orElse(""))).collect(Collectors.toList());
        List<Pair<String, String>> encodeParamList = new ArrayList<>();
        sortedParamList.stream().forEach(param -> {
            try {
                String key = URLEncoder.encode(param.getKey(), "utf-8");
                String value = URLEncoder.encode(Optional.ofNullable(param.getValue()).orElse(""), "utf-8");
                encodeParamList.add(new Pair<>(key, value));
            } catch (UnsupportedEncodingException e) {
                throw new RuntimeException("encoding error");
            }
        });
        StringBuilder queryParamString = new StringBuilder(64);
        for (Pair<String, String> encodeParam : encodeParamList) {
            queryParamString.append(encodeParam.getKey()).append("=").append(Optional.ofNullable(encodeParam.getValue()).orElse(""));
            queryParamString.append("&");
        }

        return queryParamString.substring(0, queryParamString.length() - 1);
    }

事件接收接口规范

URL: 接收方提供

请求方式

POST

Content-Type

application/json

body参数：

data字段说明

示例：

{"data":"{"areaCode":"330302000000","eventCoordinate":"0.0,0.0","eventPlaceName":"1","eventTime":"2022-07-04 00:41:04","innerEventId":"6a9542b3498545209216ea0fbea414a7","origin":"温州市消防救援支队","receiveName":"lcshzlzxEvent","scence":"wzxfsj","streetCode":"330302027000","superviseStatus":1,"title":"火警报警:1"}"}

事件进度接收接口规范

URL: 接收方提供

请求方式

POST

Content-Type

application/json

body参数：

data字段说明

示例：

{"data":"[{"detail":"该问题已处理完毕，请督查。","eventProgressExecutor":"五马中队","eventProgressExecutorId":"101059","innerEventId":"DC6A8521072110393","progressTime":"2022-07-04 00:41:04","url":""},{"detail":"","eventProgressExecutor":"市值班长27","eventProgressExecutorId":"105877","innerEventId":"DC6A8521072110393","progressTime":"2022-07-04 00:41:04","url":""}]"}