更新反馈处理逻辑

models/raspFeedBack.go

@@ -12,6 +12,14 @@ type RaspFeedback struct {
 	Complete 	bool	`json:"complete"`
 }
 
+func GetAllFeedBackList() ([]*RaspFeedback,error) {
+	var list []*RaspFeedback
+	if err := db.Find(list).Error; err != nil {
+		return nil,err
+	}
+	return list,nil
+}
+
 func IsComplete(id string)bool{
 	var feedback RaspFeedback
 	err:=db.Model(&RaspFeedback{}).Where("id=?",id).First(&feedback).Error
@@ -42,7 +50,6 @@ func DelFeedBack(id string){
 	}
 }
 
-
 func DropFeedBack(){
 	db.DropTable(&RaspFeedback{})
 }
@@ -50,4 +57,11 @@ func DropFeedBack(){
 func Complete(fd RaspFeedback){
 	db.Model(&fd).Update("Complete",true)
 
+}
+
+func DeleteCompleteFeedback(){
+	err:=db.Delete(&RaspFeedback{}).Where("complete=?",1).Error
+	if err!=nil{
+		log.Println(err)
+	}
 }
\ No newline at end of file

pkg/app/process.go

@@ -9,7 +9,6 @@ import (
 	"math/rand"
 	"os"
 	"os/exec"
-	"strings"
 	"sync"
 	"time"
 )
@@ -93,20 +92,21 @@ func reKeygen(){
 
 }
 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{//没有映射端口存在，即没有需要处理的反馈
+	list,err := models.GetAllFeedBackList()
+	if err != nil {
+		fmt.Println("GetAllFeedBackList",err)
+	}
+	fmt.Println("GetAllFeedBackList",list)
+	//var buff bytes.Buffer
+	//netstat:=exec.Command(setting.Chain33Pai.NetStat)
+	//netstat.Stdout=&buff
+	//idSelector:=strings.Split(buff.String(),"\n")
+	if len(list)==0{//没有映射端口存在，即没有需要处理的反馈
 		reKeygen()//清空authorized_keys
-		models.DropFeedBack()//清空数据库记录
 		return
 	}
-	for _,v:=range idSelector{
-		if models.IsComplete(v){
-			models.DelFeedBack(v)
-		}
-	}
+	models.DeleteCompleteFeedback()
+
 }
 
 func CornClean(ticker *time.Ticker){