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.
340 lines
12 KiB
340 lines
12 KiB
using System;
|
|
using System.Collections.Generic;
|
|
using System.Linq;
|
|
using System.Text;
|
|
using System.Data;
|
|
using System.Threading.Tasks;
|
|
using Module.DB.Model;
|
|
using Module.DB.DBUtility;
|
|
|
|
namespace Module.DB.SQLServerDAL
|
|
{
|
|
/// <summary>
|
|
/// 冷板配方数据表操作类
|
|
/// </summary>
|
|
public class SRPCpInfo
|
|
{
|
|
/// <summary>
|
|
/// 添加冷板配方信息
|
|
/// </summary>
|
|
/// <param name="cpRecipeInfo"></param>
|
|
/// <returns></returns>
|
|
public bool AddRPCPInfo(MRPCpInfo cpRecipeInfo)
|
|
{
|
|
try
|
|
{
|
|
bool bRes = false;
|
|
|
|
#region 数据更新操作字符串
|
|
|
|
string strResult = SQLHelper.GetInsertSQL<MRPCpInfo>("t_rp_cp_info", cpRecipeInfo, "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>
|
|
/// 编辑冷板配方信息
|
|
/// </summary>
|
|
/// <param name="srcOptLoginInfo"></param>
|
|
/// <returns></returns>
|
|
public bool EditRPCPInfo(MRPCpInfo cpRecipeInfo)
|
|
{
|
|
try
|
|
{
|
|
bool bRes = false;
|
|
|
|
#region 数据更新操作字符串
|
|
|
|
string strSql = "UPDATE t_rp_cp_info SET ";
|
|
strSql += " " + "f_cp_time_num='" + cpRecipeInfo.f_cp_time_num + "',";
|
|
strSql += " " + "f_modify_time='" + cpRecipeInfo.f_modify_time + "'";
|
|
strSql += " " + "WHERE f_id='" + cpRecipeInfo.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>
|
|
/// 删除冷板配方信息
|
|
/// </summary>
|
|
/// <param name="cpRepNo">冷板配方号</param>
|
|
public void DeleteRPCpInfo(string cpRepNo, int trackNo)
|
|
{
|
|
try
|
|
{
|
|
string strSql = "";
|
|
strSql += "DELETE FROM t_rp_cp_info" + " ";
|
|
strSql += "WHERE f_cp_rep_no collate Chinese_PRC_CS_AS_WS ='" + cpRepNo + "'" + " ";
|
|
strSql += "AND f_track_no ='" + trackNo + "'" + " ";
|
|
|
|
SQLServerHelper sHelper = new SQLServerHelper();
|
|
sHelper.ExecuteNonQuerySQL(strSql);
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
ex.ToString();
|
|
}
|
|
}
|
|
|
|
/// <summary>
|
|
/// 根据冷板配方号查找的冷板配方信息
|
|
/// </summary>
|
|
/// <param name="cpPlcNo">冷板下发配方号</param>
|
|
/// <returns>冷板配方信息</returns>
|
|
public MRPCpInfo GetRPCPInfo(string cpPlcNo)
|
|
{
|
|
MRPCpInfo rpCPInfo = null;
|
|
try
|
|
{
|
|
string strSql = "";
|
|
strSql += "SELECT * FROM t_rp_cp_info" + " ";
|
|
strSql += "WHERE f_cp_plc_no ='" + cpPlcNo + "'" + " ";
|
|
strSql += "ORDER BY f_id ASC";
|
|
|
|
SQLServerHelper sHelper = new SQLServerHelper();
|
|
DataTable dtResult = sHelper.QuerySql(strSql);
|
|
int rownum = dtResult.Rows.Count;
|
|
if (rownum > 0)
|
|
{
|
|
rpCPInfo = new MRPCpInfo();
|
|
|
|
object objID = dtResult.Rows[0]["f_id"];
|
|
rpCPInfo.f_id = (objID == null || objID.ToString().Trim() == "") ? 0 : Convert.ToInt32(objID);
|
|
rpCPInfo.f_cp_rep_no = dtResult.Rows[0]["f_cp_rep_no"] == null ? "" : dtResult.Rows[0]["f_cp_rep_no"].ToString().Trim();
|
|
|
|
object objTrackNo = dtResult.Rows[0]["f_track_no"];
|
|
rpCPInfo.f_track_no = (objTrackNo == null || objTrackNo.ToString().Trim() == "") ? 0 : Convert.ToInt32(objTrackNo);
|
|
|
|
object objCPPlcNo = dtResult.Rows[0]["f_cp_plc_no"];
|
|
rpCPInfo.f_cp_plc_no = (objCPPlcNo == null || objCPPlcNo.ToString().Trim() == "") ? 0 : Convert.ToInt32(objCPPlcNo);
|
|
|
|
object objCpTimeNum = dtResult.Rows[0]["f_cp_time_num"];
|
|
rpCPInfo.f_cp_time_num = (objCpTimeNum == null || objCpTimeNum.ToString().Trim() == "") ? 0 : Convert.ToInt32(objCpTimeNum);
|
|
|
|
rpCPInfo.f_creator = dtResult.Rows[0]["f_creator"].ToString();
|
|
object objCreationDate = dtResult.Rows[0]["f_create_time"];
|
|
rpCPInfo.f_create_time = (objCreationDate == null || objCreationDate.ToString() == "") ? Convert.ToDateTime("1800-1-1") : Convert.ToDateTime(objCreationDate);
|
|
|
|
object objModifyDate = dtResult.Rows[0]["f_modify_time"];
|
|
rpCPInfo.f_modify_time = (objModifyDate == null || objModifyDate.ToString() == "") ? Convert.ToDateTime("1800-1-1") : Convert.ToDateTime(objModifyDate);
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
ex.ToString();
|
|
}
|
|
return rpCPInfo;
|
|
}
|
|
|
|
public MRPCpInfo GetRPCPInfoByRepNo(string repNo, int trackNo)
|
|
{
|
|
MRPCpInfo rpCPInfo = null;
|
|
try
|
|
{
|
|
string strSql = "";
|
|
strSql += "SELECT * FROM t_rp_cp_info" + " ";
|
|
strSql += "WHERE f_cp_rep_no collate Chinese_PRC_CS_AS ='" + repNo + "'" + " ";
|
|
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)
|
|
{
|
|
rpCPInfo = new MRPCpInfo();
|
|
|
|
object objID = dtResult.Rows[0]["f_id"];
|
|
rpCPInfo.f_id = (objID == null || objID.ToString().Trim() == "") ? 0 : Convert.ToInt32(objID);
|
|
rpCPInfo.f_cp_rep_no = dtResult.Rows[0]["f_cp_rep_no"] == null ? "" : dtResult.Rows[0]["f_cp_rep_no"].ToString().Trim();
|
|
|
|
object objTrackNo = dtResult.Rows[0]["f_track_no"];
|
|
rpCPInfo.f_track_no = (objTrackNo == null || objTrackNo.ToString().Trim() == "") ? 0 : Convert.ToInt32(objTrackNo);
|
|
|
|
object objCPPlcNo = dtResult.Rows[0]["f_cp_plc_no"];
|
|
rpCPInfo.f_cp_plc_no = (objCPPlcNo == null || objCPPlcNo.ToString().Trim() == "") ? 0 : Convert.ToInt32(objCPPlcNo);
|
|
|
|
object objCpTimeNum = dtResult.Rows[0]["f_cp_time_num"];
|
|
rpCPInfo.f_cp_time_num = (objCpTimeNum == null || objCpTimeNum.ToString().Trim() == "") ? 0 : Convert.ToDecimal(objCpTimeNum);
|
|
|
|
rpCPInfo.f_creator = dtResult.Rows[0]["f_creator"].ToString();
|
|
object objCreationDate = dtResult.Rows[0]["f_create_time"];
|
|
rpCPInfo.f_create_time = (objCreationDate == null || objCreationDate.ToString() == "") ? Convert.ToDateTime("1800-1-1") : Convert.ToDateTime(objCreationDate);
|
|
|
|
object objModifyDate = dtResult.Rows[0]["f_modify_time"];
|
|
rpCPInfo.f_modify_time = (objModifyDate == null || objModifyDate.ToString() == "") ? Convert.ToDateTime("1800-1-1") : Convert.ToDateTime(objModifyDate);
|
|
}
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
ex.ToString();
|
|
}
|
|
return rpCPInfo;
|
|
}
|
|
|
|
/// <summary>
|
|
/// 判断数据表是否存在该下发的PLC配方号
|
|
/// </summary>
|
|
/// <param name="armPlcNo">冷板下发配方号</param>
|
|
/// <returns>是否存在该下发的PLC配方号</returns>
|
|
public bool ExistCPPlcNo(string cpPlcNo)
|
|
{
|
|
try
|
|
{
|
|
bool bRes = false;
|
|
|
|
#region 数据查询是否存在
|
|
|
|
string strSql = "SELECT * FROM t_rp_cp_info ";
|
|
strSql += " " + "WHERE f_cp_plc_no='" + cpPlcNo + "'";
|
|
|
|
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 ExistCPRepNo(string cpRepNo, int trackNo)
|
|
{
|
|
try
|
|
{
|
|
bool bRes = false;
|
|
|
|
#region 数据查询是否存在
|
|
|
|
string strSql = "SELECT * FROM t_rp_cp_info ";
|
|
strSql += " " + "WHERE f_cp_rep_no collate Chinese_PRC_CS_AS ='" + cpRepNo + "'";
|
|
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>
|
|
/// <returns></returns>
|
|
public List<string> GetAllRecpieRepNo(int trackNo)
|
|
{
|
|
var list = new List<string>() { "请选择" };
|
|
string strSql = "SELECT distinct(f_cp_rep_no collate Chinese_PRC_CS_AS_WS) FROM t_rp_cp_info";
|
|
strSql += " " + "WHERE f_track_no ='" + trackNo + "'" + " ";
|
|
strSql += " " + "ORDER BY f_cp_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<CpInfoModel> GetList(int trackNo)
|
|
{
|
|
try
|
|
{
|
|
var list = new List<CpInfoModel>();
|
|
string strSql = "SELECT * FROM t_rp_cp_info";
|
|
strSql += " " + "WHERE 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)
|
|
{
|
|
for (var i = 0; i < rownum; i++)
|
|
{
|
|
var cpInfo = new CpInfoModel();
|
|
var temp = dtResult.Rows[i];
|
|
|
|
cpInfo.f_cp_rep_no = temp["f_cp_rep_no"].ToString();
|
|
cpInfo.f_cp_plc_no = Convert.ToInt32(temp["f_cp_plc_no"]);
|
|
cpInfo.f_cp_time_num = Convert.ToDecimal(temp["f_cp_time_num"]);
|
|
|
|
list.Add(cpInfo);
|
|
}
|
|
}
|
|
|
|
return list;
|
|
}
|
|
catch (Exception ex)
|
|
{
|
|
ex.ToString();
|
|
return new List<CpInfoModel>();
|
|
}
|
|
}
|
|
}
|
|
}
|