up

pkg/app/process.go

@@ -11,6 +11,7 @@ import (
 	"os/exec"
 	"sync"
 	"time"
+	"strings"
 )
 
 func GennerPort()(port,daemonPort int,err error){
@@ -91,7 +92,25 @@ func reKeygen(){
 	f.Close()
 
 }
+
 func CleanUp(){
+	var buff bytes.Buffer
+	netstat:=exec.Command(setting.Chain33Pai.NetStat)
+	netstat.Stdout=&buff
+	idSelector:=strings.Split(buff.String(),"\n")
+	if len(idSelector)==0{//没有映射端口存在，即没有需要处理的反馈
+		reKeygen()//清空authorized_keys
+		models.DropFeedBack()//清空数据库记录
+		return
+	}
+	for _,v:=range idSelector{
+		if models.IsComplete(v){
+			models.DelFeedBack(v)
+		}
+	}
+}
+
+func CleanUp1(){
 	list,err := models.GetAllFeedBackList()
 	if err != nil {
 		fmt.Println("GetAllFeedBackList",err)