| | |
| | | using System.Buffers; |
| | | using System.Data; |
| | | using System.Data; |
| | | using MES.Service.DB; |
| | | using MES.Service.Dto.service; |
| | | using MES.Service.Modes; |
| | |
| | | { |
| | | var db = SqlSugarHelper.GetInstance(); |
| | | var date = DateTime.Now.ToString("yyyy-MM-dd"); |
| | | var sql = "select max(BILL_NO) from QS_ITEM_IPI_REQ where to_char(CREATE_TIME,'yyyy-mm-dd') = '" + date + "'"; |
| | | var sql = |
| | | "select max(BILL_NO) from QS_ITEM_IPI_REQ where to_char(CREATE_TIME,'yyyy-mm-dd') = '" + |
| | | date + "'"; |
| | | |
| | | var maxBillNo = db.Ado.SqlQuerySingle<string>(sql); |
| | | |
| | |
| | | } |
| | | |
| | | //获取所有数据分页 |
| | | public (List<SJPageResult> items, int TotalCount) getPage(SJPageResult queryObj) |
| | | public (List<SJPageResult> items, int TotalCount) getPage( |
| | | SJPageResult queryObj) |
| | | { |
| | | var db = SqlSugarHelper.GetInstance(); |
| | | |
| | |
| | | StringUtil.IsNotNullOrEmpty(queryObj.Result) && |
| | | !"未完成".Equals(queryObj.Result), |
| | | a => a.Result != "未完成") |
| | | .WhereIF(queryObj.Comments != null, a => a.Comments == queryObj.Comments) |
| | | .WhereIF(StringUtil.IsNotNullOrEmpty(queryObj.SearchValue),a=>a.BillNo.Contains(queryObj.SearchValue) |
| | | || a.ItemNo.Contains(queryObj.SearchValue)) |
| | | .WhereIF(queryObj.Comments != null, |
| | | a => a.Comments == queryObj.Comments) |
| | | .WhereIF(StringUtil.IsNotNullOrEmpty(queryObj.SearchValue), a => |
| | | a.BillNo.Contains(queryObj.SearchValue) |
| | | || a.ItemNo.Contains(queryObj.SearchValue)) |
| | | .OrderBy(a => a.BillNo, OrderByType.Desc) |
| | | .ToPageList(queryObj.PageIndex, queryObj.Limit, ref totalCount); |
| | | |
| | |
| | | |
| | | return db |
| | | .Queryable<MesQualityStandard>() |
| | | .Where(b => b.QsType == "1" && b.ItemNo == itemNo).Select( |
| | | b => new QsItemIpiItem |
| | | .Where(b => b.QsType == "1" && b.ItemNo == itemNo).Select(b => |
| | | new QsItemIpiItem |
| | | { |
| | | ProjName = b.ProjName, |
| | | ItemMod = b.ItemMod, |
| | |
| | | { |
| | | var qsItemIpiReq = item.From; |
| | | var qsItemIpiItems = item.Items; |
| | | SqlSugarHelper.UseTransactionWithOracle( |
| | | db => |
| | | { |
| | | qsItemIpiReq.StatusDate = DateTime.Now; |
| | | var pid = db.Insertable(qsItemIpiReq) |
| | | .ExecuteReturnIdentity(); |
| | | qsItemIpiReq.Id = pid; |
| | | SqlSugarHelper.UseTransactionWithOracle(db => |
| | | { |
| | | qsItemIpiReq.StatusDate = DateTime.Now; |
| | | var pid = db.Insertable(qsItemIpiReq) |
| | | .ExecuteReturnIdentity(); |
| | | qsItemIpiReq.Id = pid; |
| | | |
| | | item.gid = pid; |
| | | item.gid = pid; |
| | | |
| | | qsItemIpiItems.ForEach(s => s.Pid = pid); |
| | | qsItemIpiItems.ForEach(s => s.Pid = pid); |
| | | |
| | | return db.Insertable(qsItemIpiItems) |
| | | .ExecuteCommand(); |
| | | }); |
| | | return db.Insertable(qsItemIpiItems) |
| | | .ExecuteCommand(); |
| | | }); |
| | | item.Items = getQSItems(qsItemIpiReq.Id, null); |
| | | |
| | | //没有上下限的检验项目自动盘点为合格 |
| | |
| | | |
| | | item.Items = getQSItems(qsItemIpiReq.Id, null); |
| | | var sjPageResult = new SJPageResult |
| | | { Id = item.From.Id, Limit = 1, PageIndex = 1 }; |
| | | { Id = item.From.Id, Limit = 1, PageIndex = 1 }; |
| | | item.Result = getPage(sjPageResult).items[0]; |
| | | |
| | | return item; |
| | |
| | | public QsItem SaveItem(QsItem item) |
| | | { |
| | | var qsItemIpiItems = item.Items; |
| | | SqlSugarHelper.UseTransactionWithOracle( |
| | | db => |
| | | { |
| | | qsItemIpiItems.ForEach(s => s.Pid = item.gid); |
| | | SqlSugarHelper.UseTransactionWithOracle(db => |
| | | { |
| | | qsItemIpiItems.ForEach(s => s.Pid = item.gid); |
| | | |
| | | return db.Insertable(qsItemIpiItems) |
| | | .ExecuteCommand(); |
| | | }); |
| | | return db.Insertable(qsItemIpiItems) |
| | | .ExecuteCommand(); |
| | | }); |
| | | item.Items = getQSItems(item.gid, null); |
| | | |
| | | //没有上下限的检验项目自动盘点为合格 |
| | |
| | | |
| | | if (count == passCount) result = 1; |
| | | |
| | | var useTransactionWithOracle = SqlSugarHelper.UseTransactionWithOracle( |
| | | db => |
| | | var useTransactionWithOracle = |
| | | SqlSugarHelper.UseTransactionWithOracle(db => |
| | | { |
| | | var commit = 0; |
| | | commit += db.Updateable<QsItemIpiItem>() |
| | |
| | | //合格的检验结果等于总检验数视为合格 |
| | | if (icount == passCount) result = 1; |
| | | |
| | | useTransactionWithOracle += SqlSugarHelper.UseTransactionWithOracle( |
| | | db => |
| | | useTransactionWithOracle += |
| | | SqlSugarHelper.UseTransactionWithOracle(db => |
| | | { |
| | | return db.Updateable<QsItemIpiReq>() |
| | | .SetColumns(s => s.IsPass == result) |
| | |
| | | try |
| | | { |
| | | // 定义输出参数 |
| | | var outputResult = new SugarParameter("o_Result", null, DbType.Int32, ParameterDirection.Output, |
| | | var outputResult = new SugarParameter("o_Result", null, |
| | | DbType.Int32, ParameterDirection.Output, |
| | | 4000); |
| | | |
| | | var outputMessage = new SugarParameter("o_Msg", null, DbType.String, ParameterDirection.Output, 4000); |
| | | var outputMessage = new SugarParameter("o_Msg", null, DbType.String, |
| | | ParameterDirection.Output, 4000); |
| | | |
| | | // 定义输入参数 |
| | | var parameters = new List<SugarParameter> |
| | | { |
| | | |
| | | new("p_Id", item.gid, DbType.Int32,ParameterDirection.Input), |
| | | new("p_Flag", 1, DbType.Int32,ParameterDirection.Input), |
| | | new("p_User", item.userNo, DbType.String, ParameterDirection.Input), |
| | | outputResult, |
| | | outputMessage |
| | | }; |
| | | { |
| | | new("p_Id", item.gid, DbType.Int32, ParameterDirection.Input), |
| | | new("p_Flag", 1, DbType.Int32, ParameterDirection.Input), |
| | | new("p_User", item.userNo, DbType.String, |
| | | ParameterDirection.Input), |
| | | outputResult, |
| | | outputMessage |
| | | }; |
| | | |
| | | var db = SqlSugarHelper.GetInstance(); |
| | | |
| | |
| | | var resultValue = outputResult.Value?.ToString(); |
| | | var messageValue = outputMessage.Value?.ToString(); |
| | | |
| | | if ("1".Equals(resultValue)) { throw new Exception(messageValue); } |
| | | if ("0".Equals(resultValue)) { throw new Exception(messageValue); } |
| | | if ("1".Equals(resultValue)) throw new Exception(messageValue); |
| | | if ("0".Equals(resultValue)) throw new Exception(messageValue); |
| | | |
| | | return true; |
| | | } |