删除:多余代码
git-svn-id: svn://47.119.165.148/zhub@165 e63fbceb-bcc3-4977-ac22-735b83d8d0f4
This commit is contained in:
@@ -1,17 +1,14 @@
|
|||||||
package zsub
|
package zsub
|
||||||
|
|
||||||
import (
|
import (
|
||||||
"bytes"
|
|
||||||
"database/sql"
|
"database/sql"
|
||||||
"fmt"
|
"fmt"
|
||||||
_ "github.com/go-sql-driver/mysql"
|
_ "github.com/go-sql-driver/mysql"
|
||||||
"github.com/robfig/cron"
|
"github.com/robfig/cron"
|
||||||
"log"
|
"log"
|
||||||
"os/exec"
|
|
||||||
"regexp"
|
"regexp"
|
||||||
"strconv"
|
"strconv"
|
||||||
"strings"
|
"strings"
|
||||||
"text/template"
|
|
||||||
"time"
|
"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() {
|
func (s *ZSub) ReloadTimer() {
|
||||||
db, err := sql.Open("mysql", fmt.Sprintf("%s:%s@tcp(%s)/%s?charset=utf8",
|
db, err := sql.Open("mysql", fmt.Sprintf("%s:%s@tcp(%s)/%s?charset=utf8",
|
||||||
GetStr("ztimer.db.user", "root"),
|
GetStr("ztimer.db.user", "root"),
|
||||||
|
|||||||
Reference in New Issue
Block a user