From 5f13dcc8eaac7cd26c0ec41bd1b3efbb70a08180 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期二, 16 六月 2020 17:45:09 +0800
Subject: [PATCH] 云发单金额修改，增加获取电话号码接口
---
fanli/src/main/java/com/yeshi/fanli/job/UserCloudJob.java | 50 +++++++++++++++++++++++++++++---------------------
1 files changed, 29 insertions(+), 21 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..9544892 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,74 @@
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 dailyCount() {
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);
}
-
}
--
Gitblit v1.8.0