BookingHeChuan/Myshipping.Application/Service/BookingOrder/BookingValueAddedService.cs

using Furion;
using Furion.DependencyInjection;
using Furion.DistributedIDGenerator;
using Furion.DynamicApiController;
using Furion.Extensions;
using Furion.FriendlyException;
using Furion.JsonSerialization;
using Furion.RemoteRequest.Extensions;
using Mapster;
using MathNet.Numerics;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using Microsoft.Extensions.Logging;
using Microsoft.Extensions.Options;
using Myshipping.Application.ConfigOption;
using Myshipping.Application.Entity;
using Myshipping.Core;
using Myshipping.Core.Entity;
using Myshipping.Core.Service;
using MySqlX.XDevAPI.Common;
using Org.BouncyCastle.Crypto;
using Org.BouncyCastle.Utilities;
using SqlSugar;
using StackExchange.Profiling.Internal;
using System;
using System.Collections.Generic;
using System.Collections.Specialized;
using System.Diagnostics;
using System.IO;
using System.Linq;
using System.Net.Http;
using System.Net.NetworkInformation;
using System.Reflection.Metadata.Ecma335;
using System.Runtime.InteropServices;
using System.Text;
using System.Text.Json;
using System.Text.RegularExpressions;
using System.Threading;
using System.Threading.Tasks;
using System.Web;
using Ubiety.Dns.Core;
using Yitter.IdGenerator;

namespace Myshipping.Application
{
    /// <summary>
    /// 订舱增值类服务
    /// </summary>
    [ApiDescriptionSettings("Application", Name = "BookingValueAdded", Order = 9)]
    public class BookingValueAddedService : IBookingValueAddedService, IDynamicApiController, ITransient
    {
        private readonly ISysCacheService _cache;
        private readonly IBookingOrderService _bookingOrderService;
        private readonly ILogger<BookingTruckService> _logger;
        private readonly SqlSugarRepository<BookingOrder> _bookingOrderRepository;
        private readonly SqlSugarRepository<BookingFile> _bookingfile;
        private readonly SqlSugarRepository<DjyWebsiteAccountConfig> _djyWebsiteAccountConfigRepository;
        private readonly SqlSugarRepository<SysUser> _sysUserRepository;
        private readonly SqlSugarRepository<BookingLetteryard> _bookingLetteryardRepository;
        private readonly SqlSugarRepository<TaskBCInfo> _taskBCInfoRepository;

        const string CONST_MAPPING_BC_MODULE_ROUTE = "BC_DOWN_RT";
        const string CONST_MAPPING_DRAFT_MODULE_ROUTE = "DRAFT_DOWN_RT";
        const string CONST_MAPPING_MANIALLO_CHK_MODULE_ROUTE = "MANI_ALLOC_CHK_RT";
        
        const string CONST_FORMAT_BC_URL = "{0}_bc_down_url";
        const string CONST_FORMAT_DRAFT_URL = "{0}_draft_down_url";
        const string CONST_FORMAT_MANIALLO_CHK_URL = "{0}_manialloc_chk_url";

        const string CONST_FORMAT_WEB = "{0}Web";

        const string CONST_BC_FILE_PARSE_URL = "bc_file_parse_url";
        const string CONST_BC_FILE_READ_URL = "bc_file_pdf_read_url";

        public BookingValueAddedService(ISysCacheService cache, ILogger<BookingTruckService> logger,
            SqlSugarRepository<BookingOrder> bookingOrderRepository, SqlSugarRepository<BookingFile> bookingfile,
            SqlSugarRepository<DjyWebsiteAccountConfig> djyWebsiteAccountConfigRepository, SqlSugarRepository<SysUser> sysUserRepository, 
            SqlSugarRepository<BookingLetteryard> bookingLetteryardRepository, IBookingOrderService bookingOrderService
            , SqlSugarRepository<TaskBCInfo> taskBCInfoRepository)
        {
            _cache = cache;
            _logger = logger;

            _bookingOrderRepository = bookingOrderRepository;
            _bookingfile = bookingfile;

            _djyWebsiteAccountConfigRepository = djyWebsiteAccountConfigRepository;
            _sysUserRepository = sysUserRepository;
            _bookingLetteryardRepository = bookingLetteryardRepository;
            _bookingOrderService = bookingOrderService;
            _taskBCInfoRepository = taskBCInfoRepository;
        }


        /// <summary>
        /// 批量BC下载
        /// </summary>
        /// <param name="bookingIds">订舱主键数组</param>
        /// <returns>返回回执</returns>
        [HttpPost("/BookingValueAdded/DownloadBookingConfirm")]
        public async Task<TaskManageOrderResultDto> DownloadBookingConfirm([FromBody]long[] bookingIds)
        {
            TaskManageOrderResultDto result = new TaskManageOrderResultDto();

            List<Task<TaskManageOrderResultDto>> taskList = new List<Task<TaskManageOrderResultDto>>();

            string batchNo = IDGen.NextID().ToString();
            try
            {
                /*
                 1、订舱主键提取提单号、订舱编号，优先去提单号，其次订舱编号
                 2、根据不同的船公司调取单独的配置账户。
                 3、不同船公司对应不同的接口。
                 4、轮询异步调取接口等待返回接口。
                 5、成功后将文件链接存入附件表。
                 6、等待所有请求完成返回统计结果。
                 */

                var list = _bookingOrderRepository.AsQueryable()
                    .Where(a => bookingIds.Contains(a.Id)).ToList();

                if (list.Count != bookingIds.Length)
                    throw Oops.Oh($"订舱信息获取失败，订舱信息不存在或已作废");

                var noList = bookingIds.Select((a, idx) => new { no = idx + 1, id = a }).ToList();

                foreach (var bk in list)
                {
                    var sortNo = noList.FirstOrDefault(a=>a.id == bk.Id).no;
                    taskList.Add(Task.Run(() => InnerDownloadBookingConfirm(bk, batchNo, sortNo)));
                }

                Task.WaitAll(taskList.ToArray());

                result.succ = true;
                result.msg = "批量下载BC成功";

                var downResultList = taskList.Select(x => x.Result).ToList();

                if (downResultList.Any(x => !x.succ))
                {
                    result.succ = false;
                    result.msg = "BC下载失败";
                }
                else
                {
                    result.succ = true;
                    result.msg = downResultList.FirstOrDefault().msg;
                }

                result.ext = downResultList;

                var succ = downResultList.Count(x => x.succ);
                var fail = downResultList.Count(x => !x.succ);

                if (succ > 0)
                {
                    result.batchTotal = succ.ToString();
                }
                else
                {
                    result.batchTotal = "- ";
                }   

                if(fail > 0)
                {
                    result.batchTotal += "/" + fail.ToString();
                }
                else
                {
                    result.batchTotal += " -";
                }
            }
            catch (Exception ex)
            {
                result.succ = false;
                result.msg = $"批量BC下载异常，原因：{ex.Message}";
            }

            return result;
        }

