feat:查询已预订会议提交

yj_room_agent/graph/room_meeting_graph_agent.py

@@ -170,18 +170,11 @@ def cancel_meeting_node(state: RoomChatAgentState) -> dict:
 # 查询已预订会议，需要判断历史消息或者用户输入，查询已预订会议，返回结果
 def query_meeting_node(state: RoomChatAgentState) -> dict:
     logger.info(f"user:{state.get('user_id', '1')} ---------------进入 query_meeting_node(查询已预订会议) 节点-")
+    param = state.get('params', {})
     # 示例数据,后面替换用友查询接口数据
-    example_data = {
-        'meeting_list': [
-            {'meeting_id': '12345',
-             'meeting_room': '成都527',
-             'meeting_time': '2025-11-17 10:00:00',
-             'meeting_duration': '30分钟',
-             'meeting_users': ['张三', '王华']
-             }
-        ]
-    }
-    return {'query_meeting_data': example_data, 'last_node': 'query_meeting'}
+    meeting_room=getinfo.query_meetingbooking_info(param)
+    result = params_filter.filter_state(meeting_room)
+    return {'query_meeting_data': result, 'last_node': 'query_meeting'}
 
 
 # 结果汇总节点，根据上一个节点的返回结果，生成结果汇总模板，返回结果，结束会话

yj_room_agent/tools/getinfo.py

@@ -270,6 +270,8 @@ def query_meetingbooking_info(params: dict):
     logger.info("request url => {0}".format(request_url))
     if not params.get("pageSize",None):
         params['pageSize'] = page_size
+    ac=get_access_token(tenant_id)
+    params['access_token'] = ac
     logger.info("now page size => {0}".format(params['pageSize']))
     logger.debug("query_meetingbooking_info params => {0}".format(params))
     respones = requests.get(url=request_url, params=params,

yj_room_agent/tools/params_filter.py

@@ -35,7 +35,7 @@ def filter_params(data, endpoint_name):
 '''
 def filter_state(content: dict):
     filtered_data = []
-    for room in content['data']:
+    for room in content.get('data',[]):
         filtered_meetings = [meeting for meeting in room['meetingDTOList'] if meeting['state'] in [0, 1]]
 
         if filtered_meetings:  # 只保留有会议的会议室