test
This commit is contained in:
parent
13455391ac
commit
0ef91c7361
12
bot.go
12
bot.go
@ -69,6 +69,10 @@ func botText(m *tb.Message) {
|
||||
}
|
||||
|
||||
func botMsgRescan(m *tb.Message) (string, error) {
|
||||
var (
|
||||
p JobPayloadRescanMsg
|
||||
q string
|
||||
)
|
||||
fmt.Println("botRescanMsg :", m.Text)
|
||||
if !m.Private() {
|
||||
fmt.Println("botRescanMsg : !m.Private()")
|
||||
@ -76,8 +80,8 @@ func botMsgRescan(m *tb.Message) (string, error) {
|
||||
}
|
||||
r := regexp.MustCompile("^[0-9]+$")
|
||||
if r.MatchString(m.Payload) {
|
||||
var p JobPayloadRescanMsg
|
||||
fmt.Sprintf(p.Query, "SELECT o.id from obj o where o.id = %s and o.obj_type_id = %d and o.obj_sub_type_id = %d;", m.Payload, objTypeMessage, objSubTypeMessageUnknown)
|
||||
fmt.Sprintf(s, "SELECT o.id from obj o where o.id = %s and o.obj_type_id = %d and o.obj_sub_type_id = %d;", m.Payload, objTypeMessage, objSubTypeMessageUnknown)
|
||||
p.Query = s
|
||||
b, _ := json.Marshal(p)
|
||||
log.Printf("botMsgRescan : %s\n", string(b))
|
||||
err := createJob(objSubTypeJobRescanMsg, objJobPriorityRescanMsg, time.Now(), b)
|
||||
@ -91,8 +95,8 @@ func botMsgRescan(m *tb.Message) (string, error) {
|
||||
}
|
||||
r = regexp.MustCompile("^all$")
|
||||
if r.MatchString(m.Payload) {
|
||||
var p JobPayloadRescanMsg
|
||||
fmt.Sprintf(p.Query, "SELECT o.id from obj o where o.obj_type_id = %d and o.obj_sub_type_id = %d;", objTypeMessage, objSubTypeMessageUnknown)
|
||||
fmt.Sprintf(s, "SELECT o.id from obj o where o.obj_type_id = %d and o.obj_sub_type_id = %d;", objTypeMessage, objSubTypeMessageUnknown)
|
||||
p.Query = s
|
||||
b, _ := json.Marshal(p)
|
||||
log.Printf("botMsgRescan : %s\n", string(b))
|
||||
err := createJob(objSubTypeJobRescanMsg, objJobPriorityRescanAllMsg, time.Now(), b)
|
||||
|
Loading…
Reference in New Issue
Block a user