From 5b4fb9c56426b5096555560a44dd365b02853ad4 Mon Sep 17 00:00:00 2001
From: yl <ykxkd@outlook.com>
Date: 星期六, 17 六月 2023 13:14:54 +0800
Subject: [PATCH] 代码加组织过滤

---
 VueWebApi/DLL/DAL/ProductModelDAL.cs |  251 +++++++++++++++++++++++++++++++++++++++----------
 1 files changed, 199 insertions(+), 52 deletions(-)

diff --git a/VueWebApi/DLL/DAL/ProductModelDAL.cs b/VueWebApi/DLL/DAL/ProductModelDAL.cs
index 724f0d6..0f15076 100644
--- a/VueWebApi/DLL/DAL/ProductModelDAL.cs
+++ b/VueWebApi/DLL/DAL/ProductModelDAL.cs
@@ -464,14 +464,17 @@
                 // --------------鏌ヨ鎸囧畾鏁版嵁--------------
                 var total = 0; //鎬绘潯鏁�
                 var sql = @"select A.id,A.partcode,A.partname,A.partspec,A.uom_code,B.name as uom_name,D.code as stocktypecode,D.name as stocktypename,
-                            C.code as materialtypecode,C.name as materialtypename,A.stck_code,T.name as stck_name,A.maxqty,A.minqty,U.username as lm_user,A.default_route,
-                            A.lm_date,A.proute_id,A.is_batchno,A.is_fifo,A.is_incheck,A.is_outcheck
+                            C.code as materialtypecode,C.name as materialtypename,A.stck_code,T.name as stck_name,A.maxqty,A.minqty,U.username as lm_user,
+                            A.lm_date,(case when isnull(M.materiel_code,'')='' then 'N' else 'Y' end) as proute_id,A.is_batchno,A.is_fifo,A.is_incheck,A.is_outcheck
                             from TMateriel_Info A
                             left join TUom B on A.uom_code=B.code
                             left join TMateriel_Type C on A.materieltype_code=C.code
                             left join T_Dict D on A.stocktype_code=D.code and D.dict_type='CHLX'
                             left join T_Sec_Stck T on A.stck_code=T.code 
                             left join TUser U on A.lm_user=U.usercode
+                            left join (
+                              select distinct materiel_code from TMateriel_Route 
+                            )  M on A.partcode=M.materiel_code
                             where A.is_delete<>'1' " + search;
                 var data = DapperHelper.GetPageList<object>(sql, dynamicParams, prop, order, startNum, endNum, out total);
                 mes.code = "200";
@@ -686,20 +689,38 @@
         #endregion
 
         #region[瀛樿揣妗f鍏宠仈宸ヨ壓璺嚎鏌ヨ]