        #region 单票下载BC
        /// <summary>
        /// 单票下载BC
        /// </summary>
        /// <param name="bookingOrder">订舱详情</param>
        /// <param name="batchNo">批次号</param>
        /// <param name="sortNo">请求顺序号</param>
        /// <returns>返回回执</returns>
        private async Task<TaskManageOrderResultDto> InnerDownloadBookingConfirm(BookingOrder bookingOrder,string batchNo, int sortNo)
        {
            TaskManageOrderResultDto result = new TaskManageOrderResultDto();

            result.bno = bookingOrder.MBLNO;

            try
            {
                /*
                1、根据船公司代码匹配船公司映射。
                2、BC和DRAFT是分别2个请求地址。
                3、生成请求报文。
                4、请求相应的链接。
                5、返回成功写入附件。
                */
                if (string.IsNullOrWhiteSpace(bookingOrder.MBLNO))
                {
                    if (!string.IsNullOrWhiteSpace(bookingOrder.CUSTNO))
                    {
                        result.bno = $"订 {bookingOrder.CUSTNO}";
                    }
                    else
                    {
                        result.bno = $"NO.{sortNo}";
                    }

                    throw Oops.Bah($"主提单号不能为空");
                }

                var bcOrDraftRouteCfg = _cache.GetAllMappingCarrier().GetAwaiter().GetResult()
                .FirstOrDefault(t => t.Module.Equals(CONST_MAPPING_BC_MODULE_ROUTE, StringComparison.OrdinalIgnoreCase)
                && t.Code.Equals(bookingOrder.CARRIERID?.Trim(), StringComparison.OrdinalIgnoreCase));

                _logger.LogInformation("提单号【{mbl}】根据订舱的船公司代码{ca} 提取船公司映射完成，结果={rlt}",
                    bookingOrder.MBLNO, bookingOrder.CARRIERID, bcOrDraftRouteCfg);

                if (bcOrDraftRouteCfg == null)
                {
                    _logger.LogInformation("提单号{mbl} 根据订舱的船公司代码{ca} 提取船公司映射失败",
                    bookingOrder.MBLNO, bookingOrder.CARRIERID);

                    throw Oops.Bah($"船公司={bookingOrder.CARRIERID} 暂不支持BC下载");
                }

                string urlKey = string.Format(CONST_FORMAT_BC_URL, bcOrDraftRouteCfg.MapCode.ToLower());

                var bcUrl = _cache.GetAllDictData().GetAwaiter().GetResult()
                .FirstOrDefault(x => x.TypeCode == "url_set" && x.Code.Equals(urlKey, StringComparison.OrdinalIgnoreCase))?.Value;

                _logger.LogInformation("提单号{mbl} 根据订舱的船公司代码{ca} 提取BC下载URL完成，结果={rlt}",
                    bookingOrder.MBLNO, bookingOrder.CARRIERID, bcUrl);

                if (string.IsNullOrWhiteSpace(bcUrl))
                {
                    _logger.LogInformation("提单号{0} 根据订舱的船公司代码{1} 提取BC下载URL失败，未取到配置key={key}",
                    bookingOrder.MBLNO, bookingOrder.CARRIERID, urlKey);

                    throw Oops.Bah($"船公司={bookingOrder.CARRIERID} 未配置请求地址{urlKey} 请联系管理员");
                }

                string webKey = string.Format(CONST_FORMAT_WEB, bcOrDraftRouteCfg.MapCode);

                //获取个人对应的账户,这里GetAccountConfig逻辑优先取个人，个人没有配置取公司对应配置
                var userWebAccountConfig = GetAccountConfig(webKey, UserManager.UserId,UserManager.TENANT_ID).GetAwaiter()
                    .GetResult();

                _logger.LogInformation("批次={no} 获取获取网站的账户完成，result={Num}", batchNo, JSON.Serialize(userWebAccountConfig));

                if (userWebAccountConfig == null)
                    throw Oops.Oh($" 未配置个人或公司网站账户，网站{webKey}");

                BCOrDraftRequestDto requestDto = new BCOrDraftRequestDto
                {
                    user_key = App.Configuration["BCOrDraftUserKey"],
                    user_secret = App.Configuration["BCOrDraftUserSecret"],
                    web_user = userWebAccountConfig.Account?.Trim(),
                    web_psw = userWebAccountConfig.Password?.Trim(),
                    bno = bookingOrder.MBLNO,
                    is_parse = false
                };

                _logger.LogInformation("批次={no} json={json} 请求BC远端下载开始", batchNo, JSON.Serialize(requestDto));

                DateTime bDate = DateTime.Now;
                //开始请求BC
                var rlt = await ExcuteBCDownload(bcUrl, requestDto, batchNo);

                DateTime eDate = DateTime.Now;
                TimeSpan ts = eDate.Subtract(bDate);
                var timeDiff = ts.TotalMilliseconds;

                _logger.LogInformation("批次={no} result={result} 请求BC远端下载结束 耗时：{timeDiff}ms. ", batchNo, 
                    JSON.Serialize(rlt),timeDiff);

                if (rlt.code == 200)
                {
                    _logger.LogInformation("批次={no} 下载文件成功，转存本地", batchNo);

                    string currFilePath = rlt.data.FirstOrDefault().path;

                    string fileTypeCode = "bc";
                    string fileTypeName = "Booking Confirmation";

                    //读取文件配置
                    var fileCfg = App.GetOptions<BookingAttachOptions>();

                    string relativePath = $"{fileCfg.relativePath}\\bcfiles\\{bookingOrder.Id}";
                    string filePath = $"{(!string.IsNullOrWhiteSpace(fileCfg.basePath) ? fileCfg.basePath : App.WebHostEnvironment.WebRootPath)}\\{relativePath}";

                    string fileFullName = $"{filePath}\\{new System.IO.FileInfo(currFilePath).Name}";

                    if (RuntimeInformation.IsOSPlatform(OSPlatform.Linux))
                    {
                        relativePath = relativePath.Replace("\\", "/");
                        filePath = filePath.Replace("\\", "/");

                        fileFullName = fileFullName.Replace("\\", "/");
                    }

                    _logger.LogInformation("批次={no} 生成文件保存路径完成 路由={filePath} 服务器系统={system}", batchNo, filePath, RuntimeInformation.OSDescription);
                    //预先创建目录
                    if (!Directory.Exists(filePath))
                    {
                        Directory.CreateDirectory(filePath);
                    }

                    var bcStream = await currFilePath.GetAsStreamAsync();

                    using (var fileStream = File.Create(fileFullName))
                    {
                        await bcStream.CopyToAsync(fileStream);
                    }

                    _logger.LogInformation("批次={no} 完成文件保存 filepath={path}", batchNo, fileFullName);

                    string bookFilePath = string.Empty;

                    if (RuntimeInformation.IsOSPlatform(OSPlatform.Linux))
                    {
                        bookFilePath = System.Text.RegularExpressions.Regex.Match(fileFullName, relativePath.Replace("/", "\\/") + ".*").Value;
                    }
                    else
                    {
                        bookFilePath = System.Text.RegularExpressions.Regex.Match(fileFullName, relativePath.Replace("\\", "\\\\") + ".*").Value;
                    }

                    //这里先写入附件表
                    await SaveEDIFile(bookingOrder.Id, bookFilePath, new System.IO.FileInfo(currFilePath).Name,
                        fileTypeCode, fileTypeName);

                    result.succ = true;
                    result.msg = "BC下载成功";
                }
                else
                {
                    result.succ = false;
                    result.msg = $"BC下载失败，{rlt.msg}";
                }
            }
            catch (Exception ex)
            {
                result.succ = false;
                result.msg = $"BC下载失败，{ex.Message}";
            }

            return result;
        }
        #endregion

        #region 异步写入订舱附件表
        /// <summary>
        /// 异步写入订舱附件表
        /// </summary>
        /// <param name="boookId">订舱ID</param>
        /// <param name="FilePath">文件路径</param>
        /// <param name="fileName">文件名</param>
        /// <param name="fileTypeCode">附件类型代码</param>
        /// <param name="fileTypeName">附件类型名称</param>
        /// <returns></returns>
        [NonAction]
        private async Task SaveEDIFile(long boookId, string FilePath, string fileName, string fileTypeCode = "bc", string fileTypeName = "Booking Confirmation")
        {
            /*
             直接将附件信息写入附件表
             */
            //EDI文件	
            var bookFile = new BookingFile
            {
                Id = YitIdHelper.NextId(),
                FileName = fileName,
                FilePath = FilePath,
                TypeCode = fileTypeCode,
                TypeName = fileTypeName,
                BookingId = boookId,
            };

            await _bookingfile.InsertAsync(bookFile);
        }
        #endregion

        /// <summary>
        /// 批量Draft下载
        /// </summary>
        /// <param name="bookingIds">订舱主键数组</param>
        /// <returns></returns>
        [HttpPost("/BookingValueAdded/DownloadDraft")]
        public async Task<TaskManageOrderResultDto> DownloadDraft([FromBody]long[] bookingIds)
        {
            TaskManageOrderResultDto result = new TaskManageOrderResultDto();
            List<Task<TaskManageOrderResultDto>> taskList = new List<Task<TaskManageOrderResultDto>>();

            string batchNo = IDGen.NextID().ToString();

            try
            {
                /*
                 1、订舱主键提取提单号、订舱编号，优先去提单号，其次订舱编号
                 2、根据不同的船公司调取单独的配置账户。
                 3、不同船公司对应不同的接口。
                 4、轮询异步调取接口等待返回接口。
                 5、成功后将文件链接存入附件表。
                 6、等待所有请求完成返回统计结果。
                 */

                var list = _bookingOrderRepository.AsQueryable()
                    .Where(a => bookingIds.Contains(a.Id)).ToList();

                if (list.Count != bookingIds.Length)
                    throw Oops.Oh($"订舱信息获取失败，订舱信息不存在或已作废");

                var noList = bookingIds.Select((a, idx) => new { no = idx + 1, id = a }).ToList();
                foreach (var bk in list)
                {
                    var sortNo = noList.FirstOrDefault(a=>a.id == bk.Id).no;
                    taskList.Add(Task.Run(() => InnerDownloadDraft(bk, batchNo, sortNo)));
                }

                Task.WaitAll(taskList.ToArray());

                result.succ = true;
                result.msg = "下载Draft成功";

                var downResultList = taskList.Select(x => x.Result).ToList();

                if (downResultList.Any(x => !x.succ))
                {
                    result.succ = false;
                    result.msg = "Draft下载失败";
                }
                else
                {
                    result.succ = true;
                    result.msg = downResultList.FirstOrDefault().msg;
                }

                result.ext = downResultList;

                var succ = downResultList.Count(x => x.succ);
                var fail = downResultList.Count(x => !x.succ);

                if (succ > 0)
                {
                    result.batchTotal = succ.ToString();
                }
                else
                {
                    result.batchTotal = "- ";
                }

                if (fail > 0)
                {
                    result.batchTotal += "/" + fail.ToString();
                }
                else
                {
                    result.batchTotal += " -";
                }
            }
            catch (Exception ex)
            {
                result.succ = false;
                result.msg = $"下载Draft异常，原因：{ex.Message}";
            }

            return result;
        }

