Merge branch 'master' of http://git.fmode.cn:3000/csdn1233/s202226701049

Alart-server/lib/ncloud.js

@@ -0,0 +1,163 @@
+class CloudObject {
+    id
+    className
+    data = {}
+    constructor(className) {
+        this.className = className
+    }
+    toPointer() {
+        return { "__type": "Pointer", "className": this.className, "objectId": this.id }
+    }
+    set(json) {
+        Object.keys(json).forEach(key => {
+            if (["objectId", "id", "createdAt", "updatedAt", "ACL"].indexOf(key) > -1) {
+                return
+            }
+            this.data[key] = json[key]
+        })
+    }
+    get(key) {
+        return this.data[key] || null
+    }
+    async save() {
+        let method = "POST"
+        let url = "http://dev.fmode.cn:1337/parse/classes/" + this.className
+        // 更新
+        if (this.id) {
+            url += "/" + this.id
+            method = "PUT"
+        }
+        let body = JSON.stringify(this.data)
+        let response = await fetch(url, {
+            "headers": {
+                "content-type": "application/json;charset=UTF-8",
+                "x-parse-application-id": "dev"
+            },
+            "body": body,
+            "method": method,
+            "mode": "cors",
+            "credentials": "omit"
+        });
+        let result = await response?.json();
+        if (result?.error) {
+            console.error(result?.error)
+        }
+        if (result?.objectId) { this.id = result?.objectId }
+        return this
+    }
+    async destory() {
+        if (!this.id) return
+        let response = await fetch("http://dev.fmode.cn:1337/parse/classes/Doctor/" + this.id, {
+            "headers": {
+                "x-parse-application-id": "dev"
+            },
+            "body": null,
+            "method": "DELETE",
+            "mode": "cors",
+            "credentials": "omit"
+        });
+        let result = await response?.json();
+        if (result) {
+            this.id = null
+        }
+        return true
+    }
+}
+
+class CloudQuery {
+    className
+    constructor(className) {
+        this.className = className
+    }
+
+    whereOptions = {}
+    greaterThan(key, value) {
+        if (!this.whereOptions[key]) this.whereOptions[key] = {}
+        this.whereOptions[key]["$gt"] = value
+    }
+    greaterThanAndEqualTo(key, value) {
+        if (!this.whereOptions[key]) this.whereOptions[key] = {}
+        this.whereOptions[key]["$gte"] = value
+    }
+    lessThan(key, value) {
+        if (!this.whereOptions[key]) this.whereOptions[key] = {}
+        this.whereOptions[key]["$lt"] = value
+    }
+    lessThanAndEqualTo(key, value) {
+        if (!this.whereOptions[key]) this.whereOptions[key] = {}
+        this.whereOptions[key]["$lte"] = value
+    }
+    equalTo(key, value) {
+        this.whereOptions[key] = value
+    }
+
+    async get(id) {
+        let url = "http://dev.fmode.cn:1337/parse/classes/" + this.className + "/" + id + "?"
+
+        let response = await fetch(url, {
+            "headers": {
+                "if-none-match": "W/\"1f0-ghxH2EwTk6Blz0g89ivf2adBDKY\"",
+                "x-parse-application-id": "dev"
+            },
+            "body": null,
+            "method": "GET",
+            "mode": "cors",
+            "credentials": "omit"
+        });
+        let json = await response?.json();
+        return json || {}
+    }
+    async find() {
+        let url = "http://dev.fmode.cn:1337/parse/classes/" + this.className + "?"
+
+        if (Object.keys(this.whereOptions)?.length) {
+            let whereStr = JSON.stringify(this.whereOptions)
+            url += `where=${whereStr}`
+        }
+
+        let response = await fetch(url, {
+            "headers": {
+                "if-none-match": "W/\"1f0-ghxH2EwTk6Blz0g89ivf2adBDKY\"",
+                "x-parse-application-id": "dev"
+            },
+            "body": null,
+            "method": "GET",
+            "mode": "cors",
+            "credentials": "omit"
+        });
+        let json = await response?.json();
+        return json?.results || []
+    }
+    async first() {
+        let url = "http://dev.fmode.cn:1337/parse/classes/" + this.className + "?"
+
+        if (Object.keys(this.whereOptions)?.length) {
+            let whereStr = JSON.stringify(this.whereOptions)
+            url += `where=${whereStr}`
+        }
+
+        let response = await fetch(url, {
+            "headers": {
+                "if-none-match": "W/\"1f0-ghxH2EwTk6Blz0g89ivf2adBDKY\"",
+                "x-parse-application-id": "dev"
+            },
+            "body": null,
+            "method": "GET",
+            "mode": "cors",
+            "credentials": "omit"
+        });
+        let json = await response?.json();
+        let exists = json?.results?.[0] || null
+        if (exists) {
+            let existsObject = new CloudObject(this.className)
+            existsObject.set(exists)
+            existsObject.id = exists.objectId
+            existsObject.createdAt = exists.createdAt
+            existsObject.updatedAt = exists.updatedAt
+            return existsObject
+        }
+    }
+}
+
+module.exports.CloudObject = CloudObject
+module.exports.CloudQuery = CloudQuery

