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.

407 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>
/// 胶臂配方数据表操作类
/// </summary>
public class SRPArmInfo
{
/// <summary>
/// 添加胶臂配方信息
/// </summary>
/// <param name="armRecipeInfo"></param>
/// <returns></returns>
public bool AddRPArmInfo(MRPArmInfo armRecipeInfo)
{
try
{
bool bRes = false;
#region 数据更新操作字符串
string strResult = SQLHelper.GetInsertSQL<MRPArmInfo>("t_rp_arm_info", armRecipeInfo, "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="armRecipeInfo"></param>
/// <returns></returns>
public bool EditRPArmInfo(MRPArmInfo armRecipeInfo)
{
try
{
bool bRes = false;
#region 数据更新操作字符串
string strSql = "UPDATE t_rp_arm_info SET ";
strSql += " " + "f_arm_plc_no='" + armRecipeInfo.f_arm_plc_no + "',";
strSql += " " + "f_loc01='" + armRecipeInfo.f_loc01 + "',";
strSql += " " + "f_loc02='" + armRecipeInfo.f_loc02 + "',";
strSql += " " + "f_speed='" + armRecipeInfo.f_speed + "',";
strSql += " " + "f_inject_glue_num='" + armRecipeInfo.f_inject_glue_num + "',";
strSql += " " + "f_head_press_down='" + armRecipeInfo.f_head_press_down + "',";
strSql += " " + "f_track_no='" + armRecipeInfo.f_track_no + "',";
strSql += " " + "f_coating='" + armRecipeInfo.f_coating + "',";
strSql += " " + "f_modify_time='" + armRecipeInfo.f_modify_time + "'";
strSql += " " + "WHERE f_id='" + armRecipeInfo.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="armRepNo">胶臂配方号</param>
public void DeleteRPArmInfo(string armRepNo, int trackNo)
{
try
{
string strSql = "";
strSql += "DELETE FROM t_rp_arm_info" + " ";
strSql += "WHERE f_arm_rep_no ='" + armRepNo + "'" + " ";
strSql += "AND f_track_no ='" + trackNo + "'";
SQLServerHelper sHelper = new SQLServerHelper();
sHelper.ExecuteNonQuerySQL(strSql);
}
catch (Exception ex)
{
ex.ToString();
}
}
/// <summary>
/// 根据胶臂配方号查找的胶臂配方信息
/// </summary>
/// <param name="armRepNo">胶臂配方号</param>
/// <returns>胶臂配方信息</returns>
public MRPArmInfo GetRPArmInfo(string armRepNo, int trackNo)
{
MRPArmInfo rpArmInfo = null;
try
{
string strSql = "";
strSql += "SELECT * FROM t_rp_arm_info" + " ";
strSql += "WHERE f_arm_rep_no collate Chinese_PRC_CS_AS ='" + armRepNo + "'" + " ";
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)
{
rpArmInfo = new MRPArmInfo();
object objID = dtResult.Rows[0]["f_id"];
rpArmInfo.f_id = (objID == null || objID.ToString().Trim() == "") ? 0 : Convert.ToInt32(objID);
rpArmInfo.f_arm_rep_no = dtResult.Rows[0]["f_arm_rep_no"] == null ? "" : dtResult.Rows[0]["f_arm_rep_no"].ToString().Trim();
object objArmPlcNo = dtResult.Rows[0]["f_arm_plc_no"];
rpArmInfo.f_arm_plc_no = (objArmPlcNo == null || objArmPlcNo.ToString().Trim() == "") ? 0 : Convert.ToInt32(objArmPlcNo);
object objTrackNo = dtResult.Rows[0]["f_track_no"];
rpArmInfo.f_track_no = (objTrackNo == null || objTrackNo.ToString().Trim() == "") ? 0 : Convert.ToInt32(objTrackNo);
object objLoc01 = dtResult.Rows[0]["f_loc01"];
rpArmInfo.f_loc01 = (objLoc01 == null || objLoc01.ToString().Trim() == "") ? 0 : Convert.ToDecimal(objLoc01);
object objLoc02 = dtResult.Rows[0]["f_loc02"];
rpArmInfo.f_loc02 = (objLoc02 == null || objLoc02.ToString().Trim() == "") ? 0 : Convert.ToDecimal(objLoc02);
object objSpeed = dtResult.Rows[0]["f_speed"];
rpArmInfo.f_speed = (objSpeed == null || objSpeed.ToString().Trim() == "") ? 0 : Convert.ToDecimal(objSpeed);
object objInjectGlueNum = dtResult.Rows[0]["f_inject_glue_num"];
rpArmInfo.f_inject_glue_num = (objInjectGlueNum == null || objInjectGlueNum.ToString().Trim() == "") ? 0 : Convert.ToInt32(objInjectGlueNum);
object objHeadPressDown = dtResult.Rows[0]["f_head_press_down"];
rpArmInfo.f_head_press_down = (objHeadPressDown == null || objHeadPressDown.ToString().Trim() == "") ? 0 : Convert.ToInt32(objHeadPressDown);
object objCoating = dtResult.Rows[0]["f_coating"];
rpArmInfo.f_coating = (objCoating == null || objCoating.ToString().Trim() == "") ? Convert.ToByte(0) : Convert.ToByte(objCoating);
rpArmInfo.f_creator = dtResult.Rows[0]["f_creator"].ToString();
object objCreationDate = dtResult.Rows[0]["f_create_time"];
rpArmInfo.f_create_time = (objCreationDate == null || objCreationDate.ToString() == "") ? Convert.ToDateTime("1800-1-1") : Convert.ToDateTime(objCreationDate);
object objModifyDate = dtResult.Rows[0]["f_modify_time"];
rpArmInfo.f_modify_time = (objModifyDate == null || objModifyDate.ToString() == "") ? Convert.ToDateTime("1800-1-1") : Convert.ToDateTime(objModifyDate);
}
}
catch (Exception ex)
{
ex.ToString();
}
return rpArmInfo;
}
public MRPArmInfo GetRPArmInfoByRepNo(string armRepNo, int trackNo)
{
MRPArmInfo rpArmInfo = null;
try
{
string strSql = "";
strSql += "SELECT * FROM t_rp_arm_info" + " ";
strSql += "WHERE f_arm_rep_no collate Chinese_PRC_CS_AS ='" + armRepNo + "'" + " ";
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)
{
rpArmInfo = new MRPArmInfo();
object objID = dtResult.Rows[0]["f_id"];
rpArmInfo.f_id = (objID == null || objID.ToString().Trim() == "") ? 0 : Convert.ToInt32(objID);
rpArmInfo.f_arm_rep_no = dtResult.Rows[0]["f_arm_rep_no"] == null ? "" : dtResult.Rows[0]["f_arm_rep_no"].ToString().Trim();
object objArmPlcNo = dtResult.Rows[0]["f_arm_plc_no"];
rpArmInfo.f_arm_plc_no = (objArmPlcNo == null || objArmPlcNo.ToString().Trim() == "") ? 0 : Convert.ToInt32(objArmPlcNo);
object objTrackNo = dtResult.Rows[0]["f_track_no"];
rpArmInfo.f_track_no = (objTrackNo == null || objTrackNo.ToString().Trim() == "") ? 0 : Convert.ToInt32(objTrackNo);
object objLoc01 = dtResult.Rows[0]["f_loc01"];
rpArmInfo.f_loc01 = (objLoc01 == null || objLoc01.ToString().Trim() == "") ? 0 : Convert.ToDecimal(objLoc01);
object objLoc02 = dtResult.Rows[0]["f_loc02"];
rpArmInfo.f_loc02 = (objLoc02 == null || objLoc02.ToString().Trim() == "") ? 0 : Convert.ToDecimal(objLoc02);
object objSpeed = dtResult.Rows[0]["f_speed"];
rpArmInfo.f_speed = (objSpeed == null || objSpeed.ToString().Trim() == "") ? 0 : Convert.ToDecimal(objSpeed);
object objInjectGlueNum = dtResult.Rows[0]["f_inject_glue_num"];
rpArmInfo.f_inject_glue_num = (objInjectGlueNum == null || objInjectGlueNum.ToString().Trim() == "") ? 0 : Convert.ToInt32(objInjectGlueNum);
object objHeadPressDown = dtResult.Rows[0]["f_head_press_down"];
rpArmInfo.f_head_press_down = (objHeadPressDown == null || objHeadPressDown.ToString().Trim() == "") ? 0 : Convert.ToInt32(objHeadPressDown);
object objCoating = dtResult.Rows[0]["f_coating"];
rpArmInfo.f_coating = (objCoating == null || objCoating.ToString().Trim() == "") ? Convert.ToByte(0) : Convert.ToByte(objCoating);
rpArmInfo.f_creator = dtResult.Rows[0]["f_creator"].ToString();
object objCreationDate = dtResult.Rows[0]["f_create_time"];
rpArmInfo.f_create_time = (objCreationDate == null || objCreationDate.ToString() == "") ? Convert.ToDateTime("1800-1-1") : Convert.ToDateTime(objCreationDate);
object objModifyDate = dtResult.Rows[0]["f_modify_time"];
rpArmInfo.f_modify_time = (objModifyDate == null || objModifyDate.ToString() == "") ? Convert.ToDateTime("1800-1-1") : Convert.ToDateTime(objModifyDate);
}
}
catch (Exception ex)
{
ex.ToString();
}
return rpArmInfo;
}
/// <summary>
/// 判断数据表是否存在该下发的PLC配方号
/// </summary>
/// <param name="armPlcNo">胶臂下发配方号</param>
/// <returns>是否存在该下发的PLC配方号</returns>
public bool ExistArmPlcNo(string armPlcNo, int trackNo)
{
try
{
bool bRes = false;
#region 数据查询是否存在
string strSql = "SELECT * FROM t_rp_arm_info ";
strSql += " " + "WHERE f_arm_plc_no collate Chinese_PRC_CS_AS ='" + armPlcNo + "'";
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;
}
}
public bool ExistArmRepNo(string armRepNo, int trackNo)
{
try
{
bool bRes = false;
#region 数据查询是否存在
string strSql = "SELECT * FROM t_rp_arm_info ";
strSql += " " + "WHERE f_arm_rep_no collate Chinese_PRC_CS_AS ='" + armRepNo + "'";
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_arm_rep_no collate Chinese_PRC_CS_AS_WS) FROM t_rp_arm_info ";
strSql += "WHERE f_track_no ='" + trackNo + "' ";
strSql += "ORDER BY f_arm_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 DataTable GetAllRecpieNo(int trackNo)
{
DataTable dtResult = null;
try
{
string strSql = "";
strSql += "SELECT distinct(f_arm_rep_no collate Chinese_PRC_CS_AS_WS) AS f_arm_rep_no FROM t_rp_arm_info ";
strSql += "WHERE f_track_no ='" + trackNo + "'";
strSql += "ORDER BY f_arm_rep_no collate Chinese_PRC_CS_AS_WS ASC";
SQLServerHelper sHelper = new SQLServerHelper();
dtResult = sHelper.QuerySql(strSql);
DataRow inserDataRow = dtResult.NewRow();
inserDataRow["f_arm_rep_no"] = "None";
dtResult.Rows.InsertAt(inserDataRow, 0);
}
catch (Exception ex)
{
ex.ToString();
}
return dtResult;
}
public List<ArmInfoModel> GetList(int trackNo)
{
try
{
var list = new List<ArmInfoModel>();
string strSql = "SELECT * FROM t_rp_arm_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 armInfo = new ArmInfoModel();
var temp = dtResult.Rows[i];
armInfo.f_arm_rep_no = temp["f_arm_rep_no"].ToString();
armInfo.f_loc01 = Convert.ToDecimal(temp["f_loc01"]);
armInfo.f_loc02 = Convert.ToDecimal(temp["f_loc02"]);
armInfo.f_speed = Convert.ToDecimal(temp["f_speed"]);
armInfo.f_inject_glue_num = Convert.ToInt32(temp["f_inject_glue_num"]);
armInfo.f_head_press_down = Convert.ToInt32(temp["f_head_press_down"]);
armInfo.f_coating = Convert.ToInt32(temp["f_coating"]);
list.Add(armInfo);
}
}
return list;
}
catch (Exception ex)
{
ex.ToString();
return new List<ArmInfoModel>();
}
}
}
}