up

service/wf_ins_attach_service.go

@@ -1 +1,30 @@
 package service
+
+import (
+    "xps/datasource"
+    "xps/repositories"
+    "xps/viewmodel"
+)
+
+type WfInsAttachService interface {
+    GetList(m map[string]interface{}) ([]viewmodel.WfInsAttachInfo, error)
+    Delete(m map[string]interface{}) error
+}
+
+type wfInsAttachService struct {
+    repo *repositories.WfInsAttachRepo
+}
+
+func NewWfInsAttachService() WfInsAttachService {
+    return &wfInsAttachService{
+        repo: repositories.NewWfInsAttachRepo(datasource.InstanceMaster()),
+    }
+}
+
+func (s* wfInsAttachService) GetList(m map[string]interface{}) ([]viewmodel.WfInsAttachInfo, error) {
+    return s.repo.GetList(m)
+}
+
+func (s* wfInsAttachService) Delete(m map[string]interface{}) error {
+    return s.Delete(m)
+}

web/controller/wf_activity_action_def_controller.go

@@ -0,0 +1,98 @@
+package controller
+
+
+import (
+    "github.com/kataras/iris/v12/mvc"
+    "xps/datamodel"
+    "xps/service"
+)
+
+type WfActivityActionDefController struct {
+    Base
+    Service service.WfActivityActionDefService
+}
+
+func (c *WfActivityActionDefController) BeforeActivation(b mvc.BeforeActivation) {
+    b.Handle("GET",         "/",                                                        "GetList"       )
+    b.Handle("GET",         "/page",                                                    "GetPage"       )
+    b.Handle("GET",         "/{wfDefId:int64}/{activityDefId:int64}/{actionId:int64}",  "GetById"       )
+    b.Handle("POST",        "/add",                                                     "Create"        )
+    b.Handle("PUT",         "/update",                                                  "Update"        )
+    b.Handle("DELETE",      "/{wfDefId:int64}/{activityDefId:int64}/{actionId:int64}",  "DeleteByID"    )
+}
+
+func (c *WfActivityActionDefController) GetList() *JsonResult {
+    params    := c.buildParams()
+    data, err := c.Service.GetList(params)
+    if err != nil {
+        return ResultErr(err.Error(), nil)
+    } else {
+        return ResultOk("获取成功", data)
+    }
+}
+
+func (c *WfActivityActionDefController) GetPage() *JsonResult {
+    params    := c.buildParams()
+    data, err := c.Service.GetPage(params)
+    if err != nil {
+        return ResultErr(err.Error(), nil)
+    } else {
+        return ResultOk("获取成功", data)
+    }
+}
+
+func (c *WfActivityActionDefController) GetById(wfDefId, activityDefId, actionId int64) *JsonResult {
+    data, err := c.Service.GetById(wfDefId, activityDefId, actionId)
+    if err != nil {
+        return ResultErr(err.Error(), nil)
+    } else {
+        return ResultOk("获取成功", data)
+    }
+}
+
+func (c *WfActivityActionDefController) Create() *JsonResult {
+    userId  := c.GetCurUserId()
+    
+    wf   := &datamodel.WfActivityActionDef{}
+    if err := c.Ctx.ReadJSON(wf); err != nil {
+        return ResultErr("读取数据失败", nil)
+    }
+    
+    wf.CreatedBy = userId
+    if err := c.Service.Create(wf); err != nil {
+        return ResultErr(err.Error(), nil)
+    } else {
+        return ResultOk("新增成功", nil)
+    }
+}
+
+func (c *WfActivityActionDefController) Update() *JsonResult {
+    userId  := c.GetCurUserId()
+    
+    wf := &datamodel.WfActivityActionDef{}
+    if err  := c.Ctx.ReadJSON(wf); err != nil {
+        return ResultErr("读取数据失败", nil)
+    }
+    
+    wf.UpdatedBy = userId
+    if err := c.Service.Update(wf); err != nil {
+        return ResultErr(err.Error(), nil)
+    } else {
+        return ResultOk("更新成功", nil)
+    }
+}
+
+func (c *WfActivityActionDefController) DeleteByID(wfDefId, activityDefId, actionId int64) *JsonResult {
+    userId := c.GetCurUserId()
+    
+    m := make(map[string]interface{})
+    m["wfDefId"]       = wfDefId
+    m["activityDefId"] = activityDefId
+    m["actionId"]      = actionId
+    m["deletedBy"]     = userId
+    if err := c.Service.Delete(m); err != nil {
+        return ResultErr(err.Error(), nil)
+    } else {
+        return ResultOk("删除成功", nil)
+    }
+}

