using MES.Service.DB;
using MES.Service.Dto.service;
using MES.Service.Modes;
using SqlSugar;

namespace MES.Service.service.SpotCheck;

public class SpotCheckService
{
    public async Task<DjDetailResult> GetDjDetail(DJPageResultDto queryObj)
    {
        // 处理传入的 releaseNo 为 null 的情况
        if (string.IsNullOrEmpty(queryObj.eqNo))
            return new DjDetailResult
            {
                MesEqKeepsType02List = new List<MesEqKeepsType02>(),
                EqInfoList = new List<MesEqMaintain>()
            };

        using (var db = SqlSugarHelper.GetInstance())
        {
            try
            {
                // 获取当天开始和结束时间
                var todayStart = DateTime.Today;
                var todayEnd = todayStart.AddDays(1);

                var results = await db.Queryable<MesEqMaintain>()
                    .Where(x => x.EqNo == queryObj.eqNo &&
                                x.CreateDate >= todayStart &&
                                x.CreateDate < todayEnd &&
                                x.Flag == 0)
                    .Select(x => new
                    {
                        x.Id,
                        x.EqName,
                        x.PlanNo,
                        x.EqNo
                    })
                    .ToListAsync();
                if (results == null || results.Count == 0)
                    throw new Exception("单据不存在");

                var ids = results.Select(r => (decimal)r.Id).ToList();

                var eqInfoList = results.Select(r => new MesEqMaintain
                {
                    EqName = r.EqName,
                    PlanNo = r.PlanNo,
                    EqNo = r.EqNo
                }).ToList();

                if (ids.Count == 0)
                    return new DjDetailResult
                    {
                        MesEqKeepsType02List = new List<MesEqKeepsType02>(),
                        EqInfoList = new List<MesEqMaintain>()
                    };

                // 根据获取的 id 列表查询 MesEqKeepsType02 表
                var keepsType02List = await db.Queryable<MesEqKeepsType02>()
                    .Where(x => x.Pid.HasValue && ids.Contains(x.Pid.Value))
                    .ToListAsync();

                return new DjDetailResult
                {
                    MesEqKeepsType02List = keepsType02List,
                    EqInfoList = eqInfoList
                };
            }
            catch (SqlSugarException ex)
            {
                // 处理数据库操作异常
                // 这里可以根据实际需求添加日志记录等操作
                Console.WriteLine($"数据库查询出错: {ex.Message}");
                return new DjDetailResult
                {
                    MesEqKeepsType02List = new List<MesEqKeepsType02>(),
                    EqInfoList = new List<MesEqMaintain>()
                };
            }
            catch (Exception ex)
            {
                // 处理其他异常
                Console.WriteLine($"发生未知错误: {ex.Message}");
                return new DjDetailResult
                {
                    MesEqKeepsType02List = new List<MesEqKeepsType02>(),
                    EqInfoList = new List<MesEqMaintain>()
                };
            }
        }
    }

    public async Task<List<MesEqMaintain>> UpdateDjDetail(
        DJPageResultDto updateObj)
    {
        // 处理传入的 releaseNo 为 null 或空字符串的情况
        if (string.IsNullOrEmpty(updateObj.releaseNo))
            return new List<MesEqMaintain>();

        using (var db = SqlSugarHelper.GetInstance())
        {
            try
            {
                // 开启事务
                db.Ado.BeginTran();

                // 更新 MesEqMaintain 表的数据
                await db.Updateable<MesEqMaintain>()
                    .SetColumns(x => new MesEqMaintain
                    {
                        CheckBy = updateObj.userNo,
                        Flag = 1,
                        CheckDate = DateTime.Now
                    })
                    .Where(x => x.PlanNo == updateObj.releaseNo && x.Flag == 0)
                    .ExecuteCommandAsync();

                // 根据 inspectionItems 列表的 id 更新 MesEqKeepsType02 表
                if (updateObj.inspectionItems != null)
                    foreach (var item in updateObj.inspectionItems)
                        if (item.id.HasValue)
                            await db.Updateable<MesEqKeepsType02>()
                                .SetColumns(x => new MesEqKeepsType02
                                {
                                    EqEnd = item.result
                                })
                                .Where(x => x.Id == item.id.Value)
                                .ExecuteCommandAsync();

                // 提交事务
                db.Ado.CommitTran();

                // 根据更新条件查询更新后的数据
                return await db.Queryable<MesEqMaintain>()
                    .Where(x => x.PlanNo == updateObj.releaseNo)
                    .ToListAsync();
            }
            catch (SqlSugarException ex)
            {
                // 回滚事务
                db.Ado.RollbackTran();

                // 处理数据库操作异常
                // 这里可以根据实际需求添加日志记录等操作
                Console.WriteLine($"数据库操作出错: {ex.Message}");
                return new List<MesEqMaintain>();
            }
            catch (Exception ex)
            {
                // 回滚事务
                db.Ado.RollbackTran();

                // 处理其他异常
                Console.WriteLine($"发生未知错误: {ex.Message}");
                return new List<MesEqMaintain>();
            }
        }
    }
}