using Newtonsoft.Json;
using Rhea.Common;
using SqlSugar;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using Tiger.IBusiness;
using Tiger.Model;
using Tiger.Model.Minsun;

namespace Tiger.Business.WMS
{
    public class ProdMaterialReq : IProdMaterialReq
    {
        /// <summary>
        /// T100推送领料单到WMS
        /// </summary>
        /// <param name="prd_hs"></param>
        /// <returns></returns>
        public ApiAction GetMaterialReq(List<Model.Minsun.WMS_PRDPICK_H> prd_hs)
        {
            var action = new ApiAction();
            try
            {
                if (prd_hs.Count > 0)
                {
                    List<BIZ_ERP_PROD_OUT> entity_h = new();
                    List<BIZ_ERP_PROD_OUT_DTL> entity_d = new();
                    //查询出来的列表
                    List<BIZ_ERP_PROD_OUT_DTL> list_d = new();
                    DbClient db = Biz.DataSource["WMS57"].Client; 
                    foreach (var item_h in prd_hs)
                    {
                        var prd_h = db.Queryable<BIZ_ERP_PROD_OUT>().Where(s => s.BILLCODE == item_h.BILLCODE).Single();
                        if (prd_h?.STATUS != BIZ_ERP_PROD_OUT.STATUSs.COMPLETE.GetValue())
                        {
                            prd_h = prd_h ?? new BIZ_ERP_PROD_OUT()
                            {
                                STATUS = BIZ_ERP_PROD_OUT.STATUSs.INIT.GetValue(),
                                BIZTYPE = "1",
                            };
                            prd_h.BILLCODE = item_h.BILLCODE;
                            prd_h.BILLDATE = item_h.BILLDATE??DateTime.MinValue;
                            prd_h.SOURCETYPE = item_h.SOURCETYPE;
                            prd_h.STATUS = prd_h.STATUS == BIZ_ERP_PROD_OUT.STATUSs.DELETE.GetValue() ? BIZ_ERP_PROD_OUT.STATUSs.INIT.GetValue() : prd_h.STATUS;
                            prd_h.REMARK = item_h.REMARK;
                            prd_h.SOURCECODE = item_h.SOURCECODE;
                            prd_h.AUTH_ORG = item_h.STRONGHOID;
                            prd_h.HANDLED = 0;

                            entity_h.Add(prd_h);
                        }
                    }

                    Logger.Interface.Info($"推送到新数据库，开始保存数据，数量[{entity_h.Count}]");
                    //保存到数据库
                    var dbTran = db.UseTran(() =>
                    {
                        db.Storageable(entity_h, "T100").ExecuteCommand();

                    });
                    if (!dbTran.IsSuccess)
                    {
                        action.CatchExceptionWithLog(dbTran.ErrorException, $"数据保存失败");
                    }

                    //异步拉取单身列表
                    GenerateReqDetailNew(prd_hs, db);
                }

                return action;
            }
            catch (Exception ex)
            {
                return action.GetResponse().CatchExceptionWithLog(ex, $"领料单生成异常");
            }
        }

