db.idm.query

执行数据库聚合查询获取数据

• 请求路由: db.idm.query
• 交互模型: Request Stream
• 访问限制: SPI

请求

RSocket.rs({
  "route" : "db.idm.query",
  "args" : {
    "collection" : "payTransaction",
    "query" : {
      "payResult.subOrders.psInfo.finished" : true
    },
    "fields" : {
      "payResult" : 1
    },
    "pg" : {
      "sort" : [
        "crDate;desc"
      ]
    }
  }
});

请求参数

名称	类型	必须	说明
collection	String	否	集合名称
query	Object	否	查询语句
fields	Object	否	返回字段语句
pg	Object	否	分页参数
pg.page	Number	否	页码，首页从0开始
pg.size	Number	否	每页记录，默认为10
pg.sort	String[]	否	排序字段清单，默认为升序，需要指定降序时在字段名后面添加desc并用分号隔开。 例如：["id", "crDate;desc"]

返回

查询结果

[
  {
    "_id" : "CCO202312111515443125",
    "payResult" : {
      "outTradeNo" : "CCO202312111515443125",
      "subOrders" : [
        {
          "subMchName" : "三地通承运商001",
          "psInfo" : {
            "split" : true,
            "finished" : true,
            "finishTime" : "2023-12-11T14:02:41.561+00:00",
            "unfreezeNo" : "PSR202312112202601",
            "unfreezeErrMsg" : ""
          }
        }
      ]
    }
  },
  {
    "_id" : "CCO202312111452373124",
    "payResult" : {
      "subOrders" : [
        {
          "outTradeNo" : "CCO202312111452373124",
          "subMchName" : "三地通承运商001",
          "psInfo" : {
            "split" : true,
            "finished" : true,
            "finishTime" : "2023-12-11T14:02:41.539+00:00",
            "unfreezeNo" : "PSR202312112202599",
            "unfreezeErrMsg" : ""
          }
        }
      ]
    }
  }
]