using NCC.Common.Core.Manager;
using NCC.Common.Enum;
using NCC.Common.Extension;
using NCC.Common.Filter;
using NCC.Dependency;
using NCC.DynamicApiController;
using NCC.FriendlyException;
using NCC.Extend.Interfaces.LqKdKdjlb;
using Mapster;
using Microsoft.AspNetCore.Mvc;
using SqlSugar;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Threading.Tasks;
using NCC.Extend.Entitys.lq_kd_kdjlb;
using NCC.Extend.Entitys.lq_kd_jksyj;
using NCC.Extend.Entitys.lq_kd_kjbsyj;
using NCC.Extend.Entitys.lq_kd_pxmx;
using NCC.Extend.Entitys.Dto.LqKdKdjlb;
using Yitter.IdGenerator;
using NCC.Common.Helper;
using NCC.JsonSerialization;
using NCC.Common.Model.NPOI;
using NCC.Common.Configuration;
using NCC.DataEncryption;
using NCC.ClayObject;
using NCC.Extend.Utils;
using System.Net.Http;

namespace NCC.Extend.LqKdKdjlb
{
    /// <summary>
    /// 开单记录表服务
    /// </summary>
    [ApiDescriptionSettings(Tag = "Extend",Name = "LqKdKdjlb", Order = 200)]
    [Route("api/Extend/[controller]")]
    public class LqKdKdjlbService : ILqKdKdjlbService, IDynamicApiController, ITransient
    {
        private readonly ISqlSugarRepository<LqKdKdjlbEntity> _lqKdKdjlbRepository;
        private readonly ISqlSugarRepository<LqKdJksyjEntity> _lqKdJksyjRepository;
        private readonly ISqlSugarRepository<LqKdKjbsyjEntity> _lqKdKjbsyjRepository;
        private readonly ISqlSugarRepository<LqKdPxmxEntity> _lqKdPxmxRepository;
        private readonly SqlSugarScope _db;
        private readonly IUserManager _userManager;
        private readonly WeChatBotService _weChatBotService;
        private readonly LqKdKdjlbStringGenerator _stringGenerator;

        /// <summary>
        /// 初始化一个<see cref="LqKdKdjlbService"/>类型的新实例
        /// </summary>
        public LqKdKdjlbService(
            ISqlSugarRepository<LqKdKdjlbEntity> lqKdKdjlbRepository,
            ISqlSugarRepository<LqKdJksyjEntity> lqKdJksyjRepository,
            ISqlSugarRepository<LqKdKjbsyjEntity> lqKdKjbsyjRepository,
            ISqlSugarRepository<LqKdPxmxEntity> lqKdPxmxRepository,
            IUserManager userManager,
            WeChatBotService weChatBotService,
            LqKdKdjlbStringGenerator stringGenerator)
        {
            _lqKdKdjlbRepository = lqKdKdjlbRepository;            
            _db = _lqKdKdjlbRepository.Context;
            _lqKdJksyjRepository = lqKdJksyjRepository;
            _lqKdKjbsyjRepository = lqKdKjbsyjRepository;
            _lqKdPxmxRepository = lqKdPxmxRepository;
            _userManager = userManager;
            _weChatBotService = weChatBotService;
            _stringGenerator = stringGenerator;
        }

        /// <summary>
        /// 获取开单记录表
        /// </summary>
        /// <param name="id">参数</param>
        /// <returns></returns>
        [HttpGet("{id}")]
        public async Task<dynamic> GetInfo(string id)
        {
            var entity = await _db.Queryable<LqKdKdjlbEntity>().FirstAsync(p => p.Id == id);
            var output = entity.Adapt<LqKdKdjlbInfoOutput>();
            
            var lqKdJksyjList = await _db.Queryable<LqKdJksyjEntity>().Where(w => w.Glkdbh == entity.Id).ToListAsync();
            output.lqKdJksyjList = lqKdJksyjList.Adapt<List<LqKdJksyjInfoOutput>>();
            
            var lqKdKjbsyjList = await _db.Queryable<LqKdKjbsyjEntity>().Where(w => w.Glkdbh == entity.Id).ToListAsync();
            output.lqKdKjbsyjList = lqKdKjbsyjList.Adapt<List<LqKdKjbsyjInfoOutput>>();
            
            var lqKdPxmxList = await _db.Queryable<LqKdPxmxEntity>().Where(w => w.Glkdbh == entity.Id).ToListAsync();
            output.lqKdPxmxList = lqKdPxmxList.Adapt<List<LqKdPxmxInfoOutput>>();
            return output;
        }

        /// <summary>
		/// 获取开单记录表列表
		/// </summary>
		/// <param name="input">请求参数</param>
		/// <returns></returns>
        [HttpGet("")]
        public async Task<dynamic> GetList([FromQuery] LqKdKdjlbListQueryInput input)
        {
            var sidx = input.sidx == null ? "id" : input.sidx;
            List<string> queryKdrq = input.kdrq != null ? input.kdrq.Split(',').ToObeject<List<string>>() : null;
            DateTime? startKdrq = queryKdrq != null ? Ext.GetDateTime(queryKdrq.First()) : null;
            DateTime? endKdrq = queryKdrq != null ? Ext.GetDateTime(queryKdrq.Last()) : null;
            var data = await _db.Queryable<LqKdKdjlbEntity>()
                .WhereIF(!string.IsNullOrEmpty(input.id), p => p.Id.Contains(input.id))
                .WhereIF(!string.IsNullOrEmpty(input.djmd), p => p.Djmd.Equals(input.djmd))
                .WhereIF(!string.IsNullOrEmpty(input.jsj), p => p.Jsj.Equals(input.jsj))
                .WhereIF(queryKdrq != null, p => p.Kdrq >= new DateTime(startKdrq.ToDate().Year, startKdrq.ToDate().Month, startKdrq.ToDate().Day, 0, 0, 0))
                .WhereIF(queryKdrq != null, p => p.Kdrq <= new DateTime(endKdrq.ToDate().Year, endKdrq.ToDate().Month, endKdrq.ToDate().Day, 23, 59, 59))
                .WhereIF(!string.IsNullOrEmpty(input.gjlx), p => p.Gjlx.Equals(input.gjlx))
                .WhereIF(!string.IsNullOrEmpty(input.hgjg), p => p.Hgjg.Equals(input.hgjg))
                .WhereIF(!string.IsNullOrEmpty(input.zdyj), p => p.Zdyj.Equals(input.zdyj))
                .WhereIF(!string.IsNullOrEmpty(input.sfyj), p => p.Sfyj.Equals(input.sfyj))
                .WhereIF(!string.IsNullOrEmpty(input.qk), p => p.Qk.Equals(input.qk))
                .WhereIF(!string.IsNullOrEmpty(input.ckfs), p => p.Ckfs.Equals(input.ckfs))
                .WhereIF(!string.IsNullOrEmpty(input.ckmx), p => p.Ckmx.Contains(input.ckmx))
                .WhereIF(!string.IsNullOrEmpty(input.fkfs), p => p.Fkfs.Equals(input.fkfs))
                .WhereIF(!string.IsNullOrEmpty(input.fkyy), p => p.Fkyy.Equals(input.fkyy))
                .WhereIF(!string.IsNullOrEmpty(input.fkpd), p => p.Fkpd.Contains(input.fkpd))
                .WhereIF(!string.IsNullOrEmpty(input.khly), p => p.Khly.Equals(input.khly))
                .WhereIF(!string.IsNullOrEmpty(input.tjr), p => p.Tjr.Contains(input.tjr))
                .WhereIF(!string.IsNullOrEmpty(input.sfskdd), p => p.Sfskdd.Equals(input.sfskdd))
                .WhereIF(!string.IsNullOrEmpty(input.jj), p => p.Jj.Contains(input.jj))
                .WhereIF(!string.IsNullOrEmpty(input.bz), p => p.Bz.Contains(input.bz))
                .WhereIF(!string.IsNullOrEmpty(input.kdhy), p => p.Kdhy.Equals(input.kdhy))
                .WhereIF(!string.IsNullOrEmpty(input.kdhyc), p => p.Kdhyc.Contains(input.kdhyc))
                .WhereIF(!string.IsNullOrEmpty(input.kdhysjh), p => p.Kdhysjh.Contains(input.kdhysjh))
                .WhereIF(!string.IsNullOrEmpty(input.jksyj), p => p.Jksyj.Contains(input.jksyj))
                .WhereIF(!string.IsNullOrEmpty(input.kjblsyj), p => p.Kjblsyj.Contains(input.kjblsyj))
                .WhereIF(!string.IsNullOrEmpty(input.pxxx), p => p.Pxxx.Contains(input.pxxx))
                .Select(it=> new LqKdKdjlbListOutput
                {
                    id = it.Id,
                    djmd=it.Djmd,
                    jsj=it.Jsj,
                    kdrq=it.Kdrq,
                    gjlx=it.Gjlx,
                    hgjg=it.Hgjg,
                    zdyj=it.Zdyj,
                    sfyj=it.Sfyj,
                    qk=it.Qk,
                    ckfs=it.Ckfs,
                    ckmx=it.Ckmx,
                    fkfs=it.Fkfs,
                    fkyy=it.Fkyy,
                    fkpd=it.Fkpd,
                    khly=it.Khly,
                    tjr=it.Tjr,
                    sfskdd=it.Sfskdd,
                    jj=it.Jj,
                    bz=it.Bz,
                    kdhy=it.Kdhy,
                    kdhyc=it.Kdhyc,
                    kdhysjh=it.Kdhysjh,
                    jksyj=it.Jksyj,
                    kjblsyj=it.Kjblsyj,
                    pxxx=it.Pxxx,
                }).MergeTable().OrderBy(sidx+" "+input.sort).ToPagedListAsync(input.currentPage, input.pageSize);
                return PageResult<LqKdKdjlbListOutput>.SqlSugarPageResult(data);
        }

