using Admin.NET.Core;
using iWareCommon;
using iWareCommon.Utils;
using iWareSql.MyDbContext;
using Newtonsoft.Json;
using System;
using System.Collections.Generic;
using System.Data;
using System.Data.Entity;
using System.Data.Entity.Migrations;
using System.Linq;
using System.Net.Http;
using System.Threading;

namespace iWareCC
{
    /// <summary>
    /// po单收货线程
    /// </summary>
    public class ReceivingPoOrderHandler
    {
        private static object _lock;
        public static void Handler()
        {
            var errMsg = "";
            while (true)
            {
                try
                {
                    SystemWarningMsg.lbl_Alert_ReceivingPoOrderHandler = "循环开始...";
                    if (SystemValue.isAllowRuning_ReceivingPoOrderHandler && SystemValue.isStartedModel)
                    {
                        errMsg = "";//重置
                        try
                        {
                            lock (_lock)
                            {
                                Do(errMsg);
                                if (!string.IsNullOrEmpty(errMsg))
                                {
                                    SystemWarningMsg.lbl_Alert_ReceivingPoOrderHandler = errMsg;
                                }
                            }
                        }
                        catch (Exception ex)
                        {
                            Log4NetHelper.WriteErrorLog(LogType.ReceivingPoOrderHandler, "收货处理的线程=>" + errMsg + ",异常:" + ex.Message, ex);
                            SystemWarningMsg.lbl_Alert_ReceivingPoOrderHandler = "收货处理的线程=>" + errMsg + ",异常:" + ex.Message;
                        }
                    }
                }
                catch (Exception ex)
                {
                    SystemWarningMsg.lbl_Alert_ReceivingPoOrderHandler = "出现异常:" + ex.Message;
                    Log4NetHelper.WriteErrorLog(LogType.ReceivingPoOrderHandler, "PrintHandler 出现异常：" + ex.Message, ex);
                }
                Thread.Sleep(1 * 1000);//休眠40秒
            }
        }


        /// <summary>
        /// 接收收发货记录
        /// </summary>
        /// <param name="model"></param>
        /// <param name="Lane"></param>
        /// <param name="flag"></param>
        /// <param name="errMsg"></param>
        private static async void Do(string errMsg)
        {
            using (MyDbContext mycontext = new MyDbContext())
            {

                var inputData = new UpdateAdapterRecordByCCInput();
                var infoData = new AdapterLogsInfoUpdateInput();
                var recordAdapterIdList = new List<long>();
                var query_ErpPushStatus = 2;
                var receivingList = mycontext.wms_adapter_record.Where(x => (x.IsDelete == false) && x.DealWithStatus == query_ErpPushStatus && x.AdapterMethodName == "PO单收货")
                    .OrderBy(x => x.Id).ToList();
                if (receivingList.Count > 0)
                {

                }
                else
                {
                    errMsg = $"没有可收货的内容！";
                    return;
                }
                foreach (var receiving in receivingList)
                {
                    recordAdapterIdList.Add(receiving.Id);

                    inputData.ErpVoucher = Yitter.IdGenerator.YitIdHelper.NextId().ToString();
                }
                inputData.RecordAdapterIdList = recordAdapterIdList;
                infoData.RecordAdapterIdList = recordAdapterIdList;

                string jsonData = JsonConvert.SerializeObject(inputData);

                string apiUrl1 = "http://localhost:5005/api/RecordAdapter/UpdateAdapterRecordByCC";
                string apiUrl2 = "http://localhost:5005/api/RecordAdapter/UpdateAdapterRecordInfo";
                using (var httpClient = new HttpClient())
                {
                    try
                    {

                        // 创建HttpContent对象，设置为JSON格式
                        var httpContent = new StringContent(jsonData, System.Text.Encoding.UTF8, "application/json");

                        // 发送POST请求
                        var response = await httpClient.PostAsync(apiUrl1, httpContent);

                        //// 检查响应是否成功
                        //response.EnsureSuccessStatusCode();

                        //// 读取响应内容
                        //string jsonResponse = await response.Content.ReadAsStringAsync();
                        //infoData.AdapterInputInfo = jsonResponse;
                        //string infoJsonData = JsonConvert.SerializeObject(infoData);
                        //var infoHttpContent = new StringContent(infoJsonData, System.Text.Encoding.UTF8, "application/json");
                        //// 发送POST请求
                        //var response2 = await httpClient.PostAsync(apiUrl2, infoHttpContent);



                    }
                    catch (Exception ex)
                    {
                        // 处理异常情况
                        throw ex;
                    }
                }






            }
        }




