修改新增重要提醒任务

Myshipping.Application/Enum/CautionNoticeTaskEnum.cs

@@ -0,0 +1,40 @@
+using System;
+using System.Collections.Generic;
+using System.ComponentModel;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace Myshipping.Application
+{
+    /// <summary>
+    /// 重要提醒任务类型枚举
+    /// </summary>
+    public enum CautionNoticeTaskEnum
+    {
+        /// <summary>
+        /// 计费周差异
+        /// </summary>
+        [Description("计费周差异")]
+        WeekAt,
+        /// <summary>
+        /// 计费日期差异
+        /// </summary>
+        [Description("计费日期差异")]
+        PriceCalcDate
+    }
+
+    public enum CautionNoticeTypeEnum
+    {
+        /// <summary>
+        /// 钉钉消息
+        /// </summary>
+        [Description("钉钉消息")]
+        DingDing,
+        /// <summary>
+        /// 邮件提醒
+        /// </summary>
+        [Description("邮件提醒")]
+        Email
+    }
+}

Myshipping.Application/Event/CautionNoticeTaskSubscriber.cs

@@ -0,0 +1,162 @@
+using Furion;
+using Furion.DependencyInjection;
+using Furion.DistributedIDGenerator;
+using Furion.EventBus;
+using Furion.FriendlyException;
+using Furion.JsonSerialization;
+using MathNet.Numerics.LinearAlgebra.Factorization;
+using Microsoft.Extensions.DependencyInjection;
+using Microsoft.Extensions.Logging;
+using Myshipping.Application.Entity;
+using Myshipping.Core;
+using NPOI.SS.Formula.Functions;
+using System;
+using System.Collections.Generic;
+using System.ComponentModel;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace Myshipping.Application.Event
+{
+    /// <summary>
+    /// 重要通知任务订阅
+    /// </summary>
+    public class CautionNoticeTaskSubscriber : IEventSubscriber
+    {
+        private IServiceProvider _services { get; }
+        private readonly ILogger<CautionNoticeTaskSubscriber> _logger;
+        private readonly INamedServiceProvider<ITaskManageService> _namedTaskManageServiceProvider;
+
+        public CautionNoticeTaskSubscriber(IServiceProvider services, ILogger<CautionNoticeTaskSubscriber> logger,
+            INamedServiceProvider<ITaskManageService> namedTaskManageServiceProvider)
+        {
+            _services = services;
+            _logger = logger;
+
+            _namedTaskManageServiceProvider = namedTaskManageServiceProvider;
+
+        }
+
+        /// <summary>
+        /// 新增重要通知任务
+        /// </summary>
+        /// <param name="context">订阅上下文</param>
+        /// <returns></returns>
+        [EventSubscribe("CautionNoticeTask:Add")]
+        public async Task CautionNoticeTaskAdd(EventHandlerExecutingContext context)
+        {
+            _logger.LogInformation($"收到更新订阅请求：{context.Source.Payload}");
+
+            var paraObj = context.Source.Payload;
+
+            using var scope = _services.CreateScope();
+
+            var bookingRepo = scope.ServiceProvider.GetRequiredService<SqlSugarRepository<BookingOrder>>();
+            var bookingSlotRepo = scope.ServiceProvider.GetRequiredService<SqlSugarRepository<BookingSlotBase>>();
+
+            var service = _namedTaskManageServiceProvider.GetService(nameof(TaskManageService));
+
+            DateTime nowDate = DateTime.Now;
+            /*
+             1、生成重要提醒任务
+             2、先从订舱订单提取操作OP和销售OP，推送钉钉和邮件提醒。
+             3、如果没有订舱订单，可以从舱位获取操作OP，推送钉钉和邮件提醒。
+             */
+
+            CautionNoticeTaskDto dto = GetInfo(paraObj);
+
+            //生成任务
+            if (dto.cautionNoticeType == CautionNoticeTaskEnum.WeekAt)
+            {
+                TaskManageOrderMessageInfo messageInfo = new TaskManageOrderMessageInfo
+                {
+                    Head = new TaskManageOrderMessageHeadInfo
+                    {
+                        GID = IDGen.NextID().ToString(),
+                        MessageType = "CAUTION_TASK",
+                        SenderId = "CautionNoticeTask",
+                        SenderName = "重要提醒任务生成",
+                        ReceiverId = "TaskManage",
+                        ReceiverName = "任务台",
+                        RequestDate = nowDate.ToString("yyyy-MM-dd HH:mm:ss.fff"),
+                        Version = "1.0",
+                        RequestAction = "Add"
+                    },
+                    Main = new TaskManageOrderMessageMainInfo
+                    {
+                        TaskType = TaskBaseTypeEnum.CAUTION_NOTICE,
+                    }
+                };
+
+                BookingSlotBase slotInfo = null;
+                BookingOrder bookingOrder = null;
+
+                string mblNo = string.Empty;
+                string vesselVoyno = string.Empty;
+                string etd = string.Empty;
+
+                if (dto.bookingSlotId > 0)
+                {
+                    slotInfo = bookingSlotRepo.AsQueryable().Filter(null, true).First(x => x.Id == dto.bookingSlotId);
+                }
+
+                if (dto.bookingId > 0)
+                {
+                    bookingOrder = bookingRepo.AsQueryable().Filter(null, true).First(x => x.Id == dto.bookingId);
+                }
+
+                messageInfo.Main.TaskTenatId = slotInfo.TenantId;
+                messageInfo.Main.TaskTenatName = slotInfo.TenantName;
+
+                if (slotInfo != null)
+                {
+                    if (slotInfo.CARRIERID.Equals("MSK", StringComparison.OrdinalIgnoreCase))
+                    {
+                        mblNo = slotInfo.SLOT_BOOKING_NO;
+                        messageInfo.Main.MBlNo = slotInfo.SLOT_BOOKING_NO;
+                        messageInfo.Main.ETD = slotInfo.ETD;
+
+                        vesselVoyno = $"{(slotInfo.VESSEL ?? "")}/{slotInfo.VOYNO ?? ""}";
+
+                        messageInfo.Main.VesselVoyno = vesselVoyno;
+                        messageInfo.Main.TaskUserId = dto.userId.ToString();
+                        messageInfo.Main.TaskUserName = dto.userName;
+                        messageInfo.Main.CarrierId = slotInfo.CARRIERID;
+                    }
+                }
+
+                if (bookingOrder != null)
+                {
+                    messageInfo.Main.CustomerId = bookingOrder.CUSTOMERID;
+                    messageInfo.Main.CustomerName = bookingOrder.CUSTOMERNAME;
+                }
+
+                messageInfo.Main.TaskTitle = $"重要提醒-计费周发生变更 {vesselVoyno} {etd} BLNo:{mblNo}";
+                messageInfo.Main.TaskDesp = $"重要提醒-计费周发生变更 {vesselVoyno} {etd} BLNo:{mblNo}";
+
+                var rlt = await service.CreateTaskJob(messageInfo);
+            }
+        }
+
+        private CautionNoticeTaskDto GetInfo(object payload)
+        {
+            CautionNoticeTaskDto dto = null;
+
+            try
+            {
+                dto = JSON.Deserialize<CautionNoticeTaskDto>(JSON.Serialize(payload));
+            }
+            catch(Exception ex)
+            {
+                _logger.LogInformation($"解析订阅参数失败，原因：{ex.Message}");
+
+                throw Oops.Bah($"解析订阅参数失败，原因：{ex.Message}");
+            }
+
+            return dto;
+        }
+    }
+
+    
+}

