音频审核增加免审功能update

徐近程
1 parent 4b97da2a
Showing 2 changed files with 76 additions and 4 deletions
src/main/java/com/cnlive/shenhe/job/AudioJob.java
src/main/java/com/cnlive/shenhe/serviceImpl/AudioServiceImpl.java
+package com.cnlive.shenhe.job;
+
+import com.cnlive.shenhe.entity.ShyAudio;
+import com.cnlive.shenhe.entity.ShyVideos;
+import com.cnlive.shenhe.serviceImpl.AudioServiceImpl;
+import com.cnlive.shenhe.utils.CommonConst;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+/**
+ * @Author: xujincheng
+ * @Date: 2020/6/18 13:06
+ */
+@Component
+public class AudioJob {
+
+    private static Logger logger = LoggerFactory.getLogger(AudioJob.class);
+
+    @Autowired
+    AudioServiceImpl audioService;
+
+    /**
+     * 白名单sp音频通过
+     */
+    @Scheduled(fixedRate = 60 * 1000)
+    public void updateVideos() {
+        ShyAudio shyAudio = new ShyAudio();
+        // 审核类型为免审
+        shyAudio.setShenhe_type(CommonConst.AUDIT_TYPE_FREE);
+        // 审核状态为未审核
+        shyAudio.setState(CommonConst.AUDIT_INTT);
+        List<ShyAudio> shyAudioList = audioService.findshyAudio(shyAudio);
+        if (shyAudioList != null && shyAudioList.size() > 0) {
+            for (ShyAudio audio : shyAudioList) {
+                logger.info("当前白名单通过的AudioId：" + audio.getAudioId());
+                shyAudio.setUploader("白名单");
+                // 更新点播音频和审核的音频状态
+                audioService.updateAudioAndShenhe(audio, 3);
+            }
+        }
+    }
+}
@@ -5,7 +5,6 @@ import com.cnlive.shenhe.bean.ErrorEnum;
 import com.cnlive.shenhe.bean.ResponseBean;
 import com.cnlive.shenhe.entity.ShyAudio;
 import com.cnlive.shenhe.entity.ShyUsers;
-import com.cnlive.shenhe.entity.ShyUsersfree;
 import com.cnlive.shenhe.entity.ShyVideos;
 import com.cnlive.shenhe.mapper.ShyAudioMapper;
 import com.cnlive.shenhe.mapper.ShyUsersMapper;
@@ -20,9 +19,6 @@ import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import tk.mybatis.mapper.entity.Example;
-
-import java.sql.Timestamp;
-import java.text.ParseException;
 import java.util.List;
  
 /**
@@ -66,6 +62,35 @@ public class AudioServiceImpl {
         return shyAudio;
     }
  
+    public List<ShyAudio> findshyAudio(ShyAudio shyAudio) {
+        List<ShyAudio> shyAudiolist = shyAudioMapper.selectByRowBounds(shyAudio, new RowBounds(0, 100));
+        return shyAudiolist;
+    }
+
+    public int updateAudioAndShenhe(ShyAudio shyAudio, int audioState) {
+        //修改点播云音频状态
+        JSONObject result = Pass.audioPass(shyAudio.getAudioId(), audioState, shyAudio.getAttr_tags(), shyAudio.getMsg(), shyAudio.getCallback());
+        Integer code = result.getInteger("code");
+        Integer shenheState=CommonConst.AUDIT_REFUSE;
+        if (0 == code) {
+            if(audioState==3){
+                shenheState=CommonConst.AUDIT_SUCCESS;
+            }
+            //修改审核云的音频状态
+            int i = audioService.updateAudio(shyAudio.getId(), null,shyAudio.getUploader(),"", shenheState, shyAudio.getMsg());
+            if (i != 1) {
+                logger.error("点播音频更改失败,AudioId:{}", shyAudio.getAudioId());
+            }
+            return i;
+        } else {
+            shyAudio.setMsg("点播音频回调失败，"+shyAudio.getMsg());
+            audioService.updateAudio(shyAudio.getId(), null,shyAudio.getUploader(),"", CommonConst.AUDIT_CALLBACK_FAIL, shyAudio.getMsg());
+            logger.error("点播音频回调失败，activity_id:{},code:{},msg:{}", shyAudio.getAudioId(), code, result.getString("msg"));
+        }
+
+        return 0;
+    }
+
     //认领
     public Integer receive(String ids, Integer num, String userId, Integer spid) {
         Integer n = 0;