RabbitMessageHandler.java
3.17 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
package com.bsth.message.handler;
import com.bsth.config.RabbitConfig;
import com.bsth.data.alarm.AlarmCenter;
import com.bsth.data.gpsdata_v2.GpsRealData;
import com.bsth.data.gpsdata_v2.entity.GpsEntity;
import com.bsth.data.passenger_flow.PassengerFlowCenter;
import com.bsth.message.entity.*;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.amqp.rabbit.annotation.RabbitHandler;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
import org.springframework.stereotype.Component;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
/**
* @author Hill
*/
//@Component
//@ConditionalOnProperty("rabbit.use")
public class RabbitMessageHandler {
private final static Logger log = LoggerFactory.getLogger(RabbitMessageHandler.class);
@Autowired
private ObjectMapper mapper;
@Autowired
GpsRealData gpsRealData;
@Autowired
private PassengerFlowCenter passengerFlowCenter;
@RabbitHandler
@RabbitListener(queues = RabbitConfig.QUEUE_ALARM_SCHEDULE)
public void onAlarmScheduleMessage(String message) {
try {
AlarmVo alarmVo = null;
Map<String, Object> data = mapper.readValue(message, mapper.getTypeFactory().constructMapType(HashMap.class, String.class, Object.class));
if ("dsm".equals(data.get("alarmType"))) {
alarmVo = mapper.readValue(message, AlarmDSMVo.class);
} else if ("adas".equals(data.get("alarmType"))) {
alarmVo = mapper.readValue(message, AlarmADASVo.class);
} else if ("over-speed".equals(data.get("alarmType"))) {
alarmVo = mapper.readValue(message, AlarmDSMVo.class);
((AlarmDSMVo)alarmVo).setType(17);
}
if (alarmVo != null) {
if (alarmVo.getVehicleCode() == null) {
log.warn("报警未匹配到车辆,alarmVo: {}", alarmVo);
return;
}
GpsEntity gps = gpsRealData.getByNbbm(alarmVo.getVehicleCode());
if (gps == null || gps.getLineId() == null) {
alarmVo.setLineCode("249231");
log.warn("报警未匹配到线路,alarmVo: {}", alarmVo);
} else {
alarmVo.setLineCode(gps.getLineId());
}
AlarmCenter.put(alarmVo);
}
} catch (Exception e) {
log.error("报警监听异常,message: {}", message, e);
}
}
@RabbitHandler
@RabbitListener(queues = RabbitConfig.QUEUE_PASSENGER_FLOW_SCHEDULE)
public void onPassengerFlowScheduleMessage(String message) {
try {
List<PassengerFlow> passengerFlows = mapper.readValue(message, mapper.getTypeFactory().constructParametricType(List.class, PassengerFlow.class));
passengerFlowCenter.put(passengerFlows);
} catch (Exception e) {
log.error("客流监听异常,message: {}", message, e);
}
}
}