航班查询相关

controller/c_flight.js

@@ -153,6 +153,7 @@ async function updateFlight(flightId,updateOption){
     updateOptions.totalVotes = updateOption.totalVotes;
     updateOptions.departureCity = updateOption.departureCity;
     updateOptions.targetCity = updateOption.targetCity;
+    updateOptions.flightState = updateOption.flightState;
     [err,result] = await handle(db_air.updateFlight(flightId,updateOptions));
     if(err) throw err;
     return result
@@ -164,12 +165,12 @@ async function updateFlight(flightId,updateOption){
  * @returns {Promise<void>}
  */
 async function news(nums){
-    let result = {},sailFlights,wicketFlights;
+    let result = {},sellFlights,wicketFlights;
     [err,wicketFlights] = await handle(db_air.wicketFlights(nums));
     if(err){throw err}
-    [err,sailFlights] = await handle(db_air.sailFlights(nums));
+    [err,sellFlights] = await handle(db_air.sellFlights(nums));
     if(err){throw err}
-    result.sailFlights = sailFlights;
+    result.sellFlights = sellFlights;
     result.wicketFlights = wicketFlights;
     return result;
 }

database/d_air.js

@@ -168,7 +168,7 @@ function recommendFlight(){
  * @param num
  * @returns {Promise<unknown>}
  */
-function sailFlights(num = 5){
+function sellFlights(num = 5){
     let sql=``,values=[];
     // 判断状态为
     sql+=`select f.id,f.currentPrice,f.sailingTime,f.langdinTime,dep.cityname as departureCityName,tar.cityname as targetCityName
@@ -207,5 +207,5 @@ module.exports = {
     flightList,
     flightInfo,
     wicketFlights,
-    sailFlights
+    sellFlights
 }

routes/flight_api.js

@@ -177,4 +177,33 @@ router.get('/news',async (req,res)=>{
         });
     }
 })
+
+router.post('/state',
+    checkLogin(field.adminType),
+    paramsCheck({
+        post:{
+            flightId:{required:true},
+            nextState:{required:true},
+        }
+    }),
+    async (req,res)=>{
+        try{
+            let results = await c_flight.updateFlight(req.body.flightId, {
+                flightState:req.body.nextState
+            });
+            res.json({
+                rcode: code.ok,
+                data: results
+            })
+        }catch (error) {
+            if (error.rcode !== code.customError) {
+                console.log(error);
+            }
+            res.json({
+                rcode: error.rcode || code.serverError,
+                msg: error.msg || error.message
+            });
+        }
+})
+
 module.exports = router;