📄 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>
/// 实现对 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 + -