BaoKai_202508_Wms_Jingwang_.../WMS.SqlServerData/RKData/WareNoticeTabData.cs

571 lines
33 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 System.Data;
using WMS.Model.RK;
using WMS.DBUtility;
using WMS.IData.IRK;
using WMS.IData;using Oracle.ManagedDataAccess.Client;
namespace WMS.SqlServerData.RKData
{
public class WareNoticeTabData : IWareNoticeTab
{
/// <summary>
/// 查询打印次数
/// </summary>
/// <param name="orderId"></param>
/// <param name="GoodsId"></param>
/// <returns></returns>
public DataTable GetCtPringCs(string orderId, string GoodsId)
{
string sqlStr = " select PrintSts" +
" from T_RK_WARE_NOTICE_TAB where GOODS_ID='" + GoodsId+ "' and WAREHOUSING_ID='"+orderId+"'";
return SystemDataObject.Instance.GetDataTable(sqlStr);
}
/// <summary>
/// 查询打印数据
/// </summary>
/// <param name="orderId"></param>
/// <param name="goodsId"></param>
/// <returns></returns>
public DataTable GetPrintData(string orderId,string goodsId)
{
string sqlStr =@"select b.GOODS_ID as 物料编号, b.goods_name as 物料名称 ,a.PRODUCTION_DATE as 生产日期 , c.storage_name as 仓库名称 , x.VC_DICTIONARY_NAME as 单位名称, b.PERIOD as 保质期, g.provider_name as 供应商名称 , ISNULL(a.GVOLUME, 0) GVOLUME ,a.GOODSVOLUME as 装箱数 , f.GOODS_MEASURE_NAME as 箱型 ,'' as 箱码 ,'' as 二维码 ,z.GOODS_TYPE_ID as 类型 ,g.PROVIDER_ID as 供应商编号
FROM T_RK_WARE_NOTICE_TAB a left join t_base_goods b on a.goods_id = b.goods_id
left join t_base_storageinfo c on a.storage_id = c.storage_id
left join T_BASE_GOODS_MEASURE f on a.GOODS_MEASURE_ID = f.GOODS_MEASURE_ID
left join t_base_provider_dictionary g on a.provider_id = g.provider_id
left join T_BASE_GOODS_TYPE z on b.GOODS_TYPE_ID =z.GOODS_TYPE_ID
left join T_SYS_DICTIONARY_TAB x on x.VC_CHAR_VALUE = a.UNIT and x.VC_DICTIONARY_TYPE = 'vc_uom' where a.WAREHOUSING_ID='" + orderId+ "' and a.GOODS_ID='"+goodsId+"'";
return SystemDataObject.Instance.GetDataTable(sqlStr);
}
///// <summary>
///// 根据角色编号返回角色所属仓库、库区
///// </summary>
///// <param name="roleID">用户角色编号</param>
///// <returns></returns>
//public DataTable GetRoleStorageAreaDT(string roleID)
//{
// StringBuilder sqlStr = new StringBuilder();
// sqlStr.AppendLine("select ");
// sqlStr.AppendLine(" a.STORAGE_ID, ");
// sqlStr.AppendLine(" a.AREA_ID, ");
// sqlStr.AppendLine(" b.storage_area_name, ");
// sqlStr.AppendLine(" c.storage_name ");
// sqlStr.AppendLine("from ");
// sqlStr.AppendLine(" T_BASE_AREA a left join t_base_storage_area b ");
// sqlStr.AppendLine(" on a.area_id = b.storage_area_id ");
// sqlStr.AppendLine(" left join t_base_storageinfo c ");
// sqlStr.AppendLine(" on a.storage_id = c.storage_id ");
// sqlStr.AppendLine("where a.ROLE_ID =:ROLE_ID ");
// OracleParameter[] parmeter = new OracleParameter[] {
// new OracleParameter(":ROLE_ID",OracleDbType.Varchar2)
// };
// parmeter[0].Value = roleID;
// return SystemDataObject.Instance.GetDataTable(sqlStr.ToString(), parmeter);
//}
/// <summary>
/// 删除通知单明细
/// </summary>
/// <param name="PURCHASE_ID"></param>
public void DelOrderData(string PURCHASE_ID)
{
string sqlStr = " delete T_RK_WARE_NOTICE_TAB where PURCHASE_ID='"+ PURCHASE_ID + "' ";
SystemDataObject.Instance.ExecuteSql(sqlStr);
}
/// <summary>
/// ./
/// </summary>
/// <param name="orderId"></param>
/// <param name="goodId"></param>
/// <param name="sts"></param>
public void UpdateStsMp(string orderId, string goodId,string sts)
{
string sqlStr = " update T_RK_WARE_NOTICE_TAB set DISKSTS ='"+ sts + "' where WAREHOUSING_ID ='" + orderId + "' and GOODS_ID='" + goodId + "'";
SystemDataObject.Instance.ExecuteSqlCommit(sqlStr);
}
public void UpdatePrint(string orderId, string GoodsId)
{
string sqlStr = " update T_RK_WARE_NOTICE_TAB set PrintSts='1'," +
" PrintCS = PrintCS+1 where WAREHOUSING_ID ='" + orderId + "' and GOODS_ID='" + GoodsId + "' ";
SystemDataObject.Instance.ExecuteSqlCommit(sqlStr);
}
public void UpdatePrintSts(string measureID, string orderId,string GoodsId,string GOODSVOLUME,int BOXCT)
{
string sqlStr = " update T_RK_WARE_NOTICE_TAB set GOODSVOLUME='"+GOODSVOLUME+ "'," +
" GOODS_MEASURE_ID='"+ measureID + "', BOXCT = '"+ BOXCT + "',PrintSts='3' where WAREHOUSING_ID ='" + orderId+ "' and GOODS_ID='"+GoodsId+"' ";
SystemDataObject.Instance.ExecuteSqlCommit(sqlStr);
}
/// <summary>
/// 获取入库商品清单
/// </summary>
/// <returns>入库商品清单</returns>
public DataTable GetWareNoticeTabDT(WareNoticeTabModel model)
{
StringBuilder strSql = new StringBuilder();
strSql.AppendLine("select ");
strSql.AppendLine(" a.WAREHOUSING_ID, --入库通知单编号 ");
strSql.AppendLine(" a.PURCHASE_ID, --采购单号 ");
strSql.AppendLine(" a.GOODS_ID, --商品编号 ");
strSql.AppendLine(" b.goods_name, ");
strSql.AppendLine(" a.GOODS_TYPE_ID, --商品分类 ");
strSql.AppendLine(" f.GOODS_TYPE_NAME, --商品分类 ");
strSql.AppendLine(" ISNULL(a.AMOUNT,0) AMOUNT, --数量 ");
strSql.AppendLine(" ISNULL(a.TOTAL_VOLUME,0) TOTAL_VOLUME, --总体积 ");
strSql.AppendLine(" ISNULL(a.TOTAL_ROUGH_WEIGHT,0) TOTAL_ROUGH_WEIGHT, --总毛重 ");
strSql.AppendLine(" ISNULL(a.TOTAL_NET_WEIGH,0) TOTAL_NET_WEIGH, --总净重 ");
strSql.AppendLine(" ISNULL(a.TOTAL_MONEY,0) TOTAL_MONEY, --总金额 ");
strSql.AppendLine(" a.PRODUCTION_DATE, --生产日期 ");
strSql.AppendLine(" a.STORAGE_ID, --入库仓库编号 ");
strSql.AppendLine(" c.storage_name, ");
strSql.AppendLine(" a.STORAGE_AREA_ID, --入库库区编号 ");
strSql.AppendLine(" d.storage_area_name, ");
strSql.AppendLine(" a.PACKAGE_ID, --容器编号 ");
strSql.AppendLine(" e.pallet_name package_name, ");
strSql.AppendLine(" a.REMARK, --备注 ");
strSql.AppendLine(" a.operatorid, --操作人 ");
strSql.AppendLine(" a.operatedate, --操作日期 ");
strSql.AppendLine(" a.UNIT, --单位 ");
strSql.AppendLine(" a.PRICE, --标准价格 ");
strSql.AppendLine(" a.SCALE_UNIT, --重量单位 ");
strSql.AppendLine(" a.PROVIDER_ID, --供应商编号 ");
strSql.AppendLine(" g.provider_name, --供应商名称 ");
strSql.AppendLine(" a.GVOLUME --单位体积 ");
strSql.AppendLine(",a.GOODS_MEASURE_ID FROM T_RK_WARE_NOTICE_TAB a left join t_base_goods b ");
strSql.AppendLine(" on a.goods_id = b.goods_id ");
strSql.AppendLine("left join t_base_storageinfo c ");
strSql.AppendLine(" on a.storage_id = c.storage_id ");
strSql.AppendLine("left join t_base_storage_area d ");
strSql.AppendLine(" on a.storage_area_id = d.storage_area_id ");
strSql.AppendLine("left join t_base_pallet e ");
strSql.AppendLine(" on a.package_id = e.pallet_id ");
strSql.AppendLine("left join T_BASE_GOODS_TYPE f ");
strSql.AppendLine(" on a.GOODS_TYPE_ID = f.GOODS_TYPE_ID ");
strSql.AppendLine("left join t_base_provider_dictionary g ");
strSql.AppendLine(" on a.provider_id = g.provider_id ");
strSql.AppendLine("where 1=1 ");
if (!string.IsNullOrEmpty(model.WAREHOUSING_ID) && model.WAREHOUSING_ID != "all")
{
strSql.AppendLine(" and a.WAREHOUSING_ID = '" + model.WAREHOUSING_ID + "' ");
}
if (model.GOODS_ID != "")
{
strSql.AppendLine(" and a.GOODS_ID = '" + model.GOODS_ID + "' ");
}
if (model.STORAGE_ID != "")
{
strSql.AppendLine(" and a.STORAGE_ID = '" + model.STORAGE_ID + "' ");
}
if (!string.IsNullOrEmpty(model.STORAGE_AREA_ID))
{
strSql.AppendLine(" and a.STORAGE_AREA_ID = '" + model.STORAGE_AREA_ID + "' ");
}
if (!string.IsNullOrEmpty(model.PACKAGE_ID))
{
strSql.AppendLine(" and a.PACKAGE_ID = '" + model.PACKAGE_ID + "' ");
}
//strSql.AppendLine(" order by ");
return SystemDataObject.Instance.GetDataTable(strSql.ToString());
}
/// <summary>
/// 插入或修改入库商品清单信息
/// </summary>
/// <param name="WareNoticeTabModel">入库商品清单Model</param>
/// <param name="Flag">操作表示符 0:新增; 1:修改</param>
public void InsertOrUpdateWareNoticeTab(WareNoticeTabModel model, int Flag)
{
StringBuilder strSql;
//新增
if (0 == Flag)
{
//if (model.WAREHOUSING_ID == null)
//{
// strSql = new StringBuilder();
// strSql.AppendLine("insert into T_RK_WARE_NOTICE_TAB(");
// strSql.AppendLine("WAREHOUSING_ID,GOODS_ID,AMOUNT,TOTAL_VOLUME,TOTAL_ROUGH_WEIGHT,TOTAL_NET_WEIGH,TOTAL_MONEY,PRODUCTION_DATE,STORAGE_ID,STORAGE_AREA_ID,PACKAGE_ID,REMARK,operatorid,operatedate,UNIT,PRICE,SCALE_UNIT,GVOLUME)");
// strSql.AppendLine(" values (");
// strSql.AppendLine("SEQ_RK_WARE_NOTICE.currval,:GOODS_ID,:AMOUNT,:TOTAL_VOLUME,:TOTAL_ROUGH_WEIGHT,:TOTAL_NET_WEIGH,:TOTAL_MONEY,:PRODUCTION_DATE,:STORAGE_ID,:STORAGE_AREA_ID,:PACKAGE_ID,:REMARK,:operatorid,getdate(),:UNIT,:PRICE,:SCALE_UNIT,:GVOLUME)");
// OracleParameter[] parameters = {
// //new OracleParameter(":WAREHOUSING_ID",OracleDbType.Varchar2),
// new OracleParameter(":GOODS_ID",OracleDbType.Varchar2),
// new OracleParameter(":AMOUNT", OracleDbType.Decimal),
// new OracleParameter(":TOTAL_VOLUME", OracleDbType.Decimal),
// new OracleParameter(":TOTAL_ROUGH_WEIGHT", OracleDbType.Decimal),
// new OracleParameter(":TOTAL_NET_WEIGH", OracleDbType.Decimal),
// new OracleParameter(":TOTAL_MONEY", OracleDbType.Decimal),
// new OracleParameter(":PRODUCTION_DATE", OracleDbType.Date),
// new OracleParameter(":STORAGE_ID",OracleDbType.Varchar2),
// new OracleParameter(":STORAGE_AREA_ID",OracleDbType.Varchar2),
// new OracleParameter(":PACKAGE_ID",OracleDbType.Varchar2),
// new OracleParameter(":REMARK",OracleDbType.Varchar2),
// new OracleParameter(":operatorid",OracleDbType.Varchar2),
// new OracleParameter(":UNIT",OracleDbType.Varchar2),
// new OracleParameter(":PRICE",OracleDbType.Varchar2),
// new OracleParameter(":SCALE_UNIT",OracleDbType.Varchar2),
// new OracleParameter(":GVOLUME", OracleDbType.Decimal)};
// //parameters[0].Value = model.WAREHOUSING_ID;
// parameters[0].Value = model.GOODS_ID;
// parameters[1].Value = model.AMOUNT;
// parameters[2].Value = model.TOTAL_VOLUME;
// parameters[3].Value = model.TOTAL_ROUGH_WEIGHT;
// parameters[4].Value = model.TOTAL_NET_WEIGH;
// parameters[5].Value = model.TOTAL_MONEY;
// parameters[6].Value = model.PRODUCTION_DATE;
// parameters[7].Value = model.STORAGE_ID;
// parameters[8].Value = model.STORAGE_AREA_ID;
// parameters[9].Value = model.PACKAGE_ID;
// parameters[10].Value = model.REMARK;
// parameters[11].Value = model.OPERATORID;
// parameters[12].Value = model.UNIT;
// parameters[13].Value = model.PRICE;
// parameters[14].Value = model.SCALE_UNIT;
// parameters[15].Value = model.GVOLUME;
// SystemDataObject.Instance.ExecuteSql(strSql.ToString(), parameters);
//}
//else {
//
//
strSql = new StringBuilder();
strSql.AppendLine("insert into T_RK_WARE_NOTICE_TAB(");
strSql.AppendLine("WAREHOUSING_ID,PURCHASE_ID,GOODS_ID,AMOUNT,TOTAL_VOLUME,TOTAL_ROUGH_WEIGHT,TOTAL_NET_WEIGH,TOTAL_MONEY,PRODUCTION_DATE,STORAGE_ID,STORAGE_AREA_ID,PACKAGE_ID,REMARK,operatorid," +
"operatedate,UNIT,PRICE,SCALE_UNIT,GVOLUME,GOODS_TYPE_ID,PROVIDER_ID,PO_HEADER_ID,PO_LINE_ID,LINE_LOCATION_ID,SHIP_TO_ORGANIZATION_CODE,SHIP_TO_ORGANIZATION_ID,LINE_NUM,SHIPMENT_NUM,PO_DISTRIBUTION_ID,DISTRIBUTION_NUM,CONSIGENED_FLAG,GOODS_NAME)");
strSql.AppendLine(" values (");
strSql.AppendLine(":WAREHOUSING_ID,:PURCHASE_ID,:GOODS_ID,:AMOUNT,:TOTAL_VOLUME," +
":TOTAL_ROUGH_WEIGHT,:TOTAL_NET_WEIGH,:TOTAL_MONEY,:PRODUCTION_DATE,:STORAGE_ID," +
":STORAGE_AREA_ID,:PACKAGE_ID,:REMARK,:operatorid,sysdate," +
":UNIT,:PRICE,:SCALE_UNIT,:GVOLUME,:GOODS_TYPE_ID,:PROVIDER_ID,:PO_HEADER_ID,:PO_LINE_ID,:LINE_LOCATION_ID,:SHIP_TO_ORGANIZATION_CODE,:SHIP_TO_ORGANIZATION_ID,:LINE_NUM,:SHIPMENT_NUM,:PO_DISTRIBUTION_ID,:DISTRIBUTION_NUM,:CONSIGENED_FLAG,:GOODS_NAME)");
OracleParameter[] parameters = {
new OracleParameter(":WAREHOUSING_ID",OracleDbType.Varchar2),
new OracleParameter(":PURCHASE_ID",OracleDbType.Varchar2),
new OracleParameter(":GOODS_ID",OracleDbType.Varchar2),
new OracleParameter(":AMOUNT", OracleDbType.Decimal),
new OracleParameter(":TOTAL_VOLUME", OracleDbType.Decimal),
new OracleParameter(":TOTAL_ROUGH_WEIGHT", OracleDbType.Decimal),
new OracleParameter(":TOTAL_NET_WEIGH", OracleDbType.Decimal),
new OracleParameter(":TOTAL_MONEY", OracleDbType.Decimal),
new OracleParameter(":PRODUCTION_DATE", OracleDbType.Date),
new OracleParameter(":STORAGE_ID",OracleDbType.Varchar2),
new OracleParameter(":STORAGE_AREA_ID",OracleDbType.Varchar2),
new OracleParameter(":PACKAGE_ID",OracleDbType.Varchar2),
new OracleParameter(":REMARK",OracleDbType.Varchar2),
new OracleParameter(":operatorid",OracleDbType.Varchar2),
new OracleParameter(":UNIT",OracleDbType.Varchar2),
new OracleParameter(":PRICE",OracleDbType.Varchar2),
new OracleParameter(":SCALE_UNIT",OracleDbType.Varchar2),
new OracleParameter(":GVOLUME", OracleDbType.Decimal),
new OracleParameter(":GOODS_TYPE_ID",OracleDbType.Varchar2),
new OracleParameter(":PROVIDER_ID",OracleDbType.Varchar2),
new OracleParameter(":PO_HEADER_ID",OracleDbType.Int64),
new OracleParameter(":PO_LINE_ID",OracleDbType.Int64),
new OracleParameter(":LINE_LOCATION_ID",OracleDbType.Int64),
new OracleParameter(":SHIP_TO_ORGANIZATION_CODE",OracleDbType.Varchar2),
new OracleParameter(":SHIP_TO_ORGANIZATION_ID",OracleDbType.Int64),
new OracleParameter(":LINE_NUM",OracleDbType.Int64),
new OracleParameter(":SHIPMENT_NUM",OracleDbType.Int64),
new OracleParameter(":PO_DISTRIBUTION_ID",OracleDbType.Int64),
new OracleParameter(":DISTRIBUTION_NUM",OracleDbType.Int64),
new OracleParameter(":CONSIGENED_FLAG",OracleDbType.Varchar2),
new OracleParameter(":GOODS_NAME",OracleDbType.Varchar2)
};
parameters[0].Value = model.WAREHOUSING_ID;
parameters[1].Value = model.PURCHASE_ID;
parameters[2].Value = model.GOODS_ID;
parameters[3].Value = model.AMOUNT;
parameters[4].Value = model.TOTAL_VOLUME;
parameters[5].Value = model.TOTAL_ROUGH_WEIGHT;
parameters[6].Value = model.TOTAL_NET_WEIGH;
parameters[7].Value = model.TOTAL_MONEY;
parameters[8].Value = model.PRODUCTION_DATE;
parameters[9].Value = model.STORAGE_ID;
parameters[10].Value = model.STORAGE_AREA_ID;
parameters[11].Value = model.PACKAGE_ID;
parameters[12].Value = model.REMARK;
parameters[13].Value = model.OPERATORID;
parameters[14].Value = model.UNIT;
parameters[15].Value = model.PRICE;
parameters[16].Value = model.SCALE_UNIT;
parameters[17].Value = model.GVOLUME;
parameters[18].Value = model.GOODS_TYPE_ID;
parameters[19].Value = model.PROVIDER_ID;
parameters[20].Value = model.PO_HEADER_ID;
parameters[21].Value = model.PO_LINE_ID;
parameters[22].Value = model.LINE_LOCATION_ID;
parameters[23].Value = model.SHIP_TO_ORGANIZATION_CODE;
parameters[24].Value = model.SHIP_TO_ORGANIZATION_ID;
parameters[25].Value = model.LINE_NUM;
parameters[26].Value = model.SHIPMENT_NUM;
parameters[27].Value = model.PO_DISTRIBUTION_ID;
parameters[28].Value = model.DISTRIBUTION_NUM;
parameters[29].Value = model.CONSIGENED_FLAG;
parameters[30].Value = model.GOODS_NAME;
SystemDataObject.Instance.ExecuteSql(strSql.ToString(), parameters);
//}
}
//修改
else if (1 == Flag)
{
strSql = new StringBuilder();
strSql.AppendLine("update T_RK_WARE_NOTICE_TAB set ");
strSql.AppendLine("WAREHOUSING_ID=:WAREHOUSING_ID,");
strSql.AppendLine("PURCHASE_ID=:PURCHASE_ID,");
strSql.AppendLine("GOODS_ID=:GOODS_ID,");
strSql.AppendLine("AMOUNT=:AMOUNT,");
strSql.AppendLine("TOTAL_VOLUME=:TOTAL_VOLUME,");
strSql.AppendLine("TOTAL_ROUGH_WEIGHT=:TOTAL_ROUGH_WEIGHT,");
strSql.AppendLine("TOTAL_NET_WEIGH=:TOTAL_NET_WEIGH,");
strSql.AppendLine("TOTAL_MONEY=:TOTAL_MONEY,");
strSql.AppendLine("PRODUCTION_DATE=:PRODUCTION_DATE,");
strSql.AppendLine("STORAGE_ID=:STORAGE_ID,");
strSql.AppendLine("STORAGE_AREA_ID=:STORAGE_AREA_ID,");
strSql.AppendLine("PACKAGE_ID=:PACKAGE_ID,");
strSql.AppendLine("REMARK=:REMARK,");
strSql.AppendLine("operatorid=:operatorid,");
strSql.AppendLine("operatedate=getdate(),");
strSql.AppendLine("unit=:unit,");
strSql.AppendLine("PRICE=:PRICE,");
strSql.AppendLine("SCALE_UNIT=:SCALE_UNIT,");
strSql.AppendLine("GVOLUME=:GVOLUME,");
strSql.AppendLine("PROVIDER_ID=:PROVIDER_ID,");
strSql.AppendLine("GOODS_TYPE_ID=:GOODS_TYPE_ID");
strSql.AppendLine(" where WAREHOUSING_ID=:WAREHOUSING_ID and GOODS_ID=:GOODS_ID ");
OracleParameter[] parameters = {
new OracleParameter(":WAREHOUSING_ID",OracleDbType.Varchar2),
new OracleParameter(":PURCHASE_ID",OracleDbType.Varchar2),
new OracleParameter(":GOODS_ID",OracleDbType.Varchar2),
new OracleParameter(":AMOUNT", OracleDbType.Decimal),
new OracleParameter(":TOTAL_VOLUME", OracleDbType.Decimal),
new OracleParameter(":TOTAL_ROUGH_WEIGHT", OracleDbType.Decimal),
new OracleParameter(":TOTAL_NET_WEIGH", OracleDbType.Decimal),
new OracleParameter(":TOTAL_MONEY", OracleDbType.Decimal),
new OracleParameter(":PRODUCTION_DATE", OracleDbType.Date),
new OracleParameter(":STORAGE_ID",OracleDbType.Varchar2),
new OracleParameter(":STORAGE_AREA_ID",OracleDbType.Varchar2),
new OracleParameter(":PACKAGE_ID",OracleDbType.Varchar2),
new OracleParameter(":REMARK",OracleDbType.Varchar2),
new OracleParameter(":operatorid",OracleDbType.Varchar2),
new OracleParameter(":UNIT",OracleDbType.Varchar2),
new OracleParameter(":PRICE",OracleDbType.Varchar2),
new OracleParameter(":SCALE_UNIT",OracleDbType.Varchar2),
new OracleParameter(":GVOLUME", OracleDbType.Decimal),
new OracleParameter(":PROVIDER_ID",OracleDbType.Varchar2),
new OracleParameter(":GOODS_TYPE_ID",OracleDbType.Varchar2)};
parameters[0].Value = model.WAREHOUSING_ID;
parameters[1].Value = model.PURCHASE_ID;
parameters[2].Value = model.GOODS_ID;
parameters[3].Value = model.AMOUNT;
parameters[4].Value = model.TOTAL_VOLUME;
parameters[5].Value = model.TOTAL_ROUGH_WEIGHT;
parameters[6].Value = model.TOTAL_NET_WEIGH;
parameters[7].Value = model.TOTAL_MONEY;
parameters[8].Value = model.PRODUCTION_DATE;
parameters[9].Value = model.STORAGE_ID;
parameters[10].Value = model.STORAGE_AREA_ID;
parameters[11].Value = model.PACKAGE_ID;
parameters[12].Value = model.REMARK;
parameters[13].Value = model.OPERATORID;
parameters[14].Value = model.UNIT;
parameters[15].Value = model.PRICE;
parameters[16].Value = model.SCALE_UNIT;
parameters[17].Value = model.GVOLUME;
parameters[18].Value = model.PROVIDER_ID;
parameters[19].Value = model.GOODS_TYPE_ID;
SystemDataObject.Instance.ExecuteSql(strSql.ToString(), parameters);
}
}
/// <summary>
/// 向备份表中添加入库商品清单
/// </summary>
/// <param name="WareNoticeID">入库通知单编号</param>
public void InsertWareNoticeTabBack(string WareNoticeID)
{
string strSql = "insert into T_RK_WARE_NOTICE_TAB_BACK select * from T_RK_WARE_NOTICE_TAB where WAREHOUSING_ID =:WAREHOUSING_ID";
OracleParameter[] parameters = {
new OracleParameter(":WAREHOUSING_ID",OracleDbType.Varchar2)};
parameters[0].Value = WareNoticeID;
SystemDataObject.Instance.ExecuteSql(strSql.ToString(), parameters);
}
/// <summary>
/// 根据入库通知单查询任务
/// </summary>
/// <param name="wareID"></param>
/// <returns></returns>
public DataTable GetWareNoticeCt(string wareID)
{
string sqlStr =@" select count(*) a from T_RK_BOXCODE where STS='0'
and WAREHOUSING_ID = '" + wareID + "'";
return SystemDataObject.Instance.GetDataTable(sqlStr);
}
/// <summary>
/// 删除入库商品清单信息
/// </summary>
/// <param name="WareNoticeTabModel">入库商品清单Model</param>
public void DeleteWareNoticeTab(WareNoticeTabModel model)
{
StringBuilder strSql = new StringBuilder();
strSql.AppendLine("delete from T_RK_WARE_NOTICE_TAB ");
strSql.AppendLine(" where WAREHOUSING_ID=:WAREHOUSING_ID ");
if (!string.IsNullOrEmpty(model.GOODS_ID))
{
strSql.AppendLine("and GOODS_ID=:GOODS_ID ");
}
OracleParameter[] parameters = {
new OracleParameter(":WAREHOUSING_ID",OracleDbType.Varchar2),
new OracleParameter(":GOODS_ID",OracleDbType.Varchar2)
};
parameters[0].Value = model.WAREHOUSING_ID;
parameters[1].Value = model.GOODS_ID;
SystemDataObject.Instance.ExecuteSql(strSql.ToString(), parameters);
}
/// <summary>
/// 通过入库通知单编号集合查出入库商品清单信息的集合
/// </summary>
/// <param name="strListID">类似于(1,2,3,4)</param>
/// <returns></returns>
public DataTable GetWareNoticeTabByList(string strListID)
{
StringBuilder strSql = new StringBuilder();
strSql.AppendLine("select ");
strSql.AppendLine(" a.WAREHOUSING_ID, --入库通知单编号 ");
strSql.AppendLine(" a.PURCHASE_ID, --采购单号 ");
strSql.AppendLine(" a.GOODS_ID, --商品编号 ");
strSql.AppendLine(" b.goods_name, ");
strSql.AppendLine(" a.GOODS_TYPE_ID, --商品分类 ");
strSql.AppendLine(" f.GOODS_TYPE_NAME, --商品分类 ");
strSql.AppendLine(" ISNULL(a.AMOUNT,0) AMOUNT, --数量 ");
strSql.AppendLine(" ISNULL(a.TOTAL_VOLUME,0) TOTAL_VOLUME, --总体积 ");
strSql.AppendLine(" ISNULL(a.TOTAL_ROUGH_WEIGHT,0) TOTAL_ROUGH_WEIGHT, --总毛重 ");
strSql.AppendLine(" ISNULL(a.TOTAL_NET_WEIGH,0) TOTAL_NET_WEIGH, --总净重 ");
strSql.AppendLine(" ISNULL(a.TOTAL_MONEY,0) TOTAL_MONEY, --总金额 ");
strSql.AppendLine(" a.PRODUCTION_DATE, --生产日期 ");
strSql.AppendLine(" a.STORAGE_ID, --入库仓库编号 ");
strSql.AppendLine(" c.storage_name, ");
strSql.AppendLine(" a.STORAGE_AREA_ID, --入库库区编号 ");
strSql.AppendLine(" d.storage_area_name, ");
strSql.AppendLine(" a.PACKAGE_ID, --容器编号 ");
strSql.AppendLine(" e.pallet_name package_name, ");
strSql.AppendLine(" a.REMARK, --备注 ");
strSql.AppendLine(" a.operatorid, --操作人 ");
strSql.AppendLine(" a.operatedate, --操作日期 ");
strSql.AppendLine(" a.UNIT, x.VC_DICTIONARY_NAME as UNIT_NAME, --单位 ");
strSql.AppendLine(" ISNULL(a.PRICE,0) PRICE, --标准价格 ");
strSql.AppendLine(" a.SCALE_UNIT, --重量单位 ");
strSql.AppendLine(" a.PROVIDER_ID, --供应商编号 ");
strSql.AppendLine(" g.provider_name, --供应商名称 ");
strSql.AppendLine(" ISNULL(a.GVOLUME,0) GVOLUME ,a.GOODSVOLUME,a.BOXCT,a.PrintSts,a.PrintCS ,a.GOODS_MEASURE_ID --单位体积 ");
strSql.AppendLine("FROM T_RK_WARE_NOTICE_TAB a left join t_base_goods b ");
strSql.AppendLine(" on a.goods_id = b.goods_id ");
strSql.AppendLine("left join t_base_storageinfo c ");
strSql.AppendLine(" on a.storage_id = c.storage_id ");
strSql.AppendLine("left join t_base_storage_area d ");
strSql.AppendLine(" on a.storage_area_id = d.storage_area_id ");
strSql.AppendLine("left join t_base_pallet e ");
strSql.AppendLine(" on a.package_id = e.pallet_id ");
strSql.AppendLine("left join T_BASE_GOODS_TYPE f ");
strSql.AppendLine(" on a.GOODS_TYPE_ID = f.GOODS_TYPE_ID ");
strSql.AppendLine("left join t_base_provider_dictionary g ");
strSql.AppendLine(" on a.provider_id = g.provider_id ");
strSql.AppendLine("left join T_SYS_DICTIONARY_TAB x on x.VC_CHAR_VALUE=a.UNIT and x.VC_DICTIONARY_TYPE='vc_uom' ");
strSql.AppendLine("where 1=1 ");
strSql.AppendLine(" and WAREHOUSING_ID ='" + strListID + "'");
string ss = "select* from T_RK_WARE_NOTICE_TAB t where t.warehousing_id = '"+ strListID + "'";
return SystemDataObject.Instance.GetDataTable(ss.ToString());
}
/// <summary>
/// 获取打印箱子的数据
/// </summary>
/// <param name="barcode"></param>
/// <returns></returns>
public DataTable GetPrintBoxData(string barcode)
{
string sqlStr = " select count(*) a from T_RK_BOXCODE where BARCODE='"+barcode+"'";
return SystemDataObject.Instance.GetDataTable(sqlStr);
}
/// <summary>
/// 收货时打印箱码
/// </summary>
/// <param name="data"></param>
public void AddPrintBoxData(BoxCodeModel data)
{
string sqlstr = " insert into T_RK_BOXCODE(WAREHOUSING_ID,GOODS_ID,BARCODE,BOXNUM,GOODS_MEASURE_ID,UNIT,OperatorID)values" +
"('" + data.WAREHOUSING_ID + "','" + data.GOODS_ID + "','" + data.BARCODE + "'," +
"'" + data.BOXNUM + "','" + data.GOODS_MEASURE_ID + "','" + data.UNIT + "','" + data.OperatorID + "')";
SystemDataObject.Instance.ExecuteSql(sqlstr);
}
/// <summary>
/// 删除单据任务
/// </summary>
/// <param name="data"></param>
public void DelPrintBoxData(string warId,string goodsId)
{
string sqlStr = " delete T_RK_BOXCODE where WAREHOUSING_ID='"+ warId + "' and GOODS_ID='"+ goodsId + "'";
SystemDataObject.Instance.ExecuteSql(sqlStr);
}
/// <summary>
/// 查询入库箱码
/// </summary>
/// <param name="orderId"></param>
/// <param name="gooidsId"></param>
/// <returns></returns>
public DataTable GetPrintBoxData(string orderId,string gooidsId)
{
string sqlstr = "select * from [dbo].[T_RK_BOXCODE] where WAREHOUSING_ID='"+ orderId + "'and GOODS_ID = '"+ gooidsId + "'";
return SystemDataObject.Instance.GetDataTable(sqlstr);
}
/// <summary>
/// 更新入库状态
/// </summary>
/// <param name="orderId"></param>
/// <returns></returns>
public void UpBoxCodeSts(string orderId,string barcode)
{
string sqlstr = " update T_RK_BOXCODE set STS='1' where WAREHOUSING_ID='"+orderId+ "' and BARCODE='" + barcode + "' ";
SystemDataObject.Instance.ExecuteSql(sqlstr);
}
}
}