diff --git a/app/endpoints/pipeline_endpoint.py b/app/endpoints/pipeline_endpoint.py index e59b22a..ce71e9f 100644 --- a/app/endpoints/pipeline_endpoint.py +++ b/app/endpoints/pipeline_endpoint.py @@ -891,15 +891,21 @@ async def handle_image_group_async(request: Request,token_id,app_id, wxid,msg_da msg_content=msg_data["Content"]["string"] callback_to_user=msg_data["FromUserName"]["string"] - aeskey = re.search(r'aeskey="([^"]+)"', msg_content).group(1) - cdnthumburl = re.search(r'cdnthumburl="([^"]+)"', msg_content).group(1) - md5 = re.search(r'md5="([^"]+)"', msg_content).group(1) - cdnthumblength = re.search(r'cdnthumblength="([^"]+)"', msg_content).group(1) - cdnthumbheight = re.search(r'cdnthumbheight="([^"]+)"', msg_content).group(1) - cdnthumbwidth = re.search(r'cdnthumbwidth="([^"]+)"', msg_content).group(1) - length = re.search(r'length="([^"]+)"', msg_content).group(1) - - img_xml=f'\n\n\t\n\t\n\t\n' + # aeskey = re.search(r'aeskey="([^"]+)"', msg_content).group(1) + # cdnthumburl = re.search(r'cdnthumburl="([^"]+)"', msg_content).group(1) + # md5 = re.search(r'md5="([^"]+)"', msg_content).group(1) + # cdnthumblength = re.search(r'cdnthumblength="([^"]+)"', msg_content).group(1) + # cdnthumbheight = re.search(r'cdnthumbheight="([^"]+)"', msg_content).group(1) + # cdnthumbwidth = re.search(r'cdnthumbwidth="([^"]+)"', msg_content).group(1) + # length = re.search(r'length="([^"]+)"', msg_content).group(1) + + # img_xml=f'\n\n\t\n\t\n\t\n' + xml_match = re.search(r'<\?xml.*', msg_content, re.DOTALL) + if not xml_match: + logger.info(f'找不到图片地址') + return + img_xml=xml_match.group(0) + wx_img_url= await request.app.state.gewe_service.download_image_msg_async(token_id,app_id,img_xml) if not wx_img_url: logger.warning(f'{wxid} 下载 {callback_to_user} 图片失败')