实现阈值通知消息

2026-03-10 01:05:37 +08:00 · 2021-05-05 19:50:55 +08:00
parent 63f011c6c8
commit ebdb181361
6 changed files with 293 additions and 71 deletions
--- a/internal/rpc/services/service_node_value.go
+++ b/internal/rpc/services/service_node_value.go
@@ -26,6 +26,12 @@ func (this *NodeValueService) CreateNodeValue(ctx context.Context, req *pb.Creat
 		return nil, err
 	}

+	// 触发阈值
+	err = models.SharedNodeThresholdDAO.FireNodeThreshold(tx, role, nodeId, req.Item)
+	if err != nil {
+		return nil, err
+	}
+
 	return this.Success()
 }