Highways4Good/api/app/lib/controllers/data/road.js

'use strict';
const roadKeyMap = require('./road.json')

async function importIn (ctx) {
    // 数据导入
    try {
        const models = ctx.fs.dc.models;
        const { level, } = ctx.query;
        const data = ctx.request.body;

        const roadRes = await models.Road.findAll({
            where: {
                level,
                del: false
            }
        })
        let preCreateArr = []
        for (let d of data) {
            if (roadRes.some(r => r.routeCode + r.sectionNo == d['路线代码'] + d['路段序号'])) {
                //repeat
            } else {
                // await models.Road.create(d);
            }
        }

        ctx.status = 204
    } catch (error) {
        ctx.fs.logger.error(`path: ${ctx.path}, error: ${error}`);
        ctx.status = 400;
        ctx.body = {
            message: typeof error == 'string' ? error : undefined
        }
    }
}

async function get (ctx) {
    try {
        const models = ctx.fs.dc.models;
        const { codePrefix, level, road, sectionStart, sectionEnd, alterId } = ctx.query;

        let findOption = {
            where: {
                del: false
            },
            order: [['id', 'DESC']],
        }
        if (level == '村') {
            findOption.include = [{ model: models.Village, }]
        }
        if (alterId) {
            findOption.where.id = { $notIn: alterId }
        }

        if (codePrefix) {
            findOption.where.routeCode = { $like: `${codePrefix}%` }
        }

        if (level) {
            findOption.where.level = level
        }
        if (road || sectionStart || sectionEnd) {
            findOption.where['$or'] = {}
            if (road) {
                findOption.where['$or'].
                    routeName = { $like: `%${road}%` }
            }
            if (sectionStart) {
                findOption.where['$or'].
                    startingPlaceName = { $like: `%${sectionStart}%` }

            }
            if (sectionEnd) {
                findOption.where['$or'].
                    stopPlaceName = { $like: `%${sectionEnd}%` }

            }
        }

        const roadRes = await models.Road.findAll(findOption)

        ctx.status = 200;
        ctx.body = roadRes
    } catch (error) {
        ctx.fs.logger.error(`path: ${ctx.path}, error: ${error}`);
        ctx.status = 400;
        ctx.body = {
            message: typeof error == 'string' ? error : undefined
        }
    }
}

async function getRoadSection (ctx) {
    try {
        const models = ctx.fs.dc.models;
        const { level, road, sectionStart, sectionEnd } = ctx.query;
        let findOption = {
            where: {},
            order: [['id', 'DESC']],
            attributes: ['id', 'routeName', 'startingPlaceName', 'stopPlaceName', 'routeCode', 'sectionNo', 'level']
        }

        if (level) {
            findOption.where.level = level
        }
        if (road || sectionStart || sectionEnd) {
            findOption.where['$or'] = {}
            if (road) {
                findOption.where['$or'].
                    routeName = { $like: `%${road}%` }
            }
            if (sectionStart) {
                findOption.where['$or'].
                    startingPlaceName = { $like: `%${sectionStart}%` }

            }
            if (sectionEnd) {
                findOption.where['$or'].
                    stopPlaceName = { $like: `%${sectionEnd}%` }
            }
        }

        const roadRes = await models.Road.findAll(findOption)

        ctx.status = 200;
        ctx.body = roadRes
    } catch (error) {
        ctx.fs.logger.error(`path: ${ctx.path}, error: ${error}`);
        ctx.status = 400;
        ctx.body = {
            message: typeof error == 'string' ? error : undefined
        }
    }
}

async function edit (ctx) {
    try {
        const models = ctx.fs.dc.models;
        const data = ctx.request.body;

        if (!data.roadId) {
            await models.Road.create(data)
        } else {
            await models.Road.update(
                data, {
                where: {
                    id: data.roadId
                }
            })
        }

        ctx.status = 204
    } catch (error) {
        ctx.fs.logger.error(`path: ${ctx.path}, error: ${error}`);
        ctx.status = 400;
        ctx.body = {
            message: typeof error == 'string' ? error : undefined
        }
    }
}

async function del (ctx) {
    try {
        const models = ctx.fs.dc.models;
        const { roadId } = ctx.params;

        // await models.Road.destroy({
        //     where: {
        //         id: roadId
        //     }
        // })
        await models.Road.update({
            del: true
        }, {
            where: {
                id: roadId
            }
        })

        ctx.status = 204
    } catch (error) {
        ctx.fs.logger.error(`path: ${ctx.path}, error: ${error}`);
        ctx.status = 400;
        ctx.body = {
            message: typeof error == 'string' ? error : undefined
        }
    }
}

async function getVillageList (ctx) {
    try {
        const models = ctx.fs.dc.models;
        const { } = ctx.query;

        const res = await models.Village.findAll()

        ctx.status = 200;
        ctx.body = res
    } catch (error) {
        ctx.fs.logger.error(`path: ${ctx.path}, error: ${error}`);
        ctx.status = 400;
        ctx.body = {
            message: typeof error == 'string' ? error : undefined
        }
    }
}

module.exports = {
    importIn,
    getRoadSection,
    get, edit, del,
    getVillageList,
};