64 lines
2.3 KiB
C#
64 lines
2.3 KiB
C#
using System;
|
|
using System.Collections.Generic;
|
|
using System.Linq;
|
|
using System.Text;
|
|
using WMS.Model.Base;
|
|
using WMS.IData;
|
|
using WMS.IData.IBase;
|
|
using System.Data;
|
|
|
|
namespace WMS.SqlServerData.BaseData
|
|
{
|
|
public class GoodProvider : IGoodProvider
|
|
{
|
|
public DataTable GetGoodsData(string proivider)
|
|
{
|
|
string sqlStr =@"select t.*,g.GOODS_NAME from T_BASE_GOODS_PROVIDER t
|
|
left join T_BASE_GOODS g on t.GOODS_ID = g.GOODS_ID where t.PROVIDER_ID ='" + proivider + "'";
|
|
|
|
return SystemDataObject.Instance.GetDataTable(sqlStr);
|
|
}
|
|
public DataTable GetProividerGoodsData(string goodsId)
|
|
{
|
|
string sqlStr = "select * from T_BASE_GOODS_PROVIDER where GOODS_ID ='" + goodsId + "'";
|
|
|
|
return SystemDataObject.Instance.GetDataTable(sqlStr);
|
|
}
|
|
/// <summary>
|
|
/// 增加商品的供应商
|
|
/// </summary>
|
|
/// <param name="ProviderModel"></param>
|
|
public void AddProviderGoods(GoodsProviderModel ProviderModel)
|
|
{
|
|
string strSQL = "";
|
|
strSQL = strSQL + "insert into T_BASE_GOODS_PROVIDER(";
|
|
strSQL = strSQL + "GOODS_ID,PROVIDER_ID,REMARK,VERSION,GOODS_PRICE";
|
|
strSQL = strSQL + ")";
|
|
strSQL = strSQL + " values (";
|
|
strSQL = strSQL + "'" + ProviderModel.GOODS_ID + "',";
|
|
strSQL = strSQL + "'" + ProviderModel.PROVIDER_ID + "',";
|
|
strSQL = strSQL + "'" + ProviderModel.REMARK + "',";
|
|
strSQL = strSQL + "'" + ProviderModel.VERSION + "','"+ ProviderModel .GOODS_PRICE+ "'";
|
|
strSQL = strSQL + ")";
|
|
SystemDataObject.Instance.ExecuteSql(strSQL);
|
|
}
|
|
/// <summary>
|
|
/// 删除商品的供应商
|
|
/// </summary>
|
|
/// <param name="goodsId"></param>
|
|
/// <param name="providerId"></param>
|
|
public void DelProviderGoods(string goodsId, string providerId)
|
|
{
|
|
string strSQL = "delete from T_BASE_GOODS_PROVIDER where GOODS_ID = '" + goodsId + "' ";
|
|
if (providerId.Trim().Length > 0)
|
|
{
|
|
strSQL = strSQL + " and PROVIDER_ID='" + providerId + "'";
|
|
}
|
|
SystemDataObject.Instance.ExecuteSql(strSQL);
|
|
}
|
|
|
|
|
|
|
|
}
|
|
}
|