pm_controller.js 51 KB

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