【场景】一般的业务单据指定了link实体，如果下推的时候跟link无关，则无法关联。
针对这种场景目前标准产品无法实现
【案例】采购申请单下推采购订单，而后采购订单通过选单建立自定义关系
<0>数据准备
已经跟采购申请单关联的采购订单
<1>第二个关系建立准备
<2>支持选单选择其他单据填入到另外的实体；但是不会关联(仅携带)
<3>通过操作服务插件保存时，保存自定义关联
```csharp
using Kingdee.BOS;
using Kingdee.BOS.Core.DynamicForm.PlugIn;
using Kingdee.BOS.Core.DynamicForm.PlugIn.Args;
using Kingdee.BOS.ServiceHelper;
using System;
using System.Collections.Generic;
namespace DynamicFormPlugIn.BillConvert
{
[Kingdee.BOS.Util.HotUpdate]
[System.ComponentModel.Description("手动创建关联")]
public class CreateBusinessFlowNodePlugIn : AbstractOperationServicePlugIn
{
public class KeyConst
{
public static string SrcForm = "k85eec12fa5f24be7800779a5cfa22efd";
public static string TgtForm = "PUR_PurchaseOrder";
public static string Field_SBillId = "F_BHR_Integer";
public static string Entity = "F_BHR_Entity";
}
public override void OnPreparePropertys(PreparePropertysEventArgs e)
{
e.FieldKeys.Add(KeyConst.Field_SBillId);
}
/*
* 手动创建关联关系
* 操作逻辑：每次比对历史数据和本次修改后数据包的关联记录
* 历史的没有则为新增，数据包没有的则为删除
*
* 注意：由于业务流程有归档，因此本插件仅建议尽可能在归档业务前完成此逻辑，
* 获取历史数据比对支持归档查询：https://vip.kingdee.com/article/71661049120113152?productLineId=1
* 删除不支持归档删除，仅支持在当前表删除；一般的保存操作会将归档数据激活还原到当前表，但是部分场景不会
* 因此如果需要长时间后还需要调整关联关系的话，只能将业务流程的归档时间调大
*/
public override void EndOperationTransaction(EndOperationTransactionArgs e)
{
const string HeadKey = "FBillHead";
var srcTableDefine = BusinessFlowServiceHelper.LoadTableDefine(Context, KeyConst.SrcForm, HeadKey, true);
var tgtTableDefine = BusinessFlowServiceHelper.LoadTableDefine(Context, KeyConst.TgtForm, HeadKey, true);
Kingdee.BOS.Core.Metadata.EntityElement.Entity entity = this.BusinessInfo.GetEntity(KeyConst.Entity);
Kingdee.BOS.Core.Metadata.FieldElement.Field field = this.BusinessInfo.GetField(KeyConst.Field_SBillId);
foreach(var dataObj in e.DataEntitys)
{
int billId = Kingdee.BOS.Util.ObjectUtils.Object2Int(dataObj[0]);
var entityRows = dataObj[entity.EntryName] as Kingdee.BOS.Orm.DataEntity.DynamicObjectCollection;
if (entityRows.Count == 0)
continue;
Dictionary<int, List<string>> linkBillIds = SelectAllLinkNodes(srcTableDefine, tgtTableDefine, billId);
HashSet<int> curLinkIds = new HashSet<int>();
foreach (var entityRow in entityRows)
{
int srcBillId = Kingdee.BOS.Util.ObjectUtils.Object2Int(entityRow[field.PropertyName]);
curLinkIds.Add(srcBillId);
if(linkBillIds.ContainsKey(srcBillId))
{
continue;
}
CreateNode(srcTableDefine, srcBillId, tgtTableDefine, billId);
}
foreach(var hisBillId in linkBillIds)
{
if(curLinkIds.Contains(hisBillId.Key))
{
continue;
}
foreach(var instId in hisBillId.Value)
{
DeleteNode(instId);
}
}
}
}
/// <summary>
/// 创建关联节点
/// </summary>
/// <param name="srcForm"></param>
/// <param name="srcBillId"></param>
/// <param name="tgtForm"></param>
/// <param name="tgtBillId"></param>
private void CreateNode(Kingdee.BOS.BusinessEntity.BusinessFlow.TableDefine srcTd, int srcBillId,
Kingdee.BOS.BusinessEntity.BusinessFlow.TableDefine tgtTd, int tgtBillId)
{
/*
* 创建关联逻辑
* https://vip.kingdee.com/article/162633?productLineId=1
*/
string instId = Guid.NewGuid().ToString();
string rootId = Guid.NewGuid().ToString();
string nodeId = Guid.NewGuid().ToString();
Kingdee.BOS.App.Data.SqlObject sqlInst, sqlRoot, sqlNode;
List<Kingdee.BOS.App.Data.SqlObject> sqlObjList = new List<Kingdee.BOS.App.Data.SqlObject>();
{
string strCreateInst = string.Format(@"INSERT INTO T_BF_INSTANCE
(FINSTANCEID,FFLOWID,FSOURCEID,FMASTERID,FSTATUS,FFIRSTFORMID,FFIRSTBILLID,FFIRSTBILLNO,FSTARTTIME) VALUES
(@InstId, '','',@InstId,'A',@SrcForm, @SrcBillId,'',GETDATE())");
List<SqlParam> paramInst = new List<SqlParam>();
paramInst.Add(new SqlParam("@InstId", KDDbType.AnsiString, instId));
paramInst.Add(new SqlParam("@SrcForm", KDDbType.AnsiString, srcTd.TableNumber));
paramInst.Add(new SqlParam("@SrcBillId", KDDbType.Int32, srcBillId));
sqlInst = new Kingdee.BOS.App.Data.SqlObject(strCreateInst, paramInst);
sqlObjList.Add(sqlInst);
}
{
string strCreateRoot = string.Format(@"INSERT INTO T_BF_INSTANCEENTRY
(FROUTEID, FINSTANCEID, FLINEID, FSTABLENAME, FSID, FTTABLENAME, FTID, FFIRSTNODE, FCREATETIME) VALUES
(@RouteId, @InstId, '', '', '', @SrcForm, @SrcBillId, 1, GETDATE())");
List<SqlParam> paramRoot = new List<SqlParam>();
paramRoot.Add(new SqlParam("@RouteId", KDDbType.AnsiString, rootId));
paramRoot.Add(new SqlParam("@InstId", KDDbType.AnsiString, instId));
paramRoot.Add(new SqlParam("@SrcForm", KDDbType.AnsiString, srcTd.TableNumber));
paramRoot.Add(new SqlParam("@SrcBillId", KDDbType.Int32, srcBillId));
sqlRoot = new Kingdee.BOS.App.Data.SqlObject(strCreateRoot, paramRoot);
sqlObjList.Add(sqlRoot);
}
