BookingHeChuan/Myshipping.Application/Event/BookingSyncSubscriber.cs

using Furion;
using Furion.EventBus;
using Furion.FriendlyException;
using Furion.RemoteRequest.Extensions;
using Mapster;
using Microsoft.Extensions.DependencyInjection;
using Microsoft.Extensions.Logging;
using Myshipping.Application.ConfigOption;
using Myshipping.Application.Entity;
using Myshipping.Application.Enum;
using Myshipping.Application.Service.BookingOrder.Dto;
using Myshipping.Core;
using Myshipping.Core.Entity;
using Myshipping.Core.Service;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using NPOI.XWPF.UserModel;
using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using Yitter.IdGenerator;

namespace Myshipping.Application.Event
{
    /// <summary>
    /// 订舱同步给客户订舱系统
    /// </summary>
    public class BookingSyncSubscriber : IEventSubscriber
    {
        private IServiceProvider _services { get; }
        private readonly ILogger<BookingSyncSubscriber> _logger;

        public BookingSyncSubscriber(IServiceProvider services, ILogger<BookingSyncSubscriber> logger)
        {
            _services = services;
            _logger = logger;
        }

        #region 运营端事件
        //发送订舱同步数据给客户订舱系统
        [EventSubscribe("SendToCustomer:Book")]
        public async Task SendToCustomer(EventHandlerExecutingContext context)
        {
            _logger.LogInformation($"收到订舱同步客户订舱系统请求：{context.Source.Payload}");

            var paraObj = context.Source.Payload as dynamic;

            var bookId = (long)paraObj.Id;
            var syncType = (string)paraObj.SyncType;

            using var scope = _services.CreateScope();
            var repoCutomerOrder = scope.ServiceProvider.GetRequiredService<SqlSugarRepository<BookingCustomerOrder>>();
            var repoOrder = scope.ServiceProvider.GetRequiredService<SqlSugarRepository<BookingOrder>>();
            var repoCtn = scope.ServiceProvider.GetRequiredService<SqlSugarRepository<BookingCtn>>();
            var repoFile = scope.ServiceProvider.GetRequiredService<SqlSugarRepository<BookingFile>>();

            var repoStaLog = scope.ServiceProvider.GetRequiredService<SqlSugarRepository<BookingStatusLog>>();
            var repoStaLogDetail = scope.ServiceProvider.GetRequiredService<SqlSugarRepository<BookingStatusLogDetail>>();
            var repoGoodsSta = scope.ServiceProvider.GetRequiredService<SqlSugarRepository<BookingGoodsStatus>>();
            var repoGoodsStaCfg = scope.ServiceProvider.GetRequiredService<SqlSugarRepository<BookingGoodsStatusConfig>>();
            var repoLog = scope.ServiceProvider.GetRequiredService<SqlSugarRepository<BookingLog>>();
            var repoLogDetail = scope.ServiceProvider.GetRequiredService<SqlSugarRepository<BookingLogDetail>>();

            var cacheService = scope.ServiceProvider.GetRequiredService<ISysCacheService>();

            var custOrder = await repoCutomerOrder.AsQueryable().Filter(null, true).FirstAsync(x => x.BookingId == bookId);
            if (custOrder == null) //非客户订舱系统过来的数据
            {
                _logger.LogInformation($"ID为 {bookId} 的数据并非来自客户订舱系统，不继续处理数据回推");
                return;
            }

            if (string.IsNullOrEmpty(custOrder.FeedbackUrl))
            {
                _logger.LogInformation($"ID为 {bookId} 的数据未提供回推接口URL，不继续处理数据回推");
                return;
            }

            var order = await repoOrder.AsQueryable().Filter(null, true).FirstAsync(x => x.Id == bookId);
            var ctns = await repoCtn.AsQueryable().Filter(null, true).Where(x => x.BILLID == bookId).ToListAsync();
            var files = await repoFile.AsQueryable().Filter(null, true).Where(x => x.BookingId == bookId).ToListAsync();
            var staLogs = await repoStaLog.AsQueryable().Filter(null, true).Where(x => x.BookingId == bookId).ToListAsync();
            var staLogDetails = await repoStaLogDetail.AsQueryable().Filter(null, true).Where(x => staLogs.Select(y => y.Id).Contains(x.PId)).ToListAsync();
            var goodsLogs = await repoGoodsSta.AsQueryable().Filter(null, true).Where(x => x.bookingId == bookId).ToListAsync();
            var goodsLogConfigs = await repoGoodsStaCfg.AsQueryable().Filter(null, true).Where(x => goodsLogs.Select(y => y.ConfigId).Contains(x.Id)).ToListAsync();
            var bookLogs = await repoLog.AsQueryable().Filter(null, true).Where(x => x.BookingId == bookId).ToListAsync();
            var bookLogDetails = await repoLogDetail.AsQueryable().Filter(null, true).Where(x => bookLogs.Select(y => y.Id).Contains(x.PId)).ToListAsync();

            //把ID还原为客户订舱系统中的ID
            order.Id = Convert.ToInt64(order.BSNO);
            order.BSNO = null;
            ctns.ForEach(x => x.BILLID = order.Id);
            files.ForEach(x => x.BookingId = order.Id);
            staLogs.ForEach(x => x.BookingId = order.Id);
            goodsLogs.ForEach(x => x.bookingId = order.Id);

            //货运动态
            var staLogSendList = staLogs.Adapt<List<BookingStatusLogSyncCustomerDto>>();
            staLogSendList.ForEach(x =>
            {
                x.Details = staLogDetails.Where(y => y.PId == x.Id).Adapt<List<BookingStatusLogDetailSyncCustomerDto>>();
            });

            //修改日志
            var bookLogSendList = bookLogs.Adapt<List<BookingLogSyncCustomerDto>>();
            bookLogSendList.ForEach(x =>
            {
                x.Details = bookLogDetails.Where(y => y.PId == x.Id).Adapt<List<BookingLogDetailSyncCustomerDto>>();
            });

            //发送对象
            var sendObj = new BookingCustomerRecDataFeedbackDto()
            {
                Order = order.Adapt<BookingOrderSyncCustomerDto>(),
                Ctns = ctns.Adapt<List<BookingCtnSyncCustomerDto>>(),
                Files = files.Adapt<List<BookingFileSyncCustomerDto>>(),
                StatusLogs = staLogSendList,
                BookingLogs = bookLogSendList
            };


            ////文件内容
            //var opt = App.GetOptions<BookingAttachOptions>();
            //var dirAbs = opt.basePath;
            //if (string.IsNullOrEmpty(dirAbs))
            //{
            //    dirAbs = App.WebHostEnvironment.WebRootPath;
            //}

            //foreach (var file in files)
            //{
            //    var fileFullPath = Path.Combine(dirAbs, file.FilePath);
            //    if (File.Exists(fileFullPath))
            //    {
            //        sendObj.Files.First(x => x.Id == file.Id).FileContent = File.ReadAllBytes(fileFullPath);
            //    }
            //}


            var feedbackObj = new BookingFeedbackDto(BookingFeedbackType.BookingAll.ToString());
            feedbackObj.JsonContent = sendObj.ToJsonString();
            feedbackObj.SyncType = syncType;

            //回推回执
            _logger.LogInformation($"准备发送客户订舱数据同步：{feedbackObj.ToJsonString()}，URL：{custOrder.FeedbackUrl}");

            var rtn = await custOrder.FeedbackUrl
                 .SetHeaders(new Dictionary<string, object> {
                    { CommonConst.API_USER_HEADER_KEY, custOrder.FeedbackKey},
                    { CommonConst.API_USER_HEADER_SECRET, custOrder.FeedbackSecret}
                 })
                 .SetBody(feedbackObj, "application/x-www-form-urlencoded")
                 .PostAsStringAsync();

            _logger.LogInformation($"回推数据同步返回：{rtn}");

            var jobjRtn = JObject.Parse(rtn);
            if (jobjRtn.GetIntValue("code") != 200)
            {
                throw Oops.Bah(jobjRtn.GetStringValue("message"));
            }
        }


