label重大更新

panlei

2019-07-31 573edfc65d11f80280a4f5e0db3f693b668f03d7

label重大更新

 insertdata/insertDataToEs.go

@@ -377,8 +377,8 @@
                        //logger.Warn("哈哈哈哈哈",[0].Others["linkCache"].([]ruleserver.ResultMsg))
                        InsertYolo(msg2)
                        logger.Warn("兄弟难道你陷入了死循环吗")
                        os.Exit(1)
                        linkFlag = true
                        os.Exit(1)
                    }
                }
            }

 ruleserver/ruleToformula.go

@@ -460,7 +460,19 @@
                        label["linkCache"] = append(label["linkCache"].([]ResultMsg),ruleRes.CacheData)
                    }
                    logger.Debug("联动任务缓存了几个数据",len(label["linkCache"].([]ResultMsg)))
                    //os.Exit(1)
                    for _,result := range args.RuleResult["yolo"].([]Result) {
                        if result.RuleGroupId == groupRule.GroupId {
                            result.Others["linkCache"] = label
                        }
                    }
                    for i := 0; i < len(args.RuleResult["yolo"].([]Result)); i++  {
                        if args.RuleResult["yolo"].([]Result)[i].RuleGroupId == groupRule.GroupId { // 把原来那个删掉再存一份新的
                            res := args.RuleResult["yolo"].([]Result)[i]
                            res.Others["linkCache"] = label
                            args.RuleResult["yolo"] = append(args.RuleResult["yolo"].([]Result)[:i],args.RuleResult["yolo"].([]Result)[i+1:]...)
                            args.RuleResult["yolo"] = append(args.RuleResult["yolo"].([]Result),res)
                        }
                    }
                }
            }
        } else {