web/controller/wf_activity_action_ins_controller.go

@@ -0,0 +1,98 @@
+package controller
+
+import (
+    "github.com/kataras/iris/v12/mvc"
+    "xps/datamodel"
+    "xps/service"
+)
+
+type WfActivityActionInsController struct {
+    Base
+    Service service.WfActivityActionInsService
+}
+
+func (c *WfActivityActionInsController) BeforeActivation(b mvc.BeforeActivation) {
+    b.Handle("GET",         "/",                                                                        "GetList"       )
+    b.Handle("GET",         "/page",                                                                    "GetPage"       )
+    b.Handle("GET",         "/{ocId:int64}/{wfInsId:int64}/{activityInsId:int64}/{actionInsId:int64}",  "GetById"       )
+    b.Handle("POST",        "/add",                                                                     "Create"        )
+    b.Handle("PUT",         "/update",                                                                  "Update"        )
+    b.Handle("DELETE",      "/{ocId:int64}/{wfDefId:int64}/{activityDefId:int64}/{actionInsId:int64}",  "DeleteByID"    )
+}
+
+func (c *WfActivityActionInsController) GetList() *JsonResult {
+    params    := c.buildParams()
+    data, err := c.Service.GetList(params)
+    if err != nil {
+        return ResultErr(err.Error(), nil)
+    } else {
+        return ResultOk("获取成功", data)
+    }
+}
+
+func (c *WfActivityActionInsController) GetPage() *JsonResult {
+    params    := c.buildParams()
+    data, err := c.Service.GetPage(params)
+    if err != nil {
+        return ResultErr(err.Error(), nil)
+    } else {
+        return ResultOk("获取成功", data)
+    }
+}
+
+func (c *WfActivityActionInsController) GetById(ocId, wfInsId, activityInsId, actionInsId int64) *JsonResult {
+    data, err := c.Service.GetById(ocId, wfInsId, activityInsId, actionInsId)
+    if err != nil {
+        return ResultErr(err.Error(), nil)
+    } else {
+        return ResultOk("获取成功", data)
+    }
+}
+
+func (c *WfActivityActionInsController) Create() *JsonResult {
+    userId  := c.GetCurUserId()
+    
+    wf   := &datamodel.WfActivityActionIns{}
+    if err := c.Ctx.ReadJSON(wf); err != nil {
+        return ResultErr("读取数据失败", nil)
+    }
+    
+    wf.CreatedBy = userId
+    if err := c.Service.Create(wf); err != nil {
+        return ResultErr(err.Error(), nil)
+    } else {
+        return ResultOk("新增成功", nil)
+    }
+}
+
+func (c *WfActivityActionInsController) Update() *JsonResult {
+    userId  := c.GetCurUserId()
+    
+    wf := &datamodel.WfActivityActionIns{}
+    if err  := c.Ctx.ReadJSON(wf); err != nil {
+        return ResultErr("读取数据失败", nil)
+    }
+    
+    wf.UpdatedBy = userId
+    if err := c.Service.Update(wf); err != nil {
+        return ResultErr(err.Error(), nil)
+    } else {
+        return ResultOk("更新成功", nil)
+    }
+}
+
+func (c *WfActivityActionInsController) DeleteByID(ocId, wfInsId, activityInsId, actionInsId int64) *JsonResult {
+    userId := c.GetCurUserId()
+    
+    m := make(map[string]interface{})
+    m["ocId"]          = ocId
+    m["wfInsId"]       = wfInsId
+    m["activityInsId"] = activityInsId
+    m["actionInsId"]   = actionInsId
+    m["deletedBy"]     = userId
+    if err := c.Service.Delete(m); err != nil {
+        return ResultErr(err.Error(), nil)
+    } else {
+        return ResultOk("删除成功", nil)
+    }
+}

