From ec60e757d358636dcac1589c44a66f3e276fe58c Mon Sep 17 00:00:00 2001
From: yujian <yujian@163.com>
Date: 星期一, 29 六月 2020 14:41:42 +0800
Subject: [PATCH] 拉新
---
fanli/src/main/java/com/yeshi/fanli/job/UserCloudJob.java | 66 +++++++++++++++++++++++----------
1 files changed, 46 insertions(+), 20 deletions(-)
diff --git a/fanli/src/main/java/com/yeshi/fanli/job/UserCloudJob.java b/fanli/src/main/java/com/yeshi/fanli/job/UserCloudJob.java
index 25641fe..428dee7 100644
--- a/fanli/src/main/java/com/yeshi/fanli/job/UserCloudJob.java
+++ b/fanli/src/main/java/com/yeshi/fanli/job/UserCloudJob.java
@@ -1,5 +1,7 @@
package com.yeshi.fanli.job;
+import java.util.Calendar;
+import java.util.Date;
import java.util.List;
import javax.annotation.Resource;
@@ -8,68 +10,92 @@
import org.springframework.stereotype.Component;
import com.yeshi.fanli.entity.bus.user.cloud.UserCloudOrder;
+import com.yeshi.fanli.entity.dynamic.GoodsEvaluate;
+import com.yeshi.fanli.entity.dynamic.GoodsEvaluate.EvaluateEnum;
+import com.yeshi.fanli.log.LogHelper;
import com.yeshi.fanli.service.inter.dynamic.GoodsEvaluateService;
import com.yeshi.fanli.service.inter.user.cloud.UserCloudOrderService;
+import com.yeshi.fanli.service.inter.user.cloud.UserCloudService;
import com.yeshi.fanli.service.manger.alipay.UserCloudAlipayManager;
import com.yeshi.fanli.util.Constant;
@Component
public class UserCloudJob {
+ @Resource
+ private UserCloudService userCloudService;
@Resource
private UserCloudOrderService userCloudOrderService;
-
+
@Resource
private UserCloudAlipayManager userCloudAlipayManager;
-
+
@Resource
private GoodsEvaluateService goodsEvaluateService;
-
/**
* 姣忓崄鍒嗛挓妫�娴嬫槸鍚︿粯娆�
*/
@Scheduled(cron = "0 0/10 * * * ? ")
- public void tradeQuery() {
+ public void tradeQuery() {
if (!Constant.IS_TASK) {
return;
}
-
+
List<UserCloudOrder> list = userCloudOrderService.getLasthourByUnpaid();
if (list == null || list.size() == 0)
return;
-
- for (UserCloudOrder cloudOrder: list) {
+
+ for (UserCloudOrder cloudOrder : list) {
try {
userCloudAlipayManager.tradeQueryByOrderId(cloudOrder.getId());
} catch (Exception e) {
+ LogHelper.errorDetailInfo(e);
e.printStackTrace();
}
}
}
-
/**
* 瀹氭椂妫�娴嬫槸鍚﹀瓨鍦ㄦ柊鐨勫彂鍦�
*/
@Scheduled(cron = "0 0/20 * * * ? ")
- public void dailyCount() {
+ public void fixedTimeSend() {
if (!Constant.IS_TASK) {
return;
}
-
- List<UserCloudOrder> list = userCloudOrderService.getLasthourByUnpaid();
- if (list == null || list.size() == 0)
+
+ // 9-21 鎵ц浜戝彂鍗�
+ Calendar nowCalendar = Calendar.getInstance();
+ nowCalendar.setTimeInMillis(java.lang.System.currentTimeMillis());
+ int hour = nowCalendar.get(Calendar.HOUR_OF_DAY);
+ if (hour < 9 || hour > 21)
return;
-
- for (UserCloudOrder cloudOrder: list) {
- try {
- userCloudAlipayManager.tradeQueryByOrderId(cloudOrder.getId());
- } catch (Exception e) {
- e.printStackTrace();
- }
+
+ // 娲诲姩鍒楄〃
+ List<GoodsEvaluate> listActivity = goodsEvaluateService.queryValidSortASC(1, 100, EvaluateEnum.activity, false);
+ // 鍗曞搧鍟嗗搧
+ List<GoodsEvaluate> listGoods = goodsEvaluateService.queryValidSortASC(1, 5, EvaluateEnum.single, true);
+ // 鎵ц鍙戝崟
+ userCloudService.fixedTimeSend(listActivity, listGoods, true);
+ }
+
+
+ /**
+ * 姣忔棩22鐐硅繘琛屾繁澶滃彂鍦�
+ */
+ @Scheduled(cron = "0 0 22 * * ? ")
+ public void zeroPoint() {
+ if (!Constant.IS_TASK) {
+ return;
}
+
+ List<GoodsEvaluate> list = goodsEvaluateService.queryValidZeroPoint(1, 50);
+ if (list == null || list.size() == 0) {
+ return;
+ }
+ // 鎵ц鍙戝崟
+ userCloudService.fixedTimeSend(null, list, false);
}
-
}
--
Gitblit v1.8.0