injectlib/LangBot
1
0
Fork 0
mirror of https://github.com/langbot-app/LangBot.git synced 2025-11-25 03:15:06 +08:00
Code Issues Packages Projects Releases Wiki Activity

Fix wecom image message send fail issue (#1789)

Browse Source 
* Fix wecom image upload issue

* Fix log
This commit is contained in:
Duke
2025-11-18 16:02:13 +08:00
committed by GitHub
parent d91d98c9d4
commit 8a42daa63f
1 changed files with 6 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
src/langbot/libs/wecom_api/api.py
View File

@@ -109,14 +109,13 @@ class WecomClient:
async def send_image(self, user_id: str, agent_id: int, media_id: str): async def send_image(self, user_id: str, agent_id: int, media_id: str):
if not await self.check_access_token(): if not await self.check_access_token():
self.access_token = await self.get_access_token(self.secret) self.access_token = await self.get_access_token(self.secret)
url = self.base_url + '/media/upload?access_token=' + self.access_token
url = self.base_url + '/message/send?access_token=' + self.access_token
async with httpx.AsyncClient() as client: async with httpx.AsyncClient() as client:
params = { params = {
'touser': user_id, 'touser': user_id,
'toparty': '',
'totag': '',
'agentid': agent_id,
'msgtype': 'image', 'msgtype': 'image',
'agentid': agent_id,
'image': { 'image': {
'media_id': media_id, 'media_id': media_id,
}, },
@@ -125,19 +124,13 @@ class WecomClient:
'enable_duplicate_check': 0, 'enable_duplicate_check': 0,
'duplicate_check_interval': 1800, 'duplicate_check_interval': 1800,
} }
try: response = await client.post(url, json=params)
response = await client.post(url, json=params) data = response.json()
data = response.json()
except Exception as e:
await self.logger.error(f'发送图片失败:{data}')
raise Exception('Failed to send image: ' + str(e))
# 企业微信错误码40014和42001，代表accesstoken问题
if data['errcode'] == 40014 or data['errcode'] == 42001: if data['errcode'] == 40014 or data['errcode'] == 42001:
self.access_token = await self.get_access_token(self.secret) self.access_token = await self.get_access_token(self.secret)
return await self.send_image(user_id, agent_id, media_id) return await self.send_image(user_id, agent_id, media_id)
if data['errcode'] != 0: if data['errcode'] != 0:
await self.logger.error(f'发送图片失败:{data}')
raise Exception('Failed to send image: ' + str(data)) raise Exception('Failed to send image: ' + str(data))
async def send_private_msg(self, user_id: str, agent_id: int, content: str): async def send_private_msg(self, user_id: str, agent_id: int, content: str):