youngee_mc_api/app/service/youngee_task_service/local_life_info.go

package youngee_task_service

import (
	"fmt"
	"github.com/gogf/gf/frame/g"
	"github.com/gogf/gf/net/ghttp"
	"github.com/gogf/gf/os/glog"
	"github.com/gogf/gf/os/gtime"
	"github.com/gogf/gf/util/gconv"
	"math"
	"sort"
	"strconv"
	"strings"
	"youngmini_server/app/dao"
	"youngmini_server/app/model"
	"youngmini_server/app/model/youngee_talent_model"
	"youngmini_server/app/utils"
)

func GetLocalLifeList(r *ghttp.Request) *TalentHttpResult {
	pageIndex := r.GetQueryInt("idx", -1)
	cntPerPage := r.GetQueryInt("cnt", -1)
	//组合筛选
	platform := r.Get("platform", nil)       //抖音、快手、红Book、B站、微博
	taskForm := r.Get("task_form", nil)      //任务形式,1-2分别代表线下探店,素材分发
	contentType := r.Get("contenttype", nil) //图文形式、视频形式
	createTime := r.Get("createTime", nil)   //任务上线时间
	//todo 城市参数?
	//Location := r.GetQueryString("city", "") //门店store所属城市,

	//排根据浏览量排序
	viewOrder := r.GetQueryInt("pageViewOrder", -1) //根据哪个字段排序

	//仅稿费”+“稿费+赠品"。这个在recruit表中，得到列表之后进行排序
	feeForm := r.GetInt("feeform", 0)

	searchValue := r.Get("searchvalue")
	if pageIndex == -1 || cntPerPage == -1 || cntPerPage == 0 {
		return &TalentHttpResult{Code: -1, Msg: "参数错误"}
	}

	// 构造查询的条件
	startId := pageIndex * cntPerPage
	// whereStr := fmt.Sprintf("(project_status >= %d and project_status <> %d and project_type = 1)", projectStatusRecruiting, projectStatusInvalid)
	whereStr := fmt.Sprintf("(task_status >= %d and  local_type = 1)", projectStatusRecruiting)

	if taskForm != nil {
		whereStr += " and task_mode = " + taskForm.(string)
	}

	if createTime != nil {
		switch createTime.(string) {
		case "1": // 近7天
			whereStr += " AND created_at >= (NOW() - INTERVAL 7 DAY)"
		case "2": // 近30天
			whereStr += " AND created_at >= (NOW() - INTERVAL 30 DAY)"
		case "3": // 近90天
			whereStr += " AND created_at >= (NOW() - INTERVAL 90 DAY)"
		default:
			// 无效的过滤条件，跳过
			return &TalentHttpResult{
				Code: -2,
				Msg:  "无效的创建时间过滤条件",
			}
		}
	}

	if contentType != nil {
		whereStr += " and content_type = " + contentType.(string)
	}
	if platform != nil {
		whereStr += " and local_platform = " + platform.(string)
	}

	if searchValue != nil {
		whereStr += " and local_name like '%" + searchValue.(string) + "%'"
	}

	fmt.Println("whereStr:-----》 ", whereStr)

	// 查询所有project
	var localList = []youngee_talent_model.YounggeeLocalLifeInfo{}
	err := g.Model("younggee_local_life_info").Where(whereStr).Scan(&localList)
	if err != nil {
		return &TalentHttpResult{Code: -3, Msg: "查询数据库失败"}
	}

	// 判断请求页面是否超过最大页面
	c, err := g.DB().Model("younggee_local_life_info").Fields("local_id").Where(whereStr).Count()

	if c <= 0 {
		return &TalentHttpResult{Code: -4, Msg: "has no fullproject", Data: nil}
	}

	maxPage := c / cntPerPage
	if c%cntPerPage > 0 {
		maxPage += 1
	}

	if pageIndex+1 > maxPage {
		return &TalentHttpResult{Code: -5, Msg: "over max page"}
	}

	var localInfoList = youngee_talent_model.LocalInfoList{}
	err = g.DB().Model("younggee_local_life_info").WithAll().Where(whereStr).
		Order("task_status ASC,recruit_ddl DESC").Limit(startId, cntPerPage).Scan(&localInfoList.LocalInfos)

	if err != nil {
		return &TalentHttpResult{Code: -6, Msg: err.Error()}
	}

	// 遍历projectList
	for i, local := range localInfoList.LocalInfos {
		//处理浏览量
		localViewKey := "local:view:" + gconv.String(local.LocalId)
		//redis中取浏览量 返回的是gvar.Var类型。 不存咋则为nil。经过viewCount.Int变成0
		viewCount, err := g.Redis().DoVar("GET", localViewKey)
		if err != nil {
			glog.Error(err)
			return &TalentHttpResult{Code: 0, Msg: "Redis error"}
		}
		localInfoList.LocalInfos[i].WatchNum = viewCount.Int()
		// 根据 WatchedNum 从高到低排序
		if viewOrder != -1 {
			sort.Slice(localInfoList.LocalInfos, func(i, j int) bool {
				return localInfoList.LocalInfos[i].WatchNum > localInfoList.LocalInfos[j].WatchNum
			})
		}

		// 统计 RecruitStrategys 数组中的最低粉丝量和最高粉丝量
		var minFollowers, maxFollowers int
		// 初始值可以设为极大/极小值
		minFollowers = math.MaxInt32
		maxFollowers = math.MinInt32

		// 遍历 RecruitStrategys，找出最低粉丝量和最高粉丝量
		for _, strategy := range local.RecruitStrategys {
			if strategy.FollowersLow < minFollowers {
				minFollowers = strategy.FollowersLow
			}
			if strategy.FollowersUp > maxFollowers {
				maxFollowers = strategy.FollowersUp
			}
		}

		// 如果需要，可以将这些值保存到 ProjectInfo 中，供后续使用
		localInfoList.LocalInfos[i].MinFollowers = minFollowers
		localInfoList.LocalInfos[i].MaxFollowers = maxFollowers

		//稿费的展示情况
		allFeeFormNoFee := true // 假设都是无费置换
		var hasSelfPrice bool
		var minOffer, maxOffer float64

		for _, strategy := range local.RecruitStrategys {
			if strategy.FeeForm != 1 { // 如果存在非无费置换的策略
				allFeeFormNoFee = false
			}
			if strategy.FeeForm == 3 { // 存在自报价
				hasSelfPrice = true
			}
			if strategy.FeeForm == 2 { // 一口价策略
				if strategy.TOffer < minOffer || minOffer == 0 {
					minOffer = strategy.TOffer
				}
				if strategy.TOffer > maxOffer {
					maxOffer = strategy.TOffer
				}
			}
		}

		// 根据判断结果设置 IsShowOffer 和 HaveSelfPrice
		if allFeeFormNoFee {
			local.IsShowOffer = 2 // 不展示稿费
		} else {
			local.IsShowOffer = 1 // 展示稿费
			if hasSelfPrice {
				local.HaveSelfOffer = 1 //存在自报价
			} else {
				local.HaveSelfOffer = 2 //不存在自报价
			}
			localInfoList.LocalInfos[i].MaxOffer = maxOffer
			localInfoList.LocalInfos[i].MinOffer = minOffer
		}

	}
	localInfoList.MaxPage = maxPage
	var filteredLocalInfo []*youngee_talent_model.YounggeeLocalLifeInfo
	//筛选出“仅稿费”+“稿费+赠品”任务，
	//只要策略中有 无费置换 之外的fee_form就是有稿费，donate=1就是有赠品
	if feeForm != 0 {
		for _, local := range localInfoList.LocalInfos {
			if local.Donate == 1 {
				filteredLocalInfo = append(filteredLocalInfo, local)
				continue // 如果满足条件1，直接跳过后续条件判断
			}

			// 条件2：RecruitStrategy 中存在 fee_form 不等于 1 的数据
			for _, strategy := range local.RecruitStrategys {
				if strategy.FeeForm != 1 {
					filteredLocalInfo = append(filteredLocalInfo, local)
					break // 找到符合条件的策略，跳出当前循环，避免重复添加
				}
			}
		}
		localInfoList.LocalInfos = filteredLocalInfo

	}

	return &TalentHttpResult{Code: 0, Msg: "success", Data: localInfoList}

}

