BaoKai_202508_Wms_Jingwang_.../WMS.Model/SystemManage/SCData/ProcessData.cs

171 lines
7.5 KiB
C#
Raw Permalink Normal View History

2025-08-24 21:52:42 +08:00
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using WMS.IData.ISC;
using WMS.Model.SC;
using System.Data;
using WMS.IData;using System.Data.SqlClient;
namespace WMS.SqlServerData.SCData
{
public class ProcessData : IProcess
{
#region
/// <summary>
/// 获取详情
/// </summary>
/// <param name="model"></param>
/// <returns></returns>
public DataTable GetProcess(ProcessModel model)
{
StringBuilder strSql = new StringBuilder();
strSql.Append(" select ");
strSql.Append(" b.goods_name goods_name,c.storage_name storage_name,e.team_name group_name,d.plan_name task_name,");
strSql.Append(" a.RECORDDATE,a.STORAGE_ID,a.TASK_ID,a.GOODS_ID,a.GOODS_NUM,a.FINISH_NUM,a.FINISH_DATE,a.LAST_NUM,a.RECORD_PER,a.REMARK,a.VERSION,a.GROUP_ID,a.status");
strSql.Append(" from t_sc_process a ");
strSql.Append(" left join t_base_goods b on a.goods_id = b.goods_id ");
strSql.Append(" left join t_base_storageinfo c on a.storage_id = c.storage_id");
strSql.Append(" left join t_sc_process_plan d on a.task_id = d.plan_id");
strSql.Append(" left join t_sys_team e on a.group_id = e.team_id");
strSql.Append(" where 1=1 ");
if (!string.IsNullOrEmpty(model.TASK_ID))
{
strSql.Append(" and a.TASK_ID ='" + model.TASK_ID + "' ");
}
if (!string.IsNullOrEmpty(model.STORAGE_ID))
{
strSql.Append(" and a.STORAGE_ID = '" + model.STORAGE_ID + "'");
}
if (!string.IsNullOrEmpty(model.GOODS_ID))
{
strSql.Append(" and a.GOODS_ID = '" + model.GOODS_ID + "'");
}
return SystemDataObject.Instance.GetDataTable(strSql.ToString());
}
#endregion
#region
/// <summary>
/// 修改详情
/// </summary>
/// <param name="model"></param>
public void UpdateProcess(ProcessModel model)
{
StringBuilder strSql = new StringBuilder();
strSql.Append("update T_SC_PROCESS set ");
strSql.Append("GOODS_NUM=@GOODS_NUM,");
strSql.Append("FINISH_NUM=@FINISH_NUM,");
strSql.Append("FINISH_DATE=@FINISH_DATE,");
strSql.Append("LAST_NUM=@LAST_NUM,");
strSql.Append("RECORD_PER=@RECORD_PER,");
strSql.Append("REMARK=@REMARK,");
strSql.Append("VERSION=@VERSION,");
strSql.Append("GROUP_ID=@GROUP_ID,");
strSql.Append("GROUP_ID=@status");
strSql.Append(" where STORAGE_ID=@STORAGE_ID and TASK_ID=@TASK_ID and GOODS_ID=@GOODS_ID and RECORDDATE=@RECORDDATE");
SqlParameter[] parameters = {
new SqlParameter("@GOODS_NUM", SqlDbType.Decimal,4),
new SqlParameter("@FINISH_NUM", SqlDbType.Decimal,4),
new SqlParameter("@FINISH_DATE", SqlDbType.Date),
new SqlParameter("@LAST_NUM", SqlDbType.Decimal,4),
new SqlParameter("@RECORD_PER", SqlDbType.VarChar,50),
new SqlParameter("@REMARK", SqlDbType.VarChar,500),
new SqlParameter("@VERSION", SqlDbType.VarChar,50),
new SqlParameter("@GROUP_ID", SqlDbType.VarChar,50),
new SqlParameter("@STORAGE_ID", SqlDbType.VarChar,50),
new SqlParameter("@TASK_ID", SqlDbType.VarChar,50),
new SqlParameter("@GOODS_ID", SqlDbType.VarChar,50),
new SqlParameter("@RECORDDATE",SqlDbType.Date)};
parameters[0].Value = model.GOODS_NUM;
parameters[1].Value = model.FINISH_NUM;
parameters[2].Value = model.FINISH_DATE;
parameters[3].Value = model.LAST_NUM;
parameters[4].Value = model.RECORD_PER;
parameters[5].Value = model.REMARK;
parameters[6].Value = model.VERSION;
parameters[7].Value = model.Group_id;
parameters[8].Value = model.Status;
parameters[9].Value = model.STORAGE_ID;
parameters[10].Value = model.TASK_ID;
parameters[11].Value = model.GOODS_ID;
parameters[12].Value = model.RecordDate;
SystemDataObject.Instance.ExecuteSql(strSql.ToString(), parameters);
}
#endregion
#region
/// <summary>
/// 新增
/// </summary>
/// <param name="model"></param>
public void AddProcess(ProcessModel model)
{
StringBuilder strSql = new StringBuilder();
strSql.Append("insert into T_SC_PROCESS(");
strSql.Append("STORAGE_ID,TASK_ID,GOODS_ID,GOODS_NUM,FINISH_NUM,FINISH_DATE,LAST_NUM,RECORD_PER,REMARK,VERSION,GROUP_ID,RECORDDATE,status)");
strSql.Append(" values (");
strSql.Append("@STORAGE_ID,@TASK_ID,@GOODS_ID,@GOODS_NUM,@FINISH_NUM,@FINISH_DATE,@LAST_NUM,@RECORD_PER,@REMARK,@VERSION,@GROUP_ID,@RECORDDATE,@status)");
SqlParameter[] parameters = {
new SqlParameter("@STORAGE_ID", SqlDbType.VarChar,50),
new SqlParameter("@TASK_ID", SqlDbType.VarChar,50),
new SqlParameter("@GOODS_ID", SqlDbType.VarChar,50),
new SqlParameter("@GOODS_NUM", SqlDbType.Decimal,4),
new SqlParameter("@FINISH_NUM", SqlDbType.Decimal,4),
new SqlParameter("@FINISH_DATE", SqlDbType.Date),
new SqlParameter("@LAST_NUM", SqlDbType.Decimal,4),
new SqlParameter("@RECORD_PER", SqlDbType.VarChar,50),
new SqlParameter("@REMARK", SqlDbType.VarChar,500),
new SqlParameter("@VERSION", SqlDbType.VarChar,50),
new SqlParameter("@GROUP_ID", SqlDbType.VarChar,50),
new SqlParameter("@RECORDDATE", SqlDbType.Date),
new SqlParameter("@status", SqlDbType.VarChar)};
parameters[0].Value = model.STORAGE_ID;
parameters[1].Value = model.TASK_ID;
parameters[2].Value = model.GOODS_ID;
parameters[3].Value = model.GOODS_NUM;
parameters[4].Value = model.FINISH_NUM;
parameters[5].Value = model.FINISH_DATE;
parameters[6].Value = model.LAST_NUM;
parameters[7].Value = model.RECORD_PER;
parameters[8].Value = model.REMARK;
parameters[9].Value = model.VERSION;
parameters[10].Value = model.Group_id;
parameters[11].Value = model.RecordDate;
parameters[12].Value = model.Status;
SystemDataObject.Instance.ExecuteSql(strSql.ToString(), parameters);
}
#endregion
#region
/// <summary>
/// 删除
/// </summary>
/// <param name="model"></param>
public void DeleteProcess(ProcessModel model)
{
StringBuilder strSql = new StringBuilder();
strSql.Append("delete from T_SC_PROCESS ");
strSql.Append(" where STORAGE_ID=@STORAGE_ID and TASK_ID=@TASK_ID and GOODS_ID=@GOODS_ID and RECORDDATE =@RECORDDATE");
SqlParameter[] parameters = {
new SqlParameter("@STORAGE_ID", SqlDbType.VarChar,50),
new SqlParameter("@TASK_ID", SqlDbType.VarChar,50),
new SqlParameter("@GOODS_ID", SqlDbType.VarChar,50),
new SqlParameter("@RECORDDATE",SqlDbType.Date)};
parameters[0].Value = model.STORAGE_ID;
parameters[1].Value = model.TASK_ID;
parameters[2].Value = model.GOODS_ID;
parameters[3].Value = model.RecordDate;
SystemDataObject.Instance.ExecuteSql(strSql.ToString(), parameters);
}
#endregion
}
}