wcs_serve_wuxikate/WcsMain/DataBase/Dao/AppErrRecorDao.cs
2025-01-03 14:36:27 +08:00

105 lines
2.5 KiB
C#

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;
}
}
}