        #region 单票下载BC
        /// <summary>
        /// 单票下载BC
        /// </summary>
        /// <param name="bookingOrder">订舱详情</param>
        /// <param name="batchNo">批次号</param>
        /// <param name="sortNo">请求顺序号</param>
        /// <returns>返回回执</returns>
        private async Task<TaskManageOrderResultDto> InnerDownloadDraft(BookingOrder bookingOrder, string batchNo,int sortNo)
        {
            TaskManageOrderResultDto result = new TaskManageOrderResultDto();

            result.bno = bookingOrder.MBLNO;

            try
            {
                /*
                1、根据船公司代码匹配船公司映射。
                2、BC和DRAFT是分别2个请求地址。
                3、生成请求报文。
                4、请求相应的链接。
                5、返回成功写入附件。
                */
                if(bookingOrder.CARRIERID.Equals("ESL", StringComparison.OrdinalIgnoreCase))
                {
                    if(string.IsNullOrWhiteSpace(bookingOrder.TMBLNO))
                    {
                        if (!string.IsNullOrWhiteSpace(bookingOrder.CUSTNO))
                        {
                            result.bno = $"订 {bookingOrder.CUSTNO}";
                        }
                        else if (string.IsNullOrWhiteSpace(bookingOrder.MBLNO))
                        {
                            result.bno = $"NO.{sortNo}";
                        }

                        throw Oops.Bah($"EP号不能为空");
                    }
                }
                else
                {
                    if (string.IsNullOrWhiteSpace(bookingOrder.MBLNO))
                    {
                        if (!string.IsNullOrWhiteSpace(bookingOrder.CUSTNO))
                        {
                            result.bno = $"订 {bookingOrder.CUSTNO}";
                        }
                        else
                        {
                            result.bno = $"NO.{sortNo}";
                        }

                        throw Oops.Bah($"主提单号不能为空");
                    }
                }

                var bcOrDraftRouteCfg = _cache.GetAllMappingCarrier().GetAwaiter().GetResult()
                .FirstOrDefault(t => t.Module.Equals(CONST_MAPPING_DRAFT_MODULE_ROUTE, StringComparison.OrdinalIgnoreCase)
                && t.Code.Equals(bookingOrder.CARRIERID?.Trim(), StringComparison.OrdinalIgnoreCase));

                _logger.LogInformation("提单号{mbl} 根据订舱的船公司代码{ca} 提取船公司映射完成，结果={rlt}",
                    bookingOrder.MBLNO, bookingOrder.CARRIERID, bcOrDraftRouteCfg);

                if (bcOrDraftRouteCfg == null)
                {
                    _logger.LogInformation("提单号{0} 根据订舱的船公司代码{1} 提取船公司映射失败",
                    bookingOrder.MBLNO, bookingOrder.CARRIERID);

                    throw Oops.Bah($"船公司={bookingOrder.CARRIERID} 暂不支持Draft下载");
                }

                string urlKey = string.Format(CONST_FORMAT_DRAFT_URL, bcOrDraftRouteCfg.MapCode.ToLower());

                var bcUrl = _cache.GetAllDictData().GetAwaiter().GetResult()
                .FirstOrDefault(x => x.TypeCode == "url_set" && x.Code.Equals(urlKey, StringComparison.OrdinalIgnoreCase))?.Value;

                _logger.LogInformation("提单号{mbl} 根据订舱的船公司代码{ca} 提取DRAFT下载URL完成，结果={rlt}",
                    bookingOrder.MBLNO, bookingOrder.CARRIERID, bcUrl);

                if (string.IsNullOrWhiteSpace(bcUrl))
                {
                    _logger.LogInformation("提单号{0} 根据订舱的船公司代码{1} 提取BC下载URL失败，未取到配置key={key}",
                    bookingOrder.MBLNO, bookingOrder.CARRIERID, urlKey);

                    throw Oops.Bah($"船公司={bookingOrder.CARRIERID} 未配置请求地址{urlKey} 请联系管理员");
                }

                string webKey = string.Format(CONST_FORMAT_WEB, bcOrDraftRouteCfg.MapCode);

                //获取个人对应的账户,这里GetAccountConfig逻辑优先取个人，个人没有配置取公司对应配置
                var userWebAccountConfig = GetAccountConfig(webKey, UserManager.UserId, UserManager.TENANT_ID).GetAwaiter()
                    .GetResult();

                _logger.LogInformation("批次={no} 获取获取网站的账户完成，result={Num}", batchNo, JSON.Serialize(userWebAccountConfig));

                if (userWebAccountConfig == null)
                    throw Oops.Oh($" 未配置个人或公司网站账户，网站{webKey}");

                string downloadFilePathRlt = string.Empty;
                string erroMsg = string.Empty;

                if(bcOrDraftRouteCfg.MapCode.Trim().Equals("ESL", StringComparison.OrdinalIgnoreCase))
                {
                    ESLDraftRequestDto requestDto = new ESLDraftRequestDto
                    {
                        u = userWebAccountConfig.Account?.Trim(),
                        p = userWebAccountConfig.Password?.Trim(),
                        ep_code = bookingOrder.TMBLNO?.Trim().ToUpper(),
                    };

                    _logger.LogInformation("批次={no} json={json} 请求Draft远端下载开始", batchNo, JSON.Serialize(requestDto));

                    DateTime bDate = DateTime.Now;
                    //开始请求BC
                    var rlt = await ExcuteESLDraftDownload(bcUrl, requestDto, batchNo);

                    DateTime eDate = DateTime.Now;
                    TimeSpan ts = eDate.Subtract(bDate);
                    var timeDiff = ts.TotalMilliseconds;

                    _logger.LogInformation("批次={no} result={result} 请求Draft远端下载结束 耗时：{timeDiff}ms. ", batchNo,
                        JSON.Serialize(rlt), timeDiff);

                    if (rlt.status == 1)
                    {
                        downloadFilePathRlt = rlt.data.api_path;
                    }
                    else
                    {
                        erroMsg = rlt.message;
                    }
                }
                else
                {
                    BCOrDraftRequestDto requestDto = new BCOrDraftRequestDto
                    {
                        user_key = App.Configuration["BCOrDraftUserKey"],
                        user_secret = App.Configuration["BCOrDraftUserSecret"],
                        web_user = userWebAccountConfig.Account?.Trim(),
                        web_psw = userWebAccountConfig.Password?.Trim(),
                        bno = bookingOrder.MBLNO,
                        is_parse = false
                    };

                    _logger.LogInformation("批次={no} json={json} 请求Draft远端下载开始", batchNo, JSON.Serialize(requestDto));

                    DateTime bDate = DateTime.Now;
                    //开始请求BC
                    var rlt = await ExcuteDraftDownload(bcUrl, requestDto, batchNo);

                    DateTime eDate = DateTime.Now;
                    TimeSpan ts = eDate.Subtract(bDate);
                    var timeDiff = ts.TotalMilliseconds;

                    _logger.LogInformation("批次={no} result={result} 请求Draft远端下载结束 耗时：{timeDiff}ms. ", batchNo,
                        JSON.Serialize(rlt), timeDiff);

                    if (rlt.code == 200)
                    {
                        downloadFilePathRlt = rlt.data.FirstOrDefault().path;
                    }
                    else
                    {
                        erroMsg = rlt.msg;
                    }
                }

                if (!string.IsNullOrWhiteSpace(downloadFilePathRlt))
                {
                    _logger.LogInformation("批次={no} 下载文件成功，转存本地", batchNo);

                    string currFilePath = downloadFilePathRlt;

                    string fileTypeCode = "draft";
                    string fileTypeName = "Draft";

                    //读取文件配置
                    var fileCfg = App.GetOptions<BookingAttachOptions>();

                    string relativePath = $"{fileCfg.relativePath}\\draftfiles\\{bookingOrder.Id}";
                    string filePath = $"{(!string.IsNullOrWhiteSpace(fileCfg.basePath) ? fileCfg.basePath : App.WebHostEnvironment.WebRootPath)}\\{relativePath}";

                    string fileFullName = $"{filePath}\\{new System.IO.FileInfo(currFilePath).Name}";

                    if (RuntimeInformation.IsOSPlatform(OSPlatform.Linux))
                    {
                        relativePath = relativePath.Replace("\\", "/");
                        filePath = filePath.Replace("\\", "/");

                        fileFullName = fileFullName.Replace("\\", "/");
                    }

                    _logger.LogInformation("批次={no} 生成文件保存路径完成 路由={filePath} 服务器系统={system}", batchNo, filePath, RuntimeInformation.OSDescription);
                    //预先创建目录
                    if (!Directory.Exists(filePath))
                    {
                        Directory.CreateDirectory(filePath);
                    }

                    var bcStream = await currFilePath.GetAsStreamAsync();

                    using (var fileStream = File.Create(fileFullName))
                    {
                        await bcStream.CopyToAsync(fileStream);
                    }

                    _logger.LogInformation("批次={no} 完成文件保存 filepath={path}", batchNo, fileFullName);

                    string bookFilePath = string.Empty;

                    if (RuntimeInformation.IsOSPlatform(OSPlatform.Linux))
                    {
                        bookFilePath = System.Text.RegularExpressions.Regex.Match(fileFullName, relativePath.Replace("/", "\\/") + ".*").Value;
                    }
                    else
                    {
                        bookFilePath = System.Text.RegularExpressions.Regex.Match(fileFullName, relativePath.Replace("\\", "\\\\") + ".*").Value;
                    }

                    //这里先写入附件表
                    await SaveEDIFile(bookingOrder.Id, bookFilePath, new System.IO.FileInfo(currFilePath).Name,
                        fileTypeCode, fileTypeName);

                    result.succ = true;
                    result.msg = "Draft下载成功";
                }
                else
                {
                    result.succ = false;
                    result.msg = $"Draft下载失败，原因={erroMsg}";
                }
            }
            catch (Exception ex)
            {
                result.succ = false;
                result.msg = $"Draft下载失败，原因：{ex.Message}";
            }

            return result;
        }
        #endregion