        //推送货物状态到客户订舱系统
        [EventSubscribe("SyncGoodStatus:Book")]
        public async Task SyncGoodStatus(EventHandlerExecutingContext context)
        {
            _logger.LogInformation($"收到推送货物状态到客户订舱系统：{context.Source.Payload}");
            GoodsStatusSyncDto payload = context.Source.Payload as GoodsStatusSyncDto;

            using var scope = _services.CreateScope();
            var repoCutomerOrder = scope.ServiceProvider.GetRequiredService<SqlSugarRepository<BookingCustomerOrder>>();
            var repoOrder = scope.ServiceProvider.GetRequiredService<SqlSugarRepository<BookingOrder>>();

            var cacheService = scope.ServiceProvider.GetRequiredService<ISysCacheService>();

            var custOrder = await repoCutomerOrder.AsQueryable().Filter(null, true).FirstAsync(x => x.BookingId == payload.Id);
            if (custOrder == null) //非客户订舱系统过来的数据
            {
                _logger.LogInformation($"ID为 {payload.Id} 的数据并非来自客户订舱系统，不继续处理数据回推");
                return;
            }

            if (string.IsNullOrEmpty(custOrder.FeedbackUrl))
            {
                _logger.LogInformation($"ID为 {custOrder.Id} 的数据未提供回推接口URL，不继续处理数据回推");
                return;
            }

            var order = await repoOrder.AsQueryable().Filter(null, true).FirstAsync(x => x.Id == payload.Id);

            //把ID还原为客户订舱系统中的ID
            payload.Id = Convert.ToInt64(order.BSNO);

            var feedbackObj = new BookingFeedbackDto(BookingFeedbackType.GoodsStatus.ToString());
            feedbackObj.JsonContent = payload.ToJsonString();

            //回推回执
            _logger.LogInformation($"准备发送货物状态数据同步：{feedbackObj.ToJsonString()}，URL：{custOrder.FeedbackUrl}");

            var rtn = await custOrder.FeedbackUrl
                 .SetHeaders(new Dictionary<string, object> {
                    { CommonConst.API_USER_HEADER_KEY, custOrder.FeedbackKey},
                    { CommonConst.API_USER_HEADER_SECRET, custOrder.FeedbackSecret}
                 })
                 .SetBody(feedbackObj, "application/x-www-form-urlencoded")
                 .PostAsStringAsync();

            _logger.LogInformation($"回推数据同步返回：{rtn}");

            var jobjRtn = JObject.Parse(rtn);
            if (jobjRtn.GetIntValue("code") != 200)
            {
                throw Oops.Bah(jobjRtn.GetStringValue("message"));
            }
        }

