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 = 20;
            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', 'sgfh_expr', 'sjcl_expr', 'qtcl_expr', 'real_qty',
                    'dagl_status', 'dagl_url', 'gxby_status', 'gxby_url', 'gxby_limit', 'dagl_limit',
                    '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, gxby_status, gxby_url, dagl_status, dagl_url,' +
                '    gxby_limit, dagl_limit, 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,' +
                    '    dagl_status, dagl_url, gxby_status, gxby_url, gxby_limit, dagl_limit, 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' +
                '  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};
            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);
            }
            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);
            }
            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);
            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) {
                    updateBills = await this._getUpdateBills(data);
                }
            } else {
                this._completeInsertPosData(tid, data);
                if (data.sgfh_qty !== undefined || data.sjcl_qty !== undefined || data.qtcl_qty !== undefined) {
                    updateBills = await this._getUpdateBills(data);
                }
            }
            if (updateBills) {
                const transaction = await this.db.beginTransaction();
                try {
                    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;
                }
                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) {
                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]);

                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);
                }
                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);

                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) {
                    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]);
                    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);
                }
                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);
            }

            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: null, sjcl_qty: null, qtcl_qty: null, quantity: null};
            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);
            }
            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);

            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 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 }
        }

        /**
         * 保存部位明细数据
         * @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);
            }
        }

        /**
         * 复制粘贴 部位明细数据
         * @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);
            }

            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.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);
                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 loadDataFromOss(tid, url) {
            const data = await this.ctx.helper.loadLedgerDataFromOss(url);
            const curData = await this.getAllDataByCondition({
                columns: ['id', 'gxby_status', 'gxby_limit', 'gxby_url', 'dagl_status', 'dagl_limit', 'dagl_url'],
                where: { tid: tid }
            });
            this.ctx.helper.assignRelaData(data, [
                { data: curData, fields: ['gxby_status', 'gxby_limit', 'gxby_url', 'dagl_status', 'dagl_limit', 'dagl_url'], prefix: '', relaId: 'id' },
            ]);
            return data;
        }
    }

    return Pos;
};