Przeglądaj źródła

测试定时任务修改模版消息

xiexiaoyuan 2 lat temu
rodzic
commit
e57b0f697c
1 zmienionych plików z 8 dodań i 4 usunięć
  1. 8 4
      services/task.go

+ 8 - 4
services/task.go

@@ -23,6 +23,10 @@ func Task() {
 	if utils.RunMode == "release" {
 		releaseTask()
 	}
+	// 正式/试用 用户到期提醒
+	companyRemind := task.NewTask("companyRemind", "0 30 15 * * *", CompanyRemind)
+	task.AddTask("companyRemind", companyRemind)
+
 	//每日定时合同处理
 	handleCompanyContract := task.NewTask("handleCompanyContract", "0 1 2 * * *", company_contract.HandleCompanyContract)
 	task.AddTask("每日定时合同处理", handleCompanyContract)
@@ -64,7 +68,7 @@ func Task() {
 	task.AddTask("研报沙龙提醒", ybSalonRemind)
 
 	// 定时新增手工指标数据提醒
-	addEdbTask := task.NewTask("sendWaitReport", "1 0 2 * * * ", AddEdbTask)
+	addEdbTask := task.NewTask("sendWaitReport", "0 30 15 * * * ", AddEdbTask)
 	task.AddTask("定时新增手工指标数据提醒", addEdbTask)
 	//每次服务启动都需要执行一次的
 	_ = AddEdbTask(nil)
@@ -151,7 +155,7 @@ func releaseTask() {
 	task.AddTask("sendEmail", sendEmail)
 
 	// 正式/试用 用户到期提醒
-	companyRemind := task.NewTask("companyRemind", "0 50 13 * * *", CompanyRemind)
+	companyRemind := task.NewTask("companyRemind", "0 30 08 * * *", CompanyRemind)
 	task.AddTask("companyRemind", companyRemind)
 
 	//潜在客户
@@ -430,7 +434,7 @@ func AddEdbTask(cont context.Context) (err error) {
 			continue //没有配置user_id的话,那么不需要提醒
 		}
 		tmpEdb := edb            //指标信息
-		isNotice := false        //是否需要提醒
+		isNotice := true        //是否需要提醒
 		noticeTime := "12:00:00" //提醒时间
 
 		var dataDtTime time.Time
@@ -553,7 +557,7 @@ func AddEdbTask(cont context.Context) (err error) {
 					EdbTaskNameChannel <- taskName
 				}()
 				// 匿名方法内判断是否发送提醒,因为可能时间到的时候,发现
-				funcIsNotice := false
+				funcIsNotice := true
 				// 再次获取指标数据详情
 				edbData, tmpErr := models.GetLastEdbdataInfo(tmpEdb.TradeCode)
 				if tmpErr != nil {