微信音频内容安全识别

ch-wx-api/src/main/java/com/wwdz/ch/wx/impl/qiandao/QdUserServiceImpl.java

@@ -2,9 +2,11 @@ package com.wwdz.ch.wx.impl.qiandao;
 
 import cn.binarywang.wx.miniapp.bean.WxMaJscode2SessionResult;
 import com.alibaba.fastjson.JSONObject;
+import com.wwdz.ch.core.api.WxAppletApi;
 import com.wwdz.ch.core.api.qiandao.QdWxLoginManager;
 import com.wwdz.ch.core.consts.CommConsts;
 import com.wwdz.ch.core.entity.QdUserInfo;
+import com.wwdz.ch.core.entity.WxCheckMediaRequestDto;
 import com.wwdz.ch.core.notify.AliSmsSender;
 import com.wwdz.ch.core.notify.NotifyService;
 import com.wwdz.ch.core.notify.SmsResult;
@@ -32,6 +34,7 @@ import org.springframework.context.ApplicationContext;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.transaction.interceptor.TransactionAspectSupport;
+import org.springframework.util.CollectionUtils;
 import org.springframework.web.multipart.MultipartFile;
 import javax.imageio.ImageIO;
 import javax.servlet.http.HttpServletRequest;
@@ -83,6 +86,9 @@ public class QdUserServiceImpl implements QdUserService {
     @Autowired
     StorageService storageService;
 
+    @Autowired
+    WxAppletApi wxAppletApi;
+
     @Override
     public Result regCaptcha(QdUserRequestDto dto) {
         try {
@@ -276,6 +282,15 @@ public class QdUserServiceImpl implements QdUserService {
             if (Objects.isNull(user)) {
                 return Result.failed("数据异常，用户不存在");
             }
+            if (com.xxdxxs.utils.StringUtils.hasLength(dto.getAvatar())) {
+                //微信音频内容安全识别
+                WxCheckMediaRequestDto wxCheckMediaRequestDto = new WxCheckMediaRequestDto();
+                wxCheckMediaRequestDto.setMediaType(2);
+                wxCheckMediaRequestDto.setMediaUrl(dto.getAvatar());
+                wxCheckMediaRequestDto.setWxOpenId(user.getWxOpenid());
+                wxAppletApi.checkMedia(wxCheckMediaRequestDto);
+                logger.info("=========== 微信音频内容安全识别接口调用成功 ===========");
+            }
             user.setAvatar(dto.getAvatar());
             qdUserDao.updateById(user);
             // 更新用户缓存

ch-wx-api/src/main/java/com/wwdz/ch/wx/impl/qiandao/QdUserSignInServiceImpl.java

 package com.wwdz.ch.wx.impl.qiandao;
 
+import com.wwdz.ch.core.api.WxAppletApi;
 import com.wwdz.ch.core.api.wxpay.WxPayServiceApi;
 import com.wwdz.ch.core.consts.CommConsts;
 import com.wwdz.ch.core.consts.DistributionEnum;
 import com.wwdz.ch.core.consts.SigninEnum;
 import com.wwdz.ch.core.consts.qiandao.SignInTaskEnum;
+import com.wwdz.ch.core.entity.WxCheckMediaRequestDto;
 import com.wwdz.ch.core.type.Result;
 import com.wwdz.ch.core.util.IdUtils;
 import com.wwdz.ch.db.dao.distribution.DistributionOrderDao;
 import com.wwdz.ch.db.dao.qiandao.*;
+import com.wwdz.ch.db.domain.User;
 import com.wwdz.ch.db.domain.distribution.DistributionOrder;
+import com.wwdz.ch.db.domain.qiandao.QdUser;
 import com.wwdz.ch.db.domain.qiandao.QdUserSignIn;
 import com.wwdz.ch.db.domain.qiandao.QdUserSignInNote;
 import com.wwdz.ch.db.domain.qiandao.SignInTask;
@@ -20,6 +24,8 @@ import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
+import org.springframework.util.CollectionUtils;
+
 import java.text.SimpleDateFormat;
 import java.time.LocalDate;
 import java.time.LocalDateTime;
@@ -55,6 +61,9 @@ public class QdUserSignInServiceImpl implements QdUserSignInService {
     @Autowired
     QdUserSignInTaskDao qdUserSignInTaskDao;
 
+    @Autowired
+    WxAppletApi wxAppletApi;
+
 
     @Override
     public Result check(QdUserSignInRequestDto dto) {
@@ -126,6 +135,17 @@ public class QdUserSignInServiceImpl implements QdUserSignInService {
                     return Result.failed("非打卡时段");
                 }
             }
+            if (!CollectionUtils.isEmpty(dto.getImages())) {
+                //微信音频内容安全识别
+                WxCheckMediaRequestDto wxCheckMediaRequestDto = new WxCheckMediaRequestDto();
+                wxCheckMediaRequestDto.setMediaType(2);
+                wxCheckMediaRequestDto.setMediaUrl(dto.getImages().get(0));
+                //查询用户openid
+                QdUser user = qdUserDao.queryById(dto.getUserId());
+                wxCheckMediaRequestDto.setWxOpenId(user.getWxOpenid());
+                wxAppletApi.checkMedia(wxCheckMediaRequestDto);
+                logger.info("=========== 微信音频内容安全识别接口调用成功 ===========");
+            }
 
             //签到记录id
             Long recordId = null;

ch-wx-api/src/main/java/com/wwdz/ch/wx/web/qiandao/QdUserSignInController.java

@@ -3,11 +3,13 @@ package com.wwdz.ch.wx.web.qiandao;
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
 import com.wwdz.ch.core.consts.ResultCode;
+import com.wwdz.ch.core.entity.WxCheckMediaRequestDto;
 import com.wwdz.ch.core.storage.StorageService;
 import com.wwdz.ch.core.type.Result;
 import com.wwdz.ch.core.util.ImgUtil;
 import com.wwdz.ch.core.util.ResponseUtil;
 import com.wwdz.ch.db.dao.qiandao.QdUserSignInDao;
+import com.wwdz.ch.db.domain.User;
 import com.wwdz.ch.db.domain.qiandao.QdUserSignIn;
 import com.wwdz.ch.db.dto.request.UserSignInRequestDto;
 import com.wwdz.ch.db.dto.request.qiandao.QdUserRequestDto;
@@ -69,6 +71,10 @@ public class QdUserSignInController {
             String url = storageService.store(targetInput, file.getSize(), file.getContentType(), originalFilename);
             Map<String, Object> map = new HashMap<>();
             map.put("url", url);
+
+
+
+
             logger.info("【请求结束】乾岛上传文件,响应结果:{}", JSONObject.toJSONString(map));
             return Result.success(map);
         } catch (Exception e) {