junjie.wang
/
Estsh-Yiri
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity
You cannot select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
master
Branches Tags
${ item.name }
Create tag ${ searchTerm }
Create branch ${ searchTerm }
from 'master'
${ noResults }
Estsh-Yiri/Estsh.Core.Wms/Repositories/SemiFinishInStockRepository.cs

639 lines
37 KiB
C#
Raw Permalink Blame History

using Dapper;
using Estsh.Core.Base;
using Estsh.Core.Dapper;
using Estsh.Core.Wms.IRepositories;
using Estsh.Core.Model.Result;
using Estsh.Core.Repositories;
using System.Collections;
using System.Data;
using System.Text;
using System.Security.Cryptography;
using System.Text.Json;
using Estsh.Core.Models;
using Newtonsoft.Json.Linq;
using Estsh.Core.Model.EnumUtil;
namespace Estsh.Core.Wms.Repositories
{
public class SemiFinishInStockRepository : BaseRepository<BaseEntity>, ISemiFinishInStockRepository
{
public SemiFinishInStockRepository(DapperDbContext _dapperDbContext) : base(_dapperDbContext)
{
}
public List<WmsRack> GetRackNo(string RKNO)
{
using (IDbConnection dbConn = dapperDbContext.GetDbConnection())
{
dbConn.Open();
string result = string.Empty;
StringBuilder sql = new StringBuilder(1024);
sql.Append("select * from wms_rack (nolock) where rack_no=@rack_no ");
DynamicParameters parameters = new DynamicParameters();
parameters.Add("@rack_no", RKNO);
return dbConn.Query<WmsRack>(sql.ToString(), parameters).ToList();
}
}
public List<SysStock> CheckCartonNoStatus(string cartonNo)
{
using (IDbConnection dbConn = dapperDbContext.GetDbConnection())
{
dbConn.Open();
string result = string.Empty;
StringBuilder sql = new StringBuilder(1024);
sql.Append("select a.*,b.rack_part,b.part_package from sys_stock as a (nolock) left join wms_rack_part_package as b (nolock) on a.part_no=b.rack_part where carton_no=@carton_no and a.enabled='Y'");
DynamicParameters parameters = new DynamicParameters();
parameters.Add("@carton_no", cartonNo);
return dbConn.Query<SysStock>(sql.ToString(), parameters).ToList();
}
}
public List<SysStock> CheckRKNoStatus(string RKNo)
{
using (IDbConnection dbConn = dapperDbContext.GetDbConnection())
{
dbConn.Open();
string result = string.Empty;
StringBuilder sql = new StringBuilder(1024);
sql.Append("select a.* from sys_stock as a (nolock) left join wms_rack_package as b (nolock) on a.carton_no = b.rack_no left join sys_stock as c (nolock) on b.carton_no = c.carton_no where a.carton_no = @carton_no and a.enabled = 'Y' and b.enabled = 'Y' and c.enabled='Y'");
DynamicParameters parameters = new DynamicParameters();
parameters.Add("@carton_no", RKNo);
return dbConn.Query<SysStock>(sql.ToString(), parameters).ToList();
}
}
public List<SysStock> CheckCartonNoByRackNo(string cartonNo)
{
using (IDbConnection dbConn = dapperDbContext.GetDbConnection())
{
dbConn.Open();
string result = string.Empty;
StringBuilder sql = new StringBuilder(1024);
sql.Append("select * from sys_stock as a (nolock) left join wms_rack_part_package as b (nolock) on a.part_no=b.rack_part where carton_no=@carton_no and a.enabled='Y' ");
DynamicParameters parameters = new DynamicParameters();
parameters.Add("@carton_no", cartonNo);
return dbConn.Query<SysStock>(sql.ToString(), parameters).ToList();
}
}
public List<SysStock> GetSemiFinishList(string carton_no, string partno, string num)
{
using (IDbConnection dbConn = dapperDbContext.GetDbConnection())
{
dbConn.Open();
string result = string.Empty;
StringBuilder sql = new StringBuilder(1024);
sql.Append(@" select top " + num + " * from sys_stock (nolock) where locate_id = (select dest_locate_id from sys_pdline (nolock) where pdline_code = ( select pdline_code from mes_out_pdline (nolock) where serial_number = @carton_no ) or pdline_code = ( select pdline_code from mes_hg_out_pdline (nolock) where serial_number = @carton_no )) and part_no = @partno and enabled = 'Y' ");
DynamicParameters parameters = new DynamicParameters();
parameters.Add("@carton_no", carton_no);
parameters.Add("@partno", partno.Trim());
return dbConn.Query<SysStock>(sql.ToString(), parameters).ToList();
}
}
public List<SysLocate> CheckLocateStatus(string locateName)
{
using (IDbConnection dbConn = dapperDbContext.GetDbConnection())
{
dbConn.Open();
string result = string.Empty;
StringBuilder sql = new StringBuilder(1024);
sql.Append(@"SELECT a.*,B.*,c.erp_warehouse FROM dbo.sys_locate a (nolock)
LEFT JOIN sys_locate_part b (nolock) ON a.locate_id = b.locate_id
LEFT join sys_zone as c (nolock) on a.zone_id=c.zone_id
WHERE a.locate_name =@locateName ");
DynamicParameters parameters = new DynamicParameters();
parameters.Add("@locateName", locateName);
return dbConn.Query<SysLocate>(sql.ToString(), parameters).ToList();
}
}
public int UpdateRackCarBinding(string RKNO)
{
using (IDbConnection dbConn = dapperDbContext.GetDbConnection())
{
dbConn.Open();
string result = string.Empty;
List<string> sqlStrings = new List<string>();
List<DynamicParameters> parameterList = new List<DynamicParameters>();
StringBuilder sql = new StringBuilder(1024);
sql.Append(@"update wms_rack_package set enabled='N' where rack_no =@rack_no ");
sqlStrings.Add(sql.ToString());
DynamicParameters parameters = new DynamicParameters();
parameters.Add("@rack_no", RKNO);
parameterList.Add(parameters);
//sql = new StringBuilder(1024);
//sql.Append(@"update sys_stock set enabled='N' where carton_no in (@rack_no)");
//sqlStrings.Add(sql.ToString());
//parameters = new DynamicParameters();
//parameters.Add("@rack_no", RKNO);
//parameterList.Add(parameters);
//执行事务
IDbTransaction transaction = dbConn.BeginTransaction();
try
{
for (int i = 0; i < sqlStrings.Count; i++)
{
dbConn.Execute(sqlStrings[i], parameterList[i], transaction);
}
transaction.Commit();
return 1;
}
catch (Exception ex)
{
transaction.Rollback();
return 0;
}
}
}
/// <summary>
/// 获取订单编号
/// </summary>
/// <returns></returns>
public string GetOrderNo(string stockOrder, string p)
{
using (IDbConnection dbConn = dapperDbContext.GetDbConnection())
{
dbConn.Open();
DynamicParameters list = new DynamicParameters();
list.Add("@order_type", stockOrder);
list.Add("@order_prefix", p);
list.Add("@order_no", null, DbType.String, ParameterDirection.Output, 50);
var hashtable = dbConn.Execute("sys_create_orderno", list, commandType: CommandType.StoredProcedure);
string result = list.Get<string>("@order_no");
return result;
}
}
public string Insertinfo(string locateName, string RKno, string productNo, string Num, string loginId)
{
using (IDbConnection dbConn = dapperDbContext.GetDbConnection())
{
dbConn.Open();
List<SysStock> oldStock = CheckCartonNoStatus(productNo);
List<SysLocate> locate = CheckLocateStatus(locateName);
List<SysStock> RKInfo = CheckCartonNoByRackNo(RKno);
//List<SysStock> Getsemi = GetSemiFinishList(productNo, oldStock[0].PartNo, Num);
List<string> sqlStrings = new List<string>();
List<DynamicParameters> parameterList = new List<DynamicParameters>();
//if (Convert.ToInt32(Num)> Getsemi.Count)
//{
// return "成品下线数小于待入库数，请检查！";
//}
//冻结条码
//StringBuilder sql = new StringBuilder(1024);
//sql.Append(@" update sys_stock set enabled='N' where carton_no in (select top " + Num + " carton_no from sys_stock (nolock) where locate_id = (select dest_locate_id from sys_pdline (nolock) where pdline_code = ( select pdline_code from mes_out_pdline (nolock) where serial_number = @carton_no ) or pdline_code = ( select pdline_code from mes_hg_out_pdline (nolock) where serial_number = @carton_no )) and part_no = @partno and enabled = 'Y' ) ");
//sqlStrings.Add(sql.ToString());
//DynamicParameters parameters = new DynamicParameters();
//parameters.Add("@carton_no", productNo);
//parameters.Add("@partno", oldStock[0].PartNo.Trim());
//parameterList.Add(parameters);
string carNo_New = GetOrderNo("StockOrder", "T");
#region 新增库存表
//在STOCK中插入料架
StringBuilder updateString3 = new StringBuilder(1024);
updateString3.Append(@" INSERT INTO [dbo].[sys_stock]
([vendor_id]
,[vendor_code]
,[carton_no]
,[carton_type]
,[part_id]
,[part_no]
,[part_spec]
,[lot_no]
,[fix_lot_no]
,[status]
,[qty]
,[snp_qty]
,[locate_id]
,[locate_name]
,[group_no]
,[erp_warehouse]
,[date_code]
,[qms_status]
,[ref_order_no]
,[unit]
,[dock]
,[warehouse_id]
,[warehouse_name]
,[zone_id]
,[zone_name]
,[printed]
,[print_time]
,[remark]
,[factory_id]
,[factory_code]
,[enabled]
,[create_userid]
,[create_time]
,[update_userid]
,[update_time]
,[guid])
VALUES(@vendor_id,@vendor_code,@carton_no,@carton_type,@part_id,@part_no,@part_spec,@lot_no,@fix_lot_no,@status,@qty,@snp_qty
,@locate_id,@locate_name,@group_no,@erp_warehouse,@date_code,@qms_status,@ref_order_no,@unit,@dock,@warehouse_id,@warehouse_name,@zone_id,@zone_name
,@printed,@print_time,@remark,@factory_id,@factory_code,@enabled,@create_userid,@create_time,@update_userid,@update_time,@guid )");
DynamicParameters updateStringparameters3 = new DynamicParameters();
updateStringparameters3.Add("@vendor_id", oldStock[0].VendorId);
updateStringparameters3.Add("@vendor_code", oldStock[0].VendorName);
updateStringparameters3.Add("@carton_no", carNo_New);
updateStringparameters3.Add("@carton_type", "0");
updateStringparameters3.Add("@part_id", oldStock[0].PartId);
updateStringparameters3.Add("@part_no", oldStock[0].PartNo);
updateStringparameters3.Add("@part_spec", oldStock[0].PartSpec);
updateStringparameters3.Add("@lot_no", DateTime.Now.ToString("yyyy-MM-dd"));
updateStringparameters3.Add("@fix_lot_no", "");
updateStringparameters3.Add("@status", (int)WmsEnumUtil.StockStatus.INSTOCKED);
updateStringparameters3.Add("@qty", Num);
updateStringparameters3.Add("@snp_qty", Num);
updateStringparameters3.Add("@locate_id", locate[0].LocateId);
updateStringparameters3.Add("@locate_name", locate[0].LocateName);
updateStringparameters3.Add("@group_no", "");
updateStringparameters3.Add("@erp_warehouse", locate[0].ErpWarehouse);
updateStringparameters3.Add("@date_code", "");
updateStringparameters3.Add("@qms_status", "");
updateStringparameters3.Add("@ref_order_no", "");
updateStringparameters3.Add("@unit", "");
updateStringparameters3.Add("@dock", "");
updateStringparameters3.Add("@warehouse_id", locate[0].WarehouseId);
updateStringparameters3.Add("@warehouse_name", locate[0].WarehouseName);
updateStringparameters3.Add("@zone_id", locate[0].ZoneId);
updateStringparameters3.Add("@zone_name", locate[0].ZoneName);
updateStringparameters3.Add("@printed", "");
updateStringparameters3.Add("@print_time", "");
updateStringparameters3.Add("@remark", "");
updateStringparameters3.Add("@factory_id", locate[0].FactoryId);
updateStringparameters3.Add("@factory_code", locate[0].FactoryCode);
updateStringparameters3.Add("@enabled", "Y");
updateStringparameters3.Add("@update_userid", loginId);
updateStringparameters3.Add("@update_time", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
updateStringparameters3.Add("@create_userid", loginId);
updateStringparameters3.Add("@create_time", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
updateStringparameters3.Add("@guid", Guid.NewGuid());
sqlStrings.Add(updateString3.ToString());
parameterList.Add(updateStringparameters3);
#endregion
#region 新增 sys_stock_trans 事务表
StringBuilder updateString4 = new StringBuilder(1024);
updateString4.Append(@" INSERT INTO[dbo].[sys_stock_trans]
([trans_code]
,[carton_no]
,[part_id]
,[part_no]
,[part_spec]
,[src_locate_id]
,[src_locate_name]
,[dest_locate_id]
,[dest_locate_name]
,[old_qty]
,[new_qty]
,[trans_qty]
,[old_status]
,[new_status]
,[old_qms_status]
,[new_qms_status]
,[unit]
,[factory_id]
,[factory_code]
,[src_erp_warehouse]
,[dest_erp_warehouse]
,[src_warehouse_id]
,[src_warehouse_name]
,[dest_warehouse_id]
,[dest_warehouse_name]
,[src_zone_id]
,[src_zone_name]
,[dest_zone_id]
,[dest_zone_name]
,[enabled]
,[update_userid]
,[update_time]
,[create_userid]
,[create_time]
,[guid])
VALUES (@trans_code,@carton_no,@part_id,@part_no,@part_spec,@src_locate_id ,@src_locate_name ,@dest_locate_id ,@dest_locate_name ,@old_qty
,@new_qty ,@trans_qty ,@old_status ,@new_status ,@old_qms_status ,@new_qms_status ,@unit ,@factory_id ,@factory_code ,@src_erp_warehouse ,@dest_erp_warehouse ,@src_warehouse_id ,@src_warehouse_name ,@dest_warehouse_id ,@dest_warehouse_name ,@src_zone_id ,@src_zone_name ,@dest_zone_id ,@dest_zone_name ,@enabled ,@update_userid ,@update_time ,@create_userid ,@create_time ,@guid )");
DynamicParameters updateStringparameters4 = new DynamicParameters();
updateStringparameters4.Add("@trans_code", (int)WmsEnumUtil.TransType.IN_STOCK_RACK_PACKAGE_RACK);
updateStringparameters4.Add("@carton_no", carNo_New);
updateStringparameters4.Add("@part_id", oldStock[0].PartId);
updateStringparameters4.Add("@part_no", oldStock[0].PartNo);
updateStringparameters4.Add("@part_spec", oldStock[0].PartSpec);
updateStringparameters4.Add("@src_locate_id", oldStock[0].LocateId);
updateStringparameters4.Add("@src_locate_name", oldStock[0].LocateName);
updateStringparameters4.Add("@dest_locate_id", locate[0].LocateId);
updateStringparameters4.Add("@dest_locate_name", locate[0].LocateName);
updateStringparameters4.Add("@old_qty", oldStock[0].Qty);
updateStringparameters4.Add("@new_qty", Num);
updateStringparameters4.Add("@trans_qty", oldStock[0].Qty);
updateStringparameters4.Add("@old_status", oldStock[0].Status);
updateStringparameters4.Add("@new_status", (int)WmsEnumUtil.StockStatus.INSTOCKED);
updateStringparameters4.Add("@old_qms_status", oldStock[0].QmsStatus);
updateStringparameters4.Add("@new_qms_status", oldStock[0].QmsStatus);
updateStringparameters4.Add("@unit", oldStock[0].Unit);
updateStringparameters4.Add("@factory_id", oldStock[0].FactoryId);
updateStringparameters4.Add("@factory_code", oldStock[0].FactoryCode);
updateStringparameters4.Add("@src_erp_warehouse", locate[0].ErpWarehouse);
updateStringparameters4.Add("@dest_erp_warehouse", locate[0].ErpWarehouse);
updateStringparameters4.Add("@src_warehouse_id", oldStock[0].WarehouseId);
updateStringparameters4.Add("@src_warehouse_name", oldStock[0].WarehouseName);
updateStringparameters4.Add("@dest_warehouse_id", locate[0].WarehouseId);
updateStringparameters4.Add("@dest_warehouse_name", locate[0].WarehouseName);
updateStringparameters4.Add("@src_zone_id", oldStock[0].ZoneId);
updateStringparameters4.Add("@src_zone_name", oldStock[0].ZoneName);
updateStringparameters4.Add("@dest_zone_id", locate[0].ZoneId);
updateStringparameters4.Add("@dest_zone_name", locate[0].ZoneName);
updateStringparameters4.Add("@enabled", "Y");
updateStringparameters4.Add("@update_userid", loginId);
updateStringparameters4.Add("@update_time", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
updateStringparameters4.Add("@create_userid", loginId);
updateStringparameters4.Add("@create_time", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
updateStringparameters4.Add("@guid", Guid.NewGuid());
sqlStrings.Add(updateString4.ToString());
parameterList.Add(updateStringparameters4);
#endregion
//新增料架与包装信息
StringBuilder updateString2 = new StringBuilder(1024);
updateString2.Append(@"INSERT INTO [dbo].[wms_rack_package]
([rack_no]
,[carton_no]
,[factory_id]
,[factory_code]
,[enabled]
,[create_userid]
,[create_time]
,[update_userid]
,[update_time]
,[guid],rack_num)
VALUES (@rack_no,@carton_no,@factory_id,@factory_code,@enabled,@create_userid,@create_time,@update_userid,@update_time,@guid,@rack_num
)");
DynamicParameters updateStringparameters2 = new DynamicParameters();
updateStringparameters2.Add("@rack_no", RKno);
updateStringparameters2.Add("@carton_no", carNo_New);
updateStringparameters2.Add("@factory_id", locate[0].FactoryId);
updateStringparameters2.Add("@factory_code", locate[0].FactoryCode);
updateStringparameters2.Add("@enabled", "Y");
updateStringparameters2.Add("@create_userid", loginId);
updateStringparameters2.Add("@create_time", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
updateStringparameters2.Add("@guid", Guid.NewGuid());
updateStringparameters2.Add("@rack_num", 1);
updateStringparameters2.Add("@update_userid", loginId);
updateStringparameters2.Add("@update_time", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
sqlStrings.Add(updateString2.ToString());
parameterList.Add(updateStringparameters2);
if (RKInfo.Count == 0)
{
#region 新增库存表
//在STOCK中插入料架
updateString3 = new StringBuilder(1024);
updateString3.Append(@" INSERT INTO [dbo].[sys_stock]
([vendor_id]
,[vendor_code]
,[carton_no]
,[carton_type]
,[part_id]
,[part_no]
,[part_spec]
,[lot_no]
,[fix_lot_no]
,[status]
,[qty]
,[snp_qty]
,[locate_id]
,[locate_name]
,[group_no]
,[erp_warehouse]
,[date_code]
,[qms_status]
,[ref_order_no]
,[unit]
,[dock]
,[warehouse_id]
,[warehouse_name]
,[zone_id]
,[zone_name]
,[printed]
,[print_time]
,[remark]
,[factory_id]
,[factory_code]
,[enabled]
,[create_userid]
,[create_time]
,[update_userid]
,[update_time]
,[guid])
VALUES(@vendor_id,@vendor_code,@carton_no,@carton_type,@part_id,@part_no,@part_spec,@lot_no,@fix_lot_no,@status,@qty,@snp_qty
,@locate_id,@locate_name,@group_no,@erp_warehouse,@date_code,@qms_status,@ref_order_no,@unit,@dock,@warehouse_id,@warehouse_name,@zone_id,@zone_name
,@printed,@print_time,@remark,@factory_id,@factory_code,@enabled,@create_userid,@create_time,@update_userid,@update_time,@guid )");
updateStringparameters3 = new DynamicParameters();
updateStringparameters3.Add("@vendor_id", oldStock[0].VendorId);
updateStringparameters3.Add("@vendor_code", oldStock[0].VendorName);
updateStringparameters3.Add("@carton_no", RKno);
updateStringparameters3.Add("@carton_type", "1");
updateStringparameters3.Add("@part_id", "0");
updateStringparameters3.Add("@part_no", RKno);
updateStringparameters3.Add("@part_spec", "");
updateStringparameters3.Add("@lot_no", DateTime.Now.ToString("yyyy-MM-dd"));
updateStringparameters3.Add("@fix_lot_no", "");
updateStringparameters3.Add("@status", (int)WmsEnumUtil.StockStatus.INSTOCKED);
updateStringparameters3.Add("@qty", 1);
updateStringparameters3.Add("@snp_qty", 1);
updateStringparameters3.Add("@locate_id", locate[0].LocateId);
updateStringparameters3.Add("@locate_name", locate[0].LocateName);
updateStringparameters3.Add("@group_no", "");
updateStringparameters3.Add("@erp_warehouse", locate[0].ErpWarehouse);
updateStringparameters3.Add("@date_code", "");
updateStringparameters3.Add("@qms_status", "");
updateStringparameters3.Add("@ref_order_no", "台车");
updateStringparameters3.Add("@unit", "");
updateStringparameters3.Add("@dock", "");
updateStringparameters3.Add("@warehouse_id", locate[0].WarehouseId);
updateStringparameters3.Add("@warehouse_name", locate[0].WarehouseName);
updateStringparameters3.Add("@zone_id", locate[0].ZoneId);
updateStringparameters3.Add("@zone_name", locate[0].ZoneName);
updateStringparameters3.Add("@printed", "");
updateStringparameters3.Add("@print_time", "");
updateStringparameters3.Add("@remark", "");
updateStringparameters3.Add("@factory_id", locate[0].FactoryId);
updateStringparameters3.Add("@factory_code", locate[0].FactoryCode);
updateStringparameters3.Add("@enabled", "Y");
updateStringparameters3.Add("@update_userid", loginId);
updateStringparameters3.Add("@update_time", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
updateStringparameters3.Add("@create_userid", loginId);
updateStringparameters3.Add("@create_time", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
updateStringparameters3.Add("@guid", Guid.NewGuid());
sqlStrings.Add(updateString3.ToString());
parameterList.Add(updateStringparameters3);
#endregion
#region 新增 sys_stock_trans 事务表
updateString4 = new StringBuilder(1024);
updateString4.Append(@" INSERT INTO[dbo].[sys_stock_trans]
([trans_code]
,[carton_no]
,[part_id]
,[part_no]
,[part_spec]
,[src_locate_id]
,[src_locate_name]
,[dest_locate_id]
,[dest_locate_name]
,[old_qty]
,[new_qty]
,[trans_qty]
,[old_status]
,[new_status]
,[old_qms_status]
,[new_qms_status]
,[unit]
,[factory_id]
,[factory_code]
,[src_erp_warehouse]
,[dest_erp_warehouse]
,[src_warehouse_id]
,[src_warehouse_name]
,[dest_warehouse_id]
,[dest_warehouse_name]
,[src_zone_id]
,[src_zone_name]
,[dest_zone_id]
,[dest_zone_name]
,[enabled]
,[update_userid]
,[update_time]
,[create_userid]
,[create_time]
,[guid])
VALUES (@trans_code,@carton_no,@part_id,@part_no,@part_spec,@src_locate_id ,@src_locate_name ,@dest_locate_id ,@dest_locate_name ,@old_qty
,@new_qty ,@trans_qty ,@old_status ,@new_status ,@old_qms_status ,@new_qms_status ,@unit ,@factory_id ,@factory_code ,@src_erp_warehouse ,@dest_erp_warehouse ,@src_warehouse_id ,@src_warehouse_name ,@dest_warehouse_id ,@dest_warehouse_name ,@src_zone_id ,@src_zone_name ,@dest_zone_id ,@dest_zone_name ,@enabled ,@update_userid ,@update_time ,@create_userid ,@create_time ,@guid )");
updateStringparameters4 = new DynamicParameters();
updateStringparameters4.Add("@trans_code", (int)WmsEnumUtil.TransType.IN_STOCK_RACK_PACKAGE_RACK);
updateStringparameters4.Add("@carton_no", RKno);
updateStringparameters4.Add("@part_id", 0);
updateStringparameters4.Add("@part_no", RKno);
updateStringparameters4.Add("@part_spec", "");
updateStringparameters4.Add("@src_locate_id", oldStock[0].LocateId);
updateStringparameters4.Add("@src_locate_name", oldStock[0].LocateName);
updateStringparameters4.Add("@dest_locate_id", locate[0].LocateId);
updateStringparameters4.Add("@dest_locate_name", locate[0].LocateName);
updateStringparameters4.Add("@old_qty", 1);
updateStringparameters4.Add("@new_qty", 1);
updateStringparameters4.Add("@trans_qty", 1);
updateStringparameters4.Add("@old_status", oldStock[0].Status);
updateStringparameters4.Add("@new_status", (int)WmsEnumUtil.StockStatus.INSTOCKED);
updateStringparameters4.Add("@old_qms_status", oldStock[0].QmsStatus);
updateStringparameters4.Add("@new_qms_status", oldStock[0].QmsStatus);
updateStringparameters4.Add("@unit", oldStock[0].Unit);
updateStringparameters4.Add("@factory_id", oldStock[0].FactoryId);
updateStringparameters4.Add("@factory_code", oldStock[0].FactoryCode);
updateStringparameters4.Add("@src_erp_warehouse", locate[0].ErpWarehouse);
updateStringparameters4.Add("@dest_erp_warehouse", locate[0].ErpWarehouse);
updateStringparameters4.Add("@src_warehouse_id", oldStock[0].WarehouseId);
updateStringparameters4.Add("@src_warehouse_name", oldStock[0].WarehouseName);
updateStringparameters4.Add("@dest_warehouse_id", locate[0].WarehouseId);
updateStringparameters4.Add("@dest_warehouse_name", locate[0].WarehouseName);
updateStringparameters4.Add("@src_zone_id", oldStock[0].ZoneId);
updateStringparameters4.Add("@src_zone_name", oldStock[0].ZoneName);
updateStringparameters4.Add("@dest_zone_id", locate[0].ZoneId);
updateStringparameters4.Add("@dest_zone_name", locate[0].ZoneName);
updateStringparameters4.Add("@enabled", "Y");
updateStringparameters4.Add("@update_userid", loginId);
updateStringparameters4.Add("@update_time", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
updateStringparameters4.Add("@create_userid", loginId);
updateStringparameters4.Add("@create_time", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
updateStringparameters4.Add("@guid", Guid.NewGuid());
sqlStrings.Add(updateString4.ToString());
parameterList.Add(updateStringparameters4);
#endregion
}
StringBuilder updateString5 = new StringBuilder(1024);
updateString5.Append(@" update sys_stock set status=@status,locate_id=@locate_id,locate_name=@locate_name,erp_warehouse=@erp_warehouse,warehouse_id=@warehouse_id,warehouse_name=@warehouse_name,zone_id=@zone_id,zone_name=@zone_name,update_userid=@update_userid,update_time=@update_time where carton_no=@carton_no ");
DynamicParameters updateStringparameters5 = new DynamicParameters();
updateStringparameters5.Add("@status", (int)WmsEnumUtil.StockStatus.INSTOCKED);
updateStringparameters5.Add("@locate_id", locate[0].LocateId);
updateStringparameters5.Add("@locate_name", locate[0].LocateName);
updateStringparameters5.Add("@carton_no", RKno);
updateStringparameters5.Add("@erp_warehouse", locate[0].ErpWarehouse);
updateStringparameters5.Add("@warehouse_id", locate[0].WarehouseId);
updateStringparameters5.Add("@warehouse_name", locate[0].WarehouseName);
updateStringparameters5.Add("@zone_id", locate[0].ZoneId);
updateStringparameters5.Add("@zone_name", locate[0].ZoneName);
updateStringparameters5.Add("@update_userid", loginId);
updateStringparameters5.Add("@update_time", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
sqlStrings.Add(updateString5.ToString());
parameterList.Add(updateStringparameters5);
//执行事务
IDbTransaction transaction = dbConn.BeginTransaction();
bool successCount = true;
for (int i = 0; i < sqlStrings.Count; i++)
{
if (dbConn.Execute(sqlStrings[i], parameterList[i], transaction) < 1)
{
successCount = false;
}
}
if (successCount)
{
transaction.Commit();
return "OK" + oldStock[0].PartSpec;
}
else
{
transaction.Rollback();
return "操作失败，请重新尝试！";
}
}
}
}
}
Reference in New Issue View Git Blame Copy Permalink