From 5ab130b3312dbe8aa9761f1c1587cc428384a1f4 Mon Sep 17 00:00:00 2001
From: sunty <1172534965@qq.com>
Date: 星期四, 30 五月 2024 10:08:19 +0800
Subject: [PATCH] 新增空字段判断

---
 db/elastic.go |   16 +++++++++-------
 1 files changed, 9 insertions(+), 7 deletions(-)

diff --git a/db/elastic.go b/db/elastic.go
index a215726..de9734d 100644
--- a/db/elastic.go
+++ b/db/elastic.go
@@ -133,13 +133,15 @@
 			rSource := rSourceInfo["_source"].(map[string]interface{})
 			//濡傛灉璇ュぉ鏈�鍚庝竴鏉″凡缁忛璀﹁繃杩涘嚭寮傚父锛屽皢杩囨护鎺変笉鍐嶉璀�
 			alarmFlag := false
-			alarmRules := rSource["alarmRules"].([]interface{})
-			for _, alarmRule := range alarmRules {
-				ruleId := alarmRule.(map[string]interface{})["ruleId"].(string)
-				//fmt.Println("ruleId", ruleId,rSource["documentNumber"].(string),rSource["id"].(string))
-				if ruleId == "4" {
-					alarmFlag = true
-					break
+			if rSource["alarmRules"] != nil {
+				alarmRules := rSource["alarmRules"].([]interface{})
+				for _, alarmRule := range alarmRules {
+					ruleId := alarmRule.(map[string]interface{})["ruleId"].(string)
+					//fmt.Println("ruleId", ruleId,rSource["documentNumber"].(string),rSource["id"].(string))
+					if ruleId == "4" {
+						alarmFlag = true
+						break
+					}
 				}
 			}
 			if alarmFlag == true {

--
Gitblit v1.8.0