-        public static ToMessage InventoryFileAssociationRoute(string partcode)
+        public static ToMessage InventoryFileAssociationRoute(string stu_torgcode,string stu_torgtypecode,string partcode)
         {
             string sql = "";
+            string search = "";
             var dynamicParams = new DynamicParameters();
             List<MaterialRout> list = new List<MaterialRout>();
             try
             {
+                switch (stu_torgtypecode)
+                {
+                    case "":
+                        break;
+                    case "D":
+                        search += "and parent.org_code=@stu_torgcode or child.org_code=@stu_torgcode ";
+                        dynamicParams.Add("@stu_torgcode", stu_torgcode);
+                        break;
+                    case "W":
+                        search += "and parent.org_code=@stu_torgcode ";
+                        dynamicParams.Add("@stu_torgcode", stu_torgcode);
+                        break;
+                    default:
+                        break;
+                }
                 //鑾峰彇宸ヨ壓璺嚎闆嗗悎(鍖呭惈鐗╂枡缁戝畾宸ヨ壓璺嚎鏍囪瘑)
-                sql = @"select distinct A.code as routecode,A.name as routename,(case when B.route_code is null then 'N' else 'Y' end) flag  from TFlw_Rout A 
+                sql = @"select distinct parent.org_code,parent.org_name,A.code as routecode,A.name as routename,(case when B.route_code is null then 'N' else 'Y' end) flag  from TFlw_Rout A 
+                        left join TOrganization parent on A.torg_code=parent.org_code 
+                        left join TOrganization as child on parent.parent_id=child.id 
                         left join (
                           select distinct route_code  from TMateriel_Route where  materiel_code=@partcode and is_delete<>'1'
                         ) B
                         on A.code=B.route_code 
-                        where  A.is_delete='0' and A.enable='Y'";
+                        where  A.is_delete='0' and A.enable='Y' " + search;
                 dynamicParams.Add("@partcode", partcode);
                 var data = DapperHelper.selectdata(sql, dynamicParams);
                 for (int i = 0; i < data.Rows.Count; i++)
@@ -708,7 +729,8 @@
                     rout.code = data.Rows[i]["ROUTECODE"].ToString();
                     rout.name = data.Rows[i]["ROUTENAME"].ToString();
                     rout.flag = data.Rows[i]["FLAG"].ToString();
-
+                    rout.wkshopcode= data.Rows[i]["ORG_CODE"].ToString();
+                    rout.wkshopname = data.Rows[i]["ORG_NAME"].ToString();
                     //鏍规嵁宸ヨ壓璺嚎缂栫爜鑾峰彇鍏宠仈鐨勫伐搴忎俊鎭�
                     sql = @"select A.seq,B.stepcode,B.stepname,B.enable from TFlw_Rtdt A
                             inner join TStep B on A.step_code=B.stepcode
@@ -735,7 +757,7 @@
         #endregion
 
         #region[瀛樿揣妗f鍏宠仈宸ヨ壓璺嚎鎻愪氦]
-        public static ToMessage SaveInventoryFile(string partcode, string defaultroute_code, string username, List<ObjectData> json)
+        public static ToMessage SaveInventoryFile(string stu_torgcode,string stu_torgtypecode, string partcode, string defaultroute_code, string username, List<PartRout> json)
         {
             var sql = "";
             List<object> list = new List<object>();
@@ -744,22 +766,61 @@
                 list.Clear();
                 if (json == null || json.Count <= 0)
                 {
-                    //娓呴櫎鐗╂枡鍏宠仈宸ヨ壓璺嚎琛ㄦ暟鎹�
-                    sql = @"delete TMateriel_Route where materiel_code=@partcode";
-                    list.Add(new { str = sql, parm = new { partcode = partcode } });
-                    //鏍囪鐗╂枡琛ㄥ叧鑱斿伐鑹鸿矾绾挎爣璇�
-                    sql = @"update TMateriel_Info set proute_id='N',default_route='' where partcode=@partcode";
-                    list.Add(new { str = sql, parm = new { partcode = partcode } });
+                    switch (stu_torgtypecode)
+                    {
+                        case "":
+                            //娓呴櫎鐗╂枡鍏宠仈宸ヨ壓璺嚎琛ㄦ暟鎹�
+                            sql = @"delete TMateriel_Route where materiel_code=@partcode";
+                            list.Add(new { str = sql, parm = new { partcode = partcode } });
+                            break;
+                        case "D":
+                            //娓呴櫎鐗╂枡鍏宠仈宸ヨ壓璺嚎琛ㄦ暟鎹�
+                            sql = @"delete from TMateriel_Route where id in (select A.id   from TMateriel_Route A
+                                    left join TOrganization T on A.torg_code=T.org_code 
+                                    left join TOrganization as L on T.parent_id=L.id 
+                                    where 1=1 and  A.materiel_code=@partcode and  L.org_code=@stu_torgcode)";
+                            list.Add(new { str = sql, parm = new { partcode = partcode, stu_torgcode = stu_torgcode } });
+                            break;
+                        case "W":
+                            //娓呴櫎鐗╂枡鍏宠仈宸ヨ壓璺嚎琛ㄦ暟鎹�
+                            sql = @"delete from TMateriel_Route where id in (select A.id   from TMateriel_Route A
+                                    left join TOrganization T on A.torg_code=T.org_code 
+                                    left join TOrganization as L on T.parent_id=L.id 
+                                    where 1=1 and  A.materiel_code=@partcode and  T.org_code=@stu_torgcode)";
+                            list.Add(new { str = sql, parm = new { partcode = partcode, stu_torgcode = stu_torgcode } });
+                            break;
+                    }
                 }
                 else
                 {
-                    //娓呴櫎鐢ㄦ埛鍏宠仈瑙掕壊琛ㄦ暟鎹�
-                    sql = @"delete TMateriel_Route where materiel_code=@partcode";
-                    list.Add(new { str = sql, parm = new { partcode = partcode } });
+                    switch (stu_torgtypecode)
+                    {
+                        case "":
+                            //娓呴櫎鐗╂枡鍏宠仈宸ヨ壓璺嚎琛ㄦ暟鎹�
+                            sql = @"delete TMateriel_Route where materiel_code=@partcode";
+                            list.Add(new { str = sql, parm = new { partcode = partcode } });
+                            break;
+                        case "D":
+                            //娓呴櫎鐗╂枡鍏宠仈宸ヨ壓璺嚎琛ㄦ暟鎹�
+                            sql = @"delete from TMateriel_Route where id in (select A.id   from TMateriel_Route A
+                                    left join TOrganization T on A.torg_code=T.org_code 
+                                    left join TOrganization as L on T.parent_id=L.id 
+                                    where 1=1 and  A.materiel_code=@partcode and  L.org_code=@stu_torgcode)";
+                            list.Add(new { str = sql, parm = new { partcode = partcode, stu_torgcode = stu_torgcode } });
+                            break;
+                        case "W":
+                            //娓呴櫎鐗╂枡鍏宠仈宸ヨ壓璺嚎琛ㄦ暟鎹�
+                            sql = @"delete from TMateriel_Route where id in (select A.id   from TMateriel_Route A
+                                    left join TOrganization T on A.torg_code=T.org_code 
+                                    left join TOrganization as L on T.parent_id=L.id 
+                                    where 1=1 and  A.materiel_code=@partcode and  T.org_code=@stu_torgcode)";
+                            list.Add(new { str = sql, parm = new { partcode = partcode, stu_torgcode = stu_torgcode } });
+                            break;
+                    }
                     //寰幆鍐欏叆鐢ㄦ埛鍏宠仈瑙掕壊琛�
                     for (int i = 0; i < json.Count; i++)
                     {
-                        sql = @"insert into TMateriel_Route(materiel_code,route_code,lm_user,lm_date) values(@materiel_code,@route_code,@lm_user,@lm_date)";
+                        sql = @"insert into TMateriel_Route(materiel_code,route_code,lm_user,lm_date,torg_code) values(@materiel_code,@route_code,@lm_user,@lm_date,@torg_code)";
                         list.Add(new
                         {
                             str = sql,
@@ -768,13 +829,11 @@
                                 materiel_code = partcode,
                                 route_code = json[i].code,
                                 lm_user = username,
-                                lm_date = DateTime.Now.ToString()
+                                lm_date = DateTime.Now.ToString(),
+                                torg_code = json[i].wkshopcode
                             }
                         });
                     }
