循环处理

udpfileocr/main.go

@@ -63,6 +63,7 @@ func processUdpMsg(act byte, data []byte, ra *net.UDPAddr) {
 		log.Println("updocr接收数据:",mapInfo)
 		stime :=time.Now()
 		gid := strings.TrimSpace(mapInfo["gtid"].(string))
+		rgid := gid
 		lid := strings.TrimSpace(mapInfo["lteid"].(string))
 		//err = udpclient.WriteUdp([]byte("updocr接收数据成功"), mu.OP_TYPE_DATA, &net.UDPAddr{
 		//	IP:   net.ParseIP(Sysconfig["toudpip"].(string)),
@@ -111,7 +112,7 @@ func processUdpMsg(act byte, data []byte, ra *net.UDPAddr) {
 									ChanB <- true
 									if qu.ObjToString(fileinfo["fid"]) ==""{
 										<-ChanB
-										log.Println(mid, "mgo ", MgoFileFiled,"没有fid ")
+										//log.Println(mid, "mgo ", MgoFileFiled,"没有fid ")
 										continue
 									}
 									//if (strings.Contains(qu.ObjToString(fileinfo["url"]),"fs.qmx.top")|| strings.Contains(qu.ObjToString(fileinfo["url"]),"fj1.jianyu360.com"))&& (strings.TrimSpace(qu.ObjToString(fileinfo["content"]))==""||strings.Contains(qu.ObjToString(fileinfo["content"]),"error") ){
@@ -133,10 +134,9 @@ func processUdpMsg(act byte, data []byte, ra *net.UDPAddr) {
 					}
 				}
 			}
-			//识别完以后再次查询数据库，进行下一轮识别
-			log.Println("处理查询数据结束...",jsq,time.Now().Sub(stime))
+			//发送udp信号
 			by, _ := json.Marshal(map[string]interface{}{
-				"gtid":  gid,
+				"gtid":  rgid,
 				"lteid": lid,
 				"stype": "fujian",
 			})
@@ -144,9 +144,11 @@ func processUdpMsg(act byte, data []byte, ra *net.UDPAddr) {
 				IP:   net.ParseIP(Sysconfig["toudpip"].(string)),
 				Port: qu.IntAll(Sysconfig["toudpport"]),
 			})
-			//SendMail("处理完成")
+			//识别完以后再次查询数据库，进行下一轮识别
+			log.Println("处理查询数据结束...",jsq,time.Now().Sub(stime))
+			SendMail(rgid+"--->"+lid+"处理完成")
 			//进行下一轮识别
-			//forfunc(lid)
+			forfunc(lid)
 			log.Println("发送到:",Sysconfig["toudpip"].(string),Sysconfig["toudpport"],err)
 		} else {
 			log.Println("开始id或结束id参数错误:", string(data))
@@ -276,7 +278,7 @@ func SendMail( body string ) error {
 	m.SetHeader("From","Get to" + "<" + mailConn["user"] + ">")  //这种方式可以添加别名，即“XD Game”， 也可以直接用<code>m.SetHeader("From",mailConn["user"])</code> 读者可以自行实验下效果
 	m.SetHeader("To", []string{"550838476@qq.com"}...)  //发送给多个用户
 	m.SetHeader("Subject", "MongoId")  //设置邮件主题
-	m.SetBody("text/html","服务器五:"+ body)     //设置邮件正文
+	m.SetBody("text/html","服务器:"+ body)     //设置邮件正文
 
 	d := gomail.NewDialer(mailConn["host"], port, mailConn["user"], mailConn["pass"])