using Apache.NMS.ActiveMQ.Commands;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;

using Rhea.Common;
using System;
using System.Collections.Generic;
using System.ComponentModel.Design;
using System.Drawing.Drawing2D;
using System.Linq;
using System.Security.Policy;
using System.Text;
using System.Threading.Tasks;
using Tiger.IBusiness;
using Tiger.Model;
using Tiger.Model.Minsun;

namespace Tiger.Business.WMS
{
    public partial class ErpT100 : IErpT100
    {
        /// <summary>
        /// T100接口URL
        /// </summary>
        public static string t100Url { get; set; } = @"http://172.18.8.11/wstopprd/ws/r/awsp920";

        public static List<string> curDeliveryNoList { get; set; } = new List<string>();

        /// <summary>
        /// 从T100获取二级供应商接口
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        public static T100ActionResult<resultStd_data<Parameter3>> GetSecondarySupplyInfo(SupplierInputParameter input)
        {
            var t100Action = new T100Action<actionStd_data<SupplierParameter>>
            {
                key = Guid.NewGuid().ToString("N"),
                type = "sync",
                host = new host
                {
                    prod = "WMS",
                    ip = "",
                    lang = "zh_CN",
                    acct = "tiptop",
                    timestamp = DateTime.Now.ToString("yyyyMMddHHMMssfff"),
                },
                datakey = input.datakey,
                //datakey = new Datakey
                //{
                //    EntId = "88",
                //    CompanyId = "XCSJ" //据点 DGXC
                //},
                service = new Service
                {
                    ip = "",
                    prod = "T100",
                    id = "topprd",
                    name = "wms_ge_pmaauc"
                },
                payload = new PayloadData<actionStd_data<SupplierParameter>>
                {
                    std_data = new actionStd_data<SupplierParameter>
                    {
                        parameter = input.parameter
                    }
                }
            };
            var requestJson = JsonConvert.SerializeObject(t100Action);
            var response = HttpHelper.PostAsync(t100Url, requestJson).Result;
            var result = JsonConvert.DeserializeObject<T100ActionResult<resultStd_data<Parameter3>>>(response.Message);
            Logger.Interface.Info($"T100获取二级供应商提交Json: {requestJson}，返回Json: {response.Message}");

            return result;
        }

        /// <summary>
        /// 生成客供料到货单
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        public static T100ActionResult<resultStd_data<Parameter>> GenerateCustReceipt(CustReceiptInputParameter input)
        {
            try
            {
                var t100Action = new T100Action<actionStd_data<Parameter<Detail>>>
                {
                    key = Guid.NewGuid().ToString("N"),
                    type = "sync",
                    host = new host
                    {
                        prod = "WMS",
                        ip = "",
                        lang = "zh_CN",
                        acct = "tiptop",
                        timestamp = DateTime.Now.ToString("yyyyMMddHHMMssfff"),
                    },
                    datakey = input.datakey,
                    //datakey = new Datakey
                    //{
                    //    EntId = "108",  //正式 88
                    //    CompanyId = "XCSJ" //据点 DGXC
                    //},
                    service = new Service
                    {
                        ip = "",
                        prod = "T100",
                        id = "topprd",
                        name = "wms_gen_apmt520"
                    },
                    payload = new PayloadData<actionStd_data<Parameter<Detail>>>
                    {
                        std_data = new actionStd_data<Parameter<Detail>>
                        {
                            parameter = input.parameter
                            //parameter = new Parameter<Detail>
                            //{
                            //    pmds000 = "2",
                            //    pmdsdocno = "3453",
                            //    pmdsdocdt = "2023-04-26", //当天时间
                            //    pmds002 = "L36783", //用户ID
                            //    pmds003 = "",
                            //    pmds007 = "C0006", //供应商代码
                            //    pmds010 = "测试客供料无采购收货", //送货单号
                            //    pmdsud001 = "CM017", //二级供应编号
                            //    detail = new List<Detail>
                            //{
                            //    new Detail
                            //    {
                            //        pmdtseq= "1",
                            //        pmdt001= "",
                            //        pmdt002= "",
                            //        pmdt003= "",
                            //        pmdt004= "",
                            //        pmdt006= itemcode, //"K7015AA016141",
                            //        pmdt020= qty,  //"100.00000",
                            //        pmdtud011= "0"
                            //    }
                            //}
                            //}
                        }
                    }
                };

                //如果送货单已经在处理，刚不能再重复抛送
                if (!curDeliveryNoList.Contains(input.parameter.pmds010) || input.parameter.pmds010.IsNullOrEmpty())
                {
                    if (!input.parameter.pmds010.IsNullOrEmpty())
                    {
                        curDeliveryNoList.Add(input.parameter.pmds010);
                    }
                    var requestJson = JsonConvert.SerializeObject(t100Action);
                    var response = HttpHelper.PostAsync(t100Url, requestJson).Result;
                    var result = JsonConvert.DeserializeObject<T100ActionResult<resultStd_data<Parameter>>>(response.Message);
                    Logger.Interface.Info($"生成到货单提交Json: {requestJson}，返回Json: {response.Message}");
                    curDeliveryNoList.Remove(input.parameter.pmds010);
                    Logger.Interface.Info($"操作单号列表移除当前操作单号[{input.parameter.pmds010}]");
                    return result;
                }
                else
                {
                    T100ActionResult<resultStd_data<Parameter>> ret = new();
                    ret.payload.std_data.execution.code = "-1";
                    ret.payload.std_data.execution.description = $"此单[{input.parameter.pmds010}]正在推送到T100，不能重复推送！";
                    Logger.Interface.Warn($"生成到货单异常，返回: {ret.payload.std_data.execution.description}");
                    return ret;
                }

                #region 测试代码

                //var result = new T100ActionResult<resultStd_data<Parameter>>()
                //{
                //    payload = new()
                //    {
                //        std_data = new()
                //        {
                //            execution = new()
                //            {
                //                code = "0",
                //                sql_code = "0",
                //                description = "执行成功！",
                //            },
                //            parameter = new()
                //            {
                //                docno = $"DGrec-{DateTime.Now:yyMMddHHmm}",
                //            }
                //        }
                //    }
                //};
                //Logger.Interface.Info($"生成客供料到货单提交Json: {requestJson}，返回Json: {{JsonConvert.SerializeObject(result)}}");

                #endregion 测试代码
            }
            catch (System.Exception ex)
            {
                curDeliveryNoList.Remove(input.parameter.pmds010);
                Logger.Interface.Error($"生成到货单异常，返回: {ex.Message}");
            }

            return new();
        }

