Merge branch 'hotfix/auto_disable_admin' of eta_forum/eta_forum_task into master

services/eta_forum/eta_forum_hub_lib.go

@@ -30,6 +30,16 @@ func AdminBatchSaveLib(req string) (resp *models.BaseResponse, err error) {
 	return
 }
 
+// ETA 试用客户禁用
+func ETATrialDisabled() (resp *models.BaseResponse, err error) {
+	_, resultByte, err := post("", "/v1/eta_trial/admin/auto_disable")
+	err = json.Unmarshal(resultByte, &resp)
+	if err != nil {
+		return
+	}
+	return
+}
+
 func PostLib(urlStr, req string) (resp *models.BaseResponse, err error) {
 	_, resultByte, err := post(req, urlStr)
 	err = json.Unmarshal(resultByte, &resp)

services/eta_trial.go

@@ -0,0 +1,28 @@
+package services
+
+import (
+	"context"
+	"eta/eta_forum_task/services/alarm_msg"
+	"eta/eta_forum_task/services/eta_forum"
+	"eta/eta_forum_task/utils"
+	"fmt"
+	"time"
+)
+
+func ETATrialDisabled(cont context.Context) (err error) {
+	defer func() {
+		if err != nil {
+			go alarm_msg.SendAlarmMsg(utils.APP_NAME_CN+"自动禁用ETA试用客户失败"+time.Now().Format("2006-01-02 15:04:05")+"<br/>"+err.Error(), 3)
+		}
+	}()
+	respItem, err := eta_forum.ETATrialDisabled()
+	if err != nil {
+		err = fmt.Errorf("自动禁用ETA试用客户失败,Err:" + err.Error())
+		return
+	}
+	if respItem.Ret != 200 {
+		err = fmt.Errorf("自动禁用ETA试用客户失败,Err:%v,errMsg:%v", respItem.Msg, respItem.ErrMsg)
+		return
+	}
+	return
+}

services/task.go

@@ -19,11 +19,12 @@ func Task() {
 	// 每隔1小时，定时更新管理员数据到eta社区
 	etaForumAdminUpdate := task.NewTask("etaForumAdminUpdate", "0 0 */1 * * *", AdminBatchSaveTask)
 	task.AddTask("定时更新管理员数据到eta社区", etaForumAdminUpdate)
-
 	task.StartTask()
 	fmt.Println("task end")
 }
 
 func releaseTask() {
-
+	//ETA试用客户 启用->禁用
+	eTATrialDisabled := task.NewTask("eTATrialDisabled", "0 15 2 * * *", ETATrialDisabled)
+	task.AddTask("ETA试用客户 启用->禁用", eTATrialDisabled)
 }