        //运营端处理了修改服务项目的消息的回推消息
        [EventSubscribe("Message:Process:Booking:ChangeServiceItem")]
        public async Task MessageProcessBookingChangeServiceItem(EventHandlerExecutingContext context)
        {
            _logger.LogInformation($"收到回推服务项目修改审核到客户订舱系统：{context.Source.Payload}");
            var msgId = (long)context.Source.Payload;

            using var scope = _services.CreateScope();
            var repMessage = scope.ServiceProvider.GetRequiredService<SqlSugarRepository<DjyMessage>>();
            var repoCutomerOrder = scope.ServiceProvider.GetRequiredService<SqlSugarRepository<BookingCustomerOrder>>();
            var repoOrder = scope.ServiceProvider.GetRequiredService<SqlSugarRepository<BookingOrder>>();
            var repoServiceItem = scope.ServiceProvider.GetRequiredService<SqlSugarRepository<BookingServiceItem>>();
            var cacheService = scope.ServiceProvider.GetRequiredService<ISysCacheService>();

            var msg = await repMessage.AsQueryable().Filter(null, true).FirstAsync(x => x.Id == msgId);
            var extObj = JsonConvert.DeserializeObject<ChangeServiceItemExtModel>(msg.ExtData);
            var custOrdId = extObj.CustomerOrderId;
            var custOrder = await repoCutomerOrder.AsQueryable().Filter(null, true).FirstAsync(x => x.Id == custOrdId);

            //修改服务项目
            if (msg.ProcStatus == MessageProcessStatus.Accept.ToString())
            {
                var serItm = cacheService.GetAllDictData().Result.FirstOrDefault(x => x.TypeCode == "booking_service_item" && x.Code == extObj.Dto.ServiceCode);
                var serv = await repoServiceItem.AsQueryable().Filter(null, true).FirstAsync(x => x.BookingId == extObj.OrderId && x.Code == extObj.Dto.ServiceCode);
                if (extObj.Dto.IsCancel) //取消服务项目
                {
                    await repoServiceItem.DeleteAsync(serv);
                }
                else //增加服务项目
                {
                    if (serv == null)
                    {
                        serv = new BookingServiceItem();
                        serv.Id = YitIdHelper.NextId();
                        serv.BookingId = extObj.OrderId;
                        serv.Code = extObj.Dto.ServiceCode;
                        serv.Value = serItm.Value;
                        await repoServiceItem.InsertAsync(serv);
                    }
                }
            }


            ChangeServiceItemResponseDto respDto = new ChangeServiceItemResponseDto();
            respDto.Dto = extObj.Dto;
            respDto.AuditName = msg.ProcUser;
            respDto.IsReject = msg.ProcStatus == MessageProcessStatus.Reject.ToString();
            respDto.ProcResult = msg.ProcResult;

            //回推回执
            var feedbackObj = new BookingFeedbackDto(BookingFeedbackType.ServiceItemAudit.ToString());
            feedbackObj.JsonContent = respDto.ToJsonString();

            _logger.LogInformation($"准备回推服务项目修改审核到客户订舱系统：{feedbackObj.JsonContent}，URL：{custOrder.FeedbackUrl}");

            var rtn = await custOrder.FeedbackUrl
                 .SetHeaders(new Dictionary<string, object> {
                    { CommonConst.API_USER_HEADER_KEY, custOrder.FeedbackKey},
                    { CommonConst.API_USER_HEADER_SECRET, custOrder.FeedbackSecret}
                 })
                 .SetBody(feedbackObj, "application/x-www-form-urlencoded")
                 .PostAsStringAsync();

            _logger.LogInformation($"回推服务项目修改审核：{rtn}");

            var jobjRtn = JObject.Parse(rtn);
            if (jobjRtn.GetIntValue("code") != 200)
            {
                throw Oops.Bah(jobjRtn.GetStringValue("message"));
            }

        }