Myshipping.Application/Service/BookingSlot/BookingSlotService.cs

@@ -63,6 +63,7 @@ namespace Myshipping.Application
         private readonly IDjyCustomerService _djyCustomerService;
         private readonly IBookingValueAddedService _bookingValueAddedService;
         private readonly IBookingLabelService _bookingLabelService;
+        
 
         const string CONST_BC_FILE_CODE = "bc";
         const string CONST_BC_FILE_NAME = "Booking Confirmation";
@@ -92,6 +93,7 @@ namespace Myshipping.Application
             SqlSugarRepository<BookingSlotCompare> bookingSlotCompareRepository,
             SqlSugarRepository<BookingOrderContact> bookingOrderContactRepository,
             INamedServiceProvider<IBookingOrderService> namedBookingOrderServiceProvider,
+            
             IBookingValueAddedService bookingValueAddedService,
             SqlSugarRepository<BookingOrder> repBookingOrder,
             SqlSugarRepository<BookingLabelAllocation> repLabelAllocation,
@@ -119,6 +121,8 @@ namespace Myshipping.Application
             _repBookingOrder = repBookingOrder;
             _repLabelAllocation = repLabelAllocation;
             _bookingLabelService = bookingLabelService;
+
+            
         }
 
         #region 舱位
@@ -722,6 +726,9 @@ namespace Myshipping.Application
                     TaskBCInfoDto bcSrcDto = model.Adapt<TaskBCInfoDto>();
                     TaskBCInfoDto bcTargetDto = dto.DataObj.Adapt<TaskBCInfoDto>();
 
