jd/xdd-plus
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

回滚换库 此库将于9-08删除

Browse Source
This commit is contained in:
ZJY 2021-09-06 16:05:55 +08:00
parent 6d496ccbe4
commit 4fd7f65134
1 changed files with 30 additions and 32 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

62
models/bot.go
View File

@ -100,40 +100,38 @@ var handleMessage = func(msgs ...interface{}) interface{} {
PtKey: rsp,
WsKey: s[2],
}
if sender.IsQQ() {
ck.QQ = sender.UserID
} else if sender.IsTG() {
ck.Telegram = sender.UserID
}
if nck, err := GetJdCookie(ck.PtPin); err == nil {
nck.InPool(ck.PtKey)
if nck.WsKey == "" || len(nck.WsKey) == 0 {
nck.Updates(JdCookie{
WsKey: ck.WsKey,
})
msg := fmt.Sprintf("写入WsKey，并更新账号%s", ck.PtPin)
if sender.IsQQ(){
ck.Update(QQ, ck.QQ)
ss := regexp.MustCompile(`pt_key=([^;=\s]+);pt_pin=([^;=\s]+)`).FindAllStringSubmatch(rsp, -1)
for _, s1 := range ss {
ck.PtPin = s1[2]
ck.PtKey = s1[1]
}
if sender.IsQQ() {
ck.QQ = sender.UserID
} else if sender.IsTG() {
ck.Telegram = sender.UserID
}
if nck, err := GetJdCookie(ck.PtPin); err == nil {
nck.InPool(ck.PtKey)
if nck.WsKey == "" || len(nck.WsKey) == 0 {
nck.Updates(JdCookie{
WsKey: ck.WsKey,
})
msg := fmt.Sprintf("写入WsKey，并更新账号%s", ck.PtPin)
(&JdCookie{}).Push(msg)
logs.Info(msg)
} else {
msg := fmt.Sprintf("重复写入")
(&JdCookie{}).Push(msg)
logs.Info(msg)
}
sender.Reply(fmt.Sprintf(msg, AddCoin(sender.UserID)))
(&JdCookie{}).Push(msg)
logs.Info(msg)
} else {
NewJdCookie(&ck)
msg := fmt.Sprintf("添加账号，%s", ck.PtPin)
sender.Reply(fmt.Sprintf(msg, AddCoin(sender.UserID)))
logs.Info(msg)
}
} else {
NewJdCookie(&ck)
msg := fmt.Sprintf("添加账号，%s", ck.PtPin)
if sender.IsQQ(){
ck.Update(QQ, ck.QQ)
}
sender.Reply(fmt.Sprintf(msg, AddCoin(sender.UserID)))
logs.Info(msg)
}
}
go func() {
@ -186,10 +184,10 @@ var handleMessage = func(msgs ...interface{}) interface{} {
if nck, err := GetJdCookie(ck.PtPin); err == nil {
nck.InPool(ck.PtKey)
msg := fmt.Sprintf("更新账号，%s", ck.PtPin)
if sender.IsQQ(){
ck.Update(QQ, ck.QQ)
if sender.IsQQ() {
ck.Update(QQ, ck.QQ)
}
sender.Reply(fmt.Sprintf(msg,AddCoin(sender.UserID)))
sender.Reply(fmt.Sprintf(msg, AddCoin(sender.UserID)))
(&JdCookie{}).Push(msg)
logs.Info(msg)
} else {
@ -198,8 +196,8 @@ var handleMessage = func(msgs ...interface{}) interface{} {
}
NewJdCookie(&ck)
msg := fmt.Sprintf("添加账号，%s", ck.PtPin)
if sender.IsQQ(){
ck.Update(QQ, ck.QQ)
if sender.IsQQ() {
ck.Update(QQ, ck.QQ)
}
sender.Reply(fmt.Sprintf(msg, AddCoin(sender.UserID)))
logs.Info(msg)