wip:tj

userSign/userAnalysis/analysisManager.go

@@ -119,6 +119,7 @@ func (ua *UserAnalysis) LoadMapping() error {
 		fullBaseUserId         = map[BaseUserId]bool{}
 		phoneBaseUserIdMapping = map[string]BaseUserId{}
 		entIdBaseUserIdMapping = map[int64]BaseUserId{}
+		clubMap                = map[string]BaseUserId{}
 	)
 	for _, m := range data.List() {
 		var (
@@ -154,14 +155,15 @@ func (ua *UserAnalysis) LoadMapping() error {
 	ua.EntUserIdMapping = entIdBaseUserIdMapping
 
 	//加载线索
-	clueRes, err := g.DB("subjectdb").Query(ctx, "SELECT id,userid FROM dwd_f_crm_clue_info WHERE user!=''")
+	clueRes, err := g.DB("subjectdb").Query(ctx, "SELECT id,userid FROM dwd_f_crm_clue_info WHERE userid!=''")
 	if err != nil {
 		return err
 	}
 	for _, m := range clueRes.List() {
 		if value, ok := newMapping[gconv.String(m["userid"])]; ok {
-			ua.ClubMap[gconv.String(m["id"])] = value
+			clubMap[gconv.String(m["id"])] = value
 		}
 	}
+	ua.ClubMap = clubMap
 	return nil
 }

userSign/userAnalysis/jobOrderRange.go

@@ -202,5 +202,5 @@ func (hs *hasOrderClass) getAnalysisRes() []*AnalysisRes {
 		rData = append(rData, &AnalysisRes{fmt.Sprintf("近1天下单%s", s), fmt.Sprintf("%s_1_day", s), class.One, false})
 	}
 	rData = append(rData, &AnalysisRes{"近7天下单用户", "has_order_7_day", hasOrder7day, false})
-	return nil
+	return rData
 }