...
|
...
|
@@ -74,10 +74,12 @@ func IComment(header *protocol.RequestHeader, request *protocol.ICommentRequest) |
|
|
return
|
|
|
}
|
|
|
}
|
|
|
if err = agg.SendMsg(recevierId, "", header.CompanyId, sourceId, request.SourceType, request.Content, protocol.MsgTypeComment, request.Id); err != nil {
|
|
|
log.Error(err)
|
|
|
orm.Rollback()
|
|
|
return
|
|
|
if recevierId != header.UserId {
|
|
|
if err = agg.SendMsg(recevierId, "", header.CompanyId, sourceId, request.SourceType, request.Content, protocol.MsgTypeComment, request.Id); err != nil {
|
|
|
log.Error(err)
|
|
|
orm.Rollback()
|
|
|
return
|
|
|
}
|
|
|
}
|
|
|
orm.Commit()
|
|
|
rsp = &protocol.ICommentResponse{
|
...
|
...
|
|