analyze/internal/service/service.go

package service

import (
	"analyze/internal/dao"
	"context"
	"github.com/gogf/gf/v2/frame/g"
	"sync"
	"time"
)

func InitUserInfo(ctx context.Context) {
	g.Log().Info(ctx, "analyze task start...", time.Now().Unix())
	AnalyzeTasks, err := dao.Offline.OfflineData()
	if err == nil {
		var (
			wg = sync.WaitGroup{}
			ac = make(chan bool, len(AnalyzeTasks))
		)
		//数据处理
		for _, analyze := range AnalyzeTasks {
			ac <- true
			wg.Add(1)
			go func(az dao.AT) {
				defer func() {
					wg.Done()
					<-ac
				}()
				az.Run()
			}(analyze)
		}
		wg.Wait()
	} else {
		g.Log().Info(ctx, "init user offline data err :", err.Error())
	}
	g.Log().Info(ctx, "analyze task end...", time.Now().Unix())
}