推送配置相关接口修改调整字段设置，数据关联

qixiaoning

2025-08-11 ad4ad76f4cd6db55ddceedcff5bf588547786f31

 push-service/controllers/eventPush.go

@@ -1,16 +1,15 @@
package controllers

import (
   "basic.com/valib/bhomeclient.git"
   "basic.com/valib/logger.git"
   "vamicro/push-service/service"
   "vamicro/push-service/vo"

   "basic.com/valib/bhomeclient.git"
   "basic.com/valib/logger.git"
)

type EventPushController struct {

}


// @Summary 事件推送保存
// @Description 事件推送保存
@@ -19,16 +18,16 @@
// @Success 200 {string} json "{"code":200, success:true, msg:"", data:""}"
// @Failure 500 {string} json "{"code":500, success:false, msg:"",data:""}"
// @Router /data/api-v/eventPush/save [post]
func (epc EventPushController) Save(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply{
func (epc EventPushController) Save(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply {
   var saveBody vo.EventPushVo
   if err := c.BindJSON(&saveBody);err !=nil {
      return &bhomeclient.Reply{ Success: false, Msg: "参数有误"}
   if err := c.BindJSON(&saveBody); err != nil {
      return &bhomeclient.Reply{Success: false, Msg: "参数有误"}
   }
   sv := service.NewEventPushService(h.Bk)
   if sv.Save(&saveBody) {
      return &bhomeclient.Reply{ Success: true, Data: saveBody }
      return &bhomeclient.Reply{Success: true, Data: saveBody}
   } else {
      return &bhomeclient.Reply{ Success: false, Msg: "保存失败"}
      return &bhomeclient.Reply{Success: false, Msg: "保存失败"}
   }
}

@@ -41,19 +40,19 @@
// @Success 200 {string} json "{"code":200, success:true, msg:"", data:""}"
// @Failure 500 {string} json "{"code":500, success:false, msg:"",data:""}"
// @Router /data/api-v/eventPush/findByEventTopic [get]
func (epc EventPushController) FindByEventTopic(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply{
func (epc EventPushController) FindByEventTopic(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply {
   topic := c.Query("topic")
   childType := c.Query("type")
   if topic == ""{
      return &bhomeclient.Reply{ Success: false, Msg: "参数有误"}
   if topic == "" {
      return &bhomeclient.Reply{Success: false, Msg: "参数有误"}
   }

   sv := service.NewEventPushService(h.Bk)
   list, err := sv.FindByEventTopic(topic, childType)
   if err == nil {
      return &bhomeclient.Reply{ Success: true, Data: list }
      return &bhomeclient.Reply{Success: true, Data: list}
   } else {
      return &bhomeclient.Reply{ Success: false, Msg: err.Error() }
      return &bhomeclient.Reply{Success: false, Msg: err.Error()}
   }
}

@@ -68,11 +67,11 @@
func (epc EventPushController) FindAll(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply {
   name := c.Query("name")
   sv := service.NewEventPushService(h.Bk)
   flag,data := sv.FindAll(name)
   flag, data := sv.FindAll(name)
   if flag {
      return &bhomeclient.Reply{ Success: true, Data: data }
   } else{
      return &bhomeclient.Reply{ Success: false, Msg: "查询失败"}
      return &bhomeclient.Reply{Success: true, Data: data}
   } else {
      return &bhomeclient.Reply{Success: false, Msg: "查询失败"}
   }
}

@@ -80,7 +79,7 @@
func (epc EventPushController) FindAllDetails(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply {
   sv := service.NewEventPushService(h.Bk)
   data := sv.FindAllDetails()
   return &bhomeclient.Reply{ Success: true, Data: data }
   return &bhomeclient.Reply{Success: true, Data: data}
}

// @Summary 事件推送编辑
@@ -94,22 +93,22 @@
func (epc EventPushController) GetById(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply {
   id := c.Query("id")
   logger.Debug("id:", id)
   if id == ""{
      return &bhomeclient.Reply{ Success: false, Msg: "参数有误"}
   if id == "" {
      return &bhomeclient.Reply{Success: false, Msg: "参数有误"}
   }
   sv := service.NewEventPushService(h.Bk)
   flag,data := sv.GetById(id)
   flag, data := sv.GetById(id)
   logger.Debug("getByID FLAG:", flag, " data:", data)
   if flag {
      return &bhomeclient.Reply{ Success: true, Data: data}
   } else{
      return &bhomeclient.Reply{ Success:false, Msg: "查询失败"}
      return &bhomeclient.Reply{Success: true, Data: data}
   } else {
      return &bhomeclient.Reply{Success: false, Msg: "查询失败"}
   }
}

type ChangeStatusVo struct {
   Id string `json:"id"`
   Enable bool `json:"enable"`
   Id     string `json:"id"`
   Enable bool   `json:"enable"`
}

// @Summary 改变enable状态
@@ -123,14 +122,14 @@
func (epc EventPushController) ChangeStatus(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply {
   var statusBody ChangeStatusVo
   err := c.BindJSON(&statusBody)
   if err !=nil {
      return &bhomeclient.Reply{ Success: false, Msg: "参数有误"}
   if err != nil {
      return &bhomeclient.Reply{Success: false, Msg: "参数有误"}
   }
   sv := service.NewEventPushService(h.Bk)
   if sv.ChangeStatus(statusBody.Id,statusBody.Enable){
      return &bhomeclient.Reply{ Success:true, Msg: "修改成功"}
   if sv.ChangeStatus(statusBody.Id, statusBody.Enable) {
      return &bhomeclient.Reply{Success: true, Msg: "修改成功"}
   } else {
      return &bhomeclient.Reply{ Success:false, Msg: "修改失败"}
      return &bhomeclient.Reply{Success: false, Msg: "修改失败"}
   }
}

@@ -145,13 +144,13 @@
// @Router /data/api-v/eventPush/delete [post]
func (epc EventPushController) Delete(h *bhomeclient.WrapperHandler, c *bhomeclient.Request) *bhomeclient.Reply {
   id := c.PostForm("id")
   if id ==""{
      return &bhomeclient.Reply{ Success: false, Msg: "参数有误"}
   if id == "" {
      return &bhomeclient.Reply{Success: false, Msg: "参数有误"}
   }
   sv := service.NewEventPushService(h.Bk)
   if sv.DeleteById(id){
      return &bhomeclient.Reply{ Success:true, Msg: "删除成功"}
   if sv.DeleteById(id) {
      return &bhomeclient.Reply{Success: true, Msg: "删除成功"}
   } else {
      return &bhomeclient.Reply{ Success:false, Msg: "删除失败"}
      return &bhomeclient.Reply{Success: false, Msg: "删除失败"}
   }
}
}