pm_controller.js 47 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039
  1. /**
  2. * Created by Mai on 2017/1/18.
  3. */
  4. const UnitPriceFileModel = require("../../glj/models/unit_price_file_model");
  5. const moment = require('moment');
  6. const CompilationModel = require("../../users/models/compilation_model");
  7. const UserModel = require("../../users/models/user_model");
  8. const userModelObj = new UserModel();
  9. let mongoose = require('mongoose');
  10. let ProjectsData = require('../models/project_model').project;
  11. let labourCoe = require('../../main/facade/labour_coe_facade');
  12. let projType = require('../models/project_model').projType;
  13. let fileType = require('../models/project_model').fileType;
  14. const engineering = require("../../common/const/engineering");
  15. let EngineeringLibModel = require("../../users/models/engineering_lib_model");
  16. let fee_rate_facade = require("../../fee_rates/facade/fee_rates_facade");
  17. let billsModel = require('../../main/models/bills').model;
  18. let rationsModel = require('../../main/models/ration').model;
  19. let projectModel = mongoose.model('projects');
  20. let unitPriceFileModel = mongoose.model('unit_price_file');
  21. let feeRateFileModel = mongoose.model('fee_rate_file');
  22. let asyncTool = require('async');
  23. let pm_facade = require('../facade/pm_facade');
  24. const userModel = mongoose.model('user');
  25. let config = require("../../../config/config.js");
  26. const optionModel = mongoose.model('options');
  27. const stdBillsGuidanceLibModel = mongoose.model('std_billsGuidance_lib');
  28. const fs = require('fs');
  29. const _ = require('lodash');
  30. const SectionTreeDao = require('../../complementary_ration_lib/models/sectionTreeModel');
  31. const uuidV1 = require('uuid/v1');
  32. let sectionTreeDao = new SectionTreeDao();
  33. let consts = require('../../main/models/project_consts');
  34. const rationLibModel = mongoose.model('std_ration_lib_map');
  35. const multiparty = require("multiparty");
  36. let logger = require("../../../logs/log_helper").logger;
  37. let rp = require('request-promise');
  38. const commonUtil = require('../../../public/common_util');
  39. //统一回调函数
  40. let callback = function (req, res, err, message, data) {
  41. res.json({ error: err, message: message, data: data });
  42. };
  43. module.exports = {
  44. checkRight: function (req, res) {
  45. if (typeof req.body.data === 'object') {
  46. req.body.data = JSON.stringify(req.body.data);
  47. }
  48. let data = JSON.parse(req.body.data);
  49. if (data.user_id) {
  50. return data.user_id === req.session.sessionUser.id;
  51. } else {
  52. return false;
  53. }
  54. },
  55. checkProjectRight: function (userId, projectId, callback) {
  56. ProjectsData.getProject(projectId).then(async function (result) {
  57. /**
  58. * result._doc.userID(Number): MongoDB
  59. * userId(String): Session.userID
  60. */
  61. let shareInfo = null;
  62. let isOpenShareProject = false;
  63. //判断是否是打开分享的项目,分享项目shareInfo不为null
  64. if (userId !== result.userID) {
  65. shareInfo = await pm_facade.getShareInfo(userId, result.ID);
  66. isOpenShareProject = true;
  67. }
  68. if ((userId === result.userID || shareInfo) && result._doc.projType === projType.tender) {
  69. const allowCooperate = (shareInfo || {}).allowCooperate;
  70. callback(true, result, isOpenShareProject, allowCooperate);
  71. } else {
  72. callback(false);
  73. }
  74. }).catch(function (err) {
  75. callback(false);
  76. });
  77. },
  78. getProjects: async function (req, res) {
  79. await ProjectsData.getUserProjects(req.session.sessionUser.id, req.session.sessionCompilation._id, function (err, message, data) {
  80. console.log(err);
  81. callback(req, res, err, message, data);
  82. });
  83. },
  84. updateProjects: async function (req, res) {
  85. let data = JSON.parse(req.body.data);
  86. try {
  87. await ProjectsData.updateUserProjects(req.session.sessionUser.id, req.session.sessionCompilation._id, req.session.sessionCompilation.name, req.session.sessionCompilation.overWriteUrl, data.updateData, function (err, message, data) {
  88. if (err === 0) {
  89. callback(req, res, err, message, data);
  90. } else {
  91. callback(req, res, 1, message, null);
  92. }
  93. });
  94. } catch (err) {
  95. callback(req, res, 1, String(err), null);
  96. }
  97. },
  98. // CSL, 2017-12-14 该方法用于项目属性:提交保存混合型数据,这些数据来自不同的表,包括projects.property、ration、bills、labour_coes.
  99. updateMixDatas: async function (req, res) {
  100. let datas = JSON.parse(req.body.data).mixDataArr;
  101. let functions = [];
  102. function updateFunc(model, cod, doc) {
  103. return function (cb) {
  104. model.update(cod, doc, cb);
  105. }
  106. };
  107. function updateLC() {
  108. return function (cb) {
  109. datas.labourCoes.updateData.projectID = datas.projectID;
  110. labourCoe.save(datas.labourCoes.updateData, cb);
  111. }
  112. };
  113. // 项目属性
  114. if (Object.keys(datas.properties).length > 0) {
  115. //基本信息特殊处理,更新建设项目
  116. if (datas.properties['property.basicInformation']) {
  117. let constructionProject = await pm_facade.getConstructionProject(datas.projectID);
  118. if (constructionProject) {
  119. functions.push(updateFunc(projectModel, { ID: constructionProject.ID }, { 'property.basicInformation': datas.properties['property.basicInformation'] }));
  120. }
  121. delete datas.properties['property.basicInformation'];
  122. }
  123. //建设项目-编制说明,更新建设项目
  124. if (datas.properties['property.compilationIllustrationProject']) {
  125. let constructionProject = await pm_facade.getConstructionProject(datas.projectID);
  126. if (constructionProject) {
  127. functions.push(updateFunc(projectModel, { ID: constructionProject.ID }, { 'property.compilationIllustration': datas.properties['property.compilationIllustrationProject'] }));
  128. }
  129. delete datas.properties['property.compilationIllustrationProject'];
  130. }
  131. functions.push(updateFunc(projectModel, { ID: datas.projectID }, datas.properties));
  132. };
  133. //选项
  134. if (datas.options && datas.options.updateData) {
  135. functions.push(updateFunc(optionModel, { user_id: req.session.sessionUser.id, compilation_id: req.session.sessionCompilation._id }, { 'options.GENERALOPTS': datas.options.updateData }));
  136. }
  137. // 人工系数
  138. if (datas.labourCoes && datas.labourCoes.updateData) {
  139. functions.push(updateLC());
  140. };
  141. // 清单:每文档doc只存储一条清单,每条清单都必须定位一次文档,无法合并处理
  142. if (datas.bills && datas.bills.length > 0) {
  143. for (let bill of datas.bills) {
  144. functions.push(updateFunc(billsModel, { projectID: datas.projectID, ID: bill.ID, deleteInfo: null }, bill));
  145. };
  146. };
  147. // 定额:每文档doc只存储一条定额,每条定额都必须定位一次文档,无法合并处理
  148. if (datas.rations && datas.rations.length > 0) {
  149. for (let ration of datas.rations) {
  150. functions.push(updateFunc(rationsModel, { projectID: datas.projectID, ID: ration.ID, deleteInfo: null }, ration));
  151. };
  152. };
  153. asyncTool.parallel(functions, function (err, result) {
  154. {
  155. if (!err) {
  156. res.json({ error: 0, message: err, data: result });
  157. } else {
  158. res.json({ error: 1, message: err, data: null });
  159. }
  160. }
  161. });
  162. },
  163. updateFiles: async function (req, res) {
  164. let data = JSON.parse(req.body.data);
  165. let updateDatas = data.updateDatas;
  166. await ProjectsData.udpateUserFiles(req.session.sessionUser.id, updateDatas, function (err, message, data) {
  167. callback(req, res, err, message, data);
  168. });
  169. },
  170. defaultSettings: async function (req, res) {
  171. try {
  172. let data = JSON.parse(req.body.data);
  173. let projectID = data.projectID;
  174. let defaultSettingSc = await ProjectsData.defaultSettings(req.session.sessionUser.id, req.session.sessionCompilation._id, projectID);
  175. if (!defaultSettingSc) {
  176. throw '恢复失败';
  177. }
  178. res.json({ error: 0, message: '恢复成功', data: null });
  179. }
  180. catch (error) {
  181. console.log(error);
  182. res.json({ error: 1, message: error, data: null });
  183. }
  184. },
  185. /* copyProjects: function (req, res) {
  186. let data = JSON.parse(req.body.data);
  187. ProjectsData.copyUserProjects(req.session.sessionUser.id, req.session.sessionCompilation._id, data.updateData, function (err, message, data) {
  188. if (err === 0) {
  189. callback(req, res, err, message, data);
  190. } else {
  191. callback(req, res, err, message, null);
  192. }
  193. });
  194. },*/
  195. rename: function (req, res) {
  196. let data = JSON.parse(req.body.data);
  197. ProjectsData.rename(req.session.sessionUser.id, req.session.sessionCompilation._id, data, function (err, message) {
  198. callback(req, res, err, message, null);
  199. });
  200. },
  201. //project getData接口
  202. getData: function (projectID, callback, isReport, userID) {
  203. projectModel.findOne({ $or: [{ deleteInfo: null }, { 'deleteInfo.deleted': false }], ID: projectID }, '-_id').then(async function (project) {
  204. if (!project) {
  205. callback('', consts.projectConst.PROJECT_INFO, {});
  206. }
  207. let engineeringLibModel = new EngineeringLibModel();
  208. let engineeringInfo = project !== null && project.property.engineering_id !== undefined ?
  209. await engineeringLibModel.getEngineering(project.property.engineering_id) : null;
  210. //查找定额库的定额库编码
  211. if (Array.isArray(engineeringInfo.ration_lib)) {
  212. let rationLibIDs = engineeringInfo.ration_lib.map(data => data.id);
  213. let rationLibs = await rationLibModel.find({ ID: { $in: rationLibIDs } }, 'ID libCode');
  214. for (let rationLib of rationLibs) {
  215. let lib = engineeringInfo.ration_lib.find(data => data.id == rationLib.ID);
  216. lib.libCode = rationLib.libCode;
  217. }
  218. }
  219. let projInfo = project._doc;
  220. if (engineeringInfo !== null) {
  221. if (engineeringInfo.billsGuidance_lib) {
  222. for (let billsGuidanceLib of engineeringInfo.billsGuidance_lib) {
  223. let stdBillsGuidanceLib = await stdBillsGuidanceLibModel.findOne({ ID: billsGuidanceLib.id });
  224. if (stdBillsGuidanceLib) {
  225. billsGuidanceLib.type = stdBillsGuidanceLib.type ? stdBillsGuidanceLib.type : 1;
  226. }
  227. }
  228. }
  229. projInfo.engineeringInfo = engineeringInfo;
  230. }
  231. //读取建设项目的项目属性
  232. let constructionProperty = await ProjectsData.getConstructionProperty(projectID);
  233. // 文件类型(招/投标)
  234. projInfo.property.fileKind = constructionProperty && constructionProperty.fileKind || 1;
  235. //基本信息
  236. projInfo.property.basicInformation = constructionProperty && constructionProperty.basicInformation ? constructionProperty.basicInformation : [];
  237. //编制说明
  238. projInfo.property.compilationIllustrationProject = constructionProperty && constructionProperty.compilationIllustration ? constructionProperty.compilationIllustration : '';
  239. //获取单位工程完整目录结构
  240. let fullPath = await pm_facade.getFullPath(projectID);
  241. projInfo.fullPath = fullPath;
  242. // 获取分享的tip
  243. projInfo.shareTip = await pm_facade.getShareTip(projectID, 2);
  244. // 获取分享状态
  245. if (typeof userID === 'string') {
  246. projInfo.shareState = await pm_facade.getShareState(projectID, userID);
  247. }
  248. // 获取项目所属用户
  249. projInfo.owner = await userModel.findOne({_id: mongoose.Types.ObjectId(project.userID)}, 'real_name mobile').lean();
  250. projInfo.opener = await userModel.findOne({_id: mongoose.Types.ObjectId(userID)}, 'real_name mobile').lean();
  251. callback('', consts.projectConst.PROJECT_INFO, project);
  252. }, function (err) {
  253. callback(err, consts.projectConst.PROJECT_INFO, {});
  254. });
  255. },
  256. getProject: function (req, res) {
  257. let data = JSON.parse(req.body.data);
  258. let projectID = data.proj_id;
  259. ProjectsData.getUserProject(req.session.sessionUser.id, data.proj_id, async function (err, message, data) {
  260. if (err === 0) {
  261. let engineeringLibModel = new EngineeringLibModel();
  262. let engineeringInfo = data !== null && data.property.engineering_id !== undefined ?
  263. await engineeringLibModel.getEngineering(data.property.engineering_id) : null;
  264. let strData = JSON.stringify(data);
  265. let projInfo = JSON.parse(strData);
  266. if (engineeringInfo !== null) {
  267. if (engineeringInfo.billsGuidance_lib) {
  268. for (let billsGuidanceLib of engineeringInfo.billsGuidance_lib) {
  269. let stdBillsGuidanceLib = await stdBillsGuidanceLibModel.findOne({ ID: billsGuidanceLib.id });
  270. if (stdBillsGuidanceLib) {
  271. billsGuidanceLib.type = stdBillsGuidanceLib.type ? stdBillsGuidanceLib.type : 1;
  272. }
  273. }
  274. }
  275. projInfo.engineeringInfo = engineeringInfo;
  276. }
  277. //读取建设项目的项目属性
  278. let constructionProperty = await ProjectsData.getConstructionProperty(projectID);
  279. console.log(projectID);
  280. console.log(constructionProperty);
  281. //基本信息
  282. projInfo.property.basicInformation = constructionProperty && constructionProperty.basicInformation ? constructionProperty.basicInformation : [];
  283. //编制说明
  284. projInfo.property.compilationIllustrationProject = constructionProperty && constructionProperty.compilationIllustration ? constructionProperty.compilationIllustration : '';
  285. //获取单位工程完整目录结构
  286. let fullPath = await pm_facade.getFullPath(projectID);
  287. projInfo.fullPath = fullPath;
  288. callback(req, res, err, message, projInfo);
  289. } else {
  290. callback(req, res, err, message, null);
  291. }
  292. });
  293. },
  294. beforeOpenProject: function (req, res) {
  295. let data = JSON.parse(req.body.data);
  296. ProjectsData.beforeOpenProject(req.session.sessionUser.id, data.proj_id, data.updateData, function (err, message, data) {
  297. callback(req, res, err, message, data);
  298. });
  299. },
  300. getNewProjectID: function (req, res) {
  301. let data = JSON.parse(req.body.data);
  302. ProjectsData.getNewProjectID(data.count, function (err, message, data) {
  303. callback(req, res, err, message, data);
  304. });
  305. },
  306. // 项目管理首页
  307. index: async function (request, response) {
  308. //await pm_facade.prepareShareList();
  309. // 获取编办信息
  310. let sessionCompilation = request.session.sessionCompilation;
  311. if (sessionCompilation === undefined || sessionCompilation === null) {
  312. return response.redirect('/logout');
  313. }
  314. let compilationModel = new CompilationModel();
  315. //更新编办信息
  316. let compilationData = await compilationModel.getCompilationById(sessionCompilation._id);
  317. request.session.sessionCompilation = compilationData;
  318. sessionCompilation = request.session.sessionCompilation;
  319. //更新用户的使用过的费用定额列表
  320. let isFirst = await pm_facade.isFirst(request.session.sessionUser.id, compilationData._id.toString());
  321. // 清单计价
  322. let billValuation = sessionCompilation.bill_valuation !== undefined ?
  323. sessionCompilation.bill_valuation : [];
  324. // 获取标准库数据
  325. let engineeringLibModel = new EngineeringLibModel();
  326. billValuation = await engineeringLibModel.getLib(billValuation);
  327. // 定额计价
  328. let rationValuation = sessionCompilation.ration_valuation !== undefined ?
  329. sessionCompilation.ration_valuation : [];
  330. rationValuation = await engineeringLibModel.getLib(rationValuation);
  331. let absoluteUrl = compilationData.overWriteUrl ? request.app.locals.rootDir + compilationData.overWriteUrl : request.app.locals.rootDir;
  332. let overWriteUrl = fs.existsSync(absoluteUrl) && fs.statSync(absoluteUrl).isFile() ? compilationData.overWriteUrl : null;
  333. //欢迎页显示控制
  334. let [isShow, context] = await pm_facade.getWelcomeInfo(sessionCompilation._id, request.session.sessionUser, request.session.compilationVersion.includes('免费'));
  335. // 未读的分享项目数量
  336. const unreadShareList = await pm_facade.getUnreadShareListByCompilation(request.session.sessionUser.id, sessionCompilation._id);
  337. let renderData = {
  338. unreadShareList: JSON.stringify(unreadShareList),
  339. isFirst: isFirst,
  340. isShow: isShow,
  341. context: context,
  342. userAccount: request.session.userAccount,
  343. userID: request.session.sessionUser.id,
  344. compilationData: JSON.stringify(sessionCompilation),
  345. overWriteUrl: overWriteUrl,
  346. billValuation: JSON.stringify(billValuation.reverse()), // 按最新排序
  347. rationValuation: JSON.stringify(rationValuation),
  348. engineeringList: JSON.stringify(engineering.List),
  349. compilationName: sessionCompilation.name,
  350. versionName: request.session.compilationVersion,
  351. LicenseKey: config.getLicenseKey(process.env.NODE_ENV)
  352. };
  353. response.render('building_saas/pm/html/project-management.html', renderData);
  354. },
  355. //第一次进入该费用定额时准备的初始数据
  356. prepareInitialData: async function (request, response) {
  357. try {
  358. const data = {
  359. userID: request.session.sessionUser.id,
  360. compilationID: request.session.sessionCompilation._id,
  361. example: request.session.sessionCompilation.example
  362. };
  363. await redirectToImportServer(data, 'prepareInitialData', request);
  364. callback(request, response, 0, 'success', null);
  365. } catch (err) {
  366. console.log(err);
  367. callback(request, response, 1, err.toString(), null);
  368. }
  369. },
  370. // 获取单价文件列表
  371. getUnitFileList: async function (request, response) {
  372. let data = request.body.data;
  373. try {
  374. data = JSON.parse(data);
  375. let projectId = data.parentID !== undefined ? data.parentID : 0;
  376. if (isNaN(projectId) && projectId <= 0) {
  377. throw { msg: 'id数据有误!', err: 1 };
  378. }
  379. /*// 获取对应建设项目下所有的单位工程id
  380. let idList = await ProjectsData.getTenderByProjectId(projectId);
  381. if (idList.length <= 0) {
  382. throw {msg: '不存在对应单位工程', err: 0};
  383. }*/
  384. // 获取对应的单价文件
  385. let unitPriceFileModel = new UnitPriceFileModel();
  386. let unitPriceFileData = await unitPriceFileModel.getDataByRootProject(projectId);
  387. if (unitPriceFileData === null) {
  388. throw { msg: '不存在对应单价文件', err: 0 };
  389. }
  390. // 整理数据
  391. let unitPriceFileList = [];
  392. for (let unitPriceFile of unitPriceFileData) {
  393. let tmp = {
  394. name: unitPriceFile.name,
  395. id: unitPriceFile.id
  396. };
  397. unitPriceFileList.push(tmp);
  398. }
  399. callback(request, response, 0, '', unitPriceFileList);
  400. } catch (error) {
  401. console.log(error);
  402. let responseData = error.err === 1 ? null : [];
  403. callback(request, response, error.err, error.msg, responseData);
  404. }
  405. },
  406. getFeeRateFileList: async function (request, response) {
  407. let data = request.body.data;
  408. try {
  409. data = JSON.parse(data);
  410. let projectId = data.parentID !== undefined ? data.parentID : 0;
  411. if (isNaN(projectId) && projectId <= 0) {
  412. throw { msg: 'id数据有误!', err: 1 };
  413. }
  414. // 获取对应建设项目下所有的单位工程id
  415. let feeRateFileList = await fee_rate_facade.getFeeRatesByProject(projectId);
  416. callback(request, response, 0, '', feeRateFileList);
  417. } catch (error) {
  418. console.log(error);
  419. let responseData = error.err === 1 ? null : [];
  420. callback(request, response, error.err, error.msg, responseData);
  421. }
  422. },
  423. getGCDatas: async function (request, response) {
  424. let userID = request.session.sessionUser.id;
  425. let compilatoinId = request.session.sessionCompilation._id;
  426. let rst = [];
  427. let _projs = Object.create(null), _engs = Object.create(null), prefix = 'ID_';
  428. try {
  429. let gc_unitPriceFiles = await ProjectsData.getGCFiles(fileType.unitPriceFile, userID);
  430. let gc_feeRateFiles = await ProjectsData.getGCFiles(fileType.feeRateFile, userID);
  431. let gc_tenderFiles = await ProjectsData.getGCFiles(projType.tender, userID);
  432. for (let i = 0, len = gc_unitPriceFiles.length; i < len; i++) {
  433. let gc_uf = gc_unitPriceFiles[i];
  434. let theProj = _projs[prefix + gc_uf.root_project_id] || null;
  435. if (!theProj) {
  436. let tempProj = await ProjectsData.getProjectsByIds(userID, compilatoinId, [gc_uf.root_project_id]);
  437. if (tempProj.length > 0 && tempProj[0].projType !== projType.folder) {
  438. theProj = _projs[prefix + gc_uf.root_project_id] = tempProj[0]._doc;
  439. buildProj(theProj);
  440. }
  441. }
  442. if (theProj) {
  443. theProj.unitPriceFiles.push(gc_uf);
  444. }
  445. }
  446. for (let i = 0, len = gc_feeRateFiles.length; i < len; i++) {
  447. let gc_ff = gc_feeRateFiles[i];
  448. let theProj = _projs[prefix + gc_ff.rootProjectID] || null;
  449. if (!theProj) {
  450. let tempProj = await ProjectsData.getProjectsByIds(userID, compilatoinId, [gc_ff.rootProjectID]);
  451. if (tempProj.length > 0 && tempProj[0].projType !== projType.folder) {
  452. theProj = _projs[prefix + gc_ff.rootProjectID] = tempProj[0]._doc;
  453. buildProj(theProj);
  454. }
  455. }
  456. if (theProj) {
  457. theProj.feeRateFiles.push(gc_ff);
  458. }
  459. }
  460. if (gc_tenderFiles.length > 0) {
  461. for (let i = 0, len = gc_tenderFiles.length; i < len; i++) {
  462. let gc_t = gc_tenderFiles[i];
  463. let theEng = _engs[prefix + gc_t.ParentID] || null;
  464. if (!theEng) {
  465. let tempEngs = await ProjectsData.getProjectsByIds(userID, compilatoinId, [gc_t.ParentID]);
  466. if (tempEngs.length > 0 && tempEngs[0].projType === projType.engineering) {
  467. theEng = _engs[prefix + gc_t.ParentID] = tempEngs[0]._doc;
  468. theEng.children = [];
  469. }
  470. }
  471. if (theEng) {
  472. theEng.children.push(gc_t);
  473. let theProj = _projs[prefix + theEng.ParentID] || null;
  474. if (!theProj) {
  475. let tempProj = await ProjectsData.getProjectsByIds(userID, compilatoinId, [theEng.ParentID]);
  476. if (tempProj.length > 0 && tempProj[0].projType === projType.project) {
  477. theProj = _projs[prefix + theEng.ParentID] = tempProj[0]._doc;
  478. buildProj(theProj);
  479. }
  480. }
  481. if (theProj) {
  482. let isExist = false;
  483. for (let j = 0, jLen = theProj.children.length; j < jLen; j++) {
  484. if (theProj.children[j].ID === theEng.ID) {
  485. isExist = true;
  486. break;
  487. }
  488. }
  489. if (!isExist) {
  490. theProj.children.push(theEng);
  491. }
  492. }
  493. }
  494. }
  495. }
  496. for (let i in _projs) {
  497. rst.push(_projs[i]);
  498. }
  499. function buildProj(proj) {
  500. proj.children = [];
  501. proj.unitPriceFiles = [];
  502. proj.feeRateFiles = [];
  503. }
  504. callback(request, response, 0, 'success', rst);
  505. }
  506. catch (error) {
  507. callback(request, response, true, error, null);
  508. }
  509. },
  510. recGC: function (request, response) {
  511. let userID = request.session.sessionUser.id,
  512. compilationId = request.session.sessionCompilation._id;
  513. let data = JSON.parse(request.body.data);
  514. let nodes = data.nodes;
  515. ProjectsData.recGC(userID, compilationId, nodes, function (err, msg, data) {
  516. callback(request, response, err, msg, data);
  517. });
  518. },
  519. delGC: async function (request, response) {
  520. let data = JSON.parse(request.body.data);
  521. let delDatas = data.delDatas;
  522. let bulkProjs = [], bulkUFs = [], bulkFFs = [];
  523. try {
  524. for (let data of delDatas) {
  525. if (data.updateType === 'Project') {
  526. bulkProjs.push({ updateOne: { filter: { ID: data.ID }, update: { 'deleteInfo.completeDeleted': true } } });
  527. }
  528. else if (data.updateType === fileType.unitPriceFile) {
  529. bulkUFs.push({ updateOne: { filter: { id: data.ID }, update: { 'deleteInfo.completeDeleted': true } } });
  530. }
  531. else {
  532. bulkFFs.push({ updateOne: { filter: { ID: data.ID }, update: { 'deleteInfo.completeDeleted': true } } });
  533. }
  534. }
  535. if (bulkProjs.length > 0) {
  536. await projectModel.bulkWrite(bulkProjs);
  537. }
  538. if (bulkUFs.length > 0) {
  539. await unitPriceFileModel.bulkWrite(bulkUFs);
  540. }
  541. if (bulkFFs.length > 0) {
  542. await feeRateFileModel.bulkWrite(bulkFFs);
  543. }
  544. callback(request, response, 0, 'success', null);
  545. } catch (err) {
  546. callback(request, response, 1, err, null);
  547. }
  548. },
  549. moveProject: async function (req, res) {
  550. let result = {
  551. error: 0
  552. };
  553. try {
  554. let data = req.body.data;
  555. let rdata = await pm_facade.moveProject(data);
  556. result.data = rdata;
  557. } catch (err) {
  558. console.log(err);
  559. result.error = 1;
  560. result.message = err.message;
  561. }
  562. res.json(result);
  563. },
  564. copyProjects: async function (req, res) {
  565. let result = {
  566. error: 0
  567. };
  568. try {
  569. let data = { dataString: req.body.data, userID: req.session.sessionUser.id, compilationID: req.session.sessionCompilation._id };
  570. result = await redirectToImportServer(data, "copyProject", req);
  571. } catch (err) {
  572. console.log(err);
  573. result.error = 1;
  574. result.message = err.message;
  575. }
  576. res.json(result);
  577. },
  578. projectShareInfo: async function (req, res) {
  579. try {
  580. const data = JSON.parse(req.body.data);
  581. const shareList = await pm_facade.getShareList({ projectID: data.projectID });
  582. const shareInfoMap = await pm_facade.getShareInfoMap(null, shareList);
  583. const shareInfo = shareInfoMap[data.projectID] || [];
  584. //let shareInfo = await projectModel.findOne({ID: data.projectID, $or: [{deleteInfo: null}, {'deleteInfo.deleted': false}]}, '-_id shareInfo');
  585. callback(req, res, 0, 'success', shareInfo);
  586. }
  587. catch (err) {
  588. callback(req, res, 1, err, null);
  589. }
  590. },
  591. getInitialShareData: async function (req, res) {
  592. try {
  593. const { count, projectID } = JSON.parse(req.body.data);
  594. // 分享文件夹、建设项目,仅提供给专业版用户
  595. const proShareProjType = [projType.folder, projType.project];
  596. const project = await projectModel.findOne({ ID: projectID }, 'projType');
  597. if (project && proShareProjType.indexOf(project.projType) >= 0) {
  598. const isFree = userModelObj.isFreeFromSession(req.session.compilationVersion);
  599. if (isFree) {
  600. callback(req, res, 0, 'success', { isFree });
  601. return;
  602. }
  603. }
  604. const userID = req.session.sessionUser.id;
  605. // 最近分享
  606. const recentUsers = await pm_facade.getRecentShareList(userID, count);
  607. // 联系人
  608. const contacts = await userModelObj.getContacts(userID);
  609. // 分享过的人
  610. const sharedUsers = await pm_facade.getProjectShareList(projectID);
  611. callback(req, res, 0, 'success', { recentUsers, contacts, sharedUsers });
  612. } catch (err) {
  613. console.log(err);
  614. callback(req, res, 1, err.message, null);
  615. }
  616. },
  617. share: async function (req, res) {
  618. try {
  619. const data = JSON.parse(req.body.data);
  620. const { type, permissionType, shareData, projectID, count } = data;
  621. const userID = req.session.sessionUser.id;
  622. const shareDate = moment(Date.now()).format('YYYY-MM-DD HH:mm:ss');
  623. shareData.forEach(item => item.shareDate = shareDate);
  624. const task = [];
  625. // 是否只是单纯的更新分享选项,如果不是,需要重新获取最近分享和联系人
  626. let isSimpleUpdate = true;
  627. if (type === 'create') {
  628. isSimpleUpdate = false;
  629. // 生成分享记录
  630. const docs = shareData.map(item => ({
  631. ID: uuidV1(),
  632. projectID,
  633. owner: userID,
  634. receiver: item.userID,
  635. allowCooperate: item.allowCooperate,
  636. allowCopy: item.allowCopy,
  637. shareDate: item.shareDate,
  638. updateDate: item.shareDate
  639. }));
  640. task.push(pm_facade.addShareList(docs));
  641. // 分享即互相添加为联系人
  642. task.push(userModelObj.addContact(docs[0].owner, docs[0].receiver));
  643. } else if (type === 'update') {
  644. // 取消分享(以前项目管理界面可一次进行更新和取消)
  645. const cancelReceivers = shareData
  646. .filter(item => item.isCancel)
  647. .map(item => item.userID);
  648. if (cancelReceivers.length) {
  649. isSimpleUpdate = false;
  650. task.push(pm_facade.deleteShareList({ projectID, receiver: { $in: cancelReceivers } }));
  651. }
  652. // 更新分享选项
  653. const updateData = shareData
  654. .filter(item => !item.isCancel)
  655. .map(item => {
  656. const update = { updateDate: shareDate };
  657. if (commonUtil.isDef(item.allowCopy)) {
  658. update.allowCopy = item.allowCopy;
  659. }
  660. if (commonUtil.isDef(item.allowCooperate)) {
  661. update.allowCooperate = item.allowCooperate;
  662. }
  663. return {
  664. query: {
  665. projectID,
  666. receiver: item.userID
  667. },
  668. update
  669. };
  670. });
  671. if (updateData.length) {
  672. task.push(pm_facade.updateShareList(updateData))
  673. }
  674. } else { // 取消分享
  675. const cancelReceivers = shareData.map(item => item.userID);
  676. task.push(pm_facade.deleteShareList({ projectID, receiver: { $in: cancelReceivers } }));
  677. }
  678. await Promise.all(task);
  679. const rstTask = [
  680. pm_facade.getRecentShareList(userID, count),
  681. userModelObj.getContacts(userID)
  682. ];
  683. // 获取需要广播推送的单位工程
  684. // shareData数组的形式是以前需求需要,现在的需求下,shareData数组必定只有一个元素
  685. const emitTenders = await pm_facade.getShareInfoAfterChangePermission(permissionType, shareData[0].userID, projectID);
  686. let rst = { emitTenders };
  687. if (!isSimpleUpdate) {
  688. const [recentUsers, contacts] = await Promise.all(rstTask);
  689. Object.assign(rst, { recentUsers, contacts });
  690. }
  691. callback(req, res, 0, 'success', rst);
  692. }
  693. catch (err) {
  694. callback(req, res, 1, err, null);
  695. }
  696. },
  697. receiveProjects: async function (req, res) {
  698. try {
  699. let rst = { grouped: [], ungrouped: [], summaryInfo: null };
  700. let userID = req.session.sessionUser.id;
  701. const shareList = await pm_facade.getShareList({ receiver: userID });
  702. const receiveProjectIDs = shareList.map(item => item.projectID);
  703. const compilation = req.session.sessionCompilation._id;
  704. const notDeleted = [{ deleteInfo: null }, { 'deleteInfo.deleted': false }];
  705. const receiveProjects = await projectModel.find({ ID: { $in: receiveProjectIDs }, compilation, $or: notDeleted }, '-_id').lean();
  706. //设置原项目用户信息
  707. const shareInfoMap = await pm_facade.getShareInfoMap(null, shareList);
  708. if (receiveProjects.length > 0) {
  709. let orgUserIDs = [];
  710. for (let proj of receiveProjects) {
  711. orgUserIDs.push(proj.userID);
  712. if (proj.projType === projType.tender) {
  713. //设置工程专业
  714. proj.feeStandardName = proj.property.feeStandardName || '';
  715. //设置计税方法
  716. proj.taxType = proj.property.taxType;
  717. }
  718. delete proj.property;
  719. }
  720. orgUserIDs = Array.from(new Set(orgUserIDs));
  721. let userObjIDs = [];
  722. for (let uID of orgUserIDs) {
  723. userObjIDs.push(mongoose.Types.ObjectId(uID));
  724. }
  725. let orgUsersInfo = await userModel.find({ _id: { $in: userObjIDs } });
  726. //建设项目
  727. let consProjIDs = [],
  728. ungroupedTenders = [];
  729. for (let proj of receiveProjects) {
  730. // 设置分享信息
  731. proj.shareInfo = shareInfoMap[proj.ID] || [];
  732. if (proj.projType === projType.project) {
  733. consProjIDs.push(proj.ID);
  734. }
  735. //获取分享项目子项
  736. if (proj.projType !== projType.tender) {
  737. proj.children = await pm_facade.getPosterityProjects([proj.ID]);
  738. for (let projC of proj.children) {
  739. // 设置分享信息
  740. projC.shareInfo = shareInfoMap[projC.ID] || [];
  741. if (projC.projType === projType.project) {
  742. consProjIDs.push(projC.ID);
  743. } else if (projC.projType === projType.tender) {
  744. //设置工程专业
  745. projC.feeStandardName = projC.property.feeStandardName || '';
  746. //设置计税方法
  747. projC.taxType = projC.property.taxType;
  748. if (proj.projType === projType.engineering) {
  749. ungroupedTenders.push(projC);
  750. }
  751. }
  752. delete projC.property;
  753. }
  754. } else {//未分类的单位工程不进行汇总,只取价格信息
  755. ungroupedTenders.push(proj);
  756. }
  757. //设置分组,单位工程及单项工程分到未分组那
  758. if (proj.projType === projType.tender || proj.projType === projType.engineering) {
  759. rst.ungrouped.push(proj);
  760. } else {
  761. rst.grouped.push(proj);
  762. }
  763. //设置项目类型为来自别人分享
  764. proj.shareType = 'receive';
  765. for (let userData of orgUsersInfo) {
  766. if (proj.userID == userData._id.toString()) {
  767. let userInfo = { name: userData.real_name, mobile: userData.mobile, company: userData.company, email: userData.email };
  768. proj.userInfo = userInfo;
  769. }
  770. }
  771. }
  772. consProjIDs = Array.from(new Set(consProjIDs));
  773. let summaryInfo = await pm_facade.getSummaryInfo(consProjIDs);
  774. let tendersFeeInfo = await pm_facade.getTendersFeeInfo(ungroupedTenders);
  775. rst.summaryInfo = { grouped: summaryInfo, ungrouped: tendersFeeInfo };
  776. }
  777. callback(req, res, 0, 'success', rst);
  778. }
  779. catch (err) {
  780. console.log(err);
  781. callback(req, res, 1, err, null);
  782. }
  783. },
  784. getProjectsByQuery: async function (req, res) {
  785. try {
  786. let data = JSON.parse(req.body.data);
  787. let compilation = req.session.sessionCompilation._id;
  788. let query = data.query;
  789. query.compilation = compilation;
  790. let options = data.options;
  791. let projects = await projectModel.find(query, options);
  792. callback(req, res, 0, 'success', projects);
  793. }
  794. catch (err) {
  795. callback(req, res, 1, err, null);
  796. }
  797. },
  798. getSummaryInfo: async function (req, res) {
  799. try {
  800. let data = JSON.parse(req.body.data);
  801. let summaryInfo = await pm_facade.getSummaryInfo(data.projectIDs);
  802. callback(req, res, 0, 'success', summaryInfo);
  803. }
  804. catch (err) {
  805. callback(req, res, 1, err, null);
  806. }
  807. },
  808. changeFile: async function (req, res) {
  809. try {
  810. let data = JSON.parse(req.body.data);
  811. console.log(data);
  812. await pm_facade.changeFile(data.projects, data.user_id, data.fileID, data.name, data.from, data.type);
  813. callback(req, res, 0, 'success', []);
  814. }
  815. catch (err) {
  816. console.log(err);
  817. callback(req, res, 1, err, null);
  818. }
  819. },
  820. exportProject: async function (req, res) {
  821. let result = {
  822. error: 0
  823. };
  824. try {
  825. let data = { dataString: req.body.data, userID: req.session.sessionUser.id };
  826. result = await redirectToImportServer(data, "exportProject", req);
  827. } catch (err) {
  828. console.log(err);
  829. result.error = 1;
  830. result.message = err.message;
  831. }
  832. res.json(result);
  833. },
  834. importProject: async function (req, res) {
  835. let data = JSON.parse(req.body.data);
  836. let result = {
  837. error: 0
  838. };
  839. try {
  840. data.session = req.session;
  841. result = await redirectToImportServer(data, "importProject", req);
  842. } catch (err) {
  843. console.log(err);
  844. result.error = 1;
  845. result.message = err.message;
  846. }
  847. res.json(result);
  848. },
  849. importChongqingProject: async function (req, res) {
  850. let data = JSON.parse(req.body.data);
  851. let result = {
  852. error: 0
  853. };
  854. try {
  855. data.session = req.session;
  856. result.data = await redirectToImportServer(data, "importChongqingProject", req);
  857. } catch (err) {
  858. console.log(err);
  859. result.error = 1;
  860. result.message = err.message;
  861. }
  862. res.json(result);
  863. },
  864. copyConstructionProject: async function (req, res) {
  865. let data = JSON.parse(req.body.data);
  866. let result = {
  867. error: 0
  868. };
  869. try {
  870. data.session = req.session;
  871. result.data = await redirectToImportServer(data, "copyConstructionProject", req);
  872. } catch (err) {
  873. console.log(err);
  874. result.error = 1;
  875. result.message = err.message;
  876. }
  877. res.json(result);
  878. },
  879. importProcessChecking: async function (req, res) {
  880. let result = {
  881. error: 0
  882. };
  883. try {
  884. let data = JSON.parse(req.body.data);
  885. data.userID = req.session.sessionUser.id;
  886. data.compilationID = req.session.sessionCompilation._id;
  887. result.data = await pm_facade.importProcessChecking(data);
  888. } catch (err) {
  889. console.log(err);
  890. result.error = 1;
  891. result.message = err.message;
  892. }
  893. res.json(result);
  894. },
  895. getUploadToken: function (req, res) {
  896. let result = {
  897. error: 0
  898. };
  899. try {
  900. result = pm_facade.uploadToken();
  901. } catch (err) {
  902. console.log(err);
  903. result.error = 1;
  904. result.message = err.message;
  905. }
  906. res.json(result);
  907. },
  908. getBasicInfo: async function (req, res) {
  909. try {
  910. let data = JSON.parse(req.body.data);
  911. let infoLib = await pm_facade.getBasicInfo(req.session.sessionCompilation._id, data.fileKind);
  912. callback(req, res, 0, 'success', infoLib ? infoLib.info : []);
  913. } catch (err) {
  914. console.log(err);
  915. callback(req, res, 1, err, []);
  916. }
  917. },
  918. getProjectFeature: async function (req, res) {
  919. try {
  920. let data = JSON.parse(req.body.data);
  921. let featureLib = await pm_facade.getProjectFeature(data.valuationID, data.engineeringName, data.feeName);
  922. //工程专业设置为费用标准名称
  923. if (featureLib) {
  924. let engData = featureLib.feature.find(function (d) {
  925. return d.key === 'engineering';
  926. });
  927. if (engData) {
  928. engData.value = data.feeName;
  929. }
  930. }
  931. callback(req, res, 0, 'success', featureLib ? featureLib.feature : []);
  932. } catch (err) {
  933. console.log(err);
  934. callback(req, res, 1, err, []);
  935. }
  936. },
  937. getProjectByGranularity: async function (req, res) {
  938. try {
  939. let data = JSON.parse(req.body.data);
  940. const userID = req.session.sessionUser.id;
  941. const version = req.session.compilationVersion;
  942. let projData = await pm_facade.getProjectByGranularity(data.tenderID, data.granularity, data.summaryObj, userID, version);
  943. callback(req, res, 0, 'success', projData);
  944. } catch (err) {
  945. callback(req, res, 1, err, null);
  946. }
  947. },
  948. getProjectPlaceholder: async function (req, res) {
  949. let data = JSON.parse(req.body.data);
  950. try {
  951. let countRst = await pm_facade.getProjectPlaceholder(data);
  952. callback(req, res, 0, 'succes', countRst);
  953. } catch (err) {
  954. console.log(err);
  955. callback(req, res, 1, err, null);
  956. }
  957. },
  958. /* importInterface: async function(req, res) {
  959. logger.info(`${req.ip} importInterface`);
  960. const uploadOption = {
  961. uploadDir: './public'
  962. };
  963. let uploadFullName = '';
  964. const form = new multiparty.Form(uploadOption);
  965. form.parse(req, async function(err, fields, files) {
  966. try {
  967. let file = files.file && files.file.length ? files.file[0] : null;
  968. if (!file) {
  969. throw '无有效数据';
  970. }
  971. uploadFullName = file.path;
  972. //获取源数据
  973. let srcStr = fs.readFileSync(file.path, 'utf8');
  974. if (!srcStr) {
  975. throw '无有效数据'
  976. }
  977. let importData = JSON.parse(srcStr);
  978. fs.unlinkSync(file.path);
  979. let projectData = await pm_facade.importProject(importData, req.session.sessionUser.id, req.session.sessionCompilation._id);
  980. callback(req, res, 0, '', projectData);
  981. } catch (err) {
  982. console.log(err);
  983. if(uploadFullName && fs.existsSync(uploadFullName)){
  984. fs.unlinkSync(uploadFullName);
  985. }
  986. callback(req, res, 1, err, null);
  987. }
  988. });
  989. } */
  990. importInterface: async function (req, res) {
  991. const data = JSON.parse(req.body.data);
  992. let result = {
  993. error: 0
  994. };
  995. try {
  996. data.session = req.session;
  997. result = await redirectToImportServer(data, "importInterface", req);
  998. } catch (err) {
  999. console.log(err);
  1000. result.error = 1;
  1001. result.message = err.message;
  1002. }
  1003. res.json(result);
  1004. },
  1005. redirectToImportServer: redirectToImportServer
  1006. };
  1007. async function redirectToImportServer(data, action, req) {
  1008. let importURL = config.getImportURL(process.env.NODE_ENV, req.headers.origin);
  1009. let options = {
  1010. method: 'POST',
  1011. uri: `http://${importURL}/import/${action}`,
  1012. body: data,
  1013. timeout: 220000,
  1014. json: true
  1015. };
  1016. console.log("post import data to:" + options.uri);
  1017. return await rp.post(options);
  1018. }