        //运营端处理了单证补料的消息的回推消息
        [EventSubscribe("Message:Process:Booking:DocSupplement")]
        public async Task MessageProcessBookingDocSupplement(EventHandlerExecutingContext context)
        {
            _logger.LogInformation($"收到回推单证补料审核到客户订舱系统：{context.Source.Payload}");
            var msgId = (long)context.Source.Payload;

            using var scope = _services.CreateScope();
            var repMessage = scope.ServiceProvider.GetRequiredService<SqlSugarRepository<DjyMessage>>();
            var repoCutomerOrder = scope.ServiceProvider.GetRequiredService<SqlSugarRepository<BookingCustomerOrder>>();
            var repoOrder = scope.ServiceProvider.GetRequiredService<SqlSugarRepository<BookingOrder>>();
            var repoServiceItem = scope.ServiceProvider.GetRequiredService<SqlSugarRepository<BookingServiceItem>>();
            var cacheService = scope.ServiceProvider.GetRequiredService<ISysCacheService>();
            var _repBookingfile = scope.ServiceProvider.GetRequiredService<SqlSugarRepository<BookingFile>>();
            var _repStatuslog = scope.ServiceProvider.GetRequiredService<SqlSugarRepository<BookingStatusLog>>();

            var msg = await repMessage.AsQueryable().Filter(null, true).FirstAsync(x => x.Id == msgId);
            var extObj = JsonConvert.DeserializeObject<DocSupplementExtModel>(msg.ExtData);
            var custOrder = await repoCutomerOrder.AsQueryable().Filter(null, true).FirstAsync(x => x.Id == extObj.CustomerOrderId);
            var order = await repoOrder.AsQueryable().Filter(null, true).FirstAsync(x => x.Id == extObj.OrderId);

            if (msg.ProcStatus == MessageProcessStatus.Accept.ToString())
            {
                //进入订舱附件
                foreach (var ff in extObj.Dto.FileList)
                {
                    var fileSuffix = Path.GetFileName(ff.FileName);
                    var id = YitIdHelper.NextId();
                    var newFile = new BookingFile
                    {
                        Id = id,
                        FileName = ff.FileName,
                        FilePath = ff.FilePath,
                        TypeCode = ff.TypeCode,
                        TypeName = ff.TypeName,
                        BookingId = extObj.OrderId,
                        TenantId = order.TenantId,
                        TenantName = order.TenantName,
                    };
                    await _repBookingfile.InsertAsync(newFile);

                    ff.Id = id; //赋值id，回传给客户端
                }
            }

            //记录日志
            var staLog = new BookingStatusLog();
            staLog.Status = $"审核{(msg.ProcStatus == MessageProcessStatus.Accept.ToString() ? "通过" : "驳回")}单证补料";
            staLog.CreatedUserId = order.CreatedUserId;
            staLog.CreatedUserName = msg.ProcUser;
            staLog.CreatedTime = DateTime.Now;
            staLog.OpTime = DateTime.Now;
            staLog.BookingId = order.Id;
            staLog.Category = "doc_supplement";
            staLog.TenantId = order.TenantId;
            _repStatuslog.Insert(staLog);

            DocSupplementResponseDto respDto = new DocSupplementResponseDto();
            respDto.Dto = extObj.Dto;
            respDto.AuditName = msg.ProcUser;
            respDto.IsReject = msg.ProcStatus == MessageProcessStatus.Reject.ToString();
            respDto.ProcResult = msg.ProcResult;

            //回推回执
            var feedbackObj = new BookingFeedbackDto(BookingFeedbackType.DocSupplementAudit.ToString());
            feedbackObj.JsonContent = respDto.ToJsonString();

            _logger.LogInformation($"准备回推单证补料审核到客户订舱系统：{feedbackObj.JsonContent}，URL：{custOrder.FeedbackUrl}");

            var rtn = await custOrder.FeedbackUrl
                 .SetHeaders(new Dictionary<string, object> {
                    { CommonConst.API_USER_HEADER_KEY, custOrder.FeedbackKey},
                    { CommonConst.API_USER_HEADER_SECRET, custOrder.FeedbackSecret}
                 })
                 .SetBody(feedbackObj, "application/x-www-form-urlencoded")
                 .PostAsStringAsync();

            _logger.LogInformation($"回推单证补料审核：{rtn}");

            var jobjRtn = JObject.Parse(rtn);
            if (jobjRtn.GetIntValue("code") != 200)
            {
                throw Oops.Bah(jobjRtn.GetStringValue("message"));
            }

        }

