From 69a44e03958e215b6d90b89576f79ac445c01355 Mon Sep 17 00:00:00 2001
From: panlei <2799247126@qq.com>
Date: 星期四, 11 七月 2019 11:18:44 +0800
Subject: [PATCH] 更新cache，比对，和定时器
---
go.sum | 2 +
go.mod | 2
ruleserver/ruleToformula.go | 51 +++++++++++++++++--------
ruleserver/timeTicker.go | 31 ---------------
4 files changed, 38 insertions(+), 48 deletions(-)
diff --git a/go.mod b/go.mod
index 058c38f..1b5d605 100644
--- a/go.mod
+++ b/go.mod
@@ -4,7 +4,7 @@
require (
basic.com/dbapi.git v0.0.0-20190701055817-73bca225181f
- basic.com/pubsub/cache.git v0.0.0-20190710092005-5d7ea0a4cbbc
+ basic.com/pubsub/cache.git v0.0.0-20190711020946-ac4bfc72bf9c
basic.com/pubsub/protomsg.git v0.0.0-20190709070734-b34c868adcc2
basic.com/valib/deliver.git v0.0.0-20190531095353-25d8c3b20051
basic.com/valib/gopherdiscovery.git v0.0.0-20190605034340-15d89d8b4e28
diff --git a/go.sum b/go.sum
index 1f6db53..7f05d2e 100644
--- a/go.sum
+++ b/go.sum
@@ -4,6 +4,8 @@
basic.com/pubsub/cache.git v0.0.0-20190708074039-d25f504c5fab/go.mod h1:gHLJZz2ee1cGL0X0ae69fs56bAxkDgEQwDhhXZJNUcY=
basic.com/pubsub/cache.git v0.0.0-20190710092005-5d7ea0a4cbbc h1:WLWAYTyMflMnuO31RBCGJizG6Cx+xF0IRECpSNgvghs=
basic.com/pubsub/cache.git v0.0.0-20190710092005-5d7ea0a4cbbc/go.mod h1:gHLJZz2ee1cGL0X0ae69fs56bAxkDgEQwDhhXZJNUcY=
+basic.com/pubsub/cache.git v0.0.0-20190711020946-ac4bfc72bf9c h1:Gvhzx2JB97gHX9800NSzpUTNlcq5eJyo/EWAnzH6c6Y=
+basic.com/pubsub/cache.git v0.0.0-20190711020946-ac4bfc72bf9c/go.mod h1:gHLJZz2ee1cGL0X0ae69fs56bAxkDgEQwDhhXZJNUcY=
basic.com/pubsub/protomsg.git v0.0.0-20190708093242-02e81455712c h1:p6bCit0NDQvC9ziK9Zf815LXgTYWxjr4mn99gcdehyk=
basic.com/pubsub/protomsg.git v0.0.0-20190708093242-02e81455712c/go.mod h1:un5NV5VWQoblVLZfx1Rt5vyLgwR0jI92d3VJhfrJhWU=
basic.com/pubsub/protomsg.git v0.0.0-20190709070734-b34c868adcc2 h1:ygh9CQPS48KmXv+PNUrOcrMqIiDZOs11apnQdu9oGEY=
diff --git a/ruleserver/ruleToformula.go b/ruleserver/ruleToformula.go
index 1f0cc05..d4aab7e 100644
--- a/ruleserver/ruleToformula.go
+++ b/ruleserver/ruleToformula.go
@@ -247,7 +247,7 @@
if groupRule.Rules[j].SdkId == "812b674b-2375-4589-919a-5c1c3278a972" {
for _, sdkData := range args.Sdkdata {
if sdkData.IpcId == "A8B73405-373D-4F23-CED2-A617EBD7EC55" { // 鎼滅储鍒颁汉鑴告娴嬬殑sdkdata 鐜板湪鍏充簬浜鸿劯鐨勫彧鏈変粬涓�涓猻dk锛屽叏鎵句粬
- logger.Info("============================================绗竴鍏�")
+ logger.Info("============================================绗竴鍏�")
for _, areaMap := range sdkData.AreaMapList {
// 鎷垮尯鍩熶腑姣忎釜浜鸿劯鐗瑰緛鍊煎幓瀵规瘮锛屽～鍏呭叾liker
if groupRule.Rules[j].PolygonId == areaMap.areaId {
@@ -259,14 +259,14 @@
if err1 != nil {
logger.Error("getBaseInfo瑙ｅ帇閿欒", err1)
}
- logger.Info("----------------------------------------map鏄�",m)
+ logger.Info("----------------------------------------map鏄�", m)
for key, val := range m {
- logger.Info("_______________________________________瀵规瘮搴撶殑杩斿洖鍊�",key,val)
+ logger.Info("_______________________________________瀵规瘮搴撶殑杩斿洖鍊�", key, val)
baseinfo, err1 := esutil.Dbpersoninfosbyid(key)
if err1 != nil {
logger.Error("鏌ヨ搴曞簱浜哄憳淇℃伅鍑洪敊", err1)
}
- baseinfo.CompareScore = val
+ baseinfo.CompareScore = val * 100
arg.Liker = append(arg.Liker, &baseinfo)
}
}
@@ -304,7 +304,7 @@
logger.Error("姣斿瑙勫垯鏈夎", err.(string))
}
}()
- logger.Info("+++++++++++瑙勫垯寮�濮嬭繍琛�+++++++++++++++++褰撳墠瑙勫垯--锛�", *groupRule)
+ logger.Info("+++++++++++瑙勫垯寮�濮嬭繍琛�+++++++++++++++++褰撳墠澶ц鍒�--锛�", *groupRule)
Compare(args, groupRule)
resultSplice := []*LittleRuleResult{}
sdkNames := ""
@@ -393,7 +393,8 @@
ipcId := sdk.IpcId
if ipcId == sdkData.IpcId {
for _, areaMap := range sdkData.AreaMapList {
- duration(groupRule.Rules[j], &areaMap, args)
+ // 鍘诲紑鍚竴涓畾鏃跺櫒
+ duration(groupRule.Rules[j], groupRule.GroupId, &areaMap, args)
}
}
}
@@ -429,7 +430,7 @@
// 缁欒繖甯ф暟鎹墦涓婅鍒欑粍鏍囩
//args.RuleResult = append(args.RuleResult, Result{TaskId: taskId, RuleGroupId: groupRule.GroupId})
for k, timeEle := range TimeEleList {
- if strings.Contains(k, taskId) {
+ if strings.Contains(k, groupRule.GroupId) {
timeEle.N = timeEle.InitN // 閲嶇疆瀹氭椂鍣�
}
}
@@ -438,16 +439,15 @@
} else {
// 鍒ゆ柇鎸佺画鏃堕棿鏉′欢锛屽幓鐪嬫睜瀛愰噷鏄惁鏈変笌鏈抚鏁版嵁鏈夊叧鐨勫畾鏃跺櫒锛屽鏋滄湁锛岀湅姝ゆ椂鏄惁璧板埌0锛屾病鏈夋瀹氭椂鍣ㄦ垨鏈夊畾鏃跺櫒璧板埌0鐨勮瘽杩斿洖鎴愬姛鎶ヨ
var flag bool = true
- logger.Info("flag 鏄細",flag)
for k, timeEle := range TimeEleList {
- if strings.Contains(k, taskId) {
- if timeEle.N != 0 { // 璺熻繖涓换鍔℃湁鍏崇殑瀹氭椂鍣ㄨ鍏ㄩ儴绛変簬0
+ if strings.Contains(k, groupRule.GroupId) {
+ if timeEle.N != 0 { // 杩欑粍瑙勫垯鐨勫畾鏃跺櫒瑕佸叏閮ㄧ瓑浜�0
logger.Info("鈥斺�斺�斺�斺�斺�斺�斺�斺�斺�斺��-------------涓嶅啢锛屼綘鏄瀹氭椂鍣ㄦ墦璐ョ殑锛�")
flag = false
}
}
}
- if true {
+ if flag {
// 鏈�鍚庢垚鍔熸姤璀︽墠鎶婄鍚堟潯浠剁殑浜鸿劯鏁版嵁濉炶繘缁撴灉鏍囩閲�
// 閰嶄簡浜鸿劯鐨勭畻娉曟墠鎶婁汉鑴哥殑鏁版嵁鐢╁嚭鏉ユ墦鏍囩
logger.Info("------------------------------鏈�鍚庝竴鍏�")
@@ -493,6 +493,23 @@
} else {
return false
}
+}
+func TimerAlarm(groupId string) (int){
+ var flagTime int = 0
+ for k, timeEle := range TimeEleList {
+ if strings.Contains(k, groupId) {
+ if timeEle.N == 0 && !timeEle.AlarmFlag { // 杩欑粍瑙勫垯鐨勫畾鏃跺櫒瑕佸叏閮ㄧ瓑浜�0 鏆備笖璁や负涓�缁勮鍒欏彧鏈変竴涓畾鏃跺櫒
+ logger.Info("鈥斺�斺�斺�斺�斺�斺�斺�斺�斺�斺��-------------棣栨绗﹀悎鎸佺画鏃堕棿瑙勫垯骞舵姤璀�")
+ flagTime = 1
+ timeEle.AlarmFlag = true
+ }
+ if timeEle.N == 0 && timeEle.AlarmFlag {
+ logger.Info("-------------------------绗﹀悎鎸佺画鏃堕棿瑙勫垯浣嗗苟涓嶆槸棣栨锛屼笉鎶ヨ")
+ flagTime = 2
+ }
+ }
+ }
+ return flagTime
}
func putFaceToResult(am *AreaMap) []Arg {
@@ -797,14 +814,14 @@
}
}
-// 閮借繃婊ゅ畬鏉′欢涔嬪悗鐪嬬湅鏄惁婊¤冻鎸佺画鏃堕棿鏉′欢
-func duration(rule *protomsg.Rule, am *AreaMap, args *SdkDatas) {
+// 濡傛灉鏈夋寔缁椂闂存潯浠剁淮鎶ゅ紑鍚竴涓畾鏃跺櫒
+func duration(rule *protomsg.Rule, groupId string, am *AreaMap, args *SdkDatas) {
if rule.PolygonId == am.areaId { // 棣栧厛瑙勫垯鎵�瀵瑰簲鐨勫尯鍩焛d瑕佽窡鍖哄煙鏁版嵁鐨刬d瀵圭殑涓� 閰嶇疆鐨勭畻娉曡瀵圭殑涓�
if rule.SdkArgAlias == "duration" { //
// 鍏堢湅鐪嬪畾鏃跺櫒鍏冪礌闃熷垪涓槸鍚︽湁杩欎釜鎽勫儚鏈鸿繖涓尯鍩熺殑瀹氭椂鍣�,濡傛灉鏈夊氨涓嶈兘鍐嶆鍒涘缓浜�
var flag bool = true
- for k,_ := range TimeEleList {
- if k == am.taskId+" "+am.sdkId+" "+am.areaId {
+ for k, _ := range TimeEleList {
+ if k == groupId+" "+rule.Id {
flag = false // 鏈夊氨缃负false
logger.Info("鏈夎繖涓畾鏃跺櫒锛屼笉鍐嶅垱寤轰簡锛�")
}
@@ -812,9 +829,9 @@
if flag {
timeLength, _ := strconv.Atoi(rule.SdkArgValue)
- timeEle := TimeElement{N: timeLength, InitN: timeLength, AlarmFlag: false, CacheSdkData: *args} // 鎵旇繘鍘讳竴涓畾鏃跺櫒鍏冪礌
+ timeEle := TimeElement{N: timeLength, InitN: timeLength, AlarmFlag: false, CacheSdkData: *args} // 鎵旇繘鍘讳竴涓畾鏃跺櫒鍏冪礌锛堝苟缂撳瓨褰撳墠鐢婚潰甯ф暟鎹級
//TimeEleList = make(map[string]timeElement)
- TimeEleList[am.taskId+" "+am.sdkId+" "+am.areaId] = &timeEle // 瀹氭椂鍣ㄥ厓绱犱互鎽勫儚鏈篿d鎷兼帴鍖哄煙id涓洪敭
+ TimeEleList[groupId+" "+rule.Id] = &timeEle // 瀹氭椂鍣ㄥ厓绱犱互鎽勫儚鏈篿d鎷兼帴鍖哄煙id涓洪敭
logger.Info("鍒涘缓浜嗚鏁板櫒骞朵笖璁℃暟鍣ㄩ泦鍚堜负锛�", TimeEleList)
}
}
diff --git a/ruleserver/timeTicker.go b/ruleserver/timeTicker.go
index cd6ad55..4b88b14 100644
--- a/ruleserver/timeTicker.go
+++ b/ruleserver/timeTicker.go
@@ -46,7 +46,7 @@
logger.Info("-------------------------------------鎵撳嵃瀹氭椂鍣ㄥ厓绱犲綋鍓嶅��-----------------------------------------锛�", timeEle.N)
}
if timeEle.GroupId != "" && timeEle.N == 0{
- // 璇存槑鏄仈鍔ㄤ换鍔＄殑鏃堕棿绐楀彛 鍒扮偣鍎夸簡璇ラ攢姣佷簡,鍐嶆潵浜嗗啀寮�鍚�
+ // 璇存槑鏄仈鍔ㄤ换鍔＄殑鏃堕棿绐楀彛 鍒扮偣鍎夸簡璇ラ攢姣佷簡,鍐嶆潵浜嗗啀鍒涘缓
delete(TimeEleList,k)
}
}
@@ -65,35 +65,6 @@
TimeTicker()
}
-// 瀹氭椂鍣ㄥ崟鍏� 搴熷純鐗堟湰
-// func TimeTicker() chan bool {
-// logger.Info("鎵ц浜唗imeTicker")
-// ticker := time.NewTicker(1 * time.Second)
-// stopChan := make(chan bool)
-// go func(ticker *time.Ticker) {
-// defer ticker.Stop()
-// for {
-// select {
-// case <-ticker.C:
-// //logger.Info("鎵ц鍗曞厓", "璁℃暟鍣ㄩ泦鍚�2", TimeEleList)
-// for k, timeEle := range TimeEleList {
-// timeEle.n = timeEle.n - 1
-// //logger.Info("閬嶅巻鐨勬暟鍊�", TimeEleList)
-// if timeEle.n == 0 {
-// // do something alarm
-// alarm(k, timeEle)
-// }
-// }
-// case stop := <-stopChan:
-// if stop {
-// logger.Info("瀹氭椂鍣ㄧ粨鏉�")
-// return
-// }
-// }
-// }
-// }(ticker)
-// return stopChan
-// }
// 缁撴瀯浣撴牴鎹煇瀛楁鎺掑簭
type SubList []*RuleResult
--
Gitblit v1.8.0