using NFine.Data.Extensions;
using System;
using System.Data;
using NFine.Code;
using NFine.Repository;
using NFine.Domain._03_Entity.SRM;
using System.Data.SqlClient;
namespace NFine.Application.WMS
{
public class HomeWorkApp : RepositoryFactory<ICSVendor>
{
public string SetData_PR(String savePath, string Year)
{
//数据获取
try
{
string WorkPoint = NFine.Code.OperatorProvider.Provider.GetCurrent().Location;
string MUSER = NFine.Code.OperatorProvider.Provider.GetCurrent().UserCode;
string MUSERNAME = NFine.Code.OperatorProvider.Provider.GetCurrent().UserName;
SqlConnection conn = SqlHelper.GetDataCenterConn();
DataTable data = FileToExcel.ExcelToTable(savePath);
int index = 1;
int countLot = 1;
string msg = "";
string StorageCode = "";
DateTime time = DateTime.Now;
string Tday = time.ToString("yyyyMMdd");
string sql = string.Empty;
sql = string.Format(@"select InvCode FROM dbo.ICSInventory where WorkPoint ='{0}' ", WorkPoint);
sql += string.Format(@"select LocationCode ,WarehouseCode FROM dbo.ICSLocation a
inner join ICSWarehouse b on a.WHID=b.ID and a.WorkPoint=b.WorkPoint where b.Enable='1' and a.WorkPoint ='{0}' ", WorkPoint);
sql += string.Format(@"SELECT MAX(A.LotNO) AS LOTNO FROM ICSInventoryLot A WHERE A.LotNO LIKE '{0}%' and A.WorkPoint='{1}' AND LEN(a.LotNO) = 13", Tday, WorkPoint);
sql += string.Format(@"SELECT top 0 ID,LotNo,InvCode,ProductDate,ExpirationDate,Quantity,Amount,ExtensionID,Type,PrintTimes,LastPrintUser,LastPrintTime,MUSER,MUSERName,MTIME,WorkPoint,EATTRIBUTE1 FROM ICSInventoryLot ");
sql += string.Format(@"SELECT top 0 ID,LotNo,WarehouseCode,LocationCode,InvCode,Quantity,InDate,LockQuantity,MUSER,MUSERName,MTIME,WorkPoint,EATTRIBUTE1 FROM ICSWareHouseLotInfo ");
sql += string.Format(@"SELECT top 0 ID, Identification, TransCode, TransSequence, LotNo, InvCode, FromWarehouseCode, FromLocationCode, ToWarehouseCode, ToLocationCode, Quantity, Memo, Lock, TransType, BusinessCode, ERPUpload, ERPID, ERPDetailID, ERPCode, ERPSequence, LogID, MergeID, MUSER, MUSERName, MTIME, WorkPoint, EATTRIBUTE1, EATTRIBUTE2, EATTRIBUTE3 FROM dbo.ICSWareHouseLotInfoLog ");
sql += string.Format(@"SELECT ID,Colspan,ProjectCode,BatchCode,Version,Brand,cFree1,cFree2,cFree3,cFree4,cFree5,cFree6,cFree7,cFree8,cFree9,cFree10,MTIME,MUSER,MUSERName,WorkPoint,EATTRIBUTE1,EATTRIBUTE2,EATTRIBUTE3,EATTRIBUTE4,EATTRIBUTE5 FROM ICSExtension where WorkPoint='{0}' ", WorkPoint);
sql += string.Format(@"SELECT top 0 LotNo,TransCode,TransSequence,MUSER,MUSERName,MTIME,WorkPoint,EATTRIBUTE1 FROM ICSInventoryLotDetail");
DataSet ds = SqlHelper.GetDataSetBySql(sql);
DataSet dsSave = new DataSet();
dsSave.Tables.Add(ds.Tables[3].Copy());
dsSave.Tables.Add( ds.Tables[4].Copy());
dsSave.Tables.Add( ds.Tables[5].Copy());
dsSave.Tables.Add(ds.Tables[6].Clone());
dsSave.Tables.Add(ds.Tables[7].Copy());
dsSave.Tables[0].TableName="ICSInventoryLot";
dsSave.Tables[1].TableName = "ICSWareHouseLotInfo";
dsSave.Tables[2].TableName = "ICSWareHouseLotInfoLog";
dsSave.Tables[3].TableName = "ICSExtension";
dsSave.Tables[4].TableName = "ICSInventoryLotDetail";
string LotNO = "";
Int64 Lot_NO = 0;
DataTable dts = ds.Tables[2];
if (dts != null && dts.Rows.Count > 0)
{
string lot = dts.Rows[0]["LOTNO"].ToString();
if(!string.IsNullOrWhiteSpace(lot))
Lot_NO = Convert.ToInt64(lot.Substring(lot.Length - 5));
}
if (data != null && data.Rows.Count > 0)
{
foreach (DataRow dr in data.Rows)
{
index++;
string ItemCode = dr["物料编码"].ToString();
string StackCode = dr["库位"].ToString();
string Date = dr["入库日期"].ToString();
string VENCODE = dr["供应商"].ToString();
string originalCode = dr["原条码"].ToString();
decimal Amount = 0;
if (data.Columns.Contains("辅计量数量"))
{
Amount = string.IsNullOrWhiteSpace(dr["辅计量数量"].ToString())?0:Convert.ToDecimal(dr["辅计量数量"].ToString());
}
string ProjectCode = string.Empty;
string BatchCode = string.Empty;
string Version = string.Empty;
string Brand = string.Empty;
string cFree1 = string.Empty;
string cFree2 = string.Empty;
string cFree3 = string.Empty;
string cFree4 = string.Empty;
string cFree5 = string.Empty;
string cFree6 = string.Empty;
string cFree7 = string.Empty;
string cFree8 = string.Empty;
string cFree9 = string.Empty;
string cFree10 = string.Empty;
if (data.Columns.Contains("销售凭证"))
{
ProjectCode = dr["销售凭证"].ToString();
}
if (data.Columns.Contains("序列号"))
{
BatchCode= dr["序列号"].ToString();
}
if (data.Columns.Contains("版本"))
{
Version = dr["版本"].ToString();
}
if (data.Columns.Contains("销售凭证项号"))
{
Brand = dr["销售凭证项号"].ToString();
}
if (data.Columns.Contains("自由项1"))
{
cFree1 = dr["自由项1"].ToString();
}
if (data.Columns.Contains("自由项2"))
{
cFree2 = dr["自由项2"].ToString();
}
if (data.Columns.Contains("自由项3"))
{
cFree3 = dr["自由项3"].ToString();
}
if (data.Columns.Contains("自由项4"))
{
cFree4 = dr["自由项4"].ToString();
}
if (data.Columns.Contains("自由项5"))
{
cFree5 = dr["自由项5"].ToString();
}
if (data.Columns.Contains("自由项6"))
{
cFree6 = dr["自由项6"].ToString();
}
if (data.Columns.Contains("自由项7"))
{
cFree7 = dr["自由项7"].ToString();
}
if (data.Columns.Contains("自由项8"))
{
cFree8 = dr["自由项8"].ToString();
}
if (data.Columns.Contains("自由项9"))
{
cFree9 = dr["自由项9"].ToString();
}
if (data.Columns.Contains("自由项10"))
{
cFree10 = dr["自由项10"].ToString();
}
string Colspan = ProjectCode + "~" + BatchCode + "~" + Version + "~" + Brand + "~" + cFree1 + "~" + cFree2 + "~" + cFree3 + "~" + cFree4 + "~" + cFree5 + "~" + cFree6 + "~" + cFree7 + "~" + cFree8 + "~" + cFree9 + "~" + cFree10;
DateTime dataTime;
if (Date == "")
{
dataTime = DateTime.Now;
}
else
{
dataTime = Convert.ToDateTime(Date);
}
decimal QTY = 0;
bool result = decimal.TryParse(dr["库位数量或最小包装数量"].ToString(), out QTY);
if (!result)
{
throw new Exception("第 " + index + " 行，库位数量或最小包装数量:" + dr["库位数量或最小包装数量"].ToString() + " 格式不正确！");
}
if (decimal.Parse(dr["库位数量或最小包装数量"].ToString()) < 0)
{
throw new Exception("第 " + index + " 行，库位数量或最小包装数量:" + dr["库位数量或最小包装数量"].ToString() + " 数量不正确，为负值！");
}
int count = 0;
bool resultCount = int.TryParse(dr["整盘数"].ToString(), out count);
if (!resultCount)
{
throw new Exception("第 " + index + " 行，整盘数:" + dr["整盘数"].ToString() + " 格式不正确！");
}
var itemdrs = ds.Tables[0].Select(string.Format("InvCode='{0}'", ItemCode));
if (itemdrs == null || itemdrs.Length <= 0)
{
throw new Exception("第 " + index + " 行，物料编码:" + ItemCode + " 不存在！");
}
var itemdrs2 = ds.Tables[1].Select(string.Format("LocationCode='{0}'", StackCode));
if (itemdrs2 == null || itemdrs2.Length <= 0)
{
throw new Exception("第 " + index + " 行，库位:" + StackCode + " 不存在！");
}
else
{
StorageCode = itemdrs2[0]["WarehouseCode"].ToString();
}
var ID = "";
var Extension = ds.Tables[6].Select(string.Format("Colspan='{0}'", Colspan));
if (Extension == null || Extension.Length <= 0)
{
DataRow drExtension = dsSave.Tables[3].NewRow();
ID = GetNewid();
drExtension["ID"] = ID;
drExtension["Colspan"] = Colspan;
drExtension["ProjectCode"] = ProjectCode;
drExtension["BatchCode"] = BatchCode;
drExtension["Version"] = Version;
drExtension["Brand"] = Brand;
drExtension["cFree1"] = cFree1;
drExtension["cFree2"] = cFree2;
drExtension["cFree3"] = cFree3;
drExtension["cFree4"] = cFree4;
drExtension["cFree5"] = cFree5;
drExtension["cFree6"] = cFree6;
drExtension["cFree7"] = cFree7;
drExtension["cFree8"] = cFree8;
drExtension["cFree9"] = cFree9;
drExtension["cFree10"] = cFree10;
drExtension["MUSER"] = MUSER;
drExtension["MUSERName"] = MUSERNAME;
drExtension["MTIME"] = DateTime.Now;
drExtension["WorkPoint"] = WorkPoint;
dsSave.Tables[3].Rows.Add(drExtension);
DataRow drNew = ds.Tables[6].NewRow();
drNew.ItemArray = drExtension.ItemArray;
ds.Tables[6].Rows.Add(drNew);
}
else
{
ID = Extension[0]["ID"].ToString();
}
var Quantity= Convert.ToDecimal(dr["库位数量或最小包装数量"].ToString());
var logID = GetNewid();
for (int i = count; i > 0; i--)
{
if (originalCode != null&& originalCode!="")
{
LotNO = originalCode.ToString();
}
else
{
LotNO = Tday + (Lot_NO + countLot++).ToString().PadLeft(5, '0');
}
#region 条码
DataRow drInventory = dsSave.Tables[0].NewRow();
drInventory["ID"] = GetNewid();
drInventory["LotNo"] = LotNO;
drInventory["InvCode"] = ItemCode;
drInventory["ProductDate"] = dataTime;
drInventory["ExpirationDate"] = Convert.ToDateTime("2999-12-31");
drInventory["Quantity"] = Quantity;
drInventory["Amount"] = Amount;
drInventory["Type"] = "0";
drInventory["ExtensionID"] = ID;
drInventory["MUSER"] = MUSER;
drInventory["MUSERName"] = MUSERNAME;
drInventory["MTIME"] = DateTime.Now;
drInventory["WorkPoint"] = WorkPoint;
dsSave.Tables[0].Rows.Add(drInventory);
#endregion
#region 条码关联单据
DataRow drInventoryLotDetail = dsSave.Tables[4].NewRow();
drInventoryLotDetail["LotNo"] = LotNO;
drInventoryLotDetail["TransCode"] = "";
drInventoryLotDetail["TransSequence"] = "";
drInventoryLotDetail["MUSER"] = MUSER;
drInventoryLotDetail["MUSERName"] = MUSERNAME;
drInventoryLotDetail["MTIME"] = DateTime.Now;
drInventoryLotDetail["WorkPoint"] = WorkPoint;
dsSave.Tables[4].Rows.Add(drInventoryLotDetail);
#endregion
#region 库存
DataRow drHouseInfo = dsSave.Tables[1].NewRow();
drHouseInfo["ID"] = GetNewid();
drHouseInfo["LotNo"] = LotNO;
drHouseInfo["WarehouseCode"] = StorageCode;
drHouseInfo["LocationCode"] = StackCode;
drHouseInfo["InvCode"] = ItemCode;
drHouseInfo["Quantity"] = Quantity;
drHouseInfo["InDate"] = dataTime;
drHouseInfo["LockQuantity"] = 0;
drHouseInfo["MUSER"] = MUSER;
drHouseInfo["MUSERName"] = MUSERNAME;
drHouseInfo["MTIME"] = DateTime.Now;
drHouseInfo["WorkPoint"] = WorkPoint;
dsSave.Tables[1].Rows.Add(drHouseInfo);
#endregion
#region 记录表
DataRow drHouseLog = dsSave.Tables[2].NewRow();
drHouseLog["ID"] = GetNewid();
drHouseLog["Identification"] = logID;
drHouseLog["LotNo"] = LotNO;
drHouseLog["InvCode"] = ItemCode;
drHouseLog["ToWarehouseCode"] = StorageCode;
drHouseLog["ToLocationCode"] = StackCode;
drHouseLog["Quantity"] = Quantity;
drHouseLog["Lock"] = 0;
drHouseLog["TransType"] = "1";
drHouseLog["BusinessCode"] = "39";
drHouseLog["ERPUpload"] = 0;
drHouseLog["MUSER"] = MUSER;
drHouseLog["MUSERName"] = MUSERNAME;
drHouseLog["MTIME"] = DateTime.Now;
drHouseLog["WorkPoint"] = WorkPoint;
dsSave.Tables[2].Rows.Add(drHouseLog);
#endregion
}
}
SqlHelper.ExecuteDataSet(dsSave);
}
else
{
return "无有效的导入数据。";
}
return "true";
}
catch (Exception ex)
{
return ex.Message;
}
}
public string GetNewid()
{
string sql = "select newid() AS ID";
return Repository().FindTableBySql(sql, null).Rows[0]["ID"].ToString();
}
}
}