-                    //鏍囪鐗╂枡琛ㄥ叧鑱斿伐鑹鸿矾绾挎爣璇�
-                    sql = @"update TMateriel_Info set proute_id='Y',default_route=@defaultroute_code where partcode=@partcode";
-                    list.Add(new { str = sql, parm = new { partcode = partcode, defaultroute_code = defaultroute_code } });
                 }
                 bool aa = DapperHelper.DoTransaction(list);
                 if (aa)
@@ -1164,12 +1223,31 @@
 
 
         #region[宸ヨ壓璺嚎鏌ヨ]
-        public static ToMessage RouteSearch(string routecode, string routename, string description, string createuser, int startNum, int endNum, string prop, string order)
+        public static ToMessage RouteSearch(string stu_torgcode, string stu_torgtypecode, string WorkShop,string routecode, string routename, string description, string createuser, int startNum, int endNum, string prop, string order)
         {
             var dynamicParams = new DynamicParameters();
             string search = "";
             try
             {
+                if (WorkShop != "" && WorkShop != null)
+                {
+                    search += "and A.torg_code=@workShop ";
+                    dynamicParams.Add("@workShop", WorkShop);
+                }
+                else
+                {
+                    switch (stu_torgtypecode)
+                    {
+                        case "":
+                            search += "and T.description=@description ";
+                            dynamicParams.Add("@description", "W");
+                            break;
+                        case "D":
+                            search += "and  L.org_code=@stu_torgcode ";
+                            dynamicParams.Add("@stu_torgcode", stu_torgcode);
+                            break;
+                    }
+                }
                 if (routecode != "" && routecode != null)
                 {
                     search += "and A.code like '%'+@routecode+'%' ";
@@ -1196,8 +1274,10 @@
                 }
                 // --------------鏌ヨ鎸囧畾鏁版嵁--------------
                 var total = 0; //鎬绘潯鏁�
-                var sql = @"select A.id,A.code,A.name,A.description,A.enable,U.username as lm_user,A.lm_date  from TFlw_Rout A
+                var sql = @"select A.id,T.org_code,T.org_name,A.code,A.name,A.description,A.enable,U.username as lm_user,A.lm_date  from TFlw_Rout A
                             left join TUser U on A.lm_user=U.usercode
+                            left join TOrganization T on A.torg_code=T.org_code 
+                            left join TOrganization as L on T.parent_id=L.id 
                             where A.is_delete<>'1' " + search;
                 var data = DapperHelper.GetPageList<object>(sql, dynamicParams, prop, order, startNum, endNum, out total);
                 mes.code = "200";
@@ -1225,7 +1305,7 @@
             try
             {
                 //鑾峰彇宸ヨ壓璺嚎淇℃伅
-                sql = @"select code,name,description,enable 
+                sql = @"select code,name,description,enable,torg_code 
                         from TFlw_Rout
                         where code=@routecode and is_delete<>'1'";
                 dynamicParams.Add("@routecode", routecode);
@@ -1237,6 +1317,7 @@
                     rout.name = data.Rows[i]["NAME"].ToString();
                     rout.enable = data.Rows[i]["ENABLE"].ToString();
                     rout.description = data.Rows[i]["DESCRIPTION"].ToString();
+                    rout.wkshopcode = data.Rows[i]["torg_code"].ToString();
 
                     //鏍规嵁宸ヨ壓璺嚎缂栫爜鑾峰彇鍏宠仈鐨勫伐搴忎俊鎭�
                     sql = @"select A.seq,B.stepcode,B.stepname,B.enable from TFlw_Rtdt A
@@ -1285,8 +1366,8 @@
                         return mes;
                     }
                     //鏂板宸ヨ壓璺嚎琛�
-                    sql = @"insert into TFlw_Rout(code,name,description,enable,lm_user,lm_date) values(@code,@name,@description,@enable,@lm_user,@lm_date)";
-                    list.Add(new { str = sql, parm = new { code = json.code, name = json.name, description = json.description, enable = json.enable, lm_user = username, lm_date = DateTime.Now.ToString() } });
+                    sql = @"insert into TFlw_Rout(code,name,description,enable,lm_user,lm_date,torg_code) values(@code,@name,@description,@enable,@lm_user,@lm_date,@torg_code)";
+                    list.Add(new { str = sql, parm = new { code = json.code, name = json.name, description = json.description, enable = json.enable, lm_user = username, lm_date = DateTime.Now.ToString(), torg_code=json.wkshopcode } });
                     for (int i = 0; i < json.Data.Rows.Count; i++)
                     {
                         string is_firststep = "N"; //鏄惁棣栭亾宸ュ簭
@@ -1300,8 +1381,8 @@
                             is_laststep = "Y";
                         }
                         //鏂板宸ヨ壓璺嚎鍏宠仈宸ュ簭琛�
-                        sql = @"insert TFlw_Rtdt (rout_code,seq,step_code,first_choke,last_choke,lm_user,lm_date) values(@rout_code,@seq,@step_code,@first_choke,@last_choke,@lm_user,@lm_date)";
-                        list.Add(new { str = sql, parm = new { rout_code = json.code, seq = Convert.ToInt32(json.Data.Rows[i]["SEQ"].ToString()), step_code = json.Data.Rows[i]["STEPCODE"].ToString(), first_choke = is_firststep, last_choke = is_laststep, lm_user = username, lm_date = DateTime.Now.ToString() } });
+                        sql = @"insert TFlw_Rtdt (rout_code,seq,step_code,first_choke,last_choke,lm_user,lm_date,torg_code) values(@rout_code,@seq,@step_code,@first_choke,@last_choke,@lm_user,@lm_date,@torg_code)";
+                        list.Add(new { str = sql, parm = new { rout_code = json.code, seq = Convert.ToInt32(json.Data.Rows[i]["SEQ"].ToString()), step_code = json.Data.Rows[i]["STEPCODE"].ToString(), first_choke = is_firststep, last_choke = is_laststep, lm_user = username, lm_date = DateTime.Now.ToString(),torg_code=json.wkshopcode } });
                     }
                     bool aa = DapperHelper.DoTransaction(list);
                     if (aa)
@@ -1424,14 +1505,16 @@
 
 
         #region[宸ュ簭涓嬫媺鏌ヨ鎺ュ彛]
-        public static ToMessage StepSelect()
+        public static ToMessage StepSelect(string WorkShop)
         {
             string sql = "";
+            var dynamicParams = new DynamicParameters();
             try
             {
                 //鑾峰彇宸ュ簭鏁版嵁
-                sql = @"select stepcode,stepname from TStep where is_delete<>'1' and enable='Y'";
-                var data = DapperHelper.selecttable(sql);
+                sql = @"select stepcode,stepname from TStep where is_delete<>'1' and enable='Y' and torg_code=@torg_code";
+                dynamicParams.Add("@torg_code", WorkShop);
+                var data = DapperHelper.selectdata(sql, dynamicParams);
                 mes.code = "200";
                 mes.count = data.Rows.Count;
                 mes.Message = "鏌ヨ鎴愬姛!";
@@ -1449,12 +1532,31 @@
         #endregion
 
         #region[宸ュ簭鏌ヨ]
-        public static ToMessage StepSearch(string stepcode, string stepname, string enable, string steptypecode, string createuser, int startNum, int endNum, string prop, string order)
+        public static ToMessage StepSearch(string stu_torgcode,string stu_torgtypecode,string WorkShop, string stepcode, string stepname, string enable, string steptypecode, string createuser, int startNum, int endNum, string prop, string order)
         {
             var dynamicParams = new DynamicParameters();
             string search = "";
             try
             {
+                if (WorkShop != "" && WorkShop != null)
+                {
+                    search += "and A.torg_code=@workShop ";
+                    dynamicParams.Add("@workShop", WorkShop);
+                }
+                else
+                {
+                    switch (stu_torgtypecode)
+                    {
+                        case "":
+                            search += "and T.description=@description ";
+                            dynamicParams.Add("@description", "W");
+                            break;
+                        case "D":
+                            search += "and  L.org_code=@stu_torgcode ";
+                            dynamicParams.Add("@stu_torgcode", stu_torgcode);
+                            break;
+                    }
+                }
                 if (stepcode != "" && stepcode != null)
                 {
                     search += "and A.stepcode like '%'+@stepcode+'%' ";
@@ -1486,8 +1588,10 @@
                 }
                 // --------------鏌ヨ鎸囧畾鏁版嵁--------------
                 var total = 0; //鎬绘潯鏁�
-                var sql = @"select A.id,A.stepcode,A.stepname,A.flwtype,A.enable,A.descr,U.username as lm_user,A.lm_date,A.is_eqp,A.is_defect  from TStep A
+                var sql = @"select A.id,T.org_code,T.org_name,A.stepcode,A.stepname,A.flwtype,A.enable,A.descr,U.username as lm_user,A.lm_date,A.is_eqp,A.is_defect  from TStep A
                             left join TUser U on A.lm_user=U.usercode
+                            left join TOrganization T on A.torg_code=T.org_code 
+                            left join TOrganization as L on T.parent_id=L.id 
                             where A.is_delete<>'1' " + search;
                 var data = DapperHelper.GetPageList<object>(sql, dynamicParams, prop, order, startNum, endNum, out total);
                 mes.code = "200";
@@ -1507,7 +1611,7 @@
         #endregion
 
         #region[宸ュ簭鏂板缂栬緫]
-        public static ToMessage AddUpdateStep(string stepid, string stepcode, string stepname, string steptypecode, string enable, string description, string username, string operType)
+        public static ToMessage AddUpdateStep(string stepid,string WorkShop, string stepcode, string stepname, string steptypecode, string enable, string description, string username, string operType)
         {
             var dynamicParams = new DynamicParameters();
             List<object> list = new List<object>();
@@ -1527,8 +1631,8 @@
                         mes.data = null;
                         return mes;
                     }
-                    var sql = @"insert into TStep(stepcode,stepname,flwtype,enable,descr,lm_user,lm_date) 
-                            values(@stepcode,@stepname,@steptypecode,@enable,@description,@username,@CreateDate)";
+                    var sql = @"insert into TStep(stepcode,stepname,flwtype,enable,descr,lm_user,lm_date,torg_code) 
+                            values(@stepcode,@stepname,@steptypecode,@enable,@description,@username,@CreateDate,@torg_code)";
                     dynamicParams.Add("@stepcode", stepcode);
                     dynamicParams.Add("@stepname", stepname);
                     dynamicParams.Add("@steptypecode", steptypecode);
@@ -1536,6 +1640,7 @@
                     dynamicParams.Add("@description", description);
                     dynamicParams.Add("@username", username);
                     dynamicParams.Add("@CreateDate", DateTime.Now.ToString());
+                    dynamicParams.Add("@torg_code", WorkShop);
                     int cont = DapperHelper.SQL(sql, dynamicParams);
                     if (cont > 0)
                     {
@@ -1593,9 +1698,9 @@
                             list.Add(new { str = sql_1, parm = new { stepcode = stepcode } });
                         }
                     }
-                    sql_1 = @"update TStep set stepname=@stepname,flwtype=@steptypecode,enable=@enable,descr=@description,
+                    sql_1 = @"update TStep set torg_code=@torg_code, stepname=@stepname,flwtype=@steptypecode,enable=@enable,descr=@description,
                                 lm_user=@username,lm_date=@CreateDate where id=@stepid";
-                    list.Add(new { str = sql_1, parm = new { stepid = stepid, stepname = stepname, steptypecode = steptypecode, enable = enable, description = description, username = username, CreateDate = DateTime.Now.ToString() } });
+                    list.Add(new { str = sql_1, parm = new { torg_code=WorkShop, stepid = stepid, stepname = stepname, steptypecode = steptypecode, enable = enable, description = description, username = username, CreateDate = DateTime.Now.ToString() } });
                     bool aa = DapperHelper.DoTransaction(list);
                     if (aa)
                     {
@@ -1657,7 +1762,7 @@
                 sql = @"delete TDefect_Step  where step_code=@stepcode";
                 list.Add(new { str = sql, parm = new { stepcode = stepcode } });
                 //鍒犻櫎宸ュ簭
-                sql = @"update TStep set is_delete='1' where stepcode=@stepcode";
+                sql = @"delete TStep  where stepcode=@stepcode";
                 list.Add(new { str = sql, parm = new { stepcode = stepcode } });
                 bool aa = DapperHelper.DoTransaction(list);
                 if (aa)
@@ -1687,7 +1792,7 @@
         #endregion
 
         #region[宸ュ簭瀹氫箟鍏宠仈宸ヤ綔绔欐煡璇
-        public static ToMessage StepAssociationEqp(string stepcode)
+        public static ToMessage StepAssociationEqp(string WorkShop, string stepcode)
         {
             string sql = "";
             var dynamicParams = new DynamicParameters();
@@ -1700,7 +1805,7 @@
                         select distinct A.eqp_code,B.wksp_code  from TFlw_Rteqp A 
                         inner join TEqpInfo B on A.eqp_code=B.code 
                         where A.step_code=@stepcode and A.is_delete<>'1' and B.is_delete<>'1' and B.enable='Y'
-                        ) B on T.org_code=B.wksp_code where T.description='W' and is_delete<>'1'
+                        ) B on T.org_code=B.wksp_code where T.description='W' and is_delete<>'1' and T.org_code=@WorkShop
                         UNION ALL
                         select distinct T.type as wksp_code,(case when T.type='211' then '渚涘簲鍟�' when T.type='228' then '瀹㈡埛/渚涘簲鍟�' end ) as wksp_name,'W' as type,(case when B.type is null then 'N' else 'Y' end) flag 
                         from TCustomer T
@@ -1709,6 +1814,7 @@
                         inner join TCustomer B on A.eqp_code=B.code 
                         where A.step_code=@stepcode  and A.is_delete<>'1' and B.is_delete<>'1'
                         ) B on T.type=B.type where T.type in('211','228') and T.is_delete<>'1'"; //226(瀹㈡埛)
+                dynamicParams.Add("@WorkShop", WorkShop);
                 dynamicParams.Add("@stepcode", stepcode);
                 var data = DapperHelper.selectdata(sql, dynamicParams);
                 for (int i = 0; i < data.Rows.Count; i++)
@@ -1784,7 +1890,7 @@
         #endregion
 
         #region [宸ュ簭瀹氫箟鍏宠仈宸ヤ綔绔欐彁浜
-        public static ToMessage SaveStepAssociationEqp(string stepcode, string username, List<ObjectData> json)
+        public static ToMessage SaveStepAssociationEqp(string WorkShop,string stepcode, string username, List<ObjectData> json)
         {
             var sql = "";
             List<object> list = new List<object>();
@@ -1808,7 +1914,7 @@
                     //寰幆鍐欏叆鐢ㄦ埛鍏宠仈瑙掕壊琛�
                     for (int i = 0; i < json.Count; i++)
                     {
-                        sql = @"insert into TFlw_Rteqp(eqp_code,step_code,style,lm_user,lm_date) values(@eqp_code,@stepcode,@style,@lm_user,@lm_date)";
+                        sql = @"insert into TFlw_Rteqp(eqp_code,step_code,style,lm_user,lm_date,torg_code) values(@eqp_code,@stepcode,@style,@lm_user,@lm_date,@torg_code)";
                         list.Add(new
                         {
                             str = sql,
@@ -1818,7 +1924,8 @@
                                 stepcode = stepcode,
                                 style = json[i].name,
                                 lm_user = username,
-                                lm_date = DateTime.Now.ToString()
+                                lm_date = DateTime.Now.ToString(),
+                                torg_code=WorkShop
                             }
                         });
                     }
@@ -1854,19 +1961,24 @@
         #endregion
 
         #region[宸ュ簭鍏宠仈缂洪櫡鏌ヨ]
-        public static ToMessage StepAssociationDefect(string stepcode)
+        public static ToMessage StepAssociationDefect(string WorkShop,string stepcode)
         {
             string sql = "";
             var dynamicParams = new DynamicParameters();
             List<StepDefect> list = new List<StepDefect>();
             try
             {
+
                 //鑾峰彇宸ュ簭鍏宠仈缂洪櫡鏁版嵁(鍖呭惈鍏宠仈鏍囪瘑)
                 sql = @"select A.code,A.name,(case when B.defect_code is null then 'N' else 'Y' end) flag from TDefect A
                         left join(
-                        select distinct defect_code  from TDefect_Step where step_code=@stepcode and is_delete<>'1'
+                        select distinct defect_code  from TDefect_Step A
+                        left join TOrganization T on A.torg_code=T.org_code 
+                        left join TOrganization as L on T.parent_id=L.id 
+                        where step_code=@stepcode and A.is_delete<>'1' and T.org_code=@WorkShop
                         ) B on A.code=B.defect_code";
                 dynamicParams.Add("@stepcode", stepcode);
+                dynamicParams.Add("@WorkShop", WorkShop);
                 var data = DapperHelper.selectdata(sql, dynamicParams);
                 for (int i = 0; i < data.Rows.Count; i++)
                 {
@@ -1892,7 +2004,7 @@
         #endregion
 
         #region[宸ュ簭鍏宠仈缂洪櫡鎻愪氦]
-        public static ToMessage SaveStepAssociationDefect(string stepcode, string username, List<ObjectData> json)
+        public static ToMessage SaveStepAssociationDefect(string WorkShop,string stepcode, string username, List<ObjectData> json)
         {
             var sql = "";
             List<object> list = new List<object>();
@@ -1916,7 +2028,7 @@
                     //寰幆鍐欏叆鐢ㄦ埛鍏宠仈瑙掕壊琛�
                     for (int i = 0; i < json.Count; i++)
                     {
-                        sql = @"insert into TDefect_Step(defect_code,step_code,lm_user,lm_date) values(@defect_code,@stepcode,@lm_user,@lm_date)";
+                        sql = @"insert into TDefect_Step(defect_code,step_code,lm_user,lm_date,torg_code) values(@defect_code,@stepcode,@lm_user,@lm_date,@torg_code)";
                         list.Add(new
                         {
                             str = sql,
@@ -1925,7 +2037,8 @@
                                 defect_code = json[i].code,
                                 stepcode = stepcode,
                                 lm_user = username,
-                                lm_date = DateTime.Now.ToString()
+                                lm_date = DateTime.Now.ToString(),
+                                torg_code= WorkShop
                             }
                         });
                     }
@@ -1993,17 +2106,35 @@
         #endregion
 
         #region[浜у搧缂栫爜鏌ユ壘宸ヨ壓璺嚎涓嬫媺妗哴
-        public static ToMessage PartSelectRpute(string partcode)
+        public static ToMessage PartSelectRpute(string stu_torgcode,string stu_torgtypecode,string partcode)
         {
             string sql = "";
+            string search = "";
             var dynamicParams = new DynamicParameters();
             try
             {
+                switch (stu_torgtypecode)
+                {
+                    case "":
+                        break;
+                    case "D":
+                        search += "and L.org_code=@stu_torgcode ";
+                        dynamicParams.Add("@stu_torgcode", stu_torgcode);
+                        break;
+                    case "W":
+                        search += "and T.org_code=@stu_torgcode ";
+                        dynamicParams.Add("@stu_torgcode", stu_torgcode);
+                        break;
+                    default:
+                        break;
+                }
                 //閫氳繃浜у搧缂栫爜鏌ユ壘鍏宠仈鐨勫伐鑹鸿矾绾夸俊鎭�
                 sql = @"select A.route_code,B.name as route_name   
                         from TMateriel_Route A
                         inner join TFlw_Rout B on A.route_code=B.code 
-                        where A.materiel_code=@partcode and B.is_delete<>'1' and A.is_delete<>'1'";
+                        left join TOrganization T on A.torg_code=T.org_code 
+                        left join TOrganization as L on T.parent_id=L.id
+                        where A.materiel_code=@partcode and B.is_delete<>'1' and A.is_delete<>'1' "+search;
                 dynamicParams.Add("@partcode", partcode);
                 var data = DapperHelper.selectdata(sql, dynamicParams);
                 mes.code = "200";
@@ -2172,12 +2303,27 @@
         #endregion
 
         #region[鑺傛媿宸ヤ环鏌ヨ]
-        public static ToMessage BeatRateSearch(string partcode, string routecode, string stepcode, string eqpcode, int startNum, int endNum, string prop, string order)
+        public static ToMessage BeatRateSearch(string stu_torgcode,string stu_torgtypecode,string partcode, string routecode, string stepcode, string eqpcode, int startNum, int endNum, string prop, string order)
         {
             var dynamicParams = new DynamicParameters();
             string search = "";
             try
             {
+                switch (stu_torgtypecode)
+                {
+                    case "":
+                        break;
+                    case "D":
+                        search += "and L.org_code=@stu_torgcode ";
+                        dynamicParams.Add("@stu_torgcode", stu_torgcode);
+                        break;
+                    case "W":
+                        search += "and F.org_code=@stu_torgcode ";
+                        dynamicParams.Add("@stu_torgcode", stu_torgcode);
+                        break;
+                    default:
+                        break;
+                }
                 if (partcode != "" && partcode != null)
                 {
                     search += "and A.materiel_code=@partcode ";
@@ -2213,6 +2359,7 @@
                             left join TStep D on A.step_code=D.stepcode
                             left join TEqpInfo E on A.eqp_code=E.code
                             left join TOrganization F on E.wksp_code=F.org_code
+                            left join TOrganization L on  F.parent_id=L.id
                             where B.is_delete<>'1' and C.is_delete<>'1' and D.is_delete<>'1' and E.is_delete<>'1' and F.is_delete<>'1' " + search;
                 var data = DapperHelper.GetPageList<object>(sql, dynamicParams, prop, order, startNum, endNum, out total);
                 mes.code = "200";

--
Gitblit v1.9.3