Calculation/app/controller/ctrl_price_controller.js

'use strict';

/**
 *
 *
 * @author Mai
 * @date 2021/10/27
 * @version
 */
const stdDataAddType = {
    withParent: 1,
    child: 2,
    next: 3,
};
const LzString = require('lz-string');
module.exports = app => {
    class CtrlPriceController extends app.BaseController {

        _getSpreadSetting() {
            const spreadSetting = {
                cols: [
                    {title: '项目节编号', colSpan: '1', rowSpan: '2', field: 'code', hAlign: 0, width: 180, formatter: '@', cellType: 'tree'},
                    {title: '清单编号', colSpan: '1', rowSpan: '2', field: 'b_code', hAlign: 0, width: 120, formatter: '@'},
                    {title: '名称', colSpan: '1', rowSpan: '2', field: 'name', hAlign: 0, width: 230, formatter: '@'},
                    {title: '单位', colSpan: '1', rowSpan: '2', field: 'unit', hAlign: 1, width: 50, formatter: '@', cellType: 'unit', comboEdit: true},
                    {title: '设计数量|数量1', colSpan: '2|1', rowSpan: '1|1', field: 'dgn_qty1', hAlign: 2, width: 80, type: 'Number'},
                    {title: '|数量2', colSpan: '|1', rowSpan: '|1', field: 'dgn_qty2', hAlign: 2, width: 80, type: 'Number'},
                    {title: '经济指标', colSpan: '1', rowSpan: '2', field: 'dgn_price', hAlign: 2, width: 80, type: 'Number', readOnly: true},
                    {title: '清单数量', colSpan: '1', rowSpan: '2', field: 'quantity', hAlign: 2, width: 80, type: 'Number'},
                    {title: '单价', colSpan: '1', rowSpan: '2', field: 'unit_price', hAlign: 2, width: 80, type: 'Number'},
                    {title: '金额', colSpan: '1', rowSpan: '2', field: 'total_price', hAlign: 2, width: 80, type: 'Number'},
                    {title: '图册号', colSpan: '1', rowSpan: '2', field: 'drawing_code', hAlign: 0, width: 100, formatter: '@'},
                    {title: '备注', colSpan: '1', rowSpan: '2', field: 'memo', hAlign: 0, width: 100, formatter: '@'},
                ],
                emptyRows: 3,
                headRows: 2,
                headRowHeight: [25, 25],
                defaultRowHeight: 21,
                headerFont: '12px 微软雅黑',
                font: '12px 微软雅黑',
                localCache: { key: 'budget', colWidth: true },
            };
            return spreadSetting;
        }

        async index(ctx) {
            try {
                await this.ctx.service.controlPrice.checkInit(ctx.tender);
                const [stdBills, stdChapters] = await this.ctx.service.valuation.getValuationStdList(
                    ctx.tender.data.valuation, ctx.tender.data.measure_type);

                const renderData = {
                    spreadSetting: this._getSpreadSetting(),
                    jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.tender.ctrlPrice),
                    stdBills,
                    stdChapters,
                };
                await this.layout('tender/ctrl_price.ejs', renderData, 'tender/ctrl_price_modal.ejs');
            } catch (err) {
                ctx.log(err);
            }
        }

        async load(ctx) {
            try {
                ctx.body = {
                    err: 0, msg: '',
                    data: await this.ctx.service.controlPrice.getData(ctx.tender.id),
                }
            } catch (err) {
                ctx.log(err);
                ctx.ajaxErrorBody(err, '获取数据错误');
            }
        }

        _checkCanUpdate(ctx) {
            if (ctx.tender.isTourist) throw '您无权修改数据';
        }

        async _billsBase(relaService, type, data) {
            if (isNaN(data.id) || data.id <= 0) throw '数据错误';
            if (type !== 'add') {
                if (isNaN(data.count) || data.count <= 0) data.count = 1;
            }
            switch (type) {
                case 'add':
                    return await relaService.addNodeBatch(this.ctx.tender.id, data.id, {}, data.count);
                case 'delete':
                    return await relaService.delete(this.ctx.tender.id, data.id, data.count);
                case 'up-move':
                    return await relaService.upMoveNode(this.ctx.tender.id, data.id, data.count);
                case 'down-move':
                    return await relaService.downMoveNode(this.ctx.tender.id, data.id, data.count);
                case 'up-level':
                    return await relaService.upLevelNode(this.ctx.tender.id, data.id, data.count);
                case 'down-level':
                    return await relaService.downLevelNode(this.ctx.tender.id, data.id, data.count);
            }
        }
        async _addStd(relaService, data) {
            if ((isNaN(data.id) || data.id <= 0) || !data.stdType || !data.stdNode) throw '参数错误';

            let stdLib, addType;
            switch (data.stdType) {
                case 'xmj':
                    stdLib = this.ctx.service.stdXmj;
                    addType = stdDataAddType.withParent;
                    break;
                case 'gcl':
                    stdLib = this.ctx.service.stdGcl;
                    const selectNode = await relaService.getDataByKid(this.ctx.tender.id, data.id);
                    addType = selectNode.b_code ? stdDataAddType.next : stdDataAddType.child;
                    break;
                default:
                    throw '未知标准库';
            }
            const stdData = await stdLib.getDataByDataId(data.stdLibId, data.stdNode);
            switch (addType) {
                case stdDataAddType.child:
                    return await relaService.addStdNodeAsChild(this.ctx.tender.id, data.id, stdData);
                case stdDataAddType.next:
                    return await relaService.addStdNode(this.ctx.tender.id, data.id, stdData);
                case stdDataAddType.withParent:
                    return await relaService.addStdNodeWithParent(this.ctx.tender.id, stdData, stdLib);
                default:
                    throw '未知添加方式';
            }
        }
        async _pasteBlock(relaService, data) {
            if ((isNaN(data.id) || data.id <= 0) ||
                (!data.tid && data.tid <= 0) ||
                (!data.block || data.block.length <= 0)) throw '参数错误';
            return await relaService.pasteBlockData(this.ctx.tender.id, data.id, data.block);
        }
        async update(ctx) {
            try {
                if (!ctx.tender) throw '项目数据错误';
                this._checkCanUpdate(ctx);

                const relaService = this.ctx.service.controlPrice;
                const data = JSON.parse(ctx.request.body.data);
                if (!data.postType || !data.postData) throw '数据错误';
                const responseData = { err: 0, msg: '', data: {} };

                switch (data.postType) {
                    case 'add':
                    case 'delete':
                    case 'up-move':
                    case 'down-move':
                    case 'up-level':
                    case 'down-level':
                        responseData.data = await this._billsBase(relaService, data.postType, data.postData);
                        break;
                    case 'update':
                        ctx.helper.checkDgnQtyPrecision(data.postData);
                        responseData.data = await relaService.updateCalc(ctx.tender.id, data.postData);
                        break;
                    case 'add-std':
                        responseData.data = await this._addStd(relaService, data.postData);
                        break;
                    case 'paste-block':
                        responseData.data = await this._pasteBlock(relaService, data.postData);
                        break;
                    default:
                        throw '未知操作';
                }
                ctx.body = responseData;
            } catch (err) {
                this.log(err);
                ctx.body = this.ajaxErrorBody(err, '数据错误');
            }
        }

        async uploadExcel(ctx) {
            try {
                if (!ctx.tender) throw '项目数据错误';
                this._checkCanUpdate(ctx);

                const ueType = ctx.params.ueType;
                const compressData = ctx.request.body.data;
                const data = JSON.parse(LzString.decompressFromUTF16(compressData));
                const responseData = { err: 0, msg: '', data: {} };
                switch (ueType) {
                    case 'tz':
                        const templateId = await this.ctx.service.valuation.getValuationTemplate(
                            this.ctx.tender.data.valuation, this.ctx.tender.data.measure_type);
                        responseData.data = await this.ctx.service.controlPrice.importExcel(templateId, data.sheet, data.filter);
                        break;
                    case 'gcl2xmj':
                        responseData.data = await this.ctx.service.controlPrice.importGclExcel(data.id, data.sheet);
                        break;
                    default:
                        throw '数据错误';
                }
                ctx.body = responseData;
            } catch (err) {
                this.log(err);
                ctx.body = { err: 1, msg: err.toString(), data: null };
            }
        }
    }

    return CtrlPriceController;
};