        //运营端手工选中或取消服务项目的回推消息
        [EventSubscribe("ServiceItem:ChangeNotify")]
        public async Task BookingServiceItemChangeNotify(EventHandlerExecutingContext context)
        {
            _logger.LogInformation($"收到回推服务项目手工修改的通知到客户订舱系统：{context.Source.Payload}");
            var dto = context.Source.Payload as DjyChangeServiceItemDto;

            using var scope = _services.CreateScope();
            var repoCutomerOrder = scope.ServiceProvider.GetRequiredService<SqlSugarRepository<BookingCustomerOrder>>();
            var repoOrder = scope.ServiceProvider.GetRequiredService<SqlSugarRepository<BookingOrder>>();
            var repoServiceItem = scope.ServiceProvider.GetRequiredService<SqlSugarRepository<BookingServiceItem>>();
            var cacheService = scope.ServiceProvider.GetRequiredService<ISysCacheService>();

            var bookId = Convert.ToInt64(dto.Id);
            var custOrder = await repoCutomerOrder.AsQueryable().Filter(null, true).FirstAsync(x => x.BookingId == bookId);
            var order = await repoOrder.AsQueryable().Filter(null, true).FirstAsync(x => x.Id == bookId);

            dto.Id = order.BSNO; //将运营端系统的id转为客户系统的id

            //回推回执
            var feedbackObj = new BookingFeedbackDto(BookingFeedbackType.ServiceItemChange.ToString());
            feedbackObj.JsonContent = dto.ToJsonString();

            _logger.LogInformation($"准备回推服务项目手工修改的通知到客户订舱系统：{feedbackObj.JsonContent}，URL：{custOrder.FeedbackUrl}");

            var rtn = await custOrder.FeedbackUrl
                 .SetHeaders(new Dictionary<string, object> {
                    { CommonConst.API_USER_HEADER_KEY, custOrder.FeedbackKey},
                    { CommonConst.API_USER_HEADER_SECRET, custOrder.FeedbackSecret}
                 })
                 .SetBody(feedbackObj, "application/x-www-form-urlencoded")
                 .PostAsStringAsync();

            _logger.LogInformation($"回推服务项目项目手工修改的通知：{rtn}");

            var jobjRtn = JObject.Parse(rtn);
            if (jobjRtn.GetIntValue("code") != 200)
            {
                throw Oops.Bah(jobjRtn.GetStringValue("message"));
            }

        }