        /// <summary>
        /// 新建开单记录表
        /// </summary>
        /// <param name="input">参数</param>
        /// <returns></returns>
        [HttpPost("")]
        public async Task Create([FromBody] LqKdKdjlbCrInput input)
        {
            var userInfo = await _userManager.GetUserInfo();
            var entity = input.Adapt<LqKdKdjlbEntity>();
            entity.Id = YitIdHelper.NextId().ToString();
            try
            {
                //开启事务
                _db.BeginTran();
                
                //新增开单记录表记录
                var newEntity = await _db.Insertable(entity).IgnoreColumns(ignoreNullColumn: true).ExecuteReturnEntityAsync();

                var lqKdJksyjEntityList = input.lqKdJksyjList.Adapt<List<LqKdJksyjEntity>>();
                if(lqKdJksyjEntityList != null)
                {
                    foreach (var item in lqKdJksyjEntityList)
                    {
                        item.Id = YitIdHelper.NextId().ToString();
                        item.Glkdbh = newEntity.Id;
                    }
                    await _db.Insertable(lqKdJksyjEntityList).ExecuteCommandAsync();
                }

                var lqKdKjbsyjEntityList = input.lqKdKjbsyjList.Adapt<List<LqKdKjbsyjEntity>>();
                if(lqKdKjbsyjEntityList != null)
                {
                    foreach (var item in lqKdKjbsyjEntityList)
                    {
                        item.Id = YitIdHelper.NextId().ToString();
                        item.Glkdbh = newEntity.Id;
                    }
                    await _db.Insertable(lqKdKjbsyjEntityList).ExecuteCommandAsync();
                }

                var lqKdPxmxEntityList = input.lqKdPxmxList.Adapt<List<LqKdPxmxEntity>>();
                if(lqKdPxmxEntityList != null)
                {
                    foreach (var item in lqKdPxmxEntityList)
                    {
                        item.Id = YitIdHelper.NextId().ToString();
                        item.Glkdbh = newEntity.Id;
                    }
                    await _db.Insertable(lqKdPxmxEntityList).ExecuteCommandAsync();
                }

                //关闭事务
                _db.CommitTran();
                
                // 生成开单记录字符串并发送到企业微信
                try
                {
                    var entityInfo = await GetInfo(newEntity.Id);
                    if (entityInfo != null)
                    {
                        var orderRecordString = _stringGenerator.GenerateOrderRecordString(entityInfo);
                        Console.WriteLine("开单记录字符串生成成功:");
                        Console.WriteLine(orderRecordString);
                        
                        // 发送到企业微信群
                        try
                        {
                            var sendResult = await _weChatBotService.SendOrderRecordMessage(orderRecordString);
                            if (sendResult)
                            {
                                Console.WriteLine("开单记录已成功发送到企业微信群");
                            }
                            else
                            {
                                Console.WriteLine("开单记录发送到企业微信群失败");
                            }
                        }
                        catch (Exception wechatEx)
                        {
                            Console.WriteLine($"发送企业微信消息异常: {wechatEx.Message}");
                        }
                    }
                }
                catch (Exception ex)
                {
                    // 字符串生成失败不影响主流程，只记录日志
                    Console.WriteLine($"生成开单记录字符串失败: {ex.Message}");
                }
            }
            catch (Exception)
            {
                //回滚事务
                _db.RollbackTran();
                throw NCCException.Oh(ErrorCode.COM1000);
            }
        }

