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