+                    //执行差异重要提醒
+                    //await MeasureDiffCautionTask(bcSrcDto, bcTargetDto, model.Id);
+
                     //提取箱信息
                     var ctnList = _repCtn.AsQueryable().Filter(null, true)
                         .Where(x => x.IsDeleted == false && x.TenantId.Value == UserManager.TENANT_ID
@@ -2145,6 +2152,113 @@ namespace Myshipping.Application
 
             return result;
         }
+
+        #region 估算差异重要提醒
+        /// <summary>
+        /// 估算差异重要提醒
+        /// </summary>
+        /// <param name="bcSrcDto">原舱位详情</param>
+        /// <param name="bcTargetDto">新舱位详情</param>
+        /// <param name="slotId">舱位ID</param>
+        /// <returns></returns>
+        [NonAction]
+        public async Task MeasureDiffCautionTask(TaskBCInfoDto bcSrcDto, TaskBCInfoDto bcTargetDto, long slotId)
+        {
+            if (bcSrcDto.CarrierId.Equals("MSK", StringComparison.OrdinalIgnoreCase))
+            {
+                string srcWeek = bcSrcDto.WeekAt ?? "";
+                string targetWeek = bcTargetDto.WeekAt ?? "";
+
+                //如果计费周不一致需要推送推送任务台生成重要提醒
+                if (!srcWeek.Equals(targetWeek, StringComparison.OrdinalIgnoreCase))
+                {
+                    var bookingList = _repAllocation.AsQueryable().Filter(null, true)
+                        .Where(x => x.BOOKING_SLOT_ID == slotId && x.IsDeleted == false && x.TenantId == UserManager.TENANT_ID).ToList();
+
+                    if (bookingList.Count > 0)
+                    {
+                        bookingList.ForEach(async ca =>
+                        {
+                            await _publisher.PublishAsync(new ChannelEventSource("CautionNoticeTask:Add",
+                                new CautionNoticeTaskDto
+                                {
+                                    cautionNoticeType = CautionNoticeTaskEnum.WeekAt,
+                                    bookingId = ca.BOOKING_ID,
+                                    bookingSlotId = ca.BOOKING_SLOT_ID,
+                                    createTime = DateTime.Now,
+                                    origVal = srcWeek,
+                                    newVal = targetWeek,
+                                    tenentId = UserManager.TENANT_ID,
+                                    userId = UserManager.UserId,
+                                    userName = UserManager.Name,
+                                }));
+
+                        });
+                    }
+                    else
+                    {
+                        await _publisher.PublishAsync(new ChannelEventSource("CautionNoticeTask:Add",
+                                new CautionNoticeTaskDto
+                                {
+                                    cautionNoticeType = CautionNoticeTaskEnum.WeekAt,
+                                    bookingSlotId = slotId,
+                                    createTime = DateTime.Now,
+                                    origVal = srcWeek,
+                                    newVal = targetWeek,
+                                    tenentId = UserManager.TENANT_ID,
+                                    userId = UserManager.UserId,
+                                    userName = UserManager.Name,
+                                }));
+                    }
+                }
+
+                string srcPriceCalcDate = bcSrcDto.PriceCalculationDate.HasValue ? bcSrcDto.PriceCalculationDate.Value.ToString("yyyy-MM-dd") : "";
+                string targePriceCalcDate = bcTargetDto.PriceCalculationDate.HasValue ? bcTargetDto.PriceCalculationDate.Value.ToString("yyyy-MM-dd") : "";
+
+                if (!srcPriceCalcDate.Equals(targePriceCalcDate, StringComparison.OrdinalIgnoreCase))
+                {
+                    var bookingList = _repAllocation.AsQueryable().Filter(null, true)
+                        .Where(x => x.BOOKING_SLOT_ID == slotId && x.IsDeleted == false && x.TenantId == UserManager.TENANT_ID).ToList();
+
+                    if (bookingList.Count > 0)
+                    {
+                        bookingList.ForEach(async ca =>
+                        {
+                            await _publisher.PublishAsync(new ChannelEventSource("CautionNoticeTask:Add",
+                                new CautionNoticeTaskDto
+                                {
+                                    cautionNoticeType = CautionNoticeTaskEnum.PriceCalcDate,
+                                    bookingId = ca.BOOKING_ID,
+                                    bookingSlotId = ca.BOOKING_SLOT_ID,
+                                    createTime = DateTime.Now,
+                                    origVal = srcWeek,
+                                    newVal = targetWeek,
+                                    tenentId = UserManager.TENANT_ID,
+                                    userId = UserManager.UserId,
+                                    userName = UserManager.Name,
+                                }));
+
+                        });
+                    }
+                    else
+                    {
+                        await _publisher.PublishAsync(new ChannelEventSource("CautionNoticeTask:Add",
+                                new CautionNoticeTaskDto
+                                {
+                                    cautionNoticeType = CautionNoticeTaskEnum.PriceCalcDate,
+                                    bookingSlotId = slotId,
+                                    createTime = DateTime.Now,
+                                    origVal = srcWeek,
+                                    newVal = targetWeek,
+                                    tenentId = UserManager.TENANT_ID,
+                                    userId = UserManager.UserId,
+                                    userName = UserManager.Name,
+                                }));
+                    }
+                }
+            }
+        }
+        #endregion
     }
 
 

