pingconfig.go 1.1 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849
  1. package pingconfig
  2. import (
  3. "github.com/gogf/gf/v2/frame/g"
  4. "golang.org/x/net/context"
  5. "nodeMonitor/internal/dao"
  6. "nodeMonitor/internal/model"
  7. "nodeMonitor/internal/model/entity"
  8. "nodeMonitor/internal/service"
  9. )
  10. type (
  11. sPingConfig struct{}
  12. )
  13. func init() {
  14. service.RegisterPingConfig(New())
  15. }
  16. func New() *sPingConfig {
  17. return &sPingConfig{}
  18. }
  19. // Edit 编辑节点配置
  20. func (c *sPingConfig) Edit(ctx context.Context, input model.PingConfigEditInput) error {
  21. /*
  22. do.Pingconfig{
  23. NodeDie: input.NodeDie,
  24. NodeCount: input.NodeCount,
  25. NodeLoos: input.NodeLoos,
  26. PingTime: input.PingTime,
  27. }
  28. */
  29. _, err := dao.Pingconfig.Ctx(ctx).Where("ping_name", input.PingName).Update(g.Map{
  30. "node_die": input.NodeDie,
  31. "node_count": input.NodeCount,
  32. "node_loos": input.NodeLoos,
  33. "ping_time": input.PingTime,
  34. "node_recover": input.NodeRecover,
  35. })
  36. return err
  37. }
  38. // Get 编辑节点配置
  39. func (c *sPingConfig) Get(ctx context.Context) (*entity.Pingconfig, error) {
  40. var pingconfig = new(entity.Pingconfig)
  41. err := dao.Pingconfig.Ctx(ctx).Scan(&pingconfig)
  42. return pingconfig, err
  43. }