using Dapper;
|
using System;
|
using System.Collections.Generic;
|
using System.Data;
|
using System.Linq;
|
using System.Web;
|
using VueWebApi.Tools;
|
|
namespace VueWebApi.DLL.DAL
|
{
|
public class ErpSyncMesDAL
|
{
|
public static ToMessage mes = new ToMessage(); //定义全局返回信息对象
|
|
#region[制造模型：单位同步]
|
public static ToMessage SeaveSearchUnit(string username)
|
{
|
var sql = "";
|
var dynamicParams = new DynamicParameters();
|
try
|
{
|
//存储过程名
|
sql = @"h_p_IFCLD_ERPUnit";
|
dynamicParams.Add("@username", username);
|
bool a = DapperHelper.IsProcedure(sql, dynamicParams);
|
if (a)
|
{
|
mes.code = "200";
|
mes.count = 0;
|
mes.Message = "同步单位成功!";
|
mes.data = null;
|
}
|
else
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.Message = "同步单位失败!";
|
mes.data = null;
|
}
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.Message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
#region[制造模型：存货分类同步]
|
public static ToMessage SeaveSearchInventoryClass()
|
{
|
var sql = "";
|
var dynamicParams = new DynamicParameters();
|
try
|
{
|
//存储过程名
|
sql = @"h_p_IFCLD_ERPInventory_Class";
|
bool a = DapperHelper.IsProcedureNo(sql);
|
if (a)
|
{
|
mes.code = "200";
|
mes.count = 0;
|
mes.Message = "同步存货分类成功!";
|
mes.data = null;
|
}
|
else
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.Message = "同步存货分类失败!";
|
mes.data = null;
|
}
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.Message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
#region[制造模型：存货档案同步]
|
public static ToMessage SeaveSearchInventory(string username)
|
{
|
var sql = "";
|
var dynamicParams = new DynamicParameters();
|
try
|
{
|
//存储过程名
|
sql = @"h_p_IFCLD_ERPInventory";
|
dynamicParams.Add("@username", username);
|
bool a = DapperHelper.IsProcedure(sql, dynamicParams);
|
if (a)
|
{
|
mes.code = "200";
|
mes.count = 0;
|
mes.Message = "同步存货档案成功!";
|
mes.data = null;
|
}
|
else
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.Message = "同步存货档案失败!";
|
mes.data = null;
|
}
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.Message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
#region[物料管理：仓库库位同步]
|
public static ToMessage SeaveSearchWhareHouseLocation(string username)
|
{
|
var sql = "";
|
var dynamicParams = new DynamicParameters();
|
try
|
{
|
//存储过程名
|
sql = @"h_p_IFCLD_ERPWhareHousesLocation";
|
dynamicParams.Add("@username", username);
|
bool a = DapperHelper.IsProcedure(sql, dynamicParams);
|
if (a)
|
{
|
mes.code = "200";
|
mes.count = 0;
|
mes.Message = "同步仓库库位成功!";
|
mes.data = null;
|
}
|
else
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.Message = "同步仓库库位失败!";
|
mes.data = null;
|
}
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.Message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
#region[基础设置:往来单位同步]
|
public static ToMessage SeaveSearchPartner(string username)
|
{
|
var sql = "";
|
var dynamicParams = new DynamicParameters();
|
try
|
{
|
//存储过程名
|
sql = @"h_p_IFCLD_ERPPartner";
|
dynamicParams.Add("@username", username);
|
bool a = DapperHelper.IsProcedure(sql, dynamicParams);
|
if (a)
|
{
|
mes.code = "200";
|
mes.count = 0;
|
mes.Message = "同步往来单位成功!";
|
mes.data = null;
|
}
|
else
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.Message = "同步往来单位失败!";
|
mes.data = null;
|
}
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.Message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
#region[生产管理：生产订单同步]
|
public static ToMessage SeaveSearchErpOrder(string stu_torgcode,string stu_torgtypecode)
|
{
|
var sql = "";
|
var dynamicParams = new DynamicParameters();
|
try
|
{
|
if (stu_torgcode == "" || stu_torgcode == null)
|
{
|
stu_torgcode = "";
|
}
|
if (stu_torgtypecode == "D")
|
{
|
sql = @" with CTE as (
|
select id, org_code,org_name, parent_id
|
from TOrganization A
|
where org_code =@stu_torgcode
|
union all
|
select A.id,A.org_code,A.org_name,A.parent_id
|
from TOrganization A
|
inner join CTE on A.parent_id = CTE.id
|
)
|
select org_code,org_name from CTE";
|
dynamicParams.Add("@stu_torgcode", stu_torgcode);
|
var data = DapperHelper.selectdata(sql, dynamicParams);
|
stu_torgcode=string.Join(",", data.AsEnumerable().Select(row => row.Field<string>("org_code")));
|
//stu_torgcode = string.Join(",", data.AsEnumerable().Select(row => $"'{row.Field<string>("org_code")}'"));
|
//LogHelper.WriteLogData("获取车间编码："+stu_torgcode);
|
}
|
//存储过程名
|
sql = @"h_p_IFCLD_ERPMO";
|
dynamicParams.Add("@stu_torgcode", stu_torgcode);
|
dynamicParams.Add("@stu_torgtypecode", stu_torgtypecode);
|
bool a = DapperHelper.IsProcedure(sql, dynamicParams);
|
if (a)
|
{
|
mes.code = "200";
|
mes.count = 0;
|
mes.Message = "同步生产订单成功!";
|
mes.data = null;
|
}
|
else
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.Message = "同步生产订单失败!";
|
mes.data = null;
|
}
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.Message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
|
#region[采购管理：采购订单同步]
|
public static ToMessage SeaveSearchErpPurchaseOrder()
|
{
|
var sql = "";
|
var dynamicParams = new DynamicParameters();
|
try
|
{
|
//存储过程名
|
sql = @"h_p_IFCLD_ERPPurchaseOrder";
|
bool a = DapperHelper.IsProcedureNo(sql);
|
if (a)
|
{
|
mes.code = "200";
|
mes.count = 0;
|
mes.Message = "同步采购订单成功!";
|
mes.data = null;
|
}
|
else
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.Message = "同步采购订单失败!";
|
mes.data = null;
|
}
|
}
|
catch (Exception e)
|
{
|
mes.code = "300";
|
mes.count = 0;
|
mes.Message = e.Message;
|
mes.data = null;
|
}
|
return mes;
|
}
|
#endregion
|
}
|
}
|