        /// <summary>
        /// 根据领料单头拉单身
        /// </summary>
        /// <param name="dtls"></param>
        /// <param name="db"></param>
        /// <returns></returns>
        private static ApiAction GenerateReqDetailNew(List<WMS_PRDPICK_H> dtls, DbClient db)
        {
            Thread.Sleep(5000);
            var action = new ApiAction();
            try
            {
                Logger.Interface.Info($"推送到新数据库，根据领料单头拉单身开始");
                List<BIZ_ERP_PROD_OUT> entity_h = new();
                List<BIZ_ERP_PROD_OUT_DTL> entity_d = new();
                List<BIZ_WMS_TRANSFER> transferH = new();
                List<WMS_SCTRWO_TRANSFER> sctrwos = new();
                //查询出来的列表
                List<BIZ_ERP_PROD_OUT_DTL> list_dOld = new();
                foreach (var item_h in dtls)
                {
                    var prd_h = db.Queryable<BIZ_ERP_PROD_OUT>().Where(s => s.BILLCODE == item_h.BILLCODE).Single();
                    if (prd_h?.STATUS != BIZ_ERP_PROD_OUT.STATUSs.COMPLETE.GetValue())
                    {
                        var list_d = db.Queryable<BIZ_ERP_PROD_OUT_DTL>().Where(s => s.BILLCODE == item_h.BILLCODE).ToList();

                        var item_h_list = new List<BIZ_ERP_PROD_OUT_DTL>();
                        var ret = DI.Resolve<IErpT100>().GetMaterialReqDetail(new ReqInputParameter
                        {
                            parameter = new reqParameter { sfdcdocno = item_h.BILLCODE },
                            datakey = new Datakey
                            {
                                EntId = item_h.ENTERPRISECODE.ToString(),
                                CompanyId = item_h.STRONGHOID
                            }
                        });
                        List<reqParameterReturn> ret_list = new List<reqParameterReturn>();
                        if (ret.payload.std_data.execution.code != "0")
                        {
                            action.IsSuccessed = false;
                            action.Message = $"错误信息：[{ret.payload.std_data.execution.description}]";
                            Logger.Default.Info(action.Message);
                            var dt = DateTime.Now;
                            while ((dt - DateTime.Now).TotalSeconds < 10)
                            {

                            }
                            var ret1 = DI.Resolve<IErpT100>().GetMaterialReqDetail(new ReqInputParameter
                            {
                                parameter = new reqParameter { sfdcdocno = item_h.BILLCODE },
                                datakey = new Datakey
                                {
                                    EntId = item_h.ENTERPRISECODE.ToString(),
                                    CompanyId = item_h.STRONGHOID
                                }
                            });
                            if (ret1.payload.std_data.execution.code != "0")
                            {
                                action.IsSuccessed = false;
                                action.Message = $"错误信息：[{ret1.payload.std_data.execution.description}]";
                                Logger.Default.Info(action.Message);
                                return action;
                            }
                            else
                            {
                                ret_list = ret1.payload.std_data.parameter.@return;
                            }
                        }
                        else
                        {
                            ret_list = ret.payload.std_data.parameter.@return;
                        }
                        foreach (var item in ret_list)
                        {
                            BIZ_ERP_PROD_OUT_DTL d = new BIZ_ERP_PROD_OUT_DTL
                            {
                                BILLCODE = item.sfdcdocno,
                                BILLLINE = item.sfdcseq,
                                UNITCODE = item.sfdc006,
                                ITEM_CODE = item.sfdc004,
                                PRQTY = Convert.ToDecimal(item.sfdc007),
                                DELIVERYDATE = Convert.ToDateTime(item.sfdareqdt),
                                WAREHOUSECODE = item.sfdc012,
                                SOURCETYPE = Convert.ToInt32(item.sfdc003),
                                SOURCECODE = item.sfdc001,
                                SOURCELINE = item.sfdc002,
                                AUTH_ORG = item_h.STRONGHOID,
                            };
                            item_h_list.Add(d);
                        }

                        //保存委外工单号对应关系
                        WMS_SCTRWO_TRANSFER sctr = new WMS_SCTRWO_TRANSFER
                        {
                            ID = Guid.NewGuid().ToString("N"),
                            ORIGINAL_WORKORDER = ret_list[0]?.sfdc001,
                            TARGET_WORKORDER = ret_list[0]?.sfdc001_1
                        };
                        sctrwos.Add(sctr);
                        action.Message += $"，领料单明细获取成功，[{string.Join(",", item_h_list.Select(x => x.BILLCODE + ";" + x.ITEM_CODE).ToList())},获取总数[{item_h_list.Count}]，数据库中总数[{list_d.Count}]";
                        action.Message += $"，委外工单，[{string.Join(",", sctrwos.Select(x => x.ORIGINAL_WORKORDER + ";" + x.TARGET_WORKORDER).ToList())}";
                        if (list_d.Count != item_h_list.Count)
                        {
                            foreach (var d in list_d) { d.PRQTY = 0; } //需求数量都弄成0
                        }
                        int n = 0;
                        List<BIZ_ERP_PROD_OUT_DTL> prdDList = new List<BIZ_ERP_PROD_OUT_DTL>();
                        foreach (var item_d in item_h_list)
                        {
                            //根据单据重新到数据查找相应的单据明细
                            var prd_d = list_d.Where(s => s.BILLCODE == item_d.BILLCODE && s.BILLLINE == item_d.BILLLINE).FirstOrDefault();
                            prd_d = prd_d ?? new BIZ_ERP_PROD_OUT_DTL()
                            {
                                LINESTATUS = BIZ_ERP_PROD_OUT.STATUSs.INIT.GetValue(),
                                QTY = Convert.ToDecimal(0),
                            };
                            prd_d.BILLCODE = item_d.BILLCODE;
                            prd_d.BILLLINE = item_d.BILLLINE;
                            prd_d.UNITCODE = item_d.UNITCODE;
                            prd_d.ITEM_CODE = item_d.ITEM_CODE;
                            prd_d.PRQTY = Convert.ToDecimal(item_d.PRQTY);
                            prd_d.DELIVERYDATE = Convert.ToDateTime(item_d.DELIVERYDATE);
                            prd_d.WAREHOUSECODE = item_d.WAREHOUSECODE;
                            prd_d.LINESTATUS = prd_d.PRQTY == prd_d.QTY ? BIZ_ERP_PROD_OUT.STATUSs.COMPLETE.GetValue() : Convert.ToDecimal(item_d.PRQTY) == 0 ? BIZ_ERP_PROD_OUT.STATUSs.COMPLETE.GetValue() : prd_d.LINESTATUS == BIZ_ERP_PROD_OUT.STATUSs.DELETE.GetValue() ? BIZ_ERP_PROD_OUT.STATUSs.INIT.GetValue() : prd_d.LINESTATUS;
                            prd_d.SOURCETYPE = item_d.SOURCETYPE;
                            prd_d.SOURCECODE = item_d.SOURCECODE;
                            prd_d.SOURCELINE = item_d.SOURCELINE;
                            prd_d.AUTH_ORG = item_d.AUTH_ORG;
                            list_d.RemoveAll(q => q.BILLCODE == item_d.BILLCODE && q.BILLLINE == item_d.BILLLINE);
                            if (prd_d.LINESTATUS == BIZ_ERP_PROD_OUT.STATUSs.COMPLETE.GetValue()) { n++; }
                            prdDList.Add(prd_d);
                            entity_d.Add(prd_d);
                        }
                        if (prdDList.Count == n) { prd_h.STATUS = BIZ_ERP_PROD_OUT.STATUSs.COMPLETE.GetValue(); }
                        entity_h.Add(prd_h);
                        list_dOld.AddRange(list_d);
                        //检查有没有调拨单，有就更新状态为完成
                        var transferList = db.Queryable<BIZ_WMS_TRANSFER>().Where(s => s.SOURCECODE == prd_h.BILLCODE).ToList();
                        if (transferList.Any())
                        {
                            foreach (var item in transferList)
                            {
                                item.STATUS = BIZ_WMS_TRANSFER.STATUSs.FINISHED.GetValue();
                                item.SOURCECODE = prd_h.BILLCODE;
                                transferH.Add(item);
                                action.Message += $"，领料单[{prd_h.BILLCODE}]对应调拨单[{item.BILLCODE}]完成";
                            }
                        }
                    }
                }
                //保存到数据库
                var dbTran = db.UseTran(() =>
                {
                    db.Storageable(entity_h, "T100").ExecuteCommand();
                    db.Storageable(entity_d, "T100").ExecuteCommand();
                    if (transferH.Any())
                    {
                        db.Updateable(transferH, "T100").ExecuteCommand();
                    }
                    if (sctrwos.Any())
                    {
                        //db.Insertable(sctrwos).ExecuteCommand();
                        var y = db.Storageable(sctrwos)
                        .WhereColumns(t => new { t.ORIGINAL_WORKORDER, t.TARGET_WORKORDER })
                        .ToStorage();
                        y.AsInsertable.ExecuteCommand();
                        y.AsUpdateable.IgnoreColumns(t => t.ID).ExecuteCommand();
                    }
                    if (list_dOld.Any())
                    {
                        db.Deleteable(list_dOld).ExecuteCommand();
                    }
                });
                if (!dbTran.IsSuccess)
                {
                    action.CatchExceptionWithLog(dbTran.ErrorException, $"数据保存失败");
                }

                //如果未过账则尝试过账
                foreach (var reqNo in dtls.Select(x=>x.BILLCODE).ToList())
                {
                    Logger.Interface.Info($"开始检测是否T100重新推过来的领料单[{reqNo}]");
                    var req = db.Queryable<BIZ_ERP_PROD_OUT>().Where(x => x.BILLCODE == reqNo && x.STATUS == BIZ_ERP_PROD_OUT.STATUSs.COMPLETE.GetValue() && SqlFunc.IsNullOrEmpty(x.ERP_BILL_CODE)).First();
                    var dtlList = db.Queryable<BIZ_ERP_PROD_OUT_DTL>().Where(x => x.BILLCODE == reqNo).ToList();
                    if (req != null && dtlList.Where(x => x.LINESTATUS == BIZ_ERP_PROD_OUT.STATUSs.COMPLETE.GetValue()).Count() == dtlList.Count)
                    {
                        Logger.Interface.Info($"领料单[{reqNo}]重新过账准备进入过账进程");
                        iWMS.MaterialReqOldToErpNew(new MReqPostParam() {BillCode = req.BILLCODE, CompanyId=req.AUTH_ORG});
                    }
                }
                    Logger.Interface.Info(action.Message);

                return action;
            }
            catch (System.Exception ex)
            {
                return action.GetResponse().CatchExceptionWithLog(ex, $"领料单生成异常");
            }
        }