Alart-server/migration/data.js

@@ -0,0 +1,217 @@
+module.exports.QuestionnaireResultList = [
+    {
+        "objectId": "result1",
+        "createdAt": "2024-12-10T11:20:24Z",
+        "QuestionnaireResultId": "qr1", // 新增的非数据库生成的主键
+        "userId": {
+            "__type": "Pointer",
+            "className": "User",
+            "objectId": "user1"
+        },
+        "questionnaireId": {
+            "__type": "Pointer",
+            "className": "Questionnaire",
+            "objectId": "questionnaire1"
+        },
+        "answers": [
+            {
+                "__type": "Pointer",
+                "className": "Option",
+                "objectId": "option1"
+            },
+            {
+                "__type": "Pointer",
+                "className": "Option",
+                "objectId": "option2"
+            }
+        ]
+    },
+    {
+        "objectId": "result2",
+        "createdAt": "2024-12-10T11:20:24Z",
+        "QuestionnaireResultId": "qr2", // 新增的非数据库生成的主键
+        "userId": {
+            "__type": "Pointer",
+            "className": "User",
+            "objectId": "user2"
+        },
+        "questionnaireId": {
+            "__type": "Pointer",
+            "className": "Questionnaire",
+            "objectId": "questionnaire1"
+        },
+        "answers": [
+            {
+                "__type": "Pointer",
+                "className": "Option",
+                "objectId": "option3"
+            },
+            {
+                "__type": "Pointer",
+                "className": "Option",
+                "objectId": "option4"
+            }
+        ]
+    }
+];
+
+module.exports.QuestionnaireList = [
+    {
+        "objectId": "questionnaire1",
+        "createdAt": "2024-12-10T11:20:24Z",
+        "QuestionnaireId": "q1", // 新增的非数据库生成的主键
+        "title": "兴趣调查问卷",
+        "status": "已发布",
+        "questions": [
+            {
+                "__type": "Pointer",
+                "className": "Question",
+                "objectId": "question1"
+            },
+            {
+                "__type": "Pointer",
+                "className": "Question",
+                "objectId": "question2"
+            }
+        ]
+    }
+];
+
+module.exports.QuestionList = [
+    {
+        "objectId": "question1",
+        "createdAt": "2024-12-10T11:20:24Z",
+        "QuestionId": "q1", // 新增的非数据库生成的主键
+        "questionnaireId": {
+            "__type": "Pointer",
+            "className": "Questionnaire",
+            "objectId": "questionnaire1"
+        },
+        "questionText": "你最喜欢的活动是什么？",
+        "options": [
+            {
+                "__type": "Pointer",
+                "className": "Option",
+                "objectId": "option1"
+            },
+            {
+                "__type": "Pointer",
+                "className": "Option",
+                "objectId": "option2"
+            }
+        ]
+    },
+    {
+        "objectId": "question2",
+        "createdAt": "2024-12-10T11:20:24Z",
+        "QuestionId": "q2", // 新增的非数据库生成的主键
+        "questionnaireId": {
+            "__type": "Pointer",
+            "className": "Questionnaire",
+            "objectId": "questionnaire1"
+        },
+        "questionText": "你喜欢的休闲方式是什么？",
+        "options": [
+            {
+                "__type": "Pointer",
+                "className": "Option",
+                "objectId": "option3"
+            },
+            {
+                "__type": "Pointer",
+                "className": "Option",
+                "objectId": "option4"
+            }
+        ]
+    }
+];
+
+module.exports.OptionList = [
+    {
+        "objectId": "option1",
+        "createdAt": "2024-12-10T11:20:24Z",
+        "OptionId": "o1", // 新增的非数据库生成的主键
+        "questionId": {
+            "__type": "Pointer",
+            "className": "Question",
+            "objectId": "question1"
+        },
+        "optionText": "户外活动",
+        "isSelected": false
+    },
+    {
+        "objectId": "option2",
+        "createdAt": "2024-12-10T11:20:24Z",
+        "OptionId": "o2", // 新增的非数据库生成的主键
+        "questionId": {
+            "__type": "Pointer",
+            "className": "Question",
+            "objectId": "question1"
+        },
+        "optionText": "阅读",
+        "isSelected": false
+    },
+    {
+        "objectId": "option3",
+        "createdAt": "2024-12-10T11:20:24Z",
+        "OptionId": "o3", // 新增的非数据库生成的主键
+        "questionId": {
+            "__type": "Pointer",
+            "className": "Question",
+            "objectId": "question2"
+        },
+        "optionText": "看电影",
+        "isSelected": false
+    },
+    {
+        "objectId": "option4",
+        "createdAt": "2024-12-10T11:20:24Z",
+        "OptionId": "o4", // 新增的非数据库生成的主键
+        "questionId": {
+            "__type": "Pointer",
+            "className": "Question",
+            "objectId": "question2"
+        },
+        "optionText": "旅游",
+        "isSelected": false
+    }
+];
+
+module.exports.UserInterestProfileList = [
+    {
+        "objectId": "profile1",
+        "createdAt": "2024-12-10T11:20:24Z",
+        "userId": {
+            "__type": "Pointer",
+            "className": "User",
+            "objectId": "user1"
+        },
+        "interestTags": ["户外活动", "阅读"],
+        "results": [
+            {
+                "__type": "Pointer",
+                "className": "QuestionnaireResult",
+                "objectId": "result1"
+            }
+        ],
+        "content": "用户喜欢户外活动和阅读，喜欢在自然中放松和探索新书籍。"
+    },
+    {
+        "objectId": "profile2",
+        "createdAt": "2024-12-10T11:20:24Z",
+        "userId": {
+            "__type": "Pointer",
+            "className": "User",
+            "objectId": "user2"
+        },
+        "interestTags": ["看电影", "旅游"],
+        "results": [
+            {
+                "__type": "Pointer",
+                "className": "QuestionnaireResult",
+                "objectId": "result2"
+            }
+        ],
+        "content": "用户热爱看电影和旅游，喜欢通过电影探索不同的文化和风景。"
+    }
+];

