BookingHeChuan/Myshipping.Application/Service/BookingSlot/BookingSlotService.cs

using Furion.DependencyInjection;
using Furion.DynamicApiController;
using Furion.EventBus;
using Furion.FriendlyException;
using Mapster;
using Microsoft.AspNetCore.Authorization;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Extensions.Logging;
using Myshipping.Application.Entity;
using Myshipping.Application.Event;
using Myshipping.Application.Service.BookingOrder.Dto;
using Myshipping.Application.Service.BookingSlot.Dto;
using Myshipping.Core;
using Myshipping.Core.Service;
using SqlSugar;
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Linq;
using System.Threading.Tasks;


namespace Myshipping.Application
{
    /// <summary>
    /// 订舱舱位
    /// </summary>
    [ApiDescriptionSettings("Application", Name = "BookingSlot", Order = 1)]
    public class BookingSlotService : IDynamicApiController, ITransient, IBookingSlotService
    {
        private readonly SqlSugarRepository<BookingSlotBase> _repBase;
        private readonly SqlSugarRepository<BookingSlotCtn> _repCtn;
        private readonly SqlSugarRepository<BookingSlotStock> _repStock;

        private readonly SqlSugarRepository<BookingLog> _repBookingLog;
        private readonly SqlSugarRepository<BookingLogDetail> _repBookingLogDetail;

        private readonly ILogger<BookingSlotService> _logger;
        private readonly ISysCacheService _cache;

        private readonly IEventPublisher _publisher;

        public BookingSlotService(SqlSugarRepository<BookingSlotBase> repBase,
            SqlSugarRepository<BookingSlotCtn> repCtn,
            SqlSugarRepository<BookingSlotStock> repStock,
            SqlSugarRepository<BookingLog> repBookingLog,
            SqlSugarRepository<BookingLogDetail> repBookingLogDetail,
        ILogger<BookingSlotService> logger,
            ISysCacheService cache,
            IEventPublisher publisher)
        {
            _repBase = repBase;
            _repCtn = repCtn;
            _repStock = repStock;
            _repBookingLog = repBookingLog;
            _repBookingLogDetail = repBookingLogDetail;


            _logger = logger;
            _cache = cache;

            _publisher = publisher;
        }

        #region 舱位

        /// <summary>
        /// 保存订舱舱位
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        [HttpPost("/BookingSlot/save")]
        public async Task<BookingSlotBaseSaveOutput> Save(BookingSlotBaseSaveInput input)
        {
            BookingSlotBase model = null;
            if (input.Id > 0) //修改
            {
                var c = _repBase.AsQueryable().Where(x => x.SLOT_BOOKING_NO == input.SLOT_BOOKING_NO && input.Id != input.Id).Count();
                if (c > 0)
                {
                    throw Oops.Bah("订舱编号已存在");
                }

                model = _repBase.FirstOrDefault(x => x.Id == input.Id);
                var oldObj = model.Adapt<BookingSlotBaseSaveInput>();

                input.Adapt(model);

                await _repBase.UpdateAsync(model);

                await _repCtn.DeleteAsync(x => x.SLOT_ID == model.Id);
                foreach (var ctn in input.CtnList)
                {
                    var newCtn = ctn.Adapt<BookingSlotCtn>();
                    newCtn.SLOT_ID = model.Id;
                    await _repCtn.InsertAsync(newCtn);
                }

                await InsLog("Update", model.Id, typeof(BookingSlotBaseSaveInput), oldObj, input, "CtnList");
            }
            else
            {
                var c = _repBase.AsQueryable().Where(x => x.SLOT_BOOKING_NO == input.SLOT_BOOKING_NO).Count();
                if (c > 0)
                {
                    throw Oops.Bah("订舱编号已存在");
                }

                model = input.Adapt<BookingSlotBase>();
                await _repBase.InsertAsync(model);
                foreach (var ctn in input.CtnList)
                {
                    var newCtn = ctn.Adapt<BookingSlotCtn>();
                    newCtn.SLOT_ID = model.Id;
                    await _repCtn.InsertAsync(newCtn);
                }

                await InsLog("Add", model.Id, "新增舱位");
            }

            //更新库存
            await _publisher.PublishAsync(new ChannelEventSource("BookingSlotStock:Update", new BookingSlotStockUpdateModel
            {
                BOOKING_SLOT_TYPE = model.BOOKING_SLOT_TYPE,
                CARRIERID = model.CARRIERID,
                CONTRACT_NO = model.CONTRACT_NO,
                VESSEL = model.VESSEL,
                VOYNO = model.VOYNO
            }));

            return await Detail(model.Id);
        }

