From f559e6a39565f17688e44c9d881c7a8217be116b Mon Sep 17 00:00:00 2001
From: 648540858 <648540858@qq.com>
Date: 星期三, 17 十一月 2021 17:01:59 +0800
Subject: [PATCH] 完善目录订阅

---
 src/main/java/com/genersoft/iot/vmp/gb28181/transmit/SIPProcessorObserver.java |   96 ++++++++++++++++++++++++++++++++++++++---------
 1 files changed, 77 insertions(+), 19 deletions(-)

diff --git a/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/SIPProcessorObserver.java b/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/SIPProcessorObserver.java
index b3175d0..9149be1 100644
--- a/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/SIPProcessorObserver.java
+++ b/src/main/java/com/genersoft/iot/vmp/gb28181/transmit/SIPProcessorObserver.java
@@ -1,14 +1,21 @@
 package com.genersoft.iot.vmp.gb28181.transmit;
 
+import com.genersoft.iot.vmp.gb28181.event.SipSubscribe;
 import com.genersoft.iot.vmp.gb28181.transmit.event.request.ISIPRequestProcessor;
 import com.genersoft.iot.vmp.gb28181.transmit.event.response.ISIPResponseProcessor;
 import com.genersoft.iot.vmp.gb28181.transmit.event.timeout.ITimeoutProcessor;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.scheduling.annotation.Async;
+import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
 import org.springframework.stereotype.Component;
 
 import javax.sip.*;
 import javax.sip.header.CSeqHeader;
+import javax.sip.header.CallIdHeader;
+import javax.sip.message.Response;
 import java.util.Map;
 import java.util.concurrent.ConcurrentHashMap;
 
@@ -18,13 +25,20 @@
  * @date:   2021骞�11鏈�5鏃� 涓嬪崍15锛�32
  */
 @Component
