update

陈浩
1 parent 989bae58
Showing 4 changed files with 90 additions and 11 deletions
src/main/java/com/cnlive/shenhe/api/CommentsControllerApi.java
src/main/java/com/cnlive/shenhe/job/CommentsJob.java
src/main/java/com/cnlive/shenhe/job/VideosJob.java
src/main/java/com/cnlive/shenhe/serviceImpl/CommentsServiceImpl.java
@@ -16,10 +16,6 @@ import org.springframework.stereotype.Controller;
 import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.ResponseBody;
-
-import java.sql.Timestamp;
-import java.time.Year;
-import java.util.Arrays;
 import java.util.Date;
 import java.util.List;
  
 package com.cnlive.shenhe.job;
  
 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;
@@ -70,7 +68,15 @@ public class CommentsJob {
                         logger.error("评论回调失败，activity_id:{}", comments.getActivity_id());
                     }
                     comments.setState(CommonConst.AUDIT_SUCCESS);
-                    int i = commentsService.updateComment(json1, null, comments.getAuditor_id());
+                    int i = commentsService.updateComment(comments.getId(), CommonConst.AUDIT_SUCCESS, json1.getString("msg"));
+                    if (i > 0) {
+                        logger.info("评论修改成功");
+                        System.out.println("评论修改成功");
+                    } else {
+                        logger.info("评论修改失败");
+                        System.out.println("评论修改失败");
+
+                    }
                 }
             }
         }
+package com.cnlive.shenhe.job;
+
+import com.alibaba.fastjson.JSONObject;
+import com.cnlive.shenhe.entity.ShySites;
+import com.cnlive.shenhe.entity.ShyVideos;
+import com.cnlive.shenhe.serviceImpl.CommentsServiceImpl;
+import com.cnlive.shenhe.serviceImpl.SitesServiceImpl;
+import com.cnlive.shenhe.serviceImpl.UsersServiceImpl;
+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.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.List;
+
+@Component
+public class VideosJob {
+    private static Logger logger = LoggerFactory.getLogger(CommentsJob.class);
+    @Autowired
+    SitesServiceImpl sitesService;
+    @Autowired
+    AuditPass Pass;
+    @Autowired
+    CommentsServiceImpl commentsService;
+    @Autowired
+    UsersServiceImpl usersService;
+    @Autowired
+    VideosServiceImpl videosService;
+
+
+    @Scheduled(fixedRate = 30 * 60 * 1000)
+    public void syncComments() {
+
+        //收集免审的spid
+        List<ShySites> sitesList = sitesService.findAll();
+        ArrayList<Integer> sites = new ArrayList<Integer>();
+        for (ShySites shySites : sitesList) {
+            if (CommonUtils.isNotEmpty(shySites.getWrite_business())) {
+                String[] business = shySites.getWrite_business().split(",");
+                List<String> asList = Arrays.asList(business);
+                if (asList.contains(CommonConst.BUSINESS_VIDEO + "")) {
+                    sites.add(shySites.getSpid());
+                }
+            }
+        }
+        //遍历免审的spid去更改状态值
+        ShyVideos shyVideos = new ShyVideos();
+        for (int spid : sites) {
+            shyVideos.setSpid(spid);
+            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());
+                    } 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("点播视频更改失败");
+                    }
+                }
+            }
+        }
+    }
+
+}
@@ -65,11 +65,10 @@ public class CommentsServiceImpl {
         return true;
     }
  
-    public int updateComment(JSONObject json, Integer id, String auditor_id) {
+    public int updateComment(Integer id, Integer state, String msg) {
         ShyComments shyComments = shyCommentsMapper.selectByPrimaryKey(id);
-        shyComments.setAuditor_id(auditor_id);
-        shyComments.setState(json.getInteger("state"));
-        shyComments.setMsg(json.getString("msg"));
+        shyComments.setState(state);
+        shyComments.setMsg(msg);
         return shyCommentsMapper.updateByPrimaryKeySelective(shyComments);
     }