From 1ae812cd9214be7aa9f00c2ed8e671776ec74c52 Mon Sep 17 00:00:00 2001 From: lxy <237809796@qq.com> Date: Thu, 18 May 2023 11:34:56 +0000 Subject: [PATCH] =?UTF-8?q?=E5=88=A0=E9=99=A4=EF=BC=9A=E5=A4=9A=E4=BD=99?= =?UTF-8?q?=E4=BB=A3=E7=A0=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit git-svn-id: svn://47.119.165.148/zhub@165 e63fbceb-bcc3-4977-ac22-735b83d8d0f4 --- zsub/ztimer.go | 68 -------------------------------------------------- 1 file changed, 68 deletions(-) diff --git a/zsub/ztimer.go b/zsub/ztimer.go index 00e79c1..116bc34 100644 --- a/zsub/ztimer.go +++ b/zsub/ztimer.go @@ -1,17 +1,14 @@ package zsub import ( - "bytes" "database/sql" "fmt" _ "github.com/go-sql-driver/mysql" "github.com/robfig/cron" "log" - "os/exec" "regexp" "strconv" "strings" - "text/template" "time" ) @@ -100,71 +97,6 @@ func (s *ZSub) timer(rcmd []string, c *ZConn) { } } -/*func (t *ZTimer) close(c *ZConn) { - for i, item := range t.conns { - if item.conn == c.conn { - t.conns = append(t.conns[:i], t.conns[i+1:]...) - } - } -}*/ - -func (t *ZTimer) configSave() { - tpl, err := template.New("").Parse(` - if [ ! -d "/etc/zhub" ]; then - mkdir /etc/zhub - fi - if [ ! -f "/etc/zhub/ztimer.cron" ]; then - touch /etc/zhub/ztimer.cron - fi - - sed -i /^{{.Name}}\|*/d /etc/zhub/ztimer.cron - echo '{{.Name}}|{{.Expr}}|{{.Single}}' >> /etc/zhub/ztimer.cron - `) - - if err != nil { - log.Println(err) - } - - var buf bytes.Buffer - err = tpl.Execute(&buf, map[string]string{ - "Name": t.topic, - "Expr": t.expr, - "Single": func() string { - if t.single { - return "a" - } else { - return "x" - } - }(), - }) - if err != nil { - log.Println(err) - } - - //fmt.Println(buf.String()) - - rest, err, s := executeShell(buf.String()) - if err != nil { - log.Println(err) - } - if !strings.EqualFold(rest, "") { - fmt.Println("res:", rest) - } - if !strings.EqualFold(s, "") { - fmt.Println("error-rest:", s) - } -} - -func executeShell(command string) (string, error, string) { - var stdout bytes.Buffer - var stderr bytes.Buffer - cmd := exec.Command("/bin/bash", "-c", command) - cmd.Stdout = &stdout - cmd.Stderr = &stderr - err := cmd.Run() - return stdout.String(), err, stderr.String() -} - func (s *ZSub) ReloadTimer() { db, err := sql.Open("mysql", fmt.Sprintf("%s:%s@tcp(%s)/%s?charset=utf8", GetStr("ztimer.db.user", "root"),