using AutoMapper;
using ERP;
using Microsoft.EntityFrameworkCore.Storage;
using Microsoft.Extensions.Caching.Memory;
using Microsoft.Extensions.Logging;
using Microsoft.Extensions.Options;
using Newtonsoft.Json;
using Newtonsoft.Json.Linq;
using System;
using System.Collections.Generic;
using System.Linq;
using System.ServiceModel;
using System.Text;
using System.Threading.Tasks;
using WMS.Web.Core.Dto.Erp;
using WMS.Web.Core.Dto.Erp.Customer;
using WMS.Web.Core.Dto.Erp.Org;
using WMS.Web.Core.Dto.Erp.OutStock;
using WMS.Web.Core.Dto.Erp.Purchase;
using WMS.Web.Core.Dto.Erp.Supplier;
using WMS.Web.Core.Dto.Erp.TakeStock;
using WMS.Web.Core.Internal.Results;
using WMS.Web.Domain.Entitys;
using WMS.Web.Domain.Infrastructure;
using WMS.Web.Domain.IService.Public;
using WMS.Web.Domain.Options;
using WMS.Web.Domain.Values;
using WMS.Web.Domain.Values.Erp;
using WMS.Web.Domain.Values.Single;

namespace WMS.Web.Domain.Services.Public
{
    /// <summary>
    /// erp数据交互服务
    /// </summary>
    public class ErpService : IErpService
    {
        private IMapper _mapper;
        private AppOptions _appOptions;
        private ErpOptions _erpOptions;
        private ILogger<ErpService> _logger;
        private ERPGWSoapClient _client;
        private readonly IMemoryCache _memoryCache;
        private readonly ISingleDataService _singleDataService;
        private readonly ILoginRepositories _loginRepositories;
        private readonly IBasicsRepositories _basicsRepositories;
        public ErpService(
            IMapper mapper,
            IOptions<ErpOptions> erpOptions,
            IOptions<AppOptions> appOptions,
            ILogger<ErpService> logger,
            IMemoryCache memoryCache,
            ISingleDataService singleDataService,
            ILoginRepositories loginRepositories, IBasicsRepositories basicsRepositories)
        {
            this._basicsRepositories = basicsRepositories;
            this._erpOptions = erpOptions?.Value;
            this._appOptions = appOptions?.Value;
            this._mapper = mapper;
            this._logger = logger;
            this._memoryCache = memoryCache;
            this._singleDataService = singleDataService;
            this._loginRepositories = loginRepositories;
        }

        /// <summary>
        /// 初始化ERP：登录到ERP
        /// </summary>
        /// <returns></returns>
        public async Task<Result<string>> Init()
        {
            BasicHttpBinding binding = new BasicHttpBinding();
            binding.MaxReceivedMessageSize = int.MaxValue;
            binding.SendTimeout = new TimeSpan(int.MaxValue);
            EndpointAddress address = new EndpointAddress(this._erpOptions.EndpointAddress);
            this._client = new ERPGWSoapClient(binding, address);
            try
            {
                var result = await this._client.ValidateSystemAsync(this._erpOptions.UserName, this._erpOptions.Password, this._erpOptions.ErpId, "");
                if (result == null)
                    return Result<string>.ReFailure(ResultCodes.Erp_Login_Error);
                return Result<string>.ReSuccess(result.AccessToken);
            }
            catch (Exception ex)
            {
                return Result<string>.ReFailure(ResultCodes.Erp_Login_Error);
            }
        }

        /// <summary>
        /// 查单据类型的值
        /// </summary>
        /// <returns></returns>
        public async Task<ResultList<ErpBaseDto>> BillQueryForBillType() 
        {
            try
            {
                //1.先登录金蝶-拿到token
                var token_result = await this.Init();
                if (!token_result.IsSuccess)
                    return ResultList<ErpBaseDto>.ReFailure(token_result);

                //2.时间条件：可能还有其它条件
                var beginTime = DateTime.Now.AddDays(-2).ToString("yyyy-MM-dd 00:00:00");
                var endTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
                //3.获取金蝶采购订单：拼接参数和条件
                var query = new ErpBillQueryDto(token_result.Data);
                var param = new ErpBillQueryParamDto("BOS_BillType");
                param.FieldKeys = "FBILLTYPEID,FNumber,FName";
                param.Limit = 10000;
                param.FilterString = "";               
                query.Data = JsonConvert.SerializeObject(param);
                var json = JsonConvert.SerializeObject(query);

                //4.请求查询接口
                var result_json = await _client.ExecuteBillQueryAsync(json);
                var result = JsonConvert.DeserializeObject<List<List<string>>>(result_json);

                //5.返回数据的组装
                var erp_list = new List<ErpBaseDto>();
                foreach (var item in result)
                {
                    var lis = new ErpBaseDto();
                    lis.Id = item[0];
                    lis.Number = item[1];
                    lis.Name =item[2];
                    
                    erp_list.Add(lis);
                }
                return ResultList<ErpBaseDto>.ReSuccess(erp_list);
            }
            catch (Exception ex)
            {
                return ResultList<ErpBaseDto>.ReFailure(ResultCodes.Erp_BillQuery_Error);
            }
        }

        /// <summary>
        /// erp:单据查询-采购入库单
        /// </summary>
        /// <param name="billNo">模糊搜索</param>
        /// <param name="sourceBillNos">单据编号集合精确查找</param>
        /// <returns></returns>
        public async Task<ResultList<ErpInStockResultDto>> BillQueryForPurchaseInStock(List<string> sourceBillNos = null)
        {
            try
            {

                var stocks = await _basicsRepositories.GetUcStockAsync(ManagementSystemCode.GLXT0004.ToString(), "", _appOptions.CompanyId);
                if (stocks.Count == 0)
                    return ResultList<ErpInStockResultDto>.ReFailure(ResultCodes.ErpStockNoData);
                var stocks_codes = stocks.Select(x => x.Code).ToList();


                //1.先登录金蝶-拿到token
                var token_result = await this.Init();
                if (!token_result.IsSuccess)
                    return ResultList<ErpInStockResultDto>.ReFailure(token_result);

                //2.时间条件：可能还有其它条件
                var beginTime = DateTime.Now.AddDays(-2).ToString("yyyy-MM-dd 00:00:00");
                var endTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
                //3.获取金蝶采购订单：拼接参数和条件
                var query = new ErpBillQueryDto(token_result.Data);
                var param = new ErpBillQueryParamDto(FormIdParam.PUR_PurchaseOrder.ToString());
                param.FieldKeys = "FBillNo,FSupplierId,FPurchaseOrgId,FMaterialId,FSOSTOCKID,FQty,FEntryNote,FCreateDate,FCHUCHANGPRICE,FSOSTOCKID.FNumber,FStockInQty";
                param.Limit = 10000;
                //查询条件：备注其中的条件值以金蝶的值为准！！！
                //1.创建时间在两天前和当天时间之间
                //2.审核状态：已审核
                //3.单据类型：标准采购订单和标准委外订单
                //4.明细关闭状态：正常
                //5.仓库：wms系统的仓库值---现在这个没有加，因为还单点没有和金蝶同步
                param.FilterString = " FDocumentStatus='C' and (FBillTypeID='83d822ca3e374b4ab01e5dd46a0062bd' or FBillTypeID='6d01d059713d42a28bb976c90a121142') and FMRPCloseStatus='A'";
                param.FilterString = param.FilterString + " and FSOSTOCKID.FNumber in (";

                var str = "";
                int index = 0;
                foreach (var scode in stocks_codes)
                {
                    index++;
                    if (index == stocks_codes.Count)
                        str = str + $"'{scode}'";
                    else
                        str = str + $"'{scode}'" + ",";
                }
                param.FilterString = param.FilterString + str + ")";

                //根据原订单号查询
                if (sourceBillNos != null && sourceBillNos.Count() > 0)
                {
                    param.FilterString = param.FilterString + " and FBillNo in (";

                    var bill_str = "";
                    int bill_index = 0;
                    //var srt_b = JsonConvert.SerializeObject(sourceBillNos);
                    foreach (var bill in sourceBillNos)
                    {
                        bill_index++;
                        if (bill_index == sourceBillNos.Count)
                            bill_str = bill_str + $"'{bill}'";
                        else
                            bill_str = bill_str + $"'{bill}'" + ",";
                    }
                    param.FilterString = param.FilterString + bill_str + ")";
                }//注意：当有单据编号的查询的时候，时间条件去掉；不然就查不到数据了
                else
                {
                    param.FilterString = param.FilterString + " and FCreateDate>='" + beginTime + "' and FCreateDate<='" + endTime + "'";
                }

                query.Data = JsonConvert.SerializeObject(param);
                var json = JsonConvert.SerializeObject(query);

                //4.请求查询接口
                var result_json = await _client.ExecuteBillQueryAsync(json);
                var result = JsonConvert.DeserializeObject<List<List<string>>>(result_json);

                //5.返回数据的组装
                var erp_list = new List<ErpInStockResultDto>();
                foreach (var item in result)
                {
                    var lis = new ErpInStockResultDto();
                    lis.BillNo = item[0];
                    lis.SupplierId = Convert.ToInt32(item[1]);
                    lis.OrgId = Convert.ToInt32(item[2]);
                    lis.MaterialId = Convert.ToInt32(item[3]);
                    lis.StockId = Convert.ToInt32(item[4]);
                    lis.Qty = Convert.ToDecimal(item[5]);
                    lis.Remark = item[6];
                    lis.CreateTime = Convert.ToDateTime(item[7]);
                    lis.FactoryPrice = Convert.ToDecimal(item[8]);
                    lis.StockCode = item[9];
                    lis.DeliveredQty = Convert.ToDecimal(item[10]);
                    lis.Type = (int)InstockType.Purchase;
                    erp_list.Add(lis);
                }
                return ResultList<ErpInStockResultDto>.ReSuccess(erp_list);
            }
            catch (Exception ex)
            {
                return ResultList<ErpInStockResultDto>.ReFailure(ResultCodes.Erp_BillQuery_Error);
            }
        }

