sub_proj_controller.js 19 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429
  1. 'use strict';
  2. /**
  3. *
  4. *
  5. * @author Mai
  6. * @date
  7. * @version
  8. */
  9. const auditConst = require('../const/audit');
  10. const accountGroup = require('../const/account_group').group;
  11. const sendToWormhole = require('stream-wormhole');
  12. const path = require('path');
  13. module.exports = app => {
  14. class SubProjController extends app.BaseController {
  15. /**
  16. * 概算投资
  17. *
  18. * @param ctx
  19. * @returns {Promise<void>}
  20. */
  21. async index(ctx) {
  22. try {
  23. const renderData = {
  24. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.subProject.list),
  25. auditConst,
  26. };
  27. renderData.budgetStd = await ctx.service.budgetStd.getDataByProjectId(ctx.session.sessionProject.id);
  28. renderData.projectList = await ctx.service.subProject.getSubProject(ctx.session.sessionProject.id, ctx.session.sessionUser.accountId, ctx.session.sessionUser.is_admin);
  29. renderData.tenderList = await ctx.service.tender.getManageTenderList(ctx.session.sessionProject.id);
  30. const accountList = await ctx.service.projectAccount.getAllDataByCondition({
  31. where: { project_id: ctx.session.sessionProject.id, enable: 1 },
  32. columns: ['id', 'name', 'company', 'role', 'enable', 'is_admin', 'account_group', 'mobile'],
  33. });
  34. renderData.accountList = accountList;
  35. const unitList = await ctx.service.constructionUnit.getAllDataByCondition({ where: { pid: ctx.session.sessionProject.id } });
  36. renderData.accountGroup = unitList.map(item => {
  37. const groupList = accountList.filter(item1 => item1.company === item.name);
  38. return { groupName: item.name, groupList };
  39. });
  40. renderData.permissionConst = ctx.service.subProjPermission.PermissionConst;
  41. renderData.companys = await this.ctx.service.constructionUnit.getAllDataByCondition({ where: { pid: ctx.session.sessionProject.id } });
  42. renderData.templates = await this.ctx.service.filingTemplateList.getAllTemplate(ctx.session.sessionProject.id);
  43. await this.layout('sub_proj/index.ejs', renderData, 'sub_proj/modal.ejs');
  44. } catch (err) {
  45. console.log(err);
  46. ctx.log(err);
  47. ctx.session.postError = err.toString();
  48. ctx.redirect(this.menu.menu.dashboard.url);
  49. }
  50. }
  51. async addFolder(ctx) {
  52. try {
  53. const data = JSON.parse(ctx.request.body.data);
  54. if (!data.name || data.name.length > 100) throw '文件夹名称有误';
  55. const result = await ctx.service.subProject.addFolder(data);
  56. ctx.body = { err: 0, msg: '', data: result };
  57. } catch (err) {
  58. ctx.log(err);
  59. ctx.ajaxErrorBody(err, '新建文件夹失败');
  60. }
  61. }
  62. async addProj(ctx) {
  63. try {
  64. const data = JSON.parse(ctx.request.body.data);
  65. if (!data.name || data.name.length > 100) throw '项目名称有误';
  66. const result = await ctx.service.subProject.addSubProject(data);
  67. ctx.body = { err: 0, msg: '', data: result };
  68. } catch (err) {
  69. ctx.log(err);
  70. ctx.ajaxErrorBody(err, '新建项目失败');
  71. }
  72. }
  73. async dragTo(ctx) {
  74. try {
  75. const data = JSON.parse(ctx.request.body.data);
  76. if (!data.drag_id || !data.drop_id) throw '提交数据错误';
  77. const result = await ctx.service.subProject.dragTo(data);
  78. ctx.body = { err: 0, msg: '', data: result };
  79. } catch (err) {
  80. ctx.log(err);
  81. ctx.ajaxErrorBody(err, '调整所属文件夹失败');
  82. }
  83. }
  84. async move(ctx) {
  85. try {
  86. const data = JSON.parse(ctx.request.body.data);
  87. if (!data.id || !data.type) throw '提交数据错误';
  88. const result = await ctx.service.subProject.move(data);
  89. ctx.body = { err: 0, msg: '', data: result };
  90. } catch (err) {
  91. ctx.log(err);
  92. ctx.ajaxErrorBody(err, '调整所属文件夹失败');
  93. }
  94. }
  95. async del(ctx) {
  96. try {
  97. const data = JSON.parse(ctx.request.body.data);
  98. if (!data.id) throw '参数有误';
  99. const result = await ctx.service.subProject.del(data.id);
  100. ctx.body = { err: 0, msg: '', data: result };
  101. } catch(err) {
  102. ctx.log(err);
  103. ctx.ajaxErrorBody(err, '删除项目失败');
  104. }
  105. }
  106. async save(ctx) {
  107. try {
  108. const data = JSON.parse(ctx.request.body.data);
  109. if (!data.id) throw '参数有误';
  110. let result = null;
  111. if (data.name !== undefined) {
  112. if (!data.name || data.name.length > 100) throw '项目名称有误';
  113. result = await ctx.service.subProject.save({ id: data.id, name: data.name });
  114. } else if (data.rela_tender !== undefined) {
  115. result = await ctx.service.subProject.setRelaTender({ id: data.id, rela_tender: data.rela_tender });
  116. } else if (data.std_id !== undefined) {
  117. result = await ctx.service.subProject.setBudgetStd({ id: data.id, std_id: data.std_id });
  118. } else if (data.management !== undefined) {
  119. result = await ctx.service.subProject.setManagement({ id: data.id, management: data.management, filingTemplate: data.filingTemplate });
  120. }
  121. ctx.body = { err: 0, msg: '', data: { update: [result] } };
  122. } catch(err) {
  123. ctx.log(err);
  124. ctx.ajaxErrorBody(err, '保存数据失败');
  125. }
  126. }
  127. async refresh(ctx) {
  128. try {
  129. const data = JSON.parse(ctx.request.body.data);
  130. if (!data.id) throw '参数有误';
  131. const result = await ctx.service.subProject.refreshManagementPermission({ id: data.id });
  132. ctx.body = { err: 0, msg: '', data: result };
  133. } catch(err) {
  134. ctx.log(err);
  135. ctx.ajaxErrorBody(err, '保存数据失败');
  136. }
  137. }
  138. async rela(ctx) {
  139. try {
  140. const id = ctx.query.id;
  141. const projectList = await ctx.service.subProject.getSubProject(this.ctx.session.sessionProject.id, this.ctx.session.sessionUser.accountId, true);
  142. const otherProj = projectList.filter(x => { return x.id !== id || !x.rela_tender || x.is_folder });
  143. const _ = ctx.helper._;
  144. const otherRela = _.map(_.map(otherProj, 'rela_tender').join(',').split(','), _.toInteger);
  145. const tenderList = await ctx.service.tender.getList4Select('stage');
  146. ctx.body = {
  147. err: 0,
  148. msg: '',
  149. data: tenderList.filter(x => { return otherRela.indexOf(x.id) === -1})
  150. .map(y => { return {id: y.id, name: y.name, lastStageOrder: y.lastStage.order, lastStageStatus: auditConst.stage.statusString[y.lastStage.status], category: y.category}}),
  151. };
  152. } catch (err) {
  153. ctx.log(err);
  154. ctx.postError(err, '获取数据失败');
  155. }
  156. }
  157. async saveRela(ctx) {
  158. try {
  159. const data = JSON.parse(ctx.request.body.data);
  160. if (!data.id || data.rela_tender === undefined) throw '参数有误';
  161. const permission = ctx.session.sessionUser.is_admin
  162. ? ctx.service.subProjPermission.adminPermission
  163. : await ctx.service.subProjPermission.getSubProjectUserPermission(data.id, ctx.session.sessionUser.accountId);
  164. if (!permission || permission.manage_permission.indexOf(ctx.service.subProjPermission.PermissionConst.manage.rela.value) < 0) throw '您无权进行该操作';
  165. const result = await ctx.service.subProject.setRelaTender({ id: data.id, rela_tender: data.rela_tender || '' });
  166. ctx.body = { err: 0, msg: '', data: { update: [result] } };
  167. } catch(err) {
  168. ctx.log(err);
  169. ctx.ajaxErrorBody(err, '保存数据失败');
  170. }
  171. }
  172. async member(ctx) {
  173. try {
  174. const data = JSON.parse(ctx.request.body.data);
  175. const member = await ctx.service.subProjPermission.getPermission(data.id);
  176. ctx.body = { err: 0, msg: '', data: member };
  177. } catch (err) {
  178. ctx.log(err);
  179. ctx.ajaxErrorBody(err, '查询项目成员失败');
  180. }
  181. }
  182. async memberSave(ctx) {
  183. try {
  184. const data = JSON.parse(ctx.request.body.data);
  185. if (!data.id) throw '参数有误';
  186. await ctx.service.subProjPermission.savePermission(data.id, data.member);
  187. ctx.body = { err: 0, msg: '', data: '' };
  188. } catch (err) {
  189. ctx.log(err);
  190. ctx.ajaxErrorBody(err, '保存数据失败');
  191. }
  192. }
  193. async info(ctx) {
  194. try {
  195. const info = await this.ctx.service.subProjInfo.getInfo(ctx.subProject.id);
  196. info.lx_tp = await this.ctx.service.budgetGu.getSumTp(ctx.subProject.budget_id);
  197. info.cb_tp = await this.ctx.service.budgetGai.getSumTp(ctx.subProject.budget_id);
  198. info.sgt_tp = await this.ctx.service.budgetYu.getSumTp(ctx.subProject.budget_id);
  199. info.zbys_tp = await this.ctx.service.budgetZb.getSumTp(ctx.subProject.budget_id);
  200. const renderData = {
  201. info,
  202. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.subProject.info),
  203. };
  204. await this.layout('sub_proj/info.ejs', renderData);
  205. } catch (err) {
  206. ctx.log(err);
  207. }
  208. }
  209. async dataIndex(ctx) {
  210. try {
  211. const info = await this.ctx.service.subProjInfo.getInfo(ctx.subProject.id);
  212. const renderData = {
  213. info,
  214. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.subProject.data),
  215. };
  216. await this.layout('sub_proj/data_index.ejs', renderData);
  217. } catch (err) {
  218. ctx.log(err);
  219. }
  220. }
  221. async saveInfo(ctx) {
  222. try {
  223. const data = JSON.parse(ctx.request.body.data);
  224. const result = await ctx.service.subProjInfo.saveInfo(ctx.subProject.id, data);
  225. ctx.body = { err: 0, msg: '', data: result };
  226. } catch(err) {
  227. ctx.log(err);
  228. }
  229. }
  230. async progress(ctx) {
  231. try {
  232. const renderData = {
  233. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.subProject.progress),
  234. };
  235. await this.layout('sub_proj/progress.ejs', renderData, 'sub_proj/progress_modal.ejs');
  236. } catch (err) {
  237. ctx.log(err);
  238. ctx.postError(err, '查看阶段进度')
  239. }
  240. }
  241. async load(ctx) {
  242. try {
  243. const data = JSON.parse(ctx.request.body.data);
  244. const filter = data.filter.split(';');
  245. const result = {};
  246. for (const f of filter) {
  247. switch(f) {
  248. case 'progress':
  249. result[f] = await ctx.service.subProjProgress.getData(ctx.subProject);
  250. break;
  251. case 'progress_file':
  252. result[f] = await ctx.service.subProjFile.getData(ctx.subProject.id, 'progress');
  253. break;
  254. case 'push':
  255. result[f] = await ctx.service.subProjPush.getData(ctx.subProject.id);
  256. break;
  257. case 'push_file':
  258. result[f] = await ctx.service.subProjFile.getData(ctx.subProject.id, 'push');
  259. break;
  260. default:
  261. continue;
  262. }
  263. }
  264. ctx.body = { err: 0, msg: '', data: result };
  265. } catch(err) {
  266. ctx.log(err);
  267. ctx.ajaxErrorBody(err, '获取阶段进度数据有误');
  268. }
  269. }
  270. async _progressBase(subProj, type, data) {
  271. if (isNaN(data.id) || data.id <= 0) throw '数据错误';
  272. if (type !== 'add') {
  273. if (isNaN(data.count) || data.count <= 0) data.count = 1;
  274. }
  275. switch (type) {
  276. case 'add':
  277. return await this.ctx.service.subProjProgress.addProgressNode(subProj.id, data.id, data.count);
  278. case 'delete':
  279. return await this.ctx.service.subProjProgress.delete(subProj.id, data.id, data.count);
  280. case 'up-move':
  281. return await this.ctx.service.subProjProgress.upMoveNode(subProj.id, data.id, data.count);
  282. case 'down-move':
  283. return await this.ctx.service.subProjProgress.downMoveNode(subProj.id, data.id, data.count);
  284. case 'up-level':
  285. return await this.ctx.service.subProjProgress.upLevelNode(subProj.id, data.id, data.count);
  286. case 'down-level':
  287. return await this.ctx.service.subProjProgress.downLevelNode(subProj.id, data.id, data.count);
  288. }
  289. }
  290. async progressUpdate(ctx) {
  291. try {
  292. const data = JSON.parse(ctx.request.body.data);
  293. if (!data.postType || !data.postData) throw '数据错误';
  294. const responseData = { err: 0, msg: '', data: {} };
  295. switch (data.postType) {
  296. case 'add':
  297. case 'delete':
  298. case 'up-move':
  299. case 'down-move':
  300. case 'up-level':
  301. case 'down-level':
  302. responseData.data = await this._progressBase(ctx.subProject, data.postType, data.postData);
  303. break;
  304. case 'update':
  305. responseData.data = await this.ctx.service.subProjProgress.updateInfos(ctx.subProject.id, data.postData);
  306. break;
  307. break;
  308. default:
  309. throw '未知操作';
  310. }
  311. ctx.body = responseData;
  312. } catch (err) {
  313. this.log(err);
  314. ctx.body = this.ajaxErrorBody(err, '数据错误');
  315. }
  316. }
  317. async push(ctx) {
  318. try {
  319. const renderData = {
  320. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.subProject.push),
  321. };
  322. await this.layout('sub_proj/push.ejs', renderData, 'sub_proj/push_modal.ejs');
  323. } catch (err) {
  324. ctx.log(err);
  325. }
  326. }
  327. async pushUpdate(ctx) {
  328. try {
  329. const data = JSON.parse(ctx.request.body.data);
  330. const result = await ctx.service.subProjPush.updateDatas(data);
  331. ctx.body = { err: 0, msg: '', data: result };
  332. } catch (error) {
  333. ctx.helper.log(error);
  334. ctx.body = this.ajaxErrorBody(error, '提交数据失败,请重试');
  335. }
  336. }
  337. /**
  338. * 上传附件
  339. * @param {Object} ctx - egg全局变量
  340. * @return {void}
  341. */
  342. async uploadFile(ctx) {
  343. let stream;
  344. try {
  345. const parts = ctx.multipart({autoFields: true});
  346. let index = 0;
  347. const create_time = Date.parse(new Date()) / 1000;
  348. let stream = await parts();
  349. const user = await ctx.service.projectAccount.getDataById(ctx.session.sessionUser.accountId);
  350. const rela_id = parts.field.rela_id;
  351. const uploadfiles = [];
  352. while (stream !== undefined) {
  353. if (!stream.filename) throw '未发现上传文件!';
  354. const fileInfo = path.parse(stream.filename);
  355. const filepath = `sp/progress/${ctx.subProject.id}/${ctx.moment().format('YYYYMMDD')}/${create_time + '_' + index + fileInfo.ext}`;
  356. // 保存文件
  357. await ctx.app.fujianOss.put(ctx.app.config.fujianOssFolder + filepath, stream);
  358. await sendToWormhole(stream);
  359. // 插入到stage_pay对应的附件列表中
  360. uploadfiles.push({
  361. rela_id,
  362. filename: fileInfo.name,
  363. fileext: fileInfo.ext,
  364. filesize: Array.isArray(parts.field.size) ? parts.field.size[index] : parts.field.size,
  365. filepath,
  366. });
  367. ++index;
  368. if (Array.isArray(parts.field.size) && index < parts.field.size.length) {
  369. stream = await parts();
  370. } else {
  371. stream = undefined;
  372. }
  373. }
  374. const result = await ctx.service.subProjFile.addFiles(ctx.subProject.id, ctx.request.url.split('/')[3], uploadfiles, user);
  375. ctx.body = {err: 0, msg: '', data: result};
  376. } catch (error) {
  377. ctx.log(error);
  378. // 失败需要消耗掉stream 以防卡死
  379. if (stream) await sendToWormhole(stream);
  380. ctx.body = this.ajaxErrorBody(error, '上传附件失败,请重试');
  381. }
  382. }
  383. async deleteFile(ctx) {
  384. try{
  385. const data = JSON.parse(ctx.request.body.data);
  386. if (!data) throw '缺少参数';
  387. const result = await ctx.service.subProjFile.delFiles(data);
  388. ctx.body = { err: 0, msg: '', data: result };
  389. } catch(error) {
  390. this.log(error);
  391. ctx.ajaxErrorBody(error, '删除附件失败');
  392. }
  393. }
  394. }
  395. return SubProjController;
  396. };