Calculation/app/service/payment_detail.js

'use strict';
const auditConst = require('../const/audit').stage;
module.exports = app => {
    class PaymentDetail extends app.BaseService {
        constructor(ctx) {
            super(ctx);
            this.tableName = 'payment_detail';
        }

        async getValidDetails(tr_id) {
            const details = await this.db.select(this.tableName, {
                column: ['id', 'in_time', 'tr_id', 'uid', 'status', 'order', 'times', 'code', 's_time'],
                where: { tr_id },
                orders: [['order', 'desc']],
            });
            if (details.length !== 0) {
                const lastDetail = details[details.length - 1];
                if (lastDetail.status === auditConst.status.uncheck && lastDetail.uid !== this.ctx.session.sessionUser.accountId) {
                    details.splice(details.length - 1, 1);
                }
            }
            // 最新一期计量（未审批完成），当前操作人的期详细数据，应实时计算
            if (details.length > 0 && details[0].status !== auditConst.status.checked) {
                const detail = details[0];
                const curAuditor = await this.ctx.service.paymentDetailAudit.getCurAuditor(detail.id, detail.times);
                const isActive = curAuditor ? curAuditor.id === this.ctx.session.sessionUser.accountId : detail.uid === this.ctx.session.sessionUser.accountId;
                if (isActive) {
                    detail.curTimes = detail.times;
                    detail.curOrder = curAuditor ? curAuditor.order : 0;
                }
            }
            return details;
        }

        async hadDetail(trId) {
            const result = await this.count({ tr_id: trId });
            return result !== 0;
        }

        async addDetail(trInfo, code, s_time) {
            const transaction = await this.db.beginTransaction();
            try {
                if (!(trInfo.is_del === 0 && trInfo.rpt_audit)) {
                    throw '报表已删除或表单人员数据有误，无法新建';
                }
                const details = await this.getAllDataByCondition({
                    where: { tr_id: trInfo.id },
                    order: ['order'],
                });
                const preDetail = details[details.length - 1];
                if (details.length > 0 && details[details.length - 1].status !== auditConst.status.checked) {
                    throw '上一期未审批通过，请等待上一期审批通过后，再新增';
                }

                trInfo.rpt_audit = JSON.parse(trInfo.rpt_audit);
                if (this._.findIndex(trInfo.rpt_audit, { uid: null }) !== -1) {
                    throw '未配置好表单角色，无法新建';
                }
                const rptTpl = await this.ctx.service.rptTpl.getDataById(trInfo.rpt_id);
                const pageRst = this.ctx.service.jpcReport.getAllPreviewPagesCommon(rptTpl, 'A4');
                const order = details.length + 1;
                const newDetail = {
                    tender_id: this.ctx.tender.id,
                    tr_id: trInfo.id,
                    order,
                    times: 1,
                    status: auditConst.status.uncheck,
                    uid: this.ctx.session.sessionUser.accountId,
                    s_time,
                    code,
                    report_json: JSON.stringify(pageRst),
                    in_time: new Date(),
                };
                const result = await transaction.insert(this.tableName, newDetail);
                if (result.affectedRows === 1) {
                    newDetail.id = result.insertId;
                } else {
                    throw '新增支付审批数据失败';
                }
                // 报表角色创建
                const insertRptAudit = [];
                for (const [i, r] of trInfo.rpt_audit.entries()) {
                    insertRptAudit.push({
                        tender_id: this.ctx.tender.id,
                        tr_id: trInfo.id,
                        td_id: newDetail.id,
                        uid: r.uid,
                        signature_index: i,
                        signature_name: r.rpt_name,
                        in_time: new Date(),
                    });
                }
                if (insertRptAudit.length > 0) await transaction.insert(this.ctx.service.paymentRptAudit.tableName, insertRptAudit);
                // 存在上一期时，复制上一期审批流程
                if (preDetail) {
                    const auditResult = await this.ctx.service.paymentDetailAudit.copyPreDetailAuditors(transaction, preDetail, newDetail);
                    if (!auditResult) {
                        throw '复制上一期审批流程失败';
                    }
                }
                // 更新is_change值
                await transaction.update(this.ctx.service.paymentTenderRpt.tableName, { id: trInfo.id, is_change: 0 });
                await transaction.commit();
                return newDetail;
            } catch (err) {
                await transaction.rollback();
                throw err;
            }
        }

        async updateReportJson(id, report_json) {
            return await this.db.update(this.tableName, { id, report_json: JSON.stringify(report_json) });
        }

        async signOneSignatureData(report_json, signature_name, sign_msg) {
            // 签名签章
            const signCells = this._.find(report_json.items[0].signature_cells, { signature_name });
            if (signCells && (sign_msg.sign_path || sign_msg.company_stamp || sign_msg.stamp_path)) {
                const signArray = [];
                if (sign_msg.sign_path) signArray.push('/public/upload/sign/' + sign_msg.sign_path);
                if (sign_msg.company_stamp) signArray.push(sign_msg.company_stamp);
                if (sign_msg.stamp_path) signArray.push(sign_msg.stamp_path);
                signCells.path = signArray.join('!;!');
            }
            // 日期
            const dateCells = this._.find(report_json.items[0].signature_date_cells, { signature_name: signature_name + '_签字日期' });
            if (dateCells && sign_msg.date) {
                dateCells.Value = sign_msg.date;
            }
            // 意见
            const contentCells = this._.find(report_json.items[0].signature_audit_cells, { signature_name: signature_name + '_审核意见' });
            if (contentCells && sign_msg.content) {
                contentCells.Value = sign_msg.content;
            }
            return report_json;
        }

        async clearOneSignatureData(report_json, rptAudit) {
            // 签名签章
            const signCells = this._.find(report_json.items[0].signature_cells, { signature_name: rptAudit.signature_name });
            if (signCells) {
                signCells.path = null;
            }
            // 日期
            const dateCells = this._.find(report_json.items[0].signature_date_cells, { signature_name: rptAudit.signature_name + '_签字日期' });
            if (dateCells) {
                dateCells.Value = '';
            }
            // 意见
            const contentCells = this._.find(report_json.items[0].signature_audit_cells, { signature_name: rptAudit.signature_name + '_审核意见' });
            if (contentCells) {
                contentCells.Value = '';
            }
            return report_json;
        }

        async clearAllSignatureData(report_json) {
            if (report_json.items[0].signature_cells.length > 0) {
                for (const cell of report_json.items[0].signature_cells) {
                    cell.path = null;
                }
            }
            if (report_json.items[0].signature_audit_cells.length > 0) {
                for (const cell of report_json.items[0].signature_audit_cells) {
                    cell.Value = '';
                }
            }
            if (report_json.items[0].signature_date_cells.length > 0) {
                for (const cell of report_json.items[0].signature_date_cells) {
                    cell.Value = '';
                }
            }
            return report_json;
        }

        /**
         * 删除报表表单详情
         *
         * @param {Number} id - 期Id
         * @return {Promise<void>}
         */
        async deleteDetail(id) {
            const transaction = await this.db.beginTransaction();
            try {
                await transaction.delete(this.ctx.service.paymentDetailAudit.tableName, { td_id: id });
                await transaction.delete(this.ctx.service.paymentRptAudit.tableName, { td_id: id });
                await transaction.delete(this.tableName, { id });
                await transaction.commit();
                return true;
            } catch (err) {
                await transaction.rollback();
                throw err;
            }
        }

        async haveNotice2Tender(tid, uid) {
            const sql = 'SELECT count(pd.`id`) as count FROM ?? as pd LEFT JOIN ?? as pda' +
                ' ON pd.`id` = pda.`td_id` WHERE pd.`tender_id` = ? AND (pd.`uid` = ? AND (pd.`status` = ? OR pd.`status` = ?))' +
                ' OR ((pd.`status` = ? OR pd.`status` = ?) AND pda.aid = ? AND pda.`status` = ?)';
            const params = [this.tableName, this.ctx.service.paymentDetailAudit.tableName, tid,
                uid, auditConst.status.uncheck, auditConst.status.checkNo,
                auditConst.status.checking, auditConst.status.checkNoPre, uid, auditConst.status.checking];
            const result = await this.db.queryOne(sql, params);
            return result ? result.count : 0;
        }

        async haveNotice2TenderRpt(tr_id, uid) {
            const sql = 'SELECT count(pd.`id`) as count FROM ?? as pd LEFT JOIN ?? as pda' +
                ' ON pd.`id` = pda.`td_id` WHERE pd.`tr_id` = ? AND ((pd.`uid` = ? AND (pd.`status` = ? OR pd.`status` = ?))' +
                ' OR ((pd.`status` = ? OR pd.`status` = ?) AND pda.aid = ? AND pda.`status` = ?))';
            const params = [this.tableName, this.ctx.service.paymentDetailAudit.tableName, tr_id,
                uid, auditConst.status.uncheck, auditConst.status.checkNo,
                auditConst.status.checking, auditConst.status.checkNoPre, uid, auditConst.status.checking];
            const result = await this.db.queryOne(sql, params);
            return result ? result.count : 0;
        }

        async haveDetail2Tender(tid) {
            return this.count({ tender_id: tid });
        }
    }
    return PaymentDetail;
};