        /// <summary>
        /// 获取订舱舱位
        /// </summary>
        /// <param name="id"></param>
        /// <returns></returns>
        [HttpGet("/BookingSlot/detail")]
        public async Task<BookingSlotBaseSaveOutput> Detail(long id)
        {
            var slotBase = await _repBase.FirstOrDefaultAsync(u => u.Id == id);
            var ctns = await _repCtn.Where(x => x.SLOT_ID == id).ToListAsync();

            var rtn = slotBase.Adapt<BookingSlotBaseSaveOutput>();
            rtn.CtnList = ctns.Adapt<List<BookingSlotCtnSaveInput>>();

            List<BookingLogDto> list = new List<BookingLogDto>();
            var main = await _repBookingLog.AsQueryable().Where(u => u.BookingId == slotBase.Id).ToListAsync();
            var mailidlist = main.Select(x => x.Id).ToList();
            list = main.Adapt<List<BookingLogDto>>();
            if (list != null)
            {
                var bookinglogdetail = await _repBookingLogDetail.AsQueryable().Where(x => mailidlist.Contains(x.PId)).ToListAsync();
                foreach (var item in list)
                {
                    var details = bookinglogdetail.Where(x => x.PId == item.Id).ToList();
                    item.details = details;
                }
            }

            rtn.LogList = list;

            return rtn;
        }

        #region 对外接口
        /// <summary>
        /// 舱位接收保存、取消接口
        /// </summary>
        /// <returns></returns>
        [HttpPost("/BookingSlot/ApiReceive"), AllowAnonymous, ApiUser]
        public async Task ApiReceive(BookingSlotBaseApiDto dto)
        {
            //接口方法直接调用save、delete等方法会报错，可能因为非token授权登录导致，故重写一遍保存、删除代码
            if (dto.OpType == "add" || dto.OpType == "update" || dto.OpType == "del")
            {
                BookingSlotBase model = null;
                if (dto.OpType == "add")
                {
                    var c = _repBase.AsQueryable().Filter(null, true).Where(x => x.IsDeleted == false && x.TenantId == UserManager.TENANT_ID && x.SLOT_BOOKING_NO == dto.DataObj.SLOT_BOOKING_NO).Count();
                    if (c > 0)
                    {
                        throw Oops.Bah("订舱编号已存在");
                    }

                    model = dto.DataObj.Adapt<BookingSlotBase>();
                    await _repBase.InsertAsync(model);

                    foreach (var ctn in dto.DataObj.CtnList)
                    {
                        var newCtn = ctn.Adapt<BookingSlotCtn>();
                        newCtn.SLOT_ID = model.Id;
                        await _repCtn.InsertAsync(newCtn);
                    }

                    await InsLog("Add", model.Id, "新增舱位");
                }
                else if (dto.OpType == "update")
                {
                    model = await _repBase.AsQueryable().Filter(null, true).FirstAsync(x => x.IsDeleted == false && x.TenantId == UserManager.TENANT_ID && x.SLOT_BOOKING_NO == dto.DataObj.SLOT_BOOKING_NO);
                    if (model == null)
                    {
                        throw Oops.Bah($"未找到订舱编号为 {dto.DataObj.SLOT_BOOKING_NO} 的数据");
                    }

                    var oldObj = model.Adapt<BookingSlotBaseApiSaveDto>();

                    dto.DataObj.Adapt(model);
                    await _repBase.UpdateAsync(model);
                    await _repCtn.DeleteAsync(x => x.SLOT_ID == model.Id);
                    foreach (var ctn in dto.DataObj.CtnList)
                    {
                        var newCtn = ctn.Adapt<BookingSlotCtn>();
                        newCtn.SLOT_ID = model.Id;
                        await _repCtn.InsertAsync(newCtn);
                    }

                    await InsLog("Update", model.Id, typeof(BookingSlotBaseApiSaveDto), oldObj, dto.DataObj, "CtnList");
                }
                else if (dto.OpType == "del")
                {
                    var slotNO = dto.DataObj.SLOT_BOOKING_NO;
                    model = await _repBase.AsQueryable().Filter(null, true).FirstAsync(x => x.IsDeleted == false && x.TenantId == UserManager.TENANT_ID && x.SLOT_BOOKING_NO == slotNO);
                    if (model == null)
                    {
                        throw Oops.Bah($"未找到订舱编号为 {slotNO} 的数据");
                    }
                    model.IsDeleted = true;
                    await _repBase.UpdateAsync(model);

                    var ctns = await _repCtn.AsQueryable().Filter(null, true).Where(x => x.IsDeleted == false && x.TenantId == UserManager.TENANT_ID && x.SLOT_ID == model.Id).ToListAsync();
                    foreach (var ctn in ctns)
                    {
                        ctn.IsDeleted = true;
                        await _repCtn.UpdateAsync(ctn);
                    }

                    await InsLog("Del", model.Id, "取消舱位");
                }

                //更新库存
                await _publisher.PublishAsync(new ChannelEventSource("BookingSlotStock:Update", new BookingSlotStockUpdateModel
                {
                    BOOKING_SLOT_TYPE = model.BOOKING_SLOT_TYPE,
                    CARRIERID = model.CARRIERID,
                    CONTRACT_NO = model.CONTRACT_NO,
                    VESSEL = model.VESSEL,
                    VOYNO = model.VOYNO
                }));
            }
            else
            {
                throw Oops.Bah("操作类型参数有误");
            }

        }
        #endregion

