using Masuit.Tools;
using Newtonsoft.Json;
using SqlSugar;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using WIDESEA_Common.FangCang;
using WIDESEA_Core;
using WIDESEA_Core.BaseServices;
using WIDESEA_Core.Helper;
using WIDESEA_DTO.SquareCabin;
using WIDESEA_ISquareCabinRepository;
using WIDESEA_ISquareCabinServices;
using WIDESEA_Model.Models;
using WIDESEA_SquareCabinRepository;
using static System.Net.WebRequestMethods;
using static WIDESEA_DTO.SquareCabin.OrderDto;
using static WIDESEA_DTO.SquareCabin.TowcsDto;

namespace WIDESEA_SquareCabinServices
{
    public class CabinOrderServices : ServiceBase<Dt_CabinOrder, ICabinOrderRepository>, ICabinOrderServices
    {
        public CabinOrderServices(ICabinOrderRepository BaseDal) : base(BaseDal)
        {
        }
        static string SearchDate = "";

        /// <summary>
        /// 获取上游系统的入库单
        /// </summary>
        /// <param name="searchDate"></param>
        /// <returns></returns>
        //public WebResponseContent GetUpstreamOrder(DateTime searchDate)
        //{
        //    var responseContent = new WebResponseContent();

        //    try
        //    {
        //        // 请求地址
        //        var url = "http://127.0.0.1:9090/GYZ2/95fck/inOrder";

        //        //// 请求参数
        //        var requestData = new
        //        {
        //            searchDate = searchDate.ToString("yyyy-MM-dd HH:mm:ss")
        //        };

        //        // 发起请求
        //        var result = HttpHelper.Post(url, requestData.ToJsonString());

        //        // 反序列化
        //        var response = JsonConvert.DeserializeObject<UpstreamResponse<UpstreamOrderInfo>>(result);

        //        if (response.resultCode != "0")
        //        {
        //            // 调用异常接口
        //            SendErrorToUpstream(1, "", response.resultMsg ?? "上游接口返回失败", "");
        //            return responseContent.Error(response.resultMsg ?? "上游接口返回失败");
        //        }

        //        if (response.data == null || !response.data.Any())
        //        {
        //            return responseContent.OK("无新入库单数据");
        //        }

        //        Db.Ado.BeginTran();
        //        List<Dt_CabinOrder> _CabinOrders = new List<Dt_CabinOrder>();
        //        foreach (var order in response.data)
        //        {
        //            try
        //            {
        //                // 插入入库单表
        //                var entityOrder = new Dt_CabinOrder
        //                {

        //                    Order_no = order.order_no,
        //                    Order_type = order.order_type,
        //                    Supplier_no = order.supplier_no,
        //                    Account_tiem = order.account_time,
        //                    OdrderStatus = "新建",
        //                };
        //                //var orderId = Db.Insertable(entityOrder).ExecuteReturnIdentity(); //就是返回主键ID。

        //                // 插入入库明细表
        //                var detailEntities = order.details.Select(d => new Dt_CabinOrderDetail
        //                {
        //                    //OrderId= orderId,
        //                    Goods_no = d.goods_no,
        //                    Order_qty = d.order_qty,
        //                    Batch_num = d.batch_num,
        //                    Exp_date = d.exp_date,
        //                    Warehouse_no = d.warehouse_no,
        //                    Status = 0,
        //                }).ToList();
        //                entityOrder.Details.AddRange(detailEntities); //建立主对象与子对象的关联关系
        //                _CabinOrders.Add(entityOrder);

        //                //自己
        //                /// Db.Insertable(detailEntities).ExecuteCommand();

        //                //这里要调用一个接口将上面的信息传给wcs，然后改变状态
        //            }
        //            catch (Exception innerEx)
        //            {
        //                // 针对某条订单报错时，推送异常给上游
        //                SendErrorToUpstream(1, order.order_no, innerEx.Message, "");
        //                throw; // 抛出异常，让外层捕获回滚
        //            }
        //        }
        //        // 批量插入（SqlSugar自动处理主外键关系）
        //        Db.Insertable(_CabinOrders).ExecuteCommand();
        //        Db.Ado.CommitTran();

        //        //如果EdiIn完成那么就调用CompleteOrder接口

        //        return responseContent.OK("同步入库单成功");
        //    }
        //    catch (Exception ex)
        //    {
        //        // 全局异常时，也推送异常给上游
        //        SendErrorToUpstream(1, "", ex.Message, "");
        //        Db.Ado.RollbackTran();
        //        return responseContent.Error("同步失败: " + ex.Message);
        //    }
        //}


