| | |
| | | package com.genersoft.iot.vmp.conf.runner; |
| | | |
| | | import com.genersoft.iot.vmp.common.VideoManagerConstants; |
| | | import com.genersoft.iot.vmp.conf.UserSetup; |
| | | import com.genersoft.iot.vmp.storager.IRedisCatchStorage; |
| | | import com.genersoft.iot.vmp.storager.IVideoManagerStorager; |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | |
| | | @Autowired |
| | | private IRedisCatchStorage redisCatchStorage; |
| | | |
| | | @Autowired |
| | | private UserSetup userSetup; |
| | | |
| | | @Override |
| | | public void run(String... args) throws Exception { |
| | | // 读取redis没有心跳信息的则设置为离线,等收到下次心跳设置为在线 |
| | |
| | | for (String deviceId : onlineForAll) { |
| | | storager.online(deviceId); |
| | | } |
| | | |
| | | // 重置cseq计数 |
| | | redisCatchStorage.resetAllCSEQ(); |
| | | // TODO 查询在线设备那些开启了订阅,为设备开启定时的目录订阅 |
| | | } |
| | | } |