From ece3372b4f7500483092a90f2a1e40f3586f6f1b Mon Sep 17 00:00:00 2001
From: yl <ykxkd@outlook.com>
Date: 星期四, 23 六月 2022 18:47:14 +0800
Subject: [PATCH] 存货档案、工艺路线(新增、编辑、删除、关联工艺路线)

---
 VueWebApi/DLL/DAL/ProductModelDAL.cs |  687 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 682 insertions(+), 5 deletions(-)

diff --git a/VueWebApi/DLL/DAL/ProductModelDAL.cs b/VueWebApi/DLL/DAL/ProductModelDAL.cs
index 336984c..f92eef6 100644
--- a/VueWebApi/DLL/DAL/ProductModelDAL.cs
+++ b/VueWebApi/DLL/DAL/ProductModelDAL.cs
@@ -265,10 +265,10 @@
                         {
                             code = json[i].code,
                             name = json[i].name,
-                            digdect=json[i].digdect,
-                            r_ule=json[i].r_ule,
-                            username= username,
-                            CreateDate= DateTime.Now.ToString()
+                            digdect = json[i].digdect,
+                            r_ule = json[i].r_ule,
+                            username = username,
+                            CreateDate = DateTime.Now.ToString()
                         }
                     });
                 }
@@ -638,7 +638,7 @@
                     rout.code = data.Rows[i]["CODE"].ToString();
                     rout.name = data.Rows[i]["NAME"].ToString();
                     rout.flag = data.Rows[i]["FLAG"].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
@@ -664,5 +664,682 @@
         }
         #endregion
 
