aa

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) {