        //推送订舱批量订舱编号到客户订舱系统
        [EventSubscribe("SendToCustomer:MultiCustNO")]
        public async Task SendCustomerMultiCustNOSync(EventHandlerExecutingContext context)
        {
            _logger.LogInformation($"收到推送订舱批量订舱编号到客户订舱系统请求：{context.Source.Payload.ToString()}");

            var dto = context.Source.Payload as BookingCustomerMultiCustNODto;

            using var scope = _services.CreateScope();
            var repoCutomerOrder = scope.ServiceProvider.GetRequiredService<SqlSugarRepository<BookingCustomerOrder>>();
            var repoOrder = scope.ServiceProvider.GetRequiredService<SqlSugarRepository<BookingOrder>>();
            var repoCtn = scope.ServiceProvider.GetRequiredService<SqlSugarRepository<BookingCtn>>();
            //var repoFile = scope.ServiceProvider.GetRequiredService<SqlSugarRepository<BookingFile>>();
            var servCustOrder = scope.ServiceProvider.GetRequiredService<BookingCustomerOrderService>();

            //var repoStaLog = scope.ServiceProvider.GetRequiredService<SqlSugarRepository<BookingStatusLog>>();
            //var repoStaLogDetail = scope.ServiceProvider.GetRequiredService<SqlSugarRepository<BookingStatusLogDetail>>();
            //var repoGoodsSta = scope.ServiceProvider.GetRequiredService<SqlSugarRepository<BookingGoodsStatus>>();
            //var repoGoodsStaCfg = scope.ServiceProvider.GetRequiredService<SqlSugarRepository<BookingGoodsStatusConfig>>();
            //var repoLog = scope.ServiceProvider.GetRequiredService<SqlSugarRepository<BookingLog>>();
            //var repoLogDetail = scope.ServiceProvider.GetRequiredService<SqlSugarRepository<BookingLogDetail>>();

            //var cacheService = scope.ServiceProvider.GetRequiredService<ISysCacheService>();

            var custOrder = await repoCutomerOrder.AsQueryable().Filter(null, true).FirstAsync(x => x.BSNO == dto.Id);
            if (custOrder == null) //非客户订舱系统过来的数据
            {
                _logger.LogInformation($"ID为 {dto.Id} 的数据并非来自客户订舱系统，不继续处理数据回推");
                return;
            }

            var ctns = await repoCtn.AsQueryable().Filter(null, true).Where(x => x.IsDeleted == false && x.BILLID == custOrder.Id).ToListAsync();

            if (string.IsNullOrEmpty(custOrder.FeedbackUrl))
            {
                _logger.LogInformation($"ID为 {dto.Id} 的数据未提供回推接口URL，不继续处理数据回推");
                return;
            }

            var feedbackObj = new BookingFeedbackDto(BookingFeedbackType.OneToMulti.ToString());
            feedbackObj.JsonContent = dto.ToJsonString();

            //回推回执
            _logger.LogInformation($"准备发送多订舱编号数据同步：{feedbackObj.ToJsonString()}，URL：{custOrder.FeedbackUrl}");

            var rtn = await custOrder.FeedbackUrl
                 .SetHeaders(new Dictionary<string, object> {
                    { CommonConst.API_USER_HEADER_KEY, custOrder.FeedbackKey},
                    { CommonConst.API_USER_HEADER_SECRET, custOrder.FeedbackSecret}
                 })
                 .SetBody(feedbackObj, "application/x-www-form-urlencoded")
                 .PostAsStringAsync();

            _logger.LogInformation($"回推多订舱编号返回：{rtn}");

            var jobjRtn = JObject.Parse(rtn);
            if (jobjRtn.GetIntValue("code") != 200)
            {
                throw Oops.Bah(jobjRtn.GetStringValue("message"));
            }
            else
            {
                var dataResp = jobjRtn.GetJArrayValue("data");
                var parentBookingNO = custOrder.BOOKINGNO;

                foreach (JObject item in dataResp)
                {
                    //生成id并插入客户订舱数据
                    custOrder.Id = YitIdHelper.NextId();
                    custOrder.BOOKINGNO = item.GetStringValue("BookingNO");
                    custOrder.BSNO = item.GetStringValue("custOrderId");
                    custOrder.ParentBookingNO = parentBookingNO;
                    JObject jobjExt = null;
                    if (!string.IsNullOrEmpty(custOrder.ExtendData))
                    {
                        jobjExt = JObject.Parse(custOrder.ExtendData);
                    }
                    else
                    {
                        jobjExt = new JObject();
                    }

                    jobjExt["CustNO"] = item.GetStringValue("CustNO");
                    custOrder.ExtendData = jobjExt.ToString();

                    await repoCutomerOrder.InsertAsync(custOrder);

                    foreach (var ctn in ctns)
                    {
                        ctn.Id = YitIdHelper.NextId();
                        ctn.BILLID = custOrder.Id;
                        await repoCtn.InsertAsync(ctn);
                    }

                    _logger.LogInformation($"根据客户订舱反馈数据 {custOrder.BSNO} 生成了相同的数据 {custOrder.Id}");

                    //插入订舱台账
                    var ord = await servCustOrder.CustomerToOrder(custOrder);
                    custOrder.BookingId = ord.Id;
                    await repoCutomerOrder.AsUpdateable(custOrder).UpdateColumns(x => new { x.BookingId }).ExecuteCommandAsync();

                    //订舱编号和客户端BSNO
                    ord.BSNO = item.GetStringValue("orderId");
                    ord.CUSTNO = item.GetStringValue("custNO");
                    ord.CUSTOMERNAME = custOrder.BookingTenantName;
                    ord.LANENAME = ord.LANECODE;
                    await repoOrder.AsUpdateable(ord).UpdateColumns(x => new { x.BSNO, x.CUSTOMERNAME, x.LANENAME }).ExecuteCommandAsync();

                    _logger.LogInformation($"生成了订舱台账数据 {ord.Id}");

                }
            }

        }
        #endregion

