src/Hotline.Api/Controllers/DataSharing/ProvinceController.cs

@@ -4,6 +4,7 @@ using Hotline.DataSharing.Province;
 using Hotline.DataSharing.Province.Notifications;
 using Hotline.DataSharing.Province.XieTong.Receive;
 using Hotline.DataSharing.Province.XieTong.Send;
+using Hotline.Orders.Notifications;
 using Hotline.Share.Dtos.DataSharing;
 using Hotline.Share.Dtos.DataSharing.Province;
 using Hotline.Share.Dtos.DataSharing.Province.XieTong.Receive;
@@ -14,7 +15,6 @@ using MapsterMapper;
 using MediatR;
 using Microsoft.AspNetCore.Authorization;
 using Microsoft.AspNetCore.Mvc;
-using Org.BouncyCastle.Ocsp;
 using XF.Domain.Filters;
 using XF.Domain.Repository;
 
@@ -469,7 +469,7 @@ namespace Hotline.Api.Controllers.DataSharing
         }
 
         /// <summary>
-        /// 交办工单满意度接收接口
+        /// 交办工单满意度接收接口---已完成-----1
         /// </summary>
         /// <param name="receiveSendCaseEvlResult">交办工单满意度对象</param>
         /// <returns></returns>
@@ -493,8 +493,17 @@ namespace Hotline.Api.Controllers.DataSharing
 
             if (!string.IsNullOrEmpty(id))
             {
+                ProvinceOrderVisitDto orderVisitDto = new()
+                {
+                    ProvinceNo = dto.CaseSerial,
+                    VisitTime = dto.ReplyTime,
+                    VisitContent = dto.ReplyContent,
+                    OrgProcessingResults = dto.ResultEvl,
+                    VisitType = EVisitType.ArtificialVisit
+                };
+
                 //向业务系统推送消息
-                //await _capPublisher.PublishAsync(Sharing.Share.Mq.EventNames.SharingOrderEvlResult, _mapper.Map<EvlResultDto>(dto), cancellationToken: HttpContext.RequestAborted);
+                await _mediator.Send(new AddVisitNotify { OrderVisited = orderVisitDto }, HttpContext.RequestAborted);
                 return OpenResponse.Ok(Reponse.Success("您已成功提交数据！"));
             }
             else
@@ -571,8 +580,26 @@ namespace Hotline.Api.Controllers.DataSharing
 
             if (!string.IsNullOrEmpty(id))
             {
+                ProvinceOrderVisitDto orderVisitDto = new()
+                {
+                    ProvinceNo = dto.CaseSerial,
+                    VisitTime = dto.VisitTime,
+                    VisitContent = dto.VisitRemark,
+                    OrgProcessingResults = dto.SubjectResultSatify
+                };
+                orderVisitDto.VisitType = dto.VisitType switch
+                {
+                    "DH" => (EVisitType?)EVisitType.ArtificialVisit,
+                    "DX" => (EVisitType?)EVisitType.SmsVisit,
+                    "WZ" => (EVisitType?)EVisitType.WebVisit,
+                    "WX" => (EVisitType?)EVisitType.WeChatVisit,
+                    "AP" => (EVisitType?)EVisitType.AppVisit,
+                    _ => (EVisitType?)EVisitType.OtherVisit,
+                };
+
                 //向业务系统推送消息
-                // await _capPublisher.PublishAsync(Sharing.Share.Mq.EventNames.SharingOrderVisitInfo, _mapper.Map<VisitInfoDto>(dto), cancellationToken: HttpContext.RequestAborted);
+                await _mediator.Send(new AddVisitNotify { OrderVisited = orderVisitDto }, HttpContext.RequestAborted);
+
                 return OpenResponse.Ok(Reponse.Success("您已成功提交数据！"));
             }
             else

src/Hotline.Application/Handlers/Order/AddVisitNotifyHandler.cs

@@ -32,7 +32,7 @@ namespace Hotline.Application.Handlers.Order
             var orderVisit = await _orderVisitRepository.Queryable()
                 .Includes(x=>x.Order)
                 .Includes(x=>x.OrderVisitDetails)
