?? kc_cpph.cs
字號:
using System;
using System.Data;
using System.Data.SqlClient;
using System.Collections;
using com.unicafe.common;
namespace Com.Ascs.Plp.CW
{
/// <summary>
/// 對象KC_CPPH的定義
/// 根據表 KC_CPPH
/// </summary>
public class KC_CPPH
{
/// <summary>
/// 對象KC_CPPH的構造函數
/// </summary>
public KC_CPPH()
{
m_rkdh = "";
m_cpph = "";
m_jgdm = "";
}
private string m_rkdh;
private string m_cpph;
private string m_jgdm;
/// <summary>
/// 屬性 rkdh
/// </summary>
public string rkdh
{
get
{
return m_rkdh;
}
set
{
m_rkdh = value;
}
}
/// <summary>
/// 屬性 cpph
/// </summary>
public string cpph
{
get
{
return m_cpph;
}
set
{
m_cpph = value;
}
}
/// <summary>
/// 屬性 jgdm
/// </summary>
public string jgdm
{
get
{
return m_jgdm;
}
set
{
m_jgdm = value;
}
}
}
}
namespace Com.Ascs.Plp.CW
{
/// <summary>
/// 實現(xiàn)對 KC_CPPH對象的管理
/// </summary>
public class KC_CPPHMgr
{
/// <summary>
/// 添加新的KC_CPPH對象
/// </summary>
/// <param name="theKC_CPPH">要添加的KC_CPPH對象</param>
public bool AddKC_CPPH(SqlConnection cn,KC_CPPH theKC_CPPH)
{
try
{
// SqlConnection cn = new SqlConnection (com.unicafe.common.Configuration.GetDBConnectionString());
// cn.Open();
string sql;
sql = "insert into KC_CPPH (rkdh, cpph, jgdm) values (@rkdh, @cpph, @jgdm)";
SqlCommand cmd = new SqlCommand(sql, cn);
cmd.Parameters.Add ("@rkdh", theKC_CPPH.rkdh);
cmd.Parameters.Add ("@cpph", theKC_CPPH.cpph);
cmd.Parameters.Add ("@jgdm", theKC_CPPH.jgdm);
cmd.ExecuteNonQuery();
// cn.Close();
return true;
}
catch(Exception e)
{
LogService.Write ("AddKC_CPPH(KC_CPPH theKC_CPPH)");
LogService.Write (e.Message);
return false;
}
}
/// <summary>
/// 更新KC_CPPH對象
/// </summary>
/// <param name="theKC_CPPH">要更新的KC_CPPH對象</param>
public bool UpdateKC_CPPH(SqlConnection cn,KC_CPPH theKC_CPPH)
{
try
{
// SqlConnection cn = new SqlConnection (com.unicafe.common.Configuration.GetDBConnectionString());
// cn.Open();
string sql;
sql = "update KC_CPPH set cpph=@cpph, jgdm=@jgdm where rkdh=@rkdh";
SqlCommand cmd = new SqlCommand(sql, cn);
cmd.Parameters.Add ("@rkdh", theKC_CPPH.rkdh);
cmd.Parameters.Add ("@cpph", theKC_CPPH.cpph);
cmd.Parameters.Add ("@jgdm", theKC_CPPH.jgdm);
cmd.ExecuteNonQuery();
// cn.Close();
return true;
}
catch(Exception e)
{
LogService.Write ("UpdateKC_CPPH(KC_CPPH theKC_CPPH)");
LogService.Write (e.Message);
return false;
}
}
/// <summary>
/// 刪除KC_CPPH對象
/// </summary>
/// <param name="rkdh">主鍵</param>
public bool DelKC_CPPH(SqlConnection cn,string rkdh)
{
try
{
// SqlConnection cn = new SqlConnection (com.unicafe.common.Configuration.GetDBConnectionString());
// cn.Open();
string sql;
sql = "delete from KC_CPPH where rkdh=@rkdh";
SqlCommand cmd = new SqlCommand(sql, cn);
cmd.Parameters.Add ("@rkdh", rkdh);
cmd.ExecuteNonQuery();
// cn.Close();
return true;
}
catch(Exception e)
{
LogService.Write ("DelKC_CPPH(string rkdh)");
LogService.Write (e.Message);
return false;
}
}
/// <summary>
/// 根據主鍵標識獲得KC_CPPH對象
/// </summary>
/// <param name="rkdh">主鍵</param>
public KC_CPPH GetKC_CPPH(string rkdh)
{
try
{
KC_CPPH result = null;
SqlConnection cn = new SqlConnection (com.unicafe.common.Configuration.GetDBConnectionString());
cn.Open();
string sql;
sql = "select * from KC_CPPH where rkdh=@rkdh";
SqlCommand cmd = new SqlCommand(sql,cn);
cmd.Parameters.Add ("@rkdh", rkdh);
SqlDataReader dr = cmd.ExecuteReader();
if (dr.Read())
{
result = new KC_CPPH();
if (dr["rkdh"] != null)
if (!System.DBNull.Equals(dr["rkdh"], System.DBNull.Value))
result.rkdh = (string)dr["rkdh"];
if (dr["cpph"] != null)
if (!System.DBNull.Equals(dr["cpph"], System.DBNull.Value))
result.cpph = (string)dr["cpph"];
if (dr["jgdm"] != null)
if (!System.DBNull.Equals(dr["jgdm"], System.DBNull.Value))
result.jgdm = (string)dr["jgdm"];
}
dr.Close();
cn.Close();
return result;
}
catch(Exception e)
{
LogService.Write ("GetKC_CPPH(string rkdh)");
LogService.Write (e.Message);
return null;
}
}
/// <summary>
/// 查找KC_CPPH對象
/// </summary>
public ArrayList FindKC_CPPH()
{
try
{
ArrayList result = new ArrayList();
SqlConnection cn = new SqlConnection (com.unicafe.common.Configuration.GetDBConnectionString());
cn.Open();
string sql;
sql = "select * from KC_CPPH";
SqlCommand cmd = new SqlCommand(sql, cn);
SqlDataReader dr = cmd.ExecuteReader();
while (dr.Read())
{
KC_CPPH obj = new KC_CPPH();
if (dr["rkdh"] != null)
if (!System.DBNull.Equals(dr["rkdh"], System.DBNull.Value))
obj.rkdh = (string)dr["rkdh"];
if (dr["cpph"] != null)
if (!System.DBNull.Equals(dr["cpph"], System.DBNull.Value))
obj.cpph = (string)dr["cpph"];
if (dr["jgdm"] != null)
if (!System.DBNull.Equals(dr["jgdm"], System.DBNull.Value))
obj.jgdm = (string)dr["jgdm"];
result.Add(obj);
}
dr.Close();
cn.Close();
return result;
}
catch(Exception e)
{
LogService.Write ("FindKC_CPPH()");
LogService.Write (e.Message);
return null;
}
}
//begin
// <summary>
/// 根據入庫單號查找產品批次。如果有則返回產品批次；如果不存在，則生成產品批次并寫入該表，返回該產品批次
/// </summary>
/// <param name="rkdh">入庫單號</param>
/// <param name="jgdm">機構代碼</param>
/// <returns>產品批次號</returns>
public string GetCPPh(SqlConnection cn,string rkdh,string jgdm)
{
string sCPPH="";
try
{
string sql;
//根據入庫單號取產品批次
sql = "SELECT cpph FROM KC_CPPH where rkdh=@rkdh";
SqlCommand cmd = new SqlCommand(sql, cn);
cmd.Parameters.Add ("@rkdh",rkdh);
SqlDataReader dr = cmd.ExecuteReader();
if (dr.Read())
sCPPH = dr[0].ToString();
dr.Close();
//如果產品批次不存在，則生成新的產品批次，并寫入該表。
if(sCPPH==null || sCPPH=="")
{
string sDateTime = DateTime.Now.Year.ToString();
string sMonth = DateTime.Now.Month>9 ? DateTime.Now.Month.ToString() : "0"+DateTime.Now.Month.ToString();
string sDay = DateTime.Now.Day>9 ? DateTime.Now.Day.ToString() : "0"+DateTime.Now.Day.ToString();
sDateTime = sDateTime+sMonth+sDay; //年月日
sql = "select cpph from kc_cpph where jgdm=@jgdm and cpph like '"+sDateTime+"____' order by cpph desc";
cmd = new SqlCommand(sql, cn);
cmd.Parameters.Add ("@jgdm",jgdm);
dr = cmd.ExecuteReader();
if (dr.Read())
sCPPH = dr[0].ToString();
dr.Close();
//生成新的產品批次
if(sCPPH==null || sCPPH=="")
sCPPH=sDateTime+"0001";
else
sCPPH =(Convert.ToDouble(sCPPH)+1).ToString();
//向表中插入記錄
sql = "insert into KC_CPPH (rkdh, cpph, jgdm) values (@rkdh, @cpph, @jgdm)";
cmd = new SqlCommand(sql, cn);
cmd.Parameters.Add ("@rkdh", rkdh);
cmd.Parameters.Add ("@cpph", sCPPH);
cmd.Parameters.Add ("@jgdm", jgdm);
cmd.ExecuteNonQuery();
}
return sCPPH;
}
catch(Exception e)
{
LogService.Write ("Com.Ascs.Plp.CW.KC_CPPHMgr: GetCPPh(SqlConnection cn,string rkdh,string jgdm)");
LogService.Write (e.Message);
return sCPPH;
}
}
//end
}
}
?? 快捷鍵說明
復制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -