点播回调参数修改

周伟鹏
1 parent cff389be
Showing 2 changed files with 16 additions and 5 deletions
src/main/java/com/cnlive/shenhe/api/VideosControllerApi.java
src/main/java/com/cnlive/shenhe/utils/AuditPass.java
@@ -10,6 +10,8 @@ import com.cnlive.shenhe.serviceImpl.VideosServiceImpl;
 import com.cnlive.shenhe.utils.AuditPass;
 import com.cnlive.shenhe.utils.CommonConst;
 import com.cnlive.shenhe.utils.CommonUtils;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Controller;
 import org.springframework.web.bind.annotation.PostMapping;
@@ -28,6 +30,7 @@ import java.util.List;
 @Controller
 @RequestMapping("/api/videos")
 public class VideosControllerApi {
+    private static Logger logger = LoggerFactory.getLogger(VideosControllerApi.class);
     @Autowired
     AuditPass Pass;
     @Autowired
@@ -38,19 +41,22 @@ public class VideosControllerApi {
     @PostMapping("/import")
     @ResponseBody
     public ResponseBean impotVideo(@RequestBody JSONObject json) {
+        logger.info("点播入库，json====="+json.toJSONString());
         ShySites shySites = new ShySites();
         ShyVideos shyVideos = new ShyVideos();
         shyVideos.setState(CommonConst.AUDIT_INTT);
         //判断是否白名单
         shySites.setSpid(json.getInteger("spId"));
         List<ShySites> shySitesList = videosService.getBusiness(shySites);
+        String videoId = json.getString("videoId");
         if (!shySitesList.isEmpty()) {
             if (CommonUtils.isNotEmpty(shySitesList.get(0).getWrite_business())) {
                 String write_business = shySitesList.get(0).getWrite_business();
                 String[] business = write_business.split(",");
                 List<String> asList = Arrays.asList(business);
                 if (asList.contains(CommonConst.BUSINESS_VIDEO + "")) {
-                    JSONObject result = Pass.auditPass(json.getString("videoId"), 3, "", "");
+                    logger.info("白名单回调通过:videoId==="+videoId);
+                    JSONObject result = Pass.auditPass(videoId, 3, "", "");
                     Integer code = result.getInteger("code");
                     if (code != 0) {
                         return new ResponseBean(code, result.getString("msg"));
@@ -60,7 +66,7 @@ public class VideosControllerApi {
             }
         }
         //封装数据入库
-        shyVideos.setVideo_id(json.getString("videoId"));
+        shyVideos.setVideo_id(videoId);
         shyVideos.setVideo_title(json.getString("videoTitle"));
         shyVideos.setVideo_url(json.getString("videoUrl"));
         String videoCoverUrl = json.getString("videoCoverUrl");
 package com.cnlive.shenhe.utils;
 import com.alibaba.fastjson.JSONObject;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Component;
@@ -16,7 +18,7 @@ import java.util.Map;
  */
 @Component
 public class AuditPass {
-
+    private static Logger logger = LoggerFactory.getLogger(AuditPass.class);
     @Value("${url}")
     private   String url;//点播url
     @Value("${platformKey}")
@@ -35,6 +37,7 @@ public class AuditPass {
      * @return
      */
     public  JSONObject auditPass(String video_id,int state,String attr_tags,String msg){
+        logger.info("点播回调：video_id:{},state:{},attr_tags:{},msg:{}",video_id,state,attr_tags,msg);
         String token = null;
         try {
             token = CommonUtils.md5(url+platformKey+platformValue);
@@ -43,14 +46,16 @@ public class AuditPass {
         } catch (UnsupportedEncodingException e) {
             e.printStackTrace();
         }
-        Map<String, String> params = new HashMap<>();
+        Map<String, String> paramsMap = new HashMap<>();
+        JSONObject params = new JSONObject();
         params.put("video_id",video_id);
         params.put("state",state+"");
         params.put("attr_tags",attr_tags);
         params.put("msg",msg);
+        paramsMap.put("params",params.toJSONString());
         HttpUtil httpUtil = HttpUtil.init();
         String URL =url+"?platform="+platformKey+"&token="+token;
-        httpUtil.setParamMap(params);
+        httpUtil.setParamMap(paramsMap);
         Map<String, String> post = httpUtil.post(URL);
         return  JSONObject.parseObject(post.get("result"));
     }