using MES.Service.DB;
|
using MES.Service.Modes;
|
|
namespace MES.Service.service;
|
|
public class MessageCenterManager : Repository<MessageCenter>
|
{
|
//当前类已经继承了 Repository 增、删、查、改的方法
|
|
public List<MessageCenter> getPushFailedPage(MessageCenter query)
|
{
|
return Context.Queryable<MessageCenter>()
|
.Where(it =>
|
it.Result == 0 && it.Status == 1 &&
|
it.Seq == 1 &&
|
it.CreateBy == query.CreateBy)
|
.WhereIF(query.isShow == 1, it => it.DealWith == 0)
|
.OrderByDescending(it => it.CreateDate)
|
.ToPageList(1, 20);
|
}
|
|
public bool save(MessageCenter entity)
|
{
|
entity.CreateDate = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
|
entity.Method = "POST";
|
return base.Insert(entity);
|
}
|
|
//根据几种情况更新 保持页面id是固定的
|
|
|
//前台重新发送
|
public int ResetUpdate(MessageCenter entity)
|
{
|
return UseTransaction(db =>
|
{
|
return db.Updateable<MessageCenter>()
|
.SetColumns(a => a.Data == entity.Data)
|
.SetColumns(a => a.Result == entity.Result)
|
.SetColumns(a => a.ResultData == entity.ResultData)
|
.SetColumns(a => a.Status == entity.Status)
|
.SetColumns(a => a.DealWith == entity.DealWith)
|
.Where(a => a.Id == entity.Id)
|
.ExecuteCommand();
|
});
|
}
|
}
|