上限处理

clueSync/db.json

@@ -12,7 +12,7 @@
   "tiDb": {
     "host": "192.168.3.149",
     "port": 4000,
-    "database": "jianyu_subjectdb",
+    "database": "jianyu_subjectdb_test",
     "user": "datagroup",
     "password": "Dgrpdb#2024@36",
     "poolsize": 20,

clueSync/main.go

@@ -6,8 +6,10 @@ import (
 	"app.yhyue.com/moapp/jybase/mongodb"
 	"app.yhyue.com/moapp/jybase/mysql"
 	"app.yhyue.com/moapp/jybase/redis"
+	"bp.jydev.jianyu360.cn/BaseService/pushpkg/p"
 	"flag"
 	"fmt"
+	"github.com/robfig/cron"
 	"log"
 )
 
@@ -127,7 +129,7 @@ func main() {
 	InitProduct(db.ProductArr)
 	tagAllSync()
 	//activeUsers() //取关重新关注处理
-	/*if *mode == 1 {
+	if *mode == 1 {
 		//30分钟一次
 		go p.VarTimeTask.RunInTimeLoop("30分钟定时任务", "", "", db.CornExp1, true, true, nil, func() {
 			orders()      //未支付订单
@@ -207,5 +209,5 @@ func main() {
 	} else {
 		users()
 		saleLeads()
-	}*/
+	}
 }