func GetLocalLifeDetail(r *ghttp.Request) *TalentHttpResult {
	tid, _ := utils.SessionTalentInfo.GetTalentIdFromSession(r)
	local_id := r.GetQueryString("local_id", "")
	s_local_id := r.GetQueryInt("s_local_id", 0)
	var localInfoSupplier *youngee_talent_model.LocalInfoSupplier
	if s_local_id != 0 {
		// 来自服务商
		err := g.DB().Model("younggee_s_local_life_info").Where("s_local_id=?", s_local_id).Scan(&localInfoSupplier)
		if err != nil {
			fmt.Println("projectInfoSupplier err:", err.Error())
		}
		local_id = localInfoSupplier.LocalID //获取local_id
	}
	// Redis key
	loalViewKey := "local:view:" + local_id
	userViewedKey := "user:viewed:" + tid + ":" + local_id
	//在redis中增加浏览量
	// Check if the user has already viewed the product
	//DoVar方便进行类型转化
	viewed, err := g.Redis().DoVar("GET", userViewedKey)
	if err != nil {
		glog.Error(err)
		return &TalentHttpResult{Code: 0, Msg: "Redis error"}
	}

	var talentCategory []*youngee_talent_model.YounggeeTalentCategory
	err = g.DB().Model("younggee_talent_category").Scan(&talentCategory)
	if err != nil {
		// 处理查询错误
		return &TalentHttpResult{Code: -1, Msg: err.Error()}
	}
	// 创建一个数字到汉字的映射
	categoryMap := make(map[string]string)
	for _, category := range talentCategory {
		categoryMap[fmt.Sprint(category.Id)] = category.Category
	}

	var LocalDetail *youngee_talent_model.LocalInfoDetail
	err = g.DB().Model("younggee_local_life_info").WithAll().Where("local_id", local_id).Scan(&LocalDetail)
	if err != nil {
		return &TalentHttpResult{Code: -3, Msg: err.Error()}
	}

	//填充收藏信息
	collectionInfo := []youngee_talent_model.LocalCollection{}
	err = g.DB().Model("younggee_local_collect_info").Where("local_id=? and talent_id = ?", local_id, tid).Scan(&collectionInfo)
	if err != nil {
		return &TalentHttpResult{Code: -1, Msg: err.Error()}
	}
	//已被收藏
	if len(collectionInfo) != 0 && collectionInfo[0].Deleted == 0 { //有数据  且   没取消收藏
		LocalDetail.IsCollected = 1
	} else {
		LocalDetail.IsCollected = 0 //没数据  或  有数据但取消了收藏
	}

	// 将 TalentType 转换为逗号隔开的汉字字符串
	talentTypes := strings.Split(LocalDetail.TalentType, ",")
	var result []string
	for _, t := range talentTypes {
		if name, ok := categoryMap[t]; ok {
			result = append(result, name)
		}
	}
	// 将结果拼接成逗号隔开的字符串
	resultStr := strings.Join(result, ",")
	LocalDetail.TalentType = resultStr

	var younggeePhoto []*youngee_talent_model.YounggeeProductPhoto

	teamBuyingId := LocalDetail.TeamBuyingId
	if teamBuyingId != 0 {
		err := g.DB().Model("younggee_product_photo").Where("team_buying_id", teamBuyingId).Scan(&younggeePhoto)
		if err != nil {
			return &TalentHttpResult{Code: -3, Msg: err.Error()}
		}
	}

	StoreId := LocalDetail.StoreId
	if StoreId != 0 {
		err := g.DB().Model("younggee_product_photo").Where("store_id", StoreId).Scan(&younggeePhoto)
		if err != nil {
			return &TalentHttpResult{Code: -3, Msg: err.Error()}
		}
		fmt.Println("younggeePhoto", younggeePhoto)
	}

	fmt.Println("younggeePhoto", younggeePhoto)
	LocalDetail.YounggeeProductPhoto = younggeePhoto

	//违约
	//if LocalDetail.AutoTaskId != 0 && LocalDetail.AutoDefaultId != 0 {
	//	one, _ := g.DB().Model("info_auto_default_handle").Where("auto_default_id=?", LocalDetail.AutoDefaultId).One()
	//	one2, _ := g.DB().Model("info_auto_task").Where("auto_task_id=?", LocalDetail.AutoTaskId).One()
	//	LocalDetail.DraftDefault.BreakPecent = one["sketch_replace_not_upload"].Int()
	//	LocalDetail.LinkDefault.BreakPecent = one["link_replace_not_upload"].Int()
	//	LocalDetail.DataDefault.BreakPecent = one["data_replace_not_upload"].Int()
	//	LocalDetail.DraftDefault.BreakTime = one2["draft_default"].Int()
	//	LocalDetail.DraftDefault.BreakTime = one2["link_breach"].Int()
	//	LocalDetail.DraftDefault.BreakTime = one2["case_close_default"].Int()
	//}

	if viewed.IsNil() {
		// User hasn't viewed this product yet, increase the view count
		_, err = g.Redis().Do("INCR", loalViewKey)

		if err != nil {
			glog.Error(err)
			return &TalentHttpResult{Code: 0, Msg: "Redis error"}
		}
		// Mark the product as viewed by this user
		_, err = g.Redis().Do("SET", userViewedKey, true)
		if err != nil {
			glog.Error(err)
			return &TalentHttpResult{Code: 0, Msg: "Redis error"}
		}
	}
	viewNum, err := g.Redis().DoVar("GET", loalViewKey)
	if err != nil {
		fmt.Println("获取浏览量失败")
	}
	LocalDetail.WatchedNum = viewNum.Int()

	//浏览历史
	currentDate := gtime.Now().Format("Ymd")
	// 设计 Redis Key
	redisBrowseKey := fmt.Sprintf("browseLocal:%s:%s", currentDate, tid)
	fmt.Println("redis浏览记录的key为——————————", redisBrowseKey)
	_, err = g.Redis().Do("SADD", redisBrowseKey, local_id)
	if err != nil {
		return &TalentHttpResult{Code: 0, Msg: "Redis 存浏览历史数据失败"}
	}
	// 设置 Key 的过期时间为 7 天
	_, err = g.Redis().Do("EXPIRE", redisBrowseKey, 7*24*60*60) // 7 天的秒数
	if err != nil {
		return &TalentHttpResult{Code: 0, Msg: "Redis 设置过期时间失败"}
	}

	//奖励形式
	LocalDetail.IsShowDraft = 0 // 默认不展示稿费
	LocalDetail.HaveGift = 0    // 默认没有赠品

	for _, strategy := range LocalDetail.RecruitStrategys {
		if strategy.FeeForm != 1 { // 如果存在非无费置换的策略
			LocalDetail.IsShowDraft = 1
			break // 找到一个非无费置换的策略就可以了
		}
	}
	if LocalDetail.Donate == 1 { // 是否赠送达人套餐
		LocalDetail.HaveGift = 1 // 有赠品
	}

	if LocalDetail.EnterpriseId != "" { //project来自商家
		var enterprise *youngee_talent_model.Enterprise
		err = g.DB().Model("enterprise").WithAll().Where("enterprise_id", LocalDetail.EnterpriseId).Scan(&enterprise)
		if err != nil {
			return &TalentHttpResult{Code: -3, Msg: err.Error()}
		}
		LocalDetail.Enterprise = enterprise
	}
	if s_local_id != 0 {
		// 来自服务商
		var younggeeSupplier *youngee_talent_model.YounggeeSupplier
		err = g.DB().Model("younggee_supplier").WithAll().Where("supplier_id", localInfoSupplier.SupplierID).Scan(&younggeeSupplier)
		if err != nil {
			return &TalentHttpResult{Code: -3, Msg: err.Error()}
		}
		LocalDetail.YounggeeSupplier = younggeeSupplier
		LocalDetail.LocalInfoSupplier = localInfoSupplier
	}

	return &TalentHttpResult{Code: 0, Msg: "success", Data: LocalDetail}
}

