123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429 |
- 'use strict';
- /**
- *
- *
- * @author Mai
- * @date
- * @version
- */
- const auditConst = require('../const/audit');
- const accountGroup = require('../const/account_group').group;
- const sendToWormhole = require('stream-wormhole');
- const path = require('path');
- module.exports = app => {
- class SubProjController extends app.BaseController {
- /**
- * 概算投资
- *
- * @param ctx
- * @returns {Promise<void>}
- */
- async index(ctx) {
- try {
- const renderData = {
- jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.subProject.list),
- auditConst,
- };
- renderData.budgetStd = await ctx.service.budgetStd.getDataByProjectId(ctx.session.sessionProject.id);
- renderData.projectList = await ctx.service.subProject.getSubProject(ctx.session.sessionProject.id, ctx.session.sessionUser.accountId, ctx.session.sessionUser.is_admin);
- renderData.tenderList = await ctx.service.tender.getManageTenderList(ctx.session.sessionProject.id);
- const accountList = await ctx.service.projectAccount.getAllDataByCondition({
- where: { project_id: ctx.session.sessionProject.id, enable: 1 },
- columns: ['id', 'name', 'company', 'role', 'enable', 'is_admin', 'account_group', 'mobile'],
- });
- renderData.accountList = accountList;
- const unitList = await ctx.service.constructionUnit.getAllDataByCondition({ where: { pid: ctx.session.sessionProject.id } });
- renderData.accountGroup = unitList.map(item => {
- const groupList = accountList.filter(item1 => item1.company === item.name);
- return { groupName: item.name, groupList };
- });
- renderData.permissionConst = ctx.service.subProjPermission.PermissionConst;
- renderData.companys = await this.ctx.service.constructionUnit.getAllDataByCondition({ where: { pid: ctx.session.sessionProject.id } });
- renderData.templates = await this.ctx.service.filingTemplateList.getAllTemplate(ctx.session.sessionProject.id);
- await this.layout('sub_proj/index.ejs', renderData, 'sub_proj/modal.ejs');
- } catch (err) {
- console.log(err);
- ctx.log(err);
- ctx.session.postError = err.toString();
- ctx.redirect(this.menu.menu.dashboard.url);
- }
- }
- async addFolder(ctx) {
- try {
- const data = JSON.parse(ctx.request.body.data);
- if (!data.name || data.name.length > 100) throw '文件夹名称有误';
- const result = await ctx.service.subProject.addFolder(data);
- ctx.body = { err: 0, msg: '', data: result };
- } catch (err) {
- ctx.log(err);
- ctx.ajaxErrorBody(err, '新建文件夹失败');
- }
- }
- async addProj(ctx) {
- try {
- const data = JSON.parse(ctx.request.body.data);
- if (!data.name || data.name.length > 100) throw '项目名称有误';
- const result = await ctx.service.subProject.addSubProject(data);
- ctx.body = { err: 0, msg: '', data: result };
- } catch (err) {
- ctx.log(err);
- ctx.ajaxErrorBody(err, '新建项目失败');
- }
- }
- async dragTo(ctx) {
- try {
- const data = JSON.parse(ctx.request.body.data);
- if (!data.drag_id || !data.drop_id) throw '提交数据错误';
- const result = await ctx.service.subProject.dragTo(data);
- ctx.body = { err: 0, msg: '', data: result };
- } catch (err) {
- ctx.log(err);
- ctx.ajaxErrorBody(err, '调整所属文件夹失败');
- }
- }
- async move(ctx) {
- try {
- const data = JSON.parse(ctx.request.body.data);
- if (!data.id || !data.type) throw '提交数据错误';
- const result = await ctx.service.subProject.move(data);
- ctx.body = { err: 0, msg: '', data: result };
- } catch (err) {
- ctx.log(err);
- ctx.ajaxErrorBody(err, '调整所属文件夹失败');
- }
- }
- async del(ctx) {
- try {
- const data = JSON.parse(ctx.request.body.data);
- if (!data.id) throw '参数有误';
- const result = await ctx.service.subProject.del(data.id);
- ctx.body = { err: 0, msg: '', data: result };
- } catch(err) {
- ctx.log(err);
- ctx.ajaxErrorBody(err, '删除项目失败');
- }
- }
- async save(ctx) {
- try {
- const data = JSON.parse(ctx.request.body.data);
- if (!data.id) throw '参数有误';
- let result = null;
- if (data.name !== undefined) {
- if (!data.name || data.name.length > 100) throw '项目名称有误';
- result = await ctx.service.subProject.save({ id: data.id, name: data.name });
- } else if (data.rela_tender !== undefined) {
- result = await ctx.service.subProject.setRelaTender({ id: data.id, rela_tender: data.rela_tender });
- } else if (data.std_id !== undefined) {
- result = await ctx.service.subProject.setBudgetStd({ id: data.id, std_id: data.std_id });
- } else if (data.management !== undefined) {
- result = await ctx.service.subProject.setManagement({ id: data.id, management: data.management, filingTemplate: data.filingTemplate });
- }
- ctx.body = { err: 0, msg: '', data: { update: [result] } };
- } catch(err) {
- ctx.log(err);
- ctx.ajaxErrorBody(err, '保存数据失败');
- }
- }
- async refresh(ctx) {
- try {
- const data = JSON.parse(ctx.request.body.data);
- if (!data.id) throw '参数有误';
- const result = await ctx.service.subProject.refreshManagementPermission({ id: data.id });
- ctx.body = { err: 0, msg: '', data: result };
- } catch(err) {
- ctx.log(err);
- ctx.ajaxErrorBody(err, '保存数据失败');
- }
- }
- async rela(ctx) {
- try {
- const id = ctx.query.id;
- const projectList = await ctx.service.subProject.getSubProject(this.ctx.session.sessionProject.id, this.ctx.session.sessionUser.accountId, true);
- const otherProj = projectList.filter(x => { return x.id !== id || !x.rela_tender || x.is_folder });
- const _ = ctx.helper._;
- const otherRela = _.map(_.map(otherProj, 'rela_tender').join(',').split(','), _.toInteger);
- const tenderList = await ctx.service.tender.getList4Select('stage');
- ctx.body = {
- err: 0,
- msg: '',
- data: tenderList.filter(x => { return otherRela.indexOf(x.id) === -1})
- .map(y => { return {id: y.id, name: y.name, lastStageOrder: y.lastStage.order, lastStageStatus: auditConst.stage.statusString[y.lastStage.status], category: y.category}}),
- };
- } catch (err) {
- ctx.log(err);
- ctx.postError(err, '获取数据失败');
- }
- }
- async saveRela(ctx) {
- try {
- const data = JSON.parse(ctx.request.body.data);
- if (!data.id || data.rela_tender === undefined) throw '参数有误';
- const permission = ctx.session.sessionUser.is_admin
- ? ctx.service.subProjPermission.adminPermission
- : await ctx.service.subProjPermission.getSubProjectUserPermission(data.id, ctx.session.sessionUser.accountId);
- if (!permission || permission.manage_permission.indexOf(ctx.service.subProjPermission.PermissionConst.manage.rela.value) < 0) throw '您无权进行该操作';
- const result = await ctx.service.subProject.setRelaTender({ id: data.id, rela_tender: data.rela_tender || '' });
- ctx.body = { err: 0, msg: '', data: { update: [result] } };
- } catch(err) {
- ctx.log(err);
- ctx.ajaxErrorBody(err, '保存数据失败');
- }
- }
- async member(ctx) {
- try {
- const data = JSON.parse(ctx.request.body.data);
- const member = await ctx.service.subProjPermission.getPermission(data.id);
- ctx.body = { err: 0, msg: '', data: member };
- } catch (err) {
- ctx.log(err);
- ctx.ajaxErrorBody(err, '查询项目成员失败');
- }
- }
- async memberSave(ctx) {
- try {
- const data = JSON.parse(ctx.request.body.data);
- if (!data.id) throw '参数有误';
- await ctx.service.subProjPermission.savePermission(data.id, data.member);
- ctx.body = { err: 0, msg: '', data: '' };
- } catch (err) {
- ctx.log(err);
- ctx.ajaxErrorBody(err, '保存数据失败');
- }
- }
- async info(ctx) {
- try {
- const info = await this.ctx.service.subProjInfo.getInfo(ctx.subProject.id);
- info.lx_tp = await this.ctx.service.budgetGu.getSumTp(ctx.subProject.budget_id);
- info.cb_tp = await this.ctx.service.budgetGai.getSumTp(ctx.subProject.budget_id);
- info.sgt_tp = await this.ctx.service.budgetYu.getSumTp(ctx.subProject.budget_id);
- info.zbys_tp = await this.ctx.service.budgetZb.getSumTp(ctx.subProject.budget_id);
- const renderData = {
- info,
- jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.subProject.info),
- };
- await this.layout('sub_proj/info.ejs', renderData);
- } catch (err) {
- ctx.log(err);
- }
- }
- async dataIndex(ctx) {
- try {
- const info = await this.ctx.service.subProjInfo.getInfo(ctx.subProject.id);
- const renderData = {
- info,
- jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.subProject.data),
- };
- await this.layout('sub_proj/data_index.ejs', renderData);
- } catch (err) {
- ctx.log(err);
- }
- }
- async saveInfo(ctx) {
- try {
- const data = JSON.parse(ctx.request.body.data);
- const result = await ctx.service.subProjInfo.saveInfo(ctx.subProject.id, data);
- ctx.body = { err: 0, msg: '', data: result };
- } catch(err) {
- ctx.log(err);
- }
- }
- async progress(ctx) {
- try {
- const renderData = {
- jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.subProject.progress),
- };
- await this.layout('sub_proj/progress.ejs', renderData, 'sub_proj/progress_modal.ejs');
- } catch (err) {
- ctx.log(err);
- ctx.postError(err, '查看阶段进度')
- }
- }
- async load(ctx) {
- try {
- const data = JSON.parse(ctx.request.body.data);
- const filter = data.filter.split(';');
- const result = {};
- for (const f of filter) {
- switch(f) {
- case 'progress':
- result[f] = await ctx.service.subProjProgress.getData(ctx.subProject);
- break;
- case 'progress_file':
- result[f] = await ctx.service.subProjFile.getData(ctx.subProject.id, 'progress');
- break;
- case 'push':
- result[f] = await ctx.service.subProjPush.getData(ctx.subProject.id);
- break;
- case 'push_file':
- result[f] = await ctx.service.subProjFile.getData(ctx.subProject.id, 'push');
- break;
- default:
- continue;
- }
- }
- ctx.body = { err: 0, msg: '', data: result };
- } catch(err) {
- ctx.log(err);
- ctx.ajaxErrorBody(err, '获取阶段进度数据有误');
- }
- }
- async _progressBase(subProj, type, data) {
- if (isNaN(data.id) || data.id <= 0) throw '数据错误';
- if (type !== 'add') {
- if (isNaN(data.count) || data.count <= 0) data.count = 1;
- }
- switch (type) {
- case 'add':
- return await this.ctx.service.subProjProgress.addProgressNode(subProj.id, data.id, data.count);
- case 'delete':
- return await this.ctx.service.subProjProgress.delete(subProj.id, data.id, data.count);
- case 'up-move':
- return await this.ctx.service.subProjProgress.upMoveNode(subProj.id, data.id, data.count);
- case 'down-move':
- return await this.ctx.service.subProjProgress.downMoveNode(subProj.id, data.id, data.count);
- case 'up-level':
- return await this.ctx.service.subProjProgress.upLevelNode(subProj.id, data.id, data.count);
- case 'down-level':
- return await this.ctx.service.subProjProgress.downLevelNode(subProj.id, data.id, data.count);
- }
- }
- async progressUpdate(ctx) {
- try {
- const data = JSON.parse(ctx.request.body.data);
- if (!data.postType || !data.postData) throw '数据错误';
- const responseData = { err: 0, msg: '', data: {} };
- switch (data.postType) {
- case 'add':
- case 'delete':
- case 'up-move':
- case 'down-move':
- case 'up-level':
- case 'down-level':
- responseData.data = await this._progressBase(ctx.subProject, data.postType, data.postData);
- break;
- case 'update':
- responseData.data = await this.ctx.service.subProjProgress.updateInfos(ctx.subProject.id, data.postData);
- break;
- break;
- default:
- throw '未知操作';
- }
- ctx.body = responseData;
- } catch (err) {
- this.log(err);
- ctx.body = this.ajaxErrorBody(err, '数据错误');
- }
- }
- async push(ctx) {
- try {
- const renderData = {
- jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.subProject.push),
- };
- await this.layout('sub_proj/push.ejs', renderData, 'sub_proj/push_modal.ejs');
- } catch (err) {
- ctx.log(err);
- }
- }
- async pushUpdate(ctx) {
- try {
- const data = JSON.parse(ctx.request.body.data);
- const result = await ctx.service.subProjPush.updateDatas(data);
- ctx.body = { err: 0, msg: '', data: result };
- } catch (error) {
- ctx.helper.log(error);
- ctx.body = this.ajaxErrorBody(error, '提交数据失败,请重试');
- }
- }
- /**
- * 上传附件
- * @param {Object} ctx - egg全局变量
- * @return {void}
- */
- async uploadFile(ctx) {
- let stream;
- try {
- const parts = ctx.multipart({autoFields: true});
- let index = 0;
- const create_time = Date.parse(new Date()) / 1000;
- let stream = await parts();
- const user = await ctx.service.projectAccount.getDataById(ctx.session.sessionUser.accountId);
- const rela_id = parts.field.rela_id;
- const uploadfiles = [];
- while (stream !== undefined) {
- if (!stream.filename) throw '未发现上传文件!';
- const fileInfo = path.parse(stream.filename);
- const filepath = `sp/progress/${ctx.subProject.id}/${ctx.moment().format('YYYYMMDD')}/${create_time + '_' + index + fileInfo.ext}`;
- // 保存文件
- await ctx.app.fujianOss.put(ctx.app.config.fujianOssFolder + filepath, stream);
- await sendToWormhole(stream);
- // 插入到stage_pay对应的附件列表中
- uploadfiles.push({
- rela_id,
- filename: fileInfo.name,
- fileext: fileInfo.ext,
- filesize: Array.isArray(parts.field.size) ? parts.field.size[index] : parts.field.size,
- filepath,
- });
- ++index;
- if (Array.isArray(parts.field.size) && index < parts.field.size.length) {
- stream = await parts();
- } else {
- stream = undefined;
- }
- }
- const result = await ctx.service.subProjFile.addFiles(ctx.subProject.id, ctx.request.url.split('/')[3], uploadfiles, user);
- ctx.body = {err: 0, msg: '', data: result};
- } catch (error) {
- ctx.log(error);
- // 失败需要消耗掉stream 以防卡死
- if (stream) await sendToWormhole(stream);
- ctx.body = this.ajaxErrorBody(error, '上传附件失败,请重试');
- }
- }
- async deleteFile(ctx) {
- try{
- const data = JSON.parse(ctx.request.body.data);
- if (!data) throw '缺少参数';
- const result = await ctx.service.subProjFile.delFiles(data);
- ctx.body = { err: 0, msg: '', data: result };
- } catch(error) {
- this.log(error);
- ctx.ajaxErrorBody(error, '删除附件失败');
- }
- }
- }
- return SubProjController;
- };
|