const fs = require("fs");

// 异步读取
fs.readFile('input.txt','utf8', function (err, data) {
    //如果读取成功，则err的值为null
    //如果读取失败，则err的值为错误对象，dataStr的值为undefined
   if (err) {
       return console.error(err);
   }
   console.log("异步读取: " + data.toString());
});

// 同步读取
var data = fs.readFileSync('input.txt');
console.log("同步读取: " + data.toString());

console.log("程序执行完毕。");



//执行结果
同步读取: 文件读取实例

程序执行完毕。
异步读取: 文件读取实例

const fs = require("fs");

fs.writeFile('input.txt', '我是通 过fs.writeFile 写入文件的内容',  function(err) {
   if (err) {
       return console.error(err);
   }
})

const path = require("path")

const http = require('http')
const server = http.createServer()
server.on('request', function (req, res) {
    console.log('Someone visit our web server.')
})

server.listen(8080, function () {
    console.log('服务器启动了，运行在http://127.0.0.1:8080')
})

//1.导入 express
const express = require('express')
//2.创建 web 服务器
const app = express()
app.get('/user', (req, res) => {
    res.send({ name: 'hzx', age: 20, gender: '男' })
})
app.post('/user', (req, res) => {
    res.send('请求成功')
})
//3. 启动 web 服务器
app.listen(80, () => {
    console.log('express server running at http://127.0.0.1')
})

//router.js
const express = require('express')
const router = express.Router()
router.get('/user/list', (req, res) => {
    res.send('Get user list.')
})
router.post('/user/add', (req, res) => {
    res.send('Add new user.')
})
module.exports = router

//index.js
//1.导入 express
const express = require('express')
//2.创建 web 服务器
const app = express()
//注册路由模块
const router = require('./router')
app.use(router)
//3. 启动 web 服务器
app.listen(80, () => {

    console.log('express server running at http://127.0.0.1')
})

app.get('/',function(req,res,next){
next()//把流转关系转交给下一个中间件或者路由
})

const app = express()
const mw = function (req,res,next){
    console.log('这是最简单的中间件函数')
    next()
}
app.use(mw)
app.get('/',(req,res)=>{
    res.send('Home Page.')
})
app.get('/user',(req,res)=>{
    res.send("User Page")
})

const app = express()
const mw = function (req,res,next){
    console.log('这是最简单的中间件函数')
    next()
}
app.get('/',mw,(req,res)=>{
    res.send('Home Page.')
})

app.get('/',mw1,mw2,(req,res)=>{
    res.send('Home Page.')
})
app.get('/',[mw1,mw2],(req,res)=>{
    res.send('Home Page.')
})

const cors = require('cors')
app.use(cors())

const user = { username:'spider-man', password:'pcc123'}
const sqlStr = 'insert into users (username,password) values (?,?)'
db.query(sqlStr,[user.username,user.password],(err,results)=>{
    if(err) return console.log(err.message)
    //insert into 的返回结果为对象,select 的结果为数组
    if(results.affectedRows === 1) console.log('数据插入成功！')
})


//若对象的属性值与数据表的字段一一对应
const sqlStr = 'insert into users set ?'
db.query(sqlStr, user, (err, results) => {
    if (err) return console.log(err.message)
    if (results.affectedRows === 1) console.log('数据插入成功！')
})

const user = { id: 5, username: 'aaa', password: '000123' }
const sqlStr = 'update users set username=?,password=? where id=?'
db.query(sqlStr, [user.username, user.password, user.id], (err, results) => {
    if (err) return console.log(err.message)
    //update 的返回结果为对象
    if (results.affectedRows === 1) console.log('数据修改成功！')
})


//若对象的属性值与数据表的字段一一对应
const sqlStr = 'update users set ? where id=?'
db.query(sqlStr, [user, user.id], (err, results) => {
    if (err) return console.log(err.message)
    //update 的返回结果为对象
    if (results.affectedRows === 1) console.log('数据修改成功！')
})

const sqlStr = 'delete from users where id=?'
db.query(sqlStr, 5, (err, results) => {
    if (err) return console.log(err.message)
    //update 的返回结果为对象
    if (results.affectedRows === 1) console.log('数据删除成功！')
})

const express = require('express')
const session = require('express-session')
const app = express()
app.use(session({
    secret: 'keyboard cat',//可以为任意字符串
    resave: false,
    saveUninitialized: true
}))

// 1.导入用于生成JWT字符串的包
const jwt = require('jsonwebtoken')
// 2.导入将JWT字符串还原成JSON对象的包
const {expressjwt} = require('express-jwt')

//错误级别的中间件
app.use((err, req, res, next) => {
    //token解析失败
    if (err.name === "UnauthorizedError") {
        return res.send({
            status: 401,
            message: "无效的token",
        })
    }
    res.send({
        status: 500,
        message: "服务端错误",
    })
})

//.unless({})用来指定哪一些接口不需要访问权限，以下匹配/api/开头的路径
const secretKey = 'Sherlock Holmes ^_^'
app.use(expressjwt({secret:secretKey,algorithms:['HS256']}).unless({path:[/^\/api\//]}))

//登录获取token
app.post('/api/login',function(req,res){
    res.send({
        status:200,
        message:'登录成功！',
        //参数1：用户的信息对象，参数2：加密的密钥，参数3：配置对象：可以配置当前token的有效期
        token:jwt.sign({username:userinfo.username},secretKey,{expiresIn:'30s'})
    })
})

app.get('/admin/getinfo', function (req, res) {
    res.send({
        status: 200,
        message: "获取用户信息成功!",
        data: req.auth
    })
})