        /// <summary>
        /// 插入日志（仅显示一条文本信息）
        /// </summary>
        /// <param name="type"></param>
        /// <param name="slotId"></param>
        /// <param name="status"></param>
        /// <returns></returns>
        [NonAction]
        private async Task InsLog(string type, long slotId, string status)
        {
            var bid = await _repBookingLog.InsertReturnSnowflakeIdAsync(new BookingLog
            {
                Type = type,
                BookingId = slotId,
                TenantId = Convert.ToInt64(UserManager.TENANT_ID),
                CreatedTime = DateTime.Now,
                CreatedUserId = UserManager.UserId,
                CreatedUserName = UserManager.Name,
                Module = "Slot"
            });

            if (!string.IsNullOrEmpty(status))
            {
                await _repBookingLogDetail.InsertReturnSnowflakeIdAsync(new BookingLogDetail
                {
                    PId = bid,
                    Field = "",
                    OldValue = "",
                    NewValue = status,
                });
            }
        }

        /// <summary>
        /// 插入日志（比对修改内容）
        /// </summary>
        /// <param name="type"></param>
        /// <param name="id"></param>
        /// <param name="objType"></param>
        /// <param name="objOld"></param>
        /// <param name="objNew"></param>
        /// <param name="excepProp"></param>
        /// <returns></returns>
        [NonAction]
        private async Task InsLog(string type, long id, Type objType, object objOld, object objNew, params string[] excepProp)
        {
            var bid = await _repBookingLog.InsertReturnSnowflakeIdAsync(new BookingLog
            {
                Type = type,
                BookingId = id,
                TenantId = Convert.ToInt64(UserManager.TENANT_ID),
                CreatedTime = DateTime.Now,
                CreatedUserId = UserManager.UserId,
                CreatedUserName = UserManager.Name,
                Module = "Slot"
            });

            foreach (PropertyDescriptor descriptor in TypeDescriptor.GetProperties(objType))
            {
                if (excepProp.Contains(descriptor.Name))
                {
                    continue;
                }

                var compResult = false;
                var oldValue = descriptor.GetValue(objOld);
                var newValue = descriptor.GetValue(objNew);
                if (oldValue != null && newValue != null)
                {
                    if (descriptor.PropertyType == typeof(string))
                    {
                        compResult = oldValue.ToString() == newValue.ToString();
                    }
                    else if (descriptor.PropertyType == typeof(DateTime) || descriptor.PropertyType == typeof(DateTime?))
                    {
                        compResult = Convert.ToDateTime(oldValue) == Convert.ToDateTime(newValue);
                    }
                    else if (descriptor.PropertyType == typeof(decimal) || descriptor.PropertyType == typeof(float) || descriptor.PropertyType == typeof(double)
                        || descriptor.PropertyType == typeof(decimal?) || descriptor.PropertyType == typeof(float?) || descriptor.PropertyType == typeof(double?))
                    {
                        compResult = Convert.ToDecimal(oldValue) == Convert.ToDecimal(newValue);
                    }
                    else if (descriptor.PropertyType == typeof(int) || descriptor.PropertyType == typeof(long)
                        || descriptor.PropertyType == typeof(int?) || descriptor.PropertyType == typeof(long?))
                    {
                        compResult = Convert.ToInt64(oldValue) == Convert.ToInt64(newValue);
                    }
                }
                else
                {
                    compResult = oldValue == newValue;
                }

                if (!compResult)
                {
                    var fieldName = descriptor.Name;
                    if (!string.IsNullOrWhiteSpace(descriptor.Description))
                    {
                        fieldName = descriptor.Description;
                    }

                    await _repBookingLogDetail.InsertReturnSnowflakeIdAsync(new BookingLogDetail
                    {
                        PId = bid,
                        Field = fieldName,
                        OldValue = $"{oldValue}",
                        NewValue = $"{newValue}",
                    });
                }
            }
        }
        #endregion

