package cn.iocoder.yudao.module.statistics.job.trade; import cn.hutool.core.convert.Convert; import cn.hutool.core.util.NumberUtil; import cn.hutool.core.util.ObjUtil; import cn.hutool.core.util.StrUtil; import cn.iocoder.yudao.framework.quartz.core.handler.JobHandler; import cn.iocoder.yudao.framework.tenant.core.job.TenantJob; import cn.iocoder.yudao.module.statistics.service.trade.TradeStatisticsService; import org.springframework.stereotype.Component; import jakarta.annotation.Resource; /** * 交易统计 Job * * @author owen */ @Component public class TradeStatisticsJob implements JobHandler { @Resource private TradeStatisticsService tradeStatisticsService; /** * 执行交易统计任务 * * @param param 要统计的天数,只能是正整数,1 代表昨日数据 * @return 统计结果 */ @Override @TenantJob public String execute(String param) { // 默认昨日 param = ObjUtil.defaultIfBlank(param, "1"); // 校验参数的合理性 if (!NumberUtil.isInteger(param)) { throw new RuntimeException("交易统计任务的参数只能为是正整数"); } Integer days = Convert.toInt(param, 0); if (days < 1) { throw new RuntimeException("交易统计任务的参数只能为是正整数"); } String result = tradeStatisticsService.statisticsTrade(days); return StrUtil.format("交易统计:\n{}", result); } }