web/controller/wf_activity_def_controller.go

@@ -0,0 +1,96 @@
+package controller
+
+import (
+    "github.com/kataras/iris/v12/mvc"
+    "xps/datamodel"
+    "xps/service"
+)
+
+type WfActivityDefController struct {
+    Base
+    Service service.WfActivityDefService
+}
+
+func (c *WfActivityDefController) BeforeActivation(b mvc.BeforeActivation) {
+    b.Handle("GET",         "/",                                            "GetList"       )
+    b.Handle("GET",         "/page",                                        "GetPage"       )
+    b.Handle("GET",         "/{wfDefId:int64}/{activityDefId:int64}",       "GetById"       )
+    b.Handle("POST",        "/add",                                         "Create"        )
+    b.Handle("PUT",         "/update",                                      "Update"        )
+    b.Handle("DELETE",      "/{wfDefId:int64}/{activityDefId:int64}",       "DeleteByID"    )
+}
+
+func (c *WfActivityDefController) GetList() *JsonResult {
+    params    := c.buildParams()
+    data, err := c.Service.GetList(params)
+    if err != nil {
+        return ResultErr(err.Error(), nil)
+    } else {
+        return ResultOk("获取成功", data)
+    }
+}
+
+func (c *WfActivityDefController) GetPage() *JsonResult {
+    params    := c.buildParams()
+    data, err := c.Service.GetPage(params)
+    if err != nil {
+        return ResultErr(err.Error(), nil)
+    } else {
+        return ResultOk("获取成功", data)
+    }
+}
+
+func (c *WfActivityDefController) GetById(wfDefId, activityDefId int64) *JsonResult {
+    data, err := c.Service.GetById(wfDefId, activityDefId)
+    if err != nil {
+        return ResultErr(err.Error(), nil)
+    } else {
+        return ResultOk("获取成功", data)
+    }
+}
+
+func (c *WfActivityDefController) Create() *JsonResult {
+    userId  := c.GetCurUserId()
+    
+    wf   := &datamodel.WfActivityDef{}
+    if err := c.Ctx.ReadJSON(wf); err != nil {
+        return ResultErr("读取数据失败", nil)
+    }
+    
+    wf.CreatedBy = userId
+    if err := c.Service.Create(wf); err != nil {
+        return ResultErr(err.Error(), nil)
+    } else {
+        return ResultOk("新增成功", nil)
+    }
+}
+
+func (c *WfActivityDefController) Update() *JsonResult {
+    userId  := c.GetCurUserId()
+    
+    wf := &datamodel.WfActivityDef{}
+    if err  := c.Ctx.ReadJSON(wf); err != nil {
+        return ResultErr("读取数据失败", nil)
+    }
+    
+    wf.UpdatedBy = userId
+    if err := c.Service.Update(wf); err != nil {
+        return ResultErr(err.Error(), nil)
+    } else {
+        return ResultOk("更新成功", nil)
+    }
+}
+
+func (c *WfActivityDefController) DeleteByID(wfDefId, activityDefId int64) *JsonResult {
+    userId := c.GetCurUserId()
+    
+    m := make(map[string]interface{})
+    m["wfDefId"]       = wfDefId
+    m["activityDefId"] = activityDefId
+    m["deletedBy"]     = userId
+    if err := c.Service.Delete(m); err != nil {
+        return ResultErr(err.Error(), nil)
+    } else {
+        return ResultOk("删除成功", nil)
+    }
+}

