jyMicroservices/jyBXBase/rpc/internal/logic/newestbiddinglogic.go

package logic

import (
	"context"
	"encoding/json"
	"fmt"
	IC "jyBXBase/rpc/init"
	"jyBXBase/rpc/model"
	"log"
	"sort"
	"strings"
	"time"

	MC "app.yhyue.com/moapp/jybase/common"
	"app.yhyue.com/moapp/jybase/redis"

	"jyBXBase/rpc/internal/svc"
	"jyBXBase/rpc/type/bxbase"

	"github.com/zeromicro/go-zero/core/logx"
)

type NewestBiddingLogic struct {
	ctx    context.Context
	svcCtx *svc.ServiceContext
	logx.Logger
}

func NewNewestBiddingLogic(ctx context.Context, svcCtx *svc.ServiceContext) *NewestBiddingLogic {
	return &NewestBiddingLogic{
		ctx:    ctx,
		svcCtx: svcCtx,
		Logger: logx.WithContext(ctx),
	}
}

// 首页最新招标信息
func (l *NewestBiddingLogic) NewestBidding(in *bxbase.NewestBiddingReq) (*bxbase.NewsetBiddingResp, error) {
	t := time.Now()
	userType := ""
	r := func(in *bxbase.NewestBiddingReq) *bxbase.NewsetBiddingResp {
		var res = &bxbase.NewsetBiddingResp{
			Data: &bxbase.NewsetBidding{
				List: []*bxbase.NewestList{},
			},
		}
		if in.UserId == "" {
			var result []*bxbase.NewestList
			res.Data.IsVip = false
			res.Data.HasSubKeys = false
			notLoggedPush := fmt.Sprintf("p1_indexMessage_new_%d_%d_%d", time.Now().Year(), time.Now().Minute(), time.Now().Day())
			redisByte, err := redis.GetBytes("other", notLoggedPush)
			if err == nil && redisByte != nil && len(*redisByte) > 0 {
				err = json.Unmarshal(*redisByte, &result)
				if err == nil {
					res.Data.Count = int64(len(result))
					res.Data.List = result
					return res
				}
				log.Println(fmt.Sprintf("未登录用户每日数据获取缓存 序列化异常,err:%s", err.Error()))
			}
			query := model.NewestQuery("", "")
			result = model.NewestES(query)
			b, err1 := json.Marshal(result)
			if err1 == nil {
				err = redis.PutBytes("other", notLoggedPush, &b, 60*60*24)
				if err != nil {
					log.Println(fmt.Sprintf("未登录用户每日数据存入缓存 序列化异常,err:%s", err.Error()))
				}
			}
			res.Data.Count = int64(len(result))
			res.Data.List = result
			return res
		}
		//主体处理(fType：普通用户；vType：超级订阅用户；mType：大会员用户；eType：商机管理用户)
		infoCount := IC.MainMysql.CountBySql("select  count(id) from  entniche_wait_empower where  ent_id=? and  end_time>NOW() and (product_type like '%VIP订阅%' or product_type like '%大会员%') ", in.EntId)
		if infoCount > 0 {
			//主体等于企业的
			userType = "e"
		}
		rks := ""
		if userType == "e" {
			rks = MC.If(in.UserId != "", MC.InterfaceToStr(in.EntUserId), in.City).(string)
		} else {
			rks = MC.If(in.UserId != "", in.UserId, in.City).(string)
		}
		redisByte, err := redis.GetBytes("other", "p1_indexMessage_new_"+rks)
		if err == nil && redisByte != nil && len(*redisByte) > 0 {
			err = json.Unmarshal(*redisByte, res.Data)
			if err != nil {
				res.ErrCode = -1
				res.ErrMsg = fmt.Sprintf("读取缓存 序列化异常,err:%s", err.Error())
			}
			return res
		}
		//登录用户
		if in.UserId != "" {
			//优先级 由测试确认  大会员 》 商机管理 》 VIP 》 普通用户 》 搜索历史
			//获取订阅信息
			userMap, ok := IC.Mgo.FindById("user", in.UserId, `{"o_jy":1,"o_vipjy":1,"i_vip_status":1,"o_member_jy":1,"i_member_status":1,"s_m_phone":1,"s_phone":1}`)
			if !ok || userMap == nil || len(*userMap) == 0 {
				//查询出错
				res.ErrCode = -1
				res.ErrMsg = fmt.Errorf("未查询到用户信息").Error()
				return res
			}
			//var isPayUser bool = false
			//付费用户如果没有数据 直接返回 需求来源：测试
			//vip用户
			vipStatus := MC.IntAll((*userMap)["i_vip_status"])
			//大会员用户
			bigStatus := MC.Int64All((*userMap)["i_member_status"])
			if bigStatus > 0 {
				o_msgset := MC.ObjToMap((*userMap)["o_member_jy"])
				big_items, ok := (*o_msgset)["a_items"].([]interface{})
				//大会员推送历史
				result := []*bxbase.NewestList{}
				if userType == "e" {
					result = model.GetNewestInfo(rks, "e", MC.Int64All(in.EntUserId)).GetPushHistory()
				} else {
					result = model.GetNewestInfo(rks, "m", in.NewUserId).GetPushHistory()
				}
				res.Data.Count = int64(len(result))
				if res.Data.Count > 0 {
					res.Data.HasSubKeys = ok && len(big_items) > 0
					res.Data.List = result
					res.Data.SubFlag = "m"
				}
				return res
			}
			if phone := MC.If((*userMap)["s_phone"] != nil, MC.ObjToString((*userMap)["s_phone"]), MC.ObjToString((*userMap)["s_m_phone"])).(string); phone != "" && in.EntUserId != "" && in.EntId != "" {
				//商机管理
				entNicheInfos := IC.MainMysql.SelectBySql(`SELECT i.power_source,u.power FROM entniche_user u LEFT JOIN entniche_info i ON u.ent_id=i.id WHERE u.phone=? and  i.status=1 AND i.id = ?`, phone, in.EntId)
				if entNicheInfos != nil && len(*entNicheInfos) > 0 {
					entNicheInfo := (*entNicheInfos)[0]
					//排除商机管理服务
					if MC.IntAll(entNicheInfo["power_source"]) != 1 {
						// 已分发权限
						if MC.IntAll(entNicheInfo["power"]) > 0 {
							//商机管理推送历史
							result := model.GetNewestInfo(in.EntUserId, "e", MC.Int64All(in.EntUserId)).GetPushHistory()
							res.Data.Count = int64(len(result))
							if res.Data.Count > 0 {
								res.Data.List = result
								res.Data.SubFlag = "e"
							}
							return res
						}
					}
				}
			}
			if vipStatus > 0 {
				o_msgset := MC.ObjToMap((*userMap)["o_vipjy"])
				vip_items, ok := (*o_msgset)["a_items"].([]interface{})
				//vip查询推送历史
				result := []*bxbase.NewestList{}
				if userType == "e" {
					result = model.GetNewestInfo(rks, "e", MC.Int64All(in.EntUserId)).GetPushHistory()
				} else {
					result = model.GetNewestInfo(rks, "v", in.NewUserId).GetPushHistory()
				}
				res.Data.IsVip = true
				res.Data.HasSubKeys = ok && len(vip_items) > 0
				res.Data.Count = int64(len(result))
				res.Data.List = result
				res.Data.SubFlag = "v"
				return res
			}

			//普通用户用户- 有关键词
			o_msgset := MC.ObjToMap((*userMap)["o_jy"])
			items, ok := (*o_msgset)["a_key"].([]interface{})
			if ok && len(items) > 0 {
				//普通用户查询推送历史
				result := model.GetNewestInfo(rks, "f", in.NewUserId).GetPushHistory()
				res.Data.IsVip = false
				res.Data.HasSubKeys = ok && len(items) > 0
				res.Data.Count = int64(len(result))
				res.Data.List = result
				res.Data.SubFlag = "f"
				return res
			}
			//搜索历史-关键词
			hKeys := redis.GetStr("other", fmt.Sprintf("s_%s", in.UserId))
			if hKeys != "" && len(strings.Split(hKeys, ",")) > 0 {
				//历史搜索
				res.Data.History = strings.Split(hKeys, ",")
				//根据订阅词获取查询语句
				query := model.NewestQuery("", hKeys)
				result := model.NewestES(query)
				res.Data.IsVip = false
				res.Data.HasSubKeys = false
				res.Data.Count = int64(len(result))
				res.Data.List = result
				return res
			}
		}
		if in.IsSearch == 2 { //定位查询（默认全国）
			query := model.NewestQuery(rks, "")
			result := model.NewestES(query)
			res.Data.IsVip = false
			res.Data.HasSubKeys = false
			res.Data.Count = int64(len(result))
			res.Data.List = result
			return res
		}
		return res
	}(in)
	if r.Data.Count > 0 {
		//排序
		sort.Slice(r.Data.List, func(i, j int) bool {
			return r.Data.List[i].PublishTime > r.Data.List[j].PublishTime
		})
		//
		rks := ""
		if userType == "e" {
			rks = MC.If(in.UserId != "", MC.InterfaceToStr(in.EntUserId), in.City).(string)
		} else {
			rks = MC.If(in.UserId != "", in.UserId, in.City).(string)
		}
		//rks := MC.If(in.UserId != "", in.UserId, in.City).(string)
		b, err := json.Marshal(r.Data)
		if err != nil {
			r.ErrCode = -1
			r.ErrMsg = fmt.Sprintf("保存缓存 序列化异常,err:%s", err.Error())
		} else {
			if err = redis.PutBytes("other", "p1_indexMessage_new_"+rks, &b, 2*60*60); err != nil {
				r.ErrCode = -1
				r.ErrMsg = fmt.Sprintf("保存缓存 redis 异常,err:%s", err.Error())
			}

		}
	}
	model.MakeCollection(in.UserId, r.Data.List)
	log.Println("接口耗时：", time.Since(t).Seconds())
	return r, nil
}