struts定时任务实现(quartz任务调度)

最近有需求要写一个定时任务目的是更新一些员工/人员与部门之间的关系项目用的是struts2当我加了spring的jar包之后写了一个定时任务项目经理不让用spring就修改一下这次贴个全的下面是任务类packagecom.timetask.action;importjava.io.BufferedWriter;importjava.io.File;importjava….

大家好,又见面了,我是你们的朋友全栈君。

最近有需求要写一个定时任务 目的是更新一些员工/人员与部门之间的关系 
项目用的是struts2 当我加了spring的jar包之后写了一个定时任务 项目经理不让用spring 就修改一下 这次贴个全的 
下面是任务类
package com.timetask.action;
import java.io.BufferedWriter;
import java.io.File;
import java.io.FileWriter;
import java.io.PrintWriter;
import java.sql.SQLException;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;
import java.util.Iterator;
import java.util.List;
import java.util.Map;

import com.ibatis.sqlmap.client.SqlMapClient;
import com.ibatis.sqlmap.client.SqlMapExecutor;
import com.ibatis.sqlmap.engine.impl.SqlMapClientImpl;
import com.util.SqlMap;


/**
 * Quartz定时任务
 * 更新
 * @author Administrator
 *
 */
public class TimeTaskAction {

	/*定时任务方法*/
	public void exec() throws SQLException{
		System.out.println("quartz定时任务开始");
		try {
			List<Map> companys = SqlMap.getSqlMap().queryForList("timetask.findAll_company");
			updateDept(companys);
			update_sys_yuang();
		} catch (Exception e) {
			e.printStackTrace();
		}
		System.out.println("quartz定时任务结束!");
	}
	/*递归更新部门表corpid*/
	public void updateDept(List<Map> list){
		try {
			for (Map map : list) {
				SqlMap.getSqlMap().update("timetask.updatetta_by_depid",map.get("DEPID").toString());
				SqlMap.getSqlMap().update("timetask.updatetta",map.get("DEPID").toString());
				List<Map> listLevel = SqlMap.getSqlMap().queryForList("timetask.findSubsidiary",map.get("DEPID").toString());
				if(listLevel.size()>0){
					updateDept(listLevel);
				}
			}
		} catch (SQLException e) {
			System.out.println("ibatis执行sql失败");
			e.printStackTrace();
		}
	}

	/*sys_yuang 表 corpid与sys_dept表corpid同步*/
	public void update_sys_yuang(){
		try {
		long starttime = System.currentTimeMillis();
		SqlMap.getSqlMap().update("timetask.update_sys_yuang_corpid");
		long endtime = System.currentTimeMillis()-starttime;	
		System.out.println(endtime);
		} catch (SQLException e) {
			System.out.println("存储过程调用失败:"+e.getMessage());
			e.printStackTrace();
		}
	}
	
}

上面是任务类,下面是struts2-quartz配置文件

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN" "http://www.springframework.org/dtd/spring-beans.dtd">

<beans>
	<!-- 要调用的工作类 -->
	<bean id="timetask" class="com.timetask.action.TimeTaskAction"></bean>
	<!-- 定义调用对象和调用对象的方法 -->
	<bean id="mainJob" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
		<property name="targetObject">
			<ref bean="timetask"/>
		</property>
		<property name="targetMethod">
			<value>exec</value>
		</property>
		
	</bean>
	
	<!-- 定义触发时间 -->
	
	<!-- 创建触发器   触发器保存任务的执行时间-->
	<bean id="timeTrigger" class="org.springframework.scheduling.quartz.CronTriggerBean">
		<property name="jobDetail" ref="mainJob"></property>
		<!-- 每晚20:01分触发 -->
		<property name="cronExpression" value="0 1 20 * * ?"></property>
	</bean>
	<bean id="startQuertz" lazy-init="false" autowire="no" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
		<property name="triggers">
			<list>
				<ref local="timeTrigger"/>
			</list>
		</property>
	</bean>
