213 lines
9.7 KiB
C#
213 lines
9.7 KiB
C#
|
|
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
|
|||
|
|
{
|
|||
|
|
class ProBreakData : IProBreak
|
|||
|
|
{
|
|||
|
|
#region 获取集合
|
|||
|
|
/// <summary>
|
|||
|
|
/// 获取集合
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="model"></param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
public DataTable GetProBreak(ProBreakModel model)
|
|||
|
|
{
|
|||
|
|
StringBuilder strSql = new StringBuilder();
|
|||
|
|
strSql.Append("select a.STORAGE_ID,a.TASK_ID,j.goods_name material_name,a.STEP_ID,a.GOODS_ID,a.MATERIAL_ID,a.MATERIAL_NUM,a.UNIT,a.BREAK_NUM,a.BREAK_PER,a.BREAK_DATE,a.AREA_ID,a.RECORD_PER,a.RECORD_DATE ,");
|
|||
|
|
strSql.Append(" b.storage_name storage_name, ");
|
|||
|
|
strSql.Append(" c.goods_name goods_name, ");
|
|||
|
|
strSql.Append(" d.plan_name task_name, ");
|
|||
|
|
strSql.Append(" e.name Record_perName,");
|
|||
|
|
strSql.Append(" f.vc_dictionary_name Unit_name, ");
|
|||
|
|
strSql.Append(" i.vc_dictionary_name Step_name, ");
|
|||
|
|
strSql.Append(" g.storage_area_name Area_name, ");
|
|||
|
|
strSql.Append(" h.name Record_perName");
|
|||
|
|
strSql.Append(" from t_sc_pro_break a ");
|
|||
|
|
strSql.Append(" left join t_base_storageinfo b ");
|
|||
|
|
strSql.Append(" on a.storage_id = b.storage_id");
|
|||
|
|
strSql.Append(" left join t_base_goods c");
|
|||
|
|
strSql.Append(" on a.goods_id = c.goods_id ");
|
|||
|
|
strSql.Append(" left join t_sc_process_plan d");
|
|||
|
|
strSql.Append(" on a.task_id = d.plan_id");
|
|||
|
|
strSql.Append(" left join t_base_userinfo e ");
|
|||
|
|
strSql.Append(" on a.record_per = e.user_id");
|
|||
|
|
strSql.Append(" left join t_sys_dictionary_tab f ");
|
|||
|
|
strSql.Append(" on a.unit = f.vc_char_value");
|
|||
|
|
strSql.Append(" and f.VC_DICTIONARY_TYPE = 'vc_uom'");
|
|||
|
|
strSql.Append(" and c_flag = '1'");
|
|||
|
|
strSql.Append(" left join t_base_storage_area g");
|
|||
|
|
strSql.Append(" on g.storage_area_id = a.area_id");
|
|||
|
|
strSql.Append(" left join t_base_userinfo h");
|
|||
|
|
strSql.Append(" on a.break_per = h.user_id");
|
|||
|
|
strSql.Append(" left join t_base_goods j ");
|
|||
|
|
strSql.Append(" on a.MATERIAL_ID = j.goods_id ");
|
|||
|
|
strSql.Append(" left join t_sys_dictionary_tab i");
|
|||
|
|
strSql.Append(" on a.step_id = i.vc_char_value ");
|
|||
|
|
strSql.Append(" and i.VC_DICTIONARY_TYPE = 'Step'");
|
|||
|
|
strSql.Append(" and i.c_flag = '1' ");
|
|||
|
|
strSql.Append(" where 1=1 ");
|
|||
|
|
|
|||
|
|
if (!string.IsNullOrEmpty(model.STORAGE_ID))
|
|||
|
|
{
|
|||
|
|
strSql.Append(" and a.STORAGE_ID = '" + model.STORAGE_ID + "'");
|
|||
|
|
}
|
|||
|
|
if (!string.IsNullOrEmpty(model.TASK_ID))
|
|||
|
|
{
|
|||
|
|
strSql.Append(" and a.TASK_ID = '" + model.TASK_ID + "'");
|
|||
|
|
}
|
|||
|
|
if (!string.IsNullOrEmpty(model.STEP_ID))
|
|||
|
|
{
|
|||
|
|
strSql.Append(" and a.STEP_ID = '" + model.STEP_ID + "'");
|
|||
|
|
}
|
|||
|
|
if (!string.IsNullOrEmpty(model.GOODS_ID))
|
|||
|
|
{
|
|||
|
|
strSql.Append(" and a.GOODS_ID = '" + model.GOODS_ID + "'");
|
|||
|
|
}
|
|||
|
|
if (!string.IsNullOrEmpty(model.MATERIAL_ID))
|
|||
|
|
{
|
|||
|
|
strSql.Append(" and a.MATERIAL_ID = '" + model.MATERIAL_ID + "'");
|
|||
|
|
}
|
|||
|
|
if (!string.IsNullOrEmpty(model.RECORD_DATE.ToString()) && (model.RECORD_DATE.ToString()) != "0001/1/1 0@00@00")
|
|||
|
|
{
|
|||
|
|
strSql.Append(" and a.RECORD_DATE = '" + model.RECORD_DATE + "'");
|
|||
|
|
}
|
|||
|
|
return SystemDataObject.Instance.GetDataTable(strSql.ToString());
|
|||
|
|
}
|
|||
|
|
#endregion
|
|||
|
|
|
|||
|
|
#region 新增
|
|||
|
|
/// <summary>
|
|||
|
|
/// 新增
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="model"></param>
|
|||
|
|
public void AddProBreak(ProBreakModel model)
|
|||
|
|
{
|
|||
|
|
StringBuilder strSql = new StringBuilder();
|
|||
|
|
strSql.Append("insert into T_SC_PRO_BREAK(");
|
|||
|
|
strSql.Append("STORAGE_ID,TASK_ID,STEP_ID,GOODS_ID,MATERIAL_ID,MATERIAL_NUM,UNIT,BREAK_NUM,BREAK_PER,BREAK_DATE,AREA_ID,RECORD_PER,RECORD_DATE)");
|
|||
|
|
strSql.Append(" values (");
|
|||
|
|
strSql.Append("@STORAGE_ID,@TASK_ID,@STEP_ID,@GOODS_ID,@MATERIAL_ID,@MATERIAL_NUM,@UNIT,@BREAK_NUM,@BREAK_PER,@BREAK_DATE,@AREA_ID,@RECORD_PER,@RECORD_DATE)");
|
|||
|
|
SqlParameter[] parameters = {
|
|||
|
|
new SqlParameter("@STORAGE_ID", SqlDbType.VarChar,50),
|
|||
|
|
new SqlParameter("@TASK_ID", SqlDbType.VarChar,50),
|
|||
|
|
new SqlParameter("@STEP_ID", SqlDbType.VarChar,50),
|
|||
|
|
new SqlParameter("@GOODS_ID", SqlDbType.VarChar,50),
|
|||
|
|
new SqlParameter("@MATERIAL_ID", SqlDbType.VarChar,50),
|
|||
|
|
new SqlParameter("@MATERIAL_NUM", SqlDbType.Decimal,4),
|
|||
|
|
new SqlParameter("@UNIT", SqlDbType.Char),
|
|||
|
|
new SqlParameter("@BREAK_NUM", SqlDbType.Decimal,4),
|
|||
|
|
new SqlParameter("@BREAK_PER", SqlDbType.VarChar,50),
|
|||
|
|
new SqlParameter("@BREAK_DATE", SqlDbType.Date),
|
|||
|
|
new SqlParameter("@AREA_ID", SqlDbType.VarChar,50),
|
|||
|
|
new SqlParameter("@RECORD_PER", SqlDbType.VarChar,50),
|
|||
|
|
new SqlParameter("@RECORD_DATE", SqlDbType.Date)};
|
|||
|
|
parameters[0].Value = model.STORAGE_ID;
|
|||
|
|
parameters[1].Value = model.TASK_ID;
|
|||
|
|
parameters[2].Value = model.STEP_ID;
|
|||
|
|
parameters[3].Value = model.GOODS_ID;
|
|||
|
|
parameters[4].Value = model.MATERIAL_ID;
|
|||
|
|
parameters[5].Value = model.MATERIAL_NUM;
|
|||
|
|
parameters[6].Value = model.UNIT;
|
|||
|
|
parameters[7].Value = model.BREAK_NUM;
|
|||
|
|
parameters[8].Value = model.BREAK_PER;
|
|||
|
|
parameters[9].Value = model.BREAK_DATE;
|
|||
|
|
parameters[10].Value = model.AREA_ID;
|
|||
|
|
parameters[11].Value = model.RECORD_PER;
|
|||
|
|
parameters[12].Value = model.RECORD_DATE;
|
|||
|
|
|
|||
|
|
|
|||
|
|
SystemDataObject.Instance.ExecuteSql(strSql.ToString(), parameters);
|
|||
|
|
}
|
|||
|
|
#endregion
|
|||
|
|
|
|||
|
|
#region 修改
|
|||
|
|
/// <summary>
|
|||
|
|
/// 修改
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="model"></param>
|
|||
|
|
public void UpdateProBreak(ProBreakModel model)
|
|||
|
|
{
|
|||
|
|
StringBuilder strSql = new StringBuilder();
|
|||
|
|
strSql.Append("update T_SC_PRO_BREAK set ");
|
|||
|
|
strSql.Append("MATERIAL_NUM=@MATERIAL_NUM,");
|
|||
|
|
strSql.Append("UNIT=@UNIT,");
|
|||
|
|
strSql.Append("BREAK_NUM=@BREAK_NUM,");
|
|||
|
|
strSql.Append("BREAK_PER=@BREAK_PER,");
|
|||
|
|
strSql.Append("BREAK_DATE=@BREAK_DATE,");
|
|||
|
|
strSql.Append("AREA_ID=@AREA_ID,");
|
|||
|
|
strSql.Append("RECORD_PER=@RECORD_PER,");
|
|||
|
|
strSql.Append("RECORD_DATE=@RECORD_DATE");
|
|||
|
|
strSql.Append(" where STORAGE_ID=@STORAGE_ID and TASK_ID=@TASK_ID and STEP_ID=@STEP_ID and GOODS_ID=@GOODS_ID and MATERIAL_ID=@MATERIAL_ID ");
|
|||
|
|
SqlParameter[] parameters = {
|
|||
|
|
|
|||
|
|
new SqlParameter("@MATERIAL_NUM", SqlDbType.Decimal,4),
|
|||
|
|
new SqlParameter("@UNIT", SqlDbType.Char),
|
|||
|
|
new SqlParameter("@BREAK_NUM", SqlDbType.Decimal,4),
|
|||
|
|
new SqlParameter("@BREAK_PER",SqlDbType.VarChar,50),
|
|||
|
|
new SqlParameter("@BREAK_DATE", SqlDbType.Date),
|
|||
|
|
new SqlParameter("@AREA_ID",SqlDbType.VarChar,50),
|
|||
|
|
new SqlParameter("@RECORD_PER",SqlDbType.VarChar,50),
|
|||
|
|
new SqlParameter("@RECORD_DATE", SqlDbType.Date),
|
|||
|
|
new SqlParameter("@STORAGE_ID",SqlDbType.VarChar,50),
|
|||
|
|
new SqlParameter("@TASK_ID",SqlDbType.VarChar,50),
|
|||
|
|
new SqlParameter("@STEP_ID",SqlDbType.VarChar,50),
|
|||
|
|
new SqlParameter("@GOODS_ID",SqlDbType.VarChar,50),
|
|||
|
|
new SqlParameter("@MATERIAL_ID",SqlDbType.VarChar,50)};
|
|||
|
|
|
|||
|
|
parameters[0].Value = model.MATERIAL_NUM;
|
|||
|
|
parameters[1].Value = model.UNIT;
|
|||
|
|
parameters[2].Value = model.BREAK_NUM;
|
|||
|
|
parameters[3].Value = model.BREAK_PER;
|
|||
|
|
parameters[4].Value = model.BREAK_DATE;
|
|||
|
|
parameters[5].Value = model.AREA_ID;
|
|||
|
|
parameters[6].Value = model.RECORD_PER;
|
|||
|
|
parameters[7].Value = model.RECORD_DATE;
|
|||
|
|
parameters[8].Value = model.STORAGE_ID;
|
|||
|
|
parameters[9].Value = model.TASK_ID;
|
|||
|
|
parameters[10].Value = model.STEP_ID;
|
|||
|
|
parameters[11].Value = model.GOODS_ID;
|
|||
|
|
parameters[12].Value = model.MATERIAL_ID;
|
|||
|
|
|
|||
|
|
SystemDataObject.Instance.ExecuteSql(strSql.ToString(), parameters);
|
|||
|
|
}
|
|||
|
|
#endregion
|
|||
|
|
|
|||
|
|
|
|||
|
|
#region 删除
|
|||
|
|
/// <summary>
|
|||
|
|
/// 删除
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="model"></param>
|
|||
|
|
public void DeleteProBreak(ProBreakModel model)
|
|||
|
|
{
|
|||
|
|
StringBuilder strSql = new StringBuilder();
|
|||
|
|
strSql.Append("delete from T_SC_PRO_BREAK ");
|
|||
|
|
strSql.Append(" where STORAGE_ID=@STORAGE_ID and TASK_ID=@TASK_ID and STEP_ID=@STEP_ID and GOODS_ID=@GOODS_ID and MATERIAL_ID=@MATERIAL_ID and RECORD_DATE=@RECORD_DATE");
|
|||
|
|
SqlParameter[] parameters = {
|
|||
|
|
new SqlParameter("@STORAGE_ID", SqlDbType.VarChar,50),
|
|||
|
|
new SqlParameter("@TASK_ID", SqlDbType.VarChar,50),
|
|||
|
|
new SqlParameter("@STEP_ID", SqlDbType.VarChar,50),
|
|||
|
|
new SqlParameter("@GOODS_ID", SqlDbType.VarChar,50),
|
|||
|
|
new SqlParameter("@MATERIAL_ID", SqlDbType.VarChar,50),
|
|||
|
|
new SqlParameter("@RECORD_DATE",SqlDbType.Date)};
|
|||
|
|
parameters[0].Value = model.STORAGE_ID;
|
|||
|
|
parameters[1].Value = model.TASK_ID;
|
|||
|
|
parameters[2].Value = model.STEP_ID;
|
|||
|
|
parameters[3].Value = model.GOODS_ID;
|
|||
|
|
parameters[4].Value = model.MATERIAL_ID;
|
|||
|
|
parameters[5].Value = model.RECORD_DATE;
|
|||
|
|
|
|||
|
|
SystemDataObject.Instance.ExecuteSql(strSql.ToString(), parameters);
|
|||
|
|
}
|
|||
|
|
#endregion
|
|||
|
|
}
|
|||
|
|
}
|