        #region 库存
        /// <summary>
        /// 库存查询
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        [HttpPost("/BookingSlot/pageStock")]
        public async Task<dynamic> PageStock(BookingSlotStockPageInput input)
        {
            var entities = await _repStock.AsQueryable()
             .WhereIF(!string.IsNullOrEmpty(input.VESSEL), u => u.VESSEL.Contains(input.VESSEL))
             .WhereIF(!string.IsNullOrEmpty(input.VOYNO), u => u.VOYNO.Contains(input.VOYNO))
             .WhereIF(!string.IsNullOrEmpty(input.CARRIER), u => u.CARRIER.Contains(input.CARRIER))
             .WhereIF(!string.IsNullOrEmpty(input.CTN_STAT), u => u.CTN_STAT.Contains(input.CTN_STAT))
             .WhereIF(input.ETD_START.HasValue, u => u.ETD >= input.ETD_START.Value)
             .WhereIF(input.ETD_END.HasValue, u => u.ETD < input.ETD_END.Value.AddDays(1))
             .WhereIF(input.ETA_START.HasValue, u => u.ETA >= input.ETA_START.Value)
             .WhereIF(input.ETA_END.HasValue, u => u.ETA < input.ETA_END.Value.AddDays(1))
             .ToPagedListAsync(input.PageNo, input.PageSize);

            var result = entities.Adapt<SqlSugarPagedList<BookingSlotStockListOutput>>();

            return result.XnPagedResult();
        }

        /// <summary>
        /// 刷新库存统计
        /// </summary>
        /// <returns></returns>
        [HttpPost("/BookingSlot/refreshStock")]
        public async Task RefreshStock(BookingSlotStockUpdateModel input)
        {
            //更新库存
            await _publisher.PublishAsync(new ChannelEventSource("BookingSlotStock:Update", input));
        }

        /// <summary>
        /// 查询可用的舱位及箱子
        /// </summary>
        [HttpGet("/BookingSlot/getAvailableSlots")]
        public async Task<List<BookingSlotBaseWithCtnDto>> GetAvailableSlots([FromQuery] BookingSlotBaseDto input)
        {
            return await GetAvailableSlots(input, null);
        } 