        /// <summary>
        /// erp:单据查询-其他入库单
        /// </summary>
        /// <param name="sourceBillNos"></param>
        /// <returns></returns>
        public async Task<ResultList<ErpInStockResultDto>> BillQueryForMiscellaneous(List<string> sourceBillNos = null)
        {
            try
            {

                var stocks = await _basicsRepositories.GetUcStockAsync(ManagementSystemCode.GLXT0004.ToString(), "", _appOptions.CompanyId);
                if (stocks.Count == 0)
                    return ResultList<ErpInStockResultDto>.ReFailure(ResultCodes.ErpStockNoData);
                var stocks_codes = stocks.Select(x => x.Code).ToList();


                //1.先登录金蝶-拿到token
                var token_result = await this.Init();
                if (!token_result.IsSuccess)
                    return ResultList<ErpInStockResultDto>.ReFailure(token_result);

                //2.时间条件：可能还有其它条件
                var beginTime = DateTime.Now.AddDays(-2).ToString("yyyy-MM-dd 00:00:00");
                var endTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
                //3.获取金蝶其他入库订单：拼接参数和条件
                var query = new ErpBillQueryDto(token_result.Data);
                var param = new ErpBillQueryParamDto(FormIdParam.STK_MISCELLANEOUS.ToString());
                param.FieldKeys = "FBillNo,FStockOrgId,FMATERIALID,FSTOCKID,FSTOCKID.FNumber,FQty,FCreateDate,FEntryNote";
                param.Limit = 10000;
                //查询条件：备注其中的条件值以金蝶的值为准！！！
                //1.创建时间在两天前和当天时间之间
                //2.审核状态：已审核
                //3.单据类型：标准其他入库单；这里要注意了-----------测试端的“单据类型ID”和线上的可能不一样；上线的时候要核对下
                //5.仓库：wms系统的仓库值---现在这个没有加，因为还单点没有和金蝶同步
                param.FilterString = " FDocumentStatus='C' and FBillTypeID='d772ead981e748d69dda1caac7583f8c'";//
                param.FilterString = param.FilterString + " and FSTOCKID.FNumber in (";

                var str = "";
                int index = 0;
                foreach (var scode in stocks_codes)
                {
                    index++;
                    if (index == stocks_codes.Count)
                        str = str + $"'{scode}'";
                    else
                        str = str + $"'{scode}'" + ",";
                }
                param.FilterString = param.FilterString + str + ")";

                //根据原订单号查询
                if (sourceBillNos != null && sourceBillNos.Count() > 0)
                {
                    param.FilterString = param.FilterString + " and FBillNo in (";

                    var bill_str = "";
                    int bill_index = 0;
                    //var srt_b = JsonConvert.SerializeObject(sourceBillNos);
                    foreach (var bill in sourceBillNos)
                    {
                        bill_index++;
                        if (bill_index == sourceBillNos.Count)
                            bill_str = bill_str + $"'{bill}'";
                        else
                            bill_str = bill_str + $"'{bill}'" + ",";
                    }
                    param.FilterString = param.FilterString + bill_str + ")";
                }//注意：当有单据编号的查询的时候，时间条件去掉；不然就查不到数据了
                else
                {
                    param.FilterString = param.FilterString + " and FCreateDate>='" + beginTime + "' and FCreateDate<='" + endTime + "'";
                }

                query.Data = JsonConvert.SerializeObject(param);
                var json = JsonConvert.SerializeObject(query);

                //4.请求查询接口
                var result_json = await _client.ExecuteBillQueryAsync(json);
                var result = JsonConvert.DeserializeObject<List<List<string>>>(result_json);

                //5.返回数据的组装
                var erp_list = new List<ErpInStockResultDto>();
                foreach (var item in result)
                {
                    var lis = new ErpInStockResultDto();
                    lis.BillNo = item[0];
                    lis.OrgId = Convert.ToInt32(item[1]);
                    lis.MaterialId = Convert.ToInt32(item[2]);
                    lis.StockId = Convert.ToInt32(item[3]);
                    lis.StockCode = item[4];
                    lis.Qty = Convert.ToDecimal(item[5]);
                    lis.CreateTime = Convert.ToDateTime(item[6]);
                    lis.Remark = item[7];
                    lis.Type = (int)InstockType.Miscellaneous;
                    erp_list.Add(lis);
                }
                return ResultList<ErpInStockResultDto>.ReSuccess(erp_list);
            }
            catch (Exception ex)
            {
                return ResultList<ErpInStockResultDto>.ReFailure(ResultCodes.Erp_BillQuery_Error);
            }
        }

        /// <summary>
        /// erp:单据查询-直接调拨入库单
        /// </summary>
        /// <param name="sourceBillNos"></param>
        /// <returns></returns>
        public async Task<ResultList<ErpInStockResultDto>> BillQueryForTransferDirect(List<string> sourceBillNos = null) 
        {
            try
            {

                var stocks = await _basicsRepositories.GetUcStockAsync(ManagementSystemCode.GLXT0004.ToString(), "", _appOptions.CompanyId);
                if (stocks.Count == 0)
                    return ResultList<ErpInStockResultDto>.ReFailure(ResultCodes.ErpStockNoData);
                var stocks_codes = stocks.Select(x => x.Code).ToList();


                //1.先登录金蝶-拿到token
                var token_result = await this.Init();
                if (!token_result.IsSuccess)
                    return ResultList<ErpInStockResultDto>.ReFailure(token_result);

                //2.时间条件：可能还有其它条件
                var beginTime = DateTime.Now.AddDays(-2).ToString("yyyy-MM-dd 00:00:00");
                var endTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
                //3.获取金蝶直接调拨入库订单：拼接参数和条件
                var query = new ErpBillQueryDto(token_result.Data);
                var param = new ErpBillQueryParamDto(FormIdParam.STK_TransferDirect.ToString());
                param.FieldKeys = "FBillNo,FStockOrgId,FMaterialId,FDestStockId,FDestStockId.FNumber,FQty,FCreateDate,FNoteEntry";
                param.Limit = 10000;
                //查询条件：备注其中的条件值以金蝶的值为准！！！
                //1.创建时间在两天前和当天时间之间
                //2.审核状态：已审核
                //3.单据类型：标准直接调拨单；这里要注意了-----------测试端的“单据类型ID”和线上的可能不一样；上线的时候要核对下
                //5.仓库：wms系统的仓库值---现在这个没有加，因为还单点没有和金蝶同步
                param.FilterString = " FDocumentStatus='C' and FBillTypeID='ce8f49055c5c4782b65463a3f863bb4a'";//
                param.FilterString = param.FilterString + " and FDestStockId.FNumber in (";

                var str = "";
                int index = 0;
                foreach (var scode in stocks_codes)
                {
                    index++;
                    if (index == stocks_codes.Count)
                        str = str + $"'{scode}'";
                    else
                        str = str + $"'{scode}'" + ",";
                }
                param.FilterString = param.FilterString + str + ")";

                //根据原订单号查询
                if (sourceBillNos != null && sourceBillNos.Count() > 0)
                {
                    param.FilterString = param.FilterString + " and FBillNo in (";

                    var bill_str = "";
                    int bill_index = 0;
                    //var srt_b = JsonConvert.SerializeObject(sourceBillNos);
                    foreach (var bill in sourceBillNos)
                    {
                        bill_index++;
                        if (bill_index == sourceBillNos.Count)
                            bill_str = bill_str + $"'{bill}'";
                        else
                            bill_str = bill_str + $"'{bill}'" + ",";
                    }
                    param.FilterString = param.FilterString + bill_str + ")";
                }//注意：当有单据编号的查询的时候，时间条件去掉；不然就查不到数据了
                else
                {
                    param.FilterString = param.FilterString + " and FCreateDate>='" + beginTime + "' and FCreateDate<='" + endTime + "'";
                }

                query.Data = JsonConvert.SerializeObject(param);
                var json = JsonConvert.SerializeObject(query);

                //4.请求查询接口
                var result_json = await _client.ExecuteBillQueryAsync(json);
                var result = JsonConvert.DeserializeObject<List<List<string>>>(result_json);

                //5.返回数据的组装
                var erp_list = new List<ErpInStockResultDto>();
                foreach (var item in result)
                {
                    var lis = new ErpInStockResultDto();
                    lis.BillNo = item[0];
                    lis.OrgId = Convert.ToInt32(item[1]);
                    lis.MaterialId = Convert.ToInt32(item[2]);
                    lis.StockId = Convert.ToInt32(item[3]);
                    lis.StockCode = item[4];
                    lis.Qty = Convert.ToDecimal(item[5]);
                    lis.CreateTime = Convert.ToDateTime(item[6]);
                    lis.Remark = item[7];
                    lis.Type = (int)InstockType.Stkdirecttransfers;
                    erp_list.Add(lis);
                }
                return ResultList<ErpInStockResultDto>.ReSuccess(erp_list);
            }
            catch (Exception ex)
            {
                return ResultList<ErpInStockResultDto>.ReFailure(ResultCodes.Erp_BillQuery_Error);
            }
        }

