Merge branch 'master' of http://git.12345lm.cn/Bazhong/callcenter

src/CallCenter.Api/Controllers/TestController.cs

@@ -5,11 +5,15 @@ using CallCenter.Calls;
 using CallCenter.Devices;
 using CallCenter.Ivrs;
 using CallCenter.Realtimes;
+using CallCenter.Repository.SqlSugar;
 using CallCenter.Users;
+using Microsoft.AspNetCore.Authorization;
 using Microsoft.AspNetCore.Mvc;
 using Microsoft.Extensions.Options;
 using NewRock.Sdk;
 using NewRock.Sdk.Security;
+using SqlSugar;
+using System.Reactive;
 using XF.Domain.Authentications;
 using XF.Domain.Cache;
 
@@ -29,6 +33,7 @@ namespace CallCenter.Api.Controllers
         private readonly IIvrDomainService _ivrDomainService;
         private readonly ICallCacheManager _callCacheManager;
         private readonly ICallRepository _callRepository;
+        private readonly ISugarUnitOfWork<CallCenterDbContext> _uow;
         //private readonly ITypedCache<List<User>> _cache;
         //private readonly ICacheManager<User> _cache;
 
@@ -46,7 +51,8 @@ namespace CallCenter.Api.Controllers
             IBlacklistDomainService blacklistDomainService,
             IIvrDomainService ivrDomainService,
             ICallCacheManager callCacheManager,
-            ICallRepository callRepository
+            ICallRepository callRepository,
+            ISugarUnitOfWork<CallCenterDbContext> uow
             )
         {
             _logger = logger;
@@ -60,13 +66,22 @@ namespace CallCenter.Api.Controllers
             _ivrDomainService = ivrDomainService;
             _callCacheManager = callCacheManager;
             _callRepository = callRepository;
+            _uow = uow;
         }
