基于自适应工作流的计件报工数据审核处理系统的制作方法

本发明涉及数据处理与企业生产信息化管理领域，具体为基于自适应工作流的计件报工数据审核处理系统。

背景技术：

1、智能制造和生产执行管理系统持续发展，手持终端、工位机及边缘采集器应用于生产现场，计件报工数据的实时采集和审核需求增加；在多人协同作业场景下，同一任务由多名作业人员分别提交报工数据，生产管理领域存在对多源协同报工数据进行归并与审核的技术需求。

2、传统的计件报工数据审核目前主要依赖于如下方式：单条报工独立审核、接入入口设置固定等待窗口、通过业务数据库轮询拼接报工记录。

3、但是单条报工独立审核、固定等待窗口，以及业务数据库轮询拼接等方式都存在一定的缺陷，例如单条报工独立审核难以识别多人协同任务，容易因后续报工尚未到达而产生伪异常；固定等待窗口需要延迟所有报工请求，难以适应不同任务和工序的到达差异；业务数据库轮询拼接方式存在处理时延超出预设阈值、并发更新时发生数据覆盖的问题，且缺乏对运行中工作流实例吸收后续报工数据的机制。

技术实现思路

1、本发明的目的在于提供一种基于自适应工作流的计件报工数据审核处理系统，避免单条报工审核产生伪异常或轮询拼接导致数据覆盖，且吸收后续数据以实现协同任务的准确归并与审核，本发明的目的可以通过以下技术方案实现：基于自适应工作流的计件报工数据审核处理系统，运行于服务器，包括：报工接入模块，用于接收计件报工数据，解析获得任务标识；协同任务识别模块，用于获取与任务标识对应的预期协同人数以识别协同任务；工作流驱动模块，用于在计件报工数据未匹配到缓存中的有效令牌时，创建当前工作流实例并装载计件报工数据，在匹配到有效令牌时发送至上下文注入模块；挂起处理模块，用于根据计件报工数据统计当前工作流实例的当前唯一报工人数和累计报工数量，在当前唯一报工人数少于预期协同人数且累计报工数量低于与任务标识对应的标准任务数量时，暂停当前工作流实例的执行，将当前工作流实例置于等待后续数据的可唤醒挂起节点；令牌生成模块，用于基于任务标识生成令牌并写入缓存；上下文注入模块，用于在任务标识匹配命中时，将后续报工数据追加至当前工作流实例，更新协同上下文数据结构；唤醒重入模块，用于在协同上下文数据结构更新完成后唤醒处于可唤醒挂起节点的当前工作流实例；审核判定模块，用于根据协同上下文数据结构生成审核结果；结果存储模块，用于将审核结果与任务标识关联，作为报工记录存储至业务数据库。

2、优选地，报工接入模块在解析获得任务标识后进行幂等校验；令牌生成模块生成的令牌包含任务索引、工作流实例标识和有效时长，供后续报工数据通过任务标识进行索引匹配；上下文注入模块在后续报工数据的任务标识与缓存中的任务索引匹配命中时，将后续报工数据的作业人员标识和计件数量追加至当前工作流实例，以更新包含报工人数和计件数量的协同上下文数据结构；审核判定模块根据更新后的协同上下文数据结构中的报工人数和计件数量的完整度，生成审核通过、异常或复核的审核结果。

3、优选地，计件报工数据至少包括作业人员标识、计件数量、服务器到达时间、工序编号及批次标识；协同任务识别模块按照班组作业模板、生产计划排程表、历史共同报工记录的优先级顺序，获取与任务标识对应的预期协同人数。

4、优选地，协同任务识别模块在预期协同人数不小于二人，或者指定周期内的历史共同报工频次达到预设的协同任务识别阈值时，满足任一条件即判定为协同任务；工作流驱动模块在缓存中查询有效令牌，若令牌的有效时长未到期则判定为有效令牌并衔接至上下文注入模块，若未查询到令牌或令牌已到期则衔接至令牌生成模块。

