BOTP场景：引入单据，关联反写源单原创
金蝶云·星空
金蝶云社区-MiLai
MiLai
11人赞赏了该文章 1,760次浏览 未经作者许可，禁止转载编辑于2021年04月02日 09:28:32

需求背景

引入单据，或者使用WebApi导入数据时，需要同步建立和源单的关联关系，以支持联查、反写。

通常，在引入文件（或webapi数据包）中填好关联子实体行数据，填写好源单内码、分录内码，引入保存时，即会自动建立起与源单的关联关系。

但这种方式，需要在整理引入文件时，就能够确定源单内码、分录行内码，内码通常是不可见的，很难做到手工录入。

为了规避难以填写内码的难题，现场可以通过填写一些有意义的字段，如源单单据编号、源单行序号等，在引入过程中，开发引入插件根据这些字段值自动建立起与源单之间的关联关系。

本章介绍如何开发引入插件，根据源单单据编号，单据体源单行序号字段，自动建立起与源单的关联关系。

案例设计

假设下游的单据头，有如下几个字段，需要在引入文件中填写好，以便插件能够据此找到源单行内码：

  • srcbilltype：单据头字段，基础资料字段类型，记录源单类型，如demo_bill1；

  • srcbillno：单据头字段，文本字段，记录源单单据编号，如”JD-001”；

  • srcentrykey：单据头字段，文本字段，记录源单单据体名称，如”entryentity”；

  • srcrowseq：单据体字段，整数类型，记录源单行序号，如1,2,3…

相关知识点

  • 关联子实体：系统会在目标单的单据体下级，创建一个关联子表，记录源单类型、源单内码、分录行内码，保存时，会基于此建立起与源单的关联关系并反写。关联子实体，通常以单据体标识加上”_lk”后缀命名，又可称为lk子实体、lk表等。如果是单据头的下级关联子实体，标识固定为”billhead_lk”。

  • 实体表格编码：也称为tableId，为了明确的追查到源单行，关联子实体中，需要记录源单类型、源单单据体名称。这两个值是文本类型，直接记录会占用比较多的空间。因此，平台特别为每一种单据、单据体，都分配一个唯一的长整型数字，作为表格编码，即tableId。并改造关联子实体，只记录一个长整数的tableid，不再记录源单类型、单据体名称，节省不少存储空间。联查时，会自动根据表格编码，反查到明确的单据类型及单据体。

  • TableDefine对象：平台封装的公共对象，包含了主实体编码、单据体名称和表格TableId之间的对应关系。可以通过公共服务接口(EntityMetadataCache.loadTableDefine方法)，传入单据主实体编码+单据体名称获取，也可以传入tableId获取；通过这个对象，可以根据单据和单据体追查tableId，也可以根据tableId反查单据和单据体。

示例代码

案例实现思路：

  • 开发单据的表单插件，派生自AbstractBillPlugIn；

  • 重写afterImportData方法，此方法在引入字段值填写完毕，保存之前触发

  • 读取目标上引入的源单类型、源单编号字段值

  • 根据源单编号，加载源单数据包，只需要加载源单内码、分录行内码、分录行序号；

  • 对源单分录行进行逐行遍历，记录源单行号和源单内码、源单行内码之间的对应关系；

  • 对目标单分录行进行逐行遍历，根据引入的源单行号，找到对应的源单内码、分录行内码；

  • 把对应的源单内码、分录内码，填写在关联子实体中；

  • 至此，下游单据中，已经记录好了关联的源单信息；保存时，会根据这些信息自动建立关联关系，支持联查，支持反写；

示例代码：

