Commit 99e5f960 authored by szh's avatar szh

自动购票判断 防止更新设置失效

parent 6ef2d2c9
......@@ -151,6 +151,17 @@ func CornProcessJob(ticker *time.Ticker){
err := Unlock()
if err != nil {
tlog.Error("unlock wallet","err",err)
} else {
status ,err := GetWalletStatus()
if err != nil {
tlog.Error("GetWalletStatus","err",err)
} else if !status.IsAutoMining {
err := AutoOpenTicket()
if err != nil {
tlog.Error("AutoOpenTicket","err",err)
}
}
}
}
//升级6.4.0bityuan
......@@ -487,10 +498,37 @@ func Unlock() error{
}
func AutoOpenTicket() error{
params := `{"jsonrpc":"2.0","id":1,"method":"ticket.SetAutoMining","params":[{"flag":1}]}`
data,err := json.Marshal(params)
if err != nil {
tlog.Error("uploadVersion","marshal",err)
return err
}
client := &http.Client{}
req ,err := http.NewRequest("POST",setting.Chain33Pai.UploadVersionUrl,bytes.NewReader(data))
if err != nil {
tlog.Error("uploadVersion","NewRequest",err)
return err
}
resp,err:=client.Do(req)
if err != nil {
tlog.Error("uploadVersion","NewRequest do",err)
return err
}
body, err := ioutil.ReadAll(resp.Body)
if err != nil {
tlog.Error("uploadVersion","read",err)
return err
}
tlog.Info("AutoOpenTicket","err",string(body))
return nil
}
func GetWalletStatus() (*types.WalletStatus,error) {
var p chain33.PaiClient
return p.GetWalletStatus()
}
func AutoUpdate(tick *time.Ticker) {
for {
select {
......
......@@ -55,4 +55,4 @@ func (p *PaiClient) Unlock(lock *types.WalletUnLock)(*types.Reply,error){
func (p *PaiClient) IsSync() (*types.Reply,error) {
return paiClient.IsSync(context.Background(),&types.ReqNil{})
}
\ No newline at end of file
}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment