liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

aa

Browse Source
This commit is contained in:
苏尹岚
2020-12-29 16:40:36 +08:00
parent c4ce270e1a
commit 269b7fa710
1 changed files with 12 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

28
business/jxstore/event/event.go
View File

@@ -128,7 +128,7 @@ func GetOperateEvents(ctx *jxcontext.Context, name string, apiFunctions []string
return pageInfo, err return pageInfo, err
} }
func CreateMessageGroup(ctx *jxcontext.Context, userID, userID2, groupName string, dividePercentage, quitPrice int) (messageGroupResult *dao.GetMessageGroupsResult, errCode string, err error) { func CreateMessageGroup(ctx *jxcontext.Context, userID, userID2, groupName string, dividePercentage, quitPrice int) (messageGroupResult *dao.GetMessageGroupsResult, err error) {
var ( var (
db = dao.GetDB() db = dao.GetDB()
groupID int groupID int
@@ -146,14 +146,14 @@ func CreateMessageGroup(ctx *jxcontext.Context, userID, userID2, groupName strin
if userID2 != "" { if userID2 != "" {
messageGroups, err := dao.GetMessageGroups(db, userID, 0, model.GroupTypeSingle, true, userID2) messageGroups, err := dao.GetMessageGroups(db, userID, 0, model.GroupTypeSingle, true, userID2)
if len(messageGroups) > 0 && len(messageGroups[0].MessageGroupMembers) > 0 { if len(messageGroups) > 0 && len(messageGroups[0].MessageGroupMembers) > 0 {
return messageGroups[0], errCode, err return messageGroups[0], err
} }
user, err := dao.GetUserByID(db, "user_id", userID2) user, err := dao.GetUserByID(db, "user_id", userID2)
if err != nil { if err != nil {
return nil, errCode, err return nil, err
} }
if user == nil { if user == nil {
return nil, errCode, fmt.Errorf("无法找到要联系的用户！") return nil, fmt.Errorf("无法找到要联系的用户！")
} }
messageGroup := &model.MessageGroup{ messageGroup := &model.MessageGroup{
GroupID: groupID, GroupID: groupID,
@@ -194,22 +194,18 @@ func CreateMessageGroup(ctx *jxcontext.Context, userID, userID2, groupName strin
} else { } else {
userMembers, err := dao.GetUserMember(db, userID, model.MemberTypeNormal) userMembers, err := dao.GetUserMember(db, userID, model.MemberTypeNormal)
messageGroupsResult, err := dao.GetMessageGroups(db, userID, 0, model.GroupTypeMulit, false, "") messageGroupsResult, err := dao.GetMessageGroups(db, userID, 0, model.GroupTypeMulit, false, "")
//如果创建群聊时，他已经加入了别的群了，必须要退出之前的群才能创 messageGroupMembers, err := dao.GetMessageGroupMembers(db, 0, model.GroupTypeMulit, userID)
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 { if err != nil {
return nil, errCode, err return nil, err
} }
if len(userMembers) == 0 { if len(userMembers) == 0 {
return nil, errCode, fmt.Errorf("抱歉，只有会员才能创建群聊！") return nil, fmt.Errorf("抱歉，只有会员才能创建群聊！")
} }
if len(messageGroupsResult) > 0 { if len(messageGroupsResult) > 0 {
return nil, errCode, fmt.Errorf("您已经有群组了，请勿重复创建！群号为：%d", messageGroupsResult[0].GroupID) return nil, fmt.Errorf("您已经有群组了，请勿重复创建！群号为：%d", messageGroupsResult[0].GroupID)
}
if len(messageGroupMembers) > 0 {
return nil, fmt.Errorf("您已加入了[%v]群，请先退出后再创建！", messageGroupMembers[0].GroupID)
} }
messageGroup := &model.MessageGroup{ messageGroup := &model.MessageGroup{
GroupID: groupID, GroupID: groupID,
@@ -244,7 +240,7 @@ func CreateMessageGroup(ctx *jxcontext.Context, userID, userID2, groupName strin
dao.CreateEntity(db, messageGroupRead) dao.CreateEntity(db, messageGroupRead)
} }
} }
return messageGroupResult, errCode, err return messageGroupResult, err
} }
func GetMessageGroupByUser(ctx *jxcontext.Context, userID string) (messageGroupResult []*dao.GetMessageGroupsResult, err error) { func GetMessageGroupByUser(ctx *jxcontext.Context, userID string) (messageGroupResult []*dao.GetMessageGroupsResult, err error) {