        #region 客户端事件
        //推送服务项目变动到运营端
        [EventSubscribe("ServiceItem:ChangeSubmit")]
        public async Task SendServiceItemChangeSubmit(EventHandlerExecutingContext context)
        {
            _logger.LogInformation($"收到推送服务项目变动到运营端订舱系统：{context.Source.Payload}");
            var dto = context.Source.Payload as ChangeServiceItemDto;
            if (dto != null)
            {
                using var scope = _services.CreateScope();
                var _cache = scope.ServiceProvider.GetRequiredService<ISysCacheService>();

                //当前系统的url
                var sysUrlCfg = _cache.GetAllSysConfig().Result.FirstOrDefault(x => x.Code == "SystemUrl");
                var sysUrl = sysUrlCfg.Value;
                if (!sysUrl.EndsWith("/"))
                {
                    sysUrl += "/";
                }

                var recUrl = _cache.GetAllSysConfig().Result.FirstOrDefault(x => x.Code == "DjyBookingRequestReceiveUrl");
                if (recUrl == null || string.IsNullOrEmpty(recUrl.Value))
                {
                    throw Oops.Bah("大简云接收订舱URL地址未配置，请联系管理员");
                }

                var userId = _cache.GetAllSysConfig().Result.FirstOrDefault(x => x.Code == "DjyBookingReceiveUserId");
                var userSecret = _cache.GetAllSysConfig().Result.FirstOrDefault(x => x.Code == "DjyBookingReceiveUserSecret");
                if (userId == null || string.IsNullOrEmpty(userId.Value) || userSecret == null || string.IsNullOrEmpty(userSecret.Value))
                {
                    throw Oops.Bah("大简云接收订舱用户key和秘钥未配置，请联系管理员");
                }

                //构建完整url
                var submitUrl = recUrl.Value;
                if (!submitUrl.EndsWith("/"))
                {
                    submitUrl += "/";
                }

                submitUrl += "BookingCustomerOrder/ChangeServiceItem";

                _logger.LogInformation($"提交修改服务项目数据（{submitUrl}，{userId.Value}，{userSecret.Value}）：{JsonConvert.SerializeObject(dto)}");

                var rtn = await submitUrl
                     .SetHeaders(new Dictionary<string, object> {
                    { CommonConst.API_USER_HEADER_KEY, userId.Value},
                    { CommonConst.API_USER_HEADER_SECRET, userSecret.Value}
                     })
                     .SetBody(dto)
                     .PostAsStringAsync();

                _logger.LogInformation($"返回数据：{rtn}");

                var resultText = new StringBuilder();
                var jobjRtn = JObject.Parse(rtn);
                if (jobjRtn.GetIntValue("code") != 200)
                {
                    throw Oops.Bah(jobjRtn.GetStringValue("message"));
                }
            }
        }

