project_model.js 37 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887
  1. /**
  2. * Created by Mai on 2017/1/18.
  3. */
  4. let projectType = {
  5. folder: 'Folder',
  6. tender: 'Tender',
  7. project: 'Project',
  8. engineering: 'Engineering',
  9. };
  10. let fileType = {
  11. unitPriceFile: 'UnitPriceFile',
  12. feeRateFile: 'FeeRateFile'
  13. };
  14. //先导出后require可以解决循环引用问题
  15. module.exports ={ project: new ProjectsDAO(),
  16. projType: projectType,
  17. fileType: fileType
  18. };
  19. import mongoose from 'mongoose';
  20. import async_c from 'async';
  21. import UnitPriceFileModel from "../../glj/models/unit_price_file_model";
  22. let UnitPriceFiles = mongoose.model('unit_price_file');
  23. import {
  24. defaultDecimal,
  25. billsQuantityDecimal,
  26. basicInformation,
  27. projectFeature,
  28. displaySetting,
  29. calcOptions,
  30. tenderSetting,
  31. G_FILE_VER
  32. } from './project_property_template';
  33. import optionSetting from '../../options/models/optionTypes';
  34. import fixedFlag from '../../common/const/bills_fixed';
  35. let FeeRateFiles = mongoose.model('fee_rate_file');
  36. let counter = require("../../../public/counter/counter.js");
  37. let newProjController = require('../controllers/new_proj_controller');
  38. let copyProjController = require('../controllers/copy_proj_controller');
  39. let feeRateFacade = require('../../fee_rates/facade/fee_rates_facade');
  40. let labourCoeFacade = require('../../main/facade/labour_coe_facade');
  41. let calcProgramFacade = require('../../main/facade/calc_program_facade');
  42. let installationFacade = require('../../main/facade/installation_facade');
  43. let projectFacade = require('../../main/facade/project_facade');
  44. let pmFacade = require('../facade/pm_facade');
  45. let logger = require("../../../logs/log_helper").logger;
  46. let BillsModel = require("../../main/models/bills").model;
  47. let _ = require('lodash');
  48. let Projects = mongoose.model('projects');
  49. let mainColLibModel = mongoose.model('std_main_col_lib');
  50. let projSettingModel = mongoose.model('proj_setting');
  51. let optionModel = mongoose.model('options');
  52. function ProjectsDAO() {
  53. }
  54. //let G_FILE_VER = '1.0.1';
  55. ProjectsDAO.prototype.getUserProjects = async function (userId, compilation, callback) {
  56. try {//
  57. let projects = await Projects.find({
  58. '$or': [{
  59. 'userID': userId,
  60. 'compilation': compilation,
  61. 'deleteInfo': null
  62. }, {'userID': userId, 'compilation': compilation, 'deleteInfo.deleted': {'$in': [null, false]}}]
  63. }, '-_id', {lean: true});
  64. let projIDs= [];
  65. for(let project of projects){
  66. if(project.projType === projectType.project){
  67. projIDs.push(project.ID);
  68. }
  69. }
  70. let summaryInfo = await pmFacade.getSummaryInfo(projIDs);
  71. //设置汇总字段
  72. for(let proj of projects){
  73. let summaryProj = summaryInfo[proj.ID];
  74. if(summaryProj){
  75. proj.engineeringCost = summaryProj.engineeringCost;
  76. proj.subEngineering = summaryProj.subEngineering;
  77. proj.measure = summaryProj.measure;
  78. proj.safetyConstruction = summaryProj.safetyConstruction;
  79. proj.other = summaryProj.other;
  80. proj.charge = summaryProj.charge;
  81. proj.tax = summaryProj.tax;
  82. proj.rate = summaryProj.rate;
  83. proj.buildingArea = summaryProj.buildingArea;
  84. proj.perCost = summaryProj.perCost;
  85. }
  86. }
  87. callback(0, '', projects);
  88. }
  89. catch (err) {
  90. callback(1, 'Error', null);
  91. }
  92. };
  93. ProjectsDAO.prototype.getUserProject = function (userId, ProjId, callback) {
  94. Projects.findOne({$or: [{deleteInfo: null}, {'deleteInfo.deleted': false}], ID: ProjId}, '-_id', function (err, template) {
  95. if (err) {
  96. callback(1, '找不到标段数据', null);
  97. } else {
  98. //打开分享的项目,只读
  99. if(template && userId !== template.userID){
  100. template._doc.readOnly = true;
  101. }
  102. callback(0, '', template);
  103. }
  104. });
  105. };
  106. ProjectsDAO.prototype.updateUserProjects = async function (userId, compilationId, compilationName,overWriteUrl, datas, callback) {
  107. let data, project, updateLength = 0, hasError = false, deleteInfo = null, i, newProject;
  108. let updateAll = function (err) {
  109. if (!err) {
  110. updateLength += 1;
  111. if (updateLength === datas.length) {
  112. callback(0, '', datas);
  113. }
  114. } else {
  115. hasError = true;
  116. console.log(err);
  117. callback(1, '提交数据出错.', null);
  118. }
  119. };
  120. console.log(datas);
  121. if (datas) {
  122. for (i = 0; i < datas.length && !hasError; i++) {
  123. data = datas[i];
  124. if (data.updateData.name !== undefined) {
  125. data.updateData.name = data.updateData.name.trim();
  126. }
  127. if (data.updateType === 'update') {
  128. Projects.update({userID: userId, ID: data.updateData.ID}, data.updateData, updateAll);
  129. }
  130. else if (data.updateType === 'new') {
  131. data.updateData['userID'] = userId;
  132. data.updateData['compilation'] = compilationId;
  133. data.updateData['createDateTime'] = new Date();
  134. data.updateData['fileVer'] = G_FILE_VER;
  135. /*if(data.updateData.projType === projectType.project){
  136. //设置建设项目基本信息,多个单位工程共用
  137. data.updateData.property = {basicInformation: basicInformation};
  138. }*/
  139. // 如果没有选中单价文件则新增单价文件
  140. if (data.updateData.projType === projectType.tender && data.updateData.property !== null &&
  141. Object.keys(data.updateData.property.unitPriceFile).length > 0 &&
  142. data.updateData.property.unitPriceFile.id === '') {
  143. let unitPriceFileModel = new UnitPriceFileModel();
  144. let insertData = {
  145. name: data.updateData.name,
  146. project_id: data.updateData.ID,
  147. user_id: userId,
  148. root_project_id: data.updateData.property.rootProjectID
  149. };
  150. let addResult = await unitPriceFileModel.add(insertData);
  151. if (!addResult) {
  152. callback(1, '新增单价文件失败.', null);
  153. return;
  154. }
  155. data.updateData.property.unitPriceFile.id = addResult.id;
  156. }
  157. if (data.updateData.projType === projectType.tender) {
  158. //单价文件
  159. data.updateData.property.unitPriceFile.id=parseInt(data.updateData.property.unitPriceFile.id);
  160. //小数位数
  161. data.updateData.property.decimal = defaultDecimal;
  162. //清单工程量精度
  163. data.updateData.property.billsQuantityDecimal = billsQuantityDecimal;
  164. //呈现选项
  165. data.updateData.property.displaySetting = displaySetting;
  166. data.updateData.property.billsCalcMode = 0;
  167. if(overWriteUrl && overWriteUrl !=""){
  168. let overWrite = require("../../.."+overWriteUrl);
  169. if(overWrite.getBillsCalcMode) data.updateData.property.billsCalcMode = overWrite.getBillsCalcMode();//重写清单计费取费方式
  170. }
  171. data.updateData.property.zanguCalcMode = 0;
  172. //计算选项
  173. data.updateData.property.calcOptions = calcOptions;
  174. //安装增加费
  175. if(data.updateData.property.isInstall == true || data.updateData.property.isInstall=='true'){//判断是否安装工程
  176. await installationFacade.copyInstallationFeeFromLib(data.updateData.ID,data.updateData.property.engineering_id);
  177. }
  178. //锁定清单
  179. data.updateData.property.lockBills = false;
  180. //工料机单价调整系数
  181. data.updateData.property.tenderSetting = tenderSetting;
  182. //添加重庆经济指标数据
  183. await projectFacade.setSEILibData(data.updateData.property);
  184. data.updateData.property.overHeight = await pmFacade.initOverHeightItems(data.updateData.property.engineering_id);
  185. if (data.updateData.property.overHeight.length) {
  186. // 对应清单或分部下
  187. data.updateData.property.overHeightOption = 1;
  188. }
  189. }else if (data.updateData.projType === projectType.project) {
  190. //更新基本信息
  191. data.updateData.property.basicInformation.forEach(function (pData) {
  192. pData.items.forEach(function (item) {
  193. if (item.key === 'engineeringName') {
  194. item.value = data.updateData.name;
  195. } else if (item.key === 'fileKind') {
  196. item.value = {'1': '投标', '2': '招标'}[data.updateData.property.fileKind]
  197. } else if (item.key === 'taxModel') {
  198. item.value = {'1': '一般计税法', '2': '简易计税法'}[data.updateData.property.taxType]
  199. }
  200. });
  201. });
  202. }
  203. newProject = new Projects(data.updateData);
  204. if (data.updateData.projType === 'Tender') {
  205. let feeRateFileID = await feeRateFacade.newFeeRateFile(userId, data.updateData);
  206. newProject.property.feeFile = feeRateFileID ? feeRateFileID : -1;
  207. // 新建人工系数文件 CSL, 2017.10.13
  208. let lcFile = await labourCoeFacade.newProjectLabourCoe(data.updateData);
  209. newProject.property.labourCoeFile = lcFile ? lcFile : null;
  210. // 新建计算程序文件 CSL, 2017.10.23
  211. let cpFile = await calcProgramFacade.newProjectCalcProgramFile(data.updateData);
  212. newProject.property.calcProgramFile = cpFile ? cpFile : null;
  213. }
  214. newProject.save(async function (err, result) {
  215. if (!err && result._doc.projType === projectType.tender) {
  216. newProjController.copyTemplateData(result._doc.property, newProject.ID, updateAll);
  217. } else {
  218. updateAll(err);
  219. }
  220. });
  221. }
  222. else if (data.updateType === 'delete') {
  223. deleteInfo = {};
  224. deleteInfo['deleted'] = true;
  225. deleteInfo['deleteDateTime'] = new Date();
  226. deleteInfo['deleteBy'] = userId;
  227. data.updateData['deleteInfo'] = deleteInfo;
  228. //Projects.update({userID: userId, ID: data.updateData.ID}, data.updateData, updateAll);
  229. //update
  230. try {
  231. if (data.updateData.projType === projectType.project) {
  232. let engineerings = await Projects.find({userID: userId, ParentID: data.updateData.ID});
  233. let isExist = false;
  234. if (engineerings.length > 0) {
  235. for (let j = 0, jLen = engineerings.length; j < jLen; j++) {
  236. let e_tenders = await Projects.find({userID: userId, ParentID: engineerings[j].ID});
  237. if (e_tenders.length > 0) {
  238. isExist = true;
  239. break;
  240. }
  241. }
  242. }
  243. if (isExist) {//fake
  244. await UnitPriceFiles.update({
  245. user_id: userId,
  246. root_project_id: data.updateData.ID
  247. }, {$set: {deleteInfo: deleteInfo}}, {multi: true});
  248. await FeeRateFiles.update({
  249. userID: userId,
  250. rootProjectID: data.updateData.ID
  251. }, {$set: {deleteInfo: deleteInfo}}, {multi: true});
  252. await Projects.update({userID: userId, ID: data.updateData.ID}, data.updateData, updateAll);
  253. }
  254. else {//true
  255. await UnitPriceFiles.remove({user_id: userId, root_project_id: data.updateData.ID});
  256. await FeeRateFiles.remove({userID: userId, rootProjectID: data.updateData.ID});
  257. //await Projects.update({userID: userId, NextSiblingID: data.updateData.ID, deleteInfo: null}, {$set: {NextSiblingID: data.NextSiblingID}});
  258. await Projects.remove({userID: userId, ID: data.updateData.ID}, updateAll);
  259. }
  260. }
  261. else if (data.updateData.projType === projectType.engineering) {
  262. let tenders = await Projects.find({userID: userId, ParentID: data.updateData.ID});
  263. if (tenders.length > 0) {//fake
  264. await Projects.update({userID: userId, ID: data.updateData.ID}, data.updateData, updateAll);
  265. }
  266. else {//true
  267. //await Projects.update({userID: userId, NextSiblingID: data.updateData.ID, deleteInfo: null}, {$set: {NextSiblingID: data.NextSiblingID}});
  268. await Projects.remove({userID: userId, ID: data.updateData.ID}, updateAll);
  269. }
  270. }
  271. else if (data.updateData.projType === projectType.tender) {//fake
  272. let delTender = await Projects.findOne({userID: userId, ID: data.updateData.ID});
  273. //如果这个单位工程用到的费率文件、单价文件,没有被其他的单位工程使用,则应该一起跟随删除
  274. if(delTender){
  275. let unitPriceFile = delTender.property.unitPriceFile;
  276. let feeRateFile = delTender.property.feeFile;
  277. let usedUFTenders = await Projects.find(
  278. {userID: userId, $or: [{deleteInfo: null}, {'deleteInfo.deleted': false}], 'property.unitPriceFile.id': unitPriceFile.id});
  279. if(usedUFTenders.length === 1){
  280. await UnitPriceFiles.update({id: unitPriceFile.id}, {$set: {deleteInfo: deleteInfo}});
  281. }
  282. let usedFRTenders = await Projects.find(
  283. {userID: userId, $or: [{deleteInfo: null}, {'deleteInfo.deleted': false}], 'property.feeFile.id': feeRateFile.id});
  284. if(usedFRTenders.length === 1){
  285. await FeeRateFiles.update({ID: feeRateFile.id}, {$set: {deleteInfo: deleteInfo}});
  286. }
  287. await Projects.update({userID: userId, ID: data.updateData.ID}, data.updateData, updateAll);
  288. }
  289. }
  290. else if (data.updateData.projType === projectType.folder) {//true
  291. await Projects.remove({userID: userId, ID: data.updateData.ID}, updateAll);
  292. }
  293. else throw '未知文件类型,删除失败!';
  294. }
  295. catch (error) {
  296. callback(1, error, null);
  297. }
  298. }
  299. else {
  300. hasError = true;
  301. callback(1, '提交数据错误.', null);
  302. }
  303. }
  304. }
  305. };
  306. //导入接口数据
  307. ProjectsDAO.prototype.importInterface = async function (srcData) {
  308. };
  309. ProjectsDAO.prototype.udpateUserFiles = async function (userId, datas, callback) {
  310. let updateType = {update: 'update', delete: 'delete'};
  311. let deleteInfo = Object.create(null);
  312. deleteInfo.deleted = true;
  313. deleteInfo.deleteBy = userId;
  314. deleteInfo.deleteDateTime = new Date();
  315. try {
  316. for (let i = 0, len = datas.length; i < len; i++) {
  317. let data = datas[i];
  318. if (data.updateType === updateType.update && data.fileType === fileType.unitPriceFile) {
  319. await UnitPriceFiles.update({user_id: userId, id: parseInt(data.updateData.id)}, data.updateData);
  320. await Projects.update({
  321. userID: userId,
  322. 'property.unitPriceFile.id': data.updateData.id
  323. }, {$set: {'property.unitPriceFile.name': data.updateData.name}}, {multi: true});
  324. }
  325. else if (data.updateType === updateType.update && data.fileType === fileType.feeRateFile) {
  326. await FeeRateFiles.update({ID: data.updateData.ID}, data.updateData);
  327. await Projects.update({
  328. userID: userId,
  329. 'property.feeFile.id': data.updateData.ID
  330. }, {$set: {'property.feeFile.name': data.updateData.name}}, {multi: true});
  331. }
  332. else if (data.updateType === updateType.delete && data.fileType === fileType.unitPriceFile) {
  333. data.updateData.deleteInfo = deleteInfo;
  334. await UnitPriceFiles.update({user_id: userId, id: parseInt(data.updateData.id)}, data.updateData);
  335. }
  336. else if (data.updateType === updateType.delete && data.fileType === fileType.feeRateFile) {
  337. data.updateData.deleteInfo = deleteInfo;
  338. await FeeRateFiles.update({ID: data.updateData.ID}, data.updateData);
  339. }
  340. else throw '未知文件类型,删除失败'
  341. }
  342. callback(false, '删除成功', null);
  343. }
  344. catch (error) {
  345. callback(true, '删除失败', null);
  346. }
  347. };
  348. ProjectsDAO.prototype.copyUserProjects = function (userId, compilationId, datas, callback) {
  349. let data, project, updateLength = 0, hasError = false, deleteInfo = null, tempType = 1, i;
  350. let updateAll = function (err) {
  351. if (!err) {
  352. updateLength += 1;
  353. if (updateLength === datas.length) {
  354. callback(0, '', datas);
  355. }
  356. } else {
  357. hasError = true;
  358. callback(1, '提交数据出错.', null);
  359. }
  360. };
  361. if (datas) {
  362. for (i = 0; i < datas.length && !hasError; i++) {
  363. data = datas[i];
  364. if (data.updateType === 'update') {
  365. Projects.update({userID: userId, ID: data.updateData.ID}, data.updateData, updateAll)
  366. } else if (data.updateType === 'copy') {
  367. console.log(userId);
  368. data.updateData['userID'] = userId;
  369. data.updateData['compilation'] = compilationId;
  370. data.updateData['createDateTime'] = new Date();
  371. data.updateData['fileVer'] = G_FILE_VER;
  372. let newProject = new Projects(data.updateData);
  373. newProject['srcProjectId'] = data.srcProjectId;
  374. newProject.save(function (err, result) {
  375. if (!err && result._doc.projType === 'Tender') {
  376. copyProjController.copyProjectData(newProject.srcProjectId, result._doc.ID, updateAll);
  377. } else {
  378. updateAll(err);
  379. }
  380. });
  381. } else {
  382. hasError = true;
  383. callback(1, '提交数据错误', null);
  384. }
  385. }
  386. }
  387. };
  388. ProjectsDAO.prototype.rename = async function (userId, compilationId, data, callback) {
  389. try {
  390. if (data.id === undefined || data.id === '') {
  391. throw '数据错误!';
  392. }
  393. if (data.newName === undefined || data.newName === '') {
  394. throw '请填写名称!';
  395. }
  396. data.newName = data.newName.trim();
  397. let project = await Projects.findOne({ID: data.id});
  398. if (!project) {
  399. throw '项目不存在';
  400. }
  401. if (project.projType === 'Project' && project.property && Array.isArray(project.property.basicInformation)) {
  402. //更新基本信息
  403. project.property.basicInformation.forEach(function (pData) {
  404. pData.items.forEach(function (item) {
  405. if (item.key === 'engineeringName') {
  406. item.value = data.newName;
  407. }
  408. });
  409. });
  410. await Projects.update({ID: data.id}, {$set: {name: data.newName, 'property.basicInformation': project.property.basicInformation}});
  411. } else {
  412. await Projects.update({ID: data.id}, {$set: {name: data.newName}});
  413. }
  414. Projects.update({userID: userId, ID: data.id}, {name: data.newName}, function (err) {
  415. if (err) {
  416. throw '项目不存在';
  417. }
  418. });
  419. } catch (error) {
  420. callback(1, error, null);
  421. return;
  422. }
  423. callback(0, '');
  424. };
  425. ProjectsDAO.prototype.beforeOpenProject = function (userId, projectId, updateData, callback) {
  426. updateData['recentDateTime'] = new Date();
  427. Projects.update({userID: userId, ID: projectId}, updateData, function (err) {
  428. if (err) {
  429. callback(1, '项目不存在.');
  430. } else {
  431. callback(0, '');
  432. }
  433. });
  434. };
  435. ProjectsDAO.prototype.getNewProjectID = function (count, callback) {
  436. counter.counterDAO.getIDAfterCount(counter.moduleName.project, count, function (err, result) {
  437. console.log(result);
  438. let highID = result.sequence_value;
  439. if (!err) {
  440. callback(0, '', {lowID: highID - count + 1, highID: highID});
  441. } else {
  442. callback(1, '获取主键失败', null);
  443. }
  444. });
  445. };
  446. ProjectsDAO.prototype.getProject = function (key, callback) {
  447. if (callback) {
  448. Projects.findOne({'_id': key}, function (err, result) {
  449. if (err) {
  450. callback(1, '查找标段失败');
  451. } else {
  452. callback(0, result);
  453. }
  454. });
  455. } else {
  456. return Projects.findOne({$or: [{deleteInfo: null}, {'deleteInfo.deleted': false}], 'ID': key}).exec();
  457. }
  458. };
  459. ProjectsDAO.prototype.getProjectsByIds = async function (userId, compilationId, ids) {
  460. return await Projects.find({userID: userId, compilation: compilationId, ID: {$in: ids}}, '-_id -property');
  461. };
  462. ProjectsDAO.prototype.getGCFiles = async function (fileType, userID) {
  463. let rst;
  464. if (fileType === 'UnitPriceFile') {
  465. let unitPriceFileModel = new UnitPriceFileModel();
  466. rst = await unitPriceFileModel.getGCUnitPriceFiles(userID);
  467. }
  468. else if (fileType === 'FeeRateFile') {
  469. rst = await feeRateFacade.getGCFeeRateFiles(userID);
  470. }
  471. else {
  472. let isExist = false;
  473. for (let type in projectType) {
  474. if (projectType[type] === fileType) {
  475. isExist = true;
  476. break;
  477. }
  478. }
  479. if (!isExist) throw '不存在此项目类型!';
  480. rst = await Projects.find(
  481. {userID: userID, projType: fileType, 'deleteInfo.deleted': true, '$or': [{'deleteInfo.completeDeleted': false}, {'deleteInfo.completeDeleted': null}]});
  482. }
  483. return rst;
  484. };
  485. ProjectsDAO.prototype.getFirstNodeID = async function (userID, compilationId, pid) {
  486. let nodes = await Projects.find({userID: userID, compilation: compilationId, ParentID: pid, deleteInfo: null});
  487. if (nodes.length === 0) {
  488. return -1;
  489. }
  490. else {
  491. let prefix = 'ID_';
  492. let chain = Object.create(null);
  493. for (let i = 0, len = nodes.length; i < len; i++) {
  494. let nodeDoc = nodes[i]._doc;
  495. let node = Object.create(null);
  496. node.ID = nodeDoc.ID;
  497. node.NextSiblingID = nodeDoc.NextSiblingID;
  498. chain[prefix + node.ID] = node;
  499. }
  500. for (let i = 0, len = nodes.length; i < len; i++) {
  501. let nodeDoc = nodes[i]._doc;
  502. let next = nodeDoc.NextSiblingID > 0 ? chain[prefix + nodeDoc.NextSiblingID] : null;
  503. chain[prefix + nodeDoc.ID].next = next;
  504. if (next) {
  505. next.pre = chain[prefix + nodeDoc.ID]
  506. }
  507. }
  508. for (let node in chain) {
  509. let pre = chain[node].pre || null;
  510. if (!pre) {
  511. return chain[node].ID;
  512. }
  513. }
  514. }
  515. };
  516. ProjectsDAO.prototype.recGC = async function (userID, compilationId, datas, callback) {
  517. let functions = [];
  518. let updateDatas = [];
  519. for (let i = 0, len = datas.length; i < len; i++) {
  520. if (datas[i].findData.ParentID !== undefined && datas[i].findData.NextSiblingID === -1 && !datas[i].findData.deleteInfo) {//维护项目管理树
  521. let findNode = await Projects.find(datas[i].findData);
  522. if (findNode.length > 0) {
  523. datas[i].findData = Object.create(null);
  524. datas[i].findData.ID = findNode[0].ID;
  525. updateDatas.push(datas[i]);
  526. }
  527. }
  528. else {
  529. if (datas[i].updateType === projectType.project && datas[i].updateData.NextSiblingID === undefined) {//则为待查询NextSiblingID,前端无法查询
  530. let projData = await Projects.find({userID: userID, ID: datas[i].findData.ID});//建设项目原本可能属于某文件夹、文件夹的存在需要判断
  531. let projPid = projData[0].ParentID;
  532. if (projPid !== -1) {
  533. let projFolder = await Projects.find({userID: userID, ID: projPid});
  534. if (projFolder.length === 0) {//文件夹已不存在
  535. projPid = -1;
  536. datas[i].updateData.ParentID = -1;
  537. }
  538. }
  539. let firstNodeID = await this.getFirstNodeID(userID, compilationId, projPid);
  540. datas[i].updateData.NextSiblingID = firstNodeID;
  541. }
  542. updateDatas.push(datas[i])
  543. }
  544. }
  545. for (let i = 0, len = updateDatas.length; i < len; i++) {
  546. functions.push((function (data) {
  547. return function (cb) {
  548. if (data.updateType === fileType.unitPriceFile) {
  549. UnitPriceFiles.update({id: parseInt(data.findData.id)}, data.updateData, function (err) {
  550. if (err) cb(err);
  551. else {
  552. Projects.update({
  553. userID: userID,
  554. 'property.unitPriceFile.id': data.findData.id
  555. }, {$set: {'property.unitPriceFile.name': data.updateData.name}}, function (err) {
  556. if (err) cb(err);
  557. else cb(false);
  558. });
  559. }
  560. })
  561. }
  562. else if (data.updateType === fileType.feeRateFile) {
  563. FeeRateFiles.update(data.findData, data.updateData, function (err) {
  564. if (err) cb(err);
  565. else {
  566. Projects.update({
  567. userID: userID,
  568. 'property.feeFile.id': data.findData.ID
  569. }, {$set: {'property.feeFile.name': data.updateData.name}}, function (err) {
  570. if (err) cb(err);
  571. else cb(false);
  572. });
  573. }
  574. });
  575. }
  576. else {
  577. if (data) {
  578. Projects.update(data.findData, data.updateData, function (err) {
  579. if (err) cb(err);
  580. else cb(false);
  581. });
  582. }
  583. }
  584. }
  585. })(updateDatas[i]));
  586. }
  587. async_c.parallel(functions, function (err, results) {
  588. if (err) callback(err, 'fail', null);
  589. else callback(0, 'success', null);
  590. });
  591. };
  592. /**
  593. * 整理工程专业对应标准库数据
  594. *
  595. * @param {Object} data
  596. * @return {Boolean}
  597. */
  598. ProjectsDAO.prototype.isExist = async function (userId, compilationId, name, parentID) {
  599. parentID = parseInt(parentID);
  600. if (name === '' || isNaN(parentID)) {
  601. return true;
  602. }
  603. let condition = {
  604. userID: userId,
  605. compilation: compilationId,
  606. ParentID: parentID,
  607. name: name,
  608. "$or": [{deleteInfo: null}, {"deleteInfo.deleted": false}]
  609. };
  610. let count = await Projects.count(condition);
  611. return count > 0;
  612. };
  613. /**
  614. * 获取对应建设项目下所有的单位工程id
  615. *
  616. * @param {Number} projectId
  617. * @return {Promise}
  618. */
  619. ProjectsDAO.prototype.getTenderByProjectId = async function (projectId) {
  620. let result = [];
  621. // 首先获取对应的单位工程id
  622. let engineeringData = await Projects.find({ParentID: projectId});
  623. if (engineeringData.length <= 0) {
  624. return result;
  625. }
  626. let engineeringIdList = [];
  627. for (let tmp of engineeringData) {
  628. engineeringIdList.push(tmp.ID);
  629. }
  630. // 查找对应的单位工程id
  631. let tenderData = await Projects.find({ParentID: {$in: engineeringIdList},deleteInfo: null});
  632. if (tenderData.length <= 0) {
  633. return result;
  634. }
  635. for (let tmp of tenderData) {
  636. result.push(tmp.ID);
  637. }
  638. return result;
  639. };
  640. /**
  641. * 根据单价文件id获取对应的标段数据
  642. *
  643. * @param {Number} unitPriceFileId
  644. * @return {Promise}
  645. */
  646. ProjectsDAO.prototype.getTenderByUnitPriceFileId = async function (unitPriceFileId) {
  647. let result = [];
  648. unitPriceFileId = parseInt(unitPriceFileId);
  649. if (isNaN(unitPriceFileId) && unitPriceFileId <= 0) {
  650. return result;
  651. }
  652. //let condition = {projType: 'Tender', "property.unitPriceFile.id": unitPriceFileId};
  653. let condition = {"property.unitPriceFile.id": unitPriceFileId,deleteInfo:null};
  654. result = await Projects.find(condition,['name','property']);
  655. return result;
  656. };
  657. /**
  658. * 根据项目id获取单价文件列表id
  659. *
  660. * @param {Number} projectId
  661. * @return {Promise}
  662. */
  663. ProjectsDAO.prototype.getUnitPriceFileId = async function (projectId) {
  664. let result = 0;
  665. let startTime = +new Date();
  666. let projectData = await Projects.find({ID: projectId},['property.unitPriceFile']);
  667. if (projectData === null) {
  668. return result;
  669. }
  670. let endTime = +new Date();
  671. console.log("取单价文件列表id时间-----"+(endTime - startTime));
  672. projectData = projectData[0];
  673. result = projectData.property.unitPriceFile !== undefined ? projectData.property.unitPriceFile.id : 0;
  674. return result;
  675. };
  676. /**
  677. * 根据项目id获取项目property信息
  678. *
  679. * @param {Number} projectId
  680. * @return {Promise}
  681. */
  682. ProjectsDAO.prototype.getProjectProperty = async function (projectId) {
  683. let result = null;
  684. let projectData = await Projects.findOne({ID: projectId},['property']);
  685. if (projectData === null) {
  686. return result;
  687. }
  688. return projectData.property;
  689. };
  690. ProjectsDAO.prototype.getExtendData = function(property,compilation) {
  691. let ext = {};
  692. if(property){
  693. let region = property.region;
  694. let taxType = property.taxType;
  695. if(compilation.priceProperties && compilation.priceProperties.length > 0){//如果是具有多单价的编办,取单价对应的字段
  696. let priceProperty = _.find(compilation.priceProperties,{region:region,taxModel:parseInt(taxType)});
  697. if(priceProperty){
  698. ext['priceField'] = priceProperty.price.dataCode;
  699. }
  700. }
  701. if(compilation.consumeAmtProperties && compilation.consumeAmtProperties.length > 0){
  702. let consumeAmt = _.find(compilation.consumeAmtProperties,{region:region,taxModel:parseInt(taxType)});
  703. if(consumeAmt){
  704. ext['quantityField'] = consumeAmt.consumeAmt.dataCode;
  705. }
  706. }
  707. }
  708. return _.isEmpty(ext)?null:ext;
  709. }
  710. /**
  711. * 获取当前用户的建设项目数据
  712. *
  713. * @paraconsolem {Number} userId
  714. * @return {Promise}
  715. */
  716. ProjectsDAO.prototype.getUserProjectData = async function (userId,compilation) {
  717. let projectList = await Projects.find({
  718. '$or': [
  719. {'userID': userId, 'compilation': compilation, 'deleteInfo': null, projType: 'Project'},
  720. {'userID': userId, 'compilation': compilation,'deleteInfo.deleted': {'$in': [null, false]}, projType: 'Project'}
  721. ]
  722. }, {_id: 0, name: 1, ID: 1, NextSiblingID: 1, ParentID: 1});
  723. return projectList;
  724. };
  725. /**
  726. * 更改项目属性中的单价文件
  727. *
  728. * @param {Number} projectId
  729. * @param {Object} changeInfo
  730. * @return {Promise}
  731. */
  732. ProjectsDAO.prototype.changeUnitPriceFileInfo = async function (projectId, changeInfo) {
  733. projectId = parseInt(projectId);
  734. if (isNaN(projectId) || projectId <= 0) {
  735. return false;
  736. }
  737. let result = await Projects.update({ID: projectId}, {"property.unitPriceFile": changeInfo});
  738. return result.ok === 1;
  739. };
  740. /**
  741. * 更新项目属性
  742. *
  743. * @param {Number} projectId - 项目id
  744. * @param {Object} propertyData - 项目属性数据
  745. * @return {Promise}
  746. */
  747. ProjectsDAO.prototype.updateProjectProperty = async function(projectId, propertyData) {
  748. projectId = parseInt(projectId);
  749. if (isNaN(projectId) || projectId <= 0 || propertyData.property === undefined || propertyData.data === undefined) {
  750. return false;
  751. }
  752. const updateData = {};
  753. updateData["property." + propertyData.property] = propertyData.data;
  754. let result = await Projects.update({ID: projectId}, updateData);
  755. return result.ok === 1;
  756. };
  757. // CSL, 2018-01-11 获取指定ID节点(如单项工程、建设项目)下所有单位工程的各项汇总金额,用于报表计算汇总。
  758. ProjectsDAO.prototype.getSummaryFees = async function (ID) {
  759. async function getProject(ID){
  760. return await Projects.findOne({'ID': ID, deleteInfo: null}, need);
  761. };
  762. async function getChildrenDocs(IDs){
  763. return await Projects.find({'ParentID': {"$in":IDs}, deleteInfo: null}, need);
  764. };
  765. async function getEgrIDs(ID){
  766. let _docs = await Projects.find({'ParentID': ID, deleteInfo: null}, ['ID', '-_id']);
  767. let arr = [];
  768. for (let doc of _docs){
  769. arr.push(doc.ID);
  770. };
  771. return arr;
  772. };
  773. let need = ['ID', 'ParentID', 'NextSiblingID', 'name', 'projType',
  774. 'fullFolder', 'summaryFees', '-_id'];
  775. let _doc = await getProject(ID);
  776. if (!_doc) return _doc;
  777. if (_doc.projType.sameText('Engineering')){
  778. return await getChildrenDocs([ID]);
  779. }
  780. else if (_doc.projType.sameText('Project')){
  781. let eIDs = await getEgrIDs(ID);
  782. return await getChildrenDocs(eIDs);
  783. }
  784. else{
  785. return _doc;
  786. };
  787. };
  788. ProjectsDAO.prototype.updateUnitFileToProject=async function(projectID,unitFile){
  789. return await Projects.findOneAndUpdate({'ID':projectID},{'property.unitPriceFile':unitFile});
  790. }
  791. //获取建设项目项目属性
  792. ProjectsDAO.prototype.getConstructionProperty = async function (projectID) {
  793. //获取建设项目
  794. let constructionProject = await pmFacade.getConstructionProject(projectID);
  795. if(!constructionProject || !constructionProject.property){
  796. return null;
  797. }
  798. return constructionProject.property;
  799. };
  800. //获取建设项目的基本信息
  801. ProjectsDAO.prototype.getBasicInfo = async function (projectID) {
  802. //获取建设项目
  803. let constructionProject = await pmFacade.getConstructionProject(projectID);
  804. if(!constructionProject || !constructionProject.property || !constructionProject.property.basicInformation){
  805. return null;
  806. }
  807. return constructionProject.property.basicInformation;
  808. };
  809. //恢复默认系统设置
  810. ProjectsDAO.prototype.defaultSettings = async function (userID, compilationId, projectID) {
  811. let project = await Projects.findOne({ID: projectID});
  812. if(!project){
  813. return false;
  814. }
  815. let cloneProperty = _.cloneDeep(project.property);
  816. //关于计算
  817. cloneProperty.billsCalcMode = 0;
  818. cloneProperty.zanguCalcMode = 0;
  819. cloneProperty.calcOptions = calcOptions;
  820. //清单工程量精度
  821. cloneProperty.billsQuantityDecimal = billsQuantityDecimal;
  822. //小数位数
  823. cloneProperty.decimal = defaultDecimal;
  824. //呈现选项
  825. cloneProperty.displaySetting = displaySetting;
  826. //列设置
  827. let stdColLib = await mainColLibModel.findOne({ID: project.property.colLibID});
  828. if(stdColLib){
  829. await projSettingModel.update({projectID: projectID}, {$set: {main_tree_col: stdColLib.main_tree_col}});
  830. }
  831. //系统选项
  832. await optionModel.update({user_id: userID, compilation_id: compilationId}, {$set: {options: optionSetting}});
  833. await Projects.update({ID: projectID}, {$set: {property: cloneProperty}});
  834. return true;
  835. };