From 30d8e227e8d823b6c38c3b9c90ac2df03b63befe Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期二, 25 二月 2025 16:41:22 +0800
Subject: [PATCH] 淘宝转链接口更新
---
fanli/src/main/java/com/yeshi/fanli/job/UserCloudJob.java | 176 +++++++++++++++++++++++++++++++++-------------------------
1 files changed, 101 insertions(+), 75 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..adbcdac 100644
--- a/fanli/src/main/java/com/yeshi/fanli/job/UserCloudJob.java
+++ b/fanli/src/main/java/com/yeshi/fanli/job/UserCloudJob.java
@@ -1,75 +1,101 @@
-package com.yeshi.fanli.job;
-
-import java.util.List;
-
-import javax.annotation.Resource;
-
-import org.springframework.scheduling.annotation.Scheduled;
-import org.springframework.stereotype.Component;
-
-import com.yeshi.fanli.entity.bus.user.cloud.UserCloudOrder;
-import com.yeshi.fanli.service.inter.dynamic.GoodsEvaluateService;
-import com.yeshi.fanli.service.inter.user.cloud.UserCloudOrderService;
-import com.yeshi.fanli.service.manger.alipay.UserCloudAlipayManager;
-import com.yeshi.fanli.util.Constant;
-
-@Component
-public class UserCloudJob {
-
- @Resource
- private UserCloudOrderService userCloudOrderService;
-
- @Resource
- private UserCloudAlipayManager userCloudAlipayManager;
-
- @Resource
- private GoodsEvaluateService goodsEvaluateService;
-
-
- /**
- * 姣忓崄鍒嗛挓妫�娴嬫槸鍚︿粯娆�
- */
- @Scheduled(cron = "0 0/10 * * * ? ")
- public void tradeQuery() {
- if (!Constant.IS_TASK) {
- return;
- }
-
- List<UserCloudOrder> list = userCloudOrderService.getLasthourByUnpaid();
- if (list == null || list.size() == 0)
- return;
-
- for (UserCloudOrder cloudOrder: list) {
- try {
- userCloudAlipayManager.tradeQueryByOrderId(cloudOrder.getId());
- } catch (Exception e) {
- e.printStackTrace();
- }
- }
- }
-
-
- /**
- * 瀹氭椂妫�娴嬫槸鍚﹀瓨鍦ㄦ柊鐨勫彂鍦�
- */
- @Scheduled(cron = "0 0/20 * * * ? ")
- public void dailyCount() {
- if (!Constant.IS_TASK) {
- return;
- }
-
- List<UserCloudOrder> list = userCloudOrderService.getLasthourByUnpaid();
- if (list == null || list.size() == 0)
- return;
-
- for (UserCloudOrder cloudOrder: list) {
- try {
- userCloudAlipayManager.tradeQueryByOrderId(cloudOrder.getId());
- } catch (Exception e) {
- e.printStackTrace();
- }
- }
- }
-
-
-}
+package com.yeshi.fanli.job;
+
+import java.util.Calendar;
+import java.util.Date;
+import java.util.List;
+
+import javax.annotation.Resource;
+
+import org.springframework.scheduling.annotation.Scheduled;
+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() {
+ if (!Constant.IS_TASK) {
+ return;
+ }
+
+ List<UserCloudOrder> list = userCloudOrderService.getLasthourByUnpaid();
+ if (list == null || list.size() == 0)
+ return;
+
+ for (UserCloudOrder cloudOrder : list) {
+ try {
+ userCloudAlipayManager.tradeQueryByOrderId(cloudOrder.getId());
+ } catch (Exception e) {
+ LogHelper.errorDetailInfo(e);
+ e.printStackTrace();
+ }
+ }
+ }
+
+ /**
+ * 瀹氭椂妫�娴嬫槸鍚﹀瓨鍦ㄦ柊鐨勫彂鍦�
+ */
+ @Scheduled(cron = "0 0/20 * * * ? ")
+ public void fixedTimeSend() {
+ if (!Constant.IS_TASK) {
+ return;
+ }
+
+ // 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;
+
+ // 娲诲姩鍒楄〃
+ 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