        /// <summary>
        /// erp:单据查询-分步式调入单
        /// </summary>
        /// <param name="sourceBillNos"></param>
        /// <returns></returns>
        public async Task<ResultList<ErpInStockResultDto>> BillQueryForTransferin(List<string> sourceBillNos = null) 
        {
            try
            {

                var stocks = await _basicsRepositories.GetUcStockAsync(ManagementSystemCode.GLXT0004.ToString(), "", _appOptions.CompanyId);
                if (stocks.Count == 0)
                    return ResultList<ErpInStockResultDto>.ReFailure(ResultCodes.ErpStockNoData);
                var stocks_codes = stocks.Select(x => x.Code).ToList();


                //1.先登录金蝶-拿到token
                var token_result = await this.Init();
                if (!token_result.IsSuccess)
                    return ResultList<ErpInStockResultDto>.ReFailure(token_result);

                //2.时间条件：可能还有其它条件
                var beginTime = DateTime.Now.AddDays(-2).ToString("yyyy-MM-dd 00:00:00");
                var endTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
                //3.获取金蝶分步式入库订单：拼接参数和条件
                var query = new ErpBillQueryDto(token_result.Data);
                var param = new ErpBillQueryParamDto(FormIdParam.STK_TRANSFERIN.ToString());
                param.FieldKeys = "FBillNo,FStockOrgID,FMaterialID,FDestStockID,FDestStockID.FNumber,FQty,FCreateDate,FEntryNote";
                param.Limit = 10000;
                //查询条件：备注其中的条件值以金蝶的值为准！！！
                //1.创建时间在两天前和当天时间之间
                //2.审核状态：已审核
                //3.单据类型：标准分步式调入单；这里要注意了-----------测试端的“单据类型ID”和线上的可能不一样；上线的时候要核对下
                //5.仓库：wms系统的仓库值---现在这个没有加，因为还单点没有和金蝶同步
                param.FilterString = " FDocumentStatus='C' and FBillTypeID='e65a4f29743a44b7b67dc8145e1f9c92'";//
                param.FilterString = param.FilterString + " and FDestStockID.FNumber in (";

                var str = "";
                int index = 0;
                foreach (var scode in stocks_codes)
                {
                    index++;
                    if (index == stocks_codes.Count)
                        str = str + $"'{scode}'";
                    else
                        str = str + $"'{scode}'" + ",";
                }
                param.FilterString = param.FilterString + str + ")";

                //根据原订单号查询
                if (sourceBillNos != null && sourceBillNos.Count() > 0)
                {
                    param.FilterString = param.FilterString + " and FBillNo in (";

                    var bill_str = "";
                    int bill_index = 0;
                    //var srt_b = JsonConvert.SerializeObject(sourceBillNos);
                    foreach (var bill in sourceBillNos)
                    {
                        bill_index++;
                        if (bill_index == sourceBillNos.Count)
                            bill_str = bill_str + $"'{bill}'";
                        else
                            bill_str = bill_str + $"'{bill}'" + ",";
                    }
                    param.FilterString = param.FilterString + bill_str + ")";
                }//注意：当有单据编号的查询的时候，时间条件去掉；不然就查不到数据了
                else
                {
                    param.FilterString = param.FilterString + " and FCreateDate>='" + beginTime + "' and FCreateDate<='" + endTime + "'";
                }

                query.Data = JsonConvert.SerializeObject(param);
                var json = JsonConvert.SerializeObject(query);

                //4.请求查询接口
                var result_json = await _client.ExecuteBillQueryAsync(json);
                var result = JsonConvert.DeserializeObject<List<List<string>>>(result_json);

                //5.返回数据的组装
                var erp_list = new List<ErpInStockResultDto>();
                foreach (var item in result)
                {
                    var lis = new ErpInStockResultDto();
                    lis.BillNo = item[0];
                    lis.OrgId = Convert.ToInt32(item[1]);
                    lis.MaterialId = Convert.ToInt32(item[2]);
                    lis.StockId = Convert.ToInt32(item[3]);
                    lis.StockCode = item[4];
                    lis.Qty = Convert.ToDecimal(item[5]);
                    lis.CreateTime = Convert.ToDateTime(item[6]);
                    lis.Remark = item[7];
                    lis.Type = (int)InstockType.StktransferInst;
                    erp_list.Add(lis);
                }
                return ResultList<ErpInStockResultDto>.ReSuccess(erp_list);
            }
            catch (Exception ex)
            {
                return ResultList<ErpInStockResultDto>.ReFailure(ResultCodes.Erp_BillQuery_Error);
            }
        }

        /// <summary>
        /// erp:单据查询-组装拆卸单-组装（成品入库）
        /// </summary>
        /// <param name="sourceBillNos"></param>
        /// <returns></returns>
        public async Task<ResultList<ErpInStockResultDto>> BillQueryForAssembledApp_Assembly(List<string> sourceBillNos = null) 
        {
            try
            {

                var stocks = await _basicsRepositories.GetUcStockAsync(ManagementSystemCode.GLXT0004.ToString(), "", _appOptions.CompanyId);
                if (stocks.Count == 0)
                    return ResultList<ErpInStockResultDto>.ReFailure(ResultCodes.ErpStockNoData);
                var stocks_codes = stocks.Select(x => x.Code).ToList();


                //1.先登录金蝶-拿到token
                var token_result = await this.Init();
                if (!token_result.IsSuccess)
                    return ResultList<ErpInStockResultDto>.ReFailure(token_result);

                //2.时间条件：可能还有其它条件
                var beginTime = DateTime.Now.AddDays(-2).ToString("yyyy-MM-dd 00:00:00");
                var endTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
                //3.获取金蝶分步式入库订单：拼接参数和条件
                var query = new ErpBillQueryDto(token_result.Data);
                var param = new ErpBillQueryParamDto(FormIdParam.STK_AssembledApp.ToString());
                param.FieldKeys = "FBillNo,FOwnerIdHead,FMaterialID,FStockID,FStockID.FNumber,FQty,FCreateDate,FDescription";
                param.Limit = 10000;
                //查询条件：备注其中的条件值以金蝶的值为准！！！
                //1.创建时间在两天前和当天时间之间
                //2.审核状态：已审核
                //3.单据类型：标准组织拆卸单；备注：这里的单据类型只有一个，所以就不需要判断了
                //4.事务类型：1为组装，2为拆卸
                //5.仓库：wms系统的仓库值---现在这个没有加，因为还单点没有和金蝶同步
                param.FilterString = " FDocumentStatus='C' and FOwnerTypeIdHead=1";//
                param.FilterString = param.FilterString + " and FStockID.FNumber in (";

                var str = "";
                int index = 0;
                foreach (var scode in stocks_codes)
                {
                    index++;
                    if (index == stocks_codes.Count)
                        str = str + $"'{scode}'";
                    else
                        str = str + $"'{scode}'" + ",";
                }
                param.FilterString = param.FilterString + str + ")";

                //根据原订单号查询
                if (sourceBillNos != null && sourceBillNos.Count() > 0)
                {
                    param.FilterString = param.FilterString + " and FBillNo in (";

                    var bill_str = "";
                    int bill_index = 0;
                    //var srt_b = JsonConvert.SerializeObject(sourceBillNos);
                    foreach (var bill in sourceBillNos)
                    {
                        bill_index++;
                        if (bill_index == sourceBillNos.Count)
                            bill_str = bill_str + $"'{bill}'";
                        else
                            bill_str = bill_str + $"'{bill}'" + ",";
                    }
                    param.FilterString = param.FilterString + bill_str + ")";
                }//注意：当有单据编号的查询的时候，时间条件去掉；不然就查不到数据了
                else
                {
                    param.FilterString = param.FilterString + " and FCreateDate>='" + beginTime + "' and FCreateDate<='" + endTime + "'";
                }

                query.Data = JsonConvert.SerializeObject(param);
                var json = JsonConvert.SerializeObject(query);

                //4.请求查询接口
                var result_json = await _client.ExecuteBillQueryAsync(json);
                var result = JsonConvert.DeserializeObject<List<List<string>>>(result_json);

                //5.返回数据的组装
                var erp_list = new List<ErpInStockResultDto>();
                foreach (var item in result)
                {
                    var lis = new ErpInStockResultDto();
                    lis.BillNo = item[0];
                    lis.OrgId = Convert.ToInt32(item[1]);
                    lis.MaterialId = Convert.ToInt32(item[2]);
                    lis.StockId = Convert.ToInt32(item[3]);
                    lis.StockCode = item[4];
                    lis.Qty = Convert.ToDecimal(item[5]);
                    lis.CreateTime = Convert.ToDateTime(item[6]);
                    lis.Remark = item[7];
                    lis.Type = (int)InstockType.Assembled;
                    erp_list.Add(lis);
                }
                return ResultList<ErpInStockResultDto>.ReSuccess(erp_list);
            }
            catch (Exception ex)
            {
                return ResultList<ErpInStockResultDto>.ReFailure(ResultCodes.Erp_BillQuery_Error);
            }
        }

