55128ht_New/YiSha.Business/YiSha.Service/ZX/AccessRecordService.cs

using System;
using System.Linq;
using System.Text;
using System.Data.Common;
using System.Linq.Expressions;
using System.Collections.Generic;
using System.Threading.Tasks;
using YiSha.Util;
using YiSha.Util.Extension;
using YiSha.Util.Model;
using YiSha.Data;
using YiSha.Data.Repository;
using YiSha.Enum;
using System.ComponentModel.DataAnnotations.Schema;
using YiSha.Entity.ZX;
using YiSha.Model.Param.ZX;
using YiSha.IService.ZX;
using YiSha.Model.Result.ZX;
using static NPOI.HSSF.Util.HSSFColor;

namespace YiSha.Service.ZX
{
    /// <summary>
    /// 创 建：cmzx
    /// 日 期：2023-10-23 15:05
    /// 描 述：新闻统计服务实现类
    /// </summary>
    public partial class AccessRecordService : IAccessRecordService
    {
        private DBConnectTypeEnum dbConnectType = DBConnectTypeEnum.ZxDB;
        #region 获取数据
        /// <summary>
        /// 获取列表数据
        /// </summary>
        /// <param name="param">请求参数</param>
        /// <returns></returns>
        public async Task<List<AccessRecordEntity>> GetList(AccessRecordListParam param)
        {
            var expression = ListFilterPartial(param);
            var list = await _baseRepository.BaseRepository(dbConnectType).FindList(expression);
            return list.ToList();
        }

        /// <summary>
        /// 获取分页数据
        /// </summary>
        /// <param name="param">请求参数</param>
        /// <param name="pagination">分页条件</param>
        /// <returns></returns>
        public async Task<List<AccessRecordEntity>> GetPageList(AccessRecordListParam param, Pagination pagination)
        {
            var expression = ListFilterPartial(param);
            var list = await _baseRepository.BaseRepository(dbConnectType).FindList(expression, pagination);
            return list.ToList();
        }

        /// <summary>
        /// 获取指定列数据
        /// </summary>
        /// <param name="column">表字段列</param>
        /// <param name="where">条件</param>
        /// <param name="parameters">条件参数</param>
        /// <param name="sort">排序列</param>
        /// <param name="sortType">排序类型</param>
        /// <returns></returns>
        public async Task<List<AccessRecordEntity>> GetListColumn(string column, string where, List<DbParameter> parameters, string groupBy = "", string sort = "basecreatetime", string sortType = "desc")
        {
            if (string.IsNullOrEmpty(column) || string.IsNullOrEmpty(where))
                return new List<AccessRecordEntity>();
            if (!string.IsNullOrEmpty(groupBy))
                groupBy = $" group by {groupBy} ";
            string tableName = typeof(AccessRecordEntity).GetAttributeValue((TableAttribute ta) => ta.Name);
            string selectSql = $"select {column} from {tableName} where 1 = 1 and {where} {groupBy} order by {sort} {sortType}";
            var result = await _baseRepository.BaseRepository(dbConnectType).FindList<AccessRecordEntity>(selectSql, DbParameterExtension.ToDbParameter(parameters.ToArray()));
            return result.ToList();
        }

        /// <summary>
        /// 根据主键Id获取数据
        /// </summary>
        /// <param name="id">主键id</param>
        /// <returns></returns>
        public async Task<AccessRecordEntity> GetEntity(int id)
        {
            return await _baseRepository.BaseRepository(dbConnectType).FindEntity<AccessRecordEntity>(id);
        }

        /// <summary>
        /// 获取新闻浏览记录统计
        /// </summary>
        /// <returns></returns>
        public async Task<EChartModel> GetRecords(int timeType)
        {
            string whereStr = $"datediff(dd,ar.createTime,GETDATE())=0";
            switch (timeType)
            {
                case 2:
                    //近七天
                    whereStr = $"datediff(dd,ar.createTime,GETDATE())<=7";
                    break;
                case 3:
                    //近三十天
                    whereStr = $"datediff(dd,ar.createTime,GETDATE())<=30";
                    break;
            }
            string sql = @$"select * from (
select mmm.menuName,COUNT(*) as reccount from AccessRecords as ar
join newManagerModels as nmm on ar.newsId=nmm.ID
join menuManagerModels as mmm on nmm.menuId=mmm.ID
where {whereStr}
group by mmm.menuName) T
order by T.reccount desc";
            var result = await _baseRepository.BaseRepository(dbConnectType).FindList<NewsRecordsModel>(sql);
            EChartModel eChartModel = new EChartModel();
            eChartModel.Names = result.Select(x => x.menuName).ToList();
            eChartModel.RecCount = result.Select(x => x.reccount).ToList();
            //for (int i = 0; i < eChartModel.Names.Count; i++)
            //{
            //    if (eChartModel.Names[i].Length > 3)
            //    {
            //        eChartModel.Names[i] = eChartModel.Names[i].Substring(0, 3) + "..";
            //    }
            //}
            return eChartModel;
        }
        #endregion

