TaskUserRemindingJob.java
4.48 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
package com.xiniunet.quartz;
import com.alibaba.dubbo.common.utils.CollectionUtils;
import com.alibaba.fastjson.JSON;
import com.xiniunet.foundation.request.MessageBatchCreateRequest;
import com.xiniunet.foundation.request.MessageCreateRequest;
import com.xiniunet.foundation.service.FoundationService;
import com.xiniunet.framework.security.Passport;
import com.xiniunet.framework.util.SpringContext;
import com.xiniunet.quartz.base.XNQuartzJob;
import com.xiniunet.quartz.base.XNQuartzJobData;
import com.xiniunet.task.dal.TaskMapper;
import com.xiniunet.task.dal.TaskUserMapper;
import com.xiniunet.task.enumeration.BusinessTypeEnum;
import com.xiniunet.task.po.TaskPO;
import com.xiniunet.task.po.TaskUserPO;
import com.xiniunet.task.request.TaskGetRequest;
import com.xiniunet.task.request.TaskUserFindRequest;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
/**
* Created by YQ on 2018-05-24.
*/
@Component
public class TaskUserRemindingJob extends XNQuartzJob {
private Logger logger = LoggerFactory.getLogger(this.getClass());
public TaskUserRemindingJob()
{
this.setJobTag("TaskUserRemindingJob");
}
@Autowired
private TaskUserMapper taskUserMapper;
@Autowired
private FoundationService foundationService;
@Autowired
private TaskMapper taskMapper;
/**
* 用户任务提醒时间调度器
* @param jobExecutionContext
* @throws JobExecutionException
*/
@Override
public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
if(taskUserMapper==null){
taskUserMapper = SpringContext.getApplicationContext().getBean(TaskUserMapper.class);
}
if(taskMapper == null){
taskMapper = SpringContext.getApplicationContext().getBean(TaskMapper.class);
}
if(foundationService == null){
foundationService = SpringContext.getApplicationContext().getBean(FoundationService.class);
}
//获取传递信息task
String data = jobExecutionContext.getMergedJobDataMap().getString("data");
XNQuartzJobData xnQuartzJobData = JSON.toJavaObject(JSON.parseObject(data), XNQuartzJobData.class);
Passport passport = xnQuartzJobData.getPassport();
TaskGetRequest taskGetRequest = new TaskGetRequest();
taskGetRequest.setId(xnQuartzJobData.getId());
TaskPO task = taskMapper.getById(xnQuartzJobData.getId(), passport);
if(task == null){
logger.warn("---------任务信息不存在");
return;
}
if(task.getIsDone() != null && !task.getIsDone() && task.getIsAbort() !=null && !task.getIsAbort()
&& task.getIsOverdue() != null && !task.getIsOverdue()){
//查找用户任务
TaskUserPO taskUserPO = taskUserMapper.getById(xnQuartzJobData.getUserTaskId(),passport);
if(taskUserPO != null && taskUserPO.getUserId() != null &&
taskUserPO.getIsTimeAlarm() != null && taskUserPO.getIsTimeAlarm()){
String url = "xntalk://rnapp.open/kpiTarget?tenantId=" + passport.getTenantId() + "&taskId=" + task.getId() + "&name=" + task.getOwnerUserName();
MessageCreateRequest messageCreateRequest = new MessageCreateRequest();
messageCreateRequest.setBusinessId(task.getId());
messageCreateRequest.setBusinessType(BusinessTypeEnum.TASK.toString());
messageCreateRequest.setReceiptId(taskUserPO.getUserId());
messageCreateRequest.setMessageTitle("【"+task.getObjectName()+"】任务即将到期");
messageCreateRequest.setMessageContent("【"+task.getObjectName()+"】任务还有"+taskUserPO.getAheadTimeCount()+"分钟到期！");
messageCreateRequest.setMessageMobileUrl(url);
messageCreateRequest.setMessageTime(new Date());
messageCreateRequest.setSendTime(new Date());
messageCreateRequest.setSenderId(10000L);
messageCreateRequest.setSenderName("系统管理员");
foundationService.createMessage(messageCreateRequest, passport);
}
}
logger.warn("---------用户任务提醒时间调度器结束：");
return ;
}
}