人工审核

udp_winner/timedTaskWinner.go

@@ -122,7 +122,7 @@ func TaskWinner(mapinfo *map[string]interface{}) {
 					//拿到合并后的qyk
 					FClient.DbName = Config["mgodb_extract_kf"]
 					oldTmp, b := FClient.FindById(Config["mgo_qyk_c"], reply, nil)
-					if !b || (*oldTmp) == nil|| reply==""||(*oldTmp)["_id"]==nil{
+					if !b || (*oldTmp) == nil || reply == "" || (*oldTmp)["_id"] == nil {
 						log.Println(redisCName, "存量 redis id 不存在", reply)
 						continue
 					}
@@ -219,6 +219,7 @@ func TaskWinner(mapinfo *map[string]interface{}) {
 	}
 
 }
+
 //增量
 func addfunc(gtid string, cursor *mgo.Iter) string {
 	//增量处理
@@ -330,7 +331,7 @@ func addfunc(gtid string, cursor *mgo.Iter) string {
 			vvv["updatetime"] = time.Now().Unix()
 			contactMaps = append(contactMaps, vvv)
 			//分包处理
-			PackageDealWith(&contactMaps,tmp)
+			PackageDealWith(&contactMaps, tmp)
 			(*oldTmp)["contact"] = contactMaps
 			//mongo更新
 			(*oldTmp)["updatatime"] = time.Now().Unix()
@@ -392,8 +393,8 @@ func TimedTaskWinner() {
 					if _, err := redis.String(rdb.Do("GET", errwinner)); err == nil {
 						//redis存在发送udp进行处理
 						TaskWinner(&map[string]interface{}{
-							"gtid":      tmpId,
-							"lteid":     tmpId,
+							"gtid":  tmpId,
+							"lteid": tmpId,
 						})
 						//存在的话删除tmp mongo表
 						FClient.DbName = Config["mgodb_extract_kf"]
@@ -417,17 +418,31 @@ func TimedTaskWinner() {
 						//log.Println(r)
 						//人工审核正则
 						var isok bool
+						//先遍历ok
 						for _, v := range WinnerRegOk {
 							isok = v.MatchString(errwinner)
 							if isok {
-								tmp["winner_ok"] = 1
-								break
+								//匹配ok完,匹配err
+								for _, vRegErr := range WinnerRegErr {
+									isok = vRegErr.MatchString(errwinner)
+									//匹配到ok 也匹配到err 按err算
+									if isok {
+										tmp["winner_err"] = 1
+										break
+									}
+								}
+								//匹配ok，没匹配err 按ok算
+								if tmp["winner_err"] == nil {
+									tmp["winner_ok"] = 1
+									break
+								}
 							}
 						}
-						if tmp["winner_ok"] == nil {
+						//都没匹配
+						if tmp["winner_ok"] == nil  && tmp["winner_err"] == nil{
 							tmp["winner_err"] = 1
+							break
 						}
-
 						//匹配不到原始库,存入异常表删除临时表
 						FClient.DbName = Config["mgodb_extract_kf"]
 						if err := FClient.SaveForOld("winner_err", tmp); err != nil {
@@ -655,6 +670,6 @@ func TimedTaskWinner() {
 }
 
 //分包处理
-func PackageDealWith(contactMaps *[]interface{},tmp map[string]interface{})  {
-	
+func PackageDealWith(contactMaps *[]interface{}, tmp map[string]interface{}) {
+
 }