        /// <summary>
        /// erp:单据查询-组装拆卸单-拆卸（子件入库）
        /// </summary>
        /// <param name="sourceBillNos"></param>
        /// <returns></returns>
        public async Task<ResultList<ErpInStockResultDto>> BillQueryForAssembledApp_Disassembly(List<string> sourceBillNos = null)
        {
            try
            {

                var stocks = await _basicsRepositories.GetUcStockAsync(ManagementSystemCode.GLXT0004.ToString(), "", _appOptions.CompanyId);
                if (stocks.Count == 0)
                    return ResultList<ErpInStockResultDto>.ReFailure(ResultCodes.ErpStockNoData);
                var stocks_codes = stocks.Select(x => x.Code).ToList();


                //1.先登录金蝶-拿到token
                var token_result = await this.Init();
                if (!token_result.IsSuccess)
                    return ResultList<ErpInStockResultDto>.ReFailure(token_result);

                //2.时间条件：可能还有其它条件
                var beginTime = DateTime.Now.AddDays(-2).ToString("yyyy-MM-dd 00:00:00");
                var endTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
                //3.获取金蝶分步式入库订单：拼接参数和条件
                var query = new ErpBillQueryDto(token_result.Data);
                var param = new ErpBillQueryParamDto(FormIdParam.STK_AssembledApp.ToString());
                param.FieldKeys = "FBillNo,FSubProOwnerIdH,FMaterialID,FStockIDSETY,FStockIDSETY.FNumber,FQtySETY,FCreateDate,FDescriptionSETY";
                param.Limit = 10000;
                //查询条件：备注其中的条件值以金蝶的值为准！！！
                //1.创建时间在两天前和当天时间之间
                //2.审核状态：已审核
                //3.单据类型：标准组织拆卸单；备注：这里的单据类型只有一个，所以就不需要判断了
                //4.事务类型：1为组装，2为拆卸
                //5.仓库：wms系统的仓库值---现在这个没有加，因为还单点没有和金蝶同步
                param.FilterString = " FDocumentStatus='C' and FOwnerTypeIdHead=2";//
                param.FilterString = param.FilterString + " and FStockIDSETY.FNumber in (";

                var str = "";
                int index = 0;
                foreach (var scode in stocks_codes)
                {
                    index++;
                    if (index == stocks_codes.Count)
                        str = str + $"'{scode}'";
                    else
                        str = str + $"'{scode}'" + ",";
                }
                param.FilterString = param.FilterString + str + ")";

                //根据原订单号查询
                if (sourceBillNos != null && sourceBillNos.Count() > 0)
                {
                    param.FilterString = param.FilterString + " and FBillNo in (";

                    var bill_str = "";
                    int bill_index = 0;
                    //var srt_b = JsonConvert.SerializeObject(sourceBillNos);
                    foreach (var bill in sourceBillNos)
                    {
                        bill_index++;
                        if (bill_index == sourceBillNos.Count)
                            bill_str = bill_str + $"'{bill}'";
                        else
                            bill_str = bill_str + $"'{bill}'" + ",";
                    }
                    param.FilterString = param.FilterString + bill_str + ")";
                }//注意：当有单据编号的查询的时候，时间条件去掉；不然就查不到数据了
                else
                {
                    param.FilterString = param.FilterString + " and FCreateDate>='" + beginTime + "' and FCreateDate<='" + endTime + "'";
                }

                query.Data = JsonConvert.SerializeObject(param);
                var json = JsonConvert.SerializeObject(query);

                //4.请求查询接口
                var result_json = await _client.ExecuteBillQueryAsync(json);
                var result = JsonConvert.DeserializeObject<List<List<string>>>(result_json);

                //5.返回数据的组装
                var erp_list = new List<ErpInStockResultDto>();
                foreach (var item in result)
                {
                    var lis = new ErpInStockResultDto();
                    lis.BillNo = item[0];
                    lis.OrgId = Convert.ToInt32(item[1]);
                    lis.MaterialId = Convert.ToInt32(item[2]);
                    lis.StockId = Convert.ToInt32(item[3]);
                    lis.StockCode = item[4];
                    lis.Qty = Convert.ToDecimal(item[5]);
                    lis.CreateTime = Convert.ToDateTime(item[6]);
                    lis.Remark = item[7];
                    lis.Type = (int)InstockType.Assembled;
                    erp_list.Add(lis);
                }
                return ResultList<ErpInStockResultDto>.ReSuccess(erp_list);
            }
            catch (Exception ex)
            {
                return ResultList<ErpInStockResultDto>.ReFailure(ResultCodes.Erp_BillQuery_Error);
            }
        }

        /// <summary>
        /// erp:单据查询-物料
        /// </summary>
        /// <returns></returns>
        public async Task<ResultList<ErpMaterialDto>> BillQueryForMaterial()
        {
            try
            {
                //1.获取缓存中的物料数据；
                var cache_key = "erp_materials_list";
                var materials = _memoryCache.Get<List<ErpMaterialDto>>(cache_key);
                if (materials == null || materials.Count == 0)
                {
                    //2.先登录金蝶-拿到token
                    var token_result = await this.Init();
                    if (!token_result.IsSuccess)
                        return ResultList<ErpMaterialDto>.ReFailure(token_result);

                    //3.获取金蝶物料：拼接参数和条件
                    var query = new ErpBillQueryDto(token_result.Data);
                    var param = new ErpBillQueryParamDto(FormIdParam.BD_MATERIAL.ToString());
                    param.FieldKeys = "FMATERIALID,FName,FNumber,FSpecification,FBaseUnitId,FBaseUnitId.FName";
                    param.Limit = 10000;

                    //查询条件：备注其中的条件值以金蝶的值为准！！！
                    //1.审核状态：已审核
                    //2.禁用状态：A否，B是
                    //3.使用组织：只查询“深圳市元创时代科技有限公司”这个组织；组织ID=100008--固定值查询（测试端和正式是一样的）
                    param.FilterString = "FDocumentStatus='C' and FForbidStatus='A' and FUseOrgId=100008";
                    param.OrderString = "FCreateDate ASC";

                    //4.循环拿金蝶数据
                    bool isHave = true;
                    var erp_materials_list = new List<ErpMaterialDto>();
                    int skip = 0;
                    var beginTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff");
                    _logger.LogInformation($"物料拉取-开始时间：{beginTime}");
                    while (isHave)
                    {
                        //4.1.页码：页码按照金蝶的要求从0开始
                        param.StartRow = (Convert.ToInt32(skip) * param.Limit);
                        //4.2.参数json化
                        query.Data = JsonConvert.SerializeObject(param);
                        var json = JsonConvert.SerializeObject(query);

                        //4.3.请求查询接口并返回数据
                        var result_json = await _client.ExecuteBillQueryAsync(json);
                        var result = JsonConvert.DeserializeObject<List<List<string>>>(result_json);
                        //4.4.判断数据是否全部拉取完成：并停止循环的条件
                        if (result == null || result.Count == 0)
                            isHave = false;
                        //4.5.拼装
                        foreach (var item in result)
                        {
                            var lis = new ErpMaterialDto();
                            lis.MaterialId = Convert.ToInt32(item[0]);
                            lis.MaterialName = item[1];
                            lis.MaterialNumber = item[2];
                            lis.Specifications = item[3];
                            lis.BaseUnitId = Convert.ToInt32(item[4]);
                            lis.BaseUnitName = item[5];
                            erp_materials_list.Add(lis);
                        }
                        //4.6页面的叠加
                        skip++;
                    }
                    var endTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff");
                    _logger.LogInformation($"物料拉取-结束时间：{endTime}");
                    //5.物料集合进行缓存
                    _memoryCache.Set(cache_key, erp_materials_list, new MemoryCacheEntryOptions().SetAbsoluteExpiration(TimeSpan.FromHours(12)));
                    _logger.LogInformation($"物料拉取-总条数：{erp_materials_list.Count}");
                    return ResultList<ErpMaterialDto>.ReSuccess(erp_materials_list);
                }
                else
                {
                    return ResultList<ErpMaterialDto>.ReSuccess(materials);
                }
            }
            catch (Exception)
            {

                return ResultList<ErpMaterialDto>.ReFailure(ResultCodes.ErpMaterialError);
            }


        }

        /// <summary>
        /// erp:单据查询-组织数据
        /// </summary>
        /// <returns></returns>
        public async Task<ResultList<ErpOrgDto>> BillQueryForOrg()
        {
            try
            {
                //1.获取缓存中的组织数据；
                var cache_key = "erp_org_list";
                var orgs = _memoryCache.Get<List<ErpOrgDto>>(cache_key);
                if (orgs == null || orgs.Count == 0)
                {

                    //2.先登录金蝶-拿到token
                    var token_result = await this.Init();
                    if (!token_result.IsSuccess)
                        return ResultList<ErpOrgDto>.ReFailure(token_result);

                    //3.获取金蝶组织：拼接参数和条件
                    var query = new ErpBillQueryDto(token_result.Data);
                    var param = new ErpBillQueryParamDto(FormIdParam.ORG_Organizations.ToString());
                    param.FieldKeys = "FOrgID,FNumber,FName";
                    param.Limit = 10000;
                    //查询条件：备注其中的条件值以金蝶的值为准！！！
                    param.FilterString = "";

                    //备注：因为组织数据不是很多，就不能和获取物料一样循环获取；组织这里就获取10000条数据就行了
                    var beginTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff");
                    _logger.LogInformation($"组织拉取-开始时间：{beginTime}");
                    //4.参数json化
                    query.Data = JsonConvert.SerializeObject(param);
                    var json = JsonConvert.SerializeObject(query);

                    //5.请求查询接口并返回数据
                    var result_json = await _client.ExecuteBillQueryAsync(json);
                    var result = JsonConvert.DeserializeObject<List<List<string>>>(result_json);

                    var endTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff");
                    _logger.LogInformation($"组织拉取-结束时间：{endTime}");
                    //6.拼装
                    var list = new List<ErpOrgDto>();
                    foreach (var item in result)
                    {
                        var lis = new ErpOrgDto();
                        lis.Id = int.Parse(item[0]);
                        lis.Number = item[1];
                        lis.Name = item[2];
                        list.Add(lis);

                    }
                    //5.组织集合进行缓存
                    _memoryCache.Set(cache_key, list, new MemoryCacheEntryOptions().SetAbsoluteExpiration(TimeSpan.FromHours(12)));
                    _logger.LogInformation($"组织拉取-总条数：{list.Count}");
                    return ResultList<ErpOrgDto>.ReSuccess(list);

                }
                else
                {
                    return ResultList<ErpOrgDto>.ReSuccess(orgs);
                }

            }
            catch (Exception)
            {
                return ResultList<ErpOrgDto>.ReFailure(ResultCodes.ErpOrgError);
            }
        }

