Calculation/app/service/change_plan_list.js

'use strict';

/**
 *
 *
 * @author Mai
 * @date 2018/8/14
 * @version
 */

const audit = require('../const/audit');

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

        /**
         * 取出变更令清单列表，并按台账清单在前，空白清单在后排序
         * @return {void}
         */
        async getList(cpid) {
            const sql = 'SELECT * FROM ?? WHERE `cpid` = ? ORDER BY `id` asc';
            const sqlParam = [this.tableName, cpid];
            return await this.db.query(sql, sqlParam);
        }

        /**
         * 添加空白变更清单
         * @return {void}
         */
        async add(data) {
            if (!this.ctx.tender || !this.ctx.change) {
                throw '数据错误';
            }
            const insertData = {
                tid: this.ctx.tender.id,
                cpid: this.ctx.change.id,
            };
            const newData = this._.assign(insertData, data);
            // 新增工料
            const result = await this.db.insert(this.tableName, newData);
            if (result.affectedRows === 0) {
                throw '新增空白清单数据失败';
            }
            return await this.getDataById(result.insertId);
        }

        /**
         * 批量添加空白变更清单
         * @return {void}
         */
        async batchAdd(data) {
            if (!this.ctx.tender || !this.ctx.change) {
                throw '数据错误';
            }
            const num = data.num ? parseInt(data.num) : 0;
            if (num < 1 || num > 100) {
                throw '批量添加的空白清单数目不能小于1或大于100';
            }
            const insertArray = [];
            for (let i = 0; i < num; i++) {
                const insertData = {
                    tid: this.ctx.tender.id,
                    cpid: this.ctx.change.id,
                };
                insertArray.push(insertData);
            }
            // 新增工料
            const result = await this.db.insert(this.tableName, insertArray);
            if (result.affectedRows !== num) {
                throw '批量添加空白清单数据失败';
            }
            // 获取刚批量添加的所有list
            for (let j = 0; j < num; j++) {
                insertArray[j].id = result.insertId + j;
            }
            return insertArray;
        }

        /**
         * 删除变更清单
         * @param {int} id 清单id
         * @return {void}
         */
        async del(id) {
            if (!this.ctx.tender || !this.ctx.change) {
                throw '数据错误';
            }
            const transaction = await this.db.beginTransaction();
            try {
                // 判断是否可删
                await transaction.delete(this.tableName, { id });
                // 重新算变更令总额
                await this.calcCamountSum(transaction);
                await transaction.commit();
                return true;
            } catch (err) {
                await transaction.rollback();
                throw err;
            }
        }

        /**
         * 修改变更清单
         * @param {Object} data 工料内容
         * @param {int} order 期数
         * @return {void}
         */
        async save(data, order) {
            if (!this.ctx.tender || !this.ctx.change) {
                throw '数据错误';
            }

            const transaction = await this.db.beginTransaction();
            try {
                // const mb_id = data.mb_id;
                // delete data.mb_id;
                await transaction.update(this.tableName, data);
                // await this.calcQuantityByML(transaction, mb_id);
                await this.calcCamountSum(transaction);
                await transaction.commit();
                return true;
            } catch (err) {
                await transaction.rollback();
                throw err;
            }
        }

        /**
         * 修改变更清单 复制粘贴
         * @param {Object} datas 修改内容
         * @return {void}
         */
        async saveDatas(datas) {
            if (!this.ctx.tender || !this.ctx.change) {
                throw '数据错误';
            }
            // 判断是否可修改
            // 判断t_type是否为费用
            const transaction = await this.db.beginTransaction();
            try {
                // for (const data of datas) {
                //     const mb_id = data.mb_id;
                //     delete data.mb_id;
                //     await transaction.update(this.tableName, data);
                //     await this.calcQuantityByML(transaction, mb_id);
                // }
                await transaction.updateRows(this.tableName, datas);
                await this.calcCamountSum(transaction);
                await transaction.commit();
                return true;
            } catch (err) {
                await transaction.rollback();
                throw err;
            }
        }

        async calcCamountSum(transaction, updateTpDecimal = false) {
            // const sql = 'SELECT SUM(ROUND(`camount`*`unit_price`, )) as total_price FROM ?? WHERE cid = ?';
            // const sqlParam = [this.tableName, this.change.cid];
            // const tp = await transaction.queryOne(sql, sqlParam);
            // 防止小数位不精确，采用取值计算
            const sql = 'SELECT unit_price, spamount FROM ?? WHERE cpid = ?';
            const sqlParam = [this.tableName, this.ctx.change.id];
            const changeList = await transaction.query(sql, sqlParam);
            let total_price = 0;
            const tp_decimal = this.ctx.tender.info.decimal.tp;
            for (const cl of changeList) {
                total_price = this.ctx.helper.accAdd(total_price, this.ctx.helper.mul(cl.unit_price, cl.spamount, tp_decimal));
            }
            const updateData = {
                total_price,
            };
            // if (updateTpDecimal) {
            //     updateData.tp_decimal = tp_decimal;
            // }
            const options = {
                where: {
                    id: this.ctx.change.id,
                },
            };
            await transaction.update(this.ctx.service.changePlan.tableName, updateData, options);
        }

        /**
         * 用户数据数量提交
         * @param {Object} data 内容
         * @return {void}
         */
        async saveAmountData(data) {
            if (!this.ctx.tender || !this.ctx.change) {
                throw '数据错误';
            }
            // 判断是否可修改
            // 判断t_type是否为费用
            const transaction = await this.db.beginTransaction();
            try {
                await transaction.update(this.tableName, data);
                await this.calcCamountSum(transaction);
                await transaction.commit();
                return true;
            } catch (err) {
                await transaction.rollback();
                throw err;
            }
        }
    }

    return ChangePlanList;
};