WxXcxSecurityMediaCheckAsyncRequest.java

package com.yanzuoguang.wxxcx.security;

import com.alibaba.fastjson.TypeReference;
import com.yanzuoguang.util.helper.CheckerHelper;
import com.yanzuoguang.util.helper.HttpHelper;
import com.yanzuoguang.util.helper.JsonHelper;
import com.yanzuoguang.wxxcx.base.*;

/**
 * 音视频内容安全识别 转换
 * 异步校验图片/音频是否含有违法违规内容
 * 1.0版本在2021年9月1日停止更新，请尽快更新至2.0
 * 应用场景举例：
 * 语音风险识别：社交类用户发表的语音内容检测；
 * 图片智能鉴黄：涉及拍照的工具类应用(如美拍，识图类应用)用户拍照上传检测；电商类商品上架图片检测；媒体类用户文章里的图片检测等；
 * 敏感人脸识别：用户头像；媒体类用户文章里的图片检测；社交类用户上传的图片检测等。 频率限制：单个 appId 调用上限为 2000 次/分钟，200,000 次/天；文件大小限制：单个文件大小不超过10M
 *
 * @author 李贤军
 */
public class WxXcxSecurityMediaCheckAsyncRequest implements WxXcxRequestUrl, WxXcxRequestUrlPara, WxXcxRequestPostFormData {

    private final WxXcxConfig wxXcxConfig;
    private final WxXcxRequest wxXcxRequest;
    private final WxXcxAccessToken accessToken;
    private final WxXcxSecurityMediaCheckAsyncReq req;

    public WxXcxSecurityMediaCheckAsyncRequest(WxXcxConfig wxXcxConfig, WxXcxRequest wxXcxRequest, WxXcxAccessToken accessToken, WxXcxSecurityMediaCheckAsyncReq req) {
        this.wxXcxConfig = wxXcxConfig;
        this.wxXcxRequest = wxXcxRequest;
        this.accessToken = accessToken;
        this.req = req;
    }

    @Override
    public String getUrl() {
        return wxXcxConfig.getBaseUrl() + wxXcxConfig.getSecurityMediaCheckAsyncUrl() + "?" + this.getUrlPara();
    }

    @Override
    public String getUrlPara() {
        return HttpHelper.getUrlParameter(accessToken);
    }

    @Override
    public String getPost() {
        return HttpHelper.getUrlParameter(req);
    }

    public WxXcxSecurityMediaCheckAsyncRes getResponse() {
        checkParam(req);
        return this.wxXcxRequest.request(this, response -> {
            WxXcxSecurityMediaCheckAsyncRes ret = JsonHelper.deserialize(response, new TypeReference<WxXcxSecurityMediaCheckAsyncRes>() {
            });
            WxXcxAssert.assertBaseError(ret);
            return ret;
        });
    }

    private void checkParam(WxXcxSecurityMediaCheckAsyncReq req) {
        CheckerHelper.newInstance().notBlankCheck(WxXcxAccessTokenField.FIELD_ACCESS_TOKEN, req.getAccess_token())
                .notBlankCheck("media_url", req.getMedia_url())
                .notBlankCheck("media_type", req.getMedia_type())
                .notBlankCheck("version", req.getVersion())
                .notBlankCheck("openid", req.getOpenid())
                .notBlankCheck("scene", req.getScene())
                .checkException();
    }
}