Bladeren bron

广告违规素材推送

zhaoxian 1 jaar geleden
bovenliggende
commit
25e3e842ce

+ 32 - 0
jeecg-boot-module-system/src/main/java/cn/com/ctop/toutiao/modules/material/controller/ByteDanceVideoInfoController.java

@@ -179,6 +179,38 @@ public class ByteDanceVideoInfoController {
     public CallbackResponse illegalVideosPush(HttpServletRequest request,
                                               @RequestParam(value = "challenge", defaultValue = "0") int challenge,
                                               @RequestParam(value = "event", defaultValue = "") String event) throws IOException {
+        // 处理 verify 事件
+        if (null != event && event.equals("verify_webhook")) {
+            return new CallbackResponse(BaseResponse.ok(), challenge);
+        }
+
+        // 订阅任务配置页面的 "验证密钥"
+        String secretKey = System.getenv("bd881f3bcd894ed48638dfb63eb627cf");
+
+        // 数据接收,验证消息
+        AuthTokenUtil.InputStreamCacher cacher = new AuthTokenUtil.InputStreamCacher(request.getInputStream());
+        boolean isValidToken = AuthTokenUtil.isValidToken(secretKey, cacher, request.getHeader("X-Open-Signature"));
+        if (!isValidToken) {
+            return new CallbackResponse(new BaseResponse(400, "invalid token"), 0);
+        }
+
+        Map<String, String[]> parameterMap = request.getParameterMap();
+        System.out.println("------------------" + parameterMap);
+
+//        JSONObject parse = JSONObject.parseObject(data);
+//        System.out.println(parse);
+
+        // 数据处理流程...
+        return new CallbackResponse(BaseResponse.ok(), 0);
+    }
+
+    /**
+     * 广告违规素材推送
+     */
+    @RequestMapping(value = "/illegalVideosPush2", method = {RequestMethod.GET, RequestMethod.POST})
+    public CallbackResponse illegalVideosPush2(HttpServletRequest request,
+                                               @RequestParam(value = "challenge", defaultValue = "0") int challenge,
+                                               @RequestParam(value = "event", defaultValue = "") String event) throws IOException {
       /*  // 处理 verify 事件
         if (null != event && event.equals("verify_webhook")) {
             return new CallbackResponse(BaseResponse.ok(), challenge);