        //推送货物状态通知给订阅人
        [EventSubscribe("GoodsStatusSubscribeNotify:Book")]
        public async Task GoodsStatusSubscribeNotify(EventHandlerExecutingContext context)
        {
            _logger.LogInformation($"收到推送货物状态通知请求：{context.Source.Payload}");

            dynamic payload = context.Source.Payload;
            long bookId = payload.BookingId;
            string statusCode = payload.StatusCode;
            string statusName = payload.StatusName;

            using var scope = _services.CreateScope();
            var cache = scope.ServiceProvider.GetRequiredService<ISysCacheService>();
            var repoOrder = scope.ServiceProvider.GetRequiredService<SqlSugarRepository<BookingOrder>>();
            var repoBookingGoodsStatusSubscribe = scope.ServiceProvider.GetRequiredService<SqlSugarRepository<BookingGoodsStatusSubscribe>>();

            var order = await repoOrder.AsQueryable().Filter(null, true).FirstAsync(x => x.Id == bookId);

            var subList = await repoBookingGoodsStatusSubscribe.AsQueryable().Filter(null, true).Where(x => x.IsDeleted == false && x.BookingId == bookId).ToListAsync();
            foreach (var sub in subList)
            {
                if (sub.SendMail && !string.IsNullOrEmpty(sub.Email) && sub.StatusCode.Split(',').Contains(statusCode))
                {
                    var subject = $"大简云-货物通知：{order.MBLNO}---{order.VESSEL}/{order.VOYNO}{statusName}";
                    var body = $"尊敬的客户，您好：<br/><br/>您所订阅的提单号{order.MBLNO} ，船名航次{order.VESSEL}/{order.VOYNO}的业务{statusName}。<br/><br/>—— 此邮件为大简云平台自动发送，请勿回复。<br/><br/><img src='https://wechat.myshipping.net:8860/wechat_image/banner.png' style='width:300px;'/>";

                    var sendUrlCfg = cache.GetAllDictData().Result.FirstOrDefault(x => x.Code == "email_api_url");
                    if (sendUrlCfg == null)
                    {
                        _logger.LogError($"未配置邮件发送URL，推送货物状态通知邮件未能发送。订舱ID：{bookId}，状态：{statusName}({statusCode})，邮箱：{sub.Email}");
                    }

                    var mailJson = new dynamic[]{
                                 new
                                {
                                    SendTo = sub.Email,
                                    Title = subject,
                                    Body = body,
                                    SmtpConfig = "SERVICE"
                                }
                             };
                    var mailStr = mailJson.ToJsonString();

                    _logger.LogInformation($"准备推送货物状态邮件通知，JSON：{mailStr}，订舱ID：{bookId}，状态：{statusName}({statusCode})，邮箱：{sub.Email}");

                    var rtn = await sendUrlCfg.Value
                             .SetBody(mailStr)
                             .PostAsStringAsync();

                    _logger.LogError($"推送货物状态通知邮件发送返回：{rtn}。订舱ID：{bookId}，状态：{statusName}({statusCode})，邮箱：{sub.Email}");

                    var jsonRtn = JObject.Parse(rtn);
                    if (jsonRtn.GetBooleanValue("Success"))
                    {
                        _logger.LogInformation($"推送货物状态通知邮件发送成功。订舱ID：{bookId}，状态：{statusName}({statusCode})，邮箱：{sub.Email}");
                    }
                    else
                    {
                        _logger.LogError($"推送货物状态通知邮件发送失败：{jsonRtn.GetStringValue("Message")}。订舱ID：{bookId}，状态：{statusName}({statusCode})，邮箱：{sub.Email}。");
                    }

                }

            }
        }
        #endregion
    }
}