        /// <summary>
        /// erp:供应商
        /// </summary>
        /// <returns></returns>
        public async Task<ResultList<ErpSupplierDto>> BillQueryForSupplier()
        {
            try
            {
                //1.获取缓存中的供应商数据；
                var cache_key = "erp_supplier_list";
                var suppliers = _memoryCache.Get<List<ErpSupplierDto>>(cache_key);
                if (suppliers == null || suppliers.Count == 0)
                {

                    //2.先登录金蝶-拿到token
                    var token_result = await this.Init();
                    if (!token_result.IsSuccess)
                        return ResultList<ErpSupplierDto>.ReFailure(token_result);

                    //3.获取金蝶供应商：拼接参数和条件
                    var query = new ErpBillQueryDto(token_result.Data);
                    var param = new ErpBillQueryParamDto(FormIdParam.BD_Supplier.ToString());
                    param.FieldKeys = "FSupplierId,FNumber,FName";
                    param.Limit = 10000;
                    //查询条件：备注其中的条件值以金蝶的值为准！！！
                    param.FilterString = "";

                    //备注：因为供应商数据不是很多，就不能和获取物料一样循环获取；组织这里就获取10000条数据就行了
                    var beginTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff");
                    _logger.LogInformation($"供应商拉取-开始时间：{beginTime}");
                    //4.参数json化
                    query.Data = JsonConvert.SerializeObject(param);
                    var json = JsonConvert.SerializeObject(query);

                    //5.请求查询接口并返回数据
                    var result_json = await _client.ExecuteBillQueryAsync(json);
                    var result = JsonConvert.DeserializeObject<List<List<string>>>(result_json);

                    var endTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff");
                    _logger.LogInformation($"供应商拉取-结束时间：{endTime}");
                    //6.拼装
                    var list = new List<ErpSupplierDto>();
                    foreach (var item in result)
                    {
                        var lis = new ErpSupplierDto();
                        lis.Id = int.Parse(item[0]);
                        lis.Number = item[1];
                        lis.Name = item[2];
                        list.Add(lis);

                    }
                    //5.供应商集合进行缓存
                    _memoryCache.Set(cache_key, list, new MemoryCacheEntryOptions().SetAbsoluteExpiration(TimeSpan.FromHours(12)));
                    _logger.LogInformation($"供应商拉取-总条数：{list.Count}");
                    return ResultList<ErpSupplierDto>.ReSuccess(list);

                }
                else
                {
                    return ResultList<ErpSupplierDto>.ReSuccess(suppliers);
                }

            }
            catch (Exception)
            {
                return ResultList<ErpSupplierDto>.ReFailure(ResultCodes.ErpSupplierError);
            }
        }
        /// <summary>
        /// 客户
        /// </summary>
        /// <returns></returns>
        public async Task<ResultList<ErpCustomerDto>> BillQueryForCustomer()
        {
            try
            {
                //1.获取缓存中的供应商数据；
                var cache_key = "erp_customer_list";
                var customers = _memoryCache.Get<List<ErpCustomerDto>>(cache_key);
                if (customers == null || customers.Count == 0)
                {

                    //2.先登录金蝶-拿到token
                    var token_result = await this.Init();
                    if (!token_result.IsSuccess)
                        return ResultList<ErpCustomerDto>.ReFailure(token_result);

                    //3.获取金蝶供应商：拼接参数和条件
                    var query = new ErpBillQueryDto(token_result.Data);
                    var param = new ErpBillQueryParamDto(FormIdParam.BD_Customer.ToString());
                    param.FieldKeys = "FCUSTID,FNumber,FName";
                    param.Limit = 10000;
                    //查询条件：备注其中的条件值以金蝶的值为准！！！
                    param.FilterString = "";

                    //备注：因为供应商数据不是很多，就不能和获取物料一样循环获取；组织这里就获取10000条数据就行了
                    var beginTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff");
                    _logger.LogInformation($"供应商拉取-开始时间：{beginTime}");
                    //4.参数json化
                    query.Data = JsonConvert.SerializeObject(param);
                    var json = JsonConvert.SerializeObject(query);

                    //5.请求查询接口并返回数据
                    var result_json = await _client.ExecuteBillQueryAsync(json);
                    var result = JsonConvert.DeserializeObject<List<List<string>>>(result_json);

                    var endTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff");
                    _logger.LogInformation($"供应商拉取-结束时间：{endTime}");
                    //6.拼装
                    var list = new List<ErpCustomerDto>();
                    foreach (var item in result)
                    {
                        var lis = new ErpCustomerDto();
                        lis.Id = int.Parse(item[0]);
                        lis.Number = item[1];
                        lis.Name = item[2];
                        list.Add(lis);

                    }
                    //5.供应商集合进行缓存
                    _memoryCache.Set(cache_key, list, new MemoryCacheEntryOptions().SetAbsoluteExpiration(TimeSpan.FromHours(12)));
                    _logger.LogInformation($"供应商拉取-总条数：{list.Count}");
                    return ResultList<ErpCustomerDto>.ReSuccess(list);

                }
                else
                {
                    return ResultList<ErpCustomerDto>.ReSuccess(customers);
                }

            }
            catch (Exception)
            {
                return ResultList<ErpCustomerDto>.ReFailure(ResultCodes.ErpSupplierError);
            }
        }
        /// <summary>
        /// erp:仓库
        /// </summary>
        /// <returns></returns>
        public async Task<ResultList<ErpStockDto>> BillQueryForStock()
        {
            try
            {
                //1.获取缓存中的仓库数据；
                var cache_key = "erp_supplier_list";
                var stocks = _memoryCache.Get<List<ErpStockDto>>(cache_key);
                if (stocks == null || stocks.Count == 0)
                {
                    //2.先登录金蝶-拿到token
                    var token_result = await this.Init();
                    if (!token_result.IsSuccess)
                        return ResultList<ErpStockDto>.ReFailure(token_result);
                    //3.获取金蝶仓库：拼接参数和条件
                    var query = new ErpBillQueryDto(token_result.Data);
                    var param = new ErpBillQueryParamDto(FormIdParam.BD_STOCK.ToString());
                    param.FieldKeys = "FStockId,FName,FNumber,FUseOrgId";
                    param.Limit = 10000;
                    //查询条件：备注其中的条件值以金蝶的值为准！！！
                    param.FilterString = "";
                    //备注：因为供应商数据不是很多，就不能和获取物料一样循环获取；组织这里就获取10000条数据就行了
                    var beginTime = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss.fff");
                    _logger.LogInformation($"仓库拉取-开始时间：{beginTime}");
                    //4.参数json化
                    query.Data = JsonConvert.SerializeObject(param);
                    var json = JsonConvert.SerializeObject(query);
                    //5.请求查询接口并返回数据
                    var result_json = await _client.ExecuteBillQueryAsync(json);
                    var result = JsonConvert.DeserializeObject<List<List<string>>>(result_json);
                    //6.拼装
                    var list = new List<ErpStockDto>();
                    foreach (var item in result)
                    {
                        var lis = new ErpStockDto();
                        lis.Id = int.Parse(item[0]);
                        lis.Name = item[1];
                        lis.Code = item[2];
                        lis.OrgId = Convert.ToInt32(item[3]);
                        list.Add(lis);

                    }
                    //5.供应商集合进行缓存
                    _memoryCache.Set(cache_key, list, new MemoryCacheEntryOptions().SetAbsoluteExpiration(TimeSpan.FromHours(12)));
                    _logger.LogInformation($"仓库拉取-总条数：{list.Count}");
                    return ResultList<ErpStockDto>.ReSuccess(list);
                }
                else
                {
                    return ResultList<ErpStockDto>.ReSuccess(stocks);
                }

            }
            catch (Exception)
            {
                return ResultList<ErpStockDto>.ReFailure(ResultCodes.ErpStockError);
            }
        }
        /// <summary>
        /// 根据仓库编码获取仓位
        /// </summary>
        /// <param name="code"></param>
        /// <returns></returns>
        public async Task<ResultList<ErpStockDto>> BillQueryForSubStock(string code = null)
        {
            try
            {
                //1.获取缓存中的仓库数据；
                var cache_key = "erp_substock_list";
                var stocks = _memoryCache.Get<List<ErpStockDto>>(cache_key);
                if (stocks == null || stocks.Count == 0)
                {
                    var token_result = await this.Init();
                    if (!token_result.IsSuccess)
                        return ResultList<ErpStockDto>.ReFailure(token_result);
                    var query = new ErpBillQueryDto(token_result.Data);
                    var param = new ErpBillQueryParamDto(FormIdParam.BD_STOCK.ToString());
                    param.FieldKeys = "FStockFlexDetail_FDetailID,FFlexEntryName,FFlexEntryId,'0'";
                    param.Limit = 100000;
                    if (!string.IsNullOrEmpty(code))
                        param.FilterString = "FNumber='" + code + "'";//FNumber='C'
                    query.Data = JsonConvert.SerializeObject(param);
                    var json = JsonConvert.SerializeObject(query);

                    var result_json = await _client.ExecuteBillQueryAsync(json);
                    var result = JsonConvert.DeserializeObject<List<List<string>>>(result_json);

                    var list = new List<ErpStockDto>();
                    foreach (var item in result)
                    {
                        var lis = new ErpStockDto();
                        lis.Id = int.Parse(item[0]);
                        lis.Name = item[1];
                        lis.Code = item[2];
                        lis.OrgId = Convert.ToInt32(item[3]);
                        list.Add(lis);

                    }
                    //5.供应商集合进行缓存
                    _memoryCache.Set(cache_key, list, new MemoryCacheEntryOptions().SetAbsoluteExpiration(TimeSpan.FromHours(12)));
                    _logger.LogInformation($"子仓库拉取-总条数：{list.Count}");
                    return ResultList<ErpStockDto>.ReSuccess(list);
                }
                else
                {
                    return ResultList<ErpStockDto>.ReSuccess(stocks);
                }
            }
            catch (Exception)
            {
                return ResultList<ErpStockDto>.ReFailure("错误", 10002);
            }
        }