-public class SIPProcessorObserver implements SipListener {
+public class SIPProcessorObserver implements ISIPProcessorObserver {
 
     private final static Logger logger = LoggerFactory.getLogger(SIPProcessorObserver.class);
 
     private static Map<String, ISIPRequestProcessor> requestProcessorMap = new ConcurrentHashMap<>();
     private static Map<String, ISIPResponseProcessor> responseProcessorMap = new ConcurrentHashMap<>();
     private static ITimeoutProcessor timeoutProcessor;
+
+    @Autowired
+    private SipSubscribe sipSubscribe;
+
+    @Autowired
+    @Qualifier(value = "taskExecutor")
+    private ThreadPoolTaskExecutor poolTaskExecutor;
 
     /**
      * 娣诲姞 request璁㈤槄
@@ -58,13 +72,17 @@
      */
     @Override
     public void processRequest(RequestEvent requestEvent) {
-        String method = requestEvent.getRequest().getMethod();
-        ISIPRequestProcessor sipRequestProcessor = requestProcessorMap.get(method);
-        if (sipRequestProcessor == null) {
-            logger.warn("涓嶆敮鎸佹柟娉晎}鐨剅equest", method);
-            return;
-        }
-        requestProcessorMap.get(requestEvent.getRequest().getMethod()).process(requestEvent);
+
+        poolTaskExecutor.execute(() -> {
+            String method = requestEvent.getRequest().getMethod();
+            ISIPRequestProcessor sipRequestProcessor = requestProcessorMap.get(method);
+            if (sipRequestProcessor == null) {
+                logger.warn("涓嶆敮鎸佹柟娉晎}鐨剅equest", method);
+                return;
+            }
+            requestProcessorMap.get(method).process(requestEvent);
+        });
+
     }
 
     /**
@@ -73,14 +91,56 @@
      */
     @Override
     public void processResponse(ResponseEvent responseEvent) {
-        CSeqHeader cseqHeader = (CSeqHeader) responseEvent.getResponse().getHeader(CSeqHeader.NAME);
-        String method = cseqHeader.getMethod();
-        ISIPResponseProcessor sipRequestProcessor = responseProcessorMap.get(method);
-        if (sipRequestProcessor == null) {
-            logger.warn("涓嶆敮鎸佹柟娉晎}鐨剅esponse", method);
-            return;
-        }
-        sipRequestProcessor.process(responseEvent);
+        logger.debug(responseEvent.getResponse().toString());
+//        CSeqHeader cseqHeader = (CSeqHeader) responseEvent.getResponse().getHeader(CSeqHeader.NAME);
+//        String method = cseqHeader.getMethod();
+//        ISIPResponseProcessor sipRequestProcessor = responseProcessorMap.get(method);
+//        if (sipRequestProcessor == null) {
+//            logger.warn("涓嶆敮鎸佹柟娉晎}鐨剅esponse", method);
+//            return;
+//        }
+//        sipRequestProcessor.process(responseEvent);
+
+        poolTaskExecutor.execute(() -> {
+            Response response = responseEvent.getResponse();
+            logger.debug(responseEvent.getResponse().toString());
+            int status = response.getStatusCode();
+            if (((status >= 200) && (status < 300)) || status == 401) { // Success!
+//            ISIPResponseProcessor processor = processorFactory.createResponseProcessor(evt);
+                CSeqHeader cseqHeader = (CSeqHeader) responseEvent.getResponse().getHeader(CSeqHeader.NAME);
+                String method = cseqHeader.getMethod();
+                ISIPResponseProcessor sipRequestProcessor = responseProcessorMap.get(method);
+                if (sipRequestProcessor != null) {
+                    sipRequestProcessor.process(responseEvent);
+                }
+                if (responseEvent.getResponse() != null && sipSubscribe.getOkSubscribesSize() > 0 ) {
+                    CallIdHeader callIdHeader = (CallIdHeader)responseEvent.getResponse().getHeader(CallIdHeader.NAME);
+                    if (callIdHeader != null) {
+                        SipSubscribe.Event subscribe = sipSubscribe.getOkSubscribe(callIdHeader.getCallId());
+                        if (subscribe != null) {
+                            SipSubscribe.EventResult eventResult = new SipSubscribe.EventResult(responseEvent);
+                            subscribe.response(eventResult);
+                        }
+                    }
+                }
+            } else if ((status >= 100) && (status < 200)) {
+                // 澧炲姞鍏跺畠鏃犻渶鍥炲鐨勫搷搴旓紝濡�101銆�180绛�
+            } else {
+                logger.warn("鎺ユ敹鍒板け璐ョ殑response鍝嶅簲锛乻tatus锛�" + status + ",message:" + response.getReasonPhrase()/* .getContent().toString()*/);
+                if (responseEvent.getResponse() != null && sipSubscribe.getErrorSubscribesSize() > 0 ) {
+                    CallIdHeader callIdHeader = (CallIdHeader)responseEvent.getResponse().getHeader(CallIdHeader.NAME);
+                    if (callIdHeader != null) {
+                        SipSubscribe.Event subscribe = sipSubscribe.getErrorSubscribe(callIdHeader.getCallId());
+                        if (subscribe != null) {
+                            SipSubscribe.EventResult eventResult = new SipSubscribe.EventResult(responseEvent);
+                            subscribe.response(eventResult);
+                        }
+                    }
+                }
+            }
+        });
+
+
     }
 
     /**
@@ -96,17 +156,15 @@
 
     @Override
     public void processIOException(IOExceptionEvent exceptionEvent) {
-
     }
 
     @Override
     public void processTransactionTerminated(TransactionTerminatedEvent transactionTerminatedEvent) {
-
     }
 
     @Override
     public void processDialogTerminated(DialogTerminatedEvent dialogTerminatedEvent) {
-
+        CallIdHeader callId = dialogTerminatedEvent.getDialog().getCallId();
     }
 
 

--
Gitblit v1.8.0