Calculation/app/service/project_spread.js

'use strict';

/**
 *
 *
 * @author Mai
 * @date 2024/3/5
 * @version
 */

const SpreadConst = require('../const/spread');
const JsonFields = [
    'tz_ledger_set', 'tz_ledger_bills_spread', 'tz_ledger_pos_spread',
    'gcl_ledger_set', 'gcl_ledger_bills_spread', 'gcl_ledger_pos_spread',
    'tz_stage_set', 'tz_stage_bills_spread', 'tz_stage_pos_spread',
    'gcl_stage_set', 'gcl_stage_bills_spread', 'gcl_stage_pos_spread',
];

module.exports = app => {

    class ProjectSpread extends app.BaseService {

        /**
         * 构造函数
         *
         * @param {Object} ctx - egg全局变量
         * @return {void}
         */
        constructor(ctx) {
            super(ctx);
            this.tableName = 'project_spread';
        }

        async loadProjectSpread(id) {
            const result = await this.getDataByCondition({ id });
            if (result) {
                JsonFields.forEach(jf => { if(result[jf]) result[jf] = JSON.parse(result[jf]); });
            }
            return result;
        }

        generateSpreadSetting(colSet, emptyBase, BaseSetCol, BaseSpreadColSetting, spreadType = 'bills') {
            const spreadSetting = JSON.parse(JSON.stringify(emptyBase));
            for (const col of colSet) {
                if (!col.valid) continue;
                const dc = BaseSetCol.find(x => { return x.key === col.key; });
                if (!dc) continue;
                const orgBaseCols = BaseSpreadColSetting[col.key];
                if (!orgBaseCols) continue;

                const baseCols = JSON.parse(JSON.stringify(orgBaseCols));
                if (dc.fixed.indexOf('alias') < 0 && col.alias) {
                    if (baseCols.length === 1) {
                        if (baseCols[0].aliasFormat) {
                            baseCols[0].title = baseCols[0].aliasFormat.replace('{%s}', col.alias);
                            delete baseCols[0].aliasFormat;
                        } else {
                            baseCols[0].title = col.alias;
                        }
                    } else {
                        baseCols.forEach(x => {
                            if (x.aliasFormat) {
                                x.title = x.aliasFormat.replace('{%s}', col.alias);
                                delete x.aliasFormat;
                            }
                        });
                    }
                }
                spreadSetting.cols.push(...baseCols);
            }
            return spreadSetting;
        }

        generateRelaSpread(colSetType, colSet) {
            const baseSetCol = colSetType.indexOf('stage') > 0 ? SpreadConst.BaseSetCol.Stage : SpreadConst.BaseSetCol.Ledger;
            const baseSpreadColSetting = colSetType.indexOf('stage') > 0 ? SpreadConst.BaseSpreadColSetting.Stage : SpreadConst.BaseSpreadColSetting.Ledger;
            const billsSpread = this.generateSpreadSetting(colSet, SpreadConst.EmptySpreadSetting[colSetType].bills, baseSetCol, baseSpreadColSetting.bills);
            const posSpread = this.generateSpreadSetting(colSet, SpreadConst.EmptySpreadSetting[colSetType].pos, baseSetCol, baseSpreadColSetting.pos, 'pos');
            return [billsSpread, posSpread];
        }

        async initProjectSpread(id) {
            const data = JSON.parse(JSON.stringify(SpreadConst.ProjectSpreadTemplate));
            [data.tz_ledger_bills_spread, data.tz_ledger_pos_spread] = this.generateRelaSpread('tz_ledger_set', data.tz_ledger_set);
            [data.tz_stage_bills_spread, data.tz_stage_pos_spread] = this.generateRelaSpread('tz_stage_set', data.tz_stage_set);
            [data.gcl_ledger_bills_spread, data.gcl_ledger_pos_spread] = this.generateRelaSpread('gcl_ledger_set', data.gcl_ledger_set);
            [data.gcl_stage_bills_spread, data.gcl_stage_pos_spread] = this.generateRelaSpread('gcl_stage_set', data.gcl_stage_set);
            data.id = id;
            const updateData = { id };
            JsonFields.forEach(jf => { if (data[jf]) updateData[jf] = JSON.stringify(data[jf]) });
            const result = await this.db.insert(this.tableName, updateData);
            if (result.insertId = data.id) return data;
        }

        async getProjectSpread(id) {
            const curSet = await this.loadProjectSpread(id);
            if (curSet) return curSet;
            return await this.initProjectSpread(id);
        }

        async updateProjectSet(id, colSetType, colSet) {
            const updateData = { id };
            const [billsSpread, posSpread] = this.generateRelaSpread(colSetType, colSet);
            updateData[colSetType.replace('_set', '_bills_spread')] = JSON.stringify(billsSpread);
            updateData[colSetType.replace('_set', '_pos_spread')] = JSON.stringify(posSpread);
            updateData[colSetType] = JSON.stringify(colSet);
            await this.db.update(this.tableName, updateData);
        }
    }

    return ProjectSpread;
};