回调地址修改

周伟鹏
1 parent 7e16cbee
Showing 2 changed files with 27 additions and 16 deletions
src/main/java/com/cnlive/shenhe/utils/AuditPass.java
src/main/resources/application.properties
@@ -6,6 +6,8 @@ import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Component;
+import java.io.UnsupportedEncodingException;
+import java.security.NoSuchAlgorithmException;
 import java.util.HashMap;
 import java.util.Map;
@@ -18,36 +20,46 @@ import java.util.Map;
 public class AuditPass {
     private static Logger logger = LoggerFactory.getLogger(AuditPass.class);
     @Value("${platformKey}")
-    private  String platformKey;//点播platformKey
+    private String platformKey;//点播platformKey
     @Value("${platformValue}")
-    private  String platformValue;//点播platformValue
-    @Value("${token}")
-    private String token;
+    private String platformValue;//点播platformValue
+
     /**
      * 点播视频回调
+     *
      * @param video_id
      * @param state
      * @param attr_tags
      * @param msg
      * @return
      */
-    public  JSONObject auditPass(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);
+    public JSONObject auditPass(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);
+        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 URL =callBack+"?platform="+platformKey+"&token="+token;
+        httpUtil.setParam("param", params.toJSONString());
+        String token = "";
+        try {
+            String cb = callBack.replace("//", "");
+            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"));
+        return JSONObject.parseObject(post.get("result"));
     }
-    public JSONObject commentPass(JSONObject json,String callBack){
+    public JSONObject commentPass(JSONObject json, String callBack) {
         Map<String, String> map = new HashMap<>();
-        map.put("param",json.toJSONString());
+        map.put("param", json.toJSONString());
         String result = HttpUtil.form(callBack, map);
         return JSONObject.parseObject(result);
     }
@@ -27,7 +27,6 @@ sync_users_app_key=314a9dd4-a9b7-4c12-bbbe-1150a36491ae
 url=http://mam.innerapi.cnlive.com/v1/inner/ShenHeInfo/shenheNotify
 platformKey =AUDIT
 platformValue=10011438
-token=2718c88930175686e40398994cead75c
 #ÆÀÂÛ»Øµ÷µØÖ·
 commenturl=http://comment.cnlive.com/services/commentForHd/auditCallBack
 \ No newline at end of file