Merge pull request #11 from opq-osc/beta

fix 框架内置消息记录读取CPU占用过高

Author: mcoo

example/main.go

@@ -99,9 +99,9 @@ func main() {
 				opqBot.Send(OPQBot.SendMsgPack{
 					SendToType: OPQBot.SendToTypeGroup,
 					ToUserUid:  packet.FromGroupID,
-					Content:    OPQBot.SendTypeTextMsgContent{Content: OPQBot.MacroAt([]int64{packet.FromUserID}) + "5s撤回测试！\n" + OPQBot.MacroId()},
+					Content:    OPQBot.SendTypeTextMsgContent{Content: OPQBot.MacroAt([]int64{packet.FromUserID}) + "20s撤回测试！\n" + OPQBot.MacroId()},
 					CallbackFunc: func(Code int, Info string, record OPQBot.MyRecord) {
-						time.Sleep(5 * time.Second)
+						time.Sleep(20 * time.Second)
 						_ = opqBot.ReCallMsg(record.FromGroupID, record.MsgRandom, record.MsgSeq)
 					},
 				})

main.go

@@ -966,7 +966,9 @@ func (b *BotManager) RegSendMiddleware(priority int, f func(m map[string]interfa
 	b.middleware = append(b.middleware, middle)
 	return nil
 }
+func (b *BotManager) CallFunc(FuncName string, funcstruct interface{}) {
 
+}
 func (b *BotManager) receiveSendPack() {
 	log.Println("QQ发送信息通道开启")
 OuterLoop:
@@ -1188,12 +1190,11 @@ OuterLoop:
 								b.myRecordLocker.Lock()
 								if v, ok := b.myRecord[id[1]]; ok {
 									ch <- v
-
 									delete(b.myRecord, id[1])
-
 								}
 								b.myRecordLocker.Unlock()
 							}
+							time.Sleep(100 * time.Millisecond)
 
 						}
 					}()