using DevExpress.Xpo.DB.Helpers;
using FarPoint.Excel;
using Kingdee.BOS;
using Kingdee.BOS.App;
using Kingdee.BOS.App.Data;
using Kingdee.BOS.Contracts;
using Kingdee.BOS.Core.DynamicForm;
using Kingdee.BOS.Core.DynamicForm.Operation;
using Kingdee.BOS.Core.DynamicForm.PlugIn;
using Kingdee.BOS.Core.DynamicForm.PlugIn.Args;
using Kingdee.BOS.Core.List;
using Kingdee.BOS.Core.List.PlugIn;
using Kingdee.BOS.Core.Metadata;
using Kingdee.BOS.Core.Metadata.ConvertElement;
using Kingdee.BOS.Core.Metadata.ConvertElement.ServiceArgs;
using Kingdee.BOS.Core.Metadata.FormElement;
using Kingdee.BOS.Log;
using Kingdee.BOS.Orm;
using Kingdee.BOS.Orm.DataEntity;
using Kingdee.BOS.ServiceHelper;
using Kingdee.BOS.Util;
using Newtonsoft.Json.Linq;
using Pilot_KD_Parino.Common;
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Linq;
namespace Pilot_KD_Parino.Sal_Order
{
    [Description("销售单下推生成跨组织的采购申请单的插件"), HotUpdate]
    public class PushSaleBillPlugIn : AbstractDynamicFormPlugIn // AbstractListPlugIn
    {
        long sScrId = 0;
        string sScrBillNo = "";
        public override void AfterBarItemClick(AfterBarItemClickEventArgs e)
        {
            base.AfterBarItemClick(e);
           
            //this.View.ShowMessage("669977");

            if (e.BarItemKey.Equals("tbSaleBill222", StringComparison.OrdinalIgnoreCase))
            {
                var FEntity = this.View.Model.DataObject;
                var json = JsonUtil.Serialize(FEntity);
                //Logger.Error("FEntity", json, new Exception());
                var id = FEntity["id"];
                string formid = FEntity["FFormId"].ToString();
               

                int stockId = 0;
                IOperationResult result = Invoke("SAL_SaleOrder", "PUR_PurchaseOrder", id.ToString(), "7cd93c259999489c97798063f2f7bd70", ref stockId);
               
                  
                var sheet = result.SuccessDataEnity.FirstOrDefault();
                string jsonsheet = JsonHelper.ToJson(sheet);
                //Logger.Error("推送采购入库单",jsonsheet,null);
                if (sheet != null)
                {   
                     
                    result = Invoke("PUR_ReceiveBill", "STK_InStock", sheet["id"].ToString(), "a1ff32276cd9469dad3bf2494366fa4f", ref stockId);
                    //sheet = result.SuccessDataEnity.FirstOrDefault();
                    //result = Invoke("PUR_ReceiveBill", "STK_InStock", sheet["id"].ToString(), "a1ff32276cd9469dad3bf2494366fa4f");
                }

                //找到最开始的销售订单
                for (int kk = 0; kk < 6 && tablename.ToUpper() != "T_SAL_ORDERENTRY"; kk++)
                {
                    ////发货通知单
                    tempFid = int.Parse(dt.Select(t => t["FSBILLID"]).FirstOrDefault().ToString());
                    string tempTable = dt.Select(t => t["FSTABLENAME"]).FirstOrDefault().ToString();
                    getSourceSql = $@"/*dialect*/SELECT FSTABLENAME,FSBILLID FROM dbo.{tempTable}_lk
                                          WHERE FENTRYID IN ( SELECT FENTRYID FROM {tempTable} WHERE FID = {tempFid})";                   
                    dt = DBServiceHelper.ExecuteDynamicObject(this.Context, getSourceSql);

                    if (dt == null || dt.Count == 0)
                    {

                        this.View.ShowMessage("没有上查关联的跨组织的采购订单");
                        return;
                    }
                    else
                    {
                        tablename = dt.Select(t => t["FSTABLENAME"]).FirstOrDefault().ToString();
                       
                    }
                    tempFid = int.Parse(dt.Select(t => t["FSBILLID"]).FirstOrDefault().ToString());
                }
                if (tablename.ToUpper() != "T_SAL_ORDERENTRY")
                {

                    throw new KDBusinessException("", "推送销售发货通知单失败,没有上查关联的跨组织的销售订单：" + tablename);

                }
               
                result = Invoke("SAL_SaleOrder", "SAL_DELIVERYNOTICE", tempFid.ToString(), "193822715afc48aa9fa6d6beca7700ab", ref stockId);
                sheet = result.SuccessDataEnity.FirstOrDefault();
                result = Invoke("SAL_DELIVERYNOTICE", "SAL_OUTSTOCK", sheet["id"].ToString(), "ad0779a4685a43a08f08d2e42d7bf3e9", ref stockId);
               
                this.View.ShowMessage("跨组织下推订单完成");

                //this.View.ShowMessage("就是这个按钮"+ id);

                //ListSelectedRowCollection rows =new ListSelectedRowCollection();
                //List<string> pkIds = new List<string>();
                //List<object> pkEntryIds = new List<object>();
                //if (rows.Count <= 0)
                //{
                //    this.View.ShowMessage("请选择对应的发货通知单！！！");
                //    return;
                //}
                //foreach (var row in rows)
                //{
                //    sBillNo = row.BillNo.ToString();//发货通知单号
                //    sId = Convert.ToInt64(row.PrimaryKeyValue);//发货通知单ID
                //    sEntryId = Convert.ToInt64(row.EntryPrimaryKeyValue);//发货通知单ID
                //    string sSql = "select FID from T_SAL_DELIVERYNOTICEENTRY  where  FID= " + sId + " and FENTRYID= " + sEntryId + " and  abs(FBaseUnitQty) > abs(FBASEJOINOUTQTY) ";
                //    sSql = String.Format(@"/*dialect*/" + sSql);
                //    var dt = DBServiceHelper.ExecuteDynamicObject(this.Context, sSql);
                //    if (dt.Count > 0)
                //    {
                //        string getSourceSql = "select FID from T_SAL_DELIVERYNOTICE where  FBILLNO='" + sBillNo + "'";
                //        IOperationResult result = Invoke("SAL_DELIVERYNOTICE", "SAL_OUTSTOCK", getSourceSql, "ad0779a4685a43a08f08d2e42d7bf3e9");
                //    }
                //}//进入下一个循环生成下一个系列的分布式调出单
                //if (flag)
                //{
                //    this.View.ShowMessage("生成对应系列的分布式调出单完成！！！");
                //}
            }
        }


