using System.Data;
|
using System.Data.SqlClient;
|
using Masuit.Tools;
|
using NewPdaSqlServer.DB;
|
using NewPdaSqlServer.Dto.service;
|
using NewPdaSqlServer.entity;
|
using NewPdaSqlServer.entity.Base;
|
using SqlSugar;
|
|
namespace NewPdaSqlServer.service.Warehouse;
|
|
public class MesOaToMesManager : Repository<OaToMesQuery>
|
{
|
public string ApproveIqcEx(OaToMesQuery query)
|
{
|
var _strMsg = "";
|
var _intSum = 0;
|
using (var conn = new SqlConnection(DbHelperSQL.strConn))
|
{
|
// 参数校验增强
|
if (query.iqcExNo.IsNullOrEmpty()) 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
|
// LEFT JOIN Mes_QC_Exceptional A ON A.guid = B.pGuid
|
// WHERE A.fBillNo = @iqcExNo";
|
//using (var checkCmd = new SqlCommand(checkSql, conn))
|
//{
|
// checkCmd.Parameters.AddWithValue("@iqcExNo", query.iqcExNo);
|
// var dbJydList = new List<string>();
|
// using (var reader = checkCmd.ExecuteReader())
|
// {
|
// while (reader.Read())
|
// {
|
// dbJydList.Add(reader["jydNo"].ToString());
|
// }
|
// }
|
|
// // 验证数据一致性
|
// var inputJydList = query.dataJson.Select(d => d.jyd).ToList();
|
// var diff = inputJydList.Except(dbJydList).Union(dbJydList.Except(inputJydList));
|
// if (diff.Any())
|
// {
|
// throw new Exception($"传入异常处置单对应的检验单号与MES不匹配，差异单号：{string.Join(",", diff)}");
|
// }
|
//}
|
|
// 循环处理每条数据
|
foreach (var item in query.dataJson)
|
{
|
cmd.Parameters.Clear();
|
cmd.CommandType = CommandType.StoredProcedure;
|
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)
|
};
|
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成功！";
|
|
return rtnMsg;
|
}
|
catch (Exception ex)
|
{
|
// 增强异常日志
|
_strMsg = $"异常处置失败：{ex.Message}";
|
throw new Exception(_strMsg);
|
}
|
finally
|
{
|
conn.Close();
|
}
|
}
|
}
|
}
|
|
public string RetrunIqcEx(OaToMesRQuery query)
|
{
|
var _strMsg = "";
|
var _intSum = 0;
|
using (var conn = new SqlConnection(DbHelperSQL.strConn))
|
{
|
// 参数校验增强
|
if (query.iqcExNo.IsNullOrEmpty()) throw new Exception("异常单号不允许为空");
|
|
using (var cmd = new SqlCommand("[iqc_ycd_oa_mes]", conn))
|
{
|
try
|
{
|
conn.Open();
|
int inFieldValue = 0;
|
|
cmd.CommandType = CommandType.StoredProcedure;
|
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)
|
};
|
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)
|
{
|
_strMsg = $"异常单退回失败：{ex.Message}";
|
throw new Exception(_strMsg);
|
}
|
finally
|
{
|
conn.Close();
|
}
|
}
|
}
|
}
|
}
|
