? ? ? ? ? ?有项目就有数据,有数据就需要报表,报表设计对了很重要。
? ? ? ? ? ?生活中常见的报表:日报表,月报表,季报表,年度表,累计汇总表
? ? ? ? ? 大多数报表都离不开时间维度,可以说报表都是时间维度+业务主体数据构成。
? ? ? ? ? 良好的报表设计围绕着业务要求依据业务的数据量(要统计记录业务数,可理解数据表条数)进行设计。
1 报表设计是有顺序,应该按时间范围,从小到大设计。先设计明细报表,再设计汇总表。时间类的报表设计顺序:1日报表->2月报表 ->3设计季报表->4年报表->5汇总表。
报表数据的来源之间存在依赖关系:汇总表的数据来自于年报表的数据,年报表来自于季报表数据,季报表数据来自于月报表,月报表数据来自于日报表,日报表来自当日的实时统计,如果数据量大,比如一日百万条数据以上的再设计小时表统计。
根据对数据的要求可以使用定时任务是完成,也可以利用触发器,数据库的存储过程统计(维护更方便)。
基于springboot 定时任务 统计订单日报表的实例代码:
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import org.springframework.transaction.annotation.Transactional;
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.List;
/**
* 统计订单数据
* @author hua
* @Date: 2023/12/23 13:26
*/
@Component
@EnableScheduling
public class OrderDayJob {
@Autowired
ReportPlatformDayServiceImpl reportPlatformDayService;
@Autowired
SysJobRunLogServiceImpl sysJobRunLogService;
@Autowired
OrderDao orderDao;
final DateTimeFormatter DTF_DATE= DateTimeFormatter.ofPattern("yyyy-MM-dd");
final String JOB_NAME="OrderDayJob";
Logger log= LogManager.getLogger(OrderDayJob.class);
/**
* 每日订单统计
*/
@Scheduled(cron = "0 */1 * * * ?")
public void orderCalcJob() {
log.info("------------OrderDayJob------------begin");
SysJobRunLog sysJobRunLog=sysJobRunLogService.lambdaQuery()
.eq(SysJobRunLog::getJobName,JOB_NAME)
.orderByDesc(SysJobRunLog::getBusDate)
.last("limit 1").one();
//默认开始统计数据日期
String startDate="2023-12-01";
if(sysJobRunLog!=null){
startDate=sysJobRunLog.getBusDate();
}
LocalDate today=LocalDate.now();
//考虑最坏情况 如果因定时任务没有执行的,确保不占用系统过多资源 最多每次连续统计7天。
for(int i=0;i<7;i++){
LocalDate cur=LocalDate.parse(startDate,DTF_DATE);
if(cur.compareTo(today)==0){
calcOrderDayReport(startDate);
return;
}
LocalDate calcData= cur.plusDays(1);
startDate =calcData.format(DTF_DATE);
calcOrderDayReport(startDate);
}
log.info("------------OrderDayJob------------end");
}
/**
* 重算订单日报告
* @param startDate 开始日期
*/
@Transactional(rollbackFor = Exception.class)
public void calcOrderDayReport(String startDate) {
// 计算订单日期报告
List<ReportPlatformDay> reportPlatformDays = orderDao.calcOrderDayReport(startDate);
SysJobRunLog sysJobRunLog = new SysJobRunLog();
sysJobRunLog.setBeginTime(LocalDateTime.now());
//统计前删除数据
reportPlatformDayService.lambdaUpdate().eq(ReportPlatformDay::getOrderDay,startDate).remove();
// 如果报告列表不为空
if (!reportPlatformDays.isEmpty()) {
// 保存报告列表到数据订单日期服务
reportPlatformDayService.saveBatch(reportPlatformDays);
}
sysJobRunLog.setHandlerCount(reportPlatformDays.size());
sysJobRunLog.setJobName(JOB_NAME);
sysJobRunLog.setEndTime(LocalDateTime.now());
sysJobRunLog.setBusDate(startDate);
// 记录生成报表
sysJobRunLogService.save(sysJobRunLog);
}
}
?上面的SysJobRunLog类除了记录报表定时任务运行情况,还可以选择性删除最后几天或者清空表使其重新计算日报表,表结构如下:
CREATE TABLE `sys_job_run_log` (
`id` int(11) NOT NULL AUTO_INCREMENT,
`job_name` varchar(30) DEFAULT NULL COMMENT '定时器任务',
`begin_time` datetime DEFAULT NULL COMMENT '开始时间',
`end_time` datetime DEFAULT NULL COMMENT '结束时间',
`handler_count` int(1) NOT NULL COMMENT '处理数据量',
`bus_date` date NOT NULL COMMENT '业务日期',
`remark` varchar(80) DEFAULT NULL COMMENT '定时任务运行过程中备注',
PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8 ROW_FORMAT=DYNAMIC COMMENT='定时器运行记录'
?
关于定时任务请查看 ->?http://t.csdnimg.cn/DPlKl