using Apache.NMS.ActiveMQ.Commands;
using Rhea.Common;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Security.Cryptography;
using System.Text;
using System.Threading.Tasks;
using Tiger.IBusiness;
using Tiger.Model;
using Tiger.Model.Minsun;

namespace Tiger.Business.WMS
{
    public class ReceiptInfo : IReceiptInfo
    {
        /// <summary>
        /// T100调用WMS返回收货单信息
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        public ApiAction GetReceiptInfo(iReceiptParam input)
        {
            ApiAction response = new ApiAction();
            try
            {
                DbClient db = Business.Biz.Db;
                switch (input.StrongHoid)
                {
                    case "TXXC":
                    case "XCTC":
                    //db = Biz.DataSource["Main"].Client;
                    //break;
                    case "XCSJ":
                    case "DGXC":
                    //db = Biz.DataSource["DGXC"].Client;
                    //break;
                    case "AHXC":

                        db = Biz.DataSource["WMS57"].Client;
                        break;
                }
                List<iReceiptInfo> list = new List<iReceiptInfo>();
                var entity_h = db.Queryable<BIZ_SRM_DLVY>().Where(x => x.DELIVERY_NO == input.DeliveryNo).IncludesAllFirstLayer().First();
                if (entity_h == null)
                {
                    response.IsSuccessed = false;
                    response.Message = $"送货单[{input.DeliveryNo}]在WMS系统中查不到记录！";
                    return response;
                }
                if (entity_h.STATUS == 4)
                {
                    response.IsSuccessed = false;
                    response.Message = $"送货单[{input.DeliveryNo}]状态为作废，不能收货！";
                    return response;
                }
                if (entity_h != null)
                {
                    var _vender = entity_h.SUPP_CODE;
                    foreach (var item in entity_h.Dtls)
                    {
                        var pmdt004 = item.BATCH_NUMBER; // (item.poLineNo ?? "1").Split('-').Length > 2 ? (item.poLineNo ?? "1").Split('-')[2] : (item.poLineNo ?? "1");
                        var receiptInfo = new iReceiptInfo
                        {
                            BillCode = item.ERP_PO_NO,
                            lineNumber = item.PO_LINE_NO.ToString(), //!string.IsNullOrEmpty(item.extendN01) ? item.extendN01 : item.lineNo.ToString(),
                            SupplierCode = _vender,
                            ItemNumber = item.LINE_NO.ToString(), //!string.IsNullOrEmpty(item.extendN01) ? item.lineNo.ToString() : (item.poLineNo ?? "1").Split('-')[0], 采购单项次
                            SeqNumber = "1",
                            BatchOrder = pmdt004.ToString(),
                            ItemCode = item.ITEM_CODE,
                            Qty = item.QTY.ToString()
                        };
                        list.Add(receiptInfo);
                    }
                }
                response.Data = list;
                response.Message = $"送货单[{input.DeliveryNo}]明细信息获取成功";
            }
            catch (Exception ex)
            {
                response.GetResponse().CatchExceptionWithLog(ex);
            }
            return response;
        }

