xg

doFreeClueSign/config.yaml

@@ -1,4 +1,4 @@
-lastId: 0
+lastId: 258768
 mongodb:
   default: #qfw
     address: "192.168.3.149:27180"
@@ -40,4 +40,4 @@ database:
 cron:
   activityUser: "*/10 * * * * *" #更新新活跃用户
   bindPhoneAndSubAgain: "*/10 * * * * *" #再次关注&绑定手机号用户
-  newRegisterAndBind: "*/10 * * * * *" #邀请&被邀请注册&新注册
+  newRegisterAndBind: "*/3 * * * * *" #邀请&被邀请注册&新注册

doFreeClueSign/job/job.go

@@ -148,10 +148,10 @@ func verifyDate(v int64) bool {
 // @Date 2024/11/19
 func LoadOrderHis() {
 	var (
-		sql = `SELECT id, filter, order_code, product_type, user_id, user_phone, vip_starttime, vip_endtime FROM jianyu.dataexport_order WHERE id < 258763 AND ORDER BY id DESC`
+		sql = `SELECT id, filter, order_code, product_type, user_id, user_phone, vip_starttime, vip_endtime FROM jianyu.dataexport_order WHERE id <= ? AND ORDER BY id DESC`
 	)
 
-	res, err := g.DB("jianyu").Query(ctx, sql)
+	res, err := g.DB("jianyu").Query(ctx, sql, LastId)
 	if err == nil && !res.IsEmpty() {
 		for _, m := range res.List() {
 			id := gconv.Int(m["id"])

doFreeClueSign/main.go

@@ -6,8 +6,8 @@ import (
 )
 
 func main() {
-	//job.InitJobManager()
+	go job.LoadOrderHis()
+	job.InitJobManager()
 
-	job.LoadOrderHis()
 	select {}
 }