BaoKai_202508_Wms_Jingwang_.../WMS.SqlServerData/RKData/CodeDiskData.cs
2025-08-24 21:52:42 +08:00

233 lines
12 KiB
C#
Raw Permalink Blame History

This file contains invisible Unicode characters

This file contains invisible Unicode characters that are indistinguishable to humans but may be processed differently by a computer. If you think that this is intentional, you can safely ignore this warning. Use the Escape button to reveal them.

This file contains Unicode characters that might be confused with other characters. If you think that this is intentional, you can safely ignore this warning. Use the Escape button to reveal them.

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using WMS.IData.IRK;
using System.Data;
using WMS.Model.RK;
using WMS.IData;using Oracle.ManagedDataAccess.Client;
namespace WMS.SqlServerData.RKData
{
class CodeDiskData : ICodeDisk
{
#region
/// <summary>
/// 获取码盘信息
/// </summary>
/// <param name="model"></param>
/// <returns></returns>
public DataTable GetCodeDisk(CodeDiskModel model)
{
string sql = "";
#region SQL
sql +=@" select a.WAREHOUSING_ID, --通知单编号
a.STORAGE_AREA_ID, --库区编号
d.storage_area_name Storage_area_name, --库区名称
a.LOCATION_ID, --库位编号
a.Pallet_ID,  --商品编号
b.goods_name Goods_name, --商品名称
a.GOODS_ID, --备注
a.UNIT, --UNIT
a.GOODS_NUM, --商品数量
a.PRODUCTION_DATE, --生产日期
a.TOTAL_VOLUME, --总体积
a.TOTAL_ROUGH_WEIGHT, --总毛重
a.TOTAL_NET_WEIGH, --总净重
a.SCALE_UNIT, --重量UNIT
a.TOTAL_MONEY, --总金额
a.CODEDISK_PER, --码盘人
e.name Codedisk_per_name,--码盘人名称
a.CODEDISK_DATE, --码盘时间
a.REMARK, --备注
a.VERSION, --版本
a.OPERATORID, --操作人
a.OPERATEDATE, --操作日期
a.GVOLUME, --UNIT体积
a.GOODS_TYPEID, --商品类别
f.GOODS_TYPE_NAME goods_type_name, --商品类别名称
a.PRICE, --标准金额
a.LOT_ID ,a.PROVIDER_ID,a.ProDucLotId,--
a.BARCODE,a.STORAGE_ID,m.AUTOSTS,a.ConveyorID
from T_RK_CODEDISK a
left join t_base_storage_area d on a.STORAGE_AREA_ID = d.storage_area_id
left join t_base_goods b on a.GOODS_ID = b.goods_id
left join t_base_userinfo e on a.CODEDISK_PER = e.user_id
left join T_BASE_GOODS_TYPE f on a.GOODS_TYPEID = f.GOODS_TYPE_ID
left join T_BASE_STORAGEINFO m on m.STORAGE_ID=a.STORAGE_ID
where 1 = 1 ";
if (!string.IsNullOrEmpty(model.STORAGE_ID))
{
sql += " and a.STORAGE_ID='" + model.STORAGE_ID + "'";
}
if (!string.IsNullOrEmpty(model.Warehousing_id))
{
sql += " and WAREHOUSING_ID='" + model.Warehousing_id + "'";
}
if (!string.IsNullOrEmpty(model.Goods_id))
{
sql += " and GOODS_ID = '" + model.Goods_id + "'";
}
if (!string.IsNullOrEmpty(model.LOCATION_ID))
{
sql += " and LOCATION_ID = '" + model.LOCATION_ID + "'";
}
if(!string.IsNullOrEmpty(model.Storage_area_id))
{
sql += " and a.Storage_area_id='"+model.Storage_area_id+"'";
}
if (!string.IsNullOrEmpty(model.LOT_ID))
{
sql += " and a.LOT_ID='" + model.LOT_ID + "'";
}
sql += " and sts = '0'";
sql += " order by a.GOODS_TYPEID,a.Pallet_ID,OPERATEDATE desc";
#endregion
return SystemDataObject.Instance.GetDataTable(sql.ToString());
}
#endregion
#region
public void AddZpData(CodeDiskModel list_model)
{
string sql =@"insert into T_RK_CODEDISK(
WAREHOUSING_ID, --通知单编号
STORAGE_AREA_ID, --库区编号
LOCATION_ID, --库位编号
Pallet_ID,  --商品编号
GOODS_ID, --备注
UNIT, --UNIT
GOODS_NUM, --商品数量
TOTAL_VOLUME, --总体积
TOTAL_ROUGH_WEIGHT, --总毛重
TOTAL_NET_WEIGH, --总净重
TOTAL_MONEY, --总金额
CODEDISK_PER, --码盘人
REMARK, --备注
PRODUCTION_DATE, --生产日期
OPERATORID, --操作人
GVOLUME, --UNIT体积
SCALE_UNIT, --重量UNIT
PRICE , --标准金额
LOT_ID,STORAGE_ID,ConveyorID,PROVIDER_ID,ProDucLotId
) values
('" + list_model.Warehousing_id + "'," +
"'" + list_model.Storage_area_id + "'," +
"'" + list_model.LOCATION_ID + "'," +
"'" + list_model.Pallet_id + "'," +
"'" + list_model.Goods_id + "'," +
"'" + list_model.Unit + "' , " +
"'" + list_model.Goods_Num + "' ," +
"'" + list_model.Total_volume + "' , " +
"'" + list_model.Total_rough_weight + "' ," +
"'" + list_model.Total_net_weigh + "' , " +
"'" + list_model.Total_money + "', " +
"'" + list_model.Codedisk_per + "'," +
"'" + list_model.Remark + "'," +
"'" + list_model.Production_date + "'," +
"'" + list_model.OperatorID + "'," +
"'" + list_model.Gvolume + "'," +
"'" + list_model.Scale_unit + "'," +
"'" + list_model.Price + "','"+ list_model.LOT_ID + "'," +
"'" + list_model.STORAGE_ID + "','"+list_model.ConveyorID+"',"+
"'"+ list_model .PROVIDER_ID+ "','"+ list_model .ProDucLotId+ "')";
SystemDataObject.Instance.ExecuteSql(sql);
}
/// <summary>
/// 新增或修改码盘
/// </summary>
/// <param name="model"></param>
/// <param name="flg">0 新增1 修改</param>
/// <returns></returns>
public void ExecCodeDIskUpdate(CodeDiskModel list_model)
{
#region SQL
string sql =@"update T_RK_CODEDISK set STORAGE_AREA_ID =:STORAGE_AREA_ID, --库区编号
LOCATION_ID=:LOCATION_ID, --库位编号
Pallet_ID=:Pallet_ID, --商品编号
GOODS_ID=:GOODS_ID, --备注
UNIT=:UNIT, --UNIT
GOODS_NUM=:GOODS_NUM, --商品数量
TOTAL_VOLUME=:TOTAL_VOLUME, --总体积
TOTAL_ROUGH_WEIGHT=:TOTAL_ROUGH_WEIGHT, --总毛重
TOTAL_NET_WEIGH=:TOTAL_NET_WEIGH, --总净重
TOTAL_MONEY=:TOTAL_MONEY, --总金额
CODEDISK_PER=:CODEDISK_PER, --码盘人
CODEDISK_DATE=:CODEDISK_DATE, --码盘时间
REMARK=:REMARK, --备注
VERSION=:VERSION, --版本
PRODUCTION_DATE=:PRODUCTION_DATE, --生产日期
OPERATORID=:OPERATORID, --操作人
OPERATEDATE=:OPERATEDATE, --操作日期
GVOLUME=:GVOLUM, --UNIT体积
GOODS_TYPEID =:GOODS_TYPEID, --商品类别
SCALE_UNIT =:SCALE_UNIT, --重量UNIT
price =:PRICE,
ConveyorID=:ConveyorID
from T_RK_CODEDISK
where WAREHOUSING_ID = :WAREHOUSING_ID --通知单编号 ";
#endregion
SystemDataObject.Instance.ExecuteSql(sql);
}
#endregion
#region
public void DelCiskCtlGoodsId(string ctl,string orderId,string goodsId)
{
string sqlStr = "delete T_RK_CODEDISK where PALLET_ID ='" + ctl + "' and GOODS_ID='"+goodsId+"'" +
" and WAREHOUSING_ID='"+orderId+"' ";
SystemDataObject.Instance.ExecuteSql(sqlStr);
}
public void DelCiskCtl(string ctl)
{
string sqlStr = "delete T_RK_CODEDISK where PALLET_ID ='"+ctl+"' ";
SystemDataObject.Instance.ExecuteSql(sqlStr);
}
/// <summary>
/// 删除码盘
/// </summary>
/// <param name="model"></param>
/// <returns></returns>
public int DelCodeDisk(CodeDiskModel model)
{
string sql = "";
int resut = 0;
#region SQL
sql += "delete from T_RK_CODEDISK where WAREHOUSING_ID=:WAREHOUSING_ID";
OracleParameter[] parameter = new OracleParameter[] {
new OracleParameter(":WAREHOUSING_ID",OracleDbType.Varchar2)};
parameter[0].Value = model.Warehousing_id;
#endregion
resut = SystemDataObject.Instance.ExecuteSqlCommit(sql, parameter);
return resut;
}
public void UpdateDiskPallet(string ctl,string newctl)
{
string sqlStr =@" update T_RK_CODEDISK set PALLET_ID ='"+newctl+"'where PALLET_ID='"+ ctl + "'";
SystemDataObject.Instance.ExecuteSql(sqlStr);
}
#endregion
}
}