239 lines
9.9 KiB
C#
239 lines
9.9 KiB
C#
|
using System;
|
|||
|
|
using System.Collections.Generic;
|
|||
|
|
using System.Linq;
|
|||
|
|
using System.Text;
|
|||
|
|
using WMS.IData.IStock;
|
|||
|
|
using System.Data;
|
|||
|
|
|
|||
|
|
using WMS.IData;using Oracle.ManagedDataAccess.Client;
|
|||
|
|
using WMS.Model.Stock;
|
|||
|
|
using WMS.DBUtility;
|
|||
|
|
|
|||
|
|
namespace WMS.SqlServerData.StockData
|
|||
|
|
{
|
|||
|
|
public class AdjustListInfoData : IAdjustListInfo
|
|||
|
|
{
|
|||
|
|
|
|||
|
|
/// <summary>
|
|||
|
|
/// 查询所有明细
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="model"></param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
public DataTable GetAdjustList(AdjustListInfoModel model)
|
|||
|
|
{
|
|||
|
|
StringBuilder strSql = new StringBuilder();
|
|||
|
|
strSql.Append(@"select f.STORAGE_AREA_NAME area_name,
|
|||
|
|
e.STORAGE_NAME storage_name,
|
|||
|
|
b.Goods_name goods_name,
|
|||
|
|
a.LIST_ID,
|
|||
|
|
a.LIST_INFO_GOODSID,
|
|||
|
|
a.LOC_ID,
|
|||
|
|
a.LIST_INFO_COUNT,
|
|||
|
|
a.REMARK,
|
|||
|
|
a.VERSION,
|
|||
|
|
a.OPERATORID,
|
|||
|
|
a.OPERATEDATE,
|
|||
|
|
a.NEWCOUNT,
|
|||
|
|
a.OLDCOUNT,
|
|||
|
|
a.STORAGE_ID,
|
|||
|
|
a.AREA_ID,a.PUTIN_ID");
|
|||
|
|
strSql.Append(" FROM T_STOCK_ADJUSTLIST_INFO a left join t_base_goods b on a.LIST_INFO_GOODSID = b.GOODS_ID");
|
|||
|
|
strSql.Append(" left join T_BASE_STORAGEINFO e on a.STORAGE_ID = e.STORAGE_ID");
|
|||
|
|
strSql.Append(" left join T_BASE_STORAGE_AREA f on a.AREA_ID = f.STORAGE_AREA_ID where 1=1");
|
|||
|
|
if (!string.IsNullOrEmpty(model.LIST_ID))
|
|||
|
|
{
|
|||
|
|
strSql.Append(" and a.LIST_ID='" + model.LIST_ID + "'");
|
|||
|
|
}
|
|||
|
|
if (!string.IsNullOrEmpty(model.LIST_INFO_GOODSID))
|
|||
|
|
{
|
|||
|
|
strSql.Append(" and a.LIST_INFO_GOODSID='" + model.LIST_ID + "'");
|
|||
|
|
}
|
|||
|
|
if (!string.IsNullOrEmpty(model.LOC_ID))
|
|||
|
|
{
|
|||
|
|
strSql.Append(" and a.LOC_ID='" + model.LOC_ID + "'");
|
|||
|
|
}
|
|||
|
|
strSql.Append(" order by a.LIST_INFO_GOODSID");
|
|||
|
|
|
|||
|
|
return SystemDataObject.Instance.GetDataTable(strSql.ToString());
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
#region 新增商品明细
|
|||
|
|
/// <summary>
|
|||
|
|
/// 新增商品明细
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="list"></param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
public void ExecListAdd(AdjustListInfoModel list)
|
|||
|
|
{
|
|||
|
|
|
|||
|
|
|
|||
|
|
StringBuilder strSql = new StringBuilder();
|
|||
|
|
strSql.Append("insert into T_STOCK_ADJUSTLIST_INFO(");
|
|||
|
|
strSql.Append("LIST_ID,LIST_INFO_GOODSID,LOC_ID,LIST_INFO_COUNT,REMARK,VERSION,OPERATORID,OPERATEDATE,NEWCOUNT,OLDCOUNT,STORAGE_ID,AREA_ID)");
|
|||
|
|
strSql.Append(" values (");
|
|||
|
|
strSql.Append(":LIST_ID,:LIST_INFO_GOODSID,:LOC_ID,:LIST_INFO_COUNT,:REMARK,:VERSION,:OPERATORID,:OPERATEDATE,:NEWCOUNT,:OLDCOUNT,:STORAGE_ID,:AREA_ID)");
|
|||
|
|
OracleParameter[] parameters = {
|
|||
|
|
new OracleParameter(":LIST_ID",OracleDbType.Varchar2),
|
|||
|
|
new OracleParameter(":LIST_INFO_GOODSID",OracleDbType.Varchar2),
|
|||
|
|
new OracleParameter(":LOC_ID",OracleDbType.Varchar2),
|
|||
|
|
new OracleParameter(":LIST_INFO_COUNT", OracleDbType.Decimal),
|
|||
|
|
new OracleParameter(":REMARK",OracleDbType.Varchar2),
|
|||
|
|
new OracleParameter(":VERSION",OracleDbType.Varchar2),
|
|||
|
|
new OracleParameter(":OPERATORID",OracleDbType.Varchar2),
|
|||
|
|
new OracleParameter(":OPERATEDATE", OracleDbType.Date),
|
|||
|
|
new OracleParameter(":NEWCOUNT", OracleDbType.Decimal),
|
|||
|
|
new OracleParameter(":OLDCOUNT",OracleDbType.Decimal),
|
|||
|
|
new OracleParameter(":STORAGE_ID",OracleDbType.Varchar2),
|
|||
|
|
new OracleParameter(":AREA_ID",OracleDbType.Varchar2),
|
|||
|
|
new OracleParameter(":PUTIN_ID",OracleDbType.Varchar2)
|
|||
|
|
};
|
|||
|
|
|
|||
|
|
parameters[0].Value = list.LIST_ID;
|
|||
|
|
parameters[1].Value = list.LIST_INFO_GOODSID;
|
|||
|
|
parameters[2].Value = list.LOC_ID;
|
|||
|
|
parameters[3].Value = list.LIST_INFO_COUNT;
|
|||
|
|
parameters[4].Value = list.REMARK;
|
|||
|
|
parameters[5].Value = list.VERSION;
|
|||
|
|
parameters[6].Value = list.OPERATORID;
|
|||
|
|
parameters[7].Value = list.OPERATEDATE;
|
|||
|
|
parameters[8].Value = list.NEWCOUNT;
|
|||
|
|
parameters[9].Value = list.Oldcount;
|
|||
|
|
parameters[10].Value = list.Storage_id;
|
|||
|
|
parameters[11].Value = list.Area_id;
|
|||
|
|
parameters[12].Value = list.PUTIN_ID;
|
|||
|
|
|
|||
|
|
|
|||
|
|
SystemDataObject.Instance.ExecuteSql(strSql.ToString(), parameters);
|
|||
|
|
}
|
|||
|
|
#endregion
|
|||
|
|
|
|||
|
|
#region 修改
|
|||
|
|
/// <summary>
|
|||
|
|
/// 修改
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="model"></param>
|
|||
|
|
public void ExecListUpdate(AdjustListInfoModel model)
|
|||
|
|
{
|
|||
|
|
|
|||
|
|
StringBuilder strSql = new StringBuilder();
|
|||
|
|
strSql.Append("update T_STOCK_ADJUSTLIST_INFO set ");
|
|||
|
|
strSql.Append("LIST_INFO_COUNT=:LIST_INFO_COUNT,");
|
|||
|
|
strSql.Append("REMARK=:REMARK,");
|
|||
|
|
strSql.Append("VERSION=:VERSION,");
|
|||
|
|
strSql.Append("OPERATORID=:OPERATORID,");
|
|||
|
|
strSql.Append("OPERATEDATE=:OPERATEDATE,");
|
|||
|
|
strSql.Append("NEWCOUNT=:NEWCOUNT");
|
|||
|
|
strSql.Append("OLDCOUNT=:OLDCOUNT");
|
|||
|
|
strSql.Append("LOC_ID=:LOC_ID");
|
|||
|
|
strSql.Append("STORAGE_ID=:STORAGE_ID");
|
|||
|
|
strSql.Append("AREA_ID=:AREA_ID");
|
|||
|
|
strSql.Append(" where LIST_ID=:LIST_ID and LOC_ID=:LOC_ID and LIST_INFO_GOODSID=:LIST_INFO_GOODSID");
|
|||
|
|
OracleParameter[] parameters = {
|
|||
|
|
new OracleParameter(":LIST_INFO_COUNT",OracleDbType.Varchar2),
|
|||
|
|
new OracleParameter(":REMARK",OracleDbType.Varchar2),
|
|||
|
|
new OracleParameter(":VERSION",OracleDbType.Varchar2),
|
|||
|
|
new OracleParameter(":OPERATORID",OracleDbType.Varchar2),
|
|||
|
|
new OracleParameter(":OPERATEDATE",OracleDbType.Varchar2),
|
|||
|
|
new OracleParameter(":NEWCOUNT", OracleDbType.Decimal),
|
|||
|
|
new OracleParameter(":OLDCOUNT",OracleDbType.Decimal),
|
|||
|
|
new OracleParameter(":LOC_ID",OracleDbType.Varchar2),
|
|||
|
|
new OracleParameter(":STORAGE_ID",OracleDbType.Varchar2),
|
|||
|
|
new OracleParameter(":AREA_ID",OracleDbType.Varchar2),
|
|||
|
|
new OracleParameter(":LIST_ID",OracleDbType.Varchar2),
|
|||
|
|
new OracleParameter(":LIST_INFO_GOODSID",OracleDbType.Varchar2) };
|
|||
|
|
|
|||
|
|
|
|||
|
|
parameters[0].Value = model.LIST_INFO_COUNT;
|
|||
|
|
parameters[1].Value = model.REMARK;
|
|||
|
|
parameters[2].Value = model.VERSION;
|
|||
|
|
parameters[3].Value = model.OPERATORID;
|
|||
|
|
parameters[4].Value = model.OPERATEDATE;
|
|||
|
|
parameters[5].Value = model.NEWCOUNT;
|
|||
|
|
parameters[6].Value = model.Oldcount;
|
|||
|
|
parameters[7].Value = model.LOC_ID;
|
|||
|
|
parameters[8].Value = model.Storage_id;
|
|||
|
|
parameters[9].Value = model.Area_id;
|
|||
|
|
parameters[10].Value = model.LIST_ID;
|
|||
|
|
parameters[11].Value = model.LIST_INFO_GOODSID;
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
SystemDataObject.Instance.ExecuteSql(strSql.ToString(), parameters);
|
|||
|
|
}
|
|||
|
|
#endregion
|
|||
|
|
|
|||
|
|
public string Get_StrLoc(string LOCATION_ID)
|
|||
|
|
{
|
|||
|
|
string sqlStr = " select LOCATION_ID from T_BASE_STORAGE_AREA_LOCATION where LOCATION_ID='" + LOCATION_ID + "' and STATUS !='0'";
|
|||
|
|
string row = "";
|
|||
|
|
DataTable ds = new DataTable();
|
|||
|
|
try
|
|||
|
|
{
|
|||
|
|
ds = SystemDataObject.Instance.GetDataTable(sqlStr);
|
|||
|
|
if (ds != null)
|
|||
|
|
{
|
|||
|
|
if (ds.Rows.Count > 0)
|
|||
|
|
{
|
|||
|
|
row = ds.Rows[0][0].ToString();
|
|||
|
|
|
|||
|
|
if (row.Length > 0)
|
|||
|
|
{
|
|||
|
|
row = "";
|
|||
|
|
string sqlstr2 = "select * from T_MI_STOCK where location_id='" + LOCATION_ID + "'";
|
|||
|
|
ds = SystemDataObject.Instance.GetDataTable(sqlStr);
|
|||
|
|
if (ds != null)
|
|||
|
|
{
|
|||
|
|
if (ds.Rows.Count > 0)
|
|||
|
|
{
|
|||
|
|
row = ds.Rows[0][0].ToString();
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
}
|
|||
|
|
catch (Exception ex)
|
|||
|
|
{
|
|||
|
|
row = "";
|
|||
|
|
}
|
|||
|
|
return row;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
|
|||
|
|
#region 删除库调整单明细存
|
|||
|
|
/// <summary>
|
|||
|
|
/// 删除库调整单明细存
|
|||
|
|
/// </summary>
|
|||
|
|
/// <param name="model"></param>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
public void DelList(AdjustListInfoModel model)
|
|||
|
|
{
|
|||
|
|
StringBuilder strSql = new StringBuilder();
|
|||
|
|
strSql.Append("delete from T_STOCK_ADJUSTLIST_INFO ");
|
|||
|
|
strSql.Append(" where LIST_ID=:LIST_INFO_ID");
|
|||
|
|
OracleParameter[] parameters = {
|
|||
|
|
new OracleParameter(":LIST_ID",OracleDbType.Varchar2)};
|
|||
|
|
parameters[0].Value = model.LIST_ID;
|
|||
|
|
|
|||
|
|
SystemDataObject.Instance.ExecuteSql(strSql.ToString(), parameters);
|
|||
|
|
}
|
|||
|
|
#endregion
|
|||
|
|
|
|||
|
|
#region 获取流水号
|
|||
|
|
/// <summary>
|
|||
|
|
/// 获取流水号
|
|||
|
|
/// </summary>
|
|||
|
|
/// <returns></returns>
|
|||
|
|
public string GetSerialNum()
|
|||
|
|
{
|
|||
|
|
StringBuilder strSql = new StringBuilder();
|
|||
|
|
strSql.Append("select NEXT VALUE FOR SEQ_STOCK_ADLISTINFO_ID ");
|
|||
|
|
DataSet ds = SystemDataObject.Instance.GetDataSet(strSql.ToString());
|
|||
|
|
return ds.Tables[0].Rows[0][0].ToString();
|
|||
|
|
}
|
|||
|
|
#endregion
|
|||
|
|
}
|
|||
|
|
}
|