update

陈浩
1 parent ecb6f988
Showing 2 changed files with 78 additions and 20 deletions
src/main/java/com/cnlive/shenhe/serviceImpl/CommentsServiceImpl.java
src/main/java/com/cnlive/shenhe/serviceImpl/VideosServiceImpl.java
@@ -60,7 +60,7 @@ public class CommentsServiceImpl {
     }
     public boolean impotComments(ShyComments shyComments) {
-        int result = shyCommentsMapper.insert(shyComments);
+        int result = shyCommentsMapper.insertSelective(shyComments);
         if (result == 0) {
             return false;
         }
@@ -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,Boolean receive, String auditor, Integer page, Integer pageSize, String orderByClause, Integer spid,String userId) {
+    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,10 +101,10 @@ 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.isNotNull(receive)) {
+            criteria.andEqualTo("receive", receive);
+            if (receive) {
+                criteria.andEqualTo("receive_user_id", userId);
             }
         }
@@ -146,12 +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())){
+            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);
@@ -208,8 +208,8 @@ public class CommentsServiceImpl {
             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) {
+            if (!shyCommentsList.isEmpty()) {
+                for (ShyComments shyComments : shyCommentsList) {
                     shyComments.setReceive_user_id(userId);
                     shyComments.setReceive(true);
                     shyCommentsMapper.updateByPrimaryKeySelective(shyComments);
@@ -223,14 +223,14 @@ public class CommentsServiceImpl {
     public boolean retReceive(String ids, String userId) {
         boolean result = true;
         String[] cids = ids.split(",");
-        for (String cid:cids) {
+        for (String cid : cids) {
             ShyComments shyComments = shyCommentsMapper.selectByPrimaryKey(Integer.parseInt(cid));
-            if(shyComments.getState()==CommonConst.AUDIT_INTT && shyComments.getReceive() && shyComments.getReceive_user_id()==userId){
+            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{
+                if (i != 1) result = false;
+            } else {
                 result = false;
             }
         }
@@ -34,16 +34,16 @@ public class VideosServiceImpl {
     ShyUsersMapper shyUsersMapper;
     public boolean impotVideo(ShyVideos shyVideos) {
-        int result = shyVideosMapper.insert(shyVideos);
+        int result = shyVideosMapper.insertSelective(shyVideos);
         if (result == 0) {
             return false;
         }
         return true;
     }
-    public List<ShySites> getBusiness(ShySites shySites) {
-        List<ShySites> sitesList = shySitesMapper.select(shySites);
-        return sitesList;
+    public ShyVideos selectByPrimaryKey(Integer id) {
+        ShyVideos shyVideos = shyVideosMapper.selectByPrimaryKey(id);
+        return shyVideos;
     }
     public List<ShyVideos> findshyVideo(ShyVideos shyVideos) {
@@ -67,7 +67,7 @@ public class VideosServiceImpl {
         return shyVideosMapper.updateByPrimaryKeySelective(shyVideos);
     }
-    public PageInfo<ShyVideos> getListContent(String video_title, String start_date, String end_date, Integer state, Integer page, Integer pageSize, String video_priority, String orderByClause, Integer spid) {
+    public PageInfo<ShyVideos> getListContent(String video_title, String start_date, String end_date, Integer state, Boolean receive, Integer page, Integer pageSize, String video_priority, String orderByClause, Integer spid, String userId) {
         Example example = new Example(ShyVideos.class);
         Example.Criteria criteria = example.createCriteria();
         Example.Criteria criteria2 = example.createCriteria();
@@ -102,6 +102,12 @@ public class VideosServiceImpl {
         if (CommonUtils.isNotNull(spid)) {
             criteria.andEqualTo("spid", spid);
         }
+        if (CommonUtils.isNotNull(receive)) {
+            criteria.andEqualTo("receive", receive);
+            if (receive == true) {
+                criteria.andEqualTo("receive_user_id", userId);
+            }
+        }
         //默认按上传时间倒序排序
         example.setOrderByClause("video_upload_time desc");
         PageHelper.startPage(page, pageSize, true);
@@ -115,7 +121,7 @@ public class VideosServiceImpl {
         if (shyVideos.getState() != CommonConst.AUDIT_INTT) {
             String auditorName = "白名单";
             String auditor_id = shyVideos.getAuditor_id();
-            if(CommonUtils.isNotEmpty(auditor_id)){
+            if (CommonUtils.isNotEmpty(auditor_id)) {
                 ShyUsers user = new ShyUsers();
                 user.setUser_id(auditor_id);
                 user = shyUsersMapper.selectOne(user);
@@ -128,4 +134,56 @@ public class VideosServiceImpl {
         return shyVideos;
     }
+    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) {
+                ShyVideos shyVideos = shyVideosMapper.selectByPrimaryKey(Integer.parseInt(cid));
+                if (CommonUtils.isNotNull(shyVideos) && shyVideos.getState() == CommonConst.AUDIT_INTT && !shyVideos.getReceive()) {
+                    shyVideos.setReceive_user_id(userId);
+                    shyVideos.setReceive(true);
+                    shyVideosMapper.updateByPrimaryKeySelective(shyVideos);
+                    n++;
+                }
+            }
+        } else if (CommonUtils.isNotNull(num) && num > 0) {
+            Example example = new Example(ShyVideos.class);
+            example.setOrderByClause("created_at 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<ShyVideos> shyCommentsList = shyVideosMapper.selectByExampleAndRowBounds(example, new RowBounds(0, num));
+            if (!shyCommentsList.isEmpty()) {
+                for (ShyVideos shyComments : shyCommentsList) {
+                    shyComments.setReceive_user_id(userId);
+                    shyComments.setReceive(true);
+                    shyVideosMapper.updateByPrimaryKeySelective(shyComments);
+                    n++;
+                }
+            }
+        }
+        return n;
+    }
+
+    public boolean retReceive(String ids, String userId) {
+        boolean result = true;
+        String[] cids = ids.split(",");
+        for (String cid : cids) {
+            ShyVideos shyVideos = shyVideosMapper.selectByPrimaryKey(Integer.parseInt(cid));
+            if (shyVideos.getState() == CommonConst.AUDIT_INTT && shyVideos.getReceive() && shyVideos.getReceive_user_id() == userId) {
+                shyVideos.setReceive(CommonConst.RECEIVE_BEFORE);
+                shyVideos.setReceive_user_id(null);
+                int i = shyVideosMapper.updateByPrimaryKeySelective(shyVideos);
+                if (i != 1) {
+                    return false;
+                }
+            } else {
+                return false;
+            }
+        }
+        return result;
+    }
+
+
 }