feat: 更新记录字段调整

telemarketingEtl/entity/dwd_f_crm_open_sea.go

@@ -439,7 +439,7 @@ func ReturnOpenSea() {
 				WHERE b.trailstatus =?`
 		argsSelect := []interface{}{trailstatus}
 		if trailstatus != "00" {
-			sql += " AND c.next_time >? "
+			sql += " AND c.createtime <? "
 			argsSelect = append(argsSelect, nexttime)
 		}
 		sql += " GROUP BY  b.id"

telemarketingEtl/timetask/task.go

@@ -12,12 +12,26 @@ import (
 	"github.com/gogf/gf/v2/os/gctx"
 )
 
+/*
+#查看
+eventInfoTime: 5
+#搜索
+searchInfoTime: 5
+#每日
+visitInfoTime: 5
+#定时
+openSeaTime: 5
+#退出
+deleteOpenSeaTime: 5
+#自动退出
+returnOpenSeaTime: 5
+*/
 func TaskEventInfo() {
 	log.Println("开始TaskEventInfo")
 	now := time.Now()
 	end := now.Unix()
-	// start := now.Add(-time.Hour * 1).Unix()
-	start := now.Add(-time.Minute * 5).Unix()
+	min := gcfg.Instance().MustGet(gctx.New(), "eventInfoTime", "").Int()
+	start := now.Add(-time.Minute * time.Duration(min)).Unix()
 	//查看事件
 	entity.EventInfoAdd(start, end)
 	log.Println("结束TaskEventInfo")
@@ -27,8 +41,8 @@ func TaskSearchInfo() {
 	log.Println("开始TaskSearchInfo")
 	now := time.Now()
 	end := now.Unix()
-	// start := now.Add(-time.Hour * 1).Unix()
-	start := now.Add(-time.Minute * 5).Unix()
+	min := gcfg.Instance().MustGet(gctx.New(), "searchInfoTime", "").Int()
+	start := now.Add(-time.Minute * time.Duration(min)).Unix()
 	//搜索事件
 	entity.SearchInfoAdd(start, end)
 }
@@ -37,8 +51,8 @@ func TaskVisitInfo() {
 	log.Println("开始TaskVisitInfo")
 	now := time.Now()
 	end := now.Unix()
-	// start := now.Add(-time.Hour * 1).Unix()
-	start := now.Add(-time.Minute * 5).Unix()
+	min := gcfg.Instance().MustGet(gctx.New(), "visitInfoTime", "").Int()
+	start := now.Add(-time.Minute * time.Duration(min)).Unix()
 	entity.VisitInfoAdd(start, end)
 	log.Println("结束TaskVisitInfo")
 }