        private IOperationResult Invoke(string source, string target, string tempFid, string sargetBillTypeId, ref int stockId)
        {
            try
            {
                IOperationResult result = new OperationResult();
                //获取单据转换规则
                ConvertRuleElement ruleElement = ServiceHelper.GetService<IConvertService>().GetConvertRules(this.Context, source, target).FirstOrDefault();

                //如下代码 直接通过查询数据库获取单据转换源单数据
                ListSelectedRowCollection rows = new ListSelectedRowCollection();
                int i = 0;
                ListSelectedRow row = new ListSelectedRow(tempFid, string.Empty, i++, source);
                rows.Add(row);

                PushArgs pushArgs = new PushArgs(ruleElement, rows.ToArray());
                pushArgs.TargetBillTypeId = sargetBillTypeId;//单据类型
                                                             //转换生成目标单
                ConvertOperationResult convertResult = ServiceHelper.GetService<IConvertService>().Push(this.Context, pushArgs);

                ////合并转换操作结果
                //result.MergeResult(convertResult);

                ////目标单据数据集合
                DynamicObject[] destObjs = convertResult.TargetDataEntities.Select(r => r.DataEntity).ToArray();

                var sdsas = JsonHelper.ToJson(destObjs);
                Logger.Error("目标单据数据集合", sdsas, new Exception());
                int temStockId = stockId;
                if (target == "PUR_ReceiveBill")//收料通知单,强制没有配置仓库的物料进成品仓库
                {
                    //var  sheet = destObjs.FirstOrDefault(); PUR_ReceiveEntry               
                    string pur = ("PUR_ReceiveEntry");
                    var stocks3 = destObjs[0];

                    if (temStockId == 0)
                    {
                        string sql2 = $@"/*dialect*/ SELECT FUseOrgId,fname, a.FSTOCKID,FForbidStatus,FDocumentStatus FROM   T_BD_STOCK a 
      LEFT JOIN T_BD_STOCK_L b ON a.FSTOCKID=b.FSTOCKID
     WHERE fname like '%成品仓%' AND FForbidStatus='A' AND FDocumentStatus='C' AND FUseOrgId={stocks3["StockOrgId_Id"]}";
                        var stockList = DBServiceHelper.ExecuteDynamicObject(this.Context, sql2, null, null, CommandType.Text, null);
                        if (stockList == null || stockList.Count == 0)
                        {
                            throw new KDBusinessException("", "所涉及的跨组织单位没有配置成品仓");
                        }


                        temStockId = stockList.Select(t => int.Parse(t["FSTOCKID"].ToString())).FirstOrDefault();
                        stockId = temStockId;
                    }
                    var stocks333 = stocks3[pur];
                    var stocks = stocks333 as DynamicObjectCollection;
                    var stock0 = stocks.ToList();
                   
                    stock0.ForEach(t =>
                    {
                        t["StockID_Id"] = temStockId;
                    });

                  
                   
                    //if (stock0.Count > 0)
                    //{
                    //    var others= stocks.Where(t => int.Parse(t["StockID_Id"].ToString()) != 0).ToList();
                    //    if (others.Count == 0)
                    //    {
                    //        throw new KDBusinessException("", "上查关联的跨组织的采购订单明细全部没有配置仓库" );
                    //    }
                    //    var other2 = others.Select(t => t["StockId"]).ToList();
                    //    var json1 = JsonHelper.ToJson(other2);
                    //    List<PUR_ReceiveEntryStockId> other3 = JsonHelper.ToObject<List<PUR_ReceiveEntryStockId>>(json1);
                    //    var other4 = other3.Where(t => t.Name.FirstOrDefault().Value.Contains("成品仓")).ToList();
                       
                    //    if (other4.Count > 0)
                    //    {
                    //        stockId = other4.Select(t => t.Id).FirstOrDefault();
                    //    }
                    //    else
                    //    {
                    //        stockId = other3.Select(t => t.Id).FirstOrDefault();
                    //    }

                      
                    //    stock0.ForEach(t =>
                    //    {
                    //        t["StockID_Id"] = stockId;
                    //    });
                    //}
                }


                if (target == "SAL_DELIVERYNOTICE")//采购入库单,强制没有配置仓库的物料进成品仓库
                {
                    //throw new KDBusinessException("","还没开发好");
                    //var  sheet = destObjs.FirstOrDefault(); PUR_ReceiveEntry               
                    string pur = ("SAL_DELIVERYNOTICEENTRY");
                    var stocks3 = destObjs[0];                
                    var stocks333 = stocks3[pur];
                    var stocks = stocks333 as DynamicObjectCollection;
                    var stock0 = stocks.ToList();
                    stock0.ForEach(t =>
                    {
                        t["StockID_Id"] = temStockId;
                    });



                }

                //根据实际情况，处理目标单据数据
                //destObjs[0]["Date"] = Convert.ToDateTime(sDate);
                //DynamicObjectCollection col_FEntityDetail;
                //var sdsas = JsonHelper.ToJson(destObjs);
                //Logger.Error("目标单据数据集合", sdsas, new Exception());
                //this.View.ShowMessage("好了好了，就是这个按钮");

                //return result;
                ////if (target == "SAL_OUTSTOCK")//销售出库
                ////{
                //col_FEntityDetail = destObjs[0]["SAL_OUTSTOCKENTRY"] as DynamicObjectCollection;
                ////}
                ////else
                ////{//销售退货
                ////    col_FEntityDetail = destObjs[0]["SAL_RETURNSTOCKENTRY"] as DynamicObjectCollection;
                ////}
                //#region 
                //long sStockOrgID = 0;
                //sStockOrgID = Convert.ToInt64(destObjs[0]["StockOrgId_Id"]);


                //foreach (var item in col_FEntityDetail)
                //{
                //    //item["KeeperID_Id"] = item["OwnerID_Id"];//保管者

                //    string sStockSql = "select FOrgStockId  from v_BusinessOrgId where FORGID= " + sStockOrgID + " ";
                //    sStockSql = String.Format(@"/*dialect*/" + sStockSql);
                //    var dt = DBServiceHelper.ExecuteDynamicObject(this.Context, sStockSql);

                //    //if (dt.Count > 0 && Convert.ToInt64(dt[0]["FOrgStockId"]) != 0)
                //    if (dt.Count > 0)
                //    {
                //        //var targetBillMeta = ServiceHelper.GetService<IMetaDataService>().Load(this.Context, target) as FormMetadata;
                //        //BusinessInfo info = targetBillMeta.BusinessInfo;
                //        //BaseDataField stockFld = info.GetField("FStockId") as BaseDataField;
                //        //long stockId = Convert.ToInt64(dt[0]["FOrgStockId"]);
                //        //IViewService viewService = ServiceHelper.GetService<IViewService>();
                //        //DynamicObject[] stockObjs = viewService.LoadFromCache(this.Context, new object[] { stockId }, stockFld.RefFormDynamicObjectType);
                //        //stockFld.RefIDDynamicProperty.SetValue(item, stockId);           
                //        //stockFld.DynamicProperty.SetValue(item, stockObjs[0]);

                //        item["StockID_Id"] = Convert.ToInt64(dt[0]["FOrgStockId"]);
                //    }
                //}
                //#endregion

                ////目标单元数据
                FormMetadata destFormMetadata = ServiceHelper.GetService<IMetaDataService>().Load(this.Context, target) as FormMetadata;

                ////保存目标单据
                IOperationResult saveResult = ServiceHelper.GetService<ISaveService>().Save(this.Context, destFormMetadata.BusinessInfo, destObjs, OperateOption.Create());
                ////合并保存操作结果
                //result.MergeResult(saveResult);
                //根据操作结果构造返回结果
                if ((saveResult.ValidationErrors != null && saveResult.ValidationErrors.Count > 0))
                //|| (result.OperateResult != null && result.OperateResult.Count > 0))
                {
                    var errorInfo = string.Join(";", saveResult.ValidationErrors.Select(x => x.Message));
                    //this.View.ShowErrMessage("调用下推, 导致自动保存失败 原因：" + errorInfo);

                    //result.IsSuccess = false;
                    //this.View.ShowErrMessage("调用下推, 导致自动保存失败 原因：" + saveResult.ValidationErrors[0].Message.ToString());
                    throw new KDBusinessException("", "未知原因导致自动保存失败原因：" + errorInfo);
                }
                result = saveResult;
                //this.View.ShowMessage("1");
                // 取到需要自动提交、审核的单据内码 
                object[] pkArray = (from p in destObjs select p[0]).ToArray();
                //设置提交参数
                IOperationResult submitResult = ServiceHelper.GetService<ISubmitService>().Submit(this.Context, destFormMetadata.BusinessInfo, pkArray, "Submit", OperateOption.Create());

                // 判断提交结果，如果失败，则内部会抛出错误，回滚代码
                if (submitResult.IsSuccess == false)
                {
                    throw new KDBusinessException("", "未知原因导致自动提交失败！");
                }
                //设置审核参数
                IOperationResult auditResult = ServiceHelper.GetService<IAuditService>().Audit(this.Context, destFormMetadata.BusinessInfo, pkArray, OperateOption.Create());
                // 判断提交结果，如果失败，则内部会抛出错误，回滚代码
                if (auditResult.IsSuccess == false)
                {
                    throw new KDBusinessException("", "未知原因导致自动审核失败！");
                }
                //显示下推后的单据
                //ShowPushResult("k0f9e182dbc5247fcabc9479ddb300fa3", convertResult, destObjs);
                return result;
            }
            catch (Exception ex)
            {
                Logger.Error("跨组织下推订单报错", "跨组织下推订单报错 error:" + ex.Message + ex.StackTrace, ex);
                throw ex;
            }

        }

