123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777 |
- 'use strict';
- /**
- * 标段--台账 数据模型
- *
- * @author CaiAoLin
- * @date 2017/12/1
- * @version
- */
- const needField = {
- id: 'ledger_id',
- pid: 'ledger_pid',
- order: 'order',
- level: 'level',
- fullPath: 'full_path',
- isLeaf: 'is_leaf',
- };
- const keyFields = {
- table: ['id'],
- index: ['tender_id', 'ledger_id'],
- };
- // 以下字段仅可通过树结构操作改变,不可直接通过update方式从接口提交,发现时过滤
- const readOnlyFields = ['id', 'tender_id', 'ledger_id', 'ledger_pid', 'order', 'level', 'full_path', 'is_leaf'];
- const calcFields = ['unit_price', 'sgfh_qty', 'sgfh_tp', 'sjcl_qty', 'sjcl_tp', 'qtcl_qty', 'qtcl_tp', 'deal_qty', 'deal_tp', 'dgn_qty1', 'dgn_qty2'];
- const upFields = ['unit_price'];
- const qtyFields = ['sgfh_qty', 'sjcl_qty', 'qtcl_qty', 'quantity', 'deal_qty'];
- const tpFields = ['sgfh_tp', 'sjcl_tp', 'qtcl_tp', 'total_price', 'deal_tp'];
- const rootId = -1;
- const keyPre = 'tender_node_maxId:';
- const measureType = require('../const/tender').measureType;
- const SumLoad = require('../lib/sum_load');
- module.exports = app => {
- class Ledger extends app.BaseBillsService {
- /**
- * 构造函数
- *
- * @param {Object} ctx - egg全局变量
- * @return {void}
- */
- constructor(ctx) {
- super(ctx, {
- mid: 'tender_id',
- kid: 'ledger_id',
- pid: 'ledger_pid',
- order: 'order',
- level: 'level',
- isLeaf: 'is_leaf',
- fullPath: 'full_path',
- keyPre: 'ledger_bills_maxLid:',
- uuid: true,
- }, 'pos');
- this.depart = 10;
- this.tableName = 'ledger';
- }
- /**
- * 新增数据(供内部或其他service类调用, controller不可直接使用)
- * @param {Array|Object} data - 新增数据
- * @param {Number} tenderId - 标段id
- * @param {Object} transaction - 新增事务
- * @return {Promise<boolean>} - {Promise<是否正确新增成功>}
- */
- async innerAdd(data, tenderId, transaction) {
- const datas = data instanceof Array ? data : [data];
- if (tenderId <= 0) {
- throw '标段id错误';
- }
- if (datas.length <= 0) {
- throw '插入数据为空';
- }
- if (!transaction) {
- throw '内部错误';
- }
- // 整理数据
- const insertData = [];
- for (const tmp of datas) {
- tmp.ledger_id = tmp.template_id;
- tmp.ledger_pid = tmp.pid;
- tmp.tender_id = tenderId;
- delete tmp.template_id;
- delete tmp.pid;
- tmp.id = this.uuid.v4();
- insertData.push(tmp);
- }
- const operate = await transaction.insert(this.tableName, insertData);
- return operate.affectedRows === datas.length;
- }
- /**
- * 新增数据
- *
- * @param {Object} data - 新增的数据(可批量)
- * @param {Number} tenderId - 标段id
- * @return {Boolean} - 返回新增的结果
- */
- async add(data, tenderId) {
- this.transaction = await this.db.beginTransaction();
- let result = false;
- try {
- result = await this.innerAdd(data, tenderId, this.transaction);
- if (!result) {
- throw '新增数据错误';
- }
- await this.transaction.commit();
- } catch (error) {
- await this.transaction.rollback();
- result = false;
- }
- return result;
- }
- /**
- * 根据节点Id获取数据
- *
- * @param {Number} tenderId - 标段id
- * @param {Number} nodeId - 项目节/工程量清单节点id
- * @return {Object} - 返回查询到的节点数据
- */
- async getDataByNodeId(tenderId, nodeId) {
- if ((nodeId <= 0) || (tenderId <= 0)) {
- return undefined;
- }
- this.initSqlBuilder();
- this.sqlBuilder.setAndWhere('tender_id', {
- value: tenderId,
- operate: '=',
- });
- this.sqlBuilder.setAndWhere('ledger_id', {
- value: nodeId,
- operate: '=',
- });
- const [sql, sqlParam] = this.sqlBuilder.build(this.tableName);
- const data = await this.db.queryOne(sql, sqlParam);
- return data;
- }
- /**
- * 根据节点Id获取数据
- * @param {Number} tenderId - 标段Id
- * @param {Array} nodesIds - 节点Id
- * @return {Array}
- */
- async getDataByNodeIds(tenderId, nodesIds) {
- if (tenderId <= 0) {
- return [];
- }
- this.initSqlBuilder();
- this.sqlBuilder.setAndWhere('tender_id', {
- value: tenderId,
- operate: '=',
- });
- this.sqlBuilder.setAndWhere('ledger_id', {
- value: nodesIds,
- operate: 'in',
- });
- const [sql, sqlParam] = this.sqlBuilder.build(this.tableName);
- const data = await this.db.query(sql, sqlParam);
- return this._.sortBy(data, function(d) {
- return nodesIds.indexOf(d.ledger_id);
- });
- }
- /**
- * 根据主键id获取数据
- * @param {Array|Number} id - 主键id
- * @return {Promise<*>}
- */
- async getDataByIds(id) {
- if (!id) {
- return;
- }
- const ids = id instanceof Array ? id : [id];
- if (ids.length === 0) {
- return;
- }
- this.initSqlBuilder();
- this.sqlBuilder.setAndWhere('id', {
- value: ids,
- operate: 'in',
- });
- const [sql, sqlParam] = this.sqlBuilder.build(this.tableName);
- const data = await this.db.query(sql, sqlParam);
- return data;
- }
- /**
- * 根据 父节点id 获取子节点
- * @param tenderId
- * @param nodeId
- * @return {Promise<*>}
- */
- async getChildrenByParentId(tenderId, nodeId) {
- if (tenderId <= 0 || !nodeId) {
- return undefined;
- }
- const nodeIds = nodeId instanceof Array ? nodeId : [nodeId];
- if (nodeIds.length === 0) {
- return [];
- }
- this.initSqlBuilder();
- this.sqlBuilder.setAndWhere('tender_id', {
- value: tenderId,
- operate: '=',
- });
- this.sqlBuilder.setAndWhere('ledger_pid', {
- value: nodeIds,
- operate: 'in',
- });
- this.sqlBuilder.orderBy = [['order', 'ASC']];
- const [sql, sqlParam] = this.sqlBuilder.build(this.tableName);
- const data = await this.db.query(sql, sqlParam);
- return data;
- }
- /**
- * 获取项目工程量
- * @param tenderId
- * @return {Promise<*>}
- */
- async getGatherGclBills(tenderId) {
- const sql = 'SELECT `b_code`, `name`, `unit`, `unit_price`, ' +
- ' Sum(`quantity`) As `quantity`, Sum(`total_price`) As `total_price`, ' +
- ' Sum(`deal_qty`) As `deal_qty`, Sum(`deal_tp`) As `deal_tp` ' +
- ' From ?? ' +
- ' WHERE `tender_id` = ? And `b_code` And `is_leaf` ' +
- ' GROUP BY `b_code`, `name`, `unit`, `unit_price`';
- const sqlParam = [this.tableName, tenderId];
- return await this.db.query(sql, sqlParam);
- }
- async getTenderUsedUnits(tenderId) {
- const sql = 'SELECT unit ' +
- ' FROM ' + this.tableName +
- ' WHERE tender_id = ? and is_leaf = true' +
- ' GROUP By unit';
- const sqlParam = [tenderId];
- const units = await this.db.query(sql, sqlParam);
- return this._.map(units, 'unit');
- }
- /**
- * 统计子节点total_price
- * @param {Number} tenderId - 标段id
- * @param {Number} pid - 父节点id
- * @param {Number} order - order取值
- * @param {String} orderOperate - order比较操作符
- * @return {Promise<void>}
- */
- async addUpChildren(tenderId, pid, order, orderOperate) {
- this.initSqlBuilder();
- const sql = ['SELECT SUM(??) As value FROM ?? ', ' WHERE '];
- const sqlParam = ['total_price', this.tableName];
- sql.push(' ?? = ' + tenderId);
- sqlParam.push('tender_id');
- sql.push(' And ?? = ' + pid);
- sqlParam.push('ledger_pid');
- sql.push(' And ?? ' + orderOperate + ' ' + order);
- sqlParam.push('order');
- const result = await this.db.queryOne(sql.join(''), sqlParam);
- return result.value;
- }
- /**
- * 删除相关数据 用于继承
- * @param mid
- * @param deleteData
- * @return {Promise<void>}
- * @private
- */
- async _deleteRelaData(mid, deleteData) {
- await this.ctx.service.pos.deletePosData(this.transaction, mid, this._.map(deleteData, 'id'));
- }
- _checkField(data, field) {
- const fields = field instanceof Array ? field : [field];
- for (const prop in data) {
- if (fields.indexOf(prop) >= 0) {
- return true;
- }
- }
- return false;
- }
- /**
- * 复制粘贴整块
- * @param {Number} tenderId - 标段Id
- * @param {Number} selectId - 选中几点Id
- * @param {Array} block - 复制节点Id
- * @return {Object} - 提价后的数据(其中新增粘贴数据,只返回第一层)
- */
- async pasteBlock(tenderId, selectId, paste) {
- if ((tenderId <= 0) || (selectId <= 0)) {
- return [];
- }
- const selectData = await this.getDataByNodeId(this.ctx.tender.id, selectId);
- if (!selectData) {
- throw '位置数据错误';
- }
- const newParentPath = selectData.full_path.replace(selectData.ledger_id, '');
- const copyNodes = await this.getDataByNodeIds(paste.tid, paste.block);
- if (!copyNodes || copyNodes.length <= 0) {
- throw '复制数据错误';
- }
- let bSameParent = true;
- for (const node of copyNodes) {
- if (node.ledger_pid !== copyNodes[0].ledger_pid) {
- bSameParent = false;
- break;
- }
- }
- if (!bSameParent) {
- throw '复制数据错误:仅可操作同层节点';
- }
- const pasteBillsData = [],
- pastePosData = [];
- this.transaction = await this.db.beginTransaction();
- try {
- // 选中节点的所有后兄弟节点,order+粘贴节点个数
- await this._updateChildrenOrder(tenderId, selectData.ledger_pid, selectData.order + 1, copyNodes.length);
- // 数据库创建新增节点数据
- const leafBillsId = [];
- let maxId = await this._getMaxLid(this.ctx.tender.id);
- for (let iNode = 0; iNode < copyNodes.length; iNode++) {
- const node = copyNodes[iNode];
- let datas = await this.getDataByFullPath(paste.tid, node.full_path + '%');
- datas = this._.sortBy(datas, 'level');
- // 计算粘贴数据中需更新部分
- datas.sort(function(x, y) {
- return x.level - y.level;
- });
- for (const data of datas) {
- data.children = datas.filter(function(x) {
- return x.ledger_pid === data.ledger_id;
- });
- }
- for (let index = 0; index < datas.length; index++) {
- const data = datas[index];
- const newId = maxId + index + 1;
- const idChange = {
- org: data.id,
- };
- data.id = this.uuid.v4();
- idChange.new = data.id;
- data.tender_id = this.ctx.tender.id;
- if (data.children && data.children.length > 0) {
- for (const child of data.children) {
- child.ledger_pid = newId;
- }
- }
- data.ledger_id = newId;
- if (data.ledger_pid === node.ledger_pid) {
- data.ledger_pid = selectData.ledger_pid;
- data.order = selectData.order + iNode + 1;
- }
- data.level = data.level + selectData.level - copyNodes[0].level;
- if (data.is_leaf) {
- leafBillsId.push(idChange);
- }
- }
- for (const data of datas) {
- delete data.children;
- delete data.crid;
- delete data.is_tp;
- const p = datas.find(function(x) {
- return x.ledger_id === data.ledger_pid;
- });
- if (p) {
- data.full_path = p.full_path + '-' + data.ledger_id;
- } else {
- data.full_path = newParentPath + '' + data.ledger_id;
- }
- pasteBillsData.push(data);
- }
- maxId = maxId + datas.length;
- }
- const newData = await this.transaction.insert(this.tableName, pasteBillsData);
- this._cacheMaxLid(tenderId, maxId);
- for (const id of leafBillsId) {
- const posData = await this.ctx.service.pos.getAllDataByCondition({ where: { tid: paste.tid, lid: id.org } });
- if (posData.length > 0) {
- for (const pd of posData) {
- delete pd.crid;
- pd.id = this.uuid.v4();
- pd.lid = id.new;
- pd.tid = this.ctx.tender.id;
- pd.in_time = new Date();
- pastePosData.push(pd);
- }
- }
- }
- await this.transaction.insert(this.ctx.service.pos.tableName, pastePosData);
- await this.transaction.commit();
- } catch (err) {
- await this.transaction.rollback();
- throw err;
- }
- // 查询应返回的结果
- const order = [];
- for (let i = 1; i <= copyNodes.length; i++) {
- order.push(selectData.order + i);
- }
- const updateData = await this.getNextsData(selectData.tender_id, selectData.ledger_pid, selectData.order + copyNodes.length);
- return {
- ledger: { create: pasteBillsData, update: updateData },
- pos: pastePosData,
- };
- }
- /**
- *
- * @param tenderId
- * @param xmj
- * @param order
- * @param parentData
- * @return {Promise<*[]>}
- * @private
- */
- async _sortBatchInsertData(tenderId, xmj, order, parentData) {
- const result = [],
- newIds = [];
- let tp = 0;
- const maxId = await this._getMaxLid(tenderId);
- // 添加xmj数据
- const parent = {
- tender_id: tenderId,
- ledger_id: maxId + 1,
- ledger_pid: parentData.ledger_id,
- is_leaf: xmj.children.length === 0,
- order,
- level: parentData.level + 1,
- name: xmj.name,
- };
- parent.full_path = parentData.full_path + '-' + parent.ledger_id;
- // 添加gcl数据
- for (let i = 0, iLen = xmj.children.length; i < iLen; i++) {
- const gcl = xmj.children[i];
- const child = {
- tender_id: tenderId,
- ledger_id: maxId + 1 + i + 1,
- ledger_pid: parent.ledger_id,
- is_leaf: true,
- order: i + 1,
- level: parent.level + 1,
- b_code: gcl.b_code,
- name: gcl.name,
- unit: gcl.unit,
- unit_price: gcl.unit_price,
- quantity: gcl.quantity,
- };
- child.full_path = parent.full_path + '-' + child.ledger_id;
- child.total_price = this.ctx.helper.mul(child.unit_price, child.quantity, this.ctx.tender.info.decimal.tp);
- tp = this.ctx.helper.add(tp, child.total_price);
- result.push(child);
- newIds.push(child.ledger_id);
- }
- parent.total_price = tp;
- result.push(parent);
- newIds.push(parent.ledger_id);
- return [result, tp, newIds];
- }
- /**
- * 批量插入子项
- * @param {Number} tenderId - 标段Id
- * @param {Number} selectId - 选中节点Id
- * @param {Object} data - 批量插入数据
- * @return {Promise<void>}
- */
- async batchInsertChild(tenderId, selectId, data) {
- const result = { ledger: {}, pos: null };
- if ((tenderId <= 0) || (selectId <= 0)) return result;
- const selectData = await this.getDataByNodeId(tenderId, selectId);
- if (!selectData) throw '位置数据错误';
- const info = this.ctx.tender.info;
- this.transaction = await this.db.beginTransaction();
- const lastChild = await this.getLastChildData(tenderId, selectId);
- // 计算id
- const maxId = await this._getMaxLid(tenderId);
- const insertBillsData = [], insertPosData = [], in_time = new Date();
- const order = lastChild ? lastChild.order : 0;
- for (let i = 0, iLen = data.length; i < iLen; i++) {
- // 合并新增数据
- const qd = {
- id: this.uuid.v4(),
- tender_id: tenderId,
- ledger_id: maxId + i + 1,
- ledger_pid: selectData.ledger_id,
- is_leaf: true,
- order: order + i + 1,
- level: selectData.level + 1,
- b_code: data[i].b_code,
- name: data[i].name,
- unit: data[i].unit,
- unit_price: this.ctx.helper.round(data[i].price, info.decimal.up),
- };
- qd.full_path = selectData.full_path + '-' + qd.ledger_id;
- insertBillsData.push(qd);
- const precision = this.ctx.helper.findPrecision(info.precision, qd.unit);
- if (data[i].pos.length > 0) {
- for (const [j, p] of data[i].pos.entries()) {
- const inD = {
- id: this.uuid.v4(), tid: tenderId, lid: qd.id,
- add_stage: 0, add_stage_order: 0, add_times: 0, add_user: this.ctx.session.sessionUser.accountId,
- in_time, porder: j + 1,
- name: p.name, drawing_code: p.drawing_code,
- };
- if (p.quantity) {
- inD.sgfh_qty = this.round(p.quantity, precision.value);
- inD.quantity = inD.sgfh_qty;
- qd.sgfh_qty = this.ctx.helper.add(qd.sgfh_qty, inD.sgfh_qty);
- }
- insertPosData.push(inD);
- }
- qd.sgfh_tp = this.ctx.helper.mul(qd.sgfh_qty, qd.unit_price, info.decimal.tp);
- qd.quantity = qd.sgfh_qty;
- qd.total_price = qd.sgfh_tp;
- }
- }
- try {
- // 更新父项isLeaf
- if (!lastChild) {
- await this.transaction.update(this.tableName, {
- id: selectData.id,
- is_leaf: false,
- unit_price: null,
- sgfh_qty: null, sgfh_tp: null,
- sjcl_qty: null, sjcl_tp: null,
- qtcl_qty: null, qtcl_tp: null,
- quantity: null, total_price: null,
- deal_qty: null, deal_tp: null,
- });
- }
- await this.transaction.insert(this.tableName, insertBillsData);
- if (insertPosData.length > 0) await this.transaction.insert(this.ctx.service.pos.tableName, insertPosData);
- this._cacheMaxLid(tenderId, maxId + data.length);
- await this.transaction.commit();
- } catch (err) {
- await this.transaction.rollback();
- throw err;
- }
- // 查询应返回的结果
- result.ledger.create = insertBillsData;
- if (!lastChild) result.ledger.update = await this.getDataByIds([selectData.id]);
- result.pos = insertPosData;
- return result;
- }
- /**
- * 批量插入后项
- * @param {Number} tenderId - 标段Id
- * @param {Number} selectId - 选中节点Id
- * @param {Object} data - 批量插入数据
- * @return {Promise<void>}
- */
- async batchInsertNext(tenderId, selectId, data) {
- const result = { ledger: {}, pos: null };
- if ((tenderId <= 0) || (selectId <= 0)) return result;
- const selectData = await this.getDataByNodeId(tenderId, selectId);
- if (!selectData) throw '位置数据错误';
- const parentData = await this.getDataByNodeId(tenderId, selectData.ledger_pid);
- if (!parentData) throw '位置数据错误';
- const info = this.ctx.tender.info;
- this.transaction = await this.db.beginTransaction();
- const insertBillsData = [], insertPosData = [], in_time = new Date();
- const maxId = await this._getMaxLid(tenderId);
- const order = selectData.order;
- for (let i = 0, iLen = data.length; i < iLen; i++) {
- // 合并新增数据
- const qd = {
- id: this.uuid.v4(),
- tender_id: tenderId,
- ledger_id: maxId + i + 1,
- ledger_pid: selectData.ledger_pid,
- is_leaf: true,
- order: order + i + 1,
- level: selectData.level,
- b_code: data[i].b_code,
- name: data[i].name,
- unit: data[i].unit,
- unit_price: this.ctx.helper.round(data[i].price, info.decimal.up),
- };
- qd.full_path = selectData.full_path + '-' + qd.ledger_id;
- insertBillsData.push(qd);
- const precision = this.ctx.helper.findPrecision(info.precision, qd.unit);
- if (data[i].pos.length > 0) {
- for (const [j, p] of data[i].pos.entries()) {
- const inD = {
- id: this.uuid.v4(), tid: tenderId, lid: qd.id,
- add_stage: 0, add_stage_order: 0, add_times: 0, add_user: this.ctx.session.sessionUser.accountId,
- in_time, porder: j + 1,
- name: p.name, drawing_code: p.drawing_code,
- };
- if (p.quantity) {
- inD.sgfh_qty = this.round(p.quantity, precision.value);
- inD.quantity = inD.sgfh_qty;
- qd.sgfh_qty = this.ctx.helper.add(qd.sgfh_qty, inD.sgfh_qty);
- }
- insertPosData.push(inD);
- }
- qd.sgfh_tp = this.ctx.helper.mul(qd.sgfh_qty, qd.unit_price, info.decimal.tp);
- qd.quantity = qd.sgfh_qty;
- qd.total_price = qd.sgfh_tp;
- }
- }
- try {
- // 选中节点的所有后兄弟节点,order+粘贴节点个数
- await this._updateChildrenOrder(tenderId, selectData.ledger_pid, selectData.order + 1, data.length);
- await this.transaction.insert(this.tableName, insertBillsData);
- if (insertPosData.length > 0) await this.transaction.insert(this.ctx.service.pos.tableName, insertPosData);
- this._cacheMaxLid(tenderId, maxId + data.length);
- await this.transaction.commit();
- } catch (err) {
- await this.transaction.rollback();
- throw err;
- }
- // 查询应返回的结果
- result.ledger.create = insertBillsData;
- result.ledger.update = await this.getNextsData(selectData.tender_id, selectData.ledger_pid, selectData.order + data.length);
- result.pos = insertPosData;
- return result;
- }
- async _importCacheTreeNodes(transaction, nodes) {
- const datas = [];
- for (const node of nodes) {
- datas.push({
- id: node.id,
- tender_id: this.ctx.tender.id,
- ledger_id: node.ledger_id,
- ledger_pid: node.ledger_pid,
- level: node.level,
- order: node.order,
- is_leaf: !node.children || node.children.length === 0,
- full_path: node.full_path,
- code: node.code,
- b_code: node.b_code,
- name: node.name,
- unit: node.unit,
- sgfh_qty: node.sgfh_qty,
- sgfh_tp: node.sgfh_tp,
- quantity: node.quantity,
- unit_price: node.unit_price,
- total_price: node.total_price,
- dgn_qty1: node.dgn_qty1,
- dgn_qty2: node.dgn_qty2,
- memo: node.memo,
- drawing_code: node.drawing_code,
- });
- }
- await transaction.insert(this.tableName, datas);
- return datas;
- }
- /**
- * 导入Excel数据
- * @param excelData
- * @return {Promise<void>}
- */
- async importExcel(templateId, excelData, filter) {
- const AnalysisExcel = require('../lib/analysis_excel').AnalysisExcelTree;
- const analysisExcel = new AnalysisExcel(this.ctx, this.setting);
- const tempData = await this.ctx.service.tenderNodeTemplate.getData(templateId, true);
- const cacheTree = analysisExcel.analysisData(excelData, tempData, { filterZeroGcl: filter });
- const transaction = await this.db.beginTransaction();
- try {
- await transaction.delete(this.tableName, { tender_id: this.ctx.tender.id });
- await transaction.delete(this.ctx.service.pos.tableName, { tid: this.ctx.tender.id });
- const datas = [];
- for (const node of cacheTree.items) {
- const data = {
- id: node.id,
- tender_id: this.ctx.tender.id,
- ledger_id: node.ledger_id,
- ledger_pid: node.ledger_pid,
- level: node.level,
- order: node.order,
- is_leaf: !node.children || node.children.length === 0,
- full_path: node.full_path,
- code: node.code,
- b_code: node.b_code,
- name: node.name,
- unit: node.unit,
- unit_price: node.unit_price,
- dgn_qty1: node.dgn_qty1,
- dgn_qty2: node.dgn_qty2,
- memo: node.memo,
- drawing_code: node.drawing_code,
- node_type: node.node_type,
- };
- // 项目节不导入金额
- // todo 最底层项目节其实应该导入,但是由于目前项目节不能输入金额,也不能计量,导入金额就会有矛盾,故暂时不导入
- if (this.ctx.tender.data.measure_type === measureType.tz.value) {
- data.sgfh_qty = node.quantity;
- data.sgfh_tp = node.b_code ? node.total_price : 0;
- data.quantity = node.quantity;
- data.total_price = node.b_code ? node.total_price : 0;
- } else if (this.ctx.tender.data.measure_type === measureType.gcl.value) {
- data.deal_qty = node.quantity;
- data.deal_tp = node.b_code ? node.total_price : 0;
- }
- datas.push(data);
- }
- await transaction.insert(this.tableName, datas);
- if (this.ctx.tender.data.measure_type === measureType.tz.value
- && cacheTree.pos && cacheTree.pos.length > 0) {
- await transaction.insert(this.ctx.service.pos.tableName, cacheTree.pos);
- }
- await transaction.commit();
- this._cacheMaxLid(this.ctx.tender.id, cacheTree.keyNodeId);
- return { bills: datas, pos: cacheTree.pos };
- } catch (err) {
- await transaction.rollback();
- throw err;
- }
- }
- async sumLoad(lid, tenders) {
- const maxId = await this._getMaxLid(this.ctx.tender.id);
- const select = await this.getDataById(lid);
- const sumLoad = new SumLoad(this.ctx);
- const loadTree = await sumLoad.loadGatherGcl(select, maxId, tenders, {});
- const result = loadTree.getUpdateData();
- const conn = await this.db.beginTransaction();
- try {
- this._cacheMaxLid(this.ctx.tender.id, loadTree.keyNodeId);
- await this.ctx.service.sumLoadHistory.saveLedgerHistory(this.ctx.tender.id, lid, tenders);
- if (result.update.length > 0) await conn.updateRows(this.tableName, result.update);
- if (result.create.length > 0) await conn.insert(this.tableName, result.create);
- await conn.commit();
- return result;
- } catch (err) {
- await conn.rollback();
- throw (err.stack ? '导入工程量数据出错': err);
- }
- }
- async loadDataFromOss(tid, url) {
- const data = await this.ctx.helper.loadLedgerDataFromOss(url);
- const curData = await this.getAllDataByCondition({
- columns: ['id', 'is_tp', 'gxby_status', 'gxby_limit', 'gxby_url', 'dagl_status', 'dagl_limit', 'dagl_url'],
- where: { tender_id: tid }
- });
- this.ctx.helper.assignRelaData(data, [
- { data: curData, fields: ['is_tp', 'gxby_status', 'gxby_limit', 'gxby_url', 'dagl_status', 'dagl_limit', 'dagl_url'], prefix: '', relaId: 'id' },
- ]);
- return data;
- }
- }
- return Ledger;
- };
|