</beans>

这是web.xml配置文件

struts定时任务实现(quartz任务调度)

下面是oracle的SQL的xml

struts定时任务实现(quartz任务调度)

把存储过程贴一下 其实就是俩游标

create or replace procedure update_userAndyuang_corpid
as
cursor cur is select d.depid,d.corpid,u.rowid row_id from sys_dept d,sys_user u where u.depid=d.depid order by u.rowid;
cursor cury is select d.depid,d.corpid,u.rowid row_id from sys_dept d,sys_yuang u where u.depid=d.depid order by u.rowid;
v_count number;

begin
v_count :=0;
for r in cur loop
    update sys_user set corpid=r.corpid where rowid=r.row_id;
    v_count:=v_count+1;
    if(v_count>=1000) then
    commit;
    v_count:=0;
    end if;
end loop;
commit;
for r in cury loop
    update sys_yuang set corpid=r.corpid where rowid=r.row_id;
    v_count:=v_count+1;
    if(v_count>=1000) then
    commit;
    v_count:=0;
    end if;
end loop;
commit;
end update_userAndyuang_corpid;

成功执行了

struts定时任务实现(quartz任务调度)

完成

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。

发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/128719.html原文链接:https://javaforall.cn

【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛

【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...

(0)
blank

相关推荐

  • 关于矩阵的归一化

    关于矩阵的归一化最近在看Yang大牛稀疏表示论文的代码,发现里面很多的操作的用到了矩阵的列归一化,这里谈一谈列归一化的实现,以及其带来的好处。矩阵的列归一化,就是将矩阵每一列的值,除以每一列所有元素平方和的绝对值,这样做的结果就是,矩阵每一列元素的平方和为1了。举个例子,矩阵[1,2,3]’,将其归一化的结果就是[0.2673,0.5345,0.8018]。其平方和就为1了。Y

    2022年10月11日
  • datagrip 2.4 激活_最新在线免费激活

    (datagrip 2.4 激活)JetBrains旗下有多款编译器工具(如:IntelliJ、WebStorm、PyCharm等)在各编程领域几乎都占据了垄断地位。建立在开源IntelliJ平台之上,过去15年以来,JetBrains一直在不断发展和完善这个平台。这个平台可以针对您的开发工作流进行微调并且能够提供…

  • datagrip 2021激活码-激活码分享

    (datagrip 2021激活码)好多小伙伴总是说激活码老是失效,太麻烦,关注/收藏全栈君太难教程,2021永久激活的方法等着你。IntelliJ2021最新激活注册码,破解教程可免费永久激活,亲测有效,下面是详细链接哦~https://javaforall.cn/100143.htmlF6EG2ZUBVX-eyJsaWNlbnNlSWQi…

  • Java–反射机制原理、几种Class获取方式及应用场景[通俗易懂]

    Java–反射机制原理、几种Class获取方式及应用场景[通俗易懂]目录学习背景一、Java反射机制是什么?1.1反射原理1.2举例说明二、Java反射机制中获取Class的三种方式及区别?2.1三种方式及区别2.2代码演示区别三、Java反射机制的应用场景有哪些?3.1应用场景3.2应用场景实现3.2.1简单工厂模式3.2.2简单工厂模式优化(应用场景)3.2.1代理模式中动态代理(应用场景)学习背景学习Java的小伙伴,可能听过Java反射机制,但是熟悉又有点陌生,本文主要是通过思考面试中经常被问到的几个Java反射机制的问题,再通过理论知识结合代

  • Java基础学习笔记总结

    Java基础学习笔记总结Java基础学习笔记一Java介绍Java基础学习笔记二Java基础语法之变量、数据类型Java基础学习笔记三Java基础语法之流程控制语句、循环Java基础学习笔记四Java基础语法之

  • HDU 2955 Robberies

    HDU 2955 Robberies

发表回复

您的电子邮箱地址不会被公开。

关注全栈程序员社区公众号