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.
539 lines
32 KiB
C#
539 lines
32 KiB
C#
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 MoveRepository : BaseRepository<BaseEntity>, IMoveRepository
|
|
{
|
|
public MoveRepository(DapperDbContext _dapperDbContext) : base(_dapperDbContext)
|
|
{
|
|
|
|
}
|
|
//获取箱条码状态
|
|
public 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.enum_name as stock_status from sys_stock a (nolock) left join sys_enum b (nolock) on enum_type='sys_stock_status' and enum_value=status where carton_no=@carton_no ");
|
|
DynamicParameters parameters = new DynamicParameters();
|
|
parameters.Add("@carton_no", cartonNo);
|
|
|
|
return dbConn.QueryFirstOrDefault<SysStock>(sql.ToString(), parameters);
|
|
}
|
|
}
|
|
|
|
//获取库位与零件对应关系
|
|
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 List<SysStock> CheckUseStockCapacity(string locateName)
|
|
{
|
|
using (IDbConnection dbConn = dapperDbContext.GetDbConnection())
|
|
{
|
|
dbConn.Open();
|
|
string result = string.Empty;
|
|
|
|
StringBuilder sql = new StringBuilder(1024);
|
|
sql.Append(" SELECT * FROM dbo.sys_stock (nolock) WHERE locate_name = @locateName AND status IN ('50','60','80') and enabled='Y' ");
|
|
DynamicParameters parameters = new DynamicParameters();
|
|
parameters.Add("@locateName", locateName);
|
|
return dbConn.Query<SysStock>(sql.ToString(), parameters).ToList();
|
|
}
|
|
}
|
|
|
|
//获取箱条码状态 通过分组号
|
|
public List<SysStock> CheckCartonNoStatusByPack(string cartonNo)
|
|
{
|
|
using (IDbConnection dbConn = dapperDbContext.GetDbConnection())
|
|
{
|
|
dbConn.Open();
|
|
string result = string.Empty;
|
|
|
|
StringBuilder sql = new StringBuilder(1024);
|
|
sql.Append("select * from sys_stock (nolock) where group_no= (select group_no from sys_stock (nolock) where carton_no = @carton_no ) and status='50' and enabled='Y' ");
|
|
DynamicParameters parameters = new DynamicParameters();
|
|
parameters.Add("@carton_no", cartonNo);
|
|
|
|
return dbConn.Query<SysStock>(sql.ToString(), parameters).ToList();
|
|
}
|
|
}
|
|
|
|
|
|
public WmsResponseResult UpdateStockStatus(List<SysStock> oldStock, List<SysLocate> locate, int status, int TransType, string loginId)
|
|
{
|
|
using (IDbConnection dbConn = dapperDbContext.GetDbConnection())
|
|
{
|
|
dbConn.Open();
|
|
|
|
List<string> sqlStrings = new List<string>();
|
|
List<DynamicParameters> parameterList = new List<DynamicParameters>();
|
|
WmsResponseResult result = new WmsResponseResult();
|
|
for (int i = 0; i < oldStock.Count; i++)
|
|
{
|
|
//更新条码表，状态 50 改变为 50 已上架
|
|
StringBuilder updateString = new StringBuilder(1024);
|
|
updateString.Append("update sys_stock set status=@status,zone_id=@zone_id,zone_name=@zone_name,locate_id=@locate_id,locate_name=@locate_name, update_userid=@update_userid,update_time=@update_time where ruid=@ruid ");
|
|
DynamicParameters updateStringparameters = new DynamicParameters();
|
|
updateStringparameters.Add("@status", status);
|
|
updateStringparameters.Add("@locate_id", locate[0].LocateId);
|
|
updateStringparameters.Add("@locate_name", locate[0].LocateName);
|
|
updateStringparameters.Add("@zone_id", locate[0].ZoneId);
|
|
updateStringparameters.Add("@zone_name", locate[0].ZoneName);
|
|
updateStringparameters.Add("@ruid", oldStock[i].Ruid);
|
|
updateStringparameters.Add("@update_userid", loginId);
|
|
updateStringparameters.Add("@update_time", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
|
|
|
|
sqlStrings.Add(updateString.ToString());
|
|
parameterList.Add(updateStringparameters);
|
|
|
|
//新增 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", TransType);
|
|
updateStringparameters4.Add("@carton_no", oldStock[i].CartonNo);
|
|
updateStringparameters4.Add("@part_id", oldStock[i].PartId);
|
|
updateStringparameters4.Add("@part_no", oldStock[i].PartNo);
|
|
updateStringparameters4.Add("@part_spec", oldStock[i].PartSpec);
|
|
updateStringparameters4.Add("@src_locate_id", oldStock[i].LocateId);
|
|
updateStringparameters4.Add("@src_locate_name", oldStock[i].LocateName);
|
|
updateStringparameters4.Add("@dest_locate_id", locate[0].LocateId);
|
|
updateStringparameters4.Add("@dest_locate_name", locate[0].LocateName);
|
|
updateStringparameters4.Add("@old_qty", oldStock[i].Qty);
|
|
updateStringparameters4.Add("@new_qty", oldStock[i].Qty);
|
|
updateStringparameters4.Add("@trans_qty", oldStock[i].Qty);
|
|
updateStringparameters4.Add("@old_status", oldStock[i].Status);
|
|
updateStringparameters4.Add("@new_status", status);
|
|
updateStringparameters4.Add("@old_qms_status", oldStock[i].QmsStatus);
|
|
updateStringparameters4.Add("@new_qms_status", oldStock[i].QmsStatus);
|
|
updateStringparameters4.Add("@unit", oldStock[i].Unit);
|
|
updateStringparameters4.Add("@factory_id", oldStock[i].FactoryId);
|
|
updateStringparameters4.Add("@factory_code", oldStock[i].FactoryCode);
|
|
updateStringparameters4.Add("@src_erp_warehouse", oldStock[i].ErpWarehouse);
|
|
updateStringparameters4.Add("@dest_erp_warehouse", oldStock[i].ErpWarehouse);
|
|
updateStringparameters4.Add("@src_warehouse_id", oldStock[i].WarehouseId);
|
|
updateStringparameters4.Add("@src_warehouse_name", oldStock[i].WarehouseName);
|
|
updateStringparameters4.Add("@dest_warehouse_id", locate[0].WarehouseId);
|
|
updateStringparameters4.Add("@dest_warehouse_name", locate[0].WarehouseName);
|
|
updateStringparameters4.Add("@src_zone_id", oldStock[i].ZoneId);
|
|
updateStringparameters4.Add("@src_zone_name", oldStock[i].ZoneName);
|
|
updateStringparameters4.Add("@dest_zone_id", locate[0].ZoneId);
|
|
updateStringparameters4.Add("@dest_zone_name", locate[0].ZoneName);
|
|
updateStringparameters4.Add("@enabled", oldStock[i].Enabled);
|
|
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);
|
|
|
|
if (oldStock[i].CartonType == 1)
|
|
{
|
|
StringBuilder updateStringpackage = new StringBuilder(1024);
|
|
updateStringpackage.Append("update sys_stock set status=@status,zone_id=@zone_id,zone_name=@zone_name,locate_id=@locate_id,locate_name=@locate_name, update_userid=@update_userid,update_time=@update_time where carton_no in (select carton_no from wms_rack_package where rack_no=@carton_no and enabled='Y') and enabled='Y' ");
|
|
DynamicParameters updateStringparameterspackage = new DynamicParameters();
|
|
updateStringparameterspackage.Add("@status", status);
|
|
updateStringparameterspackage.Add("@locate_id", locate[0].LocateId);
|
|
updateStringparameterspackage.Add("@locate_name", locate[0].LocateName);
|
|
updateStringparameterspackage.Add("@zone_id", locate[0].ZoneId);
|
|
updateStringparameterspackage.Add("@zone_name", locate[0].ZoneName);
|
|
updateStringparameterspackage.Add("@ruid", oldStock[i].Ruid);
|
|
updateStringparameterspackage.Add("@update_userid", loginId);
|
|
updateStringparameterspackage.Add("@update_time", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
|
|
updateStringparameterspackage.Add("@carton_no", oldStock[i].CartonNo);
|
|
|
|
sqlStrings.Add(updateStringpackage.ToString());
|
|
parameterList.Add(updateStringparameterspackage);
|
|
|
|
StringBuilder sql = new StringBuilder(1024);
|
|
sql.Append("select * from sys_stock (nolock) where carton_no in (select carton_no from wms_rack_package where rack_no=@carton_no and enabled='Y') and enabled='Y' ");
|
|
DynamicParameters parameters = new DynamicParameters();
|
|
parameters.Add("@carton_no", oldStock[i].CartonNo);
|
|
|
|
oldStock = dbConn.Query<SysStock>(sql.ToString(), parameters).ToList();
|
|
}
|
|
}
|
|
//执行事务
|
|
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();
|
|
result.Success = true;
|
|
result.Data = oldStock;
|
|
return result;
|
|
}
|
|
else
|
|
{
|
|
transaction.Rollback();
|
|
result.Success = false;
|
|
result.Msg = "操作失败，请重新尝试！";
|
|
return result;
|
|
}
|
|
}
|
|
}
|
|
|
|
public string UpdateStockStatusByMoveOrder(List<SysStock> oldStock, List<SysLocate> locate, int status, int TransType, string loginId, string orderNo)
|
|
{
|
|
using (IDbConnection dbConn = dapperDbContext.GetDbConnection())
|
|
{
|
|
dbConn.Open();
|
|
|
|
List<string> sqlStrings = new List<string>();
|
|
List<DynamicParameters> parameterList = new List<DynamicParameters>();
|
|
|
|
for (int i = 0; i < oldStock.Count; i++)
|
|
{
|
|
//更新条码表，状态 50 改变为 50 已上架
|
|
StringBuilder updateString = new StringBuilder(1024);
|
|
updateString.Append("update sys_stock set status=@status,erp_warehouse=@erp_warehouse,zone_id=@zone_id,zone_name=@zone_name,locate_id=@locate_id,locate_name=@locate_name, update_userid=@update_userid,update_time=@update_time where ruid=@ruid ");
|
|
DynamicParameters updateStringparameters = new DynamicParameters();
|
|
updateStringparameters.Add("@status", status);
|
|
updateStringparameters.Add("@locate_id", locate[0].LocateId);
|
|
updateStringparameters.Add("@locate_name", locate[0].LocateName);
|
|
updateStringparameters.Add("@zone_id", locate[0].ZoneId);
|
|
updateStringparameters.Add("@zone_name", locate[0].ZoneName);
|
|
updateStringparameters.Add("@erp_warehouse", locate[0].ErpWarehouse);
|
|
updateStringparameters.Add("@ruid", oldStock[i].Ruid);
|
|
updateStringparameters.Add("@update_userid", loginId);
|
|
updateStringparameters.Add("@update_time", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
|
|
|
|
sqlStrings.Add(updateString.ToString());
|
|
parameterList.Add(updateStringparameters);
|
|
|
|
//新增 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],ref_order_no)
|
|
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,@ref_order_no )");
|
|
|
|
DynamicParameters updateStringparameters4 = new DynamicParameters();
|
|
updateStringparameters4.Add("@trans_code", TransType);
|
|
updateStringparameters4.Add("@carton_no", oldStock[i].CartonNo);
|
|
updateStringparameters4.Add("@part_id", oldStock[i].PartId);
|
|
updateStringparameters4.Add("@part_no", oldStock[i].PartNo);
|
|
updateStringparameters4.Add("@part_spec", oldStock[i].PartSpec);
|
|
updateStringparameters4.Add("@src_locate_id", oldStock[i].LocateId);
|
|
updateStringparameters4.Add("@src_locate_name", oldStock[i].LocateName);
|
|
updateStringparameters4.Add("@dest_locate_id", locate[0].LocateId);
|
|
updateStringparameters4.Add("@dest_locate_name", locate[0].LocateName);
|
|
updateStringparameters4.Add("@old_qty", oldStock[i].Qty);
|
|
updateStringparameters4.Add("@new_qty", oldStock[i].Qty);
|
|
updateStringparameters4.Add("@trans_qty", oldStock[i].Qty);
|
|
updateStringparameters4.Add("@old_status", oldStock[i].Status);
|
|
updateStringparameters4.Add("@new_status", status);
|
|
updateStringparameters4.Add("@old_qms_status", oldStock[i].QmsStatus);
|
|
updateStringparameters4.Add("@new_qms_status", oldStock[i].QmsStatus);
|
|
updateStringparameters4.Add("@unit", oldStock[i].Unit);
|
|
updateStringparameters4.Add("@factory_id", oldStock[i].FactoryId);
|
|
updateStringparameters4.Add("@factory_code", oldStock[i].FactoryCode);
|
|
updateStringparameters4.Add("@src_erp_warehouse", oldStock[i].ErpWarehouse);
|
|
updateStringparameters4.Add("@dest_erp_warehouse", locate[0].ErpWarehouse);
|
|
updateStringparameters4.Add("@src_warehouse_id", oldStock[i].WarehouseId);
|
|
updateStringparameters4.Add("@src_warehouse_name", oldStock[i].WarehouseName);
|
|
updateStringparameters4.Add("@dest_warehouse_id", locate[0].WarehouseId);
|
|
updateStringparameters4.Add("@dest_warehouse_name", locate[0].WarehouseName);
|
|
updateStringparameters4.Add("@src_zone_id", oldStock[i].ZoneId);
|
|
updateStringparameters4.Add("@src_zone_name", oldStock[i].ZoneName);
|
|
updateStringparameters4.Add("@dest_zone_id", locate[0].ZoneId);
|
|
updateStringparameters4.Add("@dest_zone_name", locate[0].ZoneName);
|
|
updateStringparameters4.Add("@enabled", oldStock[i].Enabled);
|
|
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());
|
|
updateStringparameters4.Add("@ref_order_no", orderNo);
|
|
|
|
sqlStrings.Add(updateString4.ToString());
|
|
parameterList.Add(updateStringparameters4);
|
|
|
|
//移动单主表
|
|
StringBuilder updateString2 = new StringBuilder(1024);
|
|
updateString2.Append("update wms_move_header set order_status =@status ,update_userid=@update_userid,update_time=@update_time where order_no = @order_no ");
|
|
DynamicParameters updateStringparameters2 = new DynamicParameters();
|
|
updateStringparameters2.Add("@status", (int)WmsEnumUtil.MoveOrderStatus.PROCESSING);
|
|
updateStringparameters2.Add("@order_no", orderNo);
|
|
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);
|
|
|
|
//移动单从表
|
|
StringBuilder updateString3 = new StringBuilder(1024);
|
|
updateString3.Append("update wms_move_detail set out_qty =out_qty + @out_qty,item_status = case when qty =out_qty + @out_qty then @status40 else @status30 end ,update_userid=@update_userid,update_time=@update_time where order_no = @order_no and part_id = @part_id");
|
|
DynamicParameters updateStringparameters3 = new DynamicParameters();
|
|
updateStringparameters3.Add("@status30", (int)WmsEnumUtil.MoveOrderDetailStatus.BATCHING);
|
|
updateStringparameters3.Add("@status40", (int)WmsEnumUtil.MoveOrderDetailStatus.COMPLETED);
|
|
updateStringparameters3.Add("@out_qty", oldStock[0].Qty);
|
|
updateStringparameters3.Add("@part_id", oldStock[0].PartId);
|
|
updateStringparameters3.Add("@order_no", orderNo);
|
|
updateStringparameters3.Add("@update_userid", loginId);
|
|
updateStringparameters3.Add("@update_time", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
|
|
|
|
sqlStrings.Add(updateString3.ToString());
|
|
parameterList.Add(updateStringparameters3);
|
|
|
|
|
|
StringBuilder updateString5 = new StringBuilder(1024);
|
|
updateString5.Append("INSERT INTO dbo.wms_move_sn ");
|
|
updateString5.Append("( ");
|
|
updateString5.Append(" order_no,item_no,part_id,part_no,part_spec, ");
|
|
updateString5.Append(" carton_no,qty,unit,status,factory_id,factory_code,enabled, ");
|
|
updateString5.Append(" create_userid,create_time,update_userid,update_time,guid ");
|
|
updateString5.Append(") ");
|
|
updateString5.Append("VALUES ");
|
|
updateString5.Append("( @orderNo,@itemNo,@partId,@partNo,@partSpec, ");
|
|
updateString5.Append(" @cartonNo,@qty,@unit,@status,@factoryId,@factoryCode,@enabled, ");
|
|
updateString5.Append(" @createUserid,@createTime,@updateUserid,@updateTime,@guid ");
|
|
updateString5.Append(" ) ");
|
|
|
|
DynamicParameters updateStringparameters5 = new DynamicParameters();
|
|
updateStringparameters5.Add("@orderNo", orderNo);
|
|
updateStringparameters5.Add("@itemNo", "1");
|
|
updateStringparameters5.Add("@partId", oldStock[0].PartId);
|
|
updateStringparameters5.Add("@partNo", oldStock[0].PartNo);
|
|
updateStringparameters5.Add("@partSpec", oldStock[0].PartSpec);
|
|
updateStringparameters5.Add("@cartonNo", oldStock[0].CartonNo);
|
|
updateStringparameters5.Add("@qty", oldStock[0].Qty);
|
|
updateStringparameters5.Add("@unit", oldStock[0].Unit);
|
|
updateStringparameters5.Add("@status", (int)WmsEnumUtil.MoveOrderSnStatus.CREATE);
|
|
updateStringparameters5.Add("@factoryId", oldStock[0].FactoryId);
|
|
updateStringparameters5.Add("@factoryCode", oldStock[0].FactoryCode);
|
|
updateStringparameters5.Add("@enabled", WmsEnumUtil.Enabled.Y.ToString());
|
|
updateStringparameters5.Add("@createUserid", loginId);
|
|
updateStringparameters5.Add("@createTime", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"));
|
|
updateStringparameters5.Add("@updateUserid", loginId);
|
|
updateStringparameters5.Add("@updateTime", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff"));
|
|
updateStringparameters5.Add("@guid", Guid.NewGuid());
|
|
|
|
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";
|
|
}
|
|
else
|
|
{
|
|
transaction.Rollback();
|
|
return "操作失败，请重新尝试！";
|
|
}
|
|
}
|
|
}
|
|
|
|
public List<SysStock> GetCartonNoInfoByPack(string cartonNo)
|
|
{
|
|
using (IDbConnection dbConn = dapperDbContext.GetDbConnection())
|
|
{
|
|
dbConn.Open();
|
|
string result = string.Empty;
|
|
|
|
StringBuilder sql = new StringBuilder(1024);
|
|
sql.Append("select * from sys_stock (nolock) where group_no= (select group_no from sys_stock (nolock) where carton_no = @carton_no AND ENABLED='Y' ) and status=@status ");
|
|
DynamicParameters parameters = new DynamicParameters();
|
|
parameters.Add("@carton_no", cartonNo);
|
|
parameters.Add("@status", (int)WmsEnumUtil.StockStatus.INSTOCKED);
|
|
return dbConn.Query<SysStock>(sql.ToString(), parameters).ToList();
|
|
}
|
|
}
|
|
|
|
public List<SysStock> GetCartonNoInfo(string cartonNo)
|
|
{
|
|
using (IDbConnection dbConn = dapperDbContext.GetDbConnection())
|
|
{
|
|
dbConn.Open();
|
|
string result = string.Empty;
|
|
|
|
StringBuilder sql = new StringBuilder(1024);
|
|
sql.Append("select * from sys_stock (nolock) where carton_no= @carton_no and enabled='Y' ");
|
|
DynamicParameters parameters = new DynamicParameters();
|
|
parameters.Add("@carton_no", cartonNo);
|
|
|
|
return dbConn.Query<SysStock>(sql.ToString(), parameters).ToList();
|
|
}
|
|
}
|
|
|
|
|
|
public List<WmsMoveHeader> GetMoveOrderList()
|
|
{
|
|
IDbConnection dbConn = dapperDbContext.GetDbConnection();
|
|
|
|
StringBuilder sql = new StringBuilder(1024);
|
|
sql.Append(@"select * from wms_move_header (nolock) where order_type = @order_type and order_status in (@status10,@status20,@status30)
|
|
order by case when order_status = '30' then 0 else 1 end, create_time ");
|
|
DynamicParameters parameters = new DynamicParameters();
|
|
parameters.Add("@order_type", (int)WmsEnumUtil.MoveOrderType.TRANSFER_ORDER);
|
|
parameters.Add("@status10", (int)WmsEnumUtil.MoveOrderDetailStatus.CREATE);
|
|
parameters.Add("@status20", (int)WmsEnumUtil.MoveOrderDetailStatus.GENERATED);
|
|
parameters.Add("@status30", (int)WmsEnumUtil.MoveOrderDetailStatus.BATCHING);
|
|
|
|
List<WmsMoveHeader> xxx = dbConn.Query<WmsMoveHeader>(sql.ToString(), parameters).ToList();
|
|
return xxx;
|
|
}
|
|
|
|
public List<WmsMoveDetail> CheckMoveOrderLocate(string orderNo)
|
|
{
|
|
using (IDbConnection dbConn = dapperDbContext.GetDbConnection())
|
|
{
|
|
dbConn.Open();
|
|
string result = string.Empty;
|
|
|
|
StringBuilder sql = new StringBuilder(1024);
|
|
sql.Append("select * from wms_move_detail (nolock) where order_no = @order_no and enabled='Y'");
|
|
DynamicParameters parameters = new DynamicParameters();
|
|
parameters.Add("@order_no", orderNo);
|
|
|
|
return dbConn.Query<WmsMoveDetail>(sql.ToString(), parameters).ToList();
|
|
}
|
|
}
|
|
|
|
public string ChangeMoveHeaderStatus(string loginId,string orderNo)
|
|
{
|
|
IDbConnection dbConn = dapperDbContext.GetDbConnection();
|
|
|
|
StringBuilder sql = new StringBuilder(1024);
|
|
sql.Append("update wms_move_header set order_status = @order_status , update_userid=@update_userid,update_time=@update_time where order_no = @order_no");
|
|
DynamicParameters parameters = new DynamicParameters();
|
|
parameters.Add("@order_no", orderNo);
|
|
parameters.Add("@order_status", (int)WmsEnumUtil.MoveOrderStatus.COMPLETED);
|
|
parameters.Add("@update_userid", loginId);
|
|
parameters.Add("@update_time", DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss"));
|
|
dbConn.Execute(sql.ToString(), parameters);
|
|
|
|
return "OK";
|
|
|
|
}
|
|
}
|
|
}
|