From ed670b6b4a44a11060a7527809c84ff4c32ba6a6 Mon Sep 17 00:00:00 2001 From: 南骏 池 <chiffly@163.com> Date: 星期六, 12 七月 2025 15:39:52 +0800 Subject: [PATCH] 1.AGV接口开发 2.采购扫描验退 --- service/Warehouse/MesCgthSqManager.cs | 161 +++++++++++++++++++++++++++++++++++++++++++++++++++++ 1 files changed, 161 insertions(+), 0 deletions(-) diff --git a/service/Warehouse/MesCgthSqManager.cs b/service/Warehouse/MesCgthSqManager.cs index dbb8747..4c92478 100644 --- a/service/Warehouse/MesCgthSqManager.cs +++ b/service/Warehouse/MesCgthSqManager.cs @@ -6,6 +6,7 @@ using NewPdaSqlServer.entity; using NewPdaSqlServer.entity.Base; using SqlSugar; +using static Microsoft.EntityFrameworkCore.DbLoggerCategory; namespace NewPdaSqlServer.service.Warehouse; @@ -224,4 +225,164 @@ } } } + + + /// <summary> + /// 閲囪喘鎵爜楠岄�� + /// </summary> + /// <param name="query"></param> + /// <returns></returns> + /// <exception cref="ArgumentNullException"></exception> + /// <exception cref="ArgumentException"></exception> + /// <exception cref="Exception"></exception> + public dynamic ScanCgyt(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.barcode?.ToString())) + throw new ArgumentException("閲囪喘鐗╂枡鏉$爜涓嶅厑璁镐负绌�", nameof(query.barcode)); + + using (var conn = new SqlConnection(DbHelperSQL.strConn)) + { + using (var cmd = new SqlCommand("prc_pda_scan_CGYT", conn)) + { + cmd.CommandType = CommandType.StoredProcedure; + var parameters = new SqlParameter[] + { + new("@pi_user", SqlDbType.NVarChar, 100) { Value = query.userName }, + new("@pi_barcode", SqlDbType.NVarChar, 100) { Value = query.barcode }, + new("@po_outMsg", SqlDbType.NVarChar, 2000) { Direction = ParameterDirection.Output }, + new("@po_outSum", SqlDbType.Int) { Direction = ParameterDirection.Output }, + new("@po_ygdh", SqlDbType.NVarChar, 200) { Direction = ParameterDirection.Output } + }; + + cmd.Parameters.AddRange(parameters); + conn.Open(); + cmd.ExecuteNonQuery(); + + var result = new + { + result = parameters[3].Value.ToString(), + barcode = query.barcode, + ytdh = parameters[4].Value.ToString(), + msg = parameters[2].Value.ToString() + }; + + if (result.result == "-1") + throw new Exception(parameters[2].Value.ToString()); + + return result; + } + } + } + + /// <summary> + /// 鍒犻櫎楠岄��鍗� + /// </summary> + /// <param name="query"></param> + /// <returns></returns> + /// <exception cref="ArgumentNullException"></exception> + /// <exception cref="ArgumentException"></exception> + /// <exception cref="Exception"></exception> + public dynamic deleteCgyt(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.ytdh?.ToString())) + throw new ArgumentException("杩芥函鐮佷笉鍏佽涓虹┖", nameof(query.ytdh)); + + using (var conn = new SqlConnection(DbHelperSQL.strConn)) + { + using (var cmd = new SqlCommand("prc_pda_delete_CGYT", conn)) + { + cmd.CommandType = CommandType.StoredProcedure; + var parameters = new SqlParameter[] + { + new("@pi_user", SqlDbType.NVarChar, 100) { Value = query.userName }, + new("@pi_ytdh", SqlDbType.NVarChar, 100) { Value = query.ytdh }, + new("@po_outMsg", SqlDbType.NVarChar, 2000) { Direction = ParameterDirection.Output }, + new("@po_outSum", SqlDbType.Int) { Direction = ParameterDirection.Output } + }; + + cmd.Parameters.AddRange(parameters); + conn.Open(); + cmd.ExecuteNonQuery(); + + var result = new + { + result = parameters[3].Value.ToString(), + msg = parameters[2].Value.ToString(), + }; + + if (result.result == "-1") + throw new Exception(parameters[2].Value.ToString()); + + return result; + } + } + } + + /// <summary> + /// 鑾峰彇楠岄��鍗曞凡鎵墿鏂欎俊鎭� + /// </summary> + /// <param name="query"></param> + /// <returns></returns> + public dynamic getYtItem(string ytdh) + { + if (string.IsNullOrEmpty(ytdh?.ToString())) + throw new ArgumentException("楠岄��鍗曞彿涓嶅厑璁镐负绌�", nameof(ytdh)); + + var sqlParams = new List<SugarParameter> { new("@ytdh", ytdh) }; + + var sql1 = @"SELECT C.item_id,C.item_no,C.item_name,C.item_model,A.quantity +FROM MES_INV_ITEM_CGYT_ITEMS A + LEFT JOIN MES_INV_ITEM_CGYT B ON A.item_cgyt_id = B.GUID + LEFT JOIN MES_ITEMS C ON A.item_id = C.item_id +WHERE B.item_cgyt_no = @ytdh"; + + var YtItem = Db.Ado.SqlQuery<dynamic>(sql1, sqlParams); + + //if (YtItem.Count < 1) + //{ + // throw new Exception($"璇ラ獙閫�鍗曞彿{ytdh}鐗╂枡鏄庣粏涓嶅瓨鍦紒"); + //} + + return YtItem; + } + + /// <summary> + /// 鑾峰彇楠岄��鍗曞凡鎵潯鐮佷俊鎭� + /// </summary> + /// <param name="query"></param> + /// <returns></returns> + public dynamic getYtBarInfo(string ytdh) + { + if (string.IsNullOrEmpty(ytdh?.ToString())) + throw new ArgumentException("楠岄��鍗曞彿涓嶅厑璁镐负绌�", nameof(ytdh)); + + var sqlParams = new List<SugarParameter> { new("@ytdh", ytdh) }; + + var sql1 = @"SELECT C.item_id,C.item_no,C.item_name,C.item_model,A.quantity,A.ITEM_BARCODE +FROM MES_INV_ITEM_CGYT_C_DETAILS A + LEFT JOIN MES_INV_ITEM_CGYT B ON A.item_cgyt_id = B.GUID + LEFT JOIN MES_ITEMS C ON A.item_id = C.item_id +WHERE B.item_cgyt_no = @ytdh"; + + var YtBarInfo = Db.Ado.SqlQuery<dynamic>(sql1, sqlParams); + + //if (YtBarInfo.Count < 1) + //{ + // throw new Exception($"璇ラ獙閫�鍗曞彿{ytdh}浠栦滑涓嶅瓨鍦紒"); + //} + + return YtBarInfo; + } } \ No newline at end of file -- Gitblit v1.9.3