航班查询相关

controller/c_flight.js

@@ -103,6 +103,26 @@ async function addFlight(
     return result;
 }
 
+/**
+ * 修改航班信息
+ * @param flightId
+ * @param updateOption
+ * @returns {Promise<void>}
+ */
+async function updateFlight(flightId,updateOption){
+    let err,result,departCityType,targetCityType,routerType;
+    if(updateOption.departureCity){
+        // 获取城市类型
+        [err,departCityType] = await handle(db_area.cityType(departureCity));
+    }
+    if(updateOption.departureCity){
+        // 获取城市类型
+        [err,departCityType] = await handle(db_area.cityType(departureCity));
+    }
+
+    [err,targetCityType] = await handle(db_area.cityType(targetCity));
+}
+
 module.exports = {
     searchFlight,
     flightList,

routes/flight_api.js

@@ -80,4 +80,87 @@ router.get('/detail',
         }
     }
 )
+
+// 新增航班
+router.post('/add',
+    checkLogin(field.adminType),
+    paramsCheck({
+        post:{
+            flightName:{required:true},
+            airCode:{required:true},
+            originalPrice:{required:true},
+            currentPrice:{required:true},
+            seilingTime:{required:true},
+            langdinTime:{required:true},
+            totalVotes:{required:true},
+            departureCity:{required:true},
+            targetCity:{required:true},
+        }
+    }),
+    async (req,res)=>{
+        try{
+            let results = await c_flight.addFlight(
+                req.body.flightName,
+                req.body.airCode,
+                req.body.originalPrice,
+                req.body.currentPrice,
+                req.body.seilingTime,
+                req.body.langdinTime,
+                req.body.totalVotes,
+                req.body.departureCity,
+                req.body.targetCity,
+            );
+            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
+            });
+        }
+    }
+)
+
+// 更新指定航班
+router.post('/update',
+    checkLogin(field.adminType),
+    paramsCheck({
+        post:{
+            flightId:{required:true},
+            newOption:{required:true},
+        }
+    }),
+    async (req,res)=>{
+        try{
+            let results = await c_flight.(
+                req.body.flightName,
+                req.body.airCode,
+                req.body.originalPrice,
+                req.body.currentPrice,
+                req.body.seilingTime,
+                req.body.langdinTime,
+                req.body.totalVotes,
+                req.body.departureCity,
+                req.body.targetCity,
+            );
+            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;