补充sql默认用户

64850858

2021-07-26 c3ee8ec4b289fc945e7d65b1a373e0a19760aa2a

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
package com.genersoft.iot.vmp.gb28181.event.online; 
 
import com.genersoft.iot.vmp.conf.SipConfig; 
import com.genersoft.iot.vmp.gb28181.bean.Device; 
import org.slf4j.Logger; 
import org.slf4j.LoggerFactory; 
import org.springframework.beans.factory.annotation.Autowired; 
import org.springframework.context.ApplicationListener; 
import org.springframework.stereotype.Component; 
 
import com.genersoft.iot.vmp.common.VideoManagerConstants; 
import com.genersoft.iot.vmp.storager.IVideoManagerStorager; 
import com.genersoft.iot.vmp.utils.redis.RedisUtil; 
 
import java.text.SimpleDateFormat; 
import java.util.Date; 
 
/** 
 * @Description: 在线事件监听器，监听到离线后，修改设备离在线状态。 设备在线有两个来源： 
 *               1、设备主动注销，发送注销指令，{@link com.genersoft.iot.vmp.gb28181.transmit.request.impl.RegisterRequestProcessor} 
 *               2、设备未知原因离线，心跳超时,{@link com.genersoft.iot.vmp.gb28181.transmit.request.impl.MessageRequestProcessor} 
 * @author: swwheihei 
 * @date: 2020年5月6日 下午1:51:23 
 */ 
@Component 
public class OnlineEventListener implements ApplicationListener<OnlineEvent> { 
     
    private final static Logger logger = LoggerFactory.getLogger(OnlineEventListener.class); 
 
    @Autowired 
    private IVideoManagerStorager storager; 
     
    @Autowired 
    private RedisUtil redis; 
 
    @Autowired 
    private SipConfig sipConfig; 
 
    private SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); 
 
    @Override 
    public void onApplicationEvent(OnlineEvent event) { 
         
        if (logger.isDebugEnabled()) { 
            logger.debug("设备上线事件触发，deviceId：" + event.getDevice().getDeviceId() + ",from:" + event.getFrom()); 
        } 
        Device device = event.getDevice(); 
        String key = VideoManagerConstants.KEEPLIVEKEY_PREFIX + event.getDevice().getDeviceId(); 
 
        switch (event.getFrom()) { 
        // 注册时触发的在线事件，先在redis中增加超时超时监听 
        case VideoManagerConstants.EVENT_ONLINE_REGISTER: 
            // 超时时间 
            redis.set(key, event.getDevice().getDeviceId(), sipConfig.getKeepaliveTimeOut()); 
            device.setRegisterTime(format.format(new Date(System.currentTimeMillis()))); 
            break; 
        // 设备主动发送心跳触发的在线事件 
        case VideoManagerConstants.EVENT_ONLINE_KEEPLIVE: 
            boolean exist = redis.hasKey(key); 
            // 先判断是否还存在，当设备先心跳超时后又发送心跳时，redis没有监听，需要增加 
            if (!exist) { 
                redis.set(key, event.getDevice().getDeviceId(), sipConfig.getKeepaliveTimeOut()); 
            } else { 
                redis.expire(key, sipConfig.getKeepaliveTimeOut()); 
            } 
            device.setKeepaliveTime(format.format(new Date(System.currentTimeMillis()))); 
            break; 
        // 设备主动发送消息触发的在线事件 
        case VideoManagerConstants.EVENT_ONLINE_MESSAGE: 
 
            break; 
        } 
 
        device.setOnline(1); 
        // 处理上线监听 
        storager.updateDevice(device); 
    } 
}