音频数据退领功能

徐近程
1 parent 49306b4e
Showing 3 changed files with 54 additions and 1 deletions
src/main/java/com/cnlive/shenhe/controller/AudioController.java
src/main/java/com/cnlive/shenhe/serviceImpl/AudioServiceImpl.java
src/main/java/com/cnlive/shenhe/serviceImpl/VideosServiceImpl.java
@@ -133,6 +133,14 @@ public class AudioController extends BaseController {
     }
  
  
+    /**
+     * 认领
+     *
+     * @param ids
+     * @param num
+     * @param session
+     * @return
+     */
     @PostMapping("/receive")
     @ResponseBody
     public ResponseBean receive(String ids, Integer num, HttpSession session) {
@@ -157,4 +165,28 @@ public class AudioController extends BaseController {
         Integer n = audioService.receive(ids, num, userId, spid);
         return new ResponseBean(ErrorEnum.SUCCESS.getErrorCode(), "认领到" + n + "条内容");
     }
+
+
+    /**
+     * 退领
+     *
+     * @param ids
+     * @param session
+     * @return
+     */
+    @PostMapping("/retReceive")
+    @ResponseBody
+    public ResponseBean retReceive(String ids, HttpSession session) {
+        SessionUser sessionUser = (SessionUser) session.getAttribute(SessionUser.getSessionKey());
+        String userId = sessionUser.getUserId();
+        //在退领操作前先判断是否包含已退领或者已经审核的数据，有则退回检查并重新退领
+        String[] cids = ids.split(",");
+        for (String cid : cids) {
+            ShyAudio shyAudio = audioService.selectByPrimaryKey(Integer.parseInt(cid));
+            if (shyAudio.getState() != CommonConst.AUDIT_INTT || shyAudio.getReceive()==CommonConst.RECEIVE_BEFORE || !shyAudio.getReceive_user_id().equals(userId)) {
+                return new ResponseBean(ErrorEnum.ERROR.getErrorCode(), "退领失败，您选中的内容包含已退领的或已经审核的");
+            }
+        }
+        return audioService.retReceive(ids, userId);
+    }
 }
 package com.cnlive.shenhe.serviceImpl;
  
+import com.cnlive.shenhe.bean.ErrorEnum;
+import com.cnlive.shenhe.bean.ResponseBean;
 import com.cnlive.shenhe.entity.ShyAudio;
 import com.cnlive.shenhe.entity.ShyVideos;
 import com.cnlive.shenhe.mapper.ShyAudioMapper;
@@ -40,6 +42,7 @@ public class AudioServiceImpl {
         return shyAudio;
     }
  
+    //认领
     public Integer receive(String ids, Integer num, String userId, Integer spid) {
         Integer n = 0;
         if (CommonUtils.isNotEmpty(ids)) {
@@ -72,6 +75,25 @@ public class AudioServiceImpl {
         return n;
     }
  
+    //退领
+    public ResponseBean retReceive(String ids, String userId) {
+        String[] cids = ids.split(",");
+        for (String cid : cids) {
+            ShyAudio shyAudio = shyAudioMapper.selectByPrimaryKey(Integer.parseInt(cid));
+            if (shyAudio.getState() == CommonConst.AUDIT_INTT && shyAudio.getReceive()==CommonConst.RECEIVE_AFTER && shyAudio.getReceive_user_id().equals(userId)) {
+                shyAudio.setReceive(CommonConst.RECEIVE_BEFORE);
+                shyAudio.setReceive_user_id(null);
+                int i = shyAudioMapper.updateByPrimaryKey(shyAudio);
+                if (i != 1) {
+                    return new ResponseBean(ErrorEnum.ERROR.getErrorCode(), "退领失败，请重试");
+                }
+            } else {
+                return new ResponseBean(ErrorEnum.ERROR.getErrorCode(), "退领失败，您选中的内容包含已退领的或已经审核的");
+            }
+        }
+        return new ResponseBean(ErrorEnum.SUCCESS.getErrorCode(), "已退领");
+    }
+
     //分页查询音频数据
     public PageInfo<ShyAudio> getListContent(String video_title, String start_date, String end_date, Integer state, Integer receive, Integer page, Integer pageSize, String video_priority, String orderByClause, Integer spid, String userId, String sp_Id) {
         Example example = new Example(ShyAudio.class);
@@ -233,7 +233,6 @@ public class VideosServiceImpl {
     }
  
     public ResponseBean retReceive(String ids, String userId) {
-        boolean result = true;
         String[] cids = ids.split(",");
         for (String cid : cids) {
             ShyVideos shyVideos = shyVideosMapper.selectByPrimaryKey(Integer.parseInt(cid));