BookingHeChuan/Myshipping.Application/Service/DataSync/DataSyncService.cs

using Myshipping.Core;
using Furion.DependencyInjection;
using Furion.DynamicApiController;
using Mapster;
using Microsoft.AspNetCore.Mvc;
using SqlSugar;
using System.Linq;
using System.Threading.Tasks;
using Myshipping.Application.Entity;
using Microsoft.AspNetCore.Authorization;
using Furion;
using Microsoft.AspNetCore.Http;
using Furion.DataEncryption;
using System.Collections.Generic;
using System.Security.Claims;
using Microsoft.AspNetCore.Authentication.Cookies;
using Microsoft.AspNetCore.Authentication;
using Microsoft.AspNetCore.Identity;
using Furion.FriendlyException;
using Furion.Logging;
using System;
using Microsoft.Extensions.Logging;
using System.Reflection;
using System.ComponentModel;
using Myshipping.Application.ConfigOption;
using System.IO;
using Yitter.IdGenerator;
using Myshipping.Core.Entity;
using Furion.RemoteRequest.Extensions;
using System.Net.Http;
using Myshipping.Core.Service;
using System.Reflection.Emit;
using Myshipping.Application.Service.DataSync.Dto;

namespace Myshipping.Application
{
    /// <summary>
    /// 数据同步服务
    /// </summary>
    [ApiDescriptionSettings("Application", Name = "DataSync", Order = 1), AllowAnonymous]
    public class DataSyncService : IDynamicApiController, ITransient
    {
        private readonly ILogger<BookingOrderService> _logger;
        private readonly ISysCacheService _cache;
        private readonly SqlSugarRepository<BookingOrder> _rep;
        private readonly SqlSugarRepository<BookingCtn> _repCtn;
        private readonly SqlSugarRepository<BookingCtnDetail> _ctndetailrep;
        private readonly SqlSugarRepository<SysUser> _repUser;
        private readonly SqlSugarRepository<SysTenant> _repTenant;
        private readonly SqlSugarRepository<DjyCustomer> _djycustomer;
        private readonly SqlSugarRepository<DjyCustomerContact> _djycustomercontact;
        private readonly SqlSugarRepository<DjyVesselInfo> _vesselinfo;
        private readonly SqlSugarRepository<BookingEDIExt> _bookingEDIExt;
        private readonly SqlSugarRepository<BookingLog> _bookinglog;
        private readonly SqlSugarRepository<BookingLogDetail> _bookinglogdetail;
        private readonly SqlSugarRepository<BookingRemark> _bookingremark;

        public DataSyncService(ILogger<BookingOrderService> logger, ISysCacheService cache, SqlSugarRepository<BookingOrder> rep, SqlSugarRepository<BookingCtn> repCtn,
        SqlSugarRepository<SysUser> repUser, SqlSugarRepository<SysTenant> repTenant, SqlSugarRepository<DjyCustomer> djycustomer,
        SqlSugarRepository<DjyCustomerContact> djycustomercontact, SqlSugarRepository<DjyVesselInfo> vesselinfo, SqlSugarRepository<BookingCtnDetail> ctndetailrep
            , SqlSugarRepository<BookingEDIExt> bookingEDIExt, SqlSugarRepository<BookingLog> bookinglog, SqlSugarRepository<BookingLogDetail> bookinglogdetail,
        SqlSugarRepository<BookingRemark> bookingremark)
        {
            this._logger = logger;
            this._rep = rep;
            this._repCtn = repCtn;
            this._cache = cache;
            this._repUser = repUser;
            this._repTenant = repTenant;
            this._djycustomer = djycustomer;
            this._djycustomercontact = djycustomercontact;
            this._vesselinfo = vesselinfo;
            this._ctndetailrep = ctndetailrep;
            this._bookingEDIExt = bookingEDIExt;
            this._bookinglog = bookinglog;
            this._bookinglogdetail = bookinglogdetail;
            this._bookingremark = bookingremark;
        }


        #region 上传数据
        /// <summary>
        /// 同步客户
        /// </summary>
        /// <param name="model">参数</param>
        /// <returns></returns>
        [HttpPost("/DataSync/SyncCustomer"), ApiUser(ApiCode = "SyncCustomer")]
        public async Task<long> SyncCustomer(DjyCustomerSyncDto model)
        {

            if (string.IsNullOrWhiteSpace(model.ShortName))
            {
                throw Oops.Bah("简称未录入");
            }
            var m = await _djycustomer.AsQueryable().Filter(null, true).Where(x => x.ShortName == model.ShortName).FirstAsync();
            var entity = model.Adapt<DjyCustomer>();
            if (m == null)
            {
                await _djycustomer.InsertAsync(entity);
                foreach (var item in model.ContactList)
                {
                    var contact = item.Adapt<DjyCustomerContact>();
                    contact.CustomerId = entity.Id;
                    await _djycustomercontact.InsertAsync(contact);
                }
            }
            else
            {
                entity.Id = m.Id;
                await _djycustomer.AsUpdateable(entity).IgnoreColumns(ignoreAllNullColumns: true).ExecuteCommandAsync();
                await _djycustomercontact.DeleteAsync(x => x.CustomerId == entity.Id);
                foreach (var item in model.ContactList)
                {
                    var contact = item.Adapt<DjyCustomerContact>();
                    contact.CustomerId = entity.Id;
                    await _djycustomercontact.InsertAsync(contact);
                }
            }
            return entity.Id;
        }


        /// <summary>
        /// 同步船期
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        [HttpPost("/DataSync/SyncVesselDate"), ApiUser(ApiCode = "SyncVesselDate")]
        public async Task<long> SyncVesselDate(DjyVesselInfoDto model)
        {

            if (string.IsNullOrWhiteSpace(model.BSNO))
            {
                throw Oops.Bah("BSNO未录入");
            }
            var m = await _vesselinfo.AsQueryable().Filter(null, true).Where(x => x.BSNO == model.BSNO).FirstAsync();
            var entity = model.Adapt<DjyVesselInfo>();
            entity.Vessel = model.Vessel.ToUpper().Trim();
            if (m == null)
            {
                await _vesselinfo.InsertAsync(entity);
            }
            else
            {
                entity.Id = m.Id;
                await _vesselinfo.AsUpdateable(entity).IgnoreColumns(ignoreAllNullColumns: true).ExecuteCommandAsync();
            }
            return entity.Id;
        }

