jyMicroservices/jyBXBuyer/rpc/internal/logic/buyerlistlogic.go

package logic

import (
	"app.yhyue.com/moapp/jybase/redis"
	"context"
	"encoding/json"
	"fmt"
	"github.com/zeromicro/go-zero/core/logx"
	IC "jyBXBuyer/rpc/init"
	"jyBXBuyer/rpc/internal/svc"
	"jyBXBuyer/rpc/model"
	"jyBXBuyer/rpc/type/bxbuyer"
)

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

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

// 采购单位搜索
func (l *BuyerListLogic) BuyerList(in *bxbuyer.BuyerListReq) (*bxbuyer.BuyerListResp, error) {
	logx.Info("----:", model.CheckEmpty(in))
	resp := &bxbuyer.BuyerListResp{
		Data: &bxbuyer.BuyerData{},
	}
	// 采购单位搜索过来的 最多查100条
	if in.PageSize*in.PageNum > IC.C.BuyerSearchLimit {
		in.PageNum = IC.C.BuyerSearchLimit / in.PageSize
	}
	if in.PageNum < 1 {
		in.PageNum = 1
	}
	if in.PageSize < 1 || in.PageSize > IC.C.BuyerSearchLimit {
		in.PageSize = IC.C.BuyerSearchLimit / in.PageNum
	}
	query, CountQuery := "", ""
	buyerNames := []string{}
	if model.CheckEmpty(in) {
		var isBool = true
		list := []*bxbuyer.BuyerList{} //100条数据
		bs, err := redis.GetBytes("other", fmt.Sprintf(model.P_redis_key))
		if err == nil && bs != nil && len(*bs) > 0 {
			isBool = false
			if err := json.Unmarshal(*bs, &list); err != nil {
				isBool = true
				logx.Info("获取redis缓存，序列化异常")
			} else {
				if len(list) > 0 {
					// 根据页码返回数据
					start := in.PageSize * (in.PageNum - 1)
					end := in.PageSize * in.PageNum
					count := len(list)
					resp.Data.Count = int64(count)
					if end > int64(len(list)-1) {
						end = int64(len(list) - 1)
					}
					resp.Data.List = list[start:end]
					for i := 0; i < len(resp.Data.List); i++ {
						buyerNames = append(buyerNames, resp.Data.List[i].Buyer)
					}
				} else {
					isBool = true
				}
			}
		}
		if isBool {
			/*
				空搜索
				1. 聚合出来200条采购单位数据  项目数量 采购单位规模 可以直接一块出来
				2. 查采购单位库确认100条数据有效
				3. 存一周缓存
			*/
			query = model.BuyerListRedisCacheQuery(in.PageNum, in.PageSize)
			buyerNames, resp = model.BuyerListRedisCache(query, in)

		}
	} else {
		query, CountQuery = model.BuyerListQuery(in)
		logx.Info("query:", query)
		buyerNames, resp = model.GetBuyerList(query, CountQuery, false) // 查询数据
	}
	if len(resp.Data.List) > 0 && (in.UserId != "" || in.EntUserId != "") {
		model.SupplyFollowInfo(in, buyerNames, resp)
	}
	if resp.Data.Count > IC.C.BuyerSearchLimit {
		resp.Data.Count = IC.C.BuyerSearchLimit
	}
	return resp, nil
}