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)


相关推荐

  • 富文本框_html表单输入框对齐

    富文本框_html表单输入框对齐1.HTML代码:<trid="illegal"><th></th><tdcolspan="3"style

  • 图片压缩最优方案

    图片压缩最优方案

  • 深度学习之:什么是流形(manifold)?流形空间,流形学习

    深度学习之:什么是流形(manifold)?流形空间,流形学习作者:麋路链接:https://www.zhihu.com/question/24015486/answer/194284643来源:知乎著作权归作者所有。商业转载请联系作者获得授权,非商业转载请注明出处。流形学习的观点是认为,我们所能观察到的数据实际上是由一个低维流形映射到高维空间上的。由于数据内部特征的限制,一些高维中的数据会产生维度上的冗余,实际上只需要比较低的维度就能唯一地表示。举个例子,比如说我们在平面上有个圆,如何表示这个圆呢?如果我们把圆放在一个平面直角坐标系中,那一个圆实际.

    2022年10月29日
  • BigDecimal加减乘除运算(转)[通俗易懂]

    BigDecimal加减乘除运算(转)[通俗易懂]java.math.BigDecimal。BigDecimal一共有4个够造方法,让我先来看看其中的两种用法:第一种:BigDecimal(doubleval)TranslatesadoubleintoaBigDecimal.第二种:BigDecimal(Stringval)Transla…

  • 阿里云部署SSL证书「建议收藏」

    阿里云部署SSL证书「建议收藏」查找中间证书为了确保兼容到所有浏览器,我们必须在阿里云上部署中间证书,如果不部署证书,虽然安装过程可以完全也不会报错,但可能导致Android系统,Chrome和Firefox等浏览器无法识别。

  • 开源项目之架构分享[通俗易懂]

    开源项目之架构分享[通俗易懂]此次分享是我当初在开发某个系统时,参考的一些开源项目架构的思路和风格。第一个是Jeesite,它的架构风格如下:大家如果对jeesite感兴趣的话,可以百度搜索找到,不过那已经是半年多以前的事情,jeesite目前也发生较大的变化。当初我在参考jessite这个思路时,不知道是什么原因使我没有加入module,其实从现在的角度出发,加上module也是一件不错的事情,modu…

发表回复

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

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