        /// <summary>
        /// 从T100获取二级供应商接口返回iDropdownlist列表
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        public List<iDropdownlist> GetSecondarySupplyInfoToDDL(SupplierInputParameter input)
        {
            List<iDropdownlist> iDropdownlists = new List<iDropdownlist>();
            var list = GetSecondarySupplyInfo(input).payload.std_data.parameter.@return;
            foreach (var item in list)
            {
                iDropdownlist _iDropdownlist = new()
                {
                    label = item.pmaauc003,
                    value = $"{item.pmaauc002},{item.pmaauc001}",
                };
                iDropdownlists.Add(_iDropdownlist);
            }
            return iDropdownlists;
        }

        /// <summary>
        /// 生成送检单
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        public static T100ActionResult<resultStd_data<Parameter>> GenerateInspection(InsInputParameter input)
        {
            var t100Action = new T100Action<actionStd_data<InsParameter>>
            {
                key = Guid.NewGuid().ToString("N"),
                type = "sync",
                host = new host
                {
                    prod = "WMS",
                    ip = "",
                    lang = "zh_CN",
                    acct = "tiptop",
                    timestamp = DateTime.Now.ToString("yyyyMMddHHMMssfff"),
                },
                datakey = input.datakey,
                //datakey = new Datakey
                //{
                //    EntId = "108",  //正式 88
                //    CompanyId = "XCSJ" //据点 DGXC
                //},
                service = new Service
                {
                    ip = "",
                    prod = "T100",
                    id = "topprd",
                    name = "wms_gen_aqct300"
                },
                payload = new PayloadData<actionStd_data<InsParameter>>
                {
                    std_data = new actionStd_data<InsParameter>
                    {
                        parameter = input.parameter
                    }
                }
            };
            var requestJson = JsonConvert.SerializeObject(t100Action);
            var response = HttpHelper.PostAsync(t100Url, requestJson).Result;
            var result = JsonConvert.DeserializeObject<T100ActionResult<resultStd_data<Parameter>>>(response.Message);
            Logger.Interface.Info($"生成送检单提交Json: {requestJson}，返回Json: {response.Message}");

            #region 测试代码

            //var result = new T100ActionResult<resultStd_data<Parameter>>()
            //{
            //    payload = new()
            //    {
            //        std_data = new()
            //        {
            //            execution = new()
            //            {
            //                code = "0",
            //                sql_code = "0",
            //                description = "执行成功！",
            //            },
            //            parameter = new()
            //            {
            //                docno = $"DGtest-{DateTime.Now:yyMMddHHmm}",
            //            }
            //        }
            //    }
            //};
            //Logger.Interface.Info($"生成送检单提交Json: {requestJson}，返回Json: {JsonConvert.SerializeObject(result)}");

            #endregion 测试代码

            return result;
        }

