// Controllers/LinesController.cs
using Microsoft.AspNetCore.Mvc;
using System.Collections.Generic;
using System.Threading.Tasks;
using gdbg.Models; // 引用模型命名空间
using gdbg.Services;
using Oracle.ManagedDataAccess.Client; // 引用服务命名空间

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

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

        [HttpGet]
        public async Task<ActionResult<IEnumerable<Line>>> GetLines()
        {
            // 定义获取线体数据的 SQL 查询
            var query = "SELECT LINE_NO, LINE_NAME FROM MES_LINE where DEPARTMENTCODE='BM000010' order by LINE_NO";

            // 使用封装的 GetAsync 方法获取线体数据
            var lines = await _oracleDbService.GetAsync(query, reader => new Line
            {
                LineNo = reader.GetString(0),
                LineName = reader.GetString(1)
            });

            return Ok(lines); // 返回结果
        }

        [HttpGet("{lineCode}")]
        public async Task<ActionResult<Line>> GetLineByCode(string lineCode)
        {
            var query = "SELECT LINE_NO, LINE_NAME FROM MES_LINE WHERE LINE_NO = :LineNo and DEPARTMENTCODE='BM000010' order by LINE_NO";

            // 使用 OracleParameter 来传递参数
            var parameters = new List<OracleParameter>
    {
        new OracleParameter(":LineNo", lineCode)
    };

            // 使用现有的 GetAsync 方法查询数据
            var lines = await _oracleDbService.GetAsync(query, reader => new Line
            {
                LineNo = reader.GetString(0),
                LineName = reader.GetString(1)
            }, parameters);

            // 确保只返回单条记录
            var line = lines.FirstOrDefault();

            if (line == null)
            {
                return NotFound(new { Message = "Line not found" });
            }

            return Ok(line);
        }

    }
}