ration_glj_facade.js 26 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801
  1. /**
  2. * Created by chen on 2017/6/29.
  3. */
  4. let mongoose = require('mongoose');
  5. const uuidV1 = require('uuid/v1');
  6. let consts = require('../../main/models/project_consts')
  7. let commonConsts = consts.commonConst;
  8. let _ = require("lodash");
  9. let ration_glj = mongoose.model('ration_glj');
  10. import GLJListModel from '../../glj/models/glj_list_model';
  11. let std_glj_lib_gljList_model = mongoose.model('std_glj_lib_gljList');
  12. let async_n = require("async");
  13. let ration = mongoose.model('ration');
  14. let ration_coe_facade = require('./ration_coe_facade');
  15. let ration_coe = mongoose.model('ration_coe');
  16. let std_ration_lib_ration_items = mongoose.model('std_ration_lib_ration_items');
  17. let glj_calculate_facade = require('./glj_calculate_facade');
  18. let quantity_detail_facade = require('../../main/facade/quantity_detail_facade');
  19. let logger = require("../../../logs/log_helper").logger;
  20. import stdgljutil from "../../../public/cache/std_glj_type_util";
  21. import EngineeringLibModel from "../../users/models/engineering_lib_model";
  22. import GljDao from "../../complementary_glj_lib/models/gljModel";
  23. import {complementaryGljModel, stdGljModel, gljClassModel} from "../../complementary_glj_lib/models/schemas";
  24. import projCounter from '../../main/models/proj_counter_model';
  25. module.exports = {
  26. save: save,
  27. getData: getData,
  28. deleteByRation: deleteByRation,
  29. getQuantityByProjectGLJ: getQuantityByProjectGLJ,
  30. getLibInfo: getLibInfo,
  31. getGLJData: getGLJData,
  32. addGLJ: addGLJ,
  33. replaceGLJ: replaceGLJ,
  34. mReplaceGLJ: mReplaceGLJ,
  35. updateRationGLJByEdit: updateRationGLJByEdit,
  36. getGLJClass: getGLJClass,
  37. insertGLJAsRation: insertGLJAsRation
  38. }
  39. let operationMap = {
  40. 'ut_create': create_ration_glj,
  41. 'ut_update': update_ration_glj,
  42. 'ut_delete': delete_ration_glj
  43. };
  44. let updateFunctionMap = {
  45. 'normalUpdate': normalUpdate
  46. };
  47. /**
  48. * 根据项目工料机ID和项目ID取消耗量
  49. *
  50. * @param {object} condition
  51. * @return Array
  52. */
  53. async function getQuantityByProjectGLJ(condition) {
  54. let query = {
  55. $and: [
  56. {'projectID': condition.projectID},
  57. {'projectGLJID': {$in: condition.projectGLJIDList}}
  58. ]
  59. }
  60. let results = await ration_glj.find(query, ['projectGLJID', 'quantity', 'rationID'], {sort: {projectGLJID: 1}});
  61. let rationList = _.uniq(_.map(results, 'rationID'));
  62. let rationQuery = {
  63. $and: [
  64. {'projectID': condition.projectID},
  65. {'ID': {$in: rationList}},
  66. {'deleteInfo': null}
  67. ]
  68. }
  69. let rations = await ration.find(rationQuery, ['ID', 'quantity']);
  70. return combineQuantity(results, rations);
  71. }
  72. function combineQuantity(results, rations) {
  73. let resultList = [];
  74. _.forEach(results, function (data) {
  75. let tmp = {
  76. projectGLJID: data.projectGLJID,
  77. quantity: Number(data.quantity)
  78. }
  79. let ration = _.find(rations, {ID: data.rationID});
  80. if (ration) {
  81. tmp.rationID = ration.ID;
  82. tmp.rationQuantity = ration.quantity ? Number(ration.quantity) : undefined;
  83. }
  84. resultList.push(tmp);
  85. /* if(resultMap.hasOwnProperty(data.projectGLJID)){
  86. resultMap[data.projectGLJID] += data.quantity;
  87. }else {
  88. resultMap[data.projectGLJID] = data.quantity;
  89. }*/
  90. });
  91. /* var resultList =[];
  92. for(let key in resultMap){
  93. let newObject = {
  94. 'projectGLJID':key,
  95. 'quantity':resultMap[key]
  96. }
  97. resultList.push(newObject)
  98. }*/
  99. return resultList;
  100. }
  101. function get_lib_glj_info(ration_glj) {
  102. return function (result, cb) {
  103. std_glj_lib_gljList_model.findOne({'ID': ration_glj.GLJID}, (err, glj) => {
  104. if (err) {
  105. cb(err, '')
  106. } else if (glj) {
  107. ration_glj.name = glj.name;
  108. ration_glj.code = glj.code;
  109. ration_glj.original_code = glj.code;
  110. ration_glj.unit = glj.unit;
  111. ration_glj.specs = glj.specs;
  112. ration_glj.basePrice = glj.basePrice;
  113. ration_glj.shortName = glj.shortName;
  114. ration_glj.type = glj.gljType;
  115. ration_glj.repositoryId = glj.repositoryId;
  116. ration_glj.adjCoe = glj.adjCoe;
  117. getInfoFromProjectGLJ(ration_glj).then(function (info) {
  118. if (info) {
  119. let tem = {};
  120. tem.newRecode = createNewRecord(info);
  121. tem.showData = info;
  122. result.datas.push(tem);
  123. cb(null, result);
  124. } else {
  125. cb(new Error('get project glj error'), null);
  126. }
  127. });
  128. } else {
  129. cb(null, result);
  130. }
  131. })
  132. }
  133. }
  134. function createNewRecord(ration_glj) {
  135. let newRecoed = {};
  136. newRecoed.ID = ration_glj.ID;
  137. newRecoed.projectID = ration_glj.projectID;
  138. newRecoed.GLJID = ration_glj.GLJID;
  139. newRecoed.rationID = ration_glj.rationID;
  140. newRecoed.rationItemQuantity = ration_glj.rationItemQuantity;
  141. newRecoed.quantity = ration_glj.quantity;
  142. newRecoed.name = ration_glj.name;
  143. newRecoed.code = ration_glj.code;
  144. newRecoed.original_code = ration_glj.original_code;
  145. newRecoed.unit = ration_glj.unit;
  146. newRecoed.specs = ration_glj.specs;
  147. newRecoed.from = ration_glj.from ? ration_glj.from : undefined;
  148. newRecoed.createType = ration_glj.createType ? ration_glj.createType : undefined;
  149. newRecoed.shortName = ration_glj.shortName;
  150. newRecoed.billsItemID = ration_glj.billsItemID,
  151. newRecoed.type = ration_glj.type;
  152. newRecoed.repositoryId = ration_glj.repositoryId;
  153. newRecoed.projectGLJID = ration_glj.projectGLJID;
  154. newRecoed.adjCoe = ration_glj.adjCoe
  155. return newRecoed
  156. }
  157. async function getInfoFromProjectGLJ(ration_glj) {
  158. let data = getGLJSearchInfo(ration_glj);
  159. try {
  160. let projectGljModel = new GLJListModel();
  161. let result = await projectGljModel.addList(data);
  162. ration_glj.marketPrice = result.unit_price.market_price;
  163. ration_glj.adjustPrice = result.unit_price.base_price;
  164. ration_glj.basePrice = result.unit_price.base_price;
  165. ration_glj.projectGLJID = result.id;
  166. ration_glj.isEstimate = result.is_evaluate;
  167. if (result.hasOwnProperty('subList') && result.subList.length > 0) {
  168. ration_glj.subList = getMixRatioShowDatas(result.subList);
  169. }
  170. return ration_glj;
  171. } catch (err) {
  172. logger.err(err);
  173. return null;
  174. }
  175. }
  176. function getMixRatioShowDatas(subList) {
  177. var temRationGLJs = [];
  178. for (let pg of subList) {
  179. var tem = {
  180. projectGLJID: pg.id,
  181. code: pg.code,
  182. name: pg.name,
  183. specs: pg.specs,
  184. unit: pg.unit,
  185. shortName: pg.unit_price.short_name,
  186. rationItemQuantity: pg.ratio_data.consumption,
  187. basePrice: pg.unit_price.base_price,
  188. marketPrice: pg.unit_price.market_price,
  189. adjustPrice: pg.adjust_price,
  190. isEstimate: pg.is_evaluate,
  191. isMixRatio: true,
  192. isAdd: pg.unit_price.is_add,
  193. GLJID: pg.glj_id
  194. }
  195. temRationGLJs.push(tem);
  196. }
  197. temRationGLJs = _.sortBy(temRationGLJs, 'code');
  198. return temRationGLJs;
  199. }
  200. function create_ration_glj(user_id, datas) {
  201. return function (callback) {
  202. let ration_glj_list = datas.ration_glj_list;
  203. var tasks = [];
  204. tasks.push(startingTask("get glj info"))
  205. for (let i = 0; i < ration_glj_list.length; i++) {
  206. ration_glj_list[i].ID = uuidV1();
  207. tasks.push(get_lib_glj_info(ration_glj_list[i]))
  208. }
  209. async_n.waterfall(tasks, (err, results) => {
  210. if (err) {
  211. callback(err, results)
  212. } else {
  213. let newRecords = [];
  214. let showDatas = [];
  215. for (let r of results.datas) {
  216. if (r) {
  217. newRecords.push(r.newRecode);
  218. showDatas.push(r.showData);
  219. }
  220. }
  221. if (newRecords.length > 0) {
  222. ration_glj.insertMany(newRecords, (err, doc) => {
  223. if (err) {
  224. callback(err, null);
  225. } else {
  226. let returndata = {
  227. updateTpye: commonConsts.UT_CREATE,
  228. moduleName: 'ration_glj',
  229. data: {
  230. newRecords: newRecords,
  231. showDatas: showDatas
  232. }
  233. }
  234. callback(null, returndata)
  235. }
  236. });
  237. } else {
  238. logger.info("can't find gljs")
  239. callback(null, null)
  240. }
  241. }
  242. })
  243. }
  244. }
  245. function update_ration_glj(user_id, datas) {
  246. if (datas.updateFunction) {
  247. return updateFunctionMap[datas.updateFunction](user_id, datas);
  248. } else {
  249. return normalUpdate(user_id, datas);
  250. }
  251. }
  252. function normalUpdate(user_id, datas) {
  253. return function (callback) {
  254. ration_glj.update(datas.query, datas.doc, (err, result) => {
  255. if (err) {
  256. callback(err, '');
  257. } else {
  258. let returndata = {
  259. moduleName: 'ration_glj',
  260. data: {
  261. updateTpye: commonConsts.UT_UPDATE,
  262. query: datas.query,
  263. doc: datas.doc
  264. }
  265. }
  266. callback(null, returndata)
  267. }
  268. })
  269. }
  270. }
  271. async function doCustomQuantityUpdate(datas) {
  272. let result = await ration_glj.findOneAndUpdate(datas.query, datas.doc);
  273. let cal_result = await glj_calculate_facade.calculateQuantity({
  274. projectID: datas.query.projectID,
  275. rationID: datas.query.rationID
  276. });
  277. cal_result.glj_result.forEach(function (item) {
  278. if (!item.doc.hasOwnProperty('customQuantity')) {
  279. item.doc.customQuantity = null;
  280. }
  281. });
  282. return cal_result;
  283. }
  284. function delete_ration_glj(user_id, datas) {
  285. return function (callback) {
  286. if (datas.deleteType == "RATION") {
  287. deleteByRation(datas, callback);
  288. } else if (datas.deleteType == "BILL") {
  289. deleteByBill(user_id, datas, callback);
  290. } else {
  291. deleteByID(datas, callback);
  292. }
  293. }
  294. }
  295. function deleteByRation(datas, callback) {
  296. let data = datas.updateData;
  297. let tasks = [];
  298. tasks.push(deleteGLJList(data));
  299. tasks.push(ration_coe_facade.delete_ration_coe(data));
  300. tasks.push(quantity_detail_facade.deleteByRation(data));
  301. async_n.parallel(tasks, function (err, result) {
  302. commonCallback(callback, result, err)
  303. })
  304. }
  305. function deleteGLJList(data) {
  306. return function (callback) {
  307. ration_glj.deleteMany({projectID: data.projectID, rationID: data.ID}, (err, result) => {
  308. commonCallback(callback, result, err)
  309. });
  310. }
  311. }
  312. function deleteByBill(user_id, datas, callback) {
  313. let tasks = [];
  314. tasks.push(startingTask("deleteByBill"));
  315. tasks.push(getRationsByBill(datas));
  316. tasks.push(deleteRationsbyBill(user_id, datas));
  317. tasks.push(deleteByMultiRations(datas));
  318. async_n.waterfall(tasks, function (err, results) {
  319. if (err) {
  320. callback(err, '');
  321. } else {
  322. callback(null, results);
  323. }
  324. })
  325. }
  326. function deleteByID(datas, callback) {
  327. deleteAndUpdateState(datas).then(function (result) {
  328. if (result.err) {
  329. callback(result.err, '');
  330. } else {
  331. let returndata = {
  332. moduleName: 'ration_glj',
  333. data: {
  334. updateTpye: commonConsts.UT_DELETE,
  335. query: datas.query,
  336. adjustState: result.adjustState
  337. }
  338. }
  339. callback(null, returndata)
  340. }
  341. })
  342. }
  343. async function deleteAndUpdateState(datas) {
  344. let result = {
  345. err: null
  346. }
  347. try {
  348. await ration_glj.deleteOne(datas.query);
  349. let stateResult = await glj_calculate_facade.calculateQuantity({
  350. projectID: datas.query.projectID,
  351. rationID: datas.doc.rationID
  352. });
  353. result.adjustState = stateResult.adjustState;
  354. } catch (err) {
  355. result.err = err;
  356. }
  357. return result;
  358. }
  359. function startingTask(processName) {
  360. return function (asyncCallBack) {
  361. var result = {
  362. processName: processName,
  363. datas: []
  364. };
  365. asyncCallBack(null, result);
  366. };
  367. }
  368. function getRationsByBill(datas) {
  369. return function (results, callback) {
  370. ration.find({
  371. projectID: datas.updateData.projectID,
  372. billsItemID: datas.updateData.ID,
  373. deleteInfo: null
  374. }, function (err, rations) {
  375. if (err) {
  376. callback(err, '')
  377. } else {
  378. results.rations = rations;
  379. callback(null, results)
  380. }
  381. })
  382. }
  383. }
  384. function deleteRationsbyBill(user_id, datas) {
  385. return function (results, callback) {
  386. let deleteInfo = {
  387. deleteInfo: {deleted: true, deleteDateTime: new Date(), deleteBy: user_id}
  388. };
  389. ration.update({
  390. projectID: datas.updateData.projectID,
  391. billsItemID: datas.updateData.ID
  392. }, deleteInfo, {multi: true}, (err, deleteresults) => {
  393. if (err) {
  394. callback(err, '');
  395. } else {
  396. callback(null, results);
  397. }
  398. });
  399. }
  400. }
  401. function deleteByMultiRations(datas) {
  402. return function (results, deleteCallBack) {
  403. var delete_tasks = [];
  404. var deleteOne = function (ration) {
  405. return function (callback) {
  406. ration_glj.deleteMany({projectID: ration.projectID, rationID: ration.ID}, function (err, result) {
  407. commonCallback(callback, result, err)
  408. });
  409. }
  410. }
  411. let rations = results.rations;
  412. for (let i = 0; i < rations.length; i++) {
  413. delete_tasks.push(deleteOne(rations[i]._doc));
  414. delete_tasks.push(ration_coe_facade.delete_ration_coe(rations[i]._doc));
  415. delete_tasks.push(quantity_detail_facade.deleteByRation(rations[i]._doc));
  416. }
  417. delete_tasks.push(quantity_detail_facade.deleteByBill(datas.updateData));
  418. async_n.parallel(delete_tasks, (err, results) => {
  419. if (err) {
  420. deleteCallBack(err, '')
  421. } else {
  422. deleteCallBack(null, results)
  423. }
  424. })
  425. }
  426. }
  427. /*
  428. function deleteByRation(doc) {
  429. return function (callback){
  430. ration_glj.deleteMany({projectID: doc.updateData.projectID, rationID: doc.updateData.ID},callback);
  431. }
  432. }
  433. */
  434. function save(user_id, datas, callback) {
  435. let operations = [];
  436. if (_.isArray(datas)) {
  437. for (let i = 0; i < datas.length; i++) {
  438. operations.push(operationMap[datas[i].updateType](user_id, datas[i]));
  439. }
  440. } else {
  441. operations.push(operationMap[datas.updateType](user_id, datas));
  442. }
  443. async_n.parallel(operations, function (err, results) {
  444. if (err) {
  445. callback(err, '');
  446. } else {
  447. if (results.length == 1) {
  448. callback(null, results[0])
  449. } else {
  450. callback(null, results)
  451. }
  452. }
  453. })
  454. }
  455. async function getLibInfo(req) {
  456. let gljLibId = null, engineeringId, sessionCompilation = req.session.sessionCompilation,
  457. rationValuation = sessionCompilation.ration_valuation,
  458. billValuation = sessionCompilation.bill_valuation,
  459. engineeringLibModel = new EngineeringLibModel();
  460. if (rationValuation[0]) {
  461. let engineeringList = rationValuation[0].engineering_list;
  462. engineeringId = engineeringList.length > 0 ? engineeringList[0].engineering_id : null;
  463. let engineeringInfo = await engineeringLibModel.getEngineering(engineeringId);
  464. gljLibId = engineeringInfo.glj_lib.length > 0 && typeof engineeringInfo.glj_lib !== 'undefined' ? engineeringInfo.glj_lib[0].id : null;
  465. }
  466. else if (billValuation[0]) {
  467. let engineeringList = billValuation[0].engineering_list;
  468. engineeringId = engineeringList.length > 0 ? engineeringList[0].engineering_id : null;
  469. let engineeringInfo = await engineeringLibModel.getEngineering(engineeringId);
  470. gljLibId = engineeringInfo.glj_lib.length > 0 && typeof engineeringInfo.glj_lib !== 'undefined' ? engineeringInfo.glj_lib[0].id : null;
  471. }
  472. let data = {
  473. userID: req.session.sessionUser.ssoId,
  474. gljLibId: gljLibId,
  475. compilationId: sessionCompilation._id
  476. };
  477. return data;
  478. }
  479. function getGLJData(info, callback) {
  480. let gljDao = new GljDao();
  481. let datas = {};
  482. let gljDistTypeCache = stdgljutil.getStdGljTypeCacheObj().toArray();
  483. datas.distTypeTree = gljDistTypeCache;
  484. async_n.parallel([
  485. function (cb) {
  486. gljDao.getGljTypes(info.gljLibId, function (err, data) {
  487. if (err) {
  488. cb(err);
  489. } else {
  490. datas.treeData = data;
  491. cb(null);
  492. }
  493. })
  494. },
  495. function (cb) {
  496. gljDao.getGljItems(info.gljLibId, info.userID, info.compilationId, function (err, data) {
  497. if (err) {
  498. cb(err);
  499. } else {
  500. datas.stdGLJ = data.stdGljs;
  501. datas.complementaryGLJs = data.complementaryGljs;
  502. cb(null);
  503. }
  504. });
  505. }
  506. ], function (err) {
  507. if (err) {
  508. callback(true, null);
  509. }
  510. else {
  511. callback(false, datas);
  512. }
  513. })
  514. }
  515. function getGLJSearchInfo(ration_glj) {
  516. let data = {
  517. glj_id: ration_glj.GLJID,
  518. project_id: ration_glj.projectID,
  519. code: ration_glj.code,
  520. original_code: ration_glj.original_code,
  521. name: ration_glj.name,
  522. shortName: ration_glj.shortName,
  523. specs: ration_glj.specs,
  524. unit: ration_glj.unit,
  525. type: ration_glj.subType ? ration_glj.subType : ration_glj.type,//如果有subType,则是通过插入定额级的工料机进来的
  526. type_of_work: ration_glj.subType ? ration_glj.subType : ration_glj.type,
  527. base_price: ration_glj.basePrice,
  528. market_price: ration_glj.basePrice,
  529. repositoryId: ration_glj.repositoryId,
  530. adjCoe: ration_glj.adjCoe,
  531. from: ration_glj.from ? ration_glj.from : 'std'//std:标准工料机库, cpt:补充工料机库
  532. };
  533. if (data.from == 'cpt') {//从补充工料机来的数据即为新增数据
  534. data.is_add = 1;
  535. }
  536. return data;
  537. }
  538. async function addGLJ(rgList) {
  539. let newRecodes = [];
  540. for (let g of rgList) {
  541. let projectGljModel = new GLJListModel();
  542. let result = await projectGljModel.addList(getGLJSearchInfo(g));
  543. g.marketPrice = result.unit_price.market_price;
  544. g.adjustPrice = result.unit_price.base_price;
  545. g.basePrice = result.unit_price.base_price;
  546. g.isAdd = result.unit_price.is_add;
  547. g.projectGLJID = result.id;
  548. g.isEstimate = result.is_evaluate;
  549. g.ID = uuidV1();
  550. if (result.hasOwnProperty('subList') && result.subList.length > 0) {
  551. g.subList = getMixRatioShowDatas(result.subList);
  552. }
  553. newRecodes.push(createNewRecord(g));
  554. }
  555. await ration_glj.insertMany(newRecodes);
  556. let stateResult = await glj_calculate_facade.calculateQuantity({
  557. projectID: rgList[0].projectID,
  558. rationID: rgList[0].rationID
  559. });
  560. let result = {
  561. newRecodes: newRecodes,
  562. showData: rgList,
  563. adjustState: stateResult.adjustState
  564. }
  565. return result;
  566. }
  567. async function replaceGLJ(data) {
  568. let rdata = {};
  569. let projectGljModel = new GLJListModel();
  570. let result = await projectGljModel.addList(getGLJSearchInfo(data));
  571. data.projectGLJID = result.id;
  572. let updateResult = await ration_glj.findOneAndUpdate({ID: data.ID, projectID: data.projectID}, data);//更新定额工料机
  573. //组装回传数据
  574. data.marketPrice = result.unit_price.market_price;
  575. data.adjustPrice = result.unit_price.base_price;
  576. data.basePrice = result.unit_price.base_price;
  577. data.isAdd = result.unit_price.is_add;
  578. data.isEstimate = result.is_evaluate;
  579. if (result.hasOwnProperty('subList') && result.subList.length > 0) {
  580. data.subList = getMixRatioShowDatas(result.subList);
  581. }
  582. let stateResult = await glj_calculate_facade.calculateQuantity({
  583. projectID: data.projectID,
  584. rationID: data.rationID
  585. }, true);
  586. rdata.data = data;
  587. rdata.adjustState = stateResult.adjustState;
  588. return rdata;
  589. }
  590. async function mReplaceGLJ(data) {
  591. let mresult = {};
  592. let projectGljModel = new GLJListModel();
  593. let result = await projectGljModel.addList(getGLJSearchInfo(data.doc));
  594. data.doc.projectGLJID = result.id;
  595. let rationList = await ration_glj.distinct('rationID', data.query);
  596. let updateResult = await ration_glj.update(data.query, data.doc, {multi: true});
  597. data.doc.marketPrice = result.unit_price.market_price;
  598. data.doc.adjustPrice = result.unit_price.base_price;
  599. data.doc.basePrice = result.unit_price.base_price;
  600. data.doc.isAdd = result.unit_price.is_add;
  601. data.doc.isEstimate = result.is_evaluate;
  602. if (result.hasOwnProperty('subList') && result.subList.length > 0) {
  603. data.doc.subList = getMixRatioShowDatas(result.subList);
  604. }
  605. let stateList = await changAdjustState(data, rationList);
  606. mresult.data = data;
  607. mresult.stateList = stateList;
  608. return mresult
  609. }
  610. async function updateRationGLJByEdit(data) {
  611. var doc = data.doc;
  612. var result;
  613. if (doc.hasOwnProperty('customQuantity')) {
  614. result = await doCustomQuantityUpdate(data)
  615. } else {
  616. result = await doRationGLJUpdate(data);
  617. }
  618. return result;
  619. }
  620. async function doRationGLJUpdate(data) {
  621. let resutl = {};
  622. let doc = data.doc;
  623. let priceInfo = data.priceInfo;
  624. let rg = await ration_glj.findOne(data.query);
  625. let gljListModel = new GLJListModel();
  626. let projectGLJ = getGLJSearchInfo(rg);
  627. for (let key in doc) {
  628. projectGLJ[key] = doc[key]
  629. }
  630. projectGLJ.base_price = priceInfo.base_price;
  631. projectGLJ.market_price = priceInfo.market_price;
  632. let projcetGLJ_n = await gljListModel.modifyGLJ(projectGLJ, rg);
  633. doc.code = projcetGLJ_n.code;
  634. doc.projectGLJID = projcetGLJ_n.id;
  635. if (projcetGLJ_n.unit_price.is_add == 1) {
  636. doc.createType = 'replace';
  637. doc.rcode = projcetGLJ_n.original_code;
  638. } else {
  639. doc.createType = 'normal';
  640. doc.rcode = '';
  641. }
  642. await ration_glj.findOneAndUpdate(data.query, doc);
  643. //取价格
  644. gljListModel.getGLJPrice(projcetGLJ_n);
  645. doc.basePrice = projcetGLJ_n.unit_price.base_price;
  646. doc.marketPrice = projcetGLJ_n.unit_price.market_price;
  647. doc.adjustPrice = projcetGLJ_n.adjust_price;
  648. doc.isAdd = projcetGLJ_n.unit_price.is_add;
  649. resutl.doc = doc;
  650. let stateResult = await glj_calculate_facade.calculateQuantity({
  651. projectID: data.query.projectID,
  652. rationID: data.query.rationID
  653. });
  654. resutl.adjustState = stateResult.adjustState;
  655. return resutl;
  656. }
  657. async function getGLJClass(info, data) {
  658. let result = {
  659. exist: false
  660. }
  661. //检查补充工料机中是否已经存在一样的记录了
  662. let condition = {
  663. userId: info.userID,
  664. compilationId: info.compilationId,
  665. code: data.code,
  666. name: data.name,
  667. unit: data.unit,
  668. gljType: data.type,
  669. basePrice: data.basePrice
  670. }
  671. if (data.specs != null && data.specs != undefined && data.specs != '') {
  672. condition['specs'] = data.specs;
  673. }
  674. let glj = await complementaryGljModel.find(condition);
  675. if (glj.length > 0) { //如果已存在就直接返回,不用再新增了
  676. result.exist = true;
  677. return result
  678. }
  679. //查找工料机类型树
  680. let items = await gljClassModel.find({
  681. "repositoryId": info.gljLibId,
  682. "$or": [{"isDeleted": null}, {"isDeleted": false}]
  683. });
  684. result.items = items;
  685. return result;
  686. }
  687. async function insertGLJAsRation(data) {
  688. let gljList = data.gljList;
  689. //先更新counter
  690. let counter = await projCounter.model.findOneAndUpdate({projectID: data.projectID}, {ration: data.rationCount}, {new: true});
  691. if (data.hasOwnProperty("selectedSerialNo")) { //如果需要,更新序列号。
  692. let query = {
  693. projectID: data.projectID,
  694. billsItemID: data.billsItemID,
  695. serialNo: {$gt: data.selectedSerialNo}
  696. }
  697. await ration.update(query, {$inc: {serialNo: gljList.length}}, {multi: true});
  698. }
  699. for (let glj of gljList) {
  700. let p_glj = getGLJSearchInfo(glj);
  701. let projectGljModel = new GLJListModel();
  702. let result = await projectGljModel.addList(p_glj);//逐条添加到项目工料机
  703. glj.marketPrice = result.unit_price.market_price;
  704. glj.adjustPrice = result.unit_price.base_price;
  705. glj.basePrice = result.unit_price.base_price;
  706. glj.isAdd = result.unit_price.is_add;
  707. glj.projectGLJID = result.id;
  708. glj.isEstimate = result.is_evaluate;
  709. }
  710. await ration.insertMany(gljList);
  711. console.log(gljList);
  712. return gljList;
  713. }
  714. async function changAdjustState(data, rationList) {
  715. let stateList = [];
  716. for (let r of rationList) {
  717. let stateResult = await glj_calculate_facade.calculateQuantity({
  718. projectID: data.query.projectID,
  719. rationID: r
  720. }, true);
  721. stateList.push({rationID: r, adjustState: stateResult.adjustState});
  722. }
  723. return stateList;
  724. }
  725. async function testError() {
  726. throw new Error('test Error');
  727. }
  728. function getData(projectID, callback) {
  729. ration_glj.find({'projectID': projectID}, (err, datas) => {
  730. if (err) {
  731. callback(1, '', null);
  732. } else {
  733. callback(0, consts.projectConst.RATION_GLJ, datas);
  734. }
  735. })
  736. }
  737. function commonCallback(callback, result, err) {
  738. if (err) {
  739. callback(err, '');
  740. } else {
  741. callback(null, result);
  742. }
  743. }