Myshipping.Application/Service/BookingSlot/Dto/BookingSlotMapper.cs

@@ -42,7 +42,8 @@ namespace Myshipping.Application
             .Map(dest => dest.PortDischarge, src => src.PORTDISCHARGE)
             .Map(dest => dest.Portload, src => src.PORTLOAD)
             .Map(dest => dest.TransferPort1, src => src.TRANSFER_PORT_1)
-            .Map(dest => dest.TransferPort2, src => src.TRANSFER_PORT_2);
+            .Map(dest => dest.TransferPort2, src => src.TRANSFER_PORT_2)
+            .Map(dest => dest.PriceCalculationDate, src => src.PRICE_CALCULATION_DATE);
 
             config.ForType<BookingSlotBaseApiSaveDto, TaskBCInfoDto>()
             .Map(dest => dest.CarrierId, src => src.CARRIERID)
@@ -73,7 +74,8 @@ namespace Myshipping.Application
             .Map(dest => dest.PortDischarge, src => src.PORTDISCHARGE)
             .Map(dest => dest.Portload, src => src.PORTLOAD)
             .Map(dest => dest.TransferPort1, src => src.TRANSFER_PORT_1)
-            .Map(dest => dest.TransferPort2, src => src.TRANSFER_PORT_2);
+            .Map(dest => dest.TransferPort2, src => src.TRANSFER_PORT_2)
+            .Map(dest => dest.PriceCalculationDate, src => src.PRICE_CALCULATION_DATE);
 
             config.ForType<TaskBCInfoReadDto, TaskBCInfoDto>()
             .Map(dest => dest.CarrierId, src => src.CarrierId)

Myshipping.Application/Service/BookingSlot/IBookingSlotService.cs

@@ -153,5 +153,14 @@ namespace Myshipping.Application
         /// <param name="reqBatchNo">请求批次号用来区分对应的哪个批次任务</param>
         /// <returns></returns>
         Task PushCompareBCInfo(TaskBCInfoDto bcSrcDto, TaskBCInfoDto bcTargetDto, long slotId, string reqBatchNo);
+
+        /// <summary>
+        /// 估算差异重要提醒
+        /// </summary>
+        /// <param name="bcSrcDto">原舱位详情</param>
+        /// <param name="bcTargetDto">新舱位详情</param>
+        /// <param name="slotId">舱位ID</param>
+        /// <returns></returns>
+        Task MeasureDiffCautionTask(TaskBCInfoDto bcSrcDto, TaskBCInfoDto bcTargetDto, long slotId);
     }
 }

