Calculation/app/service/stage_jgcl.js

'use strict';

/**
 *
 *
 * @author Mai
 * @date
 * @version
 */

const auditConst = require('../const/audit').stage;
module.exports = app => {
    class StageJgcl extends app.BaseService {
        /**
         * 构造函数
         *
         * @param {Object} ctx - egg全局变量
         * @return {void}
         */
        constructor(ctx) {
            super(ctx);
            this.tableName = 'stage_jgcl';
        }

        async getStageData(stage) {
            const data = await this.getAllDataByCondition({where: { sid: stage.id }});
            if (stage && stage.readOnly && stage.status !== auditConst.status.checked) {
                for (const d of data) {
                    const his = d.shistory ? JSON.parse(d.shistory) : [];
                    const h = this.ctx.helper._.find(his, {
                        stimes: stage.curTimes, sorder: stage.curOrder
                    });
                    if (h) {
                        d.arrive_qty = h.arrive_qty ? h.arrive_qty : h.arraive_qty;
                        d.arrive_tp = h.arrive_tp;
                        d.deduct_qty = h.deduct_qty;
                        d.deduct_tp = h.deduct_tp;
                    } else {
                        d.arrive_qty = null;
                        d.arrive_tp = null;
                        d.deduct_qty = null;
                        d.deduct_tp = null;
                    }
                }
            }
            return data;
        }

        async getPreStageData(sorder) {
            const sql = 'SELECT c.uuid, Sum(c.arrive_qty) as arrive_qty, Sum(c.arrive_tp) as arrive_tp,' +
                '    Sum(c.deduct_qty) as deduct_qty, Sum(c.deduct_tp) as deduct_tp' +
                '  From ' + this.tableName + ' c' +
                '  LEFT JOIN ' + this.ctx.service.stage.tableName + ' s ON s.id = c.sid' +
                '  WHERE s.`order` < ? And s.`tid` = ?' +
                '  GROUP By uuid';
            const sqlParam = [sorder, this.ctx.tender.id];
            const data = await this.db.query(sql, sqlParam);
            return data;
        }

        async getEndStageData(sorder) {
            const sql = 'SELECT c.uuid, Sum(c.arrive_qty) as arrive_qty, Sum(c.arrive_tp) as arrive_tp,' +
                '    Sum(c.deduct_qty) as deduct_qty, Sum(c.deduct_tp) as deduct_tp' +
                '  From ' + this.tableName + ' c' +
                '  LEFT JOIN ' + this.ctx.service.stage.tableName + ' s ON s.id = c.sid' +
                '  WHERE s.`order` <= ? And s.`tid` = ?' +
                '  GROUP By uuid';
            const sqlParam = [sorder, this.ctx.tender.id];
            const data = await this.db.query(sql, sqlParam);
            return data;
        }

        async _addDatas(data) {
            const datas = data instanceof Array ? data : [data];
            const insertData = [];
            for (const d of datas) {
                if (!d.name || !d.order) throw '新增甲供材料，提交的数据错误';
                const nd = {
                    uuid: this.uuid.v4(),
                    add_sid: this.ctx.stage.id,
                    add_uid: this.ctx.session.sessionUser.accountId,
                    sid: this.ctx.stage.id,
                };
                nd.name = d.name;
                nd.order = d.order;
                if (d.unit) nd.unit = d.unit;
                if (d.unit_price) nd.unit_price = d.unit_price;
                const precision = this.ctx.helper.findPrecision(this.ctx.tender.info.precision, d.unit_price);
                if (d.arrive_qty) {
                    nd.arrive_qty = this.ctx.helper.round(d.arrive_qty, precision.value);
                    nd.arrive_tp = this.ctx.helper.mul(nd.unit_price, nd.arrive_qty, this.ctx.tender.info.decimal.tp);
                }
                if (d.deduct_qty) {
                    nd.deduct_qty = this.ctx.helper.round(d.deduct_qty, precision.value);
                    nd.deduct_tp = this.ctx.helper.mul(nd.unit_price, nd.deduct_qty, this.ctx.tender.info.decimal.tp);
                }
                if (d.source) nd.source = d.source;
                if (d.bills_code) nd.bills_code = d.bills_code;
                if (d.check_code) nd.check_code = d.check_code;
                if (d.memo) nd.memo = d.memo;
                insertData.push(nd);
            }
            await this.db.insert(this.tableName, insertData);
            return await this.getAllDataByCondition({
                where: { sid: this.ctx.stage.id, uuid: this.ctx.helper._.map(insertData, 'uuid') }
            });
        }

        async _delDatas (data) {
            const datas = data instanceof Array ? data : [data];
            const orgDatas = await this.getAllDataByCondition({where: {sid: this.ctx.stage.id, id: this.ctx.helper._.map(datas, 'id')} });
            for (const od of orgDatas) {
                if (od.pre_used) throw '甲供材料往期已经计量，不可删除';
            }
            await this.db.delete(this.tableName, {id: datas});
            return datas;
        }

        async _updateDatas (data) {
            const datas = data instanceof Array ? data : [data];
            const orgDatas = await this.getAllDataByCondition({sid: this.ctx.stage.id, id: this.ctx.helper._.map(datas, 'id')});
            const info = this.ctx.tender.info;

            const uDatas = [];
            for (const d of datas) {
                const od = this.ctx.helper._.find(orgDatas, {id: d.id});
                if (!od) continue;

                const nd = {id: od.id};
                if (d.name) nd.name = d.name;
                if (od.pre_used === null || od.pre_used === undefined || od.pre_used === 0) {
                    if (d.unit !== undefined) nd.unit = d.unit;
                    nd.unit_price = d.unit_price !== undefined ? this.ctx.helper.round(d.unit_price, info.decimal.up) : od.unit_price;
                } else {
                    nd.unit_price = od.unit_price;
                }
                const precision = this.ctx.helper.findPrecision(info.precision, d.unit_price);
                if (d.arrive_qty !== undefined) {
                    nd.arrive_qty = this.ctx.helper.round(d.arrive_qty, precision.value);
                    nd.arrive_tp = this.ctx.helper.mul(nd.unit_price, nd.arrive_qty, info.decimal.tp);
                } else if (d.unit_price !== undefined) {
                    nd.arrive_tp = this.ctx.helper.mul(nd.unit_price, od.arrive_qty, info.decimal.tp);
                }
                if (d.deduct_qty !== undefined) {
                    nd.deduct_qty = this.ctx.helper.round(d.deduct_qty, precision.value);
                    nd.deduct_tp = this.ctx.helper.mul(nd.unit_price, nd.deduct_qty, info.decimal.tp);
                } else if (d.unit_price !== undefined) {
                    nd.deduct_tp = this.ctx.helper.mul(nd.unit_price, od.deduct_qty, info.decimal.tp);
                }
                if (d.source !== undefined) nd.source = d.source;
                if (d.bills_code !== undefined) nd.bills_code = d.bills_code;
                if (d.check_code !== undefined) nd.check_code = d.check_code;
                if (d.memo !== undefined) nd.memo = d.memo;
                if (d.order !== undefined) nd.order = d.order;
                uDatas.push(nd);
            }
            if (uDatas.length > 0) {
                await this.db.updateRows(this.tableName, uDatas);
                return uDatas;
            } else {
                return [];
            }
        }

        async updateDatas(data) {
            const result = {add: [], del: [], update: []};
            try {
                if (data.add) {
                    result.add = await this._addDatas(data.add);
                }
                if (data.update) {
                    result.update = await this._updateDatas(data.update);
                }
                if (data.del) {
                    result.del = await this._delDatas(data.del);
                }
                return result;
            } catch (err) {
                if (err) result.err = err;
                return result;
            }
        }

        async updateHistory(stage, transaction) {
            const datas = await this.getStageData(stage);
            if (datas.length === 0) return;

            const updateDatas = [];
            const times = this.ctx.stage.curTimes, order = this.ctx.stage.curOrder;
            for (const d of datas) {
                const history = d.shistory && d.shistory !== '' ? JSON.parse(d.shistory) : [];
                const his = history.find(function (x) {
                    return x.stimes && x.stimes === times
                        && x.sorder && x.sorder === order;
                });
                if (his) {
                    his.arrive_qty = d.arrive_qty;
                    his.arrive_tp = d.arrive_tp;
                    his.deduct_qty = d.deduct_qty;
                    his.deduct_tp = d.deduct_tp;
                } else {
                    history.push({
                        stimes: this.ctx.stage.curTimes, sorder: this.ctx.stage.curOrder,
                        arrive_qty: d.arrive_qty, arrive_tp: d.arrive_tp,
                        deduct_qty: d.deduct_qty, deduct_tp: d.deduct_tp
                    });
                }
                updateDatas.push({ id: d.id, shistory: JSON.stringify(history) });
            }
            await transaction.updateRows(this.tableName, updateDatas);
        }

        async addInitialStageData(stage, preStage, transaction) {
            if (!stage || !preStage) {
                throw '标段数据有误';
            }
            const preDatas = await this.getAllDataByCondition({
                columns: ['uuid', 'name', 'unit', 'unit_price', 'source', 'bills_code', 'check_code', 'memo', 'add_uid', 'add_sid', 'order'],
                where: { sid: preStage.id },
            });
            if (preDatas.length > 0) {
                for (const pd of preDatas) {
                    pd.pre_used = pd.pre_used || !this.ctx.helper.checkZero(pd.arrive_qty) || !this.ctx.helper.checkZero(pd.deduct_qty);
                    pd.sid = stage.id;
                }
                const result = await transaction.insert(this.tableName, preDatas);
                return result.affectedRows === preDatas.length;
            } else {
                return true;
            }
        }

        async deleteStageTimesData(sid, times, transaction) {
            const datas = await this.getAllDataByCondition({where: { sid: sid }});
            if (datas.length === 0) return;

            const updateDatas = [];
            for (const d of datas) {
                const history = d.shistory && d.shistory !== '' ? JSON.parse(d.shistory) : [];
                const his = history.filter(function (x) {
                    return x.stimes && x.stimes < times;
                });
                his.sort(function (x, y) {
                    return (x.stimes * 1000 + x.sorder) - (y.stimes * 1000 + y.sorder);
                });
                updateDatas.push({
                    id: d.id,
                    shistory: JSON.stringify(his),
                    arrive_qty: his.length > 0 ? his[his.length - 1].arrive_qty : null,
                    arrive_tp: his.length > 0 ? his[his.length - 1].arrive_tp : null,
                    deduct_qty: his.length > 0 ? his[his.length - 1].deduct_qty : null,
                    deduct_tp: his.length > 0 ? his[his.length - 1].deduct_tp : null,
                });
            }
            await transaction.updateRows(this.tableName, updateDatas);
        }
    }

    return StageJgcl;
};