From 2e1b8131aa5102eb1c90cb5b3b6abea55ae99538 Mon Sep 17 00:00:00 2001 From: cdle <798731886@qq.com> Date: Mon, 11 Oct 2021 17:34:04 +0800 Subject: [PATCH] update --- core/function.go | 3 ++- core/im.go | 4 ++-- 2 files changed, 4 insertions(+), 3 deletions(-) diff --git a/core/function.go b/core/function.go index 08b116e..4ee0430 100644 --- a/core/function.go +++ b/core/function.go @@ -82,9 +82,10 @@ func handleMessage(sender Sender) { defer sender.Finish() key := fmt.Sprintf("u=%v&c=%v&i=%v", sender.GetUserID(), sender.GetChatID(), sender.GetImType()) fmt.Println(key) + fmt.Println(waits.Load(key)) if v, ok := waits.Load(key); ok { c := v.(Carry) - fmt.Println(c, "-----") + if m := regexp.MustCompile(c.Pattern).FindString(sender.GetContent()); m != "" { c.Chan <- m sender.Reply(<-c.Result) diff --git a/core/im.go b/core/im.go index d8517c2..947425a 100644 --- a/core/im.go +++ b/core/im.go @@ -245,10 +245,10 @@ func (sender *BaseSender) Await(callback func(string, error) interface{}, params c.Result = make(chan interface{}, 1) key := fmt.Sprintf("u=%v&c=%v&i=%v", sender.GetUserID(), sender.GetChatID(), sender.GetImType()) if oc, ok := waits.LoadOrStore(key, c); ok { - fmt.Println(waits.LoadOrStore(key, c)) oc.(Carry).Chan <- InterruptError } - fmt.Println(waits.LoadOrStore(key, c)) + fmt.Println(key) + fmt.Println(waits.Load(key)) select { case result := <-c.Chan: switch result.(type) {