using Kingdee.BOS; using Kingdee.BOS.App; 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.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 Kingdee.BOS.Util; using Pilot_KD_Parino.Common; using System; using System.ComponentModel; using System.Data; using System.Linq; namespace Pilot_KD_Parino.Sal_Order { [Description("下推生成销售出库单及联动生成其他单的插件"), HotUpdate] public class PushSaleOutBillPlugIn : AbstractDynamicFormPlugIn // AbstractListPlugIn { long sScrId = 0; string sScrBillNo = ""; public override void AfterBarItemClick(AfterBarItemClickEventArgs e) { base.AfterBarItemClick(e); if (e.BarItemKey.Equals("tbPushSalOut111", StringComparison.OrdinalIgnoreCase)) { var FEntity = this.View.Model.DataObject; var id = FEntity["id"]; string formid = FEntity["FFormId"].ToString(); //var detailList = (FEntity["SAL_DELIVERYNOTICEENTRY"]); //发货通知单或者发货出库单 string getSourceSql = $@"/*dialect*/SELECT FSTABLENAME,FSBILLID FROM dbo.T_{formid}ENTRY_LK WHERE FENTRYID IN ( SELECT FENTRYID FROM dbo.T_{formid}ENTRY WHERE FID = {id})"; var dt = DBServiceHelper.ExecuteDynamicObject(this.Context, getSourceSql); if (dt == null || dt.Count == 0) { this.View.ShowMessage("没有上查关联的发货通知单"); } int tempFid = int.Parse(dt.Select(t => t["FSBILLID"]).FirstOrDefault().ToString()); string tablename = dt.Select(t => t["FSTABLENAME"]).FirstOrDefault().ToString(); int xiaoFid = 0; //找到采购订单 for (int kk = 0; kk < 6 && tablename.ToUpper() != "T_PUR_POORDERENTRY"; 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("没有上查关联的销售单"); //} ////共享的采购订单 //tempFid = int.Parse(dt.Select(t => t["FSBILLID"]).FirstOrDefault().ToString()); //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) { break; //this.View.ShowMessage("没有上查关联的跨组织的采购订单"); } else { tablename = dt.Select(t => t["FSTABLENAME"]).FirstOrDefault().ToString(); tempFid = int.Parse(dt.Select(t => t["FSBILLID"]).FirstOrDefault().ToString()); } } if (tablename.ToUpper() != "T_PUR_POORDERENTRY") { getSourceSql = $@"/*dialect*/SELECT FSTABLENAME,FSBILLID,FENTRYID FROM dbo.T_PUR_POORDERENTRY_LK WHERE FSBILLID= {tempFid}"; dt = DBServiceHelper.ExecuteDynamicObject(this.Context, getSourceSql); if (dt == null || dt.Count == 0) { throw new KDBusinessException("", "没有上查关联的跨组织的采购订单：" + tablename); } else { xiaoFid = tempFid; //tablename = dt.Select(t => t["FSTABLENAME"]).FirstOrDefault().ToString(); //tempFid = int.Parse(dt.Select(t => t["FSBILLID"]).FirstOrDefault().ToString()); var FENTRYIDList = dt.Select(t => int.Parse(t["FENTRYID"].ToString())).ToList(); string ids = string.Join(",", FENTRYIDList); getSourceSql = $@"/*dialect*/ SELECT FID FROM T_PUR_POORDERENTRY WHERE FENTRYID IN({ids})"; dt = DBServiceHelper.ExecuteDynamicObject(this.Context, getSourceSql); if (dt == null || dt.Count == 0) { throw new KDBusinessException("", "没有上查关联的跨组织的采购订单：" + tablename); } else { tempFid = int.Parse(dt.FirstOrDefault()["FID"].ToString()); } } } int stockId = 0; IOperationResult result = Invoke("PUR_PurchaseOrder", "PUR_ReceiveBill", tempFid.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" && xiaoFid == 0; 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" && xiaoFid == 0) { throw new KDBusinessException("", "推送销售发货通知单失败,没有上查关联的跨组织的销售订单：" + tablename); } if (xiaoFid > 0) tempFid = xiaoFid; getSourceSql = $@"/*dialect*/ SELECT FSALEORGID FROM T_SAL_ORDER WHERE fid ={tempFid}"; dt = DBServiceHelper.ExecuteDynamicObject(this.Context, getSourceSql); string saleorgid = ""; if (dt != null && dt.Count > 0) { saleorgid =dt.FirstOrDefault()["FSALEORGID"].ToString(); } //如果源头销售订单是珠海派诺或者珠海兴诺的销售订单，只推送到采购入库就行了。 找到最开始的销售发货通知单 if(saleorgid!="100302" && saleorgid != "100303") { getSourceSql = $@"/*dialect*/SELECT FSTABLENAME,FSBILLID,FENTRYID FROM dbo.T_SAL_DELIVERYNOTICEENTRY_LK WHERE FSBILLID= {tempFid}"; dt = DBServiceHelper.ExecuteDynamicObject(this.Context, getSourceSql); if (dt == null || dt.Count == 0) { result = Invoke("SAL_SaleOrder", "SAL_DELIVERYNOTICE", tempFid.ToString(), "193822715afc48aa9fa6d6beca7700ab", ref stockId); sheet = result.SuccessDataEnity.FirstOrDefault(); tempFid = int.Parse(sheet["id"].ToString()); //throw new KDBusinessException("", "没有上查关联的跨组织的采购订单：" + tablename); } else { var FENTRYIDList = dt.Select(t => int.Parse(t["FENTRYID"].ToString())).ToList(); string ids = string.Join(",", FENTRYIDList); getSourceSql = $@"/*dialect*/ SELECT FID FROM T_SAL_DELIVERYNOTICEENTRY WHERE FENTRYID IN({ids})"; dt = DBServiceHelper.ExecuteDynamicObject(this.Context, getSourceSql); if (dt == null || dt.Count == 0) { throw new KDBusinessException("", "没有上查关联的跨组织的发货通知单：" + tablename); } else { tempFid = int.Parse(dt.FirstOrDefault()["FID"].ToString()); } } result = Invoke("SAL_DELIVERYNOTICE", "SAL_OUTSTOCK", tempFid.ToString(), "ad0779a4685a43a08f08d2e42d7bf3e9", ref stockId); } //result = Invoke("SAL_SaleOrder", "SAL_DELIVERYNOTICE", tempFid.ToString(), "193822715afc48aa9fa6d6beca7700ab", ref stockId); //sheet = result.SuccessDataEnity.FirstOrDefault(); 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; } } } }