|
|
@@ -1,4 +1,7 @@
|
|
|
// const { MongoClient } = require('mongodb');
|
|
|
+var express = require('express');
|
|
|
+var router = express.Router();
|
|
|
+const querystring = require('querystring');
|
|
|
|
|
|
var us = {
|
|
|
mongo: require('mongodb'),
|
|
|
@@ -26,7 +29,7 @@ us.initMongoConnection = async function (host, database) {
|
|
|
return us.client.db(database); // 返回数据库实例
|
|
|
}
|
|
|
|
|
|
-async function updateUserData(host, database, cename, data) {
|
|
|
+async function updateUserData(host, database, cename, data, res) {
|
|
|
const db = await us.initMongoConnection(host, database); // 连接数据库
|
|
|
try {
|
|
|
const collection = db.collection(cename); // collection设置
|
|
|
@@ -42,7 +45,9 @@ async function updateUserData(host, database, cename, data) {
|
|
|
{ upsert: true } // 如果没有数据，默认创建一条数据
|
|
|
);
|
|
|
console.log('数据更新成功');
|
|
|
+ res.end(JSON.stringify({ status: "1" }))
|
|
|
} catch (err) {
|
|
|
+ res.end(JSON.stringify({ status: "0" }))
|
|
|
console.error('更新失败', err);
|
|
|
}
|
|
|
}
|
|
|
@@ -54,10 +59,42 @@ updateUserData("mongodb://root:usestudio-1@123.58.32.151:11641?authSource=admin"
|
|
|
"username":
|
|
|
{
|
|
|
userid: "",
|
|
|
- data: "",
|
|
|
+ date: "",
|
|
|
appname: "",
|
|
|
status: ""
|
|
|
}
|
|
|
}
|
|
|
});
|
|
|
*/
|
|
|
+
|
|
|
+//查找有无学校
|
|
|
+router.route('/updateUserData').all((req, res, next) => {
|
|
|
+ // var json = queryString(req.url);
|
|
|
+ let username = req.body.username
|
|
|
+ let today = new Date();
|
|
|
+ let date = today.getFullYear() + '-' + (today.getMonth() + 1).toString().padStart(2, '0') + '-' + today.getDate().toString().padStart(2, '0');
|
|
|
+ updateUserData("mongodb://root:usestudio-1@123.58.32.151:11641?authSource=admin", "cocolog", "applog", {
|
|
|
+ [date]: {
|
|
|
+ [username]: // 使用变量username作为键
|
|
|
+ {
|
|
|
+ userid: req.body.userid,
|
|
|
+ date: req.body.date,
|
|
|
+ appname: req.body.appname,
|
|
|
+ appid: req.body.appid,
|
|
|
+ status: req.body.status
|
|
|
+ }
|
|
|
+ }
|
|
|
+ }, res);
|
|
|
+ console.log(json);
|
|
|
+ // res.end(JSON.stringify([{ status: "0" }]));
|
|
|
+});
|
|
|
+
|
|
|
+
|
|
|
+queryString = function (url) {
|
|
|
+ var a = url.split("?");
|
|
|
+ var json = querystring.parse(a[1])
|
|
|
+ return json;
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+module.exports = router;
|