-
+        [AllowAnonymous]
         [HttpGet]
         public async Task Test1()
         {
-            var user = User;
-            var uid = _sessionContext.UserId;
+            //var user = User;
+            //var uid = _sessionContext.UserId;
+
+
+            //await _callRepository.GetExtAsync(
+            //    x => x.ConversationId == "2" &&
+            //         x.FromNo == "13408389849" && x.CreationTime >= DateTime.Now.AddHours(-2), x => x.Includes(d => d.CallDetails));
+
+            var list = await _uow.Db.Queryable<Call>().Includes(x => x.CallDetails).Where(x => x.ConversationId == "2" &&
+                     x.FromNo == "13408389849").ToListAsync() ;
             //var user = await _userRepository.GetAsync("08da8016-72af-48b3-8c8f-b39251229f79");
             //_cache.Add(user.Id, user, ExpireMode.None, TimeSpan.FromMinutes(1));
             //var user1 = _cache.Get(user.Id);

src/CallCenter.Api/appsettings.Development.json

@@ -75,7 +75,8 @@
         "RestCategory": "",
         "WorkToGroup": "1",
         "RestToGroup": "1",
-        "EvaluateCategory": "08db1e04-70c8-4419-8d4a-9b7172678ab2"
+        "EvaluateCategory": "08db1e04-70c8-4419-8d4a-9b7172678ab2",
+        "BusyGroup": ""
       },
       {
         //"NumNo": "12345",
@@ -85,11 +86,12 @@
         "AfterBegin": "12:00",
         "AfterEnd": "23:59",
         "WorkDay": [ 1, 2, 3, 4, 5, 6, 0 ],
-        "WorkCategory": "08db2b5d-50b8-4830-83c5-ebe2c3b4364e",
+        "WorkCategory": "",//"08db2b5d-50b8-4830-83c5-ebe2c3b4364e",
         "RestCategory": "",
         "WorkToGroup": "1",
         "RestToGroup": "1",
-        "EvaluateCategory": "08db1e04-70c8-4419-8d4a-9b7172678ab2"
+        "EvaluateCategory": "08db1e04-70c8-4419-8d4a-9b7172678ab2",
+        "BusyGroup": "2"
       },
       {
         "NumNo": "3490",
@@ -102,7 +104,8 @@
         "RestCategory": "",
         "WorkToGroup": "2",
         "RestToGroup": "1",
-        "EvaluateCategory": "08db1e04-70c8-4419-8d4a-9b7172678ab2"
+        "EvaluateCategory": "08db1e04-70c8-4419-8d4a-9b7172678ab2",
+        "BusyGroup": ""
       },
       {
         "NumNo": "12319",
@@ -115,7 +118,8 @@
         "RestCategory": "",
         "WorkToGroup": "1",
         "RestToGroup": "1",
-        "EvaluateCategory": "08db1e04-70c8-4419-8d4a-9b7172678ab2"
+        "EvaluateCategory": "08db1e04-70c8-4419-8d4a-9b7172678ab2",
+        "BusyGroup": ""
       },
       {
         "NumNo": "3497",
@@ -128,7 +132,8 @@
         "RestCategory": "",
         "WorkToGroup": "1",
         "RestToGroup": "1",
-        "EvaluateCategory": "08db1e04-70c8-4419-8d4a-9b7172678ab2"
+        "EvaluateCategory": "08db1e04-70c8-4419-8d4a-9b7172678ab2",
+        "BusyGroup": ""
       },
       {
         "NumNo": "12310",
@@ -141,7 +146,8 @@
         "RestCategory": "",
         "WorkToGroup": "1",
         "RestToGroup": "1",
-        "EvaluateCategory": "08db1e04-70c8-4419-8d4a-9b7172678ab2"
+        "EvaluateCategory": "08db1e04-70c8-4419-8d4a-9b7172678ab2",
+        "BusyGroup": ""
       },
       {
         "NumNo": "12312",
@@ -154,7 +160,8 @@
         "RestCategory": "",
         "WorkToGroup": "1",
         "RestToGroup": "1",
-        "EvaluateCategory": "08db1e04-70c8-4419-8d4a-9b7172678ab2"
+        "EvaluateCategory": "08db1e04-70c8-4419-8d4a-9b7172678ab2",
+        "BusyGroup": ""
       },
       {
         "NumNo": "12313",
@@ -167,7 +174,8 @@
         "RestCategory": "",
         "WorkToGroup": "1",
         "RestToGroup": "1",
-        "EvaluateCategory": "08db1e04-70c8-4419-8d4a-9b7172678ab2"
+        "EvaluateCategory": "08db1e04-70c8-4419-8d4a-9b7172678ab2",
+        "BusyGroup": ""
       },
       {
         "NumNo": "12318",
@@ -180,7 +188,8 @@
         "RestCategory": "",
         "WorkToGroup": "1",
         "RestToGroup": "1",
-        "EvaluateCategory": "08db1e04-70c8-4419-8d4a-9b7172678ab2"
+        "EvaluateCategory": "08db1e04-70c8-4419-8d4a-9b7172678ab2",
+        "BusyGroup": ""
       },
       {
         "NumNo": "12336",
@@ -193,7 +202,8 @@
         "RestCategory": "",
         "WorkToGroup": "1",
         "RestToGroup": "1",
-        "EvaluateCategory": "08db1e04-70c8-4419-8d4a-9b7172678ab2"
+        "EvaluateCategory": "08db1e04-70c8-4419-8d4a-9b7172678ab2",
+        "BusyGroup": ""
       },
       {
         "NumNo": "12338",
@@ -206,7 +216,8 @@
         "RestCategory": "",
         "WorkToGroup": "1",
         "RestToGroup": "1",
-        "EvaluateCategory": "08db1e04-70c8-4419-8d4a-9b7172678ab2"
+        "EvaluateCategory": "08db1e04-70c8-4419-8d4a-9b7172678ab2",
+        "BusyGroup": ""
       },
       {
         "NumNo": "12349",
@@ -219,7 +230,8 @@
         "RestCategory": "",
         "WorkToGroup": "1",
         "RestToGroup": "1",
-        "EvaluateCategory": "08db1e04-70c8-4419-8d4a-9b7172678ab2"
+        "EvaluateCategory": "08db1e04-70c8-4419-8d4a-9b7172678ab2",
+        "BusyGroup": ""
       },
       {
         "NumNo": "12350",
@@ -232,7 +244,8 @@
         "RestCategory": "",
         "WorkToGroup": "1",
         "RestToGroup": "1",
-        "EvaluateCategory": "08db1e04-70c8-4419-8d4a-9b7172678ab2"
+        "EvaluateCategory": "08db1e04-70c8-4419-8d4a-9b7172678ab2",
+        "BusyGroup": ""
       },
       {
         "NumNo": "12351",
@@ -245,7 +258,8 @@
         "RestCategory": "",
         "WorkToGroup": "1",
         "RestToGroup": "1",
-        "EvaluateCategory": "08db1e04-70c8-4419-8d4a-9b7172678ab2"
+        "EvaluateCategory": "08db1e04-70c8-4419-8d4a-9b7172678ab2",
+        "BusyGroup": ""
       },
       {
         "NumNo": "12355",
@@ -258,7 +272,8 @@
         "RestCategory": "",
         "WorkToGroup": "1",
         "RestToGroup": "1",
-        "EvaluateCategory": "08db1e04-70c8-4419-8d4a-9b7172678ab2"
+        "EvaluateCategory": "08db1e04-70c8-4419-8d4a-9b7172678ab2",
+        "BusyGroup": ""
       },
       {
         "NumNo": "12356",
@@ -271,7 +286,8 @@
         "RestCategory": "",
         "WorkToGroup": "1",
         "RestToGroup": "1",
-        "EvaluateCategory": "08db1e04-70c8-4419-8d4a-9b7172678ab2"
+        "EvaluateCategory": "08db1e04-70c8-4419-8d4a-9b7172678ab2",
+        "BusyGroup": ""
       },
       {
         "NumNo": "12363",
@@ -284,7 +300,8 @@
         "RestCategory": "",
         "WorkToGroup": "1",
         "RestToGroup": "1",
-        "EvaluateCategory": "08db1e04-70c8-4419-8d4a-9b7172678ab2"
+        "EvaluateCategory": "08db1e04-70c8-4419-8d4a-9b7172678ab2",
+        "BusyGroup": ""
       },
       {
         "NumNo": "12385",
@@ -297,7 +314,8 @@
         "RestCategory": "",
         "WorkToGroup": "1",
         "RestToGroup": "1",
-        "EvaluateCategory": "08db1e04-70c8-4419-8d4a-9b7172678ab2"
+        "EvaluateCategory": "08db1e04-70c8-4419-8d4a-9b7172678ab2",
+        "BusyGroup": ""
       },
       {
         "NumNo": "96198",
@@ -310,7 +328,8 @@
         "RestCategory": "",
         "WorkToGroup": "1",
         "RestToGroup": "1",
-        "EvaluateCategory": "08db1e04-70c8-4419-8d4a-9b7172678ab2"
+        "EvaluateCategory": "08db1e04-70c8-4419-8d4a-9b7172678ab2",
+        "BusyGroup": ""
       },
       {
         "NumNo": "96960",
@@ -323,7 +342,8 @@
         "RestCategory": "",
         "WorkToGroup": "1",
         "RestToGroup": "1",
-        "EvaluateCategory": "08db1e04-70c8-4419-8d4a-9b7172678ab2"
+        "EvaluateCategory": "08db1e04-70c8-4419-8d4a-9b7172678ab2",
+        "BusyGroup": ""
       }
     ]
   },