Myshipping.Application/Service/TaskManagePlat/Dtos/CautionNoitce/CautionNoticeTaskDto.cs

@@ -0,0 +1,61 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace Myshipping.Application
+{
+    public class CautionNoticeTaskDto
+    {
+        /// <summary>
+        /// WeekAt-计费周差异 PriceCalcDate-计费周差异
+        /// </summary>
+        public CautionNoticeTaskEnum cautionNoticeType { get; set; }
+
+        /// <summary>
+        /// 订舱ID
+        /// </summary>
+        public Nullable<long> bookingId { get; set; }
+
+        /// <summary>
+        /// 舱位ID
+        /// </summary>
+        public Nullable<long> bookingSlotId { get; set; }
+
+        /// <summary>
+        /// 任务ID
+        /// </summary>
+        public string taskPKId { get; set; }
+
+        /// <summary>
+        /// 创建日期
+        /// </summary>
+        public DateTime createTime { get; set; }
+
+        /// <summary>
+        /// 原值
+        /// </summary>
+        public string origVal { get; set; }
+
+        /// <summary>
+        /// 新值
+        /// </summary>
+        public string newVal { get; set; }
+
+        /// <summary>
+        /// 租户ID
+        /// </summary>
+        public long tenentId { get; set; }
+
+        /// <summary>
+        /// 用户ID
+        /// </summary>
+        public long userId { get; set; }
+
+        /// <summary>
+        /// 用户名称
+        /// </summary>
+        public string userName { get; set; }
+    }
+}

Myshipping.Application/Service/TaskManagePlat/Dtos/CautionNoitce/TaskManageOrderCautionNoticeInfo.cs

@@ -0,0 +1,72 @@
+using System;
+using System.Collections.Generic;
+using System.Linq;
+using System.Text;
+using System.Threading.Tasks;
+
+namespace Myshipping.Application
+{
+    public class TaskManageOrderCautionNoticeInfo
+    {
+        /// <summary>
+        /// WeekAt-计费周差异 PriceCalcDate-计费周差异
+        /// </summary>
+        public CautionNoticeTaskEnum CautionNoticeType { get; set; }
+
+        /// <summary>
+        /// 订舱ID
+        /// </summary>
+        public Nullable<long> BookingId { get; set; }
+
+        /// <summary>
+        /// 舱位ID
+        /// </summary>
+        public Nullable<long> BookingSlotId { get; set; }
+
+        /// <summary>
+        /// 任务ID
+        /// </summary>
+        public string TaskPKId { get; set; }
+
+        /// <summary>
+        /// 创建日期
+        /// </summary>
+        public DateTime CreateTime { get; set; }
+
+        /// <summary>
+        /// 原值
+        /// </summary>
+        public string OrigVal { get; set; }
+
+        /// <summary>
+        /// 新值
+        /// </summary>
+        public string NewVal { get; set; }
+
+        /// <summary>
+        /// 消息列表
+        /// </summary>
+        public List<TaskManageOrderCautionNoticeDetailInfo> NoticeList { get; set; }
+    }
+
+    /// <summary>
+    /// 
+    /// </summary>
+    public class TaskManageOrderCautionNoticeDetailInfo
+    {
+        /// <summary>
+        /// 重要提醒消息类型
+        /// </summary>
+        public CautionNoticeTypeEnum CautionNoticeType { get; set; }
+
+        /// <summary>
+        /// 用户ID
+        /// </summary>
+        public string UserId { get; set; }
+
+        /// <summary>
+        /// 用户手机号
+        /// </summary>
+        public string Mobile { get; set; }
+    }
+}

Myshipping.Application/Service/TaskManagePlat/Dtos/TaskBCInfoDto.cs

@@ -376,5 +376,10 @@ namespace Myshipping.Application
         /// 批次号
         /// </summary>
         public string BatchNo { get; set; }
+
+        /// <summary>
+        /// 计费日期
+        /// </summary>
+        public Nullable<DateTime> PriceCalculationDate { get; set; }
     }
 }