update

app.js

@@ -3,7 +3,8 @@ var express = require('express');        // call express
 var app = express();                 // define our app using express
 var bodyParser = require('body-parser');
 var request = require("request");
-const edurouter = require('./query');
+const blockly = require('./blockly');
+const cloud = require('./cloud');
 const morgan = require('morgan');
 var path = require("path");
 var port = "5005";        // set our port
@@ -39,7 +40,10 @@ app.use(cors({
 }));
 */
 // all of our routes will be prefixed with /api
-app.use('/query', edurouter);
+app.use('/blockly', blockly);
+
+// all of our routes will be prefixed with /api
+app.use('/cloud', cloud);
 // app.use('/game', game);
 
 app.all('/download', function (req, res, next) {

blockly.js

@@ -0,0 +1,220 @@
+// ROUTES FOR OUR API
+// =============================================================================
+var express = require('express');
+var router = express.Router();              // get an instance of the express Router
+const querystring = require('querystring');
+var mysql = require('./mysql');
+const _mysqlLabor = ["172.16.12.5", "cuhkjc_query"]; //edu數據庫信息 
+
+
+//統壹處理區域
+router.use(async function (req, res, next) {
+    await asynnext(req, res, next);
+    //// make sure we go to the next routes and don't stop here
+    //res.end("");
+});
+
+/**
+ * @des 參數解釋同上
+ */
+function asynnext(req, res, next) {
+    //異步處理
+    return new Promise(async (resolve, reject) => {
+        next();
+        //resolve(true);
+    });
+}
+
+//指定用户访问 CocoBlockly 的行为
+router.route('/history').post((req, res, next) => {
+    var _str = postmysql(req, res, "blockly_history");
+    res.end(_str);
+}).get((req, res, next) => {
+    var _str = getmysql(req, res, "blockly_history_get")
+    res.end(_str);
+});
+
+//指定用户在 CocoBlockly 停留的总时间（离开的时候请求）
+router.route('/duration').post((req, res, next) => {
+    var _str = postmysql(req, res, "blockly_duration");
+    res.end(_str);
+}).get((req, res, next) => {
+    var _str = getmysql(req, res, "blockly_duration_get")
+    res.end(_str);
+});
+
+//指定用户打开实验室的行为
+router.route('/labs').post((req, res, next) => {
+    var _str = postmysql(req, res, "blockly_labs");
+    res.end(_str);
+}).get((req, res, next) => {
+    var _str = getmysql(req, res, "blockly_labs_get")
+    res.end(_str);
+});
+
+//指定用户打开某个样例的行为
+router.route('/examples').post((req, res, next) => {
+    var _str = postmysql(req, res, "blockly_examples");
+    res.end(_str);
+}).get((req, res, next) => {
+    var _str = getmysql(req, res, "blockly_examples_get")
+    res.end(_str);
+});
+
+//指定用户切换上传模式的行为
+router.route('/mode_switch').post((req, res, next) => {
+    var _str = postmysql(req, res, "blockly_mode_switch");
+    res.end(_str);
+}).get((req, res, next) => {
+    var _str = getmysql(req, res, "blockly_mode_switch_get")
+    res.end(_str);
+});
+
+//指定用户点击串口监视窗按钮的行为
+router.route('/serial_monitor').post((req, res, next) => {
+    var _str = postmysql(req, res, "blockly_serial_monitor");
+    res.end(_str);
+}).get((req, res, next) => {
+    var _str = getmysql(req, res, "blockly_serial_monitor_get")
+    res.end(_str);
+});
+
+//指定用户点击复制源代码的行为
+router.route('/copy').post((req, res, next) => {
+    var _str = postmysql(req, res, "blockly_copy");
+    res.end(_str);
+}).get((req, res, next) => {
+    var _str = getmysql(req, res, "blockly_copy_get")
+    res.end(_str);
+});
+
+//指定用户点击运行的行为
+router.route('/upload_area/run').post((req, res, next) => {
+    var _str = postmysql(req, res, "blockly_upload_area_run");
+    res.end(_str);
+}).get((req, res, next) => {
+    var _str = getmysql(req, res, "blockly_upload_area_run_get")
+    res.end(_str);
+});
+
+//指定用户点击上传的行为
+router.route('/upload_area/upload').post((req, res, next) => {
+    var _str = postmysql(req, res, "blockly_upload_area_upload");
+    res.end(_str);
+}).get((req, res, next) => {
+    var _str = getmysql(req, res, "blockly_upload_area_upload_get")
+    res.end(_str);
+});
+
+
+//指定用户在 Blockly 中弹出错误信息的行为（并报错错误信息）
+router.route('/upload_area/errormsg').post((req, res, next) => {
+    var _str = postmysql(req, res, "blockly_upload_area_errormsg");
+    res.end(_str);
+}).get((req, res, next) => {
+    var _str = getmysql(req, res, "blockly_upload_area_errormsg_get")
+    res.end(_str);
+});
+
+//指定用户将积木拖入编程区域的行为
+router.route('/blocks/to_workspace').post((req, res, next) => {
+    var _str = postmysql(req, res, "blockly_blocks_to_workspace");
+    res.end(_str);
+}).get((req, res, next) => {
+    var _str = getmysql(req, res, "blockly_blocks_to_workspace_get")
+    res.end(_str);
+});
+
+//指定用户将积木拖入编程区域的行为
+router.route('/blocks/out_workspace').post((req, res, next) => {
+    var _str = postmysql(req, res, "blockly_blocks_out_workspace");
+    res.end(_str);
+}).get((req, res, next) => {
+    var _str = getmysql(req, res, "blockly_blocks_out_workspace_get")
+    res.end(_str);
+});
+
+//指定用户导出文件的行为
+router.route('/files/local_export').post((req, res, next) => {
+    var _str = postmysql(req, res, "blockly_files_local_export");
+    res.end(_str);
+}).get((req, res, next) => {
+    var _str = getmysql(req, res, "blockly_files_local_export_get")
+    res.end(_str);
+});
+
+//指定用户导入文件的行为
+router.route('/files/local_import').post((req, res, next) => {
+    var _str = postmysql(req, res, "blockly_files_local_import");
+    res.end(_str);
+}).get((req, res, next) => {
+    var _str = getmysql(req, res, "blockly_files_local_import_get")
+    res.end(_str);
+});
+
+//指定用户创建指定云端文件的行为
+router.route('/files/cloud_create').post((req, res, next) => {
+    var _str = postmysql(req, res, "blockly_files_cloud_create");
+    res.end(_str);
+}).get((req, res, next) => {
+    var _str = getmysql(req, res, "blockly_files_cloud_create_get")
+    res.end(_str);
+});
+
+//指定用户更新指定云端文件的行为
+router.route('/files/cloud_update').post((req, res, next) => {
+    var _str = postmysql(req, res, "blockly_files_cloud_update");
+    res.end(_str);
+}).get((req, res, next) => {
+    var _str = getmysql(req, res, "blockly_files_cloud_update_get")
+    res.end(_str);
+});
+
+//指定用户打开指定云端文件的行为
+router.route('/files/cloud_open').post((req, res, next) => {
+    var _str = postmysql(req, res, "blockly_files_cloud_open");
+    res.end(_str);
+}).get((req, res, next) => {
+    var _str = getmysql(req, res, "blockly_files_cloud_open_get")
+    res.end(_str);
+});
+
+//指定用户删除指定云端文件的行为
+router.route('/files/cloud_delete').post((req, res, next) => {
+    var _str = postmysql(req, res, "blockly_files_cloud_delete");
+    res.end(_str);
+}).get((req, res, next) => {
+    var _str = getmysql(req, res, "blockly_files_cloud_delete_get")
+    res.end(_str);
+});
+
+queryString = function (url) {
+    var a = url.split("?");
+    var json = querystring.parse(a[1])
+    return json;
+}
+
+//post存儲過程處理
+postmysql = function (req, res, functionname) {
+    //mode的處理
+    if (req.body[0]) {
+        p = Object.values(req.body[0]);
+        p.unshift(_mysqlLabor[0], _mysqlLabor[1], functionname);
+        //執行存儲過程
+        mysql.usselect(p, function (ret) { res.end(JSON.stringify(ret)); });
+    }
+}
+
+//get獲取數據庫信息
+getmysql = function (req, res, functionname, ...p) {
+    p = p || [];
+    p.unshift(_mysqlLabor[0], _mysqlLabor[1], functionname);
+    //執行存儲過程
+    mysql.usselect(p, function (ret) {
+        res.end(JSON.stringify(ret));
+    });  //
+}
+
+
+module.exports = router;
+

query.js → cloud.js

@@ -1,20 +1,15 @@
 // ROUTES FOR OUR API
 // =============================================================================
 var express = require('express');
-var bcrypt = require('bcryptjs');
 var router = express.Router();              // get an instance of the express Router
 const querystring = require('querystring');
 var mysql = require('./mysql');
-const { json } = require('express');
-// const _mysqlLabor = ["123.58.32.151", "LaborEdu"]; //edu數據庫信息
-const _mysqlLabor = ["172.16.12.5", "LaborEdu"]; //edu數據庫信息 
+const _mysqlLabor = ["172.16.12.5", "cuhkjc_query"]; //edu數據庫信息 
 
 
 //統壹處理區域
 router.use(async function (req, res, next) {
     await asynnext(req, res, next);
-    //// make sure we go to the next routes and don't stop here
-    //res.end("");
 });
 
 /**
@@ -28,9 +23,38 @@ function asynnext(req, res, next) {
     });
 }
 
-//
-router.route('/query').all((req, res, next) => {
-    postmysql(req, res, "");
+//指定用户创建云端事件的行为
+router.route('/event_create').post((req, res, next) => {
+    postmysql(req, res, "cloud_event_create");
+}).get((req, res, next) => {
+    var _str = getmysql(req, res, "cloud_event_create_get")
+    res.end(_str);
+});
+
+
+//指定用户删除云端事件的行为
+router.route('/event_del').post((req, res, next) => {
+    postmysql(req, res, "cloud_event_del");
+}).get((req, res, next) => {
+    var _str = getmysql(req, res, "cloud_event_del_get")
+    res.end(_str);
+});
+
+//指定用户创建云端可视化面板的行为
+router.route('/panel_create').post((req, res, next) => {
+    postmysql(req, res, "cloud_panel_create");
+}).get((req, res, next) => {
+    var _str = getmysql(req, res, "cloud_panel_create_get")
+    res.end(_str);
+});
+
+
+//指定用户删除云端可视化面板的行为
+router.route('/panel_del').post((req, res, next) => {
+    postmysql(req, res, "cloud_panel_del");
+}).get((req, res, next) => {
+    var _str = getmysql(req, res, "cloud_panel_del_get")
+    res.end(_str);
 });
 
 queryString = function (url) {