采购入库单和消息中心重推送

啊鑫

2024-08-01 b64efba9b005c074b3963c9d650091c70e46108b

 MES.Service/service/MessageCenterManager.cs

@@ -1,5 +1,6 @@
using MES.Service.DB;
using MES.Service.Modes;
using SqlSugar;

namespace MES.Service.service;

@@ -7,25 +8,54 @@
{
    //当前类已经继承了 Repository 增、删、查、改的方法

    public List<MessageCenter> getPushFailedPage(MessageCenter query)
    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)
                it.Seq == 1 && it.Title != null)
            .WhereIF(query.isShow == 1, it => it.DealWith == 0)
            .OrderByDescending(it => it.CreateDate)
            .ToPageList(1, 20);
    }

    public bool save(MessageCenter entity)
    public int save(MessageCenter entity)
    {
        entity.CreateDate = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
        entity.Method = "POST";
        return Db.Insertable(entity).ExecuteReturnIdentity();
    }

    public bool SetError(MessageCenter entity)
    {
        entity.CreateDate = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
        entity.Method = "POST";
        entity.Result = 0;
        entity.DealWith = 0;
        entity.Status = 1;
        return base.Insert(entity);
    }

    //获取所有没有成功的请求
    public List<MessageCenter> ErrorMsg()
    {
        return Context.Queryable<MessageCenter>()
            .GroupBy(a => new
            {
                a.TableName, a.Pid, a.Title, a.PageName
            })
            .Where(a =>
                a.DealWith == 0 && a.Status == 0 && a.Result == 0 &&
                a.Title == null)
            .Select<MessageCenter>(a => new MessageCenter
            {
                TableName = a.TableName,
                Pid = a.Pid,
                Title = a.Title,
                PageName = a.PageName,
                Count = SqlFunc.AggregateCount(a.Id)
            }).ToList();
    }
    //根据几种情况更新  保持页面id是固定的