using System.Dynamic;
using MES.Service.Dto.service;
using MES.Service.Modes;
using MES.Service.service;
using MES.Service.service.QC;
using MES.Service.util;
using Microsoft.AspNetCore.Mvc;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;

namespace MESApplication.Controllers.QC;

/// <summary>
///     PCB检测数据控制器
/// </summary>
[Route("api/[controller]")]
[ApiController]
public class PcbTestDataController : ControllerBase
{
    private readonly MessageCenterManager _manager = new();
    private readonly PcbTestDataService _service = new();

    private readonly string METHOD = "POST";
    private readonly string TableName = "MES_PCB_TEST_DATA";
    private readonly string URL = "http://localhost:10054/api/PcbTestData/";

    /// <summary>
    ///     保存整板检测数据
    /// </summary>
    /// <param name="dto">整板检测数据DTO</param>
    /// <returns>保存结果</returns>
    [HttpPost("SaveWholeboardData")]
    public ResponseResult SaveWholeboardData(
        [FromBody] WholeboardGenerateDto dto)
    {
        var entity = new MessageCenter();
        entity.TableName = TableName;
        entity.Url = URL + "SaveWholeboardData";
        entity.Method = METHOD;
        entity.Data = JsonConvert.SerializeObject(dto);
        entity.Status = 1;
        entity.CreateBy = "PL017";

        try
        {
            dynamic resultInfos = new ExpandoObject();
            var result = _service.SaveWholeboardData(dto);
            resultInfos.result = result;
            resultInfos.message = result ? "整板检测数据保存成功" : "整板检测数据保存失败";

            entity.Result = result ? (short)1 : (short)0;
            entity.DealWith = 1;
            _manager.save(entity);

            return new ResponseResult
            {
                status = result ? 0 : 1,
                message = result ? "OK" : "FAIL",
                data = resultInfos
            };
        }
        catch (Exception ex)
        {
            entity.Result = 0;
            entity.DealWith = 0;
            entity.ResultData = ex.Message;
            _manager.save(entity);

            return ResponseResult.ResponseError(ex);
        }
    }

    /// <summary>
    ///     保存单板检测数据
    /// </summary>
    /// <param name="dto">单板检测数据DTO</param>
    /// <returns>保存结果</returns>
    [HttpPost("SaveSingleBoardData")]
    public ResponseResult SaveSingleBoardData(
        [FromBody] SingleBoardGenerateDto dto)
    {
        var entity = new MessageCenter();
        entity.TableName = TableName;
        entity.Url = URL + "SaveSingleBoardData";
        entity.Method = METHOD;
        entity.Data = JsonConvert.SerializeObject(dto);
        entity.Status = 1;
        entity.CreateBy = "PL017";

        try
        {
            dynamic resultInfos = new ExpandoObject();
            var result = _service.SaveSingleBoardData(dto);
            resultInfos.result = result;
            resultInfos.message = result ? "单板检测数据保存成功" : "单板检测数据保存失败";

            entity.Result = result ? (short)1 : (short)0;
            entity.DealWith = 1;
            _manager.save(entity);

            return new ResponseResult
            {
                status = result ? 0 : 1,
                message = result ? "OK" : "FAIL",
                data = resultInfos
            };
        }
        catch (Exception ex)
        {
            entity.Result = 0;
            entity.DealWith = 0;
            entity.ResultData = ex.Message;
            _manager.save(entity);

            return ResponseResult.ResponseError(ex);
        }
    }

    /// <summary>
    ///     分页查询PCB检测数据
    /// </summary>
    /// <param name="request">查询请求</param>
    /// <returns>分页数据</returns>
    [HttpPost("GetPage")]
    public ResponseResult GetPage([FromBody] JObject request)
    {
        try
        {
            var dataType = request["dataType"]?.ToString();
            var deviceName = request["deviceName"]?.ToString();
            var pcbSn = request["pcbSn"]?.ToString();
            var startTime = request["startTime"]?.ToString();
            var endTime = request["endTime"]?.ToString();
            var pageIndex = request["pageIndex"]?.ToObject<int>() ?? 1;
            var pageSize = request["pageSize"]?.ToObject<int>() ?? 20;

            DateTime? startDateTime = null;
            DateTime? endDateTime = null;

            if (StringUtil.IsNotNullOrEmpty(startTime) &&
                DateTime.TryParse(startTime, out var start))
                startDateTime = start;

            if (StringUtil.IsNotNullOrEmpty(endTime) &&
                DateTime.TryParse(endTime, out var end))
                endDateTime = end;

            var (items, totalCount) = _service.GetPcbTestDataPage(
                dataType, deviceName, pcbSn, startDateTime, endDateTime,
                pageIndex, pageSize);

            dynamic resultInfos = new ExpandoObject();
            resultInfos.items = items;

            return new ResponseResult
            {
                status = 0,
                message = "OK",
                data = resultInfos,
                TotalCount = totalCount
            };
        }
        catch (Exception ex)
        {
            return ResponseResult.ResponseError(ex);
        }
    }

