using SqlSugar;
using System;
using System.Collections.Generic;
using MES.Service.DB;
using MES.Service.Modes;
using MES.Service.Dto.webApi;
using System.Data;

namespace MES.Service.service
{
public class MesReturnwareManager : Repository<MesReturnware>
{


        private readonly MesReturnwareDetailsManager ReturnwareDetailsManager = new();
        //当前类已经继承了 Repository 增、删、查、改的方法

        //这里面写的代码不会给覆盖,如果要重新生成请删除 MesReturnwareManager.cs


        public bool SaveList(List<ErpReturn> ReturnWare)
        {
            var result = ReturnWare.Select(Save).ToList();
            return result.All(b => b);
        }

        public bool Save(ErpReturn ReturnWare)
        {
            var ReturnWares = ReturnWare.ErpReturnWares;
            var mesReturnWares = MapErptoMesReturnware(ReturnWares);
            var ErpReturnWareDetails = MapErptoMesReturnwareDetails(ReturnWare.ErpReturnWareDetailss);

            return UseTransaction(db =>
            {
                switch (ReturnWares.Type)
                {
                    case "3":
                        return UpdateData(db, mesReturnWares, ErpReturnWareDetails) ? 1 : 0;
                    case "2":
                    case "4":
                        return SaveOrUpdateData(db, mesReturnWares, ErpReturnWareDetails)
                            ? 1
                            : 0;
                    default:
                        throw new NotImplementedException(
                            $"type没有{ReturnWares.Type}这个类型");
                }
            }) > 0;
        }

        private bool SaveOrUpdateData(SqlSugarScope db, MesReturnware mesReturnware,
            List<MesReturnwareDetails> mesReturnwareDetails)
        {


            if (mesReturnware.ReturnNo != null && mesReturnware.ReturnType != null)
            {

                db.Deleteable<MesReturnware>()
               .Where(it => it.ReturnNo == mesReturnware.ReturnNo &&
                            it.ReturnType == mesReturnware.ReturnType)
               .ExecuteCommand();

            };


            if (mesReturnwareDetails.Count > 0)
            {

                // var mesWomcab = mesWomcabs.Select(s => new { CAB001 = s.Cab001, CAB002 = s.Cab002, CAB003 = s.Cab003 }).ToList();
                var mesReturnwareDetail = mesReturnwareDetails.Select(s => new { ReturnwareNo = s.ReturnNo, ReturnwareType = s.ReturnType }).ToList();


                /*db.Deleteable<Womcab>()
                    .Where(it => mesWomcab
                    .Any(p => p.CAB001 == it.Cab001 
                    && p.CAB002 == it.Cab002 
                    && p.CAB003 == it.Cab003))
                    .ExecuteCommand();*/
                db.Deleteable<MesReturnwareDetails>()
                    .Where(it => mesReturnwareDetail
                    .Any(p => p.ReturnwareNo == it.ReturnNo
                    && p.ReturnwareType == it.ReturnType))
                    .ExecuteCommand();

            };


            // var orUpdate = db.Insertable(mesOutware).ExecuteCommand();
            //var baOrUpdate = db.Insertable(mesOutwareDetails).ExecuteCommand();


            var orUpdate = base.Insert(mesReturnware);
            var baOrUpdate = ReturnwareDetailsManager.InsertRange(mesReturnwareDetails);

            if (orUpdate && baOrUpdate)
            {
                // 保存成功后，调用存储过程生成检验单
                GenerateInspectionOrder(db, mesReturnware, mesReturnwareDetails);
                return true;
            }
            throw new NotImplementedException("插入或更新失败");


        }

        private bool UpdateData(SqlSugarScope db, MesReturnware mesReturnware,
            List<MesReturnwareDetails> mesReturnwareDetails)
        {
            //根据单别和单号进行删除
            var update = db.Deleteable<MesReturnware>()
            .Where(it => it.ReturnNo == mesReturnware.ReturnNo &&
                         it.ReturnType == mesReturnware.ReturnType)
            .ExecuteCommand() > 0;


            //var mesWomcab = mesWomcabs.Select(s => new { CAB001 = s.Cab001, CAB002 = s.Cab002, CAB003 = s.Cab003 }).ToList();
            var mesReturnwareDetail = mesReturnwareDetails.Select(s => new { ReturnwareNo = s.ReturnNo, ReturnwareType = s.ReturnType }).ToList();



            //var insertOrUpdate = db.Deleteable<Womcab>().Where(it => mesWomcab.Any(p => p.CAB001 == it.Cab001 && p.CAB002 == it.Cab002 && p.CAB003 == it.Cab003)).ExecuteCommand() > 0;
            var insertOrUpdate = db.Deleteable<MesReturnwareDetails>().Where(it => mesReturnwareDetail.Any(p => p.ReturnwareNo == it.ReturnNo && p.ReturnwareType == it.ReturnType)).ExecuteCommand() > 0;


            if (update && insertOrUpdate)
            {
                // 更新成功后，调用存储过程生成检验单
                GenerateInspectionOrder(db, mesReturnware, mesReturnwareDetails);
                return true;
            }
            throw new NotImplementedException("更新失败");
        }

        private MesReturnware MapErptoMesReturnware(ErpReturnWare dto)
        {



            var entity = new MesReturnware
            {
                ReturnType = dto.ReturnType,
                ReturnNo = dto.ReturnNo,
                CustNo = dto.CustNo,
                BillDate = dto.BillDate,
                BusinessBy = dto.BusinessBy,
                WorkshopCenterCode = dto.WorkCode,
                Remarks = dto.Remarks,
                CreateBy = dto.CreateBy,
                CreateDate = dto.CreateDate,
                Type       = dto.Type,
                Over=dto.Over ?? 0
            };



            return entity;
        }

