EventUrgeTask.java
7.3 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
141
142
143
144
145
package com.xiniunet.service.railway.util.thread;
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() {
try {
if (event == null) {
log.error("事件为空：event=null");
return;
}
String description = event.getDescription();
Map<String, String> params = new HashMap<>(8);
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_name", event.getLineName());
params.put("event_description", description == null ? "" : description.length() > 10 ? description.substring(0, 10) + "... " : description);
params.put("carriage_number", event.getCarriageNumber());
params.put("timeout_minutes", timeoutMinutes + "");
List<SmsSendRequest> smsList = new ArrayList<>();
String function = "";
if (event.getStation() != null && event.getLineName() != null) {
function = "shmetro.station.event.hotline.deal";
// 按车站发消息
List<NoticePersonPO> persons = noticePersonMapper.queryPersonByStation("line", event.getLineId(), event.getLineName(), "station", event.getStationId(), event.getStation());
for (NoticePersonPO person : persons) {
SmsSendRequest smsSendRequest = new SmsSendRequest();
// shmetro.station.event.deal 您负责的${station_name}车站，有用户于${event_time}上报了编号为${event_number}的${event_titile}事件:${event_description}，请尽快处理。
smsSendRequest.setTenantId(RAILWAY_TENANT_ID);
smsSendRequest.setFunction("shmetro.station.event.urge.deal");
smsSendRequest.setParam(JSON.toJSONString(params));
smsSendRequest.setMobile(person.getUserMobile());
smsSendRequest.setProvider(SmsTemplateProviderEnum.ALIYUN.name());
smsSendRequest.setBusinessId(event.getId());
smsSendRequest.setBusinessType(person.getType());
smsList.add(smsSendRequest);
}
} else if (event.getStation() == null && event.getLineName() != null) {
function = "shmetro.carriage.event.hotline.deal";
// 按线路发消息
List<NoticePersonPO> persons = noticePersonMapper.queryPersonByLine( "line", event.getLineId(), event.getLineName());
for (NoticePersonPO person : persons) {
SmsSendRequest smsSendRequest = new SmsSendRequest();
// shmetro.carriage.event.deal 您负责的${line_name}-${carriage_number}车厢，有用户于${event_time}上报了编号为${event_number}的${event_titile}事件:${event_description}，请尽快处理。
smsSendRequest.setTenantId(RAILWAY_TENANT_ID);
smsSendRequest.setFunction("shmetro.carriage.event.urge.deal");
smsSendRequest.setParam(JSON.toJSONString(params));
smsSendRequest.setMobile(person.getUserMobile());
smsSendRequest.setProvider(SmsTemplateProviderEnum.ALIYUN.name());
smsSendRequest.setBusinessId(event.getId());
smsSendRequest.setBusinessType(person.getType());
smsList.add(smsSendRequest);
}
}
// 查询热线人员
List<NoticePersonPO> hotlinePersons = noticePersonMapper.queryPersonByHotline();
for (NoticePersonPO person : hotlinePersons) {
SmsSendRequest smsSendRequest = new SmsSendRequest();
// shmetro.carriage.event.deal 您负责的${line_name}-${carriage_number}车厢，有用户于${event_time}上报了编号为${event_number}的${event_titile}事件:${event_description}，请尽快处理。
smsSendRequest.setTenantId(RAILWAY_TENANT_ID);
smsSendRequest.setFunction(function);
smsSendRequest.setParam(JSON.toJSONString(params));
smsSendRequest.setMobile(person.getUserMobile());
smsSendRequest.setProvider(SmsTemplateProviderEnum.ALIYUN.name());
smsSendRequest.setBusinessId(event.getId());
smsSendRequest.setBusinessType(person.getType());
smsList.add(smsSendRequest);
}
if (smsList.isEmpty()) {
return;
}
SmsSendResponse smsSendResponse = SendSmsUtils.send(smsList);
log.info("eventId-----------------------{}==smsSendResponse===={}", event.getId(), JSON.toJSONString(smsSendResponse));
} finally {
if (event != null) {
EventExtendGetRequest getRequest = new EventExtendGetRequest();
getRequest.setId(event.getId());
EventExtend extend = eventExtendManager.get(getRequest, passport).getEventExtend();
extend.setIsHurried(true);
extend.setHurryTime(new Date());
EventExtendUpdateRequest updateRequest = new EventExtendUpdateRequest();
updateRequest.setId(extend.getId());
updateRequest.setIsHurried(true);
updateRequest.setHurryTime(new Date());
updateRequest.setIsNoticed(extend.getIsNoticed());
updateRequest.setNoticeTime(extend.getNoticeTime());
updateRequest.setRequestIndex(extend.getRowVersion());
eventExtendManager.update(updateRequest, passport);
}
}
}
}