ConstructionOperation/modules/std_billsGuidance_lib/controllers/libController.js

'use strict';

/**
 *
 *
 * @author Zhong
 * @date 2018/5/29
 * @version
 */
import BaseController from '../../common/base/base_controller';
import moment from 'moment';
const billsGuidanceFacade = require('../facade/facades');
let logger = require('../../../logs/log_helper').logger;
const fs = require("fs");
// excel解析
const excel = require("node-xlsx");
let callback = function (req, res, err, msg, data) {
    res.json({ error: err, message: msg, data: data });
};

const zhLibID = 'cf851660-3534-11ec-9641-2da8021b8e4e';

class BillsGuideLibController extends BaseController {

    //获取编办及编办清单库信息
    async getComBillsLibInfo(req, res) {
        try {
            let comBillsLibInfo = await billsGuidanceFacade.getComBillsLibInfo(req);
            callback(req, res, 0, '', comBillsLibInfo);
        }
        catch (err) {
            callback(req, res, 1, err, null);
        }
    }

    async getBillsGuideLibs(req, res) {
        try {
            const compilationPermission = req.session.managerData.compilationPermission || [];
            const filter = { compilationId: { $in: compilationPermission }, deleted: false };
            let libs = await billsGuidanceFacade.getBillsGuideLibs(filter, req.session.managerData.isTemporary);
            callback(req, res, 0, '', libs);
        }
        catch (err) {
            callback(req, res, 1, '获取清单指引库数据错误', null);
        }
    }

    async updateBillsGuideLib(req, res) {
        try {
            let data = JSON.parse(req.body.data);
            if (data.updateType === 'create') {
                data.updateData.createDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss');
                data.updateData.creator = req.session.managerData.username;
                await billsGuidanceFacade.initBillsGuideLib(data.updateData);
            }
            else {
                if (data.updateType === 'delete') {
                    logger.info(`delete billsGuidanceLib ${req.ip}`);
                }
                await billsGuidanceFacade.updateBillsGuideLib(data);
            }
            callback(req, res, 0, '', data.updateData);
        }
        catch (err) {
            callback(req, res, 1, '更新失败', null);
        }
    }
    //获取清单指引库和该库引用的清单
    async getLibWithBills(req, res) {
        try {
            let data = JSON.parse(req.body.data);
            let rst = await billsGuidanceFacade.getLibWithBills(data.libID);
            callback(req, res, 0, '', rst);
        }
        catch (err) {
            callback(req, res, 1, err, null);
        }
    }

    async getItemsByBills(req, res) {
        try {
            let data = JSON.parse(req.body.data);
            let items = await billsGuidanceFacade.getItemsBybills(data.guidanceLibID, data.billsID);
            callback(req, res, 0, '', items);
        }
        catch (err) {
            callback(req, res, 1, err, null);
        }
    }

    async getItemsByBillIDs(req, res) {
        try {
            let data = JSON.parse(req.body.data);
            let items = await billsGuidanceFacade.getItemsByBillIDs(data.guidanceLibID, data.billIDs);
            callback(req, res, 0, '', items);
        }
        catch (err) {
            callback(req, res, 1, err, null);
        }
    }

    async updateItems(req, res) {
        try {

            if (req.session.managerData.isTemporary) {
                const match = req.headers.referer.match(/libID=([\d,a-z,A-Z,-]{36})/);
                if (match && match[1] && match[1] !== zhLibID) {
                    throw '无此清单精灵库权限';
                }
            }

            let data = JSON.parse(req.body.data);
            let updateDatas = data.updateDatas;
            await billsGuidanceFacade.updateItems(updateDatas, req.session.managerData.isTemporary);
            callback(req, res, 0, '', null);
        }
        catch (err) {
            callback(req, res, 1, err, null);
        }
    }

    async getBillMaterials(req, res) {
        try {
            const data = JSON.parse(req.body.data);
            const materials = await billsGuidanceFacade.getBillMaterials(data.libID, data.billID);
            callback(req, res, 0, '', materials);
        }
        catch (err) {
            callback(req, res, 1, err, null);
        }
    }

    async editBillMaterials(req, res) {
        try {
            const data = JSON.parse(req.body.data);
            const materials = await billsGuidanceFacade.editBillMaterials(data.libID, data.billID, data.gljCodes, data.compilationID);
            callback(req, res, 0, '', materials);
        }
        catch (err) {
            console.log(err);
            callback(req, res, 1, err.message, []);
        }
    }

    async generateClassData(req, res) {
        try {
            res.setTimeout(1000 * 60 * 10); // 不设置的话，处理时间过长，会触发默认的响应超时，报错(前端报错，后台还继续在处理)
            const data = JSON.parse(req.body.data);
            await billsGuidanceFacade.generateClassData(data.libID);
            callback(req, res, 0, '', []);
        }
        catch (err) {
            console.log(err);
            callback(req, res, 1, err.message, []);
        }
    }

    async autoSetMaterial(req, res) {
        try {
            res.setTimeout(1000 * 60 * 10); // 不设置的话，处理时间过长，会触发默认的响应超时，报错(前端报错，后台还继续在处理)
            const data = JSON.parse(req.body.data);
            await billsGuidanceFacade.autoSetMaterial(data.libID);
            callback(req, res, 0, '', []);
        }
        catch (err) {
            console.log(err);
            callback(req, res, 1, err.message, []);
        }
    }

    async exportClassExcel(req, res) {
        try {
            const excelData = await billsGuidanceFacade.getClassExcelData(req.query.libID);
            console.log('start-build');
            const buffer = excel.build([{ name: "清单分类库", data: excelData }], { '!cols': [{ wch: 6 }, { wch: 12 }, { wch: 14 }, { wch: 24 }, { wch: 45 }, { wch: 20 }, { wch: 30 }, { wch: 30 }] });
            console.log('end-build');
            const filePath = './public/export.xlsx';
            fs.writeFileSync(filePath, buffer, 'binary');
            const stats = fs.statSync(filePath);
            // 下载相关header
            res.set({
                'Content-Type': 'application/octet-stream',
                'Content-Disposition': 'attachment; filename=billClass.xlsx',
                'Content-Length': stats.size
            });
            fs.createReadStream(filePath).pipe(res);
            fs.unlink(filePath);
        }
        catch (err) {
            console.log(err);
            response.end(error);
        }
    }

    async testItems(req, res) {
        try {
            let data = JSON.parse(req.body.data);
            let rst = await billsGuidanceFacade.testItems(data.libID);
            res.json({ error: 0, data: rst, message: '' });
        }
        catch (error) {
            res.json({ error: 1, data: null, message: error });

        }
    }
}

export default BillsGuideLibController;