-                .Where(x => x.No == notification.OrderVisited.OrderNo && 
+                .Where(x => x.Order.ProvinceNo == notification.OrderVisited.ProvinceNo && 
              x.VisitState != Share.Enums.Order.EVisitState.None).FirstAsync(cancellationToken);
 
             if (orderVisit != null)

src/Hotline.Application/Mappers/DataSharing/DsMapperConfigs.cs

@@ -185,7 +185,21 @@ namespace Hotline.Application.Mappers.DataSharing
            .Map(d => d.SignTime, x => x.ActualHandleStepAcceptTime)
            .Map(d => d.FdBackTime, x => x.ActualHandleTime)
            .Map(d => d.HandleTimeLong, x => x.HandleDurationWorkday)
-            ; 
+            ;
+
+            ///服务工单交办处理结果
+            config.ForType<PublishPublishOrderDto, DsZmhdCaseInfoPublic>()
+           .Map(d => d.CaseSerial, x => x.Order.ProvinceNo)
+           .Map(d => d.AnswerTime, x => x.Order.ActualHandleTime)
+           .Map(d => d.AnswerOu, x => x.Order.ActualHandleOrgName)
+           .Map(d => d.AnswerContent, x => x.Order.ActualOpinion)
+           .Map(d => d.AuditFirstName, x => x.CreatorName)
+           .Map(d => d.AuditFirstTime, x => x.CreationTime)
+           .Map(d => d.AuditSecondName, x => x.CreatorName)
+           .Map(d => d.PublishDate, x => x.CreationTime)
+           .Map(d => d.PublicOpinion, x => x.ArrangeOpinion)
+           .Map(d => d.AreaCode, x => x.Order.AreaCode)
+            ;
 
             //通话记录
             config.ForType<CallConnectOrderDto, DsSubmitCaseRecord>()

src/Hotline.Share/Dtos/Order/OrderVisitDto.cs

@@ -444,7 +444,7 @@ namespace Hotline.Share.Dtos.Order
         /// <summary>
         /// 工单编号
         /// </summary>
-        public string OrderNo { get; set; }
+        public string ProvinceNo { get; set; }
         /// <summary>
         /// 回访时间
         /// </summary>

src/Hotline/DataSharing/Province/Services/ProvinceService.cs

@@ -16,6 +16,7 @@ using Hotline.Share.Dtos.File;
 using Hotline.Share.Dtos.Knowledge;
 using Hotline.Share.Dtos.Order;
 using Hotline.Share.Enums.DataSharing;
+using Hotline.Share.Enums.FlowEngine;
 using Hotline.Share.Enums.Order;
 using MapsterMapper;
 using MediatR;
@@ -397,7 +398,7 @@ namespace Hotline.DataSharing.Province.Services
         }
 
         /// <summary>
-        /// 政民互动提交公开  
+        /// 政民互动提交公开---已在接收大补数据中实现  
         /// </summary>
         /// <param name="dto"></param>
         /// <returns></returns>
@@ -970,51 +971,77 @@ namespace Hotline.DataSharing.Province.Services
         /// <param name="dto"></param>
         /// <param name="cancellationToken"></param>
         /// <returns></returns>
