评论审核自动退领

liwei2917
1 parent 1af077ce
Showing 3 changed files with 32 additions and 7 deletions
src/main/java/com/cnlive/shenhe/job/CommentsJob.java
src/main/java/com/cnlive/shenhe/job/VideosJob.java
src/main/java/com/cnlive/shenhe/serviceImpl/CommentsServiceImpl.java
@@ -3,6 +3,7 @@ package com.cnlive.shenhe.job;
 import com.alibaba.fastjson.JSONObject;
 import com.cnlive.shenhe.entity.ShyComments;
 import com.cnlive.shenhe.entity.ShySites;
+import com.cnlive.shenhe.entity.ShyVideos;
 import com.cnlive.shenhe.serviceImpl.CommentsServiceImpl;
 import com.cnlive.shenhe.serviceImpl.SitesServiceImpl;
 import com.cnlive.shenhe.serviceImpl.UsersServiceImpl;
@@ -82,4 +83,26 @@ public class CommentsJob {
             }
         }
     }
+    
+    /**
+     * 自动退领
+     */
+    @Scheduled(cron="0 0 0 * * ? ")//每天0点执行
+    public void autoRetReceive() {
+    	ShyComments shyComments = new ShyComments();
+    	shyComments.setState(CommonConst.AUDIT_INTT);//审核状态：未审核
+    	shyComments.setReceive(CommonConst.RECEIVE_AFTER);//已领取
+    	List<ShyComments> commentsList = commentsService.findshyComments(shyComments);
+        if (commentsList.size() > 0) {
+            for (ShyComments comments : commentsList) {
+            	logger.info("自动退领的comments_id："+comments.getId());
+            	comments.setReceive(CommonConst.RECEIVE_BEFORE);//未领取
+            	comments.setReceive_user_id(null);
+            	commentsService.updateshyComments1(comments);
+            }
+    	}
+    }
+    
+    
+    
 }
@@ -88,12 +88,14 @@ public class VideosJob {
     	shyVideos.setState(CommonConst.AUDIT_INTT);//审核状态：未审核
     	shyVideos.setReceive(CommonConst.RECEIVE_AFTER);//已领取
     	List<ShyVideos> shyVideosList = videosService.findshyVideo(shyVideos);
-    	for (ShyVideos shyVideos2 : shyVideosList) {
-    		logger.info("自动退领的videos_id："+shyVideos2.getId());
-    		shyVideos2.setReceive(CommonConst.RECEIVE_BEFORE);//未领取
-    		shyVideos2.setReceive_user_id(null);
-    		videosService.updateshyVideos(shyVideos2);
-		}
+    	if(shyVideosList.size()>0){
+    		for (ShyVideos shyVideos2 : shyVideosList) {
+        		logger.info("自动退领的videos_id："+shyVideos2.getId());
+        		shyVideos2.setReceive(CommonConst.RECEIVE_BEFORE);//未领取
+        		shyVideos2.setReceive_user_id(null);
+        		videosService.updateshyVideos(shyVideos2);
+    		}
+    	}
     }
 }
@@ -53,7 +53,7 @@ public class CommentsServiceImpl {
     }
     public boolean updateshyComments1(ShyComments shyComments) {
-        int result = shyCommentsMapper.updateByPrimaryKeySelective(shyComments);
+        int result = shyCommentsMapper.updateByPrimaryKey(shyComments);
         if (result == 0) {
             return false;
         }