1111

啊鑫

2 天以前 00a72fff219241eb5b0405a066cc859d07cf7735

 service/Warehouse/MesOaToMesManager.cs

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

namespace NewPdaSqlServer.service.Warehouse;

@@ -17,8 +19,7 @@
        {
            // 参数校验增强
            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))
            {
@@ -59,26 +60,25 @@
                        cmd.CommandType = CommandType.StoredProcedure;
                        SqlParameter[] parameters =
                        {
                            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)
                            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)
                        };
                        cmd.Parameters.AddRange(parameters);
                        cmd.ExecuteNonQuery();

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

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

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

                    cmd.CommandType = CommandType.StoredProcedure;
                    SqlParameter[] parameters =
                    {
                        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)
                        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)
                    };
                    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}";
                }