删除摄像机增加限制

qixiaoning

2025-09-11 397468ddc1191bf0ce9339e544ff345d1d4e6786

 push-service/service/eventPushService.go

@@ -1,16 +1,18 @@
package service

import (
   "basic.com/pubsub/protomsg.git"
   "basic.com/valib/bhomeclient.git"
   "basic.com/valib/bhomedbapi.git"
   "encoding/json"
   "errors"
   "github.com/satori/go.uuid"
   "vamicro/extend/util"
   "vamicro/push-service/models"
   "vamicro/push-service/vo"
   sysModel "vamicro/system-service/models"

   "basic.com/pubsub/protomsg.git"
   "basic.com/valib/bhomeclient.git"
   "basic.com/valib/bhomedbapi.git"
   "basic.com/valib/logger.git"
   uuid "github.com/satori/go.uuid"
)

type EventPushService struct {
@@ -82,10 +84,12 @@
   } else { //新增
      if er > 0 {
         err = errors.New("名称不允许重复")
         logger.Debug(err)
         return false
      }
      eventPushE.Id = uuid.NewV4().String()
      if err = tx.Table("event_push").Create(&eventPushE).Error; err != nil {
         logger.Debug(err)
         return false
      }
   }
@@ -101,6 +105,7 @@
         EventPushId: eventPushE.Id,
      }
      if err = tx.Table("event_push_server").Create(&ipPortE).Error; err != nil {
         logger.Debug(err)
         return false
      }
   }
@@ -109,18 +114,24 @@
         Id:          uuid.NewV4().String(),
         Enable:      urlVo.Enable,
         Url:         urlVo.Url,
         ServerIp:    urlVo.ServerIp,
         Port:        urlVo.Port,
         Type:        models.PUSH_URL_TYPE,
         EventPushId: eventPushE.Id,
      }
      if err = tx.Table("event_push_server").Create(&urlE).Error; err != nil {
         logger.Debug(err)
         return false
      }
   }

   logger.Debug("hhhhhhh")

   for _, rule := range body.Rules {
      rule.Id = uuid.NewV4().String()
      rule.EventPushId = eventPushE.Id
      if err = tx.Table("event_push_rule").Create(&rule).Error; err != nil {
         logger.Debug(err)
         return false
      }
   }
@@ -265,8 +276,10 @@
               })
            } else if pushServer.Type == models.PUSH_URL_TYPE {
               resultVo.Urls = append(resultVo.Urls, vo.EventUrlVo{
                  Enable: pushServer.Enable,
                  Url:    pushServer.Url,
                  Enable:   pushServer.Enable,
                  Url:      pushServer.Url,
                  ServerIp: pushServer.ServerIp,
                  Port:     pushServer.Port,
               })
            }
         }