jyMicroservices/jyBXCore/rpc/util/userInfo.go

package util

import (
	IC "jyBXCore/rpc/init"
	"strings"

	MC "app.yhyue.com/moapp/jybase/common"
	"app.yhyue.com/moapp/jybase/mongodb"
	"app.yhyue.com/moapp/jybase/mysql"
)

// VipState 是否是付费用户
type VipState struct {
	VipState     int64 //超级订阅状态(1普通 2升级版)
	BigMember    int64 //大会员状态
	EntMember    int64 //商机管理用户状态
	RegisterData int64 //注册时间
	IsOldVip     bool  //老版超级订阅  超前项目
	IsNewEnt     bool  //新版商机管理
}

func GetVipState(mysql *mysql.Mysql, mg mongodb.MongodbSim, userId string, entId int64) (vs *VipState) {
	vs = &VipState{}
	if userId == "" {
		return
	}
	phone := ""
	data, ok := mg.FindById("user", userId, `"i_member_status":1,"i_vip_status":1,"s_m_phone":1,"s_phone":1,"o_vipjy":1,"l_registedate":1`)
	if data != nil && len(*data) > 0 && ok {
		iVipStatus := MC.Int64All((*data)["i_vip_status"])
		if iVipStatus > 1 {
			vs.VipState = 1
			oVipJY, _ := (*data)["o_vipjy"].(map[string]interface{})
			if oVipJY["o_buyset"] != nil {
				oBuys := oVipJY["o_buyset"].(map[string]interface{})
				if oBuys["upgrade"] != nil {
					vs.VipState = 2
				}
			}
		}
		if iMemberStatus := MC.Int64All((*data)["i_member_status"]); iMemberStatus > 0 {
			vs.BigMember = iMemberStatus
		}
		if sPhone, _ := (*data)["s_phone"].(string); sPhone != "" {
			phone = sPhone
		} else if sMPhone, _ := (*data)["s_m_phone"].(string); sMPhone != "" {
			phone = sMPhone
		}
		if phone != "" && entId > 0 {
			entNicheInfos := mysql.SelectBySql(`SELECT i.status,i.isNew,r.role_id,u.power FROM (entniche_user u LEFT JOIN entniche_user_role r ON r.user_id = u.id)  LEFT JOIN entniche_info i ON u.ent_id=i.id WHERE u.phone = ? and i.id = ? `, phone, entId)
			//商机管理用户信息判断
			if entNicheInfos != nil && len(*entNicheInfos) > 0 {
				entNicheInfo := (*entNicheInfos)[0]
				if MC.IntAll(entNicheInfo["status"]) > 0 && (MC.IntAll(entNicheInfo["power"]) == 1 || MC.IntAll(entNicheInfo["role_id"]) > 0) {
					vs.EntMember = 1
				}
				vs.IsNewEnt = MC.Int64All(entNicheInfo["isNew"]) > 0
			}
		}
		vs.RegisterData, _ = ((*data)["l_registedate"]).(int64)
		vs.IsOldVip = vs.VipState > 0 && vs.RegisterData < IC.C.ContextOldVipLimit
	}
	return
}

// IsPayedUser 是否是付费账户
func (vs *VipState) IsPayedUser() bool {
	return vs.VipState > 0 || vs.BigMember > 0 || vs.EntMember > 0
}

// GetQueryItems 免费 标题(title)  正文(content) 老用户【中标企业(winner)】
// 付费用户 全部(all)、标题(title)  正文(content)  会员: 采购单位(buyer) 中标企业(winner) 招标代理机构(agency) 附件(file)
// 项目名称projectname和标的物purchasing(ppa)
func (vs *VipState) GetQueryItems(selectType string, limitOldTime int64) (items []string) {
	if vs.IsPayedUser() {
		for _, t := range strings.Split(selectType, ",") {
			if t == "content" {
				items = append(items, "detail")
			} else if t == "buyer" {
				items = append(items, "buyer.mbuyer")
			} else if t == "winner" {
				items = append(items, "s_winner.mwinner")
			} else if t == "agency" {
				items = append(items, "agency.magency")
			} else if t == "title" {
				items = append(items, "title")
			} else if t == "ppa" {
				items = append(items, []string{"purchasing", "projectname.pname"}...)
			} else if t == "file" { //dev4.7.8 标讯优化：搜索范围附件-》全部用户可用
				items = append(items, "filetext")
			}
		}
		return
	}
	//老用户 使用付费功能
	isOldUser := vs.RegisterData != 0 && vs.RegisterData < limitOldTime
	for _, t := range strings.Split(selectType, ",") {
		if t == "winner" && isOldUser {
			items = append(items, "s_winner.mwinner")
		} else if t == "title" {
			items = append(items, "title")
		} else if t == "content" {
			items = append(items, "detail")
		} else if t == "file" { //dev4.7.8 标讯优化：搜索范围附件-》全部用户可用
			items = append(items, "filetext")
		}
	}
	return
}