using Microsoft.AspNetCore.Mvc;
|
using System.Threading.Tasks;
|
using gdbg.Services;
|
using System.Collections.Generic;
|
using Oracle.ManagedDataAccess.Client;
|
using gdbg.Models;
|
|
namespace gdbg.Controllers
|
{
|
[ApiController]
|
[Route("api/[controller]")]
|
public class InspectionController : ControllerBase
|
{
|
private readonly OracleDbService _oracleDbService;
|
|
public InspectionController(OracleDbService oracleDbService)
|
{
|
_oracleDbService = oracleDbService;
|
}
|
|
[HttpPost("firstInspection")]
|
public async Task<IActionResult> FirstInspection([FromBody] FirstInspectionRequest request)
|
{
|
try
|
{
|
string procedureCall = "BEGIN PRC_ZSSJ_TJ(:pi_user, :pi_release_no, :po_flag, :po_text); END;";
|
|
var poFlag = new OracleParameter("po_flag", OracleDbType.Int32) { Direction = System.Data.ParameterDirection.Output };
|
var poText = new OracleParameter("po_text", OracleDbType.Varchar2, 2000) { Direction = System.Data.ParameterDirection.Output };
|
|
var parameters = new List<OracleParameter>
|
{
|
new OracleParameter("pi_user", request.UserId),
|
new OracleParameter("pi_release_no", request.ReleaseNo),
|
poFlag,
|
poText
|
};
|
|
await _oracleDbService.ExecuteProcedureAsync(procedureCall, parameters);
|
|
// 安全地转换输出标志
|
int flag = Convert.ToInt32(poFlag.Value.ToString());
|
string message = poText.Value.ToString();
|
|
if (flag == 0)
|
{
|
return Ok(new { message = message });
|
}
|
else
|
{
|
return BadRequest(new { message = message });
|
}
|
}
|
catch (Exception ex)
|
{
|
return StatusCode(500, new { message = "执行首检送检时发生错误。", error = ex.Message });
|
}
|
}
|
|
|
[HttpPost("startProduction")]
|
public async Task<IActionResult> StartProduction([FromBody] StartProductionRequest request)
|
{
|
try
|
{
|
string procedureCall = "BEGIN PQC_ZSBG_GDKG(:pi_user,:pi_order_no, :po_flag, :po_text); END;";
|
|
var poFlag = new OracleParameter("po_flag", OracleDbType.Int32) { Direction = System.Data.ParameterDirection.Output };
|
var poText = new OracleParameter("po_text", OracleDbType.Varchar2, 2000) { Direction = System.Data.ParameterDirection.Output };
|
|
var parameters = new List<OracleParameter>
|
{
|
new OracleParameter("pi_user", request.UserId),
|
new OracleParameter("pi_order_no", request.OrderNo),
|
|
poFlag,
|
poText
|
};
|
|
await _oracleDbService.ExecuteProcedureAsync(procedureCall, parameters);
|
|
// 安全地转换输出标志
|
int flag = Convert.ToInt32(poFlag.Value.ToString());
|
string message = poText.Value.ToString();
|
|
if (flag == 0)
|
{
|
return Ok(new { message = message });
|
}
|
else
|
{
|
return BadRequest(new { message = message });
|
}
|
}
|
catch (Exception ex)
|
{
|
return StatusCode(500, new { message = "开工请求时发生错误。", error = ex.Message });
|
}
|
}
|
|
|
}
|
}
|
