ration_glj_facade.js 38 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072
  1. /**
  2. * Created by chen on 2017/6/29.
  3. */
  4. module.exports = {
  5. save: save,
  6. getData: getData,
  7. deleteByRation: deleteByRation,
  8. getQuantityByProjectGLJ: getQuantityByProjectGLJ,
  9. getLibInfo: getLibInfo,
  10. getLibOptions,
  11. getLibOptionsForCompilation,
  12. getGLJLib,
  13. getGLJData: getGLJData,
  14. getGLJDataPaging: getGLJDataPaging,
  15. getGLJDataByCodes:getGLJDataByCodes,
  16. addGLJ: addGLJ,
  17. deleteGLJ:deleteGLJ,
  18. insertAddTypeGLJ:insertAddTypeGLJ,
  19. replaceGLJ: replaceGLJ,
  20. replaceGLJByData:replaceGLJByData,
  21. mReplaceGLJ: mReplaceGLJ,
  22. updateRationGLJByEdit: updateRationGLJByEdit,
  23. getGLJClass: getGLJClass,
  24. insertGLJAsRation: insertGLJAsRation,
  25. getRationTypeGLJQuantity:getRationTypeGLJQuantity,
  26. getInfoFromProjectGLJ:getInfoFromProjectGLJ,
  27. createNewRecord:createNewRecord,
  28. getGLJSearchInfo:getGLJSearchInfo,
  29. updateRationGLJFromDoc:updateRationGLJFromDoc,
  30. getGLJLibByEngineerID:getGLJLibByEngineerID,
  31. prepareExtData:prepareExtData
  32. }
  33. let mongoose = require('mongoose');
  34. const uuidV1 = require('uuid/v1');
  35. let consts = require('../../main/models/project_consts')
  36. let commonConsts = consts.commonConst;
  37. let _ = require("lodash");
  38. let ration_glj = mongoose.model('ration_glj');
  39. const GLJListModel = require('../../glj/models/glj_list_model');
  40. let std_glj_lib_gljList_model = mongoose.model('std_glj_lib_gljList');
  41. let async_n = require("async");
  42. let ration = mongoose.model('ration');
  43. let ration_coe_facade = require('./ration_coe_facade');
  44. let ration_coe = mongoose.model('ration_coe');
  45. let std_ration_lib_ration_items = mongoose.model('std_ration_lib_ration_items');
  46. let glj_calculate_facade = require('./glj_calculate_facade');
  47. let glj_type_util = require('../../../public/cache/std_glj_type_util');
  48. let quantity_detail_facade = require('../../main/facade/quantity_detail_facade');
  49. let ration_installation_facade = require('../../main/facade/ration_installation_facade');
  50. let logger = require("../../../logs/log_helper").logger;
  51. const stdgljutil = require("../../../public/cache/std_glj_type_util");
  52. const EngineeringLibModel = require("../../users/models/engineering_lib_model");
  53. const GljDao = require("../../complementary_glj_lib/models/gljModel");
  54. const gljType = require("../../common/const/glj_type_const.js");
  55. const complementaryGljModel = mongoose.model('complementary_glj_lib');
  56. const stdGljModel = mongoose.model('std_glj_lib_gljList');
  57. const gljClassModel = mongoose.model('std_glj_lib_gljClass');
  58. const stdGLJLibModel = mongoose.model('std_glj_lib_map');
  59. const projectDao = require('../../pm/models/project_model').project;
  60. const compleClassModel = mongoose.model('complementary_glj_section');
  61. const stdRationLibModel = mongoose.model('std_ration_lib_map');
  62. const compilationModel = mongoose.model('compilation');
  63. const engineeringModel = mongoose.model('engineering_lib');
  64. let operationMap = {
  65. 'ut_create': create_ration_glj,
  66. 'ut_update': update_ration_glj,
  67. 'ut_delete': delete_ration_glj
  68. };
  69. let updateFunctionMap = {
  70. 'normalUpdate': normalUpdate
  71. };
  72. /**
  73. * 根据项目工料机ID和项目ID取消耗量
  74. *
  75. * @param {object} condition
  76. * @return Array
  77. */
  78. async function getQuantityByProjectGLJ(condition) {
  79. let query = {
  80. 'projectID': condition.projectID,
  81. };
  82. if(condition.projectGLJIDList){
  83. query['projectGLJID'] = {$in: condition.projectGLJIDList};
  84. }
  85. let startTime = +new Date();
  86. let results = await ration_glj.find(query, ['projectGLJID', 'quantity', 'rationID'], {sort: {projectGLJID: 1}});
  87. let rationList = _.uniq(_.map(results, 'rationID'));
  88. let getQuantity = +new Date();
  89. console.log("取工料机消耗量时间-----"+(getQuantity - startTime));
  90. let rationQuery = {
  91. 'projectID': condition.projectID,
  92. 'ID': {$in: rationList},
  93. 'deleteInfo': null
  94. };
  95. /* $and: [
  96. {'projectID': condition.projectID},
  97. {'ID': {$in: rationList}},
  98. {'deleteInfo': null}
  99. ]*/
  100. let rations = await ration.find(rationQuery, ['ID', 'quantity']);
  101. let rationsTime = +new Date();
  102. console.log("取定额消耗量时间-----"+(rationsTime - getQuantity));
  103. return combineQuantity(results, rations);
  104. }
  105. function combineQuantity(results, rations) {
  106. let resultList = [];
  107. let rationMap = _.indexBy(rations,'ID');
  108. for(let r of results){
  109. let tmp = {
  110. projectGLJID: r.projectGLJID,
  111. quantity: Number(r.quantity)
  112. }
  113. let ration = rationMap[r.rationID];//_.find(rations, {ID: r.rationID})
  114. if (ration) {
  115. tmp.rationID = ration.ID;
  116. tmp.rationQuantity = ration.quantity ? Number(ration.quantity) : undefined;
  117. }
  118. resultList.push(tmp);
  119. }
  120. return resultList;
  121. return resultList;
  122. }
  123. function get_lib_glj_info(ration_glj) {
  124. return function (result, cb) {
  125. std_glj_lib_gljList_model.findOne({'ID': ration_glj.GLJID}, (err, glj) => {
  126. if (err) {
  127. cb(err, '')
  128. } else if (glj) {
  129. ration_glj.name = glj.name;
  130. ration_glj.code = glj.code;
  131. ration_glj.original_code = glj.code;
  132. ration_glj.unit = glj.unit;
  133. ration_glj.specs = glj.specs;
  134. ration_glj.basePrice = glj.basePrice;
  135. ration_glj.marketPrice = glj.basePrice;
  136. ration_glj.taxRate = glj.taxRate;
  137. ration_glj.shortName = glj.shortName;
  138. ration_glj.type = glj.gljType;
  139. ration_glj.repositoryId = glj.repositoryId;
  140. ration_glj.adjCoe = glj.adjCoe;
  141. getInfoFromProjectGLJ(ration_glj).then(function (info) {
  142. if (info &&info.length>0) {
  143. let tem = {};
  144. tem.newRecode = createNewRecord(info[0]);
  145. tem.showData = info[0];
  146. result.datas.push(tem);
  147. cb(null, result);
  148. } else {
  149. cb(new Error('get project glj error'), null);
  150. }
  151. });
  152. } else {
  153. cb(null, result);
  154. }
  155. })
  156. }
  157. }
  158. function createNewRecord(ration_glj) {
  159. let newRecoed = {};
  160. newRecoed.ID = ration_glj.ID;
  161. newRecoed.projectID = ration_glj.projectID;
  162. newRecoed.GLJID = ration_glj.GLJID;
  163. newRecoed.rationID = ration_glj.rationID;
  164. newRecoed.rationItemQuantity = ration_glj.rationItemQuantity;
  165. newRecoed.quantity = ration_glj.quantity;
  166. newRecoed.name = ration_glj.name;
  167. newRecoed.code = ration_glj.code;
  168. newRecoed.original_code = ration_glj.original_code;
  169. newRecoed.unit = ration_glj.unit;
  170. newRecoed.specs = ration_glj.specs;
  171. newRecoed.from = ration_glj.from ? ration_glj.from : 'std';
  172. newRecoed.createType = ration_glj.createType ? ration_glj.createType : 'normal';
  173. newRecoed.shortName = ration_glj.shortName;
  174. newRecoed.billsItemID = ration_glj.billsItemID;
  175. newRecoed.type = ration_glj.type;
  176. newRecoed.model = ration_glj.model;
  177. newRecoed.repositoryId = ration_glj.repositoryId;
  178. newRecoed.projectGLJID = ration_glj.projectGLJID;
  179. newRecoed.adjCoe = ration_glj.adjCoe;
  180. return newRecoed
  181. }
  182. async function getInfoFromProjectGLJ(ration_glj,unitPriceFileId,ext) {
  183. let data = getGLJSearchInfo(ration_glj);
  184. try {
  185. let projectGljModel = new GLJListModel();
  186. let result = await projectGljModel.addList(data,unitPriceFileId,ext);
  187. let typeString = result.type+"";
  188. ration_glj.marketPrice = result.unit_price.market_price;
  189. ration_glj.adjustPrice = result.unit_price.base_price;
  190. ration_glj.basePrice = result.unit_price.base_price;
  191. ration_glj.projectGLJID = result.id;
  192. if (typeString.startsWith("2")||typeString=='4'||typeString=='5') {//只有材料类型才显示是否暂估
  193. ration_glj.isEstimate = result.is_evaluate;
  194. }
  195. if (result.hasOwnProperty('subList') && result.subList.length > 0) {
  196. ration_glj.subList = getMixRatioShowDatas(result.subList);
  197. }
  198. return [ration_glj,result];
  199. } catch (err) {
  200. logger.err(err);
  201. return null;
  202. }
  203. }
  204. function getMixRatioShowDatas(subList) {
  205. var temRationGLJs = [];
  206. for (let pg of subList) {
  207. var tem = {
  208. projectGLJID: pg.id,
  209. code: pg.code,
  210. name: pg.name,
  211. specs: pg.specs,
  212. unit: pg.unit,
  213. shortName: pg.unit_price.short_name,
  214. rationItemQuantity: pg.ratio_data.consumption,
  215. basePrice: pg.unit_price.base_price,
  216. marketPrice: pg.unit_price.market_price,
  217. adjustPrice: pg.adjust_price,
  218. isEstimate: pg.is_evaluate,
  219. isMixRatio: true,
  220. isAdd: pg.unit_price.is_add,
  221. GLJID: pg.glj_id
  222. }
  223. temRationGLJs.push(tem);
  224. }
  225. temRationGLJs = _.sortBy(temRationGLJs, 'code');
  226. return temRationGLJs;
  227. }
  228. function create_ration_glj(user_id, datas) {
  229. return function (callback) {
  230. let ration_glj_list = datas.ration_glj_list;
  231. var tasks = [];
  232. tasks.push(startingTask("get glj info"))
  233. for (let i = 0; i < ration_glj_list.length; i++) {
  234. ration_glj_list[i].ID = uuidV1();
  235. tasks.push(get_lib_glj_info(ration_glj_list[i]))
  236. }
  237. async_n.waterfall(tasks, (err, results) => {
  238. if (err) {
  239. callback(err, results)
  240. } else {
  241. let newRecords = [];
  242. let showDatas = [];
  243. for (let r of results.datas) {
  244. if (r) {
  245. newRecords.push(r.newRecode);
  246. showDatas.push(r.showData);
  247. }
  248. }
  249. if (newRecords.length > 0) {
  250. ration_glj.insertMany(newRecords, (err, doc) => {
  251. if (err) {
  252. callback(err, null);
  253. } else {
  254. let returndata = {
  255. updateTpye: commonConsts.UT_CREATE,
  256. moduleName: 'ration_glj',
  257. data: {
  258. newRecords: newRecords,
  259. showDatas: showDatas
  260. }
  261. }
  262. callback(null, returndata)
  263. }
  264. });
  265. } else {
  266. logger.info("can't find gljs")
  267. callback(null, null)
  268. }
  269. }
  270. })
  271. }
  272. }
  273. function update_ration_glj(user_id, datas) {
  274. if (datas.updateFunction) {
  275. return updateFunctionMap[datas.updateFunction](user_id, datas);
  276. } else {
  277. return normalUpdate(user_id, datas);
  278. }
  279. }
  280. function normalUpdate(user_id, datas) {
  281. return function (callback) {
  282. ration_glj.update(datas.query, datas.doc, (err, result) => {
  283. if (err) {
  284. callback(err, '');
  285. } else {
  286. let returndata = {
  287. moduleName: 'ration_glj',
  288. data: {
  289. updateTpye: commonConsts.UT_UPDATE,
  290. query: datas.query,
  291. doc: datas.doc
  292. }
  293. }
  294. callback(null, returndata)
  295. }
  296. })
  297. }
  298. }
  299. async function doCustomQuantityUpdate(datas) {
  300. let result = await ration_glj.findOneAndUpdate(datas.query, datas.doc);
  301. let cal_result = await glj_calculate_facade.calculateQuantity({
  302. projectID: datas.query.projectID,
  303. rationID: datas.query.rationID
  304. });
  305. cal_result.glj_result.forEach(function (item) {
  306. if (!item.doc.hasOwnProperty('customQuantity')) {
  307. item.doc.customQuantity = null;
  308. }
  309. });
  310. return cal_result;
  311. }
  312. function delete_ration_glj(user_id, datas) {
  313. return function (callback) {
  314. deleteByID(datas, callback);
  315. //callback(new Error("删除子数据失败!"),null)
  316. //这个方法已经不用,先注释,稳定后再删除
  317. /* if (datas.deleteType == "RATION") {
  318. deleteByRation(datas, callback);
  319. } else if (datas.deleteType == "BILL") {
  320. deleteByBill(user_id, datas, callback);
  321. } else {
  322. deleteByID(datas, callback);
  323. }*/
  324. }
  325. }
  326. function deleteByRation(datas, callback) {
  327. let data = datas.updateData;
  328. let tasks = [];
  329. tasks.push(deleteGLJList(data));
  330. tasks.push(ration_coe_facade.delete_ration_coe(data));
  331. tasks.push(quantity_detail_facade.deleteByRation(data));
  332. tasks.push(ration_installation_facade.deleteByRation(data));
  333. async_n.parallel(tasks, function (err, result) {
  334. commonCallback(callback, result, err)
  335. })
  336. }
  337. function deleteGLJList(data) {
  338. return function (callback) {
  339. ration_glj.deleteMany({projectID: data.projectID, rationID: data.ID}, (err, result) => {
  340. commonCallback(callback, result, err)
  341. });
  342. }
  343. }
  344. function deleteByBill(user_id, datas, callback) {
  345. let tasks = [];
  346. tasks.push(startingTask("deleteByBill"));
  347. tasks.push(getRationsByBill(datas));
  348. tasks.push(deleteRationsbyBill(user_id, datas));
  349. tasks.push(deleteByMultiRations(datas));
  350. async_n.waterfall(tasks, function (err, results) {
  351. if (err) {
  352. callback(err, '');
  353. } else {
  354. callback(null, results);
  355. }
  356. })
  357. }
  358. function deleteByID(datas, callback) {
  359. deleteAndUpdateState(datas).then(function (result) {
  360. if (result.err) {
  361. callback(result.err, '');
  362. } else {
  363. let returndata = {
  364. moduleName: 'ration_glj',
  365. data: {
  366. updateTpye: commonConsts.UT_DELETE,
  367. query: datas.query,
  368. adjustState: result.adjustState
  369. }
  370. }
  371. callback(null, returndata)
  372. }
  373. })
  374. }
  375. async function deleteGLJ(IDs) {
  376. await ration_glj.deleteMany({'ID': {$in: IDs}});
  377. }
  378. async function deleteAndUpdateState(datas) {
  379. let result = {
  380. err: null
  381. }
  382. try {
  383. await ration_glj.deleteOne(datas.query);
  384. let stateResult = await glj_calculate_facade.calculateQuantity({
  385. projectID: datas.query.projectID,
  386. rationID: datas.doc.rationID
  387. });
  388. result.adjustState = stateResult.adjustState;
  389. } catch (err) {
  390. result.err = err;
  391. }
  392. return result;
  393. }
  394. function startingTask(processName) {
  395. return function (asyncCallBack) {
  396. var result = {
  397. processName: processName,
  398. datas: []
  399. };
  400. asyncCallBack(null, result);
  401. };
  402. }
  403. function getRationsByBill(datas) {
  404. return function (results, callback) {
  405. ration.find({
  406. projectID: datas.updateData.projectID,
  407. billsItemID: datas.updateData.ID
  408. }, function (err, rations) {
  409. if (err) {
  410. callback(err, '')
  411. } else {
  412. results.rations = rations;
  413. callback(null, results)
  414. }
  415. })
  416. }
  417. }
  418. function deleteRationsbyBill(user_id, datas) {
  419. return function (results, callback) {
  420. let deleteInfo = {
  421. deleteInfo: {deleted: true, deleteDateTime: new Date(), deleteBy: user_id}
  422. };
  423. ration.update({
  424. projectID: datas.updateData.projectID,
  425. billsItemID: datas.updateData.ID
  426. }, deleteInfo, {multi: true}, (err, deleteresults) => {
  427. if (err) {
  428. callback(err, '');
  429. } else {
  430. callback(null, results);
  431. }
  432. });
  433. }
  434. }
  435. function deleteByMultiRations(datas) {
  436. return function (results, deleteCallBack) {
  437. var delete_tasks = [];
  438. var deleteOne = function (ration) {
  439. return function (callback) {
  440. ration_glj.deleteMany({projectID: ration.projectID, rationID: ration.ID}, function (err, result) {
  441. commonCallback(callback, result, err)
  442. });
  443. }
  444. }
  445. let rations = results.rations;
  446. for (let i = 0; i < rations.length; i++) {
  447. delete_tasks.push(deleteOne(rations[i]._doc));
  448. delete_tasks.push(ration_coe_facade.delete_ration_coe(rations[i]._doc));
  449. delete_tasks.push(quantity_detail_facade.deleteByRation(rations[i]._doc));
  450. delete_tasks.push(ration_installation_facade.deleteByRation(rations[i]._doc));
  451. }
  452. delete_tasks.push(quantity_detail_facade.deleteByBill(datas.updateData));
  453. async_n.parallel(delete_tasks, (err, results) => {
  454. if (err) {
  455. deleteCallBack(err, '')
  456. } else {
  457. deleteCallBack(null, results)
  458. }
  459. })
  460. }
  461. }
  462. /*
  463. function deleteByRation(doc) {
  464. return function (callback){
  465. ration_glj.deleteMany({projectID: doc.updateData.projectID, rationID: doc.updateData.ID},callback);
  466. }
  467. }
  468. */
  469. function save(user_id, datas, callback) {
  470. let operations = [];
  471. if (_.isArray(datas)) {
  472. for (let i = 0; i < datas.length; i++) {
  473. operations.push(operationMap[datas[i].updateType](user_id, datas[i]));
  474. }
  475. } else {
  476. operations.push(operationMap[datas.updateType](user_id, datas));
  477. }
  478. async_n.parallel(operations, function (err, results) {
  479. if (err) {
  480. callback(err, '');
  481. } else {
  482. if (results.length == 1) {
  483. callback(null, results[0])
  484. } else {
  485. callback(null, results)
  486. }
  487. }
  488. })
  489. }
  490. async function getLibInfo(req) {
  491. let gljLibId = null, engineerID, sessionCompilation = req.session.sessionCompilation;
  492. engineerID = req.params.engineerID;
  493. if(engineerID){
  494. gljLibId = await getGLJLibByEngineerID(engineerID);
  495. }else {
  496. throw new Error("工程专业ID为空!");
  497. }
  498. let data = {
  499. userID: req.session.sessionUser.id,
  500. gljLibId: gljLibId,
  501. compilationId: sessionCompilation._id
  502. };
  503. return data;
  504. }
  505. async function getGLJLib(query) {
  506. return stdGLJLibModel.findOne(query);
  507. }
  508. async function getGLJLibByEngineerID (engineerID) {
  509. let engineeringLibModel = new EngineeringLibModel() ;
  510. let engineeringInfo = await engineeringLibModel.findDataByCondition({'_id': engineerID});
  511. let gljLibId = engineeringInfo.glj_lib.length > 0 && typeof engineeringInfo.glj_lib !== 'undefined' ? engineeringInfo.glj_lib[0].id : null;
  512. return gljLibId
  513. }
  514. // 获取人材机选择页面,可选的定额库-人材机库映射选项
  515. async function getLibOptions(engineerID) {
  516. // 找到工程专业绑定的定额库,再获取这些定额库引用的人材机库
  517. const engineeringLibModel = new EngineeringLibModel();
  518. const engineeringInfo = await engineeringLibModel.findDataByCondition({ _id: engineerID });
  519. const rationLibs = engineeringInfo.ration_lib;
  520. const rationLibIDs = rationLibs.map(lib => lib.id);
  521. const rationLibData = await stdRationLibModel.find({ ID: { $in: rationLibIDs } }, 'ID gljLib').lean();
  522. const rst = [];
  523. rationLibs.forEach(lib => {
  524. rationLibData.forEach(stdLib => {
  525. if (+lib.id === +stdLib.ID) {
  526. lib.gljLibId = stdLib.gljLib;
  527. rst.push(lib);
  528. }
  529. });
  530. });
  531. return rst;
  532. }
  533. // 获取人材机选择库页面,可选的定额库为费用定额下,所有工程专业的定额库(需要去重)
  534. async function getLibOptionsForCompilation(compilationId) {
  535. const compilation = await compilationModel.findOne({ _id: mongoose.Types.ObjectId(compilationId) }, 'ration_valuation bill_valuation');
  536. const valuationIDs = [];
  537. if (compilation.ration_valuation[0] && compilation.ration_valuation[0].enable) {
  538. valuationIDs.push(compilation.ration_valuation[0].id);
  539. }
  540. if (compilation.bill_valuation[0] && compilation.bill_valuation[0].enable) {
  541. valuationIDs.push(compilation.bill_valuation[0].id);
  542. }
  543. const engineeringLibs = await engineeringModel.find({ valuationID: { $in: valuationIDs }, visible: true }, 'ration_lib');
  544. const rationLibs = [];
  545. const rationLibIDs = [];
  546. let hasDefalut = false;
  547. engineeringLibs.forEach(lib => {
  548. lib.ration_lib.forEach(rLib => {
  549. if (!rationLibIDs.includes(rLib.id)) {
  550. rationLibIDs.push(rLib.id);
  551. rationLibs.push({
  552. isDefault: hasDefalut ? false: rLib.isDefault,
  553. name: rLib.name,
  554. id: rLib.id
  555. });
  556. if (rLib.isDefault) {
  557. hasDefalut = true;
  558. }
  559. }
  560. });
  561. });
  562. const stdRationLibs = await stdRationLibModel.find({ ID: { $in: rationLibIDs } }, 'ID gljLib').lean();
  563. rationLibs.forEach(lib => {
  564. stdRationLibs.forEach(stdLib => {
  565. if (+lib.id === +stdLib.ID) {
  566. lib.gljLibId = stdLib.gljLib;
  567. }
  568. });
  569. });
  570. return rationLibs;
  571. }
  572. async function getGLJDataPaging(info, condition) {
  573. let gljDao = new GljDao();
  574. let rst = {};
  575. // 初始化,需要生成分类树和类型数据
  576. if (condition.init) {
  577. rst.treeData = await gljDao.getMixedTree(info.gljLibId, info.userID, info.compilationId);
  578. rst.distTypeTree = stdgljutil.getStdGljTypeCacheObj().toArray();
  579. }
  580. let gljData = await gljDao.getGLJPaging({...info, ...condition});
  581. Object.assign(rst, gljData);
  582. return rst;
  583. }
  584. function getGLJData(info, callback) {
  585. let gljDao = new GljDao();
  586. let datas = {};
  587. let gljDistTypeCache = stdgljutil.getStdGljTypeCacheObj().toArray();
  588. datas.distTypeTree = gljDistTypeCache;
  589. async_n.parallel([
  590. async function (cb) {
  591. try {
  592. datas.treeData = await gljDao.getMixedTree(info.gljLibId, info.userID, info.compilationId);
  593. cb(null);
  594. } catch (err) {
  595. cb(err);
  596. }
  597. },
  598. function (cb) {
  599. if (info.skipGLJ) {
  600. datas.stdGLJ = [];
  601. datas.complementaryGLJs = [];
  602. cb(null);
  603. return;
  604. }
  605. gljDao.getGljItems(info.gljLibId, info.userID, info.compilationId, {_id: 0}, function (err, data) {
  606. if (err) {
  607. cb(err);
  608. } else {
  609. datas.stdGLJ = data.stdGljs;
  610. datas.complementaryGLJs = data.complementaryGljs;
  611. cb(null);
  612. }
  613. });
  614. }
  615. ], function (err) {
  616. if (err) {
  617. callback(true, null);
  618. }
  619. else {
  620. callback(false, datas);
  621. }
  622. })
  623. }
  624. function getGLJSearchInfo(ration_glj) {
  625. let data = {
  626. glj_id: ration_glj.GLJID,
  627. project_id: ration_glj.projectID,
  628. code: ration_glj.code,
  629. original_code: ration_glj.original_code,
  630. name: ration_glj.name,
  631. //shortName: ration_glj.shortName,
  632. specs: ration_glj.specs,
  633. unit: ration_glj.unit,
  634. type: ration_glj.subType ? ration_glj.subType : ration_glj.type,//如果有subType,则是通过插入定额级的工料机进来的
  635. model: ration_glj.model,
  636. type_of_work: ration_glj.subType ? ration_glj.subType : ration_glj.type,
  637. base_price: ration_glj.basePrice,
  638. market_price: ration_glj.marketPrice,
  639. taxRate:ration_glj.taxRate,//税率
  640. repositoryId: ration_glj.repositoryId,
  641. adjCoe: ration_glj.adjCoe,
  642. materialType:ration_glj.materialType,
  643. materialCoe:ration_glj.materialCoe,
  644. materialIndexType:ration_glj.materialIndexType,
  645. materialIndexUnit:ration_glj.materialIndexUnit,
  646. is_evaluate:ration_glj.isEstimate?ration_glj.isEstimate:0,
  647. is_eval_material:0,
  648. no_tax_eqp:0,
  649. is_adjust_price:0,
  650. is_main_material:0,
  651. is_contractor_material:0,
  652. supply_quantity:0,
  653. supply:0,
  654. materialIndexCoe:ration_glj.materialIndexCoe,
  655. from: ration_glj.from ? ration_glj.from : 'std'//std:标准工料机库, cpt:补充工料机库
  656. };
  657. let glj_type_object = glj_type_util.getStdGljTypeCacheObj();
  658. let type = glj_type_object.getItemById(data.type);
  659. data.shortName = type.shortName;
  660. if (data.from == 'cpt') {//从补充工料机来的数据即为新增数据
  661. data.is_add = 1;
  662. }
  663. return data;
  664. }
  665. async function prepareExtData(projectID,compilation) {
  666. let ext , unitFileId ;
  667. let property = await projectDao.getProjectProperty(projectID);
  668. ext = projectDao.getExtendData(property,compilation);
  669. unitFileId = property.unitPriceFile !== undefined ? property.unitPriceFile.id : 0;
  670. return [unitFileId,ext];
  671. }
  672. async function addGLJ(rgList,compilation) {
  673. if (rgList.length <= 0) return {};
  674. let [newRecodes,projectGLJList] = await insertAddTypeGLJ(rgList,compilation);
  675. let stateResult = await glj_calculate_facade.calculateQuantity({
  676. projectID: rgList[0].projectID,
  677. rationID: rgList[0].rationID
  678. });
  679. let result = {
  680. newRecodes: newRecodes,
  681. projectGLJList:projectGLJList,
  682. showData: rgList,
  683. adjustState: stateResult.adjustState
  684. };
  685. return result;
  686. }
  687. async function insertAddTypeGLJ(rgList,compilation) {
  688. let newRecodes = [];
  689. let projectGLJList = [];
  690. let [unitFileId,ext] = await prepareExtData(rgList[0].projectID,compilation);
  691. for (let g of rgList) {
  692. let projectGljModel = new GLJListModel();
  693. let result = await projectGljModel.addList(getGLJSearchInfo(g),unitFileId,ext);
  694. let typeString = result.type+'';
  695. g.marketPrice = result.unit_price.market_price;
  696. g.adjustPrice = result.unit_price.base_price;
  697. g.basePrice = result.unit_price.base_price;
  698. g.isAdd = result.unit_price.is_add;
  699. g.projectGLJID = result.id;
  700. if (typeString.startsWith("2")||typeString=='4'||typeString=='5') {//只有材料类型才显示是否暂估
  701. g.isEstimate = result.is_evaluate;
  702. }
  703. g.ID = uuidV1();
  704. if (result.hasOwnProperty('subList') && result.subList.length > 0) {
  705. g.subList = getMixRatioShowDatas(result.subList);
  706. }
  707. newRecodes.push(createNewRecord(g));
  708. projectGLJList.push(result);
  709. }
  710. await ration_glj.insertMany(newRecodes);
  711. return [newRecodes,projectGLJList];
  712. }
  713. async function replaceGLJByData(data,compilation) {
  714. let projectGljModel = new GLJListModel();
  715. let [unitFileId,ext] = await prepareExtData(data.projectID,compilation);
  716. let result = await projectGljModel.addList(getGLJSearchInfo(data),unitFileId,ext);
  717. let typeString = result.type+'';
  718. data.projectGLJID = result.id;
  719. let updateResult = await ration_glj.findOneAndUpdate({ID: data.ID, projectID: data.projectID}, data);//更新定额工料机
  720. //组装回传数据
  721. data.marketPrice = result.unit_price.market_price;
  722. data.adjustPrice = result.unit_price.base_price;
  723. data.basePrice = result.unit_price.base_price;
  724. data.isAdd = result.unit_price.is_add;
  725. if (typeString.startsWith("2")||typeString=='4'||typeString=='5') {//只有材料类型才显示是否暂估
  726. data.isEstimate = result.is_evaluate;
  727. }
  728. if (result.hasOwnProperty('subList') && result.subList.length > 0) {
  729. data.subList = getMixRatioShowDatas(result.subList);
  730. }
  731. return [data,result];
  732. }
  733. async function replaceGLJ(data,compilation) {
  734. let rdata = {};
  735. let [tdata,projectGLJ] = await replaceGLJByData(data,compilation);
  736. let stateResult = await glj_calculate_facade.calculateQuantity({
  737. projectID: tdata.projectID,
  738. rationID: tdata.rationID
  739. }, true,true);
  740. rdata.data = tdata;
  741. rdata.adjustState = stateResult.adjustState;
  742. rdata.name = stateResult.rationName;
  743. rdata.projectGLJ = projectGLJ;
  744. return rdata;
  745. }
  746. async function mReplaceGLJ(data,compilation) {
  747. let mresult = {};
  748. let projectGljModel = new GLJListModel();
  749. let [unitFileId,ext] = await prepareExtData(data.doc.projectID,compilation);
  750. //
  751. let result = await projectGljModel.addList(getGLJSearchInfo(data.doc),unitFileId,ext);
  752. let typeString = result.type+'';
  753. let newDoc = {};
  754. newDoc.projectGLJID = result.id;
  755. let rationList = await ration_glj.distinct('rationID', data.query);
  756. for(let t of data.tasks){
  757. t.updateOne.update.projectGLJID = result.id;//更新项目工料机ID
  758. }
  759. await ration_glj.bulkWrite(data.tasks);
  760. //let updateResult = await ration_glj.update(data.query, data.doc, {multi: true});
  761. newDoc.marketPrice = result.unit_price.market_price;
  762. newDoc.adjustPrice = result.unit_price.base_price;
  763. newDoc.basePrice = result.unit_price.base_price;
  764. newDoc.isAdd = result.unit_price.is_add;
  765. if (typeString.startsWith("2")||typeString=='4'||typeString=='5') {//只有材料类型才显示是否暂估
  766. newDoc.isEstimate = result.is_evaluate;
  767. }
  768. if (result.hasOwnProperty('subList') && result.subList.length > 0) {
  769. newDoc.subList = getMixRatioShowDatas(result.subList);
  770. }
  771. let stateList = await changAdjustState(data, rationList);
  772. data.doc = newDoc;
  773. mresult.data = data;
  774. mresult.stateList = stateList;
  775. mresult.projectGLJ = result;
  776. return mresult
  777. }
  778. async function updateRationGLJByEdit(data) {
  779. var doc = data.doc;
  780. var result;
  781. if (doc.hasOwnProperty('customQuantity')) {
  782. result = await doCustomQuantityUpdate(data)
  783. } else {
  784. result = await doRationGLJUpdate(data);
  785. }
  786. return result;
  787. }
  788. async function updateRationGLJFromDoc(rg,doc,priceInfo) {
  789. let gljListModel = new GLJListModel();
  790. let projectGLJ = getGLJSearchInfo(rg);
  791. for (let key in doc) {
  792. projectGLJ[key] = doc[key]
  793. }
  794. projectGLJ.base_price = priceInfo.base_price;
  795. projectGLJ.market_price = priceInfo.market_price;
  796. projectGLJ.taxRate = priceInfo.taxRate;
  797. let projcetGLJ_n = await gljListModel.modifyGLJ(projectGLJ, rg);
  798. doc.code = projcetGLJ_n.code;
  799. doc.projectGLJID = projcetGLJ_n.id;
  800. if(rg.createType == 'replace'&& rg.rcode == projcetGLJ_n.code){//如果原数据已经是替换过的,这次替换又恢复成原数据,则把类型改回来
  801. doc.createType = 'normal';
  802. }
  803. if (rg.createType===undefined || rg.createType == 'normal'){// createTypel 默认是normal 只有是定额下带的工料机才需把类型改成替换,其它的保持不变
  804. if(rg.code != projcetGLJ_n.code){
  805. doc.createType = 'replace';
  806. doc.rcode = rg.code;
  807. }
  808. }
  809. await ration_glj.findOneAndUpdate({ID:rg.ID}, doc);
  810. return [projcetGLJ_n,doc]
  811. }
  812. async function doRationGLJUpdate(data) {
  813. let resutl = {};
  814. let priceInfo = data.priceInfo;
  815. let rg = await ration_glj.findOne(data.query);
  816. let [projcetGLJ_n,doc] = await updateRationGLJFromDoc(rg,data.doc,priceInfo);
  817. //取价格
  818. let gljListModel = new GLJListModel();
  819. gljListModel.getGLJPrice(projcetGLJ_n);
  820. doc.basePrice = projcetGLJ_n.unit_price.base_price;
  821. doc.marketPrice = projcetGLJ_n.unit_price.market_price;
  822. doc.adjustPrice = projcetGLJ_n.adjust_price;
  823. doc.taxRate = projcetGLJ_n.unit_price.taxRate;
  824. doc.isAdd = projcetGLJ_n.unit_price.is_add;
  825. resutl.doc = doc;
  826. let stateResult = await glj_calculate_facade.calculateQuantity({
  827. projectID: data.query.projectID,
  828. rationID: data.query.rationID
  829. },null,true);
  830. resutl.adjustState = stateResult.adjustState;
  831. resutl.name = stateResult.rationName;
  832. return resutl;
  833. }
  834. async function getGLJClass(info, data) {
  835. let result = {
  836. exist: false
  837. }
  838. //检查补充工料机中是否已经存在一样的记录了
  839. let condition = {
  840. userId: info.userID,
  841. compilationId: info.compilationId,
  842. code: data.code,
  843. name: data.name,
  844. unit: data.unit,
  845. gljType: data.type,
  846. basePrice: data.basePrice
  847. }
  848. if (data.specs != null && data.specs != undefined && data.specs != '') {
  849. condition['specs'] = data.specs;
  850. }
  851. let glj = await complementaryGljModel.find(condition);
  852. if (glj.length > 0) { //如果已存在就直接返回,不用再新增了
  853. result.exist = true;
  854. return result
  855. }
  856. //查找工料机类型树
  857. let items = await compleClassModel.find({
  858. userId: info.userID,
  859. compilationId: info.compilationId
  860. });
  861. result.items = items;
  862. return result;
  863. }
  864. async function insertGLJAsRation(data,compilation) {
  865. let gljList = data.gljList;
  866. if (data.hasOwnProperty("selectedSerialNo")) { //如果需要,更新序列号。
  867. let query = {
  868. projectID: data.projectID,
  869. billsItemID: data.billsItemID,
  870. serialNo: {$gt: data.selectedSerialNo}
  871. }
  872. await ration.update(query, {$inc: {serialNo: gljList.length}}, {multi: true});
  873. }
  874. let [unitFileId,ext] = await prepareExtData(data.projectID,compilation);
  875. for (let glj of gljList) {
  876. let p_glj = getGLJSearchInfo(glj);
  877. let projectGljModel = new GLJListModel();
  878. let result = await projectGljModel.addList(p_glj,unitFileId,ext);//逐条添加到项目工料机
  879. let typeString = result.type+'';
  880. glj.marketPrice = result.unit_price.market_price;
  881. glj.adjustPrice = result.unit_price.base_price;
  882. glj.basePrice = result.unit_price.base_price;
  883. glj.isAdd = result.unit_price.is_add;
  884. glj.projectGLJID = result.id;
  885. if (typeString.startsWith("2")||typeString=='4'||typeString=='5') {//只有材料类型才显示是否暂估
  886. glj.isEstimate = result.is_evaluate;
  887. }
  888. }
  889. await ration.insertMany(gljList);
  890. return gljList;
  891. }
  892. async function getRationTypeGLJQuantity(projectID) {
  893. let rations = await ration.find({'projectID': projectID,'type':3,'deleteInfo': null}, ['ID', 'projectGLJID','quantity']);
  894. return rations;
  895. }
  896. async function changAdjustState(data, rationList) {
  897. let stateList = [];
  898. for (let r of rationList) {
  899. let stateResult = await glj_calculate_facade.calculateQuantity({
  900. projectID: data.query.projectID,
  901. rationID: r
  902. }, true,true);
  903. if(stateResult){
  904. stateList.push({rationID: r, adjustState: stateResult.adjustState,name:stateResult.rationName});
  905. }
  906. }
  907. return stateList;
  908. }
  909. async function getGLJDataByCodes(data,compilation) {
  910. let gljLibId = await getGLJLibByEngineerID(data.engineerID);
  911. let gljDatas = [];
  912. if(gljLibId){
  913. let stdList = await std_glj_lib_gljList_model.find({'repositoryId':gljLibId,code:{'$in':data.codes}});
  914. if(stdList.length > 0){
  915. let property = await projectDao.getProjectProperty(data.projectID);
  916. let ext = projectDao.getExtendData(property,compilation);//多单价处理
  917. for(let s of stdList){
  918. let tem = JSON.parse(JSON.stringify(s));
  919. if(ext && ext.priceField && tem && tem.priceProperty && tem.priceProperty[ext.priceField] !== null && tem.priceProperty[ext.priceField] !== undefined){
  920. tem.basePrice = tem.priceProperty[ext.priceField];
  921. }
  922. gljDatas.push(tem);
  923. }
  924. }
  925. }
  926. return gljDatas
  927. }
  928. async function testError() {
  929. throw new Error('test Error');
  930. }
  931. function getData(projectID, callback, isReport) {
  932. function findRation(rations, ID) {
  933. let ration = rations.find(function getElement(element) {
  934. return element.ID == ID;
  935. });
  936. return ration && ration._doc;
  937. };
  938. ration_glj.find({'projectID': projectID}, (err, datas) => {
  939. if (err) {
  940. callback(1, '', null);
  941. } else {
  942. if (isReport) { // 调价中间件机制
  943. ration.find({'projectID': projectID}, ['ID', 'code', 'name', 'quantityCoe', 'quantity', 'rationQuantityCoe'],
  944. function cbData(err, rations) {
  945. if (!err) {
  946. for (let i = 0; i < datas.length; i++) {
  947. let glj = datas[i]._doc;
  948. let ration = findRation(rations, glj.rationID);
  949. let coe = 1;
  950. if (ration && ration.quantityCoe){
  951. if ([gljType.LABOUR].includes(glj.type)){
  952. if (ration.quantityCoe._doc.labour)
  953. coe = ration.quantityCoe._doc.labour;
  954. }
  955. else if (
  956. [gljType.GENERAL_MATERIAL,
  957. gljType.CONCRETE,
  958. gljType.MORTAR,
  959. gljType.MIX_RATIO,
  960. gljType.COMMERCIAL_CONCRETE,
  961. gljType.COMMERCIAL_MORTAR,
  962. gljType.OTHER_MATERIAL].includes(glj.type)){
  963. if (ration.quantityCoe._doc.material)
  964. coe = ration.quantityCoe._doc.material;
  965. }
  966. else if ([gljType.GENERAL_MACHINE,
  967. gljType.MACHINE_COMPOSITION,
  968. gljType.MACHINE_LABOUR].includes(glj.type)){
  969. if (ration.quantityCoe._doc.machine)
  970. coe = ration.quantityCoe._doc.machine;
  971. }
  972. else if ([gljType.MAIN_MATERIAL].includes(glj.type)){
  973. if (ration.quantityCoe._doc.main)
  974. coe = ration.quantityCoe._doc.main;
  975. }
  976. else if ([gljType.EQUIPMENT].includes(glj.type)){
  977. if (ration.quantityCoe._doc.equipment)
  978. coe = ration.quantityCoe._doc.equipment;
  979. };
  980. };
  981. if ((!coe) || (coe == '0')) coe = 1;
  982. glj.quantity = glj.quantity * coe;
  983. }
  984. }
  985. });
  986. };
  987. callback(0, consts.projectConst.RATION_GLJ, datas);
  988. }
  989. })
  990. }
  991. function commonCallback(callback, result, err) {
  992. if (err) {
  993. callback(err, '');
  994. } else {
  995. callback(null, result);
  996. }
  997. }