修改审核信息返回接口和视频送审接口

陈浩
1 parent 7c4f4998
Showing 4 changed files with 76 additions and 35 deletions
src/main/java/com/cnlive/shenhe/controller/VideosController.java
src/main/java/com/cnlive/shenhe/serviceImpl/VideosServiceImpl.java
src/main/java/com/cnlive/shenhe/utils/AuditPass.java
src/main/resources/application.properties
@@ -7,10 +7,12 @@ import com.cnlive.shenhe.bean.ResponseBean;
 import com.cnlive.shenhe.entity.ShySites;
 import com.cnlive.shenhe.entity.ShyVideos;
 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 com.cnlive.shenhe.utils.HttpUtil;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Controller;
 import org.springframework.web.bind.annotation.*;
  
@@ -29,6 +31,8 @@ import java.util.Map;
 @Controller
 @RequestMapping("/videos")
 public class VideosController {
+
+
     @Autowired
     VideosServiceImpl videosService;
     @PostMapping("/import")
@@ -47,12 +51,11 @@ public class VideosController {
                 List<String> asList = Arrays.asList(business);
                 if(asList.contains(CommonConst.BUSINESS_VIDEO+"")){
                     shyVideos.setState(CommonConst.AUDIT_SUCCESS);
-                    getInfo("",0,"","");
-
+                    AuditPass.auditPass(json.getString("videoId"),CommonConst.AUDIT_SUCCESS,"","");
+                }else {
+                    shyVideos.setState(CommonConst.AUDIT_INTT);
                 }
             }
-        }else {
-            return new ResponseBean(ErrorEnum.PARAM_ERROR);
         }
         //封装数据入库
         shyVideos.setVideo_id(json.getString("videoId"));
@@ -66,37 +69,28 @@ public class VideosController {
         shyVideos.setSpid(Integer.parseInt(json.getString("spId")));
         int i = videosService.impotVideo(shyVideos);
         if(i>0){
-            return  new ResponseBean();
+            return  new ResponseBean(ErrorEnum.SUCCESS);
         }else {
             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";
-        String platformValue="10011438";
-        String token = null;
-        try {
-            token = CommonUtils.md5(url+platformKey+platformValue);
-        } catch (NoSuchAlgorithmException e) {
-            e.printStackTrace();
-        } catch (UnsupportedEncodingException e) {
-            e.printStackTrace();
+    @RequestMapping("/shenheNotify")
+    @ResponseBody
+    public ResponseBean shenheInfo(String activity_id,int state,String attr_tags,String msg){
+        String code = AuditPass.auditPass(activity_id, state, attr_tags, msg);
+        if(code.equals("-1")){
+            return new ResponseBean(ErrorEnum.ERROR);
         }
-        Map<String, String> params = new HashMap<>();
-        params.put("activity_id",activity_id);
-        params.put("state",state+"");
-        params.put("attr_tags",attr_tags);
-        params.put("msg",msg);
-        HttpUtil httpUtil = HttpUtil.init();
-        String URL =url+"platform="+platformKey+"&token="+token;
-        httpUtil.setParamMap(params);
-        Map<String, String> post = httpUtil.post(URL);
-        String result = JSON.toJSONString(post);
-        videosService.updateVideo(activity_id,state,attr_tags,msg);
-        return  result;
+        int i = videosService.updateVideo(activity_id, state, attr_tags, msg);
+        if(i==0){
+            return new ResponseBean(ErrorEnum.ERROR);
+        }
+        return  new ResponseBean(ErrorEnum.SUCCESS);
     }
  
  
+
+
+
 }
 package com.cnlive.shenhe.serviceImpl;
-import com.alibaba.fastjson.JSONObject;
 import com.cnlive.shenhe.entity.ShySites;
 import com.cnlive.shenhe.entity.ShyVideos;
 import com.cnlive.shenhe.mapper.ShySitesMapper;
 import com.cnlive.shenhe.mapper.ShyVideosMapper;
-import com.cnlive.shenhe.utils.CommonConst;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.data.domain.Example;
 import org.springframework.stereotype.Service;
  
 import java.util.List;
@@ -31,13 +28,14 @@ public class VideosServiceImpl {
         List<ShySites> sitesList = shySitesMapper.select(shySites);
         return sitesList;
     }
-    public void updateVideo(String activity_id,int state,String attr_tags,String msg){
+    public int updateVideo(String activity_id,int state,String attr_tags,String msg){
         ShyVideos shyVideos = new ShyVideos();
         shyVideos.setVideo_id(activity_id);
+        Integer id = shyVideosMapper.select(shyVideos).get(0).getId();
+        shyVideos.setId(id);
         shyVideos.setState(state);
         shyVideos.setVideo_tags(attr_tags);
         shyVideos.setMsg(msg);
-        Example<ShyVideos> example = Example.of(shyVideos);
-        shyVideosMapper.updateByExample(shyVideos,example);
+        return shyVideosMapper.updateByPrimaryKey(shyVideos);
     }
 }
+package com.cnlive.shenhe.utils;
+
+import org.springframework.beans.factory.annotation.Value;
+
+import java.io.UnsupportedEncodingException;
+import java.security.NoSuchAlgorithmException;
+import java.util.HashMap;
+import java.util.Map;
+
+/**
+ * @Auther: chenhao
+ * @Date: 2018/12/3 16:00
+ * @Description:如果是白名单直接审核通过
+ */
+public class AuditPass {
+
+    @Value("http://mam.innerapi.cnlive.com/v1/inner/ShenHeInfo/shenheNotify")
+    private static  String url;
+    @Value("AUDIT")
+    private static String platformKey;
+    @Value("10011438")
+    private static String platformValue;
+    public static String auditPass(String activity_id,int state,String attr_tags,String msg){
+        String token = null;
+        try {
+            token = CommonUtils.md5(url+platformKey+platformValue);
+        } catch (NoSuchAlgorithmException e) {
+            e.printStackTrace();
+        } catch (UnsupportedEncodingException e) {
+            e.printStackTrace();
+        }
+        Map<String, String> params = new HashMap<>();
+        params.put("activity_id",activity_id);
+        params.put("state",state+"");
+        params.put("attr_tags",attr_tags);
+        params.put("msg",msg);
+        HttpUtil httpUtil = HttpUtil.init();
+        String URL =url+"platform="+platformKey+"&token="+token;
+        httpUtil.setParamMap(params);
+        Map<String, String> post = httpUtil.post(URL);
+        String code = post.get("code");
+        return  code;
+    }
+}
@@ -13,4 +13,9 @@ mybatis.type-aliases-package=com.cnlive.shenhe.entity
  
  
 sync_users_api=http://api.cnlive.com/open/api2/inner2/shenhe/getuser
-sync_users_app_key=314a9dd4-a9b7-4c12-bbbe-1150a36491ae
 \ No newline at end of file
+sync_users_app_key=314a9dd4-a9b7-4c12-bbbe-1150a36491ae
+
+
+url=http://mam.innerapi.cnlive.com/v1/inner/ShenHeInfo/shenheNotify
+SplatformKey =AUDIT;
+platformValue=10011438;
 \ No newline at end of file