mock

v2.0/mockServer/sdk/BaseDao.js

@@ -4,7 +4,7 @@ const { CURD_REQUEST } = require('./request')
 
 class BaseDao {
   constructor(context, dbName) {
-    this.db = context.db
+    this.consumeId = context.consumeId
     this.TABLE = dbName
   }
   /**
@@ -14,7 +14,7 @@ class BaseDao {
    */
   async findOne(query, options) {
     let result = await CURD_REQUEST({
-      db: this.db,
+      consumeId: this.consumeId,
       TABLE: this.TABLE,
       type: `find`,
       query: query || {},
@@ -28,9 +28,9 @@ class BaseDao {
    * @param options
    */
   async find(query, options) {
-    console.log(`db`, this.db)
+    console.log(`consumeId`, this.consumeId)
     let result = await CURD_REQUEST({
-      db: this.db,
+      consumeId: this.consumeId,
       TABLE: this.TABLE,
       type: `find`,
       query: query || {},
@@ -45,7 +45,7 @@ class BaseDao {
    */
   async insertOne(document) {
     console.log(`insertOne`, document)
-    let result = await CURD_REQUEST({ db: this.db, TABLE: this.TABLE, type: `insert`, document: document || {} })
+    let result = await CURD_REQUEST({ consumeId: this.consumeId, TABLE: this.TABLE, type: `insert`, document: document || {} })
     return result._id || result.inertId || result
   }
 
@@ -54,7 +54,7 @@ class BaseDao {
    * @param documents 插入对象
    */
   async insertMany(documents) {
-    let result = await CURD_REQUEST({ db: this.db, TABLE: this.TABLE, type: `insert`, document: documents || [{}] })
+    let result = await CURD_REQUEST({ consumeId: this.consumeId, TABLE: this.TABLE, type: `insert`, document: documents || [{}] })
     return result
   }
 
@@ -65,7 +65,7 @@ class BaseDao {
    */
   async update(query, options) {
     let result = await CURD_REQUEST({
-      db: this.db,
+      consumeId: this.consumeId,
       TABLE: this.TABLE,
       type: `update`,
       query: query || {},
@@ -84,7 +84,7 @@ class BaseDao {
    */
   async delete(query, options) {
     let result = await CURD_REQUEST({
-      db: this.db,
+      consumeId: this.consumeId,
       TABLE: this.TABLE,
       type: `delete`,
       query: query || {},
@@ -100,7 +100,7 @@ class BaseDao {
    */
   async count(query, options) {
     let result = await CURD_REQUEST({
-      db: this.db,
+      consumeId: this.consumeId,
       TABLE: this.TABLE,
       type: `count`,
       query: query || {},
@@ -116,7 +116,7 @@ class BaseDao {
    */
   async aggregate(query) {
     let result = await CURD_REQUEST({
-      db: this.db,
+      consumeId: this.consumeId,
       TABLE: this.TABLE,
       type: `aggregate`,
       query: query || {}

v2.0/mockServer/sdk/request.js

@@ -16,10 +16,10 @@ const request = async (path, params) => {
   return res.data.data
 }
 
-const CURD_REQUEST = async ({ db, TABLE, type, query, options, document }) => {
+const CURD_REQUEST = async ({ consumeId, TABLE, type, query, options, document }) => {
   // 参数
   let data = {
-    dbName: db,
+    consumeId,
     TABLE,
     query,
     options,
@@ -30,15 +30,15 @@ const CURD_REQUEST = async ({ db, TABLE, type, query, options, document }) => {
   return await request(path, data)
 }
 
-const TBAPI_REQUEST = async (db, funName, query) => {
+const TBAPI_REQUEST = async (consumeId, funName, query) => {
   // 参数
   let data = {
-    dbName: db,
+    consumeId,
     funName
   }
   let path = `/proxy/dataMock/tbapi`
   let params = {
-    dbName: data.dbName,
+    consumeId,
     funName: data.funName,
     query
   }

v2.0/mockServer/server.js

@@ -24,9 +24,9 @@ app.get('/', (req, res) => {
 // 执行本地云函数方法
 app.post('/handler', async (req, res) => {
   console.log(req.body)
-  let { data, openId, db } = req.body
-  if (!db) {
-    res.json({ message: `参数错误,缺少数据库db` })
+  let { data, openId, consumeId } = req.body
+  if (!consumeId) {
+    res.json({ message: `参数错误,缺少consumeId` })
   }
   if (!openId) {
     res.json({ message: `参数错误,缺少openId` })
@@ -43,12 +43,9 @@ app.post('/handler', async (req, res) => {
   if (!queryData) {
     res.json({ message: `格式错误, data参数不能为空` })
   }
-  if (!process.db) {
-    process.db = db
-  }
   req.context = {
     openId,
-    db,
+    consumeId,
     env: 'mock',
     data: queryData,
     handler

v2.0/src/typings/index.d.ts

@@ -9,7 +9,7 @@ interface IContext<T> {
   accessToken: string
   openId: string
   env: string
-  db: any
+  consumeId: any
   traceId: string
   fcName: string
   handler: string