        /// <summary>
		/// 获取开单记录表无分页列表
		/// </summary>
		/// <param name="input">请求参数</param>
		/// <returns></returns>
        [NonAction]
        public async Task<dynamic> GetNoPagingList([FromQuery] LqKdKdjlbListQueryInput input)
        {
            var sidx = input.sidx == null ? "id" : input.sidx;
            List<string> queryKdrq = input.kdrq != null ? input.kdrq.Split(',').ToObeject<List<string>>() : null;
            DateTime? startKdrq = queryKdrq != null ? Ext.GetDateTime(queryKdrq.First()) : null;
            DateTime? endKdrq = queryKdrq != null ? Ext.GetDateTime(queryKdrq.Last()) : null;
            var data = await _db.Queryable<LqKdKdjlbEntity>()
                .WhereIF(!string.IsNullOrEmpty(input.id), p => p.Id.Contains(input.id))
                .WhereIF(!string.IsNullOrEmpty(input.djmd), p => p.Djmd.Equals(input.djmd))
                .WhereIF(!string.IsNullOrEmpty(input.jsj), p => p.Jsj.Equals(input.jsj))
                .WhereIF(queryKdrq != null, p => p.Kdrq >= new DateTime(startKdrq.ToDate().Year, startKdrq.ToDate().Month, startKdrq.ToDate().Day, 0, 0, 0))
                .WhereIF(queryKdrq != null, p => p.Kdrq <= new DateTime(endKdrq.ToDate().Year, endKdrq.ToDate().Month, endKdrq.ToDate().Day, 23, 59, 59))
                .WhereIF(!string.IsNullOrEmpty(input.gjlx), p => p.Gjlx.Equals(input.gjlx))
                .WhereIF(!string.IsNullOrEmpty(input.hgjg), p => p.Hgjg.Equals(input.hgjg))
                .WhereIF(!string.IsNullOrEmpty(input.zdyj), p => p.Zdyj.Equals(input.zdyj))
                .WhereIF(!string.IsNullOrEmpty(input.sfyj), p => p.Sfyj.Equals(input.sfyj))
                .WhereIF(!string.IsNullOrEmpty(input.qk), p => p.Qk.Equals(input.qk))
                .WhereIF(!string.IsNullOrEmpty(input.ckfs), p => p.Ckfs.Equals(input.ckfs))
                .WhereIF(!string.IsNullOrEmpty(input.ckmx), p => p.Ckmx.Contains(input.ckmx))
                .WhereIF(!string.IsNullOrEmpty(input.fkfs), p => p.Fkfs.Equals(input.fkfs))
                .WhereIF(!string.IsNullOrEmpty(input.fkyy), p => p.Fkyy.Equals(input.fkyy))
                .WhereIF(!string.IsNullOrEmpty(input.fkpd), p => p.Fkpd.Contains(input.fkpd))
                .WhereIF(!string.IsNullOrEmpty(input.khly), p => p.Khly.Equals(input.khly))
                .WhereIF(!string.IsNullOrEmpty(input.tjr), p => p.Tjr.Contains(input.tjr))
                .WhereIF(!string.IsNullOrEmpty(input.sfskdd), p => p.Sfskdd.Equals(input.sfskdd))
                .WhereIF(!string.IsNullOrEmpty(input.jj), p => p.Jj.Contains(input.jj))
                .WhereIF(!string.IsNullOrEmpty(input.bz), p => p.Bz.Contains(input.bz))
                .WhereIF(!string.IsNullOrEmpty(input.kdhy), p => p.Kdhy.Equals(input.kdhy))
                .WhereIF(!string.IsNullOrEmpty(input.kdhyc), p => p.Kdhyc.Contains(input.kdhyc))
                .WhereIF(!string.IsNullOrEmpty(input.kdhysjh), p => p.Kdhysjh.Contains(input.kdhysjh))
                .WhereIF(!string.IsNullOrEmpty(input.jksyj), p => p.Jksyj.Contains(input.jksyj))
                .WhereIF(!string.IsNullOrEmpty(input.kjblsyj), p => p.Kjblsyj.Contains(input.kjblsyj))
                .WhereIF(!string.IsNullOrEmpty(input.pxxx), p => p.Pxxx.Contains(input.pxxx))
                .Select(it=> new LqKdKdjlbListOutput
                {
                    id = it.Id,
                    djmd=it.Djmd,
                    jsj=it.Jsj,
                    kdrq=it.Kdrq,
                    gjlx=it.Gjlx,
                    hgjg=it.Hgjg,
                    zdyj=it.Zdyj,
                    sfyj=it.Sfyj,
                    qk=it.Qk,
                    ckfs=it.Ckfs,
                    ckmx=it.Ckmx,
                    fkfs=it.Fkfs,
                    fkyy=it.Fkyy,
                    fkpd=it.Fkpd,
                    khly=it.Khly,
                    tjr=it.Tjr,
                    sfskdd=it.Sfskdd,
                    jj=it.Jj,
                    bz=it.Bz,
                    kdhy=it.Kdhy,
                    kdhyc=it.Kdhyc,
                    kdhysjh=it.Kdhysjh,
                    jksyj=it.Jksyj,
                    kjblsyj=it.Kjblsyj,
                    pxxx=it.Pxxx,
                }).MergeTable().OrderBy(sidx+" "+input.sort).ToListAsync();
                return data;
        }