        #region 金蝶操作交互
        /// <summary>
        /// 同步数据(保存提交审核)
        /// </summary>
        /// <param name="dto"></param>
        /// <param name="formId"></param>
        /// <returns></returns>
        public async Task<Result<string>> Save<T>(T dto, string formId)
        {
            try
            {
                var token_result = await this.Init();
                if (!token_result.IsSuccess)
                    return Result<string>.ReFailure(token_result.Message,token_result.Status);
                var query = new ErpBillQueryDto(token_result.Data);
                var param = new ErpSave<T>(formId, dto);
                query.Data = JsonConvert.SerializeObject(param);
                //保存
                var result_json = await _client.SaveAsync(JsonConvert.SerializeObject(query));

                JObject jobject = (JObject)JsonConvert.DeserializeObject(result_json);
                var isSuccess = jobject["Result"]["ResponseStatus"]["IsSuccess"].ToString().ToLower();

                if (jobject["Result"]["ResponseStatus"]["IsSuccess"].ToString().ToLower() == "true")
                {
                    //保存成功后返回Id 后续操作根据Id操作
                    string id = jobject["Result"]["ResponseStatus"]["SuccessEntitys"]["Id"].ToString();
                    return Result<string>.ReSuccess(id);
                }

                var msg = jobject["Result"]["ResponseStatus"]["Errors"]["Message"].ToString();
                return Result<string>.ReFailure(msg, 10002);
            }
            catch (Exception)
            {
                return Result<string>.ReFailure("错误", 10002);
            }
        }
        /// <summary>
        /// 提交
        /// </summary>
        /// <param name="dto"></param>
        /// <param name="formId"></param>
        /// <returns></returns>
        public async Task<Result> Submit(ErpOperateDto dto, string formId)
        {
            try
            {
                var token_result = await this.Init();
                if (!token_result.IsSuccess)
                    return token_result;
                var query = new ErpBillQueryDto(token_result.Data);

                //提交
                query.Data = JsonConvert.SerializeObject(dto);
                var result_json = await _client.SubmitAsync(JsonConvert.SerializeObject(query));
                JObject jobject = (JObject)JsonConvert.DeserializeObject(result_json);
                var isSuccess = jobject["Result"]["ResponseStatus"]["IsSuccess"].ToString().ToLower();

                if (jobject["Result"]["ResponseStatus"]["IsSuccess"].ToString().ToLower() == "true")
                    return Result.ReSuccess();

                var msg = jobject["Result"]["ResponseStatus"]["Errors"]["Message"].ToString();
                return Result.ReFailure(msg, 10002);
            }
            catch (Exception)
            {
                return Result.ReFailure("错误", 10002);
            }
        }
        /// <summary>
        /// 审核
        /// </summary>
        /// <param name="dto"></param>
        /// <param name="formId"></param>
        /// <returns></returns>
        public async Task<Result> Audit(ErpOperateDto dto, string formId)
        {
            try
            {
                var token_result = await this.Init();
                if (!token_result.IsSuccess)
                    return token_result;
                var query = new ErpBillQueryDto(token_result.Data);

                //提交
                query.Data = JsonConvert.SerializeObject(dto);
                var result_json = await _client.AuditAsync(JsonConvert.SerializeObject(query));
                JObject jobject = (JObject)JsonConvert.DeserializeObject(result_json);
                var isSuccess = jobject["Result"]["ResponseStatus"]["IsSuccess"].ToString().ToLower();

                if (jobject["Result"]["ResponseStatus"]["IsSuccess"].ToString().ToLower() == "true")
                    return Result.ReSuccess();

                var msg = jobject["Result"]["ResponseStatus"]["Errors"]["Message"].ToString();
                return Result.ReFailure(msg, 10002);
            }
            catch (Exception)
            {
                return Result.ReFailure("错误", 10002);
            }
        }
        /// <summary>
        /// 反审核
        /// </summary>
        /// <param name="dto"></param>
        /// <param name="formId"></param>
        /// <returns></returns>
        public async Task<Result> NoAudit(ErpOperateDto dto, string formId)
        {
            try
            {
                var token_result = await this.Init();
                if (!token_result.IsSuccess)
                    return token_result;
                var query = new ErpBillQueryDto(token_result.Data);

                //提交
                query.Data = JsonConvert.SerializeObject(dto);
                var result_json = await _client.UnAuditAsync(JsonConvert.SerializeObject(query));
                JObject jobject = (JObject)JsonConvert.DeserializeObject(result_json);
                var isSuccess = jobject["Result"]["ResponseStatus"]["IsSuccess"].ToString().ToLower();

                if (jobject["Result"]["ResponseStatus"]["IsSuccess"].ToString().ToLower() == "true")
                    return Result.ReSuccess();

                var msg = jobject["Result"]["ResponseStatus"]["Errors"]["Message"].ToString();
                return Result.ReFailure(msg, 10002);
            }
            catch (Exception)
            {
                return Result.ReFailure("错误", 10002);
            }
        }
        /// <summary>
        /// 删除
        /// </summary>
        /// <param name="dto"></param>
        /// <param name="formId"></param>
        /// <returns></returns>
        public async Task<Result> Delete(ErpOperateDto dto, string formId)
        {
            try
            {
                var token_result = await this.Init();
                if (!token_result.IsSuccess)
                    return token_result;
                var query = new ErpBillQueryDto(token_result.Data);

                //提交
                query.Data = JsonConvert.SerializeObject(dto);
                var result_json = await _client.DeleteAsync(JsonConvert.SerializeObject(query));
                JObject jobject = (JObject)JsonConvert.DeserializeObject(result_json);
                var isSuccess = jobject["Result"]["ResponseStatus"]["IsSuccess"].ToString().ToLower();

                if (jobject["Result"]["ResponseStatus"]["IsSuccess"].ToString().ToLower() == "true")
                    return Result.ReSuccess();

                var msg = jobject["Result"]["ResponseStatus"]["Errors"]["Message"].ToString();
                return Result.ReFailure(msg, 10002);
            }
            catch (Exception)
            {
                return Result.ReFailure("错误", 10002);
            }
        }
        /// <summary>
        /// 下推
        /// </summary>
        /// <param name="dto"></param>
        /// <returns></returns>
        public async Task<Result> Push(ErpPushDto dto)
        {
            var token_result = await this.Init();
            if (!token_result.IsSuccess)
                return token_result;
            var query = new ErpBillQueryDto(token_result.Data);
            query.Data = JsonConvert.SerializeObject(dto);
            //下推
            var result_json = await _client.PushAsync(JsonConvert.SerializeObject(query));

            return Result.ReSuccess();
        }
        #endregion