+        #region[瀛樿揣妗f鍏宠仈宸ヨ壓璺嚎鎻愪氦]
+        public static ToMessage SaveInventoryFile(string partcode, string username, List<ObjectData> json)
+        {
+            var sql = "";
+            List<object> list = new List<object>();
+            try
+            {
+                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' where partcode=@partcode";
+                    list.Add(new { str = sql, parm = new { partcode = partcode } });
+                }
+                else
+                {
+                    //娓呴櫎鐢ㄦ埛鍏宠仈瑙掕壊琛ㄦ暟鎹�
+                    sql = @"delete TMateriel_Route where materiel_code=@partcode";
+                    list.Add(new { str = sql, parm = new { partcode = partcode } });
+                    //寰幆鍐欏叆鐢ㄦ埛鍏宠仈瑙掕壊琛�
+                    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)";
+                        list.Add(new
+                        {
+                            str = sql,
+                            parm = new
+                            {
+                                materiel_code = partcode,
+                                route_code = json[i].code,
+                                lm_user = username,
+                                lm_date = DateTime.Now.ToString()
+                            }
+                        });
+                    }
+                    //鏍囪鐗╂枡琛ㄥ叧鑱斿伐鑹鸿矾绾挎爣璇�
+                    sql = @"update TMateriel_Info set proute_id='Y' where partcode=@partcode";
+                    list.Add(new { str = sql, parm = new { partcode = partcode } });
+                }
+                bool aa = DapperHelper.DoTransaction(list);
+                if (aa)
+                {
+                    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 RouteSearch(string routecode, string routename, string description, string createuser, int startNum, int endNum, string prop, string order)
+        {
+            var dynamicParams = new DynamicParameters();
+            string search = "";
+            try
+            {
+                if (routecode != "" && routecode != null)
+                {
+                    search += "and code like '%'+@partcode+'%' ";
+                    dynamicParams.Add("@routecode", routecode);
+                }
+                if (routename != "" && routename != null)
+                {
+                    search += "and name like '%'+@routename+'%' ";
+                    dynamicParams.Add("@routename", routename);
+                }
+                if (description != "" && description != null)
+                {
+                    search += "and description=@description ";
+                    dynamicParams.Add("@description", description);
+                }
+                if (createuser != "" && createuser != null)
+                {
+                    search += "and lm_user=@createuser ";
+                    dynamicParams.Add("@createuser", createuser);
+                }
+                if (search == "")
+                {
+                    search = "and 1=1 ";
+                }
+                // --------------鏌ヨ鎸囧畾鏁版嵁--------------
+                var total = 0; //鎬绘潯鏁�
+                var sql = @"select code,name,description,enable,lm_user,lm_date  
+                            from TFlw_Rout
+                            where is_delete<>'1' " + search;
+                var data = DapperHelper.GetPageList<object>(sql, dynamicParams, prop, order, startNum, endNum, out total);
+                mes.code = "200";
+                mes.Message = "鏌ヨ鎴愬姛!";
+                mes.count = total;
+                mes.data = data.ToList();
+            }
+            catch (Exception e)
+            {
+                mes.code = "300";
+                mes.count = 0;
+                mes.Message = e.Message;
+                mes.data = null;
+            }
+            return mes;
+        }
+        #endregion
+
+        #region[宸ヨ壓璺嚎棰勮]
+        public static ToMessage ViewRoute(string routecode)
+        {
+            string sql = "";
+            var dynamicParams = new DynamicParameters();
+            List<RoutEdit> list = new List<RoutEdit>();
+            try
+            {
+                //鑾峰彇宸ヨ壓璺嚎淇℃伅
+                sql = @"select code,name,description,enable 
+                        from TFlw_Rout
+                        where code=@routecode and is_delete<>'1'";
+                dynamicParams.Add("@routecode", routecode);
+                var data = DapperHelper.selectdata(sql, dynamicParams);
+                for (int i = 0; i < data.Rows.Count; i++)
+                {
+                    RoutEdit rout = new RoutEdit();
+                    rout.code = data.Rows[i]["CODE"].ToString();
+                    rout.name = data.Rows[i]["NAME"].ToString();
+                    rout.enable = data.Rows[i]["ENABLE"].ToString();
+                    rout.description = data.Rows[i]["DESCRIPTION"].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
+                            where A.rout_code=@route_code and B.is_delete<>'1' order by A.seq asc";
+                    dynamicParams.Add("@route_code", rout.code);
+                    var data0 = DapperHelper.selectdata(sql, dynamicParams);
+                    rout.Data = data0;
+                    list.Add(rout);
+
+                }
+                mes.code = "200";
+                mes.Message = "鏌ヨ鎴愬姛!";
+                mes.data = list;
+            }
+            catch (Exception e)
+            {
+                mes.code = "300";
+                mes.count = 0;
+                mes.Message = e.Message;
+                mes.data = null;
+            }
+            return mes;
+        }
+        #endregion
+
+        #region[宸ヨ壓璺嚎鏂板]
+        public static ToMessage AddUpdateRoute(string id, string opertype, string username, RoutEdit json)
+        {
+            var sql = "";
+            var dynamicParams = new DynamicParameters();
+            List<object> list = new List<object>();
+            try
+            {
+                if (opertype == "Add")
+                {
+                    //鏂板宸ヨ壓璺嚎琛�
+                    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() } });
+                    string is_firststep = "N"; //鏄惁棣栭亾宸ュ簭
+                    string is_laststep = "N"; //鏄惁鏈亾宸ュ簭
+                    for (int i = 0; i < json.Data.Rows.Count; i++)
+                    {
+                        if (json.Data.Rows[i]["SEQ"].ToString() == "1")  //鏄惁棣栭亾宸ュ簭
+                        {
+                            is_firststep = "Y";
+                        }
+                        if (Convert.ToInt32(json.Data.Rows[i]["SEQ"].ToString()) == json.Data.Rows.Count) //鏄惁鏈亾宸ュ簭
+                        {
+                            is_laststep = "Y";
+                        }
+                        //鏂板宸ヨ壓璺嚎鍏宠仈宸ュ簭琛�
+                        sql = @"insert TFlw_Rtdt (rout_code,seq,step_code,first_choke,last_choke,lm_user,lm_date) values()";
+                        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() } });
+                    }
+                    bool aa = DapperHelper.DoTransaction(list);
+                    if (aa)
+                    {
+                        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 DeleteRoute(string routecode)
+        {
+            var sql = "";
+            List<object> list = new List<object>();
+            var dynamicParams = new DynamicParameters();
+            try
+            {
+                //鍒ゆ柇宸ヨ壓璺嚎鏄惁琚伐鍗曞紩鐢�(琚紩鐢ㄥ垯涓嶈兘鍒犻櫎)
+                sql = @"select *   from TK_Wrk_Man where route_code=@routecode";
+                dynamicParams.Add("@routecode", routecode);
+                var data = DapperHelper.selectdata(sql, dynamicParams);
+                if (data.Rows.Count > 0)
+                {
+                    mes.code = "300";
+                    mes.count = 0;
+                    mes.Message = "宸ヨ壓璺嚎宸茶宸ュ崟寮曠敤锛屼笉鍏佽鍒犻櫎!";
+                    mes.data = null;
+                }
+                else 
+                {
+                    //鍒ゆ柇褰撳墠宸ヨ壓璺嚎鏄惁鏈夎缃妭鎷嶅伐浠�(鏈夎缃紝鎻愮ず鍏堝垹闄よ妭鎷嶅伐浠疯缃�)
+                    sql = @"select *   from TPrteEqp_Stad where route_code=@routecode";
+                    dynamicParams.Add("@routecode", routecode);
+                    var data0 = DapperHelper.selectdata(sql, dynamicParams);
+                    if (data0.Rows.Count > 0)
+                    {
+                        mes.code = "300";
+                        mes.count = 0;
+                        mes.Message = "宸ヨ壓璺嚎宸茶缃妭鎷嶅伐浠凤紝璇峰厛鍒犻櫎璁剧疆!";
+                        mes.data = null;
+                    }
+                    else 
+                    {
+                        //鍒犻櫎宸ヨ壓璺嚎鍏宠仈宸ュ簭琛�
+                        sql = @"delete TFlw_Rtdt  where rout_code=@routecode";
+                        list.Add(new { str = sql, parm = new { routecode = routecode } });
+                        //鍒犻櫎宸ヨ壓璺嚎琛�
+                        sql = @"delete TFlw_Rout  where code=@routecode";
+                        list.Add(new { str = sql, parm = new { routecode = routecode } });
+                        //鍒犻櫎鐗╂枡鍏宠仈宸ヨ壓璺嚎琛�
+                        sql = @"delete TMateriel_Route  where route_code=@routecode";
+                        list.Add(new { str = sql, parm = new { routecode = routecode } });
+                    }
+                }
+                bool aa = DapperHelper.DoTransaction(list);
+                if (aa)
+                {
+                    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 StepSearch(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 (stepcode != "" && stepcode != null)
+                {
+                    search += "and stepcode like '%'+@stepcode+'%' ";
+                    dynamicParams.Add("@stepcode", stepcode);
+                }
+                if (stepname != "" && stepname != null)
+                {
+                    search += "and stepname like '%'+@stepname+'%' ";
+                    dynamicParams.Add("@stepname", stepname);
+                }
+                if (enable != "" && enable != null)
+                {
+                    search += "and enable=@enable ";
+                    dynamicParams.Add("@enable", enable);
+                }
+                if (steptypecode != "" && steptypecode != null)
+                {
+                    search += "and flwtype=@steptypecode ";
+                    dynamicParams.Add("@steptypecode", steptypecode);
+                }
+                if (createuser != "" && createuser != null)
+                {
+                    search += "and lm_user=@createuser ";
+                    dynamicParams.Add("@createuser", createuser);
+                }
+                if (search == "")
+                {
+                    search = "and 1=1 ";
+                }
+                // --------------鏌ヨ鎸囧畾鏁版嵁--------------
+                var total = 0; //鎬绘潯鏁�
+                var sql = @"select stepcode,stepname,flwtype,enable,descr,lm_user,lm_date,is_eqp,is_defect  
+                            from TStep
+                            where is_delete<>'1' " + search;
+                var data = DapperHelper.GetPageList<object>(sql, dynamicParams, prop, order, startNum, endNum, out total);
+                mes.code = "200";
+                mes.Message = "鏌ヨ鎴愬姛!";
+                mes.count = total;
+                mes.data = data.ToList();
+            }
+            catch (Exception e)
+            {
+                mes.code = "300";
+                mes.count = 0;
+                mes.Message = e.Message;
+                mes.data = null;
+            }
+            return mes;
+        }
+        #endregion
+
+        #region[宸ュ簭鏂板缂栬緫]
+        public static ToMessage AddUpdateStep(string stepid, string stepcode, string stepname, string steptypecode, string enable, string description, string username, string operType)
+        {
+            var dynamicParams = new DynamicParameters();
+            try
+            {
+                if (operType == "Add")
+                {
+                    var sql = @"insert into TStep(stepcode,stepname,flwtype,enable,descr,lm_user,lm_date) 
+                            values(@stepcode,@stepname,@steptypecode,@enable,@description,@username,@CreateDate)";
+                    dynamicParams.Add("@stepcode", stepcode);
+                    dynamicParams.Add("@stepname", stepname);
+                    dynamicParams.Add("@steptypecode", steptypecode);
+                    dynamicParams.Add("@enable", enable);
+                    dynamicParams.Add("@description", description);
+                    dynamicParams.Add("@username", username);
+                    dynamicParams.Add("@CreateDate", DateTime.Now.ToString());
+                    int cont = DapperHelper.SQL(sql, dynamicParams);
+                    if (cont > 0)
+                    {
+                        mes.code = "200";
+                        mes.count = 0;
+                        mes.Message = "鏂板鎿嶄綔鎴愬姛!";
+                        mes.data = null;
+                    }
+                    else
+                    {
+                        mes.code = "300";
+                        mes.count = 0;
+                        mes.Message = "鏂板鎿嶄綔澶辫触!";
+                        mes.data = null;
+                    }
+                }
+                if (operType == "Update")
+                {
+                    //濡傛灉褰撳墠宸ュ簭浣跨敤鐘舵�佷綅N(鏈惎鐢�),闇�鍒ゆ柇褰撳墠宸ュ簭瀵瑰簲宸ヨ壓璺嚎琚紩鐢ㄧ殑宸ュ崟鏄惁鍏抽棴
+                    if (enable == "N")
+                    {
+                        var sql0 = @"select *  from TFlw_Rtdt A
+                                 inner join TK_Wrk_Man B on A.rout_code=B.route_code
+                                 where A.step_code=@stepcode and B.status<>'CLOSED'";
+                        dynamicParams.Add("@stepcode", stepcode);
+                        var data = DapperHelper.selectdata(sql0, dynamicParams);
+                        if (data.Rows.Count > 0)
+                        {
+                            mes.code = "300";
+                            mes.count = 0;
+                            mes.Message = "宸ュ簭鏈変负鎵ц瀹岀殑宸ュ崟,宸ュ簭鐘舵�佷笉鑳戒负鏈惎鐢�!";
+                            mes.data = null;
+                            return mes;
+                        }
+                    }
+
+                    var sql = @"update TStep set stepname=@stepname,flwtype=@steptypecode,enable=@enable,descr=@description,
+                                lm_user=@username,lm_date=@CreateDate where id=@stepid";
+                    dynamicParams.Add("@stepid", stepid);
+                    dynamicParams.Add("@stepname", stepname);
+                    dynamicParams.Add("@steptypecode", steptypecode);
+                    dynamicParams.Add("@enable", enable);
+                    dynamicParams.Add("@description", description);
+                    dynamicParams.Add("@username", username);
+                    dynamicParams.Add("@CreateDate", DateTime.Now.ToString());
+                    int cont = DapperHelper.SQL(sql, dynamicParams);
+                    if (cont > 0)
+                    {
+                        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 DeleteStep(string stepcode)
+        {
+            var sql = "";
+            List<object> list = new List<object>();
+            var dynamicParams = new DynamicParameters();
+            try
+            {
+                list.Clear();
+                //褰撳墠宸ュ簭鏄惁鍏宠仈宸ヨ壓璺嚎
+                sql = @"select *  from TFlw_Rtdt 
+                        where step_code=@stepcode";
+                dynamicParams.Add("@stepcode", stepcode);
+                var data = DapperHelper.selectdata(sql, dynamicParams);
+                if (data.Rows.Count > 0)
+                {
+                    mes.code = "300";
+                    mes.count = 0;
+                    mes.Message = "宸ュ簭宸插叧鑱斿伐鑹鸿矾绾�,涓嶅厑璁稿垹闄�!";
+                    mes.data = null;
+                    return mes;
+                }
+
+                //鍒犻櫎璁惧鑺傛媿宸ヤ环琛�
+                sql = @"delete TPrteEqp_Stad  where stepcode=@stepcode";
+                list.Add(new { str = sql, parm = new { stepcode = stepcode } });
+                //鍒犻櫎宸ュ簭鍏宠仈宸ヤ綔绔欒〃
+                sql = @"delete TFlw_Rteqp   where step_code=@stepcode";
+                list.Add(new { str = sql, parm = new { stepcode = stepcode } });
+                //鍒犻櫎缂洪櫡鍏宠仈宸ュ簭琛�
+                sql = @"update TDefect_Step  where step_code=@stepcode";
+                list.Add(new { str = sql, parm = new { stepcode = stepcode } });
+                //鍒犻櫎宸ュ簭
+                sql = @"update TStep set is_delete='1' where partcode=@stepcode";
+                list.Add(new { str = sql, parm = new { stepcode = stepcode } });
+                bool aa = DapperHelper.DoTransaction(list);
+                if (aa)
+                {
+                    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 StepAssociationEqp(string stepcode)
+        {
+            string sql = "";
+            var dynamicParams = new DynamicParameters();
+            List<StepEqp> list = new List<StepEqp>();
+            try
+            {
+                //鑾峰彇宸ヤ綔绔欓泦鍚�(杞﹂棿銆佸鍗忎緵搴斿晢,鍖呭惈宸茬粦瀹氬伐浣滅珯鏍囪瘑)
+                sql = @"select distinct T.org_code as wksp_code,T.org_name as wksp_name,'E' as type,(case when B.eqp_code is null then 'N' else 'Y' end) flag from TOrganization T
+                        left join(
+                        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'
+                        ) B on T.org_code=B.wksp_code where T.description='W' and is_delete<>'1'
+                        UNION ALL
+                        select distinct T.btype as wksp_code,(case T.btype  when 'WX' then '澶栧崗渚涙柟' end ) as wksp_name,'W' as type,(case when B.btype is null then 'N' else 'Y' end) flag 
+                        from TCustomer T
+                        left join(
+                        select distinct A.eqp_code,B.btype  from TFlw_Rteqp A 
+                        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.code=B.eqp_code where T.btype='WX' and T.is_delete<>'1'";
+                dynamicParams.Add("@stepcode", stepcode);
+                var data = DapperHelper.selectdata(sql, dynamicParams);
+                for (int i = 0; i < data.Rows.Count; i++)
+                {
+                    StepEqp rout = new StepEqp();
+                    rout.code = data.Rows[i]["WKSP_CODE"].ToString();
+                    rout.name = data.Rows[i]["WKSP_NAME"].ToString();
+                    rout.type = data.Rows[i]["TYPE"].ToString();
+                    rout.flag = data.Rows[i]["FLAG"].ToString();
+                    rout.children = new List<StepEqpCn>();
+                    if (rout.code == "WX") //澶栧崗渚涙柟
+                    {
+                        //鏍规嵁澶栧崗渚涙柟鏍囪瘑缂栫爜鏌ユ壘澶栧崗渚涙柟淇℃伅(鍖呭惈宸插叧鑱旀爣璇�)
+                        sql = @"select A.code,A.name,'W' as type,(case when B.eqp_code is null then 'N' else 'Y' end) flag
+                                from TCustomer A
+                                left join(
+                                select distinct A.eqp_code  from TFlw_Rteqp A 
+                                inner join TCustomer B on A.eqp_code=B.code 
+                                where B.btype=@wxcode and A.is_delete<>'1' and B.is_delete<>'1'
+                                ) B on A.code=B.eqp_code where A.btype=@wxcode and A.is_delete<>'1'";
+                        dynamicParams.Add("@wxcode", rout.code);
+                        var data0 = DapperHelper.selectdata(sql, dynamicParams);
+                        for (int k = 0; k < data0.Rows.Count; k++)
+                        {
+                            StepEqpCn cn = new StepEqpCn();
+                            cn.code = data0.Rows[k]["CODE"].ToString();//澶栧崗渚涙柟缂栫爜
+                            cn.name = data0.Rows[k]["NAME"].ToString();//澶栧崗渚涙柟鍚嶇О
+                            cn.type = data0.Rows[k]["TYPE"].ToString();//宸ヤ綔绔欑被鍨�(E:璁惧 W:澶栧崗渚涙柟)
+                            cn.flag = data0.Rows[k]["FLAG"].ToString();//鍏宠仈鏍囪瘑
+                            rout.children.Add(cn);
+                        }
+                        list.Add(rout);
+                    }
+                    else
+                    {
+                        //鏍规嵁杞﹂棿缂栫爜鏌ユ壘璁惧(鍖呭惈宸插叧鑱旀爣璇�)
+                        sql = @"select A.code,A.name,'E' as type,(case when B.eqp_code is null then 'N' else 'Y' end) flag
+                              from TEqpInfo A
+                              left join(
+                              select distinct A.eqp_code  from TFlw_Rteqp A 
+                              inner join TEqpInfo B on A.eqp_code=B.code 
+                              where B.wksp_code='W001' and A.is_delete<>'1' and B.is_delete<>'1'
+                              ) B on A.code=B.eqp_code and A.is_delete<>'1'";
+                        dynamicParams.Add("@stepcode", stepcode);
+                        var data0 = DapperHelper.selectdata(sql, dynamicParams);
+                        for (int j = 0; j < data0.Rows.Count; j++)
+                        {
+                            StepEqpCn cn = new StepEqpCn();
+                            cn.code= data0.Rows[j]["CODE"].ToString();//璁惧缂栫爜
+                            cn.name = data0.Rows[j]["NAME"].ToString();//璁惧鍚嶇О
+                            cn.type = data0.Rows[j]["TYPE"].ToString();//宸ヤ綔绔欑被鍨�(E:璁惧 W:澶栧崗渚涙柟)
+                            cn.flag = data0.Rows[j]["FLAG"].ToString();//鍏宠仈鏍囪瘑
+                            rout.children.Add(cn);
+                        }
+                        list.Add(rout);
+                    }
+                }
+                mes.code = "200";
+                mes.Message = "鏌ヨ鎴愬姛!";
+                mes.data = list;
+            }
+            catch (Exception e)
+            {
+                mes.code = "300";
+                mes.count = 0;
+                mes.Message = e.Message;
+                mes.data = null;
+            }
+            return mes;
+        }
+        #endregion
+
+        #region [宸ュ簭瀹氫箟鍏宠仈宸ヤ綔绔欐彁浜
+        public static ToMessage SaveStepAssociationEqp(string stepcode, string username, List<ObjectData> json)
+        {
+            var sql = "";
+            List<object> list = new List<object>();
+            try
+            {
+                list.Clear();
+                if (json == null || json.Count <= 0)
+                {
+                    //娓呴櫎宸ュ簭鍏宠仈宸ヤ綔绔欒〃鏁版嵁
+                    sql = @"delete TFlw_Rteqp where step_code=@stepcode";
+                    list.Add(new { str = sql, parm = new { stepcode = stepcode } });
+                    //鏍囪宸ュ簭琛ㄥ叧鑱斿伐浣滅珯鏍囪瘑
+                    sql = @"update TStep is_eqp='N' where stepcode=@stepcode";
+                    list.Add(new { str = sql, parm = new { stepcode = stepcode } });
+                }
+                else
+                {
+                    //娓呴櫎宸ュ簭鍏宠仈宸ヤ綔绔欒〃鏁版嵁
+                    sql = @"delete TFlw_Rteqp where step_code=@stepcode";
+                    list.Add(new { str = sql, parm = new { stepcode = stepcode } });
+                    //寰幆鍐欏叆鐢ㄦ埛鍏宠仈瑙掕壊琛�
+                    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)";
+                        list.Add(new
+                        {
+                            str = sql,
+                            parm = new
+                            {
+                                eqp_code = json[i].code,
+                                stepcode = stepcode,
+                                style = json[i].name,
+                                lm_user = username,
+                                lm_date = DateTime.Now.ToString()
+                            }
+                        });
+                    }
+                    //鏍囪鐗╂枡琛ㄥ叧鑱斿伐鑹鸿矾绾挎爣璇�
+                    sql = @"update TStep set is_eqp='Y' where stepcode=@stepcode";
+                    list.Add(new { str = sql, parm = new { stepcode = stepcode } });
+                }
+                bool aa = DapperHelper.DoTransaction(list);
+                if (aa)
+                {
+                    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
     }
 }
\ No newline at end of file

--
Gitblit v1.9.3