BookingHeChuan/Myshipping.Application/Event/BookingSlotStockSubscriber.cs

using Furion;
using Furion.EventBus;
using Mapster;
using Microsoft.Extensions.Logging;
using Myshipping.Core;
using SqlSugar;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;

namespace Myshipping.Application.Event
{
    /// <summary>
    /// 运踪
    /// </summary>
    public class BookingSlotStockSubscriber : IEventSubscriber
    {
        private readonly ILogger<BookingSlotStockSubscriber> _logger;

        public BookingSlotStockSubscriber(
            ILogger<BookingSlotStockSubscriber> logger)
        {
            _logger = logger;
        }

        //更新库存
        [EventSubscribe("BookingSlotStock:Update")]
        public async Task BookingSlotStock(EventHandlerExecutingContext context)
        {
            BookingSlotStockUpdateModel paraObj = context.Source.Payload as BookingSlotStockUpdateModel;
            await BookingSlotStock(paraObj);
        }

        public async Task BookingSlotStock(BookingSlotStockUpdateModel paraObj)
        {
            _logger.LogInformation($"收到更新库存订阅请求：{paraObj.ToJsonString()}");

            var _repBase = App.GetService<SqlSugarRepository<BookingSlotBase>>();
            var _repCtn = App.GetService<SqlSugarRepository<BookingSlotCtn>>();
            var _repStock = App.GetService<SqlSugarRepository<BookingSlotStock>>();
            var _repAlloc = App.GetService<SqlSugarRepository<BookingSlotAllocation>>();
            var _repAllocCtn = App.GetService<SqlSugarRepository<BookingSlotAllocationCtn>>();


            if (string.IsNullOrEmpty(paraObj.VESSEL)
                || string.IsNullOrEmpty(paraObj.VOYNO)
                || string.IsNullOrEmpty(paraObj.CONTRACT_NO)
                || string.IsNullOrEmpty(paraObj.BOOKING_SLOT_TYPE)
                || string.IsNullOrEmpty(paraObj.CARRIERID)
                || string.IsNullOrEmpty(paraObj.PORTLOADID)
                || string.IsNullOrEmpty(paraObj.PORTDISCHARGEID))
            {
                _logger.LogInformation($"收到更新库存订阅请求：部分参数存在空值，结束");
                return;
            }
            var baseList = await _repBase.AsQueryable().Filter(null, true)
                                          .Where(x => !x.IsDeleted
                                           && x.TenantId == paraObj.TenantId
                                           && x.VESSEL == paraObj.VESSEL
                                           && x.VOYNO == paraObj.VOYNO
                                           && x.CONTRACT_NO == paraObj.CONTRACT_NO
                                           && x.BOOKING_SLOT_TYPE == paraObj.BOOKING_SLOT_TYPE
                                           && x.CARRIERID == paraObj.CARRIERID
                                           && x.PORTLOADID == paraObj.PORTLOADID
                                           && x.PORTDISCHARGEID == paraObj.PORTDISCHARGEID)
                                          .OrderByDescending(x => x.UpdatedTime)
                                          .ToListAsync();

            var stockObj = await _repStock.AsQueryable().Filter(null, true)
                                         .FirstAsync(x => !x.IsDeleted
                                         && x.TenantId == paraObj.TenantId
                                         && x.VESSEL == paraObj.VESSEL
                                         && x.VOYNO == paraObj.VOYNO
                                         && x.CONTRACT_NO == paraObj.CONTRACT_NO
                                         && x.BOOKING_SLOT_TYPE == paraObj.BOOKING_SLOT_TYPE
                                         && x.CARRIERID == paraObj.CARRIERID
                                         && x.PORTLOADID == paraObj.PORTLOADID
                                         && x.PORTDISCHARGEID == paraObj.PORTDISCHARGEID);

            if (!baseList.Any())
            {
                if (stockObj != null)
                {
                    // 从库存表删除这7项维度的库存数据
                    await _repStock.DeleteAsync(x => x.Id == stockObj.Id);
                }
                return;
            }

            var isInsert = stockObj == null;
            var idTemp = stockObj?.Id;

            stockObj = baseList[0].Adapt(stockObj);

            if (isInsert)
            {
                stockObj.Id = 0;
            }
            else
            {
                stockObj.Id = (long)idTemp;
            }

            // 总舱位数
            stockObj.TOTAL_ORDERS = baseList.Count;

            // 取消舱位数
            stockObj.CANCEL_NUM = baseList.Count(x => x.IS_CANCELLATION);

            // 舱位主键列表
            var slotBaseIdList = baseList.Select(x => x.Id).ToList();

            // 总的箱型箱量
            var ctnAllList = await _repCtn.AsQueryable().Filter(null, true)
                                  .Where(x => !x.IsDeleted && slotBaseIdList.Contains(x.SLOT_ID))
                                  .GroupBy(x => x.CTNALL)
                                  .Select(x => new
                                  {
                                      x.CTNALL,
                                      CTNNUM = SqlFunc.AggregateSum(x.CTNNUM)
                                  }).ToListAsync();
            stockObj.CTN_STAT = string.Join(' ', ctnAllList.Select(c => c.CTNALL + "*" + c.CTNNUM));

            // 总箱数
            stockObj.TOTAL_CTNS = ctnAllList.Sum(x => x.CTNNUM);

            // 订舱引用表主键与订舱主表主键
            var lstAllocKeyList = await _repAlloc.AsQueryable()
                                                .Filter(null, true)
                                                .Where(x => !x.IsDeleted && slotBaseIdList.Contains(x.BOOKING_SLOT_ID))
                                                .Select(x => new { x.Id, x.BOOKING_SLOT_ID })
                                                .ToListAsync();

            // 如果舱位未被引用过，可以直接确定库存
            if (!lstAllocKeyList.Any())
            {
                // 已使用舱位数
                stockObj.USE_NUM = 0;
                // 已使用的箱型箱量
                stockObj.USE_CTN_STAT = "";
                // 已使用的箱数
                stockObj.USE_CTNS_NUM = 0;

                // 剩余的箱型箱量
                stockObj.REMAIN_CTN_STAT = stockObj.CTN_STAT;
                // 剩余箱数
                stockObj.REMAIN_CTNS_NUM = stockObj.TOTAL_CTNS;
            }
            else
            {
                // 已使用舱位数
                //stockObj.USE_NUM = lstAllocKeyList.DistinctBy(x => x.BOOKING_SLOT_ID).Count();

                // 订舱引用表主键列表
                var allocIdList = lstAllocKeyList.Select(x => x.Id).ToList();
                var allocSlotIdList = lstAllocKeyList.Select(x => x.BOOKING_SLOT_ID).Distinct().ToList();
                var userCtnNumList = await _repAllocCtn.AsQueryable().Filter(null, true)
                                                             .Where(x => !x.IsDeleted && allocIdList.Contains(x.SLOT_ALLOC_ID))
                                                             .GroupBy(x => x.SLOT_ALLOC_ID)
                                                             .Select(x => new
                                                             {
                                                                 x.SLOT_ALLOC_ID,
                                                                 CTNNUM = SqlFunc.AggregateSum(x.CTNNUM)
                                                             }).ToListAsync();
                var hasCtnNumList = await _repCtn.AsQueryable().Filter(null, true)
                                                            .Where(x => !x.IsDeleted && allocSlotIdList.Contains(x.SLOT_ID))
                                                            .GroupBy(x => x.SLOT_ID)
                                                            .Select(x => new
                                                            {
                                                                x.SLOT_ID,
                                                                CTNNUM = SqlFunc.AggregateSum(x.CTNNUM)
                                                            })
                                                            .ToListAsync();
                var useNum = 0;
                foreach (long slotId in allocSlotIdList)
                {
                    List<long> temp1 = lstAllocKeyList.Where(x => x.BOOKING_SLOT_ID == slotId).Select(x => x.Id).ToList();
                    var userNum = userCtnNumList.Where(x => temp1.Contains(x.SLOT_ALLOC_ID)).Sum(x => x.CTNNUM);
                    var hasNum = hasCtnNumList.Where(x => x.SLOT_ID == slotId).Sum(x => x.CTNNUM);
                    if (userNum >= hasNum)
                    {
                        useNum++;
                    }
                }
                // 已使用舱位数
                stockObj.USE_NUM = useNum;

                // 已使用的箱型箱量
                var userCtnList = await _repAllocCtn.AsQueryable()
                                               .Filter(null, true)
                                               .Where(x => !x.IsDeleted && allocIdList.Contains(x.SLOT_ALLOC_ID))
                                               .GroupBy(x => x.CTNALL)
                                               .Select(x => new
                                               {
                                                   x.CTNALL,
                                                   CTNNUM = SqlFunc.AggregateSum(x.CTNNUM)
                                               }).ToListAsync();
                stockObj.USE_CTN_STAT = string.Join(' ', userCtnList.Select(c => c.CTNALL + "*" + c.CTNNUM));

                // 已使用的箱数
                stockObj.USE_CTNS_NUM = userCtnList.Sum(x => x.CTNNUM);

                // 剩余的箱型箱量
                Dictionary<string, int> remainCtnList = new(ctnAllList.Count);
                foreach (var item in ctnAllList)
                {
                    var useItem = userCtnList.FirstOrDefault(x => x.CTNALL == item.CTNALL);
                    if (useItem == null)
                    {
                        remainCtnList.Add(item.CTNALL, item.CTNNUM);
                    }
                    else
                    {
                        int remainCtnNum = item.CTNNUM - useItem.CTNNUM;
                        if (remainCtnNum > 0)
                        {
                            remainCtnList.Add(item.CTNALL, remainCtnNum);
                        }
                    }
                }
                stockObj.REMAIN_CTN_STAT = string.Join(' ', remainCtnList.Select(x => x.Key + "*" + x.Value));

                // 剩余箱数
                stockObj.REMAIN_CTNS_NUM = stockObj.TOTAL_CTNS - stockObj.USE_CTNS_NUM;
            }

            if (isInsert)
            {
                await _repStock.InsertAsync(stockObj);
            }
            else
            {
                await _repStock.UpdateAsync(stockObj);
            }
        }
    }