        /// <summary>
        /// 生成其他入库单
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        public static T100ActionResult<resultStd_data<Parameter>> GenerateOtherIn(OtherInputParameter<Detail4> input)
        {
            var t100Action = new T100Action<actionStd_data<InParameter<Detail4>>>
            {
                key = Guid.NewGuid().ToString("N"),
                type = "sync",
                host = new host
                {
                    prod = "WMS",
                    ip = "",
                    lang = "zh_CN",
                    acct = "tiptop",
                    timestamp = DateTime.Now.ToString("yyyyMMddHHMMssfff"),
                },
                datakey = input.datakey,
                service = new Service
                {
                    ip = "",
                    prod = "T100",
                    id = "topprd",
                    name = "wms_gen_apmt570"
                },
                payload = new PayloadData<actionStd_data<InParameter<Detail4>>>
                {
                    std_data = new actionStd_data<InParameter<Detail4>>
                    {
                        parameter = input.parameter
                    }
                }
            };
            var requestJson = JsonConvert.SerializeObject(t100Action);
            var response = HttpHelper.PostAsync(t100Url, requestJson).Result;
            var result = JsonConvert.DeserializeObject<T100ActionResult<resultStd_data<Parameter>>>(response.Message);
            if (result.payload.std_data.execution.code != "0")
            {
                throw new Exception($"T100生成入库单失败，失败原因：{result.payload.std_data.execution.description}");
            }
            Logger.Interface.Info($"生成入库单请求T100，传入参数Json:{requestJson}，返回:{response.Message}");
            return result;
        }

        /// <summary>
        /// 根据领料单号拉单身
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        public T100ActionResult<resultStd_data<reqParameter1>> GetMaterialReqDetail(ReqInputParameter input)
        {
            var t100Action = new T100Action<actionStd_data<reqParameter>>
            {
                key = Guid.NewGuid().ToString("N"),
                type = "sync",
                host = new host
                {
                    prod = "WMS",
                    ip = "",
                    lang = "zh_CN",
                    acct = "tiptop",
                    timestamp = DateTime.Now.ToString("yyyyMMddHHMMssfff"),
                },
                datakey = input.datakey,
                service = new Service
                {
                    ip = "",
                    prod = "T100",
                    id = "topprd",
                    name = "wms_erp_wms_getwoissd"
                },
                payload = new PayloadData<actionStd_data<reqParameter>>
                {
                    std_data = new actionStd_data<reqParameter>
                    {
                        parameter = input.parameter
                    }
                }
            };
            var requestJson = JsonConvert.SerializeObject(t100Action);
            var response = HttpHelper.PostAsync(t100Url, requestJson).Result;
            var result = JsonConvert.DeserializeObject<T100ActionResult<resultStd_data<reqParameter1>>>(response.Message);
            Logger.Interface.Info($"根据领料单号拉单身提交Json: {requestJson}，返回Json: {response.Message}");
            return result;
        }

        /// <summary>
        /// 领料单过账
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        public static T100ActionResult<resultStd_data<Parameter>> MaterialReqToErp(ReqErpInputParameter input)
        {
            var t100Action = new T100Action<actionStd_data<Parameter4>>
            {
                key = Guid.NewGuid().ToString("N"),
                type = "sync",
                host = new host
                {
                    prod = "WMS",
                    ip = "",
                    lang = "zh_CN",
                    acct = "tiptop",
                    timestamp = DateTime.Now.ToString("yyyyMMddHHMMssfff"),
                },
                datakey = input.datakey,
                service = new Service
                {
                    ip = "",
                    prod = "T100",
                    id = "topprd",
                    name = "wms_gen_asft310"
                },
                payload = new PayloadData<actionStd_data<Parameter4>>
                {
                    std_data = new actionStd_data<Parameter4>
                    {
                        parameter = input.parameter
                    }
                }
            };
            var requestJson = JsonConvert.SerializeObject(t100Action);
            var response = HttpHelper.PostAsync(t100Url, requestJson).Result;
            var result = JsonConvert.DeserializeObject<T100ActionResult<resultStd_data<Parameter>>>(response.Message);
            Logger.Interface.Info($"领料单过账提交Json: {requestJson}，返回Json: {response.Message}");
            if (input.datakey.CompanyId == "DGXC")
            {
                Logger.Interface.Info($"领料单[{input.parameter.sfdadocno}]过账Json保存到数据库开始");
                DbClient db = ApiConfig.IsOldVersion ? Biz.DataSource["WMS57"].Client : Business.Biz.Db;
                BIZ_ERP_PROD_OUT entity_h = db.Queryable<BIZ_ERP_PROD_OUT>().Where(x => x.BILLCODE == input.parameter.sfdadocno && x.ERP_BILL_CODE == null).First();
                if (entity_h != null)
                {
                    entity_h.COMMIT_JSON = requestJson;
                    entity_h.COMMIT_MSG = response.Message;
                }
                //数据库处理操作
                var dbTran = db.UseTran(() =>
                {
                    if (entity_h != null)
                    {
                        db.Updateable(entity_h).UpdateColumns(q => new { q.COMMIT_JSON, q.COMMIT_MSG }).ExecuteCommand();
                    }
                });
                if (!dbTran.IsSuccess)
                {
                    Logger.Interface.Error(dbTran.ErrorException);
                    throw dbTran.ErrorException;
                }
                Logger.Interface.Info($"领料单[{input.parameter.sfdadocno}]过账Json保存到数据库结束");
            }

            return result;
        }
    }
}