From a611212c18ffc298a6db7f5ca37a1dc5fea4f03f Mon Sep 17 00:00:00 2001 From: yuyubo <1870149533@qq.com> Date: Fri, 18 Apr 2025 13:42:20 +0800 Subject: [PATCH] 1 --- Pilot_KD_Parino/QPHY_AutoWrire/Bill5.cs | 103 ++++------ .../Sal_Order/PushSaleOutBillPlugIn.cs | 188 ++++++++++++++++++ 2 files changed, 229 insertions(+), 62 deletions(-) create mode 100644 Pilot_KD_Parino/Sal_Order/PushSaleOutBillPlugIn.cs diff --git a/Pilot_KD_Parino/QPHY_AutoWrire/Bill5.cs b/Pilot_KD_Parino/QPHY_AutoWrire/Bill5.cs index 05a4331..8088cce 100644 --- a/Pilot_KD_Parino/QPHY_AutoWrire/Bill5.cs +++ b/Pilot_KD_Parino/QPHY_AutoWrire/Bill5.cs @@ -647,6 +647,45 @@ namespace Pilot_KD_Parino.QPHY_AutoWrire //}); + ////1个收款单对应多张销售订单 + //SaleBILLLIS2Sa2 = SaleBILLLISNew.Where(t => t.FISHX != "已核销配对").OrderBy(t => t.FClient).ThenBy(t => t.FCONTRACTNUMBER).ThenBy(t => t.FDate).ToList(); + //ReceiveBILLLIST = ReceiveBILLLIST2.Where(a => a.F_RowNew == 1 && a.FISHX != "已核销配对").OrderBy(t => t.FClient).ThenBy(t => t.FDate).ToList(); + //ReceiveBILLLIST.ForEach(t => + //{ + // var tempList = SaleBILLLIS2Sa2.Where(h => h.FClient == t.FClient && t.FDAMOUNT >= h.FDAMOUNT && h.FISHX != "已核销配对").OrderBy(h => h.FBIllNO).ToList(); + // List sales1 = new List { t.FDAMOUNT }; + // var payments2 = tempList.Select(k => k.FDAMOUNT).ToList(); + + // var matches = CombinationGenerator_yuyubo.MatchSalesAndPayments(sales1, payments2); + // var FDAMOUNT = t.FDAMOUNT; + // if (matches.Count > 0) + // { + // var FDAMOUNTList = matches[0].FirstOrDefault(); + // tempList = tempList.Where(h => FDAMOUNTList.Contains(h.FDAMOUNT)).OrderBy(h => h.FDate).ToList(); + // var fbillNoList = tempList.Select(h => h.FBIllNO).ToList(); + // var ReceiveBILLLTempList = SaleBILLLIS2Sa2.Where(h => fbillNoList.Contains(h.FBIllNO)).ToList(); + // List fString = new List(); + // ReceiveBILLLTempList.ForEach(item => + // { + // //更新收款单数据 + // if (FDAMOUNT > 0) + // { + // item.FSKBIllNO = t.FBIllNO; + // item.FISHX = "已核销配对"; + // //item.FCONTRACTNUMBER = t.FCONTRACTNUMBER; + // fString.Add(item.FCONTRACTNUMBER); + + // } + // }); + // //更新销售订单数据 + // t.FISHX = "已核销配对"; + // string fCONTRACTNUMBER = string.Join(",", fString); + // //更新收款单数据 + // t.FCONTRACTNUMBER = fCONTRACTNUMBER; + // } + + //}); + #endregion #endregion ////删除数据 @@ -716,68 +755,8 @@ namespace Pilot_KD_Parino.QPHY_AutoWrire this.View.Model.SetValue("F_ISHX", false, Rowindex + i); } - //GridSetRowBackcolor(this.View, "FEntity2", "#C6E0B4", item.FRow); - - //if (strings.Count() == 1 && item.FWeiYi == "否") - //{ - // for (int i = 0; i < SaleBILLLISNew2.Count; i++) - // { - // if (strings.Contains(SaleBILLLISNew2[i].FCONTRACTNUMBER)) - // { - // var Rowindex = this.View.Model.GetEntryRowCount("FEntity2"); - // this.View.Model.SetValue("FPARENTROWID", FROWID, item.FRow); - // this.View.Model.CreateNewEntryRow("FEntity2"); - // this.View.Model.SetValue("FROWID", SequentialGuid.NewGuid().ToString(), Rowindex); - // this.View.Model.SetValue("FPARENTROWID", FROWID, Rowindex); - // this.View.Model.SetValue("FBILLNO2", SaleBILLLISNew2[i].FBIllNO, Rowindex); - // if (DateTime.TryParseExact(item?.FDate, dateFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out DateTime parsedDate)) - // { - // this.View.Model.SetValue("FDate2", item?.FDate, Rowindex); - // } - // else - // { - // this.View.Model.SetValue("FDate2", DateTime.Now.AddDays(-1 * Convert.ToInt32(item?.FDate)).ToString("yyyy-MM-dd"), Rowindex); - // } - // this.View.Model.SetValue("F_MBBA_Decimal_imu", item.FDAMOUNT, Rowindex); - // this.View.Model.SetValue("FClient2", SaleBILLLISNew2[i].FClient, Rowindex); - // this.View.Model.SetValue("FCreated2", SaleBILLLISNew2[i].FCreated, Rowindex); - // this.View.Model.SetValue("FCONTRACTNUMBER2", SaleBILLLISNew2[i].FCONTRACTNUMBER, Rowindex); - // this.View.Model.SetValue("FSalesman2", SaleBILLLISNew2[i].FSalesman, Rowindex); - // this.View.Model.SetValue("F_MBBA_Decimal_qtr", SaleBILLLISNew2[i].FALLAMOUNT, Rowindex); - // this.View.UpdateView("FEntity2"); - // } - // } - //} - //else - //{ - // for (int i = 0; i < SaleBILLLISNew2.Count; i++) - // { - // if (strings.Contains(SaleBILLLISNew2[i].FCONTRACTNUMBER)) - // { - // var Rowindex = this.View.Model.GetEntryRowCount("FEntity2"); - // this.View.Model.SetValue("FPARENTROWID", FROWID, item.FRow); - // this.View.Model.CreateNewEntryRow("FEntity2"); - // this.View.Model.SetValue("FROWID", SequentialGuid.NewGuid().ToString(), Rowindex); - // this.View.Model.SetValue("FPARENTROWID", FROWID, Rowindex); - // this.View.Model.SetValue("FBILLNO2", SaleBILLLISNew2[i].FBIllNO, Rowindex); - // if (DateTime.TryParseExact(item?.FDate, dateFormat, CultureInfo.InvariantCulture, DateTimeStyles.None, out DateTime parsedDate)) - // { - // this.View.Model.SetValue("FDate2", item?.FDate, Rowindex); - // } - // else - // { - // this.View.Model.SetValue("FDate2", DateTime.Now.AddDays(-1 * Convert.ToInt32(item?.FDate)).ToString("yyyy-MM-dd"), Rowindex); - // } - // this.View.Model.SetValue("F_MBBA_Decimal_imu", SaleBILLLISNew2[i].FALLAMOUNT, Rowindex); - // this.View.Model.SetValue("FClient2", SaleBILLLISNew2[i].FClient, Rowindex); - // this.View.Model.SetValue("FCreated2", SaleBILLLISNew2[i].FCreated, Rowindex); - // this.View.Model.SetValue("FCONTRACTNUMBER2", SaleBILLLISNew2[i].FCONTRACTNUMBER, Rowindex); - // this.View.Model.SetValue("FSalesman2", SaleBILLLISNew2[i].FSalesman, Rowindex); - // this.View.Model.SetValue("F_MBBA_Decimal_qtr", SaleBILLLISNew2[i].FALLAMOUNT, Rowindex); - // this.View.UpdateView("FEntity2"); - // } - // } - //} + + this.Model.SetValue("FROWEXPANDTYPE", (int)ENUM_ROWTYPE.Expand, item.FRow); } } diff --git a/Pilot_KD_Parino/Sal_Order/PushSaleOutBillPlugIn.cs b/Pilot_KD_Parino/Sal_Order/PushSaleOutBillPlugIn.cs new file mode 100644 index 0000000..a57088e --- /dev/null +++ b/Pilot_KD_Parino/Sal_Order/PushSaleOutBillPlugIn.cs @@ -0,0 +1,188 @@ +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.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.Log; +using Kingdee.BOS.Orm; +using Kingdee.BOS.Orm.DataEntity; +using Kingdee.BOS.ServiceHelper; +using System; +using System.Collections.Generic; +using System.ComponentModel; +using System.Data; +using System.Linq; +namespace Pilot_KD_Parino.Sal_Order +{ + [Description("批量下推生成销售出库单插件")] + public class PushSaleOutBillPlugIn : AbstractListPlugIn + { + long sScrId = 0; + string sScrBillNo = ""; + public override void BarItemClick(BarItemClickEventArgs e) + { + base.BarItemClick(e); + long sOutId = 0;//珠海分布式调出单单号内码 + string sOutBillNo = "";//珠海分布式调出单单号 + bool flag = true; + string sBillNo = ""; + long sEntryId = 0; + long slevel = 2; + long sId = 0; + if (e.BarItemKey == "tbPushSalOut")//批量下推调拨 + { + ListSelectedRowCollection rows = this.ListView.SelectedRowsInfo; + 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 getSourceSql, string sargetBillTypeId) + { + try + { + IOperationResult result = new OperationResult(); + //获取单据转换规则 + ConvertRuleElement ruleElement = ServiceHelper.GetService().GetConvertRules(this.Context, source, target).FirstOrDefault(); + + //如下代码 直接通过查询数据库获取单据转换源单数据 + ListSelectedRowCollection rows = new ListSelectedRowCollection(); + int i = 0; + using (IDataReader reader = DBUtils.ExecuteReader(this.Context, getSourceSql)) + { + while (reader.Read()) + { + ListSelectedRow row = new ListSelectedRow(reader["FID"].ToString(), 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; + ////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); + } + //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; + } + + } + + } +}