From 0ec22dcf4fd9c4496e6f681e7fab89f56c6e4e8a Mon Sep 17 00:00:00 2001
From: yujian <yujian@163.com>
Date: 星期四, 02 四月 2020 14:45:20 +0800
Subject: [PATCH] vip 消息
---
fanli/src/main/java/com/yeshi/fanli/job/UpdateThreeSaleJob.java | 52 +++++++++++++++++++++++-----------------------------
1 files changed, 23 insertions(+), 29 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 e665b20..3ca9fe1 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,47 +7,42 @@
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
-import com.yeshi.fanli.entity.bus.user.ThreeSale;
-import com.yeshi.fanli.entity.bus.user.UserInfo;
-import com.yeshi.fanli.service.inter.hongbao.ThreeSaleSerivce;
-import com.yeshi.fanli.service.inter.user.UserInfoService;
+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.util.Constant;
@Component
public class UpdateThreeSaleJob {
- @Resource
- private ThreeSaleSerivce ThreeSaleSerivce;
@Resource
- private UserInfoService userInfoService;
-
- // 姣忓ぉ00鐐�20鎵ц 杩囨湡閭�璇风瓫閫�
- @Scheduled(cron = "0 20 0 * * ? ")
- public void updateReward() {
-
+ 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);
+ 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 record: list) {
+ try {
+ userInviteSeparateService.inviteSeparate(record);
+ } catch (Exception e) {
+ LogHelper.errorDetailInfo(e);
+ }
}
-
- // 鏇存柊閭�璇疯繃鏈燂細 60澶╂湭琚個璇锋垚鍔熴��60澶╂湭鐧婚檰绯荤粺
- if (list.size() > 0) {
- ThreeSaleSerivce.updateExpire(list);
+
+ if (list.size() < count) {
+ break;
}
-
- } catch (Exception e) {
- e.printStackTrace();
}
-
}
}
--
Gitblit v1.8.0