        /// <summary>
        /// 同步订舱
        /// </summary>
        /// <param name="model"></param>
        /// <returns></returns>
        [SqlSugarUnitOfWork]
        [HttpPost("/DataSync/SyncBooking"), ApiUser(ApiCode = "SyncBooking")]
        public async Task<long> SyncBooking(SyncBookingOrderDto model)
        {
            if (string.IsNullOrWhiteSpace(model.BSNO))
            {
                throw Oops.Bah("主单BSNO未录入");
            }
            if (string.IsNullOrWhiteSpace(model.CreatedUserName))
            {
                throw Oops.Bah("未录入创建人");
            }
            var userlist = _repUser.AsQueryable().Filter(null, true).ToListAsync();
            var user = _repUser.AsQueryable().Filter(null, true).Where(x => x.Name == model.CreatedUserName.Trim()).FirstAsync();
            if (user.Result == null)
            {
                throw Oops.Bah($"未匹配到创建人  {model.CreatedUserName.Trim()} 请联系管理员添加相关用户");
            }
            var order = await _rep.AsQueryable().Filter(null, true).Where(x => x.BSNO == model.BSNO).FirstAsync();
            if (order == null)
            {

                #region   新增
                if (string.IsNullOrWhiteSpace(model.MBLNO))
                {
                    throw Oops.Bah("请填写提单号！");
                }

                JsonUtil.PropToUpper(model, "ORDNO", "BSSTATUS", "YardContract", "YardContractTel", "YardContractEmail", "MARKS", "DESCRIPTION", "CONSIGNEENAME", "SHIPPERNAME", "NOTIFYPARTYNAME");
                var ms = JsonUtil.TrimFields(model);
                if (!string.IsNullOrEmpty(ms))
                {
                    throw Oops.Bah(ms);
                }
                if (model.ctnInputs != null)
                {
                    var groupList = model.ctnInputs.Where(x => x.CTNNUM > 0).GroupBy(c => c.CTNALL).Select(g => $"{g.Key}*{g.Sum(gg => gg.CTNNUM)}");
                    model.CNTRTOTAL = string.Join(" / ", groupList);
                }
                var et = await _rep.Where(x => x.MBLNO == model.MBLNO && x.TenantId == UserManager.TENANT_ID && x.HBLNO == model.HBLNO && x.ParentId == 0).FirstAsync();
                if (et != null)
                {

                    throw Oops.Bah("当前提单号已存在,请勿重复录入!");
                }
                var entity = model.Adapt<BookingOrder>();
                if (!string.IsNullOrEmpty(entity.ROUTE))
                {
                    entity.ROUTEID = userlist.Result.Where(x => x.Name == entity.ROUTE).Count() == 0 ? "" : userlist.Result.Where(x => x.Name == entity.ROUTE).Select(x => x.Id).FirstOrDefault().ToString();
                }
                if (!string.IsNullOrEmpty(entity.SALE))
                {
                    entity.SALEID = userlist.Result.Where(x => x.Name == entity.SALE).Count() == 0 ? "" : userlist.Result.Where(x => x.Name == entity.SALE).Select(x => x.Id).FirstOrDefault().ToString();
                }
                if (!string.IsNullOrEmpty(entity.OP))
                {
                    entity.OPID = userlist.Result.Where(x => x.Name == entity.OP).Count() == 0 ? "" : userlist.Result.Where(x => x.Name == entity.OP).Select(x => x.Id).FirstOrDefault().ToString();
                }
                if (!string.IsNullOrEmpty(entity.DOC))
                {
                    entity.DOCID = userlist.Result.Where(x => x.Name == entity.DOC).Count() == 0 ? "" : userlist.Result.Where(x => x.Name == entity.DOC).Select(x => x.Id).FirstOrDefault().ToString();
                }
                if (!string.IsNullOrEmpty(entity.CUSTSERVICE))
                {
                    entity.CUSTSERVICEID = userlist.Result.Where(x => x.Name == entity.CUSTSERVICE).Count() == 0 ? "" : userlist.Result.Where(x => x.Name == entity.CUSTSERVICE).Select(x => x.Id).FirstOrDefault().ToString();
                }
                if (!string.IsNullOrEmpty(entity.CUSTOMSER))
                {
                    entity.CUSTOMSERID = _djycustomer.AsQueryable().Where(x => x.ShortName == entity.CUSTOMSER).Select(x => x.CodeName).First();
                }
                if (!string.IsNullOrEmpty(entity.TRUCKER))
                {
                    entity.TRUCKERID = _djycustomer.AsQueryable().Where(x => x.ShortName == entity.TRUCKER).Select(x => x.CodeName).First();
                }
                entity.CreatedUserId = user.Result.Id;
                entity.CreatedUserName = user.Result.Name.ToString();
                entity.CreatedTime = DateTime.Now;
                entity.ParentId = 0;
                await _rep.InsertAsync(entity);
                if (model.ctnInputs != null)
                {
                    foreach (var item in model.ctnInputs)
                    {
                        var ctnentity = item.Adapt<BookingCtn>();
                        ctnentity.BILLID = entity.Id;
                        ctnentity.CreatedUserId = user.Result.Id;
                        ctnentity.CreatedUserName = user.Result.Name;
                        await _repCtn.InsertAsync(ctnentity);

                        //这里保存有可能没有添加多品名，所有箱下没有货物信息
                        if (item.ctnDetailInputs != null)
                        {
                            foreach (var it in item.ctnDetailInputs)
                            {
                                var ctndetail = it.Adapt<BookingCtnDetail>();
                                ctndetail.CTNID = ctnentity.Id;
                                ctndetail.CreatedUserId = user.Result.Id;
                                ctndetail.CreatedUserName = user.Result.Name;
                                await _ctndetailrep.InsertAsync(ctndetail);
                            }
                        }
                    }
                }

                if (model.BookingEDIExt != null)
                {
                    //写入EDI扩展
                    var ediExtEntity = model.BookingEDIExt.Adapt<BookingEDIExt>();

                    ediExtEntity.BookingId = entity.Id;

                    ediExtEntity.CreatedUserId = user.Result.Id;
                    ediExtEntity.CreatedUserName = user.Result.Name;
                    ediExtEntity.CreatedTime = DateTime.Now;
                    ediExtEntity.CreatedUserId = user.Result.Id;
                    ediExtEntity.CreatedUserName = user.Result.Name;
                    await _bookingEDIExt.InsertAsync(ediExtEntity);
                }
                ////添加booking日志
                await _bookinglog.InsertAsync(new BookingLog
                {
                    Type = "Add",
                    BookingId = entity.Id,
                    TenantId = Convert.ToInt64(UserManager.TENANT_ID),
                    CreatedTime = DateTime.Now,
                    CreatedUserId = user.Result.Id,
                    CreatedUserName = "系统"
                });

                if (model.remarks != null)
                {
                    foreach (var remark in model.remarks)
                    {
                        if (remark.Type == "1")
                        {
                            BookingRemark bookingRemark = new BookingRemark();
                            bookingRemark.PId = entity.Id;
                            bookingRemark.CreatedUserId = user.Result.Id;
                            bookingRemark.CreatedUserName = user.Result.Name.ToString();
                            bookingRemark.CreatedTime = DateTime.Now;
                            bookingRemark.Remark = "单证备注:" + remark.Remark;
                            await _bookingremark.InsertAsync(bookingRemark);
                        } else if (remark.Type == "2") {

                            BookingRemark bookingRemark = new BookingRemark();
                            bookingRemark.PId = entity.Id;
                            bookingRemark.CreatedUserId = user.Result.Id;
                            bookingRemark.CreatedUserName = user.Result.Name.ToString();
                            bookingRemark.CreatedTime = DateTime.Now;
                            bookingRemark.Remark = "操作备注:" + remark.Remark;
                            await _bookingremark.InsertAsync(bookingRemark);
                        }

                    }

                }



                //分单
                if (model.childrens != null)
                {
                    foreach (var item in model.childrens)
                    {
                        if (string.IsNullOrWhiteSpace(item.MBLNO))
                        {
                            throw Oops.Bah("请填写提单号！");
                        }
                        if (string.IsNullOrWhiteSpace(item.HBLNO))
                        {
                            throw Oops.Bah("请填写分提单号！");
                        }
                        JsonUtil.PropToUpper(item, "ORDNO", "BSSTATUS", "YardContract", "YardContractTel", "YardContractEmail", "MARKS", "DESCRIPTION", "CONSIGNEENAME", "SHIPPERNAME", "NOTIFYPARTYNAME");

                        var fms = JsonUtil.TrimFields(item);
                        if (!string.IsNullOrEmpty(fms))
                        {
                            throw Oops.Bah(fms);
                        }
                        if (item.ctnInputs != null)
                        {
                            var groupList = item.ctnInputs.Where(x => x.CTNNUM > 0).GroupBy(c => c.CTNALL).Select(g => $"{g.Key}*{g.Sum(gg => gg.CTNNUM)}");
                            item.CNTRTOTAL = string.Join(" / ", groupList);
                        }
                        var fdet = await _rep.Where(x => x.MBLNO == model.MBLNO && x.TenantId == UserManager.TENANT_ID && x.HBLNO == model.HBLNO && x.ParentId == entity.Id).FirstAsync();
                        if (fdet != null)
                        {

                            throw Oops.Bah($"当前分单中提单号({item.MBLNO}_{item.HBLNO})已存在,请勿重复录入!");

                        }
                        var fdentity = item.Adapt<BookingOrder>();
                        if (!string.IsNullOrEmpty(fdentity.ROUTE))
                        {
                            fdentity.ROUTEID = userlist.Result.Where(x => x.Name == fdentity.ROUTE).Count() == 0 ? "" : userlist.Result.Where(x => x.Name == fdentity.ROUTE).Select(x => x.Id).FirstOrDefault().ToString();
                        }
                        if (!string.IsNullOrEmpty(fdentity.SALE))
                        {
                            fdentity.SALEID = userlist.Result.Where(x => x.Name == fdentity.SALE).Count() == 0 ? "" : userlist.Result.Where(x => x.Name == fdentity.SALE).Select(x => x.Id).FirstOrDefault().ToString();
                        }
                        if (!string.IsNullOrEmpty(fdentity.OP))
                        {
                            fdentity.OPID = userlist.Result.Where(x => x.Name == fdentity.OP).Count() == 0 ? "" : userlist.Result.Where(x => x.Name == fdentity.OP).Select(x => x.Id).FirstOrDefault().ToString();
                        }
                        if (!string.IsNullOrEmpty(fdentity.DOC))
                        {
                            fdentity.DOCID = userlist.Result.Where(x => x.Name == fdentity.DOC).Count() == 0 ? "" : userlist.Result.Where(x => x.Name == fdentity.DOC).Select(x => x.Id).FirstOrDefault().ToString();
                        }
                        if (!string.IsNullOrEmpty(fdentity.CUSTSERVICE))
                        {
                            fdentity.CUSTSERVICEID = userlist.Result.Where(x => x.Name == fdentity.CUSTSERVICE).Count() == 0 ? "" : userlist.Result.Where(x => x.Name == fdentity.CUSTSERVICE).Select(x => x.Id).FirstOrDefault().ToString();
                        }
                        if (!string.IsNullOrEmpty(fdentity.CUSTOMSER))
                        {
                            fdentity.CUSTOMSERID = _djycustomer.AsQueryable().Where(x => x.ShortName == fdentity.CUSTOMSER).Select(x => x.CodeName).First();
                        }
                        if (!string.IsNullOrEmpty(fdentity.TRUCKER))
                        {
                            fdentity.TRUCKERID = _djycustomer.AsQueryable().Where(x => x.ShortName == fdentity.TRUCKER).Select(x => x.CodeName).First();
                        }
                        fdentity.CreatedUserId = user.Result.Id;
                        fdentity.CreatedUserName = user.Result.Name;
                        fdentity.CreatedTime = DateTime.Now;
                        fdentity.ParentId = entity.Id;
                        await _rep.InsertAsync(fdentity);

                        if (item.ctnInputs != null)
                        {
                            foreach (var it in item.ctnInputs)
                            {
                                var ctnentity = item.Adapt<BookingCtn>();
                                ctnentity.BILLID = fdentity.Id;
                                ctnentity.CreatedUserId = user.Result.Id;
                                ctnentity.CreatedUserName = user.Result.Name;
                                await _repCtn.InsertAsync(ctnentity);

                                //这里保存有可能没有添加多品名，所有箱下没有货物信息
                                if (it.ctnDetailInputs != null)
                                {
                                    foreach (var dit in it.ctnDetailInputs)
                                    {
                                        var ctndetail = dit.Adapt<BookingCtnDetail>();
                                        ctndetail.CTNID = ctnentity.Id;
                                        ctndetail.CreatedUserId = user.Result.Id;
                                        ctndetail.CreatedUserName = user.Result.Name;

                                        await _ctndetailrep.InsertAsync(ctndetail);
                                    }
                                }
                            }

                        }



                        if (item.BookingEDIExt != null)
                        {
                            //写入EDI扩展
                            var ediExtEntity = model.BookingEDIExt.Adapt<BookingEDIExt>();

                            ediExtEntity.BookingId = fdentity.Id;
                            ediExtEntity.CreatedUserId = user.Result.Id;
                            ediExtEntity.CreatedUserName = user.Result.Name;
                            ediExtEntity.CreatedTime = DateTime.Now;
                            await _bookingEDIExt.InsertAsync(ediExtEntity);
                        }


                        if (item.remarks != null)
                        {
                            foreach (var remark in item.remarks)
                            {
                                if (remark.Type == "1")
                                {
                                    BookingRemark bookingRemark = new BookingRemark();
                                    bookingRemark.PId = fdentity.Id;
                                    bookingRemark.CreatedUserId = user.Result.Id;
                                    bookingRemark.CreatedUserName = user.Result.Name.ToString();
                                    bookingRemark.CreatedTime = DateTime.Now;
                                    bookingRemark.Remark = "单证备注:" + remark.Remark;
                                    await _bookingremark.InsertAsync(bookingRemark);
                                }
                                else if (remark.Type == "2")
                                {

                                    BookingRemark bookingRemark = new BookingRemark();
                                    bookingRemark.PId = fdentity.Id;
                                    bookingRemark.CreatedUserId = user.Result.Id;
                                    bookingRemark.CreatedUserName = user.Result.Name.ToString();
                                    bookingRemark.CreatedTime = DateTime.Now;
                                    bookingRemark.Remark = "操作备注:" + remark.Remark;
                                    await _bookingremark.InsertAsync(bookingRemark);
                                }

                            }

                        }
                        ////添加booking日志
                        await _bookinglog.InsertAsync(new BookingLog
                        {
                            Type = "Add",
                            BookingId = fdentity.Id,
                            TenantId = Convert.ToInt64(UserManager.TENANT_ID),
                            CreatedTime = DateTime.Now,
                            CreatedUserId = user.Result.Id,
                            CreatedUserName = "系统"
                        });

                    }
                }
                return entity.Id;
                #endregion
            }
            else
            {

                #region 编辑
                if (string.IsNullOrWhiteSpace(model.MBLNO))
                {
                    throw Oops.Bah("请填写提单号！");
                }

                JsonUtil.PropToUpper(model, "ORDNO", "BSSTATUS", "YardContract", "YardContractTel", "YardContractEmail", "MARKS", "DESCRIPTION", "CONSIGNEENAME", "SHIPPERNAME", "NOTIFYPARTYNAME");
                var ms = JsonUtil.TrimFields(model);
                if (!string.IsNullOrEmpty(ms))
                {
                    throw Oops.Bah(ms);
                }

                if (model.ctnInputs != null)
                {
                    var groupList = model.ctnInputs.Where(x => x.CTNNUM > 0).GroupBy(c => c.CTNALL).Select(g => $"{g.Key}*{g.Sum(gg => gg.CTNNUM)}");
                    model.CNTRTOTAL = string.Join(" / ", groupList);
                }

                var main = await _rep.AsQueryable().Filter(null, true).Where(x => x.BSNO == model.BSNO).FirstAsync();


                var et = await _rep.AsQueryable().Filter(null, true).Where(x => x.MBLNO == model.MBLNO && x.TenantId == UserManager.TENANT_ID && x.HBLNO == model.HBLNO && x.BSNO != model.BSNO).FirstAsync();
                if (et != null)
                {
                    throw Oops.Bah("当前提单号已存在,请勿重复录入!");
                }
                var entity = model.Adapt<BookingOrder>();
                entity.Id = main.Id;
                entity.UpdatedUserName = user.Result.Name;
                entity.UpdatedUserId = user.Result.Id;
                entity.UpdatedTime = DateTime.Now;
                if (!string.IsNullOrEmpty(entity.ROUTE))
                {
                    entity.ROUTEID = userlist.Result.Where(x => x.Name == entity.ROUTE).Count() == 0 ? "" : userlist.Result.Where(x => x.Name == entity.ROUTE).Select(x => x.Id).FirstOrDefault().ToString();
                }
                if (!string.IsNullOrEmpty(entity.SALE))
                {
                    entity.SALEID = userlist.Result.Where(x => x.Name == entity.SALE).Count() == 0 ? "" : userlist.Result.Where(x => x.Name == entity.SALE).Select(x => x.Id).FirstOrDefault().ToString();
                }
                if (!string.IsNullOrEmpty(entity.OP))
                {
                    entity.OPID = userlist.Result.Where(x => x.Name == entity.OP).Count() == 0 ? "" : userlist.Result.Where(x => x.Name == entity.OP).Select(x => x.Id).FirstOrDefault().ToString();
                }
                if (!string.IsNullOrEmpty(entity.DOC))
                {
                    entity.DOCID = userlist.Result.Where(x => x.Name == entity.DOC).Count() == 0 ? "" : userlist.Result.Where(x => x.Name == entity.DOC).Select(x => x.Id).FirstOrDefault().ToString();
                }
                if (!string.IsNullOrEmpty(entity.CUSTSERVICE))
                {
                    entity.CUSTSERVICEID = userlist.Result.Where(x => x.Name == entity.CUSTSERVICE).Count() == 0 ? "" : userlist.Result.Where(x => x.Name == entity.CUSTSERVICE).Select(x => x.Id).FirstOrDefault().ToString();
                }
                if (!string.IsNullOrEmpty(entity.CUSTOMSER))
                {
                    entity.CUSTOMSERID = _djycustomer.AsQueryable().Where(x => x.ShortName == entity.CUSTOMSER).Select(x => x.CodeName).First();
                }
                if (!string.IsNullOrEmpty(entity.TRUCKER))
                {
                    entity.TRUCKERID = _djycustomer.AsQueryable().Where(x => x.ShortName == entity.TRUCKER).Select(x => x.CodeName).First();
                }
                await _rep.AsUpdateable(entity).IgnoreColumns(it => new
                {
                    it.ParentId,
                    it.TenantId,
                    it.CreatedTime,
                    it.CreatedUserId,
                    it.CreatedUserName
                }).ExecuteCommandAsync();
                var ctnlist = await _repCtn.AsQueryable().Where(x => x.BILLID == main.Id).Select(x => x.Id).ToListAsync();
                await _repCtn.DeleteAsync(x => x.BILLID == main.Id);
                await _ctndetailrep.DeleteAsync(x => ctnlist.Contains((long)x.CTNID));
                if (model.ctnInputs != null)
                {
                    foreach (var item in model.ctnInputs)
                    {
                        var ctnentity = item.Adapt<BookingCtn>();
                        ctnentity.BILLID = main.Id;
                        ctnentity.CreatedUserId = user.Result.Id;
                        ctnentity.CreatedUserName = user.Result.Name;
                        await _repCtn.InsertAsync(ctnentity);
                        if (item.ctnDetailInputs != null)
                        {
                            foreach (var it in item.ctnDetailInputs)
                            {
                                var ctndetail = it.Adapt<BookingCtnDetail>();
                                ctndetail.CTNID = ctnentity.Id;
                                ctndetail.CreatedUserId = user.Result.Id;
                                ctndetail.CreatedUserName = user.Result.Name;

                                await _ctndetailrep.InsertAsync(ctndetail);
                            }
                        }
                    }
                }

                if (model.BookingEDIExt != null)
                {
                    //检索EDI扩展
                    var ediExtEntity = _bookingEDIExt.FirstOrDefault(u => u.BookingId == main.Id);

                    if (ediExtEntity == null)
                    {
                        //写入EDI扩展
                        ediExtEntity = model.BookingEDIExt.Adapt<BookingEDIExt>();
                        ediExtEntity.BookingId = main.Id;
                        ediExtEntity.CreatedUserId = user.Result.Id;
                        ediExtEntity.CreatedUserName = user.Result.Name;
                        ediExtEntity.CreatedTime = DateTime.Now;
                        await _bookingEDIExt.InsertAsync(ediExtEntity);
                    }
                    else
                    {
                        //更新EDI扩展
                        var currEdiExtEntity = model.BookingEDIExt.Adapt<BookingEDIExt>();

                        currEdiExtEntity.Id = ediExtEntity.Id;
                        currEdiExtEntity.UpdatedUserId = user.Result.Id;
                        currEdiExtEntity.UpdatedTime = DateTime.Now;
                        await _bookingEDIExt.AsUpdateable(currEdiExtEntity).IgnoreColumns(it => new
                        {
                            it.BookingId,
                            it.TenantId,
                            it.CreatedTime,
                            it.CreatedUserId,
                            it.CreatedUserName
                        }).ExecuteCommandAsync();
                    }
                }



                if (model.remarks != null)
                {
                    await _bookingremark.DeleteAsync(x => x.PId == main.Id && (x.Remark.StartsWith("单证备注") || x.Remark.StartsWith("操作备注")));
                    foreach (var remark in model.remarks)
                    {
                        if (remark.Type == "1")
                        {
                            BookingRemark bookingRemark = new BookingRemark();
                            bookingRemark.PId = main.Id;
                            bookingRemark.CreatedUserId = user.Result.Id;
                            bookingRemark.CreatedUserName = user.Result.Name.ToString();
                            bookingRemark.CreatedTime = DateTime.Now;
                            bookingRemark.Remark = "单证备注:" + remark.Remark;
                            await _bookingremark.InsertAsync(bookingRemark);
                        }
                        else if (remark.Type == "2")
                        {

                            BookingRemark bookingRemark = new BookingRemark();
                            bookingRemark.PId = main.Id;
                            bookingRemark.CreatedUserId = user.Result.Id;
                            bookingRemark.CreatedUserName = user.Result.Name.ToString();
                            bookingRemark.CreatedTime = DateTime.Now;
                            bookingRemark.Remark = "操作备注:" + remark.Remark;
                            await _bookingremark.InsertAsync(bookingRemark);
                        }

                    }

                }
                bool flag = true;
                long bid = 0;
                foreach (PropertyDescriptor descriptor in TypeDescriptor.GetProperties(entity))
                {
                    string name = descriptor.Name;
                    if (name == "TenantId" || name == "CreatedTime" || name == "UpdatedTime" || name == "CreatedUserId" || name == "CreatedUserName")
                    {
                        continue;
                    }
                    object value = descriptor.GetValue(entity);
                    var oldvalue = main.GetType().GetProperty(name).GetValue(main, null);

                    if (name == "KGS" || name == "CBM")
                    {
                        if (Convert.ToDecimal(value) == Convert.ToDecimal(oldvalue))
                        {
                            continue;
                        }
                    }
                    string _oldvalue = oldvalue != null ? oldvalue.ToString() : "";
                    string _value = value != null ? value.ToString() : "";
                    if (_oldvalue != _value && !string.IsNullOrWhiteSpace(descriptor.Description))
                    {
                        if (flag)
                        {
                            ////添加booking日志
                            bid = await _bookinglog.InsertReturnSnowflakeIdAsync(new BookingLog
                            {
                                Type = "Edit",
                                BookingId = entity.Id,
                                TenantId = Convert.ToInt64(UserManager.TENANT_ID),
                                CreatedTime = DateTime.Now,
                                CreatedUserId = user.Result.Id,
                                CreatedUserName = user.Result.Name
                            });
                            flag = false;
                        }
                        await _bookinglogdetail.InsertReturnSnowflakeIdAsync(new BookingLogDetail
                        {
                            PId = bid,
                            Field = descriptor.Description,
                            OldValue = _oldvalue,
                            NewValue = _value,
                        });

                    }
                }
                //分单
                if (model.childrens != null)
                {
                    foreach (var item in model.childrens)
                    {
                        if (string.IsNullOrWhiteSpace(item.MBLNO))
                        {
                            throw Oops.Bah("请填写提单号！");
                        }
                        JsonUtil.PropToUpper(item, "ORDNO", "BSSTATUS", "YardContract", "YardContractTel", "YardContractEmail", "MARKS", "DESCRIPTION", "CONSIGNEENAME", "SHIPPERNAME", "NOTIFYPARTYNAME");

                        var fms = JsonUtil.TrimFields(item);
                        if (!string.IsNullOrEmpty(fms))
                        {
                            throw Oops.Bah(fms);
                        }
                        if (item.ctnInputs != null)
                        {
                            var groupList = item.ctnInputs.Where(x => x.CTNNUM > 0).GroupBy(c => c.CTNALL).Select(g => $"{g.Key}*{g.Sum(gg => gg.CTNNUM)}");
                            item.CNTRTOTAL = string.Join(" / ", groupList);
                        }

                        var fdmain = await _rep.AsQueryable().Filter(null, true).Where(x => x.BSNO == item.BSNO).FirstAsync();
                        var fdentity = item.Adapt<BookingOrder>();
                        if (fdmain != null)
                        {
                            var fdet = await _rep.Where(x => x.MBLNO == item.MBLNO && x.TenantId == UserManager.TENANT_ID && x.HBLNO == item.HBLNO && x.BSNO != fdmain.BSNO).FirstAsync();
                            if (fdet != null)
                            {
                                throw Oops.Bah($"当前提单号{fdet.MBLNO}_{fdet.HBLNO}已存在,请勿重复录入!");
                            }

                            fdentity.Id = fdmain.Id;
                            fdentity.UpdatedUserName = user.Result.Name;
                            fdentity.UpdatedUserId = user.Result.Id;
                            fdentity.UpdatedTime = DateTime.Now;
                            if (!string.IsNullOrEmpty(fdentity.ROUTE))
                            {
                                fdentity.ROUTEID = userlist.Result.Where(x => x.Name == fdentity.ROUTE).Count() == 0 ? "" : userlist.Result.Where(x => x.Name == fdentity.ROUTE).Select(x => x.Id).FirstOrDefault().ToString();
                            }
                            if (!string.IsNullOrEmpty(fdentity.SALE))
                            {
                                fdentity.SALEID = userlist.Result.Where(x => x.Name == fdentity.SALE).Count() == 0 ? "" : userlist.Result.Where(x => x.Name == fdentity.SALE).Select(x => x.Id).FirstOrDefault().ToString();
                            }
                            if (!string.IsNullOrEmpty(fdentity.OP))
                            {
                                fdentity.OPID = userlist.Result.Where(x => x.Name == fdentity.OP).Count() == 0 ? "" : userlist.Result.Where(x => x.Name == fdentity.OP).Select(x => x.Id).FirstOrDefault().ToString();
                            }
                            if (!string.IsNullOrEmpty(fdentity.DOC))
                            {
                                fdentity.DOCID = userlist.Result.Where(x => x.Name == fdentity.DOC).Count() == 0 ? "" : userlist.Result.Where(x => x.Name == fdentity.DOC).Select(x => x.Id).FirstOrDefault().ToString();
                            }
                            if (!string.IsNullOrEmpty(fdentity.CUSTSERVICE))
                            {
                                fdentity.CUSTSERVICEID = userlist.Result.Where(x => x.Name == fdentity.CUSTSERVICE).Count() == 0 ? "" : userlist.Result.Where(x => x.Name == fdentity.CUSTSERVICE).Select(x => x.Id).FirstOrDefault().ToString();
                            }
                            if (!string.IsNullOrEmpty(fdentity.CUSTOMSER))
                            {
                                fdentity.CUSTOMSERID = _djycustomer.AsQueryable().Where(x => x.ShortName == fdentity.CUSTOMSER).Select(x => x.CodeName).First();
                            }
                            if (!string.IsNullOrEmpty(fdentity.TRUCKER))
                            {
                                fdentity.TRUCKERID = _djycustomer.AsQueryable().Where(x => x.ShortName == fdentity.TRUCKER).Select(x => x.CodeName).First();
                            }
                            await _rep.AsUpdateable(fdentity).IgnoreColumns(it => new
                            {
                                it.ParentId,
                                it.TenantId,
                                it.CreatedTime,
                                it.CreatedUserId,
                                it.CreatedUserName
                            }).ExecuteCommandAsync();
                            var fdctnlist = await _repCtn.AsQueryable().Where(x => x.BILLID == fdmain.Id).Select(x => x.Id).ToListAsync();
                            await _repCtn.DeleteAsync(x => x.BILLID == fdmain.Id);
                            await _ctndetailrep.DeleteAsync(x => fdctnlist.Contains((long)x.CTNID));
                            if (item.ctnInputs != null)
                            {
                                foreach (var it in model.ctnInputs)
                                {
                                    var ctnentity = item.Adapt<BookingCtn>();
                                    ctnentity.BILLID = fdmain.Id;
                                    ctnentity.CreatedUserId = user.Result.Id;
                                    ctnentity.CreatedUserName = user.Result.Name;
                                    await _repCtn.InsertAsync(ctnentity);
                                    if (it.ctnDetailInputs != null)
                                    {
                                        foreach (var it_ in it.ctnDetailInputs)
                                        {
                                            var ctndetail = it_.Adapt<BookingCtnDetail>();
                                            ctndetail.CTNID = ctnentity.Id;
                                            ctndetail.CreatedUserId = user.Result.Id;
                                            ctndetail.CreatedUserName = user.Result.Name;
                                            await _ctndetailrep.InsertAsync(ctndetail);
                                        }
                                    }
                                }
                            }


                        }
                        else
                        {


                            fdentity.CreatedUserId = user.Result.Id;
                            fdentity.CreatedUserName = user.Result.Name;
                            fdentity.CreatedTime = DateTime.Now;
                            fdentity.ParentId = entity.Id;
                            await _rep.InsertAsync(fdentity);

                            if (item.ctnInputs != null)
                            {
                                foreach (var it in item.ctnInputs)
                                {
                                    var ctnentity = item.Adapt<BookingCtn>();
                                    ctnentity.BILLID = fdentity.Id;
                                    ctnentity.CreatedUserId = user.Result.Id;
                                    ctnentity.CreatedUserName = user.Result.Name;
                                    await _repCtn.InsertAsync(ctnentity);

                                    //这里保存有可能没有添加多品名，所有箱下没有货物信息
                                    if (it.ctnDetailInputs != null)
                                    {
                                        foreach (var dit in it.ctnDetailInputs)
                                        {
                                            var ctndetail = dit.Adapt<BookingCtnDetail>();
                                            ctndetail.CTNID = ctnentity.Id;
                                            ctndetail.CreatedUserId = user.Result.Id;
                                            ctndetail.CreatedUserName = user.Result.Name;
                                            await _ctndetailrep.InsertAsync(ctndetail);
                                        }
                                    }
                                }

                            }


                        }



                        if (item.BookingEDIExt != null)
                        {
                            //检索EDI扩展
                            var ediExtEntity = _bookingEDIExt.FirstOrDefault(u => u.BookingId == fdmain.Id);

                            if (ediExtEntity == null)
                            {
                                //写入EDI扩展
                                ediExtEntity = item.BookingEDIExt.Adapt<BookingEDIExt>();
                                ediExtEntity.BookingId = fdmain.Id;
                                ediExtEntity.CreatedUserId = user.Result.Id;
                                ediExtEntity.CreatedUserName = user.Result.Name;
                                ediExtEntity.CreatedTime = DateTime.Now;
                                await _bookingEDIExt.InsertAsync(ediExtEntity);
                            }
                            else
                            {
                                //更新EDI扩展
                                var currEdiExtEntity = model.BookingEDIExt.Adapt<BookingEDIExt>();

                                currEdiExtEntity.Id = ediExtEntity.Id;

                                await _bookingEDIExt.AsUpdateable(currEdiExtEntity).IgnoreColumns(it => new
                                {
                                    it.BookingId,
                                    it.TenantId,
                                    it.CreatedTime,
                                    it.CreatedUserId,
                                    it.CreatedUserName
                                }).ExecuteCommandAsync();
                            }
                        }



                        if (item.remarks != null)
                        {
                            await _bookingremark.DeleteAsync(x => x.PId == fdmain.Id && (x.Remark.StartsWith("单证备注") || x.Remark.StartsWith("操作备注")));
                            foreach (var remark in model.remarks)
                            {
                                if (remark.Type == "1")
                                {
                                    BookingRemark bookingRemark = new BookingRemark();
                                    bookingRemark.PId = fdmain.Id;
                                    bookingRemark.CreatedUserId = user.Result.Id;
                                    bookingRemark.CreatedUserName = user.Result.Name.ToString();
                                    bookingRemark.CreatedTime = DateTime.Now;
                                    bookingRemark.Remark = "单证备注:" + remark.Remark;
                                    await _bookingremark.InsertAsync(bookingRemark);
                                }
                                else if (remark.Type == "2")
                                {
                                    BookingRemark bookingRemark = new BookingRemark();
                                    bookingRemark.PId = fdmain.Id;
                                    bookingRemark.CreatedUserId = user.Result.Id;
                                    bookingRemark.CreatedUserName = user.Result.Name.ToString();
                                    bookingRemark.CreatedTime = DateTime.Now;
                                    bookingRemark.Remark = "操作备注:" + remark.Remark;
                                    await _bookingremark.InsertAsync(bookingRemark);
                                }

                            }

                        }
                        bool fdflag = true;
                        long fdbid = 0;
                        foreach (PropertyDescriptor descriptor in TypeDescriptor.GetProperties(fdentity))
                        {
                            string name = descriptor.Name;
                            if (name == "TenantId" || name == "CreatedTime" || name == "UpdatedTime" || name == "CreatedUserId" || name == "CreatedUserName")
                            {
                                continue;
                            }
                            object value = descriptor.GetValue(fdentity);
                            var oldvalue = fdmain.GetType().GetProperty(name).GetValue(main, null);

                            if (name == "KGS" || name == "CBM")
                            {
                                if (Convert.ToDecimal(value) == Convert.ToDecimal(oldvalue))
                                {
                                    continue;
                                }
                            }
                            string _oldvalue = oldvalue != null ? oldvalue.ToString() : "";
                            string _value = value != null ? value.ToString() : "";
                            if (_oldvalue != _value && !string.IsNullOrWhiteSpace(descriptor.Description))
                            {
                                if (fdflag)
                                {
                                    ////添加booking日志
                                    fdbid = await _bookinglog.InsertReturnSnowflakeIdAsync(new BookingLog
                                    {
                                        Type = "Edit",
                                        BookingId = fdentity.Id,
                                        TenantId = Convert.ToInt64(UserManager.TENANT_ID),
                                        CreatedTime = DateTime.Now,
                                        CreatedUserId = user.Result.Id,
                                        CreatedUserName = user.Result.Name,
                                    });
                                    fdflag = false;
                                }
                                await _bookinglogdetail.InsertReturnSnowflakeIdAsync(new BookingLogDetail
                                {
                                    PId = fdbid,
                                    Field = descriptor.Description,
                                    OldValue = _oldvalue,
                                    NewValue = _value,
                                });

                            }
                        }



                    }
                }


                return main.Id;
                #endregion
            }

        }




