瀏覽代碼

远程控制:设备端同意拒绝控制功能

fly 2 年之前
父節點
當前提交
8794a8a882
共有 1 個文件被更改,包括 20 次插入14 次删除
  1. 20 14
      Service/DeviceService.cs

+ 20 - 14
Service/DeviceService.cs

@@ -67,6 +67,7 @@ namespace WingDeviceService.Service
         private int _remoteControlAskTimeoutSec = 0;
         private int _reportStateIntervalSeconds = 0;
         private int _reportStateTimeout = 0;
+        private ILiveConsultationService _liveConsultationService;
 
         /// <summary>
         /// Init service
@@ -84,6 +85,7 @@ namespace WingDeviceService.Service
             _diagnosisModuleService = GetProxy<IDiagnosisModuleDBService>();
             _remedicalService = GetProxy<IRemedicalService>();
             _rtcService = GetProxy<IWingRtcService>();
+            _liveConsultationService = GetProxy<ILiveConsultationService>();
             _heartRateSeconds = ConfigurationManager.GetParammeter<IntParameter>("Device", "HeartRateSeconds").Value;
             _deviceHeartRateManager = new DeviceHeartRateManager(SetOnlineState);
             _webSocketUrl = ConfigurationManager.GetParammeter<StringParameter>("Notification", "WebSocketUrl").Value;
@@ -1365,13 +1367,15 @@ namespace WingDeviceService.Service
             };
             await _notificationService.PostMessageAsync(notificationRequest);
             //更改房间调参状态 
-            var getRoomRequest = new FindRoomByCodeRequest { DeviceCode = deviceCode, UserCode = userCode };
-            var room = await _rtcService.GetLiveRoomByCodeAsync(getRoomRequest);
-            if (room != null && !string.IsNullOrWhiteSpace(room.RoomId))
-            {
-                var changeControllingParameterStateRequest = new SetLiveParamsRequest { UserCode = userCode, RoomId = room.RoomId, IsControllingParameter = false };
-                await _rtcService.ChangeControllingParameterStateAsync(changeControllingParameterStateRequest);
-            }
+            // var getRoomRequest = new FindRoomByCodeRequest { DeviceCode = deviceCode, UserCode = userCode };
+            // var room = await _rtcService.GetLiveRoomByCodeAsync(getRoomRequest);
+            // if (room != null && !string.IsNullOrWhiteSpace(room.RoomId))
+            // {
+            //     var changeControllingParameterStateRequest = new SetLiveParamsRequest { UserCode = userCode, RoomId = room.RoomId, IsControllingParameter = false };
+            //     await _rtcService.ChangeControllingParameterStateAsync(changeControllingParameterStateRequest);
+            // }
+            var roomRequest = new ChangeConsultationControllingStateRequest { DeviceCode = deviceCode, UserCode = userCode, IsControllingParameter = false };
+            await _liveConsultationService.ChangeConsultationControllingStateAsync(roomRequest);
             return true;
         }
 
@@ -1410,13 +1414,15 @@ namespace WingDeviceService.Service
             };
             await _notificationService.PostMessageAsync(notificationRequest);
             //更改房间调参状态 
-            var getRoomRequest = new FindRoomByCodeRequest { DeviceCode = deviceCode, UserCode = userCode };
-            var room = await _rtcService.GetLiveRoomByCodeAsync(getRoomRequest);
-            if (room != null && !string.IsNullOrWhiteSpace(room.RoomId))
-            {
-                var changeControllingParameterStateRequest = new SetLiveParamsRequest { UserCode = userCode, RoomId = room.RoomId, IsControllingParameter = false };
-                await _rtcService.ChangeControllingParameterStateAsync(changeControllingParameterStateRequest);
-            }
+            // var getRoomRequest = new FindRoomByCodeRequest { DeviceCode = deviceCode, UserCode = userCode };
+            // var room = await _rtcService.GetLiveRoomByCodeAsync(getRoomRequest);
+            // if (room != null && !string.IsNullOrWhiteSpace(room.RoomId))
+            // {
+            //     var changeControllingParameterStateRequest = new SetLiveParamsRequest { UserCode = userCode, RoomId = room.RoomId, IsControllingParameter = false };
+            //     await _rtcService.ChangeControllingParameterStateAsync(changeControllingParameterStateRequest);
+            // }
+            var roomRequest = new ChangeConsultationControllingStateRequest { DeviceCode = deviceCode, UserCode = userCode, IsControllingParameter = false };
+            await _liveConsultationService.ChangeConsultationControllingStateAsync(roomRequest);
             return true;
         }
     }