增加获取expId的功能

01006-读取消息-chat read.robot

+*** Settings ***
+Resource          flow_zmx.resource
+Resource          res_zmx.resource
+Library           get_expId.py
+
+*** Variables ***
+${path}           /api/chat/read
+
+*** Test Cases ***
+正例-正常读取消息
+    [Tags]    F
+    ${resp}    Get ExpId    http://bitagent.sit.ninetechone.com/${path}    ${sessionId}    ${ex_streamId}    ${token}
+    log    ${resp}
+    Should Contain    ${resp}    EXP_
+
+反例-传入错误的token
+    [Tags]    E
+    create session    URI    ${URL}
+    &{header}    Create Dictionary    Authorization=test666
+    ${params}    Create Dictionary    sessionId=${sessionId}    streamId=${text_streamId}
+    ${resp}    Get On Session    URI    ${PATH}    params=${params}    headers=${header}    expected_status=401
+    Should Be Equal As Integers    ${resp.json()["code"]}    401
+    Should Be Equal As Strings    ${resp.json()["message"]}    无效的access token
+
+反例-传入空白token
+    [Tags]    E
+    create session    URI    ${URL}
+    &{header}    Create Dictionary    Authorization=${EMPTY}
+    ${params}    Create Dictionary    sessionId=${sessionId}    streamId=${text_streamId}
+    ${resp}    Get On Session    URI    ${PATH}    params=${params}    headers=${header}    expected_status=401
+    Should Be Equal As Integers    ${resp.json()["code"]}    401
+    Should Be Equal As Strings    ${resp.json()["message"]}    没有找到认证信息
+
+反例-不传入sessionId参数
+    [Tags]    E
+    create session    URI    ${URL}
+    &{header}    Create Dictionary    Authorization=${token}
+    ${params}    Create Dictionary    streamId=${text_streamId}
+    ${resp}    Get On Session    URI    ${PATH}    params=${params}    headers=${header}    expected_status=200
+    Should Be Equal As Integers    ${resp.json()["code"]}    500
+    Should Be Equal As Strings    ${resp.json()["message"]}    Server busy, please try later
+
+反例-不传入streamId参数
+    [Tags]    E
+    create session    URI    ${URL}
+    &{header}    Create Dictionary    Authorization=${token}
+    ${params}    Create Dictionary    sessionId=${sessionId}
+    ${resp}    Get On Session    URI    ${PATH}    params=${params}    headers=${header}    expected_status=200
+    Should Be Equal As Integers    ${resp.json()["code"]}    500
+    Should Be Equal As Strings    ${resp.json()["message"]}    Server busy, please try later

get_expId.py

+from sseclient import SSEClient
+
+
+def get_expId(url,sessionId,streamId,token):
+    '''
+    url:sse连接地址；
+    sessionId：会话Id
+    streamId：本次对话Id
+    token：凭据
+    '''
+    params = {
+        'sessionId':sessionId,
+        'streamId':streamId,
+        'access_token':token
+    }
+    messages = SSEClient(url=url,params=params)
+    for msg in messages:
+        # 处理每个接收到的消息
+        if 'EXP' in msg.data:
+            # print("Received Message:", msg.data)
+            return msg.data
+            break
+
+# print(get_expId('http://bitagent.sit.ninetechone.com/api/chat/read','CB_05ae462bcf704b5aa990c0db9b3496cb','CB_ec83a379621a4eddb7360fcd7272b1e0','Bearer c1391926-e8ba-46c0-a0d1-c5e3c38503da'))
\ No newline at end of file