add close node

pkg/app/process.go

@@ -18,6 +18,7 @@ import (
 	"io/ioutil"
 	"chain33-pai/pkg/util"
 	"chain33-pai/pkg/e"
+	"chain33-pai/pkg/chain33"
 )
 
 type ProcessInfo struct {
@@ -348,4 +349,16 @@ func GetAbsPath(key string) string {
 		return ""
 	}
 	return ""
+}
+
+func SafeCloseNode() (bool,error) {
+	var client chain33.PaiClient
+	reply,err := client.Close()
+	if err != nil {
+		return false,err
+	}
+	if !reply.IsOk {
+		return false,nil
+	}
+	return true,nil
 }
\ No newline at end of file

pkg/chain33/client.go

@@ -44,4 +44,8 @@ func (p *PaiClient) GetNetInfo() (*types.NodeNetInfo,error) {
 
 func (p *PaiClient) Version()(*types.VersionInfo,error){
 	return paiClient.Version(context.Background(),&types.ReqNil{})
+}
+
+func (p *PaiClient) Close() (*types.Reply,error) {
+	return paiClient.CloseQueue(context.Background(),&types.ReqNil{})
 }
\ No newline at end of file

routers/api/v1/node.go

@@ -101,6 +101,13 @@ func UpdateNode(c *gin.Context){
 		appG.Response(http.StatusOK,e.NETWORK_ERROR,"network error,please checkout your network then try again")
 		return
 	}
+	t,err := app.SafeCloseNode()
+	if err != nil || !t {
+		app.UpdateInfo.Flag = true
+		app.BityuanFlag = false
+		appG.Response(http.StatusOK,e.NODE_ERROR,"close node error")
+		return
+	}
 	name := setting.BityuanSetting.Name+"_"+latestVersion+".tar.gz"
 	url := setting.Chain33Pai.DownloadUrl+ name
 	err = app.DownLoadFile(url,name,int32(1))
@@ -257,7 +264,7 @@ func UpdateNode(c *gin.Context){
 		appG.Response(http.StatusOK, e.NODE_ERROR,"start auto sh err")
 		return
 	}
-	app.DPercent.Flag = false
+	app.BityuanFlag = false
 	appG.Response(http.StatusOK,e.SUCCESS,"update job started")
 }