        /// <summary>
		/// 导出开单记录表
		/// </summary>
		/// <param name="input">请求参数</param>
		/// <returns></returns>
        [HttpGet("Actions/Export")]
        public async Task<dynamic> Export([FromQuery] LqKdKdjlbListQueryInput input)
        {
            var userInfo = await _userManager.GetUserInfo();
            var exportData = new List<LqKdKdjlbListOutput>();
            if (input.dataType == 0)
            {
                var data = Clay.Object(await this.GetList(input));
                exportData = data.Solidify<PageResult<LqKdKdjlbListOutput>>().list;
            }
            else
            {
                exportData = await this.GetNoPagingList(input);
            }
            List<ParamsModel> paramList = "[{\"value\":\"开单编号\",\"field\":\"id\"},{\"value\":\"开单会员\",\"field\":\"kdhy\"},{\"value\":\"开单会员名称\",\"field\":\"kdhyc\"},{\"value\":\"会员手机号\",\"field\":\"kdhysjh\"},{\"value\":\"单据门店\",\"field\":\"djmd\"},{\"value\":\"金三角\",\"field\":\"jsj\"},{\"value\":\"开单日期\",\"field\":\"kdrq\"},{\"value\":\"顾客类型\",\"field\":\"gjlx\"},{\"value\":\"合作机构\",\"field\":\"hgjg\"},{\"value\":\"整单业绩\",\"field\":\"zdyj\"},{\"value\":\"实付业绩\",\"field\":\"sfyj\"},{\"value\":\"欠款\",\"field\":\"qk\"},{\"value\":\"储扣方式\",\"field\":\"ckfs\"},{\"value\":\"储扣明细\",\"field\":\"ckmx\"},{\"value\":\"付款方式\",\"field\":\"fkfs\"},{\"value\":\"付款医院\",\"field\":\"fkyy\"},{\"value\":\"付款判断\",\"field\":\"fkpd\"},{\"value\":\"客户来源\",\"field\":\"khly\"},{\"value\":\"推荐人\",\"field\":\"tjr\"},{\"value\":\"是否首开订单\",\"field\":\"sfskdd\"},{\"value\":\"简介\",\"field\":\"jj\"},{\"value\":\"备注\",\"field\":\"bz\"},{\"value\":\"健康师业绩\",\"field\":\"jksyj\"},{\"value\":\"科技部老师业绩\",\"field\":\"kjblsyj\"},{\"value\":\"品项信息\",\"field\":\"pxxx\"},]".ToList<ParamsModel>();           
            ExcelConfig excelconfig = new ExcelConfig();
            excelconfig.FileName = "开单记录表.xls";
            excelconfig.HeadFont = "微软雅黑";
            excelconfig.HeadPoint = 10;
            excelconfig.IsAllSizeColumn = true;
            excelconfig.ColumnModel = new List<ExcelColumnModel>();
            List<string> selectKeyList = input.selectKey.Split(',').ToList();
            foreach (var item in selectKeyList)
            {
                var isExist = paramList.Find(p => p.field == item);
                if (isExist != null)
                {
                    excelconfig.ColumnModel.Add(new ExcelColumnModel() { Column = isExist.field, ExcelColumn = isExist.value });
                }
            }
            var addPath = FileVariable.TemporaryFilePath + excelconfig.FileName;
            ExcelExportHelper<LqKdKdjlbListOutput>.Export(exportData, excelconfig, addPath);
            var fileName = _userManager.UserId + "|" + addPath + "|xls";
            var output = new
            {
                name = excelconfig.FileName,
                url = "/api/File/Download?encryption=" + DESCEncryption.Encrypt(fileName, "NCC")
            };
            return output;
        }

