Calculation/app/service/material.js

'use strict';

/**
 * 期计量 数据模型
 *
 * @author Mai
 * @date 2018/8/13
 * @version
 */

const auditConst = require('../const/audit').material;
const payConst = require('../const/deal_pay.js');
const fs = require('fs');
const path = require('path');

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

        /**
         * 获取 最新一期 材料调差期计量
         * @param tenderId
         * @param includeUnCheck
         * @returns {Promise<*>}
         */
        async getLastestMaterial(tenderId, includeUnCheck = false) {
            this.initSqlBuilder();
            this.sqlBuilder.setAndWhere('tid', {
                value: tenderId,
                operate: '=',
            });
            if (!includeUnCheck) {
                this.sqlBuilder.setAndWhere('status', {
                    value: auditConst.status.uncheck,
                    operate: '!=',
                });
            }
            this.sqlBuilder.orderBy = [['order', 'desc']];
            const [sql, sqlParam] = this.sqlBuilder.build(this.tableName);
            const material = await this.db.queryOne(sql, sqlParam);
            return material;
        }

        /**
         * 获取 最新一期 审批完成的 材料调差期计量
         * @param tenderId
         * @returns {Promise<*>}
         */
        async getLastestCompleteMaterial(tenderId) {
            this.initSqlBuilder();
            this.sqlBuilder.setAndWhere('tid', {
                value: tenderId,
                operate: '=',
            });
            this.sqlBuilder.setAndWhere('status', {
                value: auditConst.status.checked,
                operate: '=',
            });
            this.sqlBuilder.orderBy = [['order', 'desc']];
            const [sql, sqlParam] = this.sqlBuilder.build(this.tableName);
            const material = await this.db.queryOne(sql, sqlParam);
            return material;
        }

        /**
         * 获取标段下的全部计量期，按倒序
         * @param tenderId
         * @returns {Promise<void>}
         */
        async getValidMaterials(tenderId) {
            const materials = await this.db.select(this.tableName, {
                where: { tid: tenderId },
                orders: [['order', 'desc']],
            });
            if (materials.length !== 0) {
                const lastMaterial = materials[materials.length - 1];
                if (lastMaterial.status === auditConst.status.uncheck && lastMaterial.user_id !== this.ctx.session.sessionUser.accountId) {
                    materials.splice(materials.length - 1, 1);
                }
            }
            // 最新一期计量（未审批完成），当前操作人的期详细数据，应实时计算
            if (materials.length > 0 && materials[0].status !== auditConst.status.checked) {
                const material = materials[0];
                const curAuditor = await this.ctx.service.materialAudit.getCurAuditor(material.id, material.times);
                const isActive = curAuditor ? curAuditor.id === this.ctx.session.sessionUser.accountId : material.user_id === this.ctx.session.sessionUser.accountId;
                if (isActive) {
                    material.curTimes = material.times;
                    material.curOrder = curAuditor ? curAuditor.order : 0;
                }
            }
            return materials;
        }

        /**
         * 添加材料调差期
         * @param tenderId - 标段id
         * @param data - post的数据
         * @returns {Promise<void>}
         */
        async addMaterial(tenderId, data) {
            const materials = await this.getAllDataByCondition({
                where: { tid: tenderId },
                order: ['order'],
            });
            const preMaterial = materials[materials.length - 1];
            if (materials.length > 0 && materials[materials.length - 1].status !== auditConst.status.checked) {
                throw '上一期未审批通过，请等待上一期审批通过后，再新增数据';
            }
            const order = materials.length + 1;
            const newMaterial = {
                tid: tenderId,
                order,
                in_time: new Date(),
                times: 1,
                status: auditConst.status.uncheck,
                user_id: this.ctx.session.sessionUser.accountId,
                stage_id: data.stage_id.join(','),
                s_order: data.s_order,
            };
            const transaction = await this.db.beginTransaction();
            try {
                // 新增期记录
                const result = await transaction.insert(this.tableName, newMaterial);
                if (result.affectedRows === 1) {
                    newMaterial.id = result.insertId;
                } else {
                    throw '新增期数据失败';
                }
                // 存在上一期时，复制上一期审批流程
                if (preMaterial) {
                    const auditResult = await this.ctx.service.materialAudit.copyPreMaterialAuditors(transaction, preMaterial, newMaterial);
                    if (!auditResult) {
                        throw '复制上一期审批流程失败';
                    }
                }

                await transaction.commit();
                return newMaterial;
            } catch (err) {
                await transaction.rollback();
                throw err;
            }
        }

        /**
         * 删除材料调差期
         *
         * @param {Number} id - 期Id
         * @returns {Promise<void>}
         */
        async deleteMaterial(id) {
            const transaction = await this.db.beginTransaction();
            try {
                await transaction.delete(this.tableName, { id });
                await transaction.delete(this.ctx.service.materialAudit.tableName, { mid: id });
                await transaction.commit();
                return true;
            } catch (err) {
                await transaction.rollback();
                throw err;
            }
        }
    }

    return Material;
};