处理图片下载流程

utils/wechat/message_to_db.py

@@ -137,27 +137,27 @@ class MessageStorage:
                 # 解析JSON
                 if json and json.get('data') and json['data'].get('fileUrl'):
                     file_url = json['data']['fileUrl']
-                if file_url:
-                    logger.info(f"记录gewe服务端图片路径成功: {msg.msg_id} -> {file_url}")
-                    # 后续如果需要使用，则去服务器端提取图片
-                    # 直接使用下载后的路径更新数据库
-                    self.message_db.update_message_image_path(msg.msg_id, file_url)
+                    if file_url:
+                        logger.info(f"记录gewe服务端图片路径成功: {msg.msg_id} -> {file_url}")
+                        # 后续如果需要使用，则去服务器端提取图片
+                        # 直接使用下载后的路径更新数据库
+                        self.message_db.update_message_image_path(msg.msg_id, file_url)
 
-                    return {
-                        'success': True,
-                        'message_id': msg.msg_id,
-                        'roomid': msg.roomid,
-                        'sender': msg.sender,
-                        'file_path': file_url
-                    }
-                else:
-                    return {
-                        'success': False,
-                        'message_id': msg.msg_id,
-                        'roomid': msg.roomid,
-                        'sender': msg.sender,
-                        'error': "图片下载失败"
-                    }
+                        return {
+                            'success': True,
+                            'message_id': msg.msg_id,
+                            'roomid': msg.roomid,
+                            'sender': msg.sender,
+                            'file_path': file_url
+                        }
+                    else:
+                        return {
+                            'success': False,
+                            'message_id': msg.msg_id,
+                            'roomid': msg.roomid,
+                            'sender': msg.sender,
+                            'error': "图片下载失败"
+                        }
             else:
                 return {
                     'success': False,