        #region BC请求远端下载
        /// <summary>
        /// BC请求远端下载
        /// </summary>
        /// <param name="url">请求URL</param>
        /// <param name="info">请求详情</param>
        /// <param name="batchNo">批次号</param>
        /// <returns>返回结果</returns>
        [NonAction]
        private async Task<BCAPIBaseResult> ExcuteBCDownload(string url, BCOrDraftRequestDto info, string batchNo)
        {
            BCAPIBaseResult model = null;
            /*
             1、填充请求的类，并生成JSON报文
             2、POST请求接口，并记录回执。
             3、返回信息。
             */
            try
            {
                _logger.LogInformation("批次={no} 对应请求报文 request={res}", batchNo, JSON.Serialize(info));

                var res = await url.OnClientCreating(client => {
                    // client 为 HttpClient 对象
                    client.Timeout = TimeSpan.FromMinutes(15); // 设置超时时间 15分钟
                }).SetHttpMethod(HttpMethod.Post)
                    .SetBody(JSON.Serialize(info), "application/json")
                    .SetContentEncoding(Encoding.UTF8)
                .PostAsync();

                _logger.LogInformation("批次={no} 对应请求报文完成 res={res}", batchNo, JSON.Serialize(res));

                if (res.StatusCode == System.Net.HttpStatusCode.OK)
                {
                    var userResult = await res.Content.ReadAsStringAsync();

                    System.Text.Json.JsonSerializerOptions jsonOptions = new JsonSerializerOptions();
                    jsonOptions.Converters.Add(new DateTimeJsonConverter("yyyy-MM-dd HH:mm:ss"));

                    model = JSON.Deserialize<BCAPIBaseResult>(userResult, jsonOptions);
                }
            }
            catch (Exception ex)
            {
                //写日志
                if (ex is HttpRequestException)
                    throw Oops.Oh(10000002);
            }

            return model;
        }
        #endregion

        #region Draft请求远端下载
        /// <summary>
        /// Draft请求远端下载
        /// </summary>
        /// <param name="url">请求URL</param>
        /// <param name="info">请求详情</param>
        /// <param name="batchNo">批次号</param>
        /// <returns>返回结果</returns>
        [NonAction]
        private async Task<DraftAPIBaseResult> ExcuteDraftDownload(string url, BCOrDraftRequestDto info, string batchNo)
        {
            DraftAPIBaseResult model = null;
            /*
             1、填充请求的类，并生成JSON报文
             2、POST请求接口，并记录回执。
             3、返回信息。
             */
            try
            {
                _logger.LogInformation("批次={no} 对应请求报文 request={res}", batchNo, JSON.Serialize(info));

                var res = await url.OnClientCreating(client => {
                    // client 为 HttpClient 对象
                    client.Timeout = TimeSpan.FromMinutes(15); // 设置超时时间 15分钟
                }).SetHttpMethod(HttpMethod.Post)
                    .SetBody(JSON.Serialize(info), "application/json")
                    .SetContentEncoding(Encoding.UTF8)
                .PostAsync();

                _logger.LogInformation("批次={no} 对应请求报文完成 res={res}", batchNo, JSON.Serialize(res));

                if (res.StatusCode == System.Net.HttpStatusCode.OK)
                {
                    var userResult = await res.Content.ReadAsStringAsync();

                    System.Text.Json.JsonSerializerOptions jsonOptions = new JsonSerializerOptions();
                    jsonOptions.Converters.Add(new DateTimeJsonConverter("yyyy-MM-dd HH:mm:ss"));

                    model = JSON.Deserialize<DraftAPIBaseResult>(userResult, jsonOptions);
                }
            }
            catch (Exception ex)
            {
                //写日志
                if (ex is HttpRequestException)
                    throw Oops.Oh(10000002);
            }

            return model;
        }
        #endregion

        #region ESL Draft请求远端下载
        /// <summary>
        /// ESL Draft请求远端下载
        /// 由于现有的ESL和TSL接口不一致，需要提供单独的POST方法
        /// </summary>
        /// <param name="url">请求URL</param>
        /// <param name="info">请求详情</param>
        /// <param name="batchNo">批次号</param>
        /// <returns>返回结果</returns>
        [NonAction]
        private async Task<ESLDraftAPIBaseResult> ExcuteESLDraftDownload(string url, ESLDraftRequestDto info, string batchNo)
        {
            ESLDraftAPIBaseResult model = null;
            /*
             1、填充请求的类，并生成JSON报文
             2、POST请求接口，并记录回执。
             3、返回信息。
             */
            try
            {
                _logger.LogInformation("批次={no} 对应请求报文 request={res}", batchNo, JSON.Serialize(info));

                var res = await url.OnClientCreating(client => {
                    // client 为 HttpClient 对象
                        client.Timeout = TimeSpan.FromMinutes(15); // 设置超时时间 15分钟
                    }).SetHttpMethod(HttpMethod.Post)
                    .SetBody(JSON.Serialize(info), "application/json")
                    .SetContentEncoding(Encoding.UTF8)
                .PostAsync();

                _logger.LogInformation("批次={no} 对应请求报文完成 res={res}", batchNo, JSON.Serialize(res));

                if (res.StatusCode == System.Net.HttpStatusCode.OK)
                {
                    var userResult = await res.Content.ReadAsStringAsync();

                    model = JSON.Deserialize<ESLDraftAPIBaseResult>(userResult);
                }
            }
            catch (Exception ex)
            {
                //写日志
                if (ex is HttpRequestException)
                    throw Oops.Oh(10000002);
            }

            return model;
        }
        #endregion

        #region ESL SO Ref.No搜索ESL号查询
        /// <summary>
        /// ESL SO Ref.No搜索ESL号查询
        /// </summary>
        /// <param name="url">请求URL</param>
        /// <param name="info">请求详情</param>
        /// <param name="batchNo">批次号</param>
        /// <returns>返回结果</returns>
        [NonAction]
        private async Task<ESLManiAlloChkAPIBaseResult> ExcuteManiAllocCheckDownload(string url, ESLManiAlloChkRequestDto info, string batchNo)
        {
            ESLManiAlloChkAPIBaseResult model = null;
            /*
             1、填充请求的类，并生成JSON报文
             2、POST请求接口，并记录回执。
             3、返回信息。
             */
            try
            {
                _logger.LogInformation("批次={no} 对应请求报文 request={res}", batchNo, JSON.Serialize(info));

                var res = await url.OnClientCreating(client => {
                    // client 为 HttpClient 对象
                    client.Timeout = TimeSpan.FromMinutes(15); // 设置超时时间 15分钟
                }).SetHttpMethod(HttpMethod.Post)
                    .SetBody(JSON.Serialize(info), "application/json")
                    .SetContentEncoding(Encoding.UTF8)
                .PostAsync();

                _logger.LogInformation("批次={no} 对应请求报文完成 res={res}", batchNo, JSON.Serialize(res));

                if (res.StatusCode == System.Net.HttpStatusCode.OK)
                {
                    var userResult = await res.Content.ReadAsStringAsync();
                    model = JSON.Deserialize<ESLManiAlloChkAPIBaseResult>(userResult);
                }
            }
            catch (Exception ex)
            {
                //写日志
                if (ex is HttpRequestException)
                    throw Oops.Oh(10000002);
            }

            return model;
        }
        #endregion

        /// <summary>
        /// 舱位分配查询
        /// </summary>
        /// <param name="bookingIds">订舱主键数组</param>
        /// <returns>返回回执</returns>
        [HttpPost("/BookingValueAdded/CheckUpdateManifestNo")]
        public async Task<TaskManageOrderResultDto> CheckUpdateManifestNo([FromBody] long[] bookingIds)
        {
            TaskManageOrderResultDto result = new TaskManageOrderResultDto();
            List<Task<TaskManageOrderResultDto>> taskList = new List<Task<TaskManageOrderResultDto>>();

            string batchNo = IDGen.NextID().ToString();

            try
            {
                /*
                 现在只有ESL支持舱位分配查询

                 1、订舱主键提取提单号，判断提单号如果不是ESL开头的，需要启动流程
                 2、异步调取ESL接口。
                 3、返回结果后提取esl_no号
                 4、将参考号写入订舱编号。
                 5、将esl_no号写入主提单号。
                 6、等待所有请求完成返回统计结果。
                 */

                var list = _bookingOrderRepository.AsQueryable()
                    .Where(a => bookingIds.Contains(a.Id)).ToList();

                if (list.Count != bookingIds.Length)
                    throw Oops.Oh($"订舱信息获取失败，订舱信息不存在或已作废");

                var noList = bookingIds.Select((a, idx) => new { no = idx + 1, id = a }).ToList();
                foreach (var bk in list)
                {
                    var sortNo = noList.FirstOrDefault(a => a.id == bk.Id).no;
                    taskList.Add(Task.Run(() => InnerCheckUpdateManifestNo(bk, batchNo, sortNo)));
                }

                Task.WaitAll(taskList.ToArray());

                result.succ = true;
                result.msg = "批量执行成功";

                var downResultList = taskList.Select(x => x.Result).ToList();

                if (downResultList.Any(x => !x.succ))
                {
                    result.succ = false;
                    result.msg = "批量执行失败";
                }
                else
                {
                    result.succ = true;
                    result.msg = downResultList.FirstOrDefault().msg;
                }

                result.ext = downResultList;

                var succ = downResultList.Count(x => x.succ);
                var fail = downResultList.Count(x => !x.succ);

                if (succ > 0)
                {
                    result.batchTotal = succ.ToString();
                }
                else
                {
                    result.batchTotal = "- ";
                }

                if (fail > 0)
                {
                    result.batchTotal += "/" + fail.ToString();
                }
                else
                {
                    result.batchTotal += " -";
                }
            }
            catch (Exception ex)
            {
                result.succ = false;
                result.msg = $"批量执行失败，原因：{ex.Message}";
            }

            return result;
        }

