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