java实现微信小程序内容安全检测

首先吐槽下小程序的api写的si一样
下面是正题：
公司小程序审核多次不过，沟通后确认是用户ugc没有做内容安全检测；

小程序的内容安全

1.imgSecCheck 图片检测

a.图片智能鉴黄：涉及拍照的工具类应用(如美拍，识图类应用)用户拍照上传检测；电商类商品上架图片检测；媒体类用户文章里的图片检测等；
b.敏感人脸识别：用户头像；媒体类用户文章里的图片检测；社交类用户上传的图片检测等。 频率限制：单个 appId 调用上限为 2000 次/分钟，200,000 次/天*（图片大小限制：1M）

请求地址:

POST https://api.weixin.qq.com/wxa/img_sec_check?access_token=ACCESS_TOKEN

请求参数

返回值 Object

返回的 JSON 数据包

Java代码

public ResultEntity checkImgByInputStream(InputStream inputStream) throws HttpException {
        if(inputStream == null){
            return null;
        }
        //获取access_token
        String accessToken = getAccessToken();
        String url = String.format(imgSecCheckUrl, accessToken);
        HttpClient httpclient = HttpClients.createDefault();
 
        HttpPost request = new HttpPost(url);
        request.addHeader("Content-Type", "application/octet-stream");
 
        try {
            byte[] byt = new byte[inputStream.available()];
            inputStream.read(byt);
            request.setEntity(new ByteArrayEntity(byt, ContentType.create("image/jpg")));
            HttpResponse response = httpclient.execute(request);
            HttpEntity entity = response.getEntity();
            String result = EntityUtils.toString(entity, "UTF-8");// 转成string
            logger.info("response: " + result);
            ResultEntity resultEntity = JsonKit.parseObject(result, ResultEntity.class);
            return resultEntity;
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            if(inputStream != null){
                try {
                    inputStream.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }
        return null;
    }

当图片大于给1M时，采用图片压缩，应用goodle开源的Thumbnails,现在是0.4.8版本

     <dependency>
            <groupId>net.coobird</groupId>
            <artifactId>thumbnailator</artifactId>
            <version>0.4.8</version>
      </dependency>

压缩图片(支持多种格式的书输入)

//num 文件长度
public InputStream compressImage(URLConnection connection, long num) throws IOException {
        if(num == 0 || connection == null){
            return null;
        }
        double multiple = 1.0 / (num / (1024 * 1024) + 1.0);
        BufferedImage image = Thumbnails.of(connection.getInputStream()).scale(multiple).asBufferedImage();
        ByteArrayOutputStream os = new ByteArrayOutputStream();
        ImageIO.write(image, "jpg", os);
        InputStream is = new ByteArrayInputStream(os.toByteArray());
        return is;
    }

2.msgSecCheck 文字检测

1.用户个人资料违规文字检测；
2.媒体新闻类用户发表文章，评论内容检测；
3.游戏类用户编辑上传的素材(如答题类小游戏用户上传的问题及答案)检测等。 频率限制：单个 appId 调用上限为 4000 次/分钟，2,000,000 次/天*

请求地址

POST https://api.weixin.qq.com/wxa/msg_sec_check?access_token=ACCESS_TOKEN

请求参数

返回值

返回的 JSON 数据包

java代码

   public ResultEntity checkMsg(String content) throws HttpException {
        String accessToken = getAccessToken();
        String url = String.format(msgSecCheckUrl, accessToken);
        Map<String, String> map = new HashMap<>();
        map.put("content", content);
        String result = HttpClientKit.postJson(url, JsonKit.toJson(map), 60 * 1000);
        if (StringUtils.isNotBlank(result)) {
            return JsonKit.parseObject(result, ResultEntity.class);
        }
        return null;
    }