src/CallCenter.Application/Handlers/CallState/AlertExtToOuterNotificationHandler.cs

@@ -29,7 +29,7 @@ namespace CallCenter.Application.Handlers
             string telNo = notification.Outer.From != "" ? notification.Outer.From : notification.TelNo;
             if (!string.IsNullOrEmpty(telNo))
             {
-                var model =await _callRepository.GetAsync(x => x.ConversationId==notification.Outer.Id && x.ToNo==notification.Outer.To && x.Trunk==notification.Outer.Trunk && x.CreationTime>=DateTime.Now.AddHours(-2), cancellationToken);
+                var model =await _callRepository.GetAsync(x => x.ConversationId==notification.Outer.Id && x.ToNo==notification.Outer.To && x.CreationTime>=DateTime.Now.AddHours(-2), cancellationToken);
                 var workModel = _userCacheManager.GetWorkByTel(telNo);
                 if (model!=null)
                 {

src/CallCenter.Application/Handlers/CallState/RingExtToOuterNotificationHandler.cs

@@ -51,13 +51,14 @@ namespace CallCenter.Application.Handlers
             else
             {
                 var isp = PhoneIspTool.GetPhoneIsp(notification.Outer.To);
+                string telNo = (string.IsNullOrEmpty(notification.Outer.From) || string.IsNullOrWhiteSpace(notification.Outer.From)) ? notification.TelNo : notification.Outer.From;
                 var callModel = new Call()
                 {
-                    CallStatus = ECallStatus.Alert,
+                    CallStatus = ECallStatus.Ring,
                     CallDirection = ECallDirection.Out,
                     CallType = ECallType.ExtToOuter,
                     ConversationId = notification.Outer.Id,
-                    FromNo = notification.Outer.From,
+                    FromNo = telNo,
                     ToNo = notification.Outer.To,
                     Trunk = notification.Outer.Trunk,
                     PhoneIsp = isp
@@ -68,7 +69,7 @@ namespace CallCenter.Application.Handlers
                 var detail = new CallDetail()
                 {
                     CallId = callId,
-                    CallStatus = ECallStatus.Alert,
+                    CallStatus = ECallStatus.Ring,
                     ConversationId = notification.Outer.Id,
                     OMCallId = notification.Outer.CallId,
                     EventName = notification.Attribute,

src/CallCenter.Application/Handlers/FlowControl/AnsweredVisitorToExtNotificationHandler.cs

@@ -30,9 +30,9 @@ namespace CallCenter.Application.Handlers
 
         public async Task Handle(AnsweredVisitorToExtNotification notification, CancellationToken cancellationToken)
         {
-            var model = await _callRepository.GetAsync(
+            var model = await _callRepository.GetExtAsync(
                 x => x.ConversationId == notification.Visitor.Id &&
-                     x.FromNo == notification.Visitor.From && x.CreationTime >= DateTime.Now.AddHours(-2), cancellationToken);
+                     x.FromNo == notification.Visitor.From && x.CreationTime >= DateTime.Now.AddHours(-2),x=>x.Includes(d=>d.CallDetails));
             if (model != null)
             {
                 model.CallStatus = ECallStatus.Answered;
@@ -58,7 +58,8 @@ namespace CallCenter.Application.Handlers
                 _logger.LogInformation(JsonSerializer.Serialize(_callCacheManager.GetCallQueueList()));
                 await _realtimeService.CallQueueAsync(_callCacheManager.GetCallQueueList(), cancellationToken);
 
-                var callDetail = _callDetailRepository.GetAsync(x => x.CallId == model.Id && x.EventName == "ANSWER");
+                //var callDetail = _callDetailRepository.GetAsync(x => x.CallId == model.Id && x.EventName == "ANSWER" && x.CreationTime >= model.CreationTime);
+                var callDetail = model.CallDetails.Where(x => x.CallId == model.Id && x.EventName == "ANSWER");
                 if (callDetail == null)
                 {
                     //调用业务通知 通知前端

src/CallCenter.Application/Handlers/FlowControl/ByeExtAndOuterOneNotificationHandler.cs

@@ -26,8 +26,7 @@ namespace CallCenter.Application.Handlers
         public async Task Handle(ByeExtAndOuterOneNotification notification, CancellationToken cancellationToken)
         {
             var model = await _callRepository.GetAsync(
-                x => x.ConversationId == notification.Outer.Id && 
-                     x.Trunk==notification.Outer.Trunk && x.ToNo == notification.Outer.To && x.CreationTime>=DateTime.Now.AddHours(-2), cancellationToken);
+                x => x.ConversationId == notification.Outer.Id &&  x.ToNo == notification.Outer.To && x.CreationTime>=DateTime.Now.AddHours(-2), cancellationToken);
             if (model != null)
             {
                 model.CallStatus = ECallStatus.Bye;

src/CallCenter.Application/Handlers/FlowControl/ByeExtAndOuterTwoNotificationHandler.cs

@@ -25,7 +25,7 @@ namespace CallCenter.Application.Handlers
         public async Task Handle(ByeExtAndOuterTwoNotification notification, CancellationToken cancellationToken)
         {
             var model = await _callRepository.GetAsync(
-                x => x.ConversationId == notification.Outer.Id  && x.ToNo == notification.Outer.To && x.Trunk==notification.Outer.Trunk && x.CreationTime>=DateTime.Now.AddHours(-2), cancellationToken);
+                x => x.ConversationId == notification.Outer.Id  && x.ToNo == notification.Outer.To && x.CreationTime>=DateTime.Now.AddHours(-2), cancellationToken);
             if (model != null)
             {
                 model.CallStatus = ECallStatus.Bye;

src/CallCenter.Application/Handlers/FlowControl/IncomingNotificationHandler.cs

@@ -119,7 +119,26 @@ namespace CallCenter.Application.Handlers
                             break;
                         //直接转分机组
                         case ECorrectIvr.Group:
+
+                            //判断12333是否在排队
+#if DEBUG
+                        if(notification.TrunkId == "3496")
+#else
+                        if (notification.TrunkId == "12333")
+#endif
+                        {
+                            int count = _callCacheManager.GetCallQueueListByTrunk(notification.TrunkId);
+                            if (count>=2)
+                            {
+                                if (!string.IsNullOrEmpty(correct.BusyGroup))
+                                {
+                                    correct.ReturnValue = correct.BusyGroup;
+                                }
+                            }
+                        }
+
                             _logger.LogInformation("transfer to group.no:{groupNo}", correct.ReturnValue);
+
                             await _newRockClient.VisitorToGroupQueue(new VisitorToGroupQueueRequest()
                             {
                                 Attribute = "Queue",

src/CallCenter.Application/Handlers/Transient/TransientOuterNotificationHandler.cs

@@ -22,7 +22,7 @@ namespace CallCenter.Application.Handlers
         {
             if (!string.IsNullOrEmpty(notification.Outer.Id))
             {
-                string telNo = notification.Outer.From != "" ? notification.Outer.From : notification.TelNo;
+                string telNo = (string.IsNullOrEmpty(notification.Outer.From) || string.IsNullOrWhiteSpace(notification.Outer.From)) ? notification.TelNo : notification.Outer.From;
                 var workModel = _userCacheManager.GetWorkByTel(telNo);
                 var isp = PhoneIspTool.GetPhoneIsp(notification.Outer.To);
                 var callModel = new Call()

src/CallCenter.NewRock/DeviceManager.cs

@@ -20,6 +20,7 @@ using Group = NewRock.Sdk.Control.Request.Group;
 using CallCenter.Share.Enums;
 using CallCenter.Caches;
 using Microsoft.AspNetCore.Http;
+using CallCenter.Tools;
 
 namespace CallCenter.NewRock
 {
@@ -33,8 +34,9 @@ namespace CallCenter.NewRock
         private readonly IUserCacheManager _userCacheManager;
         private readonly ITelRestRepository _telRestRepository;
         private readonly ITelCacheManager _telCacheManager;
+        private readonly ICallDetailRepository _callDetailRepository;
 
-        public DeviceManager(INewRockClient newRockClient, IOptionsSnapshot<DeviceConfigs> options, IMapper mapper, ICallRepository callRepository, ITelGroupRepository telGroupRepository,IUserCacheManager userCacheManager, ITelRestRepository telRestRepository, ITelCacheManager telCacheManager)
+        public DeviceManager(INewRockClient newRockClient, IOptionsSnapshot<DeviceConfigs> options, IMapper mapper, ICallRepository callRepository, ITelGroupRepository telGroupRepository,IUserCacheManager userCacheManager, ITelRestRepository telRestRepository, ITelCacheManager telCacheManager, ICallDetailRepository callDetailRepository)
         {
             _newRockClient = newRockClient;
             _options = options;
@@ -44,6 +46,7 @@ namespace CallCenter.NewRock
             _userCacheManager = userCacheManager;
             _telRestRepository = telRestRepository;
             _telCacheManager = telCacheManager;
+            _callDetailRepository = callDetailRepository;
         }
 
         #region 查询
@@ -673,7 +676,7 @@ namespace CallCenter.NewRock
         /// <returns></returns>
         public async Task ExtToOuterAsync(string from, string to, CancellationToken cancellationToken, string trunkid = "")
         {
-            await _newRockClient.ExtToOuter(
+             var rsp = await _newRockClient.ExtToOuter(
                     new ExtToOuterRequest()
                     {
                         Attribute = "Connect",
@@ -684,6 +687,37 @@ namespace CallCenter.NewRock
                 _options.Value.ReceiveKey,
                 _options.Value.Expired,
                 cancellationToken);
+            //写入记录
+            string telNo = (string.IsNullOrEmpty(rsp.Outer.From) || string.IsNullOrWhiteSpace(rsp.Outer.From)) ? rsp.Ext.Id : rsp.Outer.From;
+            var workModel = _userCacheManager.GetWorkByTel(telNo);
+            var isp = PhoneIspTool.GetPhoneIsp(rsp.Outer.To);
+            var callModel = new Call()
+            {
+                CallStatus = ECallStatus.ExtOuterReady,
+                CallDirection = ECallDirection.Out,
+                CallType = ECallType.ExtToOuter,
+                ConversationId = rsp.Outer.Id,
+                FromNo = telNo,
+                ToNo = rsp.Outer.To,
+                Trunk = rsp.Outer.Trunk,
+                UserId = workModel.UserId,
+                UserName = workModel.UserName,
+                PhoneIsp = isp
+            };
+            callModel.Modified();
+            var callId = await _callRepository.AddAsync(callModel,cancellationToken);
+            //写入明细
+            var detail = new CallDetail()
+            {
+                CallId = callId,
+                CallStatus = ECallStatus.ExtOuterReady,
+                ConversationId = rsp.Outer.Id,
+                OMCallId = rsp.Outer.CallId,
+                EventName = "ExtOuterReady",//去电
+                FromNo = telNo,
+                ToNo = rsp.Outer.To,
+            };
+            await _callDetailRepository.AddAsync(detail, cancellationToken);
         }
 
         /// <summary>

src/CallCenter/Caches/CallCacheManager.cs

@@ -42,6 +42,10 @@ namespace CallCenter.Caches
             return _cacheCall.GetListByPrefix().Where(x => x.GroupNo == groupNo).Count();
         }
 
+        public int GetCallQueueListByTrunk(string trunk)
+        {
+            return _cacheCall.GetListByPrefix().Where(x => x.TrunkNo == trunk).Count();
+        }
 
 
         public void RemoveCallCache(string id)

src/CallCenter/Caches/ICallCacheManager.cs

@@ -10,6 +10,8 @@ namespace CallCenter.Caches
         int GetCallQueueList(string groupNo);
         void AddCallCache(Call call,string groupNo);
 
+        int GetCallQueueListByTrunk(string trunk);
+
         void RemoveCallCache(string id);
     }
 }

src/CallCenter/Ivrs/IvrDomainService.cs

@@ -315,33 +315,33 @@ public class IvrDomainService : IIvrDomainService, IScopeDependency
     {
         if (isEvaluate)
         {
-            return new CorrectIvr() { eCorrectIvr = ECorrectIvr.Ivr, ReturnValue = settings.EvaluateCategory };
+            return new CorrectIvr() { eCorrectIvr = ECorrectIvr.Ivr, ReturnValue = settings.EvaluateCategory,BusyGroup = settings.BusyGroup };
         }
 
         if (!settings.WorkDay.Contains((int)DateTime.Now.DayOfWeek))
-            return new CorrectIvr() { eCorrectIvr = ECorrectIvr.Group, ReturnValue = settings.RestToGroup };
+            return new CorrectIvr() { eCorrectIvr = ECorrectIvr.Group, ReturnValue = settings.RestToGroup, BusyGroup = settings.BusyGroup };
         var time = TimeOnly.FromDateTime(DateTime.Now);
         if ((time >= TimeOnly.Parse(settings.MorningBegin) && time <= TimeOnly.Parse(settings.MorningEnd))
             || (time >= TimeOnly.Parse(settings.AfterBegin) && time <= TimeOnly.Parse(settings.AfterEnd)))
         {
             if (!string.IsNullOrEmpty(settings.WorkCategory))
             {
-                return new CorrectIvr() { eCorrectIvr = ECorrectIvr.Ivr, ReturnValue = settings.WorkCategory };
+                return new CorrectIvr() { eCorrectIvr = ECorrectIvr.Ivr, ReturnValue = settings.WorkCategory, BusyGroup = settings.BusyGroup };
             }
             else
             {
-                return new CorrectIvr() { eCorrectIvr = ECorrectIvr.Group, ReturnValue = settings.WorkToGroup };
+                return new CorrectIvr() { eCorrectIvr = ECorrectIvr.Group, ReturnValue = settings.WorkToGroup, BusyGroup = settings.BusyGroup };
             }
         }
         else
         {
             if (!string.IsNullOrEmpty(settings.RestCategory))
             {
-                return new CorrectIvr() { eCorrectIvr = ECorrectIvr.Ivr, ReturnValue = settings.RestCategory };
+                return new CorrectIvr() { eCorrectIvr = ECorrectIvr.Ivr, ReturnValue = settings.RestCategory, BusyGroup = settings.BusyGroup };
             }
             else
             {
-                return new CorrectIvr() { eCorrectIvr = ECorrectIvr.Group, ReturnValue = settings.RestToGroup };
+                return new CorrectIvr() { eCorrectIvr = ECorrectIvr.Group, ReturnValue = settings.RestToGroup, BusyGroup = settings.BusyGroup };
             }
         }
     }
@@ -351,6 +351,8 @@ public class IvrDomainService : IIvrDomainService, IScopeDependency
         public string ReturnValue { get; set; }
 
         public ECorrectIvr eCorrectIvr { get; set; }
+
+        public string BusyGroup { get; set; }
     }
 
 

src/CallCenter/Settings/WorkTimeSettings.cs

@@ -59,5 +59,7 @@ namespace CallCenter.Settings
         public string WorkToGroup { get; set; }
         public string RestToGroup { get; set; }
         public string EvaluateCategory { get; set; }
+
+        public string BusyGroup { get; set; }
     }
 }

src/NewRock.Sdk/NewRock.Sdk.csproj

@@ -6,10 +6,6 @@
     <Nullable>enable</Nullable>
   </PropertyGroup>
 
-  <ItemGroup>
-    <Folder Include="Transfer\Connect\Response\" />
-  </ItemGroup>
-
   <ItemGroup>
     <PackageReference Include="Mapster" Version="7.3.0" />
     <PackageReference Include="MediatR.Contracts" Version="1.0.1" />

src/NewRock.Sdk/NewRockClient.cs

@@ -41,14 +41,15 @@ namespace NewRock.Sdk
                 using var respContent = responseMessage.Content;
                 var respContentString = await respContent.ReadAsStringAsync(cancellationToken);
                 _logger.LogInformation($"response: {respContentString}");
-                if (respContentString.Contains("<Event"))
-                    return default;
-
-                var authResult = respContentString.Authentication();
-                if (authResult != null)
+                if (!respContentString.Contains("<Event attribute=\"TRANSIENT\">"))
                 {
-                    throw new AuthenticationException(
-                        string.Format("请求认证失败, code: {code}, err: {err}", authResult.Code, authResult.Reason));
+                    var authResult = respContentString.Authentication();
+                    if (authResult != null)
+                    {
+                        throw new AuthenticationException(
+                            string.Format("请求认证失败, code: {code}, err: {err}", authResult.Code, authResult.Reason));
+                    }
+                    //return default;
                 }
 
                 return respContentString.DeserializeWithErrorMsg<TResponse>();

src/NewRock.Sdk/Transfer/Connect/Response/ExtToOuterResponse.cs

@@ -0,0 +1,45 @@
+
+
+using System.Xml.Serialization;
+
+namespace NewRock.Sdk.Transfer.Connect.Response
+{
+    [XmlRoot("Event")]
+    public class ExtToOuterResponse: NewRockResponse
+    {
+        [XmlAttribute("attribute")]
+        public string Attribute { get; set; }
+
+        [XmlElement("outer")]
+        public ExtToOuterOuterResponse Outer { get; set; }
+
+        [XmlElement("ext")]
+        public ExtToOuterExtResponse Ext { get; set; }
+    }
+
+
+    public class ExtToOuterOuterResponse
+    {
+        [XmlAttribute("id")]
+        public string Id { get; set; }
+
+        [XmlAttribute("from")]
+        public string From { get; set; }
+
+        [XmlAttribute("to")]
+        public string To { get; set; }
+
+        [XmlAttribute("trunk")]
+        public string Trunk { get; set; }
+
+        [XmlAttribute("callid")]
+        public string CallId { get; set; }
+    }
+
+    public class ExtToOuterExtResponse
+    {
+        [XmlAttribute("id")]
+        public string Id { get; set; }
+    }
+
+}

src/NewRock.Sdk/Transfer/INewRockClient.Transfer.cs

@@ -1,5 +1,6 @@
 using NewRock.Sdk.Transfer.Conference.Request;
 using NewRock.Sdk.Transfer.Connect.Request;
+using NewRock.Sdk.Transfer.Connect.Response;
 using NewRock.Sdk.Transfer.Queue.Request;
 
 namespace NewRock.Sdk
@@ -28,8 +29,8 @@ namespace NewRock.Sdk
         /// <param name="expired"></param>
         /// <param name="cancellationToken"></param>
         /// <returns></returns>
-        Task<NewRockResponse?> ExtToOuter(ExtToOuterRequest request, string key, int expired,CancellationToken cancellationToken)
-            => ExecuteAsync<ExtToOuterRequest, NewRockResponse>(request, key, expired, cancellationToken);
+        Task<ExtToOuterResponse?> ExtToOuter(ExtToOuterRequest request, string key, int expired,CancellationToken cancellationToken)
+            => ExecuteAsync<ExtToOuterRequest, ExtToOuterResponse>(request, key, expired, cancellationToken);
 
         /// <summary>
         /// 来电转分机