派生自 MES-WEB-API
WebAPI/Controllers/CJGL/Sc_ProcessExchangeBillController.cs
@@ -7,6 +7,7 @@ using System.Data; using System.Data.SqlClient; using System.Web.Http; using System.Windows.Forms; using WebAPI.Models; namespace WebAPI.Controllers @@ -18,6 +19,9 @@ private json objJsonResult = new json(); SQLHelper.ClsCN oCN = new SQLHelper.ClsCN(); DataSet ds; Pub_Class.ClsXt_SystemParameter oSystemParameter = new Pub_Class.ClsXt_SystemParameter(); public DAL.ClsSc_ICMOBill BillOld = new DAL.ClsSc_ICMOBill(); #region[新增单据-保存按钮] /// <summary> @@ -36,6 +40,8 @@ string msg3 = sArray[1].ToString(); string msg4 = sArray[2].ToString(); string msg5 = sArray[3].ToString(); string OperationType = sArray[4].ToString(); string HComputerName = SystemInformation.ComputerName; //设备名称 string UserName = ""; ListModels oListModels = new ListModels(); @@ -50,7 +56,7 @@ objJsonResult.data = null; return objJsonResult; } DBUtility.ClsPub.CurUserName = msg4; DAL.ClsSc_ProcessExchangeBill oBill = new DAL.ClsSc_ProcessExchangeBill(); List<Model.ClsSc_ProcessExchangeBillMain> lsmain = new List<Model.ClsSc_ProcessExchangeBillMain>(); msg2 = msg2.Replace("\\", ""); @@ -60,9 +66,10 @@ { UserName = oItem.HMaker; //制单人 oItem.HBillType = "3772"; oItem.HBillSubType = "3772"; oItem.HDate = DBUtility.ClsPub.isDate(DateTime.Now.ToString("yyyy-MM-dd"));// --日期 oItem.HBillSubType = OperationType=="5"?"SUB":"3772"; oItem.HYear = DBUtility.ClsPub.isLong(DateTime.Now.Year); oItem.HPeriod = DBUtility.ClsPub.isLong(DateTime.Now.Month); oItem.HDate = OperationType == "5" ? DateTime.Parse(DateTime.Now.ToString("yyyy-MM-dd")) : oItem.HDate; if (DBUtility.ClsPub.isStrNull(oItem.HDate) == "") { objJsonResult.code = "0"; @@ -97,12 +104,18 @@ bool bResult; if (msg5 == "xz") { LogService.Write("用户:" + msg4 + ",日期:" + DateTime.Now + ",新增工序流转卡单据:" + oBill.omodel.HBillNo); // bResult = oBill.AddBill(ref DBUtility.ClsPub.sExeReturnInfo); bResult = oBill.AddBill(ref DBUtility.ClsPub.sExeReturnInfo); oCN.RunProc("Insert into System_log (GeginDate, userid, WorkstationName, WorkList, SystemName, NetuserName, State) select GETDATE(),'" + msg4 + "','" + HComputerName + "','" + "新增工序流转卡单据：" + oBill.omodel.HBillNo + "','LMES-工序流转卡模块','" + DBUtility.ClsPub.IPAddress + "','新增单据'", ref DBUtility.ClsPub.sExeReturnInfo); } else { LogService.Write("用户:" + msg4 + ",日期:" + DateTime.Now + ",修改工序流转卡单据:" + oBill.omodel.HBillNo); bResult = oBill.ModifyBill(oBill.omodel.HInterID, ref DBUtility.ClsPub.sExeReturnInfo); oCN.RunProc("Insert into System_log (GeginDate, userid, WorkstationName, WorkList, SystemName, NetuserName, State) select GETDATE(),'" + msg4 + "','" + HComputerName + "','" + "修改工序流转卡单据：" + oBill.omodel.HBillNo + "','LMES-工序流转卡模块','" + DBUtility.ClsPub.IPAddress + "','修改单据'", ref DBUtility.ClsPub.sExeReturnInfo); } if (bResult) { @@ -373,6 +386,247 @@ //} #endregion #region[新增单据-保存按钮-批量复制] /// <summary> /// 新增单据-保存按钮 ///参数：string sql。 ///返回值：object。 /// </summary> [Route("Sc_ProcessExchangeBill/AddBill_Copy_pl")] [HttpPost] public object AddBill_Copy_pl([FromBody] JObject sMainSub) { var _value = sMainSub["sMainSub"].ToString(); string msg1 = _value.ToString(); string[] sArray = msg1.Split(new string[] { ";" }, StringSplitOptions.RemoveEmptyEntries); int msg2 = int.Parse(sArray[0].ToString()); string msg3 = sArray[1].ToString(); string msg4 = sArray[2].ToString(); string msg5 = sArray[3].ToString(); string HComputerName = SystemInformation.ComputerName; //设备名称 string UserName = ""; ListModels oListModels = new ListModels(); string sReturn = ""; try { if (!DBUtility.ClsPub.Security_Log("Sc_ProcessExchangeBill_Edit", 1, false, msg4)) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "无保存权限！"; objJsonResult.data = null; return objJsonResult; } DAL.ClsSc_ProcessExchangeBill oBill = new DAL.ClsSc_ProcessExchangeBill(); DBUtility.ClsPub.HOrgID = long.Parse(msg5); DBUtility.ClsPub.CurUserName = msg4; oBill.ShowBill(long.Parse(msg3), ref sReturn); ds = oCN.RunProcReturn("select isnull(sum(HQty),0) from Sc_ProcessExchangeBillMain where HICMOBillNo='" + oBill.omodel.HICMOBillNo + "' and HInterID <>"+ oBill.omodel.HInterID, "Sc_ProcessExchangeBillMain"); var HQty = double.Parse(ds.Tables[0].Rows[0][0].ToString()); int num = 0; //单据数量 * 张数 + 已生成不包括本单据的数量 >生产订单数量 if ((oBill.omodel.HQty * msg2) + HQty > oBill.omodel.HPlanQty) { if (((oBill.omodel.HPlanQty - oBill.omodel.HQty - HQty) % oBill.omodel.HQty) == 0) { num = (int)((oBill.omodel.HPlanQty - oBill.omodel.HQty - HQty) / oBill.omodel.HQty); } else { num = (int)((oBill.omodel.HPlanQty - oBill.omodel.HQty - HQty) / oBill.omodel.HQty); num += 1; } objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "最多可以复制" + num + "张！"; objJsonResult.data = null; return objJsonResult; } if (num == 0) { double HPlanQty = oBill.omodel.HPlanQty - oBill.omodel.HQty - HQty; for (int i = 0; i < msg2; i++) { oBill.omodel.HBillNo = DBUtility.ClsPub.CreateBillCode("3772", ref DBUtility.ClsPub.sExeReturnInfo, true); oBill.omodel.HDate =DateTime.Parse(DateTime.Now.ToString("yyyy-MM-dd")); oBill.omodel.HYear = DBUtility.ClsPub.isLong(DateTime.Now.Year); oBill.omodel.HPeriod = DBUtility.ClsPub.isLong(DateTime.Now.Month); oBill.omodel.HChecker = ""; oBill.omodel.HCheckDate = ""; oBill.omodel.HMaker = msg4; if (HPlanQty < oBill.omodel.HQty) { oBill.omodel.HQty = HPlanQty; } for (int j = 0; j < oBill.DetailColl.Count; j++) { oBill.DetailColl[j].HRelationQty_In = 0; oBill.DetailColl[j].HRelationQty_Out = 0; oBill.DetailColl[j].HRelationQty_Bad = 0; } //保存完毕后处理 bool bResult; LogService.Write("用户:" + msg4 + ",日期:" + DateTime.Now + ",新增工序流转卡单据:" + oBill.omodel.HBillNo); oCN.RunProc("Insert into System_log (GeginDate, userid, WorkstationName, WorkList, SystemName, NetuserName, State) select GETDATE(),'" + msg4 + "','" + HComputerName + "','" + "新增工序流转卡单据：" + oBill.omodel.HBillNo + "','LMES-工序流转卡模块','" + DBUtility.ClsPub.IPAddress + "','新增单据'", ref DBUtility.ClsPub.sExeReturnInfo); bResult = oBill.AddBill(ref sReturn); if (bResult) { num++; HPlanQty -= oBill.omodel.HQty; } } } objJsonResult.code = "0"; objJsonResult.count = 1; objJsonResult.Message = "复制了" + num + "张单据！"; objJsonResult.data = 1; return objJsonResult; } catch (Exception e) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "保存失败！" + e.ToString(); objJsonResult.data = 1; return objJsonResult; } } #endregion #region[批量新增单据-保存按钮] /// <summary> /// 新增单据-保存按钮 ///参数：string sql。 ///返回值：object。 /// </summary> [Route("Sc_ProcessExchangeBill/AddBill_pl")] [HttpPost] public object AddBill_pl([FromBody] JObject sMainSub) { var _value = sMainSub["sMainSub"].ToString(); string msg1 = _value.ToString(); string[] sArray = msg1.Split(new string[] { ";" }, StringSplitOptions.RemoveEmptyEntries); string msg2 = sArray[0].ToString();//主表 string msg3 = sArray[1].ToString();//单据号及数量 string msg4 = sArray[2].ToString();//工艺路线 string msg5 = sArray[3].ToString();//类型 string msg6 = sArray[4].ToString();//用户 string HComputerName = SystemInformation.ComputerName; //设备名称 ListModels oListModels = new ListModels(); try { if (!DBUtility.ClsPub.Security_Log("Sc_ProcessExchangeBill_Edit", 1, false, msg6)) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "无保存权限！"; objJsonResult.data = null; return objJsonResult; } //单据号 及数量 DAL.ClsSc_ProcessExchangeBill oBill = new DAL.ClsSc_ProcessExchangeBill(); List<Model.ClsSc_ProcessExchangeBillMain> ListHbillNo = new List<Model.ClsSc_ProcessExchangeBillMain>(); msg3 = msg3.Replace("\\", ""); msg3 = msg3.Replace("\n", ""); //\n ListHbillNo = JsonConvert.DeserializeObject<List<Model.ClsSc_ProcessExchangeBillMain>>(msg3); //主表信息 Model.ClsSc_ProcessExchangeBillMain Main = new Model.ClsSc_ProcessExchangeBillMain(); msg2 = msg2.Replace("\\", ""); msg2 = msg2.Replace("\n", ""); //\n Main = JsonConvert.DeserializeObject<Model.ClsSc_ProcessExchangeBillMain>(msg2); DBUtility.ClsPub.CurUserName = msg6; Main.HMaker = msg6; //制单人 Main.HBillType = "3772"; Main.HBillSubType = "3772"; Main.HYear = DBUtility.ClsPub.isLong(DateTime.Now.Year); Main.HMaterID = Main.HMaterID2; if (DBUtility.ClsPub.isStrNull(Main.HDate) == "") { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "保存失败！没有单据日期，无法保存！"; objJsonResult.data = 1; return objJsonResult; } //表体数据 //按 },{来拆分数组 //去掉【和】 msg4 = msg4.Substring(1, msg4.Length - 2); msg4 = msg4.Replace("\\", ""); msg4 = msg4.Replace("\n", ""); //\n List<Model.ClsSc_ProcessExchangeBillSub> ls = new List<Model.ClsSc_ProcessExchangeBillSub>(); ls = oListModels.getObjectByJson_Sc_ProcessExchangeBillSub(msg4); //循环新增单据 for (int i = 0; i < ListHbillNo.Count; i++) { Main.HBillNo = ListHbillNo[i].HBillNo; Main.HQty = ListHbillNo[i].HQty; Main.HSplitNo = ListHbillNo[i].HSplitNo; Main.HAuxQty = 0; Main.HAuxUnit = 0; oBill.omodel = Main; int j = 0; foreach (Model.ClsSc_ProcessExchangeBillSub oItemSub in ls) { j++; oItemSub.HEntryID = j; oItemSub.HQty = Main.HQty; oItemSub.HEntryCloseDate = DBUtility.ClsPub.isDate(DateTime.Now); oBill.DetailColl.Add(oItemSub); } //保存 //保存完毕后处理 bool bResult=false; if (msg5 == "2") { LogService.Write("用户:" + msg6 + ",日期:" + DateTime.Now + ",新增工序流转卡单据:" + oBill.omodel.HBillNo); oCN.RunProc("Insert into System_log (GeginDate, userid, WorkstationName, WorkList, SystemName, NetuserName, State) select GETDATE(),'" + msg6 + "','" + HComputerName + "','" + "新增工序流转卡单据：" + oBill.omodel.HBillNo + "','LMES-工序流转卡模块','" + DBUtility.ClsPub.IPAddress + "','新增单据'", ref DBUtility.ClsPub.sExeReturnInfo); bResult = oBill.AddBill(ref DBUtility.ClsPub.sExeReturnInfo); } oBill.DetailColl.Clear(); if (!bResult) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "保存失败！" + DBUtility.ClsPub.sExeReturnInfo; objJsonResult.data = 1; return objJsonResult; } } objJsonResult.code = "1"; objJsonResult.count = 1; objJsonResult.Message = "保存成功！"; objJsonResult.data = 1; return objJsonResult; } catch (Exception e) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "保存失败！" + e.ToString(); objJsonResult.data = 1; return objJsonResult; } } #endregion #region 工序流转卡列表显示器具清单信息 [Route("Sc_ProcessExchangeBillList/QJQD")] @@ -383,7 +637,7 @@ { //得到信息 ds = oCN.RunProcReturn("select top 1 * from h_v_Sc_ProcessExchangeBillQuerySub_Mould where hmainid= " + HProcExchHinteID , "h_v_Sc_ProcessExchangeBillQuerySub_Mould"); ds = oCN.RunProcReturn("select * from h_v_Sc_ProcessExchangeBillQuerySub_Mould where hmainid= " + HProcExchHinteID , "h_v_Sc_ProcessExchangeBillQuerySub_Mould"); //写入信息 //if (ds == null || ds.Tables[0].Rows.Count == 0) //{ @@ -548,12 +802,12 @@ { SQLHelper.ClsCN oCN = new SQLHelper.ClsCN(); string sql = string.Format(@"select 流水号 HProcNo,HProcID,工序代码 HProcNumber,工序名称 HProcName,加工说明 HWorkRemark,HCenterID,工作中心代码 HCenterNumber, 工作中心 HCenterName,HSupID,供应商代码 HSupNumber,供应商 HSupName,isEntrust,计划数量 HQty,加工单价 HOutPrice, 表体备注 HRemark, 工作中心 HCenterName,HSupID,供应商代码 HSupNumber,供应商 HSupName,isEntrust HSupFlag,计划数量 HQty,加工单价 HOutPrice, 表体备注 HRemark, 进站关联数量 HRelationQty_In,出站关联数量 HRelationQty_Out,委外工单数量 HRelationQty_WWOrder,不合格数量 HRelationQty_Bad,超额比例 HOverRate, 良率 HPassRate,累计良率 HSumPassRate,图纸编号 HPicNum,本工序确认记录 HProcCheckNote,工艺参数 HTechnologyParameter,HDeptID, 加工车间代码 HDeptNumber,加工车间 HDeptName 加工车间代码 HDeptNumber,加工车间 HDeptName,出站报废关联数量 HRelationQty_OutBad from h_v_Sc_ProcessExchangeBillQuerySub"); ds = oCN.RunProcReturn(sql+ " where hmainid="+ HInterID, "h_v_Sc_ProcessExchangeBillQuerySub"); ds = oCN.RunProcReturn(sql+ " where hmainid="+ HInterID + " order by cast(流水号 as int) ", "h_v_Sc_ProcessExchangeBillQuerySub"); objJsonResult.code = "0"; objJsonResult.count = 1; objJsonResult.Message = "获取信息成功！"; @@ -577,7 +831,7 @@ /// <returns></returns> [Route("Sc_ProcessExchangeBill/DeltetProcessExchangeBillByID")] [HttpGet] public object DeltetProcessExchangeBillByID(string HInterID,int HPRDORGID, string user) public object DeltetProcessExchangeBillByID(string HInterID, int HPRDORGID, string user) { //编辑权限 if (!DBUtility.ClsPub.Security_Log("Sc_ProcessExchangeBill_Drop", 1, false, user)) @@ -589,69 +843,103 @@ return objJsonResult; } Int64 lngBillKey = 0; lngBillKey = DBUtility.ClsPub.isLong(HInterID); if (lngBillKey == 0) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "单据ID为空！"; objJsonResult.data = null; return objJsonResult; } //删除前判断关联数量 SQLHelper.ClsCN oCn = new SQLHelper.ClsCN(); DataSet ds; ds = oCn.RunProcReturn("select ct from ( " + " select 1 ct from Sc_StationInBillMain Where HProcExchInterID=" + lngBillKey + " " + " union all " + " select 1 from Sc_StationOutBillMain Where HProcExchInterID=" + lngBillKey + " ) as a ", "Sc_ProcExchReportSub"); if (ds.Tables[0].Rows.Count != 0) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "流转卡已经有下游进出站单后，不允许删除！"; objJsonResult.data = null; return objJsonResult; } string HComputerName = SystemInformation.ComputerName; //设备名称 DAL.ClsSc_ProcessExchangeBill oBill = new DAL.ClsSc_ProcessExchangeBill(); DBUtility.ClsPub.HOrgID = HPRDORGID; if (oBill.ShowBill(lngBillKey, ref DBUtility.ClsPub.sExeReturnInfo)) { if (oBill.omodel.HBillStatus > 1) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "单据当前处于不能删除状态,不能删除！"; objJsonResult.data = null; return objJsonResult; } if (oBill.omodel.HChecker != "") { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "单据已经审核,不能删除！"; objJsonResult.data = null; return objJsonResult; } bool IsDete = oBill.DeleteBill(oBill.omodel.HInterID, ref DBUtility.ClsPub.sExeReturnInfo); if (IsDete) string[] HBillNo = HInterID.Split(','); string HBillNo_S = ""; foreach (var item in HBillNo) { Int64 lngBillKey = 0; lngBillKey = DBUtility.ClsPub.isLong(item); DBUtility.ClsPub.HOrgID = HPRDORGID; if (oBill.ShowBill(lngBillKey, ref DBUtility.ClsPub.sExeReturnInfo)) { objJsonResult.code = "0"; objJsonResult.count = 1; objJsonResult.Message = DBUtility.ClsPub.sExeReturnInfo; objJsonResult.data = null; return objJsonResult; if (lngBillKey == 0) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "单据号:"+ oBill .omodel.HBillNo+ "单据ID为空！"; objJsonResult.data = null; return objJsonResult; } //删除前判断关联数量 SQLHelper.ClsCN oCn = new SQLHelper.ClsCN(); DataSet ds; ds = oCn.RunProcReturn("select ct from ( " + " select 1 ct from Sc_StationInBillMain Where HProcExchInterID=" + lngBillKey + " " + " union all " + " select 1 from Sc_StationOutBillMain Where HProcExchInterID=" + lngBillKey + " ) as a ", "Sc_ProcExchReportSub"); if (ds.Tables[0].Rows.Count != 0) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "单据号:" + oBill.omodel.HBillNo + "流转卡已经有下游进出站单后，不允许删除！"; objJsonResult.data = null; return objJsonResult; } string sReturn = ""; if (oSystemParameter.ShowBill(ref sReturn)) { if (oSystemParameter.omodel.Sc_ProcessExchangeBill_DeleterAndMakerMustSame == "Y") { if (oBill.omodel.HMaker != user && (user != "admin" && user != "Admin")) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "单据号:" + oBill.omodel.HBillNo + "只能删除本人的单据！"; objJsonResult.data = null; return objJsonResult; } } } if (oBill.omodel.HBillStatus > 1) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "单据号:" + oBill.omodel.HBillNo + "单据当前处于不能删除状态,不能删除！"; objJsonResult.data = null; return objJsonResult; } if (oBill.omodel.HChecker != "") { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "单据号:" + oBill.omodel.HBillNo + "单据已经审核,不能删除！"; objJsonResult.data = null; return objJsonResult; } HBillNo_S += oBill.omodel.HBillNo + ","; } else { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "单据未找到"; objJsonResult.data = null; return objJsonResult; } } HBillNo_S = HBillNo_S.Substring(0, HBillNo_S.Length - 1); LogService.Write("用户:" + user + ",日期:" + DateTime.Now + ",删除工序流转卡单据:" + HBillNo_S); oCN.RunProc("Insert into System_log (GeginDate, userid, WorkstationName, WorkList, SystemName, NetuserName, State) select GETDATE(),'" + user + "','" + HComputerName + "','" + "删除工序流转卡单据：" + HBillNo_S + "','LMES-工序流转卡模块','" + DBUtility.ClsPub.IPAddress + "','删除单据'", ref DBUtility.ClsPub.sExeReturnInfo); foreach (var item in HBillNo) { bool IsDete = oBill.DeleteBill(long.Parse(item), ref DBUtility.ClsPub.sExeReturnInfo); if (!IsDete) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = DBUtility.ClsPub.sExeReturnInfo; @@ -659,15 +947,643 @@ return objJsonResult; } } else if (oSystemParameter.omodel.WMS_CampanyName == "瑞与祺") { ds = oCN.RunProcReturn("select * from Sc_ProcessExchangeBillMain where HICMOInterID='" + oBill.omodel.HICMOInterID + "' and HICMOEntryID='" + oBill.omodel.HICMOEntryID + "'", "Sc_ProcessExchangeBillMain"); if (ds.Tables[0].Rows.Count == 0) { oCN.RunProc("update AIS20220308151944..T_PRD_MOENTRY set F_BSV_TEXT2 = '否' where FID='" + oBill.omodel.HICMOInterID + "' and FENTRYID='" + oBill.omodel.HICMOEntryID + "'"); } } objJsonResult.code = "0"; objJsonResult.count = 1; objJsonResult.Message = DBUtility.ClsPub.sExeReturnInfo; objJsonResult.data = null; return objJsonResult; } #endregion #region[编辑时获取表体数据(工艺参数)] [Route("Sc_ProcessExchangeBill/GetProcessExchangeBillSubTech")] [HttpGet] public object GetProcessExchangeBillSubTech(string HInterID) { DataSet ds; try { List<object> columnNameList = new List<object>(); SQLHelper.ClsCN oCN = new SQLHelper.ClsCN(); string sql = string.Format(@"exec h_p_Sc_GetProcessExchangeBillSubTech "); ds = oCN.RunProcReturn(sql + HInterID, "h_p_Sc_GetProcessExchangeBillSubTech"); //添加列名 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 = "0"; objJsonResult.count = 1; objJsonResult.list = columnNameList; objJsonResult.Message = "获取信息成功！"; objJsonResult.data = ds.Tables[0]; return objJsonResult; } catch (Exception e) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "单据未找到"; objJsonResult.Message = "没有返回任何记录！" + e.ToString(); objJsonResult.data = null; return objJsonResult; } } #endregion #region 拆分 编辑获取流转卡数据 /// <summary> /// 编辑获取表头信息 /// </summary> /// <param name="HInterID">主ID</param> /// <returns></returns> [Route("Sc_ProcessExchangeBill/GetProcessExchangeBillMain_cf")] [HttpGet] public object GetProcessExchangeBillMain_cf(string HInterID) { DataSet ds; try { SQLHelper.ClsCN oCN = new SQLHelper.ClsCN(); ds = oCN.RunProcReturn("select top 1 * from h_v_Sc_ProcessExchangeBillQuery where hmainid= " + HInterID + " ", "h_v_Sc_ProcessExchangeBillQuery"); DataSet Ds = oCN.RunProcReturn("select top 1 HNo from Sc_ProcessExchangeBillmain where HBillNo like '%" + ds.Tables[0].Rows[0]["单据号"].ToString() + "-%' order by LEN(HBillno) , HbillNo desc ", "Sc_ProcessExchangeBillmain"); char c = '1'; string sNo = "01"; int sCount = 0; if (Ds == null || Ds.Tables[0].Rows.Count == 0) { } else { sCount = DBUtility.ClsPub.isInt(Ds.Tables[0].Rows[0]["HNo"]); if (sCount >= 1) { sNo = Convert.ToChar(sCount + (int)c).ToString(); sNo = "00" + sNo; sNo = sNo.Substring(sNo.Length - 2, 2); } } string sBillNo = ds.Tables[0].Rows[0]["单据号"].ToString(); sBillNo = sBillNo.Replace("WORKX", ""); sBillNo = sBillNo.Replace("WORK", ""); sBillNo = sBillNo.Replace("_", "-"); sBillNo = sBillNo + "-" + sNo; ds.Tables[0].Rows[0]["单据号"] = sBillNo; objJsonResult.code = "0"; objJsonResult.count = 1; objJsonResult.Message = "获取信息成功！"; objJsonResult.data = ds.Tables[0]; } catch (Exception e) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "没有返回任何记录！" + e.ToString(); objJsonResult.data = null; } return objJsonResult; } /// <summary> /// 获取表体数据信息 /// </summary> /// <param name="HInterID"></param> /// <returns></returns> [Route("Sc_ProcessExchangeBill/GetProcessExchangeBillSub_cf")] [HttpGet] public object GetProcessExchangeBillSub_cf(string HInterID) { DataSet ds; try { SQLHelper.ClsCN oCN = new SQLHelper.ClsCN(); var ds1= oCN.RunProcReturn("select isnull(max(流水号),0) from h_v_Sc_ProcessExchangeBillQuerySub where hmainid=" + HInterID + " and 出站关联数量>0 ", "h_v_Sc_ProcessExchangeBillQuerySub"); string sql = string.Format(@"select * from h_v_Sc_ProcessExchangeBillQuerySub"); ds = oCN.RunProcReturn(sql + " where hmainid=" + HInterID + " and 出站关联数量=0 and cast(流水号 as int)>" + ds1 .Tables[0].Rows[0][0].ToString(), "h_v_Sc_ProcessExchangeBillQuerySub"); if (float.Parse(ds.Tables[0].Rows[0]["进站关联数量"].ToString()) > 0) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "当前单据:"+ ds.Tables[0].Rows[0]["工序名称"].ToString() + "未出站不能拆分!"; objJsonResult.data = ds.Tables[0]; } else { objJsonResult.code = "0"; objJsonResult.count = 1; objJsonResult.Message = "获取信息成功！"; objJsonResult.data = ds.Tables[0]; } } catch (Exception e) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "没有返回任何记录！" + e.ToString(); objJsonResult.data = null; } return objJsonResult; } /// <summary> /// 新增单据-保存按钮 ///参数：string sql。 ///返回值：object。 /// </summary> [Route("Sc_ProcessExchangeBill/AddBill_cf")] [HttpPost] public object AddBill_cf([FromBody] JObject sMainSub) { var _value = sMainSub["sMainSub"].ToString(); string msg1 = _value.ToString(); string[] sArray = msg1.Split(new string[] { ";" }, StringSplitOptions.RemoveEmptyEntries); string msg2 = sArray[0].ToString(); string msg3 = sArray[1].ToString(); string msg4 = sArray[2].ToString(); string msg5 = sArray[3].ToString(); string linterid = sArray[4].ToString(); string UserName = ""; ListModels oListModels = new ListModels(); try { if (!DBUtility.ClsPub.Security_Log("Sc_ProcessExchangeBill_CF", 1, false, msg5)) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "无拆分权限！"; objJsonResult.data = null; return objJsonResult; } DAL.ClsSc_ProcessExchangeBill oBill = new DAL.ClsSc_ProcessExchangeBill(); List<Model.ClsSc_ProcessExchangeBillMain> lsmain = new List<Model.ClsSc_ProcessExchangeBillMain>(); msg2 = msg2.Replace("\\", ""); msg2 = msg2.Replace("\n", ""); //\n lsmain = oListModels.getObjectByJson_Sc_ProcessExchangeBillMain(msg2); string sReturn = ""; DBUtility.ClsPub.HOrgID = lsmain[0].HPRDORGID; oBill.ShowBill(long.Parse(linterid), ref sReturn); foreach (Model.ClsSc_ProcessExchangeBillMain oItem in lsmain) { if (DBUtility.ClsPub.isStrNull(oItem.HDate) == "") { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "保存失败！没有单据日期，无法保存！"; objJsonResult.data = 1; return objJsonResult; } oBill.omodel.HMaker = msg5; //制单人 oBill.omodel.HNo = DBUtility.ClsPub.isLong(oItem.HBillNo.Split('-')[1]); oBill.omodel.HYear = DBUtility.ClsPub.isLong(DateTime.Now.Year); oBill.omodel.HPeriod = DBUtility.ClsPub.isLong(DateTime.Now.Month); oBill.omodel.HDate = oItem.HDate;// 日期 oBill.omodel.HPlanBeginDate = oItem.HPlanBeginDate;// 计划开工日期 oBill.omodel.HPlanEndDate = oItem.HPlanEndDate;// 计划完工日期 oBill.omodel.HQty = oItem.HQty;// 数量 oBill.omodel.HBillNo = oItem.HBillNo;// 单据号 } //表体数据 //按 },{来拆分数组 //去掉【和】 msg3 = msg3.Substring(1, msg3.Length - 2); msg3 = msg3.Replace("\\", ""); msg3 = msg3.Replace("\n", ""); //\n //msg2 = msg2.Replace("'", "’"); List<Model.ClsSc_ProcessExchangeBillSub> ls = new List<Model.ClsSc_ProcessExchangeBillSub>(); ls = oListModels.getObjectByJson_Sc_ProcessExchangeBillSub(msg3); string HEntryID = ""; for (int i = 0; i < oBill.DetailColl.Count; i++) { if (oBill.DetailColl[i].HRelationQty_Out > 0 || oBill.DetailColl[i].HRelationQty_In > 0) { HEntryID += i + ","; } } if (HEntryID != "") { HEntryID = HEntryID.Substring(0, HEntryID.Length - 1); var num = HEntryID.Split(','); for (int k = 0; k < num.Length; k++) { oBill.DetailColl.RemoveAt(int.Parse(num[k]) - k); } } int j = 0 ; foreach (Model.ClsSc_ProcessExchangeBillSub oItemSub in oBill.DetailColl) { if (ls[j].HSplitQty > ls[j].HLeftQty) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "第" + (j + 1) + "行，拆分数量不能大于可拆分数量！"; objJsonResult.data = null; return objJsonResult; } if (oBill.DetailColl[j].HProcNo == ls[j].HProcNo) { oBill.DetailColl[j].HEntryID = j+1; oBill.DetailColl[j].HQty = ls[j].HQty; oBill.DetailColl[j].HBackProc = ls[j].HBackProc; oBill.DetailColl[j].HPrevSourceInterID = ls[j].HPrevSourceInterID; oBill.DetailColl[j].HPrevSourceEntryID = ls[j].HPrevSourceEntryID; oBill.DetailColl[j].HRemark = ls[j].HRemark; oBill.DetailColl[j].HTechnologyParameter = ls[j].HTechnologyParameter; j++; } } //保存 //保存完毕后处理 bool bResult = false; if (msg4 == "1") { bResult = oBill.AddBill(ref DBUtility.ClsPub.sExeReturnInfo); } //else //{ // bResult = oBill.ModifyBill(oBill.omodel.HInterID, ref DBUtility.ClsPub.sExeReturnInfo); //} oCN.BeginTran(); oCN.RunProc("update Sc_ProcessExchangeBillSub set HQty=(select HQty from Sc_ProcessExchangeBillMain where HInterID="+ oBill.DetailColl[0].HPrevSourceInterID + ") where HInterID=" + oBill.DetailColl[0].HPrevSourceInterID ); oCN.Commit(); if (bResult) { objJsonResult.code = "0"; objJsonResult.count = 1; objJsonResult.Message = "保存成功！"; objJsonResult.data = 1; return objJsonResult; } else { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "保存失败！" + DBUtility.ClsPub.sExeReturnInfo; objJsonResult.data = 1; return objJsonResult; } } catch (Exception e) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "保存失败！" + e.ToString(); objJsonResult.data = 1; return objJsonResult; } } #endregion #region 工序流转卡审核/反审核功能 [Route("Sc_ProcessExchangeBill/CheckSc_ProcessExchangeBill")] [HttpGet] public object CheckSc_ProcessExchangeBill(string HInterID, int Type, string user) { try { //判断是否有删除权限 if (!DBUtility.ClsPub.Security_Log("Sc_ProcessExchangeBill_Check", 1, false, user)) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "无权限审核!"; objJsonResult.data = null; return objJsonResult; } if (string.IsNullOrWhiteSpace(HInterID)) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "HInterID为空！"; objJsonResult.data = null; return objJsonResult; } ClsPub.CurUserName = user; BillOld.MvarItemKey = "Sc_ProcessExchangeBillMain"; oCN.BeginTran();//开始事务 //Type 1 审核 2 反审核 if (Type == 1) { //判断单据是否已经审核 DataSet ds; string sql = "select * from " + BillOld.MvarItemKey + " where HinterID = " + HInterID; ds = oCN.RunProcReturn(sql, BillOld.MvarItemKey); if (ds.Tables[0] != null && ds.Tables[0].Rows.Count > 0) { if (ds.Tables[0].Rows[0]["HChecker"] != null && ds.Tables[0].Rows[0]["HChecker"].ToString() != "") { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "单据已审核!不需要再审核!"; objJsonResult.data = null; return objJsonResult; } } //审核单据 if (!BillOld.CheckBill(Int64.Parse(HInterID), ref ClsPub.sExeReturnInfo)) { objJsonResult.code = "0"; objJsonResult.count = 1; objJsonResult.Message = "审核失败!原因:" + ClsPub.sExeReturnInfo; objJsonResult.data = null; return objJsonResult; } } else { //判断单据是否已经反审核 DataSet ds; string sql = "select * from " + BillOld.MvarItemKey + " where HinterID = " + HInterID; ds = oCN.RunProcReturn(sql, BillOld.MvarItemKey); if (ds.Tables[0] != null && ds.Tables[0].Rows.Count > 0) { if (ds.Tables[0].Rows[0]["HChecker"] == null || ds.Tables[0].Rows[0]["HChecker"].ToString() == "") { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "单据已反审核!不需要再反审核!"; objJsonResult.data = null; return objJsonResult; } } //反审核单据 if (BillOld.AbandonCheck(Int64.Parse(HInterID), ref ClsPub.sExeReturnInfo)) { //SQLHelper.ClsCN oCn = new SQLHelper.ClsCN(); //DataSet DSet = oCn.RunProcReturn("exec h_p_Sc_ICMOBill_AbandonCheckCtrl " + int.Parse(HInterID), "h_p_Sc_ICMOBill_AbandonCheckCtrl"); ////if (DBUtility.ClsPub.isInt(DSet.Tables[0].Rows[0]["Hback"]) != 0) ////{ //// objJsonResult.code = "0"; //// objJsonResult.count = 1; //// objJsonResult.Message = "该任务单已下推流转卡，不允许反审核" + DBUtility.ClsPub.isStrNull(DSet.Tables[0].Rows[0]["HBackRemark"]); //// objJsonResult.data = null; //// return objJsonResult; ////} } else { objJsonResult.code = "0"; objJsonResult.count = 1; objJsonResult.Message = "审核失败!原因:" + ClsPub.sExeReturnInfo; objJsonResult.data = null; return objJsonResult; } } 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 工序流转卡关闭/反关闭功能 [Route("Sc_ProcessExchangeBill/CloseSc_ProcessExchangeBill")] [HttpGet] public object CloseSc_ProcessExchangeBill(string HInterID, int Type, string user) { try { //判断是否有删除权限 if (!DBUtility.ClsPub.Security_Log("Sc_ProcessExchangeBill_Close", 1, false, user)) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "无权限关闭!"; objJsonResult.data = null; return objJsonResult; } if (string.IsNullOrWhiteSpace(HInterID)) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "HInterID为空！"; objJsonResult.data = null; return objJsonResult; } ClsPub.CurUserName = user; BillOld.MvarItemKey = "Sc_ProcessExchangeBillMain"; oCN.BeginTran();//开始事务 //Type 1 关闭 2 反关闭 if (Type == 1) { //判断单据是否已经关闭 DataSet ds; string sql = "select * from " + BillOld.MvarItemKey + " where HinterID = " + HInterID; ds = oCN.RunProcReturn(sql, BillOld.MvarItemKey); if (ds.Tables[0] != null && ds.Tables[0].Rows.Count > 0) { if (ds.Tables[0].Rows[0]["HCloseMan"] != null && ds.Tables[0].Rows[0]["HCloseMan"].ToString() != "") { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "单据已关闭!不需要再关闭!"; objJsonResult.data = null; return objJsonResult; } } //关闭单据 if (!BillOld.CloseBill(Int64.Parse(HInterID), ref ClsPub.sExeReturnInfo)) { objJsonResult.code = "0"; objJsonResult.count = 1; objJsonResult.Message = "关闭失败!原因:" + ClsPub.sExeReturnInfo; objJsonResult.data = null; return objJsonResult; } } else { //判断单据是否已经反关闭 DataSet ds; string sql = "select * from " + BillOld.MvarItemKey + " where HinterID = " + HInterID; ds = oCN.RunProcReturn(sql, BillOld.MvarItemKey); if (ds.Tables[0] != null && ds.Tables[0].Rows.Count > 0) { if (ds.Tables[0].Rows[0]["HCloseMan"] == null || ds.Tables[0].Rows[0]["HCloseMan"].ToString() == "") { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "单据已反关闭!不需要再反关闭!"; objJsonResult.data = null; return objJsonResult; } } //反关闭单据 if (!BillOld.CancelClose(Int64.Parse(HInterID), ref ClsPub.sExeReturnInfo)) { objJsonResult.code = "0"; objJsonResult.count = 1; objJsonResult.Message = "反关闭失败!原因:" + ClsPub.sExeReturnInfo; objJsonResult.data = null; return objJsonResult; } } 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 单据变更 页面初始化 [Route("Sc_ProcessExchangeBill/GetProcessExchangeBillMain_Change_init")] [HttpGet] public object GetProcessExchangeBillMain_Change_init(string HInterID) { try { if (string.IsNullOrEmpty(HInterID)) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "Exception！HInterID不能为空"; objJsonResult.data = null; return objJsonResult; } SQLHelper.ClsCN oCN = new SQLHelper.ClsCN(); ds = oCN.RunProcReturn("select * from h_v_Sc_ProcessExchangeBillQuery where hmainid = " + HInterID + " ", "h_v_Sc_ProcessExchangeBillQuery"); if (ds==null||ds.Tables[0].Rows.Count == 0) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "Exception！不存在工序流转卡"; objJsonResult.data = null; return objJsonResult; } else { 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 = "Exception！" + e.ToString(); objJsonResult.data = null; return objJsonResult; } } #endregion #region 单据变更 保存 [Route("Sc_ProcessExchangeBill/GetProcessExchangeBillMain_Change_save")] [HttpGet] public object GetProcessExchangeBillMain_Change_save(string HInterID,string HMaterModel2) { try { if (string.IsNullOrEmpty(HInterID)) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "Exception！HInterID不能为空"; objJsonResult.data = null; return objJsonResult; } SQLHelper.ClsCN oCN = new SQLHelper.ClsCN(); oCN.BeginTran(); oCN.RunProc("update Sc_ProcessExchangeBillMain set HMaterModel2 = '" + HMaterModel2 + "' where HInterID = " + HInterID + ""); oCN.Commit(); objJsonResult.code = "1"; objJsonResult.count = 1; objJsonResult.Message = "Sucess！"; objJsonResult.data = null; return objJsonResult; } catch (Exception e) { objJsonResult.code = "0"; objJsonResult.count = 0; objJsonResult.Message = "Exception！" + e.ToString(); objJsonResult.data = null; return objJsonResult; } } #endregion } }
