音频数据认领功能

徐近程
1 parent e0af38fb
Showing 4 changed files with 74 additions and 4 deletions
src/main/java/com/cnlive/shenhe/api/AudioControllerApi.java
src/main/java/com/cnlive/shenhe/controller/AudioController.java
src/main/java/com/cnlive/shenhe/serviceImpl/AudioServiceImpl.java
src/main/resources/templates/page/audio.html
@@ -68,6 +68,7 @@ public class AudioControllerApi {
                 return new ResponseBean(ErrorEnum.SUCCESS);
             }
             shyAudio.setCreateTime(new Date());
+            shyAudio.setState(0);
             audioService.importAudioMsg(shyAudio);
         } catch (Exception e) {
             e.printStackTrace();
 package com.cnlive.shenhe.controller;
+import com.cnlive.shenhe.bean.ErrorEnum;
+import com.cnlive.shenhe.bean.ResponseBean;
 import com.cnlive.shenhe.bean.SessionUser;
 import com.cnlive.shenhe.entity.ShyAudio;
 import com.cnlive.shenhe.entity.ShySites;
 import com.cnlive.shenhe.entity.ShyUsers;
+import com.cnlive.shenhe.entity.ShyVideos;
 import com.cnlive.shenhe.serviceImpl.AudioServiceImpl;
 import com.cnlive.shenhe.serviceImpl.SitesServiceImpl;
 import com.cnlive.shenhe.serviceImpl.UsersServiceImpl;
@@ -16,7 +19,9 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Controller;
 import org.springframework.ui.Model;
 import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.ResponseBody;
 import javax.servlet.http.HttpSession;
 import java.util.List;
@@ -127,4 +132,29 @@ public class AudioController extends BaseController {
         return "page/audio.html";
     }
+
+    @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) {
+                ShyAudio shyAudio = audioService.selectByPrimaryKey(Integer.parseInt(cid));
+                if (CommonUtils.isNotNull(shyAudio)) {
+                    if (shyAudio.getState() != CommonConst.AUDIT_INTT || shyAudio.getReceive()==CommonConst.RECEIVE_AFTER) {
+                        return new ResponseBean(ErrorEnum.ERROR.getErrorCode(), "您领取的内容中有已被领取或者已经被审核，请检查并重试");
+                    }
+                } else {
+                    return new ResponseBean(ErrorEnum.ERROR.getErrorCode(), "您领取的内容不存在，请检查并重试");
+
+                }
+            }
+        }
+        Integer n = audioService.receive(ids, num, userId, spid);
+        return new ResponseBean(ErrorEnum.SUCCESS.getErrorCode(), "认领到" + n + "条内容");
+    }
 }
 package com.cnlive.shenhe.serviceImpl;
 import com.cnlive.shenhe.entity.ShyAudio;
+import com.cnlive.shenhe.entity.ShyVideos;
 import com.cnlive.shenhe.mapper.ShyAudioMapper;
 import com.cnlive.shenhe.utils.CommonConst;
 import com.cnlive.shenhe.utils.CommonUtils;
 import com.github.pagehelper.PageHelper;
 import com.github.pagehelper.PageInfo;
+import org.apache.ibatis.session.RowBounds;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
 import tk.mybatis.mapper.entity.Example;
@@ -33,6 +35,43 @@ public class AudioServiceImpl {
         return shyAudioMapper.updateByPrimaryKeySelective(ShyAudio);
     }
+    public ShyAudio selectByPrimaryKey(Integer id) {
+        ShyAudio shyAudio = shyAudioMapper.selectByPrimaryKey(id);
+        return shyAudio;
+    }
+
+    public Integer receive(String ids, Integer num, String userId, Integer spid) {
+        Integer n = 0;
+        if (CommonUtils.isNotEmpty(ids)) {
+            String[] cids = ids.split(",");
+            for (String cid : cids) {
+                ShyAudio shyAudio = shyAudioMapper.selectByPrimaryKey(Integer.parseInt(cid));
+                if (CommonUtils.isNotNull(shyAudio) && shyAudio.getState() == CommonConst.AUDIT_INTT && shyAudio.getReceive()==CommonConst.RECEIVE_BEFORE) {
+                    shyAudio.setReceive_user_id(userId);
+                    shyAudio.setReceive(CommonConst.RECEIVE_AFTER);
+                    shyAudioMapper.updateByPrimaryKeySelective(shyAudio);
+                    n++;
+                }
+            }
+        } else if (CommonUtils.isNotNull(num) && num > 0) {
+            Example example = new Example(ShyAudio.class);
+            example.setOrderByClause("createTime desc");
+            example.and().andEqualTo("state", CommonConst.AUDIT_INTT);
+            example.and().andEqualTo("receive", CommonConst.RECEIVE_BEFORE);
+            if (CommonUtils.isNotNull(spid) && spid != 0) example.and().andEqualTo("spid", spid);
+            List<ShyAudio> shyCommentsList = shyAudioMapper.selectByExampleAndRowBounds(example, new RowBounds(0, num));
+            if (!shyCommentsList.isEmpty()) {
+                for (ShyAudio shyComments : shyCommentsList) {
+                    shyComments.setReceive_user_id(userId);
+                    shyComments.setReceive(CommonConst.RECEIVE_AFTER);
+                    shyAudioMapper.updateByPrimaryKeySelective(shyComments);
+                    n++;
+                }
+            }
+        }
+        return n;
+    }
+
     //分页查询音频数据
     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);
@@ -258,13 +258,13 @@
                                                     <button  class="btn btn-info btn-sm" th:style="${state1 eq '0' && receive1 eq  'false'} ? 'display: none ' : ' '">查看</button>
                                                 </a>
                                                 <span th:if="${audio.state==0 and audio.receive==0}"> &nbsp;</span>
-                                                <a th:href="@{'javascript:applyReceive('+${video.id}+')'}"
+                                                <a th:href="@{'javascript:applyReceive('+${audio.id}+')'}"
                                                    th:if="${audio.state==0 and audio.receive==0}">
                                                     <button class="btn btn-primary btn-sm">认领</button>
                                                 </a>
-                                                <span th:if="${audio.state==0 and audio.receive==1 and session.sessionUser.userId==video.receive_user_id}"> &nbsp;</span>
-                                                <a th:href="@{'javascript:applyRetReceive('+${video.id}+')'}"
-                                                   th:if="${audio.state==0 and audio.receive==1 and session.sessionUser.userId==video.receive_user_id}">
+                                                <span th:if="${audio.state==0 and audio.receive==1 and session.sessionUser.userId==audio.receive_user_id}"> &nbsp;</span>
+                                                <a th:href="@{'javascript:applyRetReceive('+${audio.id}+')'}"
+                                                   th:if="${audio.state==0 and audio.receive==1 and session.sessionUser.userId==audio.receive_user_id}">
                                                     <button class="btn btn-warning btn-sm">退领</button>
                                                 </a>
                                             </td>