domain

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

Functions

func GetMessageBo

func GetMessageBo(id int64) (*bo.MessageBo, errs.SystemErrorInfo)

func GetMessageBoList

func GetMessageBoList(page uint, size uint, cond db.Cond) (*[]bo.MessageBo, int64, errs.SystemErrorInfo)

func InsertFailMsgToDB

func InsertFailMsgToDB(msgBody string, msgType int, orgId int64) (int64, error)

InsertFailMsgToDB 将处理错误的消息放入数据库中，以便后续的排查和处理。

func InsertMqFailMsgToDB

func InsertMqFailMsgToDB(msg model.MqMessage, msgType int, orgId int64) (int64, errs.SystemErrorInfo)

func UpdateMsgStatus

func UpdateMsgStatus(id int64, newStatus int) errs.SystemErrorInfo