// 查询所有任务
func GetLocalTaskBriefList(r *ghttp.Request) *TalentHttpResult {
	tid, err := utils.SessionTalentInfo.GetTalentIdFromSession(r)
	if err != nil {
		return &TalentHttpResult{Code: -1, Msg: "Get talent info failed"}
	}

	taskType := r.GetInt("task_type", 0) //任务类型

	if taskType == 0 {
		return &TalentHttpResult{Code: -1, Msg: "task_type is nil"}
	}
	// 构造查询条件tid和taskType
	whereStr := fmt.Sprintf("talent_id = %s and local_type = %d", tid, taskType)

	// 获取任务列表
	var taskList []*youngee_talent_model.YoungeeLocalTaskInfo
	//此达人下，所有快手账号的任务都展示
	err = g.Model("youngee_local_task_info").Where(whereStr).Scan(&taskList)
	if err != nil {
		return &TalentHttpResult{Code: -1, Msg: "Get task list failed"}
	}

	//后续根据 PlatformId 快速查找平台信息。platformMap的key是PlatformId，value是平台具体描述
	platformMap := make(map[string]model.InfoThirdPlatform)
	platformInfo := []*model.InfoThirdPlatform{}
	if len(taskList) != 0 {
		err := g.Model(dao.InfoThirdPlatform.Table).Scan(&platformInfo)
		if err != nil {
			return &TalentHttpResult{Code: -1, Msg: "Get platform failed"}
		}

		for i, _ := range platformInfo {
			platformMap[strconv.Itoa(platformInfo[i].PlatformId)] = *platformInfo[i]
		}
	}

	//为每个任务根据项目id查询项目名称和主图
	//taskBriefList存了各个阶段的tasklist
	taskBriefList := youngee_talent_model.LocalTaskInfoBriefList{}
	for _, v := range taskList { //taskList含所有任务
		//获取具体的招募策略，taskInfo中
		var localDetail *youngee_talent_model.LocalInfoDetail
		err := g.Model("younggee_local_life_info").WithAll().Where("local_id = ?", v.LocalId).Scan(&localDetail)
		if err != nil {
			return &TalentHttpResult{Code: -1, Msg: "Get fullproject info failed"}
		}
		var account *youngee_talent_model.KuaishouUserInfo
		fmt.Println("openid---->", v.OpenId)
		err = g.Model("platform_kuaishou_user_info").Where("platform_id = ? and talent_id = ? and open_id = ?", localDetail.LocalPlatform, tid, v.OpenId).Scan(&account)
		//拿快手平台验证是否过期
		//expired := youngee_talent_service.CheckKuaishouTokenExp(account.OpenId)
		//account.Expired = expired
		if err != nil {
			return &TalentHttpResult{Code: -1, Msg: "Get account info failed"}
		}
		//taskInfoBrief含需要展示在页面的内容，被加入各阶段List

		taskInfoBrief := &youngee_talent_model.LocalTaskInfoBrief{
			TaskId:          v.TaskId,
			PlatformIconUrl: platformMap[strconv.Itoa(localDetail.PlatformInfo.PlatformId)].PlatformIcon,
			//PlatformName:     platformMap[projectInfo[dao.ProjectInfo.Columns.ProjectPlatform].String()].PlatformName,
			//PlatformNickName: account[dao.YoungeePlatformAccountInfo.Columns.PlatformNickname].String(),

			ProjectName: localDetail.LocalName,
			//ProductPhotoSnap: localDetail.ProductPhotoSnap,
			TaskStatus: v.TaskStatus,
			TaskStage:  v.TaskStage,
			LinkStatus: v.LinkStatus,
			DataStatus: v.DataStatus,
			//ScriptStatus:     v.ScriptStatus,
			SketchStatus: v.SketchStatus,
			TaskReward:   v.TaskReward,
			BreakRate:    v.ScriptBreakRate + v.SketchBreakRate + v.LinkBreakRate + v.DataBreakRate,
			CurBreakAt:   v.CurBreakAt,
			FeeForm:      v.FeeForm,
			LocalDetail:  localDetail,
			TaskInfo:     v,
			AccountInfo:  account, //含是否过期，粉丝数，作品数目

		}
		taskBriefList.AllTaskInfoList = append(taskBriefList.AllTaskInfoList, taskInfoBrief)
		//1:已报名, 2:申请成功, 3:申请失败, 4:待预约探店, 5:预约确认中 6:预约成功  , 7:待传探底图片, 8:脚本待审, 9:待传初稿, 10:初稿待审,
		//11:待传链接, 12:链接待审, 13:待传数据, 14:数据待审, 15:已结案, 16:解约, 17:终止合作(过渡态)',
		if v.TaskStage <= 2 {
			taskBriefList.SignUpTaskInfoList = append(taskBriefList.SignUpTaskInfoList, taskInfoBrief)
		} else if v.TaskStage == 4 { //如果是线下探店
			taskBriefList.WaitBookList = append(taskBriefList.WaitBookList, taskInfoBrief)
		} else if v.TaskStage <= 14 && v.TaskStage >= 5 {
			taskBriefList.GoingOnTaskInfoList = append(taskBriefList.GoingOnTaskInfoList, taskInfoBrief)
		} else if v.TaskStage == 15 {
			taskBriefList.WaitToPayInfoList = append(taskBriefList.WaitToPayInfoList, taskInfoBrief)
		} else {
			taskBriefList.CompletedTaskInfoList = append(taskBriefList.CompletedTaskInfoList, taskInfoBrief)
		}

	}

	return &TalentHttpResult{Code: 0, Msg: "success", Data: taskBriefList}
}

