精简修正代码

啊鑫

8 天以前 0aa54059b26e6641196e9953490dd18616e916e3

 service/Warehouse/MesOaToMesManager.cs

@@ -3,9 +3,7 @@
using Masuit.Tools;
using NewPdaSqlServer.DB;
using NewPdaSqlServer.Dto.service;
using NewPdaSqlServer.entity;
using NewPdaSqlServer.entity.Base;
using SqlSugar;
using NewPdaSqlServer.util;

namespace NewPdaSqlServer.service.Warehouse;

@@ -19,14 +17,15 @@
        {
            // 参数校验增强
            if (query.iqcExNo.IsNullOrEmpty()) throw new Exception("异常单号不允许为空");
            if (query.dataJson == null || !query.dataJson.Any()) throw new Exception("检验数据不能为空");
            if (query.dataJson == null || !query.dataJson.Any())
                throw new Exception("检验数据不能为空");

            using (var cmd = new SqlCommand("[iqc_ycd_oa_mes]", conn))
            {
                try
                {
                    conn.Open();
                    

                    //// 校验MES检验单
                    //var checkSql = @"SELECT B.releaseNo AS jydNo 
                    //               FROM Mes_QC_Exceptional_Detail B 
@@ -58,27 +57,28 @@
                    {
                        cmd.Parameters.Clear();
                        cmd.CommandType = CommandType.StoredProcedure;
                        SqlParameter[] parameters = 
                        SqlParameter[] parameters =
                        {
                            new SqlParameter("@outMsg", SqlDbType.NVarChar, 150) { Direction = ParameterDirection.Output },
                            new SqlParameter("@outSum", SqlDbType.Int) { Direction = ParameterDirection.Output },
                            new SqlParameter("@ycdNo", query.iqcExNo),
                            new SqlParameter("@jydNo", item.jyd),
                            new SqlParameter("@xblb", item.xblb),
                            new SqlParameter("@clyj", item.clyj),
                            new SqlParameter("@jssl", item.jssl),
                            new SqlParameter("@inFieldValue", 1)
                            new("@outMsg", SqlDbType.NVarChar, 150)
                                { Direction = ParameterDirection.Output },
                            new("@outSum", SqlDbType.Int)
                                { Direction = ParameterDirection.Output },
                            new("@ycdNo", query.iqcExNo),
                            new("@jydNo", item.jyd),
                            new("@xblb", item.xblb),
                            new("@clyj", item.clyj),
                            new("@jssl", item.jssl),
                            new("@inFieldValue", 1)
                        };
                        cmd.Parameters.AddRange(parameters);
                        cmd.ExecuteNonQuery();

                        _intSum += (int)parameters[1].Value;
                        if ((int)parameters[1].Value <= 0)
                        {
                            throw new Exception(parameters[0].Value.ToString());
                        }
                    }
                    string rtnMsg = $"{query.iqcExNo}审批推送MES成功！";

                    var rtnMsg = $"{query.iqcExNo}审批推送MES成功！";

                    return rtnMsg;
                }
@@ -110,29 +110,29 @@
                try
                {
                    conn.Open();
                    int inFieldValue = 0;
                    var inFieldValue = 0;

                    cmd.CommandType = CommandType.StoredProcedure;
                    SqlParameter[] parameters = 
                    SqlParameter[] parameters =
                    {
                        new SqlParameter("@outMsg", SqlDbType.NVarChar, 150) { Direction = ParameterDirection.Output },
                        new SqlParameter("@outSum", SqlDbType.Int) { Direction = ParameterDirection.Output },
                        new SqlParameter("@ycdNo", query.iqcExNo),
                        new SqlParameter("@jydNo", DBNull.Value),
                        new SqlParameter("@xblb", DBNull.Value),
                        new SqlParameter("@clyj", DBNull.Value),
                        new SqlParameter("@jssl", DBNull.Value),
                        new SqlParameter("@inFieldValue", inFieldValue)
                        new("@outMsg", SqlDbType.NVarChar, 150)
                            { Direction = ParameterDirection.Output },
                        new("@outSum", SqlDbType.Int)
                            { Direction = ParameterDirection.Output },
                        new("@ycdNo", query.iqcExNo),
                        new("@jydNo", DBNull.Value),
                        new("@xblb", DBNull.Value),
                        new("@clyj", DBNull.Value),
                        new("@jssl", DBNull.Value),
                        new("@inFieldValue", inFieldValue)
                    };
                    cmd.Parameters.AddRange(parameters);
                    cmd.ExecuteNonQuery();

                    _intSum = (int)parameters[1].Value;
                    if (_intSum <= 0)
                    {
                        throw new Exception(parameters[0].Value.ToString());
                    }
                    

                    return $"{query.iqcExNo}退回操作成功！影响记录数：{_intSum}";
                }
                catch (Exception ex)