    /// <summary>
    /// 刷新库存统计对象
    /// </summary>
    public class BookingSlotStockUpdateModel
    {

        /// <summary>
        /// 船名
        /// </summary>
        public string VESSEL { get; set; }

        /// <summary>
        /// 航次号
        /// </summary>
        public string VOYNO { get; set; }

        /// <summary>
        /// 合约号
        /// </summary>
        public string CONTRACT_NO { get; set; }

        /// <summary>
        /// 订舱方式 CONTRACT_ORDER-合约订舱；SPOT_ORDER-SPOT订舱
        /// </summary>
        public string BOOKING_SLOT_TYPE { get; set; }

        /// <summary>
        /// 船公司代号
        /// </summary>
        public string CARRIERID { get; set; }

        ///// <summary>
        ///// 收货地
        ///// </summary>
        //public string PLACERECEIPT { get; set; }
        ///// <summary>
        ///// 交货地
        ///// </summary>
        //public string PLACEDELIVERY { get; set; }

        /// <summary>
        /// 装货港代码
        /// </summary>
        public string PORTLOADID { get; set; }
        /// <summary>
        /// 卸货港代码
        /// </summary>
        public string PORTDISCHARGEID { get; set; }
        /// <summary>
        /// 租户Id
        /// </summary>
        public long? TenantId { get; set; }
    }
}