using Microsoft.AspNetCore.Mvc;
using System;
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 PersonsController : ControllerBase
    {
        private readonly OracleDbService _oracleDbService;

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

        [HttpGet]
        public async Task<ActionResult<IEnumerable<Person>>> GetPersons()
        {
            var query = "select STAFF_NO,STAFF_NAME from MES_STAFF where DEPARTMENT_NAME=115066";
            var persons = await _oracleDbService.GetAsync(query, reader => new Person
            {
                PersonId = reader.GetString(0),
                PersonName = reader.GetString(1)
            });

            return Ok(persons);
        }

        [HttpGet("{personnelCode}")]
        public async Task<ActionResult<IEnumerable<Person>>> GetPersonnelByCode(string personnelCode)
        {
            var query = "select STAFF_NO,STAFF_NAME from MES_STAFF where STAFF_NO=:PersonnelCode";

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

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

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

            if (personnel == null)
            {
                return NotFound(new { Message = "Personnel not found" });
            }

            return Ok(personnel);
        }
    }
}