web/controller/wf_activity_ins_controller.go

@@ -0,0 +1,97 @@
+package controller
+
+import (
+    "github.com/kataras/iris/v12/mvc"
+    "xps/datamodel"
+    "xps/service"
+)
+
+type WfActivityInsController struct {
+    Base
+    Service service.WfActivityInsService
+}
+
+func (c *WfActivityInsController) BeforeActivation(b mvc.BeforeActivation) {
+    b.Handle("GET",         "/",                                                    "GetList"       )
+    b.Handle("GET",         "/page",                                                "GetPage"       )
+    b.Handle("GET",         "/{ocId:int64}/{wfInsId:int64}/{activityInsId:int64}",  "GetById"       )
+    b.Handle("POST",        "/add",                                                 "Create"        )
+    b.Handle("PUT",         "/update",                                              "Update"        )
+    b.Handle("DELETE",      "/{ocId:int64}/{wfInsId:int64}/{activityInsId:int64}",  "DeleteByID"    )
+}
+
+func (c *WfActivityInsController) GetList() *JsonResult {
+    params    := c.buildParams()
+    data, err := c.Service.GetList(params)
+    if err != nil {
+        return ResultErr(err.Error(), nil)
+    } else {
+        return ResultOk("获取成功", data)
+    }
+}
+
+func (c *WfActivityInsController) GetPage() *JsonResult {
+    params    := c.buildParams()
+    data, err := c.Service.GetPage(params)
+    if err != nil {
+        return ResultErr(err.Error(), nil)
+    } else {
+        return ResultOk("获取成功", data)
+    }
+}
+
+func (c *WfActivityInsController) GetById(ocId, wfInsId, activityInsId int64) *JsonResult {
+    data, err := c.Service.GetById(ocId, wfInsId, activityInsId)
+    if err != nil {
+        return ResultErr(err.Error(), nil)
+    } else {
+        return ResultOk("获取成功", data)
+    }
+}
+
+func (c *WfActivityInsController) Create() *JsonResult {
+    userId  := c.GetCurUserId()
+    
+    wf   := &datamodel.WfActivityIns{}
+    if err := c.Ctx.ReadJSON(wf); err != nil {
+        return ResultErr("读取数据失败", nil)
+    }
+    
+    wf.CreatedBy = userId
+    if err := c.Service.Create(wf); err != nil {
+        return ResultErr(err.Error(), nil)
+    } else {
+        return ResultOk("新增成功", nil)
+    }
+}
+
+func (c *WfActivityInsController) Update() *JsonResult {
+    userId  := c.GetCurUserId()
+    
+    wf := &datamodel.WfActivityIns{}
+    if err  := c.Ctx.ReadJSON(wf); err != nil {
+        return ResultErr("读取数据失败", nil)
+    }
+    
+    wf.UpdatedBy = userId
+    if err := c.Service.Update(wf); err != nil {
+        return ResultErr(err.Error(), nil)
+    } else {
+        return ResultOk("更新成功", nil)
+    }
+}
+
+func (c *WfActivityInsController) DeleteByID(ocId, wfInsId, activityInsId int64) *JsonResult {
+    userId := c.GetCurUserId()
+    
+    m := make(map[string]interface{})
+    m["ocId"]           = ocId
+    m["wfInsId"]        = wfInsId
+    m["activityInsId"]  = activityInsId
+    m["deletedBy"]      = userId
+    if err := c.Service.Delete(m); err != nil {
+        return ResultErr(err.Error(), nil)
+    } else {
+        return ResultOk("删除成功", nil)
+    }
+}

web/controller/wf_def_controller.go

