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