智云MES后端API代码
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
yusijie
2024-10-07 d8fc6ac36336cb02a00f1e5f4e90b7bdfb34fb85 
 WebAPI/Controllers/LMESController.cs


@@ -1,6 +1,7 @@


using Newtonsoft.Json;


using Newtonsoft.Json.Linq;


using Pub_Class;


using SyntacticSugar.constant;


using System;


using System.Collections;


using System.Collections.Generic;


@@ -191,7 +192,7 @@


                SQLHelper.ClsCN oCN = new SQLHelper.ClsCN();






                ds = oCN.RunProcReturn("select * from h_v_Sc_ProcessExchangeBillList_Query where 1 = 1 " + sWhere + " order by hmainid desc ", "h_v_Sc_ProcessExchangeBillList_Query");


                ds = oCN.RunProcReturn("select * from h_v_Sc_ProcessExchangeBillList_Query where 1 = 1 " + sWhere + " order by 日期 desc ", "h_v_Sc_ProcessExchangeBillList_Query");






                //添加列名


@@ -510,7 +511,16 @@


                        objJsonResult.data = null;


                        return objJsonResult;


                    }




                    ds = oCN.RunProcReturn(@"select * from Sc_ICMOBillStatus_Tmp where HSourceInterID='"+ HInterID + "'   and  HSourceEntryID='"+ HEntryID + "'", "Sc_ICMOBillStatus_Tmp");


                    if (ds.Tables[0].Rows.Count != 0)


                    {


                        objJsonResult.code = "0";


                        objJsonResult.count = 0;


                        objJsonResult.Message = "该工序已派单,不允许重复排单！";


                        objJsonResult.data = null;


                        return objJsonResult;


                    }


                   


                    oCN.BeginTran();




                    oCN.RunProc("update Sc_ProcessExchangeBillSub set HSourceID=" + HSourceID + " where HInterID=" + HInterID + " and HEntryID=" + HEntryID);


@@ -1105,6 +1115,60 @@




        #region 工艺路线




        #region 工艺路线分页列表


        [Route("Gy_RoutingBill/page")]


        [HttpGet]


        public json Gy_RoutingBillPage(string sWhere, string user, int page, int size)


        {


            DataSet ds;


            json res = new json();


            try


            {


                List<object> columnNameList = new List<object>();


                //编辑权限


                if (!DBUtility.ClsPub.Security_Log_second("Gy_RoutingBill_Query", 1, false, user))


                {


                    res.code = "0";


                    res.count = 0;


                    res.Message = "无查看权限！";


                    res.data = null;


                    return res;


                }


                if (sWhere == null || sWhere.Equals(""))


                {


                    ds = oCN.RunProcReturn("exec h_p_Gy_RoutingBillList " + page + "," + size + ",''", "h_p_Gy_RoutingBillList");


                }


                else


                {


                    ds = oCN.RunProcReturn("exec h_p_Gy_RoutingBillList " + page + "," + size + ",'" + sWhere + "'", "h_p_Gy_RoutingBillList");


                }




                //添加列名


                foreach (DataColumn col in ds.Tables[0].Columns)


                {


                    Type dataType = col.DataType;


                    string ColmString = "{\"ColmCols\":\"" + col.ColumnName + "\",\"ColmType\":\"" + dataType.Name + "\"}";


                    columnNameList.Add(JsonConvert.DeserializeObject(ColmString));//获取到DataColumn列对象的列名


                }




                res.code = CodeConstant.SUCCEED;


                res.count = int.Parse(ds.Tables[1].Rows[0]["count"].ToString());


                res.Message = "Sucess！";


                res.list = columnNameList;


                res.data = ds.Tables[0];


                return res;


            }


            catch (Exception e)


            {


                res.code = CodeConstant.FAIL;


                res.count = CountConstant.FAIL;


                res.Message = "Exception！" + e.ToString();


                res.data = null;


                return objJsonResult;


            }


        }


        #endregion




        #region 工艺路线列表


        /// <summary>


        /// 返回工艺路线列表


