From 196be8875acbf152da8a792a4906be8634e66d32 Mon Sep 17 00:00:00 2001 From: yuyubo <1870149533@qq.com> Date: Tue, 29 Apr 2025 19:37:04 +0800 Subject: [PATCH] 111 --- Pilot_KD_Parino/Common/BOSCommon.cs | 53 ++ Pilot_KD_Parino/Pilot_KD_Parino.csproj | 3 +- .../Sal_Order/PushSaleBillPlugIn.cs | 481 +++++++++--------- .../Sal_Order/PushSaleOutBillPlugIn.cs | 6 +- Pilot_KD_Parino/Sal_Order/SupplierClass.cs | 139 +++++ 5 files changed, 425 insertions(+), 257 deletions(-) create mode 100644 Pilot_KD_Parino/Common/BOSCommon.cs create mode 100644 Pilot_KD_Parino/Sal_Order/SupplierClass.cs diff --git a/Pilot_KD_Parino/Common/BOSCommon.cs b/Pilot_KD_Parino/Common/BOSCommon.cs new file mode 100644 index 0000000..7848d04 --- /dev/null +++ b/Pilot_KD_Parino/Common/BOSCommon.cs @@ -0,0 +1,53 @@ +using Kingdee.BOS; +using Kingdee.BOS.Core.Metadata.FieldElement; +using Kingdee.BOS.Orm; +using Kingdee.BOS.Orm.DataEntity; +using Kingdee.BOS.Orm.Metadata.DataEntity; +using Kingdee.BOS.Util; +using System; +using System.Collections.Generic; +using System.Linq; +using System.Text; +using System.Threading.Tasks; + +namespace Pilot_KD_Parino.Common +{ + public static class BOSCommon + { + /// + /// 给基础资料赋值 + /// + /// + /// + /// + /// + public static void SetBaseDataFieldValue(Context ctx, BaseDataField field, DynamicObject data, object value) + { + long result = 0L; + long.TryParse(value.ToString(), out result); + if ((value.ToString().Length > 1) || (result > 0L)) + { + DynamicObject newValue = LoadReferenceData(ctx, field.RefFormDynamicObjectType, value); + field.DynamicProperty.SetValue(data, newValue); + field.RefIDDynamicProperty.SetValue(data, value); + } + else + { + field.DynamicProperty.SetValue(data, null); + field.RefIDDynamicProperty.SetValue(data, 0); + } + } + + public static DynamicObject LoadReferenceData(Context ctx, DynamicObjectType dt, object pkValue) + { + if (pkValue.IsEmptyPrimaryKey()) + { + return null; + } + OperateOption option = OperateOption.Create(); + option.SetThrowExceptionWhenNotFind(false); + return Kingdee.BOS.ServiceHelper.BusinessDataServiceHelper.LoadSingle(ctx, pkValue, dt, option); + + } + } +} diff --git a/Pilot_KD_Parino/Pilot_KD_Parino.csproj b/Pilot_KD_Parino/Pilot_KD_Parino.csproj index 1637a79..acbebd5 100644 --- a/Pilot_KD_Parino/Pilot_KD_Parino.csproj +++ b/Pilot_KD_Parino/Pilot_KD_Parino.csproj @@ -310,6 +310,7 @@ + @@ -333,9 +334,9 @@ - + diff --git a/Pilot_KD_Parino/Sal_Order/PushSaleBillPlugIn.cs b/Pilot_KD_Parino/Sal_Order/PushSaleBillPlugIn.cs index ff07bca..72108d6 100644 --- a/Pilot_KD_Parino/Sal_Order/PushSaleBillPlugIn.cs +++ b/Pilot_KD_Parino/Sal_Order/PushSaleBillPlugIn.cs @@ -1,28 +1,23 @@ -using DevExpress.Xpo.DB.Helpers; -using FarPoint.Excel; -using Kingdee.BOS; +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.Core.Metadata.FieldElement; +using Kingdee.BOS.Core.Metadata.Util; 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; @@ -36,9 +31,17 @@ namespace Pilot_KD_Parino.Sal_Order public override void AfterBarItemClick(AfterBarItemClickEventArgs e) { base.AfterBarItemClick(e); - + //this.View.ShowMessage("669977"); + if (e.BarItemKey.Equals("tbSaleBill333", StringComparison.OrdinalIgnoreCase)) + { + var FEntity = this.View.Model.DataObject; + var json = JsonUtil.Serialize(FEntity); + Logger.Error("采购订单信息", json, new Exception()); + //var id = FEntity["id"]; + //string formid = FEntity["FFormId"].ToString(); + } if (e.BarItemKey.Equals("tbSaleBill222", StringComparison.OrdinalIgnoreCase)) { var FEntity = this.View.Model.DataObject; @@ -46,99 +49,51 @@ namespace Pilot_KD_Parino.Sal_Order //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); - - + //IOperationResult result = Invoke("SAL_SaleOrder", "d124a6be-5f97-4d1f-b5fd-e20e53e0ed2a", id.ToString(), "83d822ca3e374b4ab01e5dd46a0062bd", ref stockId); + IOperationResult result = Invoke("SAL_SaleOrder", "PUR_PurchaseOrder", id.ToString(), "83d822ca3e374b4ab01e5dd46a0062bd", ref stockId, FEntity, null); 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"); - } + string id2 = sheet["id"].ToString(); - //找到最开始的销售订单 - 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) - { + result = Invoke("PUR_PurchaseOrder", "SAL_SaleOrder", id2, "5eaf7dde-df05-4c11-accd-3a175f117968", ref stockId, sheet, FEntity); + //sheet = result.SuccessDataEnity.FirstOrDefault(); + //result = Invoke("SAL_DELIVERYNOTICE", "SAL_OUTSTOCK", sheet["id"].ToString(), "ad0779a4685a43a08f08d2e42d7bf3e9", ref stockId); - 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) + /// + /// + /// + /// + /// + /// + /// + /// + /// 本次操作页面的对象 + /// 最开始的销售单对象 + /// + private IOperationResult Invoke(string source, string target, string tempFid, string sargetBillTypeId, ref int stockId, DynamicObject FEntity, DynamicObject FEntity2) { try { IOperationResult result = new OperationResult(); //获取单据转换规则 - ConvertRuleElement ruleElement = ServiceHelper.GetService().GetConvertRules(this.Context, source, target).FirstOrDefault(); + ConvertRuleElement ruleElement; + if (target == "PUR_PurchaseOrder") + { + var ruleMetaData = ConvertServiceHelper.GetConvertRule(this.Context, "d124a6be-5f97-4d1f-b5fd-e20e53e0ed2a"); + ruleElement = ruleMetaData.Rule; + } + else + ruleElement = ServiceHelper.GetService().GetConvertRules(this.Context, source, target).FirstOrDefault(); //如下代码 直接通过查询数据库获取单据转换源单数据 ListSelectedRowCollection rows = new ListSelectedRowCollection(); int i = 0; @@ -150,8 +105,7 @@ namespace Pilot_KD_Parino.Sal_Order //转换生成目标单 ConvertOperationResult convertResult = ServiceHelper.GetService().Push(this.Context, pushArgs); - ////合并转换操作结果 - //result.MergeResult(convertResult); + ////目标单据数据集合 DynamicObject[] destObjs = convertResult.TargetDataEntities.Select(r => r.DataEntity).ToArray(); @@ -159,6 +113,166 @@ namespace Pilot_KD_Parino.Sal_Order var sdsas = JsonHelper.ToJson(destObjs); Logger.Error("目标单据数据集合", sdsas, new Exception()); int temStockId = stockId; + //采购订单 1 采购类型=02 生产物资采购 供应商=珠海兴诺能源技术有限公司 + string SupplierId_Id = ""; + string number = ""; + string name = ""; + if (target == "PUR_PurchaseOrder") + { + var beiHuoName1 = FEntity["F_SaleOrgId"] as DynamicObject; + string SaleOrgId_Id = FEntity["SaleOrgId_Id"].ToString(); + if (beiHuoName1 != null) + { + var beiHuoName2 = beiHuoName1["MultiLanguageText"] as DynamicObjectCollection; + if (beiHuoName2 != null && beiHuoName2.Count() > 0) + { + var beiHuoName3 = beiHuoName2[0]["Name"].ToString(); + + string sqltemp1 = $@"/*dialect*/ SELECT FUseOrgId,a.FNUMBER,b.FNAME,a.FSUPPLIERID FROM T_BD_SUPPLIER a + LEFT JOIN T_BD_SUPPLIER_L b ON a.FSUPPLIERID=b.FSUPPLIERID + WHERE FUseOrgId={SaleOrgId_Id} AND FNAME LIKE '%{beiHuoName3}%' "; + var supplierList = DBServiceHelper.ExecuteDynamicObject(this.Context, sqltemp1, null, null, CommandType.Text, null); + if (supplierList != null && supplierList.Count > 0) + { + var orderSheet = destObjs[0]; + + DynamicObject supplierObj = null;//.Select(t => t["FSUPPLIERID"].ToString()) + if (beiHuoName3 == "珠海兴诺") + { + supplierObj = supplierList.Where(t => t["FNAME"].ToString() == "珠海兴诺能源技术有限公司").FirstOrDefault(); + + + } + if (beiHuoName3 == "珠海派诺") + { + supplierObj = supplierList.Where(t => t["FNAME"].ToString() == "珠海派诺科技股份有限公司").FirstOrDefault(); + + } + else + { + supplierObj = supplierList.FirstOrDefault(); + + } + + SupplierId_Id = supplierObj["FSUPPLIERID"].ToString(); + orderSheet["SupplierId_Id"] = SupplierId_Id; + number = supplierObj["FNUMBER"].ToString(); + name = supplierObj["FNAME"].ToString(); + SupplierClass supplier = new SupplierClass(); + supplier.Id = int.Parse(SupplierId_Id); + supplier.Number = number; + supplier.UseOrgId_Id = int.Parse(SaleOrgId_Id); + //string json2= JsonHelper.ToJson(supplier); + + + //采购类型 + /** + * SELECT * FROM dbo.T_BAS_ASSISTANTDATAENTRY_l + WHERE FENTRYID IN ( SELECT FENTRYID FROM dbo.T_BAS_ASSISTANTDATAENTRY + WHERE fid='6736e9ea1d1dcb') + */ + orderSheet["F_Procurementtype_Id"] = "6736ea151d1dcf"; //采购类型 + + //明细价税合计 AllAmount_LC 税率 TaxRate POOrderEntry + var detailList = (orderSheet["POOrderEntry"] as DynamicObjectCollection).ToList(); + var saleDetailList = (FEntity["SaleOrderEntry"] as DynamicObjectCollection).ToList(); + if (detailList != null && detailList.Count > 0) + { + detailList.ForEach(t => + { + var dasda = t["Qty"].ToString(); + decimal qty = decimal.Parse(dasda); + var tempOne = saleDetailList.Where(h => h["MaterialId_Id"].ToString() == t["MaterialId_Id"].ToString() + && decimal.Parse(h["Qty"].ToString()) == qty).FirstOrDefault(); + if (tempOne != null) + { + t["Price"] = tempOne["Price"]; + t["AllAmount_LC"] = tempOne["AllAmount_LC"]; + t["AllAmount"] = tempOne["AllAmount"]; + t["TaxPrice"] = tempOne["TaxPrice"]; + t["TaxRate"] = tempOne["TaxRate"]; + t["TaxAmount"] = tempOne["TaxAmount"]; + t["Amount"] = tempOne["Amount"]; + + } + }); + + + } + + //this.View.ShowMessage($@"{beiHuoName3}备货组织跨组织下推订单完成"); + } + else + { + throw new KDBusinessException("", $@"{beiHuoName3}备货组织没有对应的同名供应商,无法跨组织推送采购订单"); + } + + } + else + { + throw new KDBusinessException("", $@"备货组织没有值"); + } + } + else + throw new KDBusinessException("", "推送跨组织采购订单必须选择备货组织"); + + } + if (target == "SAL_SaleOrder") + { + //客户，销售员，是否海外 + var beiHuoName1 = FEntity2["SaleOrgId"] as DynamicObject; + string SaleOrgId_Id = FEntity2["SaleOrgId_Id"].ToString(); + if (beiHuoName1 != null) + { + //通过上游销售单的销售组织找到对应的客户 + var beiHuoName2 = beiHuoName1["MultiLanguageText"] as DynamicObjectCollection; + if (beiHuoName2 != null && beiHuoName2.Count() > 0) + { + var beiHuoName3 = beiHuoName2[0]["Name"].ToString(); + + + var orderSheet = destObjs[0]; + orderSheet["SaleOrgId_Id"] = SaleOrgId_Id; + orderSheet["F_SFHW"] = "2"; + SupplierId_Id = orderSheet["SaleOrgId_Id"].ToString(); + string sqltemp1 = $@"/*dialect*/ SELECT FUseOrgId,a.FNUMBER,b.FNAME,a.FCUSTID FROM T_BD_CUSTOMER a + LEFT JOIN T_BD_CUSTOMER_L b ON a.FCUSTID=b.FCUSTID + WHERE FUseOrgId={SupplierId_Id} AND FNAME LIKE '%{beiHuoName3}%' "; + var keHuList = DBServiceHelper.ExecuteDynamicObject(this.Context, sqltemp1, null, null, CommandType.Text, null); + + if (keHuList != null && keHuList.Count > 0) + { + + + DynamicObject supplierObj = null;//.Select(t => t["FSUPPLIERID"].ToString()) + if (beiHuoName3 == "珠海兴诺") + { + supplierObj = keHuList.Where(t => t["FNAME"].ToString() == "珠海兴诺国际能源有限公司").FirstOrDefault(); + + + } + if (beiHuoName3 == "珠海派诺") + { + supplierObj = keHuList.Where(t => t["FNAME"].ToString() == "珠海派诺科技股份有限公司").FirstOrDefault(); + + } + else + { + supplierObj = keHuList.FirstOrDefault(); + + } + + SupplierId_Id = supplierObj["FCUSTID"].ToString(); + orderSheet["CustId_Id"] = SupplierId_Id; + number = supplierObj["FNUMBER"].ToString(); + name = supplierObj["FNAME"].ToString(); + + } + } + + }//F_SFHW + } + if (target == "PUR_ReceiveBill")//收料通知单,强制没有配置仓库的物料进成品仓库 { //var sheet = destObjs.FirstOrDefault(); PUR_ReceiveEntry @@ -167,7 +281,8 @@ namespace Pilot_KD_Parino.Sal_Order if (temStockId == 0) { - string sql2 = $@"/*dialect*/ SELECT FUseOrgId,fname, a.FSTOCKID,FForbidStatus,FDocumentStatus FROM T_BD_STOCK a + 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); @@ -183,14 +298,14 @@ namespace Pilot_KD_Parino.Sal_Order 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(); @@ -202,7 +317,7 @@ namespace Pilot_KD_Parino.Sal_Order // 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(); @@ -212,7 +327,7 @@ namespace Pilot_KD_Parino.Sal_Order // stockId = other3.Select(t => t.Id).FirstOrDefault(); // } - + // stock0.ForEach(t => // { // t["StockID_Id"] = stockId; @@ -226,7 +341,7 @@ namespace Pilot_KD_Parino.Sal_Order //throw new KDBusinessException("","还没开发好"); //var sheet = destObjs.FirstOrDefault(); PUR_ReceiveEntry string pur = ("SAL_DELIVERYNOTICEENTRY"); - var stocks3 = destObjs[0]; + var stocks3 = destObjs[0]; var stocks333 = stocks3[pur]; var stocks = stocks333 as DynamicObjectCollection; var stock0 = stocks.ToList(); @@ -239,55 +354,33 @@ namespace Pilot_KD_Parino.Sal_Order } - //根据实际情况，处理目标单据数据 - //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; + //sdsas = JsonHelper.ToJson(destObjs); + //Logger.Error("目标单据数据集合3", sdsas, new Exception()); + //destFormMetadata.BusinessInfo.Entrys.ForEach(t => ); + if (target == "PUR_PurchaseOrder") + { + destObjs[0]["SupplierId"] = BusinessDataServiceHelper.LoadSingle(this.Context, SupplierId_Id, (destFormMetadata.BusinessInfo.GetField("FSupplierId") as BaseDataField).RefFormDynamicObjectType); + } + + if (target == "SAL_SaleOrder") + { + destObjs[0]["SaleOrgId"] = BusinessDataServiceHelper.LoadSingle(this.Context, FEntity2["SaleOrgId_Id"].ToString(), (destFormMetadata.BusinessInfo.GetField("FSaleOrgId") as BaseDataField).RefFormDynamicObjectType); + destObjs[0]["CustId"] = BusinessDataServiceHelper.LoadSingle(this.Context, SupplierId_Id, (destFormMetadata.BusinessInfo.GetField("FCustId") as BaseDataField).RefFormDynamicObjectType); + + } + //Logger.Error("目标单据数据集合3", sdsas, new Exception()); + + IOperationResult saveResult2 = BusinessDataServiceHelper.Draft(this.Context, destFormMetadata.BusinessInfo, destObjs, OperateOption.Create()); + //var ddd = (from p in destObjs select p[0]).ToArray(); + //var ddd = saveResult2.SuccessDataEnity.Select(t => t).ToArray(); + //sdsas = JsonHelper.ToJson(ddd); + //Logger.Error("目标单据数据集合4", sdsas, new Exception()); ////保存目标单据 IOperationResult saveResult = ServiceHelper.GetService().Save(this.Context, destFormMetadata.BusinessInfo, destObjs, OperateOption.Create()); ////合并保存操作结果 @@ -334,123 +427,7 @@ namespace Pilot_KD_Parino.Sal_Order } - 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; - } - - } } } diff --git a/Pilot_KD_Parino/Sal_Order/PushSaleOutBillPlugIn.cs b/Pilot_KD_Parino/Sal_Order/PushSaleOutBillPlugIn.cs index f88c278..118a922 100644 --- a/Pilot_KD_Parino/Sal_Order/PushSaleOutBillPlugIn.cs +++ b/Pilot_KD_Parino/Sal_Order/PushSaleOutBillPlugIn.cs @@ -91,10 +91,8 @@ namespace Pilot_KD_Parino.Sal_Order tempFid = int.Parse(dt.Select(t => t["FSBILLID"]).FirstOrDefault().ToString()); } if (tablename.ToUpper() != "T_PUR_POORDERENTRY") - { - - throw new KDBusinessException("", "没有上查关联的跨组织的采购订单：" + tablename); - + { + throw new KDBusinessException("", "没有上查关联的跨组织的采购订单：" + tablename); } int stockId = 0; diff --git a/Pilot_KD_Parino/Sal_Order/SupplierClass.cs b/Pilot_KD_Parino/Sal_Order/SupplierClass.cs new file mode 100644 index 0000000..591e85c --- /dev/null +++ b/Pilot_KD_Parino/Sal_Order/SupplierClass.cs @@ -0,0 +1,139 @@ +using System; +using System.Collections.Generic; +using System.Linq; +using System.Text; +using System.Threading.Tasks; + +namespace Pilot_KD_Parino.Sal_Order +{ + + public class SupplierClass + { + /// + /// + /// + public string DirtyFlags { get; set; } + /// + /// + /// + public string FromDatabase { get; set; } + /// + /// + /// + public int Id { get; set; } + /// + /// + /// + public int msterID { get; set; } + /// + /// + /// + public List MultiLanguageText { get; set; } + /// + /// + /// + public List Name { get; set; } + /// + /// + /// + public string Number { get; set; } + /// + /// + /// + public int UseOrgId_Id { get; set; } + /// + /// + /// + public UseOrgId UseOrgId { get; set; } + } + + public class MultiLanguageTextItem + { + /// + /// + /// + public string DirtyFlags { get; set; } + /// + /// + /// + public string FromDatabase { get; set; } + /// + /// + /// + public int PkId { get; set; } + /// + /// + /// + public int LocaleId { get; set; } + /// + /// 珠海兴诺能源技术有限公司 + /// + public string Name { get; set; } + } + + public class NameItem + { + /// + /// + /// + public int Key { get; set; } + /// + /// 珠海兴诺能源技术有限公司 + /// + public string Value { get; set; } + } + + public class SnapshotsItem + { + /// + /// + /// + public string TableName { get; set; } + /// + /// + /// + public string Oids { get; set; } + /// + /// + /// + public string OidType { get; set; } + } + + + + + public class UseOrgId + { + /// + /// + /// + public string DirtyFlags { get; set; } + /// + /// + /// + public List Snapshots { get; set; } + /// + /// + /// + public string FromDatabase { get; set; } + /// + /// + /// + public int Id { get; set; } + /// + /// + /// + public string Number { get; set; } + /// + /// + /// + public List MultiLanguageText { get; set; } + /// + /// + /// + public List Name { get; set; } + } + + + +}