using Microsoft.AspNetCore.Mvc;
using System.Threading.Tasks;
using gdbg.Services;
using System.Collections.Generic;
using Oracle.ManagedDataAccess.Client;
using System.Data;

namespace gdbg.Controllers
{
    [ApiController]
    [Route("api/[controller]")]
    public class RefreshController : ControllerBase
    {
        private readonly OracleDbService _oracleDbService;

        public RefreshController(OracleDbService oracleDbService)
        {
            _oracleDbService = oracleDbService;
        }

        [HttpPost]
        public async Task<IActionResult> RefreshStatus([FromBody] RefreshRequest request)
        {
            try
            {
                // 检查输入参数
                if (string.IsNullOrEmpty(request.LineNo))
                {
                    return BadRequest(new { message = "LineNo is required." });
                }

                // 定义存储过程调用的 SQL
                string procedureCall = @"
            BEGIN 
                RefreshStatus(
                    :p_lineNo, 
                    :p_orderNo, 
                    :p_sj, 
                    :p_xj, 
                    :p_checkedInspection, 
                    :p_checkedMaintenance
                ); 
            END;";

                // 定义输出参数
                var sjParam = new OracleParameter("p_sj", OracleDbType.Int32, ParameterDirection.Output);
                var xjParam = new OracleParameter("p_xj", OracleDbType.Int32, ParameterDirection.Output);
                var checkedInspectionParam = new OracleParameter("p_checkedInspection", OracleDbType.Int32, ParameterDirection.Output);
                var checkedMaintenanceParam = new OracleParameter("p_checkedMaintenance", OracleDbType.Int32, ParameterDirection.Output);

                // 参数列表
                var parameters = new List<OracleParameter>
        {
            new OracleParameter("p_lineNo", request.LineNo),
            new OracleParameter("p_orderNo", string.IsNullOrEmpty(request.OrderNo) ? DBNull.Value : request.OrderNo),
            sjParam,
            xjParam,
            checkedInspectionParam,
            checkedMaintenanceParam
        };

                // 调用存储过程
                await _oracleDbService.ExecuteProcedureAsync(procedureCall, parameters);

                // 安全检查和转换输出参数
                int safeConvert(object value, int defaultValue = 0)
                {
                    if (value == DBNull.Value)
                        return defaultValue;

                    if (value is Oracle.ManagedDataAccess.Types.OracleDecimal oracleDecimal)
                        return Convert.ToInt32(oracleDecimal.Value);

                    return Convert.ToInt32(value);
                }

                var result = new
                {
                    CheckFirstPass = safeConvert(sjParam.Value, 3),        // 默认未做
                    CheckXJ = safeConvert(xjParam.Value, 3),              // 默认未做
                    CheckedInspection = safeConvert(checkedInspectionParam.Value, 0), // 默认未点检
                    CheckedMaintenance = safeConvert(checkedMaintenanceParam.Value, 0) // 默认未保养
                };

                return Ok(result);
            }
            catch (Exception ex)
            {
                return StatusCode(500, new { message = "An error occurred during refreshing status.", error = ex.Message });
            }
        }


    }

    // 请求参数类
    public class RefreshRequest
    {
        public string LineNo { get; set; } // 产线编号
        public string OrderNo { get; set; } // 工单编号（可选）
    }
}