        /// <summary>
        /// 获取领料单列表
        /// </summary>
        /// <param name="pageIndex"></param>
        /// <param name="pageSize"></param>
        /// <returns></returns>
        public ApiAction<PageAble<BIZ_ERP_PROD_OUT>> GetProdMaterialReqHeaders(int pageIndex, int pageSize, string orgcode, string billcode)
        {
            var action = new ApiAction<PageAble<BIZ_ERP_PROD_OUT>>();
            var query = Biz.Db.Queryable<BIZ_ERP_PROD_OUT>().Where(x =>
            (x.STATUS == BIZ_ERP_PROD_OUT.STATUSs.INIT.GetValue()
            || x.STATUS == BIZ_ERP_PROD_OUT.STATUSs.WORKING.GetValue())
            && x.AUTH_ORG == orgcode)
                .WhereIF(!billcode.IsNullOrEmpty(),x=>x.BILLCODE.Contains(billcode))
                .OrderByDescending(x => x.UPDATE_TIME.ToString("yyyy-MM-dd"))
                .OrderBy(x => x.REMARK == "L40774" ? 0 : 1)
                .OrderBy(x => x.SOURCECODE == null ? 1 : 0)
                .OrderBy(x => x.CREATE_TIME)
                .ToPage(pageIndex, pageSize);

            action.Data = query;
            return action;
        }

