IOT/SERVER/IotAdmin/app/schedule/jobs/clean-log.go

package jobs

import (
	"IotAdmin/common"
	"IotAdmin/common/jobs"
	iotLog "IotAdmin/iot/log"
	"strconv"
	"strings"
)

// CleanLog
// 新添加的job 必须按照以下格式定义，并实现Exec函数
type CleanLog struct {
}

func (t *CleanLog) Exec(job *jobs.JobCore) error {
	job.Logger.Infof("【CleanLog】 EXEC START")
	err := common.CleanSysLog()
	if err != nil {
		job.Logger.Errorf("CleanSysLog EXEC ERROR:%s", err.Error())
		return err
	}

	arr := strings.Split(job.Args, ",")
	var p1, p2, p3 int
	p1, err = strconv.Atoi(arr[0])
	if err != nil {
		job.Logger.Errorf("CleanLog P1:%s EXEC ERROR:%s", arr[0], err.Error())
		return err
	}
	p2 = p1
	p3 = p1
	if len(arr) > 2 {
		p2, err = strconv.Atoi(arr[1])
		if err != nil {
			job.Logger.Errorf("CleanLog P2:%s EXEC ERROR:%s", arr[1], err.Error())
			return err
		}
		p3, err = strconv.Atoi(arr[2])
		if err != nil {
			job.Logger.Errorf("CleanLog P3:%s EXEC ERROR:%s", arr[2], err.Error())
			return err
		}
	} else if len(arr) > 1 {
		p2, err = strconv.Atoi(arr[1])
		if err != nil {
			job.Logger.Errorf("CleanLog P2:%s EXEC ERROR:%s", arr[1], err.Error())
			return err
		}
	}
	err = iotLog.Clean(p1, p2)
	if err != nil {
		job.Logger.Errorf("CleanLog EXEC ERROR:%s", err.Error())
		return err
	}
	err = jobs.CleanJobLog(p3)
	if err != nil {
		job.Logger.Errorf("CleanJobLog EXEC ERROR:%s", err.Error())
		return err
	}
	job.Logger.Infof("【CleanLog】 EXEC END\r\n")

	return nil
}

func (t *CleanLog) GetName() string {
	return "清理日志"
}