        /// <summary>
        /// 批量删除开单记录表
        /// </summary>
        /// <param name="ids">主键数组</param>
        /// <returns></returns>
        [HttpPost("batchRemove")]
        public async Task BatchRemove([FromBody] List<string> ids)
        {
            var entitys = await _db.Queryable<LqKdKdjlbEntity>().In(it => it.Id, ids).ToListAsync();
            if (entitys.Count > 0)
            {
                try
                {
                    //开启事务
                    _db.BeginTran();
                    //批量删除开单记录表
                    await _db.Deleteable<LqKdKdjlbEntity>().In(d => d.Id,ids).ExecuteCommandAsync();

                    //清空子表数据
                    await _db.Deleteable<LqKdJksyjEntity>().In(u => u.Glkdbh,ids).ExecuteCommandAsync();

                    //清空子表数据
                    await _db.Deleteable<LqKdKjbsyjEntity>().In(u => u.Glkdbh,ids).ExecuteCommandAsync();

                    //清空子表数据
                    await _db.Deleteable<LqKdPxmxEntity>().In(u => u.Glkdbh,ids).ExecuteCommandAsync();
                    //关闭事务
                    _db.CommitTran();
                }
                catch (Exception)
                {
                    //回滚事务
                    _db.RollbackTran();
                    throw NCCException.Oh(ErrorCode.COM1002);
                }
            }
        }

