java scheduler 定时demo

/** * MessageTaskJob.java 2017年8月7日 * * @Copyright 2013-2017 深圳超群高科技有限公司 * 广东省深圳市南山区科技园紫光信息港C栋608， 中国 * 保留所有权利。 * * 本软件是深圳超群高科技有限公司的机密和专有信息， * 您不得披露该保密信息，并只能按照您与深圳超群高科技有限公司签订的许可协议中的条款使用。 * */ package com.cqgk.web.scheduler; import java.util.Date; import java.util.List; import org.apache.commons.collections.CollectionUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; import com.cqgk.common.util.DateUtil; import com.cqgk.common.web.BaseController; import com.cqgk.service.form.IFormPageCfgService; import com.cqgk.service.foundation.constant.Const; import com.cqgk.service.foundation.partnerInfo.IPartnerInfoService; import com.cqgk.service.foundation.partnerInfo.entity.PartnerInfo; import com.cqgk.service.foundation.sys.ISysUserRoleLinkService; import com.cqgk.service.message.IMessageService; import com.cqgk.service.message.IPushMessageService; import com.cqgk.service.message.entity.Messages; import com.cqgk.service.order.IBonusAccountService; import com.cqgk.service.order.IOrderService; import com.cqgk.service.order.entity.BonusResetTask; /** * ClassName: MessageTaskJob <br/> * Function: 消息推送定时任务 <br/> * * @author 肖传毅 * @version * @date 2017年8月7日 上午10:46:37 */ @RestController @RequestMapping("/messageTimer") @Component("messageTaskJob") public class MessageTaskJob extends BaseController { private Logger log = LoggerFactory.getLogger(MessageTaskJob.class); @Autowired private IPushMessageService pushMessageService; @Autowired private IMessageService messageService; @Autowired private IPartnerInfoService partnerInfoService; @Autowired private ISysUserRoleLinkService sysUserRoleLinkService; @Autowired private IOrderService orderService; @Autowired private IBonusAccountService bonusAccountService; @Autowired private IFormPageCfgService formPageCfgService; /** * 定时轮询推送待推送的消息 <br/> * cron 表达式必须为6个参数，分别表示 ：{秒} {分} {时} {日} {月} {周} {年(可选)} <br/> * 比如 cron = "0 0/10 * * * ?" 表示 每隔10分钟执行一次<br/> * 比如 cron = "0/30 * * * * ?" 表示 每隔30秒执行一次<br/> * * @author 肖传毅 * @date: 2017年8月7日 下午3:47:51 <br/> * @since */ @Scheduled(cron = "0 0/1 * * * ?") @RequestMapping(value="/start.do", produces="application/json;charset=UTF-8") public void pushMessage() { if(!MessagePushRunnable.isRunning()) { new Thread(new MessagePushRunnable(pushMessageService, log)).start(); }else { log.error("running"); } } /** * 定时更新订单打印状态 * * @author 周桂芩 * @date: 2017年8月7日 下午7:48:39 <br/> * @desc 没五分钟执行一次，更新订单打印状态 * @since */ @Scheduled(cron = "0 * 0/5 * * ?") @RequestMapping(value="/batchUpdatePrintLog.do", produces="application/json;charset=UTF-8") public void batchUpdatePrintLog() { try { orderService.batchUpdatePrintState(); } catch (Exception e) { e.printStackTrace(); } } /** * 定时查询并执行积分清零（每天00:00:00）<br/> * * @author 王辉 * @date: 2017年11月23日 下午5:34:58 <br/> * @since */ @Scheduled(cron = "0 0 0 * * ?") @RequestMapping(value="/executeBonusResetTask.do", produces="application/json;charset=UTF-8") public void executeBonusResetTask() { try { System.out.println("查询清零任务"); List<BonusResetTask> tasks = bonusAccountService.queryNeedResetBonusTasks(new Date()); if(CollectionUtils.isNotEmpty(tasks)) { for(BonusResetTask task : tasks) { try { System.out.println("执行清零任务"); bonusAccountService.executeBonusResetTask(task.getId()); } catch (Exception e) { e.printStackTrace(); continue; } } } } catch (Exception e) { e.printStackTrace(); } } /** * 定时查询续费快到期的合作伙伴公司，对其管理员和BOSS进行短信和通知提醒任务（每天8点执行）<br/> * * @author 段伟忠 * @date: 2018年02月06日 上午11:28:26 <br/> * @since JDK 1.8 */ @Scheduled(cron = "0 0 8 * * ?") @RequestMapping(value="/executePartnerRenewRemindTask.do", produces="application/json;charset=UTF-8") public void executePartnerRenewRemindTask() { try { System.out.println("查询续费快到期的合作伙伴公司任务"); boolean isNotFirst = messageService.existsPartnerRenewRemindMessagemsSendLog(); Date now = new Date(); List<PartnerInfo> partnerList = partnerInfoService.queryPartnerRenewRemindList(now, isNotFirst); if(CollectionUtils.isNotEmpty(partnerList)) { System.out.println("执行短信和通知发送任务"); for(PartnerInfo partnerInfo : partnerList) { try { //给管理员和BOSS发送短信，同时返回BOSS的userId列表 long expireDay = DateUtil.getDayInterval(partnerInfo.getValidEndDate(), now); List<String> bossUserIds = sysUserRoleLinkService.queryBossAndPartnerAdminToSendRenewRemindSMS(partnerInfo.getCreatedUserId(), partnerInfo.getId(), expireDay); //循环给boss人员推送通知 if(bossUserIds.size() > 0) { String massageContent = "尊敬的新农宝客户，您的系统有效期仅剩" + expireDay + "天，请联系交付经理或拨打新农宝客户热线4000-456-115及时续费。"; for(String receiverId : bossUserIds) { try { messageService.sendMessage("续费通知", "", "", massageContent, Messages.TYPE_NOTIFY, null, null, partnerInfo.getId(), receiverId, Const.SYSTEM_ROLE_BOSS, partnerInfo.getCreatedUserId(), null, null, null, null); } catch (Exception e) { e.printStackTrace(); } } } } catch (Exception e) { e.printStackTrace(); } } } System.out.println("查询续费快到期的合作伙伴公司任务处理结束"); } catch (Exception e) { e.printStackTrace(); } } /** * 定时查询积分清零需要发送短信的任务（每天16点执行）<br/> * * @author 王辉 * @date: 2017年11月23日 下午5:40:20 <br/> * @since */ @Scheduled(cron = "0 0 16 * * ?") @RequestMapping(value="/executeBonusResetSendMsgTask.do", produces="application/json;charset=UTF-8") public void executeBonusResetSendMsgTask() { try { System.out.println("查询清零发送短信任务"); List<BonusResetTask> tasks = bonusAccountService.queryNeedBonusResetSendMsgTasks(new Date()); if(CollectionUtils.isNotEmpty(tasks)) { for(BonusResetTask task : tasks) { try { System.out.println("执行清零发送短信任务"); bonusAccountService.executeBonusResetSendMsgTask(task.getId()); } catch (Exception e) { e.printStackTrace(); continue; } } } } catch (Exception e) { e.printStackTrace(); } } @Scheduled(cron = "0 0/1 * * * ?") @RequestMapping(value="/sendCustomMessage.do", produces="application/json;charset=UTF-8") public void sendCustomMessage() { try { Date now = new Date(); //log.info("执行发送自定义消息 ==== 开始 ---- {}", DateUtil.convertDateToString(now)); messageService.sendCustomMessage(null, now)