func GetLocalTaskDetail(r *ghttp.Request) *TalentHttpResult {
	taskId := r.Get("task_id", "")
	if taskId == "" {
		return &TalentHttpResult{Code: -1, Msg: "task_id is empty"}
	}
	var task *youngee_talent_model.YoungeeLocalTaskInfo
	err := g.Model("youngee_local_task_info").Where("task_id = ?", taskId).Scan(&task)
	if err != nil {
		return &TalentHttpResult{Code: -1, Msg: "Get task info failed"}
	}

	var localDetail *youngee_talent_model.LocalInfoDetail
	err = g.Model(youngee_talent_model.LocalInfoDetail{}).WithAll().Where("local_id", task.LocalId).Scan(&localDetail)
	if err != nil {
		return &TalentHttpResult{Code: -3, Msg: "data query failed"}
	}

	var productPhoto *youngee_talent_model.YounggeeProductPhoto
	err = g.Model("younggee_product_photo").Where("store_id = ? and symbol = 1", localDetail.StoreId).Scan(&productPhoto)
	if err != nil {
		return &TalentHttpResult{Code: -3, Msg: "data query failed"}
	}

	var withdrawStatus = 1
	var taskIncome *model.YounggeeTalentIncome
	err = g.Model(dao.YounggeeTalentIncome.Table).Where("task_id = ? and income_type = 1", taskId).Scan(&taskIncome)
	if err != nil {
		return &TalentHttpResult{Code: -3, Msg: "Get task income detail failed."}
	}
	if taskIncome != nil {
		withdrawStatus = taskIncome.WithdrawStatus + 1
	}

	taskDetail := &youngee_talent_model.LocalTaskDetail{}
	if localDetail.LocalType == 1 {
		var strategy *youngee_talent_model.RecruitStrategy
		err = g.DB().Model("recruit_strategy").Where("project_id = ? and strategy_id = ?", task.LocalId, task.StrategyId).Scan(&strategy)
		if err != nil {
			return &TalentHttpResult{Code: -3, Msg: "data query failed"}
		}

		taskDetail = &youngee_talent_model.LocalTaskDetail{
			TaskInfo:       task,
			LocalDetail:    localDetail,
			ProductPhoto:   productPhoto, //首页图片
			Strategy:       strategy,
			WithdrawStatus: withdrawStatus,
		}
	} else {
		taskDetail = &youngee_talent_model.LocalTaskDetail{
			TaskInfo:       task,
			LocalDetail:    localDetail,
			ProductPhoto:   productPhoto,
			WithdrawStatus: withdrawStatus,
		}
	}

	return &TalentHttpResult{Code: 0, Msg: "success", Data: taskDetail}

}