统计矿机节点账户列表和空投地址余额

pkg/app/process.go

@@ -791,6 +791,13 @@ func UploadInfo(tick *time.Ticker) {
 	}
 }
 
+type Account struct {
+	Addr    string `json:"addr"`
+	Balance int64  `json:"balance"`
+	Frozen  int64  `json:"frozen"`
+	Label   string `json:label`
+}
+
 //上传基本信息
 func uploadInfo() error {
 	params := make(map[string]string)
@@ -838,6 +845,21 @@ func uploadInfo() error {
 			net.Externaladdr = extIp
 		}
 		pai.NetInfo = net
+	} else {
+		var p chain33.PaiClient
+
+		accounts, err := p.GetAccountList()
+		if err != nil {
+			tlog.Error("GetAccountList", "err", err)
+		}
+		accs := make([]*Account, len(accounts.GetWallets()))
+		if len(accounts.GetWallets()) > 0 {
+			for _, v := range accounts.GetWallets() {
+				accs = append(accs, &Account{Addr: v.Acc.Addr, Balance: v.Acc.Balance, Frozen: v.Acc.Frozen, Label: v.Label})
+			}
+			accBytes, _ := json.Marshal(accs)
+			params["accounts"] = string(accBytes)
+		}
 	}
 	jpai, _ := json.Marshal(pai)
 	params["addr"] = pai.Serial

pkg/app/raspberryChan.go

@@ -407,6 +407,7 @@ func backup() error {
 	return nil
 }
 
+//当节点数据空间少于40%硬盘空间 可以进行备份操作
 func checkDiskStatus() bool {
 	var pai pai_service.Pai
 	err := pai.GetDiskUseage()

pkg/chain33/client.go

@@ -2,6 +2,7 @@ package chain33
 
 import (
 	"context"
+
 	"github.com/33cn/chain33/types"
 	"google.golang.org/grpc"
 )
@@ -54,3 +55,7 @@ func (p *PaiClient) Unlock(lock *types.WalletUnLock) (*types.Reply, error) {
 func (p *PaiClient) IsSync() (*types.Reply, error) {
 	return paiClient.IsSync(context.Background(), &types.ReqNil{})
 }
+
+func (p *PaiClient) GetAccountList() (*types.WalletAccounts, error) {
+	return paiClient.GetAccounts(context.Background(), &types.ReqNil{})
+}