        /// <summary>
        /// 查询可用的舱位及箱子列表
        /// </summary>
        /// <param name="slotInput">筛选条件1：舱位信息、箱型</param>
        /// <param name="slotIdListInput">筛选条件2：舱位主键列表</param>
        /// <returns>可用的舱位列表（含可用的箱子列表）</returns>
        [NonAction]
        public async Task<List<BookingSlotBaseWithCtnDto>> GetAvailableSlots(BookingSlotBaseDto slotInput = null, List<long> slotIdListInput = null)
        {
            slotInput ??= new();
            slotIdListInput ??= new();

            string[] ctnCodeList = null;
            if (!string.IsNullOrEmpty(slotInput.CTN_STAT))
            {
                ctnCodeList = slotInput.CTN_STAT.Split(',');
            }

            // 1. 【舱位基础表】与【箱子表】做关联，并根据【舱位主键】、【箱型】做分组，统计出【总的箱量】，作为queryable1
            var queryable1 = _repBase.Context.Queryable<BookingSlotBase, BookingSlotCtn>((bas, ctn) => bas.Id == ctn.SLOT_ID)
                                             .WhereIF(!string.IsNullOrEmpty(slotInput.PORTLOAD), bas => bas.PORTLOAD.Contains(slotInput.PORTLOAD))
                                             .WhereIF(!string.IsNullOrEmpty(slotInput.PORTDISCHARGE), bas => bas.PORTLOAD.Contains(slotInput.PORTLOAD))
                                             .WhereIF(!string.IsNullOrEmpty(slotInput.VESSEL), bas => bas.VESSEL.Contains(slotInput.VESSEL))
                                             .WhereIF(!string.IsNullOrEmpty(slotInput.VOYNO), bas => bas.VOYNO.Contains(slotInput.VOYNO))
                                             .WhereIF(!string.IsNullOrEmpty(slotInput.CARRIAGE_TYPE), bas => bas.CARRIAGE_TYPE == slotInput.CARRIAGE_TYPE)
                                             .WhereIF(!string.IsNullOrEmpty(slotInput.BOOKING_SLOT_TYPE), bas => bas.BOOKING_SLOT_TYPE == slotInput.BOOKING_SLOT_TYPE)
                                             .WhereIF(ctnCodeList != null, (bas, ctn) => ctnCodeList.Contains(ctn.CTNCODE))
                                             .WhereIF(slotIdListInput.Any(), (bas) => slotIdListInput.Contains(bas.Id))
                                             .GroupBy((bas, ctn) => new
                                             {
                                                 bas.Id,
                                                 ctn.CTNCODE
                                             })
                                             .Select((bas, ctn) => new
                                             {
                                                 id = bas.Id,
                                                 ctnCode = ctn.CTNCODE,
                                                 numAll = SqlFunc.AggregateSum(ctn.CTNNUM)
                                             })
                                             .MergeTable();

            // 2. 【已引入舱位表】与【已使用的箱子表】做关联，并根据【舱位主键】、【箱型】做分组，统计出【已使用的箱量】，作为queryable2
            var queryable2 = _repBase.Context.Queryable<BookingSlotAllocation, BookingSlotAllocationCtn>((alc, ctn) => alc.Id == ctn.SLOT_ALLOC_ID)
                                             .GroupBy((alc, ctn) => new
                                             {
                                                 alc.BOOKING_SLOT_ID,
                                                 ctn.CTNCODE
                                             })
                                             .Select((alc, ctn) => new
                                             {
                                                 id = alc.BOOKING_SLOT_ID,
                                                 ctnCode = ctn.CTNCODE,
                                                 numUse = SqlFunc.AggregateSum(ctn.CTNNUM)
                                             })
                                             .MergeTable();

            // 3. 将queryable1 左连接 queryable2，使用【总的箱量】减去【已使用的箱量】，得到【剩余的箱量】，添加【剩余的箱量】> 0 的条件，作为queryable3
            var queryable3 = queryable1.LeftJoin(queryable2, (q1, q2) => q1.id == q2.id && q1.ctnCode == q2.ctnCode)
                                       .Select((q1, q2) => new
                                       {
                                           q1.id,
                                           q1.ctnCode,
                                           numResidue = SqlFunc.IsNull(q1.numAll - q2.numUse, q1.numAll)
                                       })
                                       .MergeTable()
                                       .Where(r => r.numResidue > 0);

            // 4. 执行ToList()，得到可用的【舱位主键】、【箱型】、【箱量】列表
            var canUselist = await queryable3.ToListAsync();

            // 查询舱位列表
            var baseIdList = canUselist.Select(c => c.id);
            List<BookingSlotBase> baseList = await _repBase.AsQueryable()
                                                           .Where(u => baseIdList.Contains(u.Id))
                                                           .ToListAsync();

            List<Core.Entity.CodeCtn> ctnCodeCache = await _cache.GetAllCodeCtn();

            // 构建结果
            List<BookingSlotBaseWithCtnDto> result = baseList.Adapt<List<BookingSlotBaseWithCtnDto>>();
            foreach (var item in result)
            {
                var ctnList = canUselist.Where(c => c.id == item.Id).ToList();
                if (ctnList?.Any() == true)
                {
                    item.CtnList = ctnList.Select(c => new BookingSlotCtnDto()
                    {
                        CTNCODE = c.ctnCode,
                        CTNNUM = c.numResidue,
                        CTNALL = ctnCodeCache.FirstOrDefault(e => e.Code == c.ctnCode)?.Name ?? throw new Exception($"舱位信息中存在未收录的箱型：{c.ctnCode}，需要在箱型字典中补充"),
                    }).ToList();
                }
            }

            return result;
        }
        #endregion
    }
}