From 142dfd7077c29fd3dd36ad844fa2b0904456a003 Mon Sep 17 00:00:00 2001 From: ztino <> Date: Tue, 5 Jan 2021 19:41:37 +0800 Subject: [PATCH 1/2] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E6=8A=A2=E8=B4=AD?= =?UTF-8?q?=E6=8F=90=E4=BA=A4=E8=AE=A2=E5=8D=95=E6=95=B0=E7=BB=84=E8=B6=8A?= =?UTF-8?q?=E7=95=8C=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- jd_seckill/seckill.go | 47 ++++++++++++++++++++++--------------------- 1 file changed, 24 insertions(+), 23 deletions(-) diff --git a/jd_seckill/seckill.go b/jd_seckill/seckill.go index 8be8e04..e72d9bb 100644 --- a/jd_seckill/seckill.go +++ b/jd_seckill/seckill.go @@ -77,20 +77,6 @@ func (this *Seckill) getSeckillUrl() (string, error) { url := "" for { _, body, _ := req.Send().End() - //临时打印数据 - log.Println("返回信息:"+body) - //先注释,测试过gjson可以解析jQuery1153906({"type":"3","state":"13","url":""})格式 -/* var cbBody string - cbBody = body - spBody := strings.Split(body, "(") - if len(spBody) >= 2 { - cbBody = strings.Trim(spBody[1], ")") - } - - if gjson.Get(cbBody, "url").Exists() && gjson.Get(cbBody, "url").String() != "" { - url = gjson.Get(cbBody, "url").String() - break - }*/ if gjson.Get(body, "url").Exists() && gjson.Get(body, "url").String() != "" { url = gjson.Get(body, "url").String() break @@ -158,16 +144,23 @@ func (this *Seckill) SeckillInitInfo() (string, error) { req.SetData("sku", skuId) req.SetData("num", seckillNum) req.SetData("isModifyAddress", "false") - resp, body, err := req.SetUrl("https://marathon.jd.com/seckillnew/orderService/pc/init.action").SetMethod("post").Send().End() - if err != nil || resp.StatusCode != http.StatusOK { - log.Println("初始化秒杀信息失败") - return "", errors.New("初始化秒杀信息失败") - } - if !gjson.Valid(body) { - log.Println("抢购失败，返回信息:" + body) - return "", errors.New("抢购失败，返回信息:" + body) + req.SetUrl("https://marathon.jd.com/seckillnew/orderService/pc/init.action").SetMethod("post") + //尝试获取三次 + errorCount:=3 + errorMsg:="" + for errorCount > 0 { + _, body, _ := req.Send().End() + if body!="null" && gjson.Valid(body) { + log.Println("获取秒杀初始化信息成功") + return body,nil + }else{ + log.Println("获取秒杀初始化信息失败,返回信息:"+body) + errorMsg=body + } + errorCount=errorCount-1 + time.Sleep(300*time.Millisecond) } - return body, nil + return "", errors.New(errorMsg) } func (this *Seckill) SubmitSeckillOrder() bool { @@ -182,6 +175,10 @@ func (this *Seckill) SubmitSeckillOrder() bool { return false } address := gjson.Get(initInfo, "addressList").Array() + if !gjson.Get(initInfo, "addressList").Exists() || len(address)<1 { + log.Println("抢购失败，可能你还未设置默认收货地址") + return false + } defaultAddress := address[0] isinvoiceInfo := gjson.Get(initInfo, "invoiceInfo").Exists() invoiceTitle := "-1" @@ -241,6 +238,10 @@ func (this *Seckill) SubmitSeckillOrder() bool { _ = service.SendMessage(this.conf, "茅台抢购通知", "抢购失败，网络错误") return false } + + //临时打印数据 + log.Println("返回信息:"+body) + if !gjson.Valid(body) { log.Println("抢购失败，返回信息:" + body) _ = service.SendMessage(this.conf, "茅台抢购通知", "抢购失败，返回信息:"+body) From 0563fc05135ec129104b47a3f6fcbbdde3084225 Mon Sep 17 00:00:00 2001 From: ztino <> Date: Tue, 5 Jan 2021 20:10:22 +0800 Subject: [PATCH 2/2] =?UTF-8?q?jd=5Fseckill=20seckill=20=E6=96=B0=E5=A2=9E?= =?UTF-8?q?run=E5=8F=82=E6=95=B0=E6=94=AF=E6=8C=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- cmd/seckill.go | 42 +++++++++++++++++++++++++----------------- 1 file changed, 25 insertions(+), 17 deletions(-) diff --git a/cmd/seckill.go b/cmd/seckill.go index 8464061..89f1622 100644 --- a/cmd/seckill.go +++ b/cmd/seckill.go @@ -17,6 +17,7 @@ import ( func init() { rootCmd.AddCommand(seckillCmd) + seckillCmd.Flags().BoolP("run","r",false,"Run directly without waiting for the time to buy") } var seckillCmd = &cobra.Command{ @@ -26,6 +27,8 @@ var seckillCmd = &cobra.Command{ } func startSeckill(cmd *cobra.Command, args []string) { + //获取是否直接运行抢购 + isRun,_:=cmd.Flags().GetBool("run") session:=jd_seckill.NewSession(common.CookieJar) err:=session.CheckLoginStatus() if err!=nil { @@ -34,24 +37,29 @@ func startSeckill(cmd *cobra.Command, args []string) { //活跃用户会话,当会话失效自动退出程序 user:=jd_seckill.NewUser(common.Client,common.Config) go KeepSession(user) - //计算抢购时间 - nowLocalTime:=time.Now().UnixNano()/1e6 - jdTime,_:=GetJdTime() - buyDate:=common.Config.MustValue("config","buy_time","") - loc, _ := time.LoadLocation("Local") - t,_:=time.ParseInLocation("2006-01-02 15:04:05",buyDate,loc) - buyTime:=t.UnixNano()/1e6 - diffTime:=nowLocalTime-jdTime - log.Println(fmt.Sprintf("正在等待到达设定时间:%s，检测本地时间与京东服务器时间误差为【%d】毫秒",buyDate,diffTime)) - timerTime:=(buyTime+diffTime)-jdTime - if timerTime<=0 { - log.Println("请设置抢购时间") - os.Exit(0) + //直接运行抢购跳过等待抢购时间 + if !isRun { + //计算抢购时间 + nowLocalTime:=time.Now().UnixNano()/1e6 + jdTime,_:=GetJdTime() + buyDate:=common.Config.MustValue("config","buy_time","") + loc, _ := time.LoadLocation("Local") + t,_:=time.ParseInLocation("2006-01-02 15:04:05",buyDate,loc) + buyTime:=t.UnixNano()/1e6 + diffTime:=nowLocalTime-jdTime + log.Println(fmt.Sprintf("正在等待到达设定时间:%s，检测本地时间与京东服务器时间误差为【%d】毫秒",buyDate,diffTime)) + timerTime:=(buyTime+diffTime)-jdTime + if timerTime<=0 { + log.Println("请设置抢购时间") + os.Exit(0) + } + //等待抢购 + time.Sleep(time.Duration(timerTime)*time.Millisecond) + //开始抢购 + log.Println("时间到达，开始执行……") + }else{ + log.Println("开始执行……") } - //等待抢购 - time.Sleep(time.Duration(timerTime)*time.Millisecond) - //开始抢购 - log.Println("时间到达，开始执行……") seckill:=jd_seckill.NewSeckill(common.Client,common.Config) //开启抢购任务,第二个参数为开启几个协程 //怕封号的可以减少协程数量,相反抢到的成功率也减低了