From 207dc8655711cddac2653e18b51e58a88dba2084 Mon Sep 17 00:00:00 2001
From: yj <Administrator@192>
Date: 星期五, 06 三月 2020 18:14:36 +0800
Subject: [PATCH] 发圈处理
---
fanli/src/main/java/com/yeshi/fanli/job/UpdateThreeSaleJob.java | 54 ++++++++++++++++++++++++++----------------------------
1 files changed, 26 insertions(+), 28 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..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,47 +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.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.service.inter.user.vip.UserVIPInfoService;
import com.yeshi.fanli.util.Constant;
@Component
public class UpdateThreeSaleJob {
- @Resource
- private ThreeSaleSerivce ThreeSaleSerivce;
@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);
+ 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);
+ }
}
-
- // 鏇存柊閭�璇疯繃鏈燂細 60澶╂湭琚個璇锋垚鍔熴��60澶╂湭鐧婚檰绯荤粺
- if (list.size() > 0) {
- ThreeSaleSerivce.updateExpire(list);
+
+ if (list.size() < count) {
+ break;
}
-
- } catch (Exception e) {
- e.printStackTrace();
}
-
}
}
--
Gitblit v1.8.0