    /// <summary>
    ///     根据ID获取PCB检测数据
    /// </summary>
    /// <param name="request">请求参数</param>
    /// <returns>PCB检测数据</returns>
    [HttpPost("GetById")]
    public ResponseResult GetById([FromBody] JObject request)
    {
        try
        {
            var id = request["id"]?.ToObject<decimal>();
            if (!id.HasValue)
                return new ResponseResult
                {
                    status = 1,
                    message = "ID不能为空",
                    data = null
                };

            var testData = _service.GetPcbTestDataById(id.Value);
            var componentData = _service.GetComponentDataByTestDataId(id.Value);

            dynamic resultInfos = new ExpandoObject();
            resultInfos.testData = testData;
            resultInfos.componentData = componentData;

            return new ResponseResult
            {
                status = 0,
                message = "OK",
                data = resultInfos
            };
        }
        catch (Exception ex)
        {
            return ResponseResult.ResponseError(ex);
        }
    }

    /// <summary>
    ///     根据PCB条码获取检测数据
    /// </summary>
    /// <param name="request">请求参数</param>
    /// <returns>检测数据列表</returns>
    [HttpPost("GetByPcbSn")]
    public ResponseResult GetByPcbSn([FromBody] JObject request)
    {
        try
        {
            var pcbSn = request["pcbSn"]?.ToString();
            if (StringUtil.IsNullOrEmpty(pcbSn))
                return new ResponseResult
                {
                    status = 1,
                    message = "PCB条码不能为空",
                    data = null
                };

            var testDataList = _service.GetPcbTestDataByPcbSn(pcbSn);

            dynamic resultInfos = new ExpandoObject();
            resultInfos.testDataList = testDataList;

            return new ResponseResult
            {
                status = 0,
                message = "OK",
                data = resultInfos
            };
        }
        catch (Exception ex)
        {
            return ResponseResult.ResponseError(ex);
        }
    }

    /// <summary>
    ///     获取器件检测数据
    /// </summary>
    /// <param name="request">请求参数</param>
    /// <returns>器件检测数据</returns>
    [HttpPost("GetComponentData")]
    public ResponseResult GetComponentData([FromBody] JObject request)
    {
        try
        {
            var testDataId = request["testDataId"]?.ToObject<decimal>();
            if (!testDataId.HasValue)
                return new ResponseResult
                {
                    status = 1,
                    message = "测试数据ID不能为空",
                    data = null
                };

            var componentData =
                _service.GetComponentDataByTestDataId(testDataId.Value);

            dynamic resultInfos = new ExpandoObject();
            resultInfos.componentData = componentData;

            return new ResponseResult
            {
                status = 0,
                message = "OK",
                data = resultInfos
            };
        }
        catch (Exception ex)
        {
            return ResponseResult.ResponseError(ex);
        }
    }

    /// <summary>
    ///     获取检测统计数据
    /// </summary>
    /// <param name="request">请求参数</param>
    /// <returns>统计数据</returns>
    [HttpPost("GetStatistics")]
    public ResponseResult GetStatistics([FromBody] JObject request)
    {
        try
        {
            var dataType = request["dataType"]?.ToString();
            var deviceName = request["deviceName"]?.ToString();
            var startTime = request["startTime"]?.ToString();
            var endTime = request["endTime"]?.ToString();

            DateTime? startDateTime = null;
            DateTime? endDateTime = null;

            if (StringUtil.IsNotNullOrEmpty(startTime) &&
                DateTime.TryParse(startTime, out var start))
                startDateTime = start;

            if (StringUtil.IsNotNullOrEmpty(endTime) &&
                DateTime.TryParse(endTime, out var end))
                endDateTime = end;

            var statistics = _service.GetTestStatistics(dataType, deviceName,
                startDateTime, endDateTime);

            dynamic resultInfos = new ExpandoObject();
            resultInfos.statistics = statistics;

            return new ResponseResult
            {
                status = 0,
                message = "OK",
                data = resultInfos
            };
        }
        catch (Exception ex)
        {
            return ResponseResult.ResponseError(ex);
        }
    }