        #region 单票舱位分配查询
        /// <summary>
        /// 单票舱位分配查询
        /// </summary>
        /// <param name="bookingOrder">订舱详情</param>
        /// <param name="batchNo">批次号</param>
        /// <param name="sortNo">请求顺序号</param>
        /// <returns>返回回执</returns>
        private async Task<TaskManageOrderResultDto> InnerCheckUpdateManifestNo(BookingOrder bookingOrder, string batchNo, int sortNo)
        {
            TaskManageOrderResultDto result = new TaskManageOrderResultDto();

            result.bno = bookingOrder.MBLNO;

            try
            {
                /*
                1、根据船公司代码匹配船公司映射。
                2、BC和DRAFT是分别2个请求地址。
                3、生成请求报文。
                4、请求相应的链接。
                5、返回成功写入附件。
                */

                //2023-07-06 按照最新要求，从订舱编号取单号
                if (string.IsNullOrWhiteSpace(bookingOrder.CUSTNO))
                {
                    if (!string.IsNullOrWhiteSpace(bookingOrder.MBLNO))
                    {
                        result.bno = $"订 {bookingOrder.MBLNO}";
                    }
                    else
                    {
                        result.bno = $"NO.{sortNo}";
                    }

                    throw Oops.Bah($"订舱编号不能为空");
                }
                else
                {
                    if (Regex.IsMatch(bookingOrder.CUSTNO, "\\bESL\\w+"))
                    {
                        _logger.LogInformation("批次={no} id={id} 订舱编号没填写参考号，无法继续", batchNo, bookingOrder.Id);

                        throw Oops.Oh($"订舱编号不是有效的参考号");
                    }
                }

                var bcOrDraftRouteCfg = _cache.GetAllMappingCarrier().GetAwaiter().GetResult()
                .FirstOrDefault(t => t.Module.Equals(CONST_MAPPING_MANIALLO_CHK_MODULE_ROUTE, StringComparison.OrdinalIgnoreCase)
                && t.Code.Equals(bookingOrder.CARRIERID?.Trim(), StringComparison.OrdinalIgnoreCase));

                _logger.LogInformation("订舱编号【{mbl}】根据订舱的船公司代码{ca} 提取船公司映射完成，结果={rlt}",
                    bookingOrder.CUSTNO, bookingOrder.CARRIERID, bcOrDraftRouteCfg);

                if (bcOrDraftRouteCfg == null)
                {
                    _logger.LogInformation("订舱编号{mbl} 根据订舱的船公司代码{ca} 提取船公司映射失败",
                    bookingOrder.CUSTNO, bookingOrder.CARRIERID);

                    throw Oops.Bah($"船公司={bookingOrder.CARRIERID} 暂不支持舱位分配查询");
                }

                string urlKey = string.Format(CONST_FORMAT_MANIALLO_CHK_URL, bcOrDraftRouteCfg.MapCode.ToLower());

                var bcUrl = _cache.GetAllDictData().GetAwaiter().GetResult()
                .FirstOrDefault(x => x.TypeCode == "url_set" && x.Code.Equals(urlKey, StringComparison.OrdinalIgnoreCase))?.Value;

                _logger.LogInformation("订舱编号{mbl} 根据订舱的船公司代码{ca} 提取舱位分配查询URL完成，结果={rlt}",
                    bookingOrder.CUSTNO, bookingOrder.CARRIERID, bcUrl);

                if (string.IsNullOrWhiteSpace(bcUrl))
                {
                    _logger.LogInformation("订舱编号{0} 根据订舱的船公司代码{1} 提取舱位分配查询URL失败，未取到配置key={key}",
                    bookingOrder.CUSTNO, bookingOrder.CARRIERID, urlKey);

                    throw Oops.Bah($"船公司={bookingOrder.CARRIERID} 未配置请求地址{urlKey} 请联系管理员");
                }

                string webKey = string.Format(CONST_FORMAT_WEB, bcOrDraftRouteCfg.MapCode);

                //获取个人对应的账户,这里GetAccountConfig逻辑优先取个人，个人没有配置取公司对应配置
                var userWebAccountConfig = GetAccountConfig(webKey, UserManager.UserId, UserManager.TENANT_ID).GetAwaiter()
                    .GetResult();

                _logger.LogInformation("批次={no} 获取获取网站的账户完成，result={Num}", batchNo, JSON.Serialize(userWebAccountConfig));

                if (userWebAccountConfig == null)
                    throw Oops.Oh($" 未配置个人或公司网站账户，网站{webKey}");

                ESLManiAlloChkRequestDto requestDto = new ESLManiAlloChkRequestDto
                {
                    u = userWebAccountConfig.Account?.Trim(),
                    p = userWebAccountConfig.Password?.Trim(),
                    so_no = bookingOrder.CUSTNO,
                };

                _logger.LogInformation("批次={no} json={json} 请求舱位分配查询远端下载开始", batchNo, JSON.Serialize(requestDto));

                DateTime bDate = DateTime.Now;
                //开始请求BC
                var rlt = await ExcuteManiAllocCheckDownload(bcUrl, requestDto, batchNo);

                DateTime eDate = DateTime.Now;
                TimeSpan ts = eDate.Subtract(bDate);
                var timeDiff = ts.TotalMilliseconds;

                _logger.LogInformation("批次={no} result={result} 请求舱位分配查询远端下载结束 耗时：{timeDiff}ms. ", batchNo,
                    JSON.Serialize(rlt), timeDiff);

                if (rlt.status == 1)
                {
                    if(rlt.data == null || string.IsNullOrWhiteSpace(rlt.data.esl_no))
                    {
                        _logger.LogInformation("批次={no} 舱位分配查询失败，ESL号不存在", batchNo);

                        throw Oops.Oh($"查询ESL号失败");
                    }
                    _logger.LogInformation("批次={no} 舱位分配查询成功", batchNo);

                    /*
                     提单号写入订舱编号，并把esl_no写入主提单号
                     */
                    var bkInfo = _bookingOrderRepository.AsQueryable().First(a => a.Id == bookingOrder.Id);

                    if(bkInfo == null)
                    {
                        _logger.LogInformation("批次={no} id={id} 订舱信息获取失败，无法更新", batchNo, bookingOrder.Id);

                        throw Oops.Oh($"订舱信息获取失败，无法更新");
                    }

                    /* //2023-07-06 按照最新要求，从订舱编号取单号,所以这里不判断了
                    if(Regex.IsMatch(bkInfo.MBLNO,"\\bESL\\w+"))
                    {
                        _logger.LogInformation("批次={no} id={id} 主提单号已变更，无法更新", batchNo, bookingOrder.Id);

                        throw Oops.Oh($"主提单号已变更，无法更新");
                    }*/

                    _logger.LogInformation("批次={no} 变更前记录 id={id} MBLNO={MBLNO} CUSTNO={CUSTNO} esl_no={eslno}", 
                        batchNo, bookingOrder.Id, bkInfo.MBLNO, bkInfo.CUSTNO, rlt.data.esl_no);

                    //bkInfo.CUSTNO = bkInfo.MBLNO;
                    bkInfo.MBLNO = rlt.data.esl_no.Trim().ToUpper();
                    bkInfo.UpdatedTime = DateTime.Now;
                    bkInfo.UpdatedUserId = UserManager.UserId;
                    bkInfo.UpdatedUserName = UserManager.Name;

                    await _bookingOrderRepository.AsUpdateable(bkInfo).UpdateColumns(it => new
                    {
                        it.MBLNO,
                        it.UpdatedTime,
                        it.UpdatedUserId,
                        it.UpdatedUserName
                    }).ExecuteCommandAsync();

                    result.succ = true;
                    result.msg = "舱位分配查询成功";
                }
                else
                {
                    result.succ = false;
                    result.msg = $"舱位分配查询失败，{rlt.message}";
                }
            }
            catch (Exception ex)
            {
                result.succ = false;
                result.msg = $"舱位分配查询失败，{ex.Message}";
            }

            return result;
        }
        #endregion

        /// <summary>
        /// 提交规则意见
        /// </summary>
        /// <param name="model">规则意见详情</param>
        /// <returns>返回回执</returns>
        [HttpPost("/BookingValueAdded/SubmitRuleOpinion")]
        public async Task<TaskManageOrderResultDto> SubmitRuleOpinion([FromBody] RulesEngineUserFeedBackDto model)
        {
            TaskManageOrderResultDto result = new TaskManageOrderResultDto();

            string batchNo = IDGen.NextID().ToString();

            DateTime nowDate = DateTime.Now;
            try
            {
                if(string.IsNullOrWhiteSpace(model.ruleName))
                    throw Oops.Oh($"规则名称不能为空");

                if (string.IsNullOrWhiteSpace(model.opinionType))
                    throw Oops.Oh($"意见类型不能为空");

                if (string.IsNullOrWhiteSpace(model.opinionContent))
                    throw Oops.Oh($"意见内容不能为空");

                RulesEngineUserFeedBackMessageInfo msgModel = new RulesEngineUserFeedBackMessageInfo();

                msgModel.Head = new RulesEngineUserFeedBackHead
                {
                    GID = batchNo,
                    MessageType = "BUSI_RULE",
                    SenderId = App.Configuration["RulesEngineSender"],
                    SenderName = App.Configuration["RulesEngineSenderName"],
                    SenderKey = App.Configuration["RulesEngineAuthKey"],
                    ReceiverId = "RulesEngine",
                    ReceiverName = "大简云规则引擎",
                    Version = "1.0",
                    RequestDate = nowDate.ToString("yyyy-MM-dd HH:mm:ss"),
                    RequestAction = "Add",
                };

                msgModel.Main = new RulesEngineUserFeedBackMain
                {
                    ruleName = model.ruleName,
                    opinionType = model.opinionType,
                    opinionContent = model.opinionContent,
                    ruleNotice = model.ruleNotice,
                    submitUser = UserManager.Name
                };

                DateTime bDate = DateTime.Now;

                var rlt = await ExcuteRuleOpinion(App.Configuration["RulesEngineOpinionUrl"], msgModel, batchNo);

                DateTime eDate = DateTime.Now;
                TimeSpan ts = eDate.Subtract(bDate);
                var timeDiff = ts.TotalMilliseconds;

                _logger.LogInformation("批次={no} 请求完成,耗时：{timeDiff}ms. 结果{msg}", batchNo, timeDiff, rlt.succ ? "成功" : "失败");


                if (!rlt.succ)
                {
                    throw Oops.Oh($"请求失败，原因={rlt.msg}");
                }

                result.succ = true;
                result.msg = "提交成功";
            }
            catch (Exception ex)
            {
                result.succ = false;
                result.msg = $"提交规则意见失败，{ex.Message}";

                _logger.LogInformation("批次={no} 异常，{msg}", batchNo, ex.Message);
            }

            return result;
        }

