faet:定时任务配置项

telemarketingEtl/config.yaml

@@ -73,4 +73,15 @@ classThreeHighSeasDay: 0
 classThreeHighSeaslastDay: 30
 recycleBin_A: 5  #回收站：A.5个自然日内被销售人员手动退回公海的客户；
 recycleBin_B: 3  #回收站：B.3个自然日内有过“已接听”的通话记录且仍处于“商机线索”状态下的客户；
-
+#定时任务 查看事件
+eventInfoTask: '0 0 * * * *'
+#定时任务 搜索事件
+searchInfoTask: '0 0 * * * *'
+#定时任务 每日访问
+visitInfoTask: '0 0 * * * *'
+#定时任务
+TaskOpenSea: '0 0 0 * * *'
+#退出公海
+deleteOpenSeaTask: '0 0 0 * * *'
+#自动退回公海
+returnOpenSeaTask: '0 0 0 * * *'

telemarketingEtl/entity/dwd_f_crm_open_sea.go

@@ -461,15 +461,3 @@ func ReturnOpenSea() {
 				WHERE b.trailstatus =? AND c.next_time >?  GROUP BY  b.id`, trailstatus, nexttime)
 	}
 }
-
-/*
-01		1	商机线索
-02		1	成交客户
-03		1	待签署客户
-04		1	高意向客户
-05		1	意向客户
-06		1	潜在客户
-07		1	沉睡客户
-08		1	无意向客户
-00		1	空号停机
-*/

telemarketingEtl/entity/entity.go

@@ -10,6 +10,7 @@ const (
 	DWD_F_USERBASE_VISIT_INFO = "dwd_f_userbase_visit_info"
 
 	BUYPORTRAIT = "采购单位画像"
-	INFO        = "标讯"
+	INFO        = "标讯三级页"
 	ENTPORTRAIT = "企业画像"
+	//TODO
 )

telemarketingEtl/main.go

@@ -1,21 +1,15 @@
 package main
 
 import (
-	"log"
-	"telemarketingEtl/config"
 	_ "telemarketingEtl/config"
 	"telemarketingEtl/timetask"
 	"time"
 )
 
 func main() {
-	r, ok := config.MgoLog.Find("jy_logs", map[string]interface{}{
-		"userid": "333",
-	}, nil, `{"_id":1}`, false, 0, 1)
-	log.Println(r, ok, len(*r), r != nil)
-	return
 
-	timetask.TimeTask()
+	//定时任务开始
+	timetask.Run()
 
 	time.Sleep(999999 * time.Hour)
 }

telemarketingEtl/timetask/task.go

@@ -3,53 +3,116 @@ package timetask
 import (
 	"context"
 	_ "github.com/gogf/gf/contrib/drivers/mysql/v2"
-	"github.com/gogf/gf/v2/frame/g"
+	"github.com/gogf/gf/v2/os/gcfg"
 	"github.com/gogf/gf/v2/os/gcron"
 	"github.com/gogf/gf/v2/os/gctx"
 	"telemarketingEtl/entity"
 	"time"
 )
 
-func TimeTask() {
-	//TaskEventInfo()
-	//TaskSearchInfo()
-	TaskVisitInfo()
-	return
-	var (
-		err error
-		ctx = gctx.New()
-	)
-	_, err = gcron.Add(ctx, "1 0 0 * * *", func(ctx context.Context) {
-		g.Log().Print(ctx, "Every day")
-		//Task_clearUserLog()
-	}, "clearUserTask")
-	if err != nil {
-		panic(err)
-	}
-
-}
+//func TimeTask() {
+//	//TaskEventInfo()
+//	//TaskSearchInfo()
+//	TaskVisitInfo()
+//	return
+//	var (
+//		err error
+//		ctx = gctx.New()
+//	)
+//	_, err = gcron.Add(ctx, "1 0 0 * * *", func(ctx context.Context) {
+//		g.Log().Print(ctx, "Every day")
+//		//Task_clearUserLog()
+//	}, "clearUserTask")
+//	if err != nil {
+//		panic(err)
+//	}
+//
+//}
 
 func TaskEventInfo() {
 	now := time.Now()
 	end := now.Unix()
-	//start := now.Add(-time.Hour * 24).Unix()
-	entity.EventInfoAdd(1677657397, end)
+	start := now.Add(-time.Hour * 24).Unix()
+	//查看事件
+	entity.EventInfoAdd(start, end)
 }
 
 func TaskSearchInfo() {
 	now := time.Now()
 	end := now.Unix()
-	//start := now.Add(-time.Hour * 24).Unix()
-	entity.SearchInfoAdd(1677657397, end)
+	start := now.Add(-time.Hour * 24).Unix()
+	//搜索事件
+	entity.SearchInfoAdd(start, end)
 }
 
 func TaskVisitInfo() {
 	now := time.Now()
 	end := now.Unix()
-	//start := now.Add(-time.Hour * 24).Unix()
-	entity.VisitInfoAdd(1677657397, end)
+	start := now.Add(-time.Hour * 24).Unix()
+	entity.VisitInfoAdd(start, end)
 }
 
 func TaskOpenSea() {
 	entity.GetOpenSea()
 }
+
+// 定时任务
+func Run() {
+	timetaskBl := gcfg.Instance().MustGet(gctx.New(), "timetaskBl", "").Bool()
+	if timetaskBl {
+		var (
+			err error
+			ctx = gctx.New()
+		)
+
+		eventInfoTask := gcfg.Instance().MustGet(gctx.New(), "eventInfoTask", "").String()
+		searchInfoTask := gcfg.Instance().MustGet(gctx.New(), "searchInfoTask", "").String()
+		visitInfoTask := gcfg.Instance().MustGet(gctx.New(), "visitInfoTask", "").String()
+		openSeaTask := gcfg.Instance().MustGet(gctx.New(), "openSeaTask", "").String()
+		deleteOpenSeaTask := gcfg.Instance().MustGet(gctx.New(), "deleteOpenSeaTask", "").String()
+		returnOpenSeaTask := gcfg.Instance().MustGet(gctx.New(), "returnOpenSeaTask", "").String()
+		//
+		_, err = gcron.Add(ctx, eventInfoTask, func(ctx context.Context) {
+			TaskEventInfo()
+		}, "TaskEventInfo")
+		if err != nil {
+			panic(err)
+		}
+
+		//
+		_, err = gcron.Add(ctx, searchInfoTask, func(ctx context.Context) {
+			TaskSearchInfo()
+		}, "TaskSearchInfo")
+		if err != nil {
+			panic(err)
+		}
+		//
+		_, err = gcron.Add(ctx, visitInfoTask, func(ctx context.Context) {
+			TaskVisitInfo()
+		}, "TaskVisitInfo")
+		if err != nil {
+			panic(err)
+		}
+		//
+		_, err = gcron.Add(ctx, openSeaTask, func(ctx context.Context) {
+			TaskOpenSea()
+		}, "TaskOpenSea")
+		if err != nil {
+			panic(err)
+		}
+		//
+		_, err = gcron.Add(ctx, deleteOpenSeaTask, func(ctx context.Context) {
+			entity.DeleteOpenSea()
+		}, "DeleteOpenSea")
+		if err != nil {
+			panic(err)
+		}
+		//
+		_, err = gcron.Add(ctx, returnOpenSeaTask, func(ctx context.Context) {
+			entity.ReturnOpenSea()
+		}, "ReturnOpenSea")
+		if err != nil {
+			panic(err)
+		}
+	}
+}