|
|
@@ -1,341 +0,0 @@
|
|
|
-package jy
|
|
|
-
|
|
|
-import (
|
|
|
- "encoding/json"
|
|
|
- "fmt"
|
|
|
- "log"
|
|
|
- "math/rand"
|
|
|
- . "mongodb"
|
|
|
- qutil "qfw/util"
|
|
|
- "qfw/util/mysql"
|
|
|
- "qfw/util/redis"
|
|
|
- "strings"
|
|
|
- "time"
|
|
|
-)
|
|
|
-
|
|
|
-// 大会员状态redis缓存
|
|
|
-type BigVipBaseMsg struct {
|
|
|
- Status int `json:"status"` //大会员状态
|
|
|
- Used bool `json:"used"` //是否首次使用大会员
|
|
|
- PowerMap map[int]bool `json:"p_map"` //权限列表
|
|
|
- ProNum int `json:"p_num"` //可关注项目数量
|
|
|
- EntNum int `json:"e_num"` //可关注企业数量(取企业情报监控和企业中标动态中最大的值)
|
|
|
- DailyNum int `json:"d_num"` //数据包导出数量
|
|
|
- Pid string `json:"pid"` //若为子账号此处为父节点userid
|
|
|
- Uid string `json:"uid"` //用户id
|
|
|
- HasTrial bool `json:"has_trial"` //是否试用过
|
|
|
- Customers int `json:"customers"` //可关注客户数量
|
|
|
- VipStatus int `json:"vip_status"` //超级订阅状态
|
|
|
- Vip_BuySet BuySet `json:"vip_buyset"` //超级订阅套餐内容
|
|
|
- EntnicheStatus int `json:"entniche_status"` //商机管理状态
|
|
|
- IsUpgrade bool `json:"isUpgrade"` //是否是免费用户订阅升级用户 默认true
|
|
|
- Registedate int64 `json:"registedate"` //用户注册时间
|
|
|
- EntName string `json:"entname"` //企业名称
|
|
|
- EntIsNew bool `json:"entIsNew"` //是否是新版商机管理用户
|
|
|
- IsEntService bool `json:"isEntService"` //是否有商机管理服务
|
|
|
- PrivateGD bool `json:"PrivateGD"` //广东移动DICT 用户
|
|
|
- Email string `json:"email"`
|
|
|
- EntInfo map[int]*EntInfoStruct `json:"entInfo"` //企业信息
|
|
|
- MemberPowerType int64 `json:"memberPowerType"` //大会员权益类型 0无 1个人 2企业
|
|
|
- VipPowerType int64 `json:"vipPowerType"` //超级订阅权益类型 0无 1个人 2企业
|
|
|
- BaseUserId int `json:"base_user_id"` //用户base_user_id
|
|
|
-}
|
|
|
-
|
|
|
-type EntInfoStruct struct {
|
|
|
- IsNew bool `json:"isNew"` //是否是新版商机管理
|
|
|
- IsPower bool `json:"isPower"` //是否分配了商机管理权限
|
|
|
- Status int `json:"status"` //是否购买
|
|
|
- Name string `json:"name"` //企业名称
|
|
|
- IsService bool `json:"isService"` //企业商机管理服务
|
|
|
- RoleId int `json:"roleId"` //角色默认0：员工； 1：系统（企业）管理员；2：部门管理员
|
|
|
-}
|
|
|
-
|
|
|
-// 超级订阅购买内容
|
|
|
-type BuySet struct {
|
|
|
- Upgrade int `json:"upgrade"` //是否是升级版;1是 其他不是
|
|
|
- AreaCount int `json:"areacount"` //省份数量
|
|
|
- BuyerclassCount int `json:"buyerclasscount"` //行业数
|
|
|
-}
|
|
|
-
|
|
|
-var FrontService, BackService map[string][]int
|
|
|
-
|
|
|
-const (
|
|
|
- IsNewFreeTimeCell = 1637830020
|
|
|
- BigmemberServiceTable = "bigmember_service"
|
|
|
- BigmemberUserPowerTable = "bigmember_service_user"
|
|
|
-
|
|
|
- PowerCacheDb = "other"
|
|
|
- PowerCacheKey = "bigmember_power_3_%s"
|
|
|
- OneDay = 60 * 60 * 24
|
|
|
- UserUpdateAreaKey = "free_area_num_%s_%s"
|
|
|
- BaseAreaNum = 1
|
|
|
- VipFileUploadNumKey = "vip_file_num_%s_%s" //超级订阅附件本月一下载次数 %s:userid ; %s:当前月份-fmt.Sprint(time.Now().Month())
|
|
|
- FilePackNumKey = "file_pack_num_%s_%s" //附件下载包本月 剩余次数 %s:userid %s 当前月份-fmt.Sprint(time.Now().Month())
|
|
|
- BaseInfoCacheDb = "newother"
|
|
|
- IsGetUserBaseInfoRedisKey = "baseinfo_%s"
|
|
|
- RedisMenuKeyPC = "jy_workdesktopmenu_10000_PC_%s" //剑鱼appid：10000
|
|
|
- RedisMenuKeyWX = "jy_workdesktopmenu_10000_WX_%s" //剑鱼appid：10000
|
|
|
- RedisMenuKeyAPP = "jy_workdesktopmenu_10000_APP_%s" //剑鱼appid：10000
|
|
|
- UserPowerRedisKey = "jy_userpowerredis_10000_%d_%s" //工作桌面 用户功能缓存（类似bigmember_power_3_%s）
|
|
|
-)
|
|
|
-
|
|
|
-// 初始化大会员权益
|
|
|
-func InitBigVipService(mysql *mysql.Mysql) {
|
|
|
- serviceList := mysql.Find(BigmemberServiceTable, nil, "id,s_url_front,s_url_back", "id", -1, -1)
|
|
|
- if serviceList == nil || len(*serviceList) == 0 {
|
|
|
- panic(fmt.Sprintf("大会员初始权限失败,请检查mysql链接是否正常、查看%s表是否正常", BigmemberServiceTable))
|
|
|
- }
|
|
|
- FrontService, BackService = make(map[string][]int), make(map[string][]int)
|
|
|
- for _, one := range *serviceList {
|
|
|
- power := qutil.ObjToMap(one)
|
|
|
- if power == nil {
|
|
|
- continue
|
|
|
- }
|
|
|
- serviceId := qutil.IntAll((*power)["id"])
|
|
|
- if urlFronts := qutil.ObjToString((*power)["s_url_front"]); urlFronts != "" {
|
|
|
- for _, urlFront := range strings.Split(urlFronts, "&") {
|
|
|
- FrontService[urlFront] = append(FrontService[urlFront], serviceId)
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- if urlBacks := qutil.ObjToString((*power)["s_url_back"]); urlBacks != "" {
|
|
|
- for _, urlBack := range strings.Split(urlBacks, "&") {
|
|
|
- BackService[urlBack] = append(BackService[urlBack], serviceId)
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
- log.Printf("init BigVipService status \nFrontService:%+v\nBackService:%+v\n", FrontService, BackService)
|
|
|
-}
|
|
|
-
|
|
|
-// 当大会员状态改变时清除此状态
|
|
|
-func ClearBigVipUserPower(userId string) bool {
|
|
|
- cacheKey := fmt.Sprintf(PowerCacheKey, userId)
|
|
|
- baseInfoCacheKey := fmt.Sprintf(IsGetUserBaseInfoRedisKey, userId)
|
|
|
- redisMenuKeyPC := fmt.Sprintf(RedisMenuKeyPC, userId)
|
|
|
- redisMenuKeyWX := fmt.Sprintf(RedisMenuKeyWX, userId)
|
|
|
- redisMenuKeyAPP := fmt.Sprintf(RedisMenuKeyAPP, userId)
|
|
|
- userPowerRedisKey := fmt.Sprintf(UserPowerRedisKey, time.Now().Day(), userId)
|
|
|
- return redis.Del(BaseInfoCacheDb, cacheKey) && redis.Del(BaseInfoCacheDb, baseInfoCacheKey) && redis.Del(BaseInfoCacheDb, redisMenuKeyPC) && redis.Del(BaseInfoCacheDb, redisMenuKeyWX) && redis.Del(BaseInfoCacheDb, redisMenuKeyAPP) && redis.Del(BaseInfoCacheDb, userPowerRedisKey)
|
|
|
-}
|
|
|
-
|
|
|
-// 获取商机管理个人基本信息
|
|
|
-func GetEntnicheState(userId string, mysql *mysql.Mysql, mg MongodbSim) *BigVipBaseMsg {
|
|
|
- userPower := BigVipBaseMsg{}
|
|
|
- userPower.EntnicheStatus = 0
|
|
|
- //手机号
|
|
|
- data, ok := mg.FindById("user", userId, `{"s_phone":1,"s_m_phone":1,i_member_status":1,"i_member_give":1,"s_member_mainid":1,"i_member_sub_status":1,"i_member_trial":1,"i_vip_status":1,"o_vipjy":1,"o_jy":1,"l_registedate":1}`)
|
|
|
- if ok && *data != nil && len(*data) > 0 {
|
|
|
- //查询是否是商机管理付费用户
|
|
|
- phone, _ := qutil.If((*data)["s_phone"] != nil, (*data)["s_phone"], (*data)["s_m_phone"]).(string)
|
|
|
- if phone != "" {
|
|
|
- if count := mysql.CountBySql(`SELECT count(1) FROM entniche_user u LEFT JOIN entniche_info i ON u.ent_id=i.id WHERE u.phone=? and u.power=1 and i.status=1`, phone); count > 0 {
|
|
|
- userPower.EntnicheStatus = 1
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
- return &userPower
|
|
|
-}
|
|
|
-
|
|
|
-// 获取大会员个人基本信息
|
|
|
-func GetBigVipUserBaseMsg(userId string, mysql *mysql.Mysql, mg MongodbSim) *BigVipBaseMsg {
|
|
|
- userPower := BigVipBaseMsg{}
|
|
|
- userPower.PowerMap = make(map[int]bool)
|
|
|
- if userId == "" {
|
|
|
- return &userPower
|
|
|
- }
|
|
|
- userPower.IsUpgrade = false
|
|
|
- userPower.Uid = userId
|
|
|
- cacheKey := fmt.Sprintf(PowerCacheKey, userId)
|
|
|
-
|
|
|
- if bytes, err := redis.GetBytes(BaseInfoCacheDb, cacheKey); err == nil && bytes != nil {
|
|
|
- if err := json.Unmarshal(*bytes, &userPower); err == nil {
|
|
|
- return &userPower
|
|
|
- }
|
|
|
- }
|
|
|
- //大会员状态
|
|
|
- data, ok := mg.FindById("user", userId, `{"s_phone":1,"s_m_phone":1,i_member_status":1,"i_member_give":1,"s_member_mainid":1,"i_member_sub_status":1,"i_member_trial":1,"i_vip_status":1,"o_vipjy":1,"o_jy":1,"l_registedate":1,"s_myemail":1,"base_user_id":1}`)
|
|
|
- if ok && *data != nil && len(*data) > 0 {
|
|
|
- userPower.Email = qutil.ObjToString((*data)["s_myemail"])
|
|
|
- userPower.BaseUserId = qutil.IntAll((*data)["base_user_id"])
|
|
|
- userPower.Registedate = qutil.Int64All((*data)["l_registedate"])
|
|
|
- userPower.Status = qutil.IntAllDef((*data)["i_member_status"], 0)
|
|
|
- //子账号被启用
|
|
|
- i_member_sub_status := qutil.IntAllDef((*data)["i_member_sub_status"], 0)
|
|
|
- if (*data)["s_member_mainid"] != nil && qutil.ObjToString((*data)["s_member_mainid"]) != "" && i_member_sub_status > 0 {
|
|
|
- userPower.Pid = qutil.ObjToString((*data)["s_member_mainid"])
|
|
|
- }
|
|
|
- if (userPower.Pid != "" && qutil.IntAllDef((*data)["i_member_sub_status"], 0) == 1) || mg.Count("member", map[string]interface{}{"userid": userId}) > 0 {
|
|
|
- userPower.Used = true
|
|
|
- }
|
|
|
- if (*data)["i_member_trial"] != nil {
|
|
|
- userPower.HasTrial = true
|
|
|
- }
|
|
|
- if vipStatus := qutil.IntAll((*data)["i_vip_status"]); vipStatus > 0 {
|
|
|
- userPower.VipStatus = vipStatus
|
|
|
- if o_vipjy := qutil.ObjToMap((*data)["o_vipjy"]); o_vipjy != nil {
|
|
|
- if o_buyset := qutil.ObjToMap((*o_vipjy)["o_buyset"]); o_buyset != nil {
|
|
|
- userPower.Vip_BuySet = BuySet{
|
|
|
- Upgrade: qutil.IntAll((*o_buyset)["upgrade"]),
|
|
|
- AreaCount: qutil.IntAll((*o_buyset)["areacount"]),
|
|
|
- BuyerclassCount: qutil.IntAll((*o_buyset)["buyerclasscount"]),
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
- userPower.VipPowerType = 1
|
|
|
- }
|
|
|
- if userPower.Status > 0 {
|
|
|
- userPower.MemberPowerType = 1
|
|
|
- }
|
|
|
- //免费用户画像和附件下载权限
|
|
|
- //if userPower.Status <= 0 && userPower.VipStatus <= 0 {
|
|
|
- o_jy := qutil.ObjToMap((*data)["o_jy"])
|
|
|
- //"i_newfree": 1, //新免费用户=>新订阅设置页面 20211122
|
|
|
- //IsNewFreeTimeCell dev3.6.4版本之前发了个紧急版本处理老用户订阅问题，i_newfree字段必须用户选择地区才能生成，不能作为判断是否是新用户得唯一标识，在此版本添加了常量：IsNewFreeTimeCell作为判断标准；--ws
|
|
|
- if qutil.IntAll((*o_jy)["i_newfree"]) > 0 || IsNewFreeTimeCell < userPower.Registedate {
|
|
|
- userPower.IsUpgrade = true
|
|
|
- }
|
|
|
- //}
|
|
|
- //查询是否是商机管理付费用户
|
|
|
- //userPower.EntnicheStatus = 0
|
|
|
- phone, _ := qutil.If((*data)["s_phone"] != nil, (*data)["s_phone"], (*data)["s_m_phone"]).(string)
|
|
|
- if phone != "" {
|
|
|
- res := mysql.SelectBySql(`SELECT i. STATUS AS status, i.isNew, i.power_source, r.role_id, u.power, i.name,i.id 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 = ? ORDER BY i. STATUS DESC, i.auth_status DESC`, phone)
|
|
|
- if res != nil && len(*res) > 0 {
|
|
|
- userPower.EntInfo = map[int]*EntInfoStruct{}
|
|
|
- //商机管理
|
|
|
- userPower.EntName = qutil.ObjToString((*res)[0]["name"])
|
|
|
- //已购买企业未过期-商机管理用户
|
|
|
- for _, v := range *res {
|
|
|
- if qutil.IntAll(v["id"]) == 0 {
|
|
|
- continue
|
|
|
- }
|
|
|
- entId := qutil.IntAll(v["id"])
|
|
|
- userPower.EntInfo[entId] = &EntInfoStruct{
|
|
|
- IsNew: qutil.IntAll(v["isNew"]) > 0,
|
|
|
- IsPower: qutil.IntAll(v["power"]) > 0,
|
|
|
- Status: qutil.IntAll(v["status"]),
|
|
|
- Name: qutil.ObjToString(v["name"]),
|
|
|
- IsService: qutil.IntAll(v["power_source"]) > 0,
|
|
|
- RoleId: qutil.IntAll(v["role_id"]),
|
|
|
- }
|
|
|
- // 判断是否是新商机管理
|
|
|
- if qutil.IntAll(v["status"]) == 1 && qutil.IntAll(v["power"]) == 1 {
|
|
|
- userPower.EntnicheStatus = 1
|
|
|
- if qutil.IntAll(v["isNew"]) == 1 {
|
|
|
- userPower.EntIsNew = true
|
|
|
- // if userPower.EntIsNew && userPower.IsEntService {
|
|
|
- // break
|
|
|
- // }
|
|
|
- }
|
|
|
- }
|
|
|
- // 判断是否是商机管理服务 (在超级订阅或者大会员、医械通（暂无）的基础上才会有的)
|
|
|
- // if qutil.IntAll(v["power_source"]) == 1 {
|
|
|
- // userPower.IsEntService = true
|
|
|
- // break
|
|
|
- // }
|
|
|
-
|
|
|
- }
|
|
|
- }
|
|
|
- // 如果是商机管理服务用户，则不能是旧版商机管理及新版商机管理
|
|
|
- // if userPower.IsEntService {
|
|
|
- // userPower.EntnicheStatus = 0 // 商机管理状态
|
|
|
- // userPower.EntIsNew = false // 新版商机管理
|
|
|
- // }
|
|
|
- //if count := mysql.CountBySql(`SELECT count(1) FROM entniche_user u LEFT JOIN entniche_info i ON u.ent_id=i.id WHERE u.phone=? and u.power=1 and i.status=1`, phone); count > 0 {
|
|
|
- // userPower.EntnicheStatus = 1
|
|
|
- //}
|
|
|
- //广东移动DICT 用户
|
|
|
- userPower.PrivateGD = mysql.CountBySql(`select count(1) from privatedata where phone = ?`, phone) > 0
|
|
|
-
|
|
|
- //用于判断是否含有企业主体的超级订阅、大会员服务
|
|
|
- epowerData := mysql.SelectBySql(`SELECT c.product_type FROM entniche_user a INNER JOIN entniche_power b
|
|
|
- INNER JOIN entniche_wait_empower c
|
|
|
- ON a.id =b.ent_user_id AND c.id = b.wait_empower_id WHERE a.phone =? AND c.end_time >?`, phone, time.Now().Format(qutil.Date_Full_Layout))
|
|
|
- if epowerData != nil && len(*epowerData) > 0 {
|
|
|
- for _, v := range *epowerData {
|
|
|
- product_type := qutil.ObjToString(v["product_type"])
|
|
|
- if strings.Contains(product_type, "VIP订阅") {
|
|
|
- userPower.VipPowerType = 2
|
|
|
- } else if strings.Contains(product_type, "大会员") {
|
|
|
- userPower.MemberPowerType = 2
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- //子账号查询父节点权限
|
|
|
- queryId := qutil.If(userPower.Pid == "", userId, userPower.Pid).(string)
|
|
|
- //用户购买的服务
|
|
|
- serviceList := mysql.Find(BigmemberUserPowerTable, map[string]interface{}{"s_userid": queryId, "i_status": 0}, "DISTINCT(s_serviceid),i_frequency", "", -1, -1)
|
|
|
- if serviceList != nil && len(*serviceList) != 0 {
|
|
|
- pCount, eCount, dailyNum, customers := 0, 0, 0, 10
|
|
|
- for _, item := range *serviceList {
|
|
|
- serviceid := qutil.IntAll(item["s_serviceid"])
|
|
|
- userPower.PowerMap[serviceid] = true
|
|
|
- if serviceid == 14 { //项目数量
|
|
|
- pCount = qutil.IntAll(item["i_frequency"])
|
|
|
- } else if serviceid == 4 || serviceid == 12 || serviceid == 13 { //企业情报监控 企业中标动态
|
|
|
- tEcount := qutil.IntAll(item["i_frequency"])
|
|
|
- if tEcount > eCount {
|
|
|
- eCount = tEcount
|
|
|
- }
|
|
|
- } else if serviceid == 17 || serviceid == 18 { //每日数据包
|
|
|
- dailyNum = qutil.IntAll(item["i_frequency"])
|
|
|
- } else if serviceid == 7 { //潜在客户 关注客户
|
|
|
- customers = qutil.IntAll(item["i_frequency"])
|
|
|
- }
|
|
|
- }
|
|
|
- userPower.EntNum = eCount
|
|
|
- userPower.ProNum = pCount
|
|
|
- userPower.DailyNum = dailyNum
|
|
|
- userPower.Customers = customers
|
|
|
- }
|
|
|
-
|
|
|
- //存储缓存
|
|
|
- go func() {
|
|
|
- if bytes, err := json.Marshal(userPower); err == nil && bytes != nil {
|
|
|
- oneDayMore := OneDay + rand.Intn(60*60)
|
|
|
- _ = redis.PutBytes(BaseInfoCacheDb, cacheKey, &bytes, oneDayMore)
|
|
|
- }
|
|
|
- }()
|
|
|
- return &userPower
|
|
|
-}
|
|
|
-
|
|
|
-// 权限判断
|
|
|
-func (this *BigVipBaseMsg) CheckBigVipFrontPower(reqFlag string) (pass bool) {
|
|
|
- if reqFlag == "ent_portrait" || reqFlag == "unit_portrayal" { //画像页面无权限控制
|
|
|
- return true
|
|
|
- }
|
|
|
- if this.Vip_BuySet.Upgrade == 1 {
|
|
|
- if reqFlag == "ent_portrait" || reqFlag == "svip" {
|
|
|
- return true
|
|
|
- }
|
|
|
- }
|
|
|
- return this.checkPower(reqFlag, FrontService)
|
|
|
-}
|
|
|
-
|
|
|
-func (this *BigVipBaseMsg) CheckBigVipBackPower(reqFlag string) (pass bool) {
|
|
|
- return this.checkPower(reqFlag, BackService)
|
|
|
-}
|
|
|
-
|
|
|
-func (this *BigVipBaseMsg) checkPower(reqFlag string, servicesPower map[string][]int) bool {
|
|
|
- powers, ok := servicesPower[reqFlag]
|
|
|
- if !ok {
|
|
|
- return false
|
|
|
- }
|
|
|
- for _, p := range powers {
|
|
|
- if this.PowerMap[p] {
|
|
|
- return true
|
|
|
- }
|
|
|
- }
|
|
|
-
|
|
|
- return false
|
|
|
-}
|
|
|
-
|
|
|
-func (this *BigVipBaseMsg) GetUseId() string {
|
|
|
- if this.Pid != "" {
|
|
|
- return this.Pid
|
|
|
- }
|
|
|
- return this.Uid
|
|
|
-}
|