        public ApiAction<PageAble<BIZ_ERP_PROD_OUT>> GetWoReqHeaders(int pageIndex, int pageSize, string orgcode, string billcode)
        {
            var action = new ApiAction<PageAble<BIZ_ERP_PROD_OUT>>();
            var query = Biz.Db.Queryable<BIZ_ERP_PROD_OUT>().Where(x =>
            (x.STATUS == BIZ_ERP_PROD_OUT.STATUSs.INIT.GetValue()
            || x.STATUS == BIZ_ERP_PROD_OUT.STATUSs.WORKING.GetValue())
            && x.AUTH_ORG == orgcode)
                .WhereIF(!billcode.IsNullOrEmpty(), x => x.BILLCODE.Contains(billcode))
                .OrderByDescending(x => x.UPDATE_TIME.ToString("yyyy-MM-dd"))
                .OrderByDescending(x => x.BILLDATE)
                .OrderBy(x => new { x.CREATE_TIME, x.BILLCODE })
                .ToPage(pageIndex, pageSize);

            action.Data = query;
            return action;
        }

        /// <summary>
        /// 调拨出库明细
        /// </summary>
        /// <param name="pageIndex"></param>
        /// <param name="pageSize"></param>
        /// <param name="orgcode"></param>
        /// <param name="billcode"></param>
        /// <returns></returns>
        public ApiAction<PageAble<BIZ_WMS_TRANSFER>> GetOutTransferHeaders(int pageIndex, int pageSize, string orgcode, string billcode)
        {
            var action = new ApiAction<PageAble<BIZ_WMS_TRANSFER>>();
            var query = Biz.Db.Queryable<BIZ_WMS_TRANSFER>().Where(x =>
            (x.STATUS == BIZ_WMS_TRANSFER.STATUSs.INIT.GetValue()
            || x.STATUS == BIZ_WMS_TRANSFER.STATUSs.MANUAL.GetValue()
            || x.STATUS == BIZ_WMS_TRANSFER.STATUSs.WORKING.GetValue())
            && x.AUTH_ORG == orgcode)
                .WhereIF(!billcode.IsNullOrEmpty(), x => x.BILLCODE.Contains(billcode))
                .OrderByDescending(x => x.UPDATE_TIME.ToString("yyyy-MM-dd"))
                //.OrderBy(x => x.REMARK == "L40774" ? 0 : 1)
                //.OrderBy(x => x.SOURCECODE == null ? 1 : 0)
                .OrderByDescending(x => x.BILLDATE)
                .OrderBy(x => new { x.CREATE_TIME, x.BILLCODE})
                
                //.OrderBy(x => x.CREATE_TIME)
                .ToPage(pageIndex, pageSize);

            action.Data = query;
            return action;
        }

