Calculation/app/service/pos.js

'use strict';

/**
 * 部位明细
 *
 * @author Mai
 * @date
 * @version
 */

module.exports = app => {

    class Pos extends app.BaseService {
        /**
         * 构造函数
         *
         * @param {Object} ctx - egg全局变量
         * @return {void}
         */
        constructor(ctx) {
            super(ctx);
            this.depart = ctx.app.config.table_depart.heavy;
            this.tableName = 'pos';
        }

        async getPosData(condition, column) {
            if (!condition.tid) throw '查询计量单元缺少必要信息';
            return await this.db.select(this.departTableName(condition.tid), {
                where: condition,
                columns: column || ['id', 'tid', 'lid', 'name', 'quantity', 'position', 'drawing_code', 'sgfh_qty', 'sjcl_qty',
                    'qtcl_qty', 'in_time', 'porder', 'add_stage', 'add_stage_order', 'sgfh_expr', 'sjcl_expr', 'qtcl_expr', 'real_qty', 'ex_qty1',
                    'ex_memo1', 'ex_memo2', 'ex_memo3'],
                order: [['porder', 'ASC']],
            });
        }

        async getPosDataWithAddStageOrder(condition) {
            if (!condition.tid) throw '查询计量单元缺少必要信息';
            const sql = 'SELECT id, tid, lid, name, quantity, position, drawing_code,' +
                '    sgfh_qty, sjcl_qty, qtcl_qty, porder, add_stage, add_times, add_user, add_stage_order,' +
                '    sgfh_expr, sjcl_expr, qtcl_expr, real_qty, ex_qty1, ex_memo1, ex_memo2, ex_memo3' +
                '  FROM ' + this.departTableName(condition.tid) + this.ctx.helper.whereSql(condition);
            return await this.db.query(sql);
        }

        async getPosDataByIds(tid, ids) {
            if (ids instanceof Array && ids.length > 0) {
                const sql = 'SELECT id, tid, lid, name, quantity, position, drawing_code,' +
                    '    sgfh_qty, sjcl_qty, qtcl_qty, add_stage, add_times, add_user, sgfh_expr, sjcl_expr, qtcl_expr, real_qty, ex_qty1,' +
                    '    ex_memo1, ex_memo2, ex_memo3' +
                    '  FROM ' + this.departTableName(tid) +
                    '  WHERE id in (' + this.ctx.helper.getInArrStrSqlFilter(ids) + ')';
                return await this.db.query(sql, []);
            } else {
                return [];
            }
            // this.initSqlBuilder();
            // this.sqlBuilder.setAndWhere('id', {
            //     operate: 'in',
            //     value: ids
            // });
            // this.sqlBuilder.columns = ['id', 'tid', 'lid', 'name', 'quantity', 'drawing_code', 'sgfh_qty', 'sjcl_qty', 'qtcl_qty'];
            // const [sql, sqlParam] = this.sqlBuilder.build(this.tableName)
            // return await this.db.query(sql, sqlParam);
        }

        async getPosDataByUnits(tenderId, units) {
            const sql = 'SELECT p.id, p.lid, p.sgfh_qty, p.sjcl_qty, p.qtcl_qty, p.ex_qty1' +
                '  FROM ' + this.departTableName(tenderId) + ' p' +
                '  LEFT JOIN ' + this.ctx.service.ledger.tableName + ' b' +
                '  ON p.lid = b.id ' +
                '  WHERE p.tid = ? and b.unit IN (?)';
            const sqlParam = [tenderId, units];
            return await this.db.query(sql, sqlParam);
        }

        async _insertPosData(transaction, data, tid) {
            data.id = this.uuid.v4();
            data.tid = tid;
            // todo 新增期
            data.add_stage = 0;
            data.add_stage_order = 0;
            data.add_times = 0;
            data.in_time = new Date();
            data.add_user = this.ctx.session.sessionUser.accountId;
            if (data.quantity) {
                const bills = await this.ctx.service.ledger.getDataById(data.lid);
                const precision = this.ctx.helper.findPrecision(this.ctx.tender.info.precision, bills.unit);
                data.quantity = this.round(data.quantity, precision.value);
            }
            if (transaction) {
                const addRst = await transaction.insert(this.tableName, data);
            } else {
                const addRst = await this.db.insert(this.tableName, data);
            }
        }

        async _completeInsertPosData(tid, data) {
            data.id = this.uuid.v4();
            data.tid = tid;
            // todo 新增期
            data.add_stage = 0;
            data.add_stage_order = 0;
            data.add_times = 0;
            data.in_time = new Date();
            data.add_user = this.ctx.session.sessionUser.accountId;
        }

        async _getUpdateBills(data) {
            const datas = data instanceof Array ? data : [data];
            const bills = await this.ctx.service.ledger.getDataById(datas[0].lid);
            const billsPos = await this.getAllDataByCondition({where: {tid: bills.tender_id, lid: bills.id} });
            const precision = this.ctx.helper.findPrecision(this.ctx.tender.info.precision, bills.unit);
            const updateBills = {id: bills.id, ledger_id: bills.ledger_id};
            for (const bp of billsPos) {
                updateBills.sgfh_qty = this.ctx.helper.add(updateBills.sgfh_qty, bp.sgfh_qty);
                updateBills.sjcl_qty = this.ctx.helper.add(updateBills.sjcl_qty, bp.sjcl_qty);
                updateBills.qtcl_qty = this.ctx.helper.add(updateBills.qtcl_qty, bp.qtcl_qty);
                updateBills.quantity = this.ctx.helper.add(updateBills.quantity, bp.quantity);
                updateBills.ex_qty1 = this.ctx.helper.add(updateBills.ex_qty1, bp.ex_qty1);
            }
            for (const d of datas) {
                if (d.sgfh_qty) {
                    d.sgfh_qty = this.ctx.helper.round(d.sgfh_qty, precision.value);
                    updateBills.sgfh_qty = this.ctx.helper.add(updateBills.sgfh_qty, d.sgfh_qty);
                }
                if (d.sjcl_qty) {
                    d.sjcl_qty = this.ctx.helper.round(d.sjcl_qty, precision.value);
                    updateBills.sjcl_qty = this.ctx.helper.add(updateBills.sjcl_qty, d.sjcl_qty);
                }
                if (d.qtcl_qty) {
                    d.qtcl_qty = this.ctx.helper.round(d.qtcl_qty, precision.value);
                    updateBills.qtcl_qty = this.ctx.helper.add(updateBills.qtcl_qty, d.qtcl_qty);
                }
                d.quantity = this.ctx.helper.sum([d.sgfh_qty, d.qtcl_qty, d.sjcl_qty]);
                updateBills.quantity = this.ctx.helper.add(updateBills.quantity, d.quantity);
                if (d.ex_qty1) {
                    d.ex_qty1 = this.ctx.helper.round(d.ex_qty1, precision.value);
                    updateBills.ex_qty1 = this.ctx.helper.add(updateBills.ex_qty1, d.ex_qty1);
                }
            }
            const info = this.ctx.tender.info;
            updateBills.sgfh_tp = this.ctx.helper.mul(updateBills.sgfh_qty, bills.unit_price, info.decimal.tp);
            updateBills.sjcl_tp = this.ctx.helper.mul(updateBills.sjcl_qty, bills.unit_price, info.decimal.tp);
            updateBills.qtcl_tp = this.ctx.helper.mul(updateBills.qtcl_qty, bills.unit_price, info.decimal.tp);
            updateBills.total_price = this.ctx.helper.mul(updateBills.quantity, bills.unit_price, info.decimal.tp);
            updateBills.ex_tp1 = this.ctx.helper.mul(updateBills.ex_qty1, bills.unit_price, info.decimal.tp);
            return updateBills;
        }

        async _addPosData(tid, data) {
            let updateBills = null;
            if (data instanceof Array) {
                for (const d of data) {
                    this._completeInsertPosData(tid, d);
                }
                if (data[0].sgfh_qty !== undefined || data[0].sjcl_qty !== undefined || data[0].qtcl_qty !== undefined || data[0].ex_qty1 !== undefined) {
                    updateBills = await this._getUpdateBills(data);
                }
            } else {
                this._completeInsertPosData(tid, data);
                if (data.sgfh_qty !== undefined || data.sjcl_qty !== undefined || data.qtcl_qty !== undefined || data.ex_qty1 !== undefined) {
                    updateBills = await this._getUpdateBills(data);
                }
            }
            if (updateBills) {
                const transaction = await this.db.beginTransaction();
                try {
                    await transaction.insert(this.tableName, data);
                    await transaction.update(this.ctx.service.ledger.tableName, updateBills);
                    await transaction.commit();
                } catch (err) {
                    await transaction.rollback();
                    throw err;
                }
                return {
                    ledger: { update: [updateBills] },
                    pos: data,
                }
            } else {
                await this.db.insert(this.tableName, data);
                return { pos: data }
            }
        }

        async _updatePosData(tid, data) {
            if (data.sgfh_qty !== undefined || data.sjcl_qty !== undefined || data.qtcl_qty !== undefined || data.ex_qty1 !== undefined) {
                const op = await this.getDataById(data.id);
                const bills = await this.ctx.service.ledger.getDataById(op.lid);
                if (!bills) throw '数据错误';
                const billsPos = await this.getAllDataByCondition({where: {tid: tid, lid: op.lid} });

                const precision = this.ctx.helper.findPrecision(this.ctx.tender.info.precision, bills.unit);
                if (data.sgfh_qty !== undefined) {
                    data.sgfh_qty = this.round(data.sgfh_qty, precision.value);
                } else if (op) {
                    data.sgfh_qty = op.sgfh_qty;
                }
                if (data.sjcl_qty !== undefined) {
                    data.sjcl_qty = this.round(data.sjcl_qty, precision.value);
                } else if (op) {
                    data.sjcl_qty = op.sjcl_qty;
                }
                if (data.qtcl_qty !== undefined) {
                    data.qtcl_qty = this.round(data.qtcl_qty, precision.value);
                } else if (op) {
                    data.qtcl_qty = op.qtcl_qty;
                }
                data.quantity = this.ctx.helper.sum([data.sgfh_qty, data.qtcl_qty, data.sjcl_qty]);
                if (data.ex_qty1 !== undefined) {
                    data.ex_qty1 = this.round(data.ex_qty1, precision.value);
                } else if (op) {
                    data.ex_qty1 = op.ex_qty1;
                }

                const updateBills = {id: bills.id};
                for (const bp of billsPos) {
                    const calcData = bp.id === data.id ? data : bp;
                    updateBills.sgfh_qty = this.ctx.helper.add(updateBills.sgfh_qty, calcData.sgfh_qty);
                    updateBills.sjcl_qty = this.ctx.helper.add(updateBills.sjcl_qty, calcData.sjcl_qty);
                    updateBills.qtcl_qty = this.ctx.helper.add(updateBills.qtcl_qty, calcData.qtcl_qty);
                    updateBills.quantity = this.ctx.helper.add(updateBills.quantity, calcData.quantity);
                    updateBills.ex_qty1 = this.ctx.helper.add(updateBills.ex_qty1, calcData.ex_qty1);
                }
                const info = this.ctx.tender.info;
                updateBills.sgfh_tp = this.ctx.helper.mul(updateBills.sgfh_qty, bills.unit_price, info.decimal.tp);
                updateBills.sjcl_tp = this.ctx.helper.mul(updateBills.sjcl_qty, bills.unit_price, info.decimal.tp);
                updateBills.qtcl_tp = this.ctx.helper.mul(updateBills.qtcl_qty, bills.unit_price, info.decimal.tp);
                updateBills.total_price = this.ctx.helper.mul(updateBills.quantity, bills.unit_price, info.decimal.tp);
                updateBills.ex_tp1 = this.ctx.helper.mul(updateBills.ex_qty1, bills.unit_price, info.decimal.tp);

                const transaction = await this.db.beginTransaction();
                try {
                    await transaction.update(this.tableName, data);
                    await transaction.update(this.ctx.service.ledger.tableName, updateBills);
                    await transaction.commit();
                    updateBills.ledger_id = bills.ledger_id;
                    return {
                        ledger: { update: [updateBills] },
                        pos: data,
                    }
                } catch(err) {
                    await transaction.rollback();
                    throw err;
                }
            } else {
                await this.db.update(this.tableName, data);
                return {pos: data};
            }
        }

        async _updatePosDatas(tid, data) {
            if (data.length === 0) return;
            const op = await this.getDataById(data[0].id);
            const bills = await this.ctx.service.ledger.getDataById(op.lid);
            const billsPos = await this.getAllDataByCondition({where: {tid: tid, lid: op.lid} });
            const precision = this.ctx.helper.findPrecision(this.ctx.tender.info.precision, bills.unit);
            let needUpdateBills;
            for (const d of data) {
                if (d.sgfh_qty !== undefined || d.sjcl_qty !== undefined || d.qtcl_qty !== undefined || d.ex_qty1 !== undefined) {
                    if (d.sgfh_qty !== undefined) {
                        d.sgfh_qty = this.round(d.sgfh_qty, precision.value);
                    } else if (op) {
                        d.sgfh_qty = op.sgfh_qty;
                    }
                    if (d.sjcl_qty !== undefined) {
                        d.sjcl_qty = this.round(d.sjcl_qty, precision.value);
                    } else if (op) {
                        d.sjcl_qty = op.sjcl_qty;
                    }
                    if (d.qtcl_qty !== undefined) {
                        d.qtcl_qty = this.round(d.qtcl_qty, precision.value);
                    } else if (op) {
                        d.qtcl_qty = op.qtcl_qty;
                    }
                    d.quantity = this.ctx.helper.sum([d.sgfh_qty, d.qtcl_qty, d.sjcl_qty]);
                    if (d.ex_qty1 !== undefined) {
                        d.ex_qty1 = this.round(d.ex_qty1, precision.value);
                    } else if (op) {
                        d.ex_qty1 = op.ex_qty1;
                    }
                    needUpdateBills = true;
                }
            }
            const updateBills = {id: bills.id};
            if (needUpdateBills) {
                for (const bp of billsPos) {
                    const newPos = data.find(function (x) { return x.id === bp.id });
                    updateBills.sgfh_qty = newPos && newPos.sgfh_qty !== undefined
                        ? this.ctx.helper.add(updateBills.sgfh_qty, newPos.sgfh_qty)
                        : this.ctx.helper.add(updateBills.sgfh_qty, bp.sgfh_qty);
                    updateBills.sjcl_qty = newPos && newPos.sjcl_qty !== undefined
                        ? this.ctx.helper.add(updateBills.sjcl_qty, newPos.sjcl_qty)
                        : this.ctx.helper.add(updateBills.sjcl_qty, bp.sjcl_qty);
                    updateBills.qtcl_qty = newPos && newPos.qtcl_qty !== undefined
                        ? this.ctx.helper.add(updateBills.qtcl_qty, newPos.qtcl_qty)
                        : this.ctx.helper.add(updateBills.qtcl_qty, bp.qtcl_qty);
                    updateBills.quantity = newPos && newPos.quantity !== undefined
                        ? this.ctx.helper.add(updateBills.quantity, newPos.quantity)
                        : this.ctx.helper.add(updateBills.quantity, bp.quantity);
                    updateBills.ex_qty1 = newPos && newPos.ex_qty1 !== undefined
                        ? this.ctx.helper.add(updateBills.ex_qty1, newPos.ex_qty1)
                        : this.ctx.helper.add(updateBills.ex_qty1, bp.ex_qty1);
                }
                const info = this.ctx.tender.info;
                updateBills.sgfh_tp = this.ctx.helper.mul(updateBills.sgfh_qty, bills.unit_price, info.decimal.tp);
                updateBills.sjcl_tp = this.ctx.helper.mul(updateBills.sjcl_qty, bills.unit_price, info.decimal.tp);
                updateBills.qtcl_tp = this.ctx.helper.mul(updateBills.qtcl_qty, bills.unit_price, info.decimal.tp);
                updateBills.total_price = this.ctx.helper.mul(updateBills.quantity, bills.unit_price, info.decimal.tp);
                updateBills.ex_tp1 = this.ctx.helper.mul(updateBills.ex_qty1, bills.unit_price, info.decimal.tp);
            }

            const transaction = await this.db.beginTransaction();
            try {
                for (const d of data) {
                    await transaction.update(this.tableName, d);
                }
                if (needUpdateBills) await transaction.update(this.ctx.service.ledger.tableName, updateBills);
                await transaction.commit();
                updateBills.ledger_id = bills.ledger_id;
                return {
                    ledger: { update: [updateBills] },
                    pos: data,
                }
            } catch(err) {
                await transaction.rollback();
                throw err;
            }
        }

        async _deletePosData(tid, data) {
            if (!data || data.length === 0) throw '提交数据错误';

            const pos = await this.getPosData({tid: tid, id: data});
            if (!pos || pos.length === 0) throw '删除的计量单元不存在';

            const bills = await this.ctx.service.ledger.getDataById(pos[0].lid);
            const billsPos = await this.getAllDataByCondition({ where: {tid: tid, lid: bills.id} });
            const updateBills = {id: bills.id, sgfh_qty: 0, sjcl_qty: 0, qtcl_qty: 0, quantity: 0, ex_qty1: 0};
            for (const bp of billsPos) {
                if (data.indexOf(bp.id) >= 0) continue;
                updateBills.sgfh_qty = this.ctx.helper.add(updateBills.sgfh_qty, bp.sgfh_qty);
                updateBills.sjcl_qty = this.ctx.helper.add(updateBills.sjcl_qty, bp.sjcl_qty);
                updateBills.qtcl_qty = this.ctx.helper.add(updateBills.qtcl_qty, bp.qtcl_qty);
                updateBills.quantity = this.ctx.helper.add(updateBills.quantity, bp.quantity);
                updateBills.ex_qty1 = this.ctx.helper.add(updateBills.ex_qty1, bp.ex_qty1);
            }
            const info = this.ctx.tender.info;
            updateBills.sgfh_tp = this.ctx.helper.mul(updateBills.sgfh_qty, bills.unit_price, info.decimal.tp);
            updateBills.sjcl_tp = this.ctx.helper.mul(updateBills.sjcl_qty, bills.unit_price, info.decimal.tp);
            updateBills.qtcl_tp = this.ctx.helper.mul(updateBills.qtcl_qty, bills.unit_price, info.decimal.tp);
            updateBills.total_price = this.ctx.helper.mul(updateBills.quantity, bills.unit_price, info.decimal.tp);
            updateBills.ex_tp1 = this.ctx.helper.mul(updateBills.ex_qty1, bills.unit_price, info.decimal.tp);

            const transaction = await this.db.beginTransaction();
            try {
                await transaction.delete(this.tableName, {tid: tid, id: data});
                await transaction.update(this.ctx.service.ledger.tableName, updateBills);
                await this.ctx.service.posCalcDetail.deletePosPartData(transaction, tid, data);
                await this.ctx.service.ancillaryGcl.deletePosPartData(transaction, tid, data);
                await this.ctx.service.ancillaryGclDetail.deletePosPartData(transaction, tid, data);
                await transaction.commit();
                updateBills.ledger_id = bills.ledger_id;
                return { ledger: { update: [updateBills] }, pos: data };
            } catch(err) {
                await transaction.rollback();
                throw err;
            }
        }

        async _insertPosData(tid, data) {
            if (!data.length) return;

            let porder = data[0].porder, lid = data[0].lid;
            for (const d of data) {
                this._completeInsertPosData(tid, d);
                porder = Math.min(porder, d.porder);
            }

            const transaction = await this.db.beginTransaction();
            try {
                this.initSqlBuilder();
                this.sqlBuilder.setAndWhere('lid', {
                    value: this.db.escape(lid),
                    operate: '=',
                });
                this.sqlBuilder.setAndWhere('porder', {
                    value: porder,
                    operate: '>=',
                });
                this.sqlBuilder.setUpdateData('porder', {
                    value: data.length,
                    selfOperate: '+',
                });
                const [sql, sqlParam] = this.sqlBuilder.build(this.tableName, 'update');
                const result = await transaction.query(sql, sqlParam);
                await transaction.insert(this.tableName, data);
                await transaction.commit();
            } catch (err) {
                await transaction.rollback();
                throw err;
            }

            this.initSqlBuilder();
            this.sqlBuilder.setAndWhere('lid', {
                value: this.db.escape(lid),
                operate: '=',
            });
            this.sqlBuilder.setAndWhere('porder', {
                value: porder,
                operate: '>=',
            });
            const [sql, sqlParam] = this.sqlBuilder.build(this.tableName);
            const update = await this.db.query(sql, sqlParam);
            return { pos: update }
        }

        _calcExpr(data, field, expr, defaultValue, precision) {
            if (expr) {
                try {
                    data[field] = this.ctx.helper.round(this.ctx.helper.calcExpr(expr), precision.value);
                } catch (err) {
                }
            } else {
                data[field] = this.ctx.helper.round(defaultValue, precision.value);
            }
        }
        async pasteBlockData(tid, data) {
            if (!(data.block instanceof Array)) throw '提交数据错误';

            const result = { ledger: {}, pos: null };
            const qtyDecimal = this.ctx.tender.info.decimal.qty;
            const user_id = this.ctx.session.sessionUser.accountId;

            const bills = await this.ctx.service.ledger.getDataById(data.lid);
            const le = await this.ctx.service.ledgerExtra.getDataById(data.lid);
            const calcTemplate = le && le.calc_template ? await this.ctx.service.calcTmpl.getTemplate(le.calc_template) : null;
            const precision = this.ctx.helper.findPrecision(this.ctx.tender.info.precision, bills.unit);
            const existPos = await this.ctx.service.pos.getAllDataByCondition({ where : { lid: bills.id }, orders: [['porder', 'DESC']]});
            const maxOrder = existPos.length > 0 ? existPos[0].porder : 0;
            const updateBills = existPos.length > 0
                ? { id: bills.id, sgfh_qty: bills.sgfh_qty, sjcl_qty: bills.sjcl_qty, qtcl_qty: bills.qtcl_qty, quantity: bills.quantity, ex_qty1: bills.ex_qty1 }
                : { id: bills.id, sgfh_qty: 0, sjcl_qty: 0, qtcl_qty: 0, quantity: 0, ex_qty1: 0 };

            const insertPos = [], insertDetail = [], insertAncGcl = [], insertAncGclDetail = [];
            for (const [i, b] of data.block.entries()) {
                const nip = {};
                insertPos.push(nip);
                this._completeInsertPosData(tid, nip);
                nip.lid = b.lid;
                nip.name = b.name || '';
                nip.drawing_code = b.drawing_code || '';
                nip.porder = maxOrder + i + 1;
                nip.position = b.position;
                nip.sgfh_expr = b.sgfh_expr ? b.sgfh_expr : '';
                nip.sjcl_expr = b.sjcl_expr ? b.sjcl_expr : '';
                nip.qtcl_expr = b.qtcl_expr ? b.qtcl_expr : '';
                nip.ex_memo1 = b.ex_memo1;
                nip.ex_memo2 = b.ex_memo2;
                nip.ex_memo3 = b.ex_memo3;
                if (calcTemplate) {
                    let sumQty = 0;
                    for (const cd of b.calcDetail) {
                        const newDetail = {
                            id: this.uuid.v4(), tid: tid, lid: bills.id, pid: nip.id,
                            create_user_id: this.ctx.session.sessionUser.accountId,
                            update_user_id: this.ctx.session.sessionUser.accountId,
                            pcd_order: cd.pcd_order,
                        };
                        if (data.calc_template === le.calc_template) {
                            newDetail.str1 = cd.str1 || '';
                            newDetail.str2 = cd.str2 || '';
                            newDetail.str3 = cd.str3 || '';
                            newDetail.str4 = cd.str4 || '';
                            newDetail.num_a = cd.num_a || 0;
                            newDetail.num_b = cd.num_b || 0;
                            newDetail.num_c = cd.num_c || 0;
                            newDetail.num_d = cd.num_d || 0;
                            newDetail.num_e = cd.num_e || 0;
                            newDetail.num_f = cd.num_f || 0;
                            newDetail.num_g = cd.num_g || 0;
                            newDetail.num_h = cd.num_h || 0;
                            newDetail.num_i = cd.num_i || 0;
                            newDetail.num_j = cd.num_j || 0;
                            newDetail.num_k = cd.num_k || 0;
                            newDetail.num_l = cd.num_l || 0;
                            newDetail.num_m = cd.num_m || 0;
                            newDetail.num_n = cd.num_n || 0;
                            newDetail.num_o = cd.num_o || 0;
                            newDetail.num_p = cd.num_p || 0;
                            newDetail.num_q = cd.num_q || 0;
                            newDetail.num_r = cd.num_r || 0;
                            newDetail.num_s = cd.num_s || 0;
                            newDetail.num_t = cd.num_t || 0;
                            newDetail.num_u = cd.num_u || 0;
                            newDetail.qty = cd.qty || 0;
                            newDetail.expr = cd.expr || '';
                            newDetail.spec = cd.spec || '';
                        } else {
                            this.ctx.service.posCalcDetail._loadDataAndCalc(newDetail, cd, {}, calcTemplate);
                        }
                        sumQty = this.ctx.helper.add(sumQty, newDetail.qty);
                        insertDetail.push(newDetail);
                    }
                    this._calcExpr(nip, 'sgfh_qty', '', sumQty, precision);
                } else {
                    this._calcExpr(nip, 'sgfh_qty', b.sgfh_expr, b.sgfh_qty, precision);
                }
                this._calcExpr(nip, 'sjcl_qty', b.sjcl_expr, b.sjcl_qty, precision);
                this._calcExpr(nip, 'qtcl_qty', b.qtcl_expr, b.qtcl_qty, precision);
                nip.quantity = this.ctx.helper.add(nip.sgfh_qty, this.ctx.helper.add(nip.sjcl_qty, nip.qtcl_qty));
                nip.ex_qty1 = this.ctx.helper.round(b.ex_qty1, precision.value);
                for (const ag of b.ancGcl) {
                    const nig = {
                        id: this.uuid.v4(), tid: this.ctx.tender.id,
                        add_user_id: user_id, update_user_id: user_id,
                        lid: nip.lid, pid: nip.id, g_order: ag.g_order,
                        is_aux: ag.is_aux || 0, name: ag.name || '', unit: ag.unit || '',
                        drawing_code: ag.drawing_code || '', memo: ag.memo || '',
                        quantity: ag.quantity || 0, expr: ag.expr || '', calc_template: ag.calc_template || ''
                    };
                    insertAncGcl.push(nig);
                    if (!ag.calc_template) continue;

                    let sumQty = 0;
                    for (const cd of ag.calcDetail) {
                        const newDetail = {
                            id: this.uuid.v4(), tid: this.ctx.tender.id, lid: nip.lid, pid: nip.id, ag_id: nig.id,
                            create_user_id: user_id, update_user_id: user_id,
                            agd_order: cd.agd_order,
                            str1 : cd.str1 || '', str2 : cd.str1 || '', str3 : cd.str1 || '', str4 : cd.str1 || '',
                            num_a : cd.num_a || 0, num_b : cd.num_b || 0, num_c : cd.num_c || 0, num_d : cd.num_d || 0,
                            num_e : cd.num_e || 0, num_f : cd.num_f || 0, num_g : cd.num_g || 0, num_h : cd.num_h || 0,
                            num_i : cd.num_i || 0, num_j : cd.num_j || 0, num_k : cd.num_k || 0, num_l : cd.num_l || 0,
                            num_m : cd.num_m || 0, num_n : cd.num_n || 0, num_o : cd.num_o || 0, num_p : cd.num_p || 0,
                            num_q : cd.num_q || 0, num_r : cd.num_r || 0, num_s : cd.num_s || 0, num_t : cd.num_t || 0,
                            num_u : cd.num_u || 0,
                            qty: cd.qty || 0, expr: cd.expr || 0, spec: cd.spec || ''
                        };
                        sumQty = this.ctx.helper.add(sumQty, newDetail.qty);
                        insertAncGclDetail.push(newDetail);
                    }
                    nig.quantity = this.ctx.helper.round(sumQty, qtyDecimal);
                }

                updateBills.sgfh_qty = this.ctx.helper.add(updateBills.sgfh_qty, nip.sgfh_qty);
                updateBills.sjcl_qty = this.ctx.helper.add(updateBills.sjcl_qty, nip.sjcl_qty);
                updateBills.qtcl_qty = this.ctx.helper.add(updateBills.qtcl_qty, nip.qtcl_qty);
                updateBills.ex_qty1 = this.ctx.helper.add(updateBills.ex_qty1, nip.ex_qty1);
            }

            const info = this.ctx.tender.info;
            updateBills.quantity = this.ctx.helper.add(updateBills.sgfh_qty, this.ctx.helper.add(updateBills.sjcl_qty, updateBills.qtcl_qty));
            updateBills.sgfh_tp = this.ctx.helper.mul(updateBills.sgfh_qty, bills.unit_price, info.decimal.tp);
            updateBills.sjcl_tp = this.ctx.helper.mul(updateBills.sjcl_qty, bills.unit_price, info.decimal.tp);
            updateBills.qtcl_tp = this.ctx.helper.mul(updateBills.qtcl_qty, bills.unit_price, info.decimal.tp);
            updateBills.total_price = this.ctx.helper.mul(updateBills.quantity, bills.unit_price, info.decimal.tp);
            updateBills.ex_tp1 = this.ctx.helper.mul(updateBills.ex_qty1, bills.unit_price, info.decimal.tp);

            const transaction = await this.db.beginTransaction();
            try {
                await transaction.insert(this.tableName, insertPos);
                if (insertDetail.length > 0) await transaction.insert(this.ctx.service.posCalcDetail.tableName, insertDetail);
                if (insertAncGcl.length > 0) await transaction.insert(this.ctx.service.ancillaryGcl.tableName, insertAncGcl);
                if (insertAncGclDetail.length > 0) await transaction.insert(this.ctx.service.ancillaryGclDetail.tableName, insertAncGclDetail);
                await transaction.update(this.ctx.service.ledger.tableName, updateBills);
                await transaction.commit();
            } catch (err) {
                await transaction.rollback();
                throw err;
            }
            result.pos = insertPos;
            updateBills.ledger_id = bills.ledger_id;
            result.ledger.update = [updateBills];
            result.posCalcDetail = { add: insertDetail };
            result.ancGcl = { add: insertAncGcl };
            result.ancGclDetail = { add: insertAncGclDetail };
            return result;
        }

        /**
         * 保存部位明细数据
         * @param data
         * @param {Number} tid - 标段id
         * @returns {Promise<{ledger: {}, pos: null}>}
         */
        async savePosData(data, tid) {
            switch (data.updateType) {
                case 'add':
                    return await this._addPosData(tid, data.updateData);
                case 'update':
                    if (data.updateData instanceof Array) {
                        return await this._updatePosDatas(tid, data.updateData);
                    } else {
                        return await this._updatePosData(tid, data.updateData);
                    }
                case 'delete':
                    return await this._deletePosData(tid, data.updateData);
                case 'insert':
                    return await this._insertPosData(tid, data.updateData);
                case 'paste-block':
                    return await this.pasteBlockData(tid, data.updateData);
            }
        }

        /**
         * 复制粘贴 部位明细数据
         * @param {Array} data - 复制粘贴的数据
         * @param {Number} tid - 标段id
         * @returns {Promise<{ledger: {}, pos: null}>}
         */
        async pastePosData(data, tid) {
            if (!(data instanceof Array)) {
                throw '提交数据错误';
            }

            const transaction = await this.db.beginTransaction();
            const result = { ledger: {}, pos: null };

            const bills = await this.ctx.service.ledger.getDataById(data[0].lid);
            const precision = this.ctx.helper.findPrecision(this.ctx.tender.info.precision, bills.unit);
            const updateBills = {id: bills.id};
            const billsPos = await this.getAllDataByCondition({where: {tid: tid, lid: bills.id} });
            for (const bp of billsPos) {
                const d = data.find(function (x) {
                    return bp.id ? x.id === bp.id : false;
                });
                if (d) continue;
                updateBills.sgfh_qty = this.ctx.helper.add(updateBills.sgfh_qty, bp.sgfh_qty);
                updateBills.sjcl_qty = this.ctx.helper.add(updateBills.sjcl_qty, bp.sjcl_qty);
                updateBills.qtcl_qty = this.ctx.helper.add(updateBills.qtcl_qty, bp.qtcl_qty);
                updateBills.quantity = this.ctx.helper.add(updateBills.quantity, bp.quantity);
                updateBills.ex_qty1 = this.ctx.helper.add(updateBills.ex_qty1, bp.ex_qty1);
            }

            try {
                for (const d of data) {
                    const op = d.id ? this._.find(billsPos, {id: d.id}) : null;
                    
                    if (d.sgfh_qty !== undefined) {
                        d.sgfh_qty = this.round(d.sgfh_qty, precision.value);
                    } else if (op) {
                        d.sgfh_qty = op.sgfh_qty;
                    }
                    updateBills.sgfh_qty = this.ctx.helper.add(updateBills.sgfh_qty, d.sgfh_qty);
                    if (d.sjcl_qty !== undefined) {
                        d.sjcl_qty = this.round(d.sjcl_qty, precision.value);
                    } else if (op) {
                        d.sjcl_qty = op.sjcl_qty;
                    }
                    updateBills.sjcl_qty = this.ctx.helper.add(updateBills.sjcl_qty, d.sjcl_qty);
                    if (d.qtcl_qty) {
                        d.qtcl_qty = this.round(d.qtcl_qty, precision.value);
                    } else if (op) {
                        d.qtcl_qty = op.qtcl_qty;
                    }
                    updateBills.qtcl_qty = this.ctx.helper.add(updateBills.qtcl_qty, d.qtcl_qty);
                    d.quantity = this.ctx.helper.sum([d.sgfh_qty, d.qtcl_qty, d.sjcl_qty]);
                    updateBills.quantity = this.ctx.helper.add(updateBills.quantity, d.quantity);
                    if (d.ex_qty1) {
                        d.ex_qty1 = this.round(d.ex_qty1, precision.value);
                    } else if (op) {
                        d.ex_qty1 = op.ex_qty1;
                    }
                    updateBills.ex_qty1 = this.ctx.helper.add(updateBills.ex_qty1, d.ex_qty1);

                    if (d.id) {
                        await transaction.update(this.tableName, d);
                    } else {
                        this._completeInsertPosData(tid, d);
                        await transaction.insert(this.tableName, d);
                    }
                }

                const info = this.ctx.tender.info;
                updateBills.sgfh_tp = this.ctx.helper.mul(updateBills.sgfh_qty, bills.unit_price, info.decimal.tp);
                updateBills.sjcl_tp = this.ctx.helper.mul(updateBills.sjcl_qty, bills.unit_price, info.decimal.tp);
                updateBills.qtcl_tp = this.ctx.helper.mul(updateBills.qtcl_qty, bills.unit_price, info.decimal.tp);
                updateBills.total_price = this.ctx.helper.mul(updateBills.quantity, bills.unit_price, info.decimal.tp);
                updateBills.ex_tp1 = this.ctx.helper.mul(updateBills.ex_qty1, bills.unit_price, info.decimal.tp);
                await transaction.update(this.ctx.service.ledger.tableName, updateBills);
                updateBills.ledger_id = bills.ledger_id;
                await transaction.commit();
            } catch (err) {
                await transaction.rollback();
                throw err;
            }
            result.pos = data;
            result.ledger.update = [updateBills];
            return result;
        }

        /**
         * 删除清单下部位明细数据(删除清单时调用)
         *
         * @param transaction - 事务
         * @param tid - 标段id
         * @param lid - 清单id
         * @returns {Promise<void>}
         */
        async deletePosData(transaction, tid, lid) {
            await transaction.delete(this.tableName, {tid: tid, lid: lid});
        }

        async getMemoData(tid, columns) {
            if (!columns || columns.length === 0) return [];

            return await this.db.select(this.departTableName(tid), {
                where: { tid },
                columns: ['id', ...columns],
            });
        }
    }

    return Pos;
};