feat:对接了strapi 接口

server/routers/anki/employee.mjs

@@ -1,173 +0,0 @@
-import cuid from "cuid";
-// import getDb from "../dbServer.mjs";
-import _ from "lodash";
-
-import { getDb } from "funjia-server/lib/funjia-server.mjs";
-const getEmployee = (router) => {
-
-    router.post('/api/employee/list', async (ctx) => {
-        // 设置头类型, 如果不设置，会直接下载该页面
-        ctx.type = 'application/json';
-        const db = await getDb();
-        const body = ctx.request.body;
-        const data = db.data?.employee?.filter((item) => {
-            let isMatch = true;
-            for (let field in body) {
-                if (["page", "pageSize"].includes(field)) {
-                    continue;
-                }
-
-                if (typeof (item[field]) == "string") {
-                    isMatch = item[field]?.indexOf?.(body[field]) > -1;
-                } else if (typeof (item[field]) == "number") {
-                    isMatch = item[field] == body[field];
-                }
-                if (!isMatch)
-                    break;
-            }
-            return isMatch;
-        });
-
-        const {
-            page,
-            pageSize
-        } = body;
-        let batchData = data;
-        if (page && pageSize) {
-            batchData = data.slice((page - 1) * pageSize, page * pageSize);
-        }
-
-        ctx.body = {
-            code: 0,
-            data: batchData || [],
-            total: data.length
-        };
-    });
-
-    router.get('/api/employee', async (ctx) => {
-        // 设置头类型, 如果不设置，会直接下载该页面
-        ctx.type = 'application/json';
-        const db = await getDb();
-        const data = db.data.employee;
-        const query = ctx.request.query;
-        console.log("参数：", query, ctx.request.body, ctx.query);
-        let detail = {};
-        if (query.id && data) {
-            detail = data.find((item) => {
-                return item.id == query.id;
-            });
-        }
-
-        ctx.body = {
-            code: 0,
-            data: detail || {}
-        };
-    });
-
-    router.post('/api/employee/add', async (ctx) => {
-        ctx.type = 'application/json';
-        const db = await getDb();
-
-        // You can also use this syntax if you prefer
-        if (!db.data?.employee)
-            db.data.employee = [];
-        const {
-            employee
-        } = db.data;
-        const data = ctx.request.body;
-        console.log("add:", data);
-        data.id = cuid();
-        data.createTime = new Date();
-        employee.push(data)
-        // Write db.data content to db.json
-        await db.write()
-
-        ctx.body = {
-            code: 0,
-        };
-    });
-
-    router.post('/api/employee/upd', async (ctx) => {
-        ctx.type = 'application/json';
-        const db = await getDb();
-
-        // You can also use this syntax if you prefer
-        if (!db.data?.employee)
-            db.data = {
-                employee: []
-            }
-        const {
-            employee
-        } = db.data;
-        const data = ctx.request.body;
-        const id = data.id;
-        console.log("数据Id：", id);
-        if (id && employee) {
-            const currentDetail = employee.find(item => item.id == id);
-            if (currentDetail) {
-                _.merge(currentDetail, data);
-            }
-            // Write db.data content to db.json
-            await db.write()
-        }
-
-        ctx.body = {
-            code: 0,
-        };
-    });
-
-    router.post('/api/employee/delete', async (ctx) => {
-        ctx.type = 'application/json';
-        const db = await getDb();
-
-        // You can also use this syntax if you prefer
-        if (!db.data?.employee)
-            db.data = {
-                employee: []
-            }
-        let {
-            employee
-        } = db.data;
-        const data = ctx.request.body;
-        const ids = data.ids;
-        if (ids?.length > 0 && employee) {
-            let id = null;
-            for (let i = 0; i < ids.length; i++) {
-                id = ids[i];
-                const idx = employee.findIndex(item => item.id == id);
-                if (idx != -1) {
-                    employee.splice(idx, 1);
-                }
-            }
-            // Write db.data content to db.json
-            await db.write()
-        }
-
-        ctx.body = {
-            code: 0,
-        };
-    });
-
-    router.post('/api/employee/login', async (ctx) => {
-        // 设置头类型, 如果不设置，会直接下载该页面
-        ctx.type = 'application/json';
-        const db = await getDb();
-        const data = db.data.employee;
-        const params = ctx.request.body;
-        let detail = {};
-        if (data) {
-            detail = data.find((item) => {
-                return item.userName == params.userName && item.pwd == params.pwd;
-            });
-        }
-
-        const code = detail ? 0 : 1;
-
-        ctx.body = {
-            code,
-            data: detail || {}
-        };
-    });
-}
-
-export default getEmployee;