        /// <summary>
        /// 领料单过账到T100
        /// </summary>
        /// <param name="param"></param>
        /// <returns></returns>
        public ApiAction MaterialReqToErp(MReqPostParam param)
        {
            var action = new ApiAction();
            Work.DoAsync(() =>
            {
                Thread.Sleep(3000);
                try
                {
                    BIZ_ERP_PROD_OUT entity_h = Biz.Db.Queryable<BIZ_ERP_PROD_OUT>().Where(x => x.BILLCODE == param.BillCode && x.ERP_BILL_CODE == null).First();
                    List<BIZ_ERP_PROD_OUT_DTL> entity_d = Biz.Db.Queryable<BIZ_ERP_PROD_OUT_DTL>().Where(x => x.BILLCODE == param.BillCode && Convert.ToInt32(x.PRQTY) != 0).ToList();
                    List<Detail5> details = new List<Detail5>();
                    foreach (var item in entity_d)
                    {
                        //计算数量
                        var qty = item.QTY > item.PRQTY ? item.PRQTY.ToString() : item.QTY.ToString();
                        details.Add(new Detail5
                        {
                            sfdcseq = item.BILLLINE.ToString(),
                            sfdc001 = item.SOURCECODE,
                            sfdc002 = item.SOURCELINE.ToString(),
                            sfdc003 = item.SOURCETYPE.ToString(),
                            sfdc007 = qty,
                        });
                    }
                    var ret = ErpT100.MaterialReqToErp(new ReqErpInputParameter
                    {
                        parameter = new Parameter4
                        {
                            sfdatype = entity_h.SOURCETYPE.ToString(),
                            sfdadocno = entity_h.BILLCODE,
                            detail = details
                        },
                        datakey = new Datakey
                        {
                            EntId = "88", //ApiConfig.IsTestServer ? "108" : "88",
                            CompanyId = param.CompanyId
                        }
                    });
                    if (ret.payload.std_data.execution.code == "0") //成功
                    {
                        entity_h.ERP_BILL_CODE = ret.payload.std_data.parameter.docno;
                        entity_h.UPDATE_TIME = DateTime.Now;
                        action.Message += $"{action.Message.IsNullOrEmpty("", "；")}{ret.payload.std_data.execution.description}，返回的ERP_BILL_CODE：[{ret.payload.std_data.parameter.docno}]";
                        Logger.Interface.Info(action.Message);
                    }
                    else //失败
                    {
                        action.IsSuccessed = false;
                        action.Message += $"，领料单{entity_h.BILLCODE}过账失败，返回的信息:{ret.payload.std_data.execution.description}";
                        Logger.Interface.Error(action.Message);
                        //return action;
                    }
                    //数据库处理操作
                    DbClient db = Business.Biz.Db;
                    if (action.IsSuccessed)
                    {
                        action.Message += $"，领料单{entity_h.BILLCODE}过账成功";
                        var dbTran = db.UseTran(() =>
                        {
                            db.Updateable(entity_h).ExecuteCommand();
                            db.Updateable(entity_d).ExecuteCommand();

                        });
                        if (!dbTran.IsSuccess)
                        {
                            action.CatchExceptionWithLog(dbTran.ErrorException, $"数据处理失败");
                        }
                    }
                    Logger.Interface.Info(action.Message);
                    //return action;

                }
                catch (Exception ex)
                {
                    action.GetResponse().CatchExceptionWithLog(ex, $"发料单过账异常");
                }
            });
            return action;
        }
    }
}