add message

business/jxstore/event/event.go

@@ -225,3 +225,24 @@ func GetMessageGroupByUser(ctx *jxcontext.Context, userID string) (messageGroupR
 	}
 	return messageGroups, err
 }
+
+func AddMessageGroup(ctx *jxcontext.Context, groupID int, userID string) (err error) {
+	var (
+		db = dao.GetDB()
+	)
+	messageGroupMembers, err := dao.GetMessageGroupMembers(db, groupID, userID)
+	if err != nil {
+		return err
+	}
+	if len(messageGroupMembers) > 0 {
+		return fmt.Errorf("此用户已经在该群组中了，请不要重复邀请！")
+	}
+	messageGroupMember := &model.MessageGroupMember{
+		GroupID:      groupID,
+		MemberUserID: userID,
+		Type:         model.GroupMemberTypeNormal,
+	}
+	dao.WrapAddIDCULDEntity(messageGroupMember, ctx.GetUserName())
+	dao.CreateEntity(db, messageGroupMember)
+	return err
+}

business/model/dao/event.go

@@ -211,3 +211,22 @@ func GetMessageGroups(db *DaoDB, userID string, groupType int, isMember bool, us
 	}
 	return messageGroupsResult, err
 }
+
+func GetMessageGroupMembers(db *DaoDB, groupID int, memberUserID string) (messageGroupMembers []*model.MessageGroupMember, err error) {
+	sql := `
+		SELECT * 
+		  FROM message_group_member
+		 WHERE deleted_at = ?  
+	`
+	sqlParams := []interface{}{utils.DefaultTimeValue}
+	if groupID != 0 {
+		sql += " AND group_id = ?"
+		sqlParams = append(sqlParams, groupID)
+	}
+	if memberUserID != "" {
+		sql += " AND member_user_id = ?"
+		sqlParams = append(sqlParams, memberUserID)
+	}
+	err = GetRows(db, &messageGroupMembers, sql, sqlParams)
+	return messageGroupMembers, err
+}

controllers/event.go

@@ -222,13 +222,14 @@ func (c *EventController) GetMessageGroupByUser() {
 // @Title 加入用户组
 // @Description 加入用户组
 // @Param	token			header		string	true	"认证token"
-// @Param	groupID		 	formData	string	true	"组号"
+// @Param	groupID		 	formData	int		true	"组号"
 // @Param	userID		 	formData	string	true	"被邀请人ID"
 // @Success 200 {object} controllers.CallResult
 // @Failure 200 {object} controllers.CallResult
 // @router /AddMessageGroup [post]
 func (c *EventController) AddMessageGroup() {
 	c.callAddMessageGroup(func(params *tEventAddMessageGroupParams) (retVal interface{}, errCode string, err error) {
+		err = event.AddMessageGroup(params.Ctx, params.GroupID, params.UserID)
 		return retVal, "", err
 	})
 }