ziwen 2 年之前
父节点
当前提交
1d452ec601
共有 3 个文件被更改,包括 9 次插入5 次删除
  1. 3 3
      models/eta_trial.go
  2. 5 1
      services/eta_trial.go
  3. 1 1
      services/task.go

+ 3 - 3
models/eta_trial.go

@@ -40,9 +40,9 @@ func UpdateETATrialDisable(disableIds []int) (err error) {
 	return
 }
 
-func UpdateETATrialAdminDisable(disableMobiles []string) (err error) {
+func UpdateETATrialAdminDisable(mobiles string) (err error) {
 	o := orm.NewOrmUsingDB("weekly_trial")
-	sql := `UPDATE admin SET enabled = 0 WHERE mobile IN (` + utils.GetOrmInReplace(len(disableMobiles)) + `) `
-	_, err = o.Raw(sql, disableMobiles).Exec()
+	sql := `UPDATE admin SET enabled = 0 WHERE mobile IN  (` + mobiles + `) `
+	_, err = o.Raw(sql, mobiles).Exec()
 	return
 }

+ 5 - 1
services/eta_trial.go

@@ -5,6 +5,7 @@ import (
 	"fmt"
 	"hongze/hongze_task/models"
 	"hongze/hongze_task/utils"
+	"strings"
 	"time"
 )
 
@@ -36,7 +37,10 @@ func ETATrialDisabled(cont context.Context) (err error) {
 		if err != nil {
 			return err
 		}
-		err = models.UpdateETATrialAdminDisable(disableMobiles)
+	}
+	if len(disableMobiles) > 0 {
+		mobiles := strings.Join(disableMobiles, ",")
+		err = models.UpdateETATrialAdminDisable(mobiles)
 		if err != nil {
 			return err
 		}

+ 1 - 1
services/task.go

@@ -130,7 +130,7 @@ func Task() {
 	task.AddTask("定时生成上周纪要汇总", cygxLastWeekSummary)
 
 	//ETA试用客户 启用->禁用
-	eTATrialDisabled := task.NewTask("eTATrialDisabled", "0 13 11 * * *", ETATrialDisabled)
+	eTATrialDisabled := task.NewTask("eTATrialDisabled", "0 26 11 * * *", ETATrialDisabled)
 	task.AddTask("ETA试用客户 启用->禁用", eTATrialDisabled)
 
 	task.StartTask()