project_model.js 38 KB

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