        /// <summary>
        /// 查询规则意见历史
        /// </summary>
        /// <param name="model">规则意见详情</param>
        /// <returns>返回回执</returns>
        [HttpPost("/BookingValueAdded/GetRuleOpinionLog")]
        public async Task<TaskManageOrderResultDto> GetRuleOpinionLog([FromBody] RulesEngineUserFeedBackDto model)
        {
            TaskManageOrderResultDto result = new TaskManageOrderResultDto();

            string batchNo = IDGen.NextID().ToString();

            DateTime nowDate = DateTime.Now;
            try
            {
                RulesEngineUserFeedBackMessageInfo msgModel = new RulesEngineUserFeedBackMessageInfo();

                msgModel.Head = new RulesEngineUserFeedBackHead
                {
                    GID = batchNo,
                    MessageType = "BUSI_RULE",
                    SenderId = App.Configuration["RulesEngineSender"],
                    SenderName = App.Configuration["RulesEngineSenderName"],
                    SenderKey = App.Configuration["RulesEngineAuthKey"],
                    ReceiverId = "RulesEngine",
                    ReceiverName = "大简云规则引擎",
                    Version = "1.0",
                    RequestDate = nowDate.ToString("yyyy-MM-dd HH:mm:ss"),
                    RequestAction = "Add",
                };

                msgModel.Main = new RulesEngineUserFeedBackMain
                {
                    ruleName = model.ruleName,
                    opinionType = model.opinionType,
                    opinionContent = model.opinionContent,
                    ruleNotice = model.ruleNotice,
                    submitUser = UserManager.Name
                };

                DateTime bDate = DateTime.Now;

                var rlt = await ExcuteRuleOpinion(App.Configuration["RulesEngineQueryOpinionUrl"], msgModel, batchNo);

                DateTime eDate = DateTime.Now;
                TimeSpan ts = eDate.Subtract(bDate);
                var timeDiff = ts.TotalMilliseconds;

                _logger.LogInformation("批次={no} 请求完成,耗时：{timeDiff}ms. 结果{msg}", batchNo, timeDiff, rlt.succ ? "成功" : "失败");


                if (!rlt.succ)
                {
                    throw Oops.Oh($"请求失败，原因={rlt.msg}");
                }

                result.succ = true;
                result.msg = "查询成功";

                if (rlt.rows != null)
                    result.rows = JSON.Deserialize<List<RulesEngineUserFeedBackCollectionLogShowDto>>(JSON.Serialize(rlt.rows));
            }
            catch (Exception ex)
            {
                result.succ = false;
                result.msg = $"查询规则意见历史失败，{ex.Message}";

                _logger.LogInformation("批次={no} 异常，{msg}", batchNo, ex.Message);
            }

            return result;
        }

        #region 规则用户反馈请求远端
        /// <summary>
        /// 规则用户反馈请求远端
        /// </summary>
        /// <param name="url">请求URL</param>
        /// <param name="info">请求详情</param>
        /// <param name="batchNo">批次号</param>
        /// <returns>返回结果</returns>
        [NonAction]
        private async Task<RulesEngineWebApiResult> ExcuteRuleOpinion(string url, RulesEngineUserFeedBackMessageInfo info, string batchNo)
        {
            RulesEngineWebApiResult model = null;
            /*
             1、填充请求的类，并生成JSON报文
             2、POST请求接口，并记录回执。
             3、返回信息。
             */
            try
            {
                _logger.LogInformation("批次={no} 对应请求报文 request={res}", batchNo, JSON.Serialize(info));

                var res = await url.OnClientCreating(client => {
                    // client 为 HttpClient 对象
                    client.Timeout = TimeSpan.FromMinutes(15); // 设置超时时间 15分钟
                }).SetHttpMethod(HttpMethod.Post)
                    .SetBody(JSON.Serialize(info), "application/json")
                    .SetContentEncoding(Encoding.UTF8)
                .PostAsync();

                _logger.LogInformation("批次={no} 对应请求报文完成 res={res}", batchNo, JSON.Serialize(res));

                if (res.StatusCode == System.Net.HttpStatusCode.OK)
                {
                    var userResult = await res.Content.ReadAsStringAsync();

                    _logger.LogInformation("批次={no} 对应请求报文完成 userResult={userResult}", batchNo, userResult);
                    model = JSON.Deserialize<RulesEngineWebApiResult>(userResult);
                }
            }
            catch (Exception ex)
            {
                //写日志
                if (ex is HttpRequestException)
                    throw Oops.Oh(10000002);
            }

            return model;
        }
        #endregion

        /// <summary>
        /// 获取个人或公司网站账户配置
        /// </summary>
        /// <param name="typeCode">账户类型代码</param>
        /// <param name="userId">用户ID</param>
        /// <param name="tendId">租户ID</param>
        /// <returns>返回账户配置</returns>
        private async Task<DjyWebsiteAccountConfig> GetAccountConfig(string typeCode,long userId,long tendId)
        {
            DjyWebsiteAccountConfig accountConfig = new DjyWebsiteAccountConfig();
            accountConfig = await _djyWebsiteAccountConfigRepository.EntityContext.CopyNew().Queryable<DjyWebsiteAccountConfig>()
                .FirstAsync(x => x.TypeCode == typeCode && x.CreatedUserId == userId);

            if (accountConfig == null)
            {
                accountConfig = await _djyWebsiteAccountConfigRepository.EntityContext.CopyNew().Queryable<DjyWebsiteAccountConfig>()
                .FirstAsync(x => x.TypeCode == typeCode && x.TenantId == tendId && x.IsTenant == true);
            }

            return accountConfig;
        }

