diff --git a/business/jxstore/event/event.go b/business/jxstore/event/event.go index 9c16c94e2..5d9725f0d 100644 --- a/business/jxstore/event/event.go +++ b/business/jxstore/event/event.go @@ -128,7 +128,7 @@ func GetOperateEvents(ctx *jxcontext.Context, name string, apiFunctions []string return pageInfo, err } -func CreateMessageGroup(ctx *jxcontext.Context, userID, userID2, groupName string, dividePercentage, quitPrice int) (messageGroupResult *dao.GetMessageGroupsResult, err error) { +func CreateMessageGroup(ctx *jxcontext.Context, userID, userID2, groupName string, dividePercentage, quitPrice int) (messageGroupResult *dao.GetMessageGroupsResult, errCode string, err error) { var ( db = dao.GetDB() groupID int @@ -146,14 +146,14 @@ func CreateMessageGroup(ctx *jxcontext.Context, userID, userID2, groupName strin if userID2 != "" { messageGroups, err := dao.GetMessageGroups(db, userID, 0, model.GroupTypeSingle, true, userID2) if len(messageGroups) > 0 && len(messageGroups[0].MessageGroupMembers) > 0 { - return messageGroups[0], err + return messageGroups[0], errCode, err } user, err := dao.GetUserByID(db, "user_id", userID2) if err != nil { - return nil, err + return nil, errCode, err } if user == nil { - return nil, fmt.Errorf("无法找到要联系的用户!") + return nil, errCode, fmt.Errorf("无法找到要联系的用户!") } messageGroup := &model.MessageGroup{ GroupID: groupID, @@ -194,14 +194,22 @@ func CreateMessageGroup(ctx *jxcontext.Context, userID, userID2, groupName strin } else { userMembers, err := dao.GetUserMember(db, userID, model.MemberTypeNormal) messageGroupsResult, err := dao.GetMessageGroups(db, userID, 0, model.GroupTypeMulit, false, "") + //如果创建群聊时,他已经加入了别的群了,必须要退出之前的群才能创 + userBill, err = dao.GetUserBill(db, ctx.GetUserID(), "") + if userBill == nil { + return 0, errCode, fmt.Errorf("未查询到该用户的账单!") + } + if userBill.AccountBalance < jobOrder.UserActualPrice { + return 0, model.ErrCodeAccountBalanceNotEnough, fmt.Errorf("用户余额不足!") + } if err != nil { - return nil, err + return nil, errCode, err } if len(userMembers) == 0 { - return nil, fmt.Errorf("抱歉,只有会员才能创建群聊!") + return nil, errCode, fmt.Errorf("抱歉,只有会员才能创建群聊!") } if len(messageGroupsResult) > 0 { - return nil, fmt.Errorf("您已经有群组了,请勿重复创建!群号为:%d", messageGroupsResult[0].GroupID) + return nil, errCode, fmt.Errorf("您已经有群组了,请勿重复创建!群号为:%d", messageGroupsResult[0].GroupID) } messageGroup := &model.MessageGroup{ GroupID: groupID, @@ -236,7 +244,7 @@ func CreateMessageGroup(ctx *jxcontext.Context, userID, userID2, groupName strin dao.CreateEntity(db, messageGroupRead) } } - return messageGroupResult, err + return messageGroupResult, errCode, err } func GetMessageGroupByUser(ctx *jxcontext.Context, userID string) (messageGroupResult []*dao.GetMessageGroupsResult, err error) {