123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254 |
- using MOKA_Factory_Tools.Database;
- using MOKA_Factory_Tools.Models;
- using System;
- using System.Collections.Generic;
- using System.Data;
- using System.Linq;
- using System.Text;
- using System.Threading.Tasks;
- namespace MOKA_Factory_Tools.DAL
- {
- public class DAL_AMResult : BaseDAL
- {
- public DAL_AMResult()
- {
- this.TableFieldNameString = "";
- }
- #region 属性和字段
- string _tableName = "AMResult";
- /// <summary>
- /// 获取数据表名
- /// </summary>
- public override string TableName
- {
- get { return _tableName; }
- set { this._tableName = value; }
- }
- /// <summary>
- /// 获取当前新的数据表模型对象
- /// </summary>
- public override object ObjModel
- {
- get
- {
- return this.CurrentModel;
- }
- }
- /// <summary>
- /// 获取当前新的MOdel
- /// </summary>
- public AMResult CurrentModel
- {
- get { return new AMResult(); }
- }
- string _tableFieldNameString = "";
- /// <summary>
- /// 数据表字段名数组
- /// </summary>
- public override string TableFieldNameString
- {
- get { return this._tableFieldNameString; }
- set { this._tableFieldNameString = value; }
- }
- #endregion
- #region 检查记录
- //基类已经实现
- #endregion
- #region 增加数据
- /// <summary>
- /// 增加一条数据
- /// </summary>
- /// <param name="model">Model对象</param>
- /// <returns></returns>
- public bool Add(AMResult model)
- {
- return base.Add(model);
- }
- /// <summary>
- /// 增加一条数据
- /// </summary>
- /// <param name="model">Model对象</param>
- /// <param name="overlookFieldList">忽略字段名列表 字段名之间用“,”号分隔</param>
- /// <returns></returns>
- public bool Add(AMResult model, string overlookFieldList = "ID")
- {
- return base.Add(model, overlookFieldList);
- }
- #endregion
- #region 删除数据
- /// <summary>
- /// 删除数据
- /// </summary>
- /// <param name="model"></param>
- /// <returns></returns>
- public bool Delete(AMResult model)
- {
- return base.Delete(string.Format("Station = '{0}' and SN = '{1}' and ReDo = '{2}'", model.Station, model.SN, model.ReDo));
- }
- #endregion
- #region 更新数据
- /// <summary>
- /// 更新一条数据
- /// </summary>
- public bool Update(AMResult model)
- {
- return base.Update(model);
- }
- /// <summary>
- /// 根据筛选字段和SQL筛选运算符号更新数据
- /// </summary>
- /// <param name="model">Model对象</param>
- /// <param name="filterFieldName">筛选字段名称</param>
- /// <param name="operators">SQL筛选运算符号</param>
- /// <param name="overlookFieldList">忽略字段名列表 字段名之间用“,”号分隔</param>
- /// <returns></returns>
- public bool Update(AMResult model, string strWhere, string IgnoreUpdateFields = "Station,SN,ODF,DSN,Line,Model,Dimension")
- {
- return base.UpdateAMResult(model, strWhere, IgnoreUpdateFields);
- }
- #endregion
- #region 查询数据
- /// <summary>
- ///
- /// </summary>
- /// <param name="strWhere"></param>
- /// <returns></returns>
- public AMResult GetModel(string strWhere)
- {
- return DataRowToModel(GetDataRow(strWhere));
- }
- /// <summary>
- /// 得到一个对象实体
- /// </summary>
- public AMResult GetModel(string strStation, string strSN)
- {
- return DataRowToModel(GetDataRow(string.Format("Station = '{0}' and SN = '{1}'", strStation, strSN)));
- }
- public HourlyResultData GetHourlyResultData(string Line, string Station, string ODF, DateTime TestDate, int TestHour)
- {
- DataRow row = GetHourlyDataRow(string.Format("Line='{0}' and Station='{1}' and ODF='{2}' and TestDate='{3}' and TestHour='{4}'", Line, Station, ODF, TestDate, TestHour));
- if ( row != null )
- {
- HourlyResultData model = new HourlyResultData();
- model.TotalCount = row["Total"].ToString();
- model.RealTotalCount = row["RealTotal"].ToString();
- model.OncePassCount = row["OncePass"].ToString();
- model.OnceFailCount = row["OnceFail"].ToString();
- model.NTFCount = row["NTF"].ToString();
- model.TwiceFailCount = row["TwiceFail"].ToString();
- model.FinalFailCount = row["FinalFail"].ToString();
- model.FinalPassCount = row["FinalPass"].ToString();
- model.RealFailCount = row["RealFail"].ToString();
- model.RealPassCount = row["RealPass"].ToString();
- model.NTFSN = row["NTFSN"].ToString();
- model.FailDSN = row["FailDSN"].ToString();
- return model;
- }
- return null;
- }
- public DataRow GetHourlyDataRow(string whereString)
- {
- if (whereString.Trim().Length > 0)
- {
- StringBuilder strSql = new StringBuilder();
- strSql.Append("select ");
- strSql.Append("count(1) as 'Total',");
- strSql.Append("count(case when ReDo = '0' then 1 else null end) as 'RealTotal',");
- strSql.Append("count(case when ResultType = 'OncePass' then 1 else null end) as 'OncePass',");
- strSql.Append("count(case when ResultType = 'OnceFail' then 1 else null end) as 'OnceFail',");
- strSql.Append("count(case when ResultType = 'NTF' then 1 else null end) as 'NTF',");
- strSql.Append("count(case when ResultType = 'TwiceFail' then 1 else null end) as 'TwiceFail',");
- strSql.Append("count(case when ResultType = 'FinalFail' then 1 else null end) as 'FinalFail',");
- strSql.Append("count(case when ResultType = 'FinalPass' then 1 else null end) as 'FinalPass',");
- strSql.Append("count(case when FinalTest = 'PASS' and ReDo = '0' then 1 else null end) as 'RealPass',");
- strSql.Append("count(case when FinalTest = 'FAIL' and ReDo = '0' then 1 else null end) as 'RealFail',");
- strSql.Append(string.Format("stuff((select ',' + SN from {0} where {1} and ResultType='NTF' for XML PATH('')),1,1,'') as 'NTFSN',", this.TableName, whereString));
- strSql.Append(string.Format("stuff((select ',' + DSN from {0} where {1} and FinalTest='FAIL' for XML PATH('')),1,1,'') as 'FailDSN' ", this.TableName, whereString));
- strSql.Append("from " + this.TableName);
- strSql.Append(" where " + whereString);
- DataSet ds = DbHelper.Query(cps.ConnectionString, strSql.ToString());
- if (ds.Tables[0].Rows.Count > 0)
- {
- return ds.Tables[0].Rows[0];
- }
- }
- return null;
- }
- /// <summary>
- /// 得到一个对象实体
- /// </summary>
- /// <param name="row"></param>
- /// <returns></returns>
- public AMResult DataRowToModel(DataRow row)
- {
- return DataRowToModelObject(row) as AMResult;
- }
- /// <summary>
- /// 获得数据Model列表
- /// </summary>
- /// <param name="strWhere">条件 不包含 where 关键字</param>
- public List<AMResult> GetModelList(string strWhere)
- {
- DataSet ds = base.GetList(strWhere);
- return DataTableToList(ds.Tables[0]);
- }
- /// <summary>
- ///
- /// </summary>
- /// <param name="strLine"></param>
- /// <param name="strStation"></param>
- /// <param name="ODF"></param>
- /// <param name="TestDate"></param>
- /// <param name="TestHour"></param>
- /// <returns></returns>
- public List<AMResult> GetModelList(string strLine, string strStation, string ODF, DateTime TestDate, int TestHour)
- {
- DataSet ds = base.GetList(string.Format("Line = '{0}' and Station = '{1}' and ODF='{2}' and TestDate='{3}' and TestHour='{4}'", strLine, strStation, ODF, TestDate, TestHour));
- return DataTableToList(ds.Tables[0]);
- }
- /// <summary>
- /// 获得数据列表
- /// </summary>
- /// <param name="dt">DataTable</param>
- public List<AMResult> DataTableToList(DataTable dt)
- {
- List<AMResult> modelList = new List<AMResult>();
- List<object> ObjList = base.GetDataTableToOblList(dt);
- foreach (object obj in ObjList)
- {
- modelList.Add((AMResult)obj);
- }
- return modelList;
- }
- #endregion
- }
- }
|