        public WebResponseContent GetUpstreamOrder()
        {
            var responseContent = new WebResponseContent();

            try
            {
                // 请求地址
                var url = "http://127.0.0.1:9090/GYZ2/95fck/inOrder";
                if (string.IsNullOrEmpty(SearchDate)) SearchDate = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
                //// 请求参数
                var requestData = new
                {
                    searchDate = SearchDate
                };
                SearchDate = DateTime.Now.AddDays(-1).ToString("yyyy-MM-dd HH:mm:ss");
                // 发起请求
                var result = HttpHelper.Post(url, requestData.ToJsonString());

                // 反序列化
                var response = JsonConvert.DeserializeObject<UpstreamResponse<UpstreamOrderInfo>>(result);

                if (response.resultCode != "0")
                {
                    // 调用异常接口
                    SendErrorToUpstream(1, "", response.resultMsg ?? "上游接口返回失败", "");
                    return responseContent.Error(response.resultMsg ?? "上游接口返回失败");
                }

                if (response.data == null || !response.data.Any())
                {
                    return responseContent.OK("无新入库单数据");
                }

                Db.Ado.BeginTran();
                try
                {
                    List<Dt_CabinOrder> _CabinOrders = new List<Dt_CabinOrder>();
                    //存储入库单号
                    List<string> orderNos = new List<string>();

                    foreach (var order in response.data)
                    {
                        var entityOrder = new Dt_CabinOrder
                        {
                            Order_no = order.order_no,
                            Order_type = order.order_type,
                            Supplier_no = order.supplier_no,
                            Account_tiem = order.account_time,
                            OdrderStatus = "新建",
                            Details = order.details.Select(d => new Dt_CabinOrderDetail
                            {
                                Goods_no = d.goods_no,
                                Order_qty = d.order_qty,
                                Batch_num = d.batch_num,
                                Exp_date = d.exp_date,
                                Warehouse_no = d.warehouse_no,
                                OrderDetailStatus="新建",
                                Status = d.warehouse_no== "001" ? 0 : 2, //如果是001房那么就是未同步状态，如果不是001房那么就是无需同步状态
                            }).ToList()
                        };
                        _CabinOrders.Add(entityOrder);
                        orderNos.Add(order.order_no);
                    };
                    BaseDal.Db.InsertNav(_CabinOrders).Include(x => x.Details).ExecuteCommand();

                    //在下发给wcs 
                  var reslut=  EdiIn(); //发给下游
                                        //如果这个方法成功了，那么就调用CompleteOrder接口，然后改变
                    if (reslut.Status==true)
                    {
                        //如果EdiIn完成那么就调用CompleteOrder接口，将状态改为UpOrderStatus == "已完成
                        foreach (var no in orderNos)
                        {
                            //CompleteOrder(no); // 使用收集的单号

                            //Db.Updateable<Dt_CabinOrder>()
                            //  .SetColumns(o => o.UpOrderStatus == "已完成") // 更新上游状态
                            //  .Where(o => o.Order_no == no && o.OdrderStatus == "已完成")
                            //  .ExecuteCommand();
                        }
                    }
                    Db.Ado.CommitTran();
                    return responseContent.OK("同步入库单成功");
                }
                catch (Exception ex)
                {
                    Db.Ado.RollbackTran();
                    SendErrorToUpstream(1, "", ex.Message, "");
                    return responseContent.Error("同步失败: " + ex.Message);
                }
            }
            catch (Exception ex)
            {
                // 全局异常时，也推送异常给上游
                SendErrorToUpstream(1, "", ex.Message, "");
                return responseContent.Error("同步失败: " + ex.Message);
            }
        }

