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

namespace MESApplication.Controllers.BasicData;

[ApiController]
[Route("api/[controller]")]
public class MesCgthSqController : ControllerBase
{
    private readonly MessageCenterManager _messageCenterManager = new();
    private readonly MesCgthSqManager _mesCgthSqManager = new();

    private readonly string _method = "POST";
    private readonly string _tableName = "MES_CGTH_SQ";
    private readonly string _baseUrl = "http://localhost:10054/api/MesCgthSq/";

    /// <summary>
    /// 保存采购退货申请单
    /// </summary>
    [HttpPost("Save")]
    public ResponseResult Save(ErpCgth erpCgth)
    {
// 初始化消息中心实体（用于记录接口调用日志）
        var messageEntity = new MessageCenter
        {
            TableName = _tableName,
            Url = _baseUrl + "Save",
            Method = _method,
            Data = JsonConvert.SerializeObject(erpCgth),
            Status = 1, // 状态：1 - 待处理
            CreateBy = "SYSTEM", // 创建人标识
            Route = erpCgth.ErpCgtha.billNo // 路由标识（使用单据编号）
        };

        try
        {
            dynamic resultData = new ExpandoObject();
// 调用业务层保存方法（将 ERP 传入的 DTO 转换为实体并保存）
            var saveSuccess = _mesCgthSqManager.Save(erpCgth);
            resultData.saveResult = saveSuccess;

// 更新消息中心状态（保存成功）
            messageEntity.Result = 1; // 结果：1 - 成功
            messageEntity.DealWith = 1; // 处理状态：1 - 已处理
            _messageCenterManager.save(messageEntity);

            return new ResponseResult
            {
                status = 0,
                message = "保存成功",
                data = resultData
            };
        }
        catch (Exception ex)
        {
// 异常处理：记录错误信息
            messageEntity.Result = 0; // 结果：0 - 失败
            messageEntity.DealWith = 0; // 处理状态：0 - 未处理
            messageEntity.ResultData = ex.Message; // 错误详情
            _messageCenterManager.save(messageEntity);

            return ResponseResult.ResponseError(ex);
        }
    }

    /// <summary>
    /// 批量保存采购退货申请单
    /// </summary>
    [HttpPost("SaveList")]
    public ResponseResult SaveList(List<ErpCgth> erpCgthaList)
    {
        var messageEntity = new MessageCenter
        {
            TableName = _tableName,
            Url = _baseUrl + "SaveList",
            Method = _method,
            Data = JsonConvert.SerializeObject(erpCgthaList),
            Status = 1,
            CreateBy = "SYSTEM"
        };

        try
        {
            dynamic resultData = new ExpandoObject();
            var saveSuccess = _mesCgthSqManager.SaveList(erpCgthaList);
            resultData.totalCount = erpCgthaList.Count;
            resultData.successCount = saveSuccess ? erpCgthaList.Count : 0;

            messageEntity.Result = saveSuccess ? 1 : 0;
            messageEntity.DealWith = 1;
            _messageCenterManager.save(messageEntity);

            return new ResponseResult
            {
                status = 0,
                message = $"批量保存完成，共 {erpCgthaList.Count} 条数据",
                data = resultData
            };
        }
        catch (Exception ex)
        {
            messageEntity.Result = 0;
            messageEntity.DealWith = 0;
            messageEntity.ResultData = ex.Message;
            _messageCenterManager.save(messageEntity);

            return ResponseResult.ResponseError(ex);
        }
    }

    /// <summary>
    /// 获取采购退货申请单列表
    /// </summary>
    [HttpGet("GetList")]
    public ResponseResult GetList()
    {
        try
        {
            var cgthList = _mesCgthSqManager.GetList();
            return new ResponseResult
            {
                status = 0,
                message = "查询成功",
                data = new { total = cgthList.Count, list = cgthList }
            };
        }
        catch (Exception ex)
        {
            return ResponseResult.ResponseError(ex);
        }
    }

    /// <summary>
    /// 根据 ID 获取采购退货申请单详情
    /// </summary>
    [HttpGet("GetById")]
    public ResponseResult GetById(string id)
    {
        try
        {
            var cgthEntity = _mesCgthSqManager.GetById(Guid.Parse(id));
            return new ResponseResult
            {
                status = 0,
                message = "查询成功",
                data = cgthEntity
            };
        }
        catch (Exception ex)
        {
            return ResponseResult.ResponseError(ex);
        }
    }


    /// <summary>
    /// 新增采购退货申请单（直接传入实体）
    /// </summary>
    [HttpPost("Insert")]
    public ResponseResult Insert([FromBody] MesCgthSq entity)
    {
        try
        {
// 自动生成主键 ID
            entity.Id = Guid.NewGuid();
            entity.CreateDate = DateTime.Now;
            var insertSuccess = _mesCgthSqManager.Insert(entity);

            return new ResponseResult
            {
                status = 0,
                message = insertSuccess ? "新增成功" : "新增失败",
                data = new { id = entity.Id }
            };
        }
        catch (Exception ex)
        {
            return ResponseResult.ResponseError(ex);
        }
    }

    /// <summary>
    /// 更新采购退货申请单
    /// </summary>
    [HttpPost("Update")]
    public ResponseResult Update([FromBody] MesCgthSq entity)
    {
        try
        {
            entity.LastUpdateTime = DateTime.Now;
            var updateSuccess = _mesCgthSqManager.Update(entity);

            return new ResponseResult
            {
                status = 0,
                message = updateSuccess ? "更新成功" : "更新失败",
                data = updateSuccess
            };
        }
        catch (Exception ex)
        {
            return ResponseResult.ResponseError(ex);
        }
    }

}