完成了消息通知

ssti.js

@@ -29,7 +29,7 @@ function asynnext(req, res, next) {
 }
 /*測試*/
 router.route('/a').all((req, res, next) => {
-    var json = queryString(req.url);
+    var json = GetData(req);
     getmysql(req, res, "a");
 });
 // router.route('/b').all((req, res, next) => {
@@ -38,13 +38,13 @@ router.route('/a').all((req, res, next) => {
 
 //qgt 查看数据库是否有此人
 router.use((req,res,next)=>{
-    const uid = req.body['uid'];
+    const uid = GetData(req)['uid'];
     let p = [_mysqlLabor[0], _mysqlLabor[1], 'select_UserByUserId',uid];
     mysql.usselect(p,function(result){
         if(result[0].length==1){
             next();
         }else{
-            res.Back(1,"用户不存在",queryString(req.url))
+            res.Back(1,"用户不存在",GetData(req))
         }
     })
 })
@@ -52,7 +52,7 @@ router.use((req,res,next)=>{
 //qgt 新增全站通知
 router.post('/CreateNewNotification',(req,res)=>{
     //uid title brief
-    const ReqData = req.body;
+    const ReqData =  GetData(req);
     //随机ID
     const nid = crypto.randomUUID({ disableEntropyCache: true })
     let p = [_mysqlLabor[0], _mysqlLabor[1], 'insert_New',nid,ReqData['title'],ReqData['brief'],ReqData['uid'],getNowDate()];
@@ -65,14 +65,56 @@ router.post('/CreateNewNotification',(req,res)=>{
     })    
 })
 
+//qgt 获取全站通知
+router.get('/SelectNotification',(req,res)=>{
+    //uid title nowPage lim 
+    const ReqData =  GetData(req);
+    let p = [_mysqlLabor[0], _mysqlLabor[1], 'select_NewByTitle',ReqData['title'],ReqData['nowPage'],ReqData['lim']];
+    mysql.usselect(p,function(result){
+        res.Back(0,"查询成功",result)
+    }) 
+})
+
+//qgt 删除通知
+router.post("/DeleteNotification",(req,res)=>{
+    //uid nid
+    const ReqData = GetData(req);
+    const p = [_mysqlLabor[0], _mysqlLabor[1], 'update_NewStatusById',ReqData['nid']];
+    mysql.usselect(p,(result)=>{
+        if(result==1){
+            res.Back(0,"成功删除一条通知",result);
+        }else{
+            res.Back(1,"删除通知失败",result);
+        }
+    })
+})
+
+//qgt 获取消息通知详细
+router.get("/SelectNotificationDetail",(req,res)=>{
+    //uid nid
+    const ReqData = GetData(req);
+    const p = [_mysqlLabor[0], _mysqlLabor[1], 'select_NewById',ReqData['nid']];
+    mysql.usselect(p,(result)=>{
+        if(result[0].length==1){
+            res.Back(0,"成功获取消息详细",result[0][0]);
+        }else{
+            res.Back(1,"获取消息消息失败")
+        }
+    })
+})
 
 
 
 
-queryString = function(url) {
-    var a = url.split("?");
+
+GetData = function(req) {
+    var a = req.url.split("?");
     var json = querystring.parse(a[1])
-    return json;
+    if(Object.keys(json).length!=0){
+        return json
+    }else{
+        return req.body
+    }
 }
 
 //post存儲過程處理
@@ -150,9 +192,28 @@ usergetmysql = function(req, res, functionname, ...p) {
     //执行存储过程
 
     mysql.usselect(p, function(ret) { res.end(JSON.stringify(ret)); }); //
-
 }
 
+
+// //获取请求数据
+// function GetData(req){
+//     if(req.body['uid']==null){
+//         return req.query
+//     }else{
+//         return req.body
+//     }
+
+    
+//     // return req.query | req.body;
+
+//     // if(req.method =='POST'){
+//         // return req.body;
+//     // }else if(req.method =="GET"){
+//         // return req.query;
+//     // }
+// }   
+
+
 //获取当前时间
 function getNowDate() {
     let date = new Date();