        /// <summary>
        /// 传给wcs
        /// </summary>
        public WebResponseContent EdiIn()
        {
            try
            {
                // 1. 先找出至少有一条符合条件的明细对应的订单ID
                //var validOrderIds = Db.Queryable<Dt_CabinOrderDetail>()
                //    .Where(d => d.Status == 0 || d.Status == 2)
                //    .Select(d => d.OrderId)
                //    .Distinct()
                //    .ToList();

                // 2. 查询符合条件的订单（表头=新建 && 包含有效明细）
                var orders = BaseDal.Db.Queryable<Dt_CabinOrder>()
                    .Where(o => o.OdrderStatus == "新建")
                    .Includes(o => o.Details, d => d.MedicineGoods)
                    .ToList();
                // 3. 再过滤掉不符合条件的明细（只保留 Status=0）
                foreach (var order in orders)
                {
                    order.Details = order.Details.Where(d => d.Status == 0).ToList();
                }

                if (orders == null || !orders.Any())
                {
                    Console.WriteLine("没有符合条件的订单需要推送");
                    return WebResponseContent.Instance.Error("没有符合条件的订单需要推送");
                }

                // 4. 遍历订单，组装 DTO 并推送
                foreach (var order in orders)
                {
                    var ediDto = new ToediInInfo
                    {
                        //客户代码
                        customerCode = "905",
                        //物料类型
                        materialCode = "YY",
                        //入库单号
                        externalOrderNo = order.Order_no,
                        //入库单类型
                        inOrderType = order.Order_type == "1" ? "10" : "20",
                        //优先级
                        priority = 0,
                        //是否取消
                        Is_cancel = 0,
                        details = order.Details.Select(d => new ToediInDetail
                        {
                            //批号
                            batchNo = d.Batch_num,
                            //产品
                            productCode = d.Goods_no,
                            //sku名称
                            productName = d.MedicineGoods?.Goods_spm,
                            //sku规格
                            productSpecifications = d.MedicineGoods?.Model,
                            //数量
                            quantity = (int)d.Order_qty,
                            //效期
                            validityPeriod = d.Exp_date,
                            //生产厂家
                            manufacturer = d.MedicineGoods?.Factory,
                            //房号
                            libraryNo = d.Warehouse_no,
                            //盘盈入库
                            //stocktakingDetails = new List<ToediInStock>()
                            //stocktakingDetails = new List<ToediInStock>()
                            //{
                            //    new ToediInStock
                            //    {
                            //         //料箱号
                            //        palletCode = "PDA001", 
                            //        //数量
                            //        quantity = d.Order_qty.ToString()
                            //    }
                            // }
                        }).ToList()
                    };

                    var url = "http://172.16.1.2:9357/file-admin/api/in/ediIn";
                    var result = HttpHelper.Post(url, ediDto.ToJsonString());
                    var resp = JsonConvert.DeserializeObject<TowcsResponse<object>>(result);

                    if (resp != null && resp.code == "0")
                    {
                        // 更新表头状态
                        Db.Updateable<Dt_CabinOrder>()
                          .SetColumns(o => new Dt_CabinOrder { OdrderStatus = "开始" })
                          .Where(o => o.Id == order.Id)
                          .ExecuteCommand();

                        // 更新明细状态为已同步
                        Db.Updateable<Dt_CabinOrderDetail>()
                          .SetColumns(d => new Dt_CabinOrderDetail { Status = 1, OrderDetailStatus = "已完成" })
                          .Where(d => d.OrderId == order.Id && d.Status == 0)
                          .ExecuteCommand();

                        Console.WriteLine($"订单 {order.Order_no} 推送成功");
                    }
                    else
                    {
                        SendErrorToUpstream(3, order.Order_no, resp?.msg ?? "WCS 推送失败", "");
                        Console.WriteLine($"订单 {order.Order_no} 推送失败：{resp?.msg}");
                        return new WebResponseContent { Status = false, Message = "订单推送失败" };
                    }
                }
                return new WebResponseContent { Status = true, Message = "推送成功" };
            }
            catch (Exception ex)
            {
                Console.WriteLine("EdiIn 异常：" + ex.Message);
                return new WebResponseContent { Status = false, Message = ex.Message };
            }
        }



        /// <summary>
        /// 入库报完成接口
        /// </summary>
        /// <param name="order_no">入库单号</param>
        /// <returns></returns>
        public WebResponseContent CompleteOrder(string order_no)
        {
            var responseContent = new WebResponseContent();
            try
            {
                if (string.IsNullOrWhiteSpace(order_no))
                {
                    return responseContent.Error("入库单号不可以为空");
                }

                var url = "http://127.0.0.1:9090/GYZ2/95fck/inOrderOk";
                var result = HttpHelper.Post(url, new { order_no }.ToJsonString());
                var response = JsonConvert.DeserializeObject<UpstreamOrderResponse>(result);

                if (response.resultCode != "0")
                {
                    SendErrorToUpstream(2, "", "上游接口返回失败", "");
                    return responseContent.Error(response.resultMsg ?? "上游接口返回失败");
                }

                // 先查表头
                var order = Db.Queryable<Dt_CabinOrder>()
                              .First(o => o.Order_no == order_no);

                if (order == null)
                {
                    return responseContent.Error($"未找到入库单号: {order_no}");
                }

                // 查询所有明细是否都已完成
                var allDetailsCompleted = Db.Queryable<Dt_CabinOrderDetail>()
                    .Where(d => d.OrderId == order.Id&&d.OrderDetailStatus=="已完成")  // 明细表用 OrderId 关联主表
                     .Count();

                if (allDetailsCompleted>0)
                {
                    // 更新表头状态为已完成
                    Db.Updateable<Dt_CabinOrder>()
                      .SetColumns(o => o.OdrderStatus == "已完成")
                      .Where(o => o.Order_no == order_no)
                      .ExecuteCommand();

                    return responseContent.OK("操作成功，入库单及明细全部完成");
                }
                else
                {
                    return responseContent.OK("操作成功，但仍有未完成的明细");
                }
                //删除全部状为已完成的明细和表头，移入历史表
            }
            catch (Exception ex)
            {
                SendErrorToUpstream(1, "", ex.Message, "");
                return responseContent.Error("同步失败: " + ex.Message);
            }
        }


        /// <summary>
        /// 推送异常信息给上游系统1.入库单接口；2.入库单报完成接口；3.出库单接口；4.出库报完成接口；5.药品基础信息同步接口；6.供应商信息接口；7.客户信息接口；8.库存
        /// </summary>
        public void SendErrorToUpstream(int type, string code, string message, string remark)
        {
            try
            {
                var url = "http://127.0.0.1:9090/GYZ2/95fck/lexceptionLogog";

                var requestData = new
                {
                    type = type.ToString(),
                    code = code,
                    message = message,
                    remark = remark
                };

                var result = HttpHelper.Post(url, requestData.ToJsonString());
                // 可以反序列化检查 resultCode 是否为0
            }
            catch (Exception e)
            {
                // 这里不要再抛异常了，避免死循环
                Console.WriteLine("异常接口推送失败：" + e.Message);
            }
        }



      


    }
}