using WcsMain.Common;
using WcsMain.DataBase.JoinTableEntity;
using WcsMain.DataBase.TableEntity;
using WcsMain.WcsAttribute.AutoFacAttribute;

namespace WcsMain.DataBase.Dao;

[Component]
public class AppErrRecorDao
{

    /// <summary>
    /// 插入数据
    /// </summary>
    /// <param name="records"></param>
    /// <returns></returns>
    public int Insert(params AppErrRecord[] records)
    {
        try
        {
            var sqlFuc = CommonTool.DbServe.Insertable(records);
            return sqlFuc.ExecuteCommand();
        }
        catch (Exception ex)
        {
            _ = ex;
            return 0;
        }
    }

    /// <summary>
    /// 查询所有数据
    /// </summary>
    /// <returns></returns>
    public List<AppErrRecord>? Query()
    {
        try
        {
            var sqlFuc = CommonTool.DbServe.Queryable<AppErrRecord>();
            return sqlFuc.ToList();
        }
        catch (Exception ex)
        {
            _ = ex;
            return null;
        }
    }

    /// <summary>
    /// 查询指定条数的数据
    /// </summary>
    /// <param name="count"></param>
    /// <returns></returns>
    public List<AppErrRecord>? Query(int count)
    {
        if(count < 1) return null;
        try
        {
            var sqlFuc = CommonTool.DbServe.Queryable<AppErrRecord>().Take(count);
            return sqlFuc.ToList();
        }
        catch (Exception ex)
        {
            _ = ex;
            return null;
        }
    }

    /// <summary>
    /// 查询最近一个月的故障列表
    /// </summary>
    /// <returns></returns>
    public List<AppErrorRecordJoin>? SelectErrorRecordWithJoin()
    {
        try
        {
            var sqlFuc = CommonTool.DbServe.Queryable<AppErrRecord>()
                .LeftJoin<AppBaseErr>((r, b) => r.ErrNo == b.ErrNo)
                .Where(r => r.CreateTime > DateTime.Now.AddMonths(-1))
                .OrderByDescending(r => r.CreateTime)
                .Select((r, b) =>
                    new AppErrorRecordJoin
                    {
                        Area = r.Area,
                        ErrNo = r.ErrNo,
                        EquipmentId = r.EquipmentId,
                        CreateTime = r.CreateTime,
                        ErrType = b.ErrType,
                        ErrMsg = b.ErrMsg
                    });
            return sqlFuc.ToList();
        }
        catch (Exception ex)
        {
            _ = ex;
            return null;
        }
    }





}