case-admin-api/api/service/User.go

package service

import (
	"case-admin-api/api/dao"
	"case-admin-api/api/model"
	"case-admin-api/extend/aliyun"
	"case-admin-api/extend/app"
	"case-admin-api/extend/superKangaroo"
	"errors"
	"fmt"
	"gorm.io/gorm"
	"io"
	"math/rand"
	"net/http"
	"time"
)

type UserService struct {
}

// HandleUserImage 处理用户图片
func (r *UserService) HandleUserImage(wxAvatar string) (ossPath string, err error) {
	if wxAvatar == "" {
		return "", nil
	}

	// 发送GET请求
	resp, err := http.Get(wxAvatar)
	if err != nil {
		return "", err
	}

	defer func(Body io.ReadCloser) {
		_ = Body.Close()
	}(resp.Body)

	if resp.StatusCode != 200 {
		return "", errors.New("请求失败")
	}

	// 读取响应体
	respBody, err := io.ReadAll(resp.Body)
	if err != nil {
		return "", err
	}

	// 设置文件名字
	now := time.Now()
	dateTimeString := now.Format("20060102150405")  // 当前时间字符串
	rand.New(rand.NewSource(time.Now().UnixNano())) // 设置随机数
	ossPath = "user/avatar/" + dateTimeString + fmt.Sprintf("%d", rand.Intn(9000)+1000) + ".png"

	// 上传oss
	_, err = aliyun.PutObjectByte(ossPath, respBody)
	if err != nil {
		return "", err
	}

	ossPath = "/" + ossPath

	return ossPath, nil
}

