router.js

/*

- 路由模块

- */
let express = require('express')
let user = require('./models/user')
let publish = require('./models/publish')
let message = require('./models/message')
let md5 = require('blueimp-md5')
let router = express.Router()
const fs = require('fs');
const marked = require('marked');

router.get('/', function (req, res) {
    publish.find(function (err, publish) {
        if (err) {
            return res.status(500).send('Serve Error')
        }
        publish.forEach(function (e) {
            e.UTCtodata = new Date(e.publishDate).toLocaleString()
        })

        let arr = []
        let GETtimearr = []
        publish.forEach(function (e) {
            if (e.publishIdentifying != '') {
                arr.push(e.publishIdentifying)
                GETtimearr.push(e.UTCtodata)
            }
        })

        function getWordCnt(arr) {
            return arr.reduce(function (prev, next) {
                prev[next] = (prev[next] + 1) || 1;
                return prev;
            }, {});
        }

        function GetData(data) {
            let arr = data.map(item => {
                let str = item.split(' ')[0]
                return str.split('-')[0] + str.split('-')[1]
            })
            let map = new Map()
            for (let item of arr) {
                if (!map.has(item)) {
                    map.set(item, 1)
                } else {
                    let num = map.get(item)
                    map.set(item, num + 1)
                }
            }
            return map
        }
        publish.push(getWordCnt(arr))
        let resultMap = GetData(GETtimearr)
        let othernewObj = {}
        for (let item of resultMap.entries()) {
            let key = item[0].slice(0, 4) + '年' + item[0].slice(4) + '月'
            let value = item[1]
            othernewObj[key] = value
        }
        res.render('index.html', {
            othernewObj: othernewObj,
            publish: publish,
            user: req.session.user
        })
    })
})

router.get('/category', function (req, res, next) {
    publish.find(function (err, publish) {
        if (err) {
            return next(err)
        }
        let arr = []
        publish.forEach(function (e) {
            arr.push(e.publishIdentifying)
        })

        function unique(arr) {
            const seen = new Map()
            return arr.filter((a) => !seen.has(a) && seen.set(a, 1))
        }

        let newarr = unique(arr).filter(function (e) {
            return e != ''
        })
        publish.forEach(function (e) {
            e.newarr = newarr
        })
        publish.forEach(function (e) {
            e.UTCtodata = new Date(e.publishDate).toLocaleString()
        })
        res.render('category.html', {
            publish: publish
        })
    })
})

router.get('/search', function (req, res) {
    publish.find(function (err, publish) {
        if (err) {
            return res.status(500).send('Serve Error')
        }
        publish.forEach(function (e) {
            e.UTCtodata = new Date(e.publishDate).toLocaleString()
        })
        res.render('search.html', {
            publish: publish
        })
    })


})

router.get('/timeline', function (req, res) {
    publish.find(function (err, publish) {
        if (err) {
            return res.status(500).send('Serve Error')
        }
        publish.forEach(function (e) {
            e.UTCtodata = new Date(e.publishDate).toLocaleString()
            e.year = new Date(e.publishDate).toLocaleString().substring(0, 4)
        })

        res.render('timeline.html', {
            publish: publish
        })
    })
})

router.get('/his', function (req, res) {
    res.render('his.html')
})

router.get('/login', function (req, res) {
    res.render('login.html')
})

router.post('/login', function (req, res, next) {
    let body = req.body

    user.findOne({
        email: body.email,
        password: md5(md5(body.password) + 'text')
    }, function (err, user) {
        if (err) {
            return next(err)
        }

        if (!user) {
            return res.status(200).json({
                err_code: 1,
                message: 'email or password is invalid'
            })
        }
        //用户存在，登录成功，通过session记录登录状态
        req.session.user = user
        return res.status(200).json({
            err_code: 0,
            message: 'OK'
        })
    })
})

router.get('/register', function (req, res) {
    res.render('register.html')
})

router.post('/register', function (req, res, next) {
    let body = req.body
    user.findOne({
            $or: [
                {
                    email: body.email
                },
                {
                    nickname: body.nickname
                }
            ]
        }, function (err, data) {
            if (err) {
                return next(err)
                console.log(err)
            }
            if (data) {
                return res.status(200).json({
                    err_code: 1,
                    message: 'email or nickname aleary exist.'
                })
            }
            //加密
            body.password = md5(md5(body.password) + 'text')
            new user(body).save(function (err, user) {
                if (err) {
                    return next(err)
                }
                //注册成功，使用session记录用户的登录状态
                req.session.user = user

                res.status(200).json({
                    err_code: 0,
                    message: 'OK'
                })
            })
        }
    )
})

