content: package org.jeecg.modules.message.job;
  
  import java.util.List;
  
  import org.jeecg.common.util.DateUtils;
  import org.jeecg.modules.message.entity.SysMessage;
  import org.jeecg.modules.message.handle.ISendMsgHandle;
  import org.jeecg.modules.message.handle.enums.SendMsgStatusEnum;
  import org.jeecg.modules.message.handle.enums.SendMsgTypeEnum;
  import org.jeecg.modules.message.service.ISysMessageService;
  import org.quartz.Job;
  import org.quartz.JobExecutionContext;
  import org.quartz.JobExecutionException;
  import org.springframework.beans.factory.annotation.Autowired;
  
  import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
  
  import lombok.extern.slf4j.Slf4j;
  
  /**
   * 发送消息任务
   */
  
  @Slf4j
  public class SendMsgJob implements Job {
  
  	@Autowired
  	private ISysMessageService sysMessageService;
  
  	@Override
  	public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
  
  		log.info(String.format(" Jeecg-Boot 发送消息任务 SendMsgJob !  时间:" + DateUtils.getTimestamp()));
  
  		// 1.读取消息中心数据，只查询未发送的和发送失败不超过次数的
  		QueryWrapper<SysMessage> queryWrapper = new QueryWrapper<SysMessage>();
  		queryWrapper.eq("es_send_status", SendMsgStatusEnum.WAIT.getCode())
  				.or(i -> i.eq("es_send_status", SendMsgStatusEnum.FAIL.getCode()).lt("es_send_num", 6));
  		List<SysMessage> sysMessages = sysMessageService.list(queryWrapper);
  		System.out.println(sysMessages);
  		// 2.根据不同的类型走不通的发送实现类
  		for (SysMessage sysMessage : sysMessages) {
  			ISendMsgHandle sendMsgHandle = null;
  			try {
  				if (sysMessage.getEsType().equals(SendMsgTypeEnum.EMAIL.getType())) {
  					sendMsgHandle = (ISendMsgHandle) Class.forName(SendMsgTypeEnum.EMAIL.getImplClass()).newInstance();
  				} else if (sysMessage.getEsType().equals(SendMsgTypeEnum.SMS.getType())) {
  					sendMsgHandle = (ISendMsgHandle) Class.forName(SendMsgTypeEnum.SMS.getImplClass()).newInstance();
  				} else if (sysMessage.getEsType().equals(SendMsgTypeEnum.WX.getType())) {
  					sendMsgHandle = (ISendMsgHandle) Class.forName(SendMsgTypeEnum.WX.getImplClass()).newInstance();
  				}
  			} catch (Exception e) {
  				log.error(e.getMessage(),e);
  			}
  			Integer sendNum = sysMessage.getEsSendNum();
  			try {
  				sendMsgHandle.SendMsg(sysMessage.getEsReceiver(), sysMessage.getEsTitle(),
  						sysMessage.getEsContent().toString());
  				// 发送消息成功
  				sysMessage.setEsSendStatus(SendMsgStatusEnum.SUCCESS.getCode());
  			} catch (Exception e) {
  				e.printStackTrace();
  				// 发送消息出现异常
  				sysMessage.setEsSendStatus(SendMsgStatusEnum.FAIL.getCode());
  			}
  			sysMessage.setEsSendNum(++sendNum);
  			// 发送结果回写到数据库
  			sysMessageService.updateById(sysMessage);
  		}
  
  	}
  
  }
  