易盾网页审核状态修改

郑超
1 parent cce9aac5
Showing 4 changed files with 51 additions and 29 deletions
src/main/java/com/cnlive/shenhe/job/ContentJob.java
src/main/java/com/cnlive/shenhe/job/YiDunUrlResultJob.java
src/main/java/com/cnlive/shenhe/serviceImpl/ContentServiceImpl.java
src/main/java/com/cnlive/shenhe/utils/YiDunAntiFraudUtil.java
@@ -33,8 +33,10 @@ public class ContentJob {
     @Scheduled(fixedRate = 60 * 1000)
     public void updateVideos() {
         ShyContent shyContent = new ShyContent();
-        shyContent.setShenhe_type(CommonConst.AUDIT_TYPE_FREE);// 审核类型为免审
-        shyContent.setReceive_status(CommonConst.RECEIVE_BEFORE);// 领取状态为未领取
+        // 审核类型为免审
+        shyContent.setShenhe_type(CommonConst.AUDIT_TYPE_FREE);
+        // 领取状态为未领取
+        shyContent.setReceive_status(CommonConst.RECEIVE_BEFORE);
         List<ShyContent> shyContentList = contentService.findshyContent(shyContent);
         if (shyContentList.size() > 0) {
             for (ShyContent content : shyContentList) {
@@ -48,14 +50,17 @@ public class ContentJob {
     /**
      * 定时向易盾提交网站地址
+     * //每分钟一次
      */
-    @Scheduled(cron = "0 0/1 * * * ? ")//每分钟一次
+    @Scheduled(cron = "0 0/1 * * * ? ")
     public void videofilter() {
+        logger.info("提交网页审核到易盾...........");
         ShyContent shyContent = new ShyContent();
         //机审
         shyContent.setShenhe_type(CommonConst.AUDIT_TYPE_MACHANE);
         //待审
         shyContent.setReceive_status(CommonConst.RECEIVE_BEFORE);
+
         List<ShyContent> shyContentList = contentService.findshyContent(shyContent);
         if (shyContentList != null && shyContentList.size() > 0) {
             for (ShyContent content : shyContentList) {
@@ -64,7 +69,6 @@ public class ContentJob {
                 shyYidun.setContent_id(content.getId().toString());
                 ShyYidun shyYidun1 = yiDunServiceImpl.getidunMsgByContentId(shyYidun);
                 if (shyYidun1 == null) {
-                    logger.info("定时发送易盾检测的content_id：" + content.getId());
                     contentService.contentFilter(content);
                 }
             }
@@ -79,12 +83,14 @@ public class ContentJob {
     public void autoRetReceive() {
         logger.info("图文自动退领的进入.....");
         ShyContent shyContent = new ShyContent();
-        shyContent.setReceive_status(CommonConst.RECEIVE_AFTER);//领取状态为，已领
+        //领取状态为，已领
+        shyContent.setReceive_status(CommonConst.RECEIVE_AFTER);
         List<ShyContent> shyContentList = contentService.findshyContent(shyContent);
         if (shyContentList.size() > 0) {
             for (ShyContent shyContent2 : shyContentList) {
                 logger.info("自动退领的content_id：" + shyContent2.getId());
-                shyContent2.setReceive_status(CommonConst.RECEIVE_BEFORE);//未领取
+                //未领取
+                shyContent2.setReceive_status(CommonConst.RECEIVE_BEFORE);
                 shyContent2.setAuditor_id(null);
                 contentService.updateshyContent(shyContent2);
             }
@@ -101,6 +101,7 @@ public class YiDunUrlResultJob {
                             newYiDunMsg.setResult_type(String.valueOf(result));
                             if (result == 1) {
                                 desc = "易盾网站审核通过了";
+                                shyContent.setReceive_status(2);
                                 shyContent.setShenhe_msg(desc);
                                 newYiDunMsg.setDesc_msg(desc);
                                 //修改图文状态
@@ -172,7 +173,8 @@ public class YiDunUrlResultJob {
                                     }
                                 }
                                 shyContent.setShenhe_type(CommonConst.AUDIT_TYPE_USER);
-                                //拒绝原因
+                                //拒绝原因 3=拒审
+                                shyContent.setReceive_status(3);
                                 shyContent.setShenhe_msg(desc);
                                 newYiDunMsg.setDesc_msg(desc);
                             }
@@ -66,7 +66,7 @@ public class ContentServiceImpl {
     //**************************************
     public List<ShyContent> findshyContent(ShyContent shyContent) {
-        return shyContentMapper.selectByRowBounds(shyContent, new RowBounds(0, 100));
+        return shyContentMapper.selectByRowBounds(shyContent, new RowBounds(0, 50));
     }
     //***************************
@@ -375,7 +375,8 @@ public class ContentServiceImpl {
      * @return
      */
     public void contentFilter(ShyContent shyContent) {
-        String contentUrl = localhost_url + "/api/content/detail/" + shyContent.getId() + ".html";
+//        String contentUrl = localhost_url + "/api/content/detail/" + shyContent.getId() + ".html";
+        String contentUrl = shyContent.getContent_url();
         logger.info("向易盾网站检测接口提交的url:" + contentUrl);
         //调用易盾网站检测接口
         JSONObject jsonObject = YiDunAntiFraudUtil.submitYiDunUrl(contentUrl);
@@ -83,31 +83,42 @@ public class YiDunAntiFraudUtil {
     private final static String AUDIOONDEMAND_URL_SUBMIT = "http://as.dun.163.com/v3/audio/submit";
     public static void main(String[] args) {
+        Map<String, String> params = new HashMap<String, String>(5);
+        // 1.设置公共参数
+        params.put("secretId", SECRETID);
+        params.put("version", "v1.0");
+        params.put("timestamp", String.valueOf(System.currentTimeMillis()));
+        params.put("nonce", String.valueOf(new Random().nextInt()));
+        // 2.生成签名信息
+        String signature1 = YiDunAntiFraudUtil.genSignature(SECRETKEY, params);
+        params.put("signature", signature1);
+        String s1 = HttpClientUtils.post_str(URL_RESULT, params);
+        logger.info("查询易盾网站检测结果:{}", s1);
         //智能文本识别审核测试
         //getTextFilter("王八蛋");
         //智能图片识别审核测试
-        JSONArray jsonArray = new JSONArray();
-        JSONObject image1 = new JSONObject();
-        image1.put("name", UUID.randomUUID());
-        image1.put("type", 1);
-        image1.put("data", "http://article-bj.bj.bcebos.com//20200326/7f3d23bbb28421e6e2a6f131273554fb_15.jpg?authorization=bce-auth-v1%2F1eda661c3697440eaaca912ccb6f959c%2F2020-03-30T05%3A42%3A21Z%2F604800%2F%2F39f195e2327ef87270bd095fa64dfdcadad6f01a0d6dc6a4313306f164591cc5");
-        jsonArray.add(image1);
-        JSONObject image2 = new JSONObject();
-        image2.put("name", UUID.randomUUID());
-        image2.put("type", 1);
-        image2.put("data", "http://test.qnvod.cnlive.com/shen/802/2020/03/01/8a8a878c6dce5cfe017096cd07940c84/000002.jpg");
-        jsonArray.add(image2);
-        JSONObject image3 = new JSONObject();
-        image3.put("name", UUID.randomUUID());
-        image3.put("type", 1);
-        image3.put("data", "https://wjj.ys2.cnliveimg.com/769/img/0/2020/03/21/158474856886077030277.jpg");
-        jsonArray.add(image3);
-        System.out.println(jsonArray);
-        JSONObject imagesFilter = getImagesFilter(jsonArray.toString());
-//        System.out.println(image1);
-        System.out.println(imagesFilter);
+//        JSONArray jsonArray = new JSONArray();
+//        JSONObject image1 = new JSONObject();
+//        image1.put("name", UUID.randomUUID());
+//        image1.put("type", 1);
+//        image1.put("data", "http://article-bj.bj.bcebos.com//20200326/7f3d23bbb28421e6e2a6f131273554fb_15.jpg?authorization=bce-auth-v1%2F1eda661c3697440eaaca912ccb6f959c%2F2020-03-30T05%3A42%3A21Z%2F604800%2F%2F39f195e2327ef87270bd095fa64dfdcadad6f01a0d6dc6a4313306f164591cc5");
+//        jsonArray.add(image1);
+//        JSONObject image2 = new JSONObject();
+//        image2.put("name", UUID.randomUUID());
+//        image2.put("type", 1);
+//        image2.put("data", "http://test.qnvod.cnlive.com/shen/802/2020/03/01/8a8a878c6dce5cfe017096cd07940c84/000002.jpg");
+//        jsonArray.add(image2);
+//        JSONObject image3 = new JSONObject();
+//        image3.put("name", UUID.randomUUID());
+//        image3.put("type", 1);
+//        image3.put("data", "https://wjj.ys2.cnliveimg.com/769/img/0/2020/03/21/158474856886077030277.jpg");
+//        jsonArray.add(image3);
+//        System.out.println(jsonArray);
+//        JSONObject imagesFilter = getImagesFilter(jsonArray.toString());
+////        System.out.println(image1);
+//        System.out.println(imagesFilter);
         //智能网页识别审核测试
@@ -420,6 +431,7 @@ public class YiDunAntiFraudUtil {
      */
     public static JSONObject submitYiDunUrl(String url) {
         try {
+            logger.info("向易盾网站检测接口提交的url.....................");
             Map<String, String> params = new HashMap<String, String>();
             // 1.设置公共参数
@@ -513,4 +525,5 @@ public class YiDunAntiFraudUtil {
         return signature.equals(serverSignature) && TEXTANDIMAGESECRETID.equals(secretId) && AUDIOONDEMANDBUSINESSID.equals(businessId);
     }
+
 }