|
@@ -7,22 +7,22 @@ import (
|
|
|
"gorm.io/gorm"
|
|
|
)
|
|
|
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
|
|
|
func CreateWorkflowProcess(workflowProcess model.WorkflowProcess) (err error) {
|
|
|
err = global.GVA_DB.Create(&workflowProcess).Error
|
|
|
return err
|
|
|
}
|
|
|
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
|
|
|
func DeleteWorkflowProcess(workflowProcess model.WorkflowProcess) (err error) {
|
|
|
err = global.GVA_DB.Transaction(func(tx *gorm.DB) error {
|
|
@@ -49,22 +49,22 @@ func DeleteWorkflowProcess(workflowProcess model.WorkflowProcess) (err error) {
|
|
|
return err
|
|
|
}
|
|
|
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
|
|
|
func DeleteWorkflowProcessByIds(ids request.IdsReq) (err error) {
|
|
|
err = global.GVA_DB.Delete(&[]model.WorkflowProcess{}, "id in ?", ids.Ids).Error
|
|
|
return err
|
|
|
}
|
|
|
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
|
|
|
func UpdateWorkflowProcess(workflowProcess *model.WorkflowProcess) (err error) {
|
|
|
return global.GVA_DB.Transaction(func(tx *gorm.DB) error {
|
|
@@ -106,23 +106,22 @@ func UpdateWorkflowProcess(workflowProcess *model.WorkflowProcess) (err error) {
|
|
|
})
|
|
|
}
|
|
|
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
|
|
|
func GetWorkflowProcess(id string) (err error, workflowProcess model.WorkflowProcess) {
|
|
|
err = global.GVA_DB.Preload("Nodes").Preload("Edges").Where("id = ?", id).First(&workflowProcess).Error
|
|
|
return
|
|
|
}
|
|
|
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
-
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
|
|
|
func GetWorkflowProcessInfoList(info request.WorkflowProcessSearch) (err error, list interface{}, total int64) {
|
|
|
limit := info.PageSize
|