VueWebCoreApi/DLL/DAL/GeneralBasicDataDAL.cs
@@ -7,13 +7,14 @@
using System.Threading.Tasks;
using VueWebCoreApi.Models;
using VueWebCoreApi.Models.UnitMaterial;
using VueWebCoreApi.Models.WorkData;
using VueWebCoreApi.Tools;
namespace VueWebCoreApi.DLL.DAL
{
    public class GeneralBasicDataDAL
    {
        public static DataTable dt;    //定义全局变量dt
        public static DataTable dt;    //定义全局变量dt
        public static bool res;       //定义全局变量dt
        public static ToMessage mes = new ToMessage(); //定义全局返回信息对象
        public static string strProcName = ""; //定义全局sql变量
@@ -22,6 +23,30 @@
        public static dynamic CompanyCode = AppSetting.GetAppSetting("CompanyCode");
        public static dynamic CompanyName = AppSetting.GetAppSetting("CompanyName");
        #region[组织架构类型资料]
        public static ToMessage TOrganTypeDate()
        {
            var sql = "";
            var dynamicParams = new DynamicParameters();
            try
            {
                sql = @"select torgtype_code,torgtype_name from TOrganType where torgtype_code<>'C'";
                var data = DapperHelper.selectdata(sql, dynamicParams);
                mes.code = "200";
                mes.message = "查询成功!";
                mes.data = data;
            }
            catch (Exception e)
            {
                mes.code = "300";
                mes.count = 0;
                mes.message = e.Message;
                mes.data = null;
            }
            return mes;
        }
        #endregion
        #region [组织架构查找]
        public static ToMessage PrentOrganization()
@@ -57,6 +82,30 @@
            try
            {
                sql = @"select * from TOrganization where  status='Y' and parent_id<>'0' or leve<>'0'";
                var data = DapperHelper.selectdata(sql, dynamicParams);
                mes.code = "200";
                mes.message = "查询成功!";
                mes.data = data;
            }
            catch (Exception e)
            {
                mes.code = "300";
                mes.count = 0;
                mes.message = e.Message;
                mes.data = null;
            }
            return mes;
        }
        #endregion
        #region[组织架构车间基础资料]
        public static ToMessage TorgWkshop()
        {
            var sql = "";
            var dynamicParams = new DynamicParameters();
            try
            {
                sql = @"select * from TOrganization where  status='Y' and torgtype_code='W'";
                var data = DapperHelper.selectdata(sql, dynamicParams);
                mes.code = "200";
                mes.message = "查询成功!";
@@ -364,6 +413,32 @@
        }
        #endregion
        #region[车间查找设备基础资料]
        public static ToMessage WkshopEqpPermissions(string wkshopcode)
        {
            var sql = "";
            var dynamicParams = new DynamicParameters();
            try
            {
                string[] wkshopcodelist = Array.ConvertAll<string, string>(wkshopcode.Split(new char[] { ',' }, StringSplitOptions.RemoveEmptyEntries), s => s.ToString()); //string分割转string[]
                sql = @"select code,name from TEqpInfo where  enable='Y' and torg_code in @torg_code";
                dynamicParams.Add("@torg_code", wkshopcodelist);
                var data = DapperHelper.selectdata(sql, dynamicParams);
                mes.code = "200";
                mes.message = "查询成功!";
                mes.data = data;
            }
            catch (Exception e)
            {
                mes.code = "300";
                mes.count = 0;
                mes.message = e.Message;
                mes.data = null;
            }
            return mes;
        }
        #endregion
        #region[设备类型编码查找设备信息]
        public static ToMessage EqpTypecodeSeachEqpPermissions(string eqptypecode)
        {
@@ -437,7 +512,7 @@
                    var data0 = DapperHelper.selectdata(sql, dynamicParams);
                    for (int j = 0; j < data0.Rows.Count; j++)
                    {
                        LocationData  locat = new LocationData();
                        LocationData locat = new LocationData();
                        locat.value = data0.Rows[j]["code"].ToString();
                        locat.text = data0.Rows[j]["name"].ToString();
                        warhouse.children.Add(locat);
@@ -509,6 +584,68 @@
        }
        #endregion
        #region[工序设备基础资料]
        public static ToMessage StepEqpData()
        {
            var sql = "";
            List<object> list = new List<object>();
            var dynamicParams = new DynamicParameters();
            try
            {
                //查找工序信息
                sql = @"select  '' as id,'' as wo_code,'' as seq,S.stepcode as step_code,T.stepname,T.flwtype,'0' as unprice,'0' as produceq_qty,
                        '0' as good_qty,'0' as ng_qty,'0' as laborbad_qty,'0' as materielbad_qty,'0' as delive_qty,'' as isbott,'' as isend
                        from TStep S
                        left join TStep  T on S.stepcode=T.stepcode";
                var parents = DapperHelper.selectdatalist<WorkRouteStepEqp>(sql);
                //获取工序对应设备信息
                for (int i = 0; i < parents.Count; i++)
                {
                    if (parents[i].flwtype == "Z")
                    {
                        //通过工艺路线工序表ID查找对应设备信息
                        sql = @"select  R.eqp_code,E.name as eqp_name,'N' as enable,'0' as unprice,
                              '0' as produceq_qty, '0' as good_qty,'0' as ng_qty,'0' as laborbad_qty,'0' as materielbad_qty
                              from TFlw_Rteqp R
                              left join  TEqpInfo E on R.eqp_code=E.code
                              where R.step_code=@step_code and R.style=@style";
                        dynamicParams.Add("@step_code", parents[i].step_code);
                        dynamicParams.Add("@style", "E"); //设备
                        var children = DapperHelper.select<WorkRouteStepEqpSub>(sql, dynamicParams);
                        parents[i].children = children.ToList();
                    }
                    else
                    {
                        //通过工艺路线工序表ID查找对应外协供应商信息
                        sql = @"select  R.eqp_code,E.name as eqp_name,'N' as enable,'0' as unprice,
                              '0' as produceq_qty, '0' as good_qty,'0' as ng_qty,'0' as laborbad_qty,'0' as materielbad_qty
                              from TFlw_Rteqp R
                              inner join TCustomer E on R.eqp_code=E.code
                              where R.step_code=@step_code and R.style=@style";
                        dynamicParams.Add("@step_code", parents[i].step_code);
                        dynamicParams.Add("@style", parents[i].flwtype);
                        var children = DapperHelper.select<WorkRouteStepEqpSub>(sql, dynamicParams);
                        parents[i].children = children.ToList();
                    }
                }
                var data = DapperHelper.selectdata(sql, dynamicParams);
                mes.code = "200";
                mes.count = parents.Count;
                mes.data = parents;
                mes.message = "查询成功!";
            }
            catch (Exception e)
            {
                mes.code = "300";
                mes.count = 0;
                mes.message = e.Message;
                mes.data = null;
            }
            return mes;
        }
        #endregion
        #region[缺陷基础资料]
        public static ToMessage DefectPermissions()
        {
@@ -518,6 +655,30 @@
            try
            {
                sql = @"select code,name from TDefect";
                var data = DapperHelper.selectdata(sql, dynamicParams);
                mes.code = "200";
                mes.message = "查询成功!";
                mes.data = data;
            }
            catch (Exception e)
            {
                mes.code = "300";
                mes.count = 0;
                mes.message = e.Message;
                mes.data = null;
            }
            return mes;
        }
        #endregion
        #region[往来单位类型基础资料]
        public static ToMessage CustomerTypePermissions()
        {
            var sql = "";
            var dynamicParams = new DynamicParameters();
            try
            {
                sql = @"select code,name from TCustomerType";
                var data = DapperHelper.selectdata(sql, dynamicParams);
                mes.code = "200";
                mes.message = "查询成功!";
@@ -558,6 +719,32 @@
        }
        #endregion
        #region[往来单位类型查找往来单位基础资料]
        public static ToMessage CustomerTypeSearchPermissions(string customertypecode)
        {
            var sql = "";
            var dynamicParams = new DynamicParameters();
            try
            {
                string[] customerTypecodelist = Array.ConvertAll<string, string>(customertypecode.Split(new char[] { ',' }, StringSplitOptions.RemoveEmptyEntries), s => s.ToString()); //string分割转string[]
                sql = @"select code,name  from  TCustomer where customertype in @customerTypecodelist";
                dynamicParams.Add("@customerTypecodelist", customerTypecodelist);
                var data = DapperHelper.selectdata(sql, dynamicParams);
                mes.code = "200";
                mes.message = "查询成功!";
                mes.data = data;
            }
            catch (Exception e)
            {
                mes.code = "300";
                mes.count = 0;
                mes.message = e.Message;
                mes.data = null;
            }
            return mes;
        }
        #endregion
        #region[存货树型基础资料]
        public static ToMessage InventoryTreePermissions()
        {
@@ -565,7 +752,7 @@
            var dynamicParams = new DynamicParameters();
            try
            {
              sql = @"WITH RecursiveCTE AS (
                sql = @"WITH RecursiveCTE AS (
                     SELECT code, name, idparent
                     FROM TMateriel_Class
                     WHERE code in(select distinct idinventoryclass from TMateriel_Info where status='0')
@@ -643,5 +830,30 @@
            return mes;
        }
        #endregion
        #region[查询工单/产品基础资料]
        public static ToMessage WrkOrderDataSelect()
        {
            string sql = "";
            try
            {
                sql = @"select P.wo_code,P.materiel_code,M.partname as materiel_name
                        from TK_Wrk_Man P
                        left join TMateriel_Info M on P.materiel_code=M.partcode";
                var data = DapperHelper.selecttable(sql);
                mes.code = "200";
                mes.message = "查询成功!";
                mes.data = data;
            }
            catch (Exception e)
            {
                mes.code = "300";
                mes.count = 0;
                mes.message = e.Message;
                mes.data = null;
            }
            return mes;
        }
        #endregion
    }
}