        /// <summary>
        /// 接收收发货记录
        /// </summary>
        /// <param name="model"></param>
        /// <param name="Lane"></param>
        /// <param name="flag"></param>
        /// <param name="errMsg"></param>
        private static void Do2(ref string errMsg)
        {
            using (MyDbContext mycontext = new MyDbContext())
            {

                var inputData = new UpdateAdapterRecordByCCInput();

                var query_ErpPushStatus = 0;
                var receivingList = mycontext.wms_adapter_record.Where(x => (x.IsDelete == false) && x.DealWithStatus == query_ErpPushStatus)
                    .OrderBy(x => x.Id).ToList();
                if (receivingList.Count > 0)
                {
                    foreach (var item in receivingList)
                    {
                        //判断是否是 PO收货
                        if (1 == 1)
                        {//是PO收货
                         //1、模拟调用SERP
                         //2、模拟调用成功ERP
                         //3、调用成功后- 更新wms_adapter_record的状态
                            item.DealWithStatus = 0;//已处理
                            item.UpdateTime = DateTime.Now;
                            item.UpdateUserName = "调度系统";

                            //查询收货记录表 ，更新他的ErpPushStatusEnum值
                            //
                        }
                    }

                }
                else
                {
                    errMsg = $"没有可收货的内容！";
                    return;
                }
                foreach (var receiving in receivingList)
                {

                    inputData.ErpVoucher = Yitter.IdGenerator.YitIdHelper.NextId().ToString();
                }
                string jsonData = JsonConvert.SerializeObject(inputData);

                string apiUrl = "http://localhost:5005/api/RecordAdapter/UpdateAdapterRecordByCC";
                using (var httpClient = new HttpClient())
                {
                    try
                    {
                        // 创建HttpContent对象，设置为JSON格式
                        var httpContent = new StringContent(jsonData, System.Text.Encoding.UTF8, "application/json");

                        // 发送POST请求
                        var response = httpClient.PostAsync(apiUrl, httpContent);


                    }
                    catch (Exception ex)
                    {
                        // 处理异常情况
                        Console.WriteLine($"发生异常：{ex.Message}");
                    }
                }






            }
        }

        public class UpdateAdapterRecordByCCInput
        {
            public List<long> RecordAdapterIdList { get; set; }

            public string ErpVoucher { get; set; }
        }

        public class AdapterLogsInfoUpdateInput
        {
            public List<long> RecordAdapterIdList { get; set; }

            public string AdapterInputInfo { get; set; }
        }




        private static bool GetPrintClassifyEnum(wms_record_sncode_print item, MyDbContext mycontext, ref string errMsg, ref PrintClassifyEnum printClassifyEnum)
        {
            if (item.PrintType == (int)PrintTypeEnum.看板卡)
            {
                printClassifyEnum = PrintClassifyEnum.看板卡;
            }
            else
            {
                wms_config_sncode_rule rule = null;
                var ruleList = mycontext.wms_config_sncode_rule.Where(x => (x.RuleName == "ASN一维码" || x.RuleName == "ASN二维码") && x.IsDisabled == false).ToList();
                if (ruleList != null && ruleList.Count > 1)
                {
                    errMsg = "条码生成规则配置中，ASN一维码和ASN二维码只能启用其中一个！";
                    return false;
                }
                if (ruleList == null || ruleList.Count == 0)
                {
                    errMsg = "条码生成规则配置中，ASN一维码和ASN二维码两个都没有配置启用！";
                    return false;
                }
                rule = ruleList.First();

                printClassifyEnum = default(PrintClassifyEnum);
                if (rule.RuleName == "ASN一维码")
                {
                    printClassifyEnum = PrintClassifyEnum.一维跟踪码;
                }
                else
                {
                    printClassifyEnum = PrintClassifyEnum.二维跟踪码;
                }
            }

            return true;

        }

    }
}