hz_crm_api/services/cygx/user_rai_label.go

package cygx

import (
	"errors"
	"fmt"
	"hongze/hz_crm_api/models/cygx"
	"hongze/hz_crm_api/services/alarm_msg"
)

// GetUserLabelByUserIdArr 根据多个userId 获取每个UserId最新的十条数据
func GetUserLabelByUserIdArr(userIdArr []int) (mapRsp map[int][]*cygx.WxUserRaiLabelListResp) {
	if len(userIdArr) == 0 {
		return
	}
	var err error
	defer func() {
		if err != nil {
			fmt.Println(err)
			go alarm_msg.SendAlarmMsg(fmt.Sprint("根据多个userId 获取每个UserId最新的十条数据失败："+err.Error(), "userIdArr", userIdArr), 2)
		}
	}()
	labelList, e := cygx.GetWxUserRaiLabelListByUserIds(userIdArr)
	if e != nil {
		err = errors.New("GetWxUserRaiLabelListByUserIds, Err: " + e.Error())
		return
	}
	mapRsp = make(map[int][]*cygx.WxUserRaiLabelListResp)
	for _, v := range labelList {
		mapRsp[v.UserId] = append(mapRsp[v.UserId], v)
	}
	return
}