正文

XX出行项目子系统-统计系统设计（定时器项目设计例子）

IP云
IP云V管理员/3 阅读
11/29
提示：扫一扫查出行
【扫一扫了解最新限行尾号】
复制提示

一. 引言

目前开发的XX出行系统，需要开发数据统计功能，鉴于约约出行系统已经在运营，并且有新版本的迭代，方便以后下个版本复用，遂新建一个子系统。

二. 架构设计

三. 具体实现

1.MySql数据库

（1）配置表：使用配置表，控制要执行的存储过程。 

CREATE TABLE `t_report_config` (

  `uuid` varchar(32) NOT NULL COMMENT '主键ID',

  `source_view` varchar(64) NOT NULL COMMENT '数据源视图',

  `result_table` varchar(64) NOT NULL COMMENT '结果存储表',

  `cycle` int(11) NOT NULL COMMENT '周期类型（1：小时，2：天）',

  `status` int(11) DEFAULT NULL COMMENT '状态（0：失败，1：成功）',

  `update_time` datetime DEFAULT NULL COMMENT '更新时间',

  PRIMARY KEY (`uuid`)

) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='统计报表_配置表';

（2）存储过程：存储过程根据配置表给的视图名和存储表，将视图的数据存储到存储表中。 

CREATE DEFINER=`admin`@`%` PROCEDURE `P_REPORT_CONFIG`(IN args_cycle INT)

BEGIN

    -- 需要定义接收游标数据的变量  

-- 配置表主键ID

DECLARE var_uuid CHAR (32);  

-- 数据源视图

DECLARE var_source_view CHAR (64);  

-- 结果存储表

DECLARE var_result_table CHAR (64);  

-- 周期类型（1：小时，2：天）

DECLARE var_cycle INT;  

-- 状态（0：失败，1：成功）

DECLARE var_status INT;  

-- 动态SQL语句

DECLARE sqlStr VARCHAR(500);  

-- 遍历数据结束标志

DECLARE done INT DEFAULT FALSE;  

-- 游标

DECLARE cur CURSOR FOR SELECT

    trc.uuid var_uuid,

    trc.source_view var_source_view,

    trc.result_table var_result_table,

    trc.cycle var_cycle,

    trc.status var_status

    FROM

    t_report_config trc WHERE trc.cycle = args_cycle

;  

-- 将结束标志绑定到游标

DECLARE CONTINUE HANDLER FOR NOT FOUND

SET done = TRUE;  

-- 打开游标

OPEN cur;  

-- 开始循环

read_loop :

LOOP

    -- 提取游标里的数据，这里只有一个，多个的话也一样；

    FETCH cur INTO

    var_uuid,

    var_source_view,

    var_result_table,

    var_cycle,

    var_status;  

-- 声明结束的时候

IF done THEN

    LEAVE read_loop;  

END

IF;  

-- 这里做你想做的循环的事件  

SET @tableName = var_result_table;

SET @viewName = var_source_view;

set sqlStr = CONCAT('INSERT INTO ',@tableName,' SELECT * FROM ',@viewName);

SET @sqlstr = sqlStr;

PREPARE stmt from @sqlstr;

EXECUTE stmt;

deallocate prepare stmt;  

UPDATE t_report_config trc SET trc.`status` = 1,trc.update_time = NOW() WHERE trc.uuid = var_uuid;  

END

LOOP

;  

-- 关闭游标

CLOSE cur;  

END

（3）视图（略）：查询的SQL，放到新建视图就可以生成。假设存储过程的入参是1，那么就使用所有配置表中cycle=1的记录，每小时统计一次。

（4）远程表连接：FEDERATED:FEDERATED存储引擎是访问远程数据库中的表，在平时开发中可以用此特性来访问远程库中的参数表之类的，还是非常方便的。使用时直接在本地构建一个federated表来链接远程数据表，配置好之后本地数据库可以直接和远程数据表进行同步，实际上这个数据库并不是真实存放数据，所需要的数据都是存放在远程服务器上。配置条件:mysql版本需要5.1以上；在安装是需要把federated引擎已经安装;检查是否开启：show engines;如果没开启，则:修改mysql的配置文件,在my.ini中[mysqld]标签下下直接加上一行 federated重启数据库服务即可。建立远程表连接：ENGINE=FEDERATED DEFAULT CHARSET=utf8 COMMENT='订单表' CONNECTION='mysql://user:password@ip:port/schema/tableName'; 

CREATE TABLE `yy_order` (

  `uuid` char(32) NOT NULL,

  `order_no` varchar(32) DEFAULT NULL COMMENT '订单号',

  PRIMARY KEY (`uuid`),

) ENGINE=FEDERATED DEFAULT CHARSET=utf8 COMMENT='订单表' CONNECTION='mysql://user:password@ip:port/schema/tableName';

2.Java工程方面

（1）定时器类： 

package com.summersoft.ts.base;  

import com.summersoft.ts.service.ConfigService;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.stereotype.Component;  

@Component("processTask")

public class ProcessTask {  

    @Autowired

    private ConfigService configService;  

    /**

     * 执行存储过程(小时)

     */

    public void  runHourProcess(){

        configService.processReportConfig(1);

    }  

    /**

     * 执行存储过程(天)

     */

    public void  runDayProcess(){

        configService.processReportConfig(2);

    }

}

（2）定时器配置：applicationContext.xml里面<beans></beans>添加配置 

<!-- 定时任务配置 -->

<task:scheduled-tasks>

    <task:scheduled ref="processTask" method="runHourProcess" cron="0 0 * * * *" />

    <task:scheduled ref="processTask" method="runDayProcess" cron="0 0 3 * * *" />

</task:scheduled-tasks>

（3） ConfigService: 

package com.summersoft.ts.service;  

public interface ConfigService {

    void processReportConfig(int cycle);

}

（4）ConfigServiceImpl: 

package com.summersoft.ts.service.impl;  

import com.summersoft.ts.dao.ReportConfigDao;

import com.summersoft.ts.service.ConfigService;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.stereotype.Service;  

@Service("configService")

public class ConfigServiceImpl implements ConfigService {  

    @Autowired

    private ReportConfigDao configDao;  

    @Override

    public void processReportConfig(int cycle) {

        try {

            configDao.processReportConfig(cycle);

        }catch (Exception e){

            System.out.println("存储过程执行异常:"+e.getMessage());

        }

    }

}

（5）ReportConfigMapper.xml对应的SQL写法： 

<select id="processReportConfig" statementType="CALLABLE" parameterType="int">

    {CALL P_REPORT_CONFIG(#{cycle, mode=IN, jdbcType=INTEGER})}

</select>

相关阅读

目录[+]