using HH.WCS.Hexafluo;
|
using HH.WCS.Hexafluo.util;
|
using HH.WCS.Hexafluo.wms;
|
using HH.WCS.SJML.Dto;
|
using HH.WCS.SJML.Entitys;
|
using NLog.Fluent;
|
using SqlSugar;
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using System.Threading.Tasks;
|
using static HH.WCS.Hexafluo.dispatch.NDC;
|
|
namespace HH.WCS.SJML.wms
|
{
|
public class MaterialHelper
|
{
|
public OperateResult SjMaterialMainAdd(List<TN_MaterialEntitys> suppliers)
|
{
|
OperateResult result = new OperateResult();
|
var db = new SqlHelper<object>().GetInstance();
|
try
|
{
|
var Mater = suppliers.Select(e => e.S_ITEM_CODE).ToList();
|
//查询是否存在相同数据
|
var location = db.Queryable<TN_MaterialEntitys>().Where(it => Mater.Contains(it.S_ITEM_CODE)).ToList();
|
if (location.Count > 0)
|
{
|
suppliers.RemoveAll(e => location.Select(c => c.S_ITEM_CODE).ToList().Contains(e.S_ITEM_CODE));
|
}
|
if (suppliers.Count() > 0)
|
{
|
db.BeginTran();
|
var I = db.Insertable(suppliers).ExecuteCommand();
|
db.Ado.CommitTran();
|
if (I > 0)
|
{
|
result.Success = true;
|
result.AffectedRows = I;
|
}
|
else
|
{
|
result.Success = false;
|
result.Msg = "添加失败!";
|
}
|
}
|
else
|
{
|
result.Success = false;
|
result.Msg = "经过验证数据已存在,无法重复添加!";
|
}
|
return result;
|
}
|
catch (Exception ex)
|
{
|
LogHelper.Info("物料维护", "添加报错--" + ex.Message + ex.StackTrace);
|
db.Ado.RollbackTran();
|
return OperateResult.Error(ex.Message);
|
}
|
}
|
|
|
public OperateResult SjMaterialMainDelete(List<TN_MaterialEntitys> suppliers)
|
{
|
OperateResult result = new OperateResult();
|
var db = new SqlHelper<object>().GetInstance();
|
try
|
{
|
db.BeginTran();
|
var I = db.Deleteable<TN_MaterialEntitys>().WhereColumns(suppliers, it => new { it.S_ITEM_CODE }).ExecuteCommand();
|
db.Ado.CommitTran();
|
if (I > 0)
|
{
|
result.Success = true;
|
result.AffectedRows = I;
|
}
|
else
|
{
|
result.Success = false;
|
result.Msg = "添加失败!";
|
}
|
return result;
|
}
|
catch (Exception ex)
|
{
|
LogHelper.Info("物料维护", "删除报错--" + ex.Message + ex.StackTrace);
|
db.Ado.RollbackTran();
|
return OperateResult.Error(ex.Message);
|
}
|
}
|
|
|
public OperateResult SjMaterialMainUpdate(List<TN_MaterialEntitys> suppliers)
|
{
|
OperateResult result = new OperateResult();
|
var db = new SqlHelper<object>().GetInstance();
|
try
|
{
|
var supplier = suppliers.Select(e=>e.S_ITEM_CODE).ToList();
|
db.BeginTran();
|
var I = db.Updateable(suppliers).WhereColumns(e=> new { e.S_ITEM_CODE }).ExecuteCommand();
|
db.Ado.CommitTran();
|
if (I > 0)
|
{
|
result.Success = true;
|
result.AffectedRows = I;
|
}
|
else
|
{
|
result.Success = false;
|
result.Msg = "更新失败!";
|
}
|
return result;
|
}
|
catch (Exception ex)
|
{
|
LogHelper.Info("物料维护", "更新报错--" + ex.Message + ex.StackTrace);
|
db.Ado.RollbackTran();
|
return OperateResult.Error(ex.Message);
|
}
|
}
|
|
public OperateResult SjMaterialMainSelect(MaterialMainDto suppliers)
|
{
|
OperateResult result = new OperateResult();
|
var db = new SqlHelper<object>().GetInstance();
|
var exp = Expressionable.Create<TN_MaterialEntitys>();
|
exp.AndIF(!string.IsNullOrEmpty(suppliers.S_ITEM_TYPE), it => it.S_ITEM_TYPE == suppliers.S_ITEM_TYPE);
|
exp.AndIF(!string.IsNullOrEmpty(suppliers.S_ITEM_CODE), it => it.S_ITEM_CODE.Contains(suppliers.S_ITEM_CODE));
|
exp.AndIF(!string.IsNullOrEmpty(suppliers.S_ITEM_NAME), it => it.S_ITEM_NAME == suppliers.S_ITEM_NAME);
|
exp.AndIF(!string.IsNullOrEmpty(suppliers.S_SPEC), it => it.S_SPEC == suppliers.S_SPEC);
|
exp.AndIF(!string.IsNullOrEmpty(suppliers.S_DRAW_NO), it => it.S_DRAW_NO == suppliers.S_DRAW_NO);
|
exp.AndIF(!string.IsNullOrEmpty(suppliers.C_ENABLE_OWNER), it => it.C_ENABLE_OWNER == suppliers.C_ENABLE_OWNER);
|
var I = db.Queryable<TN_MaterialEntitys>().Where(exp.ToExpression()).ToList();
|
result.Success = true;
|
result.Data = I;
|
return result;
|
}
|
}
|
}
|