ledger.js 30 KB

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