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

测试

Browse Source
This commit is contained in:
ZJY 2021-09-07 13:56:24 +08:00
parent f38346e1df
commit 1d386bb339
1 changed files with 74 additions and 38 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

112
models/available.go
View File

@ -146,46 +146,82 @@ func updateCookie() {
var pinky = fmt.Sprintf("pin=%s;wskey=%s;", ck.PtPin, ck.WsKey)
rsp := cmd(fmt.Sprintf(`python3 test.py "%s"`, pinky), &Sender{})
logs.Info(rsp)
ss := regexp.MustCompile(`pt_key=([^;=\s]+);pt_pin=([^;=\s]+)`).FindAllStringSubmatch(rsp, -1)
if len(ss) > 0 {
xyb := 0
for _, s := range ss {
ck := JdCookie{
PtKey: s[1],
PtPin: s[2],
}
if CookieOK(&ck) {
xyb++
if HasKey(ck.PtKey) {
(&JdCookie{}).Push(fmt.Sprintf("重复提交"))
} else {
if nck, err := GetJdCookie(ck.PtPin); err == nil {
nck.InPool(ck.PtKey)
msg := fmt.Sprintf("定时更新账号，%s", ck.PtPin)
(&JdCookie{}).Push(msg)
logs.Info(msg)
} else {
NewJdCookie(&ck)
msg := fmt.Sprintf("添加账号，账号名:%s", ck.PtPin)
logs.Info(msg)
}
}
} else {
(&JdCookie{}).Push(fmt.Sprintf("无效CK转换失败，%s", ck.PtPin))
}
}
} else {
(&JdCookie{}).Push(fmt.Sprintf("Wskey失效，%s", ck.PtPin))
}
go func() {
Save <- &JdCookie{}
}()
}
}
for i := 0; i < l-1; i++ {
if len(cks[i].WsKey) > 0 {
rsp := cmd(fmt.Sprintf(`python3 test.py "%s"`, cks[i].WsKey), &Sender{})
ss := regexp.MustCompile(`pt_key=([^;=\s]+);pt_pin=([^;=\s]+)`).FindAllStringSubmatch(rsp, -1)
if len(ss) > 0 {
xyb := 0
for _, s := range ss {
ck := JdCookie{
PtKey: s[1],
PtPin: s[2],
}
if CookieOK(&ck) {
xyb++
if HasKey(ck.PtKey) {
(&JdCookie{}).Push(fmt.Sprintf("重复提交"))
} else {
if nck, err := GetJdCookie(ck.PtPin); err == nil {
nck.InPool(ck.PtKey)
msg := fmt.Sprintf("定时更新账号，%s", ck.PtPin)
(&JdCookie{}).Push(msg)
logs.Info(msg)
} else {
NewJdCookie(&ck)
msg := fmt.Sprintf("添加账号，账号名:%s", ck.PtPin)
logs.Info(msg)
}
}
} else {
(&JdCookie{}).Push(fmt.Sprintf("无效CK转换失败，%s", ck.PtPin))
}
}
}
go func() {
Save <- &JdCookie{}
}()
}
}
//for i := 0; i < l-1; i++ {
// if len(cks[i].WsKey) > 0 {
// rsp := cmd(fmt.Sprintf(`python3 test.py "%s"`, cks[i].WsKey), &Sender{})
// ss := regexp.MustCompile(`pt_key=([^;=\s]+);pt_pin=([^;=\s]+)`).FindAllStringSubmatch(rsp, -1)
// if len(ss) > 0 {
//
// xyb := 0
// for _, s := range ss {
// ck := JdCookie{
// PtKey: s[1],
// PtPin: s[2],
// }
// if CookieOK(&ck) {
// xyb++
// if HasKey(ck.PtKey) {
// (&JdCookie{}).Push(fmt.Sprintf("重复提交"))
// } else {
// if nck, err := GetJdCookie(ck.PtPin); err == nil {
// nck.InPool(ck.PtKey)
// msg := fmt.Sprintf("定时更新账号，%s", ck.PtPin)
// (&JdCookie{}).Push(msg)
// logs.Info(msg)
// } else {
// NewJdCookie(&ck)
// msg := fmt.Sprintf("添加账号，账号名:%s", ck.PtPin)
// logs.Info(msg)
// }
// }
// } else {
// (&JdCookie{}).Push(fmt.Sprintf("无效CK转换失败，%s", ck.PtPin))
// }
// }
// }
// go func() {
// Save <- &JdCookie{}
// }()
// }
//}
}
func CookieOK(ck *JdCookie) bool {