소스 검색

wip:提交

wangkaiyue 1 년 전
부모
커밋
a447641b86
4개의 변경된 파일5개의 추가작업 그리고 5개의 파일을 삭제
  1. 1 1
      doFreeClueSign/config.yaml
  2. 2 2
      doFreeClueSign/job/mamager.go
  3. 1 1
      doFreeClueSign/public/getPayUser.go
  4. 1 1
      doFreeClueSign/runSign.json

+ 1 - 1
doFreeClueSign/config.yaml

@@ -34,5 +34,5 @@ database:
     debug: true
 
 cron:
-  activityUser: " */10 * * * * *" #更新新活跃用户
+  activityUser: "*/10 * * * * *" #更新新活跃用户
   bindPhoneAndSubAgain: "*/10 * * * * *" #再次关注&绑定手机号用户

+ 2 - 2
doFreeClueSign/job/mamager.go

@@ -38,7 +38,8 @@ func InitJobManager() *JobManager {
 	)
 
 	job := &JobManager{
-		payUser: gmap.New(true),
+		payUser:  gmap.New(true),
+		register: gmap.New(true),
 	}
 	job.LoadLastRun()
 
@@ -116,7 +117,6 @@ func (jm *JobManager) LoadPayUser() {
 		newMap.Set(i, v)
 	}
 	jm.payUser = newMap
-	g.Dump(newMap)
 }
 
 func (jm *JobManager) FilterPayUserAndSaveDb(ctx context.Context, value interface{}) error {

+ 1 - 1
doFreeClueSign/public/getPayUser.go

@@ -15,7 +15,7 @@ func GetPayUser() map[string]bool {
 	res, err := g.DB("subjectdb").Query(ctx, `SELECT id,userid FROM dwd_f_data_equity_info WHERE endtime>?`, time.Now().Format(time.DateTime))
 	if err == nil && !res.IsEmpty() {
 		for _, m := range res.List() {
-			pay[gconv.String(m["user_id"])] = true
+			pay[gconv.String(m["userid"])] = true
 		}
 	}
 	return pay

+ 1 - 1
doFreeClueSign/runSign.json

@@ -1 +1 @@
-{"bindPhone":"2024-07-24 00:00:00","againSub":"2024-07-24 00:00:00","newActivity":"2024-07-24 00:00:00"}
+{"bindPhone":"2024-07-26 15:15:11","againSub":"2024-07-26 15:15:11","newActivity":"2024-07-26 15:15:11"}