From 00f7111026685a610ff2f189d9b426213e903aaf Mon Sep 17 00:00:00 2001
From: yujian <yujian@163.com>
Date: 星期六, 14 十二月 2019 09:39:02 +0800
Subject: [PATCH] 定时分分离邀请脱离

---
 fanli/src/main/java/com/yeshi/fanli/job/UpdateThreeSaleJob.java |   62 +++++++++++++------------------
 1 files changed, 26 insertions(+), 36 deletions(-)

diff --git a/fanli/src/main/java/com/yeshi/fanli/job/UpdateThreeSaleJob.java b/fanli/src/main/java/com/yeshi/fanli/job/UpdateThreeSaleJob.java
index defee60..d166aed 100644
--- a/fanli/src/main/java/com/yeshi/fanli/job/UpdateThreeSaleJob.java
+++ b/fanli/src/main/java/com/yeshi/fanli/job/UpdateThreeSaleJob.java
@@ -1,6 +1,5 @@
 package com.yeshi.fanli.job;
 
-import java.util.ArrayList;
 import java.util.List;
 
 import javax.annotation.Resource;
@@ -8,55 +7,46 @@
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 
-import com.yeshi.fanli.entity.bus.user.ThreeSale;
-import com.yeshi.fanli.service.inter.user.UserInfoService;
-import com.yeshi.fanli.service.inter.user.invite.ThreeSaleSerivce;
-import com.yeshi.fanli.service.inter.user.invite.UserInviteMsgNotificationService;
+import com.yeshi.fanli.entity.bus.user.UserInviteSeparate;
+import com.yeshi.fanli.log.LogHelper;
+import com.yeshi.fanli.service.inter.user.UserInviteSeparateService;
+import com.yeshi.fanli.service.inter.user.vip.UserVIPInfoService;
 import com.yeshi.fanli.util.Constant;
 
 @Component
 public class UpdateThreeSaleJob {
 
-	@Resource
-	private ThreeSaleSerivce ThreeSaleSerivce;
-	@Resource
-	private UserInviteMsgNotificationService userInviteMsgNotificationService;
 
 	@Resource
-	private UserInfoService userInfoService;
+	private UserVIPInfoService userVIPInfoService;
 
-	// 姣忓ぉ00鐐�20鎵ц 杩囨湡閭�璇风瓫閫�
-	@Scheduled(cron = "0 20 0 * * ? ")
-	public void updateReward() {
-
+	@Resource
+	private UserInviteSeparateService userInviteSeparateService;
+	
+	// 閭�璇峰叧绯昏劚绂�
+	@Scheduled(cron = "0 0/10 * * * ? ")
+	public void inviteSeparate() {
 		if (!Constant.IS_TASK) {
 			return;
 		}
-
-		try {
-			List<Long> list = new ArrayList<Long>();
-
-			// 鍙戝嚭閭�璇锋湭鎴愬姛 瓒呰繃60澶�
-			List<Long> listFailed = ThreeSaleSerivce.queryLongTimeFailed(60);
-			if (listFailed != null && listFailed.size() > 0) {
-				list.addAll(listFailed);
-			}
-
-			// 鏇存柊閭�璇疯繃鏈燂細 60澶╂湭琚個璇锋垚鍔熴��60澶╂湭鐧婚檰绯荤粺
-			if (list.size() > 0) {
-				ThreeSaleSerivce.updateExpire(list);
-				for (Long id : listFailed) {
-					// 閫氱煡
-					ThreeSale ts = ThreeSaleSerivce.selectByPrimaryKey(id);
-					if (ts != null)
-						userInviteMsgNotificationService.inviteFail(ts.getBoss().getId(), ts);
+		int count = 100;
+		for (int i = 0; i < 1000; i++) {
+			List<UserInviteSeparate> list = userInviteSeparateService.getHandleOverdue(i, count);
+			if (list == null || list.size() == 0)
+				break;
+			
+			for (UserInviteSeparate separate: list) {
+				try {
+					userVIPInfoService.inviteSeparate(separate.getWorkerId(), separate.getBossId());
+				} catch (Exception e) {
+					LogHelper.errorDetailInfo(e);
 				}
 			}
-
-		} catch (Exception e) {
-			e.printStackTrace();
+			
+			if (list.size() < count) {
+				break;
+			}
 		}
-
 	}
 
 }

--
Gitblit v1.8.0