TANG JIANG 1 年之前
父節點
當前提交
587d226fe5
共有 1 個文件被更改,包括 15 次插入7 次删除
  1. 15 7
      src/DataSharing.Application/Receivers/ProvinceReceiver.cs

+ 15 - 7
src/DataSharing.Application/Receivers/ProvinceReceiver.cs

@@ -491,6 +491,17 @@ namespace DataSharing.Application.Receivers
         [CapSubscribe(Hotline.Share.Mq.EventNames.HotlineOrderFiled)]
         public async Task OrderFiledAsync(OrderFlowDto dto, CancellationToken cancellationToken)
         {
+            //先看看需要处理工单数据不
+            SubmitCaseInfo data = new();
+            if (dto != null && dto.Order != null && !dto.Order.IsProvince)
+            {
+                data = await InitDataAsync(dto.Order, cancellationToken);
+                var validator = new SubmitCaseInfoValidator();
+                var validResult = await validator.ValidateAsync(data, cancellationToken);
+                if (!validResult.IsValid)
+                    throw new UserFriendlyException(string.Join(',', validResult.Errors.Select(d => d.ErrorMessage)));
+            }
+
             //推送办理记录
             dto.ExpiredTimeChanged = false;
             await SubmitCaseProcessFlowAsync(dto, cancellationToken);
@@ -502,12 +513,8 @@ namespace DataSharing.Application.Receivers
             //IsProvince 如果是false 则推送服务工单受理
             if (dto != null && dto.Order != null && !dto.Order.IsProvince)
             {
-                var data = await InitDataAsync(dto.Order, cancellationToken);
-                var validator = new SubmitCaseInfoValidator();
-                var validResult = await validator.ValidateAsync(data, cancellationToken);
-                if (!validResult.IsValid)
-                    throw new UserFriendlyException(string.Join(',', validResult.Errors.Select(d => d.ErrorMessage)));
-                #region 处理请求参数
+
+                #region 处理请求参数--推送工单数据
                 var configProvince = _channelConfigurationManager.GetConfigurationProvince();
                 var request = new ProvinceListRequest<SubmitCaseInfo>(configProvince.ClientId, configProvince.ClientSecret);
                 request.SetData(new List<SubmitCaseInfo>() { data });
@@ -1024,7 +1031,8 @@ namespace DataSharing.Application.Receivers
         {
             var data = _mapper.Map<GetKnowledgeInfoAbandonInfo>(dto);
             data.AreaCode = _channelConfigurationManager.GetConfigurationCityCode().AreaCode;
-
+            data.CategoryCode = "01";
+            data.CategoryName = "公共服务";
             #region 处理请求参数
             var configProvince = _channelConfigurationManager.GetConfigurationProvince();
             var request = new ProvinceRequest<GetKnowledgeInfoAbandonInfo>(configProvince.ClientId, configProvince.ClientSecret);