5、优选地，挂起处理模块在判定当前唯一报工人数与累计报工数量均未达标时，生成挂起指令，保持当前工作流实例的状态不变，释放计算资源，否则将当前工作流实例的状态转换为审核中并发送至审核判定模块进行处理。

6、优选地，还包括参数调整模块，参数调整模块按照工序类别获取历史协同报工到达时间差，基于时间差的平均到达延迟、延迟离散程度及预期协同人数计算目标时长，并结合预设时长上下限截断目标时长以确定令牌有效时长；参数调整模块在新增历史协同报工数据的数量达到更新阈值时，重新触发令牌有效时长的计算与替换。

7、优选地，计件报工数据还包括返工轮次标识；令牌生成模块将任务标识、工序编号和批次标识作为必选字段建立缓存索引，并在识别到计件报工数据包含表示返工的特征值时，将返工轮次标识加入缓存索引；上下文注入模块根据批次标识、返工轮次标识及任务标识匹配定位对应的当前工作流实例，以隔离不同班次、批次或返工轮次的报工数据。

8、优选地，报工接入模块根据计件报工数据的作业人员标识、任务标识、计件数量及服务器到达时间通过哈希算法生成幂等标识，并将幂等标识与缓存中已存在的幂等标识进行比较；若幂等标识不存在，则放行计件报工数据并将幂等标识存入缓存，若存在则拦截计件报工数据并拒绝注入，同时生成包含拦截时间的重复报工日志记录并单独存储。

9、优选地，令牌还包含初始值为零的版本号；上下文注入模块读取当前工作流实例的当前版本号，通过比较并交换方式将当前版本号更新为自增1后的版本；若版本号更新成功，则完成报工数据注入，若版本号更新失败，则重新读取当前工作流实例的最新版本号及协同上下文数据结构后再次执行注入校验，当重试次数达到预设上限时终止注入并抛出并发冲突异常。

10、优选地，唤醒重入模块在当前唯一报工人数达到预期协同人数、累计报工数量达到标准任务数量或令牌有效时长到期三者任一条件满足时，生成唤醒指令，并在三者任一条件均不满足时保持挂起状态；审核判定模块基于报工人数维度、计件数量维度及令牌时效维度的多维特征生成完整性评分；完整性评分为：将当前唯一报工人数与预期协同人数的比值、累计报工数量与标准任务数量的比值以及令牌剩余有效时长与令牌有效时长的比值分别按照人数权重、数量权重和时效权重加权求和得到；审核判定模块在协同上下文数据结构中的各条报工数据之间不存在工序编号不一致冲突，且完整性评分达到预设的通过阈值时生成审核通过结果，在完整性评分低于预设的异常阈值时生成异常结果，在完整性评分大于或等于预设的异常阈值且小于预设的通过阈值时生成复核结果。

11、本发明带来的有益技术效果：

12、1.本发明通过接收并解析包含作业人员标识、任务标识、计件数量、服务器到达时间、工序编号及批次标识的计件报工数据，并按照班组作业模板、生产计划排程表和历史共同报工记录的优先级识别协同任务及预期协同人数，有效提高了多人协同任务识别的准确性，减少了因后续报工尚未到达而产生的伪异常。

13、2.本发明通过对未命中有效令牌的首条报工创建工作流实例，并在唯一报工人数和累计计件数量均未达到对应目标时，将工作流实例置于可唤醒挂起节点，同时生成包含任务索引和工作流实例标识的令牌写入缓存，使后续报工能够直接命中并注入已挂起的工作流实例，避免对所有报工请求设置统一等待窗口，降低了入口阻塞和处理时延。

14、3.本发明通过按照工序类别统计历史协同报工到达时间差，并结合平均到达延迟、延迟离散程度、预期协同人数以及预设时长上下限自适应确定令牌有效时长，使等待范围能够适配不同工序和协同人数的报工到达差异。