|
@@ -479,7 +479,11 @@ func (s *globalLimitService) DeleteGlobalLimit(ctx context.Context, req v1.Globa
|
|
|
})
|
|
|
|
|
|
g.Go(func() error {
|
|
|
- e := s.udpForWarding.DeleteUdpForwarding(ctx,udpIds)
|
|
|
+ e := s.udpForWarding.DeleteUdpForwarding(ctx, v1.DeleteUdpForwardingRequest{
|
|
|
+ Ids: udpIds,
|
|
|
+ Uid: req.Uid,
|
|
|
+ HostId: req.HostId,
|
|
|
+ })
|
|
|
if e != nil {
|
|
|
return fmt.Errorf("删除UDP转发失败: %w", e)
|
|
|
}
|
|
@@ -487,7 +491,11 @@ func (s *globalLimitService) DeleteGlobalLimit(ctx context.Context, req v1.Globa
|
|
|
})
|
|
|
|
|
|
g.Go(func() error {
|
|
|
- e := s.webForWarding.DeleteWebForwarding(ctx,webIds)
|
|
|
+ e := s.webForWarding.DeleteWebForwarding(ctx,v1.DeleteWebForwardingRequest{
|
|
|
+ Ids: webIds,
|
|
|
+ Uid: req.Uid,
|
|
|
+ HostId: req.HostId,
|
|
|
+ })
|
|
|
if e != nil {
|
|
|
return fmt.Errorf("删除WEB转发失败: %w", e)
|
|
|
}
|