nodeconfig.go 1.4 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556
  1. package controller
  2. import (
  3. "github.com/gogf/gf/v2/errors/gcode"
  4. "github.com/gogf/gf/v2/errors/gerror"
  5. "golang.org/x/net/context"
  6. v1 "nodeMonitor/api/v1"
  7. "nodeMonitor/internal/model"
  8. "nodeMonitor/internal/service"
  9. )
  10. var NodeConfig = sNodeConfig{}
  11. type sNodeConfig struct {
  12. }
  13. func (c *sNodeConfig) All(ctx context.Context, req *v1.NodeConfigAllReq) (res *v1.NodeConfigAllRes, err error) {
  14. res = new(v1.NodeConfigAllRes)
  15. res.NodeConfigItem, err = service.NodeConfig().GetAll(ctx)
  16. return
  17. }
  18. func (c *sNodeConfig) Add(ctx context.Context, req *v1.NodeConfigReq) (res *v1.NodeConfigRes, err error) {
  19. exist, err := service.NodeConfig().IsExist(ctx, req.ServerId)
  20. if err != nil {
  21. return
  22. }
  23. if !exist {
  24. err = gerror.NewCode(gcode.New(401, "", nil), "数据已经存在")
  25. return
  26. }
  27. err = service.NodeConfig().Create(ctx, model.NodeConfigAndEditCreateInput{
  28. ServerId: req.ServerId,
  29. SshCom: req.SshCom,
  30. SshPass: req.SshPass,
  31. SshUser: req.SshUser,
  32. })
  33. return
  34. }
  35. func (c *sNodeConfig) Edit(ctx context.Context, req *v1.NodeConfigEditReq) (res *v1.NodeConfigEditRes, err error) {
  36. err = service.NodeConfig().Edit(ctx, model.NodeConfigAndEditCreateInput{
  37. ServerId: req.ServerId,
  38. SshCom: req.SshCom,
  39. SshPass: req.SshPass,
  40. SshUser: req.SshUser,
  41. })
  42. return
  43. }
  44. func (c *sNodeConfig) Del(ctx context.Context, req *v1.NodeConfigDelReq) (res *v1.NodeConfigDelRes, err error) {
  45. err = service.NodeConfig().Delete(ctx, req.ServerId)
  46. return
  47. }