它是基于Dubbo的分布式系统架构，快速简单的上手，有服务层、前端页面层、定时任务系统、日志系统等.zip

package com.site.quartz.service; import java.text.ParseException; import java.util.Date; import java.util.List; import java.util.Map; import java.util.UUID; import org.apache.commons.collections4.MapUtils; import org.apache.commons.lang3.StringUtils; import org.apache.commons.lang3.math.NumberUtils; import org.apache.commons.lang3.time.DateUtils; import org.quartz.CronExpression; import org.quartz.JobDetail; import org.quartz.Scheduler; import org.quartz.SchedulerException; import org.quartz.TriggerKey; import org.quartz.impl.triggers.CronTriggerImpl; import org.quartz.impl.triggers.SimpleTriggerImpl; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import com.alibaba.druid.support.json.JSONUtils; import com.site.biz.mapper.QrtzTriggersMapper; import com.site.biz.model.QrtzTriggers; import com.site.common.constants.Constants; import com.site.quartz.dao.QuartzDao; @Service("schedulerService") public class SchedulerServiceImpl implements SchedulerService { private static final Logger log = LoggerFactory.getLogger(SchedulerServiceImpl.class); private static final String NULLSTRING = null; private static final Date NULLDATE = null; @Autowired private Scheduler scheduler; @Autowired private JobDetail jobDetail; @Autowired private QuartzDao quartzDao; @Autowired private QrtzTriggersMapper qrtzTriggersMapper; @Override public List<Map<String, Object>> getQrtzTriggers() { return quartzDao.getQrtzTriggers(); } @Override public List<QrtzTriggers> getQrtzTriggers(String name, String group) { QrtzTriggers qt = new QrtzTriggers(); qt.setTriggerName(name); qt.setTriggerGroup(group); return qrtzTriggersMapper.findAll(qt); } @Override public void schedule(String cronExpression) { schedule(NULLSTRING, cronExpression); } @Override public void schedule(String name, String cronExpression) { schedule(name, NULLSTRING, cronExpression); } @Override public void schedule(String name, String group, String cronExpression) { log.info("# name={} , group={} , cronExpression={}", name, group, cronExpression); try { schedule(name, group, new CronExpression(cronExpression)); } catch (ParseException e) { log.error("#schedule name={} , group={} , cronExpression={} , SchedulerException.message={}", name, group, cronExpression, e.getLocalizedMessage()); throw new IllegalArgumentException(e); } } @Override public void schedule(CronExpression cronExpression) { schedule(NULLSTRING, cronExpression); } @Override public void schedule(String name, CronExpression cronExpression) { schedule(name, NULLSTRING, cronExpression); } @Override public void schedule(String name, String group, CronExpression cronExpression) { if (isValidExpression(cronExpression)) { if (name == null || name.trim().equals("")) { name = UUID.randomUUID().toString(); } CronTriggerImpl trigger = new CronTriggerImpl(); trigger.setCronExpression(cronExpression); TriggerKey triggerKey = new TriggerKey(name, group); trigger.setJobName(jobDetail.getKey().getName()); trigger.setKey(triggerKey); try { scheduler.addJob(jobDetail, true); if (scheduler.checkExists(triggerKey)) { scheduler.rescheduleJob(triggerKey, trigger); } else { scheduler.scheduleJob(trigger); } } catch (SchedulerException e) { log.error("#schedule name={} , group={} , cronExpression={} , SchedulerException.message={}", name, group, cronExpression, e.getLocalizedMessage()); throw new IllegalArgumentException(e); } } } @Override public void schedule(Date startTime) { schedule(startTime, NULLDATE); } @Override public void schedule(Date startTime, String group) { schedule(startTime, NULLDATE, group); } @Override public void schedule(String name, Date startTime) { schedule(name, startTime, NULLDATE); } @Override public void schedule(String name, Date startTime, String group) { schedule(name, startTime, NULLDATE, group); } @Override public void schedule(Date startTime, Date endTime) { schedule(startTime, endTime, 0); } @Override public void schedule(Date startTime, Date endTime, String group) { schedule(startTime, endTime, 0, group); } @Override public void schedule(String name, Date startTime, Date endTime) { schedule(name, startTime, endTime, 0); } @Override public void schedule(String name, Date startTime, Date endTime, String group) { schedule(name, startTime, endTime, 0, group); } @Override public void schedule(Date startTime, int repeatCount) { schedule(null, startTime, NULLDATE, 0); } @Override public void schedule(Date startTime, Date endTime, int repeatCount) { schedule(null, startTime, endTime, 0); } @Override public void schedule(Date startTime, Date endTime, int repeatCount, String group) { schedule(null, startTime, endTime, 0, group); } @Override public void schedule(String name, Date startTime, Date endTime, int repeatCount) { schedule(name, startTime, endTime, 0, 0L); } @Override public void schedule(String name, Date startTime, Date endTime, int repeatCount, String group) { schedule(name, startTime, endTime, 0, 0L, group); } @Override public void schedule(Date startTime, int repeatCount, long repeatInterval) { schedule(null, startTime, NULLDATE, repeatCount, repeatInterval); } @Override public void schedule(Date startTime, Date endTime, int repeatCount, long repeatInterval) { schedule(null, startTime, endTime, repeatCount, repeatInterval); } @Override public void schedule(Date startTime, Date endTime, int repeatCount, long repeatInterval, String group) { schedule(null, startTime, endTime, repeatCount, repeatInterval, group); } @Override public void schedule(String name, Date startTime, Date endTime, int repeatCount, long repeatInterval) { schedule(name, startTime, endTime, repeatCount, repeatInterval, NULLSTRING); } @Override public void schedule(String name, Date startTime, Date endTime, int repeatCount, long repeatInterval, String group) { log.info("# name={} , startTimie={} , endTime={} , repeatCount={} , repeatInterval={} , group={}", name, startTime, endTime, repeatCount, repeatInterval, group); if (this.isValidExpression(startTime)) { if (name == null || name.trim().equals("")) { name = UUID.randomUUID().toString(); } TriggerKey triggerKey = new TriggerKey(name, group); SimpleTriggerImpl trigger = new SimpleTriggerImpl(); trigger.setKey(triggerKey); trigger.setJobName(jobDetail.getKey().getName()); trigger.setStartTime(startTime); trigger.setEndTime(endTime); trigger.setRepeatCount(repeatCount); trigger.setRepeatInterval(repeatInterval); try { scheduler.addJob(jobDetail, true); if (scheduler.checkExists(triggerKey)) { scheduler.rescheduleJob(trig