forked from all_user/stat_center
75 lines
1.6 KiB
Go
75 lines
1.6 KiB
Go
package service
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"stat/models/advertiseMod"
|
|
)
|
|
|
|
type InviteInfo struct {
|
|
Count int64
|
|
}
|
|
|
|
func UserStatInfo() error {
|
|
ctx := context.Background()
|
|
adsList, err := advertiseMod.FindAds(ctx)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
//fmt.Println(len(adsList))
|
|
for _, v := range adsList {
|
|
links := make([]advertiseMod.LinkInfo, 0)
|
|
links = append(links, advertiseMod.LinkInfo{
|
|
Link: v.Link,
|
|
Weight: 100,
|
|
Foreign: false,
|
|
})
|
|
doc := advertiseMod.UpdateAds{
|
|
Links: &links,
|
|
}
|
|
|
|
err = advertiseMod.UpdateAdvertise(ctx, v.Id, doc)
|
|
if err != nil {
|
|
fmt.Println(err)
|
|
}
|
|
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
// func UserStatInfo() error {
|
|
// ctx := context.Background()
|
|
// userList, err := registermod.TimeUsersStatInfoByTime(ctx, 1)
|
|
// if err != nil {
|
|
// return err
|
|
// }
|
|
// fmt.Println(len(userList))
|
|
// userIds := make([]uint64, 0)
|
|
// for _, v := range userList {
|
|
// if v.AppId == 1 {
|
|
// userIds = append(userIds, v.UserId)
|
|
// }
|
|
// }
|
|
// dspuserList, _ := model.FindManyUserInfo(ctx, userIds)
|
|
|
|
// writeModels := make([]mongo.WriteModel, 0)
|
|
// for _, v := range dspuserList {
|
|
// model := mongo.NewUpdateOneModel()
|
|
// filter := bson.M{"userId": v.UID, "appId": 1}
|
|
// update := bson.M{"$set": bson.M{"promCode": v.PromCode}}
|
|
// model.SetFilter(filter).SetUpdate(update)
|
|
|
|
// writeModels = append(writeModels, model)
|
|
// fmt.Println(filter, update)
|
|
// }
|
|
// fmt.Println("update.............")
|
|
// err = registermod.UpdateRegisterInfo(ctx, writeModels)
|
|
// if err != nil {
|
|
// log.Error("SyncUserInfo UpdateRegisterInfo", log.E(err))
|
|
// return err
|
|
// }
|
|
|
|
// return nil
|
|
// }
|