From af5743fb96ba3d38cd6f4905258a47e7e0eb42ef Mon Sep 17 00:00:00 2001 From: yuyubo <1870149533@qq.com> Date: Mon, 28 Apr 2025 16:04:47 +0800 Subject: [PATCH] 222 --- Pilot_KD_Parino/Pilot_KD_Parino.csproj | 1 + Pilot_KD_Parino/QPHY_AutoWrire/Bill5.cs | 17 +- .../Sal_Order/PushSaleBillPlugIn.cs | 456 ++++++++++++++++++ 3 files changed, 468 insertions(+), 6 deletions(-) create mode 100644 Pilot_KD_Parino/Sal_Order/PushSaleBillPlugIn.cs diff --git a/Pilot_KD_Parino/Pilot_KD_Parino.csproj b/Pilot_KD_Parino/Pilot_KD_Parino.csproj index 5c71130..1637a79 100644 --- a/Pilot_KD_Parino/Pilot_KD_Parino.csproj +++ b/Pilot_KD_Parino/Pilot_KD_Parino.csproj @@ -334,6 +334,7 @@ + diff --git a/Pilot_KD_Parino/QPHY_AutoWrire/Bill5.cs b/Pilot_KD_Parino/QPHY_AutoWrire/Bill5.cs index c8e0719..dd4f047 100644 --- a/Pilot_KD_Parino/QPHY_AutoWrire/Bill5.cs +++ b/Pilot_KD_Parino/QPHY_AutoWrire/Bill5.cs @@ -59,8 +59,6 @@ namespace Pilot_KD_Parino.QPHY_AutoWrire public override void OnLoad(EventArgs e) { base.OnLoad(e); - - var showParameter = new DynamicFormShowParameter(); showParameter.FormId = "NAAD_ZiDongHeXiao"; showParameter.ParentPageId = this.View.PageId; @@ -427,6 +425,9 @@ namespace Pilot_KD_Parino.QPHY_AutoWrire FType = Convert.ToString(item["FType"]), FISHX = item["FISHX"]?.ToString(), FWeiYi = item["FWeiYi"]?.ToString(), + FaHuoAmount30Days = Convert.ToDouble( item["FaHuoAmount30Days"].ToString()), + FInvoiceAmount30Days= Convert.ToDouble(item["FInvoiceAmount30Days"].ToString()), + }).ToList(); var SaleBILLLISNew = SaleBILLLIS.Where(a => a.FISHX != "已核销配对").ToList(); var ReceiveBILLLIST2 = new List(); @@ -473,7 +474,7 @@ namespace Pilot_KD_Parino.QPHY_AutoWrire //var dasdsas = oneToOneTemp.Where(h => h.FBIllNO == "PL-XSDD20250400471").FirstOrDefault(); var saleList1 = oneToOneTemp.Select(t => t.FBIllNO).Distinct().ToList(); var ReceiveList1 = oneToOneTemp.Select(t => t.UFbillNo).Distinct().ToList(); - if (saleList1.Count > ReceiveList1.Count) + if (saleList1.Count() > ReceiveList1.Count()) { List deleteFBIllNOList = new List(); ReceiveList1.ForEach(t => @@ -557,7 +558,7 @@ namespace Pilot_KD_Parino.QPHY_AutoWrire //var dasdsas = oneToOneTemp.Where(h => h.FBIllNO == "PL-XSDD20250400471").FirstOrDefault(); var saleList22 = oneToOneTemp2.Select(t => t.FBIllNO).Distinct().ToList(); var ReceiveList22 = oneToOneTemp2.Select(t => t.UFbillNo).Distinct().ToList(); - if (saleList22.Count > ReceiveList22.Count) + if (saleList22.Count() > ReceiveList22.Count()) { List deleteFBIllNOList = new List(); ReceiveList22.ForEach(t => @@ -636,13 +637,13 @@ namespace Pilot_KD_Parino.QPHY_AutoWrire var SaleBILLLIS2Sa333 = SaleBILLLISNew.Where(t => t.FISHX != "已核销配对" && t.FDAMOUNT > 0 ).OrderBy(t => t.FClient).ThenByDescending(t => t.FDate).ToList(); ReceiveBILLLIST = ReceiveBILLLIST2.Where(a => a.F_RowNew == 1 && a.FISHX != "已核销配对" && a.FDAMOUNT > 0).OrderBy(t => t.FClient).ThenByDescending(t => t.FDate).ToList(); - var oneToOneTemp3 = (from q in SaleBILLLIS2Sa222 + var oneToOneTemp3 = (from q in SaleBILLLIS2Sa333 join u in ReceiveBILLLIST on new { q.FClient, FDAMOUNT = q.FInvoiceAmount30Days } equals new { u.FClient, u.FDAMOUNT } select new { q.FClient, q.FBIllNO, q.FCONTRACTNUMBER, u.FDAMOUNT, UFbillNo = u.FBIllNO }).ToList(); //var dasdsas = oneToOneTemp.Where(h => h.FBIllNO == "PL-XSDD20250400471").FirstOrDefault(); var saleList33 = oneToOneTemp3.Select(t => t.FBIllNO).Distinct().ToList(); var ReceiveList33 = oneToOneTemp3.Select(t => t.UFbillNo).Distinct().ToList(); - if (SaleBILLLIS2Sa333.Count > ReceiveList33.Count) + if (SaleBILLLIS2Sa333.Count() > ReceiveList33.Count()) { List deleteFBIllNOList = new List(); ReceiveList33.ForEach(t => @@ -1612,7 +1613,11 @@ namespace Pilot_KD_Parino.QPHY_AutoWrire this.View.Model.SetValue("F_Ordercategory2", SaleBILLLIS2[i].F_Ordercategory2, i); this.View.Model.SetValue("F_Ordercategory", SaleBILLLIS2[i].F_Ordercategory, i); this.View.Model.SetValue("FInvoiceAmount", SaleBILLLIS2[i].FInvoiceAmount, i); + this.View.Model.SetValue("FInvoiceAmount30Days", SaleBILLLIS2[i].FInvoiceAmount30Days, i); + this.View.Model.SetValue("FaHuoAmount30Days", SaleBILLLIS2[i].FaHuoAmount30Days, i); + //FaHuoAmount30Days = Convert.ToDouble(item["FaHuoAmount30Days"]), + //FInvoiceAmount30Days = Convert.ToDouble(item["FInvoiceAmount30Days"]), } diff --git a/Pilot_KD_Parino/Sal_Order/PushSaleBillPlugIn.cs b/Pilot_KD_Parino/Sal_Order/PushSaleBillPlugIn.cs new file mode 100644 index 0000000..ff07bca --- /dev/null +++ b/Pilot_KD_Parino/Sal_Order/PushSaleBillPlugIn.cs @@ -0,0 +1,456 @@ +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 pkIds = new List(); + //List pkEntryIds = new List(); + //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().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().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 other3 = JsonHelper.ToObject>(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().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(); + // //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().Load(this.Context, target) as FormMetadata; + + ////保存目标单据 + IOperationResult saveResult = ServiceHelper.GetService().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().Submit(this.Context, destFormMetadata.BusinessInfo, pkArray, "Submit", OperateOption.Create()); + + // 判断提交结果，如果失败，则内部会抛出错误，回滚代码 + if (submitResult.IsSuccess == false) + { + throw new KDBusinessException("", "未知原因导致自动提交失败！"); + } + //设置审核参数 + IOperationResult auditResult = ServiceHelper.GetService().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().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().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().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(); + // //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().Load(this.Context, target) as FormMetadata; + + ////保存目标单据 + IOperationResult saveResult = ServiceHelper.GetService().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().Submit(this.Context, destFormMetadata.BusinessInfo, pkArray, "Submit", OperateOption.Create()); + + // 判断提交结果，如果失败，则内部会抛出错误，回滚代码 + if (submitResult.IsSuccess == false) + { + throw new KDBusinessException("", "未知原因导致自动提交失败！"); + } + //设置审核参数 + IOperationResult auditResult = ServiceHelper.GetService().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; + } + + } + + } +}