using System.Dynamic;
using Microsoft.AspNetCore.Mvc;
using NewPdaSqlServer.Dto.service;
using NewPdaSqlServer.entity;
using NewPdaSqlServer.service.QC;
using NewPdaSqlServer.util;
using Newtonsoft.Json.Linq;

namespace NewPdaSqlServer.Controllers.QC;

[Route("api/[controller]")]
[ApiController]
public class IpqcController : ControllerBase
{
    IpqcService m = new IpqcService();

    /// <summary>
    /// 首检单据查询
    /// </summary>
    /// <param name="queryObj"></param>
    /// <returns></returns>
    [HttpPost("getPageSj")]
    public ResponseResult getPageSj([FromBody] XJPageResult queryObj)
    {
        try
        {
            dynamic resultInfos = new ExpandoObject();
            var (item, totalCount) = m.getPageSj(queryObj);
            var tbBillList =
                resultInfos.tbBillList = item;
            return new ResponseResult
            {
                status = 0,
                message = "OK",
                data = resultInfos,
                TotalCount = totalCount
            };
        }
        catch (Exception ex)
        {
            return ResponseResult.ResponseError(ex);
        }
    }

    //getItems
    [HttpPost("getJYItem")]
    public ResponseResult getJYItem([FromBody] JObject data)
    {
        var id = data["id"]?.ToString();
        var releaseNo = data["releaseNo"]?.ToString();
        try
        {
            dynamic resultInfos = new ExpandoObject();
            var tbBillList =
                m.GetItems(releaseNo,
                    id);
            resultInfos.tbBillList = tbBillList;
            return new ResponseResult
            {
                status = 0,
                message = "OK",
                data = resultInfos
            };
        }
        catch (Exception ex)
        {
            return ResponseResult.ResponseError(ex);
        }
    }


    /// <summary>
    /// 首检单据查询
    /// </summary>
    /// <param name="queryObj"></param>
    /// <returns></returns>
    [HttpPost("getPageXj")]
    public ResponseResult getPageXj([FromBody] XJPageResult queryObj)
    {
        try
        {
            dynamic resultInfos = new ExpandoObject();
            var (item, totalCount) = m.getPageXj(queryObj);
            var tbBillList =
                resultInfos.tbBillList = item;
            return new ResponseResult
            {
                status = 0,
                message = "OK",
                data = resultInfos,
                TotalCount = totalCount
            };
        }
        catch (Exception ex)
        {
            return ResponseResult.ResponseError(ex);
        }
    }

