node.go 1.1 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647
  1. package workflow
  2. import (
  3. "fmt"
  4. "server/dao"
  5. "server/model/common/request"
  6. )
  7. type NodeService struct{}
  8. func (ns *NodeService) QueryAllNode() (nodes []dao.Node, err error) {
  9. return dao.QueryAllNode()
  10. }
  11. func (ns *NodeService) QueryNodeList(info request.PageInfo) (list interface{}, total int64, err error) {
  12. limit := info.PageSize
  13. offset := info.PageSize * (info.Page - 1)
  14. nodes, total, err := dao.QueryNodeList(limit, offset)
  15. return nodes, total, err
  16. }
  17. func (ns *NodeService) QueryNodeById(id int) (node dao.Node, err error) {
  18. return dao.QueryNodeById(id)
  19. }
  20. func (ns *NodeService) QueryNodeByApproverId(approverId int) (nodes []dao.Node, err error) {
  21. return dao.QueryNodeByApproverId(approverId)
  22. }
  23. func (ns *NodeService) CreateNode(node dao.Node) error {
  24. return node.CreateNode()
  25. }
  26. func (ns *NodeService) UpdateNode(node dao.Node) error {
  27. return node.UpdateNode()
  28. }
  29. func (ns *NodeService) DeleteNode(node dao.Node) error {
  30. nodes, err := ns.QueryNodeByApproverId(int(node.ID))
  31. if err != nil {
  32. return err
  33. }
  34. if len(nodes) > 0 {
  35. return fmt.Errorf("节点被使用")
  36. }
  37. return node.DeleteNode()
  38. }