feat(call): 实现通话类型图标区分和RTC频道管理功能

- 根据通话类型显示不同的图标：视频通话显示视频图标，语音通话显示语音图标
- 为通话项添加颜色区分，发送方显示白色，接收方显示橙色
- 新增消费一对一RTC频道响应模型定义
- 实现观众离开时断开RTC频道连接功能
- 优化主播离开时的RTC频道销毁逻辑
- 为语音和视频通话分别显示对应的价格信息

lib/controller/discover/room_controller.dart

@@ -375,7 +375,6 @@ class RoomController extends GetxController with WidgetsBindingObserver {
   }
 
   Future<void> leaveChannel() async {
-    // 如果是主播，先销毁 RTC 频道，然后发送结束直播消息
     if (currentRole == CurrentRole.broadcaster) {
       try {
         // 先调用销毁 RTC 频道 API
@@ -393,6 +392,22 @@ class RoomController extends GetxController with WidgetsBindingObserver {
       } catch (e) {
         print('❌ 销毁 RTC 频道异常: $e');
       }
+    } else if (currentRole == CurrentRole.maleAudience || currentRole == CurrentRole.femaleAudience) {
+      try {
+        // 嘉宾离开时调用断开 RTC 频道连接接口
+        final channelId = RTCManager.instance.currentChannelId;
+        if (channelId != null && channelId.isNotEmpty) {
+          final data = {'channelId': channelId};
+          final response = await _networkService.rtcApi.disconnectRtcChannel(data);
+          if (response.data.isSuccess) {
+            print('✅ [RoomController] 嘉宾已断开 RTC 频道连接，channelId: $channelId');
+          } else {
+            print('⚠️ [RoomController] 断开 RTC 频道连接失败: ${response.data.message}');
+          }
+        }
+      } catch (e) {
+        print('❌ [RoomController] 断开 RTC 频道连接异常: $e');
+      }
     }
 
     isLive.value = false;

lib/controller/message/call_controller.dart

@@ -3,6 +3,7 @@ import 'package:agora_rtc_engine/agora_rtc_engine.dart';
 import 'package:audioplayers/audioplayers.dart';
 import 'package:dating_touchme_app/generated/assets.dart';
 import 'package:dating_touchme_app/model/rtc/chat_audio_product_model.dart';
+import 'package:dating_touchme_app/model/rtc/consume_rtc_channel_response.dart';
 import 'package:dating_touchme_app/model/rtc/rtc_channel_data.dart';
 import 'package:dating_touchme_app/network/network_service.dart';
 import 'package:dating_touchme_app/rtc/rtc_manager.dart';
@@ -117,6 +118,9 @@ class CallController extends GetxController {
   String? _callChannelId;
   int? _callUid;
 
+  // 消费响应数据（用于显示玫瑰剩余数量和每分钟价格）
+  final Rxn<ConsumeRtcChannelResponse> consumeResponse = Rxn<ConsumeRtcChannelResponse>();
+
   @override
   void onInit() {
     super.onInit();
@@ -450,9 +454,6 @@ class CallController extends GetxController {
       // 接收方接听后，立即调用一次消费接口并启动定时器
       // 确保 _callChannelId 已设置
       if (_callChannelId != null && _callChannelId!.isNotEmpty) {
-        Future .delayed(Duration(seconds: 1), () async {
-          await _consumeOneOnOneRtcChannel();
-        });
         _startConsumeTimer();
         print('✅ [CallController] 接收方接听后已启动消费定时器');
       }
@@ -591,6 +592,8 @@ class CallController extends GetxController {
   void _stopConsumeTimer() {
     _consumeTimer?.cancel();
     _consumeTimer = null;
+    // 清空消费响应数据
+    consumeResponse.value = null;
   }
 
   /// 调用消费一对一RTC频道接口
@@ -606,7 +609,28 @@ class CallController extends GetxController {
         'channelId': consumeChannelId,
       });
       if (response.data.isSuccess) {
-        print('✅ [CallController] 已调用消费一对一RTC频道接口，channelId: $consumeChannelId');
+        final consumeData = response.data.data;
+        if (consumeData != null) {
+          // 更新消费响应数据
+          consumeResponse.value = consumeData;
+          
+          print('✅ [CallController] 已调用消费一对一RTC频道接口，channelId: $consumeChannelId, isFree: ${consumeData.isFree}, status: ${consumeData.status}, availableBalance: ${consumeData.availableBalance}, unitSellingBalance: ${consumeData.unitSellingBalance}');
+          
+          // 如果 status == 3，挂断通话
+          if (consumeData.status == 3) {
+            print('⚠️ [CallController] 检测到 status=3，自动挂断通话');
+            await hangUpCall();
+            return;
+          }
+          
+          // 如果是免费通话，停止定时器，不再调用消费接口
+          if (consumeData.isFree) {
+            _stopConsumeTimer();
+            print('✅ [CallController] 检测到免费通话，已停止消费定时器');
+          }
+        } else {
+          print('✅ [CallController] 已调用消费一对一RTC频道接口，channelId: $consumeChannelId');
+        }
       } else {
         print('⚠️ [CallController] 消费一对一RTC频道接口失败: ${response.data.message}');
       }

lib/model/rtc/consume_rtc_channel_response.dart

@@ -0,0 +1,42 @@
+/// 消费一对一RTC频道响应模型
+class ConsumeRtcChannelResponse {
+  final bool isFree;
+  final int status;
+  final int availableBalance;
+  final int unitSellingBalance;
+  final String? code;
+
+  ConsumeRtcChannelResponse({
+    required this.isFree,
+    required this.status,
+    required this.availableBalance,
+    required this.unitSellingBalance,
+    this.code,
+  });
+
+  factory ConsumeRtcChannelResponse.fromJson(Map<String, dynamic> json) {
+    return ConsumeRtcChannelResponse(
+      isFree: json['isFree'] as bool? ?? false,
+      status: json['status'] as int? ?? 0,
+      availableBalance: json['availableBalance'] as int? ?? 0,
+      unitSellingBalance: json['unitSellingBalance'] as int? ?? 0,
+      code: json['code'] as String?,
+    );
+  }
+
+  Map<String, dynamic> toJson() {
+    return {
+      'isFree': isFree,
+      'status': status,
+      'availableBalance': availableBalance,
+      'unitSellingBalance': unitSellingBalance,
+      'code': code,
+    };
+  }
+
+  @override
+  String toString() {
+    return 'ConsumeRtcChannelResponse(isFree: $isFree, status: $status, availableBalance: $availableBalance, unitSellingBalance: $unitSellingBalance, code: $code)';
+  }
+}
+

lib/network/rtc_api.dart

@@ -1,6 +1,7 @@
 import 'package:dating_touchme_app/model/discover/rtc_channel_model.dart';
 import 'package:dating_touchme_app/model/live/gift_product_model.dart';
 import 'package:dating_touchme_app/model/rtc/chat_audio_product_model.dart';
+import 'package:dating_touchme_app/model/rtc/consume_rtc_channel_response.dart';
 import 'package:dating_touchme_app/model/rtc/link_mic_card_model.dart';
 import 'package:dating_touchme_app/model/rtc/rtc_channel_data.dart';
 import 'package:dating_touchme_app/model/rtc/rtc_channel_detail.dart';
@@ -133,7 +134,7 @@ abstract class RtcApi {
 
   /// 消费一对一RTC频道
   @POST(ApiUrls.consumeOneOnOneRtcChannel)
-  Future<HttpResponse<BaseResponse<dynamic>>> consumeOneOnOneRtcChannel(
+  Future<HttpResponse<BaseResponse<ConsumeRtcChannelResponse>>> consumeOneOnOneRtcChannel(
     @Body() Map<String, dynamic> data,
   );
 }

lib/network/rtc_api.g.dart

@@ -750,30 +750,33 @@ class _RtcApi implements RtcApi {
   }
 
   @override
-  Future<HttpResponse<BaseResponse<dynamic>>> consumeOneOnOneRtcChannel(
-    Map<String, dynamic> data,
-  ) async {
+  Future<HttpResponse<BaseResponse<ConsumeRtcChannelResponse>>>
+  consumeOneOnOneRtcChannel(Map<String, dynamic> data) async {
     final _extra = <String, dynamic>{};
     final queryParameters = <String, dynamic>{};
     final _headers = <String, dynamic>{};
     final _data = <String, dynamic>{};
     _data.addAll(data);
-    final _options = _setStreamType<HttpResponse<BaseResponse<dynamic>>>(
-      Options(method: 'POST', headers: _headers, extra: _extra)
-          .compose(
-            _dio.options,
-            'dating-agency-chat-audio/user/consume/one-on-one/rtc-channel',
-            queryParameters: queryParameters,
-            data: _data,
-          )
-          .copyWith(baseUrl: _combineBaseUrls(_dio.options.baseUrl, baseUrl)),
-    );
+    final _options =
+        _setStreamType<HttpResponse<BaseResponse<ConsumeRtcChannelResponse>>>(
+          Options(method: 'POST', headers: _headers, extra: _extra)
+              .compose(
+                _dio.options,
+                'dating-agency-chat-audio/user/consume/one-on-one/rtc-channel',
+                queryParameters: queryParameters,
+                data: _data,
+              )
+              .copyWith(
+                baseUrl: _combineBaseUrls(_dio.options.baseUrl, baseUrl),
+              ),
+        );
     final _result = await _dio.fetch<Map<String, dynamic>>(_options);
-    late BaseResponse<dynamic> _value;
+    late BaseResponse<ConsumeRtcChannelResponse> _value;
     try {
-      _value = BaseResponse<dynamic>.fromJson(
+      _value = BaseResponse<ConsumeRtcChannelResponse>.fromJson(
         _result.data!,
-        (json) => json as dynamic,
+        (json) =>
+            ConsumeRtcChannelResponse.fromJson(json as Map<String, dynamic>),
       );
     } on Object catch (e, s) {
       errorLogger?.logError(e, s, _options);

lib/pages/message/video_call_page.dart

@@ -561,15 +561,45 @@ class _VideoCallPageState extends State<VideoCallPage> {
         bottom: MediaQuery.of(context).size.height * 0.25,
         left: 0,
         right: 0,
-        child: Center(
-          child: Text(
-            isCallConnected ? _formatDuration(duration) : '正在呼叫中',
-            style: TextStyle(
-              color: Colors.white,
-              fontSize: 16.sp,
-              fontWeight: FontWeight.w500,
+        child: Column(
+          children: [
+            Center(
+              child: Text(
+                isCallConnected ? _formatDuration(duration) : '正在呼叫中',
+                style: TextStyle(
+                  color: Colors.white,
+                  fontSize: 16.sp,
+                  fontWeight: FontWeight.w500,
+                ),
+              ),
             ),
-          ),
+            Obx(() {
+              final callSession = _callController.currentCall.value;
+              final consumeData = _callController.consumeResponse.value;
+              
+              // 呼叫中（waitCalling）或免费时不显示
+              final isCalling = callSession?.status == CallStatus.waitCalling;
+              final isFree = consumeData?.isFree == true;
+              
+              if (isCalling || isFree) {
+                return const SizedBox.shrink();
+              }
+              
+              final availableBalance = consumeData?.availableBalance ?? 44;
+              final unitSellingBalance = consumeData?.unitSellingBalance ?? 35;
+              
+              return Center(
+                child: Text(
+                  '玫瑰剩余$availableBalance支($unitSellingBalance玫瑰/分钟)',
+                  style: TextStyle(
+                    color: Colors.white,
+                    fontSize: 16.sp,
+                    fontWeight: FontWeight.w500,
+                  ),
+                ),
+              );
+            })
+          ],
         ),
       );
     });

lib/widget/message/call_item.dart

@@ -136,7 +136,12 @@ class CallItem extends StatelessWidget {
       if (callStatus == CallStatus.rejected) {
         return Assets.imagesRejectCall;
       } else {
-        return Assets.imagesAcceptCall;
+        // 根据通话类型显示不同的图标：视频通话显示视频图标，语音通话显示语音图标
+        if (callType == CallType.video) {
+          return Assets.imagesSendVideoCall;
+        } else {
+          return Assets.imagesSendCall;
+        }
       }
     }
   }
@@ -225,6 +230,7 @@ class CallItem extends StatelessWidget {
                       width: 24.w,
                       height: 24.w,
                       fit: BoxFit.contain,
+                      color: isSentByMe ? Colors.white : Colors.orange,
                     ),
                     SizedBox(width: 8.w),
                     // 状态文本

lib/widget/message/call_type_selection_dialog.dart

@@ -49,7 +49,8 @@ class CallTypeSelectionDialog extends StatelessWidget {
 
   @override
   Widget build(BuildContext context) {
-    String price = _formatPrice(voiceProduct);
+    String voicePrice = _formatPrice(voiceProduct);
+    String videoPrice = _formatPrice(videoProduct);
     return Container(
       decoration: BoxDecoration(
         color: Colors.white,
@@ -72,7 +73,7 @@ class CallTypeSelectionDialog extends StatelessWidget {
               padding: EdgeInsets.symmetric(vertical: 16.w),
               child: Center(
                 child: Text(
-                  price.isNotEmpty ? '语音通话 ($price)' : '语音通话',
+                  voicePrice.isNotEmpty ? '语音通话 ($voicePrice)' : '语音通话',
                   style: TextStyle(
                     fontSize: 16.sp,
                     color: const Color.fromRGBO(51, 51, 51, 1),
@@ -98,7 +99,7 @@ class CallTypeSelectionDialog extends StatelessWidget {
               padding: EdgeInsets.symmetric(vertical: 16.w),
               child: Center(
                 child: Text(
-                  price.isNotEmpty ? '视频通话 ($price)' : '视频通话',
+                  videoPrice.isNotEmpty ? '视频通话 ($videoPrice)' : '视频通话',
                   style: TextStyle(
                     fontSize: 16.sp,
                     color: const Color.fromRGBO(51, 51, 51, 1),