You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
254 lines
10 KiB
254 lines
10 KiB
using CK.SCP.Models;
|
|
using CK.SCP.Models.ExchangeCenterTables;
|
|
using CK.SCP.Utils;
|
|
using System;
|
|
using System.Collections.Generic;
|
|
using System.Data;
|
|
using System.Data.Entity.Migrations;
|
|
using System.Data.SqlClient;
|
|
using System.Linq;
|
|
using System.Text;
|
|
using System.Threading.Tasks;
|
|
|
|
namespace CK.SCP.Controller
|
|
{
|
|
public class UN_EC_CONTROLLER_PART
|
|
{
|
|
public static void Get_TES_PART_MSTR_List(TES_PART_MSTR p_entity, Action<ResultObject<IQueryable<TES_PART_MSTR>>> p_action)
|
|
{
|
|
ResultObject<IQueryable<TES_PART_MSTR>> _ret = new ResultObject<IQueryable<TES_PART_MSTR>>();
|
|
try
|
|
{
|
|
using (var db = EntitiesFactory.CreateExchangeCenterInstance())
|
|
{
|
|
IQueryable<TES_PART_MSTR> q = db.TES_PART_MSTR;
|
|
if (!string.IsNullOrEmpty(p_entity.PartCode))
|
|
{
|
|
q = q.Where(p => p.PartCode.Contains(p_entity.PartCode));
|
|
}
|
|
if (!string.IsNullOrEmpty(p_entity.Desc1))
|
|
{
|
|
q = q.Where(p => p.Desc1.Contains(p_entity.Desc1));
|
|
}
|
|
if (!string.IsNullOrEmpty(p_entity.Desc2))
|
|
{
|
|
q = q.Where(p => p.Desc2.Contains(p_entity.Desc2));
|
|
}
|
|
if (!string.IsNullOrEmpty(p_entity.Um))
|
|
{
|
|
q = q.Where(p => p.Um.Contains(p_entity.Um));
|
|
}
|
|
if (!string.IsNullOrEmpty(p_entity.ProdLine))
|
|
{
|
|
q = q.Where(p => p.ProdLine.Contains(p_entity.ProdLine));
|
|
}
|
|
if (!string.IsNullOrEmpty(p_entity.DsgnGroup))
|
|
{
|
|
q = q.Where(p => p.DsgnGroup.Contains(p_entity.DsgnGroup));
|
|
}
|
|
if (!string.IsNullOrEmpty(p_entity.PromotionGroup))
|
|
{
|
|
q = q.Where(p => p.PromotionGroup.Contains(p_entity.PromotionGroup));
|
|
}
|
|
if (!string.IsNullOrEmpty(p_entity.PartType))
|
|
{
|
|
q = q.Where(p => p.PartType.Contains(p_entity.PartType));
|
|
}
|
|
if (!string.IsNullOrEmpty(p_entity.Status))
|
|
{
|
|
q = q.Where(p => p.Status.Contains(p_entity.Status));
|
|
}
|
|
if (!string.IsNullOrEmpty(p_entity.Group))
|
|
{
|
|
q = q.Where(p => p.Group.Contains(p_entity.Group));
|
|
}
|
|
if (!string.IsNullOrEmpty(p_entity.Drawing))
|
|
{
|
|
q = q.Where(p => p.Drawing.Contains(p_entity.Drawing));
|
|
}
|
|
if (!string.IsNullOrEmpty(p_entity.PartRevision))
|
|
{
|
|
q = q.Where(p => p.PartRevision.Contains(p_entity.PartRevision));
|
|
}
|
|
if (!string.IsNullOrEmpty(p_entity.DrawingLocation))
|
|
{
|
|
q = q.Where(p => p.DrawingLocation.Contains(p_entity.DrawingLocation));
|
|
}
|
|
if (!string.IsNullOrEmpty(p_entity.Size))
|
|
{
|
|
q = q.Where(p => p.Size.Contains(p_entity.Size));
|
|
}
|
|
if (!string.IsNullOrEmpty(p_entity.PriceBreakCategory))
|
|
{
|
|
q = q.Where(p => p.PriceBreakCategory.Contains(p_entity.PriceBreakCategory));
|
|
}
|
|
if (p_entity.AuxiliaryMaterial != false)
|
|
{
|
|
q = q.Where(p => p.AuxiliaryMaterial == p_entity.AuxiliaryMaterial);
|
|
}
|
|
if (!string.IsNullOrEmpty(p_entity.Qgrade))
|
|
{
|
|
q = q.Where(p => p.Qgrade.Contains(p_entity.Qgrade));
|
|
}
|
|
if (p_entity.WmsPartType != 0)
|
|
{
|
|
q = q.Where(p => p.WmsPartType == p_entity.WmsPartType);
|
|
}
|
|
if (!string.IsNullOrEmpty(p_entity.ManageWay))
|
|
{
|
|
q = q.Where(p => p.ManageWay.Contains(p_entity.ManageWay));
|
|
}
|
|
if (!string.IsNullOrEmpty(p_entity.InventoryCode))
|
|
{
|
|
q = q.Where(p => p.InventoryCode.Contains(p_entity.InventoryCode));
|
|
}
|
|
if (!string.IsNullOrEmpty(p_entity.ManageType))
|
|
{
|
|
q = q.Where(p => p.ManageType.Contains(p_entity.ManageType));
|
|
}
|
|
if (p_entity.InspectType != null)
|
|
{
|
|
q = q.Where(p => p.InspectType == p_entity.InspectType);
|
|
}
|
|
if (p_entity.UID != 0)
|
|
{
|
|
q = q.Where(p => p.UID == p_entity.UID);
|
|
}
|
|
if (!string.IsNullOrEmpty(p_entity.CreateUser))
|
|
{
|
|
q = q.Where(p => p.CreateUser.Contains(p_entity.CreateUser));
|
|
}
|
|
if (!string.IsNullOrEmpty(p_entity.Remark))
|
|
{
|
|
q = q.Where(p => p.Remark.Contains(p_entity.Remark));
|
|
}
|
|
if (!string.IsNullOrEmpty(p_entity.CommandType))
|
|
{
|
|
q = q.Where(p => p.CommandType.Contains(p_entity.CommandType));
|
|
}
|
|
if (!string.IsNullOrEmpty(p_entity.Domain))
|
|
{
|
|
q = q.Where(p => p.Domain.Contains(p_entity.Domain));
|
|
}
|
|
if (!string.IsNullOrEmpty(p_entity.Site))
|
|
{
|
|
q = q.Where(p => p.Site.Contains(p_entity.Site));
|
|
}
|
|
_ret.Result = q;
|
|
_ret.State = ReturnStatus.Succeed;
|
|
p_action(_ret);
|
|
}
|
|
}
|
|
catch (Exception e)
|
|
{
|
|
_ret.State = ReturnStatus.Failed;
|
|
_ret.ErrorList.Add(e);
|
|
LogHelper.Writlog(LogHelper.LogType.Error, typeof(TES_PART_MSTR), "Get_TES_PART_MSTR_List", e.Message);
|
|
throw e;
|
|
}
|
|
|
|
}
|
|
|
|
public static DataTable Get_TES_PART_MSTR_List(string p_PartCode, string p_tableName)
|
|
{
|
|
DataTable dt = new DataTable(); ;
|
|
var dbSetting = GlobalConfig.ExchangeCenterDB;
|
|
try
|
|
{
|
|
var strConn = EntitiesFactory.GetEfConnectionString(dbSetting);
|
|
SqlConnection conn = new System.Data.SqlClient.SqlConnection();
|
|
conn.ConnectionString = strConn;
|
|
if (conn.State != ConnectionState.Open)
|
|
{
|
|
conn.Open();
|
|
}
|
|
SqlCommand cmd = new SqlCommand();
|
|
cmd.Connection = conn;
|
|
string _sql = string.Format("select * from {0} where PartCode='{1}'", p_tableName, p_PartCode);
|
|
|
|
cmd.CommandText = _sql;
|
|
|
|
SqlDataAdapter adapter = new SqlDataAdapter(cmd);
|
|
|
|
adapter.Fill(dt);
|
|
|
|
}
|
|
catch (SqlException ex)
|
|
{
|
|
throw new Exception($"系统无法连接到数据库:{dbSetting}，请检查配置的服务器,数据库,用户名和密码等信息是否正确。{Environment.NewLine}{ex}");
|
|
}
|
|
return dt;
|
|
}
|
|
|
|
public static ResultObject<bool> Save_TES_PART_MSTR(List<long> p_listUid, EnumTaskState p_state)
|
|
{
|
|
|
|
ResultObject<bool> _ret = new ResultObject<bool>();
|
|
try
|
|
{
|
|
using (var db = EntitiesFactory.CreateExchangeCenterInstance())
|
|
{
|
|
var _lst = db.TES_PART_MSTR.Where(p => p_listUid.Contains(p.UID)).ToList();
|
|
foreach (var itm in _lst)
|
|
{
|
|
db.TES_PART_MSTR.AddOrUpdate(itm);
|
|
}
|
|
if (db.SaveChanges() != -1)
|
|
{
|
|
_ret.State = ReturnStatus.Succeed;
|
|
_ret.Result = true;
|
|
}
|
|
else
|
|
{
|
|
_ret.State = ReturnStatus.Failed;
|
|
_ret.Result = false;
|
|
}
|
|
}
|
|
}
|
|
catch (Exception e)
|
|
{
|
|
_ret.State = ReturnStatus.Failed;
|
|
LogHelper.Writlog(LogHelper.LogType.Error, typeof(TES_PART_MSTR), "Save_TES_PART_MSTR", e.Message);
|
|
_ret.Result = false;
|
|
_ret.ErrorList.Add(e);
|
|
throw e;
|
|
}
|
|
return _ret;
|
|
|
|
}
|
|
public ResultObject<bool> Del_TES_PART_MSTR(List<TES_PART_MSTR> p_entitys)
|
|
{
|
|
ResultObject<bool> _ret = new ResultObject<bool>();
|
|
try
|
|
{
|
|
using (var db = EntitiesFactory.CreateExchangeCenterInstance())
|
|
{
|
|
foreach (var itm in p_entitys)
|
|
{
|
|
db.TES_PART_MSTR.Remove(itm);
|
|
}
|
|
if (db.SaveChanges() != -1)
|
|
{
|
|
_ret.State = ReturnStatus.Succeed;
|
|
_ret.Result = true;
|
|
}
|
|
else
|
|
{
|
|
_ret.State = ReturnStatus.Failed;
|
|
_ret.Result = false;
|
|
}
|
|
}
|
|
}
|
|
catch (Exception e)
|
|
{
|
|
_ret.State = ReturnStatus.Failed;
|
|
_ret.Result = false;
|
|
_ret.ErrorList.Add(e);
|
|
LogHelper.Writlog(LogHelper.LogType.Error, typeof(TES_PART_MSTR), "Del_TES_PART_MSTR", e.Message); throw e;
|
|
}
|
|
return _ret;
|
|
}
|
|
|
|
|
|
}
|
|
}
|
|
|