using Kingdee.BOS;

using Kingdee.BOS.App.Data;

using Kingdee.BOS.Contracts;

using Kingdee.BOS.Core;

using Kingdee.BOS.Core.Report;

using Kingdee.BOS.Log;

using Kingdee.BOS.Model.ReportFilter;

using Kingdee.BOS.Orm.DataEntity;

using Kingdee.BOS.ServiceHelper;

using Kingdee.BOS.Util;

using System;

using System.Collections.Generic;

using System.ComponentModel;

using System.Data;

using System.Linq;

using System.Text;

namespace YDL.K3.Plugins.Server.ISchedule

{

    [HotUpdate]

    [Description("【执行计划】物料收发明细表保存")]

    public class STK_StockDetailRpt : IScheduleService

    {

        public void Run(Context ctx, Schedule schedule)

        {

            try

            {

                Logger.Info("提示：", "开始查询物料收发明细表！");

                ISysReportService sysReporSservice = ServiceFactory.GetSysReportService(ctx);

                var filterMetadata = FormMetaDataCache.GetCachedFilterMetaData(ctx);

                var reportMetadata = FormMetaDataCache.GetCachedFormMetaData(ctx, "STK_StockDetailRpt");

                var reportFilterMetadata = FormMetaDataCache.GetCachedFormMetaData(ctx, "STK_StockDetailFilter");

                var reportFilterServiceProvider = reportFilterMetadata.BusinessInfo.GetForm().GetFormServiceProvider();

                SysReportFilterModel model = new SysReportFilterModel();

                model.SetContext(ctx, reportFilterMetadata.BusinessInfo, reportFilterServiceProvider);

                model.FormId = reportFilterMetadata.BusinessInfo.GetForm().Id;

                model.FilterObject.FilterMetaData = filterMetadata;

                model.InitFieldList(reportMetadata, reportFilterMetadata);

                model.GetSchemeList();

                // 金蝶账套ID

                model.Load("xxxxxxxxxxx");

                // 获取当前日期  

                DateTime now = DateTime.Now;

                var filter = model.GetFilterParameter();

                DynamicObject filterObj = filter.CustomFilter;

                // 开始日期

                filterObj["BeginDate"] = new DateTime(now.Year, now.Month, 1).AddMonths(-1);

                // 结束日期

                filterObj["EndDate"] = new DateTime(now.Year, now.Month, 1).AddMonths(1).AddDays(-1).AddMonths(-1);

                //加载创建组织的物料

                //var materialDy = cse["MaterialId"] as DynamicObject;

                //var mastMaterial = BusinessDataServiceHelper.LoadSingle(ctx, materialDy["msterID"], materialDy.DynamicObjectType);

                //filterObj["EndMaterialId"] = mastMaterial;

                //filterObj["EndMaterialId_Id"] = mastMaterial["Id"];

                //filterObj["BeginMaterialId"] = mastMaterial;

                //filterObj["BeginMaterialId_Id"] = mastMaterial["Id"];

                filterObj["StockOrgId"] = 101505;//cse["PurchaseOrgId_Id"];

                IPermissionService permissionService = ServiceFactory.GetPermissionService(ctx);

                IRptParams p = new RptParams();

                p.FormId = reportFilterMetadata.BusinessInfo.GetForm().Id;

                p.StartRow = 1;

                p.EndRow = int.MaxValue;//StartRow和EndRow是报表数据分页的起始行数和截至行数，一般取所有数据，所以EndRow取int最大值。

                p.FilterParameter = filter;

                p.FilterFieldInfo = model.FilterFieldInfo;

                p.CustomParams["OpenParameter"] = null;

                p.BaseDataTempTable.AddRange(permissionService.GetBaseDataTempTable(ctx, reportMetadata.BusinessInfo.GetForm().Id));

                MoveReportServiceParameter param = new MoveReportServiceParameter(ctx, reportMetadata.BusinessInfo, Guid.NewGuid().ToString(), p);

                //SerializerProxy serialHelper = new SerializerProxy(MessageFormats.Json, UTF8Encoding.UTF8, false, string.Empty, true);

                //DataTable dt = new DataTable();

                IMoveReport moveReport = sysReporSservice.GetListAndReportData(param);

                //var dtMetaData = FormMetaDataCache.GetCachedFormMetaData(ctx, "QDNF_WLSFDTXX");

                //var DDys = new List<DynamicObject>();

                using (DataTable dt = moveReport.DataSource)

                {

                    if (dt == null)

                        return;

                    var cc = dt.ExtendedProperties;

                    var cccc = cc["BaseTable.0"];

                    string sql = string.Format(@"/*dialext*/ INSERT INTO Wlsfmxb

(FGUID,FSTOCKORGNUMBER,FOWNERNAME,FIOPRICE,FIOAMOUNT,FMATERIALID,FMATERIALNO,FMATERIALNAME,FSTOCKGROUP,FDATE,FCREATEDATE,FLOTNO,FMATERIALTYPENAME,FSTOCKNAME,FDEPARTMENTNAME,FFORMID,FBILLNAME,FBILLID,FBILLNO,FBILLTYPENAME,FMTONO,FSTOCKUNITNAME,FBASEINQTY,FBASEINPRICE,FSTOCKINQTY,FSTOCKINPRICE,FINAMOUNT,FBASEOUTQTY,FBASEOUTPRICE,FSTOCKOUTQTY,FSTOCKOUTPRICE,FOUTAMOUNT,FBASEJCQTY,FBASEJCPRICE,FSTOCKJCQTY,FSTOCKJCPRICE,FJCAMOUNT,FSRCBILLNO,FENTRYTABLE,FBILLENTRYID,F_TZH)

SELECT FGUID,FSTOCKORGNUMBER,FOWNERNAME,FIOPRICE,FIOAMOUNT,FMATERIALID,FMATERIALNO,FMATERIALNAME,FSTOCKGROUP,FDATE,FCREATEDATE,FLOTNO,FMATERIALTYPENAME,FSTOCKNAME,FDEPARTMENTNAME,FFORMID,FBILLNAME,FBILLID,FBILLNO,FBILLTYPENAME,FMTONO,FSTOCKUNITNAME,FBASEINQTY,FBASEINPRICE,FSTOCKINQTY,FSTOCKINPRICE,FINAMOUNT,FBASEOUTQTY,FBASEOUTPRICE,FSTOCKOUTQTY,FSTOCKOUTPRICE,FOUTAMOUNT,FBASEJCQTY,FBASEJCPRICE,FSTOCKJCQTY,FSTOCKJCPRICE,FJCAMOUNT,FSRCBILLNO,FENTRYTABLE,FBILLENTRYID,F_TZH 

FROM {0}", cccc);

                    var a1 = DBUtils.ExecuteDynamicObject(ctx, sql, null, null, System.Data.CommandType.Text);

                }

            }

            catch (Exception ex)

            {

                Logger.Info("错误提示:", ex.ToString());

                throw;

            }

            Logger.Info("提示：", "更新成功！");

        }

    }

}

//