派生自 MES-WEB-API
WebAPI/Controllers/LMESController.cs
@@ -14,6 +14,7 @@ public DBUtility.ClsPub.Enum_BillStatus BillStatus; private json objJsonResult = new json(); SQLHelper.ClsCN oCN = new SQLHelper.ClsCN(); /// <summary> /// 返回进站扫描列表|工序进站接收单列表 ///参数：string sql。 @@ -53,33 +54,49 @@ /// </summary> [Route("LEMS/MES_Sc_ProcessExchangeBillQuery_Json")] [HttpGet] public object MES_Sc_ProcessExchangeBillList_Json(string sWhere) public object MES_Sc_ProcessExchangeBillList_Json(string sWhere,string user) { DataSet ds; try { SQLHelper.ClsCN oCN = new SQLHelper.ClsCN(); if (sWhere == null || sWhere.Equals("")) //判断是否有查询权限 if (!DBUtility.ClsPub.Security_Log("Sc_ProcessExchangeBill_Query", 1, false, user)) { ds = oCN.RunProcReturn("select * from h_v_Sc_ProcessExchangeBillQuery", "h_v_Sc_ProcessExchangeBillQuery"); } else { string sql1 = "select * from h_v_Sc_ProcessExchangeBillQuery where 1 = 1 "; string sql = sql1 + sWhere; ds = oCN.RunProcReturn(sql, "h_v_Sc_ProcessExchangeBillQuery"); objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "无查询权限!"; objJsonResult.data = null; return objJsonResult; } SQLHelper.ClsCN oCN = new SQLHelper.ClsCN(); ds = oCN.RunProcReturn("select * from h_v_Sc_ProcessExchangeBillQuery where 1 = 1 " + sWhere+ " order by hmainid desc ", "h_v_Sc_ProcessExchangeBillQuery"); //if (ds.Tables[0].Rows.Count != 0 || ds != null) //{ objJsonResult.code = "1"; objJsonResult.count = 1; objJsonResult.Message = "Sucess！"; objJsonResult.data = ds.Tables[0]; return objJsonResult; //} //else //{ //objJsonResult.code = "0"; //objJsonResult.count = 0; //objJsonResult.Message = "无数据"; //objJsonResult.data = null; //return objJsonResult; //} } catch (Exception e) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "没有返回任何记录！" + e.ToString(); objJsonResult.Message = "异常！" + e.ToString(); objJsonResult.data = null; return objJsonResult; } return GetObjectJson(ds); } /// <summary> @@ -97,7 +114,7 @@ SQLHelper.ClsCN oCN = new SQLHelper.ClsCN(); string sql = "select * from h_v_Sc_ProcessExchangeBillQuerySub where hmainid = "; string sql1 = sql + sWhere; ds = oCN.RunProcReturn(sql1, "h_v_Sc_ProcessExchangeBillQuerySub"); ds = oCN.RunProcReturn(sql1+ " order by cast(工序号 as int)", "h_v_Sc_ProcessExchangeBillQuerySub"); } catch (Exception e) { @@ -108,6 +125,73 @@ return objJsonResult; } return GetObjectJson(ds); } /// <summary> /// 返回工序流转卡（下达）列表 ///参数：string sql。 ///返回值：object。 /// </summary> [Route("LEMS/MES_Sc_ProcessExchangeIssueBillList_Json")] [HttpGet] public object MES_Sc_ProcessExchangeIssueBillList_Json(string sWhere, string user) { DataSet ds; try { //判断是否有查询权限 if (!DBUtility.ClsPub.Security_Log("Sc_ProcessExchangeBill_Query", 1, false, user)) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "无查询权限!"; objJsonResult.data = null; return objJsonResult; } SQLHelper.ClsCN oCN = new SQLHelper.ClsCN(); ds = oCN.RunProcReturn("select * from h_v_Sc_ProcessExchangeIssueBillQuery where 1 = 1 " + sWhere + " order by hmainid desc ", "h_v_Sc_ProcessExchangeIssueBillQuery"); objJsonResult.code = "1"; objJsonResult.count = 1; objJsonResult.Message = "Sucess！"; objJsonResult.data = ds.Tables[0]; return objJsonResult; } catch (Exception e) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "异常！" + e.ToString(); objJsonResult.data = null; return objJsonResult; } } /// <summary> /// 下达 /// </summary> /// <returns></returns> [Route("LEMS/MES_Sc_ProcessExchangeIssue")] [HttpGet] public object MES_Sc_ProcessExchangeIssue(string HGroupID, string HSourceID, string HEntryId) { DataSet ds; try { SQLHelper.ClsCN oCN = new SQLHelper.ClsCN(); ds = oCN.RunProcReturn($"exec REALESE_Sc_ProcessExchangeIssue '{HGroupID}','{HSourceID}','{HEntryId}' ", "REALESE_Sc_ProcessExchangeIssue"); objJsonResult.code = "1"; objJsonResult.count = 1; objJsonResult.Message = "Sucess！"; objJsonResult.data = ds.Tables[0]; return objJsonResult; } catch (Exception e) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "异常！" + e.ToString(); objJsonResult.data = null; return objJsonResult; } } /// <summary> @@ -174,6 +258,9 @@ return GetObjectJson(ds); } #region 工艺路线 #region 工艺路线列表 /// <summary> /// 返回工艺路线列表 ///参数：string sql。 @@ -181,20 +268,30 @@ /// </summary> [Route("LEMS/MES_Gy_RoutingBillList_Json")] [HttpGet] public object MES_Gy_RoutingBillList_Json(string sWhere) public object MES_Gy_RoutingBillList_Json(string sWhere,string user) { DataSet ds; try { //判断是否有查询权限 //if (!DBUtility.ClsPub.Security_Log("Gy_RoutingBill_Query", 1, false, user)) //{ // objJsonResult.code = "0"; // objJsonResult.count = 0; // objJsonResult.Message = "无权限查询!"; // objJsonResult.data = null; // return objJsonResult; //} SQLHelper.ClsCN oCN = new SQLHelper.ClsCN(); if (sWhere == null || sWhere.Equals("")) { ds = oCN.RunProcReturn("select * from h_v_Gy_RoutingBillList ", "h_v_Gy_RoutingBillList"); ds = oCN.RunProcReturn("select top 1000 * from h_v_Gy_RoutingBillList order by hmainid desc", "h_v_Gy_RoutingBillList"); } else { string sql1 = "select * from h_v_Gy_RoutingBillList where 1 = 1 "; string sql = sql1 + sWhere; string 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"); } } @@ -209,6 +306,134 @@ return GetObjectJson(ds); } #endregion #region 工艺路线 删除 /// <summary> /// 工艺路线删除功能 /// </summary> /// <returns></returns> [Route("LEMS/DeltetGy_RoutingBillSub")] [HttpGet] public object DeltetGy_RoutingBillSub(Int64 lngBillKey,string user) { DataSet ds; string ModRightNameCheck = "Gy_RoutingBill_Drop"; try { //删除权限 if (!DBUtility.ClsPub.Security_Log(ModRightNameCheck, 1, false, user)) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "删除失败！无权限！"; objJsonResult.data = null; return objJsonResult; } SQLHelper.ClsCN oCN = new SQLHelper.ClsCN(); if (lngBillKey == 0) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "单据id为空！"; objJsonResult.data = null; return objJsonResult; } oCN.BeginTran();//开始事务 ds = oCN.RunProcReturn("select * from Gy_RoutingBillmain where HInterID=" + lngBillKey, "Gy_RoutingBillmain"); if (ds == null || ds.Tables[0].Rows.Count == 0) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "没有数据，无法删除！"; objJsonResult.data = null; return objJsonResult; ; } string HChecker = Convert.ToString(ds.Tables[0].Rows[0]["HChecker"]); //string hdeleteman = Convert.ToString(ds.Tables[0].Rows[0]["hdeleteman"]); if (HChecker != "") { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "单据已经审核,不能删除！"; objJsonResult.data = null; return objJsonResult; } //if (hdeleteman != "") //{ // objJsonResult.code = "0"; // objJsonResult.count = 0; // objJsonResult.Message = "单据已经作废,不能删除！"; // objJsonResult.data = null; // return objJsonResult; //} oCN.RunProc("delete from Gy_RoutingBillmain where HInterID=" + lngBillKey); oCN.RunProc("delete from Gy_RoutingBillSub where HInterID=" + lngBillKey); oCN.Commit();//提交事务 objJsonResult.code = "0"; objJsonResult.count = 1; objJsonResult.Message = "* 数据删除成功！"; objJsonResult.data = null; return objJsonResult; ; } catch (Exception e) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "删除失败！" + e.ToString(); objJsonResult.data = null; return objJsonResult; } } #endregion #region 工艺路线基础列表 /// <summary> /// 返回工艺路线列表 ///参数：string sql。 ///返回值：object。 /// </summary> [Route("LEMS/Gy_RoutingBillList")] [HttpGet] public object Gy_RoutingBillList(string sWhere, string user) { DataSet ds; try { //判断是否有查询权限 if (!DBUtility.ClsPub.Security_Log("Gy_RoutingBill_Query", 1, false, user)) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "无权限查询!"; objJsonResult.data = null; return objJsonResult; } SQLHelper.ClsCN oCN = new SQLHelper.ClsCN(); string sql1 = "select * from h_v_Gy_RoutingBillList_Base where 1 = 1 "; string sql = sql1 + sWhere + " order by hmainid desc"; ds = oCN.RunProcReturn(sql, "h_v_Gy_RoutingBillList_Base"); } catch (Exception e) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "没有返回任何记录！" + e.ToString(); objJsonResult.data = null; return objJsonResult; } return GetObjectJson(ds); } #endregion #endregion /// <summary> /// 返回生产任务单列表 ///参数：string sql。 @@ -216,22 +441,22 @@ /// </summary> [Route("LEMS/MES_IF_ICMOBillList_Json")] [HttpGet] public object MES_IF_ICMOBillList_Json(string sWhere) public object MES_IF_ICMOBillList_Json(string sWhere,string user) { DataSet ds; try { SQLHelper.ClsCN oCN = new SQLHelper.ClsCN(); if (sWhere == null || sWhere.Equals("")) //判断是否有查询权限 if (!DBUtility.ClsPub.Security_Log("Sc_ICMOBillQuery", 1, false, user)) { ds = oCN.RunProcReturn("select top 500 * from h_v_IF_ICMOBillList ", "h_v_IF_ICMOBillList"); objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "无权限查询!"; objJsonResult.data = null; return objJsonResult; } else { string sql1 = "select * from h_v_IF_ICMOBillList where 1 = 1 "; string sql = sql1 + sWhere; ds = oCN.RunProcReturn(sql, "h_v_IF_ICMOBillList"); } ds = oCN.RunProcReturn("select * from h_v_IF_ICMOBillList where 1 = 1 " + sWhere + " order by 单据号 desc", "h_v_IF_ICMOBillList"); } catch (Exception e) { @@ -285,22 +510,22 @@ { try { if (ds == null || ds.Tables[0].Rows.Count <= 0) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "没有返回任何记录！"; objJsonResult.data = null; return objJsonResult; } else { objJsonResult.code = "0"; objJsonResult.count = 1; objJsonResult.Message = "获取信息成功！"; objJsonResult.data = ds.Tables[0]; return objJsonResult; } //if (ds.Tables[0].Rows.Count != 0 || ds != null) //{ objJsonResult.code = "1"; objJsonResult.count = 1; objJsonResult.Message = "Sucess！"; objJsonResult.data = ds.Tables[0]; return objJsonResult; //} //else //{ //objJsonResult.code = "0"; //objJsonResult.count = 0; //objJsonResult.Message = "无数据"; //objJsonResult.data = null; //return objJsonResult; //} } catch (Exception e) { @@ -1030,6 +1255,81 @@ return GetObjectJson(ds); } // /// <summary> /// 返回墙咔工资统计报表 ///参数：string sql。 ///返回值：object。 /// </summary> [Route("LEMS/MES_Qk_OutProcessList_Json")] [HttpGet] public object MES_Qk_OutProcessList_Json(string sWhere) { DataSet ds; try { SQLHelper.ClsCN oCN = new SQLHelper.ClsCN(); ds = oCN.RunProcReturn("select * from (select min(a.HDate) 起始时间, max(a.HDate) 截至时间, b.HName 工序名称, c.HName 班组名称, d.HName 汇报人, sum(a.HQty) 合计汇报数量, sum(b.HFixPrice * a.HQty) 合计工资 from Sc_StationOutBillMain a left join Gy_Process b on a.HProcID = b.HItemID Left join Gy_Group c on a.HGroupID = c.HItemID left join Gy_Employee d on a.HEmpID = d.HItemID where 1=1 group by b.HName,c.HName,d.HName) t where 1=1 " + sWhere, "Sc_StationOutBillMain"); } catch (Exception e) { ds = null; } return GetObjectJson(ds); } //单行删除进站接收单列表 [Route("LEMS/StationInBillListDelete_Json")] [HttpGet] public object StationInBillListDelete_Json(long sHInterID) { try { SQLHelper.ClsCN oCn = new SQLHelper.ClsCN(); oCn.RunProc("Delete from Sc_StationInBillMain where HInterID=" + sHInterID, ref DBUtility.ClsPub.sExeReturnInfo); objJsonResult.code = "200"; objJsonResult.count = 1; objJsonResult.Message = "删除成功！"; objJsonResult.data = null; return objJsonResult; } catch (Exception e) { objJsonResult.code = "000"; objJsonResult.count = 0; objJsonResult.Message = "删除失败！"; objJsonResult.data = e.ToString(); return objJsonResult; } } //单行删除出站汇报单列表 [Route("LEMS/StationOutBillListDelete_Json")] [HttpGet] public object StationOutBillListDelete_Json(long sHInterID) { try { SQLHelper.ClsCN oCn = new SQLHelper.ClsCN(); oCn.RunProc("Delete from Sc_StationOutBillMain where HInterID=" + sHInterID, ref DBUtility.ClsPub.sExeReturnInfo); objJsonResult.code = "200"; objJsonResult.count = 1; objJsonResult.Message = "删除成功！"; objJsonResult.data = null; return objJsonResult; } catch (Exception e) { objJsonResult.code = "000"; objJsonResult.count = 0; objJsonResult.Message = "删除失败！"; objJsonResult.data = e.ToString(); return objJsonResult; } } } }
