using System.Collections.Generic;
using System.Dynamic;
using System.Linq;
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>
///     SPI/AOI检测数据控制器
/// </summary>
[Route("api/[controller]")]
[ApiController]
public class SpiAoiController : ControllerBase
{
    private readonly MessageCenterManager _manager = new();
    private readonly SpiAoiService _service = new();

    private const string METHOD = "POST";
    private const string HeaderTableName = "MES_SPI_AOI_HEADER";
    private const string DetailTableName = "MES_SPI_AOI_DETAIL";
    private const string BaseUrl = "http://localhost:10054/api/QC/SpiAoi/";

    /// <summary>
    ///     Upload AOI header data.
    /// </summary>
    /// <param name="header">AOI header payload.</param>
    /// <returns>Upload result.</returns>
    [HttpPost("UploadAoiHeader")]
    public ResponseResult UploadAoiHeader(
        [FromBody] SpiAoiHeaderDto header)
    {
        var entity = new MessageCenter
        {
            TableName = HeaderTableName,
            Url = BaseUrl + "UploadAoiHeader",
            Method = METHOD,
            Data = JsonConvert.SerializeObject(header),
            Status = 1,
            CreateBy = "SPI_AOI_SYSTEM"
        };

        try
        {
            var response = _service.UploadAoiHeader(header);

            dynamic resultInfos = new ExpandoObject();
            resultInfos.headerId = response.HeaderId;
            resultInfos.message = "AOI header upload succeeded";

            entity.Result = 1;
            entity.DealWith = 1;
            entity.ResultData = JsonConvert.SerializeObject(response);
            _manager.save(entity);

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

            return ResponseResult.ResponseError(ex);
        }
    }

    /// <summary>
    ///     Batch upload AOI header data.
    /// </summary>
    /// <param name="headers">AOI header payload collection.</param>
    /// <returns>Upload result.</returns>
    [HttpPost("UploadAoiHeaderBatch")]
    public ResponseResult UploadAoiHeaderBatch(
        [FromBody] List<SpiAoiHeaderDto> headers)
    {
        var entity = new MessageCenter
        {
            TableName = HeaderTableName,
            Url = BaseUrl + "UploadAoiHeaderBatch",
            Method = METHOD,
            Data = JsonConvert.SerializeObject(headers),
            Status = 1,
            CreateBy = "SPI_AOI_SYSTEM"
        };

        try
        {
            var responses = _service.UploadAoiHeaderBatch(headers);
            dynamic resultInfos = new ExpandoObject();
            resultInfos.headerIds = responses.Select(r => r.HeaderId).ToList();
            resultInfos.message = "AOI header batch upload succeeded";

            entity.Result = 1;
            entity.DealWith = 1;
            entity.ResultData = JsonConvert.SerializeObject(responses);
            _manager.save(entity);

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

            return ResponseResult.ResponseError(ex);
        }
    }

    /// <summary>
    ///     Upload SPI detail data.
    /// </summary>
    /// <param name="request">SPI detail payload.</param>
    /// <returns>Upload result.</returns>
    [HttpPost("UploadSpiDetails")]
    public ResponseResult UploadSpiDetails(
        [FromBody] SpiAoiDetailDto request)
    {
        var entity = new MessageCenter
        {
            TableName = DetailTableName,
            Url = BaseUrl + "UploadSpiDetails",
            Method = METHOD,
            Data = JsonConvert.SerializeObject(request),
            Status = 1,
            CreateBy = "SPI_AOI_SYSTEM"
        };

        try
        {
            var response = _service.UploadSpiDetails(request);

            dynamic resultInfos = new ExpandoObject();
            resultInfos.detailCount = response.DetailCount;
            resultInfos.message = "SPI detail upload succeeded";

            entity.Result = 1;
            entity.DealWith = 1;
            entity.ResultData = JsonConvert.SerializeObject(response);
            _manager.save(entity);

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

            return ResponseResult.ResponseError(ex);
        }
    }

    /// <summary>
    ///     Batch upload SPI detail data.
    /// </summary>
    /// <param name="requests">SPI detail payload collection.</param>
    /// <returns>Upload result.</returns>
    [HttpPost("UploadSpiDetailsBatch")]
    public ResponseResult UploadSpiDetailsBatch(
        [FromBody] List<SpiAoiDetailDto> requests)
    {
        var entity = new MessageCenter
        {
            TableName = DetailTableName,
            Url = BaseUrl + "UploadSpiDetailsBatch",
            Method = METHOD,
            Data = JsonConvert.SerializeObject(requests),
            Status = 1,
            CreateBy = "SPI_AOI_SYSTEM"
        };

        try
        {
            var response = _service.UploadSpiDetailsBatch(requests);

            dynamic resultInfos = new ExpandoObject();
            resultInfos.detailCount = response.DetailCount;
            resultInfos.message = "SPI detail batch upload succeeded";

            entity.Result = 1;
            entity.DealWith = 1;
            entity.ResultData = JsonConvert.SerializeObject(response);
            _manager.save(entity);

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

            return ResponseResult.ResponseError(ex);
        }
    }

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

            var (header, details) = _service.GetByBarcode(boardBarcode);

            if (header == null)
            {
                return new ResponseResult
                {
                    status = 1,
                    message = $"未找到条码 {boardBarcode} 的检测数据",
                    data = null
                };
            }

            dynamic resultInfos = new ExpandoObject();
            resultInfos.header = header;
            resultInfos.details = details;

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

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

            var (header, details) = _service.GetById(headerId.Value);

            if (header == null)
            {
                return new ResponseResult
                {
                    status = 1,
                    message = $"未找到ID {headerId} 的检测数据",
                    data = null
                };
            }

            dynamic resultInfos = new ExpandoObject();
            resultInfos.header = header;
            resultInfos.details = details;

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

    /// <summary>
    ///     分页查询SPI/AOI检测数据
    /// </summary>
    /// <param name="request">查询请求</param>
    /// <returns>分页数据</returns>
    [HttpPost("GetPage")]
    public ResponseResult GetPage([FromBody] JObject request)
    {
        try
        {
            var boardBarcode = request["boardBarcode"]?.ToString();
            var workOrder = request["workOrder"]?.ToString();
            var surface = request["surface"]?.ToString();
            var startDate = request["startDate"]?.ToString();
            var endDate = request["endDate"]?.ToString();
            var pageIndex = request["pageIndex"]?.ToObject<int>() ?? 1;
            var pageSize = request["pageSize"]?.ToObject<int>() ?? 20;

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

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

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

            var (items, totalCount) = _service.GetPage(
                boardBarcode, workOrder, surface, 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);
        }
    }
}