        /// <summary>
        /// 单票BC文件解析
        /// </summary>
        /// <param name="file">上传文件</param>
        /// <param name="bookingOrderId">订舱主键</param>
        /// <returns>返回回执</returns>
        [HttpPost("/BookingValueAdded/SingleBCFileRead")]
        public async Task<TaskManageOrderResultDto> SingleBCFileRead(IFormFile file, [FromForm] long bookingOrderId)
        {
            TaskManageOrderResultDto result = new TaskManageOrderResultDto();

            string batchNo = IDGen.NextID().ToString();

            SingleBCDto singleBCDto = null;
            try
            {
                /*
                 1、推送附件到识别接口，等待识别结果。
                 2、解析识别结果，并返回BC的解析明细。
                 */

                if(bookingOrderId < 0)
                    throw Oops.Oh($"订舱主键不能为空");

                var bookingOrder = _bookingOrderRepository.AsQueryable().First(a => a.Id == bookingOrderId);

                if(bookingOrder == null)
                    throw Oops.Oh($"订舱信息获取失败，订舱信息不存在或已作废");

                //获取解析BC文件链接
                var bcUrl = _cache.GetAllDictData().GetAwaiter().GetResult()
                .FirstOrDefault(x => x.TypeCode == "url_set" && x.Code.Equals(CONST_BC_FILE_PARSE_URL, StringComparison.OrdinalIgnoreCase))?.Value;

                _logger.LogInformation("提单号{mbl} 获取解析BC文件URL完成，结果={rlt}",
                    bookingOrder.MBLNO, bcUrl);

                if (string.IsNullOrWhiteSpace(bcUrl))
                {
                    _logger.LogInformation("提单号{0} 获取解析BC文件URL失败，未取到配置key={key}",
                    bookingOrder.MBLNO, CONST_BC_FILE_PARSE_URL);

                    throw Oops.Bah($"未配置请求地址{CONST_BC_FILE_PARSE_URL} 请联系管理员");
                }

                byte[] bytes = file.ToByteArray();

                DateTime bDate = DateTime.Now;

                //请求BC解析
                var bcParseRlt = await TransmitFile(bcUrl, new
                {
                    file = "file",
                    fileName = file.FileName,
                    fileBytes = bytes
                });

                DateTime eDate = DateTime.Now;
                TimeSpan ts = eDate.Subtract(bDate);
                var timeDiff = ts.TotalMilliseconds;

                _logger.LogInformation("批次={no} result={result} 获取解析BC文件URL结束 耗时：{timeDiff}ms. ", batchNo,
                    JSON.Serialize(bcParseRlt), timeDiff);

                if (bcParseRlt.status == 1)
                {
                    var currBC = bcParseRlt.data.BCList.FirstOrDefault();

                    if(!string.IsNullOrWhiteSpace(currBC.Vessel) && Regex.IsMatch(currBC.Vessel, "\\(|（|\\)|）|\\n"))
                    {
                        if(Regex.IsMatch(currBC.Vessel, "\\(|（|\\)|）"))
                        {
                            currBC.Vessel = Regex.Match(currBC.Vessel,"\\w+\\s?\\n?\\s?\\w+(?=\\()").Value;
                        }

                        if (Regex.IsMatch(currBC.Vessel, "\\n"))
                        {
                            currBC.Vessel = Regex.Replace(Regex.Replace(currBC.Vessel, "\\n", " "), "\\s{2,}", " ");
                        }
                    }

                    singleBCDto = new SingleBCDto
                    {
                        BookingOrderId = bookingOrderId,
                        BLNo = currBC.BLNo?.Trim().ToUpper(),
                        Vessel = currBC.Vessel?.Trim().ToUpper(),
                        Voyage = currBC.Voyage?.Trim().ToUpper(),
                        ClosingDate = currBC.CutSingleTime,
                        CYCutOffTime = currBC.CYCutOffTime,
                        VGMCutOffTime = currBC.VGMCutOffTime,
                        ETD = currBC.ETD
                    };

                    singleBCDto.BookingOrderBCDto = new BookingOrderBCDto {
                        MBLNO = bookingOrder.MBLNO,
                        CUSTNO = bookingOrder.CUSTNO,
                        CLOSEDOCDATE = bookingOrder.CLOSEDOCDATE,
                        CLOSEVGMDATE = bookingOrder.CLOSEVGMDATE,
                        CLOSINGDATE = bookingOrder.CLOSINGDATE,
                        ETD = bookingOrder.ETD,
                        VESSEL = bookingOrder.VESSEL,
                        VOYNO = bookingOrder.VOYNO,
                    };

                    /*
                     这里考虑后面会有将文件写入附件表的动作，在识别成功后将文件写入暂存路径，后续完成放舱讲文件写入正式链接
                     */
                    //读取文件配置

                   var fileFullName = await FileAttachHelper.TempSaveWebFile(bookingOrder.Id.ToString(), file, batchNo);

                    _logger.LogInformation("批次={no} 完成文件保存 filepath={path}", batchNo, fileFullName);

                    singleBCDto.FileTempPath = fileFullName;

                    result.succ = true;
                    result.ext = singleBCDto;
                }
                else
                {
                    result.succ = false;
                    result.msg = $"解析BC失败，原因：{bcParseRlt.message}";
                }
            }
            catch(Exception ex)
            {
                _logger.LogInformation("批次={no} 解析BC异常，原因：{error} ", batchNo, ex.Message);

                result.succ = false;
                result.msg = $"解析BC异常，原因：{ex.Message}";
            }
            return result;
        }

        #region 请求BC解析
        /// <summary>
        /// 请求BC解析
        /// </summary>
        /// <param name="requestUrl">请求地址</param>
        /// <param name="fileInfo">文件详情</param>
        /// <returns>返回BC解析详情</returns>
        private async Task<BCAPIBaseDataParse> TransmitFile(string requestUrl, dynamic fileInfo)
        {
            BCAPIBaseDataParse model = null;

            try
            {
                var  response = await requestUrl.SetContentType("multipart/form-data")
                .SetBodyBytes((fileInfo.file.ToString(), fileInfo.fileBytes, HttpUtility.UrlEncode(fileInfo.fileName.ToString())))
                .PostAsync();

                if (response.StatusCode == System.Net.HttpStatusCode.OK)
                {
                    var result = response.Content.ReadAsStringAsync().Result;

                    if (string.IsNullOrWhiteSpace(result))
                    {
                        throw Oops.Bah($"获取解析BC文件失败，未获取到有效信息");
                    }

                    System.Text.Json.JsonSerializerOptions jsonOptions = new JsonSerializerOptions();
                    jsonOptions.Converters.Add(new DateTimeJsonConverter("yyyy-MM-dd HH:mm:ss"));
                    jsonOptions.Converters.Add(new IntegerJsonConverter());
                    jsonOptions.Converters.Add(new DecimalJsonConverter());

                    model = JSON.Deserialize<BCAPIBaseDataParse>(result, jsonOptions);
                }
            }
            catch (Exception ex)
            {
                _logger.LogInformation("{name} 发送BC文件解析请求 url={url} 异常，原因={error}", nameof(TransmitFile),
                    requestUrl, ex.Message);

                throw Oops.Bah($"{nameof(TransmitFile)} {requestUrl} 发送BC文件解析请求异常，{ex.Message}");
            }
            return model;
        }
        #endregion

        #region 单票BC更新订舱
        /// <summary>
        /// 单票BC更新订舱
        /// </summary>
        /// <param name="model">单票BC详情</param>
        /// <returns>返回回执</returns>
        [HttpPost("/BookingValueAdded/SingleBCUpdateBookingOrder")]
        public async Task<TaskManageOrderResultDto> SingleBCUpdateBookingOrder(SingleBCDto model)
        {
            TaskManageOrderResultDto result = new TaskManageOrderResultDto();

            string batchNo = IDGen.NextID().ToString();

            try
            {
                /*
                 1、根据BC的数据更新订舱相关信息（提单号、截港时间、截单时间、船名航次、开船日期）
                 2、如果选择了转为入货通知，则先保存入货通知。
                 3、调取入货通知的发送。
                 */
                var bookingOrder = _bookingOrderRepository.AsQueryable().First(a => a.Id == model.BookingOrderId);

                if (bookingOrder == null)
                    throw Oops.Bah($"订舱信息获取失败，订舱信息不存在或已作废");

                var updateRlt = InnerBCUpdateBookingOrder(model, bookingOrder, batchNo,1).GetAwaiter().GetResult();

                if (!updateRlt.succ)
                    throw Oops.Bah($"订舱信息更新失败，{updateRlt.msg}");

                if (model.IsLetterYard)
                {
                    _logger.LogInformation("批次={no} id={id} 单票BC更新订舱后，用户选择转为入货通知，开始执行入货通知", batchNo
                        , bookingOrder.Id);

                    if (string.IsNullOrWhiteSpace(model.FileTempPath))
                    {
                        _logger.LogInformation("批次={no} id={id} 未提交文件路径，请求失败", batchNo
                        , bookingOrder.Id);

                        throw Oops.Bah($"未提交文件路径，执行放舱失败");
                    }

                    var letterYardDto = new UpdateBookingLetteryardInput();

                    letterYardDto = model.LetteryardDto.Adapt<UpdateBookingLetteryardInput>();

                    if (model.LetterYardId.HasValue && model.LetterYardId.Value > 0)
                    {
                        letterYardDto.Id = model.LetterYardId.Value;

                        _logger.LogInformation("批次={no} id={id} 单票BC更新订舱后，存在放舱记录 LetterYardId={LetterYardId}", batchNo
                            , bookingOrder.Id, letterYardDto.Id);
                    }
                    else
                    {
                        var letterYardModel = _bookingLetteryardRepository.AsQueryable()
                            .First(x => x.BookingId == model.BookingOrderId);

                        if(letterYardModel != null)
                            letterYardDto.Id = letterYardModel.Id;
                    }

                    //放舱保存
                    var letterYardId = await _bookingOrderService.LetteryardSave(letterYardDto);

                    _logger.LogInformation("批次={no} id={id} 已完放舱记录保存 返回结果{rlt}", batchNo
                            , bookingOrder.Id, letterYardId);

                    _logger.LogInformation("批次={no} id={id} templateid={tempid} 开始发送放舱", batchNo
                            , bookingOrder.Id, model.TemplateId);

                    //发送放舱
                    await _bookingOrderService.SendLetterYard(model.BookingOrderId, model.TemplateId);

                    _logger.LogInformation("批次={no} id={id} templateid={tempid} 完成发送放舱", batchNo
                            , bookingOrder.Id, model.TemplateId);

                    string fileTypeCode = "bc";
                    string fileTypeName = "Booking Confirmation";

                    //重新将暂存文件写入正式路径

                    //读取文件配置
                    var bookFilePath = await FileAttachHelper.MoveFile(bookingOrder.Id.ToString(), model.FileTempPath,batchNo);

                    //将BC引入的文件写入订舱的附件
                    await SaveEDIFile(bookingOrder.Id, bookFilePath, new System.IO.FileInfo(bookFilePath).Name,
                        fileTypeCode, fileTypeName);

                    _logger.LogInformation("批次={no} id={id} 完成写入附件表 {filepath}", batchNo
                            , bookingOrder.Id, model.FileTempPath);
                }

                result.succ = true;
                result.msg = "执行成功";
            }
            catch (Exception ex)
            {
                result.succ = false;
                result.msg = ex.Message;
            }

            return result;
        }
        #endregion

