178 lines
6.9 KiB
C#
178 lines
6.9 KiB
C#
|
using System;
|
|||
|
|
using System.Data;
|
|||
|
|
using System.Text;
|
|||
|
|
using WMS.Model.Base;
|
|||
|
|
using WMS.IData.ISystemManage;
|
|||
|
|
using WMS.IData;using Oracle.ManagedDataAccess.Client;
|
|||
|
|
using WMS.Common;
|
|||
|
|
using WMS.DBUtility;
|
|||
|
|
using WMS.Model.SystemManage;
|
|||
|
|
using Oracle.ManagedDataAccess.Client;
|
|||
|
|
|
|||
|
|
namespace WMS.SqlServerData.SystemManageData
|
|||
|
|
{
|
|||
|
|
/// <summary>
|
|||
|
|
/// 数据访问类:T_SYS_SCHEDULING
|
|||
|
|
/// </summary>
|
|||
|
|
public partial class SchedulingData : IScheduling
|
|||
|
|
{
|
|||
|
|
#region BasicMethod
|
|||
|
|
/// <summary>
|
|||
|
|
/// 增加一条数据
|
|||
|
|
/// </summary>
|
|||
|
|
public void Add(SchedulingModel model)
|
|||
|
|
{
|
|||
|
|
StringBuilder strSql=new StringBuilder();
|
|||
|
|
strSql.Append("insert into T_SYS_SCHEDULING(");
|
|||
|
|
strSql.Append("S_DATE,S_USER,S_TYPE,S_STORAGE,STATUS,S_KIND,S_STARTIME,S_ENDTIME,ID,REMARK)");
|
|||
|
|
strSql.Append(" values (");
|
|||
|
|
strSql.Append(":S_DATE,:S_USER,:S_TYPE,:S_STORAGE,:STATUS,:S_KIND,:S_STARTIME,:S_ENDTIME,:ID,:REMARK)");
|
|||
|
|
OracleParameter[] parameters = {
|
|||
|
|
new OracleParameter(":S_DATE", OracleDbType.Date),
|
|||
|
|
new OracleParameter(":S_USER",OracleDbType.Varchar2),
|
|||
|
|
new OracleParameter(":S_TYPE",OracleDbType.Varchar2),
|
|||
|
|
new OracleParameter(":S_STORAGE",OracleDbType.Varchar2),
|
|||
|
|
new OracleParameter(":STATUS",OracleDbType.Varchar2),
|
|||
|
|
new OracleParameter(":S_KIND",OracleDbType.Varchar2),
|
|||
|
|
new OracleParameter(":S_STARTIME", OracleDbType.Date),
|
|||
|
|
new OracleParameter(":S_ENDTIME", OracleDbType.Date),
|
|||
|
|
new OracleParameter(":ID",OracleDbType.Varchar2),
|
|||
|
|
new OracleParameter(":ID",OracleDbType.Varchar2)};
|
|||
|
|
parameters[0].Value = model.S_DATE;
|
|||
|
|
parameters[1].Value = model.S_USER;
|
|||
|
|
parameters[2].Value = model.S_TYPE;
|
|||
|
|
parameters[3].Value = model.S_STORAGE;
|
|||
|
|
parameters[4].Value = model.STATUS;
|
|||
|
|
parameters[5].Value = model.S_KIND;
|
|||
|
|
parameters[6].Value = model.S_STARTIME;
|
|||
|
|
parameters[7].Value = model.S_ENDTIME;
|
|||
|
|
parameters[8].Value = model.ID;
|
|||
|
|
parameters[8].Value = model.REMARK;
|
|||
|
|
|
|||
|
|
SystemDataObject.Instance.ExecuteSql(strSql.ToString(), parameters);
|
|||
|
|
}
|
|||
|
|
/// <summary>
|
|||
|
|
/// 更新一条数据
|
|||
|
|
/// </summary>
|
|||
|
|
public void Update(SchedulingModel model)
|
|||
|
|
{
|
|||
|
|
StringBuilder strSql=new StringBuilder();
|
|||
|
|
strSql.Append("update T_SYS_SCHEDULING set ");
|
|||
|
|
strSql.Append("S_DATE=:S_DATE,");
|
|||
|
|
strSql.Append("S_USER=:S_USER,");
|
|||
|
|
strSql.Append("S_TYPE=:S_TYPE,");
|
|||
|
|
strSql.Append("S_STORAGE=:S_STORAGE,");
|
|||
|
|
strSql.Append("STATUS=:STATUS,");
|
|||
|
|
strSql.Append("S_KIND=:S_KIND,");
|
|||
|
|
strSql.Append("S_STARTIME=:S_STARTIME,");
|
|||
|
|
strSql.Append("S_ENDTIME=:S_ENDTIME,");
|
|||
|
|
strSql.Append("REMARK=:REMARK");
|
|||
|
|
strSql.Append(" where ");
|
|||
|
|
strSql.Append("ID=:ID");
|
|||
|
|
OracleParameter[] parameters = {
|
|||
|
|
new OracleParameter(":S_DATE", OracleDbType.Date),
|
|||
|
|
new OracleParameter(":S_USER",OracleDbType.Varchar2),
|
|||
|
|
new OracleParameter(":S_TYPE",OracleDbType.Varchar2),
|
|||
|
|
new OracleParameter(":S_STORAGE",OracleDbType.Varchar2),
|
|||
|
|
new OracleParameter(":STATUS",OracleDbType.Varchar2),
|
|||
|
|
new OracleParameter(":S_KIND",OracleDbType.Varchar2),
|
|||
|
|
new OracleParameter(":S_STARTIME", OracleDbType.Date),
|
|||
|
|
new OracleParameter(":S_ENDTIME", OracleDbType.Date),
|
|||
|
|
new OracleParameter(":REMARK",OracleDbType.Varchar2),
|
|||
|
|
new OracleParameter(":ID",OracleDbType.Varchar2)};
|
|||
|
|
parameters[0].Value = model.S_DATE;
|
|||
|
|
parameters[1].Value = model.S_USER;
|
|||
|
|
parameters[2].Value = model.S_TYPE;
|
|||
|
|
parameters[3].Value = model.S_STORAGE;
|
|||
|
|
parameters[4].Value = model.STATUS;
|
|||
|
|
parameters[5].Value = model.S_KIND;
|
|||
|
|
parameters[6].Value = model.S_STARTIME;
|
|||
|
|
parameters[7].Value = model.S_ENDTIME;
|
|||
|
|
parameters[8].Value = model.REMARK;
|
|||
|
|
parameters[9].Value = model.ID;
|
|||
|
|
|
|||
|
|
SystemDataObject.Instance.ExecuteSql(strSql.ToString(), parameters);
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 删除一条数据
|
|||
|
|
/// </summary>
|
|||
|
|
public void Delete(SchedulingModel model)
|
|||
|
|
{
|
|||
|
|
//该表无主键信息，请自定义主键/条件字段
|
|||
|
|
StringBuilder strSql=new StringBuilder();
|
|||
|
|
strSql.Append("delete from T_SYS_SCHEDULING ");
|
|||
|
|
strSql.Append(" where 1=1 ");
|
|||
|
|
if (!string.IsNullOrEmpty(model.S_USER))
|
|||
|
|
{
|
|||
|
|
strSql.Append(" and t.S_USER ='" + model.S_USER + "'");
|
|||
|
|
}
|
|||
|
|
if (!string.IsNullOrEmpty(model.S_STORAGE))
|
|||
|
|
{
|
|||
|
|
strSql.Append(" and t.S_STORAGE = '" + model.S_STORAGE + "'");
|
|||
|
|
}
|
|||
|
|
OracleParameter[] parameters = {
|
|||
|
|
};
|
|||
|
|
|
|||
|
|
SystemDataObject.Instance.ExecuteSql(strSql.ToString(), parameters);
|
|||
|
|
}
|
|||
|
|
/// <summary>
|
|||
|
|
/// 获得数据列表
|
|||
|
|
/// </summary>
|
|||
|
|
public DataTable GetList(SchedulingModel model)
|
|||
|
|
{
|
|||
|
|
StringBuilder strSql=new StringBuilder();
|
|||
|
|
strSql.Append("select t.S_DATE,");
|
|||
|
|
strSql.Append("t.S_USER,");
|
|||
|
|
strSql.Append("b.NAME as S_USER_NAME,");
|
|||
|
|
strSql.Append("t.S_TYPE,");
|
|||
|
|
strSql.Append("a.WORK_NAME S_TYPE_NAME,");
|
|||
|
|
strSql.Append("t.S_STORAGE,");
|
|||
|
|
strSql.Append("c.STORAGE_NAME S_STORAGE_NAME,");
|
|||
|
|
strSql.Append("t.STATUS,");
|
|||
|
|
strSql.Append("t.S_KIND,");
|
|||
|
|
strSql.Append("t.S_STARTIME,");
|
|||
|
|
strSql.Append("t.S_ENDTIME,");
|
|||
|
|
strSql.Append("t.REMARK,");
|
|||
|
|
strSql.Append("t.ID ");
|
|||
|
|
strSql.Append(" FROM T_SYS_SCHEDULING t");
|
|||
|
|
strSql.Append(" LEFT JOIN T_BASE_USERINFO b ON b.USER_ID = t.S_USER");
|
|||
|
|
strSql.Append(" LEFT JOIN T_BASE_WORKTYPE a ON a.WORK_ID = t.S_TYPE");
|
|||
|
|
strSql.Append(" LEFT JOIN T_BASE_STORAGEINFO c ON c.STORAGE_ID = t.S_STORAGE");
|
|||
|
|
strSql.Append(" where 1=1 ");
|
|||
|
|
if (!string.IsNullOrEmpty(model.S_USER))
|
|||
|
|
{
|
|||
|
|
strSql.Append(" and t.S_USER ='" + model.S_USER + "'");
|
|||
|
|
}
|
|||
|
|
if (!string.IsNullOrEmpty(model.S_STORAGE))
|
|||
|
|
{
|
|||
|
|
strSql.Append(" and t.S_STORAGE = '" + model.S_STORAGE + "'");
|
|||
|
|
}
|
|||
|
|
if (!string.IsNullOrEmpty(model.STATUS))
|
|||
|
|
{
|
|||
|
|
strSql.Append(" and t.STATUS = '" + model.STATUS + "'");
|
|||
|
|
}
|
|||
|
|
if (model.S_DATE_STAR != DateTime.MinValue && model.S_DATE_END != DateTime.MinValue)
|
|||
|
|
{
|
|||
|
|
strSql.Append(" and t.S_DATE between convert(varchar(100),'" + model.S_DATE_STAR.ToString("yyyy-MM-dd") + "',23) and convert(varchar(100),'" + model.S_DATE_END.ToString("yyyy-MM-dd") + "',23)");
|
|||
|
|
}
|
|||
|
|
strSql.Append(" order by t.S_DATE desc");
|
|||
|
|
return SystemDataObject.Instance.GetDataTable(strSql.ToString());
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 获取流水号
|
|||
|
|
/// </summary>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
public string GetSerialNum()
|
|||
|
|
{
|
|||
|
|
StringBuilder strSql = new StringBuilder();
|
|||
|
|
strSql.Append("select NEXT VALUE FOR [SEQ_SCHEDULING] ");
|
|||
|
|
DataSet ds = SystemDataObject.Instance.GetDataSet( strSql.ToString());
|
|||
|
|
return ds.Tables[0].Rows[0][0].ToString();
|
|||
|
|
}
|
|||
|
|
#endregion BasicMethod
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
|