@@ -1118,6 +1182,7 @@


            DataSet ds;


            try


            {


                List<object> columnNameList = new List<object>();


                if (HBillSubType == "SUB")


                {


                    //判断是否有查询权限


@@ -1169,13 +1234,25 @@


                {


                    string sql1 = "select * from h_v_Gy_RoutingBillList where 1 = 1 ";


                    //客户自定义


                    if (oSystemParameter.omodel.WMS_CampanyName == "瑞与祺" || oSystemParameter.omodel.WMS_CampanyName == "凯贝奈特")


                    if (oSystemParameter.omodel.WMS_CampanyName == "瑞与祺" || oSystemParameter.omodel.WMS_CampanyName == "凯贝奈特" || oSystemParameter.omodel.WMS_CampanyName == "添康科技")


                    {


                         sql1 = "select top 1000 * from h_v_Gy_RoutingBillList where 1 = 1 ";


                    }


                    string sql = sql1 + sWhere + " order by hmainid desc,cast(工序号 as int)";


                    ds = oCN.RunProcReturn(sql, "h_v_Gy_RoutingBillList");


                }   //添加列名


                foreach (DataColumn col in ds.Tables[0].Columns)


                {


                    Type dataType = col.DataType;


                    string ColmString = "{\"ColmCols\":\"" + col.ColumnName + "\",\"ColmType\":\"" + dataType.Name + "\"}";


                    columnNameList.Add(JsonConvert.DeserializeObject(ColmString));//获取到DataColumn列对象的列名


                }


                objJsonResult.code = "1";


                objJsonResult.count = 1;


                objJsonResult.Message = "Sucess！";


                objJsonResult.data = ds.Tables[0];


                objJsonResult.list = columnNameList;


              


            }


            catch (Exception e)


            {


@@ -1203,6 +1280,7 @@


            DataSet ds;


            try


            {


                //List<object> columnNameList = new List<object>();  //定义声明变量 ，把通过 new List<object>()创建的 实例，赋值给变量


                //判断是否有查询权限


                if (!DBUtility.ClsPub.Security_Log("Gy_RoutingBill_Query", 1, false, user))


                {


@@ -1243,6 +1321,18 @@


                    string sql = sql1 + sWhere + " order by hmainid desc,cast(工序号 as int)";


                    ds = oCN.RunProcReturn(sql, "h_v_Gy_RoutingBillList_His");


                }


                //foreach (DataColumn col in ds.Tables[0].Columns)//遍历ds中第一个表（Tables[0]）的所有列（Columns）每次循环中，col变量会持有当前列的引用


                //{


                //    Type dataType = col.DataType; //获取当前数据类型传入 自定义变量datadataType


                //    string ColmString = "{\"ColmCols\":\"" + col.ColumnName + "\",\"ColmType\":\"" + dataType.Name + "\"}"; //字符串拼接         // 将列名和数据类型信息拼接成一个JSON格式的字符串


                //    columnNameList.Add(JsonConvert.DeserializeObject(ColmString));//获取到DataColumn列对象的列名


                //}


                //objJsonResult.code = "1";


                //objJsonResult.count = 1;


                //objJsonResult.Message = "Sucess！";


                //objJsonResult.data = ds.Tables[0];//代码将第一个DataTable（索引为0）赋值给objJsonResult的data属性


                //objJsonResult.list = columnNameList;//将columnNameList赋值给objJsonResult的list属性


             


            }


            catch (Exception e)


            {


@@ -1587,7 +1677,8 @@


            DataSet ds;


            try


            {


                //判断是否有查询权限


                List<object> columnNameList = new List<object>()


;                //判断是否有查询权限


                if (!DBUtility.ClsPub.Security_Log("Sc_ICMOBillQuery", 1, false, user))


                {


                    objJsonResult.code = "0";


@@ -1612,6 +1703,22 @@


                }




                ds = oCN.RunProcReturn("select * from h_v_IF_ICMOBillList where 1 = 1 " + sWhere + " order by 制单日期 desc,单据号 desc", "h_v_IF_ICMOBillList");


                //添加列名


                foreach (DataColumn col in ds.Tables[0].Columns)


                {


                    Type dataType = col.DataType;


                    string ColmString = "{\"ColmCols\":\"" + col.ColumnName + "\",\"ColmType\":\"" + dataType.Name + "\"}";


                    columnNameList.Add(JsonConvert.DeserializeObject(ColmString));//获取到DataColumn列对象的列名


                }




                //if (ds.Tables[0].Rows.Count != 0 || ds != null)


                //{


                //objJsonResult.code = "1";


                //objJsonResult.count = 1;


                //objJsonResult.Message = "Sucess！";


                //objJsonResult.data = ds.Tables[0];


                //objJsonResult.list = a;


                //return objJsonResult;


            }


            catch (Exception e)


            {


@@ -1624,11 +1731,60 @@


            return GetObjectJson(ds);


        }




        /// <summary>


        /// 返回工序流转卡列表


        ///参数：string sql。


        ///返回值：object。


        /// </summary>


        #region 生产订单分页列表


        [Route("LEMS/MES_IF_ICMOBillListPage")]


        [HttpGet]


        public object MES_IF_ICMOBillListPage(string sWhere, string user, int page, int size)


        {


            DataSet ds;


            try


            {


                List<object> columnNameList = new List<object>();


                //编辑权限


                if (!DBUtility.ClsPub.Security_Log_second("Sc_ICMOBillQuery", 1, false, user))


                {


                    objJsonResult.code = "0";


                    objJsonResult.count = 0;


                    objJsonResult.Message = "无查看权限！";


                    objJsonResult.data = null;


                    return objJsonResult;


                }


                if (sWhere == null || sWhere.Equals(""))


                {


                    ds = oCN.RunProcReturn("exec h_p_IF_ICMOBillList " + page + "," + size + ",''", "h_p_IF_ICMOBillList");


                }


                else


                {


                    ds = oCN.RunProcReturn("exec h_p_IF_ICMOBillList " + page + "," + size + ",'" + sWhere + "'", "h_p_IF_ICMOBillList");


                }




                //添加列名


                foreach (DataColumn col in ds.Tables[0].Columns)


                {


                    Type dataType = col.DataType;


                    string ColmString = "{\"ColmCols\":\"" + col.ColumnName + "\",\"ColmType\":\"" + dataType.Name + "\"}";


                    columnNameList.Add(JsonConvert.DeserializeObject(ColmString));//获取到DataColumn列对象的列名


                }




                objJsonResult.code = "1";


                objJsonResult.count = int.Parse(ds.Tables[1].Rows[0]["count"].ToString());


                objJsonResult.Message = "Sucess！";


                objJsonResult.list = columnNameList;


                objJsonResult.data = ds.Tables[0];


                return objJsonResult;


            }


            catch (Exception e)


            {


                objJsonResult.code = "0";


                objJsonResult.count = 0;


                objJsonResult.Message = "Exception！" + e.ToString();


                objJsonResult.data = null;


                return objJsonResult;


            }


        }


        #endregion




        #region 工序流转卡下推生产质量汇报单


        [Route("LEMS/MES_IF_ProcessBillList_Json")]


        [HttpGet]


        public object MES_IF_ProcessBillList_Json(string hinterid, string HEntryID, string user)


@@ -1649,6 +1805,30 @@


            }


            return GetObjectJson(ds);


        }


        #endregion




        #region 工序流转卡下推设备点检参数表


        [Route("LEMS/MES_IF_EquipICMOTechParamList_Json")]


        [HttpGet]


        public object MES_IF_EquipICMOTechParamList_Json(string hinterid, string HEntryID, string user)


        {


            DataSet ds;


            try


            {




                ds = oCN.RunProcReturn(" exec h_p_Sc_ProcessExchangeBillQuery_TechParam '" + hinterid + "' , '" + HEntryID + "'", "h_p_Sc_ProcessExchangeBillQuery_TechParam");


            }


            catch (Exception e)


            {


                objJsonResult.code = "0";


                objJsonResult.count = 0;


                objJsonResult.Message = "没有返回任何记录！" + e.ToString();


                objJsonResult.data = null;


                return objJsonResult;


            }


            return GetObjectJson(ds);


        }


        #endregion




        #region 生产订单 下查


        /// <summary>


@@ -1777,6 +1957,44 @@


                {


                      ds = oCN.RunProcReturn("exec [h_p_Sc_ProductionAnalysisReportList] '" + DateYear + "','" + HType + "'", "[h_p_Sc_ProductionAnalysisReportList]");


                }




                //添加列名


                foreach (DataColumn col in ds.Tables[0].Columns)


                {


                    Type dataType = col.DataType;


                    string ColmString = "{\"ColmCols\":\"" + col.ColumnName + "\",\"ColmType\":\"" + dataType.Name + "\"}";


                    columnNameList.Add(JsonConvert.DeserializeObject(ColmString));//获取到DataColumn列对象的列名


                }




                objJsonResult.code = "1";


                objJsonResult.count = 1;


                objJsonResult.Message = "Sucess！";


                objJsonResult.data = ds.Tables[0];


                objJsonResult.list = columnNameList;


                return objJsonResult;


            }


            catch (Exception e)


            {


                objJsonResult.code = "0";


                objJsonResult.count = 0;


                objJsonResult.Message = "Exception！" + e.ToString();


                objJsonResult.data = null;


                return objJsonResult;


            }


        }


        #endregion




        #region 螺母检验CCD合格率


        [Route("LEMS/Sc_NutInspectionCCDPassRate")]


        [HttpGet]


        public object Sc_NutInspectionCCDPassRate(string HBatchNo, string user)


        {


            try


            {


                DataSet ds;


                List<object> columnNameList = new List<object>();




                ds = oCN.RunProcReturn("exec h_p_Sc_NutInspectionCCDPassRate '" + HBatchNo + "'", "h_p_Sc_NutInspectionCCDPassRate");




                //添加列名


                foreach (DataColumn col in ds.Tables[0].Columns)


@@ -2223,7 +2441,7 @@


            {


                List<object> columnNameList = new List<object>();


               


                //添加列名


               //添加列名


                foreach (DataColumn col in ds.Tables[0].Columns)


                {


                    Type dataType = col.DataType;


@@ -2234,8 +2452,9 @@


                objJsonResult.code = "1";


                objJsonResult.count = 1;


                objJsonResult.Message = "Sucess！";


                objJsonResult.list = columnNameList;


             


                objJsonResult.data = ds.Tables[0];


                objJsonResult.list = columnNameList;


                return objJsonResult;


            }


            catch (Exception e)