#region

using System;
using System.Data;
using System.Data.Common;
using CSFrameworkV5.Core;
using CSFrameworkV5.Core.CodeGenerator;
using CSFrameworkV5.Models;

#endregion

/*===================================================================
 *   程序说明: Reports的数据访问层源码
 *   作者资料: 孙中吕
 *   创建日期: 2020-10-13 02:36:58
 *   最后修改: 2020-10-13 02:36:58
 *
 *   注: 本文件由代码生成器(Code Generator)自动生成。
 *   (此源码文件请放置在 YourProject.DataAccess 模块)
 *   版权所有 Copyright 2006~2020, C/S框架网(www.cscode.net)
 *===================================================================*/

namespace CSFrameworkV5.DataAccess
{
    /// <summary>
    ///     DAL数据层:dalReports
    /// </summary>
    [DefaultORM_UpdateMode(typeof(sys_Reports), true)]
    public class dalReports : dalBaseDataDict
    {
        /// <summary>
        ///     构造器
        /// </summary>
        /// <param name="loginer">当前登录用户</param>
        public dalReports(Loginer loginer) : base(loginer)
        {
            _KeyName = sys_Reports.__KeyName; //主键字段
            _TableName = sys_Reports.__TableName; //表名
            _ModelType = typeof(sys_Reports); //指定ORM模型
            _UpdateSummaryKeyMode = UpdateKeyMode.OnlyDocumentNo;
            _Database = DatabaseProvider.SystemDatabase;
        }

        /// <summary>
        ///     根据表名获取该表的SQL命令生成器
        /// </summary>
        /// <param name="tableName">表名</param>
        /// <returns></returns>
        protected override IGenerateSqlCommand CreateSqlGenerator(
            DataTable table)
        {
            Type ORM = null;
            if (table.TableName == sys_Reports.__TableName)
                ORM = typeof(sys_Reports); //指定表与ORM模型的对应关系

            if (ORM == null) throw new Exception(table.TableName + "表没有ORM模型！");

            return new GenerateSqlCmdByTableFields(ORM, table,
                GeneratorFactory);
        }

        protected override string GetNumber(DbTransaction tran)
        {
            var SN =
                DocNoTool.GetDataSN(_Database, tran, "PT", true,
                    6); //注意修改流水号字头!
            return SN;
        }

        public byte[] GetReportData(string reportID)
        {
            var sql =
                $"SELECT Data FROM sys_Reports WHERE ReportID={_Database.ParamSymboName}ReportID";
            var cmd = _Database.CreateCommand(sql);
            cmd.AddParam("ReportID", reportID);
            return (byte[])_Database.ExecuteScalar(cmd.Command);
        }

        public DataTable Query(string ReportID, string ReportTitle)
        {
            var cmd = _Database.CreateSqlProc("usp_QueryReport");
            cmd.AddParam("ReportID", ReportID);
            cmd.AddParam("ReportTitle", ReportTitle);
            return _Database.GetTable(cmd.Command, sys_Reports.__TableName);
        }
    } //public class
} //namespace