工单流程 质检

src/Hotline.Application/Handlers/FlowEngine/WorkflowEndHandler.cs

@@ -237,15 +237,15 @@ public class WorkflowEndHandler : INotificationHandler<EndWorkflowNotify>
                 orderFlowDto.IsNonPoliceReturn = notification.Dto.External == null ? false : notification.Dto.External.IsPoliceReturn;
                 await _capPublisher.PublishAsync(Hotline.Share.Mq.EventNames.HotlineOrderFiled, orderFlowDto, cancellationToken: cancellationToken);
 
-                try
-                {
-                    //写入质检  针对受理之后直接结束的工单
-                    await _qualityApplication.AddQualityAsync(EQualitySource.Accepted, order.Id, cancellationToken);
-                }
-                catch (Exception e)
-                {
-                    _logger.LogError($"写入质检异常！orderId: {order.Id}, \r\n{e.Message}");
-                }
+                //try
+                //{
+                //    //写入质检  针对受理之后直接结束的工单
+                //    await _qualityApplication.AddQualityAsync(EQualitySource.Accepted, order.Id, cancellationToken);
+                //}
+                //catch (Exception e)
+                //{
+                //    _logger.LogError($"写入质检异常！orderId: {order.Id}, \r\n{e.Message}");
+                //}
 
                 //司法行政监督管理-工单处理
                 await _enforcementApplication.AddEnforcementOrderAsync(order, cancellationToken);

src/Hotline.Application/Handlers/FlowEngine/WorkflowStartHandler.cs

@@ -201,15 +201,15 @@ namespace Hotline.Application.Handlers.FlowEngine
                         _logger.LogError($"发送短信失败! orderId: {order.Id}，\r\n{e.Message}");
                     }
 
-                    //try
-                    //{
-                    //    //写入质检
-                    //    await _qualityApplication.AddQualityAsync(EQualitySource.Accepted, order.Id, cancellationToken);
-                    //}
-                    //catch (Exception e)
-                    //{
-                    //    _logger.LogError($"写入质检异常！orderId: {order.Id}, \r\n{e.Message}");
-                    //}
+                    try
+                    {
+                        //写入质检
+                        await _qualityApplication.AddQualityAsync(EQualitySource.Accepted, order.Id, cancellationToken);
+                    }
+                    catch (Exception e)
+                    {
+                        _logger.LogError($"写入质检异常！orderId: {order.Id}, \r\n{e.Message}");
+                    }
                     break;
                 case WorkflowModuleConsts.KnowledgeAdd:
                 case WorkflowModuleConsts.KnowledgeUpdate:

src/Hotline.Application/Quality/QualityApplication.cs

@@ -124,49 +124,49 @@ namespace Hotline.Application.Quality
                     {
                         quality.AiQuality = true;
                         quality.Mode = "智能质检";
-                        //var call = await _trCallRecordRepository.GetAsync(x => x.CallAccept == order.CallId); //由CallAccept改成OtherAccept
-                        //var call = await _trCallRecordRepository.GetAsync(x => x.OtherAccept == order.CallId);
 
-                        //var audioFile = string.Empty;
-                        //var fromNo = string.Empty;
-                        //DateTime? callStartTime = null;
-                        //if (_callcenterOptions.Value.CallCenterType == AppDefaults.CallCenterType.TianRun)
-                        //{
-                        //    var call = await _callApplication.GetTianrunCallAsync(order.CallId, cancellationToken);
-                        //    audioFile = call.RecordingAbsolutePath;
-                        //    fromNo = call.CPN;
-                        //    callStartTime = call.CreatedTime;
-                        //}
-                        //else if (_callcenterOptions.Value.CallCenterType == AppDefaults.CallCenterType.XingTang)
-                        //{
-                        //    var call = await _callApplication.GetCallAsync(order.CallId, cancellationToken);
-                        //    audioFile = call.AudioFile;
-                        //    fromNo = call.FromNo;
-                        //    callStartTime = call.BeginIvrTime;
-                        //}
+                        await _qualityRepository.AddAsync(quality, cancellationToken);
 
-                        //var setting = _systemSettingCacheManager.GetSetting(SettingConstants.ViteRecordPrefix);
-                        ////await _aiQualityService.CreateAiOrderQualityTask(quality, call, order, setting?.SettingValue[0], cancellationToken);
-                        //try
-                        //{
-                        //    await _aiQualityService.CreateAiOrderQualityTask(
-                        //        quality,
-                        //        audioFile,
-                        //        fromNo,
-                        //        callStartTime,
-                        //        order, setting?.SettingValue[0], cancellationToken);
-                        //}
-                        //catch (Exception e)
-                        //{
-                        //    _logger.LogError($"写入智能质检异常！, \r\n{e.Message}");
-                        //}
+                        ///调用智能质检
+                        try
+                        {
+	                        var audioFile = string.Empty;
+	                        var fromNo = string.Empty;
+	                        DateTime? callStartTime = null;
+	                        if (_callcenterOptions.Value.CallCenterType == AppDefaults.CallCenterType.TianRun)
+	                        {
+		                        var call = await _callApplication.GetTianrunCallAsync(order.CallId, cancellationToken);
+		                        audioFile = call.RecordingAbsolutePath;
+		                        fromNo = call.CPN;
+		                        callStartTime = call.CreatedTime;
+	                        }
+	                        else if (_callcenterOptions.Value.CallCenterType == AppDefaults.CallCenterType.XingTang)
+	                        {
+		                        var call = await _callApplication.GetCallAsync(order.CallId, cancellationToken);
+		                        audioFile = call.AudioFile;
+		                        fromNo = call.FromNo;
+		                        callStartTime = call.BeginIvrTime;
+	                        }
+
+	                        var setting = _systemSettingCacheManager.GetSetting(SettingConstants.ViteRecordPrefix);
+							await _aiQualityService.CreateAiOrderQualityTask(
+                                quality,
+                                audioFile,
+                                fromNo,
+                                callStartTime,
+                                order, setting?.SettingValue[0], cancellationToken);
+                        }
+                        catch (Exception e)
+                        {
+                            _logger.LogError($"写入智能质检异常！, \r\n{e.Message}");
+                        }
                     }
                 }
             }
 
-            _logger.LogInformation($"质检对象：{System.Text.Json.JsonSerializer.Serialize(quality, 
-                new JsonSerializerOptions { Encoder = JavaScriptEncoder.Create(UnicodeRanges.BasicLatin, UnicodeRanges.CjkUnifiedIdeographs) })}");
-            await _qualityRepository.AddAsync(quality, cancellationToken);
+            //_logger.LogInformation($"质检对象：{System.Text.Json.JsonSerializer.Serialize(quality, 
+            //    new JsonSerializerOptions { Encoder = JavaScriptEncoder.Create(UnicodeRanges.BasicLatin, UnicodeRanges.CjkUnifiedIdeographs) })}");
+            //await _qualityRepository.AddAsync(quality, cancellationToken);
         }
 
         public async Task UpdateQualityAsync(UpdateQualityDto model, CancellationToken cancellationToken)