You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.

385 lines
16 KiB

using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using Module.DB.Model;
using Module.DB.DBUtility;
namespace Module.DB.SQLServerDAL
{
/// <summary>
/// 热板2配方数据表操作类
/// </summary>
public class SRPHp2Info
{
/// <summary>
/// 添加热板2配方信息
/// </summary>
/// <param name="hp2RecipeInfo"></param>
/// <returns></returns>
public bool AddRPHp2Info(MRPHp2Info hp2RecipeInfo)
{
try
{
bool bRes = false;
#region 数据更新操作字符串
string strResult = SQLHelper.GetInsertSQL<MRPHp2Info>("t_rp_hp2_info", hp2RecipeInfo, "f_id");
SQLServerHelper sHelper = new SQLServerHelper();
int iRes = sHelper.ExecuteNonQuerySQL(strResult);
#endregion 数据更新操作字符串
if (iRes != 0)
{
bRes = true;
}
return bRes;
}
catch (Exception ex)
{
ex.ToString();
return false;
}
}
/// <summary>
/// 编辑热板1配方信息
/// </summary>
/// <param name="hp2RecipeInfo"></param>
/// <returns></returns>
public bool EditRPHp2Info(MRPHp2Info hp2RecipeInfo)
{
try
{
bool bRes = false;
#region 数据更新操作字符串
string strSql = "UPDATE t_rp_hp2_info SET ";
strSql += " " + "f_hp2_plc_no='" + hp2RecipeInfo.f_hp2_plc_no + "',";
strSql += " " + "f_hp2_temp='" + hp2RecipeInfo.f_hp2_temp + "',";
strSql += " " + "f_hp2_interval='" + hp2RecipeInfo.f_hp2_interval + "',";
strSql += " " + "f_hp2_time_num='" + hp2RecipeInfo.f_hp2_time_num + "',";
strSql += " " + "f_hp2_n2='" + hp2RecipeInfo.f_hp2_n2 + "',";
strSql += " " + "f_hp2_n2_time='" + hp2RecipeInfo.f_hp2_n2_time + "',";
strSql += " " + "f_modify_time='" + hp2RecipeInfo.f_modify_time + "'";
strSql += " " + "WHERE f_id='" + hp2RecipeInfo.f_id + "'";
SQLServerHelper sHelper = new SQLServerHelper();
int iRes = sHelper.ExecuteNonQuerySQL(strSql);
#endregion 数据更新操作字符串
if (iRes != 0)
{
bRes = true;
}
return bRes;
}
catch (Exception ex)
{
ex.ToString();
return false;
}
}
/// <summary>
/// 删除热板2配方信息
/// </summary>
/// <param name="hp2RepNo">热板2配方号</param>
public void DeleteRPHp2Info(string hp2RepNo, int trackNo)
{
try
{
string strSql = "";
strSql += "DELETE FROM t_rp_hp2_info" + " ";
strSql += "WHERE f_hp2_rep_no collate Chinese_PRC_CS_AS_WS ='" + hp2RepNo + "'" + " ";
strSql += "AND f_track_no ='" + trackNo + "'" + " ";
SQLServerHelper sHelper = new SQLServerHelper();
sHelper.ExecuteNonQuerySQL(strSql);
}
catch (Exception ex)
{
ex.ToString();
}
}
/// <summary>
/// 根据热板1配方号查找的热板1配方信息
/// </summary>
/// <param name="hp2PlcNo">热板1下发配方号</param>
/// <returns>热板1配方信息</returns>
public List<MRPHp2Info> GetRPHp2Info(string hp2PlcNo)
{
List<MRPHp2Info> lstRpHp2Info = null;
try
{
string strSql = "";
strSql += "SELECT * FROM t_rp_hp2_info" + " ";
strSql += "WHERE f_hp2_plc_no ='" + hp2PlcNo + "'" + " ";
strSql += "ORDER BY f_id ASC";
SQLServerHelper sHelper = new SQLServerHelper();
DataTable dtResult = sHelper.QuerySql(strSql);
int rownum = dtResult.Rows.Count;
if (rownum > 0)
{
lstRpHp2Info = new List<MRPHp2Info>();
for (int i = 0; i < rownum; i++)
{
MRPHp2Info rpHp2Info = new MRPHp2Info();
object objID = dtResult.Rows[i]["f_id"];
rpHp2Info.f_id = (objID == null || objID.ToString().Trim() == "") ? 0 : Convert.ToInt32(objID);
rpHp2Info.f_hp2_rep_no = dtResult.Rows[i]["f_hp2_rep_no"] == null ? "" : dtResult.Rows[i]["f_hp2_rep_no"].ToString().Trim();
object objHp2PlcNo = dtResult.Rows[i]["f_hp2_plc_no"];
rpHp2Info.f_hp2_plc_no = (objHp2PlcNo == null || objHp2PlcNo.ToString().Trim() == "") ? 0 : Convert.ToInt32(objHp2PlcNo);
object objTrackNo = dtResult.Rows[0]["f_track_no"];
rpHp2Info.f_track_no = (objTrackNo == null || objTrackNo.ToString().Trim() == "") ? 0 : Convert.ToInt32(objTrackNo);
object objHp2Temp = dtResult.Rows[i]["f_hp2_temp"];
rpHp2Info.f_hp2_temp = (objHp2Temp == null || objHp2Temp.ToString().Trim() == "") ? 0 : Convert.ToDecimal(objHp2Temp);
object objHp2SeqNo = dtResult.Rows[i]["f_hp2_seq_no"];
rpHp2Info.f_hp2_seq_no = (objHp2SeqNo == null || objHp2SeqNo.ToString().Trim() == "") ? 0 : Convert.ToInt32(objHp2SeqNo);
object objHp2Interval = dtResult.Rows[i]["f_hp2_interval"];
rpHp2Info.f_hp2_interval = (objHp2Interval == null || objHp2Interval.ToString().Trim() == "") ? 0 : Convert.ToInt32(objHp2Interval);
object objHp2TimeNum = dtResult.Rows[i]["f_hp2_time_num"];
rpHp2Info.f_hp2_time_num = (objHp2TimeNum == null || objHp2TimeNum.ToString().Trim() == "") ? 0 : Convert.ToInt32(objHp2TimeNum);
object objHp2N2 = dtResult.Rows[i]["f_hp2_n2"];
rpHp2Info.f_hp2_n2 = (objHp2N2 == null || objHp2N2.ToString().Trim() == "") ? 0 : Convert.ToInt32(objHp2N2);
object objHp2N2Time = dtResult.Rows[i]["f_hp2_n2_time"];
rpHp2Info.f_hp2_n2_time = (objHp2N2 == null || objHp2N2.ToString().Trim() == "") ? 0 : Convert.ToDecimal(objHp2N2Time);
rpHp2Info.f_creator = dtResult.Rows[i]["f_creator"].ToString();
object objCreationDate = dtResult.Rows[i]["f_create_time"];
rpHp2Info.f_create_time = (objCreationDate == null || objCreationDate.ToString() == "") ? Convert.ToDateTime("1800-1-1") : Convert.ToDateTime(objCreationDate);
object objModifyDate = dtResult.Rows[i]["f_modify_time"];
rpHp2Info.f_modify_time = (objModifyDate == null || objModifyDate.ToString() == "") ? Convert.ToDateTime("1800-1-1") : Convert.ToDateTime(objModifyDate);
lstRpHp2Info.Add(rpHp2Info);
}
}
}
catch (Exception ex)
{
ex.ToString();
}
return lstRpHp2Info;
}
public List<MRPHp2Info> GetRPHp2InfoByRepNo(string hp2RepNo, int trackNo)
{
List<MRPHp2Info> lstRpHp2Info = null;
try
{
string strSql = "";
strSql += "SELECT * FROM t_rp_hp2_info" + " ";
strSql += "WHERE f_hp2_rep_no collate Chinese_PRC_CS_AS ='" + hp2RepNo + "'" + " ";
strSql += "AND f_track_no ='" + trackNo + "'" + " ";
strSql += "ORDER BY f_id ASC";
SQLServerHelper sHelper = new SQLServerHelper();
DataTable dtResult = sHelper.QuerySql(strSql);
int rownum = dtResult.Rows.Count;
if (rownum > 0)
{
lstRpHp2Info = new List<MRPHp2Info>();
for (int i = 0; i < rownum; i++)
{
MRPHp2Info rpHp2Info = new MRPHp2Info();
object objID = dtResult.Rows[i]["f_id"];
rpHp2Info.f_id = (objID == null || objID.ToString().Trim() == "") ? 0 : Convert.ToInt32(objID);
rpHp2Info.f_hp2_rep_no = dtResult.Rows[i]["f_hp2_rep_no"] == null ? "" : dtResult.Rows[i]["f_hp2_rep_no"].ToString().Trim();
object objTrackNo = dtResult.Rows[0]["f_track_no"];
rpHp2Info.f_track_no = (objTrackNo == null || objTrackNo.ToString().Trim() == "") ? 0 : Convert.ToInt32(objTrackNo);
object objHp2PlcNo = dtResult.Rows[i]["f_hp2_plc_no"];
rpHp2Info.f_hp2_plc_no = (objHp2PlcNo == null || objHp2PlcNo.ToString().Trim() == "") ? 0 : Convert.ToInt32(objHp2PlcNo);
object objHp2Temp = dtResult.Rows[i]["f_hp2_temp"];
rpHp2Info.f_hp2_temp = (objHp2Temp == null || objHp2Temp.ToString().Trim() == "") ? 0 : Convert.ToDecimal(objHp2Temp);
object objHp2SeqNo = dtResult.Rows[i]["f_hp2_seq_no"];
rpHp2Info.f_hp2_seq_no = (objHp2SeqNo == null || objHp2SeqNo.ToString().Trim() == "") ? 0 : Convert.ToInt32(objHp2SeqNo);
object objHp2Interval = dtResult.Rows[i]["f_hp2_interval"];
rpHp2Info.f_hp2_interval = (objHp2Interval == null || objHp2Interval.ToString().Trim() == "") ? 0 : Convert.ToDecimal(objHp2Interval);
object objHp2TimeNum = dtResult.Rows[i]["f_hp2_time_num"];
rpHp2Info.f_hp2_time_num = (objHp2TimeNum == null || objHp2TimeNum.ToString().Trim() == "") ? 0 : Convert.ToDecimal(objHp2TimeNum);
object objHp2N2 = dtResult.Rows[i]["f_hp2_n2"];
rpHp2Info.f_hp2_n2 = (objHp2N2 == null || objHp2N2.ToString().Trim() == "") ? 0 : Convert.ToInt32(objHp2N2);
object objHp2N2Time = dtResult.Rows[i]["f_hp2_n2_time"];
rpHp2Info.f_hp2_n2_time = (objHp2N2 == null || objHp2N2.ToString().Trim() == "") ? 0 : Convert.ToDecimal(objHp2N2Time);
rpHp2Info.f_creator = dtResult.Rows[i]["f_creator"].ToString();
object objCreationDate = dtResult.Rows[i]["f_create_time"];
rpHp2Info.f_create_time = (objCreationDate == null || objCreationDate.ToString() == "") ? Convert.ToDateTime("1800-1-1") : Convert.ToDateTime(objCreationDate);
object objModifyDate = dtResult.Rows[i]["f_modify_time"];
rpHp2Info.f_modify_time = (objModifyDate == null || objModifyDate.ToString() == "") ? Convert.ToDateTime("1800-1-1") : Convert.ToDateTime(objModifyDate);
lstRpHp2Info.Add(rpHp2Info);
}
}
}
catch (Exception ex)
{
ex.ToString();
}
return lstRpHp2Info;
}
/// <summary>
/// 判断数据表是否存在该下发的PLC配方号
/// </summary>
/// <param name="hp2PlcNo">热板1下发配方号</param>
/// <returns>是否存在该下发的PLC配方号</returns>
public bool ExistHp2PlcNo(string hp2PlcNo)
{
try
{
bool bRes = false;
#region 数据查询是否存在
string strSql = "SELECT * FROM t_rp_hp2_info ";
strSql += " " + "WHERE f_hp2_plc_no='" + hp2PlcNo + "'";
SQLServerHelper sHelper = new SQLServerHelper();
DataTable dtResult = sHelper.QuerySql(strSql);
int rownum = dtResult.Rows.Count;
if (rownum > 0)
{
bRes = true;
}
#endregion 数据查询是否存在
return bRes;
}
catch (Exception ex)
{
ex.ToString();
return false;
}
}
public bool ExistHp2RepNo(string hp2RepNo, int trackNo)
{
try
{
bool bRes = false;
#region 数据查询是否存在
string strSql = "SELECT * FROM t_rp_hp2_info ";
strSql += " " + "WHERE f_hp2_rep_no collate Chinese_PRC_CS_AS ='" + hp2RepNo + "'";
strSql += " " + "AND f_track_no ='" + trackNo + "'" + " ";
SQLServerHelper sHelper = new SQLServerHelper();
DataTable dtResult = sHelper.QuerySql(strSql);
int rownum = dtResult.Rows.Count;
if (rownum > 0)
{
bRes = true;
}
#endregion 数据查询是否存在
return bRes;
}
catch (Exception ex)
{
ex.ToString();
return false;
}
}
/// <summary>
/// 获取所有的配方号
/// </summary>
/// <returns></returns>
public List<string> GetAllRecpieRepNo(int trackNo)
{
var list = new List<string>() { "请选择" };
string strSql = "SELECT distinct(f_hp2_rep_no collate Chinese_PRC_CS_AS_WS) FROM t_rp_hp2_info";
strSql += " " + "WHERE f_track_no ='" + trackNo + "'" + " ";
strSql += " " + "ORDER BY f_hp2_rep_no collate Chinese_PRC_CS_AS_WS ASC";
SQLServerHelper sHelper = new SQLServerHelper();
var dataset = sHelper.QuerySqlDataset(strSql);
if (dataset.Tables.Count == 0 || dataset.Tables[0].Rows.Count == 0)
{
return list;
}
for (int i = 0; i < dataset.Tables[0].Rows.Count; i++)
{
list.Add(dataset.Tables[0].Rows[i][0].ToString());
}
return list;
}
public List<Hp2InfoModel> GetList()
{
try
{
var list = new List<Hp2InfoModel>();
string strSql = "SELECT * FROM t_rp_hp2_info ORDER BY f_id ASC ";
SQLServerHelper sHelper = new SQLServerHelper();
DataTable dtResult = sHelper.QuerySql(strSql);
int rownum = dtResult.Rows.Count;
if (rownum > 0)
{
for (var i = 0; i < rownum; i++)
{
var hp2Info = new Hp2InfoModel();
var temp = dtResult.Rows[i];
hp2Info.f_hp2_rep_no = temp["f_hp2_rep_no"].ToString();
hp2Info.f_hp2_temp = Convert.ToDecimal(temp["f_hp2_temp"]);
hp2Info.f_hp2_n2_time = Convert.ToDecimal(temp["f_hp2_n2_time"]);
hp2Info.f_hp2_n2 = Convert.ToInt32(temp["f_hp2_n2"]);
hp2Info.f_hp2_seq_no = Convert.ToInt32(temp["f_hp2_seq_no"]);
hp2Info.f_hp2_interval = Convert.ToDecimal(temp["f_hp2_interval"]);
hp2Info.f_hp2_time_num = Convert.ToDecimal(temp["f_hp2_time_num"]);
list.Add(hp2Info);
}
}
return list;
}
catch (Exception ex)
{
ex.ToString();
return new List<Hp2InfoModel>();
}
}
}
}