@@ -0,0 +1,95 @@
+package controller
+
+import (
+    "github.com/kataras/iris/v12/mvc"
+    "xps/datamodel"
+    "xps/service"
+)
+
+type WfDefController struct {
+    Base
+    Service service.WfDefService
+}
+
+func (c *WfDefController) BeforeActivation(b mvc.BeforeActivation) {
+    b.Handle("GET",         "/",                        "GetList"       )
+    b.Handle("GET",         "/page",                    "GetPage"       )
+    b.Handle("GET",         "/{wfDefId:int64}",         "GetById"       )
+    b.Handle("POST",        "/add",                     "Create"        )
+    b.Handle("PUT",         "/update",                  "Update"        )
+    b.Handle("DELETE",      "/{wfDefId:int64}",         "DeleteByID"    )
+}
+
+func (c *WfDefController) GetList() *JsonResult {
+    params    := c.buildParams()
+    data, err := c.Service.GetList(params)
+    if err != nil {
+        return ResultErr(err.Error(), nil)
+    } else {
+        return ResultOk("获取成功", data)
+    }
+}
+
+func (c *WfDefController) GetPage() *JsonResult {
+    params    := c.buildParams()
+    data, err := c.Service.GetPage(params)
+    if err != nil {
+        return ResultErr(err.Error(), nil)
+    } else {
+        return ResultOk("获取成功", data)
+    }
+}
+
+func (c *WfDefController) GetById(wfDefId int64) *JsonResult {
+    data, err := c.Service.GetById(wfDefId)
+    if err != nil {
+        return ResultErr(err.Error(), nil)
+    } else {
+        return ResultOk("获取成功", data)
+    }
+}
+
+func (c *WfDefController) Create() *JsonResult {
+    userId  := c.GetCurUserId()
+    
+    wf   := &datamodel.WfDef{}
+    if err := c.Ctx.ReadJSON(wf); err != nil {
+        return ResultErr("读取数据失败", nil)
+    }
+    
+    wf.CreatedBy = userId
+    if err := c.Service.Create(wf); err != nil {
+        return ResultErr(err.Error(), nil)
+    } else {
+        return ResultOk("新增成功", nil)
+    }
+}
+
+func (c *WfDefController) Update() *JsonResult {
+    userId  := c.GetCurUserId()
+    
+    wf := &datamodel.WfDef{}
+    if err  := c.Ctx.ReadJSON(wf); err != nil {
+        return ResultErr("读取数据失败", nil)
+    }
+    
+    wf.UpdatedBy = userId
+    if err := c.Service.Update(wf); err != nil {
+        return ResultErr(err.Error(), nil)
+    } else {
+        return ResultOk("更新成功", nil)
+    }
+}
+
+func (c *WfDefController) DeleteByID(wfDefId int64) *JsonResult {
+    userId := c.GetCurUserId()
+    
+    m := make(map[string]interface{})
+    m["wfDefId"]   = wfDefId
+    m["deletedBy"] = userId
+    if err := c.Service.Delete(m); err != nil {
+        return ResultErr(err.Error(), nil)
+    } else {
+        return ResultOk("删除成功", nil)
+    }
+}

web/controller/wf_ins_attach_controller.go

@@ -0,0 +1,40 @@
+package controller
+
+import (
+    "github.com/kataras/iris/v12/mvc"
+    "xps/service"
+)
+
+type WfInsAttachController struct {
+    Base
+    Service service.WfInsAttachService
+}
+
+func (c *WfInsAttachController) BeforeActivation(b mvc.BeforeActivation) {
+    b.Handle("GET",         "/",                                    "GetList"       )
+    b.Handle("DELETE",      "/{wfInsId:int64}/{fileId:int64}",      "DeleteByID"    )
+}
+
+func (c *WfInsAttachController) GetList() *JsonResult {
+    params    := c.buildParams()
+    data, err := c.Service.GetList(params)
+    if err != nil {
+        return ResultErr(err.Error(), nil)
+    } else {
+        return ResultOk("获取成功", data)
+    }
+}
+
+func (c *WfInsAttachController) DeleteByID(wfInsId, fileId int64) *JsonResult {
+    ocId   := c.GetCurOcId()
+    
+    m := make(map[string]interface{})
+    m["ocId"]      = ocId
+    m["wfInsId"]   = wfInsId
+    m["fileId"]    = fileId
+    if err := c.Service.Delete(m); err != nil {
+        return ResultErr(err.Error(), nil)
+    } else {
+        return ResultOk("删除成功", nil)
+    }
+}