    /// <summary>
    ///     删除PCB检测数据
    /// </summary>
    /// <param name="request">请求参数</param>
    /// <returns>删除结果</returns>
    [HttpPost("Delete")]
    public ResponseResult Delete([FromBody] JObject request)
    {
        var entity = new MessageCenter();
        entity.TableName = TableName;
        entity.Url = URL + "Delete";
        entity.Method = METHOD;
        entity.Data = JsonConvert.SerializeObject(request);
        entity.Status = 1;
        entity.CreateBy = "PL017";

        try
        {
            var id = request["id"]?.ToObject<decimal>();
            if (!id.HasValue)
            {
                entity.Result = 0;
                entity.DealWith = 0;
                entity.ResultData = "ID不能为空";
                _manager.save(entity);

                return new ResponseResult
                {
                    status = 1,
                    message = "ID不能为空",
                    data = null
                };
            }

            var result = _service.DeletePcbTestData(id.Value);

            dynamic resultInfos = new ExpandoObject();
            resultInfos.result = result;
            resultInfos.message = result ? "删除成功" : "删除失败";

            entity.Result = result ? (short)1 : (short)0;
            entity.DealWith = 1;
            _manager.save(entity);

            return new ResponseResult
            {
                status = result ? 0 : 1,
                message = result ? "OK" : "FAIL",
                data = resultInfos
            };
        }
        catch (Exception ex)
        {
            entity.Result = 0;
            entity.DealWith = 0;
            entity.ResultData = ex.Message;
            _manager.save(entity);

            return ResponseResult.ResponseError(ex);
        }
    }

    /// <summary>
    ///     统一保存接口（自动识别整板或单板数据）
    /// </summary>
    /// <param name="request">请求参数</param>
    /// <returns>保存结果</returns>
    [HttpPost("SaveTestData")]
    public ResponseResult SaveTestData([FromBody] JObject request)
    {
        var entity = new MessageCenter();
        entity.TableName = TableName;
        entity.Url = URL + "SaveTestData";
        entity.Method = METHOD;
        entity.Data = JsonConvert.SerializeObject(request);
        entity.Status = 1;
        entity.CreateBy = "PL017";

        try
        {
            var dataType = request["dataType"]?.ToString();

            if (StringUtil.IsNullOrEmpty(dataType))
            {
                entity.Result = 0;
                entity.DealWith = 0;
                entity.ResultData = "数据类型不能为空，请指定WHOLE或SINGLE";
                _manager.save(entity);

                return new ResponseResult
                {
                    status = 1,
                    message = "数据类型不能为空，请指定WHOLE或SINGLE",
                    data = null
                };
            }

            dynamic resultInfos = new ExpandoObject();
            var result = false;
            var message = "";

            switch (dataType.ToUpper())
            {
                case "WHOLE":
                    var wholeboardDto = request["data"]
                        ?.ToObject<WholeboardGenerateDto>();
                    if (wholeboardDto == null)
                    {
                        entity.Result = 0;
                        entity.DealWith = 0;
                        entity.ResultData = "整板数据不能为空";
                        _manager.save(entity);

                        return new ResponseResult
                        {
                            status = 1,
                            message = "整板数据不能为空",
                            data = null
                        };
                    }

                    result = _service.SaveWholeboardData(wholeboardDto);
                    message = result ? "整板检测数据保存成功" : "整板检测数据保存失败";
                    break;

                case "SINGLE":
                    var singleBoardDto = request["data"]
                        ?.ToObject<SingleBoardGenerateDto>();
                    if (singleBoardDto == null)
                    {
                        entity.Result = 0;
                        entity.DealWith = 0;
                        entity.ResultData = "单板数据不能为空";
                        _manager.save(entity);

                        return new ResponseResult
                        {
                            status = 1,
                            message = "单板数据不能为空",
                            data = null
                        };
                    }

                    result = _service.SaveSingleBoardData(singleBoardDto);
                    message = result ? "单板检测数据保存成功" : "单板检测数据保存失败";
                    break;

                default:
                    entity.Result = 0;
                    entity.DealWith = 0;
                    entity.ResultData = "不支持的数据类型，请指定WHOLE或SINGLE";
                    _manager.save(entity);

                    return new ResponseResult
                    {
                        status = 1,
                        message = "不支持的数据类型，请指定WHOLE或SINGLE",
                        data = null
                    };
            }

            resultInfos.result = result;
            resultInfos.message = message;

            entity.Result = result ? (short)1 : (short)0;
            entity.DealWith = 1;
            _manager.save(entity);

            return new ResponseResult
            {
                status = result ? 0 : 1,
                message = result ? "OK" : "FAIL",
                data = resultInfos
            };
        }
        catch (Exception ex)
        {
            entity.Result = 0;
            entity.DealWith = 0;
            entity.ResultData = ex.Message;
            _manager.save(entity);

            return ResponseResult.ResponseError(ex);
        }
    }
}