server/routers/dynamic.mjs

@@ -1,157 +1,119 @@
 import cuid from "cuid";
 // import getDb from "../dbServer.mjs";
-import {getDb} from "funjia-server/lib/funjia-server.mjs";
+import { ConfigHelper } from "funjia-server";
 import _ from "lodash";
-
+const headers = {
+    'content-type': 'application/json'
+}
 const getDynamic = (router) => {
-
+    const url = ConfigHelper.config.server.url + "/api";
     router.post('/api/dynamic/list/:tableName', async (ctx) => {
         // 设置头类型, 如果不设置，会直接下载该页面
         ctx.type = 'application/json';
-        const db = await getDb();
-        const body = ctx.request.body;
-        const data = db.data[ctx.params.tableName]?.filter((item) => {
-            let isMatch = true;
-            for (let field in body) {
-                if (["page", "pageSize"].includes(field)) {
-                    continue;
-                }
-
-                if (typeof (item[field]) == "string") {
-                    isMatch = item[field]?.indexOf?.(body[field]) > -1;
-                } else if (typeof (item[field]) == "number") {
-                    isMatch = item[field] == body[field];
-                }
-                if (!isMatch)
-                    break;
-            }
-            return isMatch;
-        });
-
-        const {
-            page,
-            pageSize
-        } = body;
-        let batchData = data;
-        if (page && pageSize) {
-            batchData = data.slice((page - 1) * pageSize, page * pageSize);
-        }
-
+        const params = ctx.params,
+            tableName = params.tableName;
+        const res = await fetch(`${url}/${_.kebabCase(tableName)}s`, {
+            headers,
+            // body:JSON.parse({})
+        })
+        const data = await res.json();
+        // console.log(data);
         ctx.body = {
             code: 0,
-            data: batchData || [],
-            total: data.length
+            data: data.data.map(item => {
+                return { ...item, id: item.documentId }
+            }),
+            total: data.meta.pagination.total
         };
     });
-
     router.get('/api/dynamic/:tableName', async (ctx) => {
         // 设置头类型, 如果不设置，会直接下载该页面
-        ctx.type = 'application/json';                
-        const db = await getDb();
-        const data = db.data[ctx.params.tableName];
-        const query = ctx.request.query;
-        console.log("参数：", query, ctx.request.body, ctx.query);
-        let detail = {};
-        if (query.id && data) {
-            detail = data.find((item) => {
-                return item.id == query.id;
-            });
-        }
-
+        ctx.type = 'application/json';
+        const params = ctx.params,
+            tableName = params.tableName,
+            query = ctx.request.query,
+            id = query.id;
+        const res = await fetch(`${url}/${_.kebabCase(tableName)}s/` + id, {
+            headers,
+            // body:JSON.parse({})
+        })
+        const data = await res.json();
+        data.data.id = data.data.documentId;
         ctx.body = {
             code: 0,
-            data: detail || {}
+            data: data.data
         };
     });
-
     router.post('/api/dynamic/add/:tableName', async (ctx) => {
-        ctx.type = 'application/json';        
-        const tableName=ctx.params.tableName;
+        ctx.type = 'application/json';
+        const tableName = ctx.params.tableName;
+        const body = ctx.request.body;
+        delete body.id;
+        delete body.documentId;
 
-        const db = await getDb();
+        const res = await fetch(`${url}/${_.kebabCase(tableName)}s`, {
+            method: "post",
+            headers,
+            body: JSON.stringify({ data: ctx.request.body })
+        });
 
-        // You can also use this syntax if you prefer
-        if (!db.data[tableName])
-            db.data[tableName] = [];
-
-        const dynamic = db.data[tableName];
-        const data = ctx.request.body;
-        console.log("add:", data);
-        data.id = cuid();
-        data.createTime = new Date();
-        dynamic.push(data)
-        // Write db.data content to db.json
-        await db.write()
+        const data = await res.json();
+        // console.log(data);
 
         ctx.body = {
             code: 0,
         };
     });
-
     router.post('/api/dynamic/upd/:tableName', async (ctx) => {
         ctx.type = 'application/json';
-        const tableName=ctx.params.tableName;
+        const tableName = ctx.params.tableName;
+        const body = ctx.request.body;
+        const documentId = body.id;// body.documentId;
+        delete body.id;
+        delete body.documentId;
+        // delete body.jsonValue;
 
-        const db = await getDb();
+        const putData = JSON.stringify({ data: body });
+        // console.log(putData, documentId, tableName,`${url}/${_.kebabCase(tableName)}s/`);
+        const res = await fetch(`${url}/${_.kebabCase(tableName)}s/` + documentId, {
+            method: "PUT",
+            headers,
+            body: putData
+        })
 
-        // You can also use this syntax if you prefer
-        if (!db.data[tableName])
-            db.data = {
-                dynamic: []
-            }
-
-        const dynamic = db.data[tableName];
-
-        const data = ctx.request.body;
-        const id = data.id;
-        console.log("数据Id：", id);
-        if (id && dynamic) {
-            const currentDetail = dynamic.find(item => item.id == id);
-            if (currentDetail) {
-                _.merge(currentDetail, data);
-            }
-            // Write db.data content to db.json
-            await db.write()
-        }
+        await res.text();
+        // const data = await res.json();
 
+        // console.log(data);
         ctx.body = {
             code: 0,
         };
     });
-
     router.post('/api/dynamic/delete/:tableName', async (ctx) => {
         ctx.type = 'application/json';
-        const tableName=ctx.params.tableName;
-
-        const db = await getDb();
-
-        // You can also use this syntax if you prefer
-        if (!db.data[tableName])
-            db.data = {
-                [tableName]: []
-            }
-
-        const dynamic = db.data[tableName];
-
+        const tableName = ctx.params.tableName;
         const data = ctx.request.body;
         const ids = data.ids;
-        if (ids?.length > 0 && dynamic) {
-            let id = null;
-            for (let i = 0; i < ids.length; i++) {
-                id = ids[i];
-                const idx = dynamic.findIndex(item => item.id == id);
-                if (idx != -1) {
-                    dynamic.splice(idx, 1);
-                }
-            }
-            // Write db.data content to db.json
-            await db.write()
+
+        for (const id of ids) {
+            await deleteData(tableName, id);
         }
 
+        ids.forEach((id) => {
+            deleteData(tableName, id);
+        })
+
         ctx.body = {
             code: 0,
         };
     });
+
+
 }
 
+const deleteData = async (tableName, id) => {
+    return fetch(`${url}/${_.kebabCase(tableName)}s/${id}`, {
+        method: "delete"
+    })
+}
 export default getDynamic;

server/routers/employee.mjs

@@ -0,0 +1,19 @@
+import _ from "lodash";
+import { ConfigHelper } from "funjia-server";
+const getEmployee = (router) => {
+    router.post('/api/employee/login', async (ctx) => {
+        const url = ConfigHelper.config.server.url + "/api";
+
+        // 设置头类型, 如果不设置，会直接下载该页面
+        ctx.type = 'application/json';
+        const params = ctx.request.body;
+
+        const res = await fetch(`${url}/employees?filters[userName][$eq]=${params.userName}&filters[pwd][$eq]=${params.pwd}`, {
+            method: 'GET'
+        })
+
+        const data = await res.json();
+        ctx.body = { code: data.data.length > 0 ? 0 : 1, data: data.data?.[0] }
+    });
+}
+export default getEmployee;

server/routers/questionAnswer.mjs

@@ -0,0 +1,142 @@
+import _ from "lodash";
+import qs from "qs";
+import { ConfigHelper } from "funjia-server";
+// https://docs.strapi.io/cms/api/graphql#filters
+const headers = {
+    'content-type': 'application/json'
+}
+
+const getQuestionAnswer = (router) => {
+    const fullUrl = ConfigHelper.config.server.url + "/api";
+
+    router.post('/api/questionAnswer/list', async (ctx) => {
+        // 设置头类型, 如果不设置，会直接下载该页面
+        ctx.type = 'application/json';
+        const params = ctx.request.body;
+
+        const url = buildUrl(`${fullUrl}/question-answers`, {
+            pagination: {
+                page: params.page,
+                pageSize: params.pageSize,
+            },
+            populate: 'tags',
+            sort: "id:desc",
+            filters: params.filters
+        });
+
+        const res = await fetch(url, {
+            method: 'GET',
+        })
+
+        const data = await res.json(),
+            ctxData = data.data.map(item => {
+                return { ...item, id: item.documentId }
+            });
+        ctx.body = {
+            code: ctxData.length > 0 ? 0 : 1, data: ctxData,
+            total: data.meta.pagination.total
+        }
+    });
+
+    router.get('/api/questionAnswer', async (ctx) => {
+        // 设置头类型, 如果不设置，会直接下载该页面
+        ctx.type = 'application/json';
+        const params = ctx.params,
+            tableName = params.tableName,
+            query = ctx.request.query,
+            id = query.id;
+
+        const url = buildUrl(`${fullUrl}/question-answers/${id}`, {
+            populate: 'tags'
+        });
+        const res = await fetch(url, {
+            // headers,
+            // body:JSON.parse({})
+        })
+        const data = await res.json();
+        const ctxData = data.data;
+        ctxData.id = ctxData?.documentId;
+        // console.log(ctxData.tags);
+        ctxData.tags = ctxData.tags.map(item => item.documentId);
+        ctx.body = {
+            code: 0,
+            data: ctxData
+        };
+    });
+
+    router.post('/api/questionAnswer/add', async (ctx) => {
+        ctx.type = 'application/json';
+        const body = ctx.request.body;
+        delete body.id;
+        delete body.documentId;
+
+        const res = await fetch(`${fullUrl}/question-answers`, {
+            method: "post",
+            headers,
+            body: JSON.stringify({ data: ctx.request.body })
+        });
+
+        const data = await res.json();
+        // console.log(data);
+
+        ctx.body = {
+            code: 0,
+        };
+    });
+
+    router.post('/api/questionAnswer/upd', async (ctx) => {
+        ctx.type = 'application/json';
+        // const tableName = ctx.params.tableName;
+        const body = ctx.request.body;
+        const documentId = body.id;// body.documentId;
+        delete body.id;
+        delete body.documentId;
+        // delete body.tags;
+
+        const putData = JSON.stringify({ data: body });
+        // console.log(putData, documentId);
+        const res = await fetch(`${fullUrl}/question-answers/` + documentId, {
+            method: "PUT",
+            headers,
+            body: putData
+        })
+
+        const data = await res.json();
+        // console.log(data);
+        ctx.body = {
+            code: 0,
+        };
+    });
+
+    router.post('/api/questionAnswer/delete', async (ctx) => {
+        ctx.type = 'application/json';
+        const tableName = 'questionAnswer';
+        const data = ctx.request.body;
+        const ids = data.ids;
+
+        for (const id of ids) {
+            await deleteData(tableName, id);
+        }
+
+        ids.forEach((id) => {
+            deleteData(tableName, id);
+        })
+
+        ctx.body = {
+            code: 0,
+        };
+    });
+
+    const deleteData = async (tableName, id) => {
+        return fetch(`${fullUrl}/${_.kebabCase(tableName)}s/${id}`, {
+            method: "delete"
+        })
+    }
+}
+
+export default getQuestionAnswer;
+
+
+function buildUrl(baseUrl, params) {
+    return baseUrl + "?" + qs.stringify(params);
+}