ledger.js 32 KB

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