    //更新检验项目认证信息 
    [HttpPost("updateIpqcRzxx")]
    public ResponseResult updateIpqcRzxx(dynamic ipqcDto)
    {
        try
        {
            dynamic resultInfos = new ExpandoObject();
            var tbBillList = m.updateIpqcRzxx(ipqcDto);
            resultInfos.tbBillList = tbBillList;
            return new ResponseResult
            {
                status = 0,
                message = "OK",
                data = resultInfos
            };
        }
        catch (Exception ex)
        {
            return ResponseResult.ResponseError(ex);
        }
    }
    /// <summary>
    /// 首检单据查询
    /// </summary>
    [HttpPost("createByWomdaa")]
    public ResponseResult CreateByWomdaa(dynamic query)
    {
        try
        {
            dynamic resultInfos = new ExpandoObject();
            resultInfos.tbBillList = m.CreateByWomdaa(query);
            return new ResponseResult
            {
                status = 0,
                message = "OK",
                data = resultInfos
            };
        }
        catch (Exception ex)
        {
            return ResponseResult.ResponseError(ex);
        }
    }
    /// <summary>
    /// 获取表格配置
    /// </summary>
    [HttpPost("GetTableConfig")]
    public ResponseResult GetTableConfig([FromBody] dynamic query)
    {
        try
        {
            if (query.mxguid == null)
                throw new ArgumentException("明细记录GUID不能为空");

            var configData = m.GetTableConfig(query.mxguid?.ToString());
            
            if (configData == null)
                throw new Exception("未找到相关配置信息");

            dynamic resultInfos = new ExpandoObject();
            resultInfos.selectedWater = configData.ipqc_zrxn_sel1;
            resultInfos.selectedFlow = configData.ipqc_zrxn_sel2;
            resultInfos.tableData = configData.ipqc_zrxn_table;

            return new ResponseResult
            {
                status = 0,
                message = "OK",
                data = resultInfos
            };
        }
        catch (Exception ex)
        {
            return ResponseResult.ResponseError(ex);
        }
    }
    /// <summary>
    /// 保存表格配置
    /// </summary>
    [HttpPost("SaveTableConfig")]
    public ResponseResult SaveTableConfig([FromBody] dynamic query)
    {
        try
        {
            // 参数校验
            if (query.mxguid == null)
                throw new ArgumentException("明细记录GUID不能为空");
            if (query.selectedWater == null || query.selectedFlow == null)
                throw new ArgumentException("检测项目配置不能为空");

            // 执行SQL更新
            var affectedRows = m.UpdateTableConfig(
                query.selectedWater?.ToString(),
                query.selectedFlow?.ToString(),
                Newtonsoft.Json.JsonConvert.SerializeObject(query.tableData),
                query.mxguid?.ToString()
            );

            return new ResponseResult
            {
                status = affectedRows > 0 ? 0 : 1,
                message = affectedRows > 0 ? "配置保存成功" : "无数据更新",
                data = new { updated = affectedRows }
            };
        }
        catch (Exception ex)
        {
            return ResponseResult.ResponseError(ex);
        }
    }
    /// <summary>
    /// 获取认证信息列表
    /// </summary>
    [HttpPost("GetRzxxList")]
    public ResponseResult GetRzxxList([FromBody] dynamic query)
    {
        try
        {
            if (query.mxguid == null)
                throw new ArgumentException("检验项目GUID不能为空");

            var rzxxList = m.GetRzxxList(query.mxguid?.ToString());
            
            dynamic resultInfos = new ExpandoObject();
            resultInfos.tbBillList = rzxxList;

            return new ResponseResult
            {
                status = 0,
                message = "OK",
                data = resultInfos
            };
        }
        catch (Exception ex)
        {
            return ResponseResult.ResponseError(ex);
        }
    }
    /// <summary>
    /// 更新认证信息_生产日期
    /// </summary>
    [HttpPost("updateScDate")]
    public ResponseResult UpdateScDate([FromBody] dynamic query)
    {
        try
        {
            if (query.mxguid == null)
                throw new ArgumentException("检验项目GUID不能为空");
            if (query.scDateValue == null)
                throw new ArgumentException("日期参数不能为空");

            var affectedRows = m.UpdateScDate(
                query.scDateValue?.ToString(),
                query.mxguid?.ToString()
            );

            return new ResponseResult
            {
                status = affectedRows > 0 ? 0 : 1,
                message = affectedRows > 0 ? "日期更新成功" : "无数据更新",
                data = new { updated = affectedRows }
            };
        }
        catch (Exception ex)
        {
            return ResponseResult.ResponseError(ex);
        }
    }

    /// <summary>
    /// 保存认证信息相关使用数量
    /// </summary>
    [HttpPost("saveIpqcrzxxNum")]
    public ResponseResult SaveIpqcrzxxNum([FromBody] dynamic query)
    {
        try
        {
            if (query.guid == null || query.ipqcrzxxNum == null)
                throw new ArgumentException("参数不能为空");

            var affectedRows = m.UpdateRzxxNum(
                query.ipqcrzxxNum?.ToString(),
                query.guid?.ToString()
            );

            return new ResponseResult
            {
                status = affectedRows > 0 ? 0 : 1,
                message = affectedRows > 0 ? "数量更新成功" : "无数据更新",
                data = new { updated = affectedRows }
            };
        }
        catch (Exception ex)
        {
            return ResponseResult.ResponseError(ex);
        }
    }
    /// <summary>
    /// 保存品水测试是否有异味
    /// </summary>
    [HttpPost("saveIpqCpscs")]
    public ResponseResult SaveIpqCpscs([FromBody] dynamic query)
    {
        try
        {
            if (query.guid == null || query.ipqCpscs == null)
                throw new ArgumentException("参数不能为空");

            var affectedRows = m.UpdateCpscs(
                query.ipqCpscs?.ToString(),
                query.guid?.ToString()
            );

            return new ResponseResult
            {
                status = affectedRows > 0 ? 0 : 1,
                message = affectedRows > 0 ? "是否有无异味更新成功" : "无数据更新",
                data = new { updated = affectedRows }
            };
        }
        catch (Exception ex)
        {
            return ResponseResult.ResponseError(ex);
        }
    }


    /// <summary>
    /// 现场收料获取可选工单信息
    /// </summary>
    /// <param name="query"></param>
    /// <returns></returns>
    [HttpPost("GetIpqcXjDaa")]
    public ResponseResult GetIpqcXjDaa([FromBody] dynamic query)
    {
        try
        {
            dynamic resultInfos = new ExpandoObject();
            resultInfos.tbBillList = m.GetIpqcXjDaa(query);
            return new ResponseResult
            {
                status = 0,
                message = "OK",
                data = resultInfos
            };
        }
        catch (Exception ex)
        {
            return ResponseResult.ResponseError(ex);
        }
    }

}