update

周伟鹏
1 parent 1c2cfab6
Showing 2 changed files with 28 additions and 8 deletions
src/main/java/com/cnlive/shenhe/controller/VideosController.java
src/main/java/com/cnlive/shenhe/utils/CommonConst.java
@@ -2,6 +2,8 @@ package com.cnlive.shenhe.controller;
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.JSONObject;
+import com.cnlive.shenhe.bean.ErrorEnum;
+import com.cnlive.shenhe.bean.ResponseBean;
 import com.cnlive.shenhe.entity.ShySites;
 import com.cnlive.shenhe.entity.ShyVideos;
 import com.cnlive.shenhe.serviceImpl.VideosServiceImpl;
@@ -14,6 +16,7 @@ import org.springframework.web.bind.annotation.*;
 import java.io.UnsupportedEncodingException;
 import java.security.NoSuchAlgorithmException;
+import java.util.Arrays;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
@@ -30,20 +33,26 @@ public class VideosController {
     VideosServiceImpl videosService;
     @PostMapping("/import")
     @ResponseBody
-    public String impotVideo(@RequestBody  JSONObject json){
+    public ResponseBean impotVideo(@RequestBody  JSONObject json){
         ShySites shySites = new ShySites();
         ShyVideos shyVideos = new ShyVideos();
+        shyVideos.setState(CommonConst.AUDIT_INTT);
         //判断是否白名单
-        shySites.setSpid(Integer.parseInt(json.getString("spId")));
+        shySites.setSpid(json.getInteger("spId"));
         List<ShySites> shySitesList = videosService.getBusiness(shySites);
         if(!shySitesList.isEmpty()){
             if(!shySitesList.get(0).getWrite_business().isEmpty()){
-                shyVideos.setState(CommonConst.AUDIT_SUCCESS);
-            }else {
-                shyVideos.setState(CommonConst.AUDIT_INTT);
+                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+"")){
+                    shyVideos.setState(CommonConst.AUDIT_SUCCESS);
+                    getInfo("",0,"","");
+
+                }
             }
         }else {
-            return "没有此站点";
+            return new ResponseBean(ErrorEnum.PARAM_ERROR);
         }
         //封装数据入库
         shyVideos.setVideo_id(json.getString("videoId"));
@@ -57,11 +66,12 @@ public class VideosController {
         shyVideos.setSpid(Integer.parseInt(json.getString("spId")));
         int i = videosService.impotVideo(shyVideos);
         if(i>0){
-            return  "\"errorCode\" = 0,\"errorMessage\" = \"点播审核请求收到成功\"";
+            return  new ResponseBean();
         }else {
-            return  "\"errorCode\" = 0,\"errorMessage\" = \"点播审核请求收到失败\"";
+            return  new ResponseBean(ErrorEnum.ERROR);
         }
     }
+
     public String getInfo(String activity_id,int state,String attr_tags,String msg){
         String url ="http://mam.innerapi.cnlive.com/v1/inner/ShenHeInfo/shenheNotify";
         String platformKey ="AUDIT";
@@ -29,4 +29,14 @@ public class CommonConst {
      */
     public static Integer USER_STATUS_FORBID = 2;
+
+    /**
+     * 白名单业务：点播
+     */
+    public static Integer BUSINESS_VIDEO = 1;
+    /**
+     * 白名单业务：评论
+     */
+    public static Integer BUSINESS_COMMENT = 2;
+
 }