        #region 出库
        public async Task<ResultList<ErpDeliveryNoticeOutStockResultDto>> BillQueryForDeliveryNoticeOutStock(List<string> sourceBillNos = null, DateTime? beginTime = null)
        {
            try
            {

                var stocks = await _basicsRepositories.GetUcStockAsync(ManagementSystemCode.GLXT0004.ToString(), "", _appOptions.CompanyId);
                if (stocks.Count == 0)
                    return ResultList<ErpDeliveryNoticeOutStockResultDto>.ReFailure(ResultCodes.ErpStockNoData);
                var stocks_codes = stocks.Select(x => x.Id).ToList();

                //1.先登录金蝶-拿到token
                var token_result = await this.Init();
                if (!token_result.IsSuccess)
                    return ResultList<ErpDeliveryNoticeOutStockResultDto>.ReFailure(token_result);

                //2.时间条件：可能还有其它条件

                var beginStr = DateTime.Now.ToString("yyyy-MM-dd 00:00:00");
                if (beginTime != null) beginStr = beginTime?.ToString("yyyy-MM-dd 00:00:00");
                var endStr = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
                //3.获取金蝶采购订单：拼接参数和条件
                var query = new ErpBillQueryDto(token_result.Data);
                var param = new ErpBillQueryParamDto(FormIdParam.SAL_DELIVERYNOTICE.ToString());
                param.FieldKeys = "FBillNo,FOrderNo,FDeliveryOrgID,FCustomerID,FMaterialID,FStockID,FStockLocID,FQty,FNoteEntry,FCreateDate,FEntryID";
                param.Limit = 10;
                //查询条件：备注其中的条件值以金蝶的值为准！！！
                //1.创建时间在两天前和当天时间之间
                //2.审核状态：已审核
                //3.未出库数量>0
                //4.日期>=系统上线之日
                //5.仓库：wms系统的仓库值---现在这个没有加，因为还单点没有和金蝶同步
                param.FilterString = "FCreateDate>='" + beginStr + "' and FCreateDate<='" + endStr + "' and FDocumentStatus='C' and FRemainOutQty>=0";
                //string srt = JsonConvert.SerializeObject(stocks_codes);
                //param.FilterString = param.FilterString + " and FStockID in (" + srt.Substring(1, srt.Length - 2) + ")";

                //根据原订单号查询
                if (sourceBillNos != null && sourceBillNos.Count() > 0)
                {
                    var srt_b = JsonConvert.SerializeObject(sourceBillNos);
                    param.FilterString = param.FilterString + " and FBillNo in (" + srt_b.Substring(1, srt_b.Length - 2) + ")";
                }
                query.Data = JsonConvert.SerializeObject(param);
                var json = JsonConvert.SerializeObject(query);

                //4.请求查询接口
                var result_json = await _client.ExecuteBillQueryAsync(json);
                var result = JsonConvert.DeserializeObject<List<List<string>>>(result_json);

                //5.返回数据的组装
                var erp_list = new List<ErpDeliveryNoticeOutStockResultDto>();
                foreach (var item in result)
                {
                    var lis = new ErpDeliveryNoticeOutStockResultDto();
                    lis.SourceBillNo = item[0];
                    lis.SaleBillNo = item[1];
                    lis.DeliveryOrgId = Convert.ToInt32(item[2]);
                    lis.ReceiptCustomerId = Convert.ToInt32(item[3]);
                    lis.MaterialId = Convert.ToInt32(item[4]);
                    lis.StockId = Convert.ToInt32(item[5]);
                    lis.SubStockId = Convert.ToInt32(item[6]);
                    lis.AccruedQty = Convert.ToDecimal(item[7]);
                    lis.Remark = item[8];
                    lis.CreateTime = Convert.ToDateTime(item[9]);
                    lis.Type = (int)OutStockType.Sal;
                    lis.Erp_DetailId = Convert.ToInt32(item[10]);
                    erp_list.Add(lis);
                }
                return ResultList<ErpDeliveryNoticeOutStockResultDto>.ReSuccess(erp_list);
            }
            catch (Exception ex)
            {
                return ResultList<ErpDeliveryNoticeOutStockResultDto>.ReFailure(ResultCodes.Erp_BillQuery_Error);
            }
        }
        /// <summary>
        /// 直接调拨出库
        /// </summary>
        /// <param name="sourceBillNos"></param>
        /// <returns></returns>
        public async Task<ResultList<ErpDeliveryNoticeOutStockResultDto>> BillQueryForTransferDirectOutStock(List<string> sourceBillNos = null, DateTime? beginTime = null)
        {
            try
            {

                var stocks = await _basicsRepositories.GetUcStockAsync(ManagementSystemCode.GLXT0004.ToString(), "", _appOptions.CompanyId);
                if (stocks.Count == 0)
                    return ResultList<ErpDeliveryNoticeOutStockResultDto>.ReFailure(ResultCodes.ErpStockNoData);
                var stocks_codes = stocks.Select(x => x.Id).ToList();

                //1.先登录金蝶-拿到token
                var token_result = await this.Init();
                if (!token_result.IsSuccess)
                    return ResultList<ErpDeliveryNoticeOutStockResultDto>.ReFailure(token_result);

                //2.时间条件：可能还有其它条件
                var beginStr = DateTime.Now.ToString("yyyy-MM-dd 00:00:00");
                if (beginTime != null) beginStr = beginTime?.ToString("yyyy-MM-dd 00:00:00");
                var endStr = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
                //3.获取金蝶采购订单：拼接参数和条件
                var query = new ErpBillQueryDto(token_result.Data);
                var param = new ErpBillQueryParamDto(FormIdParam.STK_TransferDirect.ToString());
                param.FieldKeys = "FBillNo,'',FStockOutOrgId,FStockOrgId,FMaterialID,FSrcStockId,FSrcStockLocId,FQty,FNoteEntry,FCreateDate";
                param.Limit = 10;
                //查询条件：备注其中的条件值以金蝶的值为准！！！
                //1.创建时间在两天前和当天时间之间
                //2.审核状态：已审核
                //3.未出库数量>0
                //4.日期>=系统上线之日
                //5.仓库：wms系统的仓库值---现在这个没有加，因为还单点没有和金蝶同步
                param.FilterString = "FCreateDate>='" + beginStr + "' and FCreateDate<='" + endStr + "' and FDocumentStatus='C'";
                //string srt = JsonConvert.SerializeObject(stocks_codes);
                //param.FilterString = param.FilterString + " and FSrcStockId in (" + srt.Substring(1, srt.Length - 2) + ")";

                //根据原订单号查询
                if (sourceBillNos != null && sourceBillNos.Count() > 0)
                {
                    var srt_b = JsonConvert.SerializeObject(sourceBillNos);
                    param.FilterString = param.FilterString + " and FBillNo in (" + srt_b.Substring(1, srt_b.Length - 2) + ")";
                }
                query.Data = JsonConvert.SerializeObject(param);
                var json = JsonConvert.SerializeObject(query);

                //4.请求查询接口
                var result_json = await _client.ExecuteBillQueryAsync(json);
                var result = JsonConvert.DeserializeObject<List<List<string>>>(result_json);

                //5.返回数据的组装
                var erp_list = new List<ErpDeliveryNoticeOutStockResultDto>();
                foreach (var item in result)
                {
                    var lis = new ErpDeliveryNoticeOutStockResultDto();
                    lis.SourceBillNo = item[0];
                    lis.SaleBillNo = item[1];
                    lis.DeliveryOrgId = Convert.ToInt32(item[2]);
                    lis.ReceiptCustomerId = Convert.ToInt32(item[3]);
                    lis.MaterialId = Convert.ToInt32(item[4]);
                    lis.StockId = Convert.ToInt32(item[5]);
                    lis.SubStockId = Convert.ToInt32(item[6]);
                    lis.AccruedQty = Convert.ToDecimal(item[7]);
                    lis.Remark = item[8];
                    lis.CreateTime = Convert.ToDateTime(item[9]);
                    lis.Type = (int)OutStockType.Stkdirecttransfers;
                    erp_list.Add(lis);
                }
                return ResultList<ErpDeliveryNoticeOutStockResultDto>.ReSuccess(erp_list);
            }
            catch (Exception ex)
            {
                return ResultList<ErpDeliveryNoticeOutStockResultDto>.ReFailure(ResultCodes.Erp_BillQuery_Error);
            }
        }
        /// <summary>
        /// 分布式调出
        /// </summary>
        /// <param name="sourceBillNos"></param>
        /// <returns></returns>
        public async Task<ResultList<ErpDeliveryNoticeOutStockResultDto>> BillQueryForTransferOutOutStock(List<string> sourceBillNos = null, DateTime? beginTime = null)
        {
            try
            {

                var stocks = await _basicsRepositories.GetUcStockAsync(ManagementSystemCode.GLXT0004.ToString(), "", _appOptions.CompanyId);
                if (stocks.Count == 0)
                    return ResultList<ErpDeliveryNoticeOutStockResultDto>.ReFailure(ResultCodes.ErpStockNoData);
                var stocks_codes = stocks.Select(x => x.Id).ToList();

                //1.先登录金蝶-拿到token
                var token_result = await this.Init();
                if (!token_result.IsSuccess)
                    return ResultList<ErpDeliveryNoticeOutStockResultDto>.ReFailure(token_result);

                //2.时间条件：可能还有其它条件
                var beginStr = DateTime.Now.ToString("yyyy-MM-dd 00:00:00");
                if (beginTime != null) beginStr = beginTime?.ToString("yyyy-MM-dd 00:00:00");
                var endStr = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
                //3.获取金蝶采购订单：拼接参数和条件
                var query = new ErpBillQueryDto(token_result.Data);
                var param = new ErpBillQueryParamDto(FormIdParam.STK_TRANSFEROUT.ToString());
                param.FieldKeys = "FBillNo,'',FStockOrgID,FStockInOrgID,FMaterialID,FSrcStockID,FSrcStockLocId,FQty,FEntryNote,FCreateDate";
                param.Limit = 10;
                //查询条件：备注其中的条件值以金蝶的值为准！！！
                //1.创建时间在两天前和当天时间之间
                //2.审核状态：已审核
                //3.未出库数量>0
                //4.日期>=系统上线之日
                //5.仓库：wms系统的仓库值---现在这个没有加，因为还单点没有和金蝶同步 
                param.FilterString = "FCreateDate>='" + beginStr + "' and FCreateDate<='" + endStr + "' and FDocumentStatus='C'";
                //string srt = JsonConvert.SerializeObject(stocks_codes);
                //param.FilterString = param.FilterString + " and FSrcStockID in (" + srt.Substring(1, srt.Length - 2) + ")";

                //根据原订单号查询
                if (sourceBillNos != null && sourceBillNos.Count() > 0)
                {
                    var srt_b = JsonConvert.SerializeObject(sourceBillNos);
                    param.FilterString = param.FilterString + " and FBillNo in (" + srt_b.Substring(1, srt_b.Length - 2) + ")";
                }
                query.Data = JsonConvert.SerializeObject(param);
                var json = JsonConvert.SerializeObject(query);

                //4.请求查询接口
                var result_json = await _client.ExecuteBillQueryAsync(json);
                var result = JsonConvert.DeserializeObject<List<List<string>>>(result_json);

                //5.返回数据的组装
                var erp_list = new List<ErpDeliveryNoticeOutStockResultDto>();
                foreach (var item in result)
                {
                    var lis = new ErpDeliveryNoticeOutStockResultDto();
                    lis.SourceBillNo = item[0];
                    lis.SaleBillNo = item[1];
                    lis.DeliveryOrgId = Convert.ToInt32(item[2]);
                    lis.ReceiptCustomerId = Convert.ToInt32(item[3]);
                    lis.MaterialId = Convert.ToInt32(item[4]);
                    lis.StockId = Convert.ToInt32(item[5]);
                    lis.SubStockId = Convert.ToInt32(item[6]);
                    lis.AccruedQty = Convert.ToDecimal(item[7]);
                    lis.Remark = item[8];
                    lis.CreateTime = Convert.ToDateTime(item[9]);
                    lis.Type = (int)OutStockType.StktransferInst;
                    erp_list.Add(lis);
                }
                return ResultList<ErpDeliveryNoticeOutStockResultDto>.ReSuccess(erp_list);
            }
            catch (Exception ex)
            {
                return ResultList<ErpDeliveryNoticeOutStockResultDto>.ReFailure(ResultCodes.Erp_BillQuery_Error);
            }
        }
        /// <summary>
        /// 组装拆卸单 (拆卸 主出)
        /// </summary>
        /// <param name="sourceBillNos"></param>
        /// <returns></returns>
        public async Task<ResultList<ErpDeliveryNoticeOutStockResultDto>> BillQueryForAssembledAppOutStock_Dassembly(List<string> sourceBillNos = null, DateTime? beginTime = null)
        {
            try
            {

                var stocks = await _basicsRepositories.GetUcStockAsync(ManagementSystemCode.GLXT0004.ToString(), "", _appOptions.CompanyId);
                if (stocks.Count == 0)
                    return ResultList<ErpDeliveryNoticeOutStockResultDto>.ReFailure(ResultCodes.ErpStockNoData);
                var stocks_codes = stocks.Select(x => x.Id).ToList();

                //1.先登录金蝶-拿到token
                var token_result = await this.Init();
                if (!token_result.IsSuccess)
                    return ResultList<ErpDeliveryNoticeOutStockResultDto>.ReFailure(token_result);

                //2.时间条件：可能还有其它条件
                var beginStr = DateTime.Now.ToString("yyyy-MM-dd 00:00:00");
                if (beginTime != null) beginStr = beginTime?.ToString("yyyy-MM-dd 00:00:00");
                var endStr = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
                //3.获取金蝶采购订单：拼接参数和条件
                var query = new ErpBillQueryDto(token_result.Data);
                var param = new ErpBillQueryParamDto(FormIdParam.STK_AssembledApp.ToString());
                param.FieldKeys = "FBillNo,'','0','0',FMaterialID,FStockID,FStockLocId,FQty,FDescription,FCreateDate";
                param.Limit = 10;
                //查询条件：备注其中的条件值以金蝶的值为准！！！
                //1.创建时间在两天前和当天时间之间
                //2.审核状态：已审核
                //3.未出库数量>0
                //4.日期>=系统上线之日
                //5.仓库：wms系统的仓库值---现在这个没有加，因为还单点没有和金蝶同步 FBillTypeID
                param.FilterString = "FCreateDate>='" + beginStr + "' and FCreateDate<='" + endStr + "' and FDocumentStatus='C' and FAffairType='Dassembly'";
                //string srt = JsonConvert.SerializeObject(stocks_codes);
                //param.FilterString = param.FilterString + " and FSrcStockID in (" + srt.Substring(1, srt.Length - 2) + ")";

                //根据原订单号查询
                if (sourceBillNos != null && sourceBillNos.Count() > 0)
                {
                    var srt_b = JsonConvert.SerializeObject(sourceBillNos);
                    param.FilterString = param.FilterString + " and FBillNo in (" + srt_b.Substring(1, srt_b.Length - 2) + ")";
                }
                query.Data = JsonConvert.SerializeObject(param);
                var json = JsonConvert.SerializeObject(query);

                //4.请求查询接口
                var result_json = await _client.ExecuteBillQueryAsync(json);
                var result = JsonConvert.DeserializeObject<List<List<string>>>(result_json);

                //5.返回数据的组装
                var erp_list = new List<ErpDeliveryNoticeOutStockResultDto>();
                foreach (var item in result)
                {
                    var lis = new ErpDeliveryNoticeOutStockResultDto();
                    lis.SourceBillNo = item[0];
                    lis.SaleBillNo = item[1];
                    lis.DeliveryOrgId = Convert.ToInt32(item[2]);
                    lis.ReceiptCustomerId = Convert.ToInt32(item[3]);
                    lis.MaterialId = Convert.ToInt32(item[4]);
                    lis.StockId = Convert.ToInt32(item[5]);
                    lis.SubStockId = Convert.ToInt32(item[6]);
                    lis.AccruedQty = Convert.ToDecimal(item[7]);
                    lis.Remark = item[8];
                    lis.CreateTime = Convert.ToDateTime(item[9]);
                    lis.Type = (int)OutStockType.Assembled;
                    erp_list.Add(lis);
                }
                return ResultList<ErpDeliveryNoticeOutStockResultDto>.ReSuccess(erp_list);
            }
            catch (Exception ex)
            {
                return ResultList<ErpDeliveryNoticeOutStockResultDto>.ReFailure(ResultCodes.Erp_BillQuery_Error);
            }
        }
        /// <summary>
        /// 其他出库
        /// </summary>
        /// <param name="sourceBillNos"></param>
        /// <returns></returns>
        public async Task<ResultList<ErpDeliveryNoticeOutStockResultDto>> BillQueryForMisDeliveryOutStock(List<string> sourceBillNos = null, DateTime? beginTime = null)
        {
            try
            {

                var stocks = await _basicsRepositories.GetUcStockAsync(ManagementSystemCode.GLXT0004.ToString(), "", _appOptions.CompanyId);
                if (stocks.Count == 0)
                    return ResultList<ErpDeliveryNoticeOutStockResultDto>.ReFailure(ResultCodes.ErpStockNoData);
                var stocks_codes = stocks.Select(x => x.Id).ToList();

                //1.先登录金蝶-拿到token
                var token_result = await this.Init();
                if (!token_result.IsSuccess)
                    return ResultList<ErpDeliveryNoticeOutStockResultDto>.ReFailure(token_result);

                //2.时间条件：可能还有其它条件
                var beginStr = DateTime.Now.ToString("yyyy-MM-dd 00:00:00");
                if (beginTime != null) beginStr = beginTime?.ToString("yyyy-MM-dd 00:00:00");
                var endStr = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
                //3.获取金蝶采购订单：拼接参数和条件
                var query = new ErpBillQueryDto(token_result.Data);
                var param = new ErpBillQueryParamDto(FormIdParam.STK_MisDelivery.ToString());
                param.FieldKeys = "FBillNo,'',FStockOrgId,FPickOrgId,FMaterialId,FStockId,FStockLocId ,FQty,FEntryNote,FCreateDate";
                param.Limit = 10;
                //查询条件：备注其中的条件值以金蝶的值为准！！！
                //1.创建时间在两天前和当天时间之间
                //2.审核状态：已审核
                //3.未出库数量>0
                //4.日期>=系统上线之日
                //5.仓库：wms系统的仓库值---现在这个没有加，因为还单点没有和金蝶同步
                param.FilterString = "FCreateDate>='" + beginStr + "' and FCreateDate<='" + endStr + "' and FDocumentStatus='C'";
                //string srt = JsonConvert.SerializeObject(stocks_codes);
                //param.FilterString = param.FilterString + " and FSrcStockID in (" + srt.Substring(1, srt.Length - 2) + ")";

                //根据原订单号查询
                if (sourceBillNos != null && sourceBillNos.Count() > 0)
                {
                    var srt_b = JsonConvert.SerializeObject(sourceBillNos);
                    param.FilterString = param.FilterString + " and FBillNo in (" + srt_b.Substring(1, srt_b.Length - 2) + ")";
                }
                query.Data = JsonConvert.SerializeObject(param);
                var json = JsonConvert.SerializeObject(query);

                //4.请求查询接口
                var result_json = await _client.ExecuteBillQueryAsync(json);
                var result = JsonConvert.DeserializeObject<List<List<string>>>(result_json);

                //5.返回数据的组装
                var erp_list = new List<ErpDeliveryNoticeOutStockResultDto>();
                foreach (var item in result)
                {
                    var lis = new ErpDeliveryNoticeOutStockResultDto();
                    lis.SourceBillNo = item[0];
                    lis.SaleBillNo = item[1];
                    lis.DeliveryOrgId = Convert.ToInt32(item[2]);
                    lis.ReceiptCustomerId = Convert.ToInt32(item[3]);
                    lis.MaterialId = Convert.ToInt32(item[4]);
                    lis.StockId = Convert.ToInt32(item[5]);
                    lis.SubStockId = Convert.ToInt32(item[6]);
                    lis.AccruedQty = Convert.ToDecimal(item[7]);
                    lis.Remark = item[8];
                    lis.CreateTime = Convert.ToDateTime(item[9]);
                    lis.Type = (int)OutStockType.Miscellaneous;
                    erp_list.Add(lis);
                }
                return ResultList<ErpDeliveryNoticeOutStockResultDto>.ReSuccess(erp_list);
            }
            catch (Exception ex)
            {
                return ResultList<ErpDeliveryNoticeOutStockResultDto>.ReFailure(ResultCodes.Erp_BillQuery_Error);
            }
        }
        /// <summary>
        /// 组装拆卸单 (组装 子出)
        /// </summary>
        /// <param name="sourceBillNos"></param>
        /// <returns></returns>
        public async Task<ResultList<ErpDeliveryNoticeOutStockResultDto>> BillQueryForAssembledAppOutStock_Assembly(List<string> sourceBillNos = null, DateTime? beginTime = null)
        {
            try
            {

                var stocks = await _basicsRepositories.GetUcStockAsync(ManagementSystemCode.GLXT0004.ToString(), "", _appOptions.CompanyId);
                if (stocks.Count == 0)
                    return ResultList<ErpDeliveryNoticeOutStockResultDto>.ReFailure(ResultCodes.ErpStockNoData);
                var stocks_codes = stocks.Select(x => x.Id).ToList();

                //1.先登录金蝶-拿到token
                var token_result = await this.Init();
                if (!token_result.IsSuccess)
                    return ResultList<ErpDeliveryNoticeOutStockResultDto>.ReFailure(token_result);

                //2.时间条件：可能还有其它条件
                var beginStr = DateTime.Now.ToString("yyyy-MM-dd 00:00:00");
                if (beginTime != null) beginStr = beginTime?.ToString("yyyy-MM-dd 00:00:00");
                var endStr = DateTime.Now.ToString("yyyy-MM-dd HH:mm:ss");
                //3.获取金蝶采购订单：拼接参数和条件
                var query = new ErpBillQueryDto(token_result.Data);
                var param = new ErpBillQueryParamDto(FormIdParam.STK_AssembledApp.ToString());
                param.FieldKeys = "FBillNo,'',FSubProOwnerIdH,FOwnerIdHead,FMaterialIDSETY,FStockIDSETY,FStockLocIdSETY,FQtySETY,FDescriptionSETY,FCreateDate";
                param.Limit = 10;
                //查询条件：备注其中的条件值以金蝶的值为准！！！
                //1.创建时间在两天前和当天时间之间
                //2.审核状态：已审核
                //3.未出库数量>0
                //4.日期>=系统上线之日
                //5.仓库：wms系统的仓库值---现在这个没有加，因为还单点没有和金蝶同步 FBillTypeID
                param.FilterString = "FCreateDate>='" + beginStr + "' and FCreateDate<='" + endStr + "' and FDocumentStatus='C' and FAffairType='Assembly'";
                //string srt = JsonConvert.SerializeObject(stocks_codes);
                //param.FilterString = param.FilterString + " and FSrcStockID in (" + srt.Substring(1, srt.Length - 2) + ")";

                //根据原订单号查询
                if (sourceBillNos != null && sourceBillNos.Count() > 0)
                {
                    var srt_b = JsonConvert.SerializeObject(sourceBillNos);
                    param.FilterString = param.FilterString + " and FBillNo in (" + srt_b.Substring(1, srt_b.Length - 2) + ")";
                }
                query.Data = JsonConvert.SerializeObject(param);
                var json = JsonConvert.SerializeObject(query);

                //4.请求查询接口
                var result_json = await _client.ExecuteBillQueryAsync(json);
                var result = JsonConvert.DeserializeObject<List<List<string>>>(result_json);

                //5.返回数据的组装
                var erp_list = new List<ErpDeliveryNoticeOutStockResultDto>();
                foreach (var item in result)
                {
                    var lis = new ErpDeliveryNoticeOutStockResultDto();
                    lis.SourceBillNo = item[0];
                    lis.SaleBillNo = item[1];
                    lis.DeliveryOrgId = Convert.ToInt32(item[2]);
                    lis.ReceiptCustomerId = Convert.ToInt32(item[3]);
                    lis.MaterialId = Convert.ToInt32(item[4]);
                    lis.StockId = Convert.ToInt32(item[5]);
                    lis.SubStockId = Convert.ToInt32(item[6]);
                    lis.AccruedQty = Convert.ToDecimal(item[7]);
                    lis.Remark = item[8];
                    lis.CreateTime = Convert.ToDateTime(item[9]);
                    lis.Type = (int)OutStockType.Assembled;
                    erp_list.Add(lis);
                }
                return ResultList<ErpDeliveryNoticeOutStockResultDto>.ReSuccess(erp_list);
            }
            catch (Exception ex)
            {
                return ResultList<ErpDeliveryNoticeOutStockResultDto>.ReFailure(ResultCodes.Erp_BillQuery_Error);
            }
        }

        #endregion
    }
}