接口用来用户在泛普OA办公软件ThinkOne系统自由定义一些需要定时执行的操作

申请免费试用、咨询电话：400-8352-114

自定义定时器
一. 接口说明
该接口用来用户在泛普OA办公软件泛普OA系统系统自由定义一些需要定时执行的操作，它是由Quartz这一个开源的作业调度框架来实现；
该接口通过配置调度时间和自行开发调度动作来实现需要定时执行的任务。
该接口提供了两种调度方式
IntervalJob接口，此接口每隔一段时间执行一次(自己定义间隔时间)
CronJob接口，此接口在指定的时间点执行(自己定义时间点)
在开发调度动作需要实现泛普OA办公软件泛普OA系统提供的自定义动作接口。

二. 实现方法&步骤
1. 配置调度文件schedule.xml(该文件位于泛普OA办公软件泛普OA系统的WEB-INF/service/目录下)
<?xml version="1.0" encoding="GBK"?>
<module id="datasource" version="1.0.0">
<service-point id="job1" interface="OA.interfaces.schedule.IntervalJob">
        <invoke-factory>
            <construct class="MyIntervalJob "> 
            <set-service property="ds" service-id="datasource.dt1"/>
               <set property="second" value="60"/>
            </construct>
        </invoke-factory>
</service-point>
<service-point id="job2" interface="OA.interfaces.schedule.CronJob">
        <invoke-factory>
            <construct class="MyCronJob ">
        <set-service property="ds" service-id="datasource.dt2"/>
                <set property="cronExpr" value="0 44 12 ? * MON-FRI"/>
            </construct>
        </invoke-factory>
</service-point>

上文中配置两个调度任务job1,job2，实现了两种调度策略，其中黑体部分是在配置每个调度时需要改变的内容；

注意：每次配置后需要重启OA服务方可生效；
2. 属性说明
 Id：唯一标识该调度任务，无其他作用
 service-id：上文定义的自定义数据源，如果任务执行的动作中需要和数据源中的数据库交付数据，需要设置该属性
 class：该任务真正执行的操作，其中job1中MyIntervalJob必须继承OA.interfaces.schedule.IntervalJob，job2中MyCronJob必须继承OA.interfaces.schedule.CronJob；继承后需要实现的方法是其中的execute();
 value：任务执行的频率，在JOB1中表示没60秒执行一次，在JOB2中表示每周一到周五12：44执行(JOB2的执行频率配置方式和一般LINUX操作系统的定时任务配置方式一致)
3. 在5.0及以上版本对于CronJob可以直接在进行可视化的配置
通过顶部菜单【设置中心】【外部接口设置】【配置计划任务接口】即可进入配置界面
 

点击右键【新建】即可创建一个新的【计划任务】
 
注意：该配置，不需要重启OA服务即可生效

4. 可视化配置属性说明
 计划任务标识，即xml配置中的Id：唯一标识该调度任务，无其他作用
 计划任务类，即xml配置中的class：该任务真正执行的操作，MyCronJo必须继承OA.interfaces.schedule.CronJob；继承后需要实现的方法是其中的execute();
 定时时间，即xml配置中的value：任务执行的频率，表示每周一到周五12：44执行(执行频率配置方式和一般LINUX操作系统的定时任务配置方式一致)

5. 如何实现任务执行的操作
实现定时执行的操作，实际上就是实现OA.interfaces.schedule.BaseIntervalJob 或者OA.interfaces.schedule.BaseCronJob中的execute()方法
import OA.interfaces.schedule.BaseIntervalJob;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
/**
 * IntervalJob示范代码,集成BaseIntervalJob,用自己的业务逻辑覆盖了execute()方法,实际使用中这里可以编写用户需要实现的代码
 */
public class MyIntervalJob extends BaseIntervalJob {
    public void execute() {
        //从数据源中获取连接
        Connection conn = getDs().getConnection();  //此处是取得上文定义的数据源dt1,如果需要操作其他系统的数据才需要该定义
        try {
            //通过jdbc获取人数
            PreparedStatement s = conn.prepareStatement("select count(*) as amount from hrmresource");  //此时假设在数据源dt1定义的数据库中有hrmresource表
            ResultSet rs = s.executeQuery();
            rs.next();
            String amount = rs.getString("amount");
            //输出到控制台
            System.out.println("人数:" + amount);
            //关闭记录集
            rs.close();
            //关闭statement
            s.close();
        } catch (Exception e) {
                   } finally {
            try {
                //关闭连接
                conn.close();
            } catch (Exception e) {
                           }
        }
    }
}