update

陈浩
1 parent 5142a9d5
Showing 1 changed file with 65 additions and 3 deletions
src/main/java/com/cnlive/shenhe/controller/VideosController.java
@@ -7,12 +7,15 @@ import com.cnlive.shenhe.bean.ResponseBean;
 import com.cnlive.shenhe.bean.SessionUser;
 import com.cnlive.shenhe.entity.ShyUsers;
 import com.cnlive.shenhe.entity.ShyVideos;
+import com.cnlive.shenhe.serviceImpl.CommentsServiceImpl;
 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 com.github.pagehelper.PageInfo;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Controller;
 import org.springframework.ui.Model;
@@ -27,7 +30,7 @@ import java.util.List;
 @Controller
 @RequestMapping("/videos")
 public class VideosController {
-
+    private static Logger logger = LoggerFactory.getLogger(VideosController.class);
     @Autowired
     AuditPass Pass;
     @Autowired
@@ -50,6 +53,11 @@ public class VideosController {
     public ResponseBean shenheInfo(Integer id, String activity_id, Integer state, String attr_tags, String msg, String callback, HttpSession session) {
         SessionUser sessionUser = (SessionUser) session.getAttribute(SessionUser.getSessionKey());
         String userId = sessionUser.getUserId();
+        ShyVideos shyVideos = videosService.selectByPrimaryKey(id);
+        /*if (!shyVideos.getReceive() || CommonUtils.isEmpty(shyVideos.getReceive_user_id()) || !userId.equals(shyVideos.getReceive_user_id())) {
+            logger.error("领取逻辑不符，不能审核，Video_id:{}", shyVideos.getVideo_id());
+            return new ResponseBean(ErrorEnum.ERROR);
+        }*/
         JSONObject result = null;
         try {
             result = Pass.auditPass(activity_id, state, attr_tags, msg, callback);
@@ -88,13 +96,20 @@ public class VideosController {
      * @return
      */
     @GetMapping("/page")
-    public Object getListVideos(Model model, String video_title, String start_date, String end_date, Integer state, Integer page, Integer pageSize, String video_priority, String orderByClause, HttpSession session) {
+    public Object getListVideos(Model model, String video_title, String start_date, String end_date, Integer state, Boolean receive, Integer page, Integer pageSize, String video_priority, String orderByClause, HttpSession session) {
         SessionUser sessionUser = (SessionUser) session.getAttribute(SessionUser.getSessionKey());
         Integer spid = sessionUser.getSpid();
+        String userId = null;
+        //如果是我的待审则获取本人id
+        if (CommonUtils.isNotNull(receive)) {
+            if (receive == true) {
+                userId = sessionUser.getUserId();
+            }
+        }
         if (CommonUtils.isNull(page)) page = 1;
         if (CommonUtils.isNull(pageSize)) pageSize = 10;
         if (spid == 0) spid = null;
-        PageInfo<ShyVideos> videoPage = videosService.getListContent(video_title, start_date, end_date, state, page, pageSize, video_priority, orderByClause, spid);
+        PageInfo<ShyVideos> videoPage = videosService.getListContent(video_title, start_date, end_date, state, receive, page, pageSize, video_priority, orderByClause, spid, userId);
         List<ShyVideos> list = videoPage.getList();
         if (!list.isEmpty()) {
             for (ShyVideos videos : list) {
@@ -134,5 +149,52 @@ public class VideosController {
         return "page/videoDetail.html";
     }
+    /**
+     * 认领
+     *
+     * @param ids     根据id认领
+     * @param num     认领条数
+     * @param session
+     * @return
+     */
+    @PostMapping("/receive")
+    @ResponseBody
+    public ResponseBean receive(String ids, Integer num, HttpSession session) {
+        SessionUser sessionUser = (SessionUser) session.getAttribute(SessionUser.getSessionKey());
+        String userId = sessionUser.getUserId();
+        Integer spid = sessionUser.getSpid();
+        //领取时要检查领取的数据是否可以领
+        if (CommonUtils.isNotEmpty(ids)) {
+            String[] cids = ids.split(",");
+            for (String cid : cids) {
+                ShyVideos shyVideos = videosService.selectByPrimaryKey(Integer.parseInt(cid));
+                if (CommonUtils.isNotNull(shyVideos)) {
+                    if (shyVideos.getState() != CommonConst.AUDIT_INTT || shyVideos.getReceive()) {
+                        return new ResponseBean(ErrorEnum.ERROR.getErrorCode(), "您领取的内容中有已被领取或者已经被审核，请检查并重试");
+                    }
+                } else {
+                    return new ResponseBean(ErrorEnum.ERROR.getErrorCode(), "您领取的内容不存在，请检查并重试");
+
+                }
+            }
+        }
+        Integer n = videosService.receive(ids, num, userId, spid);
+        return new ResponseBean(ErrorEnum.SUCCESS.getErrorCode(), "认领到" + n + "条内容");
+    }
+
+
+    @PostMapping("/retReceive")
+    @ResponseBody
+    public ResponseBean retReceive(String ids, HttpSession session) {
+        SessionUser sessionUser = (SessionUser) session.getAttribute(SessionUser.getSessionKey());
+        String userId = sessionUser.getUserId();
+        boolean n = videosService.retReceive(ids, userId);
+        if (n) {
+            return new ResponseBean(ErrorEnum.SUCCESS);
+        } else {
+            return new ResponseBean(ErrorEnum.ERROR);
+        }
+    }
+
 }