        private List<MesReturnwareDetails> MapErptoMesReturnwareDetails(List<ErpReturnWareDetails> dtoList)
        {
            var returnwareList = new List<MesReturnwareDetails>();

            foreach (var dto in dtoList)
            {
                var ReturnwareDetails = new MesReturnwareDetails
                {

                   
                    ItemNo = dto.ItemNo,
                    ItemName = dto.ItemName,
                    ItemModel = dto.ItemModel,
                    Quantity = dto.Quantity,
                    Type = dto.Type,
                    DepotCode = dto.DepotCode,
                    ReturnType = dto.ReturnType,
                    ReturnNo   = dto.ReturnNo,
                    ReturnOrder = dto.ReturnOrder,
                    OrderType = dto.OrderType,
                    OrderNumber = dto.OrderNumber,
                    OrderNo = dto.OrderNo,
                    ActualQuantity = dto.ActQuantity,
                    CustItemNo = dto.CustItemNo,
                    CustItemName = dto.CustItemName,
                    CustItemModel = dto.CustItemModel,
                    Remarks=dto.Remarks

                };



                returnwareList.Add(ReturnwareDetails);
            }

            return returnwareList;
        }


        public bool Delete(YFDelete data)
        {
            return UseTransaction(db =>
            {
                // 先删除退货通知单明细
                var detailsDeleted = db.Deleteable<MesReturnwareDetails>()
                      .Where(it => it.ReturnNo == data.FBillNo &&
                                   it.ReturnType == data.FBillTypeID)
                      .ExecuteCommand() > 0;

                // 再删除退货通知单主表
                var mainDeleted = db.Deleteable<MesReturnware>()
                       .Where(it => it.ReturnNo == data.FBillNo &&
                                    it.ReturnType == data.FBillTypeID)
                       .ExecuteCommand() > 0;

                if (detailsDeleted && mainDeleted)
                {
                    // 删除成功后，调用存储过程删除对应的检验单
                    DeleteInspectionOrder(db, data.FBillTypeID, data.FBillNo);
                    return 1;
                }
                
                throw new NotImplementedException("删除失败");
            }) > 0;
        }

        /// <summary>
        /// 调用存储过程生成检验单
        /// </summary>
        /// <param name="mesReturnware">退货通知单主表</param>
        /// <param name="mesReturnwareDetails">退货通知单明细表</param>
        private void GenerateInspectionOrder(SqlSugarScope db, MesReturnware mesReturnware, List<MesReturnwareDetails> mesReturnwareDetails)
        {
            try
            {
                // 定义输入参数
                var inputParam1 = new SugarParameter("P_RETURN_TYPE", mesReturnware.ReturnType ?? "");
                var inputParam2 = new SugarParameter("P_RETURN_NO", mesReturnware.ReturnNo ?? "");
                
                // 定义输出参数
                var outParam1 = new SugarParameter("P_RESULT", null, true);
                var outParam2 = new SugarParameter("P_MESSAGE", null, true);

                // 使用 SqlSugar 执行存储过程
                db.Ado.ExecuteCommand("BEGIN SP_GEN_RETURN_INSP(:P_RETURN_TYPE,:P_RETURN_NO,:P_RESULT,:P_MESSAGE); END;", 
                    inputParam1, inputParam2, outParam1, outParam2);

                // 获取输出参数的值
                int result = int.Parse((string)outParam1.Value);
                string message = outParam2.Value == DBNull.Value ? string.Empty : (string)outParam2.Value;

                if (result != 1)
                {
                    // 记录警告日志，但不影响退货通知单的保存
                    Console.WriteLine($"生成检验单警告: {message}");
                }
                else
                {
                    Console.WriteLine($"生成检验单成功: {message}");
                }
            }
            catch (Exception ex)
            {
                // 记录错误日志，但不影响退货通知单的保存
                Console.WriteLine($"生成检验单时发生错误: {ex.Message}");
            }
        }

        /// <summary>
        /// 调用存储过程删除检验单
        /// </summary>
        /// <param name="db">数据库连接</param>
        /// <param name="returnType">退货单别</param>
        /// <param name="returnNo">退货单号</param>
        private void DeleteInspectionOrder(SqlSugarScope db, string returnType, string returnNo)
        {
            try
            {
                // 定义输入参数
                var inputParam1 = new SugarParameter("P_RETURN_TYPE", returnType ?? "");
                var inputParam2 = new SugarParameter("P_RETURN_NO", returnNo ?? "");
                
                // 定义输出参数
                var outParam1 = new SugarParameter("P_RESULT", null, true);
                var outParam2 = new SugarParameter("P_MESSAGE", null, true);

                // 使用 SqlSugar 执行存储过程
                db.Ado.ExecuteCommand("BEGIN SP_DEL_RETURN_INSP(:P_RETURN_TYPE,:P_RETURN_NO,:P_RESULT,:P_MESSAGE); END;", 
                    inputParam1, inputParam2, outParam1, outParam2);

                // 获取输出参数的值
                int result = int.Parse((string)outParam1.Value);
                string message = outParam2.Value == DBNull.Value ? string.Empty : (string)outParam2.Value;

                if (result != 1)
                {
                    // 记录警告日志，但不影响退货通知单的删除
                    Console.WriteLine($"删除检验单警告: {message}");
                }
                else
                {
                    Console.WriteLine($"删除检验单成功: {message}");
                }
            }
            catch (Exception ex)
            {
                // 记录错误日志，但不影响退货通知单的删除
                Console.WriteLine($"删除检验单时发生错误: {ex.Message}");
            }
        }


    }
}