using Infrastructure;
using Infrastructure.Attribute;
using ZR.Model;
using ZR.Model.Business;
using ZR.Model.Business.Dto;
using ZR.Model.System;
using ZR.Repository;
using ZR.Service.Business.IBusinessService;

namespace ZR.Service.Business
{
    /// <summary>
    /// 签到记录Service业务层处理
    /// </summary>
    [AppService(ServiceType = typeof(IOdfCheckinService), ServiceLifetime = LifeTime.Transient)]
    public class OdfCheckinService : BaseService<OdfCheckin>, IOdfCheckinService
    {
        /// <summary>
        /// 新增签到记录
        /// </summary>
        /// <param name="dto"></param>
        /// <returns></returns>
        public OdfCheckin AddCheckin(OdfCheckinDto dto)
        {
            // 校验 RoomId 存在
            var room = Context.Queryable<OdfRooms>()
                .Where(r => r.Id == dto.RoomId)
                .First();
            if (room == null)
            {
                throw new CustomException("机房不存在");
            }

            var model = new OdfCheckin
            {
                RoomId = dto.RoomId,
                Personnel = dto.Personnel,
                CheckinTime = DateTime.Parse(dto.CheckinTime),
                WorkContent = dto.WorkContent,
                UserId = dto.UserId,
                CreatedAt = DateTime.Now
            };

            return Insertable(model).ExecuteReturnEntity();
        }

        /// <summary>
        /// 分页查询签到记录（联查机房名称和提交人用户名）
        /// </summary>
        /// <param name="parm"></param>
        /// <returns></returns>
        public PagedInfo<OdfCheckinListDto> GetList(OdfCheckinQueryDto parm)
        {
            var predicate = QueryExp(parm);

            var response = Queryable()
                .Where(predicate.ToExpression())
                .LeftJoin<OdfRooms>((it, r) => it.RoomId == r.Id)
                .LeftJoin<SysUser>((it, r, u) => it.UserId == u.UserId)
                .OrderByDescending((it, r, u) => it.CheckinTime)
                .Select((it, r, u) => new OdfCheckinListDto()
                {
                    RoomName = r.RoomName,
                    UserName = u.NickName
                }, true)
                .ToPage(parm);

            return response;
        }

        /// <summary>
        /// 导出签到记录
        /// </summary>
        /// <param name="parm"></param>
        /// <returns></returns>
        public PagedInfo<OdfCheckinListDto> ExportList(OdfCheckinQueryDto parm)
        {
            parm.PageNum = 1;
            parm.PageSize = 100000;
            var predicate = QueryExp(parm);

            var response = Queryable()
                .Where(predicate.ToExpression())
                .LeftJoin<OdfRooms>((it, r) => it.RoomId == r.Id)
                .LeftJoin<SysUser>((it, r, u) => it.UserId == u.UserId)
                .OrderByDescending((it, r, u) => it.CheckinTime)
                .Select((it, r, u) => new OdfCheckinListDto()
                {
                    RoomName = r.RoomName,
                    UserName = u.NickName
                }, true)
                .ToPage(parm);

            return response;
        }

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

            predicate = predicate.AndIF(parm.RoomId != null, it => it.RoomId == parm.RoomId);
            predicate = predicate.AndIF(!string.IsNullOrEmpty(parm.Personnel), it => it.Personnel.Contains(parm.Personnel));
            predicate = predicate.AndIF(parm.BeginCheckinTime != null, it => it.CheckinTime >= parm.BeginCheckinTime);
            predicate = predicate.AndIF(parm.EndCheckinTime != null, it => it.CheckinTime <= parm.EndCheckinTime);

            return predicate;
        }
    }
}