pm_controller.js 22 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529
  1. /**
  2. * Created by Mai on 2017/1/18.
  3. */
  4. import UnitPriceFileModel from "../../glj/models/unit_price_file_model";
  5. import moment from 'moment';
  6. let mongoose = require('mongoose');
  7. let ProjectsData = require('../models/project_model').project;
  8. let labourCoe = require('../../main/facade/labour_coe_facade');
  9. let projType = require('../models/project_model').projType;
  10. let fileType = require('../models/project_model').fileType;
  11. const engineering = require("../../common/const/engineering");
  12. let EngineeringLibModel = require("../../users/models/engineering_lib_model");
  13. let fee_rate_facade = require("../../fee_rates/facade/fee_rates_facade");
  14. let billsModel = require('../../main/models/bills').model;
  15. let rationsModel = require('../../main/models/ration').model;
  16. let projectModel = mongoose.model('projects');
  17. let unitPriceFileModel = mongoose.model('unit_price_file');
  18. let feeRateFileModel = mongoose.model('fee_rate_file');
  19. let asyncTool = require('async');
  20. let pm_facade = require('../facade/pm_facade');
  21. const userModel = mongoose.model('user');
  22. //统一回调函数
  23. let callback = function(req, res, err, message, data){
  24. res.json({error: err, message: message, data: data});
  25. };
  26. module.exports = {
  27. checkRight: function (req, res) {
  28. if(typeof req.body.data === 'object'){
  29. req.body.data = JSON.stringify(req.body.data);
  30. }
  31. let data = JSON.parse(req.body.data);
  32. if (data.user_id) {
  33. return data.user_id === req.session.sessionUser.id;
  34. } else {
  35. return false;
  36. }
  37. },
  38. checkProjectRight: function (userId, projectId, callback) {
  39. ProjectsData.getProject(projectId).then(function (result) {
  40. /**
  41. * result._doc.userID(Number): MongoDB
  42. * userId(String): Session.userID
  43. */
  44. //result._doc.userID == userId &&
  45. if (result._doc.projType === projType.tender) {
  46. callback(true);
  47. } else {
  48. callback(false);
  49. }
  50. }).catch(function (err) {
  51. callback(false);
  52. });
  53. },
  54. getProjects: async function(req, res){
  55. await ProjectsData.getUserProjects(req.session.sessionUser.id, req.session.sessionCompilation._id, function(err, message, projects){
  56. if (projects) {
  57. callback(req, res, err, message, projects);
  58. } else {
  59. callback(req, res, err, message, null);
  60. }
  61. });
  62. },
  63. updateProjects: async function (req, res) {
  64. let data = JSON.parse(req.body.data);
  65. await ProjectsData.updateUserProjects(req.session.sessionUser.id, req.session.sessionCompilation._id, data.updateData, function (err, message, data) {
  66. if (err === 0) {
  67. callback(req, res, err, message, data);
  68. } else {
  69. callback(req, res, err, message, null);
  70. }
  71. });
  72. },
  73. // CSL, 2017-12-14 该方法用于项目属性:提交保存混合型数据,这些数据来自不同的表,包括projects.property、ration、bills、labour_coes.
  74. updateMixDatas: function(req, res){
  75. let datas = JSON.parse(req.body.data).mixDataArr;
  76. let functions = [];
  77. function updateFunc(model, cod, doc) {
  78. return function (cb) {
  79. model.update(cod, doc, cb);
  80. }
  81. };
  82. function updateLC(){
  83. return function (cb) {
  84. datas.labourCoes.updateData.projectID = datas.projectID;
  85. labourCoe.save(datas.labourCoes.updateData, cb);
  86. }
  87. };
  88. // 项目属性
  89. if (Object.keys(datas.properties).length > 0){
  90. functions.push(updateFunc(projectModel, {ID: datas.projectID}, datas.properties));
  91. };
  92. // 人工系数
  93. if (datas.labourCoes&&datas.labourCoes.updateData){
  94. functions.push(updateLC());
  95. };
  96. // 清单:每文档doc只存储一条清单,每条清单都必须定位一次文档,无法合并处理
  97. if (datas.bills.length > 0){
  98. for (let bill of datas.bills){
  99. functions.push(updateFunc(billsModel, {projectID: datas.projectID, ID: bill.ID, deleteInfo: null}, bill));
  100. };
  101. };
  102. // 定额:每文档doc只存储一条定额,每条定额都必须定位一次文档,无法合并处理
  103. if (datas.rations.length > 0){
  104. for (let ration of datas.rations){
  105. functions.push(updateFunc(rationsModel, {projectID: datas.projectID, ID: ration.ID, deleteInfo: null}, ration));
  106. };
  107. };
  108. asyncTool.parallel(functions, function(err, result){
  109. {
  110. if (!err) {
  111. res.json({error: 0, message: err, data: result});
  112. } else {
  113. res.json({error: 1, message: err, data: null});
  114. }
  115. }
  116. });
  117. },
  118. updateFiles: async function(req, res){
  119. let data = JSON.parse(req.body.data);
  120. let updateDatas = data.updateDatas;
  121. await ProjectsData.udpateUserFiles(req.session.sessionUser.id, updateDatas, function (err, message, data) {
  122. callback(req, res, err, message, data);
  123. });
  124. },
  125. /* copyProjects: function (req, res) {
  126. let data = JSON.parse(req.body.data);
  127. ProjectsData.copyUserProjects(req.session.sessionUser.id, req.session.sessionCompilation._id, data.updateData, function (err, message, data) {
  128. if (err === 0) {
  129. callback(req, res, err, message, data);
  130. } else {
  131. callback(req, res, err, message, null);
  132. }
  133. });
  134. },*/
  135. rename: function (req, res) {
  136. let data = JSON.parse(req.body.data);
  137. ProjectsData.rename(req.session.sessionUser.id, req.session.sessionCompilation._id, data, function (err, message) {
  138. callback(req, res, err, message, null);
  139. });
  140. },
  141. getProject: function(req, res){
  142. let data = JSON.parse(req.body.data);
  143. ProjectsData.getUserProject(req.session.sessionUser.id, data.proj_id, async function(err, message, data){
  144. if (err === 0) {
  145. let engineeringLibModel = new EngineeringLibModel();
  146. let engineeringInfo = data !== null && data.property.engineering_id !== undefined ?
  147. await engineeringLibModel.getEngineering(data.property.engineering_id) : null;
  148. let strData = JSON.stringify(data);
  149. let projInfo = JSON.parse(strData);
  150. if (engineeringInfo !== null) {
  151. projInfo.engineeringInfo = engineeringInfo;
  152. }
  153. callback(req, res, err, message, projInfo);
  154. } else {
  155. callback(req, res, err, message, null);
  156. }
  157. });
  158. },
  159. beforeOpenProject: function (req, res) {
  160. let data = JSON.parse(req.body.data);
  161. ProjectsData.beforeOpenProject(req.session.sessionUser.id, data.proj_id, data.updateData, function (err, message, data) {
  162. callback(req, res, err, message, data);
  163. });
  164. },
  165. getNewProjectID: function (req, res) {
  166. let data = JSON.parse(req.body.data);
  167. ProjectsData.getNewProjectID(data.count, function (err, message, data) {
  168. callback(req, res, err, message, data);
  169. });
  170. },
  171. // 项目管理首页
  172. index: async function(request, response) {
  173. // 获取编办信息
  174. let sessionCompilation = request.session.sessionCompilation;
  175. if (sessionCompilation === undefined) {
  176. return response.redirect('/logout');
  177. }
  178. // 清单计价
  179. let billValuation = sessionCompilation.bill_valuation !== undefined ?
  180. sessionCompilation.bill_valuation : [];
  181. // 获取标准库数据
  182. let engineeringLibModel = new EngineeringLibModel();
  183. billValuation = await engineeringLibModel.getLib(billValuation);
  184. // 定额计价
  185. let rationValuation = sessionCompilation.ration_valuation !== undefined ?
  186. sessionCompilation.ration_valuation : [];
  187. rationValuation = await engineeringLibModel.getLib(rationValuation);
  188. let renderData = {
  189. userAccount: request.session.userAccount,
  190. userID: request.session.sessionUser.id,
  191. compilationData: JSON.stringify(sessionCompilation),
  192. billValuation: JSON.stringify(billValuation),
  193. rationValuation: JSON.stringify(rationValuation),
  194. engineeringList: JSON.stringify(engineering.List),
  195. versionName: sessionCompilation.name + '免费版'
  196. };
  197. response.render('building_saas/pm/html/project-management.html', renderData);
  198. },
  199. // 获取单价文件列表
  200. getUnitFileList: async function(request, response) {
  201. let data = request.body.data;
  202. try {
  203. data = JSON.parse(data);
  204. let projectId = data.parentID !== undefined ? data.parentID : 0;
  205. if (isNaN(projectId) && projectId <= 0) {
  206. throw {msg: 'id数据有误!', err: 1};
  207. }
  208. /*// 获取对应建设项目下所有的单位工程id
  209. let idList = await ProjectsData.getTenderByProjectId(projectId);
  210. if (idList.length <= 0) {
  211. throw {msg: '不存在对应单位工程', err: 0};
  212. }*/
  213. // 获取对应的单价文件
  214. let unitPriceFileModel = new UnitPriceFileModel();
  215. let unitPriceFileData = await unitPriceFileModel.getDataByRootProject(projectId);
  216. if (unitPriceFileData === null) {
  217. throw {msg: '不存在对应单价文件', err: 0};
  218. }
  219. // 整理数据
  220. let unitPriceFileList = [];
  221. for (let unitPriceFile of unitPriceFileData) {
  222. let tmp = {
  223. name: unitPriceFile.name,
  224. id: unitPriceFile.id
  225. };
  226. unitPriceFileList.push(tmp);
  227. }
  228. callback(request, response, 0, '', unitPriceFileList);
  229. } catch (error) {
  230. console.log(error);
  231. let responseData = error.err === 1 ? null : [];
  232. callback(request, response, error.err, error.msg, responseData);
  233. }
  234. },
  235. getFeeRateFileList:async function(request, response) {
  236. let data = request.body.data;
  237. try {
  238. data = JSON.parse(data);
  239. let projectId = data.parentID !== undefined ? data.parentID : 0;
  240. if (isNaN(projectId) && projectId <= 0) {
  241. throw {msg: 'id数据有误!', err: 1};
  242. }
  243. // 获取对应建设项目下所有的单位工程id
  244. let feeRateFileList = await fee_rate_facade.getFeeRatesByProject(projectId);
  245. callback(request, response, 0, '',feeRateFileList );
  246. } catch (error) {
  247. console.log(error);
  248. let responseData = error.err === 1 ? null : [];
  249. callback(request, response, error.err, error.msg, responseData);
  250. }
  251. },
  252. getGCDatas: async function(request, response) {
  253. let userID = request.session.sessionUser.id;
  254. let compilatoinId = request.session.sessionCompilation._id;
  255. let rst = [];
  256. let _projs = Object.create(null), _engs = Object.create(null), prefix = 'ID_';
  257. try{
  258. let gc_unitPriceFiles = await ProjectsData.getGCFiles(fileType.unitPriceFile, userID);
  259. let gc_feeRateFiles = await ProjectsData.getGCFiles(fileType.feeRateFile, userID);
  260. let gc_tenderFiles = await ProjectsData.getGCFiles(projType.tender, userID);
  261. for(let i = 0, len = gc_unitPriceFiles.length; i < len; i++){
  262. let gc_uf = gc_unitPriceFiles[i];
  263. let theProj = _projs[prefix + gc_uf.root_project_id] || null;
  264. if(!theProj){
  265. let tempProj = await ProjectsData.getProjectsByIds(userID, compilatoinId, [gc_uf.root_project_id]);
  266. if(tempProj.length > 0 && tempProj[0].projType !== projType.folder){
  267. theProj = _projs[prefix + gc_uf.root_project_id] = tempProj[0]._doc;
  268. buildProj(theProj);
  269. }
  270. }
  271. if(theProj){
  272. theProj.unitPriceFiles.push(gc_uf);
  273. }
  274. }
  275. for(let i = 0, len = gc_feeRateFiles.length; i < len; i++){
  276. let gc_ff = gc_feeRateFiles[i];
  277. let theProj = _projs[prefix + gc_ff.rootProjectID] || null;
  278. if(!theProj){
  279. let tempProj = await ProjectsData.getProjectsByIds(userID, compilatoinId, [gc_ff.rootProjectID]);
  280. if(tempProj.length > 0 && tempProj[0].projType !== projType.folder){
  281. theProj = _projs[prefix + gc_ff.rootProjectID] = tempProj[0]._doc;
  282. buildProj(theProj);
  283. }
  284. }
  285. if(theProj) {
  286. theProj.feeRateFiles.push(gc_ff);
  287. }
  288. }
  289. if(gc_tenderFiles.length > 0){
  290. for(let i = 0, len = gc_tenderFiles.length; i < len; i++){
  291. let gc_t = gc_tenderFiles[i];
  292. let theEng = _engs[prefix + gc_t.ParentID] || null;
  293. if(!theEng){
  294. let tempEngs = await ProjectsData.getProjectsByIds(userID, compilatoinId, [gc_t.ParentID]);
  295. if(tempEngs.length > 0 && tempEngs[0].projType === projType.engineering){
  296. theEng = _engs[prefix + gc_t.ParentID] = tempEngs[0]._doc;
  297. theEng.children = [];
  298. }
  299. }
  300. if(theEng) {
  301. theEng.children.push(gc_t);
  302. let theProj = _projs[prefix + theEng.ParentID] || null;
  303. if(!theProj){
  304. let tempProj = await ProjectsData.getProjectsByIds(userID, compilatoinId, [theEng.ParentID]);
  305. if(tempProj.length > 0 && tempProj[0].projType === projType.project){
  306. theProj = _projs[prefix + theEng.ParentID] = tempProj[0]._doc;
  307. buildProj(theProj);
  308. }
  309. }
  310. if(theProj) {
  311. let isExist = false;
  312. for(let j = 0, jLen = theProj.children.length; j < jLen; j++){
  313. if(theProj.children[j].ID === theEng.ID){
  314. isExist = true;
  315. break;
  316. }
  317. }
  318. if(!isExist){
  319. theProj.children.push(theEng);
  320. }
  321. }
  322. }
  323. }
  324. }
  325. for(let i in _projs){
  326. rst.push(_projs[i]);
  327. }
  328. function buildProj(proj){
  329. proj.children = [];
  330. proj.unitPriceFiles = [];
  331. proj.feeRateFiles = [];
  332. }
  333. callback(request, response, 0, 'success', rst);
  334. }
  335. catch (error){
  336. callback(request, response, true, error, null);
  337. }
  338. },
  339. recGC: function(request, response){
  340. let userID = request.session.sessionUser.id;
  341. let data = JSON.parse(request.body.data);
  342. let nodes = data.nodes;
  343. ProjectsData.recGC(userID, nodes, function (err, msg, data) {
  344. callback(request, response, err, msg, data);
  345. });
  346. },
  347. delGC: async function(request, response){
  348. let data = JSON.parse(request.body.data);
  349. let delDatas = data.delDatas;
  350. let bulkProjs = [], bulkUFs = [], bulkFFs = [];
  351. try{
  352. for(let data of delDatas){
  353. if(data.updateType === 'Project'){
  354. bulkProjs.push({updateOne: {filter: {ID: data.ID}, update: {'deleteInfo.completeDeleted': true}}});
  355. }
  356. else if(data.updateType === fileType.unitPriceFile){
  357. bulkUFs.push({updateOne: {filter: {id: data.ID}, update: {'deleteInfo.completeDeleted': true}}});
  358. }
  359. else{
  360. bulkFFs.push({updateOne: {filter: {ID: data.ID}, update: {'deleteInfo.completeDeleted': true}}});
  361. }
  362. }
  363. if(bulkProjs.length > 0){
  364. await projectModel.bulkWrite(bulkProjs);
  365. }
  366. if(bulkUFs.length > 0){
  367. await unitPriceFileModel.bulkWrite(bulkUFs);
  368. }
  369. if(bulkFFs.length > 0){
  370. await feeRateFileModel.bulkWrite(bulkFFs);
  371. }
  372. callback(request, response, 0, 'success', null);
  373. } catch(err){
  374. callback(request, response, 1, err, null);
  375. }
  376. },
  377. moveProject:async function(req,res){
  378. let result={
  379. error:0
  380. };
  381. try {
  382. let data = req.body.data;
  383. let rdata= await pm_facade.moveProject(data);
  384. result.data= rdata;
  385. }catch (err){
  386. console.log(err);
  387. result.error=1;
  388. result.message = err.message;
  389. }
  390. res.json(result);
  391. },
  392. copyProjects:async function (req, res) {
  393. let result={
  394. error:0
  395. };
  396. try {
  397. let data = JSON.parse(req.body.data);
  398. result.data = await pm_facade.copyProject(req.session.sessionUser.id, req.session.sessionCompilation._id,data);
  399. }catch (err){
  400. console.log(err);
  401. result.error=1;
  402. result.message = err.message;
  403. }
  404. res.json(result);
  405. },
  406. projectShareInfo: async function(req, res){
  407. try{
  408. let data = JSON.parse(req.body.data);
  409. let shareInfo = await projectModel.findOne({ID: data.projectID, $or: [{deleteInfo: null}, {'deleteInfo.deleted': false}]}, '-_id shareInfo');
  410. callback(req, res, 0, 'success', shareInfo);
  411. }
  412. catch (err){
  413. callback(req, res, 1, err, null);
  414. }
  415. },
  416. share: async function(req, res){
  417. try{
  418. let data = JSON.parse(req.body.data);
  419. //添加分享
  420. let shareData = {userID: data.userID, allowCopy: data.allowCopy, shareDate: moment(Date.now()).format('YYYY-MM-DD HH:mm:ss')};
  421. if(data.type === 'create'){
  422. await projectModel.update({ID: data.projectID, $or: [{deleteInfo: null}, {'deleteInfo.deleted': false}]}, {$addToSet: {shareInfo: shareData}});
  423. }
  424. //取消分享
  425. else {
  426. await projectModel.update({ID: data.projectID, $or: [{deleteInfo: null}, {'deleteInfo.deleted': false}]}, {$pull: {shareInfo: {userID: data.userID}}});
  427. }
  428. callback(req, res, 0, 'success', null);
  429. }
  430. catch (err){
  431. callback(req, res, 1, err, null);
  432. }
  433. },
  434. getShareProjects: async function (req, res) {
  435. try {
  436. let userID = req.session.sessionUser.id;
  437. let rst = {receive: [], share: []}//接收的、由我分享的
  438. let shareProjects = await projectModel.find({userID: userID, $or: [{deleteInfo: null}, {'deleteInfo.deleted': false}], 'shareInfo.0': {$exists: true}});
  439. //项目类型为分享给别人
  440. let shareToUserIDs = [];
  441. for(let proj of shareProjects){
  442. proj._doc.shareType = 'shareTo';
  443. for(let shareToUser of proj.shareInfo){
  444. shareToUserIDs.push(shareToUser.userID);
  445. }
  446. }
  447. shareToUserIDs = Array.from(new Set(shareToUserIDs));
  448. let shareToObjIDs = [];
  449. for(let userID of shareToUserIDs){
  450. shareToObjIDs.push(mongoose.Types.ObjectId(userID));
  451. }
  452. let shareToUsers = await userModel.find({_id: {$in: shareToObjIDs}});
  453. for(let shareToUser of shareToUsers){
  454. for(let proj of shareProjects){
  455. for(let user of proj.shareInfo){
  456. if(user.userID === shareToUser._id.toString()){
  457. user._doc.company = shareToUser.company;
  458. user._doc.email = shareToUser.email;
  459. user._doc.name = shareToUser.real_name;
  460. user._doc.mobile = shareToUser.mobile;
  461. }
  462. }
  463. }
  464. }
  465. rst.share = shareProjects;
  466. let receiveProjects = await projectModel.find({$or: [{deleteInfo: null}, {'deleteInfo.deleted': false}], 'shareInfo.userID': userID});
  467. //设置原项目用户信息
  468. if(receiveProjects.length > 0){
  469. let orgUserIDs = [];
  470. for(let proj of receiveProjects){
  471. orgUserIDs.push(proj.userID);
  472. }
  473. orgUserIDs = Array.from(new Set(orgUserIDs));
  474. let userObjIDs = [];
  475. for(let uID of orgUserIDs){
  476. userObjIDs.push(mongoose.Types.ObjectId(uID));
  477. }
  478. let orgUsersInfo = await userModel.find({_id: {$in : userObjIDs}});
  479. for(let proj of receiveProjects){
  480. //设置项目类型为来自别人分享
  481. proj._doc.shareType = 'receive';
  482. for(let userData of orgUsersInfo){
  483. if(proj.userID == userData._id.toString()){
  484. let userInfo = {name: userData.real_name, mobile: userData.mobile, company: userData.company, email: userData.email};
  485. proj._doc.userInfo = userInfo;
  486. }
  487. }
  488. }
  489. }
  490. rst.receive = receiveProjects;
  491. callback(req, res, 0, 'success', rst);
  492. }
  493. catch (err){
  494. callback(req, res, 1, err, null);
  495. }
  496. },
  497. getProjectsByQuery: async function (req, res) {
  498. try{
  499. let data = JSON.parse(req.body.data);
  500. let query = data.query;
  501. let options = data.options;
  502. let projects = await projectModel.find(query, options);
  503. callback(req, res, 0, 'success', projects);
  504. }
  505. catch (err){
  506. callback(req, res, 1, err, null);
  507. }
  508. }
  509. };