From c96fbe6b0aeb413a17c429133ee6d81d138144b9 Mon Sep 17 00:00:00 2001
From: liujie <1793218484@qq.com>
Date: 星期二, 09 六月 2026 10:58:52 +0800
Subject: [PATCH] Merge branch '1.0' of http://120.76.84.145:10101/gitblit/r/java/Robotaxi into 1.0
---
xp-robotaxi-operation-boot/src/main/java/com/xiaopeng/operation/utils/task/ActivityTask.java | 48 +++++++++++++++++++-----------------------------
1 files changed, 19 insertions(+), 29 deletions(-)
diff --git a/xp-robotaxi-operation-boot/src/main/java/com/xiaopeng/operation/utils/task/ActivityTask.java b/xp-robotaxi-operation-boot/src/main/java/com/xiaopeng/operation/utils/task/ActivityTask.java
index f1ed16a..bd148a8 100644
--- a/xp-robotaxi-operation-boot/src/main/java/com/xiaopeng/operation/utils/task/ActivityTask.java
+++ b/xp-robotaxi-operation-boot/src/main/java/com/xiaopeng/operation/utils/task/ActivityTask.java
@@ -3,18 +3,17 @@
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.xiaopeng.api.model.operation.XpActicityStrategy;
-import com.xiaopeng.api.model.operation.XpActicityUser;
import com.xiaopeng.api.model.operation.XpActivity;
import com.xiaopeng.operation.service.IXpActicityService;
import com.xiaopeng.operation.service.IXpActicityStrategyService;
-import com.xiaopeng.operation.service.IXpActicityUserService;
import lombok.extern.slf4j.Slf4j;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import javax.annotation.Resource;
+import java.time.LocalDateTime;
+import java.time.format.DateTimeFormatter;
import java.util.List;
-import java.util.stream.Collectors;
@Slf4j
@Component
@@ -26,17 +25,11 @@
@Resource
private IXpActicityService xpActicityService;
- @Resource
- private IXpActicityUserService xpActicityUserService;
-
-
-
- /**
- * 凌晨执行的定时任务
- */
- @Scheduled(cron = "0 0 0 * * *")
+ @Scheduled(cron = "0 0/1 * * * *")
public void taskOrder() {
+ xpActicityService.updateStatus();
+ //循环发放的活动
pusCoupon();
}
@@ -44,27 +37,24 @@
/**
* 每日发放券的活动
*/
- public void pusCoupon(){
+ public void pusCoupon() {
List<XpActivity> activities = xpActicityService.list(new QueryWrapper<XpActivity>().eq("status", 2)
.eq("is_deleted", 0).last(" and now() between start_time and end_time"));
- if(activities.isEmpty()){
+ if (activities.isEmpty()) {
return;
}
- List<Long> activityIds = activities.stream().map(XpActivity::getId).collect(Collectors.toList());
- //获取发放人
- List<XpActicityUser> xpActicityUsers = xpActicityUserService.list(new QueryWrapper<XpActicityUser>().eq("is_deleted", 0)
- .in("actitcity_id", activityIds));
- List<XpActicityStrategy> list = xpActicityStrategyService.list(new QueryWrapper<XpActicityStrategy>()
- .eq("distribution_rules", 1)
- .eq("is_deleted", 0)
- .in("actitcity_id", activityIds));
- for (XpActicityStrategy xpActicityStrategy : list) {
- //发放人
- List<XpActicityUser> collect = xpActicityUsers.stream().filter(s -> s.getActitcityStrategeId().equals(xpActicityStrategy.getId())).collect(Collectors.toList());
-
-
-
-
+ for (XpActivity activity : activities) {
+ List<XpActicityStrategy> list = xpActicityStrategyService.list(new QueryWrapper<XpActicityStrategy>()
+ .eq("distribution_rules", 1)
+ .eq("is_deleted", 0)
+ .eq("actitcity_id", activity.getId()));
+ for (XpActicityStrategy xpActicityStrategy : list) {
+ String distributionTime = xpActicityStrategy.getDistributionTime();
+ String format = LocalDateTime.now().format(DateTimeFormatter.ofPattern("HH:mm"));
+ if (distributionTime.equals(format)) {
+ xpActicityService.pushCoupon(activity, xpActicityStrategy);
+ }
+ }
}
}
}
--
Gitblit v1.7.1