        /// <summary>
        /// 更新开单记录表
        /// </summary>
        /// <param name="id">主键</param>
        /// <param name="input">参数</param>
        /// <returns></returns>
        [HttpPut("{id}")]
        public async Task Update(string id, [FromBody] LqKdKdjlbUpInput input)
        {
            var entity = input.Adapt<LqKdKdjlbEntity>();
            try
            {
                //开启事务
                _db.BeginTran();
                
                //更新开单记录表记录
                await _db.Updateable(entity).IgnoreColumns(ignoreAllNullColumns: true).ExecuteCommandAsync();

                //清空原有数据
                await _db.Deleteable<LqKdJksyjEntity>().Where(u => u.Glkdbh == id).ExecuteCommandAsync();
                //新增新数据
                var lqKdJksyjEntityList = input.lqKdJksyjList.Adapt<List<LqKdJksyjEntity>>();
                if(lqKdJksyjEntityList != null)
                {
                    foreach (var item in lqKdJksyjEntityList)
                    {
                        item.Id = YitIdHelper.NextId().ToString();
                        item.Glkdbh = entity.Id;
                    }
                    await _db.Insertable(lqKdJksyjEntityList).ExecuteCommandAsync();
                }

                //清空原有数据
                await _db.Deleteable<LqKdKjbsyjEntity>().Where(u => u.Glkdbh == id).ExecuteCommandAsync();
                //新增新数据
                var lqKdKjbsyjEntityList = input.lqKdKjbsyjList.Adapt<List<LqKdKjbsyjEntity>>();
                if(lqKdKjbsyjEntityList != null)
                {
                    foreach (var item in lqKdKjbsyjEntityList)
                    {
                        item.Id = YitIdHelper.NextId().ToString();
                        item.Glkdbh = entity.Id;
                    }
                    await _db.Insertable(lqKdKjbsyjEntityList).ExecuteCommandAsync();
                }

                //清空原有数据
                await _db.Deleteable<LqKdPxmxEntity>().Where(u => u.Glkdbh == id).ExecuteCommandAsync();
                //新增新数据
                var lqKdPxmxEntityList = input.lqKdPxmxList.Adapt<List<LqKdPxmxEntity>>();
                if(lqKdPxmxEntityList != null)
                {
                    foreach (var item in lqKdPxmxEntityList)
                    {
                        item.Id = YitIdHelper.NextId().ToString();
                        item.Glkdbh = entity.Id;
                    }
                    await _db.Insertable(lqKdPxmxEntityList).ExecuteCommandAsync();
                }
                
                //关闭事务
                _db.CommitTran();
            }
            catch (Exception)
            {
                //回滚事务
                _db.RollbackTran();
                throw NCCException.Oh(ErrorCode.COM1001);
            }
        }

        /// <summary>
        /// 删除开单记录表
        /// </summary>
        /// <returns></returns>
        [HttpDelete("{id}")]
        public async Task Delete(string id)
        {
            var entity = await _db.Queryable<LqKdKdjlbEntity>().FirstAsync(p => p.Id == id);
            _ = entity ?? throw NCCException.Oh(ErrorCode.COM1005);
            try
            {
                //开启事务
                _db.BeginTran();
                
                //删除开单记录表记录
                await _db.Deleteable<LqKdKdjlbEntity>().Where(d => d.Id == id).ExecuteCommandAsync();

                //清空子表数据
                await _db.Deleteable<LqKdJksyjEntity>().Where(u => u.Glkdbh == id).ExecuteCommandAsync();

                //清空子表数据
                await _db.Deleteable<LqKdKjbsyjEntity>().Where(u => u.Glkdbh == id).ExecuteCommandAsync();

                //清空子表数据
                await _db.Deleteable<LqKdPxmxEntity>().Where(u => u.Glkdbh == id).ExecuteCommandAsync();
                
                //关闭事务
                _db.CommitTran();
            }
            catch (Exception)
            {
                //回滚事务
                _db.RollbackTran();
                throw NCCException.Oh(ErrorCode.COM1002);
            }
        }

    }
}