'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;