package kd.bos.plugin.sample.bill.billconvert.bizcase;
import java.util.HashMap;
import java.util.HashSet;
import java.util.Map;
import java.util.Set;
import kd.bos.bill.AbstractBillPlugIn;
import kd.bos.dataentity.entity.DynamicObject;
import kd.bos.dataentity.entity.DynamicObjectCollection;
import kd.bos.dataentity.utils.StringUtils;
import kd.bos.entity.BillEntityType;
import kd.bos.entity.EntityMetadataCache;
import kd.bos.entity.botp.runtime.TableDefine;
import kd.bos.entity.datamodel.events.ImportDataEventArgs;
import kd.bos.orm.query.QCP;
import kd.bos.orm.query.QFilter;
import kd.bos.servicehelper.BusinessDataServiceHelper;
/**
 * 示例代码：开发下游单单据插件，在引入时建立和源单关联信息，以支持联查、反写
 * 
 * @author rd_johnnyding
 */
public class AutoLinkSample extends AbstractBillPlugIn {
    // 下游单据头字段：源单类型字段，记录源单的标识，如"demo_bill1"
    private String KEY_SOURCEBILLTYPE = "srcbilltype";
    // 下游单据头字段：源单单据编号字段，记录源单单据编号，如 "JD-0001"
    private String KEY_SOURCEBILLNO = "srcbillno";
    // 下游单据头字段：源单关联主单据体标识字段，记录源单单据体标识，如 "entryentity"
    private String KEY_SOURCEENTRYKEY = "srcentrykey";
    // 下游单据体字段：源单关联主单据行号字段，记录源单行号，如 1,2,3...
    private String KEY_SOURCEROWSEQ = "srcrowseq";
    /**
     * 引入字段值填写完毕，保存前，触发此事件
     */
    @Override
    public void afterImportData(ImportDataEventArgs e) {
        this.linkSourceRow(this.getModel().getDataEntityType().getName(), "entryentity");
    }
    /**
     * 根据引入的源单编号和物料，自动匹配源单行，在lk子实体记录源单行内码
     */
    private void linkSourceRow(String targetEntityNumber, String targetEntryKey) {
        // 读取单据头源单类型、源单编号字段值
        Object srcEntityFldValue = this.getModel().getValue(KEY_SOURCEBILLTYPE);
        String srcEntityNumber = "";
        if (srcEntityFldValue instanceof DynamicObject) {
            srcEntityNumber = (String)((DynamicObject)srcEntityFldValue).getPkValue();
        }
        else {
            srcEntityNumber = (String)srcEntityFldValue;
        }
        String srcBillNo = (String) this.getModel().getValue(KEY_SOURCEBILLNO);
        String srcEntryKey = (String) this.getModel().getValue(KEY_SOURCEENTRYKEY);
        if (StringUtils.isBlank(srcEntityNumber) || StringUtils.isBlank(srcBillNo) || StringUtils.isBlank(srcEntryKey)) {
            // 没有填写源单类型、源单编号字段值，找不到源单，无法建立与源单的关联
            return;
        }
        // 读取源单数据包
        DynamicObject[] srcObjs = this.loadSourceBill(srcEntityNumber, srcEntryKey, srcBillNo);
        if (srcObjs.length == 0) {
            return;
        }
        // 循环分析源单行，提取源单行号、源单内码、分录行内码对应关系，放在字典中备用: key = 源单行号； value = [源单内码、分录行内码]
        Map<Integer, Object[]> srcRowIds = new HashMap<>();
        for(DynamicObject srcObj : srcObjs) {
            DynamicObjectCollection srcRows = srcObj.getDynamicObjectCollection(srcEntryKey);
            for (DynamicObject srcRow : srcRows) {
                Integer srcRowSeq = srcRow.getInt("seq");
                Object[] srcRowId = new Object[] {srcObj.getPkValue(), srcRow.getPkValue()};
                srcRowIds.put(srcRowSeq, srcRowId);
            }
        }
        // 获取源单单据体的表格编码：传入源单标识、源单单据体，记录关联关系时，需要用此编码，标识源单及单据体
        TableDefine tableDefine = EntityMetadataCache.loadTableDefine(srcEntityNumber, srcEntryKey);
        Long srcTableId = tableDefine.getTableId();
        // 拼接处关联子实体标识：如果是单据头下的lk子表，固定使用billhead_lk；如果是单据体下的lk子表，用单据体标识+lk
        String lkEntryKey = StringUtils.equals(targetEntityNumber, targetEntryKey) ? "billhead_lk" : targetEntryKey + "_lk"; 
        // 循环分析下游单的单据体行，逐一建立起与源单行的关联关系
        DynamicObject targetObj = this.getModel().getDataEntity(true);
        DynamicObjectCollection targetRows = targetObj.getDynamicObjectCollection(targetEntryKey);
        for(DynamicObject targetRow : targetRows) { 
            // 获取下级_lk子实体行
            DynamicObjectCollection linkRows = targetRow.getDynamicObjectCollection(lkEntryKey);
            if (!linkRows.isEmpty()) {
                continue;
            }
            linkRows.clear();
            // 寻找匹配的源单行：提取本行的匹配字段值，和源单行进行比对
            Integer srcRowSeq = targetRow.getInt(KEY_SOURCEROWSEQ);
            if (srcRowIds.containsKey(srcRowSeq)) {
                // 找到了匹配的行，创建一条_lk子实体上数据，记录源单内码
                DynamicObject linkRow = new DynamicObject(linkRows.getDynamicObjectType());
                linkRows.add(linkRow);
                // 在lk行中，记录源单分录表格编码、源单内码、源单分录内码
                Object[] srcRowId = srcRowIds.get(srcRowSeq);
                linkRow.set(lkEntryKey + "_stableid", srcTableId);        // 源单分录表格编码：以此标识源单类型及单据体
                linkRow.set(lkEntryKey + "_sbillid", srcRowId[0]);        // 源单内码
                linkRow.set(lkEntryKey + "_sid", srcRowId[1]);        // 源单分录行内码    
            }
        }
        // 至此：目标单分录行上，已经自动填写源单分录行内码；保存时，会自动创建关联关系及反写
    }
    /**
     * 从目标单中提取源单编号，读取出源单数据包
     * 
     * @param srcEntityNumber 源单主实体编码
     * @param srcEntryKey 源单关联主单据体标识
     * @param srcBillNo 源单单据编号
     * 
     * @return 源单数据包，仅包含源单内码、源单编号、源单行内码、行号
     */
    private DynamicObject[] loadSourceBill(String srcEntityNumber, String srcEntryKey, String srcBillNo) {
        BillEntityType sourceMainType = (BillEntityType)EntityMetadataCache.getDataEntityType(srcEntityNumber);
        // 读取源单：仅读取需要用到的字段：源单内码、源单单据编号、源单行内码、源单行号
        Set<String> selectFields = new HashSet<>();
        selectFields.add("id");
        selectFields.add(sourceMainType.getBillNo());
        selectFields.add(srcEntryKey + ".id");        
        selectFields.add(srcEntryKey + ".seq");
        QFilter filter = new QFilter(sourceMainType.getBillNo(), QCP.equals, srcBillNo);
        DynamicObject[] sourceBillObjs = BusinessDataServiceHelper.load(
                srcEntityNumber, 
                StringUtils.join(selectFields.toArray(), ","), 
                new QFilter[] {filter});
        return sourceBillObjs;
    }
}


图标赞 11
11人点赞
还没有人点赞，快来当第一个点赞的人吧！
图标打赏
0人打赏
还没有人打赏，快来当第一个打赏的人吧！

推荐阅读

BOTP场景：手工修复与源单关联关系

[链接] 需求背景 下游单据是手工录入、或者引入的，与源单没有关联关系，不支持联查、反写。 对于已经保存的下游单据，现在用户需要手工修复与源单的关联关系，以支持 …

    文章

    2,258

【单据关联】如何实现引入的单据上下查

通过引入引出模板引入的采购申请单、采购订单。 如何实现正常的上下查功能？ 目前引入的单据，没办法上下查。 :sleepy:

    文章

    1,110

供应链类的单据引入后无法关联订单

经测试，系统中录入的销售订单，通过下推生成销售出库单，引出后，把原销售出库单删除后，再次引入后无法关联订单 引入无法建立关联关系 ,有没有办法建立关联呢？或是后 …

    文章

    741