package data_manage import ( "encoding/json" "eta/eta_api/controllers" "eta/eta_api/models" "eta/eta_api/models/data_manage/edb_inspection" "eta/eta_api/services/data" ) type EdbInspectionMessageController struct { controllers.BaseAuthController } // List // @Title 巡检消息列表 // @Description 巡检消息列表 // @Param PageSize query int true "每页数据条数" // @Param CurrentIndex query int true "当前页页码,从1开始" // @Success 200 {object} response.EdbInspectionMessageListResp // @router /edb_inspection/message/list [get] func (c *EdbInspectionMessageController) List() { br := new(models.BaseResponse).Init() defer func() { c.Data["json"] = br c.ServeJSON() }() sysUser := c.SysUser if sysUser == nil { br.Msg = "请登录" br.ErrMsg = "请登录,SysUser Is Empty" br.Ret = 408 return } pageSize, _ := c.GetInt("PageSize") currentIndex, _ := c.GetInt("CurrentIndex") resp, err := data.GetInspectionMessageList(sysUser.AdminId, currentIndex, pageSize) if err != nil { br.Msg = "获取失败" br.ErrMsg = err.Error() return } br.Data = resp br.Msg = "获取成功" br.Ret = 200 br.Success = true } // Read // @Title 巡检消息已读 // @Description 巡检消息已读 // @Param request body request.EdbInspectionMessageReadReq true "消息ID" // @Success 200 {object} models.BaseResponse // @router /edb_inspection/message/read [post] func (m *EdbInspectionMessageController) Read() { br := new(models.BaseResponse).Init() defer func() { m.Data["json"] = br m.ServeJSON() }() sysUser := m.SysUser if sysUser == nil { br.Msg = "请登录" br.ErrMsg = "请登录,SysUser Is Empty" br.Ret = 408 return } var req edb_inspection.EdbInspectionMessageReadReq if err := json.Unmarshal(m.Ctx.Input.RequestBody, &req); err != nil { br.Msg = "参数错误" br.ErrMsg = "参数错误,err:" + err.Error() return } if req.MessageId <= 0 { br.Msg = "参数错误" return } msg, err := data.ReadEdbInspectionMessage(req.MessageId, sysUser.AdminId) if err != nil { if msg == "" { msg = "系统错误" } br.Msg = msg br.ErrMsg = "读取消息失败,err:" + err.Error() return } br.Msg = "已读成功" br.Ret = 200 br.Success = true }