增加定时任务管理功能

pom.xml

@@ -141,6 +141,16 @@
 			<version>1.1.8</version>
 		</dependency>
 
+		<dependency>
+			<groupId>com.github.pagehelper</groupId>
+			<artifactId>pagehelper</artifactId>
+			<version>5.0.0</version>
+		</dependency>
+		<dependency>
+			<groupId>org.quartz-scheduler</groupId>
+			<artifactId>quartz</artifactId>
+			<version>2.2.1</version>
+		</dependency>
 	</dependencies>
 	<build>
 		<finalName>SolrDataComparison</finalName>

src/main/java/com/cc/solr/SolrDataComparisonApplication.java

@@ -3,6 +3,7 @@ package com.cc.solr;
 import org.mybatis.spring.annotation.MapperScan;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.context.annotation.ComponentScan;
 import org.springframework.scheduling.annotation.EnableAsync;
 import org.springframework.scheduling.annotation.EnableScheduling;
 @MapperScan(value = "com.cc.solr.mapper")

src/main/java/com/cc/solr/conf/SchedulerConfig.java

+package com.cc.solr.conf;
+
+import org.quartz.Scheduler;
+import org.quartz.ee.servlet.QuartzInitializerListener;
+import org.springframework.beans.factory.config.PropertiesFactoryBean;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.core.io.ClassPathResource;
+import org.springframework.scheduling.quartz.SchedulerFactoryBean;
+
+import java.io.IOException;
+import java.util.Properties;
+
+@Configuration
+public class SchedulerConfig {
+
+    @Bean(name="SchedulerFactory")
+    public SchedulerFactoryBean schedulerFactoryBean() throws IOException {
+        SchedulerFactoryBean factory = new SchedulerFactoryBean();
+        factory.setQuartzProperties(quartzProperties());
+        return factory;
+    }
+
+    @Bean
+    public Properties quartzProperties() throws IOException {
+        PropertiesFactoryBean propertiesFactoryBean = new PropertiesFactoryBean();
+        propertiesFactoryBean.setLocation(new ClassPathResource("/quartz.properties"));
+        //在quartz.properties中的属性被读取并注入后再初始化对象
+        propertiesFactoryBean.afterPropertiesSet();
+        return propertiesFactoryBean.getObject();
+    }
+  
+    /*
+     * quartz初始化监听器
+     */
+    @Bean
+    public QuartzInitializerListener executorListener() {
+       return new QuartzInitializerListener();
+    }
+    
+    /*
+     * 通过SchedulerFactoryBean获取Scheduler的实例
+     */
+    @Bean(name="Scheduler")
+    public Scheduler scheduler() throws IOException {
+        return schedulerFactoryBean().getScheduler();
+    }
+
+}

src/main/java/com/cc/solr/conf/WebMvcConfig.java

