@@ -60,3 +60,11 @@ func (ce CloudEvent) GetDataProcess() (*WorkflowEventDataProcess, error) {
}
return dataProcess, nil
+
+func (dp *DataProcess) GenBusinessEntity(businessEntity any) error {
+ err := json.Unmarshal([]byte(dp.BusinessEntityInstance), businessEntity)
+ if err != nil {
+ return err
+ }
+ return nil
+}