using System.Data;
using System.Data.SqlClient;
using Gs.Toolbox;
using Gs.Toolbox.ApiCore.Abstract.Mvc;
using Gs.Toolbox.ApiCore.Common.Mvc;
using Gs.Toolbox.ApiCore.Group;
using Microsoft.AspNetCore.Http;
using Microsoft.AspNetCore.Mvc;
using static Gs.Toolbox.UtilityHelper;
namespace Gs.Pda.Service
{
[ApiGroup(ApiGroupNames.PDA)]
public class PqcManager: IRomteService
{
private readonly IHttpContextAccessor _http;
///
/// 用户Code,用户Guid,组织ID
///
private readonly string _userCode, _userGuid, _orgFids;
public PqcManager(IHttpContextAccessor httpContextAccessor)
{
_http = httpContextAccessor;
(_userCode, _userGuid, _orgFids) = GetUserGuidAndOrgGuid(_http);
}
// LogHelper.Debug("GetUserGuidAndOrgGuid:", ex.Message);
///
/// 首检/巡检输入检验值
///
///
///
///
/// 录入检验结果
///
///
///
[RequestMethod(RequestMethods.POST)]
public ReturnDto AddIpqcJyz([FromBody] dynamic model)
{
string inOrderGuid1 = model.inOrderGuid1; //这是检验单guid
string inOrderGuid5 = model.inOrderGuid5; //这是抽样的guid
string inP1 = model.inP1; //这是9,有可能是19,或者0k-19,或者ng-19
var _outMsg = "";
int? _outSum = -1;
using (var conn = new SqlConnection(DbHelperSQL.strConn))
{
using (var cmd = new SqlCommand("[ipqc_detect01_panding]", conn))
{
try
{
conn.Open();
cmd.CommandType = CommandType.StoredProcedure;
SqlParameter[] parameters =
{
new("@outMsg", SqlDbType.NVarChar, 300),
new("@outSum", SqlDbType.Int),
new("@inEdtUserGuid", _userGuid),
new("@inOrderGuid1", inOrderGuid1),
new("@inOrderGuid5", inOrderGuid5),
new("@inP1", inP1),
};
parameters[0].Direction = ParameterDirection.Output;
parameters[1].Direction = ParameterDirection.Output;
foreach (var parameter in parameters)
cmd.Parameters.Add(parameter);
cmd.ExecuteNonQuery();
_outMsg = parameters[0].Value.ToString();
_outSum = int.Parse(parameters[1].Value.ToString());
}
catch (Exception ex)
{
LogHelper.Debug(ToString(),
"ipqc_detect01_panding error:" + ex.Message);
_outMsg = ex.Message;
_outSum = -1;
}
finally
{
conn.Close();
}
}
}
if (_outSum <= 0)
return ReturnDto.QuickReturn(_outSum,
ReturnCode.Exception, _outMsg);
return ReturnDto.QuickReturn(_outSum,
ReturnCode.Success, _outMsg);
}
///
/// 删除检验结果
///
///
///
[RequestMethod(RequestMethods.POST)]
public ReturnDto DeleteIpqcJyz([FromBody] dynamic model)
{
string inOrderGuid1 = model.inOrderGuid1; //这是检验单guid
string inOrderGuid5 = model.inOrderGuid5; //这是抽样的guid
string inOrderGuid12 = model.inOrderGuid12; //这是抽样的guid
string inP1 = model.inP1; //这是9,有可能是19,或者0k-19,或者ng-19
var _outMsg = "";
int? _outSum = -1;
using (var conn = new SqlConnection(DbHelperSQL.strConn))
{
using (var cmd = new SqlCommand("[ipqc_QADETAIL12_DELETE]", conn))
{
try
{
conn.Open();
cmd.CommandType = CommandType.StoredProcedure;
SqlParameter[] parameters =
{
new("@outMsg", SqlDbType.NVarChar, 300),
new("@outSum", SqlDbType.Int),
new("@inEdtUserGuid", _userGuid),
new("@inOrderGuid1", inOrderGuid1),
new("@inOrderGuid5", inOrderGuid5),
new("@inOrderGuid12", inOrderGuid12),
new("@inP1", inP1),
};
parameters[0].Direction = ParameterDirection.Output;
parameters[1].Direction = ParameterDirection.Output;
foreach (var parameter in parameters)
cmd.Parameters.Add(parameter);
cmd.ExecuteNonQuery();
_outMsg = parameters[0].Value.ToString();
_outSum = int.Parse(parameters[1].Value.ToString());
}
catch (Exception ex)
{
LogHelper.Debug(ToString(),
"ipqc_detect01_panding error:" + ex.Message);
_outMsg = ex.Message;
_outSum = -1;
}
finally
{
conn.Close();
}
}
}
if (_outSum <= 0)
return ReturnDto.QuickReturn(_outSum,
ReturnCode.Exception, _outMsg);
return ReturnDto.QuickReturn(_outSum,
ReturnCode.Success, _outMsg);
}
}
}