@@ -13,7 +13,9 @@ public class WebMvcConfig extends WebMvcConfigurerAdapter {
 
     @Override
     public void addViewControllers(ViewControllerRegistry registry) {
+
         registry.addViewController("/").setViewName("sourceecharts");
+        registry.addViewController("job").setViewName("JobManager.html");
         registry.addViewController("/form").setViewName("form");
         registry.addViewController("/main").setViewName("main");
         registry.addViewController("/sourceDataList").setViewName("sourceDataList");

src/main/java/com/cc/solr/controller/JobController.java

+package com.cc.solr.controller;
+
+
+import com.cc.solr.entity.JobAndTrigger;
+import com.cc.solr.job.BaseJob;
+import com.cc.solr.service.IJobAndTriggerService;
+import com.github.pagehelper.PageInfo;
+import org.quartz.*;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.web.bind.annotation.*;
+
+import java.util.HashMap;
+import java.util.Map;
+
+
+@RestController
+@RequestMapping(value="/job")
+public class JobController 
+{
+	@Autowired
+	private IJobAndTriggerService iJobAndTriggerService;
+	
+	//加入Qulifier注解，通过名称注入bean
+	@Autowired
+    @Qualifier("Scheduler")
+	private Scheduler scheduler;
+	
+	private static Logger log = LoggerFactory.getLogger(JobController.class);  
+	
+
+	@PostMapping(value="/addjob")
+	public void addjob(@RequestParam(value="jobClassName")String jobClassName,
+			@RequestParam(value="jobGroupName")String jobGroupName,
+			@RequestParam(value="cronExpression")String cronExpression) throws Exception
+	{			
+		addJob(jobClassName, jobGroupName, cronExpression);
+	}
+	
+	public void addJob(String jobClassName, String jobGroupName, String cronExpression)throws Exception{
+        
+        // 启动调度器  
+		scheduler.start(); 
+		
+		//构建job信息
+		JobDetail jobDetail = JobBuilder.newJob(getClass(jobClassName).getClass()).withIdentity(jobClassName, jobGroupName).build();
+		
+		//表达式调度构建器(即任务执行的时间)
+        CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(cronExpression);
+
+        //按新的cronExpression表达式构建一个新的trigger
+        CronTrigger trigger = TriggerBuilder.newTrigger().withIdentity(jobClassName, jobGroupName)
+            .withSchedule(scheduleBuilder).build();
+        
+        try {
+        	scheduler.scheduleJob(jobDetail, trigger);
+            
+        } catch (SchedulerException e) {
+            System.out.println("创建定时任务失败"+e);
+            throw new Exception("创建定时任务失败");
+        }
+	}
+
+
+	@PostMapping(value="/pausejob")
+	public void pausejob(@RequestParam(value="jobClassName")String jobClassName, @RequestParam(value="jobGroupName")String jobGroupName) throws Exception
+	{			
+		jobPause(jobClassName, jobGroupName);
+	}
+	
+	public void jobPause(String jobClassName, String jobGroupName) throws Exception
+	{	
+		scheduler.pauseJob(JobKey.jobKey(jobClassName, jobGroupName));
+	}
+	
+
+	@PostMapping(value="/resumejob")
+	public void resumejob(@RequestParam(value="jobClassName")String jobClassName, @RequestParam(value="jobGroupName")String jobGroupName) throws Exception
+	{			
+		jobresume(jobClassName, jobGroupName);
+	}
+	
+	public void jobresume(String jobClassName, String jobGroupName) throws Exception
+	{
+		scheduler.resumeJob(JobKey.jobKey(jobClassName, jobGroupName));
+	}
+	
+	
+	@PostMapping(value="/reschedulejob")
+	public void rescheduleJob(@RequestParam(value="jobClassName")String jobClassName,
+			@RequestParam(value="jobGroupName")String jobGroupName,
+			@RequestParam(value="cronExpression")String cronExpression) throws Exception
+	{			
+		jobreschedule(jobClassName, jobGroupName, cronExpression);
+	}
+	
+	public void jobreschedule(String jobClassName, String jobGroupName, String cronExpression) throws Exception
+	{				
+		try {
+			TriggerKey triggerKey = TriggerKey.triggerKey(jobClassName, jobGroupName);
+			// 表达式调度构建器
+			CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(cronExpression);
+
+			CronTrigger trigger = (CronTrigger) scheduler.getTrigger(triggerKey);
+
+			// 按新的cronExpression表达式重新构建trigger
+			trigger = trigger.getTriggerBuilder().withIdentity(triggerKey).withSchedule(scheduleBuilder).build();
+
+			// 按新的trigger重新设置job执行
+			scheduler.rescheduleJob(triggerKey, trigger);
+		} catch (SchedulerException e) {
+			System.out.println("更新定时任务失败"+e);
+			throw new Exception("更新定时任务失败");
+		}
+	}
+	
+	
+	@PostMapping(value="/deletejob")
+	public void deletejob(@RequestParam(value="jobClassName")String jobClassName, @RequestParam(value="jobGroupName")String jobGroupName) throws Exception
+	{			
+		jobdelete(jobClassName, jobGroupName);
+	}
+	
+	public void jobdelete(String jobClassName, String jobGroupName) throws Exception
+	{		
+		scheduler.pauseTrigger(TriggerKey.triggerKey(jobClassName, jobGroupName));
+		scheduler.unscheduleJob(TriggerKey.triggerKey(jobClassName, jobGroupName));
+		scheduler.deleteJob(JobKey.jobKey(jobClassName, jobGroupName));
+	}
+	
+	
+	@GetMapping(value="/queryjob")
+	public Map<String, Object> queryjob(@RequestParam(value="pageNum")Integer pageNum, @RequestParam(value="pageSize")Integer pageSize)
+	{			
+		PageInfo<JobAndTrigger> jobAndTrigger = iJobAndTriggerService.getJobAndTriggerDetails(pageNum, pageSize);
+		Map<String, Object> map = new HashMap<String, Object>();
+		map.put("JobAndTrigger", jobAndTrigger);
+		map.put("number", jobAndTrigger.getTotal());
+		return map;
+	}
+	
+	public static BaseJob getClass(String classname) throws Exception 
+	{
+		Class<?> class1 = Class.forName(classname);
+		return (BaseJob)class1.newInstance();
+	}
+	
+	
+}

src/main/java/com/cc/solr/entity/JobAndTrigger.java

+package com.cc.solr.entity;
+
+import java.math.BigInteger;
+
+public class JobAndTrigger {
+	private String JOB_NAME;
+	private String JOB_GROUP;
+	private String JOB_CLASS_NAME;
+	private String TRIGGER_NAME;
+	private String TRIGGER_GROUP;
+	private BigInteger REPEAT_INTERVAL;
+	private BigInteger TIMES_TRIGGERED;
+	private String CRON_EXPRESSION;
+	private String TIME_ZONE_ID;
+	
+	public String getJOB_NAME() {
+		return JOB_NAME;
+	}
+	public void setJOB_NAME(String jOB_NAME) {
+		JOB_NAME = jOB_NAME;
+	}
+	public String getJOB_GROUP() {
+		return JOB_GROUP;
+	}
+	public void setJOB_GROUP(String jOB_GROUP) {
+		JOB_GROUP = jOB_GROUP;
+	}
+	public String getJOB_CLASS_NAME() {
+		return JOB_CLASS_NAME;
+	}
+	public void setJOB_CLASS_NAME(String jOB_CLASS_NAME) {
+		JOB_CLASS_NAME = jOB_CLASS_NAME;
+	}
+	public String getTRIGGER_NAME() {
+		return TRIGGER_NAME;
+	}
+	public void setTRIGGER_NAME(String tRIGGER_NAME) {
+		TRIGGER_NAME = tRIGGER_NAME;
+	}
+	public String getTRIGGER_GROUP() {
+		return TRIGGER_GROUP;
+	}
+	public void setTRIGGER_GROUP(String tRIGGER_GROUP) {
+		TRIGGER_GROUP = tRIGGER_GROUP;
+	}
+	public BigInteger getREPEAT_INTERVAL() {
+		return REPEAT_INTERVAL;
+	}
+	public void setREPEAT_INTERVAL(BigInteger rEPEAT_INTERVAL) {
+		REPEAT_INTERVAL = rEPEAT_INTERVAL;
+	}
+	public BigInteger getTIMES_TRIGGERED() {
+		return TIMES_TRIGGERED;
+	}
+	public void setTIMES_TRIGGERED(BigInteger tIMES_TRIGGERED) {
+		TIMES_TRIGGERED = tIMES_TRIGGERED;
+	}
+	public String getCRON_EXPRESSION() {
+		return CRON_EXPRESSION;
+	}
+	public void setCRON_EXPRESSION(String cRON_EXPRESSION) {
+		CRON_EXPRESSION = cRON_EXPRESSION;
+	}
+	public String getTIME_ZONE_ID() {
+		return TIME_ZONE_ID;
+	}
+	public void setTIME_ZONE_ID(String tIME_ZONE_ID) {
+		TIME_ZONE_ID = tIME_ZONE_ID;
+	}
+	
+}

src/main/java/com/cc/solr/job/BaseJob.java

+package com.cc.solr.job;
+
+import org.quartz.Job;
+import org.quartz.JobExecutionContext;
+import org.quartz.JobExecutionException;
+
+public interface BaseJob extends Job{
+	public void execute(JobExecutionContext context) throws JobExecutionException;
+}
+

src/main/java/com/cc/solr/job/HelloJob.java

+package com.cc.solr.job;
+
+import org.quartz.JobExecutionContext;
+import org.quartz.JobExecutionException;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.util.Date;
+
+public class HelloJob implements BaseJob {  
+  
+    private static Logger _log = LoggerFactory.getLogger(HelloJob.class);  
+     
+    public HelloJob() {  
+          
+    }  
+     
+    public void execute(JobExecutionContext context)  
+        throws JobExecutionException {  
+        _log.error("Hello Job执行时间: " + new Date());  
+          
+    }  
+}  

src/main/java/com/cc/solr/job/NewJob.java

+package com.cc.solr.job;
+
+import org.quartz.JobExecutionContext;
+import org.quartz.JobExecutionException;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.util.Date;
+
+public class NewJob implements BaseJob {  
+  
+    private static Logger _log = LoggerFactory.getLogger(NewJob.class);  
+     
+    public NewJob() {  
+          
+    }  
+     
+    public void execute(JobExecutionContext context)  
+        throws JobExecutionException {  
+        _log.error("New Job执行时间: " + new Date());  
+          
+    }  
+}  
\ No newline at end of file

src/main/java/com/cc/solr/mapper/JobAndTriggerMapper.java

+package com.cc.solr.mapper;
+
+
+import com.cc.solr.entity.JobAndTrigger;
+
+import java.util.List;
+
+public interface JobAndTriggerMapper {
+	public List<JobAndTrigger> getJobAndTriggerDetails();
+}

src/main/java/com/cc/solr/service/IJobAndTriggerService.java

+package com.cc.solr.service;
+
+
+import com.cc.solr.entity.JobAndTrigger;
+import com.github.pagehelper.PageInfo;
+
+public interface IJobAndTriggerService {
+	public PageInfo<JobAndTrigger> getJobAndTriggerDetails(int pageNum, int pageSize);
+}

src/main/java/com/cc/solr/service/serviceimpl/JobAndTriggerImpl.java

+package com.cc.solr.service.serviceimpl;
+
+
+import com.cc.solr.entity.JobAndTrigger;
+import com.cc.solr.mapper.JobAndTriggerMapper;
+import com.cc.solr.service.IJobAndTriggerService;
+import com.github.pagehelper.PageHelper;
+import com.github.pagehelper.PageInfo;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+
+@Service
+public class JobAndTriggerImpl implements IJobAndTriggerService {
+
+	@Autowired
+	private JobAndTriggerMapper jobAndTriggerMapper;
+	
+	public PageInfo<JobAndTrigger> getJobAndTriggerDetails(int pageNum, int pageSize) {
+		PageHelper.startPage(pageNum, pageSize);
+		List<JobAndTrigger> list = jobAndTriggerMapper.getJobAndTriggerDetails();
+		PageInfo<JobAndTrigger> page = new PageInfo<JobAndTrigger>(list);
+		return page;
+	}
+
+}
\ No newline at end of file

src/main/resources/application.yml

@@ -30,3 +30,4 @@ mybatis:
   config-location: classpath:mybatis/mybatis-config.xml
   # 指定sql映射文件位置
   mapper-locations: classpath:mybatis/mapper/*.xml
+

src/main/resources/mybatis/mapper/JobMapper.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >  
+<mapper namespace="com.cc.solr.mapper.JobAndTriggerMapper">
+    
+    <select id="getJobAndTriggerDetails" resultType="com.cc.solr.entity.JobAndTrigger">
+			SELECT
+				qrtz_job_details.JOB_NAME,
+				qrtz_job_details.JOB_GROUP,
+				qrtz_job_details.JOB_CLASS_NAME,
+				qrtz_triggers.TRIGGER_NAME,
+				qrtz_triggers.TRIGGER_GROUP,
+				qrtz_cron_triggers.CRON_EXPRESSION,
+				qrtz_cron_triggers.TIME_ZONE_ID
+			FROM
+				qrtz_job_details
+			JOIN qrtz_triggers
+			JOIN qrtz_cron_triggers ON qrtz_job_details.JOB_NAME = qrtz_triggers.JOB_NAME
+			AND qrtz_triggers.TRIGGER_NAME = qrtz_cron_triggers.TRIGGER_NAME
+			AND qrtz_triggers.TRIGGER_GROUP = qrtz_cron_triggers.TRIGGER_GROUP
+    </select>
+    
+</mapper>
\ No newline at end of file

src/main/resources/quartz.properties

+# 固定前缀org.quartz
+# 主要分为scheduler、threadPool、jobStore、plugin等部分
+#
+#
+org.quartz.scheduler.instanceName = DefaultQuartzScheduler
+org.quartz.scheduler.rmi.export = false
+org.quartz.scheduler.rmi.proxy = false
+org.quartz.scheduler.wrapJobExecutionInUserTransaction = false
+
+# 实例化ThreadPool时，使用的线程类为SimpleThreadPool
+org.quartz.threadPool.class = org.quartz.simpl.SimpleThreadPool
+
+# threadCount和threadPriority将以setter的形式注入ThreadPool实例
+# 并发个数
+org.quartz.threadPool.threadCount = 5
+# 优先级
+org.quartz.threadPool.threadPriority = 5
+org.quartz.threadPool.threadsInheritContextClassLoaderOfInitializingThread = true
+
+org.quartz.jobStore.misfireThreshold = 5000
+
+# 默认存储在内存中
+#org.quartz.jobStore.class = org.quartz.simpl.RAMJobStore
+
+#持久化
+org.quartz.jobStore.class = org.quartz.impl.jdbcjobstore.JobStoreTX
+
+org.quartz.jobStore.tablePrefix = QRTZ_
+
+org.quartz.jobStore.dataSource = qzDS
+
+org.quartz.dataSource.qzDS.driver = com.mysql.jdbc.Driver
+
+org.quartz.dataSource.qzDS.URL = jdbc:mysql://127.0.0.1:3306/mybatis?useUnicode=true&characterEncoding=UTF-8
+
+org.quartz.dataSource.qzDS.user = root
+
+org.quartz.dataSource.qzDS.password = 123
+
+org.quartz.dataSource.qzDS.maxConnections = 10
\ No newline at end of file

src/main/resources/templates/JobManager.html

+<!DOCTYPE html>
+<html>
+<head>
+<meta charset="UTF-8">
+	<title>QuartzDemo</title>
+	<link rel="stylesheet" href="https://unpkg.com/element-ui@2.0.5/lib/theme-chalk/index.css">
+	<script src="https://unpkg.com/vue/dist/vue.js"></script>
+	<script src="http://cdn.bootcss.com/vue-resource/1.3.4/vue-resource.js"></script>
+	<script src="https://unpkg.com/element-ui@2.0.5/lib/index.js"></script>
+	
+	<style>      
+      #top {
+	      background:#20A0FF;
+	      padding:5px;
+	      overflow:hidden
+      }
+	</style>
+	
+</head>
+<body>
+    <div id="test">		        
+
+		<div id="top">			
+				<el-button type="text" @click="search" style="color:white">查询</el-button>	
+				<el-button type="text" @click="handleadd" style="color:white">添加</el-button>	
+			</span>						
+		</div>	
+				
+		<br/>
+
+        <div style="margin-top:15px">	
+
+		  <el-table
+		    ref="testTable"		  
+		    :data="tableData"
+		    style="width:100%"
+		    border
+		    >
+		    <el-table-column
+		      prop="job_NAME"
+		      label="任务名称"
+		      sortable
+		      show-overflow-tooltip>
+		    </el-table-column>
+		    
+		    <el-table-column
+		      prop="job_GROUP"
+		      label="任务所在组"
+		      sortable>
+		    </el-table-column>
+		    
+   		    <el-table-column
+		      prop="job_CLASS_NAME"
+		      label="任务类名"
+		      sortable>
+		    </el-table-column>
+		    
+   		    <el-table-column
+		      prop="trigger_NAME"
+		      label="触发器名称"
+		      sortable>
+		    </el-table-column>
+		    
+		    <el-table-column
+		      prop="trigger_GROUP"
+		      label="触发器所在组"
+		      sortable>
+		    </el-table-column>
+		    
+		    <el-table-column
+		      prop="cron_EXPRESSION"
+		      label="表达式"
+		      sortable>
+		    </el-table-column>
+		    
+		    <el-table-column
+		      prop="time_ZONE_ID"
+		      label="时区"
+		      sortable>
+		    </el-table-column>
+		    
+	        <el-table-column label="操作" width="300">
+		      <template scope="scope">
+		      	<el-button
+		          size="small"
+		          type="warning"
+		          @click="handlePause(scope.$index, scope.row)">暂停</el-button>
+		          
+		        <el-button
+		          size="small"
+		          type="info"
+		          @click="handleResume(scope.$index, scope.row)">恢复</el-button>
+		          
+		        <el-button
+		          size="small"
+		          type="danger"
+		          @click="handleDelete(scope.$index, scope.row)">删除</el-button>
+		          
+		        <el-button
+		          size="small"
+		          type="success"
+		          @click="handleUpdate(scope.$index, scope.row)">修改</el-button>
+		      </template>
+		    </el-table-column>
+		  </el-table>
+		  
+		  <div align="center">
+			  <el-pagination
+			      @size-change="handleSizeChange"
+			      @current-change="handleCurrentChange"
+			      :current-page="currentPage"
+			      :page-sizes="[10, 20, 30, 40]"
+			      :page-size="pagesize"
+			      layout="total, sizes, prev, pager, next, jumper"
+			      :total="totalCount">
+			  </el-pagination>
+		  </div>
+		</div> 
+		
+		<el-dialog title="添加任务" :visible.sync="dialogFormVisible">
+		  <el-form :model="form">
+		    <el-form-item label="任务名称" label-width="120px" style="width:35%">
+		      <el-input v-model="form.jobName" auto-complete="off"></el-input>
+		    </el-form-item>	    
+		    <el-form-item label="任务分组" label-width="120px" style="width:35%">
+		      <el-input v-model="form.jobGroup" auto-complete="off"></el-input>
+		    </el-form-item>
+		    <el-form-item label="表达式" label-width="120px" style="width:35%">
+		      <el-input v-model="form.cronExpression" auto-complete="off"></el-input>
+		    </el-form-item>
+		  </el-form>
+		  <div slot="footer" class="dialog-footer">
+		    <el-button @click="dialogFormVisible = false">取 消</el-button>
+		    <el-button type="primary" @click="add">确 定</el-button>
+		  </div>
+		</el-dialog>
+		
+		<el-dialog title="修改任务" :visible.sync="updateFormVisible">
+		  <el-form :model="updateform">
+		    <el-form-item label="表达式" label-width="120px" style="width:35%">
+		      <el-input v-model="updateform.cronExpression" auto-complete="off"></el-input>
+		    </el-form-item>
+		  </el-form>
+		  <div slot="footer" class="dialog-footer">
+		    <el-button @click="updateFormVisible = false">取 消</el-button>
+		    <el-button type="primary" @click="update">确 定</el-button>
+		  </div>
+		</el-dialog>
+		
+    </div>
+	
+    <footer align="center">
+        <p>&copy; Quartz 任务管理</p>
+    </footer>
+
+	<script>
+	var vue = new Vue({			
+			el:"#test",
+		    data: {		  
+		    	//表格当前页数据
+		    	tableData: [],
+		        
+		        //请求的URL
+		        url:'job/queryjob',
+		        
+		        //默认每页数据量
+		        pagesize: 10,		        
+		        
+		        //当前页码
+		        currentPage: 1,
+		        
+		        //查询的页码
+		        start: 1,
+		        
+		        //默认数据总数
+		        totalCount: 1000,
+		        
+		        //添加对话框默认可见性
+		        dialogFormVisible: false,
+		        
+		        //修改对话框默认可见性
+		        updateFormVisible: false,
+		        
+		        //提交的表单
+		        form: {
+		        	jobName: '',
+		        	jobGroup: '',
+		        	cronExpression: '',
+		          },
+		          
+		        updateform: {
+		        	jobName: '',
+		        	jobGroup: '',
+		        	cronExpression: '',
+		        },
+		    },
+
+		    methods: {
+		    	
+		        //从服务器读取数据
+				loadData: function(pageNum, pageSize){					
+					this.$http.get('job/queryjob?' + 'pageNum=' +  pageNum + '&pageSize=' + pageSize).then(function(res){
+						console.log(res)
+                		this.tableData = res.body.JobAndTrigger.list;
+                		this.totalCount = res.body.number;
+                	},function(){
+                  		console.log('failed');
+                	});					
+				},			    		        
+				      
+		        //单行删除
+			    handleDelete: function(index, row) {
+					this.$http.post('job/deletejob',{"jobClassName":row.job_NAME,"jobGroupName":row.job_GROUP},{emulateJSON: true}).then(function(res){
+						this.loadData( this.currentPage, this.pagesize);
+		            },function(){
+		                console.log('failed');
+		            });
+		        },
+		        
+		        //暂停任务
+		        handlePause: function(index, row){
+		        	this.$http.post('job/pausejob',{"jobClassName":row.job_NAME,"jobGroupName":row.job_GROUP},{emulateJSON: true}).then(function(res){
+						this.loadData( this.currentPage, this.pagesize);
+		            },function(){
+		                console.log('failed');
+		            });
+		        },
+		        
+		        //恢复任务
+		        handleResume: function(index, row){
+		        	this.$http.post('job/resumejob',{"jobClassName":row.job_NAME,"jobGroupName":row.job_GROUP},{emulateJSON: true}).then(function(res){
+						this.loadData( this.currentPage, this.pagesize);
+		            },function(){
+		                console.log('failed');
+		            });
+		        },
+		        
+		        //搜索
+		        search: function(){
+		        	this.loadData(this.currentPage, this.pagesize);
+		        },
+		        
+		        //弹出对话框
+		        handleadd: function(){		                
+		            this.dialogFormVisible = true;	              
+		        },
+		        
+		        //添加
+		        add: function(){
+		        	this.$http.post('job/addjob',{"jobClassName":this.form.jobName,"jobGroupName":this.form.jobGroup,"cronExpression":this.form.cronExpression},{emulateJSON: true}).then(function(res){
+        				this.loadData(this.currentPage, this.pagesize);
+        				this.dialogFormVisible = false;
+                    },function(){
+                        console.log('failed');
+                    });
+		        },
+		        
+		        //更新
+		        handleUpdate: function(index, row){
+		        	console.log(row)
+		        	this.updateFormVisible = true;
+		        	this.updateform.jobName = row.job_CLASS_NAME;
+		        	this.updateform.jobGroup = row.job_GROUP;
+		        },
+		        
+		        //更新任务
+		        update: function(){
+		        	this.$http.post
+		        	('job/reschedulejob',
+		        			{"jobClassName":this.updateform.jobName,
+		        			 "jobGroupName":this.updateform.jobGroup,
+		        			 "cronExpression":this.updateform.cronExpression
+		        			 },{emulateJSON: true}
+		        	).then(function(res){
+		        		this.loadData(this.currentPage, this.pagesize);
+        				this.updateFormVisible = false;
+		        	},function(){
+                        console.log('failed');
+                    });
+		    
+		        },
+		      
+		        //每页显示数据量变更
+		        handleSizeChange: function(val) {
+		            this.pagesize = val;
+		            this.loadData(this.currentPage, this.pagesize);
+		        },
+		        
+		        //页码变更
+		        handleCurrentChange: function(val) {
+		            this.currentPage = val;
+		            this.loadData(this.currentPage, this.pagesize);
+		        },	      
+		        		        
+		    },	    
+		    
+		    
+		  });
+	
+		  //载入数据
+    	  vue.loadData(vue.currentPage, vue.pagesize);
+	</script>  
+	
+</body>
+</html>