        /// <summary>
        /// 到货单生成接口	清点系统 --> wms,新数据库
        /// </summary>
        /// <param name="input"></param>
        /// <returns></returns>
        public ApiAction GenerateReceipt(iReceiptInput input)
        {
            var action = new ApiAction();
            try
            {
                DbClient db = Biz.DataSource["WMS57"].Client;
                //待提交数据按来源单号分组（ASN/PO）
                var dlvys = input.iReceipts
                        .Select(p => p.DeliveryNo)
                        .Distinct()
                        .ToList();
                List<BIZ_ERP_RECEIPT> receiptHeaders = new List<BIZ_ERP_RECEIPT>();
                List<BIZ_ERP_RECEIPT_DTL> detailList = new List<BIZ_ERP_RECEIPT_DTL>();
                List<BIZ_ERP_RECEIPT_SN> receiptScans = new List<BIZ_ERP_RECEIPT_SN>();
                List<Detail> details = new List<Detail>();
                List<BIZ_ERP_IQC> iqcHeaders = new List<BIZ_ERP_IQC>();
                List<WMS_ITEM_HIS> ItemHistorys = new List<WMS_ITEM_HIS>();
                List<WMS_ITEM_PKG> ItemPkgs = new List<WMS_ITEM_PKG>();
                List<WMS_ITEM> items = db.Queryable<WMS_ITEM>().Where(x => dlvys.Contains(x.TRANS_NO)).ToList();

                bool isIQCOk = true;
                string OrgCode = input.StrongHold;
                var usercode = "00000";
                switch (input.CompanyCode)
                {
                    case "XCQX":
                        usercode = "LX0001";
                        break;

                    case "XCHF":
                        usercode = "AA0001";
                        break;

                    case "XCTH":
                        //usercode = "AA0001";
                        break;

                    case "XCTX":
                        usercode = "TA0001";
                        break;
                }

                //所有送货单
                var srmDlvys = db.Queryable<BIZ_SRM_DLVY>().Where(x => dlvys.Contains(x.DELIVERY_NO)).IncludesAllFirstLayer().ToList();
                if (srmDlvys == null)
                {
                    action.IsSuccessed = false;
                    action.LocaleMsg = Biz.L($"SRM中查不到明细");
                    return action;
                }
                foreach (var srmDlvy in srmDlvys.OrderBy(o => o.DELIVERY_NO))
                {
                    //Logger.Interface.Info($"送货单[{srcBill.Key}]总数[{asnBarcodeList.Count}]，扫描总数[{input.iReceipts.Where(x => x.DeliveryNo == srcBill.Key).ToList().Count}]");

                    // 生成收料单
                    //新建单据
                    Result ruleResult = Biz.CodeRule["R001"].Generate("RE");
                    if (!ruleResult.IsSuccessed)
                    {
                        throw new Exception(ruleResult.ExceptionMsg.Message);
                    }
                    var billcode = ruleResult.Data.ToString();
                    var nBillHeader = new BIZ_ERP_RECEIPT
                    {
                        BILLCODE = billcode,
                        BILLDATE = DateTime.Now.Date,
                        //WAREHOUSECODE = WarehouseCode,
                        STATUS = BIZ_ERP_RECEIPT.STATUSs.WORKING.GetValue(),
                        //SUPPLIERCODE = nScannedBarcodes[0].SUPPLIERCODE,
                        AUTH_ORG = OrgCode
                    };

                    var supplyCode = "";
                    //创建收货单明细
                    nBillHeader.SUPPLIERCODE = srmDlvy.SUPP_CODE;
                    foreach (var item in srmDlvy.Dtls.OrderBy(o => o.PO_LINE_NO))
                    {
                        //供应商代码
                        supplyCode = srmDlvy.SUPP_CODE;
                        //插入单据明细行
                        if (!detailList.Where(x => x.BILLLINE == item.PO_LINE_NO.ToString()).Any())
                        {
                            detailList.Add(new BIZ_ERP_RECEIPT_DTL
                            {
                                //WAREHOUSECODE = WarehouseCode,
                                BILLCODE = billcode,
                                BILLID = Guid.NewGuid().ToString("N"),
                                BILLLINE = item.PO_LINE_NO.ToString(),
                                LINESTATUS = BIZ_ERP_RECEIPT.STATUSs.WORKING.GetValue(),
                                ITEM_CODE = item.ITEM_CODE,
                                UNITCODE = item.UNIT,
                                QTYPASS = 0,
                                INSTOCKQTY = 0,
                                RETURNQTY = 0,
                                PRINTQTY = 0,
                                ISGIVEAWAY = false,
                                SOURCETYPE = nameof(BIZ_SRM_DLVY),
                                SOURCECODE = item.DELIVERY_NO,
                                SOURCELINE = item.PO_LINE_NO.ToString(),
                                AUTH_ORG = OrgCode,
                                QTY = item.QTY
                            });

                            Result iqcResult = Biz.CodeRule["IQC001"].Generate("IQC");
                            if (!iqcResult.IsSuccessed)
                            {
                                throw new Exception(iqcResult.ExceptionMsg.Message);
                            }
                            iqcHeaders.Add(new BIZ_ERP_IQC
                            {
                                BILLCODE = iqcResult.Data.ToString(),
                                SOURCETYPE = (int)BIZ_ERP_IQC.BillType.CustSupplyInStock,
                                SOURCECODE = billcode,
                                SOURCELINE = item.PO_LINE_NO.ToString(),
                                PONO = item.ERP_PO_NO,
                                POLINE = item.LINE_NO.ToString(),
                                MEASURE = "Y",
                                AUTH_ORG = OrgCode,
                                QCTIMES = 0,
                                QCSTATUS = (int)BIZ_ERP_IQC.QCSTATUSs.Finished, /*(int)IqcManagementSides.QCStatus.UnFinish,*/
                                QCRESULT = (int)BIZ_ERP_IQC.QCRESULTs.Wait,
                                QCREVIEW = (int)BIZ_ERP_IQC.QCReview.UnReview,
                                QCLEVEL = 11,
                                ITEM_CODE = item.ITEM_CODE,
                                RECEIVEQTY = item.QTY
                                //ReceiveQty = detail.Qty,
                            });
                        }
                        //到货明细
                        if (!details.Where(x => x.pmdtseq == item.PO_LINE_NO.ToString()).Any())
                        {
                            details.Add(new Detail
                            {
                                pmdtseq = item.PO_LINE_NO.ToString(),
                                pmdt001 = item.ERP_PO_NO, //lineNumber
                                pmdt002 = item.LINE_NO.ToString(), //itemNumber
                                pmdt003 = "1",
                                pmdt004 = item.BATCH_NUMBER,
                                pmdt006 = item.ITEM_CODE, //"K7015AA016141",
                                                          //pmdt018 = "创米科技",
                                pmdt020 = item.QTY.ToString(),  //"100.00000",
                                pmdtud011 = "0"
                            });
                        }
                    }

                    //更新SN单号和状态
                    foreach (var scanTemp in input.iReceipts.Where(x => x.DeliveryNo == srmDlvy.DELIVERY_NO).ToList())
                    {
                        BIZ_ERP_RECEIPT_SN scanObj = new BIZ_ERP_RECEIPT_SN
                        {
                            BILLCODE = billcode,
                            BILLLINE = "SHReceipt",
                            SOURCETYPE = (int)WMS_RECEIPT_H.SourceType.Asn,
                            ITEM_CODE = scanTemp.MaterialCode,
                            SN = scanTemp.SmallBarcode,
                            META_SN = scanTemp.SCAN_BARCODE,
                            CARTON = scanTemp.BigBarcode,
                            PALLET = scanTemp.OuterBarcode,
                            SUPPLIERCODE = scanTemp.innerVendorCode,
                            DATECODE = DateTime.Now,
                            SCANQTY = scanTemp.SCANQTY,
                            STATUS = WMS_ITEM.STATUSs.WaitTest.GetValue(),
                            AUTH_ORG = OrgCode,
                            DELIVERY_NO = srmDlvy.DELIVERY_NO,  //送货单据
                        };
                        receiptScans.Add(scanObj);
                    }

                    //更新库存表
                    foreach (var wi in items.Where(x => x.TRANS_NO == srmDlvy.DELIVERY_NO))
                    {
                        wi.STATUS = WMS_ITEM.STATUSs.WaitTest.GetValue();
                        wi.TRANS_CODE = nameof(BIZ_ERP_RECEIPT);
                        wi.TRANS_NO = billcode;
                        wi.SOURCE_CODE = nameof(srmDlvy);
                        wi.SOURCE_ORDER = srmDlvy.DELIVERY_NO;
                        wi.AUTH_ORG = OrgCode;

                        WMS_ITEM_HIS his = new WMS_ITEM_HIS(wi, $"自购来料清点，到货单[{billcode}]，送货单[{srmDlvy.DELIVERY_NO}]");
                        ItemHistorys.Add(his);
                    }

                    //调用T100接口生成到货单
                    var ret = ErpT100.GenerateCustReceipt(new CustReceiptInputParameter
                    {
                        parameter = new Parameter<Detail>
                        {
                            pmds000 = "1",
                            pmdsdocno = "3438",
                            pmdsdocdt = DateTime.Now.ToString("yyyy-MM-dd"), //"2023-04-26", //当天时间
                            pmds002 = usercode, //用户ID
                            pmds003 = "",
                            pmds007 = supplyCode, //"C0006", //供应商代码
                            pmds010 = srmDlvy.DELIVERY_NO, //"测试客供料无采购收货", //送货单号
                                                           //pmdsud001 = SecondVenderCode, //"CM017", //二级供应编号
                            detail = details
                        },
                        datakey = new Datakey
                        {
                            EntId = "88",
                            CompanyId = OrgCode
                        }
                    });
                    if (ret.payload.std_data.execution.code == "0") //成功
                    {
                        nBillHeader.ERP_BILL_CODE = ret.payload.std_data.parameter.docno;
                        action.Message += $"{action.Message.IsNullOrEmpty("", "；")}{ret.payload.std_data.execution.description}，返回的收货单号：[{ret.payload.std_data.parameter.docno}]";

                        #region 生成送检单

                        foreach (var item in iqcHeaders)
                        {
                            var retIns = ErpT100.GenerateInspection(new InsInputParameter
                            {
                                parameter = new InsParameter
                                {
                                    pmdsdocno = ret.payload.std_data.parameter.docno,
                                    pmdsdocdt = DateTime.Now.ToString("yyyy-MM-dd"),
                                    pmdtseq = item.SOURCELINE.ToString(),
                                    pmdt020 = item.RECEIVEQTY.ToString(),
                                    qcbadocno = "3701",
                                },
                                datakey = new Datakey
                                {
                                    EntId = "88",
                                    CompanyId = OrgCode
                                }
                            });
                            isIQCOk &= retIns.payload.std_data.execution.code == "0";
                            if (retIns.payload.std_data.execution.code != "0")
                            {
                                action.IsSuccessed = false;
                                action.Message = $"返回到货单[{ret.payload.std_data.parameter.docno}]，当前用户[{usercode}]，送货单号[{srmDlvy.DELIVERY_NO}]，到货单号[{billcode}]，返回的信息:{retIns.payload.std_data.execution.description}"; ;
                            }
                            else
                            {
                                var receipDtl = detailList.Where(q => q.BILLCODE == item.SOURCECODE && q.BILLLINE == item.SOURCELINE).FirstOrDefault();
                                if (!receipDtl.IsNullOrEmpty())
                                {
                                    receipDtl.ERP_BILL_CODE = retIns.payload.std_data.parameter.docno;
                                }
                                item.ERP_BILL_CODE = retIns.payload.std_data.parameter.docno;
                                action.Message = $"到货单[{ret.payload.std_data.parameter.docno}]，当前用户[{usercode}]，返回的信息:{retIns.payload.std_data.execution.description}"; ;
                            }
                        }
                        receiptHeaders.Add(nBillHeader);

                        #endregion 生成送检单
                    }
                    else //失败
                    {
                        action.IsSuccessed = false;
                        action.Message = $"当前用户[{usercode}]，送货单号[{srmDlvy.DELIVERY_NO}]，到货单号[{billcode}]，返回的信息:{ret.payload.std_data.execution.description}";
                        return action;
                    }
                }
                db = Biz.DataSource["WMS57"].Client;
                //保存到数据库
                var dbTran = db.UseTran(() =>
                {
                    if (receiptHeaders.Any())
                    {
                        db.Insertable(receiptHeaders, usercode).ExecuteCommand();
                    }
                    if (detailList.Any())
                    {
                        db.Insertable(detailList, usercode).ExecuteCommand();
                    }
                    if (receiptScans.Any())
                    {
                        db.Insertable(receiptScans, usercode).ExecuteCommand();
                    }
                    if (action.IsSuccessed && isIQCOk)
                    {
                        db.Insertable(iqcHeaders).ExecuteCommand();
                    }
                    db.Updateable(items, usercode).UpdateColumns(x => new { x.UPDATE_USER, x.UPDATE_TIME, x.STATUS, x.TRANS_CODE, x.TRANS_NO, x.TRANS_LINE, x.SOURCE_CODE, x.SOURCE_ORDER }).ExecuteCommand();
                    db.Insertable(ItemHistorys, usercode).ExecuteCommand();
                });
                if (!dbTran.IsSuccess)
                {
                    action.GetResponse().CatchException(dbTran.ErrorException, $"到货单生成异常");
                }
                action.LocaleMsg = Biz.L($"到货单和送检单生成成功！");
                return action;
            }
            catch (Exception ex)
            {
                return action.GetResponse().CatchException(ex, $"到货单生成异常");
            }
        }
    }
}