| | |
|---|
| | | |
|---|
| | | return dto; |
|---|
| | | } |
|---|
| | | |
|---|
| | | /// <summary> |
|---|
| | | /// 获取工单条码信息 |
|---|
| | | /// </summary> |
|---|
| | | /// <param name="query"></param> |
|---|
| | | /// <returns></returns> |
|---|
| | | public dynamic getZsBarInfo(dynamic query) |
|---|
| | | { |
|---|
| | | |
|---|
| | | var sql = string.Format(@"SELECT TOP 1 A.barCode AS zsBarcode, |
|---|
| | | D.name AS lineName, |
|---|
| | | D.line_no, |
|---|
| | | B.daa001, |
|---|
| | | C.item_no, |
|---|
| | | C.item_name, |
|---|
| | | C.item_model, |
|---|
| | | A.quantity as barQty, |
|---|
| | | B.daa008 as sumQty, |
|---|
| | | isnull((SELECT count(1) FROM WORK_COLLECT WHERE processNo = '{0}' AND ABOUT_GUID = A.ABOUT_GUID),0) AS finQty, |
|---|
| | | isnull((SELECT TOP 1 processNo FROM WORK_COLLECT WHERE WORK_COLLECT.barCode = '{1}' AND checkResult = '√' ORDER BY WORK_COLLECT.createDate DESC ),'') AS lastGx |
|---|
| | | FROM WORK_TRAC_CODE A |
|---|
| | | LEFT JOIN WOMDAA B ON A.ABOUT_GUID = B.guid |
|---|
| | | LEFT JOIN MES_ITEMS C ON B.daa002 = C.item_id |
|---|
| | | LEFT JOIN MES_WORKSHOP_LINE D ON A.lineId = D.id |
|---|
| | | WHERE A.barCode = '{1}'", query.GX, query.Zsbarcode); |
|---|
| | | |
|---|
| | | var ZsBarInfo = Db.Ado.SqlQuery<dynamic>(sql); |
|---|
| | | |
|---|
| | | if (ZsBarInfo.Count < 1) |
|---|
| | | { |
|---|
| | | throw new Exception($"该追溯码{query.Zsbarcode}不存在不存在"); |
|---|
| | | } |
|---|
| | | |
|---|
| | | return ZsBarInfo; |
|---|
| | | } |
|---|
| | | |
|---|
| | | //获取生产 |
|---|
| | | public dynamic getTraceability(dynamic query) |
|---|
| | | { |
|---|
| | | var sql = string.Format(@"SELECT processNo, A.barCode, B.lineId, line_no, name AS lineName, checkResult, C.USER_NAME |
|---|
| | | FROM WORK_COLLECT A |
|---|
| | | LEFT JOIN WORK_TRAC_CODE B ON A.barCode = B.barCode |
|---|
| | | LEFT JOIN SYS_USER C ON C.ACCOUNT = A.createBy |
|---|
| | | LEFT JOIN MES_WORKSHOP_LINE D ON B.lineId = D.id |
|---|
| | | WHERE A.barCode = '{0}'", query.Zsbarcode); |
|---|
| | | |
|---|
| | | var Traceability = Db.Ado.SqlQuery<dynamic>(sql); |
|---|
| | | |
|---|
| | | return Traceability; |
|---|
| | | } |
|---|
| | | |
|---|
| | | public dynamic ProductBinding(dynamic query) |
|---|
| | | { |
|---|
| | | if (query == null) throw new ArgumentNullException(nameof(query), "参数对象不能为 null"); |
|---|
| | | |
|---|
| | | // 2. 使用 string.IsNullOrEmpty 直接判断字符串属性（避免 NullReferenceException） |
|---|
| | | if (string.IsNullOrEmpty(query.userName?.ToString())) |
|---|
| | | throw new ArgumentException("用户名不允许为空", nameof(query.userName)); |
|---|
| | | |
|---|
| | | if (string.IsNullOrEmpty(query.ZsBar?.ToString())) |
|---|
| | | throw new ArgumentException("追溯码不允许为空", nameof(query.ZsBar)); |
|---|
| | | |
|---|
| | | if (string.IsNullOrEmpty(query.LsBar?.ToString())) |
|---|
| | | throw new ArgumentException("后盖码不允许为空", nameof(query.LsBar)); |
|---|
| | | |
|---|
| | | var _strMsg = ""; |
|---|
| | | var _intSum = ""; |
|---|
| | | using (var conn = new SqlConnection(DbHelperSQL.strConn)) |
|---|
| | | { |
|---|
| | | using (var cmd = new SqlCommand("prc_pda_product_binding", conn)) |
|---|
| | | { |
|---|
| | | try |
|---|
| | | { |
|---|
| | | conn.Open(); |
|---|
| | | cmd.CommandType = CommandType.StoredProcedure; |
|---|
| | | SqlParameter[] parameters = |
|---|
| | | { |
|---|
| | | new("@pi_user", SqlDbType.NVarChar, 100) { Value = query.userName }, |
|---|
| | | new("@pi_trac_barcode", SqlDbType.NVarChar, 100) { Value = query.ZsBar }, |
|---|
| | | new("@pi_ls_barcode", SqlDbType.NVarChar, 100) { Value = query.LsBar }, |
|---|
| | | new("@po_outMsg", SqlDbType.NVarChar, 2000) { Direction = ParameterDirection.Output }, |
|---|
| | | new("@po_outStatus", SqlDbType.Int) { Direction = ParameterDirection.Output } |
|---|
| | | }; |
|---|
| | | |
|---|
| | | foreach (var parameter in parameters) |
|---|
| | | cmd.Parameters.Add(parameter); |
|---|
| | | |
|---|
| | | cmd.ExecuteNonQuery(); |
|---|
| | | |
|---|
| | | _strMsg = parameters[3].Value?.ToString() ?? ""; |
|---|
| | | _intSum = parameters[4].Value?.ToString() ?? "-1"; |
|---|
| | | |
|---|
| | | var result = Convert.ToInt32(_intSum); |
|---|
| | | if (result <= 0) throw new Exception(_strMsg); |
|---|
| | | |
|---|
| | | var dto = new |
|---|
| | | { |
|---|
| | | message = _strMsg, |
|---|
| | | status = result, |
|---|
| | | tracBarcode = query.ZsBar |
|---|
| | | }; |
|---|
| | | |
|---|
| | | return dto; |
|---|
| | | } |
|---|
| | | catch (Exception ex) |
|---|
| | | { |
|---|
| | | throw new Exception(ex.Message); |
|---|
| | | } |
|---|
| | | finally |
|---|
| | | { |
|---|
| | | conn.Close(); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
| | | /// <summary> |
|---|
| | | /// 获取卡板信息 |
|---|
| | | /// </summary> |
|---|
| | | /// <param name="query"></param> |
|---|
| | | /// <returns></returns> |
|---|
| | | public dynamic getKbBarInfo(dynamic query) |
|---|
| | | { |
|---|
| | | if (string.IsNullOrEmpty(query.Kbbarcode?.ToString())) |
|---|
| | | throw new ArgumentException("卡板条码不允许为空", nameof(query.userName)); |
|---|
| | | |
|---|
| | | var sql = string.Format(@"SELECT OLDQTY, |
|---|
| | | ISNULL((SELECT COUNT(1) FROM MES_INV_ITEM_BARCODES_TBMX WHERE ABOUT_TB_BARCODE = '{0}'), 0) AS YSum, |
|---|
| | | DAA001 |
|---|
| | | FROM MES_INV_ITEM_BARCODES A LEFT JOIN WOMDAA B ON A.ABOUT_GUID = B.guid |
|---|
| | | WHERE ITEM_BARCODE = '{0}' ", query.Kbbarcode); |
|---|
| | | |
|---|
| | | var ZsBarInfo = Db.Ado.SqlQuery<dynamic>(sql); |
|---|
| | | |
|---|
| | | if (ZsBarInfo.Count < 1) |
|---|
| | | { |
|---|
| | | throw new Exception($"该卡板码{query.Zsbarcode}不存在！"); |
|---|
| | | } |
|---|
| | | |
|---|
| | | return ZsBarInfo; |
|---|
| | | } |
|---|
| | | |
|---|
| | | /// <summary> |
|---|
| | | /// 获取卡板明细信息 |
|---|
| | | /// </summary> |
|---|
| | | /// <param name="query"></param> |
|---|
| | | /// <returns></returns> |
|---|
| | | public dynamic getKbBarMxInfo(dynamic query) |
|---|
| | | { |
|---|
| | | |
|---|
| | | var sql = string.Format(@"SELECT ITEM_BARCODE, QUANTITY,item_no,item_name,item_model |
|---|
| | | FROM MES_INV_ITEM_BARCODES_TBMX A |
|---|
| | | LEFT JOIN WOMDAA B ON B.daa001 = A.DAA_001 |
|---|
| | | LEFT JOIN MES_ITEMS C ON C.item_id = B.daa002 |
|---|
| | | WHERE ABOUT_TB_BARCODE = '{0}' ", query.Kbbarcode); |
|---|
| | | |
|---|
| | | var ZsBarInfo = Db.Ado.SqlQuery<dynamic>(sql); |
|---|
| | | |
|---|
| | | |
|---|
| | | return ZsBarInfo; |
|---|
| | | } |
|---|
| | | |
|---|
| | | /// <summary> |
|---|
| | | /// 获取卡板明细信息 |
|---|
| | | /// </summary> |
|---|
| | | /// <param name="query"></param> |
|---|
| | | /// <returns></returns> |
|---|
| | | public dynamic getXBarInfo(dynamic query) |
|---|
| | | { |
|---|
| | | var sql1 = string.Format(@"SELECT 1 FROM MES_INV_ITEM_BARCODES_TBMX WHERE ITEM_BARCODE = '{0}' ", query.Xbarcode); |
|---|
| | | |
|---|
| | | var IS_CZ = Db.Ado.SqlQuery<dynamic>(sql1); |
|---|
| | | |
|---|
| | | if (IS_CZ.Count < 1) |
|---|
| | | { |
|---|
| | | throw new Exception($"该箱条码[{query.Xbarcode}]不存在！"); |
|---|
| | | } |
|---|
| | | |
|---|
| | | var sql2 = string.Format(@"SELECT ITEM_BARCODE, QUANTITY,item_no,item_name,item_model,'0' as is_hedui |
|---|
| | | FROM MES_INV_ITEM_BARCODES_TBMX A |
|---|
| | | LEFT JOIN WOMDAA B ON B.daa001 = A.DAA_001 |
|---|
| | | LEFT JOIN MES_ITEMS C ON C.item_id = B.daa002 |
|---|
| | | WHERE DAA_001 = '{0}' |
|---|
| | | AND ITEM_BARCODE = '{1}' |
|---|
| | | AND ISNULL(ABOUT_TB_BARCODE, '') = '' ", query.DAA001, query.Xbarcode); |
|---|
| | | |
|---|
| | | var ZsBarInfo = Db.Ado.SqlQuery<dynamic>(sql2); |
|---|
| | | |
|---|
| | | if (ZsBarInfo.Count < 1) |
|---|
| | | { |
|---|
| | | throw new Exception($"该箱条码[{query.Xbarcode}]对应工单与托码工单[{query.DAA001}]不匹配或已绑定托码！"); |
|---|
| | | } |
|---|
| | | |
|---|
| | | return ZsBarInfo; |
|---|
| | | } |
|---|
| | | |
|---|
| | | public dynamic submitAllChecked(dynamic query) |
|---|
| | | { |
|---|
| | | if (query == null) throw new ArgumentNullException(nameof(query), "参数对象不能为 null"); |
|---|
| | | |
|---|
| | | // 参数校验强化 |
|---|
| | | if (string.IsNullOrEmpty(query.userName?.ToString())) |
|---|
| | | throw new ArgumentException("用户名不允许为空", nameof(query.userName)); |
|---|
| | | |
|---|
| | | if (string.IsNullOrEmpty(query.KbBar?.ToString())) |
|---|
| | | throw new ArgumentException("卡板条码不允许为空", nameof(query.KbBar)); |
|---|
| | | |
|---|
| | | if (query.XbarInfo == null || !((IEnumerable<dynamic>)query.XbarInfo).GetEnumerator().MoveNext()) |
|---|
| | | throw new ArgumentException("箱码列表不能为空", nameof(query.XbarInfo)); |
|---|
| | | |
|---|
| | | var successRecords = new List<dynamic>(); |
|---|
| | | using (var conn = new SqlConnection(DbHelperSQL.strConn)) |
|---|
| | | { |
|---|
| | | conn.Open(); |
|---|
| | | using (var transaction = conn.BeginTransaction()) // 开启事务 |
|---|
| | | { |
|---|
| | | try |
|---|
| | | { |
|---|
| | | foreach (var xBar in query.XbarInfo) // 遍历箱码集合 |
|---|
| | | { |
|---|
| | | using (var cmd = new SqlCommand("prc_pda_Xbar_binding", conn, transaction)) |
|---|
| | | { |
|---|
| | | cmd.CommandType = CommandType.StoredProcedure; |
|---|
| | | SqlParameter[] parameters = |
|---|
| | | { |
|---|
| | | new("@pi_user", SqlDbType.NVarChar, 100) { Value = query.userName }, |
|---|
| | | new("@pi_kb_barcode", SqlDbType.NVarChar, 100) { Value = query.KbBar }, |
|---|
| | | new("@pi_ls_barcode", SqlDbType.NVarChar, 100) { Value = xBar.iteM_BARCODE }, |
|---|
| | | new("@po_outMsg", SqlDbType.NVarChar, 2000) { Direction = ParameterDirection.Output }, |
|---|
| | | new("@po_outStatus", SqlDbType.Int) { Direction = ParameterDirection.Output } |
|---|
| | | }; |
|---|
| | | |
|---|
| | | foreach (var parameter in parameters) |
|---|
| | | cmd.Parameters.Add(parameter); |
|---|
| | | |
|---|
| | | cmd.ExecuteNonQuery(); |
|---|
| | | |
|---|
| | | var _strMsg = parameters[3].Value?.ToString() ?? ""; |
|---|
| | | var _intSum = parameters[4].Value?.ToString() ?? "-1"; |
|---|
| | | |
|---|
| | | var result = Convert.ToInt32(_intSum); |
|---|
| | | if (result <= 0) |
|---|
| | | { |
|---|
| | | //transaction.Rollback(); |
|---|
| | | throw new Exception(_strMsg); |
|---|
| | | //return new { |
|---|
| | | // status = result, |
|---|
| | | // message = $"操作回滚：{_strMsg}", |
|---|
| | | // failedBarcode = xBar.iteM_BARCODE, |
|---|
| | | // successCount = successRecords.Count |
|---|
| | | //}; |
|---|
| | | } |
|---|
| | | |
|---|
| | | successRecords.Add(new { |
|---|
| | | kbBarcode = query.KbBar, |
|---|
| | | xBarcode = xBar.iteM_BARCODE, |
|---|
| | | processTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss") |
|---|
| | | }); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | transaction.Commit(); // 全部成功提交事务 |
|---|
| | | return new { |
|---|
| | | status = 1, |
|---|
| | | message = "批量绑定成功", |
|---|
| | | successCount = successRecords.Count, |
|---|
| | | details = successRecords |
|---|
| | | }; |
|---|
| | | } |
|---|
| | | catch (Exception ex) |
|---|
| | | { |
|---|
| | | transaction.Rollback(); |
|---|
| | | throw new Exception($"异常信息 ：{ex.Message}"); |
|---|
| | | } |
|---|
| | | finally |
|---|
| | | { |
|---|
| | | conn.Close(); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | public dynamic SubmitKbInspection(dynamic query) |
|---|
| | | { |
|---|
| | | if (query == null) throw new ArgumentNullException(nameof(query), "参数对象不能为 null"); |
|---|
| | | |
|---|
| | | // 参数校验 |
|---|
| | | if (string.IsNullOrEmpty(query.userAccount?.ToString())) |
|---|
| | | throw new ArgumentException("用户名不允许为空", nameof(query.userAccount)); |
|---|
| | | |
|---|
| | | if (string.IsNullOrEmpty(query.KbBar?.ToString())) |
|---|
| | | throw new ArgumentException("卡板条码不允许为空", nameof(query.KbBar)); |
|---|
| | | |
|---|
| | | var _strMsg = ""; |
|---|
| | | var _status = -1; |
|---|
| | | using (var conn = new SqlConnection(DbHelperSQL.strConn)) |
|---|
| | | { |
|---|
| | | using (var cmd = new SqlCommand("prc_pda_KBbar_submitInspection", conn)) |
|---|
| | | { |
|---|
| | | try |
|---|
| | | { |
|---|
| | | conn.Open(); |
|---|
| | | cmd.CommandType = CommandType.StoredProcedure; |
|---|
| | | SqlParameter[] parameters = |
|---|
| | | { |
|---|
| | | new("@pi_user", SqlDbType.NVarChar, 100) { Value = query.userAccount }, |
|---|
| | | new("@pi_kb_barcode", SqlDbType.NVarChar, 100) { Value = query.KbBar }, |
|---|
| | | new("@po_outMsg", SqlDbType.NVarChar, 2000) { Direction = ParameterDirection.Output }, |
|---|
| | | new("@po_outStatus", SqlDbType.Int) { Direction = ParameterDirection.Output } |
|---|
| | | }; |
|---|
| | | |
|---|
| | | foreach (var parameter in parameters) |
|---|
| | | cmd.Parameters.Add(parameter); |
|---|
| | | |
|---|
| | | cmd.ExecuteNonQuery(); |
|---|
| | | |
|---|
| | | _strMsg = parameters[2].Value?.ToString() ?? ""; |
|---|
| | | _status = Convert.ToInt32(parameters[3].Value ?? -1); |
|---|
| | | |
|---|
| | | if (_status <= 0) throw new Exception(_strMsg); |
|---|
| | | |
|---|
| | | return new { |
|---|
| | | message = _strMsg, |
|---|
| | | status = _status, |
|---|
| | | kbBarcode = query.KbBar |
|---|
| | | }; |
|---|
| | | } |
|---|
| | | catch (Exception ex) |
|---|
| | | { |
|---|
| | | throw new Exception($"卡板送检失败：{ex.Message}"); |
|---|
| | | } |
|---|
| | | finally |
|---|
| | | { |
|---|
| | | conn.Close(); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
