采购入库优化

kyy

2025-10-22 7d772840712a8dd5be125ba70060a1bf1bf322d6

采购入库优化

 service/Warehouse/MesInvItemInCDetailsManager.cs

@@ -23,7 +23,7 @@
    public ItemInBaseModel SaveBarCodes(WarehouseQuery entity)
    {
        ItemInBaseModel res = new ItemInBaseModel();
        string connectionString = DbHelperSQL.strConn;
        string connectionString = DB.DbHelperSQL.strConn;

        // 参数验证
        if (string.IsNullOrEmpty(entity.userName)) throw new ArgumentNullException(nameof(entity.userName), "用户名不允许为空");
@@ -34,8 +34,8 @@
        {
            using (var cmd = new SqlCommand("[prc_pda_inv_cgrk]", conn))
            {
                try
                {
                //try
                //{
                    conn.Open();
                    cmd.CommandType = CommandType.StoredProcedure;

@@ -45,6 +45,7 @@
                        new SqlParameter("@pi_user", SqlDbType.NVarChar, 100) { Value = entity.userName },
                        new SqlParameter("@pi_barcode", SqlDbType.NVarChar, 100) { Value =  entity.barcode.Trim().ToLower() },
                        new SqlParameter("@pi_sectionCode", SqlDbType.NVarChar, 30) { Value = entity.sectionCode },
                        new SqlParameter("@pi_cgrkType", SqlDbType.NVarChar, 30) { Value = "正常入库" },
                        new SqlParameter("@pi_weight", SqlDbType.Decimal) { Value = entity.weight },
                        new SqlParameter("@po_outMsg", SqlDbType.NVarChar, 300) { Direction = ParameterDirection.Output },
                        new SqlParameter("@po_outSum", SqlDbType.NVarChar, 300) { Direction = ParameterDirection.Output }
@@ -54,8 +55,8 @@
                    cmd.ExecuteNonQuery();

                    // 获取输出参数
                    string? outMessage = parameters[4].Value?.ToString();
                    string? outSum = parameters[5].Value?.ToString();
                    string? outMessage = parameters[5].Value?.ToString();
                    string? outSum = parameters[6].Value?.ToString();


                    // 检查参数是否为空，并在异常中显示实际值
@@ -135,16 +136,16 @@
                    

                    return res;
                }
                catch (Exception ex)
                {
                //}
                //catch (Exception ex)
                //{


                    // 记录异常日志（建议添加日志记录）
                    res.Message = $"操作失败: {ex.Message}";
                    res.SumQuantity = -1;
                    return res;
                }
                //    // 记录异常日志（建议添加日志记录）
                //    res.Message = $"操作失败: {ex.Message}";
                //    res.SumQuantity = -1;
                //    return res;
                //}
            }
        }
    }
@@ -1412,7 +1413,7 @@
            string intSum = "";
            string cfBar = "";

            using (var conn = new SqlConnection(DbHelperSQL.strConn))
            using (var conn = new SqlConnection(DB.DbHelperSQL.strConn))
            {
                using (var cmd = new SqlCommand("[prc_pda_bar_cf_before]", conn))
                {
@@ -1448,7 +1449,7 @@
            string ytSum = "";
            string ytdh = "";

            using (var conn = new SqlConnection(DbHelperSQL.strConn))
            using (var conn = new SqlConnection(DB.DbHelperSQL.strConn))
            {
                using (var cmd = new SqlCommand("prc_pda_scan_CGYT", conn))
                {
@@ -1478,7 +1479,7 @@
            string rkMsg = "";
            string rkSum = "";

            using (var conn = new SqlConnection(DbHelperSQL.strConn))
            using (var conn = new SqlConnection(DB.DbHelperSQL.strConn))
            {
                using (var cmd = new SqlCommand("prc_pda_inv_cgrk", conn))
                {
@@ -1489,6 +1490,7 @@
                        new("@pi_user", SqlDbType.NVarChar, 100) { Value = entity.userName },
                        new("@pi_barcode", SqlDbType.NVarChar, 100) { Value = entity.returnBarcode }, // 使用原始条码
                        new("@pi_sectionCode", SqlDbType.NVarChar, 100) { Value = entity.sectionCode },
                        new("@pi_cgrkType", SqlDbType.NVarChar, 30) { Value = "正常入库" },
                        new("@pi_weight", SqlDbType.Decimal) { Value = entity.weight },
                        new("@po_outMsg", SqlDbType.NVarChar, 2000) { Direction = ParameterDirection.Output },
                        new("@po_outSum", SqlDbType.Int) { Direction = ParameterDirection.Output }
@@ -1497,8 +1499,8 @@
                    cmd.Parameters.AddRange(rkParameters);
                    cmd.ExecuteNonQuery();

                    rkMsg = rkParameters[4].Value.ToString();
                    rkSum = rkParameters[5].Value.ToString();
                    rkMsg = rkParameters[5].Value.ToString();
                    rkSum = rkParameters[6].Value.ToString();

                    if (rkSum == "-1") throw new Exception(rkMsg);
                }