BaoKai_202508-Wms-Jingwang..../WMS.Model/SystemManage/SCData/ProcessPlanData.cs

166 lines
7.0 KiB
C#
Raw Permalink Normal View History

2025-08-24 09:35:55 +08:00
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Data;
using WMS.DBUtility;
using WMS.IData.ICK;
using WMS.IData;using System.Data.SqlClient;
using WMS.Model.CK;
using WMS.Model.SC;
using WMS.IData.ISC;
namespace WMS.SqlServerData.SCData
{
/// <summary>
/// 数据访问类@_PROCESS_PLAN
/// </summary>
public partial class ProcessPlanData : IProcessPlan
{
#region BasicMethod
/// <summary>
/// 增加一条数据
/// </summary>
public void Add(ProcessPlanModel model)
{
StringBuilder strSql = new StringBuilder();
strSql.Append("insert into T_SC_PROCESS_PLAN(");
strSql.Append("PLAN_ID,PLAN_NAME,PLAN_USERID,PLAN_DESCRIPTION,PLAN_STARTDATE,PLAN_CREATETIME,STATUS,STORAGE_ID,PLAN_ENDDATE)");
strSql.Append(" values (");
strSql.Append("@PLAN_ID,@PLAN_NAME,@PLAN_USERID,@PLAN_DESCRIPTION,@PLAN_STARTDATE,@PLAN_CREATETIME,@STATUS,@STORAGE_ID,@PLAN_ENDDATE)");
SqlParameter[] parameters = {
new SqlParameter("@PLAN_ID", SqlDbType.VarChar),
new SqlParameter("@PLAN_NAME", SqlDbType.VarChar),
new SqlParameter("@PLAN_USERID", SqlDbType.VarChar),
new SqlParameter("@PLAN_DESCRIPTION", SqlDbType.VarChar),
new SqlParameter("@PLAN_STARTDATE", SqlDbType.Date),
new SqlParameter("@PLAN_CREATETIME", SqlDbType.Date),
new SqlParameter("@STATUS", SqlDbType.VarChar),
new SqlParameter("@STORAGE_ID", SqlDbType.VarChar),
new SqlParameter("@PLAN_ENDDATE", SqlDbType.Date),};
parameters[0].Value = model.PLAN_ID;
parameters[1].Value = model.PLAN_NAME;
parameters[2].Value = model.PLAN_USERID;
parameters[3].Value = model.PLAN_DESCRIPTION;
parameters[4].Value = model.PLAN_STARTDATE;
parameters[5].Value = model.PLAN_CREATETIME;
parameters[6].Value = model.STATUS;
parameters[7].Value = model.STORAGE_ID;
parameters[8].Value = model.PLAN_ENDDATE;
SystemDataObject.Instance.ExecuteSql(strSql.ToString(), parameters);
}
/// <summary>
/// 更新一条数据
/// </summary>
public void Update(ProcessPlanModel model)
{
StringBuilder strSql = new StringBuilder();
strSql.Append("update T_SC_PROCESS_PLAN set ");
strSql.Append("PLAN_NAME=@PLAN_NAME,");
strSql.Append("PLAN_USERID=@PLAN_USERID,");
strSql.Append("PLAN_DESCRIPTION=@PLAN_DESCRIPTION,");
strSql.Append("PLAN_STARTDATE=@PLAN_STARTDATE,");
strSql.Append("PLAN_CREATETIME=@PLAN_CREATETIME,");
strSql.Append("STATUS=@STATUS,");
strSql.Append("STORAGE_ID=@STORAGE_ID,");
strSql.Append("PLAN_ENDDATE=@PLAN_ENDDATE");
strSql.Append(" where PLAN_ID=@PLAN_ID ");
SqlParameter[] parameters = {
new SqlParameter("@PLAN_NAME", SqlDbType.VarChar),
new SqlParameter("@PLAN_USERID", SqlDbType.VarChar),
new SqlParameter("@PLAN_DESCRIPTION", SqlDbType.VarChar),
new SqlParameter("@PLAN_STARTDATE", SqlDbType.Date),
new SqlParameter("@PLAN_CREATETIME", SqlDbType.Date),
new SqlParameter("@STATUS", SqlDbType.VarChar),
new SqlParameter("@STORAGE_ID", SqlDbType.VarChar),
new SqlParameter("@PLAN_ENDDATE", SqlDbType.Date),
new SqlParameter("@PLAN_ID", SqlDbType.VarChar)};
parameters[0].Value = model.PLAN_NAME;
parameters[1].Value = model.PLAN_USERID;
parameters[2].Value = model.PLAN_DESCRIPTION;
parameters[3].Value = model.PLAN_STARTDATE;
parameters[4].Value = model.PLAN_CREATETIME;
parameters[5].Value = model.STATUS;
parameters[6].Value = model.STORAGE_ID;
parameters[7].Value = model.PLAN_ENDDATE;
parameters[8].Value = model.PLAN_ID;
SystemDataObject.Instance.ExecuteSql(strSql.ToString(), parameters);
}
/// <summary>
/// 删除一条数据
/// </summary>
public void Delete(ProcessPlanModel model)
{
StringBuilder strSql = new StringBuilder();
strSql.Append("delete from T_SC_PROCESS_PLAN ");
strSql.Append(" where PLAN_ID=@PLAN_ID ");
SqlParameter[] parameters = {
new SqlParameter("@PLAN_ID", SqlDbType.VarChar) };
parameters[0].Value = model.PLAN_ID;
SystemDataObject.Instance.ExecuteSql(strSql.ToString(), parameters);
}
/// <summary>
/// 获得数据列表
/// </summary>
public DataTable GetList(ProcessPlanModel model)
{
StringBuilder strSql = new StringBuilder();
strSql.Append("select t.PLAN_ID,");
strSql.Append("t.PLAN_NAME,");
strSql.Append("t.PLAN_USERID,");
strSql.Append("b.NAME PLAN_USERNAME,");
strSql.Append("t.PLAN_DESCRIPTION,");
strSql.Append("t.PLAN_STARTDATE,");
strSql.Append("t.PLAN_CREATETIME,");
strSql.Append("t.PLAN_ENDDATE,");
strSql.Append("t.STATUS,");
strSql.Append("t.STORAGE_ID,");
strSql.Append("a.STORAGE_NAME STORAGE_NAME");
strSql.Append(" FROM T_SC_PROCESS_PLAN t");
strSql.Append(" LEFT JOIN T_BASE_USERINFO b ON b.USER_ID = t.plan_userid");
strSql.Append(" LEFT JOIN T_BASE_STORAGEINFO a ON a.STORAGE_ID = t.STORAGE_ID");
strSql.Append(" where 1=1 ");
if (!string.IsNullOrEmpty(model.PLAN_NAME))
{
strSql.Append(" and t.PLAN_NAME='" + model.PLAN_NAME + "' ");
}
if (!string.IsNullOrEmpty(model.STATUS))
{
strSql.Append(" and t.STATUS='" + model.STATUS + "' ");
}
if (model.DATESTAR != DateTime.MinValue && model.DATEEND != DateTime.MinValue)
{
strSql.Append(" and t.PLAN_CREATETIME between convert(varchar(100),'" + model.DATESTAR.ToString("yyyy-MM-dd") + "',23) and convert(varchar(100),'" + model.DATEEND.ToString("yyyy-MM-dd") + "',23)");
}
if (!string.IsNullOrEmpty(model.Str_goods_ids) && model.Str_goods_ids != "()")
{
strSql.Append(" and t.PLAN_ID in (select PLAN_ID from T_SC_PLANGOODS where GOODS_ID in " + model.Str_goods_ids + ")");
}
return SystemDataObject.Instance.GetDataTable(strSql.ToString());
}
/// <summary>
/// 获取流水号
/// </summary>
/// <returns></returns>
public string GetSerialNum()
{
StringBuilder strSql = new StringBuilder();
strSql.Append("select NEXT VALUE FOR SEQ_SC_PLANGOODS_ID ");
DataSet ds = SystemDataObject.Instance.GetDataSet( strSql.ToString());
return ds.Tables[0].Rows[0][0].ToString();
}
#endregion BasicMethod
}
}