package jd_seckill
import (
"errors"
"fmt"
"github.com/Albert-Zhan/httpc"
"github.com/PuerkitoBio/goquery"
"github.com/tidwall/gjson"
"github.com/unknwon/goconfig"
"github.com/ztino/jd_seckill/common"
"github.com/ztino/jd_seckill/log"
"github.com/ztino/jd_seckill/service"
"net/http"
"net/url"
"os"
"regexp"
"strconv"
"strings"
"time"
)
type Seckill struct {
client * httpc . HttpClient
conf * goconfig . ConfigFile
}
func NewSeckill ( client * httpc . HttpClient , conf * goconfig . ConfigFile ) * Seckill {
return & Seckill { client : client , conf : conf }
}
func ( this * Seckill ) getUserAgent ( ) string {
return this . conf . MustValue ( "config" , "default_user_agent" , "" )
}
func ( this * Seckill ) SkuTitle ( ) ( string , error ) {
skuId := this . conf . MustValue ( "config" , "sku_id" , "" )
req := httpc . NewRequest ( this . client )
resp , body , err := req . SetUrl ( fmt . Sprintf ( "https://item.jd.com/%s.html" , skuId ) ) . SetMethod ( "get" ) . Send ( ) . End ( )
if err != nil || resp . StatusCode != http . StatusOK {
log . Println ( "访问商品详情失败" )
return "" , errors . New ( "访问商品详情失败" )
}
html := strings . NewReader ( body )
doc , _ := goquery . NewDocumentFromReader ( html )
return strings . TrimSpace ( doc . Find ( ".sku-name" ) . Text ( ) ) , nil
}
func ( this * Seckill ) GetDiffTime ( ) int64 {
log . Println ( "获取本地时间与京东云端时间差" )
localTime := time . Now ( ) . UnixNano ( ) / 1e6
log . Println ( "本地系统时间:" , time . Unix ( 0 , localTime * 1e6 ) )
jdTime := localTime
req := httpc . NewRequest ( common . Client )
resp , body , err := req . SetUrl ( "https://a.jd.com//ajax/queryServerData.html" ) . SetMethod ( "get" ) . Send ( ) . End ( )
if err != nil || resp . StatusCode != http . StatusOK {
log . Println ( "获取京东服务器时间失败,以本地时间为准" )
} else {
jdTime = gjson . Get ( body , "serverTime" ) . Int ( )
}
log . Println ( "京东云端时间:" , time . Unix ( 0 , jdTime * 1e6 ) )
delayTime := time . Now ( ) . UnixNano ( ) / 1e6 - localTime
log . Println ( "网络请求延时:" , delayTime , "ms" )
diffTime := localTime - jdTime + delayTime / 2
log . Println ( "实际时间误差:" , diffTime , "ms (本地时间-京东云端时间+网络请求延时/2)" )
return diffTime
}
func ( this * Seckill ) GetWareBusiness ( ) ( [ ] string , [ ] string , error ) {
log . Println ( "获取商品的预约时间、抢购时间" )
skuId := this . conf . MustValue ( "config" , "sku_id" , "" ) //商品ID
cat := "12259,12260,9435" //分类路径,TODO:适配其他商品时要调整
area := "16_1303_3484_0" //配送至,TODO:适配其他商品时要调整成购买者实际地区
shopId := "1000085463" //卖家ID
venderId := "1000085463" //供应商ID
paramJson := "{\"platform2\":\"1\",\"specialAttrStr\":\"p0pp1pppppppppppppppp\",\"skuMarkStr\":\"00\"}" //TODO:不知道干嘛用的?
num := this . conf . MustValue ( "config" , "seckill_num" , "1" ) //购买数量
req := httpc . NewRequest ( this . client )
req . SetHeader ( "User-Agent" , this . getUserAgent ( ) )
req . SetHeader ( "Referer" , fmt . Sprintf ( "https://item.jd.com/%s.html" , skuId ) )
resp , body , err := req . SetUrl ( fmt . Sprintf ( "https://item-soa.jd.com/getWareBusiness?callback=jQuery%s&skuId=%s&cat=%s&area=%s&shopId=%s&venderId=%s¶mJson=%s&num=%s&_=%s" ,
common . RandomNumber ( 7 ) ,
skuId ,
cat ,
area ,
shopId ,
venderId ,
url . QueryEscape ( paramJson ) ,
num ,
strconv . Itoa ( int ( time . Now ( ) . Unix ( ) * 1000 ) ) ,
) ) . SetMethod ( "get" ) . Send ( ) . End ( )
var yuyueTimeArr [ ] string
var buyTimeArr [ ] string
if err != nil || resp . StatusCode != http . StatusOK {
log . Println ( "获取商品详情失败" , resp , body , err )
return yuyueTimeArr , buyTimeArr , errors . New ( "访问商品详情失败" )
}
if ! gjson . Get ( body , "yuyueInfo" ) . Exists ( ) || ! gjson . Get ( body , "yuyueInfo.yuyueTime" ) . Exists ( ) || ! gjson . Get ( body , "yuyueInfo.buyTime" ) . Exists ( ) {
log . Println ( "获取商品预约信息失败" , body )
return yuyueTimeArr , buyTimeArr , errors . New ( "获取商品预约信息失败" )
}
yuyueTime := gjson . Get ( body , "yuyueInfo.yuyueTime" ) . String ( )
buyTime := gjson . Get ( body , "yuyueInfo.buyTime" ) . String ( )
log . Println ( "预约起止时间:" , yuyueTime )
log . Println ( "购买起止时间:" , buyTime )
reg := regexp . MustCompile ( ` (\d { 4}-\d { 2}-\d { 2}\s\d { 2}:\d { 2}) ` )
yuyueTimeArr = reg . FindAllString ( yuyueTime , 2 )
buyTimeArr = reg . FindAllString ( buyTime , 2 )
return yuyueTimeArr , buyTimeArr , nil
}
func ( this * Seckill ) MakeReserve ( ) {
yuyueTimeArr , buyTimeArr , err := this . GetWareBusiness ( )
if err == nil && len ( yuyueTimeArr ) == 2 {
diffTime := this . GetDiffTime ( )
loc , _ := time . LoadLocation ( "Local" )
yuyueTimeBegin , _ := time . ParseInLocation ( common . DateTimeFormatStr , yuyueTimeArr [ 0 ] + ":00" , loc )
yuyueTimeEnd , _ := time . ParseInLocation ( common . DateTimeFormatStr , yuyueTimeArr [ 1 ] + ":59" , loc )
beginTime := yuyueTimeBegin . UnixNano ( ) / 1e6 + diffTime
endTime := yuyueTimeEnd . UnixNano ( ) / 1e6 + diffTime
diffTime = beginTime - time . Now ( ) . UnixNano ( ) / 1e6
if diffTime > 0 {
log . Println ( "还没到预约时间,等待" , diffTime , "ms 后开始预约" )
time . Sleep ( time . Duration ( diffTime ) * time . Millisecond )
}
diffTime = time . Now ( ) . UnixNano ( ) / 1e6 - endTime
if diffTime > 0 {
log . Println ( "您已经错过预约时间,下次请早!" )
os . Exit ( 0 )
}
} else {
log . Println ( "预约起始时间获取失败,立即尝试预约:" , err , yuyueTimeArr )
}
user := NewUser ( this . client , this . conf )
userInfo , _ := user . GetUserInfo ( )
log . Println ( "用户:" + userInfo )
shopTitle , err := this . SkuTitle ( )
if err != nil {
log . Println ( "获取商品信息失败" )
} else {
log . Println ( "商品名称:" + shopTitle )
}
skuId := this . conf . MustValue ( "config" , "sku_id" , "" )
req := httpc . NewRequest ( this . client )
req . SetHeader ( "User-Agent" , this . getUserAgent ( ) )
req . SetHeader ( "Referer" , fmt . Sprintf ( "https://item.jd.com/%s.html" , skuId ) )
resp , body , err := req . SetUrl ( "https://yushou.jd.com/youshouinfo.action?callback=fetchJSON&sku=" + skuId + "&_=" + strconv . Itoa ( int ( time . Now ( ) . Unix ( ) * 1000 ) ) ) . SetMethod ( "get" ) . Send ( ) . End ( )
if err != nil || resp . StatusCode != http . StatusOK {
log . Println ( "预约商品失败" )
} else {
reserveUrl := gjson . Get ( body , "url" ) . String ( )
req = httpc . NewRequest ( this . client )
_ , _ , _ = req . SetUrl ( "https:" + reserveUrl ) . SetMethod ( "get" ) . Send ( ) . End ( )
msg := "商品名称《" + shopTitle + "》预约成功,已获得抢购资格 / 您已成功预约过了,无需重复预约!\n\n[我的预约](https://yushou.jd.com/member/qualificationList.action)"
_ = service . SendMessage ( this . conf , "京东秒杀通知" , msg )
log . Println ( msg )
//更新购买时间
if len ( buyTimeArr ) == 2 {
confFile := "./conf.ini"
cfg , err := goconfig . LoadConfigFile ( confFile )
if err != nil {
log . Println ( "配置文件不存在,程序退出" )
os . Exit ( 0 )
}
buyTime := buyTimeArr [ 0 ] + ":00"
cfg . SetValue ( "config" , "buy_time" , buyTime )
if err := goconfig . SaveConfigFile ( cfg , confFile ) ; err != nil {
log . Println ( "保存配置文件失败,请手动修改conf.ini,buy_time =" , buyTime )
}
log . Println ( "下一次抢购开始时间设定已经更新:" , buyTime )
}
}
}
// 获取抢购链接
func ( this * Seckill ) getSeckillUrl ( ) ( string , error ) {
skuId := this . conf . MustValue ( "config" , "sku_id" , "" )
req := httpc . NewRequest ( this . client )
req . SetHeader ( "User-Agent" , this . getUserAgent ( ) )
req . SetHeader ( "Host" , "itemko.jd.com" )
req . SetHeader ( "Referer" , fmt . Sprintf ( "https://item.jd.com/%s.html" , skuId ) )
req . SetUrl ( "https://itemko.jd.com/itemShowBtn?callback=jQuery" + strconv . Itoa ( common . Rand ( 1000000 , 9999999 ) ) + "&skuId=" + skuId + "&from=pc&_=" + strconv . Itoa ( int ( time . Now ( ) . Unix ( ) * 1000 ) ) ) . SetMethod ( "get" )
url := ""
for {
_ , body , _ := req . Send ( ) . End ( )
if gjson . Get ( body , "url" ) . Exists ( ) && gjson . Get ( body , "url" ) . String ( ) != "" {
url = gjson . Get ( body , "url" ) . String ( )
break
}
log . Println ( "抢购链接获取失败,稍后自动重试" )
time . Sleep ( 300 * time . Millisecond )
}
url = "https:" + url
//https://divide.jd.com/user_routing?skuId=8654289&sn=c3f4ececd8461f0e4d7267e96a91e0e0&from=pc
url = strings . ReplaceAll ( url , "divide" , "marathon" )
//https://marathon.jd.com/captcha.html?skuId=8654289&sn=c3f4ececd8461f0e4d7267e96a91e0e0&from=pc
url = strings . ReplaceAll ( url , "user_routing" , "captcha.html" )
log . Println ( "抢购链接获取成功:" + url )
return url , nil
}
func ( this * Seckill ) RequestSeckillUrl ( ) {
user := NewUser ( this . client , this . conf )
userInfo , _ := user . GetUserInfo ( )
log . Println ( "用户:" + userInfo )
shopTitle , err := this . SkuTitle ( )
if err != nil {
log . Println ( "获取商品信息失败" )
} else {
log . Println ( "商品名称:" + shopTitle )
}
url , _ := this . getSeckillUrl ( )
skuId := this . conf . MustValue ( "config" , "sku_id" , "" )
log . Println ( "访问商品的抢购连接..." )
client := httpc . NewHttpClient ( )
client . SetCookieJar ( common . CookieJar )
client . SetRedirect ( func ( req * http . Request , via [ ] * http . Request ) error {
return http . ErrUseLastResponse
} )
req := httpc . NewRequest ( client )
req . SetHeader ( "User-Agent" , this . getUserAgent ( ) )
req . SetHeader ( "Host" , "marathon.jd.com" )
req . SetHeader ( "Referer" , fmt . Sprintf ( "https://item.jd.com/%s.html" , skuId ) )
_ , _ , _ = req . SetUrl ( url ) . SetMethod ( "get" ) . Send ( ) . End ( )
}
func ( this * Seckill ) SeckillPage ( ) {
log . Println ( "访问抢购订单结算页面..." )
skuId := this . conf . MustValue ( "config" , "sku_id" , "" )
seckillNum := this . conf . MustValue ( "config" , "seckill_num" , "2" )
client := httpc . NewHttpClient ( )
client . SetCookieJar ( common . CookieJar )
client . SetRedirect ( func ( req * http . Request , via [ ] * http . Request ) error {
return http . ErrUseLastResponse
} )
req := httpc . NewRequest ( client )
req . SetHeader ( "User-Agent" , this . getUserAgent ( ) )
req . SetHeader ( "Host" , "marathon.jd.com" )
req . SetHeader ( "Referer" , fmt . Sprintf ( "https://item.jd.com/%s.html" , skuId ) )
_ , _ , _ = req . SetUrl ( "https://marathon.jd.com/seckill/seckill.action?skuId=" + skuId + "&num=" + seckillNum + "&rid=" + strconv . Itoa ( int ( time . Now ( ) . Unix ( ) ) ) ) . SetMethod ( "get" ) . Send ( ) . End ( )
}
func ( this * Seckill ) SeckillInitInfo ( ) ( string , error ) {
log . Println ( "获取秒杀初始化信息..." )
skuId := this . conf . MustValue ( "config" , "sku_id" , "" )
seckillNum := this . conf . MustValue ( "config" , "seckill_num" , "2" )
req := httpc . NewRequest ( this . client )
req . SetHeader ( "User-Agent" , this . getUserAgent ( ) )
req . SetHeader ( "Host" , "marathon.jd.com" )
req . SetData ( "sku" , skuId )
req . SetData ( "num" , seckillNum )
req . SetData ( "isModifyAddress" , "false" )
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 {
if len ( body ) < 200 {
log . Println ( "获取秒杀初始化信息失败,返回信息:" + body )
} else {
log . Println ( "获取秒杀初始化信息失败,返回信息: 网页" )
}
errorMsg = body
}
errorCount = errorCount - 1
time . Sleep ( 300 * time . Millisecond )
}
return "" , errors . New ( errorMsg )
}
func ( this * Seckill ) SubmitSeckillOrder ( ) bool {
eid := this . conf . MustValue ( "config" , "eid" , "" )
fp := this . conf . MustValue ( "config" , "fp" , "" )
skuId := this . conf . MustValue ( "config" , "sku_id" , "" )
seckillNum := this . conf . MustValue ( "config" , "seckill_num" , "2" )
paymentPwd := this . conf . MustValue ( "account" , "payment_pwd" , "" )
initInfo , err := this . SeckillInitInfo ( )
if err != nil {
if len ( err . Error ( ) ) > 200 {
log . Println ( fmt . Sprintf ( "抢购失败,无法获取生成订单的基本信息,接口返回: html代码" ) )
} else {
log . Println ( fmt . Sprintf ( "抢购失败,无法获取生成订单的基本信息,接口返回:【%s】" , err . Error ( ) ) )
}
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"
invoiceContentType := "-1"
invoicePhone := ""
invoicePhoneKey := ""
invoiceInfo := "false"
if isinvoiceInfo {
invoiceTitle = gjson . Get ( initInfo , "invoiceInfo.invoiceTitle" ) . String ( )
invoiceContentType = gjson . Get ( initInfo , "invoiceInfo.invoiceContentType" ) . String ( )
invoicePhone = gjson . Get ( initInfo , "invoiceInfo.invoicePhone" ) . String ( )
invoicePhoneKey = gjson . Get ( initInfo , "invoiceInfo.invoicePhoneKey" ) . String ( )
invoiceInfo = "true"
}
token := gjson . Get ( initInfo , "token" ) . String ( )
log . Println ( "提交抢购订单..." )
req := httpc . NewRequest ( this . client )
req . SetHeader ( "User-Agent" , this . getUserAgent ( ) )
req . SetHeader ( "Host" , "marathon.jd.com" )
req . SetHeader ( "Referer" , fmt . Sprintf ( "https://marathon.jd.com/seckill/seckill.action?skuId=%s&num=%s&rid=%d" , skuId , seckillNum , int ( time . Now ( ) . Unix ( ) ) ) )
req . SetData ( "skuId" , skuId )
req . SetData ( "num" , seckillNum )
req . SetData ( "addressId" , defaultAddress . Get ( "id" ) . String ( ) )
req . SetData ( "yuShou" , "true" )
req . SetData ( "isModifyAddress" , "false" )
req . SetData ( "name" , defaultAddress . Get ( "name" ) . String ( ) )
req . SetData ( "provinceId" , defaultAddress . Get ( "provinceId" ) . String ( ) )
req . SetData ( "cityId" , defaultAddress . Get ( "cityId" ) . String ( ) )
req . SetData ( "countyId" , defaultAddress . Get ( "countyId" ) . String ( ) )
req . SetData ( "townId" , defaultAddress . Get ( "townId" ) . String ( ) )
req . SetData ( "addressDetail" , defaultAddress . Get ( "addressDetail" ) . String ( ) )
req . SetData ( "mobile" , defaultAddress . Get ( "mobile" ) . String ( ) )
req . SetData ( "mobileKey" , defaultAddress . Get ( "mobileKey" ) . String ( ) )
req . SetData ( "email" , defaultAddress . Get ( "email" ) . String ( ) )
req . SetData ( "postCode" , "" )
req . SetData ( "invoiceTitle" , invoiceTitle )
req . SetData ( "invoiceCompanyName" , "" )
req . SetData ( "invoiceContent" , invoiceContentType )
req . SetData ( "invoiceTaxpayerNO" , "" )
req . SetData ( "invoiceEmail" , "" )
req . SetData ( "invoicePhone" , invoicePhone )
req . SetData ( "invoicePhoneKey" , invoicePhoneKey )
req . SetData ( "invoice" , invoiceInfo )
req . SetData ( "password" , paymentPwd )
req . SetData ( "codTimeType" , "3" )
req . SetData ( "paymentType" , "4" )
req . SetData ( "areaCode" , "" )
req . SetData ( "overseas" , "0" )
req . SetData ( "phone" , "" )
req . SetData ( "eid" , eid )
req . SetData ( "fp" , fp )
req . SetData ( "token" , token )
req . SetData ( "pru" , "" )
//req.SetData("sk", "s76lo6CABKGBMSZ") // 自己添加
resp , body , err := req . SetUrl ( "https://marathon.jd.com/seckillnew/orderService/pc/submitOrder.action?skuId=" + skuId ) . SetMethod ( "post" ) . Send ( ) . End ( )
if err != nil || resp . StatusCode != http . StatusOK {
log . Println ( "抢购失败,网络错误" )
_ = service . SendMessage ( this . conf , "京东秒杀通知" , "抢购失败,网络错误" )
return false
}
if ! gjson . Valid ( body ) {
log . Println ( "抢购失败,返回信息:" + body )
_ = service . SendMessage ( this . conf , "京东秒杀通知" , "抢购失败,返回信息:" + body )
return false
}
if gjson . Get ( body , "success" ) . Bool ( ) {
orderId := gjson . Get ( body , "orderId" ) . String ( )
totalMoney := gjson . Get ( body , "totalMoney" ) . String ( )
payUrl := "https:" + gjson . Get ( body , "pcUrl" ) . String ( )
log . Println ( fmt . Sprintf ( "抢购成功,订单号:%s, 总价:%s, 电脑端付款链接:%s" , orderId , totalMoney , payUrl ) )
_ = service . SendMessage ( this . conf , "京东秒杀通知" , fmt . Sprintf ( "抢购成功,订单号:%s, 总价:%s, 电脑端付款链接:%s" , orderId , totalMoney , payUrl ) )
return true
} else {
log . Println ( "抢购失败,返回信息:" + body )
_ = service . SendMessage ( this . conf , "京东秒杀通知" , "抢购失败,返回信息:" + body )
return false
}
}