web/controller/wf_ins_controller.go

@@ -0,0 +1,96 @@
+package controller
+
+import (
+    "github.com/kataras/iris/v12/mvc"
+    "xps/datamodel"
+    "xps/service"
+)
+
+type WfInsController struct {
+    Base
+    Service service.WfInsService
+}
+
+func (c *WfInsController) BeforeActivation(b mvc.BeforeActivation) {
+    b.Handle("GET",         "/",                                    "GetList"       )
+    b.Handle("GET",         "/page",                                "GetPage"       )
+    b.Handle("GET",         "/{ocId:int64}/{wfInsId:int64}",        "GetById"       )
+    b.Handle("POST",        "/add",                                 "Create"        )
+    b.Handle("PUT",         "/update",                              "Update"        )
+    b.Handle("DELETE",      "/{ocId:int64}/{wfInsId:int64}",        "DeleteByID"    )
+}
+
+func (c *WfInsController) GetList() *JsonResult {
+    params    := c.buildParams()
+    data, err := c.Service.GetList(params)
+    if err != nil {
+        return ResultErr(err.Error(), nil)
+    } else {
+        return ResultOk("获取成功", data)
+    }
+}
+
+func (c *WfInsController) GetPage() *JsonResult {
+    params    := c.buildParams()
+    data, err := c.Service.GetPage(params)
+    if err != nil {
+        return ResultErr(err.Error(), nil)
+    } else {
+        return ResultOk("获取成功", data)
+    }
+}
+
+func (c *WfInsController) GetById(ocId, wfInsId int64) *JsonResult {
+    data, err := c.Service.GetById(ocId, wfInsId)
+    if err != nil {
+        return ResultErr(err.Error(), nil)
+    } else {
+        return ResultOk("获取成功", data)
+    }
+}
+
+func (c *WfInsController) Create() *JsonResult {
+    userId  := c.GetCurUserId()
+    
+    wf   := &datamodel.WfIns{}
+    if err := c.Ctx.ReadJSON(wf); err != nil {
+        return ResultErr("读取数据失败", nil)
+    }
+    
+    wf.CreatedBy = userId
+    if err := c.Service.Create(wf); err != nil {
+        return ResultErr(err.Error(), nil)
+    } else {
+        return ResultOk("新增成功", nil)
+    }
+}
+
+func (c *WfInsController) Update() *JsonResult {
+    userId  := c.GetCurUserId()
+    
+    wf := &datamodel.WfIns{}
+    if err  := c.Ctx.ReadJSON(wf); err != nil {
+        return ResultErr("读取数据失败", nil)
+    }
+    
+    wf.UpdatedBy = userId
+    if err := c.Service.Update(wf); err != nil {
+        return ResultErr(err.Error(), nil)
+    } else {
+        return ResultOk("更新成功", nil)
+    }
+}
+
+func (c *WfInsController) DeleteByID(ocId, wfInsId int64) *JsonResult {
+    userId := c.GetCurUserId()
+    
+    m := make(map[string]interface{})
+    m["ocId"]      = ocId
+    m["wfInsId"]   = wfInsId
+    m["deletedBy"] = userId
+    if err := c.Service.Delete(m); err != nil {
+        return ResultErr(err.Error(), nil)
+    } else {
+        return ResultOk("删除成功", nil)
+    }
+}