1

udp_ocr_conter/main.go

@@ -288,7 +288,9 @@ func processUdpMsg(act byte, data []byte, ra *net.UDPAddr) {
 			return
 		}
 		config.Sys.Lock()
-		datas := mongodb.Find("ocr_task", bson.M{"isrun":"run"}, `{"_id":1}`, nil, false, -1, -1)
+		datas := mongodb.Find("ocr_task", bson.M{"isrun":bson.M{
+			"$ne":"stop",
+		}}, `{"_id":1}`, nil, false, -1, -1)
 		if len(*datas) == 0 {
 			go config.Udpclient.WriteUdp([]byte("没有新数据"), mu.OP_TYPE_DATA, ra)
 			config.Sys.Unlock()

udp_ocr_conter/src/corntask/task_corn.go

@@ -36,7 +36,9 @@ var Auto = func() {
 			}
 		}
 	}
-	taskArr := mongodb.Find("ocr_task", bson.M{}, `{_id:1}`, nil, false, -1, -1)
+	taskArr := mongodb.Find("ocr_task", bson.M{"isrun":bson.M{
+		"$ne":"stop",
+	}}, `{_id:1}`, nil, false, -1, -1)
 	taskNum := len(*taskArr)
 	log.Println("当前任务数量：", taskNum)
 	//if taskNum <= 0 {
@@ -190,7 +192,9 @@ func DynamicTask() {
 }
 func compute() int {
 	nowtime := time.Now().Unix()
-	taskArrase := mongodb.Find("ocr_task", bson.M{}, `{_id:1}`, nil, false, -1, -1)
+	taskArrase := mongodb.Find("ocr_task", bson.M{"isrun":bson.M{
+		"$ne":"stop",
+	}}, `{_id:1}`, nil, false, -1, -1)
 	if taskArrase == nil || len(*taskArrase) == 0 {
 		log.Println(464, "nil ro len(*taskArrase) == 0")
 		return 0

udp_ocr_conter/src/info/taskinfo.go

@@ -13,7 +13,12 @@ import (
 func QueryInfo() map[string]interface{} {
 	now := time.Now()
 	data := make(map[string]interface{})
-	taskArr := mongodb.Find("ocr_task", bson.M{}, `{_id:1}`, nil, false, -1, -1)
+	config.Sys.Lock()
+	data["isrun"] = config.IsRun
+	config.Sys.Unlock()
+	taskArr := mongodb.Find("ocr_task", bson.M{"isrun":bson.M{
+		"$ne":"stop",
+	}}, `{_id:1}`, nil, false, -1, -1)
 	taskNum := len(*taskArr)
 	if taskNum == 0 {
 		return data
@@ -66,8 +71,5 @@ func QueryInfo() map[string]interface{} {
 	data["esc"] = fmt.Sprint(3 ,"+", len(cluster.CID))
 	data["resultInfos"] = resultInfos
 	//log.Println(resultInfos)
-	config.Sys.Lock()
-	data["isrun"] = config.IsRun
-	config.Sys.Unlock()
 	return data
 }