Merge branch 'dev' of http://bj.gitlab.cnlive.com/zhouweipeng/cnlive_shenhe into dev

陈浩
2 parents b8ef8f4a 130d8296
Showing 9 changed files with 429 additions and 56 deletions
src/main/java/com/cnlive/shenhe/controller/CommentsController.java
src/main/java/com/cnlive/shenhe/entity/ShyComments.java
src/main/java/com/cnlive/shenhe/entity/ShyUsers.java
src/main/java/com/cnlive/shenhe/entity/ShyVideos.java
src/main/java/com/cnlive/shenhe/serviceImpl/CommentsServiceImpl.java
src/main/java/com/cnlive/shenhe/utils/CommonConst.java
src/main/resources/mapper/ShyCommentsMapper.xml
src/main/resources/mapper/ShyVideosMapper.xml
src/main/resources/templates/page/comment.html
@@ -48,10 +48,11 @@ public class CommentsController {
      */
     @GetMapping("/page")
     public String getPage(Model model, String activity_id, String content, Integer is_hot,
-                          String start_date, String end_date, String state,
+                          String start_date, String end_date, String state,Boolean receive,
                           Integer page, Integer pageSize, String orderByClause, HttpSession session) {
         SessionUser sessionUser = (SessionUser) session.getAttribute(SessionUser.getSessionKey());
         Integer spid = sessionUser.getSpid();
+        String userId = sessionUser.getUserId();
         if (spid == 0) spid = null;
         if (CommonUtils.isNull(page)) page = 1;
         if (CommonUtils.isNull(pageSize)) pageSize = 10;
@@ -70,7 +71,7 @@ public class CommentsController {
             } catch (Exception e) {
             }
         }
-        PageInfo<ShyComments> commentPage = commentsService.getPage(activity_id, content, is_hot, sDate, eDate, state, null, page, pageSize, orderByClause, spid);
+        PageInfo<ShyComments> commentPage = commentsService.getPage(activity_id, content, is_hot, sDate, eDate, state,receive, null, page, pageSize, orderByClause, spid,userId);
         List<ShyComments> list = commentPage.getList();
         if (!list.isEmpty()) {
             for (ShyComments comment : list) {
@@ -148,4 +149,36 @@ public class CommentsController {
     }
+
+    /**
+     * 认领
+     * @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();
+        Integer n = commentsService.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 = commentsService.retReceive(ids, userId);
+        if(n){
+            return new ResponseBean();
+        }else{
+            return new ResponseBean(ErrorEnum.ERROR);
+        }
+    }
+
 }
 package com.cnlive.shenhe.entity;
+import javax.persistence.Id;
+import javax.persistence.Table;
+import javax.persistence.Transient;
 import java.util.Date;
-import javax.persistence.*;
 @Table(name = "shy_comments")
 public class ShyComments {
@@ -64,11 +66,6 @@ public class ShyComments {
      * 审核员id
      */
     private String auditor_id;
-    /**
-     * 审核员
-     */
-    @Transient
-    private String auditor;
     /**
      * 回调函数
@@ -110,6 +107,22 @@ public class ShyComments {
     private Date updated_at;
     /**
+     * 领取状态。0：未领取；1：已领取
+     */
+    private Boolean receive;
+
+    /**
+     * 领取人id
+     */
+    private String receive_user_id;
+
+    /**
+     * 审核员
+     */
+    @Transient
+    private String auditor;
+
+    /**
      * @return id
      */
     public Integer getId() {
@@ -489,6 +502,42 @@ public class ShyComments {
         this.updated_at = updated_at;
     }
+    /**
+     * 获取领取状态。0：未领取；1：已领取
+     *
+     * @return receive - 领取状态。0：未领取；1：已领取
+     */
+    public Boolean getReceive() {
+        return receive;
+    }
+
+    /**
+     * 设置领取状态。0：未领取；1：已领取
+     *
+     * @param receive 领取状态。0：未领取；1：已领取
+     */
+    public void setReceive(Boolean receive) {
+        this.receive = receive;
+    }
+
+    /**
+     * 获取领取人id
+     *
+     * @return receive_user_id - 领取人id
+     */
+    public String getReceive_user_id() {
+        return receive_user_id;
+    }
+
+    /**
+     * 设置领取人id
+     *
+     * @param receive_user_id 领取人id
+     */
+    public void setReceive_user_id(String receive_user_id) {
+        this.receive_user_id = receive_user_id;
+    }
+
     public String getAuditor() {
         return auditor;
     }
 package com.cnlive.shenhe.entity;
+import javax.persistence.Id;
+import javax.persistence.Table;
 import java.util.Date;
-import javax.persistence.*;
 @Table(name = "shy_users")
 public class ShyUsers {
@@ -63,19 +64,6 @@ public class ShyUsers {
     private Long tm;
     private String user_logo;
-    /**
-     * 审核员
-     */
-    @Transient
-    private String auditor;
-
-    public String getAuditor() {
-        return auditor;
-    }
-
-    public void setAuditor(String auditor) {
-        this.auditor = auditor;
-    }
     /**
      * @return id
 package com.cnlive.shenhe.entity;
+import javax.persistence.Id;
+import javax.persistence.Table;
+import javax.persistence.Transient;
 import java.util.Date;
-import javax.persistence.*;
 @Table(name = "shy_videos")
 public class ShyVideos {
@@ -45,7 +47,7 @@ public class ShyVideos {
     private String callback;
     /**
-     * 优先级
+     * 优先级,1：热点，0：非热点
      */
     private String video_priority;
@@ -82,20 +84,38 @@ public class ShyVideos {
     private Date created_at;
     private Date updated_at;
+
+    /**
+     * 领取状态。0：未领取；1：已领取
+     */
+    private Boolean receive;
+
+    /**
+     * 领取人id
+     */
+    private String receive_user_id;
+
+    /**
+     * 是否抽帧
+     */
+    private Boolean avsample;
+
+    /**
+     * 抽帧图片地址
+     */
+    private String avsample_imgs;
+
+    /**
+     * 抽帧返回信息(主要找问题时使用)
+     */
+    private String avsample_msg;
+
     /**
      * 审核员
      */
     @Transient
     private String auditor;
-    public String getAuditor() {
-        return auditor;
-    }
-
-    public void setAuditor(String auditor) {
-        this.auditor = auditor;
-    }
-
     /**
      * @return id
      */
@@ -261,18 +281,18 @@ public class ShyVideos {
     }
     /**
-     * 获取优先级
+     * 获取优先级,1：热点，0：非热点
      *
-     * @return video_priority - 优先级
+     * @return video_priority - 优先级,1：热点，0：非热点
      */
     public String getVideo_priority() {
         return video_priority;
     }
     /**
-     * 设置优先级
+     * 设置优先级,1：热点，0：非热点
      *
-     * @param video_priority 优先级
+     * @param video_priority 优先级,1：热点，0：非热点
      */
     public void setVideo_priority(String video_priority) {
         this.video_priority = video_priority;
@@ -413,4 +433,102 @@ public class ShyVideos {
     public void setUpdated_at(Date updated_at) {
         this.updated_at = updated_at;
     }
+
+    /**
+     * 获取领取状态。0：未领取；1：已领取
+     *
+     * @return receive - 领取状态。0：未领取；1：已领取
+     */
+    public Boolean getReceive() {
+        return receive;
+    }
+
+    /**
+     * 设置领取状态。0：未领取；1：已领取
+     *
+     * @param receive 领取状态。0：未领取；1：已领取
+     */
+    public void setReceive(Boolean receive) {
+        this.receive = receive;
+    }
+
+    /**
+     * 获取领取人id
+     *
+     * @return receive_user_id - 领取人id
+     */
+    public String getReceive_user_id() {
+        return receive_user_id;
+    }
+
+    /**
+     * 设置领取人id
+     *
+     * @param receive_user_id 领取人id
+     */
+    public void setReceive_user_id(String receive_user_id) {
+        this.receive_user_id = receive_user_id;
+    }
+
+    /**
+     * 获取是否抽帧
+     *
+     * @return avsample - 是否抽帧
+     */
+    public Boolean getAvsample() {
+        return avsample;
+    }
+
+    /**
+     * 设置是否抽帧
+     *
+     * @param avsample 是否抽帧
+     */
+    public void setAvsample(Boolean avsample) {
+        this.avsample = avsample;
+    }
+
+    /**
+     * 获取抽帧图片地址
+     *
+     * @return avsample_imgs - 抽帧图片地址
+     */
+    public String getAvsample_imgs() {
+        return avsample_imgs;
+    }
+
+    /**
+     * 设置抽帧图片地址
+     *
+     * @param avsample_imgs 抽帧图片地址
+     */
+    public void setAvsample_imgs(String avsample_imgs) {
+        this.avsample_imgs = avsample_imgs;
+    }
+
+    /**
+     * 获取抽帧返回信息(主要找问题时使用)
+     *
+     * @return avsample_msg - 抽帧返回信息(主要找问题时使用)
+     */
+    public String getAvsample_msg() {
+        return avsample_msg;
+    }
+
+    /**
+     * 设置抽帧返回信息(主要找问题时使用)
+     *
+     * @param avsample_msg 抽帧返回信息(主要找问题时使用)
+     */
+    public void setAvsample_msg(String avsample_msg) {
+        this.avsample_msg = avsample_msg;
+    }
+
+    public String getAuditor() {
+        return auditor;
+    }
+
+    public void setAuditor(String auditor) {
+        this.auditor = auditor;
+    }
 }
 \ No newline at end of file
@@ -47,7 +47,7 @@ public class CommentsServiceImpl {
     //**************************************
     public List<ShyComments> findshyComments(ShyComments shyComments) {
-        List<ShyComments> commentsList = shyCommentsMapper.selectByRowBounds(shyComments,new RowBounds(0,100));
+        List<ShyComments> commentsList = shyCommentsMapper.selectByRowBounds(shyComments, new RowBounds(0, 100));
         return commentsList;
     }
@@ -74,7 +74,7 @@ public class CommentsServiceImpl {
         return shyCommentsMapper.updateByPrimaryKeySelective(shyComments);
     }
-    public PageInfo<ShyComments> getPage(String activity_id, String content, Integer is_hot, Date start_date, Date end_date, String states, String auditor, Integer page, Integer pageSize, String orderByClause, Integer spid) {
+    public PageInfo<ShyComments> getPage(String activity_id, String content, Integer is_hot, Date start_date, Date end_date, String states,Boolean receive, String auditor, Integer page, Integer pageSize, String orderByClause, Integer spid,String userId) {
         Example example = new Example(ShyComments.class);
         Example.Criteria criteria = example.createCriteria();
         if (CommonUtils.isNotEmpty(orderByClause)) {
@@ -101,6 +101,13 @@ public class CommentsServiceImpl {
         if (CommonUtils.isNotEmpty(activity_id)) {
             criteria.andLike("activity_id", "%" + activity_id + "%");
         }
+        if(CommonUtils.isNotNull(receive)){
+            criteria.andEqualTo("receive",receive);
+            if(receive){
+                criteria.andEqualTo("receive_user_id",userId);
+            }
+        }
+
         if (CommonUtils.isNotEmpty(states)) {
             Example.Criteria criteria1 = example.createCriteria();
             String[] stas = states.split(",");
@@ -109,6 +116,7 @@ public class CommentsServiceImpl {
             }
             example.and(criteria1);
         }
+
         PageHelper.startPage(page, pageSize, true);
         List<ShyComments> commentsList = shyCommentsMapper.selectByExample(example);
         PageInfo<ShyComments> pageInfo = new PageInfo<>(commentsList);
@@ -124,8 +132,8 @@ public class CommentsServiceImpl {
                 ShyUsers user = new ShyUsers();
                 user.setUser_id(auditor_id);
                 user = shyUsersMapper.selectOne(user);
-                String userName = CommonUtils.isEmpty(user.getUsername())?"":user.getUsername();
-                String email = CommonUtils.isEmpty(user.getEmail())?"":user.getEmail();
+                String userName = CommonUtils.isEmpty(user.getUsername()) ? "" : user.getUsername();
+                String email = CommonUtils.isEmpty(user.getEmail()) ? "" : user.getEmail();
                 auditorName = userName + email;
             }
             comment.setAuditor(auditorName);
@@ -138,6 +146,12 @@ public class CommentsServiceImpl {
         String[] commentIds = ids.split(",");
         for (String commentId : commentIds) {
             ShyComments comment = shyCommentsMapper.selectByPrimaryKey(Integer.parseInt(commentId));
+            if(!comment.getReceive() || CommonUtils.isEmpty(comment.getReceive_user_id()) || !userId.equals(comment.getReceive_user_id())){
+                logger.error("领取逻辑不符，不能审核，activity_id:{}", comment.getActivity_id());
+                success = false;
+                break;
+            }
+            
             JSONObject json = new JSONObject();
             json.put("activity_id", comment.getActivity_id());
             json.put("state", state + 2);
@@ -173,6 +187,55 @@ public class CommentsServiceImpl {
         }
         return success;
     }
+
+    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) {
+                ShyComments shyComments = shyCommentsMapper.selectByPrimaryKey(Integer.parseInt(cid));
+                if (CommonUtils.isNotNull(shyComments) && shyComments.getState() == CommonConst.AUDIT_INTT && !shyComments.getReceive()) {
+                    shyComments.setReceive_user_id(userId);
+                    shyComments.setReceive(true);
+                    shyCommentsMapper.updateByPrimaryKeySelective(shyComments);
+                    n++;
+                }
+            }
+        } else if (CommonUtils.isNotNull(num) && num > 0) {
+            Example example = new Example(ShyComments.class);
+            example.setOrderByClause("created_at desc");
+            example.and().andEqualTo("state", CommonConst.AUDIT_INTT);
+            example.and().andEqualTo("receive", CommonConst.RECEIVE_AFTER);
+            if (CommonUtils.isNotNull(spid) && spid != 0) example.and().andEqualTo("spid", spid);
+            List<ShyComments> shyCommentsList = shyCommentsMapper.selectByExampleAndRowBounds(example, new RowBounds(0, num));
+            if(!shyCommentsList.isEmpty()){
+                for (ShyComments shyComments:shyCommentsList) {
+                    shyComments.setReceive_user_id(userId);
+                    shyComments.setReceive(true);
+                    shyCommentsMapper.updateByPrimaryKeySelective(shyComments);
+                    n++;
+                }
+            }
+        }
+        return n;
+    }
+
+    public boolean retReceive(String ids, String userId) {
+        boolean result = true;
+        String[] cids = ids.split(",");
+        for (String cid:cids) {
+            ShyComments shyComments = shyCommentsMapper.selectByPrimaryKey(Integer.parseInt(cid));
+            if(shyComments.getState()==CommonConst.AUDIT_INTT && shyComments.getReceive() && shyComments.getReceive_user_id()==userId){
+                shyComments.setReceive(CommonConst.RECEIVE_BEFORE);
+                shyComments.setReceive_user_id(null);
+                int i = shyCommentsMapper.updateByPrimaryKeySelective(shyComments);
+                if(i!=1)result = false;
+            }else{
+                result = false;
+            }
+        }
+        return result;
+    }
 }
@@ -25,6 +25,15 @@ public class CommonConst {
     /**
+     * 领取状态：未领
+     */
+    public static Boolean RECEIVE_BEFORE = false;
+    /**
+     * 领取状态：已领
+     */
+    public static Boolean RECEIVE_AFTER= true;
+
+    /**
      * 用户状态：可用
      */
     public static Integer USER_STATUS_USE = 1;
@@ -27,5 +27,7 @@
     <result column="comment_user_ip" jdbcType="CHAR" property="comment_user_ip" />
     <result column="created_at" jdbcType="TIMESTAMP" property="created_at" />
     <result column="updated_at" jdbcType="TIMESTAMP" property="updated_at" />
+    <result column="receive" jdbcType="BIT" property="receive" />
+    <result column="receive_user_id" jdbcType="VARCHAR" property="receive_user_id" />
   </resultMap>
 </mapper>
 \ No newline at end of file
@@ -24,5 +24,10 @@
     <result column="video_id" jdbcType="VARCHAR" property="video_id" />
     <result column="created_at" jdbcType="TIMESTAMP" property="created_at" />
     <result column="updated_at" jdbcType="TIMESTAMP" property="updated_at" />
+    <result column="receive" jdbcType="BIT" property="receive" />
+    <result column="receive_user_id" jdbcType="VARCHAR" property="receive_user_id" />
+    <result column="avsample" jdbcType="BIT" property="avsample" />
+    <result column="avsample_imgs" jdbcType="VARCHAR" property="avsample_imgs" />
+    <result column="avsample_msg" jdbcType="VARCHAR" property="avsample_msg" />
   </resultMap>
 </mapper>
 \ No newline at end of file
@@ -25,25 +25,30 @@
                         <div class="box-body">
                             <div class="clearfix">
                                 <div class="btn-group margin-bottom pull-left">
-                                    <input type="hidden" name="state" id="state" value="2">
-                                    <div class="btn-group margin-bottom" id="hide_select_area" style="">
+                                    <div class="btn-group margin-bottom hide" id="hide_select_area">
                                         <button type="button" class="btn btn-success btn-sm margin-r-5 action_bottom"
-                                                value="2" data="claim" data-toggle="modal" data-target="#modal"
                                                 id="more_pass">批量通过
                                         </button>
                                         <button type="button" class="btn btn-danger btn-sm margin-r-5 action_bottom"
-                                                value="2" data="claim" data-toggle="modal" data-target="#modal"
                                                 id="more_reject">批量拒绝
                                         </button>
                                     </div>
+                                    <div class="btn-group margin-bottom" id="receive_select" >
+                                        <button type="button" class="btn btn-success btn-sm margin-r-5 action_bottom" onclick="receive(0);">认领</button>
+                                        <button type="button" class="btn btn-success btn-sm margin-r-5 action_bottom" onclick="receive(100);">认领100条</button>
+                                        <button type="button" class="btn btn-success btn-sm margin-r-5 action_bottom" onclick="receive(1000);">认领1000条</button>
+                                        <button type="button" class="btn btn-warning btn-sm margin-r-5 action_bottom" onclick="retReceive();">退领</button>
+                                    </div>
+
                                 </div>
                                 <div class="btn-group margin-bottom pull-right">
-                                    <div class="btn-group margin-bottom"  style="">
-                                        <button type="button" class="btn btn-info btn-sm margin-r-5 action_bottom" onclick="searchStatus('')">全部</button>
-                                        <button type="button" class="btn btn-success btn-sm margin-r-5 action_bottom" onclick="searchStatus('1,2')">已审</button>
-                                        <button type="button" class="btn btn-danger btn-sm margin-r-5 action_bottom"  onclick="searchStatus('0')">未审</button>
+                                    <div class="btn-group margin-bottom">
+                                        <button type="button" th:class="${param.state==null and param.receive==null}?'btn btn-info btn-sm margin-r-5 action_bottom':'btn btn-sm margin-r-5 action_bottom'" onclick="searchStatus('','')">全部</button>
+                                        <button type="button" th:class="${param.state==0 and param.receive==null}?'btn btn-warning btn-sm margin-r-5 action_bottom':'btn btn-sm margin-r-5 action_bottom'" onclick="searchStatus('0','')">全部待审</button>
+                                        <button type="button" th:class="${param.state!=null and param.state!=0 and param.receive==true}?'btn btn-success btn-sm margin-r-5 action_bottom':'btn btn-sm margin-r-5 action_bottom'" onclick="searchStatus('1,2',true)">我的已审</button>
+                                        <button type="button" th:class="${param.state==0 and param.receive==true}?'btn btn-danger btn-sm margin-r-5 action_bottom':'btn btn-sm margin-r-5 action_bottom'"  onclick="searchStatus('0',true)">我的未审</button>
                                     </div>
                                     <button type="button" class="btn btn-primary btn-sm margin-r-5" id="query"
                                             onclick="openOrClose(&#39;forms&#39;)">高级查询
@@ -234,12 +239,24 @@
                                                     <a class="detail" th:href="@{'/comments/details/'+${comment.id}}">
                                                         <button class="btn btn-info btn-sm">查看</button>
                                                     </a>
-                                                    <span> &nbsp;</span>
-                                                    <a class="pass_one" th:href="@{'javascript:comment('+${comment.id}+',1)'}">
+
+                                                    <span th:if="${comment.state==0 and !comment.receive}"> &nbsp;</span>
+                                                    <a th:href="@{'javascript:applyReceive('+${comment.id}+')'}" th:if="${comment.state==0 and !comment.receive}">
+                                                        <button class="btn btn-primary btn-sm">认领</button>
+                                                    </a>
+
+                                                    <span th:if="${comment.state==0 and comment.receive and session.sessionUser.userId==comment.receive_user_id}"> &nbsp;</span>
+                                                    <a th:href="@{'javascript:applyRetReceive('+${comment.id}+')'}" th:if="${comment.state==0 and comment.receive and session.sessionUser.userId==comment.receive_user_id}">
+                                                        <button class="btn btn-warning btn-sm">退领</button>
+                                                    </a>
+
+                                                    <span th:if="${comment.receive and session.sessionUser.userId==comment.receive_user_id}"> &nbsp;</span>
+                                                    <a class="pass_one" th:href="@{'javascript:comment('+${comment.id}+',1)'}" th:if="${comment.receive and session.sessionUser.userId==comment.receive_user_id}">
                                                         <button class="btn btn-success btn-sm">通过</button>
                                                     </a>
-                                                    <span> &nbsp;</span>
-                                                    <a class="failed_one" th:href="@{'javascript:comment('+${comment.id}+',2)'}">
+
+                                                    <span th:if="${comment.receive and session.sessionUser.userId==comment.receive_user_id}"> &nbsp;</span>
+                                                    <a class="failed_one" th:href="@{'javascript:comment('+${comment.id}+',2)'}" th:if="${comment.receive and session.sessionUser.userId==comment.receive_user_id}">
                                                         <button class="btn btn-danger btn-sm">拒绝</button>
                                                     </a>
                                                 </td>
@@ -321,11 +338,11 @@
             }
         })
         //已审、未审、全部，状态切换
-        function searchStatus(commentStatus){
+        function searchStatus(commentStatus,receive){
             var href = location.href;
             if(sea==""){//没有参数
                 if(href.endsWith("?"))href = href.substring(0,href.length-1);
-                href = href+"?state="+commentStatus;
+                if($.trim(commentStatus)!='')href = href+"?state="+commentStatus;
             }else if(sea.indexOf("state=")<0){//没有参数state
                 var se = sea.replace("?","");//去掉问号，防止问号和要去掉的参数相连
                 if(sea.indexOf("page=")>=0){//有参数page，去掉
@@ -337,7 +354,7 @@
                     }
                     se = h.substring(1);
                 }
-                href = location.origin+location.pathname+"?"+se+"&state="+commentStatus;
+                if($.trim(commentStatus)!='')href = location.origin+location.pathname+"?"+se+"&state="+commentStatus;
             }else{//有参数state
                 if(href.indexOf("&")>=0){//有其他参数，去掉page和旧的state
                     var se = sea.replace("?","");//去掉问号
@@ -349,7 +366,22 @@
                     }
                     href =location.origin+location.pathname+"?"+ h.substring(1);
                 }else{//只有state参数，直接拼接链接
-                    href = location.origin+location.pathname+"?state="+commentStatus;
+                    if($.trim(commentStatus)!='')href = location.origin+location.pathname+"?state="+commentStatus;
+                }
+            }
+            //去掉领取参数
+            if(href.indexOf("receive")>=0){
+                href = href.replace("receive=true","");
+            }
+            href = href.replace("&&","&");
+            href = href.replace("?&","?");
+            if(href.endsWith("&"))href = href.substring(0,href.length-1);
+            if(href.endsWith("?"))href = href.substring(0,href.length-1);
+            if(receive==true){
+                if(href.indexOf("=")>0){//有其他参数
+                    href+="&receive=true";
+                }else{
+                    href+="?receive=true";
                 }
             }
             location.href = href;
@@ -442,6 +474,80 @@
                 $('#a_down').show();
             }
         }
+
+        /**
+         * 认领
+         */
+        function receive(n) {
+           if(n>0){
+               applyReceiveNum(n);
+           } else{
+               var rows = $("[name=btSelectItem]:checkbox:checked");
+               if (rows.length > 0) {
+                   var ids = "";
+                   rows.each(function(i,e){
+                       ids = ids + "," + e.value;
+                   })
+                   ids = ids.substring(1);
+                   applyReceive(ids);
+               }else{
+                   alert("请选择要认领的内容！");
+               }
+           }
+        }
+
+        //认领选中请求
+        function applyReceive(ids){
+            $.post("/comments/receive?ids="+ids,function (data) {
+                if (data.errorCode==0){
+                    alert(data.errorMessage);
+                    location.href = location.href;
+                } else{
+                    alert(data.errorMessage);
+                }
+            })
+        }
+        //认领多条请求
+        function applyReceiveNum(num){
+            $.post("/comments/receive?num="+num,function (data) {
+                if (data.errorCode==0){
+                    alert(data.errorMessage);
+                    location.href = location.href;
+                } else{
+                    alert(data.errorMessage);
+                }
+            })
+        }
+
+        //退领选中内容
+        function retReceive(){
+            var rows = $("[name=btSelectItem]:checkbox:checked");
+            if (rows.length > 0) {
+                var r=confirm("您确定退领选中的"+rows.length+"条评论吗？");
+                if(r == true){
+                    var ids = "";
+                    rows.each(function(i,e){
+                        ids = ids + "," + e.value;
+                    })
+                    ids = ids.substring(1);
+                    applyRetReceive(ids);
+                }
+            } else {
+                alert("没有选中的数据！");
+            }
+        }
+
+        //退领
+        function applyRetReceive(ids){
+            $.post("/comments/retReceive?ids="+ids,function (data) {
+                if (data.errorCode==0){
+                    alert(data.errorMessage);
+                    location.href = location.href;
+                } else{
+                    alert(data.errorMessage);
+                }
+            })
+        }
     </script>
     <script>
         /*时间插件*/