        /// <summary>
        /// 同步订舱批量  没有返回值
        /// </summary>
        /// <param name="list"></param>
        /// <returns></returns>
        [SqlSugarUnitOfWork]
        [HttpPost("/DataSync/SyncBookingList"), ApiUser(ApiCode = "SyncBookingList")]
        public async void SyncBookingList(List<SyncBookingOrderDto> list)
        {
            foreach (var model in list)
            {
                if (string.IsNullOrWhiteSpace(model.BSNO))
                {
                    throw Oops.Bah("主单BSNO未录入");
                }
                if (string.IsNullOrWhiteSpace(model.CreatedUserName))
                {
                    throw Oops.Bah("未录入创建人");
                }
                var userlist = _repUser.AsQueryable().Filter(null, true).ToListAsync();
                var user = _repUser.AsQueryable().Filter(null, true).Where(x => x.Name == model.CreatedUserName.Trim()).FirstAsync();
                if (user.Result == null)
                {
                    throw Oops.Bah($"未匹配到创建人  {model.CreatedUserName.Trim()} 请联系管理员添加相关用户");
                }
                var order = await _rep.AsQueryable().Filter(null, true).Where(x => x.BSNO == model.BSNO).FirstAsync();
                if (order == null)
                {

                    #region   新增
                    if (string.IsNullOrWhiteSpace(model.MBLNO))
                    {
                        throw Oops.Bah("请填写提单号！");
                    }

                    JsonUtil.PropToUpper(model, "ORDNO", "BSSTATUS", "YardContract", "YardContractTel", "YardContractEmail", "MARKS", "DESCRIPTION", "CONSIGNEENAME", "SHIPPERNAME", "NOTIFYPARTYNAME");
                    var ms = JsonUtil.TrimFields(model);
                    if (!string.IsNullOrEmpty(ms))
                    {
                        throw Oops.Bah(ms);
                    }
                    if (model.ctnInputs != null)
                    {
                        var groupList = model.ctnInputs.Where(x => x.CTNNUM > 0).GroupBy(c => c.CTNALL).Select(g => $"{g.Key}*{g.Sum(gg => gg.CTNNUM)}");
                        model.CNTRTOTAL = string.Join(" / ", groupList);
                    }
                    var et = await _rep.Where(x => x.MBLNO == model.MBLNO && x.TenantId == UserManager.TENANT_ID && x.HBLNO == model.HBLNO && x.ParentId == 0).FirstAsync();
                    if (et != null)
                    {

                        throw Oops.Bah("当前提单号已存在,请勿重复录入!");
                    }
                    var entity = model.Adapt<BookingOrder>();
                    if (!string.IsNullOrEmpty(entity.ROUTE))
                    {
                        entity.ROUTEID = userlist.Result.Where(x => x.Name == entity.ROUTE).Count() == 0 ? "" : userlist.Result.Where(x => x.Name == entity.ROUTE).Select(x => x.Id).FirstOrDefault().ToString();
                    }
                    if (!string.IsNullOrEmpty(entity.SALE))
                    {
                        entity.SALEID = userlist.Result.Where(x => x.Name == entity.SALE).Count() == 0 ? "" : userlist.Result.Where(x => x.Name == entity.SALE).Select(x => x.Id).FirstOrDefault().ToString();
                    }
                    if (!string.IsNullOrEmpty(entity.OP))
                    {
                        entity.OPID = userlist.Result.Where(x => x.Name == entity.OP).Count() == 0 ? "" : userlist.Result.Where(x => x.Name == entity.OP).Select(x => x.Id).FirstOrDefault().ToString();
                    }
                    if (!string.IsNullOrEmpty(entity.DOC))
                    {
                        entity.DOCID = userlist.Result.Where(x => x.Name == entity.DOC).Count() == 0 ? "" : userlist.Result.Where(x => x.Name == entity.DOC).Select(x => x.Id).FirstOrDefault().ToString();
                    }
                    if (!string.IsNullOrEmpty(entity.CUSTSERVICE))
                    {
                        entity.CUSTSERVICEID = userlist.Result.Where(x => x.Name == entity.CUSTSERVICE).Count() == 0 ? "" : userlist.Result.Where(x => x.Name == entity.CUSTSERVICE).Select(x => x.Id).FirstOrDefault().ToString();
                    }
                    if (!string.IsNullOrEmpty(entity.CUSTOMSER))
                    {
                        entity.CUSTOMSERID = _djycustomer.AsQueryable().Where(x => x.ShortName == entity.CUSTOMSER).Select(x => x.CodeName).First();
                    }
                    if (!string.IsNullOrEmpty(entity.TRUCKER))
                    {
                        entity.TRUCKERID = _djycustomer.AsQueryable().Where(x => x.ShortName == entity.TRUCKER).Select(x => x.CodeName).First();
                    }
                    entity.CreatedUserId = user.Result.Id;
                    entity.CreatedUserName = user.Result.Name.ToString();
                    entity.CreatedTime = DateTime.Now;
                    entity.ParentId = 0;
                    await _rep.InsertAsync(entity);
                    if (model.ctnInputs != null)
                    {
                        foreach (var item in model.ctnInputs)
                        {
                            var ctnentity = item.Adapt<BookingCtn>();
                            ctnentity.BILLID = entity.Id;
                            ctnentity.CreatedUserId = user.Result.Id;
                            ctnentity.CreatedUserName = user.Result.Name;
                            await _repCtn.InsertAsync(ctnentity);

                            //这里保存有可能没有添加多品名，所有箱下没有货物信息
                            if (item.ctnDetailInputs != null)
                            {
                                foreach (var it in item.ctnDetailInputs)
                                {
                                    var ctndetail = it.Adapt<BookingCtnDetail>();
                                    ctndetail.CTNID = ctnentity.Id;
                                    ctndetail.CreatedUserId = user.Result.Id;
                                    ctndetail.CreatedUserName = user.Result.Name;
                                    await _ctndetailrep.InsertAsync(ctndetail);
                                }
                            }
                        }
                    }

                    if (model.BookingEDIExt != null)
                    {
                        //写入EDI扩展
                        var ediExtEntity = model.BookingEDIExt.Adapt<BookingEDIExt>();

                        ediExtEntity.BookingId = entity.Id;

                        ediExtEntity.CreatedUserId = user.Result.Id;
                        ediExtEntity.CreatedUserName = user.Result.Name;
                        ediExtEntity.CreatedTime = DateTime.Now;
                        ediExtEntity.CreatedUserId = user.Result.Id;
                        ediExtEntity.CreatedUserName = user.Result.Name;
                        await _bookingEDIExt.InsertAsync(ediExtEntity);
                    }
                    ////添加booking日志
                    await _bookinglog.InsertAsync(new BookingLog
                    {
                        Type = "Add",
                        BookingId = entity.Id,
                        TenantId = Convert.ToInt64(UserManager.TENANT_ID),
                        CreatedTime = DateTime.Now,
                        CreatedUserId = user.Result.Id,
                        CreatedUserName = "系统"
                    });


                    //分单
                    if (model.childrens != null)
                    {
                        foreach (var item in model.childrens)
                        {
                            if (string.IsNullOrWhiteSpace(item.MBLNO))
                            {
                                throw Oops.Bah("请填写提单号！");
                            }
                            if (string.IsNullOrWhiteSpace(item.HBLNO))
                            {
                                throw Oops.Bah("请填写分提单号！");
                            }
                            JsonUtil.PropToUpper(item, "ORDNO", "BSSTATUS", "YardContract", "YardContractTel", "YardContractEmail", "MARKS", "DESCRIPTION", "CONSIGNEENAME", "SHIPPERNAME", "NOTIFYPARTYNAME");

                            var fms = JsonUtil.TrimFields(item);
                            if (!string.IsNullOrEmpty(fms))
                            {
                                throw Oops.Bah(fms);
                            }
                            if (item.ctnInputs != null)
                            {
                                var groupList = item.ctnInputs.Where(x => x.CTNNUM > 0).GroupBy(c => c.CTNALL).Select(g => $"{g.Key}*{g.Sum(gg => gg.CTNNUM)}");
                                item.CNTRTOTAL = string.Join(" / ", groupList);
                            }
                            var fdet = await _rep.Where(x => x.MBLNO == model.MBLNO && x.TenantId == UserManager.TENANT_ID && x.HBLNO == model.HBLNO && x.ParentId == entity.Id).FirstAsync();
                            if (fdet != null)
                            {

                                throw Oops.Bah($"当前分单中提单号({item.MBLNO}_{item.HBLNO})已存在,请勿重复录入!");

                            }
                            var fdentity = item.Adapt<BookingOrder>();
                            if (!string.IsNullOrEmpty(fdentity.ROUTE))
                            {
                                fdentity.ROUTEID = userlist.Result.Where(x => x.Name == fdentity.ROUTE).Count() == 0 ? "" : userlist.Result.Where(x => x.Name == fdentity.ROUTE).Select(x => x.Id).FirstOrDefault().ToString();
                            }
                            if (!string.IsNullOrEmpty(fdentity.SALE))
                            {
                                fdentity.SALEID = userlist.Result.Where(x => x.Name == fdentity.SALE).Count() == 0 ? "" : userlist.Result.Where(x => x.Name == fdentity.SALE).Select(x => x.Id).FirstOrDefault().ToString();
                            }
                            if (!string.IsNullOrEmpty(fdentity.OP))
                            {
                                fdentity.OPID = userlist.Result.Where(x => x.Name == fdentity.OP).Count() == 0 ? "" : userlist.Result.Where(x => x.Name == fdentity.OP).Select(x => x.Id).FirstOrDefault().ToString();
                            }
                            if (!string.IsNullOrEmpty(fdentity.DOC))
                            {
                                fdentity.DOCID = userlist.Result.Where(x => x.Name == fdentity.DOC).Count() == 0 ? "" : userlist.Result.Where(x => x.Name == fdentity.DOC).Select(x => x.Id).FirstOrDefault().ToString();
                            }
                            if (!string.IsNullOrEmpty(fdentity.CUSTSERVICE))
                            {
                                fdentity.CUSTSERVICEID = userlist.Result.Where(x => x.Name == fdentity.CUSTSERVICE).Count() == 0 ? "" : userlist.Result.Where(x => x.Name == fdentity.CUSTSERVICE).Select(x => x.Id).FirstOrDefault().ToString();
                            }
                            if (!string.IsNullOrEmpty(fdentity.CUSTOMSER))
                            {
                                fdentity.CUSTOMSERID = _djycustomer.AsQueryable().Where(x => x.ShortName == fdentity.CUSTOMSER).Select(x => x.CodeName).First();
                            }
                            if (!string.IsNullOrEmpty(entity.TRUCKER))
                            {
                                fdentity.TRUCKERID = _djycustomer.AsQueryable().Where(x => x.ShortName == fdentity.TRUCKER).Select(x => x.CodeName).First();
                            }
                            fdentity.CreatedUserId = user.Result.Id;
                            fdentity.CreatedUserName = user.Result.Name;
                            fdentity.CreatedTime = DateTime.Now;
                            fdentity.ParentId = entity.Id;
                            await _rep.InsertAsync(fdentity);

                            if (item.ctnInputs != null)
                            {
                                foreach (var it in item.ctnInputs)
                                {
                                    var ctnentity = item.Adapt<BookingCtn>();
                                    ctnentity.BILLID = fdentity.Id;
                                    ctnentity.CreatedUserId = user.Result.Id;
                                    ctnentity.CreatedUserName = user.Result.Name;
                                    await _repCtn.InsertAsync(ctnentity);

                                    //这里保存有可能没有添加多品名，所有箱下没有货物信息
                                    if (it.ctnDetailInputs != null)
                                    {
                                        foreach (var dit in it.ctnDetailInputs)
                                        {
                                            var ctndetail = dit.Adapt<BookingCtnDetail>();
                                            ctndetail.CTNID = ctnentity.Id;
                                            ctndetail.CreatedUserId = user.Result.Id;
                                            ctndetail.CreatedUserName = user.Result.Name;

                                            await _ctndetailrep.InsertAsync(ctndetail);
                                        }
                                    }
                                }

                            }



                            if (item.BookingEDIExt != null)
                            {
                                //写入EDI扩展
                                var ediExtEntity = model.BookingEDIExt.Adapt<BookingEDIExt>();

                                ediExtEntity.BookingId = fdentity.Id;
                                ediExtEntity.CreatedUserId = user.Result.Id;
                                ediExtEntity.CreatedUserName = user.Result.Name;
                                ediExtEntity.CreatedTime = DateTime.Now;
                                await _bookingEDIExt.InsertAsync(ediExtEntity);
                            }
                            ////添加booking日志
                            await _bookinglog.InsertAsync(new BookingLog
                            {
                                Type = "Add",
                                BookingId = fdentity.Id,
                                TenantId = Convert.ToInt64(UserManager.TENANT_ID),
                                CreatedTime = DateTime.Now,
                                CreatedUserId = user.Result.Id,
                                CreatedUserName = "系统"
                            });

                        }
                    }

                    #endregion
                }
                else
                {

                    #region 编辑
                    if (string.IsNullOrWhiteSpace(model.MBLNO))
                    {
                        throw Oops.Bah("请填写提单号！");
                    }

                    JsonUtil.PropToUpper(model, "ORDNO", "BSSTATUS", "YardContract", "YardContractTel", "YardContractEmail", "MARKS", "DESCRIPTION", "CONSIGNEENAME", "SHIPPERNAME", "NOTIFYPARTYNAME");

                    var ms = JsonUtil.TrimFields(model);
                    if (!string.IsNullOrEmpty(ms))
                    {
                        throw Oops.Bah(ms);
                    }
                    if (model.ctnInputs != null)
                    {
                        var groupList = model.ctnInputs.Where(x => x.CTNNUM > 0).GroupBy(c => c.CTNALL).Select(g => $"{g.Key}*{g.Sum(gg => gg.CTNNUM)}");
                        model.CNTRTOTAL = string.Join(" / ", groupList);
                    }

                    var main = await _rep.AsQueryable().Filter(null, true).Where(x => x.BSNO == model.BSNO).FirstAsync();


                    var et = await _rep.AsQueryable().Filter(null, true).Where(x => x.MBLNO == model.MBLNO && x.TenantId == UserManager.TENANT_ID && x.HBLNO == model.HBLNO && x.BSNO != model.BSNO).FirstAsync();
                    if (et != null)
                    {
                        throw Oops.Bah("当前提单号已存在,请勿重复录入!");
                    }
                    var entity = model.Adapt<BookingOrder>();
                    entity.Id = main.Id;
                    entity.UpdatedUserName = user.Result.Name;
                    entity.UpdatedUserId = user.Result.Id;
                    entity.UpdatedTime = DateTime.Now;
                    if (!string.IsNullOrEmpty(entity.ROUTE))
                    {
                        entity.ROUTEID = userlist.Result.Where(x => x.Name == entity.ROUTE).Count() == 0 ? "" : userlist.Result.Where(x => x.Name == entity.ROUTE).Select(x => x.Id).FirstOrDefault().ToString();
                    }
                    if (!string.IsNullOrEmpty(entity.SALE))
                    {
                        entity.SALEID = userlist.Result.Where(x => x.Name == entity.SALE).Count() == 0 ? "" : userlist.Result.Where(x => x.Name == entity.SALE).Select(x => x.Id).FirstOrDefault().ToString();
                    }
                    if (!string.IsNullOrEmpty(entity.OP))
                    {
                        entity.OPID = userlist.Result.Where(x => x.Name == entity.OP).Count() == 0 ? "" : userlist.Result.Where(x => x.Name == entity.OP).Select(x => x.Id).FirstOrDefault().ToString();
                    }
                    if (!string.IsNullOrEmpty(entity.DOC))
                    {
                        entity.DOCID = userlist.Result.Where(x => x.Name == entity.DOC).Count() == 0 ? "" : userlist.Result.Where(x => x.Name == entity.DOC).Select(x => x.Id).FirstOrDefault().ToString();
                    }
                    if (!string.IsNullOrEmpty(entity.CUSTSERVICE))
                    {
                        entity.CUSTSERVICEID = userlist.Result.Where(x => x.Name == entity.CUSTSERVICE).Count() == 0 ? "" : userlist.Result.Where(x => x.Name == entity.CUSTSERVICE).Select(x => x.Id).FirstOrDefault().ToString();
                    }
                    if (!string.IsNullOrEmpty(entity.CUSTOMSER))
                    {
                        entity.CUSTOMSERID = _djycustomer.AsQueryable().Where(x => x.ShortName == entity.CUSTOMSER).Select(x => x.CodeName).First();
                    }
                    if (!string.IsNullOrEmpty(entity.TRUCKER))
                    {
                        entity.TRUCKERID = _djycustomer.AsQueryable().Where(x => x.ShortName == entity.TRUCKER).Select(x => x.CodeName).First();
                    }
                    await _rep.AsUpdateable(entity).IgnoreColumns(it => new
                    {
                        it.ParentId,
                        it.TenantId,
                        it.CreatedTime,
                        it.CreatedUserId,
                        it.CreatedUserName
                    }).ExecuteCommandAsync();
                    var ctnlist = await _repCtn.AsQueryable().Where(x => x.BILLID == main.Id).Select(x => x.Id).ToListAsync();
                    await _repCtn.DeleteAsync(x => x.BILLID == main.Id);
                    await _ctndetailrep.DeleteAsync(x => ctnlist.Contains((long)x.CTNID));
                    if (model.ctnInputs != null)
                    {
                        foreach (var item in model.ctnInputs)
                        {
                            var ctnentity = item.Adapt<BookingCtn>();
                            ctnentity.BILLID = main.Id;
                            ctnentity.CreatedUserId = user.Result.Id;
                            ctnentity.CreatedUserName = user.Result.Name;
                            await _repCtn.InsertAsync(ctnentity);
                            if (item.ctnDetailInputs != null)
                            {
                                foreach (var it in item.ctnDetailInputs)
                                {
                                    var ctndetail = it.Adapt<BookingCtnDetail>();
                                    ctndetail.CTNID = ctnentity.Id;
                                    ctndetail.CreatedUserId = user.Result.Id;
                                    ctndetail.CreatedUserName = user.Result.Name;

                                    await _ctndetailrep.InsertAsync(ctndetail);
                                }
                            }
                        }
                    }

                    if (model.BookingEDIExt != null)
                    {
                        //检索EDI扩展
                        var ediExtEntity = _bookingEDIExt.FirstOrDefault(u => u.BookingId == main.Id);

                        if (ediExtEntity == null)
                        {
                            //写入EDI扩展
                            ediExtEntity = model.BookingEDIExt.Adapt<BookingEDIExt>();
                            ediExtEntity.BookingId = main.Id;
                            ediExtEntity.CreatedUserId = user.Result.Id;
                            ediExtEntity.CreatedUserName = user.Result.Name;
                            ediExtEntity.CreatedTime = DateTime.Now;
                            await _bookingEDIExt.InsertAsync(ediExtEntity);
                        }
                        else
                        {
                            //更新EDI扩展
                            var currEdiExtEntity = model.BookingEDIExt.Adapt<BookingEDIExt>();

                            currEdiExtEntity.Id = ediExtEntity.Id;
                            currEdiExtEntity.UpdatedUserId = user.Result.Id;
                            currEdiExtEntity.UpdatedTime = DateTime.Now;
                            await _bookingEDIExt.AsUpdateable(currEdiExtEntity).IgnoreColumns(it => new
                            {
                                it.BookingId,
                                it.TenantId,
                                it.CreatedTime,
                                it.CreatedUserId,
                                it.CreatedUserName
                            }).ExecuteCommandAsync();
                        }
                    }

                    bool flag = true;
                    long bid = 0;
                    foreach (PropertyDescriptor descriptor in TypeDescriptor.GetProperties(entity))
                    {
                        string name = descriptor.Name;
                        if (name == "TenantId" || name == "CreatedTime" || name == "UpdatedTime" || name == "CreatedUserId" || name == "CreatedUserName")
                        {
                            continue;
                        }
                        object value = descriptor.GetValue(entity);
                        var oldvalue = main.GetType().GetProperty(name).GetValue(main, null);

                        if (name == "KGS" || name == "CBM")
                        {
                            if (Convert.ToDecimal(value) == Convert.ToDecimal(oldvalue))
                            {
                                continue;
                            }
                        }
                        string _oldvalue = oldvalue != null ? oldvalue.ToString() : "";
                        string _value = value != null ? value.ToString() : "";
                        if (_oldvalue != _value && !string.IsNullOrWhiteSpace(descriptor.Description))
                        {
                            if (flag)
                            {
                                ////添加booking日志
                                bid = await _bookinglog.InsertReturnSnowflakeIdAsync(new BookingLog
                                {
                                    Type = "Edit",
                                    BookingId = entity.Id,
                                    TenantId = Convert.ToInt64(UserManager.TENANT_ID),
                                    CreatedTime = DateTime.Now,
                                    CreatedUserId = user.Result.Id,
                                    CreatedUserName = user.Result.Name
                                });
                                flag = false;
                            }
                            await _bookinglogdetail.InsertReturnSnowflakeIdAsync(new BookingLogDetail
                            {
                                PId = bid,
                                Field = descriptor.Description,
                                OldValue = _oldvalue,
                                NewValue = _value,
                            });

                        }
                    }
                    //分单
                    if (model.childrens != null)
                    {
                        foreach (var item in model.childrens)
                        {
                            if (string.IsNullOrWhiteSpace(item.MBLNO))
                            {
                                throw Oops.Bah("请填写提单号！");
                            }
                            JsonUtil.PropToUpper(item, "ORDNO", "BSSTATUS", "YardContract", "YardContractTel", "YardContractEmail", "MARKS", "DESCRIPTION", "CONSIGNEENAME", "SHIPPERNAME", "NOTIFYPARTYNAME");

                            var fms = JsonUtil.TrimFields(item);
                            if (!string.IsNullOrEmpty(fms))
                            {
                                throw Oops.Bah(fms);
                            }
                            if (item.ctnInputs != null)
                            {
                                var groupList = item.ctnInputs.Where(x => x.CTNNUM > 0).GroupBy(c => c.CTNALL).Select(g => $"{g.Key}*{g.Sum(gg => gg.CTNNUM)}");
                                item.CNTRTOTAL = string.Join(" / ", groupList);
                            }

                            var fdmain = await _rep.AsQueryable().Filter(null, true).Where(x => x.BSNO == item.BSNO).FirstAsync();
                            var fdentity = item.Adapt<BookingOrder>();
                            if (fdmain != null)
                            {
                                var fdet = await _rep.Where(x => x.MBLNO == item.MBLNO && x.TenantId == UserManager.TENANT_ID && x.HBLNO == item.HBLNO && x.BSNO != fdmain.BSNO).FirstAsync();
                                if (fdet != null)
                                {
                                    throw Oops.Bah($"当前提单号{fdet.MBLNO}_{fdet.HBLNO}已存在,请勿重复录入!");
                                }

                                fdentity.Id = fdmain.Id;
                                fdentity.UpdatedUserName = user.Result.Name;
                                fdentity.UpdatedUserId = user.Result.Id;
                                fdentity.UpdatedTime = DateTime.Now;
                                if (!string.IsNullOrEmpty(fdentity.ROUTE))
                                {
                                    fdentity.ROUTEID = userlist.Result.Where(x => x.Name == fdentity.ROUTE).Count() == 0 ? "" : userlist.Result.Where(x => x.Name == fdentity.ROUTE).Select(x => x.Id).FirstOrDefault().ToString();
                                }
                                if (!string.IsNullOrEmpty(fdentity.SALE))
                                {
                                    fdentity.SALEID = userlist.Result.Where(x => x.Name == fdentity.SALE).Count() == 0 ? "" : userlist.Result.Where(x => x.Name == fdentity.SALE).Select(x => x.Id).FirstOrDefault().ToString();
                                }
                                if (!string.IsNullOrEmpty(fdentity.OP))
                                {
                                    fdentity.OPID = userlist.Result.Where(x => x.Name == fdentity.OP).Count() == 0 ? "" : userlist.Result.Where(x => x.Name == fdentity.OP).Select(x => x.Id).FirstOrDefault().ToString();
                                }
                                if (!string.IsNullOrEmpty(fdentity.DOC))
                                {
                                    fdentity.DOCID = userlist.Result.Where(x => x.Name == fdentity.DOC).Count() == 0 ? "" : userlist.Result.Where(x => x.Name == fdentity.DOC).Select(x => x.Id).FirstOrDefault().ToString();
                                }
                                if (!string.IsNullOrEmpty(fdentity.CUSTSERVICE))
                                {
                                    fdentity.CUSTSERVICEID = userlist.Result.Where(x => x.Name == fdentity.CUSTSERVICE).Count() == 0 ? "" : userlist.Result.Where(x => x.Name == fdentity.CUSTSERVICE).Select(x => x.Id).FirstOrDefault().ToString();
                                }
                                if (!string.IsNullOrEmpty(fdentity.CUSTOMSER))
                                {
                                    fdentity.CUSTOMSERID = _djycustomer.AsQueryable().Where(x => x.ShortName == fdentity.CUSTOMSER).Select(x => x.CodeName).First();
                                }
                                if (!string.IsNullOrEmpty(fdentity.TRUCKER))
                                {
                                    fdentity.TRUCKERID = _djycustomer.AsQueryable().Where(x => x.ShortName == fdentity.TRUCKER).Select(x => x.CodeName).First();
                                }
                                await _rep.AsUpdateable(fdentity).IgnoreColumns(it => new
                                {
                                    it.ParentId,
                                    it.TenantId,
                                    it.CreatedTime,
                                    it.CreatedUserId,
                                    it.CreatedUserName
                                }).ExecuteCommandAsync();
                                var fdctnlist = await _repCtn.AsQueryable().Where(x => x.BILLID == fdmain.Id).Select(x => x.Id).ToListAsync();
                                await _repCtn.DeleteAsync(x => x.BILLID == fdmain.Id);
                                await _ctndetailrep.DeleteAsync(x => fdctnlist.Contains((long)x.CTNID));
                                if (item.ctnInputs != null)
                                {
                                    foreach (var it in model.ctnInputs)
                                    {
                                        var ctnentity = item.Adapt<BookingCtn>();
                                        ctnentity.BILLID = fdmain.Id;
                                        ctnentity.CreatedUserId = user.Result.Id;
                                        ctnentity.CreatedUserName = user.Result.Name;
                                        await _repCtn.InsertAsync(ctnentity);
                                        if (it.ctnDetailInputs != null)
                                        {
                                            foreach (var it_ in it.ctnDetailInputs)
                                            {
                                                var ctndetail = it_.Adapt<BookingCtnDetail>();
                                                ctndetail.CTNID = ctnentity.Id;
                                                ctndetail.CreatedUserId = user.Result.Id;
                                                ctndetail.CreatedUserName = user.Result.Name;
                                                await _ctndetailrep.InsertAsync(ctndetail);
                                            }
                                        }
                                    }
                                }


                            }
                            else
                            {


                                fdentity.CreatedUserId = user.Result.Id;
                                fdentity.CreatedUserName = user.Result.Name;
                                fdentity.CreatedTime = DateTime.Now;
                                fdentity.ParentId = entity.Id;
                                await _rep.InsertAsync(fdentity);

                                if (item.ctnInputs != null)
                                {
                                    foreach (var it in item.ctnInputs)
                                    {
                                        var ctnentity = item.Adapt<BookingCtn>();
                                        ctnentity.BILLID = fdentity.Id;
                                        ctnentity.CreatedUserId = user.Result.Id;
                                        ctnentity.CreatedUserName = user.Result.Name;
                                        await _repCtn.InsertAsync(ctnentity);

                                        //这里保存有可能没有添加多品名，所有箱下没有货物信息
                                        if (it.ctnDetailInputs != null)
                                        {
                                            foreach (var dit in it.ctnDetailInputs)
                                            {
                                                var ctndetail = dit.Adapt<BookingCtnDetail>();
                                                ctndetail.CTNID = ctnentity.Id;
                                                ctndetail.CreatedUserId = user.Result.Id;
                                                ctndetail.CreatedUserName = user.Result.Name;
                                                await _ctndetailrep.InsertAsync(ctndetail);
                                            }
                                        }
                                    }

                                }


                            }



                            if (item.BookingEDIExt != null)
                            {
                                //检索EDI扩展
                                var ediExtEntity = _bookingEDIExt.FirstOrDefault(u => u.BookingId == fdmain.Id);

                                if (ediExtEntity == null)
                                {
                                    //写入EDI扩展
                                    ediExtEntity = item.BookingEDIExt.Adapt<BookingEDIExt>();
                                    ediExtEntity.BookingId = fdmain.Id;
                                    ediExtEntity.CreatedUserId = user.Result.Id;
                                    ediExtEntity.CreatedUserName = user.Result.Name;
                                    ediExtEntity.CreatedTime = DateTime.Now;
                                    await _bookingEDIExt.InsertAsync(ediExtEntity);
                                }
                                else
                                {
                                    //更新EDI扩展
                                    var currEdiExtEntity = model.BookingEDIExt.Adapt<BookingEDIExt>();

                                    currEdiExtEntity.Id = ediExtEntity.Id;

                                    await _bookingEDIExt.AsUpdateable(currEdiExtEntity).IgnoreColumns(it => new
                                    {
                                        it.BookingId,
                                        it.TenantId,
                                        it.CreatedTime,
                                        it.CreatedUserId,
                                        it.CreatedUserName
                                    }).ExecuteCommandAsync();
                                }
                            }

                            bool fdflag = true;
                            long fdbid = 0;
                            foreach (PropertyDescriptor descriptor in TypeDescriptor.GetProperties(fdentity))
                            {
                                string name = descriptor.Name;
                                if (name == "TenantId" || name == "CreatedTime" || name == "UpdatedTime" || name == "CreatedUserId" || name == "CreatedUserName")
                                {
                                    continue;
                                }
                                object value = descriptor.GetValue(fdentity);
                                var oldvalue = fdmain.GetType().GetProperty(name).GetValue(main, null);

                                if (name == "KGS" || name == "CBM")
                                {
                                    if (Convert.ToDecimal(value) == Convert.ToDecimal(oldvalue))
                                    {
                                        continue;
                                    }
                                }
                                string _oldvalue = oldvalue != null ? oldvalue.ToString() : "";
                                string _value = value != null ? value.ToString() : "";
                                if (_oldvalue != _value && !string.IsNullOrWhiteSpace(descriptor.Description))
                                {
                                    if (fdflag)
                                    {
                                        ////添加booking日志
                                        fdbid = await _bookinglog.InsertReturnSnowflakeIdAsync(new BookingLog
                                        {
                                            Type = "Edit",
                                            BookingId = fdentity.Id,
                                            TenantId = Convert.ToInt64(UserManager.TENANT_ID),
                                            CreatedTime = DateTime.Now,
                                            CreatedUserId = user.Result.Id,
                                            CreatedUserName = user.Result.Name,
                                        });
                                        fdflag = false;
                                    }
                                    await _bookinglogdetail.InsertReturnSnowflakeIdAsync(new BookingLogDetail
                                    {
                                        PId = fdbid,
                                        Field = descriptor.Description,
                                        OldValue = _oldvalue,
                                        NewValue = _value,
                                    });

                                }
                            }
                        }
                    }
                    #endregion
                }
            }
        }


        #endregion

        #region 下载数据

        #endregion

        #region 其他
        /// <summary>
        /// 测试用
        /// </summary>
        /// <returns></returns>
        [HttpGet("/DataSync/Test"), ApiUser(ApiCode = "Test")]
        public async Task<string> Test()
        {
            return $"当前用户：{UserManager.UserId} {UserManager.Name} ，当前租户：{UserManager.TENANT_ID} {UserManager.TENANT_NAME}，管理员类型：{(UserManager.IsSuperAdmin ? "超级管理员" : (UserManager.IsTenantAdmin ? "租户管理员" : "普通用户"))}";
        }
        #endregion
    }
}