EventUrgeTask.java
6.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
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
package com.xiniunet.service.railway.util.thread;
import com.alibaba.dubbo.common.utils.StringUtils;
import com.alibaba.fastjson.JSON;
import com.xiniunet.basic.enumeration.SmsTemplateProviderEnum;
import com.xiniunet.framework.security.Passport;
import com.xiniunet.railway.domain.EventExtend;
import com.xiniunet.railway.request.EventExtendGetRequest;
import com.xiniunet.railway.request.EventExtendUpdateRequest;
import com.xiniunet.service.railway.biz.EventExtendManager;
import com.xiniunet.service.railway.dal.NoticePersonMapper;
import com.xiniunet.service.railway.po.EventPO;
import com.xiniunet.service.railway.po.NoticePersonPO;
import com.xiniunet.service.railway.util.SendSmsUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.util.*;
import static com.xiniunet.service.railway.Constant.RAILWAY_TENANT_ID;
/**
* @author xiang
*/
public class EventUrgeTask implements Runnable {
private final Logger log = LoggerFactory.getLogger(EventUrgeTask.class);
private final NoticePersonMapper noticePersonMapper;
private final EventExtendManager eventExtendManager;
/**事件id*/
private final EventPO event;
private final Passport passport;
private final int timeoutMinutes;
public EventUrgeTask(EventPO event,
NoticePersonMapper noticePersonMapper,
EventExtendManager eventExtendManager,
int timeoutMinutes,
Passport passport) {
this.event = event;
this.eventExtendManager = eventExtendManager;
this.noticePersonMapper = noticePersonMapper;
this.timeoutMinutes = timeoutMinutes;
this.passport = passport;
}
@Override
public void run() {
log.warn("======event_quartz_async---");
try {
if (event == null) {
log.error("事件为空：event=null");
return;
}
log.warn("======event_quartz_async---{}", event.getId());
String description = event.getDescription();
Map<String, String> params = new HashMap<>(7);
params.put("station_name", event.getStation());
params.put("event_time", event.getHappenTime());
params.put("event_number", event.getAppEventId() != null ? event.getAppEventId() : "");
params.put("event_titile", event.getTitle());
params.put("line_carriage", (event.getLineName() + event.getCarriageNumber()).replaceAll("null", ""));
params.put("event_description", description == null ? "" : description.length() > 20 ? description.substring(0, 20) + "... " : description);
params.put("timeout_minutes", timeoutMinutes + "");
List<SmsSendRequest> smsList = new ArrayList<>();
String function = "";
if (!StringUtils.isBlank(event.getStationId()) && !StringUtils.isBlank(event.getLineId())) {
log.warn("======event_quartz_async_by_station---{}", event.getId());
function = "shmetro.station.event.hotline.deal";
// 按车站发消息
List<NoticePersonPO> persons = noticePersonMapper.queryPersonByStation("line", event.getLineId(), "station", event.getStationId());
for (NoticePersonPO person : persons) {
smsList.add(getSmsSendRequest(person, JSON.toJSONString(params), "shmetro.station.event.urge.deal"));
}
} else if (StringUtils.isBlank(event.getStationId()) && !StringUtils.isBlank(event.getLineId())) {
log.warn("======event_quartz_async_by_line---{}", event.getId());
function = "shmetro.carriage.event.hotline.deal";
// 按线路发消息
List<NoticePersonPO> persons = noticePersonMapper.queryPersonByLine("line", event.getLineId());
for (NoticePersonPO person : persons) {
smsList.add(getSmsSendRequest(person, JSON.toJSONString(params), "shmetro.carriage.event.urge.deal"));
}
}
// 查询热线人员
List<NoticePersonPO> hotlinePersons = noticePersonMapper.queryPersonByHotline();
log.warn("======event_quartz_async_by_hotline---{}---热线人员个数：{}", event.getId(), hotlinePersons != null ? hotlinePersons.size() : 0);
if (hotlinePersons != null) {
for (NoticePersonPO person : hotlinePersons) {
smsList.add(getSmsSendRequest(person, JSON.toJSONString(params), function));
}
}
if (smsList.isEmpty()) {
log.warn("======event_quartz_async_empty---{}", event.getId());
return;
}
SmsSendResponse smsSendResponse = SendSmsUtils.send(smsList);
log.info("eventId-----------------------{}==smsSendResponse===={}", event.getId(), JSON.toJSONString(smsSendResponse));
} finally {
if (event != null) {
log.warn("======event_quartz_async_finally---{}", event.getId());
EventExtendGetRequest getRequest = new EventExtendGetRequest();
getRequest.setId(event.getId());
EventExtend extend = eventExtendManager.get(getRequest, passport).getEventExtend();
EventExtendUpdateRequest updateRequest = new EventExtendUpdateRequest();
updateRequest.setId(extend.getId());
updateRequest.setIsHurried(true);
updateRequest.setHurryTime(new Date());
updateRequest.setIsNoticed(extend.getIsNoticed());
updateRequest.setNoticeTime(extend.getNoticeTime());
updateRequest.setRowVersion(extend.getRowVersion());
eventExtendManager.update(updateRequest, passport);
} else {
log.warn("======event_quartz_async_event=null---");
}
}
}
private SmsSendRequest getSmsSendRequest(NoticePersonPO person, String params, String function) {
SmsSendRequest smsSendRequest = new SmsSendRequest();
smsSendRequest.setTenantId(RAILWAY_TENANT_ID);
smsSendRequest.setFunction(function);
smsSendRequest.setParam(params);
smsSendRequest.setMobile(person.getUserMobile());
smsSendRequest.setProvider(SmsTemplateProviderEnum.ALIYUN.name());
smsSendRequest.setBusinessId(event.getId());
smsSendRequest.setBusinessType(person.getType());
smsSendRequest.setSign("平安地铁");
return smsSendRequest;
}
}