GBRSWN/CZKJ.GBRS2/Logic/PriceAnnouncementLogic.cs

using CZFW.Framework.Logic;
using CZFW.Framework.Model.Entity;
using CZKJ.GBRS2.Entity;
using CZKJ.GBRS2.Interface;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;

namespace CZKJ.GBRS2.Logic
{
    public class PriceAnnouncementLogic : LogicBase<PriceAnnouncementEntity>, IPriceAnnouncement
    {
        public IList<PriceAnnouncementEntity> GetList(int typeId, DateTime? startTime, DateTime? endTime,int pageIndex, int pageSize, out int rowsCount)
        {
            IQueryable<PriceAnnouncementEntity> query = DbContext.Set<PriceAnnouncementEntity>();
            if (typeId != 0)
            {
                query = query.Where(x => x.Typeofinsuance == typeId);
            }
            if(startTime.HasValue&&endTime.HasValue)
            {
                query = query.Where(x => x.DateTime >= startTime && x.DateTime <= endTime);
            }
            rowsCount = query.Count();
            var result = query.Join(DbContext.Set<TypeEntity>(), x => x.Typeofinsuance, y => y.Id, (x, y) => new { x, y.Name }).OrderByDescending(x => x.x.DateTime).Skip((pageIndex - 1) * pageSize).Take(pageSize).ToList();
            return result.Select(x => new PriceAnnouncementEntity
            {
                TypeName = x.Name,
                Id = x.x.Id,
                Typeofinsuance = x.x.Typeofinsuance,
                DateTime = x.x.DateTime,
                DayInterestRate = x.x.DayInterestRate,
                YearInterestRate = x.x.YearInterestRate,
            }).ToList();
        }

        public int GetMaxYear()
        {
            return int.Parse(DbContext.Set<PriceAnnouncementEntity>().Max(x => x.DateTime).ToString("yyyy"));
        }

        public int GetMinYear()
        {
            return int.Parse(DbContext.Set<PriceAnnouncementEntity>().Min(x => x.DateTime).ToString("yyyy"));
        }

        public IList<PriceAnnouncementEntity> GetTableList(int? typeId, int pageIndex, int pageSize, out int rowsCount)
        {
            IQueryable<PriceAnnouncementEntity> query = DbContext.Set<PriceAnnouncementEntity>();
            if (typeId.HasValue)
            {
                query = query.Where(x => x.Typeofinsuance == typeId);
            }
            rowsCount = query.Count();
            var result = query.Join(DbContext.Set<TypeEntity>(), x => x.Typeofinsuance, y => y.Id, (x, y) => new { x, y.Name }).OrderByDescending(x => x.x.DateTime).Skip((pageIndex - 1) * pageSize).Take(pageSize).ToList();
            return result.Select(x => new PriceAnnouncementEntity
            {
                TypeName = x.Name,
                Id = x.x.Id,
                Typeofinsuance = x.x.Typeofinsuance,
                DateTime = x.x.DateTime,
                DayInterestRate = x.x.DayInterestRate,
                YearInterestRate = x.x.YearInterestRate,
            }).ToList();
        }
    }
}