Alart-server/migration/import-data.js

@@ -0,0 +1,154 @@
+const { CloudQuery, CloudObject } = require("../lib/ncloud");
+const { QuestionnaireResultList, QuestionnaireList, QuestionList, OptionList, UserInterestProfileList } = require("./data");
+
+importData();
+
+let DataMap = {
+    QuestionnaireResult: {},
+    Questionnaire: {},
+    Question: {},
+    Option: {},
+    UserInterestProfile: {}
+}
+
+async function importData() {
+    // 导入问卷结果数据
+    let questionnaireResultList = QuestionnaireResultList;
+    for (let index = 0; index < questionnaireResultList.length; index++) {
+        let result = questionnaireResultList[index];
+        result = await importObject("QuestionnaireResult", result);
+    }
+
+    // 导入问卷数据
+    let questionnaireList = QuestionnaireList;
+    for (let index = 0; index < questionnaireList.length; index++) {
+        let questionnaire = questionnaireList[index];
+        questionnaire = await importObject("Questionnaire", questionnaire);
+    }
+
+    // 导入问题数据
+    let questionList = QuestionList;
+    for (let index = 0; index < questionList.length; index++) {
+        let question = questionList[index];
+        question = await importObject("Question", question);
+    }
+
+    // 导入选项数据
+    let optionList = OptionList;
+    for (let index = 0; index < optionList.length; index++) {
+        let option = optionList[index];
+        option = await importObject("Option", option);
+    }
+
+    // 导入用户兴趣画像数据
+    let userInterestProfileList = UserInterestProfileList;
+    for (let index = 0; index < userInterestProfileList.length; index++) {
+        let profile = userInterestProfileList[index];
+        profile = await importObject("UserInterestProfile", profile);
+    }
+
+    // console.log(DataMap)
+}
+
+async function importObject(className, data) {
+    // 查重 srcId 数据源列表中的 objectId 并非数据库生成的唯一 ID，因此需要有一个 srcId 字段进行记录，并查重
+    let query = new CloudQuery(className);
+    let srcId = data.objectId;
+    query.equalTo("srcId", srcId);
+    let importObj = await query.first();
+    console.log(importObj);
+
+    // 导入前批量处理 Pointer 类型数据，进行重定向
+    Object.keys(data)?.forEach(key => {
+        let field = data[key];
+        let srcId = field?.objectId;
+        if (srcId) { // 是 Pointer 类型
+            if (key === "userId" || key === "questionnaireId" || key === "questionId") {
+                data[key] = DataMap?.[key.replace("Id", "")]?.[srcId]?.toPointer();
+            } else if (Array.isArray(field)) {
+                data[key] = field.map(item => {
+                    return DataMap?.[item.className]?.[item.objectId]?.toPointer();
+                });
+            }
+        }
+    });
+    // 若未添加，则创建新对象并保存
+    if (!importObj?.id) {
+        importObj = new CloudObject(className);
+    }
+
+    // 保存或更新数据
+    data.srcId = srcId;
+    importObj.set(data);
+    importObj = await importObj.save();
+
+    DataMap[className][srcId] = importObj;
+}
+
+
+/// 展示当前问卷内的问题及其选项
+async function displayQuestionnaireDetails(questionnaireId) {
+    // 查询问卷
+    let questionnaireQuery = new CloudQuery("Questionnaire");
+    questionnaireQuery.equalTo("objectId", questionnaireId);
+    let questionnaire = await questionnaireQuery.first();
+
+    // 检查问卷是否存在
+    if (!questionnaire) {
+        console.log("问卷未找到，无法展示问题和选项。");
+        return;
+    }
+
+    console.log(`问卷标题: ${questionnaire.title}`);
+    console.log(`问卷状态: ${questionnaire.status}`);
+    console.log("问题列表:");
+
+    // 查询问题
+    let questionQuery = new CloudQuery("Question");
+    questionQuery.equalTo("questionnaireId", {
+        "__type": "Pointer",
+        "className": "Questionnaire",
+        "objectId": questionnaireId
+    });
+    let questions = await questionQuery.find();
+
+    // 检查是否有问题
+    if (questions.length === 0) {
+        console.log("当前问卷没有问题。");
+        return;
+    }
+
+    // 遍历问题并查询选项
+    for (let question of questions) {
+        // 检查问题是否存在
+        if (!question) {
+            console.log("问题未找到，无法展示选项。");
+            continue; // 跳过当前循环，继续下一个问题
+        }
+
+        console.log(`  问题: ${question.questionText}`);
+
+        // 查询选项
+        let optionQuery = new CloudQuery("Option");
+        optionQuery.equalTo("questionId", {
+            "__type": "Pointer",
+            "className": "Question",
+            "objectId": question.objectId
+        });
+        let options = await optionQuery.find();
+
+        // 输出选项
+        console.log("  选项:");
+        if (options.length === 0) {
+            console.log("    - 此问题没有选项。");
+        } else {
+            for (let option of options) {
+                console.log(`    - ${option.optionText} (已选: ${option.isSelected})`);
+            }
+        }
+        console.log(""); // 添加空行以便于阅读
+    }
+}
+
+// 示例调用
+displayQuestionnaireDetails("jbg6EYXk3G");