TaskWeeklyRemindingJob.java
4.94 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
108
109
110
111
112
113
114
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.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.biz.TaskManager;
import com.xiniunet.task.biz.TaskManagerImpl;
import com.xiniunet.task.dal.TaskMapper;
import com.xiniunet.task.dal.TaskUserMapper;
import com.xiniunet.task.domain.Task;
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 com.xiniunet.task.response.TaskGetResponse;
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 TaskWeeklyRemindingJob extends XNQuartzJob {
private Logger logger = LoggerFactory.getLogger(this.getClass());
public TaskWeeklyRemindingJob()
{
this.setJobTag("TaskWeeklyRemindingJob");
}
@Autowired
private TaskUserMapper taskUserMapper;
@Autowired
private TaskMapper taskMapper;
@Autowired
private FoundationService foundationService;
/**
* 每周几定时检查提醒调度器
* @param jobExecutionContext
* @throws JobExecutionException
*/
@Override
public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
taskUserMapper = SpringContext.getApplicationContext().getBean(TaskUserMapper.class);
foundationService = SpringContext.getApplicationContext().getBean(FoundationService.class);
taskMapper = SpringContext.getApplicationContext().getBean(TaskMapper.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()){
List<Long> receiptIds = new ArrayList<>();
//查找执行者和抄送者
TaskUserFindRequest taskUserFindRequest = new TaskUserFindRequest();
taskUserFindRequest.setTaskId(task.getId());
List<TaskUserPO> taskPOList = taskUserMapper.find(taskUserFindRequest,passport);
if(CollectionUtils.isNotEmpty(taskPOList)){
for(TaskUserPO taskUserPO: taskPOList){
//只有开启时间提醒的才会推送消息提醒
// if(taskUserPO.getIsTimeAlarm() != null && taskUserPO.getIsTimeAlarm()){
receiptIds.add(taskUserPO.getUserId());
// }
}
}
if(CollectionUtils.isNotEmpty(receiptIds)){
String url = "xntalk://rnapp.open/kpiTarget?page=TargetDetail&tenantId=" + passport.getTenantId() + "&taskId=" + task.getId() + "&name=" + task.getOwnerUserName();
MessageBatchCreateRequest messageBatchCreateRequest = new MessageBatchCreateRequest();
messageBatchCreateRequest.setBusinessId(task.getId());
messageBatchCreateRequest.setBusinessType(BusinessTypeEnum.TASK.toString());
messageBatchCreateRequest.setReceiptIds(receiptIds);
messageBatchCreateRequest.setMessageTitle("任务进度到时提醒");
messageBatchCreateRequest.setMessageContent(task.getObjectName()+"任务进度提醒");
messageBatchCreateRequest.setMessageMobileUrl(url);
messageBatchCreateRequest.setMessageTime(new Date());
messageBatchCreateRequest.setSendTime(new Date());
messageBatchCreateRequest.setSenderId(10000L);
messageBatchCreateRequest.setSenderName("系统管理员");
foundationService.batchCreateMessage(messageBatchCreateRequest, passport);
}
}
logger.warn("---------任务过期收到消息通知结束：");
return ;
}
}