update

周伟鹏
1 parent cc73da74
Showing 3 changed files with 13 additions and 16 deletions
src/main/java/com/cnlive/shenhe/api/CommentsControllerApi.java
src/main/java/com/cnlive/shenhe/api/VideosControllerApi.java
src/main/java/com/cnlive/shenhe/job/VideosJob.java
@@ -4,7 +4,6 @@ import com.alibaba.fastjson.JSONObject;
 import com.cnlive.shenhe.bean.ErrorEnum;
 import com.cnlive.shenhe.bean.ResponseBean;
 import com.cnlive.shenhe.entity.ShyComments;
-import com.cnlive.shenhe.entity.ShySites;
 import com.cnlive.shenhe.serviceImpl.CommentsServiceImpl;
 import com.cnlive.shenhe.utils.AuditPass;
 import com.cnlive.shenhe.utils.CommonConst;
@@ -92,7 +91,6 @@ public class CommentsControllerApi {
         shyComments.setSpid(json.getInteger("spId"));
         shyComments.setApp_id(json.getString("appId"));
         shyComments.setPlatform(json.getString("platform"));
-        shyComments.setActivity_id(json.getString("activityId"));
         shyComments.setIs_hot(json.getBoolean("priority"));
         shyComments.setCallback(json.getString("callback"));
         boolean YorN = commentsService.impotComments(shyComments);
@@ -3,7 +3,6 @@ package com.cnlive.shenhe.api;
 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.UsersServiceImpl;
 import com.cnlive.shenhe.serviceImpl.VideosServiceImpl;
@@ -18,7 +17,6 @@ import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.ResponseBody;
-import java.util.Arrays;
 import java.util.List;
 /**
@@ -76,7 +74,6 @@ public class VideosControllerApi {
             }
         }
         //查了，没有，直接插入数据库
-        shyVideos1.setVideo_id(videoId);
         shyVideos1.setVideo_title(json.getString("videoTitle"));
         shyVideos1.setVideo_url(json.getString("videoUrl"));
         String videoCoverUrl = json.getString("videoCoverUrl");
@@ -22,7 +22,7 @@ import java.util.List;
 @Component
 public class VideosJob {
-    private static Logger logger = LoggerFactory.getLogger(CommentsJob.class);
+    private static Logger logger = LoggerFactory.getLogger(VideosJob.class);
     @Autowired
     SitesServiceImpl sitesService;
     @Autowired
@@ -35,9 +35,8 @@ public class VideosJob {
     VideosServiceImpl videosService;
-    @Scheduled(fixedRate = 30 * 60 * 1000)
-    public void syncComments() {
-
+    @Scheduled(fixedRate =  60 * 1000)
+    public void updateVideos() {
         //收集免审的spid
         List<ShySites> sitesList = sitesService.findAll();
         ArrayList<Integer> sites = new ArrayList<Integer>();
@@ -54,22 +53,25 @@ public class VideosJob {
         ShyVideos shyVideos = new ShyVideos();
         for (int spid : sites) {
             shyVideos.setSpid(spid);
+            shyVideos.setState(CommonConst.AUDIT_INTT);
             List<ShyVideos> shyVideosList = videosService.findshyVideo(shyVideos);
             if (shyVideosList.size() > 0) {
                 for (ShyVideos video : shyVideosList) {
                     JSONObject result = new JSONObject();
                     try {
                         result = Pass.auditPass(video.getVideo_id(), 3, "", "", video.getCallback());
+                        Integer code = result.getInteger("code");
+                        if (0 == code) {
+                            int i = videosService.updateVideo(video.getId(), video.getAuditor_id(), CommonConst.AUDIT_SUCCESS, "");
+                            if (i != 1) {
+                                logger.error("点播视频更改失败,activity_id:{}", video.getVideo_id());
+                            }
+                        } else {
+                            logger.error("点播视频回调失败，activity_id:{},code:{},msg:{}", video.getVideo_id(), code, result.getString("msg"));
+                        }
                     } catch (Exception e) {
                         logger.error("点播视频回调失败，activity_id:{}", video.getVideo_id());
                     }
-                    int i = videosService.updateVideo(video.getId(), video.getAuditor_id(), CommonConst.AUDIT_SUCCESS, "");
-                    if (i > 0) {
-                        System.out.println("点播视频更改成功");
-                        logger.info("点播视频更改成功");
-                    } else {
-                        logger.info("点播视频更改失败");
-                    }
                 }
             }
         }