using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using QMAPP.DAL;
using QMAPP.FJC.Entity.InterfaceData;
using QMFrameWork.Data;

namespace QMAPP.FJC.DAL.InterfaceData
{
    public class LeakInspectRecordDAL:BaseDAL
    {
        #region 插入信息
        /// <summary>
        /// 插入信息(单表)
        /// </summary>
        /// <param name="">信息</param>
        /// <returns>插入行数</returns>
        public int Insert(LeakInspectRecord model)
        {
            int count = 0;
            try
            {
                if (this.BaseSession != null)
                {
                    count = BaseSession.Insert<LeakInspectRecord>(model);
                }
                else
                {
                    using (IDataSession session = AppDataFactory.CreateMainSession())
                    {
                        //插入基本信息
                        count = session.Insert<LeakInspectRecord>(model);
                    }
                }

                return count;
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }
        #endregion


        public LeakInspectRecord GetLastRecord(string productcode)
        {
            List<DataParameter> parameters = new List<DataParameter>();
            try
            {
                StringBuilder sql = new StringBuilder();
                sql.AppendLine("SELECT TOP 1 * ");
                sql.AppendLine("  FROM T_ID_LEAKINSPECT_RECORD ");
                sql.AppendLine(" WHERE PRODUCTCODE=@productcode ");
                sql.AppendLine(" ORDER BY CREATEDATE DESC ");
                parameters.Add(new DataParameter("productcode", productcode));

                using (IDataSession session = AppDataFactory.CreateMainSession())
                {
                    return session.Get<LeakInspectRecord>(sql.ToString(), parameters.ToArray());
                }
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }
    }
}