        #region 提交数据
        /// <summary>
        /// 保存数据
        /// </summary>
        /// <param name="entity">实体参数</param>
        /// <returns></returns>
        public async Task SaveForm(AccessRecordEntity entity)
        {
            if (entity.Id.IsNullOrZero())
            {
                entity.Create();
                await _baseRepository.BaseRepository(dbConnectType).Insert(entity);
            }
            else
            {

                await _baseRepository.BaseRepository(dbConnectType).Update(entity);
            }
        }

        /// <summary>
        /// 保存多条数据
        /// </summary>
        /// <param name="list">数据列表</param>
        /// <returns></returns>
        public async Task<int> InsertMany(List<AccessRecordEntity> list)
        {
            return await _baseRepository.BaseRepository(dbConnectType).Insert(list);
        }

        /// <summary>
        /// 根据主键Id删除数据
        /// </summary>
        /// <param name="ids">主键Id</param>
        /// <param name="del">是否真删除 true真删除 false软删除 默认false</param>
        /// <returns></returns>
        public async Task<int> DeleteFormById(string ids, bool del = false)
        {
            if (string.IsNullOrWhiteSpace(ids) || !ids.Split(", ").Any())
            {
                return await Task.FromResult(-1);
            }
            ids = $"{string.Join(",", ids.Split(","))}";
            string tableName = typeof(AccessRecordEntity).GetAttributeValue((TableAttribute ta) => ta.Name);
            List<DbParameter> parameters = new List<DbParameter>();
            string deleteSql = $"delete from {tableName} where id in ({ids})";
            return await _baseRepository.BaseRepository(dbConnectType).ExecuteBySql(deleteSql, DbParameterExtension.ToDbParameter(parameters.ToArray()));
        }

        /// <summary>
        /// 根据条件删除数据
        /// </summary>
        /// <param name="where">where条件</param>
        /// <param name="parameters">参数</param>
        /// <param name="del">是否真删除 true真删除 false软删除 默认false</param>
        /// <returns></returns>
        public async Task<int> DeleteFormByWhere(string where, List<DbParameter> parameters, bool del = false)
        {
            if (string.IsNullOrWhiteSpace(where))
            {
                return await Task.FromResult(-1);
            }
            string tableName = typeof(AccessRecordEntity).GetAttributeValue((TableAttribute ta) => ta.Name);
            string deleteSql = $"delete from {tableName} where {where}";
            return await _baseRepository.BaseRepository(dbConnectType).ExecuteBySql(deleteSql, DbParameterExtension.ToDbParameter(parameters.ToArray()));
        }

        /// <summary>
        /// 修改多条数据
        /// </summary>
        /// <param name="list">数据列表</param>
        /// <returns></returns>
        public async Task<int> UpdateMany(List<AccessRecordEntity> list)
        {
            return await _baseRepository.BaseRepository(dbConnectType).Update(list);
        }

        /// <summary>
        /// 根据条件修改数据
        /// </summary>
        /// <param name="setField">修改字段</param>
        /// <param name="where">where条件</param>
        /// <param name="parameters">参数</param>
        /// <returns></returns>
        public async Task<int> UpdateFormByWhere(string setField, string where, List<DbParameter> parameters)
        {
            if (string.IsNullOrWhiteSpace(setField) || string.IsNullOrWhiteSpace(where))
            {
                return await Task.FromResult(-1);
            }
            string tableName = typeof(AccessRecordEntity).GetAttributeValue((TableAttribute ta) => ta.Name);
            string updateSql = $"update {tableName} set {setField} where {where}";
            return await _baseRepository.BaseRepository(dbConnectType).ExecuteBySql(updateSql, DbParameterExtension.ToDbParameter(parameters.ToArray()));
        }
        #endregion

        #region 私有方法
        ///// <summary>
        ///// 列表条件过滤
        ///// 建议该方法放在Partial部分类中，因为代码生成时当前类会被覆盖（该方法在生成时将会被注释）
        ///// </summary>
        ///// <param name="param"></param>
        ///// <returns></returns>
        //private Expression<Func<AccessRecordEntity, bool>> ListFilter(AccessRecordListParam param)
        //{
        //    var expression = LinqExtensions.True<AccessRecordEntity>();
        //    expression = expression.And(t => t.BaseIsDelete == (int)IsDeleteEnum.No);
        //    if (param != null)
        //    {
        //    }
        //    return expression;
        //}
        #endregion
    }
}