project_model.js 29 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730
  1. /**
  2. * Created by Mai on 2017/1/18.
  3. */
  4. import mongoose from 'mongoose';
  5. import async_c from 'async';
  6. import UnitPriceFileModel from "../../glj/models/unit_price_file_model";
  7. let UnitPriceFiles = mongoose.model('unit_price_file');
  8. import {
  9. defaultDecimal,
  10. billsQuantityDecimal,
  11. basicInformation,
  12. projectFeature,
  13. displaySetting,
  14. calcOptions
  15. } from './project_property_template';
  16. import fixedFlag from '../../common/const/bills_fixed';
  17. let FeeRateFiles = mongoose.model('fee_rate_file');
  18. let counter = require("../../../public/counter/counter.js");
  19. let newProjController = require('../controllers/new_proj_controller');
  20. let copyProjController = require('../controllers/copy_proj_controller');
  21. let feeRateFacade = require('../../fee_rates/facade/fee_rates_facade');
  22. let labourCoeFacade = require('../../main/facade/labour_coe_facade');
  23. let calcProgramFacade = require('../../main/facade/calc_program_facade');
  24. let installationFacade = require('../../main/facade/installation_facade');
  25. let logger = require("../../../logs/log_helper").logger;
  26. let BillsModel = require("../../main/models/bills").model;
  27. let Projects = mongoose.model('projects');
  28. let projectType = {
  29. folder: 'Folder',
  30. tender: 'Tender',
  31. project: 'Project',
  32. engineering: 'Engineering',
  33. };
  34. let fileType = {
  35. unitPriceFile: 'UnitPriceFile',
  36. feeRateFile: 'FeeRateFile'
  37. };
  38. let ProjectsDAO = function () {
  39. };
  40. let G_FILE_VER = '1.0.1';
  41. ProjectsDAO.prototype.getUserProjects = async function (userId, compilation, callback) {
  42. try {
  43. let projects = await Projects.find({
  44. '$or': [{
  45. 'userID': userId,
  46. 'compilation': compilation,
  47. 'deleteInfo': null
  48. }, {'userID': userId, 'compilation': compilation, 'deleteInfo.deleted': {'$in': [null, false]}}]
  49. }, '-_id');
  50. let projIDs= [];
  51. let projIndex = {};
  52. for(let proj of projects){
  53. projIDs.push(proj.ID);
  54. projIndex[proj.ID] = proj;
  55. }
  56. let bills = await BillsModel.find({projectID: {$in : projIDs}, 'flags.flag': fixedFlag.ENGINEERINGCOST, 'fees.totalFee': {$exists: true}}, 'projectID fees');
  57. for(let bill of bills){
  58. projIndex[bill.projectID]._doc.engineeringCost = bill.fees[0].totalFee;
  59. }
  60. callback(0, '', projects);
  61. }
  62. catch (err) {
  63. callback(1, 'Error', null);
  64. }
  65. };
  66. ProjectsDAO.prototype.getUserProject = function (userId, ProjId, callback) {
  67. Projects.findOne({userID: userId, ID: ProjId}, '-_id', function (err, template) {
  68. if (err) {
  69. callback(1, '找不到标段数据', null);
  70. } else {
  71. callback(0, '', template);
  72. }
  73. });
  74. }
  75. ProjectsDAO.prototype.updateUserProjects = async function (userId, compilationId, datas, callback) {
  76. let data, project, updateLength = 0, hasError = false, deleteInfo = null, i, newProject;
  77. let updateAll = function (err) {
  78. if (!err) {
  79. updateLength += 1;
  80. if (updateLength === datas.length) {
  81. callback(0, '', datas);
  82. }
  83. } else {
  84. hasError = true;
  85. console.log(err);
  86. callback(1, '提交数据出错.', null);
  87. }
  88. };
  89. console.log(datas);
  90. if (datas) {
  91. for (i = 0; i < datas.length && !hasError; i++) {
  92. data = datas[i];
  93. if (data.updateData.name !== undefined) {
  94. data.updateData.name = data.updateData.name.trim();
  95. }
  96. if (data.updateType === 'update') {
  97. Projects.update({userID: userId, ID: data.updateData.ID}, data.updateData, updateAll);
  98. }
  99. else if (data.updateType === 'new') {
  100. data.updateData['userID'] = userId;
  101. data.updateData['compilation'] = compilationId;
  102. data.updateData['createDateTime'] = new Date();
  103. data.updateData['fileVer'] = G_FILE_VER;
  104. // 如果没有选中单价文件则新增单价文件
  105. if (data.updateData.projType === projectType.tender && data.updateData.property !== null &&
  106. Object.keys(data.updateData.property.unitPriceFile).length > 0 &&
  107. data.updateData.property.unitPriceFile.id === '') {
  108. let unitPriceFileModel = new UnitPriceFileModel();
  109. let insertData = {
  110. name: data.updateData.name,
  111. project_id: data.updateData.ID,
  112. user_id: userId,
  113. root_project_id: data.updateData.property.rootProjectID
  114. };
  115. let addResult = await unitPriceFileModel.add(insertData);
  116. if (!addResult) {
  117. callback(1, '新增单价文件失败.', null);
  118. return;
  119. }
  120. data.updateData.property.unitPriceFile.id = addResult.id;
  121. }
  122. if (data.updateData.projType === projectType.tender) {
  123. //单价文件
  124. data.updateData.property.unitPriceFile.id=parseInt(data.updateData.property.unitPriceFile.id);
  125. //小数位数
  126. data.updateData.property.decimal = defaultDecimal;
  127. //清单工程量精度
  128. data.updateData.property.billsQuantityDecimal = billsQuantityDecimal;
  129. //基本信息
  130. basicInformation[0]['items'][1]['value'] = data.updateData.property.engineeringName || '';
  131. data.updateData.property.basicInformation = basicInformation;
  132. //工程特征
  133. data.updateData.property.projectFeature = projectFeature;
  134. //呈现选项
  135. data.updateData.property.displaySetting = displaySetting;
  136. data.updateData.property.billsCalcMode = 0;
  137. data.updateData.property.zanguCalcMode = 0;
  138. //计算选项
  139. data.updateData.property.calcOptions = calcOptions
  140. //安装增加费
  141. if(parseInt(data.updateData.property.engineering)==4){
  142. await installationFacade.copyInstallationFeeFromLib(data.updateData.ID,data.updateData.property.engineering_id);
  143. }
  144. //锁定清单
  145. data.updateData.property.lockBills = false;
  146. }
  147. newProject = new Projects(data.updateData);
  148. // 查找同级是否存在同名数据
  149. let exist = await this.isExist(userId, compilationId, data.updateData.name, data.updateData.ParentID);
  150. if (exist) {
  151. callback(1, '同级目录已存在相同名称数据.', null);
  152. return;
  153. }
  154. if (data.updateData.projType === 'Tender') {
  155. let feeRateFileID = await feeRateFacade.newFeeRateFile(userId, data.updateData);
  156. newProject.property.feeFile = feeRateFileID ? feeRateFileID : -1;
  157. // 新建人工系数文件 CSL, 2017.10.13
  158. let lcFile = await labourCoeFacade.newProjectLabourCoe(data.updateData);
  159. newProject.property.labourCoeFile = lcFile ? lcFile : null;
  160. // 新建计算程序文件 CSL, 2017.10.23
  161. let cpFile = await calcProgramFacade.newProjectCalcProgramFile(data.updateData);
  162. newProject.property.calcProgramFile = cpFile ? cpFile : null;
  163. }
  164. newProject.save(async function (err, result) {
  165. if (!err && result._doc.projType === projectType.tender) {
  166. newProjController.copyTemplateData(result._doc.property, newProject.ID, updateAll);
  167. } else {
  168. updateAll(err);
  169. }
  170. });
  171. }
  172. else if (data.updateType === 'delete') {
  173. deleteInfo = {};
  174. deleteInfo['deleted'] = true;
  175. deleteInfo['deleteDateTime'] = new Date();
  176. deleteInfo['deleteBy'] = userId;
  177. data.updateData['deleteInfo'] = deleteInfo;
  178. //Projects.update({userID: userId, ID: data.updateData.ID}, data.updateData, updateAll);
  179. //update
  180. try {
  181. if (data.updateData.projType === projectType.project) {
  182. let engineerings = await Projects.find({userID: userId, ParentID: data.updateData.ID});
  183. let isExist = false;
  184. if (engineerings.length > 0) {
  185. for (let j = 0, jLen = engineerings.length; j < jLen; j++) {
  186. let e_tenders = await Projects.find({userID: userId, ParentID: engineerings[j].ID});
  187. if (e_tenders.length > 0) {
  188. isExist = true;
  189. break;
  190. }
  191. }
  192. }
  193. if (isExist) {//fake
  194. await UnitPriceFiles.update({
  195. user_id: userId,
  196. root_project_id: data.updateData.ID
  197. }, {$set: {deleteInfo: deleteInfo}}, {multi: true});
  198. await FeeRateFiles.update({
  199. userID: userId,
  200. rootProjectID: data.updateData.ID
  201. }, {$set: {deleteInfo: deleteInfo}}, {multi: true});
  202. await Projects.update({userID: userId, ID: data.updateData.ID}, data.updateData, updateAll);
  203. }
  204. else {//true
  205. await UnitPriceFiles.remove({user_id: userId, root_project_id: data.updateData.ID});
  206. await FeeRateFiles.remove({userID: userId, rootProjectID: data.updateData.ID});
  207. //await Projects.update({userID: userId, NextSiblingID: data.updateData.ID, deleteInfo: null}, {$set: {NextSiblingID: data.NextSiblingID}});
  208. await Projects.remove({userID: userId, ID: data.updateData.ID}, updateAll);
  209. }
  210. }
  211. else if (data.updateData.projType === projectType.engineering) {
  212. let tenders = await Projects.find({userID: userId, ParentID: data.updateData.ID});
  213. if (tenders.length > 0) {//fake
  214. await Projects.update({userID: userId, ID: data.updateData.ID}, data.updateData, updateAll);
  215. }
  216. else {//true
  217. //await Projects.update({userID: userId, NextSiblingID: data.updateData.ID, deleteInfo: null}, {$set: {NextSiblingID: data.NextSiblingID}});
  218. await Projects.remove({userID: userId, ID: data.updateData.ID}, updateAll);
  219. }
  220. }
  221. else if (data.updateData.projType === projectType.tender) {//fake
  222. await Projects.update({userID: userId, ID: data.updateData.ID}, data.updateData, updateAll);
  223. }
  224. else if (data.updateData.projType === projectType.folder) {//true
  225. await Projects.remove({userID: userId, ID: data.updateData.ID}, updateAll);
  226. }
  227. else throw '未知文件类型,删除失败!';
  228. }
  229. catch (error) {
  230. callback(1, error, null);
  231. }
  232. }
  233. else {
  234. hasError = true;
  235. callback(1, '提交数据错误.', null);
  236. }
  237. }
  238. }
  239. };
  240. ProjectsDAO.prototype.udpateUserFiles = async function (userId, datas, callback) {
  241. let updateType = {update: 'update', delete: 'delete'};
  242. let deleteInfo = Object.create(null);
  243. deleteInfo.deleted = true;
  244. deleteInfo.deleteBy = userId;
  245. deleteInfo.deleteDateTime = new Date();
  246. try {
  247. for (let i = 0, len = datas.length; i < len; i++) {
  248. let data = datas[i];
  249. if (data.updateType === updateType.update && data.fileType === fileType.unitPriceFile) {
  250. await UnitPriceFiles.update({user_id: userId, id: parseInt(data.updateData.id)}, data.updateData);
  251. await Projects.update({
  252. userID: userId,
  253. 'property.unitPriceFile.id': data.updateData.id
  254. }, {$set: {'property.unitPriceFile.name': data.updateData.name}});
  255. }
  256. else if (data.updateType === updateType.update && data.fileType === fileType.feeRateFile) {
  257. await FeeRateFiles.update({ID: data.updateData.ID}, data.updateData);
  258. await Projects.update({
  259. userID: userId,
  260. 'property.feeFile.id': data.updateData.ID
  261. }, {$set: {'property.feeFile.name': data.updateData.name}});
  262. }
  263. else if (data.updateType === updateType.delete && data.fileType === fileType.unitPriceFile) {
  264. data.updateData.deleteInfo = deleteInfo;
  265. await UnitPriceFiles.update({user_id: userId, id: parseInt(data.updateData.id)}, data.updateData);
  266. await Projects.update({
  267. userID: userId,
  268. 'property.feeFile.id': data.updateData.id
  269. }, {$set: {'property.feeFile.name': data.updateData.name}});
  270. }
  271. else if (data.updateType === updateType.delete && data.fileType === fileType.feeRateFile) {
  272. data.updateData.deleteInfo = deleteInfo;
  273. await FeeRateFiles.update({ID: data.updateData.ID}, data.updateData);
  274. }
  275. else throw '未知文件类型,删除失败'
  276. }
  277. callback(false, '删除成功', null);
  278. }
  279. catch (error) {
  280. callback(true, '删除失败', null);
  281. }
  282. };
  283. ProjectsDAO.prototype.copyUserProjects = function (userId, compilationId, datas, callback) {
  284. let data, project, updateLength = 0, hasError = false, deleteInfo = null, tempType = 1, i;
  285. let updateAll = function (err) {
  286. if (!err) {
  287. updateLength += 1;
  288. if (updateLength === datas.length) {
  289. callback(0, '', datas);
  290. }
  291. } else {
  292. hasError = true;
  293. callback(1, '提交数据出错.', null);
  294. }
  295. };
  296. if (datas) {
  297. for (i = 0; i < datas.length && !hasError; i++) {
  298. data = datas[i];
  299. if (data.updateType === 'update') {
  300. Projects.update({userID: userId, ID: data.updateData.ID}, data.updateData, updateAll)
  301. } else if (data.updateType === 'copy') {
  302. console.log(userId);
  303. data.updateData['userID'] = userId;
  304. data.updateData['compilation'] = compilationId;
  305. data.updateData['createDateTime'] = new Date();
  306. data.updateData['fileVer'] = G_FILE_VER;
  307. let newProject = new Projects(data.updateData);
  308. newProject['srcProjectId'] = data.srcProjectId;
  309. newProject.save(function (err, result) {
  310. if (!err && result._doc.projType === 'Tender') {
  311. copyProjController.copyProjectData(newProject.srcProjectId, result._doc.ID, updateAll);
  312. } else {
  313. updateAll(err);
  314. }
  315. });
  316. } else {
  317. hasError = true;
  318. callback(1, '提交数据错误', null);
  319. }
  320. }
  321. }
  322. };
  323. ProjectsDAO.prototype.rename = async function (userId, compilationId, data, callback) {
  324. try {
  325. if (data.id === undefined || data.id === '') {
  326. throw '数据错误!';
  327. }
  328. if (data.newName === undefined || data.newName === '') {
  329. throw '请填写名称!';
  330. }
  331. data.newName = data.newName.trim();
  332. // 查找同级是否存在同名数据
  333. let exist = await this.isExist(userId, compilationId, data.newName, data.parentID);
  334. if (exist) {
  335. throw '同级目录已存在相同名称数据';
  336. }
  337. Projects.update({userID: userId, ID: data.id}, {name: data.newName}, function (err) {
  338. if (err) {
  339. throw '项目不存在';
  340. }
  341. });
  342. } catch (error) {
  343. callback(1, error, null);
  344. return;
  345. }
  346. callback(0, '');
  347. };
  348. ProjectsDAO.prototype.beforeOpenProject = function (userId, projectId, updateData, callback) {
  349. updateData['recentDateTime'] = new Date();
  350. Projects.update({userID: userId, ID: projectId}, updateData, function (err) {
  351. if (err) {
  352. callback(1, '项目不存在.');
  353. } else {
  354. callback(0, '');
  355. }
  356. });
  357. };
  358. ProjectsDAO.prototype.getNewProjectID = function (count, callback) {
  359. counter.counterDAO.getIDAfterCount(counter.moduleName.project, count, function (err, result) {
  360. console.log(result);
  361. let highID = result.sequence_value;
  362. if (!err) {
  363. callback(0, '', {lowID: highID - count + 1, highID: highID});
  364. } else {
  365. callback(1, '获取主键失败', null);
  366. }
  367. });
  368. };
  369. ProjectsDAO.prototype.getProject = function (key, callback) {
  370. if (callback) {
  371. Projects.findOne({'_id': key}, function (err, result) {
  372. if (err) {
  373. callback(1, '查找标段失败');
  374. } else {
  375. callback(0, result);
  376. }
  377. });
  378. } else {
  379. return Projects.findOne({'ID': key}).exec();
  380. }
  381. };
  382. ProjectsDAO.prototype.getProjectsByIds = async function (userId, compilationId, ids) {
  383. return await Projects.find({userID: userId, compilation: compilationId, ID: {$in: ids}}, '-_id -property');
  384. };
  385. ProjectsDAO.prototype.getGCFiles = async function (fileType, userID) {
  386. let rst;
  387. if (fileType === 'UnitPriceFile') {
  388. let unitPriceFileModel = new UnitPriceFileModel();
  389. rst = await unitPriceFileModel.getGCUnitPriceFiles(userID);
  390. }
  391. else if (fileType === 'FeeRateFile') {
  392. rst = await feeRateFacade.getGCFeeRateFiles(userID);
  393. }
  394. else {
  395. let isExist = false;
  396. for (let type in projectType) {
  397. if (projectType[type] === fileType) {
  398. isExist = true;
  399. break;
  400. }
  401. }
  402. if (!isExist) throw '不存在此项目类型!';
  403. rst = await Projects.find(
  404. {userID: userID, projType: fileType, 'deleteInfo.deleted': true, '$or': [{'deleteInfo.completeDeleted': false}, {'deleteInfo.completeDeleted': null}]});
  405. }
  406. return rst;
  407. };
  408. ProjectsDAO.prototype.getFirstNodeID = async function (userID, pid) {
  409. let nodes = await Projects.find({userID: userID, ParentID: pid, deleteInfo: null});
  410. if (nodes.length === 0) {
  411. return -1;
  412. }
  413. else {
  414. let prefix = 'ID_';
  415. let chain = Object.create(null);
  416. for (let i = 0, len = nodes.length; i < len; i++) {
  417. let nodeDoc = nodes[i]._doc;
  418. let node = Object.create(null);
  419. node.ID = nodeDoc.ID;
  420. node.NextSiblingID = nodeDoc.NextSiblingID;
  421. chain[prefix + node.ID] = node;
  422. }
  423. for (let i = 0, len = nodes.length; i < len; i++) {
  424. let nodeDoc = nodes[i]._doc;
  425. let next = nodeDoc.NextSiblingID > 0 ? chain[prefix + nodeDoc.NextSiblingID] : null;
  426. chain[prefix + nodeDoc.ID].next = next;
  427. if (next) {
  428. next.pre = chain[prefix + nodeDoc.ID]
  429. }
  430. }
  431. for (let node in chain) {
  432. let pre = chain[node].pre || null;
  433. if (!pre) {
  434. return chain[node].ID;
  435. }
  436. }
  437. }
  438. };
  439. ProjectsDAO.prototype.recGC = async function (userID, datas, callback) {
  440. let functions = [];
  441. let updateDatas = [];
  442. for (let i = 0, len = datas.length; i < len; i++) {
  443. if (datas[i].findData.ParentID !== undefined && datas[i].findData.NextSiblingID === -1 && !datas[i].findData.deleteInfo) {//维护项目管理树
  444. let findNode = await Projects.find(datas[i].findData);
  445. if (findNode.length > 0) {
  446. datas[i].findData = Object.create(null);
  447. datas[i].findData.ID = findNode[0].ID;
  448. updateDatas.push(datas[i]);
  449. }
  450. }
  451. else {
  452. if (datas[i].updateType === projectType.project && datas[i].updateData.NextSiblingID === undefined) {//则为待查询NextSiblingID,前端无法查询
  453. let projData = await Projects.find({userID: userID, ID: datas[i].findData.ID});//建设项目原本可能属于某文件夹、文件夹的存在需要判断
  454. let projPid = projData[0].ParentID;
  455. if (projPid !== -1) {
  456. let projFolder = await Projects.find({userID: userID, ID: projPid});
  457. if (projFolder.length === 0) {//文件夹已不存在
  458. projPid = -1;
  459. datas[i].updateData.ParentID = -1;
  460. }
  461. }
  462. let firstNodeID = await this.getFirstNodeID(userID, projPid);
  463. datas[i].updateData.NextSiblingID = firstNodeID;
  464. }
  465. updateDatas.push(datas[i])
  466. }
  467. }
  468. for (let i = 0, len = updateDatas.length; i < len; i++) {
  469. functions.push((function (data) {
  470. return function (cb) {
  471. if (data.updateType === fileType.unitPriceFile) {
  472. UnitPriceFiles.update({id: parseInt(data.findData.id)}, data.updateData, function (err) {
  473. if (err) cb(err);
  474. else {
  475. Projects.update({
  476. userID: userID,
  477. 'property.unitPriceFile.id': data.findData.id
  478. }, {$set: {'property.unitPriceFile.name': data.updateData.name}}, function (err) {
  479. if (err) cb(err);
  480. else cb(false);
  481. });
  482. }
  483. })
  484. }
  485. else if (data.updateType === fileType.feeRateFile) {
  486. FeeRateFiles.update(data.findData, data.updateData, function (err) {
  487. if (err) cb(err);
  488. else {
  489. Projects.update({
  490. userID: userID,
  491. 'property.feeFile.id': data.findData.ID
  492. }, {$set: {'property.feeFile.name': data.updateData.name}}, function (err) {
  493. if (err) cb(err);
  494. else cb(false);
  495. });
  496. }
  497. });
  498. }
  499. else {
  500. if (data) {
  501. Projects.update(data.findData, data.updateData, function (err) {
  502. if (err) cb(err);
  503. else cb(false);
  504. });
  505. }
  506. }
  507. }
  508. })(updateDatas[i]));
  509. }
  510. async_c.parallel(functions, function (err, results) {
  511. if (err) callback(err, 'fail', null);
  512. else callback(0, 'success', null);
  513. });
  514. };
  515. /**
  516. * 整理工程专业对应标准库数据
  517. *
  518. * @param {Object} data
  519. * @return {Boolean}
  520. */
  521. ProjectsDAO.prototype.isExist = async function (userId, compilationId, name, parentID) {
  522. parentID = parseInt(parentID);
  523. if (name === '' || isNaN(parentID)) {
  524. return true;
  525. }
  526. let condition = {
  527. userID: userId,
  528. compilation: compilationId,
  529. ParentID: parentID,
  530. name: name,
  531. "$or": [{deleteInfo: null}, {"deleteInfo.deleted": false}]
  532. };
  533. let count = await Projects.count(condition);
  534. return count > 0;
  535. };
  536. /**
  537. * 获取对应建设项目下所有的单位工程id
  538. *
  539. * @param {Number} projectId
  540. * @return {Promise}
  541. */
  542. ProjectsDAO.prototype.getTenderByProjectId = async function (projectId) {
  543. let result = [];
  544. // 首先获取对应的单位工程id
  545. let engineeringData = await Projects.find({ParentID: projectId});
  546. if (engineeringData.length <= 0) {
  547. return result;
  548. }
  549. let engineeringIdList = [];
  550. for (let tmp of engineeringData) {
  551. engineeringIdList.push(tmp.ID);
  552. }
  553. // 查找对应的单位工程id
  554. let tenderData = await Projects.find({ParentID: {$in: engineeringIdList},deleteInfo: null});
  555. if (tenderData.length <= 0) {
  556. return result;
  557. }
  558. for (let tmp of tenderData) {
  559. result.push(tmp.ID);
  560. }
  561. return result;
  562. };
  563. /**
  564. * 根据单价文件id获取对应的标段数据
  565. *
  566. * @param {Number} unitPriceFileId
  567. * @return {Promise}
  568. */
  569. ProjectsDAO.prototype.getTenderByUnitPriceFileId = async function (unitPriceFileId) {
  570. let result = [];
  571. unitPriceFileId = parseInt(unitPriceFileId);
  572. if (isNaN(unitPriceFileId) && unitPriceFileId <= 0) {
  573. return result;
  574. }
  575. //let condition = {projType: 'Tender', "property.unitPriceFile.id": unitPriceFileId};
  576. let condition = {"property.unitPriceFile.id": unitPriceFileId,deleteInfo:null};
  577. result = await Projects.find(condition,['name','property']);
  578. return result;
  579. };
  580. /**
  581. * 根据项目id获取单价文件列表id
  582. *
  583. * @param {Number} projectId
  584. * @return {Promise}
  585. */
  586. ProjectsDAO.prototype.getUnitPriceFileId = async function (projectId) {
  587. let result = 0;
  588. let startTime = +new Date();
  589. let projectData = await Projects.find({ID: projectId},['property.unitPriceFile']);
  590. if (projectData === null) {
  591. return result;
  592. }
  593. let endTime = +new Date();
  594. console.log("取单价文件列表id时间-----"+(endTime - startTime));
  595. projectData = projectData[0];
  596. result = projectData.property.unitPriceFile !== undefined ? projectData.property.unitPriceFile.id : 0;
  597. return result;
  598. };
  599. /**
  600. * 获取当前用户的建设项目数据
  601. *
  602. * @paraconsolem {Number} userId
  603. * @return {Promise}
  604. */
  605. ProjectsDAO.prototype.getUserProjectData = async function (userId) {
  606. let projectList = await Projects.find({
  607. '$or': [
  608. {'userID': userId, 'deleteInfo': null, projType: 'Project'},
  609. {'userID': userId, 'deleteInfo.deleted': {'$in': [null, false]}, projType: 'Project'}
  610. ]
  611. }, {_id: 0, name: 1, ID: 1});
  612. return projectList;
  613. };
  614. /**
  615. * 更改项目属性中的单价文件
  616. *
  617. * @param {Number} projectId
  618. * @param {Object} changeInfo
  619. * @return {Promise}
  620. */
  621. ProjectsDAO.prototype.changeUnitPriceFileInfo = async function (projectId, changeInfo) {
  622. projectId = parseInt(projectId);
  623. if (isNaN(projectId) || projectId <= 0) {
  624. return false;
  625. }
  626. let result = await Projects.update({ID: projectId}, {"property.unitPriceFile": changeInfo});
  627. return result.ok === 1;
  628. };
  629. /**
  630. * 更新项目属性
  631. *
  632. * @param {Number} projectId - 项目id
  633. * @param {Object} propertyData - 项目属性数据
  634. * @return {Promise}
  635. */
  636. ProjectsDAO.prototype.updateProjectProperty = async function(projectId, propertyData) {
  637. projectId = parseInt(projectId);
  638. if (isNaN(projectId) || projectId <= 0 || propertyData.property === undefined || propertyData.data === undefined) {
  639. return false;
  640. }
  641. const updateData = {};
  642. updateData["property." + propertyData.property] = propertyData.data;
  643. let result = await Projects.update({ID: projectId}, updateData);
  644. return result.ok === 1;
  645. };
  646. // CSL, 2018-01-11 获取指定ID节点(如单项工程、建设项目)下所有单位工程的各项汇总金额,用于报表计算汇总。
  647. ProjectsDAO.prototype.getSummaryFees = async function (ID) {
  648. async function getProject(ID){
  649. return await Projects.findOne({'ID': ID, deleteInfo: null}, need);
  650. };
  651. async function getChildrenDocs(IDs){
  652. return await Projects.find({'ParentID': {"$in":IDs}, deleteInfo: null}, need);
  653. };
  654. async function getEgrIDs(ID){
  655. let _docs = await Projects.find({'ParentID': ID, deleteInfo: null}, ['ID', '-_id']);
  656. let arr = [];
  657. for (let doc of _docs){
  658. arr.push(doc.ID);
  659. };
  660. return arr;
  661. };
  662. let need = ['ID', 'ParentID', 'NextSiblingID', 'name', 'projType',
  663. 'fullFolder', 'summaryFees', '-_id'];
  664. let _doc = await getProject(ID);
  665. if (!_doc) return _doc;
  666. if (_doc.projType.sameText('Engineering')){
  667. return await getChildrenDocs([ID]);
  668. }
  669. else if (_doc.projType.sameText('Project')){
  670. let eIDs = await getEgrIDs(ID);
  671. return await getChildrenDocs(eIDs);
  672. }
  673. else{
  674. return _doc;
  675. };
  676. };
  677. ProjectsDAO.prototype.updateUnitFileToProject=async function(projectID,unitFile){
  678. return await Projects.findOneAndUpdate({'ID':projectID},{'property.unitPriceFile':unitFile});
  679. }
  680. module.exports ={ project: new ProjectsDAO(),
  681. projType: projectType,
  682. fileType: fileType
  683. };