'use strict'; /** * * * @author Mai * @date * @version */ const audit = require('../const/audit').common; const calcBase = [ {name: '签约合同价', code: 'htj', sort: 10}, {name: '暂列金额', code: 'zlje', sort: 2}, {name: '签约合同价(不含暂列金)', code: 'htjszl', sort: 1}, {name: '签约开工预付款', code: 'kgyfk', sort: 2}, {name: '签约材料预付款', code: 'clyfk', sort: 2}, {name: '本期完成计量', code: 'bqwc', limit: true, sort: 10, checkStart: 'gather_tp'}, {name: '本期合同计量', code: 'bqht', limit: true, sort: 10, checkStart: 'contract_tp'}, {name: '本期变更计量', code: 'bqbg', limit: true, sort: 10}, {name: '本期清单完成计量', code: 'bqqdwc', limit: true, sort: 10}, {name: '本期清单合同计量', code: 'bqqdht', limit: true, sort: 10}, {name: '本期清单变更计量', code: 'bqqdbg', limit: true, sort: 10}, {name: '本期一般变更计量', code: 'ybbqbg', limit: true, sort: 5}, {name: '本期较大变更计量', code: 'jdbqbg', limit: true, sort: 5}, {name: '本期重大变更计量', code: 'zdbqbg', limit: true, sort: 5}, {name: '100章本期完成计量', code: 'ybbqwc', limit: true, sort: 1}, {name: '本期应付', code: 'bqyf', limit: true, ptNormalLimit: true, sort: 20}, {name: '奖金', code: 'bonus', limit: true, sort: 1}, {name: '罚金', code: 'fine', limit: true, sort: 1}, {name: '甲供材料', code: 'jgcl', limit: true, sort: 1}, ]; module.exports = app => { class PhasePay extends app.BaseService { /** * 构造函数 * * @param {Object} ctx - egg全局变量 * @return {void} */ constructor(ctx) { super(ctx); this.tableName = 'phase_pay'; } analysisPhasePay(data) { if (!data) return; const datas = data instanceof Array ? data : [data]; datas.forEach(x => { x.rela_stage = x.rela_stage ? JSON.parse(x.rela_stage) : []; x.calc_base = x.calc_base ? JSON.parse(x.calc_base) : []; }); } calculatePhasePay(data) { const helper = this.ctx.helper; const datas = data instanceof Array ? data : [data]; const formatNum = this.ctx.tender.info.display.thousandth ? this.ctx.helper.formatNum : function(num) { return num ? num + '' : ''; }; datas.forEach(x => { x.end_calc_tp = helper.add(x.calc_tp, x.pre_calc_tp); x.end_pay_tp = helper.add(x.pay_tp, x.pre_pay_tp); x.end_cut_tp = helper.add(x.cut_tp, x.pre_cut_tp); x.end_sf_tp = helper.add(x.sf_tp, x.pre_sf_tp); x.end_yf_tp = helper.add(x.yf_tp, x.pre_yf_tp); for (const prop in x) { if (prop.indexOf('_tp') > 0) { x['display_' + prop] = formatNum(x[prop]); } } }); } /** * 获取全部修订 * @param tid * @returns {Promise<*>} */ async getAllPhasePay (tid, sort = 'ASC') { const result = await this.getAllDataByCondition({ where: {tid: tid}, orders: [['phase_order', sort]], }); this.analysisPhasePay(result); return result; } async getPhasePay(id) { const result = await this.getDataById(id); this.analysisPhasePay(result); return result; } async getPhasePayByOrder(tid, phaseOrder) { const result = await this.getDataByCondition({ tid, phase_order: phaseOrder }); this.analysisPhasePay(result); return result; } async getMaxOrder(tid) { const sql = 'SELECT Max(`phase_order`) As max_order FROM ' + this.tableName + ' Where `tid` = ?'; const sqlParam = [tid]; const result = await this.db.queryOne(sql, sqlParam); return result.max_order || 0; } async _checkRelaStageConflict(relaStage, phasePay) { const pays = await this.getAllPhasePay(phasePay.tid); for (const p of pays) { if (p.id === phasePay.id) continue; for (const s of relaStage) { if (p.rela_stage.find(x => { return x.id === s.id; })) return true; } } return false; } async getCalcBase(relaStage, prePhase) { const result = {}; for (const stage of relaStage) { result.contract_tp = this.ctx.helper.add(result.contract_tp, stage.contract_tp); result.qc_tp = this.ctx.helper.add(result.contract_tp, stage.qc_tp); result.pc_tp = this.ctx.helper.add(result.pc_tp, stage.pc_tp); const qdSum = await this.ctx.service.stageBills.getSumTotalPriceGcl(stage); result.qd_contract_tp = qdSum.contract_tp || 0; result.qd_qc_tp = qdSum.qc_tp || 0; result.qd_pc_tp = qdSum.pc_tp || 0; const sumGcl = await this.ctx.service.stageBills.getSumTotalPriceGcl(stage, '^[^0-9]*1[0-9]{2}(-|$)'); const sumPc = await this.ctx.service.stageBillsPc.getSumTotalPriceGcl(stage, '^[^0-9]*1[0-9]{2}(-|$)'); result.gather_100_tp = this.ctx.helper.sum([sumGcl.contract_tp, sumGcl.qc_tp, sumPc.pc_tp]); const bg = await this.ctx.service.stage.getChangeSubtotal(stage); result.common_bg_tp = bg.common || 0; result.more_bg_tp = bg.more || 0; result.great_bg_tp = bg.great || 0; } result.gather_tp = this.ctx.helper.sum([result.contract_tp, result.qc_tp, result.pc_tp]) || 0; result.qd_gather_tp = this.ctx.helper.sum([result.qd_contract_tp, result.qd_qc_tp, result.qd_pc_tp]) || 0; const bonusSum = await this.ctx.service.stageBonus.getSumTp(relaStage); result.bonus_positive_tp = bonusSum.positive_tp || 0; result.bonus_negative_tp = bonusSum.negative_tp || 0; result.bonus_tp = bonusSum.sum_tp || 0; const jgclSum = await this.ctx.service.stageJgcl.getSumTp(relaStage); result.jgcl_tp = jgclSum.sum_tp || 0; const otherSum = await this.ctx.service.stageOther.getSumTp(relaStage); result.other_tp = otherSum.sum_tp || 0; const safeProdSum = await this.ctx.service.stageSafeProd.getSumTp(relaStage); result.safe_prod_tp = safeProdSum.sum_tp || 0; const tempLandSum = await this.ctx.service.stageTempLand.getSumTp(relaStage); result.temp_land_tp = tempLandSum.sum_tp || 0; if (prePhase && prePhase.calc_base) { result.pre_contract_tp = this.ctx.helper.add(prePhase.calc_base.contract_tp, prePhase.calc_base.pre_contract_tp); result.pre_qc_tp = this.ctx.helper.add(prePhase.calc_base.qc_tp, prePhase.calc_base.pre_qc_tp); result.pre_pc_tp = this.ctx.helper.add(prePhase.calc_base.pc_tp, prePhase.calc_base.pre_pc_tp); result.pre_gather_tp = this.ctx.helper.add(prePhase.calc_base.gather_tp, prePhase.calc_base.pre_gather_tp); result.pre_qd_contract_tp = this.ctx.helper.add(prePhase.calc_base.qd_contract_tp, prePhase.calc_base.pre_qd_contract_tp); result.pre_qd_qc_tp = this.ctx.helper.add(prePhase.calc_base.qd_qc_tp, prePhase.calc_base.pre_qd_qc_tp); result.pre_qd_pc_tp = this.ctx.helper.add(prePhase.calc_base.qd_pc_tp, prePhase.calc_base.pre_qd_pc_tp); result.pre_qd_gather_tp = this.ctx.helper.add(prePhase.calc_base.qd_gather_tp, prePhase.calc_base.pre_qd_gather_tp); result.pre_bonus_positive_tp = this.ctx.helper.add(prePhase.calc_base.bonus_positive_tp, prePhase.calc_base.pre_bonus_positive_tp); result.pre_bonus_negative_tp = this.ctx.helper.add(prePhase.calc_base.bonus_negative_tp, prePhase.calc_base.pre_bonus_negative_tp); result.pre_bonus_tp = this.ctx.helper.add(prePhase.calc_base.bonus_tp, prePhase.calc_base.pre_bonus_tp); result.pre_jgcl_tp = this.ctx.helper.add(prePhase.calc_base.jgcl_tp, prePhase.calc_base.pre_jgcl_tp); result.pre_other_tp = this.ctx.helper.add(prePhase.calc_base.other_tp, prePhase.calc_base.pre_other_tp); result.pre_safe_prod_tp = this.ctx.helper.add(prePhase.calc_base.safe_prod_tp, prePhase.calc_base.pre_safe_prod_tp); result.pre_temp_land_tp = this.ctx.helper.add(prePhase.calc_base.temp_land_tp, prePhase.calc_base.pre_temp_land_tp); } return result; } /** * 获取 当期的 计算基数 * @return {Promise} */ getPhasePayCalcBase(phasePay, tenderInfo) { const payCalcBase = JSON.parse(JSON.stringify(calcBase)); for (const cb of payCalcBase) { switch (cb.code) { case 'htj': cb.value = tenderInfo.deal_param.contractPrice; break; case 'zlje': cb.value = tenderInfo.deal_param.zanLiePrice; break; case 'htjszl': cb.value = this.ctx.helper.sub(tenderInfo.deal_param.contractPrice, tenderInfo.deal_param.zanLiePrice); break; case 'kgyfk': cb.value = tenderInfo.deal_param.startAdvance; break; case 'clyfk': cb.value = tenderInfo.deal_param.materialAdvance; break; case 'bqwc': cb.value = phasePay.calc_base.gather_tp; break; case 'bqht': cb.value = phasePay.calc_base.contract_tp; break; case 'bqbg': cb.value = phasePay.calc_base.qc_tp; break; case 'bqqdwc': cb.value = phasePay.calc_base.qd_gather_tp; break; case 'bqqdht': cb.value = phasePay.calc_base.qd_contract_tp; break; case 'bqqdbg': cb.value = phasePay.calc_base.qd_qc_tp; break; case 'ybbqwc': cb.value = phasePay.calc_base.gather_100_tp; break; case 'ybbqbg': cb.value = phasePay.calc_base.common_bg_tp; break; case 'jdbqbg': cb.value = phasePay.calc_base.more_bg_tp; break; case 'zdbqbg': cb.value = phasePay.calc_base.great_bg_tp; break; case 'bonus': cb.value = phasePay.calc_base.bonus_positive_tp; break; case 'fine': cb.value = phasePay.calc_base.bonus_negative_tp; break; case 'jgcl': cb.value = phasePay.calc_base.jgcl_tp; break; case 'aqsc': cb.value = phasePay.calc_base.safe_prod_tp; break; case 'lsyd': cb.value = phasePay.calc_base.temp_land_tp; break; default: cb.value = 0; } } return payCalcBase; } async add(tid, relaStage, phaseDate, memo) { if (!tid) throw '数据错误'; const user_id = this.ctx.session.sessionUser.accountId; const maxOrder = await this.getMaxOrder(); const data = { id: this.uuid.v4(), tid: tid, create_user_id: user_id, update_user_id: user_id, phase_order: maxOrder + 1, phase_date: phaseDate, memo, audit_times: 1, audit_status: audit.status.uncheck, rela_stage: JSON.stringify(relaStage.map(s => { return {stage_id: s.id, stage_order: s.order}; })), }; if (await this._checkRelaStageConflict(relaStage, data)) throw '选择的计量期，已被调用，请刷新页面后选择计量期新增合同支付'; const prePhase = maxOrder > 0 ? await this.getPhasePayByOrder(tid, maxOrder) : null; const calcBase = await this.getCalcBase(relaStage, prePhase); data.calc_base = JSON.stringify(calcBase); const transaction = await this.db.beginTransaction(); try { const result = await transaction.insert(this.tableName, data); if (result.affectedRows !== 1) throw '新增合同支付失败'; await this.ctx.service.phasePayDetail.initPhaseData(transaction, data); await transaction.commit(); return data; } catch(err) { await transaction.rollback(); throw err; } } async refreshCalcBase(phasePay) { const prePhase = phasePay.phase_order > 1 ? await this.getPhasePayByOrder(phasePay.tid, phasePay.phase_order - 1) : null; const relaStage = await this.ctx.service.stage.getAllDataByCondition({ where: { tid: phasePay.tid, order: phasePay.rela_stage.map(x => { return x.stage_order; }) } }); const calcBase = await this.getCalcBase(relaStage, prePhase); const conn = await this.db.beginTransaction(); try { await conn.update(this.tableName, { id: phasePay.id, update_user_id: this.ctx.session.sessionUser.accountId, calc_base: JSON.stringify(calcBase), calc_base_time: new Date() }); phasePay.calc_base = calcBase; await this.ctx.service.phasePayDetail.calculateSave(phasePay, conn); await conn.commit(); } catch(err) { await conn.rollback(); throw err; } } async resetRelaStageId(phasePay, relaStage) { if (await this._checkRelaStageConflict(relaStage, phasePay)) throw '选择的计量期，已被调用，请刷新页面后选择计量期新增合同支付'; const prePhase = prePhase.phase_order > 1 ? await this.getPhasePayByOrder(phasePay.tid, phasePay.phase_order - 1) : null; const calcBase = await this.getCalcBase(relaStage, prePhase); const rela_stage = relaStage.map(s => { return {stage_id: s.id, stage_order: s.order}; }); const conn = await this.db.beginTransaction(); try { await conn.update(this.tableName, { id: phasePay.id, update_user_id: this.ctx.session.sessionUser.accountId, calc_base: JSON.stringify(calcBase), rela_stage: JSON.stringify(rela_stage), calc_base_time: new Date() }); phasePay.calc_base = calcBase; phasePay.rela_stage = relaStage; await this.ctx.service.phasePayDetail.calculateSave(phasePay, conn); await conn.commit(); } catch(err) { await conn.rollback(); throw err; } } async loadUser(phasePay) { phasePay.user = await this.ctx.service.projectAccount.getAccountInfoById(phasePay.create_user_id); phasePay.auditors = []; phasePay.curAuditors = phasePay.auditors.filter(x => { return x.audit_status === audit.status.checking; }); phasePay.curAuditorIds = phasePay.curAuditors.map(x => { return x.audit_id; }); phasePay.flowAuditors = phasePay.curAuditors.length === 0 ? [] : phasePay.auditors.filter(x => { return x.audit_sort === phasePay.curAuditors[0].audit_sort; }); phasePay.flowAuditorIds = phasePay.curAuditors.map(x => { return x.audit_id; }); phasePay.nextAuditors = phasePay.curAuditors.length > 0 ? phasePay.auditors.filter(x => { return x.audit_sort === phasePay.curAuditors[0].audit_sort + 1; }) : []; phasePay.nextAuditorIds = this._.map(phasePay.nextAuditors, 'audit_id'); phasePay.auditorGroups = this.ctx.helper.groupAuditors(phasePay.auditors, 'audit_sort'); phasePay.userGroups = this.ctx.helper.groupAuditorsUniq(phasePay.auditorGroups, 'audit_order'); phasePay.finalAuditorIds = phasePay.userGroups.length > 1 ? phasePay.userGroups[phasePay.userGroups.length - 1].map(x => { return x.audit_id; }) : []; } async doCheckPhase(phasePay) { await this.loadUser(phasePay); const accountId = this.ctx.session.sessionUser.accountId; if (phasePay.audit_status === audit.status.uncheck) { phasePay.readOnly = accountId !== phasePay.create_user_id; phasePay.curTimes = phasePay.audit_times; phasePay.curOrder = 0; } else if (phasePay.audit_status === audit.status.checkNo) { phasePay.readOnly = accountId !== phasePay.create_user_id; if (!phasePay.readOnly) { phasePay.curTimes = phasePay.times; phasePay.curOrder = 0; } else { const checkNoAudit = await this.service.phasePayAudit.getDataByCondition({ phase_id: phasePay.id, audit_times: phasePay.audit_times - 1, status: audit.status.checkNo, }); phasePay.curTimes = phasePay.times - 1; phasePay.curOrder = checkNoAudit.audit_order; } } else if (phasePay.audit_status === audit.status.checked) { phasePay.readOnly = true; phasePay.curTimes = phasePay.audit_times; phasePay.curOrder = phasePay.audit_max_order; } else { // 会签，会签人部分审批通过时，只读，但是curOrder需按原来的取值 phasePay.curTimes = phasePay.audit_times; phasePay.curOrder = phasePay.flowAuditorIds.indexOf(accountId) < 0 ? phasePay.curAuditors[0].order : phasePay.curAuditors[0].order - 1; phasePay.readOnly = !_.isEqual(stage.flowAuditorIds, stage.curAuditorIds); phasePay.canCheck = phasePay.readOnly && stage.curAuditorIds.indexOf(accountId) > 0; } } async delete(id) { const conn = await this.db.beginTransaction(); try { await conn.delete(this.tableName, { id }); await conn.delete(this.ctx.service.phasePayDetail.tableName, { phase_id: id }); // todo 不确定是否真删除，是否需要防止用户找回附件 ? // await conn.delete(this.ctx.service.phasePayAtt.tableName, { phase_id: id }); await conn.delete(this.ctx.service.phasePayAudit.tableName, { phase_id: id }); } catch (err) { await conn.rollback(); throw err; } } async save(phasePay, data) { await this.defaultUpdate({id: phasePay.id, phase_date: data.phase_date, memo: data.memo}); } } return PhasePay; };