package com.ruoyi.web.task;
|
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.ruoyi.system.model.TBigGiftPackageOrder;
|
import com.ruoyi.system.model.TCommissionTransactionFlow;
|
import com.ruoyi.system.service.TBigGiftPackageOrderService;
|
import com.ruoyi.system.service.TCommissionTransactionFlowService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Component;
|
|
import javax.annotation.Resource;
|
import java.util.List;
|
import java.util.stream.Collectors;
|
|
/**
|
* 分佣计算定时任务
|
*
|
* @author mitao
|
* @since 2025-12-16
|
*/
|
@Slf4j
|
@Component
|
public class CommissionTask {
|
|
@Resource
|
private TBigGiftPackageOrderService bigGiftPackageOrderService;
|
|
@Resource
|
private TCommissionTransactionFlowService commissionTransactionFlowService;
|
|
/**
|
* 处理启用生效日的大礼包订单分佣计算
|
* 每月1号凌晨执行
|
*
|
* 执行条件：
|
* 1. 订单状态为"完成支付"（status=3）
|
* 2. 支付方式为全款（paymentType=2）
|
* 3. 启用生效日（effectDayFlag=true）
|
* 4. 尚未计算分佣
|
*/
|
@Scheduled(cron = "0 0 0 1 * ?")
|
public void processDelayedCommission() {
|
log.info("【定时任务】开始处理启用生效日的大礼包订单分佣计算");
|
|
try {
|
// 查询所有满足条件的订单
|
LambdaQueryWrapper<TBigGiftPackageOrder> wrapper = new LambdaQueryWrapper<>();
|
wrapper.eq(TBigGiftPackageOrder::getStatus, 3) // 完成支付
|
.eq(TBigGiftPackageOrder::getPaymentType, 2) // 全款模式
|
.eq(TBigGiftPackageOrder::getEffectDayFlag, true) // 启用生效日
|
.eq(TBigGiftPackageOrder::getDelFlag, 0); // 未删除
|
|
List<TBigGiftPackageOrder> orders = bigGiftPackageOrderService.list(wrapper);
|
|
if (orders == null || orders.isEmpty()) {
|
log.info("【定时任务】没有需要处理的订单");
|
return;
|
}
|
|
log.info("【定时任务】找到{}个需要处理的订单", orders.size());
|
|
// 过滤掉已经计算过分佣的订单
|
List<TBigGiftPackageOrder> pendingOrders = filterPendingOrders(orders);
|
|
if (pendingOrders.isEmpty()) {
|
log.info("【定时任务】所有订单都已计算过分佣");
|
return;
|
}
|
|
log.info("【定时任务】实际需要计算分佣的订单数：{}", pendingOrders.size());
|
|
// 处理每个订单
|
int successCount = 0;
|
int failCount = 0;
|
|
for (TBigGiftPackageOrder order : pendingOrders) {
|
try {
|
log.info("【定时任务】开始处理订单：{}", order.getCode());
|
|
// 计算分佣
|
commissionTransactionFlowService.calculateAndSaveCommission(
|
order.getId(),
|
1, // 订单类型：1=大礼包
|
order.getOrderPrice(),
|
order.getAppUserId()
|
);
|
|
successCount++;
|
log.info("【定时任务】订单{}分佣计算成功", order.getCode());
|
} catch (Exception e) {
|
failCount++;
|
log.error("【定时任务】订单{}分佣计算失败：{}", order.getCode(), e.getMessage(), e);
|
}
|
}
|
|
log.info("【定时任务】分佣计算完成，成功：{}，失败：{}", successCount, failCount);
|
} catch (Exception e) {
|
log.error("【定时任务】处理启用生效日的大礼包订单分佣计算失败：{}", e.getMessage(), e);
|
}
|
}
|
|
/**
|
* 过滤掉已经计算过分佣的订单
|
*
|
* @param orders 订单列表
|
* @return 尚未计算分佣的订单列表
|
*/
|
private List<TBigGiftPackageOrder> filterPendingOrders(List<TBigGiftPackageOrder> orders) {
|
return orders.stream().filter(order -> {
|
// 检查是否已经有分佣记录
|
LambdaQueryWrapper<TCommissionTransactionFlow> wrapper = new LambdaQueryWrapper<>();
|
wrapper.eq(TCommissionTransactionFlow::getOrderId, order.getId())
|
.eq(TCommissionTransactionFlow::getOrderType, 1); // 订单类型：1=大礼包
|
|
long count = commissionTransactionFlowService.count(wrapper);
|
return count == 0; // 没有分佣记录的订单
|
}).collect(Collectors.toList());
|
}
|
}
|