-        public async Task PublishOrder(OrderDto dto, CancellationToken cancellationToken)
+        public async Task PublishOrder(PublishPublishOrderDto dto, CancellationToken cancellationToken)
         {
-            #region 服务工单交办处理结果
-            //判断是否是热线中心
-            if (!string.IsNullOrEmpty(dto.ActualHandleOrgCode))
+            if (dto.Order.IsProvince && dto.Order.Source == ESource.ProvinceStraight)
             {
-                if (dto.ActualHandleOrgCode.Substring(0, 3) == "001")
+                #region 服务工单交办处理结果
+                //判断是否是热线中心
+                if (!string.IsNullOrEmpty(dto.Order.ActualHandleOrgCode) && dto.Order.ActualHandleOrgCode.Substring(0, 3) == "001")
+                    dto.Order.ActualHandleOrgName = "热线中心";
+
+                var data = _mapper.Map<DsGetCaseResultReceive>(dto.Order);
+                data.ConcactType = "40";
+                data.FinishType = "1";
+                data.HandleTimeLong = dto.Order.AllDuration;
+                switch (dto.Order.RealCommunicationMode)
                 {
-                    dto.ActualHandleOrgName = "热线中心";
+                    case ERealCommunicationMode.Phone:
+                        data.ConcactType = "10";
+                        break;
+                    case ERealCommunicationMode.Locale:
+                        data.ConcactType = "20";
+                        break;
+                    default:
+                        data.ConcactType = "40";
+                        break;
                 }
-            }
-
-            var data = _mapper.Map<DsGetCaseResultReceive>(dto);
-            data.ConcactType = "40";
-            data.FinishType = "1";
-            data.HandleTimeLong = dto.AllDuration;
-            data.CliengGuid = Guid.NewGuid().ToString();
-            //将上报信息写入本地库
-            data.Id = await _getCaseResultReceiveRepository.AddAsync(data, cancellationToken);
-
-            //将待推送数据写入待推送表
-            DsWaitingPushData pushData = new()
-            {
-                ServiceInterface = "GetCaseResultReceive",
-                Data = System.Text.Json.JsonSerializer.Serialize(data),
-                Priority = 0,
-                PushUrl = "get_case_result_receive",
-                Method = HttpMethods.Post,
-                SyncID = data.Id
-            };
-            await _waitingPushDataRepository.AddAsync(pushData, cancellationToken);
-            //处理附件
-            await FileData(new List<FileJson>(), data.CaseSerial, data.CliengGuid, dto.AreaCode, cancellationToken);
-            #endregion
+                data.CliengGuid = Guid.NewGuid().ToString();
 
-            //这里业务系统处理
-            if (dto.SourceChannelCode == "ZGZFW")
-            {
+                //中国政府网的数据处理
+                if (dto.Order.SourceChannelCode == "ZGZFW")
+                {
+                    data.Notes = "无";
+                    data.MsgOpenByArea = dto.ProPublishState == true ? "1" : "0";
+                    data.AreaNotPublicReason = dto.NoPubReason;
+                    data.FeedBackAnswerContent = dto.ArrangeOpinion;
+                    data.FeedBackTel = dto.FeedBackPhone;
+                    data.EventType = "";
+                    data.Eventname = "";
+                    data.ContactFlag = "1";
+                    data.AssessFlag = "1";
+                    data.AssessOpinion = "1";
+                    data.AssessContent = "";
+                }
+                
+                //将上报信息写入本地库
+                data.Id = await _getCaseResultReceiveRepository.AddAsync(data, cancellationToken);
 
+                //将待推送数据写入待推送表
+                DsWaitingPushData pushData = new()
+                {
+                    ServiceInterface = "GetCaseResultReceive",
+                    Data = System.Text.Json.JsonSerializer.Serialize(data),
+                    Priority = 0,
+                    PushUrl = "get_case_result_receive",
+                    Method = HttpMethods.Post,
+                    SyncID = data.Id
+                };
+                await _waitingPushDataRepository.AddAsync(pushData, cancellationToken);
+                //处理附件
+                await FileData(new List<FileJson>(), data.CaseSerial, data.CliengGuid, dto.Order.AreaCode, cancellationToken);
+                #endregion
             }
 
             //政民互动提交公开
-            if (dto.SourceChannelCode == "ZMHD")
+            if (dto.Order.SourceChannelCode == "ZMHD")
             {
+                var data = _mapper.Map<DsZmhdCaseInfoPublic>(dto);
+                //将上报信息写入本地库
+                data.Id = await _zMHDCaseInfoPublicRepository.AddAsync(data);
 
+                //将待推送数据写入待推送表
+                await InitPushData("ZmhdCaseInfoPublic", System.Text.Json.JsonSerializer.Serialize(data), "zmhd_case_info_public", data.Id, 0, cancellationToken);
             }
         }
 

src/Hotline/DataSharing/Province/Services/PusherProviderService.cs

@@ -1356,31 +1356,34 @@ namespace Hotline.DataSharing.Province.Services
                         fileContentBytes = memoryStream.ToArray();
                     }
                 }
-                //获取附件上传Token
-                string strToken = await _xieTongClient.GetTokenAsync(cancellationToken);
-
-                //组装请求参数
-                var model = new GetCaseMaterialInfoRequest
-                {
-                    paras = dto,
-                    token = new ClientInfo(configProvince.ClientId, configProvince.ClientSecret)
-                };
-
-                Dictionary<string, object> dicParam = new()
+                if (fileContentBytes != null)
                 {
-                    { "params",  System.Text.Json.JsonSerializer.Serialize(model) } // 第一个接口参数，json格式字符串
-                };
-
-                // 构造字典文件数据
-                // 接口参数名称为files
-                CFormUpload.FileParameter fileParameter = new CFormUpload.FileParameter("files", fileContentBytes, fileName, null);
-                dicParam.Add(fileName, fileParameter);
+                    //获取附件上传Token
+                    string strToken = await _xieTongClient.GetTokenAsync(cancellationToken);
 
-                string strUrl = configProvince.HuiJu + "get_case_material_info";
-                // 上传附件
-                string strResult = CFormUpload.MultipartFormDataPost(strUrl, null, dicParam, strToken);
+                    //组装请求参数
+                    var model = new GetCaseMaterialInfoRequest
+                    {
+                        paras = dto,
+                        token = new ClientInfo(configProvince.ClientId, configProvince.ClientSecret)
+                    };
 
