搭配zgyw，实现gb28181
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
648540858
2022-09-08 394c40d8bb29b8e40fc7978ea638f1592b03d617 
 src/main/java/com/genersoft/iot/vmp/gb28181/transmit/event/request/impl/message/response/cmd/RecordInfoResponseMessageHandler.java


@@ -19,6 +19,7 @@


import org.springframework.beans.factory.annotation.Qualifier;


import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;


import org.springframework.stereotype.Component;


import org.springframework.util.ObjectUtils;


import org.springframework.util.StringUtils;




import javax.sip.InvalidArgumentException;


@@ -39,7 +40,7 @@


@Component


public class RecordInfoResponseMessageHandler extends SIPRequestProcessorParent implements InitializingBean, IMessageHandler {




    private Logger logger = LoggerFactory.getLogger(RecordInfoResponseMessageHandler.class);


    private final Logger logger = LoggerFactory.getLogger(RecordInfoResponseMessageHandler.class);


    private final String cmdType = "RecordInfo";




    private ConcurrentLinkedQueue<HandlerCatchData> taskQueue = new ConcurrentLinkedQueue<>();


@@ -93,7 +94,7 @@


                            recordInfo.setName(getText(rootElementForCharset, "Name"));


                            String sumNumStr = getText(rootElementForCharset, "SumNum");


                            int sumNum = 0;


                            if (!StringUtils.isEmpty(sumNumStr)) {


                            if (!ObjectUtils.isEmpty(sumNumStr)) {


                                sumNum = Integer.parseInt(sumNumStr);


                            }


                            recordInfo.setSumNum(sumNum);


@@ -172,16 +173,12 @@




    public void releaseRequest(String deviceId, String sn){


        String key = DeferredResultHolder.CALLBACK_CMD_RECORDINFO + deviceId + sn;


        WVPResult<RecordInfo> wvpResult = new WVPResult<>();


        wvpResult.setCode(0);


        wvpResult.setMsg("success");


        // 对数据进行排序


        Collections.sort(recordDataCatch.getRecordInfo(deviceId, sn).getRecordList());


        wvpResult.setData(recordDataCatch.getRecordInfo(deviceId, sn));




        RequestMessage msg = new RequestMessage();


        msg.setKey(key);


        msg.setData(wvpResult);


        msg.setData(recordDataCatch.getRecordInfo(deviceId, sn));


        deferredResultHolder.invokeAllResult(msg);


        recordDataCatch.remove(deviceId, sn);


    }