Documentation
¶
Index ¶
- func GetMessageBo(id int64) (*bo.MessageBo, errs.SystemErrorInfo)
- func GetMessageBoList(page uint, size uint, cond db.Cond) (*[]bo.MessageBo, int64, errs.SystemErrorInfo)
- func InsertFailMsgToDB(msgBody string, msgType int, orgId int64) (int64, error)
- func InsertMqFailMsgToDB(msg model.MqMessage, msgType int, orgId int64) (int64, errs.SystemErrorInfo)
- func UpdateMsgStatus(id int64, newStatus int) errs.SystemErrorInfo
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetMessageBo ¶
func GetMessageBo(id int64) (*bo.MessageBo, errs.SystemErrorInfo)
func GetMessageBoList ¶
func InsertFailMsgToDB ¶
InsertFailMsgToDB 将处理错误的消息放入数据库中，以便后续的排查和处理。
func InsertMqFailMsgToDB ¶
func UpdateMsgStatus ¶
func UpdateMsgStatus(id int64, newStatus int) errs.SystemErrorInfo
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.