-                return JsonConvert.DeserializeObject<ProvinceResponse>(strResult);
+                    Dictionary<string, object> dicParam = new()
+                    {
+                        { "params",  System.Text.Json.JsonSerializer.Serialize(model) } // 第一个接口参数，json格式字符串
+                    };
+
+                    // 构造字典文件数据
+                    // 接口参数名称为files
+                    CFormUpload.FileParameter fileParameter = new CFormUpload.FileParameter("files", fileContentBytes, fileName, null);
+                    dicParam.Add(fileName, fileParameter);
+
+                    string strUrl = configProvince.HuiJu + "get_case_material_info";
+                    // 上传附件
+                    string strResult = CFormUpload.MultipartFormDataPost(strUrl, null, dicParam, strToken);
+                    return JsonConvert.DeserializeObject<ProvinceResponse>(strResult);
+                }
+                return new ProvinceResponse();
             }
             catch (Exception)
             {

src/Hotline/DataSharing/Province/XieTong/Send/DsGetCaseResultReceive.cs

@@ -50,7 +50,7 @@ namespace Hotline.DataSharing.Province.XieTong.Send
         /// 办理人员
         /// </summary>
         [SugarColumn(ColumnDescription = "办理人员", ColumnDataType = "varchar(200)", IsNullable = true)]
-        public string EndName { get; set; }
+        public string? EndName { get; set; }
 
         /// <summary>
         /// 联系时间
@@ -116,7 +116,7 @@ namespace Hotline.DataSharing.Province.XieTong.Send
         /// 统一社会信用代码
         /// </summary>
         [SugarColumn(ColumnDescription = "统一社会信用代码", ColumnDataType = "varchar(50)", IsNullable = true)]
-        public string OperateDeptCode { get; set; }
+        public string? OperateDeptCode { get; set; }
 
         /// <summary>
         /// 任务单关联 guid
@@ -128,67 +128,67 @@ namespace Hotline.DataSharing.Province.XieTong.Send
         /// 是否提供公开答复口径
         /// </summary>
         [SugarColumn(ColumnDescription = "是否提供公开答复口径", ColumnDataType = "varchar(2)", IsNullable = true)]
-        public string MsgOpenByArea { get; set; }
+        public string? MsgOpenByArea { get; set; }
 
         /// <summary>
         /// 地方不公开处理结果原因
         /// </summary>
         [SugarColumn(ColumnDescription = "地方不公开处理结果原因", ColumnDataType = "varchar(1000)", IsNullable = true)]
-        public string AreaNotPublicReason { get; set; }
+        public string? AreaNotPublicReason { get; set; }
 
         /// <summary>
         /// 地方公开答复口径
         /// </summary>
         [SugarColumn(ColumnDescription = "地方公开答复口径", ColumnDataType = "varchar(1000)", IsNullable = true)]
-        public string FeedBackAnswerContent { get; set; }
+        public string? FeedBackAnswerContent { get; set; }
 
         /// <summary>
         /// 反馈人电话号码
         /// </summary>
         [SugarColumn(ColumnDescription = "反馈人电话号码", ColumnDataType = "varchar(11)", IsNullable = true)]
-        public string FeedBackTel { get; set; }
+        public string? FeedBackTel { get; set; }
 
         /// <summary>
         /// 备注-办理单位备注，仅审核可见，群众不可见，无备注填“无”
         /// </summary>
         [SugarColumn(ColumnDescription = " 备注-办理单位备注，仅审核可见", ColumnDataType = "text", IsNullable = true)]
-        public string Notes { get; set; } = "无";
+        public string? Notes { get; set; } = "无";
 
         /// <summary>
         /// 事件类型
         /// </summary>
         [SugarColumn(ColumnDescription = "事件类型", ColumnDataType = "varchar(10)", IsNullable = true)]
-        public string EventType { get; set; }
+        public string? EventType { get; set; }
 
         /// <summary>
         /// 事件名称
         /// </summary>
         [SugarColumn(ColumnDescription = "事件名称", ColumnDataType = "varchar(100)", IsNullable = true)]
-        public string Eventname { get; set; }
+        public string? Eventname { get; set; }
 
         /// <summary>
         /// 是否与网民取得联系
         /// </summary>
         [SugarColumn(ColumnDescription = "是否与网民取得联系", ColumnDataType = "varchar(5)", IsNullable = true)]
-        public string ContactFlag { get; set; }
+        public string? ContactFlag { get; set; }
 
         /// <summary>
         /// 是否邀请网民评价
         /// </summary>
         [SugarColumn(ColumnDescription = "是否邀请网民评价", ColumnDataType = "varchar(5)", IsNullable = true)]
-        public string AssessFlag { get; set; }
+        public string? AssessFlag { get; set; }
 
         /// <summary>
-        /// 网民评价类型
+        /// 网民评价类型0：不满意；1： 满意；2：表示理解
         /// </summary>
         [SugarColumn(ColumnDescription = "网民评价类型", ColumnDataType = "varchar(5)", IsNullable = true)]
-        public string AssessOpinion { get; set; }
+        public string? AssessOpinion { get; set; }
 
         /// <summary>
         /// 网民评价内容
         /// </summary>
         [SugarColumn(ColumnDescription = "网民评价内容", ColumnDataType = "varchar(3000)", IsNullable = true)]
-        public string AssessContent { get; set; }
+        public string? AssessContent { get; set; }
 
         /// <summary>
         /// 服务工单编号  
@@ -200,19 +200,19 @@ namespace Hotline.DataSharing.Province.XieTong.Send
         /// 材料标识
         /// </summary>
         [SugarColumn(ColumnDescription = "材料标识", ColumnDataType = "varchar(50)", IsNullable = true)]
-        public string CliengGuid { get; set; }
+        public string? CliengGuid { get; set; }
 
         /// <summary>
         /// 行政区划代码
         /// </summary>
         [SugarColumn(ColumnDescription = "行政区划代码", ColumnDataType = "varchar(24)")]
-        public string AreaCode { get; set; }
+        public string? AreaCode { get; set; }
 
         /// <summary>
         /// 接口返回结果
         /// </summary>
         [SugarColumn(ColumnDataType = "json", IsJson = true, IsNullable = true)]
-        public string ReturnResult { get; set; }
+        public string? ReturnResult { get; set; }
 
         /// <summary>
         /// 同步状态 0：待同步；	  1：同步成功；	 2：同步失败；

src/Hotline/DataSharing/Province/XieTong/Send/DsZmhdCaseInfoPublic.cs

@@ -14,49 +14,49 @@ namespace Hotline.DataSharing.Province.XieTong.Send
         /// 部门答复时间
         /// </summary>
         [SugarColumn(ColumnDescription = "部门答复时间")]
-        public DateTime? ANSWER_TIME { get; set; }
+        public DateTime? AnswerTime { get; set; }
 
         /// <summary>
         /// 答复部门名称
         /// </summary>
         [SugarColumn(ColumnDescription = "答复部门名称", ColumnDataType = "varchar(100)")]
-        public string ANSWER_OU { get; set; }
+        public string AnswerOu { get; set; }
 
         /// <summary>
         /// 答复内容
         /// </summary>
         [SugarColumn(ColumnDescription = "答复内容", ColumnDataType = "text")]
-        public string ANSWER_CONTENT { get; set; }
+        public string AnswerContent { get; set; }
 
         /// <summary>
         /// 初审人姓名
         /// </summary>
         [SugarColumn(ColumnDescription = "初审人姓名", ColumnDataType = "varchar(100)")]
-        public string AUDIT_FIRST_NAME { get; set; }
+        public string AuditFirstName { get; set; }
 
         /// <summary>
         /// 初审时间
         /// </summary>
         [SugarColumn(ColumnDescription = "初审时间")]
-        public DateTime? AUDIT_FIRST_TIME { get; set; }
+        public DateTime? AuditFirstTime { get; set; }
 
         /// <summary>
         /// 二审人姓名
         /// </summary>
         [SugarColumn(ColumnDescription = "二审人姓名", ColumnDataType = "varchar(100)")]
-        public string AUDIT_SECOND_NAME { get; set; }
+        public string AuditSecondName { get; set; }
 
         /// <summary>
         /// 公开时间
         /// </summary>
         [SugarColumn(ColumnDescription = "公开时间")]
-        public DateTime? PUBLISH_DATE { get; set; }
+        public DateTime? PublishDate { get; set; }
 
         /// <summary>
         /// 公开意见
         /// </summary>
         [SugarColumn(ColumnDescription = "公开意见", ColumnDataType = "varchar(300)")]
-        public string PUBLIC_OPINION { get; set; }
+        public string PublicOpinion { get; set; }
 
         /// <summary>
         /// 服务工单编号