音频数据拒绝功能

徐近程
1 parent 79c54a3f
Showing 3 changed files with 114 additions and 1 deletions
src/main/java/com/cnlive/shenhe/controller/AudioController.java
src/main/java/com/cnlive/shenhe/serviceImpl/AudioServiceImpl.java
src/main/java/com/cnlive/shenhe/utils/AuditPass.java
@@ -189,4 +189,30 @@ public class AudioController extends BaseController {
         }
         return audioService.retReceive(ids, userId);
     }
+
+    /**
+     * 打回(审核拒绝，应要求不加权限、状态等限制)
+     *
+     * @param ids
+     * @param msg
+     * @param session
+     * @return
+     */
+    @PostMapping("/repulse")
+    @ResponseBody
+    public ResponseBean repulse(String ids, String msg, HttpSession session) {
+        SessionUser sessionUser = (SessionUser) session.getAttribute(SessionUser.getSessionKey());
+        String userId = sessionUser.getUserId();
+        ResponseBean responseBean = new ResponseBean();
+        String[] shyAudiods = ids.split(",");
+        String showMsg = "";
+        for (String shyAudioId : shyAudiods) {
+            showMsg = audioService.repulse(shyAudioId, msg, userId);
+        }
+        if (CommonUtils.isNotEmpty(showMsg)) {
+            responseBean.setErrorCode(ErrorEnum.ERROR.getErrorCode());
+            responseBean.setErrorMessage(showMsg);
+        }
+        return responseBean;
+    }
 }
 package com.cnlive.shenhe.serviceImpl;
+import com.alibaba.fastjson.JSONObject;
 import com.cnlive.shenhe.bean.ErrorEnum;
 import com.cnlive.shenhe.bean.ResponseBean;
 import com.cnlive.shenhe.entity.ShyAudio;
-import com.cnlive.shenhe.entity.ShyVideos;
 import com.cnlive.shenhe.mapper.ShyAudioMapper;
+import com.cnlive.shenhe.utils.AuditPass;
 import com.cnlive.shenhe.utils.CommonConst;
 import com.cnlive.shenhe.utils.CommonUtils;
 import com.github.pagehelper.PageHelper;
 import com.github.pagehelper.PageInfo;
 import org.apache.ibatis.session.RowBounds;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import tk.mybatis.mapper.entity.Example;
@@ -22,9 +25,17 @@ import java.util.List;
 @Service
 public class AudioServiceImpl {
+    private static Logger logger = LoggerFactory.getLogger(AudioServiceImpl.class);
+
     @Autowired
     ShyAudioMapper shyAudioMapper;
+    @Autowired
+    AudioServiceImpl audioService;
+
+    @Autowired
+    AuditPass Pass;
+
     public ShyAudio getAudioMsg(String audioId) {
         return shyAudioMapper.getAudioMsg(audioId);
     }
@@ -94,6 +105,57 @@ public class AudioServiceImpl {
         return new ResponseBean(ErrorEnum.SUCCESS.getErrorCode(), "已退领");
     }
+    public String repulse(String shyAudioId,String msg,String userId){
+        String showMsg="";
+        ShyAudio shyAudio = audioService.selectByPrimaryKey(Integer.parseInt(shyAudioId));
+        JSONObject result;
+        try {
+            result = Pass.audioPass(shyAudio.getAudioId(), 4, msg, msg, shyAudio.getCallback());
+        } catch (Exception e) {
+            logger.error("视频审核失败,id==" + shyAudioId, e);
+            showMsg = showMsg + "," + shyAudio.getAudioTitle() + " 拒绝请求失败";
+            return showMsg;
+        }
+        if (result == null) {
+            logger.error("视频审核失败且接口错误没有返回信息,id==" + shyAudioId);
+            showMsg = showMsg + "," + shyAudio.getAudioTitle() + " 拒绝请求失败";
+            return showMsg;
+        }
+        Integer code = result.getInteger("code");
+        if (code != 0) {
+            logger.error("视频审核失败,id:{},code:{}", shyAudioId, code);
+            showMsg = showMsg + "," + shyAudio.getAudioTitle() + " " + result.getString("msg");
+            return showMsg;
+        }
+        //0.未审核,1:已审核,2.拒绝
+        int i = audioService.updateAudio(Integer.parseInt(shyAudioId), userId,null,"", 2, msg);
+        if (i == 0) {
+            showMsg = showMsg + "," + shyAudio.getAudioTitle() + " 更新失败";
+            return showMsg;
+        }
+
+        return showMsg;
+    }
+
+    public int updateAudio(Integer id, String auditor_id,String updater,String attr_tags, Integer state, String msg) {
+        ShyAudio shyAudio = shyAudioMapper.selectByPrimaryKey(id);
+        shyAudio.setAuditor_id(auditor_id);
+        shyAudio.setState(state);
+        if(CommonUtils.isNotEmpty(attr_tags)){
+            shyAudio.setAttr_tags(attr_tags);
+        }
+        if(CommonUtils.isNotEmpty(msg)){
+            shyAudio.setMsg(msg);
+        }
+        shyAudio.setUploader(updater);
+        if(CommonUtils.isNotEmpty(auditor_id)){
+            shyAudio.setReceive(CommonConst.RECEIVE_AFTER);
+            shyAudio.setReceive_user_id(auditor_id);
+            shyAudio.setShenhe_type(CommonConst.AUDIT_TYPE_USER);
+        }
+        return shyAudioMapper.updateByPrimaryKey(shyAudio);
+    }
+
     //分页查询音频数据
     public PageInfo<ShyAudio> getListContent(String video_title, String start_date, String end_date, Integer state, Integer receive, Integer page, Integer pageSize, String video_priority, String orderByClause, Integer spid, String userId, String sp_Id) {
         Example example = new Example(ShyAudio.class);
@@ -218,4 +218,29 @@ public class AuditPass {
 	        Map<String, String> post = httpUtil.post(URL);
 	        return JSONObject.parseObject(post.get("result"));
 	}
+
+	//音频回调
+	public JSONObject audioPass(String video_id, int state, String attr_tags, String msg, String callBack) {
+		logger.info("点播回调：video_id:{},state:{},attr_tags:{},msg:{}", video_id, state, attr_tags, msg);
+		JSONObject params = new JSONObject();
+		params.put("video_id", video_id);
+		params.put("state", state + "");
+		params.put("attr_tags", attr_tags);
+		params.put("msg", msg);
+		HttpUtil httpUtil = HttpUtil.init();
+		httpUtil.setParam("param", params.toJSONString());
+		String token = "";
+		try {
+			String cb = callBack.replace("//", "");
+			cb = cb.substring(cb.indexOf("/"));
+			token = CommonUtils.md5(cb + platformKey + platformValue);
+		} catch (NoSuchAlgorithmException e) {
+			e.printStackTrace();
+		} catch (UnsupportedEncodingException e) {
+			e.printStackTrace();
+		}
+		String URL = callBack + "?platform=" + platformKey + "&token=" + token;
+		Map<String, String> post = httpUtil.post(URL);
+		return JSONObject.parseObject(post.get("result"));
+	}
 }