|
|
@@ -26,42 +26,55 @@ namespace WingCloudServer.InteractionCenter
|
|
|
public async Task<bool> SyncReceiveSlaveServiceDataAsync(SyncReceiveServiceDataRequest request)
|
|
|
{
|
|
|
|
|
|
- //todo 判断是当前服务器并且是主服务器 则只需要发送oplogs到其他副服务器
|
|
|
+ // //todo 判断是当前服务器并且是主服务器 则只需要发送oplogs到其他副服务器
|
|
|
|
|
|
- var localServerUrl = ConfigurationManager.Host;
|
|
|
- var baseLiveConsultation = JsonConvert.DeserializeObject<BaseLiveConsultationJson>(request.ServiceDataJson);
|
|
|
- // 调用manager
|
|
|
+ // var localServerUrl = ConfigurationManager.Host;
|
|
|
+ // var baseLiveConsultation = JsonConvert.DeserializeObject<BaseLiveConsultationJson>(request.ServiceDataJson);
|
|
|
+ // // 调用manager
|
|
|
|
|
|
- // 判断是否存在其他服务器的用户
|
|
|
- var getLiveRoomByCodeDBRequest = new GetLiveRoomByCodeDBRequest();
|
|
|
- getLiveRoomByCodeDBRequest.LiveRoomCode = baseLiveConsultation.RoomCode;
|
|
|
- var roomDTO = await _liveRoomDBService.GetLiveRoomByCodeAsync(getLiveRoomByCodeDBRequest);
|
|
|
- var users = roomDTO.UserInfos;
|
|
|
- //操作人所在服务器
|
|
|
- var operatorUser = users.FirstOrDefault(x => x.Code == baseLiveConsultation.OperatorCode);
|
|
|
- //连接其他副服务器的用户
|
|
|
- var usersConnectOtherSlave = users.Where(x => x.LoginServerHost != operatorUser.LoginServerHost && x.LoginServerHost != localServerUrl);
|
|
|
- if (usersConnectOtherSlave != null && usersConnectOtherSlave.Count() > 0)
|
|
|
- {
|
|
|
- //获取oplogs
|
|
|
- var getOpLogsByCodesFormMasterRequest = new GetOpLogsByCodesFormMasterRequest();
|
|
|
- getOpLogsByCodesFormMasterRequest.Codes = new List<string> { baseLiveConsultation.ConsultationRecordCode, baseLiveConsultation.RoomCode };
|
|
|
- var oplogs = await _opLogDBService.GetOpLogsByCodesAsync(getOpLogsByCodesFormMasterRequest);
|
|
|
- //通知副服务器
|
|
|
- var otherSlaves = usersConnectOtherSlave.Select(x => x.LoginServerHost).Distinct();
|
|
|
- if (otherSlaves.Count() > 0)
|
|
|
- {
|
|
|
- //动态注册副服务器服务
|
|
|
- var otherSlaveHosts = new List<string>();
|
|
|
- foreach (var item in otherSlaves)
|
|
|
- {
|
|
|
- var slaveHost = item.Replace("http:", "").Replace(".", "").Replace("/", "");
|
|
|
- DynamicSlaveService(request, slaveHost);
|
|
|
- }
|
|
|
+ // // 判断是否存在其他服务器的用户
|
|
|
+ // var getLiveRoomByCodeDBRequest = new GetLiveRoomByCodeDBRequest();
|
|
|
+ // getLiveRoomByCodeDBRequest.LiveRoomCode = baseLiveConsultation.RoomCode;
|
|
|
+ // var roomDTO = await _liveRoomDBService.GetLiveRoomByCodeAsync(getLiveRoomByCodeDBRequest);
|
|
|
+ // var users = roomDTO.UserInfos;
|
|
|
+ // //操作人所在服务器
|
|
|
+ // var operatorUser = users.FirstOrDefault(x => x.Code == baseLiveConsultation.OperatorCode);
|
|
|
+ // //连接其他副服务器的用户
|
|
|
+ // var usersConnectOtherSlave = users.Where(x => x.LoginServerHost != operatorUser.LoginServerHost && x.LoginServerHost != localServerUrl);
|
|
|
+ // if (usersConnectOtherSlave != null && usersConnectOtherSlave.Count() > 0)
|
|
|
+ // {
|
|
|
+ // //获取oplogs
|
|
|
+ // var getOpLogsByCodesFormMasterRequest = new GetOpLogsByCodesFormMasterRequest();
|
|
|
+ // getOpLogsByCodesFormMasterRequest.Codes = new List<string> { baseLiveConsultation.ConsultationRecordCode, baseLiveConsultation.RoomCode };
|
|
|
+ // var oplogs = await _opLogDBService.GetOpLogsByCodesAsync(getOpLogsByCodesFormMasterRequest);
|
|
|
+ // //通知副服务器
|
|
|
+ // var otherSlaves = usersConnectOtherSlave.Select(x => x.LoginServerHost).Distinct();
|
|
|
+ // if (otherSlaves.Count() > 0)
|
|
|
+ // {
|
|
|
+ // //动态注册副服务器服务
|
|
|
+ // var otherSlaveHosts = new List<string>();
|
|
|
+ // foreach (var item in otherSlaves)
|
|
|
+ // {
|
|
|
+ // var slaveHost = item.Replace("http:", "").Replace(".", "").Replace("/", "");
|
|
|
+ // DynamicSlaveService(request, slaveHost);
|
|
|
+ // }
|
|
|
+
|
|
|
+ // }
|
|
|
+ // }
|
|
|
+ // return true;
|
|
|
+
|
|
|
+ //获取oplogs
|
|
|
+
|
|
|
+ //通知副服务器
|
|
|
+
|
|
|
+
|
|
|
+ //动态注册副服务器服务
|
|
|
+ var otherSlaveHosts = new List<string>();
|
|
|
+ var slaveHost = "127001";
|
|
|
+ DynamicSlaveService(request, slaveHost);
|
|
|
|
|
|
- }
|
|
|
- }
|
|
|
return true;
|
|
|
+
|
|
|
}
|
|
|
|
|
|
public void DynamicSlaveService(SyncReceiveServiceDataRequest request, string host)
|
