|
@@ -21,7 +21,6 @@ type GlobalLimitService interface {
|
|
|
AddGlobalLimit(ctx context.Context, req v1.GlobalLimitRequest) error
|
|
|
EditGlobalLimit(ctx context.Context, req v1.GlobalLimitRequest) error
|
|
|
DeleteGlobalLimit(ctx context.Context, req v1.GlobalLimitRequest) error
|
|
|
- EditGlobalLimitBySnail(ctx context.Context, req v1.GlobalLimitEditRequest) error
|
|
|
}
|
|
|
|
|
|
func NewGlobalLimitService(
|
|
@@ -346,35 +345,6 @@ func (s *globalLimitService) EditGlobalLimit(ctx context.Context, req v1.GlobalL
|
|
|
return nil
|
|
|
}
|
|
|
|
|
|
-func (s *globalLimitService) EditGlobalLimitBySnail(ctx context.Context, req v1.GlobalLimitEditRequest) error {
|
|
|
- configCount, err := s.host.GetGlobalLimitConfig(ctx, req.HostId)
|
|
|
- if err != nil {
|
|
|
- return fmt.Errorf("获取配置限制失败: %w", err)
|
|
|
- }
|
|
|
- data, err := s.globalLimitRepository.GetGlobalLimitByHostId(ctx, int64(req.HostId))
|
|
|
- if err != nil {
|
|
|
- return err
|
|
|
- }
|
|
|
- t := time.Unix(req.ExpiredAt, 0)
|
|
|
- expiredAt := t.Format("2006-01-02 15:04:05")
|
|
|
- formData := map[string]interface{}{
|
|
|
- "tag": data.Name,
|
|
|
- "bps": configCount.Bps,
|
|
|
- "max_bytes_month": configCount.MaxBytesMonth,
|
|
|
- "expired_at": expiredAt,
|
|
|
- }
|
|
|
-
|
|
|
- respBody, err := s.required.SendForm(ctx, "admin/info/waf_common_limit/edit?&__goadmin_edit_pk="+strconv.Itoa(req.RuleId), "admin/edit/waf_common_limit", formData)
|
|
|
-
|
|
|
- if err != nil {
|
|
|
- return err
|
|
|
- }
|
|
|
- if respBody == nil {
|
|
|
- return nil
|
|
|
- }
|
|
|
- return nil
|
|
|
-
|
|
|
-}
|
|
|
|
|
|
func (s *globalLimitService) DeleteGlobalLimit(ctx context.Context, req v1.GlobalLimitRequest) error {
|
|
|
if err := s.globalLimitRepository.DeleteGlobalLimitByHostId(ctx, int64(req.HostId)); err != nil {
|