        #region 单票BC更新订舱信息
        /// <summary>
        /// 单票BC更新订舱信息
        /// </summary>
        /// <param name="model">BC详情</param>
        /// <param name="bookingOrder">订舱详情</param>
        /// <param name="batchNo">批次号</param>
        /// <param name="sortNo">顺序号</param>
        /// <returns>返回回执</returns>
        private async Task<TaskManageOrderResultDto> InnerBCUpdateBookingOrder(SingleBCDto model, BookingOrder bookingOrder,
            string batchNo,int sortNo)
        {
            TaskManageOrderResultDto result = new TaskManageOrderResultDto();

            result.bno = bookingOrder.MBLNO;

            try
            {
                if (string.IsNullOrWhiteSpace(result.bno))
                {
                    if (!string.IsNullOrWhiteSpace(bookingOrder.CUSTNO))
                    {
                        result.bno = $"订 {bookingOrder.CUSTNO}";
                    }
                    else
                    {
                        result.bno = $"NO.{sortNo}";
                    }
                }

                //截单日期
                if (model.ClosingDate.HasValue)
                {
                    _logger.LogInformation("批次={no} id={id} 更新截单日期 原：{date1} 变更为 {date2}", batchNo, bookingOrder.Id,
                        bookingOrder.CLOSEDOCDATE, model.ClosingDate);

                    bookingOrder.CLOSEDOCDATE = model.ClosingDate;
                }
                //截VGM时间
                if (model.VGMCutOffTime.HasValue)
                {
                    _logger.LogInformation("批次={no} id={id} 更新截VGM日期 原：{date1} 变更为 {date2}", batchNo, bookingOrder.Id,
                        bookingOrder.CLOSEVGMDATE, model.VGMCutOffTime);

                    bookingOrder.CLOSEVGMDATE = model.VGMCutOffTime;
                }

                //截港日期
                if (model.CYCutOffTime.HasValue)
                {
                    _logger.LogInformation("批次={no} id={id} 更新截港日期 原：{date1} 变更为 {date2}", batchNo, bookingOrder.Id,
                       bookingOrder.CLOSINGDATE, model.CYCutOffTime);

                    bookingOrder.CLOSINGDATE = model.CYCutOffTime;
                }
                //开船日期
                if (model.ETD.HasValue)
                {
                    _logger.LogInformation("批次={no} id={id} 更新截港日期 原：{date1} 变更为 {date2}", batchNo, bookingOrder.Id,
                       bookingOrder.ETD, model.ETD);

                    bookingOrder.ETD = model.ETD;
                }

                //船名
                if (!string.IsNullOrWhiteSpace(model.Vessel))
                {
                    _logger.LogInformation("批次={no} id={id} 更新船名 原：{date1} 变更为 {date2}", batchNo, bookingOrder.Id,
                       bookingOrder.VESSEL, model.Vessel);

                    bookingOrder.VESSEL = model.Vessel;
                }

                //航次
                if (!string.IsNullOrWhiteSpace(model.Voyage))
                {
                    _logger.LogInformation("批次={no} id={id} 更新航次 原：{date1} 变更为 {date2}", batchNo, bookingOrder.Id,
                       bookingOrder.VOYNO, model.Voyage);

                    bookingOrder.VOYNO = model.Voyage;
                }

                //提单号
                if (!string.IsNullOrWhiteSpace(model.BLNo))
                {
                    _logger.LogInformation("批次={no} id={id} 更新提单号 原：{date1} 变更为 {date2}", batchNo, bookingOrder.Id,
                       bookingOrder.MBLNO, model.BLNo);

                    bookingOrder.MBLNO = model.BLNo;
                }

                bookingOrder.UpdatedTime = DateTime.Now;
                bookingOrder.UpdatedUserId = UserManager.UserId;
                bookingOrder.UpdatedUserName = UserManager.Name;

                await _bookingOrderRepository.AsUpdateable(bookingOrder).UpdateColumns(it => new
                {
                    it.UpdatedTime,
                    it.UpdatedUserId,
                    it.UpdatedUserName,
                    it.CLOSEDOCDATE,
                    it.CLOSEVGMDATE,
                    it.CLOSINGDATE,
                    it.ETD,
                    it.VESSEL,
                    it.VOYNO,
                    it.MBLNO
                }).ExecuteCommandAsync();

                _logger.LogInformation("批次={no} id={id} BC引入更新订舱完成", batchNo, bookingOrder.Id);

                result.succ = true;
                result.msg = "执行成功";
            }
            catch (Exception ex)
            {
                result.succ = false;
                result.msg = ex.Message;
            }

            return result;
        }
        #endregion

        #region 批量BC更新订舱
        /// <summary>
        /// 批量BC更新订舱
        /// </summary>
        /// <param name="batchBCList">批量BC更新列表</param>
        /// <returns>返回回执</returns>
        [HttpPost("/BookingValueAdded/BatchBCUpdate")]
        public async Task<TaskManageOrderResultDto> BatchBCUpdate([FromBody]List<BatchBCDto> batchBCList)
        {
            TaskManageOrderResultDto result = new TaskManageOrderResultDto();
            List<Task<TaskManageOrderResultDto>> taskList = new List<Task<TaskManageOrderResultDto>>();

            string batchNo = IDGen.NextID().ToString();

            try
            {
                var bcTaskList = batchBCList.Select(a=>a.bcPKId).Distinct().ToList();
                var bkOrderList = batchBCList.Select(a => a.bkOrderId.Value).Distinct().ToList();

                var bklist = _bookingOrderRepository.AsQueryable()
                    .Where(a => bkOrderList.Contains(a.Id)).ToList();

                var bclist = _taskBCInfoRepository.AsQueryable()
                    .Where(a => bcTaskList.Contains(a.PK_ID)).ToList();

                if (bklist.Count != bkOrderList.Count)
                    throw Oops.Oh($"订舱信息获取失败，订舱信息不存在或已作废");

                var noList = bklist.Select((a, idx) => new { no = idx + 1, id = a.Id }).ToList();
                foreach (var bk in bklist)
                {
                    var sortNo = noList.FirstOrDefault(a => a.id == bk.Id).no;

                    var currBC = batchBCList.Join(bclist, l => l.bcPKId, r => r.PK_ID, (l, r) => {
                        return r;
                    }).FirstOrDefault();

                    SingleBCDto singleBCDto = new SingleBCDto { 
                        BLNo = currBC.MBL_NO,
                        Vessel = currBC.VESSEL,
                        Voyage = currBC.VOYNO,
                        ETD = currBC.ETD,
                        CYCutOffTime = currBC.CY_CUTOFF_TIME,
                        VGMCutOffTime = currBC.VGM_CUTOFF_TIME,
                        ClosingDate = currBC.CUT_SINGLE_TIME
                    };
                    taskList.Add(Task.Run(() => InnerBCUpdateBookingOrder(singleBCDto,bk, batchNo, sortNo)));
                }

                Task.WaitAll(taskList.ToArray());

                result.succ = true;
                result.msg = "批量执行成功";

                var downResultList = taskList.Select(x => x.Result).ToList();

                if (downResultList.Any(x => !x.succ))
                {
                    result.succ = false;
                    result.msg = "批量执行失败";
                }
                else
                {
                    result.succ = true;
                    result.msg = downResultList.FirstOrDefault().msg;
                }

                result.ext = downResultList;

                var succ = downResultList.Count(x => x.succ);
                var fail = downResultList.Count(x => !x.succ);

                if (succ > 0)
                {
                    result.batchTotal = succ.ToString();
                }
                else
                {
                    result.batchTotal = "- ";
                }

                if (fail > 0)
                {
                    result.batchTotal += "/" + fail.ToString();
                }
                else
                {
                    result.batchTotal += " -";
                }
            }
            catch (Exception ex)
            {
                result.succ = false;
                result.msg = $"批量执行失败，原因：{ex.Message}";
            }

            return result;
        }
        #endregion
    }

    public class DateTimeJsonConverter : System.Text.Json.Serialization.JsonConverter<Nullable<DateTime>>
    {
        private readonly string _dateFormatString;
        public DateTimeJsonConverter()
        {
            _dateFormatString = "yyyy-MM-dd HH:mm:ss";
        }

        public DateTimeJsonConverter(string dateFormatString)
        {
            _dateFormatString = dateFormatString;
        }

        public override Nullable<DateTime> Read(ref Utf8JsonReader reader, Type typeToConvert, JsonSerializerOptions options)
        {
            DateTime currDate = DateTime.MinValue;
            if (DateTime.TryParse(reader.GetString(), out currDate))
                return currDate;

            return null;
        }

        public override void Write(Utf8JsonWriter writer, Nullable<DateTime> value, JsonSerializerOptions options)
        {
            if (value.HasValue)
                writer.WriteStringValue(value.Value.ToUniversalTime().ToString(_dateFormatString));
            else
                writer.WriteNullValue();
        }
    }

    public class IntegerJsonConverter : System.Text.Json.Serialization.JsonConverter<Int32>
    {
        public IntegerJsonConverter()
        {
        }

        public override Int32 Read(ref Utf8JsonReader reader, Type typeToConvert, JsonSerializerOptions options)
        {
            if (reader.TokenType == JsonTokenType.String)
            {
                var curStr = reader.GetString();
                Int32 curVal = 0;
                Int32.TryParse(curStr, out curVal);
                    return curVal;
            }
            else
            {
                return reader.GetInt32();
            }
        }

        public override void Write(Utf8JsonWriter writer, Int32 value, JsonSerializerOptions options)
        {
            writer.WriteNumberValue(value);
        }
    }

    public class DecimalJsonConverter : System.Text.Json.Serialization.JsonConverter<decimal>
    {
        public DecimalJsonConverter()
        {
        }

        public override decimal Read(ref Utf8JsonReader reader, Type typeToConvert, JsonSerializerOptions options)
        {
            if (reader.TokenType == JsonTokenType.String)
            {
                var curStr = reader.GetString();
                decimal curVal = 0;
                decimal.TryParse(curStr, out curVal);
                return curVal;
            }
            else
            {
                return reader.GetDecimal();
            }
        }

        public override void Write(Utf8JsonWriter writer, decimal value, JsonSerializerOptions options)
        {
            writer.WriteNumberValue(value);
        }
    }
}