ledger.js 35 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848
  1. 'use strict';
  2. /**
  3. * 标段--台账 数据模型
  4. *
  5. * @author CaiAoLin
  6. * @date 2017/12/1
  7. * @version
  8. */
  9. const needField = {
  10. id: 'ledger_id',
  11. pid: 'ledger_pid',
  12. order: 'order',
  13. level: 'level',
  14. fullPath: 'full_path',
  15. isLeaf: 'is_leaf',
  16. };
  17. const keyFields = {
  18. table: ['id'],
  19. index: ['tender_id', 'ledger_id'],
  20. };
  21. // 以下字段仅可通过树结构操作改变,不可直接通过update方式从接口提交,发现时过滤
  22. const readOnlyFields = ['id', 'tender_id', 'ledger_id', 'ledger_pid', 'order', 'level', 'full_path', 'is_leaf'];
  23. const calcFields = ['unit_price', 'sgfh_qty', 'sgfh_tp', 'sjcl_qty', 'sjcl_tp', 'qtcl_qty', 'qtcl_tp', 'deal_qty', 'deal_tp', 'dgn_qty1', 'dgn_qty2'];
  24. const upFields = ['unit_price'];
  25. const qtyFields = ['sgfh_qty', 'sjcl_qty', 'qtcl_qty', 'quantity', 'deal_qty', 'dgn_qty1', 'dgn_qty2'];
  26. const tpFields = ['sgfh_tp', 'sjcl_tp', 'qtcl_tp', 'total_price', 'deal_tp'];
  27. const rootId = -1;
  28. const keyPre = 'tender_node_maxId:';
  29. module.exports = app => {
  30. class Ledger extends app.BaseBillsService {
  31. /**
  32. * 构造函数
  33. *
  34. * @param {Object} ctx - egg全局变量
  35. * @return {void}
  36. */
  37. constructor(ctx) {
  38. super(ctx, {
  39. mid: 'tender_id',
  40. kid: 'ledger_id',
  41. pid: 'ledger_pid',
  42. order: 'order',
  43. level: 'level',
  44. isLeaf: 'is_leaf',
  45. fullPath: 'full_path',
  46. keyPre: 'ledger_bills_maxLid:',
  47. uuid: true,
  48. });
  49. this.tableName = 'ledger';
  50. }
  51. /**
  52. * 新增数据(供内部或其他service类调用, controller不可直接使用)
  53. * @param {Array|Object} data - 新增数据
  54. * @param {Number} tenderId - 标段id
  55. * @param {Object} transaction - 新增事务
  56. * @return {Promise<boolean>} - {Promise<是否正确新增成功>}
  57. */
  58. async innerAdd(data, tenderId, transaction) {
  59. const datas = data instanceof Array ? data : [data];
  60. if (tenderId <= 0) {
  61. throw '标段id错误';
  62. }
  63. if (datas.length <= 0) {
  64. throw '插入数据为空';
  65. }
  66. if (!transaction) {
  67. throw '内部错误';
  68. }
  69. // 整理数据
  70. const insertData = [];
  71. for (const tmp of datas) {
  72. tmp.ledger_id = tmp.template_id;
  73. tmp.ledger_pid = tmp.pid;
  74. tmp.tender_id = tenderId;
  75. delete tmp.template_id;
  76. delete tmp.pid;
  77. tmp.id = this.uuid.v4();
  78. insertData.push(tmp);
  79. }
  80. const operate = await transaction.insert(this.tableName, insertData);
  81. return operate.affectedRows === datas.length;
  82. }
  83. /**
  84. * 新增数据
  85. *
  86. * @param {Object} data - 新增的数据(可批量)
  87. * @param {Number} tenderId - 标段id
  88. * @return {Boolean} - 返回新增的结果
  89. */
  90. async add(data, tenderId) {
  91. this.transaction = await this.db.beginTransaction();
  92. let result = false;
  93. try {
  94. result = await this.innerAdd(data, tenderId, this.transaction);
  95. if (!result) {
  96. throw '新增数据错误';
  97. }
  98. await this.transaction.commit();
  99. } catch (error) {
  100. await this.transaction.rollback();
  101. result = false;
  102. }
  103. return result;
  104. }
  105. /**
  106. * 根据节点Id获取数据
  107. *
  108. * @param {Number} tenderId - 标段id
  109. * @param {Number} nodeId - 项目节/工程量清单节点id
  110. * @return {Object} - 返回查询到的节点数据
  111. */
  112. async getDataByNodeId(tenderId, nodeId) {
  113. if ((nodeId <= 0) || (tenderId <= 0)) {
  114. return undefined;
  115. }
  116. this.initSqlBuilder();
  117. this.sqlBuilder.setAndWhere('tender_id', {
  118. value: tenderId,
  119. operate: '=',
  120. });
  121. this.sqlBuilder.setAndWhere('ledger_id', {
  122. value: nodeId,
  123. operate: '=',
  124. });
  125. const [sql, sqlParam] = this.sqlBuilder.build(this.tableName);
  126. const data = await this.db.queryOne(sql, sqlParam);
  127. return data;
  128. }
  129. /**
  130. * 根据节点Id获取数据
  131. * @param {Number} tenderId - 标段Id
  132. * @param {Array} nodesIds - 节点Id
  133. * @return {Array}
  134. */
  135. async getDataByNodeIds(tenderId, nodesIds) {
  136. if (tenderId <= 0) {
  137. return [];
  138. }
  139. this.initSqlBuilder();
  140. this.sqlBuilder.setAndWhere('tender_id', {
  141. value: tenderId,
  142. operate: '=',
  143. });
  144. this.sqlBuilder.setAndWhere('ledger_id', {
  145. value: nodesIds,
  146. operate: 'in',
  147. });
  148. const [sql, sqlParam] = this.sqlBuilder.build(this.tableName);
  149. const data = await this.db.query(sql, sqlParam);
  150. return this._.sortBy(data, function (d) {
  151. return nodesIds.indexOf(d.ledger_id);
  152. });
  153. }
  154. /**
  155. * 根据主键id获取数据
  156. * @param {Array|Number} id - 主键id
  157. * @return {Promise<*>}
  158. */
  159. async getDataByIds(id) {
  160. if (!id) {
  161. return;
  162. }
  163. const ids = id instanceof Array ? id : [id];
  164. if (ids.length === 0) {
  165. return;
  166. }
  167. this.initSqlBuilder();
  168. this.sqlBuilder.setAndWhere('id', {
  169. value: ids,
  170. operate: 'in',
  171. });
  172. const [sql, sqlParam] = this.sqlBuilder.build(this.tableName);
  173. const data = await this.db.query(sql, sqlParam);
  174. return data;
  175. }
  176. /**
  177. * 根据 父节点id 获取子节点
  178. * @param tenderId
  179. * @param nodeId
  180. * @return {Promise<*>}
  181. */
  182. async getChildrenByParentId(tenderId, nodeId) {
  183. if (tenderId <= 0 || !nodeId) {
  184. return undefined;
  185. }
  186. const nodeIds = nodeId instanceof Array ? nodeId : [nodeId];
  187. if (nodeIds.length === 0) {
  188. return [];
  189. }
  190. this.initSqlBuilder();
  191. this.sqlBuilder.setAndWhere('tender_id', {
  192. value: tenderId,
  193. operate: '=',
  194. });
  195. this.sqlBuilder.setAndWhere('ledger_pid', {
  196. value: nodeIds,
  197. operate: 'in',
  198. });
  199. this.sqlBuilder.orderBy = [['order', 'ASC']];
  200. const [sql, sqlParam] = this.sqlBuilder.build(this.tableName);
  201. const data = await this.db.query(sql, sqlParam);
  202. return data;
  203. }
  204. /**
  205. * 获取项目工程量
  206. * @param tenderId
  207. * @returns {Promise<*>}
  208. */
  209. async getGatherGclBills(tenderId) {
  210. const sql = 'SELECT `b_code`, `name`, `unit`, `unit_price`, ' +
  211. ' Sum(`quantity`) As `quantity`, Sum(`total_price`) As `total_price`, ' +
  212. ' Sum(`deal_qty`) As `deal_qty`, Sum(`deal_tp`) As `deal_tp` ' +
  213. ' From ?? ' +
  214. ' WHERE `tender_id` = ? And `b_code` And `is_leaf` ' +
  215. ' GROUP BY `b_code`, `name`, `unit`, `unit_price`';
  216. const sqlParam = [this.tableName, tenderId];
  217. return await this.db.query(sql, sqlParam);
  218. }
  219. /**
  220. * 统计子节点total_price
  221. * @param {Number} tenderId - 标段id
  222. * @param {Number} pid - 父节点id
  223. * @param {Number} order - order取值
  224. * @param {String} orderOperate - order比较操作符
  225. * @return {Promise<void>}
  226. */
  227. async addUpChildren(tenderId, pid, order, orderOperate) {
  228. this.initSqlBuilder();
  229. const sql = ['SELECT SUM(??) As value FROM ?? ', ' WHERE '];
  230. const sqlParam = ['total_price', this.tableName];
  231. sql.push(' ?? = ' + tenderId);
  232. sqlParam.push('tender_id');
  233. sql.push(' And ?? = ' + pid);
  234. sqlParam.push('ledger_pid');
  235. sql.push(' And ?? ' + orderOperate + ' ' + order);
  236. sqlParam.push('order');
  237. const result = await this.db.queryOne(sql.join(''), sqlParam);
  238. return result.value;
  239. }
  240. /**
  241. * 删除相关数据 用于继承
  242. * @param mid
  243. * @param deleteData
  244. * @returns {Promise<void>}
  245. * @private
  246. */
  247. async _deleteRelaData(mid, deleteData) {
  248. await this.ctx.service.pos.deletePosData(this.transaction, mid, this._.map(deleteData, 'id'));
  249. }
  250. /**
  251. * 过滤data中update方式不可提交的字段
  252. * @param {Number} id - 主键key
  253. * @param {Object} data
  254. * @return {Object<{id: *}>}
  255. * @private
  256. */
  257. _filterUpdateInvalidField(id, data) {
  258. const result = {
  259. id,
  260. };
  261. for (const prop in data) {
  262. if (readOnlyFields.indexOf(prop) === -1) {
  263. result[prop] = data[prop];
  264. }
  265. }
  266. return result;
  267. }
  268. /**
  269. * newData中,以orgData为基准,过滤掉orgData中未定义或值相等的部分
  270. * @param {Object} orgData
  271. * @param {Object} newData
  272. * @private
  273. */
  274. _filterChangedField(orgData, newData) {
  275. const result = {};
  276. let bChanged = false;
  277. for (const prop in orgData) {
  278. if (this._.isEmpty(newData[prop]) && newData[prop] !== orgData[prop]) {
  279. result[prop] = newData[prop];
  280. bChanged = true;
  281. }
  282. }
  283. return bChanged ? result : undefined;
  284. }
  285. _checkField(data, field) {
  286. const fields = field instanceof Array ? field : [field];
  287. for (const prop in data) {
  288. if (fields.indexOf(prop) >= 0) {
  289. return true;
  290. }
  291. }
  292. return false;
  293. }
  294. /**
  295. * 检查data中是否含有计算字段
  296. * @param {Object} data
  297. * @return {boolean}
  298. * @private
  299. */
  300. _checkCalcField(data) {
  301. for (const prop in data) {
  302. if (calcFields.indexOf(prop) >= 0) {
  303. return true;
  304. }
  305. }
  306. return false;
  307. }
  308. /**
  309. * 复制粘贴整块
  310. * @param {Number} tenderId - 标段Id
  311. * @param {Number} selectId - 选中几点Id
  312. * @param {Array} block - 复制节点Id
  313. * @return {Object} - 提价后的数据(其中新增粘贴数据,只返回第一层)
  314. */
  315. async pasteBlock(tenderId, selectId, block) {
  316. if ((tenderId <= 0) || (selectId <= 0)) {
  317. return [];
  318. }
  319. const selectData = await this.getDataByNodeId(this.ctx.tender.id, selectId);
  320. if (!selectData) {
  321. throw '位置数据错误';
  322. }
  323. const newParentPath = selectData.full_path.replace(selectData.ledger_id, '');
  324. const copyNodes = await this.getDataByNodeIds(tenderId, block);
  325. if (!copyNodes || copyNodes.length <= 0) {
  326. throw '复制数据错误';
  327. }
  328. let bSameParent = true;
  329. for (const node of copyNodes) {
  330. if (node.ledger_pid !== copyNodes[0].ledger_pid) {
  331. bSameParent = false;
  332. break;
  333. }
  334. }
  335. if (!bSameParent) {
  336. throw '复制数据错误:仅可操作同层节点';
  337. }
  338. const orgParentPath = copyNodes[0].full_path.replace(copyNodes[0].ledger_id, '');
  339. const newIds = [];
  340. this.transaction = await this.db.beginTransaction();
  341. try {
  342. // 选中节点的所有后兄弟节点,order+粘贴节点个数
  343. await this._updateChildrenOrder(tenderId, selectData.ledger_pid, selectData.order + 1);
  344. // 数据库创建新增节点数据
  345. for (let iNode = 0; iNode < copyNodes.length; iNode++) {
  346. const node = copyNodes[iNode];
  347. let datas = await this.getDataByFullPath(tenderId, node.full_path + '%');
  348. datas = this._.sortBy(datas, 'level');
  349. const maxId = await this._getMaxLid(this.ctx.tender.id);
  350. const leafBillsId = [];
  351. // 计算粘贴数据中需更新部分
  352. for (let index = 0; index < datas.length; index++) {
  353. const data = datas[index];
  354. const newId = maxId + index + 1;
  355. const idChange = {
  356. org: data.id,
  357. };
  358. data.id = this.uuid.v4();
  359. idChange.new = data.id;
  360. data.tender_id = this.ctx.tender.id;
  361. if (!data.is_leaf) {
  362. for (const children of datas) {
  363. children.full_path = children.full_path.replace('-' + data.ledger_id, '-' + newId);
  364. if (children.ledger_pid === data.ledger_id) {
  365. children.ledger_pid = newId;
  366. }
  367. }
  368. } else {
  369. data.full_path = data.full_path.replace('-' + data.ledger_id, '-' + newId);
  370. }
  371. data.ledger_id = newId;
  372. data.full_path = data.full_path.replace(orgParentPath, newParentPath);
  373. if (data.ledger_pid === node.ledger_pid) {
  374. data.ledger_pid = selectData.ledger_pid;
  375. data.order = selectData.order + iNode + 1;
  376. }
  377. data.level = data.level + selectData.level - copyNodes[0].level;
  378. if (data.is_leaf) {
  379. leafBillsId.push(idChange);
  380. }
  381. newIds.push(data.id);
  382. }
  383. const newData = await this.transaction.insert(this.tableName, datas);
  384. for (const id of leafBillsId) {
  385. await this.ctx.service.pos.copyBillsPosData(id.org, id.new, this.transaction);
  386. }
  387. this._cacheMaxLid(tenderId, maxId + datas.length);
  388. }
  389. await this.transaction.commit();
  390. } catch (err) {
  391. await this.transaction.rollback();
  392. throw err;
  393. }
  394. // 查询应返回的结果
  395. const order = [];
  396. for (let i = 1; i <= copyNodes.length; i++) {
  397. order.push(selectData.order + i);
  398. }
  399. const createData = await this.getDataByIds(newIds);
  400. const updateData = await this.getNextsData(selectData.tender_id, selectData.ledger_pid, selectData.order + copyNodes.length);
  401. const posData = await this.ctx.service.pos.getPosData({ lid: newIds });
  402. return {
  403. ledger: { create: createData, update: updateData },
  404. pos: posData,
  405. };
  406. }
  407. /**
  408. * 提交数据 - 响应计算(增量方式计算)
  409. * @param {Number} tenderId
  410. * @param {Object} data
  411. * @return {Promise<*>}
  412. */
  413. async updateCalc(tenderId, data) {
  414. // 简单验证数据
  415. if (tenderId <= 0 || !this.ctx.tender) {
  416. throw '标段不存在';
  417. }
  418. const info = this.ctx.tender.info;
  419. if (!data) {
  420. throw '提交数据错误';
  421. }
  422. const datas = data instanceof Array ? data : [data];
  423. const ids = [];
  424. for (const row of datas) {
  425. if (tenderId !== row.tender_id) {
  426. throw '提交数据错误';
  427. }
  428. ids.push(row.id);
  429. }
  430. this.transaction = await this.db.beginTransaction();
  431. try {
  432. for (const row of datas) {
  433. const updateNode = await this.getDataById(row.id);
  434. if (!updateNode || tenderId !== updateNode.tender_id || row.ledger_id !== updateNode.ledger_id) {
  435. throw '提交数据错误';
  436. }
  437. let updateData;
  438. if (row.unit) {
  439. if (row.sgfh_qty === undefined) { row.sgfh_qty = updateNode.sgfh_qty; }
  440. if (row.sjcl_qty === undefined) { row.sjcl_qty = updateNode.sjcl_qty; }
  441. if (row.qtcl_qty === undefined) { row.qtcl_qty = updateNode.qtcl_qty; }
  442. if (row.deal_qty === undefined) { row.deal_qty = updateNode.deal_qty; }
  443. }
  444. if (row.b_code) {
  445. row.dgn_qty1 = null;
  446. row.dgn_qty2 = null;
  447. }
  448. if (this._checkCalcField(row)) {
  449. let calcData = JSON.parse(JSON.stringify(row));
  450. const precision = this.ctx.helper.findPrecision(info.precision, row.unit ? row.unit : updateNode.unit);
  451. // 数量保留小数位数
  452. this.ctx.helper.checkFieldPrecision(calcData, qtyFields, precision.value);
  453. // 单位保留小数位数
  454. this.ctx.helper.checkFieldPrecision(calcData, upFields, info.decimal.up);
  455. // 未提交单价则读取数据库单价
  456. if (row.unit_price === undefined) calcData.unit_price = updateNode.unit_price;
  457. // 计算
  458. if (row.sgfh_qty !== undefined || row.sjcl_qty !== undefined || row.qtcl_qty !== undefined ||
  459. row.deal_qty !== undefined || row.unit_price) {
  460. if (row.sgfh_qty === undefined) calcData.sgfh_qty = updateNode.sgfh_qty;
  461. if (row.sjcl_qty === undefined) calcData.sjcl_qty = updateNode.sjcl_qty;
  462. if (row.qtcl_qty === undefined) calcData.qtcl_qty = updateNode.qtcl_qty;
  463. if (row.deal_qty === undefined) calcData.deal_qty = updateNode.deal_qty;
  464. calcData.quantity = this.ctx.helper.sum([calcData.sgfh_qty, calcData.sjcl_qty, calcData.qtcl_qty]);
  465. calcData.sgfh_tp = this.ctx.helper.mul(calcData.sgfh_qty, calcData.unit_price, info.decimal.tp);
  466. calcData.sjcl_tp = this.ctx.helper.mul(calcData.sjcl_qty, calcData.unit_price, info.decimal.tp);
  467. calcData.qtcl_tp = this.ctx.helper.mul(calcData.qtcl_qty, calcData.unit_price, info.decimal.tp);
  468. calcData.total_price = this.ctx.helper.mul(calcData.quantity, calcData.unit_price, info.decimal.tp);
  469. calcData.deal_tp = this.ctx.helper.mul(calcData.deal_qty, calcData.unit_price, info.decimal.tp);
  470. } else if (row.sgfh_tp !== undefined || row.sjcl_tp !== undefined || row.qtcl_tp !== undefined || row.deal_tp !== undefined) {
  471. calcData.sgfh_qty = null;
  472. calcData.sjcl_qty = null;
  473. calcData.qtcl_qty = null;
  474. calcData.quantity = null;
  475. calcData.deal_qty = null;
  476. calcData.sgfh_tp = (row.sgfh_tp !== undefined) ? this.ctx.helper.round(calcData.row.sgfh_tp, info.decimal.tp) : updateNode.sgfh_tp;
  477. calcData.sjcl_tp = (row.sgfh_tp !== undefined) ? this.ctx.helper.round(calcData.row.sjcl_tp, info.decimal.tp) : updateNode.sjcl_tp;
  478. calcData.qtcl_tp = (row.sgfh_tp !== undefined) ? this.ctx.helper.round(calcData.row.qtcl_tp, info.decimal.tp) : updateNode.qtcl_tp;
  479. calcData.total_price = this.ctx.helper.sum([calcData.sgfh_tp, calcData.sjcl_tp, calcData.qtcl_tp]);
  480. calcData.deal_tp = (row.deal_tp !== undefined) ? this.ctx.helper.round(calcData.row.deal_tp, info.decimal.tp) : updateNode.deal_tp;
  481. } else if (row.unit_price !== undefined) {
  482. calcData.sgfh_tp = this.ctx.helper.mul(calcData.sgfh_qty, calcData.unit_price, info.decimal.tp);
  483. calcData.sjcl_tp = this.ctx.helper.mul(calcData.sjcl_qty, calcData.unit_price, info.decimal.tp);
  484. calcData.qtcl_tp = this.ctx.helper.mul(calcData.qtcl_qty, calcData.unit_price, info.decimal.tp);
  485. calcData.total_price = this.ctx.helper.mul(calcData.quantity, calcData.unit_price, info.decimal.tp);
  486. calcData.deal_tp = this.ctx.helper.mul(calcData.deal_qty, calcData.unit_price, info.decimal.tp);
  487. }
  488. updateData = this._filterUpdateInvalidField(updateNode.id, calcData);
  489. } else {
  490. updateData = this._filterUpdateInvalidField(updateNode.id, row);
  491. }
  492. await this.transaction.update(this.tableName, updateData);
  493. }
  494. await this.transaction.commit();
  495. } catch (err) {
  496. await this.transaction.rollback();
  497. throw err;
  498. }
  499. return { update: await this.getDataByIds(ids) };
  500. }
  501. /**
  502. *
  503. * @param tenderId
  504. * @param xmj
  505. * @param order
  506. * @param parentData
  507. * @return {Promise<*[]>}
  508. * @private
  509. */
  510. async _sortBatchInsertData(tenderId, xmj, order, parentData) {
  511. const result = [],
  512. newIds = [];
  513. let tp = 0;
  514. const maxId = await this._getMaxLid(tenderId);
  515. // 添加xmj数据
  516. const parent = {
  517. tender_id: tenderId,
  518. ledger_id: maxId + 1,
  519. ledger_pid: parentData.ledger_id,
  520. is_leaf: xmj.children.length === 0,
  521. order,
  522. level: parentData.level + 1,
  523. name: xmj.name,
  524. };
  525. parent.full_path = parentData.full_path + '-' + parent.ledger_id;
  526. // 添加gcl数据
  527. for (let i = 0, iLen = xmj.children.length; i < iLen; i++) {
  528. const gcl = xmj.children[i];
  529. const child = {
  530. tender_id: tenderId,
  531. ledger_id: maxId + 1 + i + 1,
  532. ledger_pid: parent.ledger_id,
  533. is_leaf: true,
  534. order: i + 1,
  535. level: parent.level + 1,
  536. b_code: gcl.b_code,
  537. name: gcl.name,
  538. unit: gcl.unit,
  539. unit_price: gcl.unit_price,
  540. quantity: gcl.quantity,
  541. };
  542. child.full_path = parent.full_path + '-' + child.ledger_id;
  543. child.total_price = this.ctx.helper.mul(child.unit_price, child.quantity, this.ctx.tender.info.decimal.tp);
  544. tp = this.ctx.helper.add(tp, child.total_price);
  545. result.push(child);
  546. newIds.push(child.ledger_id);
  547. }
  548. parent.total_price = tp;
  549. result.push(parent);
  550. newIds.push(parent.ledger_id);
  551. return [result, tp, newIds];
  552. }
  553. /**
  554. * 批量插入子项
  555. * @param {Number} tenderId - 标段Id
  556. * @param {Number} selectId - 选中节点Id
  557. * @param {Object} data - 批量插入数据
  558. * @return {Promise<void>}
  559. */
  560. async batchInsertChild(tenderId, selectId, data) {
  561. const result = { ledger: {}, pos: null };
  562. if ((tenderId <= 0) || (selectId <= 0)) {
  563. return result;
  564. }
  565. const selectData = await this.getDataByNodeId(tenderId, selectId);
  566. if (!selectData) {
  567. throw '位置数据错误';
  568. }
  569. this.transaction = await this.db.beginTransaction();
  570. const newIds = [];
  571. const lastChild = await this.getLastChildData(tenderId, selectId);
  572. try {
  573. // 更新父项isLeaf
  574. if (!lastChild) {
  575. await this.transaction.update(this.tableName, {
  576. id: selectData.id,
  577. is_leaf: false,
  578. unit_price: null,
  579. quantity: null,
  580. total_price: null,
  581. deal_qty: null,
  582. deal_tp: null,
  583. });
  584. }
  585. const order = lastChild ? lastChild.order : 0;
  586. // 计算id
  587. const maxId = await this._getMaxLid(tenderId);
  588. // 数据库创建新增节点数据
  589. for (let i = 0, iLen = data.length; i < iLen; i++) {
  590. // 合并新增数据
  591. const qd = {
  592. id: this.uuid.v4(),
  593. tender_id: tenderId,
  594. ledger_id: maxId + i + 1,
  595. ledger_pid: selectData.ledger_id,
  596. is_leaf: true,
  597. order: order + i + 1,
  598. level: selectData.level + 1,
  599. b_code: data[i].b_code,
  600. name: data[i].name,
  601. unit: data[i].unit,
  602. unit_price: data[i].price,
  603. };
  604. qd.full_path = selectData.full_path + '-' + qd.ledger_id;
  605. const insertResult = await this.transaction.insert(this.tableName, qd);
  606. newIds.push(qd.id);
  607. if (data[i].pos.length > 0) {
  608. await this.ctx.service.pos.insertLedgerPosData(this.transaction, tenderId, qd, data[i].pos);
  609. await this._calcNode(qd, this.transaction);
  610. }
  611. }
  612. this._cacheMaxLid(tenderId, maxId + data.length);
  613. await this.transaction.commit();
  614. } catch (err) {
  615. await this.transaction.rollback();
  616. throw err;
  617. }
  618. // 查询应返回的结果
  619. result.ledger.create = await this.getDataByIds(newIds);
  620. if (!lastChild) {
  621. result.ledger.update = await this.getDataByIds([selectData.id]);
  622. }
  623. result.pos = await this.ctx.service.pos.getPosData({ lid: newIds });
  624. return result;
  625. }
  626. /**
  627. * 批量插入后项
  628. * @param {Number} tenderId - 标段Id
  629. * @param {Number} selectId - 选中节点Id
  630. * @param {Object} data - 批量插入数据
  631. * @return {Promise<void>}
  632. */
  633. async batchInsertNext(tenderId, selectId, data) {
  634. const result = { ledger: {}, pos: null };
  635. if ((tenderId <= 0) || (selectId <= 0)) {
  636. return result;
  637. }
  638. const selectData = await this.getDataByNodeId(tenderId, selectId);
  639. if (!selectData) {
  640. throw '位置数据错误';
  641. }
  642. const parentData = await this.getDataByNodeId(tenderId, selectData.ledger_pid);
  643. if (!parentData) {
  644. throw '位置数据错误';
  645. }
  646. this.transaction = await this.db.beginTransaction();
  647. const newIds = [];
  648. try {
  649. // 选中节点的所有后兄弟节点,order+粘贴节点个数
  650. await this._updateChildrenOrder(tenderId, selectData.ledger_pid, selectData.order + 1, data.length);
  651. // 计算id和order
  652. const maxId = await this._getMaxLid(tenderId);
  653. const order = selectData.order;
  654. // 数据库创建新增节点数据
  655. for (let i = 0, iLen = data.length; i < iLen; i++) {
  656. // 合并新增数据
  657. const qd = {
  658. id: this.uuid.v4(),
  659. tender_id: tenderId,
  660. ledger_id: maxId + i + 1,
  661. ledger_pid: parentData.ledger_id,
  662. is_leaf: true,
  663. order: order + i + 1,
  664. level: parentData.level + 1,
  665. b_code: data[i].b_code,
  666. name: data[i].name,
  667. unit: data[i].unit,
  668. unit_price: data[i].price,
  669. };
  670. qd.full_path = parentData.full_path + '-' + qd.ledger_id;
  671. const insertResult = await this.transaction.insert(this.tableName, qd);
  672. newIds.push(qd.id);
  673. if (data[i].pos.length > 0) {
  674. await this.ctx.service.pos.insertLedgerPosData(this.transaction, tenderId, qd, data[i].pos);
  675. await this._calcNode(qd, this.transaction);
  676. }
  677. }
  678. this._cacheMaxLid(tenderId, maxId + data.length);
  679. await this.transaction.commit();
  680. } catch (err) {
  681. await this.transaction.rollback();
  682. throw err;
  683. }
  684. // 查询应返回的结果
  685. result.ledger.create = await this.getDataByIds(newIds);
  686. result.ledger.update = await this.getNextsData(selectData.tender_id, selectData.ledger_pid, selectData.order + data.length);
  687. result.pos = await this.ctx.service.pos.getPosData({ lid: newIds });
  688. return result;
  689. }
  690. /**
  691. *
  692. * @param node
  693. * @param transaction
  694. * @returns {Promise<void>}
  695. * @private
  696. */
  697. async _calcNode(node, transaction) {
  698. const info = this.ctx.tender.info;
  699. const precision = this.ctx.helper.findPrecision(info.precision, node.unit);
  700. const calcQtySql = 'SELECT SUM(`sgfh_qty`) As `sgfh_qty`, SUM(`sjcl_qty`) As `sjcl_qty`, SUM(`qtcl_qty`) As `qtcl_qty`, SUM(`quantity`) As `quantity` FROM ?? WHERE `lid` = ?';
  701. const data = await transaction.queryOne(calcQtySql, [this.ctx.service.pos.tableName, node.id]);
  702. data.id = node.id;
  703. data.sgfh_qty = this.round(data.sgfh_qty, precision.value);
  704. data.sjcl_qty = this.round(data.sjcl_qty, precision.value);
  705. data.qtcl_qty = this.round(data.qtcl_qty, precision.value);
  706. data.quantity = this.round(data.quantity, precision.value);
  707. data.sgfh_tp = this.ctx.helper.mul(data.sgfh_qty, node.unit_price, info.decimal.tp);
  708. data.sjcl_tp = this.ctx.helper.mul(data.sjcl_qty, node.unit_price, info.decimal.tp);
  709. data.qtcl_tp = this.ctx.helper.mul(data.qtcl_qty, node.unit_price, info.decimal.tp);
  710. data.total_price = this.ctx.helper.mul(data.quantity, node.unit_price, info.decimal.tp);
  711. const result = await transaction.update(this.tableName, data);
  712. }
  713. /**
  714. *
  715. * @param {Number} tid - 标段id
  716. * @param {Number} id - 需要计算的节点的id
  717. * @param {Object} transaction - 操作所属事务,没有则创建
  718. * @return {Promise<void>}
  719. */
  720. async calc(tid, id, transaction) {
  721. const node = await transaction.get(this.tableName, {id: id});
  722. if (!node) {
  723. throw '数据错误';
  724. }
  725. await this._calcNode(node, transaction);
  726. }
  727. async _importCacheTreeNodes(transaction, nodes) {
  728. const datas = [];
  729. for (const node of nodes) {
  730. datas.push({
  731. id: node.id,
  732. tender_id: this.ctx.tender.id,
  733. ledger_id: node.ledger_id,
  734. ledger_pid: node.ledger_pid,
  735. level: node.level,
  736. order: node.order,
  737. is_leaf: !node.children || node.children.length === 0,
  738. full_path: node.full_path,
  739. code: node.code,
  740. b_code: node.b_code,
  741. name: node.name,
  742. unit: node.unit,
  743. sgfh_qty: node.sgfh_qty,
  744. sgfh_tp: node.sgfh_tp,
  745. quantity: node.quantity,
  746. unit_price: node.unit_price,
  747. total_price: node.total_price,
  748. dgn_qty1: node.dgn_qty1,
  749. dgn_qty2: node.dgn_qty2,
  750. memo: node.memo,
  751. drawing_code: node.drawing_code,
  752. });
  753. }
  754. await transaction.insert(this.tableName, datas);
  755. }
  756. /**
  757. * 导入Excel数据
  758. * @param excelData
  759. * @returns {Promise<void>}
  760. */
  761. async importExcel(excelData) {
  762. //console.time('analysis');
  763. const AnalysisExcel = require('../lib/analysis_excel');
  764. const analysisExcel = new AnalysisExcel(this.ctx);
  765. const tempData = await this.ctx.service.tenderNodeTemplate.getData(true);
  766. const cacheTree = analysisExcel.analysisData(excelData, tempData);
  767. const cacheKey = keyPre + this.ctx.tender.id;
  768. const orgMaxId = parseInt(await this.cache.get(cacheKey));
  769. //console.timeEnd('analysis');
  770. const transaction = await this.db.beginTransaction();
  771. try {
  772. //console.time('deleteBills');
  773. await transaction.delete(this.tableName, {tender_id: this.ctx.tender.id});
  774. //console.timeEnd('deleteBills');
  775. //console.time('deletePos');
  776. await transaction.delete(this.ctx.service.pos.tableName, {tid: this.ctx.tender.id});
  777. //console.timeEnd('deletePos');
  778. //console.time('insertBills');
  779. await this._importCacheTreeNodes(transaction, cacheTree.items);
  780. //console.timeEnd('insertBills');
  781. //console.time('insertPos');
  782. await transaction.insert(this.ctx.service.pos.tableName, cacheTree.pos);
  783. //console.timeEnd('insertPos');
  784. await transaction.commit();
  785. this.cache.set(cacheKey, cacheTree.items.length + 1, 'EX', this.ctx.app.config.cacheTime);
  786. } catch (err) {
  787. await transaction.rollback();
  788. if (orgMaxId) {
  789. this.cache.set(cacheKey, cacheTree.keyNodeId, 'EX', this.ctx.app.config.cacheTime);
  790. }
  791. throw err;
  792. }
  793. }
  794. }
  795. return Ledger;
  796. };