// ReportUserScore 发放积分
// scoreType : 积分类型（1:完成阅读 2:阅读时间满足 3:优质留言 4:再次优质留言 ）
func (r *UserService) ReportUserScore(tx *gorm.DB, projectId, caseId, platformId int64, scoreType int, user *model.User) (err error) {
	// 获取项目关联平台
	projectPlatformDao := dao.ProjectPlatformDao{}
	maps := make(map[string]interface{})
	maps["project_id"] = projectId
	maps["platform_id"] = platformId
	projectPlatform, err := projectPlatformDao.GetProjectPlatform(maps)
	if err != nil {
		return err
	}

	// 检测福利开关
	if projectPlatform.IsWelfare == 0 {
		// 福利未开
		return nil
	}

	// 获取需发放积分
	score := 0
	appScoreTypeStr := ""   // 积分发放原因-app
	superScoreTypeStr := "" // 积分发放原因-超级袋鼠
	nodeName := ""          // 获取积分节点名称
	if scoreType == 1 {
		// 完成阅读
		score = projectPlatform.CompleteRead
		appScoreTypeStr = "互动病例-完成阅读"
		superScoreTypeStr = "调研奖励(完成阅读)"
		nodeName = "学习"
	} else if scoreType == 2 {
		// 阅读时间满足
		score = projectPlatform.CompleteReadTime
		appScoreTypeStr = "互动病例-阅读时间满足"
		superScoreTypeStr = "调研奖励(阅读质量)"
		nodeName = "阅读达标"
	} else if scoreType == 3 {
		// 优质留言
		score = projectPlatform.FirstHighQuality
		appScoreTypeStr = "互动病例-优质留言"
		superScoreTypeStr = "调研奖励(社区贡献)"
		nodeName = "优质留言"
	} else if scoreType == 4 {
		// 再次优质留言
		score = projectPlatform.OnceMoreHighQuality
		appScoreTypeStr = "互动病例-优质留言"
		superScoreTypeStr = "调研奖励(社区贡献)"
		nodeName = "优质留言"
	}

	recordScoreDao := dao.RecordScoreDao{}

	// 检测是否有相同手机号用户
	userDao := dao.UserDao{}
	maps = make(map[string]interface{})
	maps["mobile_encryption"] = user.MobileEncryption
	users, err := userDao.GetUserList(maps)
	if err != nil {
		return nil
	}
	for _, m := range users {
		// 检测积分是否已在其他平台发放过
		maps = make(map[string]interface{})
		maps["project_id"] = projectId
		maps["case_id"] = caseId
		maps["user_id"] = m.UserId
		recordScore, _ := recordScoreDao.GetRecordScoreUseTx(tx, maps)
		if recordScore != nil {
			if recordScore.PlatformId != platformId {
				// 由其他平台进行发放积分 修改平台id为其他平台id
				platformId = recordScore.PlatformId

				user = m
			}
		}

		// 检测该类型积分是否已经发放(其他平台也算)
		maps = make(map[string]interface{})
		maps["project_id"] = projectId
		maps["case_id"] = caseId
		maps["platform_id"] = platformId
		maps["user_id"] = m.UserId
		maps["type"] = scoreType
		recordScore, _ = recordScoreDao.GetRecordScore(maps)
		if recordScore != nil {
			// 积分已发放过
			return nil
		}
	}

	// 默认为白名单用户
	isWhite := true
	if projectPlatform.IsWhite == 1 {
		projectPlatformWhiteService := ProjectPlatformWhiteService{}
		isWhite, err = projectPlatformWhiteService.CheckProjectPlatformWhiteByUser(user, projectId, platformId)
		if err != nil {
			return err
		}
	}

	// 佳动力需求：非白名单用户也需要请求积分记录
	// 当用户为非白名单时，重置积分数
	if isWhite == false {
		score = 0
	}

	// 获取病例关联平台数据
	casePlatformDao := dao.CasePlatformDao{}
	maps = make(map[string]interface{})
	maps["case_id"] = caseId
	maps["platform_id"] = platformId
	casePlatform, err := casePlatformDao.GetCasePlatform(maps)
	if err != nil {
		return err
	}

	// 检测全部积分是否已发放完毕
	remainingScore := projectPlatform.SingleCaseScore - casePlatform.IssuedScore
	if remainingScore <= 0 {
		// 积分已发放完毕
		return nil
	}

	// 新增发放记录-每发一次记录一次
	recordScore := &model.RecordScore{
		ProjectId:  projectId,
		CaseId:     caseId,
		PlatformId: platformId,
		UserId:     user.UserId,
		UserName:   user.UserName,
		Type:       scoreType,
		NodeName:   nodeName,
		Score:      score,
	}

	recordScore, err = recordScoreDao.AddRecordScore(tx, recordScore)
	if err != nil {
		return err
	}

	// 获取用户参与记录
	caseUserDao := dao.CaseUserDao{}
	maps = make(map[string]interface{})
	maps["case_id"] = caseId
	maps["platform_id"] = platformId
	maps["user_id"] = user.UserId
	caseUser, _ := caseUserDao.GetCaseUserUseTx(tx, maps)
	if caseUser == nil {
		return errors.New("用户还未完成该病例阅读，请稍后再试")
	}

	// 累计用户领取积分数据
	err = caseUserDao.Inc(tx, caseUser.CaseUserId, "total_score", score)
	if err != nil {
		return err
	}

	// 累计平台发放积分数据
	err = casePlatformDao.Inc(tx, casePlatform.CasePlatformId, "issued_score", score)
	if err != nil {
		return err
	}

	// 累计发放积分数据
	caseDao := dao.CaseDao{}
	err = caseDao.Inc(tx, caseId, "issued_score", score)
	if err != nil {
		return err
	}

	// 发放积分-
	if platformId != 1 && platformId != 2 {
		return errors.New("积分发放失败")
	}

	// 肝胆相照
	if platformId == 1 && score > 0 {
		_, err = app.ReportUserScore(appScoreTypeStr, user.UserIden, score)
		if err != nil {
			return err
		}
	}

	// 超级袋鼠
	if platformId == 2 {
		// 获取病例数据
		caseDao := dao.CaseDao{}
		result, err := caseDao.GetCaseById(caseId)
		if err != nil {
			return err
		}

		_, err = superKangaroo.ReportUserScore(caseId, user.UserIden, superScoreTypeStr, recordScore, result)
		if err != nil {
			return err
		}
	}

	return nil
}