package logic import ( quitl "app.yhyue.com/moapp/jybase/common" "app.yhyue.com/moapp/jybase/encrypt" util "bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/entity" "bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/service" "context" "bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/rpc/messagecenter/internal/svc" "bp.jydev.jianyu360.cn/SocialPlatform/messageCenter/rpc/messagecenter/messagecenter" "github.com/zeromicro/go-zero/core/logx" ) type SaveAutoReplyMsgLogic struct { ctx context.Context svcCtx *svc.ServiceContext logx.Logger } func NewSaveAutoReplyMsgLogic(ctx context.Context, svcCtx *svc.ServiceContext) *SaveAutoReplyMsgLogic { return &SaveAutoReplyMsgLogic{ ctx: ctx, svcCtx: svcCtx, Logger: logx.WithContext(ctx), } } // 创建会话并且保存信息 func (l *SaveAutoReplyMsgLogic) SaveAutoReplyMsg(in *messagecenter.SaveAutoReplyReq) (*messagecenter.MessageResp, error) { // todo: add your logic here and delete this line m := service.MessaggeService{} error_code, messageId := m.SaveAutoReplyMsg(in.UserType, in.EntId, in.EntUserId, in.UserId, in.Content, in.AppId, in.NowFormat) error_message := "" if error_code { return &messagecenter.MessageResp{ ErrorCode: util.SUCCESS_CODE, ErrorMsg: error_message, Data: []*messagecenter.MessageEntity{ { MessageId: encrypt.SE.Encode2Hex(quitl.InterfaceToStr(messageId)), }, }, }, nil } else { return &messagecenter.MessageResp{ ErrorCode: util.ERROR_CODE, ErrorMsg: "保存失败", }, nil } }