新增修改手机号接口

controller/account.js

@@ -154,6 +154,11 @@ async function addCar(flightId,account){
     if(result[0].flightState !== field.flightState_sail+''){
         throw {rcode:codeMap.customError,msg:'航班非销售状态'}
     }
+    [err,result] = await handle(db_user.findCar(userId,flightId));
+    if(err)throw err;
+    if(result.length >= 1){
+        throw {rcode:codeMap.customError,msg:'该航班已经在购物车中'}
+    }
     // 开始添加购物车
     [err,result] = await handle(db_user.addCar(flightId,userId));
     if(err)throw err;

database/d_user.js

@@ -82,7 +82,21 @@ function info(type,account){
     return mysql.pq(sql,values);
 }
 
-function cars(id){
+
+function findCar(userId,flightId){
+    let sql = ``,values = [];
+    sql = `select c.*,f.flightState,f.currentPrice,f.sailingTime,f.langdinTime,dep.cityname as departureCityName,tar.cityname as targetCityName
+            from
+            flight as f
+            inner JOIN (select * from car ) as c on c.flightId = f.id
+            LEFT JOIN (select id,cityName from area ) as dep on dep.id = f.departureCity
+            LEFT JOIN (select id,cityName from area ) as tar on tar.id = f.targetCity
+            where c.userId = ? and flightId = ?;`
+    values.push(userId,flightId);
+    return mysql.pq(sql,values);
+}
+
+function cars(userId){
     let sql = ``,values = [];
     sql = `select c.*,f.flightState,f.currentPrice,f.sailingTime,f.langdinTime,dep.cityname as departureCityName,tar.cityname as targetCityName
             from
@@ -91,7 +105,7 @@ function cars(id){
             LEFT JOIN (select id,cityName from area ) as dep on dep.id = f.departureCity
             LEFT JOIN (select id,cityName from area ) as tar on tar.id = f.targetCity
             where c.userId = ?;`
-    values.push(id);
+    values.push(userId);
     return mysql.pq(sql,values);
 }
 
@@ -123,5 +137,6 @@ module.exports =  {
     info,
     cars,
     removeCar,
-    addCar
+    addCar,
+    findCar
 }

routes/userApi.js

@@ -30,6 +30,32 @@ router.get('/check',
         }
 })
 // 获取用户信息
+router.post('/changePhone',
+    checkLogin(fields.userType),
+    checkParams(
+    {
+        post:{
+            phone:{required:true},
+            passwd:{required:true}
+        }
+    }),async(req,res)=>{
+    try{
+        let results = await c_user.changePhone(fields.userType,req.session[progress.userSessionField],req.body.passwd,req.body.phone);
+        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.get('/info',checkLogin(fields.userType),async(req,res)=>{
     try{
         let results = await c_user.info(fields.userType,req.session[progress.userSessionField]);