using System.Text;
using System.Web;
using MES.Service.Dto.service;
using MES.Service.Modes;
using MES.Service.service.Warehouse;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;

namespace MES.Service.service;

public class GetErpParametersServer
{
    private readonly MesInvItemInCDetailsManager _invItemInCDetailsServer =
        new();

    private readonly MesInvItemOutsManager _invItemOutsServer =
        new();

    private readonly MessageCenterManager _messageCenterServer = new();

    private List<MessageCenter> GetErpParameters(List<MessageCenter> data)
    {
        var centers = new List<MessageCenter>();

        //获取主请求
        var center = data.Find(p => p.Seq == 1);

        //解析URL
        var queryString =
            center.PageName.Substring(center.PageName.IndexOf('?') + 1);
        //提取参数
        var queryParameters = HttpUtility.ParseQueryString(queryString);

        var strings = center.TableName.Split("_");

        var centerUpdateBy = center.UpdateBy;
        var centerUpdateDate = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");

        MessageCenter mesToErp = null;
        var query = new WarehouseQuery();
        switch (center.TableName)
        {
            //采购入库单审核
            case "MES_INV_ITEM_INS_A":
            //采购入库单反审核
            case "MES_INV_ITEM_INS_B":

                //获取到类型（审核还是反审核）
                query.Type = strings[^1];
                //获取url中附带的参数
                query.id = Convert.ToDecimal(queryParameters["id"]);
                query.billNo = queryParameters["billNo"];
                query.userName = centerUpdateBy;
                //重新获取请求的数据
                mesToErp = _invItemInCDetailsServer.MesToErpParam(query);
                //赋值主id
                mesToErp.Id = center.Id;
                mesToErp.UpdateBy = centerUpdateBy;
                mesToErp.UpdateDate = centerUpdateDate;
                centers.Add(mesToErp);

                //更新剩下的请求的参数
                var messageCenter = data[0];
                var json = new JObject
                {
                    new JProperty("id", query.id),
                    new JProperty("billNo", query.billNo),
                    new JProperty("userName", query.userName)
                };
                messageCenter.Data = json.ToString();
                messageCenter.UpdateBy = centerUpdateBy;
                messageCenter.UpdateDate = centerUpdateDate;
                centers.Add(messageCenter);

                break;

            //采购退料单审核
            case "MES_INV_ITEM_OUTS_A":
            //采购退料单反审核
            case "MES_INV_ITEM_OUTS_B":

                //获取到类型（审核还是反审核）
                query.Type = strings[^1];
                query.id = Convert.ToDecimal(queryParameters["id"]);
                query.billNo = queryParameters["itemOutNo"];
                query.userName = centerUpdateBy;

                //重新获取请求的数据
                mesToErp = _invItemOutsServer.MesToErpParam(query);
                //更正为主id
                mesToErp.Id = center.Id;
                mesToErp.UpdateBy = centerUpdateBy;
                mesToErp.UpdateDate = centerUpdateDate;
                //添加到请求集合中
                centers.Add(mesToErp);

                //获取剩余的请求
                PostRequest(data, query, centers, centerUpdateDate);
                break;
            //生产领料单
            case "INV_ITEM_OUTS_A":
                //获取到类型（审核还是反审核）
                query.Type = strings[^1];
                query.id = Convert.ToDecimal(queryParameters["id"]);
                query.billNo = queryParameters["itemOutNo"];
                query.userName = centerUpdateBy;

                //重新获取请求的数据
                mesToErp = _invItemOutsServer.ProductionMesToErpParam(query);
                //更正为主id
                mesToErp.Id = center.Id;
                mesToErp.UpdateBy = centerUpdateBy;
                mesToErp.UpdateDate = centerUpdateDate;
                //添加到请求集合中
                centers.Add(mesToErp);

                //获取剩余的请求
                PostRequest(data, query, centers, centerUpdateDate);
                break;
            default:
                throw new Exception("无法识别TableName类型");
        }

        //根据顺序返回
        return centers.OrderBy(p => p.Seq).ToList();
    }

    private void PostRequest(List<MessageCenter> data, WarehouseQuery query,
        List<MessageCenter> centers, string centerUpdateDate)
    {
        var find = data.FindAll(s => s.Seq != 1);

        var result = new JObject
        {
            new JProperty("id", query.id),
            new JProperty("billNo", query.billNo),
            new JProperty("userName", query.userName)
        };
        find.ForEach(s =>
        {
            s.Data = result.ToString();
            s.UpdateBy = query.userName;
            s.UpdateDate = centerUpdateDate;
            centers.Add(s);
        });
    }


    public string Resend(MessageCenter data)
    {
        //获取所有的回调
        var messageCenters =
            _messageCenterServer.GetList(it => it.Pid == data.Id);
        messageCenters.Add(data);
        var erpParameters = GetErpParameters(messageCenters);

        return sendHttp(erpParameters).Result;
    }


    private async Task<string> sendHttp(List<MessageCenter> requestList)
    {
        var sortedRequests = requestList.OrderBy(r => r.Seq).ToList();

        using var httpClient = new HttpClient();

        var responses = "";

        foreach (var request in sortedRequests)
        {
            var httpRequestMessage = new HttpRequestMessage
            {
                Method = new HttpMethod(request.Method),
                RequestUri = new Uri(request.Url),
                Content = new StringContent(request.Data, Encoding.UTF8,
                    request.ContentType)
            };

            var response =
                await httpClient.SendAsync(httpRequestMessage);
            var responseData = await response.Content.ReadAsStringAsync();

            var result = JsonConvert.DeserializeObject<Result>(responseData);

            responses += result.msg + "!!!";
            responses += result.message + "!!!";

            if ("500".Equals(result.state))
            {
                responses = "返回报错：" + responses;
                return responses;
            }

            if ("1".Equals(result.status))
            {
                responses = "返回报错：" + responses;
                return responses;
            }

            request.Result = 1;
            request.ResultData = result.msg;
            request.Status = 1;
            request.DealWith = 1;

            _messageCenterServer.ResetUpdate(request);
        }

        responses = "重推成功：" + responses;
        return responses;
    }
}

public class Result
{
    public string? state { get; set; }
    public string? msg { get; set; }

    public string? status { get; set; }

    public string? message { get; set; }
}