定时任务

src/main/java/com/ssj/SysApp.java

@@ -1,15 +1,19 @@
 package com.ssj;
 
+import org.springframework.amqp.rabbit.annotation.EnableRabbit;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
 import org.springframework.boot.builder.SpringApplicationBuilder;
 import org.springframework.boot.web.servlet.ServletComponentScan;
 import org.springframework.boot.web.support.SpringBootServletInitializer;
 import org.springframework.data.jpa.repository.config.EnableJpaRepositories;
+import org.springframework.scheduling.annotation.EnableScheduling;
 
 @SpringBootApplication(scanBasePackages = {"com.ssj"})
 @EnableJpaRepositories
 @ServletComponentScan
+@EnableRabbit
+@EnableScheduling
 public class SysApp extends SpringBootServletInitializer {
 	
     public static void main(String[] args) {

src/main/java/com/ssj/quartz/web/JobController.java

@@ -39,7 +39,7 @@ public class JobController{
     @PostConstruct
     public void initialize() {
         try {
-            //reStartAllJobs();
+            reStartAllJobs();
             logger.info("INIT SUCCESS");
         } catch (Exception e) {
             logger.info("INIT EXCEPTION : " + e.getMessage());

src/main/java/com/ssj/service/weixin/push/service/impl/PushTemplateServiceImpl.java

@@ -3,13 +3,17 @@ package com.ssj.service.weixin.push.service.impl;
 import com.alibaba.fastjson.JSONObject;
 import com.ssj.bean.weixin.push.domain.PushTemplate;
 import com.ssj.bean.weixin.push.domain.SendTemplateShort;
+import com.ssj.bean.weixin.push.domain.TbWxTemplate;
 import com.ssj.framework.core.common.service.BaseServiceImpl;
 import com.ssj.framework.core.rabbitmq.TopicRabbitConfig;
 import com.ssj.framework.core.rabbitmq.producer.BaseRabbitSend;
+import com.ssj.framework.core.security.manager.TokenManager;
+import com.ssj.framework.weixin.util.NewsUtil;
 import com.ssj.service.weixin.push.service.PushTemplateService;
 import com.ssj.service.weixin.push.service.dao.PushTemplateDao;
 import com.ssj.taskthread.Task;
 import com.ssj.taskthread.ThreadPool;
+import com.ssj.util.WxTemplateCacheUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -18,7 +22,9 @@ import org.springframework.data.repository.PagingAndSortingRepository;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
+import java.util.Calendar;
 import java.util.Date;
+import java.util.List;
 
 
 /** 
@@ -35,14 +41,17 @@ public class PushTemplateServiceImpl  extends BaseServiceImpl<PushTemplate, Stri
 	
     @Autowired
 	private PushTemplateDao dao;
+	@Autowired
+	private TokenManager tokenManager;
  
-
+	@Override
 	public boolean savePushWxTemplate(SendTemplateShort sendTemplateShort) {
 		boolean is=true;
 		ThreadPool.getInstance().addTask(new SyncSaveAndSendPushDBTask(sendTemplateShort,dao));
 		return is;
 	}
 
+	@Override
 	public void saveAndSendPushWxTemplate(SendTemplateShort sendTemplateShort) {
 		ThreadPool.getInstance().addTask(new SyncSaveAndSendPushDBTask(sendTemplateShort,dao));
 	}
@@ -81,14 +90,100 @@ public class PushTemplateServiceImpl  extends BaseServiceImpl<PushTemplate, Stri
 
 	@Override
 	public void pushTemplate() {
+		List<PushTemplate> list =dao.getPushTemplateStat();
+		if(list !=null && list.size()>0){
+			for (PushTemplate pushTemplate : list) {
+				NewsUtil.sendTemplate( tokenManager.getSSJAccessToken(), pushTemplate.getContent());
+				if(pushTemplate.getTotal() == 2){
+					this.delete(pushTemplate);
+				}else{
+					pushTemplate.setTotal(pushTemplate.getTotal()+1);
+					this.save(pushTemplate);
+				}
+			}
+		}
 	}
 
 	@Override
 	public void savePushTemplate(String objectId, String content) {
+		PushTemplate pushTemplate = new PushTemplate();
+		pushTemplate.setContent(content);
+		pushTemplate.setCreateTime(new Date());
+		//pushTemplate.setObjectId(objectId);
+		pushTemplate.setStat(1);
+		pushTemplate.setTotal(0);
+		this.save(pushTemplate);
 	}
 
 	@Override
 	public void pushWxTemplate() {
+		List<PushTemplate> TempList =dao.getPushWxTemplateStat();
+		logger.info("3分钟微信推送任务开始，本次任务推送量为："+TempList.size());
+		int errorNum=0;
+		for (PushTemplate pushTemplate : TempList) {
+			try{
+				//需要重复推送，数据库查出来的cur_total<total，
+				if(pushTemplate.getTotal()>0 && pushTemplate.getSuccessTime()!=null){
+					Calendar lastTime=Calendar.getInstance();
+					lastTime.setTime(pushTemplate.getSuccessTime());
+
+					Calendar curTime=Calendar.getInstance();
+					curTime.setTime(new Date());
+
+					long time=curTime.getTimeInMillis()-lastTime.getTimeInMillis();
+					long minute=(time)/(1000*60);//转化minute
+
+					if(minute<pushTemplate.getInterVal()){//没到时间，下一条
+						continue;
+					}
+				}
+				TbWxTemplate tbWxTemplate= WxTemplateCacheUtils.getTbWxTemplate(pushTemplate.getWxTplSid(),null,null);
+				if(tbWxTemplate==null || StringUtils.isEmpty(tbWxTemplate.getTemplateId())){
+					pushTemplate.setRemark("模板池无法得到微信模板ID...");
+					pushTemplate.setTryTime(pushTemplate.getTryTime()+1);
+					errorNum=errorNum+1;
+				}else if(StringUtils.isEmpty(pushTemplate.getOpenid())){
+					pushTemplate.setRemark("OPENID为空，请注意检查来源代码逻辑...");
+					pushTemplate.setTryTime(pushTemplate.getTryTime()+1);
+					errorNum=errorNum+1;
+				}else{
+					String msg= NewsUtil.WX_TPL_BODY
+							.replace(NewsUtil.TPL_CODE_OPENID, pushTemplate.getOpenid())
+							.replace(NewsUtil.TPL_CODE_TPLID, tbWxTemplate.getTemplateId())
+							.replace(NewsUtil.TPL_CODE_URL, StringUtils.isNotEmpty(pushTemplate.getClickUrl())?pushTemplate.getClickUrl():"")
+							.replace(NewsUtil.TPL_CODE_DATA, pushTemplate.getContent())
+							.replace(NewsUtil.TPL_CODE_TOPCOLOR, StringUtils.isNotEmpty(pushTemplate.getTopColor())?pushTemplate.getTopColor():"");
+					if(StringUtils.isNotEmpty(pushTemplate.getMiniprogram())){
+						msg=msg.replace(NewsUtil.TPL_CODE_MINIPROQRAM_TEXT, NewsUtil.TPL_SUB_MINIPROQRAM_DATA);
+						msg=msg.replace(NewsUtil.MINIPROQRAM_DATA, pushTemplate.getMiniprogram());
+					}else{
+						msg=msg.replace(NewsUtil.TPL_CODE_MINIPROQRAM_TEXT, "");
+					}
+					//再去查询，防止重复推送,定时推送数据锁定一分钟
+					if(StringUtils.isNotEmpty(pushTemplate.getId())){
+						pushTemplate=this.getById(pushTemplate.getId());
+					}
+					if(pushTemplate.getIsSuccess()==0){
+						JSONObject result = NewsUtil.sendTemplate(tokenManager.getSSJAccessToken(), msg);
+						if(result != null && "0".equals(result.getString("errcode"))){
+							pushTemplate.setIsSuccess(1);
+							pushTemplate.setSuccessTime(new Date());
+							pushTemplate.setCurTotal(pushTemplate.getCurTotal()+1);
+							pushTemplate.setRemark("");
+						}else{
+							pushTemplate.setTryTime(pushTemplate.getTryTime()+1);
+							pushTemplate.setRemark("errcode:"+result.getString("errcode"));
+							errorNum=errorNum+1;
+						}
+					}
+				}
+				this.save(pushTemplate);
+			}catch(Exception e){
+				e.printStackTrace();
+				logger.error(pushTemplate.getWxTplSid()+"3分钟微信推送任务结束，推送异常...");
+			}
+		}
+		logger.info("3分钟微信推送任务结束，本次任务推送量为："+TempList.size()+",成功量："+(TempList.size()-errorNum)+"失败量："+errorNum);
 	}
 
 	@Override

src/main/java/com/ssj/task/PushWxTemplateTask.java

@@ -0,0 +1,35 @@
+package com.ssj.task;
+
+import com.ssj.framework.core.util.SystemResourceLocator;
+import com.ssj.service.weixin.push.service.PushTemplateService;
+import org.quartz.DisallowConcurrentExecution;
+import org.quartz.Job;
+import org.quartz.JobExecutionContext;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.stereotype.Component;
+
+
+/** 
+ * @version wuwen  2019年1月23日14:30:57
+ * 短微信模板id推送
+ * 定时任务 3分钟一次
+ * 
+ */
+@DisallowConcurrentExecution
+@Component
+public class PushWxTemplateTask implements Job {
+	
+	private static Logger logger = LoggerFactory.getLogger(PushWxTemplateTask.class);
+
+    @Override
+    public void execute(JobExecutionContext jobExecutionContext) {
+        try {
+            PushTemplateService pushTemplateService = SystemResourceLocator.getBean(PushTemplateService.class);
+            pushTemplateService.pushWxTemplate();
+        } catch (Exception e) {
+            logger.error("PushWxTemplateTask任务失败:" + e.getMessage(), e);
+        }
+    }
+}
+

src/main/java/com/ssj/taskasync/SyncSendMailTask.java

@@ -0,0 +1,55 @@
+package com.ssj.taskasync;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.mail.SimpleMailMessage;
+import org.springframework.mail.javamail.JavaMailSender;
+import org.springframework.scheduling.annotation.Async;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+@Component
+public class SyncSendMailTask {
+	
+	protected Logger logger = LoggerFactory.getLogger(this.getClass());
+	
+	@Autowired
+	private JavaMailSender mailSender;
+	
+	@Value("${spring.mail.username}")
+	private String from;
+
+	/**
+	 * from //发送者列表
+	 * @param // 邮件接受者
+	 * @param subject // 主题
+	 * @param content// 内容
+	 */
+	@Async("taskExecutor")
+	public void run(List<String> tos,String subject,String content) {
+		logger.error("立即Mail发送任务开始---------------");
+		try {
+			SimpleMailMessage message =null;
+			for (String to : tos) {
+				message = new SimpleMailMessage();
+		        message.setFrom(from);
+		        message.setTo(to); 
+		        message.setSubject(subject);
+		        message.setText(content); 
+		        mailSender.send(message);
+			}
+		} catch (Exception e) {
+			e.printStackTrace();
+			logger.info("立即Mail发送任务异常...");
+		}
+		logger.error("立即Mail发送任务结束---------------");
+	}
+
+	
+	
+	
+
+}