| | |
|---|
| | | |
|---|
| | | import com.genersoft.iot.vmp.gb28181.bean.RecordInfo; |
|---|
| | | import com.genersoft.iot.vmp.gb28181.bean.RecordItem; |
|---|
| | | import com.genersoft.iot.vmp.gb28181.transmit.event.request.impl.message.response.cmd.RecordInfoMessageHandler; |
|---|
| | | import com.genersoft.iot.vmp.gb28181.transmit.event.request.impl.message.response.cmd.RecordInfoResponseMessageHandler; |
|---|
| | | import com.genersoft.iot.vmp.utils.redis.RedisUtil; |
|---|
| | | import org.slf4j.Logger; |
|---|
| | | |
|---|
| | |
|---|
| | | // 自然顺序排序, 元素进行升序排列 |
|---|
| | | this.recordInfo.getRecordList().sort(Comparator.naturalOrder()); |
|---|
| | | RequestMessage msg = new RequestMessage(); |
|---|
| | | msg.setKey(DeferredResultHolder.CALLBACK_CMD_RECORDINFO + recordInfo.getDeviceId() + recordInfo.getChannelId()); |
|---|
| | | msg.setKey(DeferredResultHolder.CALLBACK_CMD_RECORDINFO + recordInfo.getDeviceId() + recordInfo.getSn()); |
|---|
| | | msg.setData(recordInfo); |
|---|
| | | deferredResultHolder.invokeAllResult(msg); |
|---|
| | | logger.info("处理完成，返回结果"); |
|---|
| | | RecordInfoMessageHandler.threadNameList.remove(cacheKey); |
|---|
| | | RecordInfoResponseMessageHandler.threadNameList.remove(cacheKey); |
|---|
| | | } |
|---|
| | | |
|---|
| | | public void setRedis(RedisUtil redis) { |
|---|
