mongo.go 4.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171
  1. package data
  2. import (
  3. "context"
  4. "encoding/json"
  5. "fmt"
  6. "github.com/mark3labs/mcp-go/mcp"
  7. "github.com/mark3labs/mcp-go/server"
  8. "go.mongodb.org/mongo-driver/bson"
  9. "go.mongodb.org/mongo-driver/mongo/options"
  10. "fwh-toolbox-server/cmd/mcp/tools/helper"
  11. "fwh-toolbox-server/database"
  12. )
  13. // mongoAllowedCollections 允许查询的 collection 白名单
  14. var mongoAllowedCollections = []string{
  15. // 站点信息管理
  16. "SiteInfoManageData",
  17. "SiteInfoManageRecord",
  18. // SIM卡管理
  19. "SimCardManage",
  20. "SimCardMonthlyData",
  21. // 批量下载
  22. "BatchDownloadConfig",
  23. // 站点分析
  24. "SiteAnalysisConfig",
  25. // 统计
  26. "StatisticsShutdown",
  27. "StatisticsAlarm",
  28. // 站点监控
  29. "SiteMonitorConfig",
  30. // 用户配置
  31. "UserInfo",
  32. // 自动升级
  33. "AutoUpdateConfigOption",
  34. "AutoUpdateConfig",
  35. // AI会话
  36. "AiChatSessions",
  37. }
  38. func registerMongoTools(s *server.MCPServer) {
  39. s.AddTool(
  40. mcp.NewTool("data_mongo_find",
  41. mcp.WithDescription("直接查询 MongoDB 集合数据(只读)。用于 service 层无法满足的灵活查询场景。"),
  42. mcp.WithString("collection", mcp.Required(), mcp.Description(
  43. fmt.Sprintf("集合名,可选值: %v", mongoAllowedCollections),
  44. )),
  45. mcp.WithString("filter", mcp.Description("查询条件,JSON 格式的 MongoDB filter(如 {\"sn\": \"xxx\"}),不传则查全部")),
  46. mcp.WithNumber("limit", mcp.Description("返回数量限制,默认10,最大100")),
  47. mcp.WithNumber("skip", mcp.Description("跳过数量(分页偏移),默认0")),
  48. mcp.WithString("sort", mcp.Description("排序条件,JSON 格式(如 {\"createdAt\": -1})")),
  49. ),
  50. handleMongoFind,
  51. )
  52. s.AddTool(
  53. mcp.NewTool("data_mongo_count",
  54. mcp.WithDescription("统计 MongoDB 集合中符合条件的文档数量"),
  55. mcp.WithString("collection", mcp.Required(), mcp.Description(
  56. fmt.Sprintf("集合名,可选值: %v", mongoAllowedCollections),
  57. )),
  58. mcp.WithString("filter", mcp.Description("查询条件,JSON 格式的 MongoDB filter,不传则统计全部")),
  59. ),
  60. handleMongoCount,
  61. )
  62. }
  63. func handleMongoFind(ctx context.Context, req mcp.CallToolRequest) (*mcp.CallToolResult, error) {
  64. collection, err := req.RequireString("collection")
  65. if err != nil {
  66. return helper.ParamError("collection"), nil
  67. }
  68. if !isAllowedCollection(collection) {
  69. return helper.ParamInvalidError("collection", fmt.Sprintf("不允许查询此集合,可选: %v", mongoAllowedCollections)), nil
  70. }
  71. // 解析 filter
  72. filterStr := req.GetString("filter", "{}")
  73. var filter bson.M
  74. if err := json.Unmarshal([]byte(filterStr), &filter); err != nil {
  75. return helper.ParamInvalidError("filter", fmt.Sprintf("JSON 解析失败: %v", err)), nil
  76. }
  77. // limit
  78. limit := int64(req.GetFloat("limit", 10))
  79. if limit > 100 {
  80. limit = 100
  81. }
  82. if limit < 1 {
  83. limit = 10
  84. }
  85. // skip
  86. skip := int64(req.GetFloat("skip", 0))
  87. if skip < 0 {
  88. skip = 0
  89. }
  90. // sort
  91. var sort bson.M
  92. sortStr := req.GetString("sort", "")
  93. if sortStr != "" {
  94. if err := json.Unmarshal([]byte(sortStr), &sort); err != nil {
  95. return helper.ParamInvalidError("sort", fmt.Sprintf("JSON 解析失败: %v", err)), nil
  96. }
  97. }
  98. // 查询
  99. coll := database.GetCollection(collection)
  100. findOpts := options.Find().SetLimit(limit).SetSkip(skip)
  101. if sort != nil {
  102. findOpts.SetSort(sort)
  103. }
  104. cursor, err := coll.Find(ctx, filter, findOpts)
  105. if err != nil {
  106. return helper.ServiceError("MongoDB查询", err), nil
  107. }
  108. defer cursor.Close(ctx)
  109. var results []bson.M
  110. if err := cursor.All(ctx, &results); err != nil {
  111. return helper.ServiceError("读取MongoDB结果", err), nil
  112. }
  113. if len(results) == 0 {
  114. return helper.EmptyResult("查询结果为空"), nil
  115. }
  116. return helper.JSONResult(results), nil
  117. }
  118. func handleMongoCount(ctx context.Context, req mcp.CallToolRequest) (*mcp.CallToolResult, error) {
  119. collection, err := req.RequireString("collection")
  120. if err != nil {
  121. return helper.ParamError("collection"), nil
  122. }
  123. if !isAllowedCollection(collection) {
  124. return helper.ParamInvalidError("collection", fmt.Sprintf("不允许查询此集合,可选: %v", mongoAllowedCollections)), nil
  125. }
  126. filterStr := req.GetString("filter", "{}")
  127. var filter bson.M
  128. if err := json.Unmarshal([]byte(filterStr), &filter); err != nil {
  129. return helper.ParamInvalidError("filter", fmt.Sprintf("JSON 解析失败: %v", err)), nil
  130. }
  131. coll := database.GetCollection(collection)
  132. count, err := coll.CountDocuments(ctx, filter)
  133. if err != nil {
  134. return helper.ServiceError("MongoDB统计", err), nil
  135. }
  136. return helper.JSONResult(map[string]any{
  137. "collection": collection,
  138. "count": count,
  139. }), nil
  140. }
  141. func isAllowedCollection(name string) bool {
  142. for _, c := range mongoAllowedCollections {
  143. if c == name {
  144. return true
  145. }
  146. }
  147. return false
  148. }