| | |
|---|
| | | if (totalRecordList.size() < this.recordInfo.getSumNum()) { |
|---|
| | | logger.info("已获取" + totalRecordList.size() + "项录像数据，共" + this.recordInfo.getSumNum() + "项"); |
|---|
| | | } else { |
|---|
| | | logger.info("录像数据已全部获取，共" + this.recordInfo.getSumNum() + "项"); |
|---|
| | | logger.info("录像数据已全部获取，共 {} 项", this.recordInfo.getSumNum()); |
|---|
| | | this.recordInfo.setRecordList(totalRecordList); |
|---|
| | | for (int i = 0; i < cacheKeys.size(); i++) { |
|---|
| | | redis.del(cacheKeys.get(i).toString()); |
|---|
| | |
|---|
| | | // 自然顺序排序, 元素进行升序排列 |
|---|
| | | this.recordInfo.getRecordList().sort(Comparator.naturalOrder()); |
|---|
| | | RequestMessage msg = new RequestMessage(); |
|---|
| | | String deviceId = recordInfo.getDeviceId(); |
|---|
| | | msg.setDeviceId(deviceId); |
|---|
| | | msg.setType(DeferredResultHolder.CALLBACK_CMD_RECORDINFO); |
|---|
| | | msg.setKey(DeferredResultHolder.CALLBACK_CMD_RECORDINFO + recordInfo.getDeviceId() + recordInfo.getChannelId()); |
|---|
| | | msg.setData(recordInfo); |
|---|
| | | deferredResultHolder.invokeResult(msg); |
|---|
| | | deferredResultHolder.invokeAllResult(msg); |
|---|
| | | logger.info("处理完成，返回结果"); |
|---|
| | | MessageRequestProcessor.threadNameList.remove(cacheKey); |
|---|
| | | } |
|---|