        private IOperationResult Invoke2(string source, string target, string tempFid, string sargetBillTypeId)
        {
            try
            {
                IOperationResult result = new OperationResult();
                //获取单据转换规则
                ConvertRuleElement ruleElement = ServiceHelper.GetService<IConvertService>().GetConvertRules(this.Context, source, target).FirstOrDefault();

                //如下代码 直接通过查询数据库获取单据转换源单数据
                ListSelectedRowCollection rows = new ListSelectedRowCollection();
                int i = 0;
                ListSelectedRow row = new ListSelectedRow(tempFid, string.Empty, i++, source);
                rows.Add(row);

                PushArgs pushArgs = new PushArgs(ruleElement, rows.ToArray());
                pushArgs.TargetBillTypeId = sargetBillTypeId;//单据类型
                                                             //转换生成目标单
                ConvertOperationResult convertResult = ServiceHelper.GetService<IConvertService>().Push(this.Context, pushArgs);
    
                ////合并转换操作结果
                //result.MergeResult(convertResult);

                ////目标单据数据集合
                DynamicObject[] destObjs = convertResult.TargetDataEntities.Select(r => r.DataEntity).ToArray();
                //根据实际情况，处理目标单据数据
                //destObjs[0]["Date"] = Convert.ToDateTime(sDate);
                DynamicObjectCollection col_FEntityDetail;
               var sdsas= JsonHelper.ToJson(destObjs);
                Logger.Error("目标单据数据集合", sdsas, new Exception ());
                this.View.ShowMessage("好了好了，就是这个按钮");
                //return result;
                ////if (target == "SAL_OUTSTOCK")//销售出库
                ////{
                //col_FEntityDetail = destObjs[0]["SAL_OUTSTOCKENTRY"] as DynamicObjectCollection;
                ////}
                ////else
                ////{//销售退货
                ////    col_FEntityDetail = destObjs[0]["SAL_RETURNSTOCKENTRY"] as DynamicObjectCollection;
                ////}
                //#region 
                //long sStockOrgID = 0;
                //sStockOrgID = Convert.ToInt64(destObjs[0]["StockOrgId_Id"]);


                //foreach (var item in col_FEntityDetail)
                //{
                //    //item["KeeperID_Id"] = item["OwnerID_Id"];//保管者

                //    string sStockSql = "select FOrgStockId  from v_BusinessOrgId where FORGID= " + sStockOrgID + " ";
                //    sStockSql = String.Format(@"/*dialect*/" + sStockSql);
                //    var dt = DBServiceHelper.ExecuteDynamicObject(this.Context, sStockSql);

                //    //if (dt.Count > 0 && Convert.ToInt64(dt[0]["FOrgStockId"]) != 0)
                //    if (dt.Count > 0)
                //    {
                //        //var targetBillMeta = ServiceHelper.GetService<IMetaDataService>().Load(this.Context, target) as FormMetadata;
                //        //BusinessInfo info = targetBillMeta.BusinessInfo;
                //        //BaseDataField stockFld = info.GetField("FStockId") as BaseDataField;
                //        //long stockId = Convert.ToInt64(dt[0]["FOrgStockId"]);
                //        //IViewService viewService = ServiceHelper.GetService<IViewService>();
                //        //DynamicObject[] stockObjs = viewService.LoadFromCache(this.Context, new object[] { stockId }, stockFld.RefFormDynamicObjectType);
                //        //stockFld.RefIDDynamicProperty.SetValue(item, stockId);           
                //        //stockFld.DynamicProperty.SetValue(item, stockObjs[0]);

                //        item["StockID_Id"] = Convert.ToInt64(dt[0]["FOrgStockId"]);
                //    }
                //}
                //#endregion

                ////目标单元数据
                FormMetadata destFormMetadata = ServiceHelper.GetService<IMetaDataService>().Load(this.Context, target) as FormMetadata;

                ////保存目标单据
                IOperationResult saveResult = ServiceHelper.GetService<ISaveService>().Save(this.Context, destFormMetadata.BusinessInfo, destObjs, OperateOption.Create());
                ////合并保存操作结果
                //result.MergeResult(saveResult);
                //根据操作结果构造返回结果
                if ((saveResult.ValidationErrors != null && saveResult.ValidationErrors.Count > 0))
                //|| (result.OperateResult != null && result.OperateResult.Count > 0))
                {
                    var errorInfo = string.Join(";", saveResult.ValidationErrors.Select(x => x.Message));
                    //this.View.ShowErrMessage("调用下推, 导致自动保存失败 原因：" + errorInfo);

                    //result.IsSuccess = false;
                    //this.View.ShowErrMessage("调用下推, 导致自动保存失败 原因：" + saveResult.ValidationErrors[0].Message.ToString());
                    throw new KDBusinessException("", "未知原因导致自动保存失败原因：" + errorInfo);
                }
                return result;
                //this.View.ShowMessage("1");
                // 取到需要自动提交、审核的单据内码 
                object[] pkArray = (from p in destObjs select p[0]).ToArray();
                //设置提交参数
                IOperationResult submitResult = ServiceHelper.GetService<ISubmitService>().Submit(this.Context, destFormMetadata.BusinessInfo, pkArray, "Submit", OperateOption.Create());

                // 判断提交结果，如果失败，则内部会抛出错误，回滚代码
                if (submitResult.IsSuccess == false)
                {
                    throw new KDBusinessException("", "未知原因导致自动提交失败！");
                }
                //设置审核参数
                IOperationResult auditResult = ServiceHelper.GetService<IAuditService>().Audit(this.Context, destFormMetadata.BusinessInfo, pkArray, OperateOption.Create());
                // 判断提交结果，如果失败，则内部会抛出错误，回滚代码
                if (auditResult.IsSuccess == false)
                {
                    throw new KDBusinessException("", "未知原因导致自动审核失败！");
                }
                //显示下推后的单据
                //ShowPushResult("k0f9e182dbc5247fcabc9479ddb300fa3", convertResult, destObjs);
                return result;
            }
            catch (Exception ex)
            {
                Logger.Error("同步报关信息时", "同步报关信息时 error:" + ex.Message + ex.StackTrace, ex);
                throw ex;
            }

        }

    }
}