Valeo_Line_MES_backend/RIZO.ServiceCore/Services/UserOnlineLogService.cs

using Infrastructure.Attribute;
using RIZO.Model;
using RIZO.Model.Dto;
using RIZO.Model.Models;
using RIZO.Model.System;
using RIZO.Repository;
using RIZO.ServiceCore.Monitor.IMonitorService;
using RIZO.ServiceCore.Signalr;

namespace RIZO.ServiceCore.Monitor
{
    /// <summary>
    /// 用户在线时长Service业务层处理
    /// </summary>
    [AppService(ServiceType = typeof(IUserOnlineLogService), ServiceLifetime = LifeTime.Transient)]
    public class UserOnlineLogService : BaseService<UserOnlineLog>, IUserOnlineLogService
    {
        /// <summary>
        /// 查询用户在线时长列表
        /// </summary>
        /// <param name="parm"></param>
        /// <returns></returns>
        public PagedInfo<UserOnlineLogDto> GetList(UserOnlineLogQueryDto parm)
        {
            var predicate = QueryExp(parm);

            var response = Queryable()
                //.OrderBy("Id desc")
                .Where(predicate.ToExpression())
                .LeftJoin<SysUser>((it, u) => it.UserId == u.UserId)
                .Select((it, u) => new UserOnlineLogDto()
                {
                    NickName = u.NickName
                }, true)
                .ToPage(parm);

            return response;
        }

        /// <summary>
        /// 添加用户在线时长
        /// </summary>
        /// <param name="model"></param>
        /// <param name="user"></param>
        /// <returns></returns>
        public async Task<UserOnlineLog> AddUserOnlineLog(UserOnlineLog model, OnlineUsers user)
        {
            model.UserId = user.Userid;
            model.Location = user?.Location;
            model.OnlineTime = user.OnlineTime;
            model.UserIP = user.UserIP;
            model.Platform = user.Platform;
            model.Remark = user.Browser;
            model.LoginTime = user.LoginTime;
            model.AddTime = DateTime.Now;
            if (model.OnlineTime >= 0.5)
            {
                await Insertable(model).ExecuteReturnSnowflakeIdAsync();
            }
            return model;
        }

        /// <summary>
        /// 导出用户在线时长
        /// </summary>
        /// <param name="parm"></param>
        /// <returns></returns>
        public PagedInfo<UserOnlineLogDto> ExportList(UserOnlineLogQueryDto parm)
        {
            var predicate = QueryExp(parm);

            var response = Queryable()
                .Where(predicate.ToExpression())
                .Select((it) => new UserOnlineLogDto()
                {
                }, true)
                .ToPage(parm);

            return response;
        }

        /// <summary>
        /// 查询导出表达式
        /// </summary>
        /// <param name="parm"></param>
        /// <returns></returns>
        private static Expressionable<UserOnlineLog> QueryExp(UserOnlineLogQueryDto parm)
        {
            var predicate = Expressionable.Create<UserOnlineLog>();

            predicate = predicate.AndIF(parm.UserId != null, it => it.UserId == parm.UserId);
            predicate = predicate.AndIF(!string.IsNullOrEmpty(parm.UserIP), it => it.UserIP == parm.UserIP);
            predicate = predicate.AndIF(parm.BeginAddTime == null, it => it.AddTime >= DateTime.Now.ToShortDateString().ParseToDateTime());
            predicate = predicate.AndIF(parm.BeginAddTime != null, it => it.AddTime >= parm.BeginAddTime);
            return predicate;
        }
    }
}