瀏覽代碼

不活跃用户处理

WH01243 1 年之前
父節點
當前提交
ac7a757e75
共有 2 個文件被更改,包括 6 次插入3 次删除
  1. 1 2
      jyBXSubscribe/rpc/internal/logic/getsublistlogic.go
  2. 5 1
      jyBXSubscribe/rpc/model/push.go

+ 1 - 2
jyBXSubscribe/rpc/internal/logic/getsublistlogic.go

@@ -107,7 +107,7 @@ func (l *GetSubListLogic) GetSubList(in *bxsubscribe.SubscribeInfosReq) (*bxsubs
 	sp := model.NewSubscribePush(in.UserType)
 	//用户信息
 	bsp := sp.GetUserInfo(spqp)
-	hasNextPage, total, list := sp.Datas(spqp)
+	hasNextPage, total, list := sp.Datas(spqp, bsp)
 	start1 := time.Now().Unix()
 	logx.Info("1、查询数据用户", start1-start)
 	/*
@@ -115,7 +115,6 @@ func (l *GetSubListLogic) GetSubList(in *bxsubscribe.SubscribeInfosReq) (*bxsubs
 	 *免费用户默认推送50条
 	 *大会员、新版商机管理、超级订阅用户 默认推送1000条记录
 	 */
-	//hasNextPage, total, list = model.NewSubscribePush(in.UserType).DefaultDatas(spqp)
 	if in.PageNum == 1 && spqp.IsEmpty() && len(list) == 0 && in.IsEnt == false {
 		hasNextPage, total, list = model.NewSubscribePush(in.UserType).DefaultDatas(spqp, bsp)
 	}

+ 5 - 1
jyBXSubscribe/rpc/model/push.go

@@ -286,10 +286,14 @@ func (s *subscribePush) InfoFormat(p *PushCa, info *map[string]interface{}, isPa
 
 }
 
-func (s *subscribePush) Datas(spqp *SubPushQueryParam) (hasNextPage bool, total int64, result []*bxsubscribe.SubscribeInfo) {
+func (s *subscribePush) Datas(spqp *SubPushQueryParam, bsp *ViewCondition) (hasNextPage bool, total int64, result []*bxsubscribe.SubscribeInfo) {
 	logx.Info(spqp.UserId, spqp.NewUserId, s.ModuleFlag, "subscribePush query param:", "SelectTime:", spqp.SelectTime, "Area:", spqp.Area, "District:", spqp.District, "City:", spqp.City, "Subtype:", spqp.Subtype, "Subscopeclass:", spqp.Subscopeclass, "Buyerclass:", spqp.Buyerclass, "Key:", spqp.Key, "PageNum:", spqp.PageNum, "Price:", spqp.Price, "FileExists:", spqp.FileExists)
 	if spqp.UserId == "" {
 		return
+	}
+	//不活跃用户处理
+	if spqp.UserType == "" && spqp.PositionType == 0 {
+
 	}
 	if spqp.PageNum < 1 {
 		spqp.PageNum = 1