工作流

如何清理串行堵塞流程

通过工作流ID 在 MongoDB 数据库中查询流程对应的 storeId

以工作流ID为 5f12855302740ff3c82f 示例

> use mdworkflow
> db.app_consumerSequence.find({_id:ObjectId("5f12855302740ff3c82f")})

拿到流程对应的 storeId 后执行清除语句

以 storeId 为 32e8d0fdsa32948d449 示例

> db.app_consumerSequence.remove({storeId:"32e8d0fdsa32948d449"}) 
> db.app_consumerActivity.remove({processId:"5f12855302740ff3c82f",storeId:"32e8d0fdsa32948d449"}) 

如何查询指定时间段执行的工作流

v4.5.0及以上版本

在组织管理-工作流监控页面可以查看监控图中的历史执行详情

v4.5.0以前的版本

提前获取组织ID，路径：组织管理 -> 组织信息

MongoDB 中查询

> use mdworkflow
> db.wf_instance.aggregate([{"$match": {"companyId":"xxxxxx","createDate": {"$gt": ISODate("2023-05-06T06:10:00.000Z"),"$lt": ISODate("2023-05-06T06:20:00.000Z")}}},{"$group": {"_id": "$processId","count": {"$sum": 1}}},{"$sort": {"count": -1}}])

• 语句中 companyId 注意替换为实际的组织ID
• 查询条件中的时间为 UTC 时区，06:10:00.000Z 换算东八区时区对应14:10:00

查询结果示例：

{ "_id" : "6455b144ab61ff25944abd32", "count" : 5890 }
{ "_id" : "645359f4bf0d053e6dec5f43", "count" : 1618 }
{ "_id" : "6455dc569eb0167f785c0692", "count" : 1514 }
{ "_id" : "6455db87690c6744298e6aa4", "count" : 603 }
{ "_id" : "645359f3bf0d053e6dec5f1b", "count" : 332 }
{ "_id" : "645497ca77b2ac62d41c227a", "count" : 294 }
{ "_id" : "645359f4bf0d053e6dec5f5e", "count" : 113 }

• _id 为工作流ID
• count 为这个时间段执行的次数

浏览器中访问：系统地址/workflowedit/工作流ID，即可进入对应工作流

如：https://hap.domain.com/workflowedit/6455b144ab61ff25944abd32

如果提示无权限访问工作流，可以通过工作流ID查询工作流名称及所在应用

如何通过工作流ID查询工作流名称及所在应用

MongoDB 中查询

> use mdworkflow
> db.wf_process.find({"_id":ObjectId("6455b144ab61ff25944abd32")})

• 输出的信息中包含 name 字段，对应工作流名称

得到工作流名称后，到 组织管理-工作流 中搜索，即可查询到工作流所在的应用

如何通过工作流执行ID查询工作流ID

MongoDB中查询

> use mdworkflow
> db.wf_instance.find({_id:ObjectId("instacneId")})

• instacneId 需要换成实际的执行ID

• 输出的信息中包含 processId 字段，对应工作流ID