router.get('/publish', function (req, res) {
    let user = req.session.user
    if (user) {
        if (user.nickname == "周琛") {
            res.render('publish.html')
        } else {
            res.render('放过小弟吧！')
        }
    } else {
        res.render('放过小弟吧！')
    }
})

router.post('/publish', function (req, res, next) {
    let body = req.body
    new publish(body).save(function (err, publish) {
        if (err) {
            return next(err)
        }
        res.status(200).json({
            err_code: 0,
            message: 'OK'
        })
    })
})


router.get("/lcj/:docName", function (req, res, next) {
    let docId = req.params.docName.replace(/"/g, '')
    publish.findById(docId, function (err, publish) {
        if (err) {
            return next(err)
        }
        if (publish.wholepublishIdentifying == "代码") {
            fs.readFile(__dirname + '/src/doc/' + publish.publishMainBodyUrl + '.md', 'utf-8', function (err, data) {
                if (err) {
                    console.log(err);
                } else {
                    htmlStr = marked(data.toString());
                    res.type('html')
                    message.find({
                        message_type: publish.publishMainBodyUrl
                    }, function (err, message) {
                        if (err) {
                            return next(err)
                        }
                        message.forEach(function (e) {
                            e.UTCtodata = new Date(e.message_time).toLocaleString()
                        })
                        res.render('MainBody.html', {
                            doc: htmlStr,
                            publish: publish,
                            message: message
                        });
                    })
                }
            });
        }
        if (publish.wholepublishIdentifying == "心得体会") {
            fs.readFile(__dirname + '/src/feelings/' + publish.publishMainBodyUrl + '.md', 'utf-8', function (err, data) {
                if (err) {
                    console.log(err);
                } else {
                    htmlStr = marked(data.toString());
                    res.type('html')
                    message.find({
                        message_type: publish.publishMainBodyUrl
                    }, function (err, message) {
                        if (err) {
                            return next(err)
                        }
                        message.forEach(function (e) {
                            e.UTCtodata = new Date(e.message_time).toLocaleString()
                        })

                        res.render('MainBody.html', {
                            doc: htmlStr,
                            publish: publish,
                            message: message
                        });
                    })
                }
            });
        }
    })

})

router.get("/sort/:sortName", function (req, res, next) {
    publish.find({
        publishIdentifying: req.params.sortName
    }, function (err, publish) {
        if (err) {
            return next(err)
        }
        publish.forEach(function (e) {
            e.UTCtodata = new Date(e.publishDate).toLocaleString()
        })
        res.render('sortlayout.html', {
            publish: publish
        })
    })
})


router.post('/message', function (req, res, next) {
    let body = req.body
    let user = req.session.user
    if (!user) {
        return res.status(200).json({
            err_code: 1,
            message: '用户没有登陆.'
        })
    } else {
        body.message_nickname = user.nickname

        new message(body).save(function (err, data) {
            if (err) {
                return next(err)
            }
            return res.status(200).json({
                err_code: 0,
                message: data
            })
        })
    }
})


router.get('/lovelogin', function (req, res, next) {
    res.render('lovelogin.html')
})

router.get('/Secret', function (req, res, next) {
    res.render('lovelcjlogin.html')
})


router.get('/love', function (req, res, next) {
    res.render('love.html')
})

router.get('/zclovelcj', function (req, res, next) {
    res.render('lovelcj.html')
})


router.post('/lovelogin', function (req, res, next) {
    var password = req.body.password
    console.log(password)

    if (password == '12110219') {
        return res.status(200).json({
            err_code: 0,
            message: '成功'
        })
    } else {
        console.log('失败')
        return res.status(200).json({
            err_code: 1,
            message: '失败'
        })
    }

})

router.post('/search', function (req, res, next) {
    console.log(req.body)
    let searchtext = req.body.search
    publish.find(function (err, newpublish) {
        if (err) {
            return res.status(500).send('Serve Error')
        }

        let publish = []
        console.log(newpublish)

        newpublish.forEach(function (e) {
            if (e.publishTitle.toLowerCase().indexOf(searchtext.toLowerCase()) != -1 ||
                e.publishIntro.toLowerCase().indexOf(searchtext.toLowerCase()) != -1 ||
                e.publishIdentifying.toLowerCase().indexOf(searchtext.toLowerCase()) != -1) {
                publish.push(e)
            }
        })
        // console.log(publish)
        res.render('search.html', {
            publish: publish
        })

    })
})


//导出router
module.exports = router